Function TestGetReconciliation_Success

database/reconciliation_test.go:117–146

(t *testing.T)

}

func TestGetReconciliation_Success(t *testing.T) {
	db, mock, err := sqlmock.New()
	assert.NoError(t, err)
	defer func() { _ = db.Close() }()
	completedAt := time.Now()
	ds := Datasource{Conn: db}
	ctx := context.TODO()

	expectedRec := &model.Reconciliation{
		ID:                    1,
		ReconciliationID:      "rec123",
		UploadID:              "upl123",
		Status:                "completed",
		MatchedTransactions:   10,
		UnmatchedTransactions: 5,
		StartedAt:             time.Now(),
		CompletedAt:           &completedAt,
	}

	mock.ExpectQuery("SELECT id, reconciliation_id, upload_id, status").
		WithArgs("rec123").
		WillReturnRows(sqlmock.NewRows([]string{
			"id", "reconciliation_id", "upload_id", "status", "matched_transactions", "unmatched_transactions", "started_at", "completed_at",
		}).AddRow(expectedRec.ID, expectedRec.ReconciliationID, expectedRec.UploadID, expectedRec.Status, expectedRec.MatchedTransactions,
			expectedRec.UnmatchedTransactions, expectedRec.StartedAt, expectedRec.CompletedAt))

	rec, err := ds.GetReconciliation(ctx, "rec123")
	assert.NoError(t, err)
	assert.Equal(t, expectedRec.ReconciliationID, rec.ReconciliationID)
}

func TestGetReconciliation_NotFound(t *testing.T) {
	db, mock, err := sqlmock.New()