tech/sendico
2
0
Fork 0
Code Issues 31 Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Merge pull request 'extended logging' (#452) from mntx-452 into main
All checks were successful
ci/woodpecker/push/gateway_mntx Pipeline was successful
Details

Browse Source 
Reviewed-on: #452
This commit was merged in pull request #452.
This commit is contained in:
tech
2026-02-10 10:14:24 +00:00
parent 9463c7ce1f 3578ddd54f
commit 5e92d7b9ff
2 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
api/gateway/mntx/internal/service/gateway/transfer_notifications.go
View File

@@ -38,7 +38,9 @@ func toOpStatus(t *model.CardPayout) rail.OperationResult {
func (p *cardPayoutProcessor) updatePayoutStatus(ctx context.Context, state *model.CardPayout) error { func (p *cardPayoutProcessor) updatePayoutStatus(ctx context.Context, state *model.CardPayout) error {
if err := p.store.Payouts().Upsert(ctx, state); err != nil { if err := p.store.Payouts().Upsert(ctx, state); err != nil {
p.logger.Warn("Failed to update transfer status", zap.String("transfer_ref", state.PayoutID), zap.String("status", string(state.Status)), zap.Error(err)) p.logger.Warn("Failed to update transfer status", zap.Error(err), mzap.ObjRef("payout_ref", state.ID),
zap.String("transfer_ref", state.PayoutID), zap.String("status", string(state.Status)),
)
} }
if isFinalStatus(state) { if isFinalStatus(state) {
p.emitTransferStatusEvent(state) p.emitTransferStatusEvent(state)

2
api/gateway/mntx/storage/mongo/store/payouts.go
View File

@@ -69,6 +69,7 @@ func (p *Payouts) FindByPaymentID(ctx context.Context, paymentID string) (*model
func (p *Payouts) Upsert(ctx context.Context, record *model.CardPayout) error { func (p *Payouts) Upsert(ctx context.Context, record *model.CardPayout) error {
if record == nil { if record == nil {
p.logger.Warn("Invalid argument provided: nil record")
return merrors.InvalidArgument("payout record is nil", "record") return merrors.InvalidArgument("payout record is nil", "record")
} }
@@ -79,6 +80,7 @@ func (p *Payouts) Upsert(ctx context.Context, record *model.CardPayout) error {
record.ProviderPaymentID = strings.TrimSpace(record.ProviderPaymentID) record.ProviderPaymentID = strings.TrimSpace(record.ProviderPaymentID)
if record.OperationRef == "" { if record.OperationRef == "" {
p.logger.Warn("Invalid argument provided: operation reference missing")
return merrors.InvalidArgument("operation ref is required", "operation_ref") return merrors.InvalidArgument("operation ref is required", "operation_ref")
} }