New broadcast notification, use snake case

BuxOrg · May 3, 2022 · 0b2a6f5 · 0b2a6f5
1 parent 5dde67e
commit 0b2a6f5
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 5 deletions.
diff --git a/model_sync_transactions.go b/model_sync_transactions.go
@@ -9,6 +9,7 @@ import (
 
 	"github.com/BuxOrg/bux/chainstate"
 	"github.com/BuxOrg/bux/datastore"
+	"github.com/BuxOrg/bux/notifications"
 	"github.com/BuxOrg/bux/taskmanager"
 	"github.com/BuxOrg/bux/utils"
 	"github.com/tonicpow/go-paymail"
@@ -408,6 +409,9 @@ func processBroadcastTransaction(ctx context.Context, syncTx *SyncTransaction) e
 		return err
 	}
 
+	// Fire a notification
+	notify(notifications.EventTypeBroadcast, syncTx)
+
 	// Notify any P2P paymail providers associated to the transaction
 	if syncTx.P2PStatus == SyncStatusReady {
 		return processP2PTransaction(ctx, syncTx, transaction)

diff --git a/notifications/notifications.go b/notifications/notifications.go
@@ -13,7 +13,7 @@ func (c *Client) GetWebhookEndpoint() string {
 	return c.options.config.webhookEndpoint
 }
 
-// Notify will create a new notification
+// Notify will create a new notification event
 func (c *Client) Notify(ctx context.Context, modelType string, eventType EventType,
 	model interface{}, id string) error {
 
@@ -23,10 +23,10 @@ func (c *Client) Notify(ctx context.Context, modelType string, eventType EventTy
 		}
 	} else {
 		jsonData, err := json.Marshal(map[string]interface{}{
-			"eventType": eventType,
-			"id":        id,
-			"model":     model,
-			"modelType": modelType,
+			"event_type": eventType,
+			"id":         id,
+			"model":      model,
+			"model_type": modelType,
 		})
 		if err != nil {
 			return err