From f59789ab7a4f3bf27e0c94efcbf89e4cd4b3e34a Mon Sep 17 00:00:00 2001 From: Stephan D Date: Tue, 10 Feb 2026 11:24:45 +0100 Subject: [PATCH] extended logging --- api/gateway/mntx/storage/mongo/store/payouts.go | 14 ++++++++++++-- 1 file changed, 12 insertions(+), 2 deletions(-) diff --git a/api/gateway/mntx/storage/mongo/store/payouts.go b/api/gateway/mntx/storage/mongo/store/payouts.go index c54b823f..a2f1b862 100644 --- a/api/gateway/mntx/storage/mongo/store/payouts.go +++ b/api/gateway/mntx/storage/mongo/store/payouts.go @@ -10,6 +10,7 @@ import ( ri "github.com/tech/sendico/pkg/db/repository/index" "github.com/tech/sendico/pkg/merrors" "github.com/tech/sendico/pkg/mlogger" + "github.com/tech/sendico/pkg/mutil/mzap" "go.mongodb.org/mongo-driver/v2/bson" "go.mongodb.org/mongo-driver/v2/mongo" "go.uber.org/zap" @@ -85,10 +86,19 @@ func (p *Payouts) Upsert(ctx context.Context, record *model.CardPayout) error { } if record.ID == bson.NilObjectID { - return p.repository.Insert(ctx, record, nil) + if err := p.repository.Insert(ctx, record, nil); err != nil { + p.logger.Warn("Failed to insert new record", zap.Error(err), zap.String("operation_Ref", record.OperationRef)) + return err + } + return nil } - return p.repository.Update(ctx, record) + if err := p.repository.Update(ctx, record); err != nil { + p.logger.Warn("Failed to update existing record", zap.Error(err), + zap.String("operation_Ref", record.OperationRef), mzap.ObjRef("payout_ref", record.ID)) + return err + } + return nil } var _ storage.PayoutsStore = (*Payouts)(nil) -- 2.49.1