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.
157 lines
5.1 KiB
Go
157 lines
5.1 KiB
Go
package events
|
|
|
|
import (
|
|
"encoding/json"
|
|
"math/big"
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/hanzo-fi/payments/pkg/domain/models"
|
|
"github.com/google/uuid"
|
|
"github.com/stretchr/testify/assert"
|
|
"github.com/stretchr/testify/require"
|
|
)
|
|
|
|
func TestConversionMessagePayload_MarshalJSON(t *testing.T) {
|
|
t.Parallel()
|
|
|
|
t.Run("with all big.Int fields", func(t *testing.T) {
|
|
t.Parallel()
|
|
|
|
feeAsset := "USD/2"
|
|
payload := ConversionMessagePayload{
|
|
ID: "conv-1",
|
|
ConnectorID: "conn-1",
|
|
Provider: "coinbaseprime",
|
|
Reference: "ref-1",
|
|
CreatedAt: time.Date(2026, 2, 9, 15, 33, 0, 0, time.UTC),
|
|
UpdatedAt: time.Date(2026, 2, 9, 15, 34, 0, 0, time.UTC),
|
|
SourceAsset: "USD/2",
|
|
DestinationAsset: "USDC/6",
|
|
SourceAmount: big.NewInt(10000),
|
|
DestinationAmount: big.NewInt(10000000),
|
|
Fee: big.NewInt(50),
|
|
FeeAsset: &feeAsset,
|
|
Status: "COMPLETED",
|
|
}
|
|
|
|
data, err := json.Marshal(&payload)
|
|
require.NoError(t, err)
|
|
|
|
var result map[string]interface{}
|
|
err = json.Unmarshal(data, &result)
|
|
require.NoError(t, err)
|
|
|
|
assert.Equal(t, "conv-1", result["id"])
|
|
assert.Equal(t, "10000", result["sourceAmount"])
|
|
assert.Equal(t, "10000000", result["destinationAmount"])
|
|
assert.Equal(t, "50", result["fee"])
|
|
assert.Equal(t, "COMPLETED", result["status"])
|
|
})
|
|
|
|
t.Run("with nil optional fields", func(t *testing.T) {
|
|
t.Parallel()
|
|
|
|
payload := ConversionMessagePayload{
|
|
ID: "conv-2",
|
|
SourceAsset: "USD/2",
|
|
SourceAmount: big.NewInt(200),
|
|
Status: "PENDING",
|
|
}
|
|
|
|
data, err := json.Marshal(&payload)
|
|
require.NoError(t, err)
|
|
|
|
var result map[string]interface{}
|
|
err = json.Unmarshal(data, &result)
|
|
require.NoError(t, err)
|
|
|
|
assert.Equal(t, "200", result["sourceAmount"])
|
|
assert.Nil(t, result["destinationAmount"])
|
|
assert.Nil(t, result["fee"])
|
|
})
|
|
|
|
t.Run("round-trip", func(t *testing.T) {
|
|
t.Parallel()
|
|
|
|
feeAsset := "USD/2"
|
|
original := ConversionMessagePayload{
|
|
ID: "conv-rt",
|
|
ConnectorID: "conn-1",
|
|
Provider: "coinbaseprime",
|
|
Reference: "ref-rt",
|
|
SourceAsset: "USD/2",
|
|
DestinationAsset: "USDC/6",
|
|
SourceAmount: big.NewInt(100000),
|
|
DestinationAmount: big.NewInt(100000000),
|
|
Fee: big.NewInt(0),
|
|
FeeAsset: &feeAsset,
|
|
Status: "COMPLETED",
|
|
SourceAccountID: "eyJhY2N0MSJ9",
|
|
DestinationAccountID: "eyJhY2N0MiJ9",
|
|
Metadata: map[string]string{"key": "value"},
|
|
Raw: json.RawMessage(`{"raw":"data"}`),
|
|
}
|
|
|
|
data, err := json.Marshal(&original)
|
|
require.NoError(t, err)
|
|
|
|
var restored ConversionMessagePayload
|
|
err = json.Unmarshal(data, &restored)
|
|
require.NoError(t, err)
|
|
|
|
assert.Equal(t, original.ID, restored.ID)
|
|
assert.Equal(t, original.SourceAsset, restored.SourceAsset)
|
|
assert.Equal(t, original.DestinationAsset, restored.DestinationAsset)
|
|
assert.Equal(t, 0, original.SourceAmount.Cmp(restored.SourceAmount))
|
|
assert.Equal(t, 0, original.DestinationAmount.Cmp(restored.DestinationAmount))
|
|
assert.Equal(t, 0, original.Fee.Cmp(restored.Fee))
|
|
assert.Equal(t, *original.FeeAsset, *restored.FeeAsset)
|
|
assert.Equal(t, original.SourceAccountID, restored.SourceAccountID)
|
|
assert.Equal(t, original.DestinationAccountID, restored.DestinationAccountID)
|
|
assert.Equal(t, original.Metadata["key"], restored.Metadata["key"])
|
|
})
|
|
}
|
|
|
|
func TestNewEventSavedConversion(t *testing.T) {
|
|
t.Parallel()
|
|
|
|
connID := models.ConnectorID{Provider: "test", Reference: uuid.MustParse("00000000-0000-0000-0000-000000000001")}
|
|
srcAcct := models.AccountID{Reference: "wallet-usd", ConnectorID: connID}
|
|
dstAcct := models.AccountID{Reference: "wallet-usdc", ConnectorID: connID}
|
|
|
|
conversion := models.Conversion{
|
|
ID: models.ConversionID{Reference: "conv-1", ConnectorID: connID},
|
|
ConnectorID: connID,
|
|
Reference: "conv-1",
|
|
CreatedAt: time.Date(2026, 2, 9, 15, 33, 0, 0, time.UTC),
|
|
UpdatedAt: time.Date(2026, 2, 9, 15, 34, 0, 0, time.UTC),
|
|
SourceAsset: "USD/2",
|
|
DestinationAsset: "USDC/6",
|
|
SourceAmount: big.NewInt(10000),
|
|
DestinationAmount: big.NewInt(10000000),
|
|
Status: models.CONVERSION_STATUS_COMPLETED,
|
|
SourceAccountID: &srcAcct,
|
|
DestinationAccountID: &dstAcct,
|
|
Metadata: map[string]string{"key": "val"},
|
|
Raw: json.RawMessage(`{"raw":"data"}`),
|
|
}
|
|
|
|
e := Events{}
|
|
msg := e.NewEventSavedConversion(conversion)
|
|
|
|
assert.Equal(t, "SAVED_CONVERSION", msg.Type)
|
|
assert.NotEmpty(t, msg.IdempotencyKey)
|
|
|
|
payload, ok := msg.Payload.(ConversionMessagePayload)
|
|
require.True(t, ok)
|
|
assert.Equal(t, "conv-1", payload.Reference)
|
|
assert.Equal(t, "USD/2", payload.SourceAsset)
|
|
assert.Equal(t, "USDC/6", payload.DestinationAsset)
|
|
assert.Equal(t, 0, payload.SourceAmount.Cmp(big.NewInt(10000)))
|
|
assert.Equal(t, 0, payload.DestinationAmount.Cmp(big.NewInt(10000000)))
|
|
assert.Equal(t, "COMPLETED", payload.Status)
|
|
assert.NotEmpty(t, payload.SourceAccountID)
|
|
assert.NotEmpty(t, payload.DestinationAccountID)
|
|
}
|