Function TestInflightTransaction_Commit_API

api/transaction_api_test.go:475–588

(t *testing.T)

}

func TestInflightTransaction_Commit_API(t *testing.T) {
	router, b, err := setupRouter(t)
	if err != nil {
		t.Fatalf("Failed to setup router: %v", err)
	}

	cnf, err := config.Fetch()
	if err != nil {
		t.Fatalf("Failed to fetch config: %v", err)
	}

	// Determine the actual queue name the worker should listen to
	// Assuming NumberOfQueues is 1 (default), the queue index will be 1.
	actualTransactionQueueName := fmt.Sprintf("%s_%d", cnf.Queue.TransactionQueue, 1)
	cleanupWorker := StartTestAsynqWorker(t, cnf, b, actualTransactionQueueName)
	defer cleanupWorker()

	ctx := context.Background()
	ledger, err := b.CreateLedger(model.Ledger{Name: gofakeit.Name()})
	assert.NoError(t, err)

	sourceBalance, err := b.CreateBalance(ctx, model.Balance{LedgerID: ledger.LedgerID, Currency: "USD"})
	assert.NoError(t, err)
	destBalance, err := b.CreateBalance(ctx, model.Balance{LedgerID: ledger.LedgerID, Currency: "USD"})
	assert.NoError(t, err)

	// 1. Create Inflight Transaction
	inflightPayload := model2.RecordTransaction{
		Amount:         100.50,
		Precision:      100,
		Reference:      "inflight_commit_" + gofakeit.UUID(),
		Description:    "Inflight for API commit test",
		Currency:       "USD",
		Source:         sourceBalance.BalanceID,
		Destination:    destBalance.BalanceID,
		AllowOverDraft: true,
		Inflight:       true,
		SkipQueue:      false,
	}
	payloadBytes, _ := request.ToJsonReq(&inflightPayload)
	var inflightTxResponse model.Transaction

	testReqInflight := TestRequest{
		Payload:  payloadBytes,
		Response: &inflightTxResponse,
		Method:   "POST",
		Route:    "/transactions",
		Auth:     "",
		Router:   router,
	}

	respInflight, errInflight := SetUpTestRequest(testReqInflight)
	assert.NoError(t, errInflight)
	assert.Equal(t, http.StatusCreated, respInflight.Code)
	assert.Equal(t, "QUEUED", inflightTxResponse.Status)
	assert.True(t, inflightTxResponse.Inflight)

	ds, err := database.NewDataSource(cnf)