feat: Adds subscriptions for review creation and acceptance

mensatt · Aug 6, 2023 · 14f3087 · 14f3087
1 parent 5772568
commit 14f3087
Show file tree

Hide file tree

Showing 6 changed files with 336 additions and 11 deletions.
diff --git a/internal/graphql/gqlserver/generated.go b/internal/graphql/gqlserver/generated.go
diff --git a/internal/graphql/graphql.go b/internal/graphql/graphql.go
@@ -49,11 +49,13 @@ func graphqlHandler(params *GraphQLParams) gin.HandlerFunc {
 		gqlserver.NewExecutableSchema(
 			gqlserver.Config{
 				Resolvers: &resolvers.Resolver{
-					Database:      params.Database,
-					JWTKeyStore:   params.JWTKeyStore,
-					VCSBuildInfo:  vscBuildInfo,
-					ImageUploader: params.ImageUploader,
-					ImageBaseURL:  params.ImageBaseURL,
+					Database:               params.Database,
+					JWTKeyStore:            params.JWTKeyStore,
+					VCSBuildInfo:           vscBuildInfo,
+					ImageUploader:          params.ImageUploader,
+					ImageBaseURL:           params.ImageBaseURL,
+					ReviewAcceptedChannels: map[string]chan *ent.Review{},
+					ReviewCreatedChannels:  map[string]chan *ent.Review{},
 				},
 				Directives: gqlserver.DirectiveRoot{
 					Authenticated: directives.Authenticated,

diff --git a/internal/graphql/resolvers/mutations.resolvers.go b/internal/graphql/resolvers/mutations.resolvers.go
diff --git a/internal/graphql/resolvers/resolver.go b/internal/graphql/resolvers/resolver.go
@@ -4,16 +4,20 @@ import (
 	ent "github.com/mensatt/backend/internal/database/ent"
 	"github.com/mensatt/backend/pkg/imageuploader"
 	"github.com/mensatt/backend/pkg/utils"
+	"sync"
 )
 
 // This file will not be regenerated automatically.
 //
 // It serves as dependency injection for your app, add any dependencies you require here.
 
 type Resolver struct {
-	Database      *ent.Client
-	JWTKeyStore   *utils.JWTKeyStore
-	VCSBuildInfo  *utils.VCSBuildInfo
-	ImageUploader *imageuploader.ImageUploader
-	ImageBaseURL  string
+	Database               *ent.Client
+	JWTKeyStore            *utils.JWTKeyStore
+	VCSBuildInfo           *utils.VCSBuildInfo
+	ImageUploader          *imageuploader.ImageUploader
+	ImageBaseURL           string
+	ReviewCreatedChannels  map[string]chan *ent.Review
+	ReviewAcceptedChannels map[string]chan *ent.Review
+	mutex                  sync.Mutex
 }