mirror of
https://github.com/hanzo-fi/payments.git
synced 2026-10-30 20:31:20 +00:00
zeekay
7d727874d5
- go.mod module path + all self-imports: github.com/formancehq/payments -> github.com/hanzo-fi/payments (1590 .go files / 3152 refs; 20 modules: root, pkg/client, pkg/domain, 18 ce/plugins). External dep kept: formancehq/go-libs. - plugins: each ce/plugins/* consumed a *published* pkg/domain; added local 'replace .../pkg/domain => ../../../pkg/domain' (consistent with root) so every standalone plugin module builds in-monorepo. compile-plugin.sh MOD var rebranded too. - branding: README, LICENSE (dual MIT+EE; upstream copyright retained + Hanzo added), goreleaser (release images -> registry.hanzo.ai/hanzo-fi, OCI labels, homepage), proto go_package, renovate, speakeasy gen.yaml, connector-template *.gotpl. - CI: removed Numary/Formance workflows + composite action; added canonical hanzo.yml + cicd.yml (hanzoai/ci, gated HANZO_CI_ENABLED) + secretless ci.yml (go build/vet). - kept as data/compat keys: wire capability enums ALLOW_FORMANCE_*, generated SDK type client.Formance, domain field FormanceRedirectURL, OTEL_SERVICE_NAME, upstream base image. - verified: go build ./... (default + -tags ee) + all 20 nested modules green.
131 lines
4.2 KiB
Go
131 lines
4.2 KiB
Go
package mappers
|
|
|
|
import (
|
|
"encoding/json"
|
|
"testing"
|
|
|
|
"github.com/hanzo-fi/payments/ee/plugins/bitstamp/client"
|
|
)
|
|
|
|
func TestPaymentMetadata(t *testing.T) {
|
|
t.Parallel()
|
|
tx := client.UserTransaction{
|
|
Type: TxTypeWithdrawal,
|
|
Fee: "0.005",
|
|
OrderID: json.Number("0"),
|
|
}
|
|
got := PaymentMetadata(tx)
|
|
if got[MetadataKeyType] != TxTypeWithdrawal {
|
|
t.Errorf("missing type: %v", got)
|
|
}
|
|
if got[MetadataKeySource] != PaymentSourceUserTransactions {
|
|
t.Errorf("user_transactions metadata must carry source=user_transactions, got %q", got[MetadataKeySource])
|
|
}
|
|
if got[MetadataKeyFee] != "0.005" {
|
|
t.Errorf("missing fee: %v", got)
|
|
}
|
|
if _, ok := got[MetadataKeyOrderID]; ok {
|
|
t.Errorf("order_id 0 should not surface: %v", got)
|
|
}
|
|
|
|
tx2 := client.UserTransaction{Type: "0", Fee: "0", OrderID: json.Number("12345")}
|
|
got2 := PaymentMetadata(tx2)
|
|
if _, ok := got2[MetadataKeyFee]; ok {
|
|
t.Errorf("zero fee should not surface: %v", got2)
|
|
}
|
|
if got2[MetadataKeyOrderID] != "12345" {
|
|
t.Errorf("missing order_id: %v", got2)
|
|
}
|
|
}
|
|
|
|
func TestConversionMetadata(t *testing.T) {
|
|
t.Parallel()
|
|
tx := client.UserTransaction{Type: TxTypeBuySell, Fee: "0.000000", OrderID: json.Number("458254264")}
|
|
got := ConversionMetadata(tx, "eur_usdc", "0.86047")
|
|
if got[MetadataKeyType] != TxTypeBuySell {
|
|
t.Errorf("missing type: %v", got)
|
|
}
|
|
if got[MetadataKeyCurrencyPair] != "eur_usdc" {
|
|
t.Errorf("missing currency_pair: %v", got)
|
|
}
|
|
if got[MetadataKeyRate] != "0.86047" {
|
|
t.Errorf("missing rate: %v", got)
|
|
}
|
|
if _, ok := got[MetadataKeyFee]; ok {
|
|
t.Errorf("zero fee should be omitted: %v", got)
|
|
}
|
|
if got[MetadataKeyOrderID] != "458254264" {
|
|
t.Errorf("order_id=%q, want 458254264", got[MetadataKeyOrderID])
|
|
}
|
|
|
|
// Zero order_id must be omitted.
|
|
txNoOrder := client.UserTransaction{Type: TxTypeBuySell, OrderID: json.Number("0")}
|
|
gotNoOrder := ConversionMetadata(txNoOrder, "eur_usdc", "")
|
|
if _, ok := gotNoOrder[MetadataKeyOrderID]; ok {
|
|
t.Errorf("zero order_id must be omitted: %v", gotNoOrder)
|
|
}
|
|
}
|
|
|
|
func TestMetadataKeysAreNamespaced(t *testing.T) {
|
|
t.Parallel()
|
|
// Guard against accidental drift from the com.bitstamp.spec/* prefix.
|
|
for _, k := range []string{
|
|
MetadataKeyType, MetadataKeyFee, MetadataKeyOrderID,
|
|
MetadataKeyCurrencyPair, MetadataKeyClientOrderID, MetadataKeyRate,
|
|
MetadataKeySource, MetadataKeyTransferPairID, MetadataKeyTransferDirection,
|
|
MetadataKeyCounterpartySubAccountID, MetadataKeyCounterpartySubAccountName,
|
|
MetadataKeyNetworks, MetadataKeyWithdrawalFees, MetadataKeyTradableMarkets,
|
|
MetadataKeyFeeTierMaker, MetadataKeyFeeTierTaker, MetadataKeyMinOrderValue,
|
|
MetadataKeyMarketSymbol, MetadataKeyOrderDatetimeSecs,
|
|
} {
|
|
if !startsWith(k, MetadataPrefix) {
|
|
t.Errorf("%q not under %s", k, MetadataPrefix)
|
|
}
|
|
}
|
|
}
|
|
|
|
func startsWith(s, prefix string) bool {
|
|
if len(s) < len(prefix) {
|
|
return false
|
|
}
|
|
return s[:len(prefix)] == prefix
|
|
}
|
|
|
|
func TestTransferPairMetadata(t *testing.T) {
|
|
t.Parallel()
|
|
got := TransferPairMetadata(458254264, TransferDirectionOutgoing, "sub-acct-A", "Trading Sub")
|
|
if got[MetadataKeyTransferPairID] != "458254264" {
|
|
t.Errorf("pair id = %q", got[MetadataKeyTransferPairID])
|
|
}
|
|
if got[MetadataKeyTransferDirection] != TransferDirectionOutgoing {
|
|
t.Errorf("direction = %q", got[MetadataKeyTransferDirection])
|
|
}
|
|
if got[MetadataKeyCounterpartySubAccountID] != "sub-acct-A" || got[MetadataKeyCounterpartySubAccountName] != "Trading Sub" {
|
|
t.Errorf("counterparty fields missing: %+v", got)
|
|
}
|
|
|
|
// Empty counterparty must be omitted (sub_accounts endpoint is 404).
|
|
got = TransferPairMetadata(42, TransferDirectionIncoming, "", "")
|
|
if _, present := got[MetadataKeyCounterpartySubAccountID]; present {
|
|
t.Errorf("empty counterparty id must be omitted")
|
|
}
|
|
if _, present := got[MetadataKeyCounterpartySubAccountName]; present {
|
|
t.Errorf("empty counterparty name must be omitted")
|
|
}
|
|
}
|
|
|
|
func TestMergeMetadata(t *testing.T) {
|
|
t.Parallel()
|
|
a := map[string]string{"k1": "a1", "k2": "a2"}
|
|
b := map[string]string{"k2": "b2", "k3": "b3"}
|
|
|
|
got := MergeMetadata(a, b)
|
|
if got["k1"] != "a1" || got["k2"] != "b2" || got["k3"] != "b3" {
|
|
t.Errorf("merge order broken: %+v", got)
|
|
}
|
|
// Inputs must not mutate.
|
|
if a["k2"] != "a2" {
|
|
t.Error("MergeMetadata must not mutate input maps")
|
|
}
|
|
}
|