mirror of
https://github.com/hanzoai/commerce.git
synced 2026-10-30 15:08:42 +00:00
zeekay
1943f1c093
Multi-tenant commerce and billing: orders, subscriptions, invoices, plans, usage metering and a credit ledger. One Go binary. MIT OR Apache-2.0. Claude-Session: https://claude.ai/code/session_01SAtaDFm8VDiWrhYHNNtxMw
44 lines
1.3 KiB
Go
44 lines
1.3 KiB
Go
package blockchain
|
|
|
|
import (
|
|
"github.com/hanzoai/commerce/datastore"
|
|
"github.com/hanzoai/commerce/log"
|
|
"github.com/hanzoai/commerce/models/order"
|
|
"github.com/hanzoai/commerce/models/user"
|
|
"github.com/hanzoai/commerce/models/wallet"
|
|
)
|
|
|
|
// GetUserOrderByWallet returns the (user, order, wallet) triple associated
|
|
// with walletId. Chain-agnostic — used by Bitcoin pay task in-tree and by
|
|
// the Ethereum pay task in the luxfi/cevm sub-module.
|
|
func GetUserOrderByWallet(db *datastore.Datastore, walletId string) (*user.User, *order.Order, *wallet.Wallet, error) {
|
|
ctx := db.Context
|
|
|
|
w := wallet.New(db)
|
|
if err := w.GetById(walletId); err != nil {
|
|
log.Warn("Could not find Wallet '%s': %v", walletId, err, ctx)
|
|
return nil, nil, nil, err
|
|
}
|
|
|
|
// Check if there's an order with this wallet
|
|
ord := order.New(db)
|
|
if ok, err := ord.Query().Filter("WalletId=", w.Id()).Get(); !ok {
|
|
if err != nil {
|
|
log.Warn("No order found for Wallet '%s': %v", w.Id(), err, ctx)
|
|
return nil, nil, nil, err
|
|
}
|
|
|
|
log.Warn("No order found for Wallet '%s'", w.Id(), ctx)
|
|
return nil, nil, nil, nil
|
|
}
|
|
|
|
// Get user so we can get a buyer
|
|
usr := user.New(db)
|
|
if err := usr.GetById(ord.UserId); err != nil {
|
|
log.Warn("User not found for Order '%s', Wallet '%s'", ord.Id(), w.Id(), ctx)
|
|
return nil, nil, nil, err
|
|
}
|
|
|
|
return usr, ord, w, nil
|
|
}
|