fix: failed to create puller log for none-demo deployment (#2158)

Author: hvn2k1

manifests/bucketeer/charts/subscriber/templates/deployment.yaml

@@ -60,6 +60,8 @@ spec:
               value: "{{ .Values.global.pubsub.project }}"
             - name: BUCKETEER_SUBSCRIBER_PROFILE
               value: "{{.Values.env.profile}}"
+            - name: BUCKETEER_SUBSCRIBER_DEMO_SITE_ENABLED
+              value: "{{.Values.env.demoSiteEnabled}}"
             - name: BUCKETEER_SUBSCRIBER_GCP_TRACE_ENABLED
               value: "{{.Values.env.gcpEnabled}}"
             - name: PUBSUB_EMULATOR_HOST

manifests/bucketeer/charts/subscriber/values.yaml

@@ -8,6 +8,7 @@ fullnameOverride: "subscriber"
 env:
   project:
   profile: true
+  demoSiteEnabled: false
   gcpEnabled: true
   enablePprof: false
   pprofAddr: 127.0.0.1:6060

manifests/bucketeer/values.dev.yaml

@@ -292,6 +292,7 @@ subscriber:
   env:
     project: bucketeer-test
     profile: false
+    demoSiteEnabled: false
     gcpEnabled: false
     enablePprof: false
     pprofAddr: 127.0.0.1:6060

pkg/subscriber/cmd/server/server.go

@@ -58,6 +58,7 @@ type server struct {
 	keyPath          *string
 	serviceTokenPath *string
 	webURL           *string
+	demoSiteEnabled  *bool
 	// MySQL
 	mysqlUser        *string
 	mysqlPass        *string
@@ -98,6 +99,7 @@ func RegisterCommand(r cli.CommandRegistry, p cli.ParentCommand) cli.Command {
 		CmdClause:        cmd,
 		port:             cmd.Flag("port", "Port to bind to.").Default("9090").Int(),
 		project:          cmd.Flag("project", "Google Cloud project name.").String(),
+		demoSiteEnabled:  cmd.Flag("demo-site-enabled", "Enable demo site.").Default("false").Bool(),
 		certPath:         cmd.Flag("cert", "Path to TLS certificate.").Required().String(),
 		keyPath:          cmd.Flag("key", "Path to TLS key.").Required().String(),
 		serviceTokenPath: cmd.Flag("service-token", "Path to service token.").Required().String(),
@@ -556,15 +558,17 @@ func (s *server) registerPubSubProcessorMap(
 			userEventPersister,
 		)
 
-		demoOrganizationCreationNotifier := processor.NewDemoOrganizationCreationNotifier(
-			processorsConfigMap[processor.DemoOrganizationCreationNotifierName],
-			*s.webURL,
-			logger,
-		)
-		processors.RegisterProcessor(
-			processor.DemoOrganizationCreationNotifierName,
-			demoOrganizationCreationNotifier,
-		)
+		if *s.demoSiteEnabled {
+			demoOrganizationCreationNotifier := processor.NewDemoOrganizationCreationNotifier(
+				processorsConfigMap[processor.DemoOrganizationCreationNotifierName],
+				*s.webURL,
+				logger,
+			)
+			processors.RegisterProcessor(
+				processor.DemoOrganizationCreationNotifierName,
+				demoOrganizationCreationNotifier,
+			)
+		}
 
 		redisCache := cachev3.NewRedisCache(persistentRedisClient)
 		evaluationCountEventPersister, err := processor.NewEvaluationCountEventPersister(