Pubsub events (#37)

* ps client

* print

* payload?

* topic name

function.go

@@ -216,6 +216,31 @@ func ProcessTransaction(w http.ResponseWriter, r *http.Request) {
 	}
 
 	wg.Wait()
+
+	// push the message to pubsub
+	type TransactionEvent struct {
+		Account     model.AccountResource
+		Transaction model.TransactionResource
+	}
+
+	data, _ := json.Marshal(TransactionEvent{
+		Account:     account,
+		Transaction: transaction,
+	})
+
+	client := integrations.GetClient()
+	topic := client.Topic("transactions")
+	res := topic.Publish(context.Background(), &pubsub.Message{
+		ID:   uuid.NewString(),
+		Data: data,
+	})
+	id, err := res.Get(context.Background())
+	if err != nil {
+		fmt.Println("error publishing message:", err)
+	} else {
+		fmt.Println("new published message:", id)
+	}
+
 	return
 }
 

internal/service/webhook.go

@@ -29,7 +29,6 @@ func formatCurrency(value string, iso string) string {
 }
 
 func SendWebhookEvent(uri string, account model.AccountResource, transaction model.TransactionResource) error {
-
 	_, err := url.Parse(uri)
 	if err != nil {
 		return err