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

fixed balance fetch

Browse Source
This commit is contained in:
Stephan D
2026-02-05 12:39:06 +01:00
parent 0675978bd1
commit 6e3115e7fa
2 changed files with 11 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
api/payments/orchestrator/storage/mongo/store/payments.go
View File

@@ -200,12 +200,11 @@ func (p *Payments) List(ctx context.Context, filter *model.PaymentFilter) (*mode
query = query.And(endpointFilter)
}
}
if ref := strings.TrimSpace(filter.OrganizationRef); ref != "" {
orgRef, err := bson.ObjectIDFromHex(ref)
if err != nil {
p.logger.Warn("Failed to decode organization reference", zap.Error(err), zap.String("provided_org_ref", ref))
return nil, err
}
if orgRef, err := bson.ObjectIDFromHex(strings.TrimSpace(filter.OrganizationRef)); err != nil {
p.logger.Warn("Failed to decode organization reference", zap.Error(err),
zap.String("provided_org_ref", filter.OrganizationRef))
return nil, err
} else {
query.And(repository.OrgFilter(orgRef))
}
@@ -231,7 +230,7 @@ func (p *Payments) List(ctx context.Context, filter *model.PaymentFilter) (*mode
decoder := func(cur *mongo.Cursor) error {
item := &model.Payment{}
if err := cur.Decode(item); err != nil {
p.logger.Warn("Failed to decode item", zap.Error(err), zap.Any("item", cur.Current))
p.logger.Warn("Failed to decode item", zap.Error(err))
return err
}
payments = append(payments, item)