Function TestGetBalanceByIndicator

balance_test.go:493–563

(t *testing.T)

}

func TestGetBalanceByIndicator(t *testing.T) {
	// Skip in short mode
	if testing.Short() {
		t.Skip("Skipping real service test in short mode")
	}

	ctx := context.Background()
	cnf := &config.Configuration{
		Redis: config.RedisConfig{
			Dns: "localhost:6379",
		},
		DataSource: config.DataSourceConfig{
			Dns: "postgres://postgres:password@localhost:5432/ledgerforge?sslmode=disable",
		},
		Queue: config.QueueConfig{
			WebhookQueue:     "webhook_queue_test",
			IndexQueue:       "index_queue_test",
			TransactionQueue: "transaction_queue_test",
			NumberOfQueues:   1,
		},
		Server: config.ServerConfig{
			SecretKey: "test-secret",
		},
		Transaction: config.TransactionConfig{
			BatchSize:        100,
			MaxQueueSize:     1000,
			LockDuration:     time.Second * 30,
			IndexQueuePrefix: "test_index",
		},
	}
	config.ConfigStore.Store(cnf)

	ds, err := database.NewDataSource(cnf)
	require.NoError(t, err, "Failed to create datasource")

	ledgerforge, err := NewLedgerForge(ds)
	require.NoError(t, err, "Failed to create LedgerForge instance")

	// Generate unique indicator and currency
	indicator := "@" + model.GenerateUUIDWithSuffix("test")
	currency := "USD"
	ledgerID := "general_ledger_id"

	// 1. Create the balance
	balanceToCreate := model.Balance{
		Indicator: indicator,
		Currency:  currency,
		LedgerID:  ledgerID,
	}

	createdBalance, err := ledgerforge.CreateBalance(ctx, balanceToCreate)
	require.NoError(t, err, "Failed to create balance")
	require.NotEmpty(t, createdBalance.BalanceID, "Created balance should have an ID")
	require.Equal(t, indicator, createdBalance.Indicator, "Created balance indicator mismatch")
	require.Equal(t, currency, createdBalance.Currency, "Created balance currency mismatch")

	// 2. Get the balance by indicator
	retrievedBalance, err := ledgerforge.GetBalanceByIndicator(ctx, indicator, currency)