fix: payments publish

formancehq · Aug 29, 2022 · 66646f7 · 66646f7
1 parent 4729bb2
commit 66646f7
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
diff --git a/pkg/bridge/ingestion/ingester.go b/pkg/bridge/ingestion/ingester.go
@@ -212,7 +212,7 @@ func (i *defaultIngester) Ingest(ctx context.Context, batch Batch, commitState a
 			for _, e := range allPayments {
 				i.publish(ctx, TopicPayments,
 					NewEventSavedPayment(
-						SavedPayment(e.Computed())))
+						e.Computed()))
 			}
 		}
 

diff --git a/pkg/bridge/ingestion/message.go b/pkg/bridge/ingestion/message.go
@@ -26,9 +26,7 @@ type EventMessage struct {
 	Payload json.RawMessage `json:"payload"`
 }
 
-type SavedPayment payments.ComputedPayment
-
-func NewEventSavedPayment(payment SavedPayment) EventMessage {
+func NewEventSavedPayment(payment payments.ComputedPayment) EventMessage {
 	payload, err := json.Marshal(payment)
 	if err != nil {
 		panic(err)