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

Merge pull request 'fixed upsert' (#435) from mntx-433 into main
All checks were successful
ci/woodpecker/push/gateway_mntx Pipeline was successful
Details

Browse Source 
Reviewed-on: #435
This commit was merged in pull request #435.
This commit is contained in:
tech
2026-02-05 15:35:10 +00:00
parent 67598449e6 bc50391fe7
commit 5984f2c2f7
2 changed files with 11 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
api/gateway/mntx/internal/service/gateway/card_processor.go
View File

@@ -11,10 +11,12 @@ import (
"github.com/tech/sendico/gateway/mntx/storage"
"github.com/tech/sendico/gateway/mntx/storage/model"
clockpkg "github.com/tech/sendico/pkg/clock"
"github.com/tech/sendico/pkg/db/storable"
"github.com/tech/sendico/pkg/merrors"
msg "github.com/tech/sendico/pkg/messaging"
"github.com/tech/sendico/pkg/mlogger"
mntxv1 "github.com/tech/sendico/pkg/proto/gateway/mntx/v1"
"go.mongodb.org/mongo-driver/v2/bson"
"go.uber.org/zap"
)
@@ -87,6 +89,9 @@ func (p *cardPayoutProcessor) Submit(ctx context.Context, req *mntxv1.CardPayout
now := p.clock.Now()
state := &model.CardPayout{
Base: storable.Base{
ID: bson.NilObjectID,
},
PayoutID: strings.TrimSpace(req.GetPayoutId()),
OperationRef: strings.TrimSpace(req.GetOperationRef()),
IdempotencyKey: strings.TrimSpace(req.GetIdempotencyKey()),

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

@@ -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"
"go.mongodb.org/mongo-driver/v2/bson"
"go.mongodb.org/mongo-driver/v2/mongo"
"go.uber.org/zap"
)
@@ -81,7 +82,11 @@ func (p *Payouts) Upsert(ctx context.Context, record *model.CardPayout) error {
return merrors.InvalidArgument("operation ref is required", "operation_ref")
}
return p.repository.Insert(ctx, record, repository.Filter(payoutIdemField, record.IdempotencyKey))
if record.ID == bson.NilObjectID {
return p.repository.Insert(ctx, record, nil)
}
return p.repository.Update(ctx, record)
}
var _ storage.PayoutsStore = (*Payouts)(nil)