Function TestGetTransaction_Mock

transaction_test.go:6090–6138

(t *testing.T)

}

func TestGetTransaction_Mock(t *testing.T) {
	cnf := &config.Configuration{
		Redis: config.RedisConfig{Dns: "localhost:6379"},
		Queue: config.QueueConfig{
			WebhookQueue:     "webhook_queue",
			TransactionQueue: "transaction_queue",
			NumberOfQueues:   1,
		},
	}
	config.ConfigStore.Store(cnf)

	t.Run("Success", func(t *testing.T) {
		mockDS := new(mocks.MockDataSource)

		txnID := "txn_123"
		expectedTxn := &model.Transaction{
			TransactionID: txnID,
			Amount:        100.0,
			Reference:     "ref_123",
			Status:        "APPLIED",
			PreciseAmount: big.NewInt(10000),
		}

		mockDS.On("GetTransaction", mock.Anything, txnID).Return(expectedTxn, nil)

		ledgerforge := &LedgerForge{datasource: mockDS, config: cnf}
		result, err := ledgerforge.GetTransaction(context.Background(), txnID)

		assert.NoError(t, err)
		assert.NotNil(t, result)
		assert.Equal(t, txnID, result.TransactionID)
		assert.Equal(t, "APPLIED", result.Status)
		mockDS.AssertExpectations(t)
	})

	t.Run("Not Found", func(t *testing.T) {
		mockDS := new(mocks.MockDataSource)

		txnID := "txn_nonexistent"
		mockDS.On("GetTransaction", mock.Anything, txnID).Return((*model.Transaction)(nil), fmt.Errorf("not found"))

		ledgerforge := &LedgerForge{datasource: mockDS, config: cnf}
		result, err := ledgerforge.GetTransaction(context.Background(), txnID)

		assert.Error(t, err)
		assert.Nil(t, result)
		mockDS.AssertExpectations(t)
	})
}

func TestGetAllTransactions_Mock(t *testing.T) {
	cnf := &config.Configuration{