Function convertStoreToV1DatabaseGroup

backend/api/v1/database_group_service.go:301–323

(
	ctx context.Context,
	databaseGroup *store.DatabaseGroupMessage,
	projectResourceID string,
	databases []*store.DatabaseMessage,
)

}

func convertStoreToV1DatabaseGroup(
	ctx context.Context,
	databaseGroup *store.DatabaseGroupMessage,
	projectResourceID string,
	databases []*store.DatabaseMessage,
) (*v1pb.DatabaseGroup, error) {
	ret := &v1pb.DatabaseGroup{
		Name:         fmt.Sprintf("%s/%s%s", common.FormatProject(projectResourceID), common.DatabaseGroupNamePrefix, databaseGroup.ResourceID),
		Title:        databaseGroup.Title,
		DatabaseExpr: databaseGroup.Expression,
	}

	matches, err := utils.GetMatchedDatabasesInDatabaseGroup(ctx, databaseGroup, databases)
	if err != nil {
		return nil, connect.NewError(connect.CodeInternal, errors.Errorf("failed to get matched databases for group %v with error: %v", ret.Name, err.Error()))
	}
	for _, database := range matches {
		ret.MatchedDatabases = append(ret.MatchedDatabases, &v1pb.DatabaseGroup_Database{
			Name: common.FormatDatabase(database.InstanceID, database.DatabaseName),
		})
	}
	return ret, nil
}