unboundsoftware/schemas
6
0
Fork 0
Code Issues 1 Pull Requests 2 Actions Packages Projects Releases 32 Activity

style: apply gofumpt formatting (#828)
schemas / vulnerabilities (push) Successful in 2m8s
Details
schemas / check (push) Successful in 2m39s
Details
Release / release (push) Successful in 55s
Details
schemas / check-release (push) Successful in 2m56s
Details
pre-commit / pre-commit (push) Successful in 7m18s
Details
schemas / build (push) Successful in 8m0s
Details
schemas / deploy-prod (push) Successful in 1m11s
Details

Browse Source
This commit was merged in pull request #828.
This commit is contained in:
Joakim Olsson
2026-05-05 09:22:48 +00:00
parent 2c981fc21d
commit be9a64a41b
3 changed files with 22 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
graph/schema.resolvers.go
+18 -9
View File
@@ -178,7 +178,8 @@ func (r *mutationResolver) UpdateSubGraph(ctx context.Context, input model.Input
// same org+ref only trigger one config generation.
r.Debouncer.Debounce(orgId+":"+input.Ref, func() {
services, lastUpdate := r.Cache.Services(orgId, input.Ref, "")
r.Logger.Info("Publishing schema update after subgraph change",
r.Logger.Info(
"Publishing schema update after subgraph change",
"ref", input.Ref,
"orgId", orgId,
"lastUpdate", lastUpdate,
@@ -210,7 +211,8 @@ func (r *mutationResolver) UpdateSubGraph(ctx context.Context, input model.Input
CosmoRouterConfig: &cosmoConfig,
}
r.Logger.Info("Publishing schema update to subscribers",
r.Logger.Info(
"Publishing schema update to subscribers",
"ref", update.Ref,
"id", update.ID,
"subGraphsCount", len(update.SubGraphs),
@@ -246,7 +248,8 @@ func (r *queryResolver) Supergraph(ctx context.Context, ref string, isAfter *str
orgId := middleware.OrganizationFromContext(ctx)
userId := middleware.UserFromContext(ctx)
r.Logger.Info("Supergraph query",
r.Logger.Info(
"Supergraph query",
"ref", ref,
"orgId", orgId,
"userId", userId,
@@ -312,7 +315,8 @@ func (r *queryResolver) LatestSchema(ctx context.Context, ref string) (*model.Sc
orgId := middleware.OrganizationFromContext(ctx)
userId := middleware.UserFromContext(ctx)
r.Logger.Info("LatestSchema query",
r.Logger.Info(
"LatestSchema query",
"ref", ref,
"orgId", orgId,
"userId", userId,
@@ -342,7 +346,8 @@ func (r *queryResolver) LatestSchema(ctx context.Context, ref string) (*model.Sc
// Get current services and schema
services, lastUpdate := r.Cache.Services(orgId, ref, "")
r.Logger.Info("Fetching latest schema",
r.Logger.Info(
"Fetching latest schema",
"ref", ref,
"orgId", orgId,
"lastUpdate", lastUpdate,
@@ -381,7 +386,8 @@ func (r *queryResolver) LatestSchema(ctx context.Context, ref string) (*model.Sc
CosmoRouterConfig: &cosmoConfig,
}
r.Logger.Info("Latest schema fetched",
r.Logger.Info(
"Latest schema fetched",
"ref", update.Ref,
"id", update.ID,
"subGraphsCount", len(update.SubGraphs),
@@ -395,7 +401,8 @@ func (r *queryResolver) LatestSchema(ctx context.Context, ref string) (*model.Sc
func (r *subscriptionResolver) SchemaUpdates(ctx context.Context, ref string) (<-chan *model.SchemaUpdate, error) {
orgId := middleware.OrganizationFromContext(ctx)
r.Logger.Info("SchemaUpdates subscription started",
r.Logger.Info(
"SchemaUpdates subscription started",
"ref", ref,
"orgId", orgId,
)
@@ -412,7 +419,8 @@ func (r *subscriptionResolver) SchemaUpdates(ctx context.Context, ref string) (<
// Send initial state immediately
go func() {
services, lastUpdate := r.Cache.Services(orgId, ref, "")
r.Logger.Info("Preparing initial schema update",
r.Logger.Info(
"Preparing initial schema update",
"ref", ref,
"orgId", orgId,
"lastUpdate", lastUpdate,
@@ -444,7 +452,8 @@ func (r *subscriptionResolver) SchemaUpdates(ctx context.Context, ref string) (<
CosmoRouterConfig: &cosmoConfig,
}
r.Logger.Info("Sending initial schema update",
r.Logger.Info(
"Sending initial schema update",
"ref", update.Ref,
"id", update.ID,
"subGraphsCount", len(update.SubGraphs),