|
| 1 | +package com.siftscience; |
| 2 | + |
| 3 | +import static java.net.HttpURLConnection.HTTP_OK; |
| 4 | + |
| 5 | +import com.siftscience.model.WagerFieldSet; |
| 6 | +import okhttp3.OkHttpClient; |
| 7 | +import okhttp3.mockwebserver.MockResponse; |
| 8 | +import okhttp3.mockwebserver.MockWebServer; |
| 9 | +import okhttp3.mockwebserver.RecordedRequest; |
| 10 | +import org.junit.Assert; |
| 11 | +import org.junit.Test; |
| 12 | +import org.skyscreamer.jsonassert.JSONAssert; |
| 13 | + |
| 14 | +public class WagerFieldSetTest { |
| 15 | + @Test |
| 16 | + public void testWagerEvent() throws Exception { |
| 17 | + String expectedRequestBody = "{\n" + |
| 18 | + " \"$type\" : \"$wager\",\n" + |
| 19 | + " \"$api_key\" : \"YOUR_API_KEY\",\n" + |
| 20 | + " \"$user_id\" : \"billy_jones_301\",\n" + |
| 21 | + " \"$wager_id\" : \"wager_id_123\",\n" + |
| 22 | + " \"$wager_type\" : \"win_1\",\n" + |
| 23 | + " \"$wager_status\" : \"$accept\",\n" + |
| 24 | + " \"$amount\" : 506790000,\n" + |
| 25 | + " \"$currency_code\" : \"USD\",\n" + |
| 26 | + " \"$wager_event_type\" : \"sportsbook\",\n" + |
| 27 | + " \"$wager_event_name\" : \"NFL\",\n" + |
| 28 | + " \"$wager_event_id\" : \"NFL_2024_N1234\",\n" + |
| 29 | + " \"$minimum_wager_amount\" : 1000000,\n" + |
| 30 | + "}"; |
| 31 | + |
| 32 | + // Start a new mock server and enqueue a mock response. |
| 33 | + MockWebServer server = new MockWebServer(); |
| 34 | + MockResponse response = new MockResponse(); |
| 35 | + response.setResponseCode(HTTP_OK); |
| 36 | + response.setBody("{\n" + |
| 37 | + " \"status\" : 0,\n" + |
| 38 | + " \"error_message\" : \"OK\",\n" + |
| 39 | + " \"time\" : 1327604222,\n" + |
| 40 | + " \"request\" : \"" + TestUtils.unescapeJson(expectedRequestBody) + "\"\n" + |
| 41 | + "}"); |
| 42 | + server.enqueue(response); |
| 43 | + server.start(); |
| 44 | + |
| 45 | + // Create a new client and link it to the mock server. |
| 46 | + SiftClient client = new SiftClient("YOUR_API_KEY", "YOUR_ACCOUNT_ID", |
| 47 | + new OkHttpClient.Builder() |
| 48 | + .addInterceptor(OkHttpUtils.urlRewritingInterceptor(server)) |
| 49 | + .build()); |
| 50 | + |
| 51 | + // Build and execute the request against the mock server. |
| 52 | + EventRequest request = client.buildRequest(new WagerFieldSet() |
| 53 | + .setUserId("billy_jones_301") |
| 54 | + .setWagerId("wager_id_123") |
| 55 | + .setWagerType("win_1") |
| 56 | + .setWagerStatus("$accept") |
| 57 | + .setAmount(506790000L) |
| 58 | + .setCurrencyCode("USD") |
| 59 | + .setWagerEventType("sportsbook") |
| 60 | + .setWagerEventName("NFL") |
| 61 | + .setWagerEventId("NFL_2024_N1234") |
| 62 | + .setMinimumWagerAmount(1000000L)); |
| 63 | + EventResponse siftResponse = request.send(); |
| 64 | + |
| 65 | + // Verify the request. |
| 66 | + RecordedRequest request1 = server.takeRequest(); |
| 67 | + Assert.assertEquals("POST", request1.getMethod()); |
| 68 | + Assert.assertEquals("/v205/events", request1.getPath()); |
| 69 | + JSONAssert.assertEquals(expectedRequestBody, request.getFieldSet().toJson(), true); |
| 70 | + |
| 71 | + // Verify the response. |
| 72 | + Assert.assertEquals(HTTP_OK, siftResponse.getHttpStatusCode()); |
| 73 | + Assert.assertEquals(0, (int) siftResponse.getBody().getStatus()); |
| 74 | + JSONAssert.assertEquals(response.getBody().readUtf8(), |
| 75 | + siftResponse.getBody().toJson(), true); |
| 76 | + server.shutdown(); |
| 77 | + } |
| 78 | +} |
0 commit comments