feat: publish the change stream to pubsub

ucpr · Dec 16, 2023 · 531b1ea · 531b1ea
1 parent d3321e0
commit 531b1ea
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 0 deletions.
diff --git a/cmd/handler.go b/cmd/handler.go
@@ -20,5 +20,13 @@ func NewEventHandler(ps pubsub.Publisher) *EventHandler {
 
 func (e *EventHandler) EventHandler(ctx context.Context, event []byte) error {
 	log.Info("event", slog.String("event", string(event)))
+	res := e.pubsub.AsyncPublish(ctx, pubsub.Message{
+		Data: event,
+	})
+	id, err := res.Get(ctx)
+	if err != nil {
+		return err
+	}
+	log.Info("successful publish event", slog.String("id", id))
 	return nil
 }
diff --git a/docker-compose.yaml b/docker-compose.yaml
@@ -39,6 +39,15 @@ services:
       - "8085:8085"
     entrypoint: /bin/bash
 
+  pubsub-init:
+    image: gcr.io/google.com/cloudsdktool/cloud-sdk:455.0.0-emulators
+    depends_on:
+      - pubsub-emulator
+    environment:
+      PUBSUB_EMULATOR_HOST: "pubsub-emulator:8085"
+    command: |
+      gcloud config configurations create emulator && gcloud config set project dummy-project && gcloud config set auth/disable_credentials true && gcloud pubsub topics create dummy-topic && echo "finish setup pubsub"
+
   mongo-streamer:
     build: .
     restart: always