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

tgsettle status optimization, + build optimization

Browse Source
This commit is contained in:
Stephan D
2026-02-04 10:54:45 +01:00
parent f1f16a30e6
commit f02f28d53f
15 changed files with 100 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -253,6 +253,10 @@ func (s *Service) onIntent(ctx context.Context, intent *model.PaymentGatewayInte
s.logger.Warn("Payment gateway intent rejected", zap.String("reason", "requested_money is required"), zap.String("idempotency_key", intent.IdempotencyKey))
return merrors.InvalidArgument("requested_money is required", "requested_money")
}
if intent.OperationRef == "" {
s.logger.Warn("Payment gateway intent rejected", zap.String("reason", "operation_ref is required"))
return merrors.InvalidArgument("operation_ref is required", "operation_ref")
}
if s.repo == nil || s.repo.Payments() == nil {
s.logger.Warn("Payment gateway storage unavailable", zap.String("idempotency_key", intent.IdempotencyKey))
return merrors.Internal("payment gateway storage unavailable")
@@ -274,7 +278,9 @@ func (s *Service) onIntent(ctx context.Context, intent *model.PaymentGatewayInte
zap.String("payment_intent_id", confirmReq.PaymentIntentID),
zap.String("quote_ref", confirmReq.QuoteRef),
zap.String("rail", confirmReq.Rail),
zap.String("status", string(existing.Status)))
zap.String("status", string(existing.Status)),
zap.String("operation_ref", confirmReq.OperationRef),
)
return nil
}
@@ -609,6 +615,10 @@ func intentFromSubmitTransfer(req *chainv1.SubmitTransferRequest, defaultRail, d
if paymentRef == "" {
return nil, merrors.InvalidArgument("submit_transfer: payment_ref is required")
}
operationRef := strings.TrimSpace(req.OperationRef)
if operationRef == "" {
return nil, merrors.InvalidArgument("submit_transfer: operation_ref is required")
}
quoteRef := strings.TrimSpace(metadata[metadataQuoteRef])
targetChatID := strings.TrimSpace(metadata[metadataTargetChatID])
outgoingLeg := strings.TrimSpace(metadata[metadataOutgoingLeg])
@@ -626,6 +636,7 @@ func intentFromSubmitTransfer(req *chainv1.SubmitTransferRequest, defaultRail, d
QuoteRef: quoteRef,
RequestedMoney: requestedMoney,
IntentRef: intentRef,
OperationRef: operationRef,
}, nil
}