|
|
|
@@ -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),
|
|
|
|
|