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

fixed message status update
Some checks failed
ci/woodpecker/push/gateway_tgsettle Pipeline failed
Details

Browse Source
This commit is contained in:
Stephan D
2026-02-27 13:51:08 +01:00
parent 57428c5c56
commit 651f103abd
2 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
api/gateway/tgsettle/internal/service/gateway/service.go
View File

@@ -533,6 +533,7 @@ func (s *Service) startAnnouncer() {
caps := discovery.ProviderSettlementRailGatewayOperations() caps := discovery.ProviderSettlementRailGatewayOperations()
announce := discovery.Announcement{ announce := discovery.Announcement{
ID: discovery.StablePaymentGatewayID(rail), ID: discovery.StablePaymentGatewayID(rail),
InstanceID: discovery.InstanceID(),
Service: string(mservice.PaymentGateway), Service: string(mservice.PaymentGateway),
Rail: rail, Rail: rail,
Operations: caps, Operations: caps,

6
api/gateway/tgsettle/storage/mongo/store/pending_confirmations.go
View File

@@ -159,8 +159,7 @@ func (p *PendingConfirmations) MarkClarified(ctx context.Context, requestID stri
return merrors.InvalidArgument("request_id is required", "request_id") return merrors.InvalidArgument("request_id is required", "request_id")
} }
patch := repository.Patch(). patch := repository.Patch().
Set(repository.Field("clarified"), true). Set(repository.Field("clarified"), true)
Set(repository.Field("updatedAt"), time.Now())
_, err := p.repo.PatchMany(ctx, repository.Filter(fieldPendingRequestID, requestID), patch) _, err := p.repo.PatchMany(ctx, repository.Filter(fieldPendingRequestID, requestID), patch)
return err return err
} }
@@ -183,8 +182,7 @@ func (p *PendingConfirmations) AttachMessage(ctx context.Context, requestID stri
), ),
) )
patch := repository.Patch(). patch := repository.Patch().
Set(repository.Field(fieldPendingMessageID), messageID). Set(repository.Field(fieldPendingMessageID), messageID)
Set(repository.Field("updatedAt"), time.Now())
updated, err := p.repo.PatchMany(ctx, filter, patch) updated, err := p.repo.PatchMany(ctx, filter, patch)
if err != nil { if err != nil {
return err return err