fix: clean up database metadata

we're still not extracting database calls in either runtime, but this fixes the metadata type

backend/protos/xyz/block/ftl/v1/schema/schema.proto

@@ -138,7 +138,7 @@ message MetadataCalls {
 
 message MetadataDatabases {
   optional Position pos = 1;
-  repeated Database calls = 2;
+  repeated Ref calls = 2;
 }
 
 message MetadataIngress {

backend/schema/database.go

@@ -47,11 +47,3 @@ func DatabaseFromProto(s *schemapb.Database) *Database {
 		Comments: s.Comments,
 	}
 }
-
-func databaseListToSchema(s []*schemapb.Database) []*Database {
-	var out []*Database
-	for _, n := range s {
-		out = append(out, DatabaseFromProto(n))
-	}
-	return out
-}

backend/schema/metadatadatabases.go

@@ -12,7 +12,7 @@ import (
 type MetadataDatabases struct {
 	Pos Position `parser:"" protobuf:"1,optional"`
 
-	Calls []*Database `parser:"'+' 'database' 'calls' @@ (',' @@)*" protobuf:"2"`
+	Calls []*Ref `parser:"'+' 'database' 'calls' @@ (',' @@)*" protobuf:"2"`
 }
 
 var _ Metadata = (*MetadataDatabases)(nil)
@@ -35,7 +35,7 @@ func (m *MetadataDatabases) String() string {
 		w += len(str)
 		fmt.Fprint(out, str)
 	}
-	fmt.Fprintln(out)
+	fmt.Fprint(out)
 	return out.String()
 }
 
@@ -51,6 +51,6 @@ func (*MetadataDatabases) schemaMetadata() {}
 func (m *MetadataDatabases) ToProto() proto.Message {
 	return &schemapb.MetadataDatabases{
 		Pos:   posToProto(m.Pos),
-		Calls: nodeListToProto[*schemapb.Database](m.Calls),
+		Calls: nodeListToProto[*schemapb.Ref](m.Calls),
 	}
 }

backend/schema/protobuf_dec.go

@@ -103,7 +103,7 @@ func metadataToSchema(s *schemapb.Metadata) Metadata {
 	case *schemapb.Metadata_Databases:
 		return &MetadataDatabases{
 			Pos:   posFromProto(s.Databases.Pos),
-			Calls: databaseListToSchema(s.Databases.Calls),
+			Calls: refListToSchema(s.Databases.Calls),
 		}
 
 	case *schemapb.Metadata_Ingress:

backend/schema/schema_test.go

@@ -21,6 +21,10 @@ func TestSchemaString(t *testing.T) {
 module todo {
   config configValue String
 
+  secret secretValue String
+
+  database testdb
+
   data CreateRequest {
     name {String: String}? +alias json "rqn"
   }
@@ -39,10 +43,8 @@ module todo {
     when Time
   }
 
-  secret secretValue String
-
   verb create(todo.CreateRequest) todo.CreateResponse
-      +calls todo.destroy
+      +calls todo.destroy  +database calls todo.testdb 
 
   verb destroy(builtin.HttpRequest<todo.DestroyRequest>) builtin.HttpResponse<todo.DestroyResponse, String>
       +ingress http GET /todo/destroy/{id}
@@ -95,6 +97,9 @@ func TestVisit(t *testing.T) {
 Module
   Config
     String
+  Secret
+    String
+  Database
   Data
     Field
       Optional
@@ -115,13 +120,13 @@ Module
       String
     Field
       Time
-  Secret
-    String
   Verb
     Ref
     Ref
     MetadataCalls
       Ref
+    MetadataDatabases
+      Ref
   Verb
     Ref
       Ref
@@ -365,6 +370,7 @@ func TestParseModule(t *testing.T) {
 module todo {
   config configValue String
   secret secretValue String
+  database testdb
 
   data CreateRequest {
     name {String: String}? +alias json "rqn"
@@ -381,7 +387,7 @@ module todo {
 	when Time
   }
   verb create(todo.CreateRequest) todo.CreateResponse
-  	+calls todo.destroy
+  	+calls todo.destroy +database calls todo.testdb
   verb destroy(builtin.HttpRequest<todo.DestroyRequest>) builtin.HttpResponse<todo.DestroyResponse, String>
   	+ingress http GET /todo/destroy/{id}
 }
@@ -429,6 +435,9 @@ var testSchema = MustValidate(&Schema{
 					Name: "configValue",
 					Type: &String{},
 				},
+				&Database{
+					Name: "testdb",
+				},
 				&Data{
 					Name: "CreateRequest",
 					Fields: []*Field{
@@ -457,7 +466,10 @@ var testSchema = MustValidate(&Schema{
 				&Verb{Name: "create",
 					Request:  &Ref{Module: "todo", Name: "CreateRequest"},
 					Response: &Ref{Module: "todo", Name: "CreateResponse"},
-					Metadata: []Metadata{&MetadataCalls{Calls: []*Ref{{Module: "todo", Name: "destroy"}}}}},
+					Metadata: []Metadata{
+						&MetadataCalls{Calls: []*Ref{{Module: "todo", Name: "destroy"}}},
+						&MetadataDatabases{Calls: []*Ref{{Module: "todo", Name: "testdb"}}},
+					}},
 				&Verb{Name: "destroy",
 					Request:  &Ref{Module: "builtin", Name: "HttpRequest", TypeParameters: []Type{&Ref{Module: "todo", Name: "DestroyRequest"}}},
 					Response: &Ref{Module: "builtin", Name: "HttpResponse", TypeParameters: []Type{&Ref{Module: "todo", Name: "DestroyResponse"}, &String{}}},

backend/schema/validate.go

@@ -101,7 +101,7 @@ func Validate(schema *Schema) (*Schema, error) {
 			case *Ref:
 				if mdecl := scopes.Resolve(*n); mdecl != nil {
 					switch decl := mdecl.Symbol.(type) {
-					case *Verb, *Enum:
+					case *Verb, *Enum, *Database, *Config, *Secret:
 						if mdecl.Module != nil {
 							n.Module = mdecl.Module.Name
 						}
@@ -121,7 +121,6 @@ func Validate(schema *Schema) (*Schema, error) {
 					case *TypeParameter:
 					default:
 						merr = append(merr, fmt.Errorf("%s: invalid reference %q at %q", n.Pos, n, mdecl.Symbol.Position()))
-
 					}
 				} else {
 					merr = append(merr, fmt.Errorf("%s: unknown reference %q", n.Pos, n))
@@ -209,8 +208,10 @@ func ValidateModule(module *Module) error {
 		case *Ref:
 			if mdecl := scopes.Resolve(*n); mdecl != nil {
 				switch decl := mdecl.Symbol.(type) {
-				case *Verb, *Enum:
-					n.Module = mdecl.Module.Name
+				case *Verb, *Enum, *Database, *Config, *Secret:
+					if n.Module == "" {
+						n.Module = mdecl.Module.Name
+					}
 					if len(n.TypeParameters) != 0 {
 						merr = append(merr, fmt.Errorf("%s: reference to %s %q cannot have type parameters",
 							n.Pos, reflect.TypeOf(decl).Elem().Name(), n.Name))
@@ -224,7 +225,6 @@ func ValidateModule(module *Module) error {
 							n.Pos, n.Name, len(n.TypeParameters), len(decl.TypeParameters)))
 					}
 				case *TypeParameter:
-
 				default:
 					if n.Module == "" {
 						merr = append(merr, fmt.Errorf("%s: unqualified reference to invalid %s %q", n.Pos, reflect.TypeOf(decl).Elem().Name(), n))
@@ -293,16 +293,37 @@ func ValidateModule(module *Module) error {
 	sort.SliceStable(module.Decls, func(i, j int) bool {
 		iDecl := module.Decls[i]
 		jDecl := module.Decls[j]
-		iType := reflect.TypeOf(iDecl).String()
-		jType := reflect.TypeOf(jDecl).String()
-		if iType == jType {
+		iPriority := getDeclSortingPriority(iDecl)
+		jPriority := getDeclSortingPriority(jDecl)
+		if iPriority == jPriority {
 			return iDecl.GetName() < jDecl.GetName()
 		}
-		return iType < jType
+		return iPriority < jPriority
 	})
 	return errors.Join(merr...)
 }
 
+// getDeclSortingPriority (used for schema sorting) is pulled out into it's own switch so the Go sumtype check will fail
+// if a new Decl is added but not explicitly prioritized
+func getDeclSortingPriority(decl Decl) int {
+	priority := 0
+	switch decl.(type) {
+	case *Config:
+		priority = 1
+	case *Secret:
+		priority = 2
+	case *Database:
+		priority = 3
+	case *Enum:
+		priority = 4
+	case *Data:
+		priority = 5
+	case *Verb:
+		priority = 6
+	}
+	return priority
+}
+
 // Sort and de-duplicate errors.
 func cleanErrors(merr []error) []error {
 	if len(merr) == 0 {