argoyle
80daed081d
Creates a new `GenerateCosmoRouterConfig` function to build and serialize a Cosmo Router configuration from subgraphs. Implements PubSub mechanism for managing schema updates, allowing subscription to updates. Adds Subscription resolver and updates existing structures to accommodate new functionalities. This enhances the system's capabilities for dynamic updates and configuration management.
61 lines
1.7 KiB
Go
61 lines
1.7 KiB
Go
package graph
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"log/slog"
|
|
|
|
"gitlab.com/unboundsoftware/eventsourced/eventsourced"
|
|
|
|
"gitlab.com/unboundsoftware/schemas/cache"
|
|
"gitlab.com/unboundsoftware/schemas/middleware"
|
|
)
|
|
|
|
//go:generate go run github.com/99designs/gqlgen
|
|
//go:generate gofumpt -w .
|
|
//go:generate goimports -w -local gitlab.com/unboundsoftware/schemas .
|
|
|
|
// This file will not be regenerated automatically.
|
|
//
|
|
// It serves as dependency injection for your app, add any dependencies you require here.
|
|
|
|
type Publisher interface {
|
|
Publish(ctx context.Context, event eventsourced.Event) error
|
|
}
|
|
|
|
type Resolver struct {
|
|
EventStore eventsourced.EventStore
|
|
Publisher Publisher
|
|
Logger *slog.Logger
|
|
Cache *cache.Cache
|
|
PubSub *PubSub
|
|
}
|
|
|
|
func (r *Resolver) apiKeyCanAccessRef(ctx context.Context, ref string, publish bool) (string, error) {
|
|
key, err := middleware.ApiKeyFromContext(ctx)
|
|
if err != nil {
|
|
return "", err
|
|
}
|
|
apiKey := r.Cache.ApiKeyByKey(key)
|
|
if publish && !apiKey.Publish {
|
|
return "", fmt.Errorf("provided API-key doesn't have publish privilege")
|
|
}
|
|
if !publish && !apiKey.Read {
|
|
return "", fmt.Errorf("provided API-key doesn't have read privilege")
|
|
}
|
|
for _, rr := range apiKey.Refs {
|
|
if rr == ref {
|
|
return apiKey.Name, nil
|
|
}
|
|
}
|
|
return "", fmt.Errorf("provided API-key doesn't have the required privilege on the requested Schema Ref")
|
|
}
|
|
|
|
func (r *Resolver) handler(ctx context.Context, aggregate eventsourced.Aggregate) (eventsourced.CommandHandler, error) {
|
|
return eventsourced.NewHandler(ctx, aggregate, r.EventStore, eventsourced.WithEventPublisher(r.Publisher))
|
|
}
|
|
|
|
func apiKeyId(orgId, name string) string {
|
|
return fmt.Sprintf("%s-%s", orgId, name)
|
|
}
|