(t *testing.T)
| 972 | } |
| 973 | |
| 974 | func TestUpdateTransactionStatus_Error(t *testing.T) { |
| 975 | db, mock, err := sqlmock.New() |
| 976 | assert.NoError(t, err) |
| 977 | defer func() { _ = db.Close() }() |
| 978 | |
| 979 | ds := Datasource{Conn: db} |
| 980 | ctx := context.Background() |
| 981 | |
| 982 | query := ` |
| 983 | UPDATE ledgerforge.transactions |
| 984 | SET status = $2 |
| 985 | WHERE transaction_id = $1 |
| 986 | ` |
| 987 | |
| 988 | mock.ExpectExec(regexp.QuoteMeta(query)). |
| 989 | WithArgs("txn_123", "APPLIED"). |
| 990 | WillReturnError(errors.New("database error")) |
| 991 | |
| 992 | err = ds.UpdateTransactionStatus(ctx, "txn_123", "APPLIED") |
| 993 | assert.Error(t, err) |
| 994 | apiErr, ok := err.(apierror.APIError) |
| 995 | assert.True(t, ok) |
| 996 | assert.Equal(t, apierror.ErrInternalServer, apiErr.Code) |
| 997 | |
| 998 | err = mock.ExpectationsWereMet() |
| 999 | assert.NoError(t, err) |
| 1000 | } |
| 1001 | |
| 1002 | func TestGetAllTransactions_Success(t *testing.T) { |
| 1003 | db, mock, err := sqlmock.New() |
nothing calls this directly
no test coverage detected