Skip to content

Commit e601880

Browse files
committed
fix(java): use the dsn with the read transporter
1 parent 853786a commit e601880

File tree

3 files changed

+34
-4
lines changed

3 files changed

+34
-4
lines changed

clients/algoliasearch-client-java/algoliasearch/src/main/java/com/algolia/internal/HttpRequester.java

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@
1818
import okhttp3.*;
1919
import okhttp3.internal.http.HttpMethod;
2020
import okio.BufferedSink;
21+
import com.algolia.utils.UseReadTransporter;
2122

2223
/**
2324
* HttpRequester is responsible for making HTTP requests using the OkHttp client. It provides a
@@ -72,7 +73,12 @@ private <T> T execute(@Nonnull HttpRequest httpRequest, RequestOptions requestOp
7273
RequestBody requestBody = createRequestBody(httpRequest);
7374

7475
// Build the HTTP request.
75-
Request request = new Request.Builder().url(url).headers(headers).method(httpRequest.getMethod(), requestBody).build();
76+
Request.Builder requestBuilder = new Request.Builder().url(url).headers(headers).method(httpRequest.getMethod(), requestBody);
77+
if (httpRequest.isRead()) {
78+
requestBuilder.tag(new UseReadTransporter());
79+
}
80+
81+
Request request = requestBuilder.build();
7682

7783
// Get or adjust the HTTP client according to request options.
7884
OkHttpClient client = getOkHttpClient(requestOptions);

templates/java/api.mustache

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -85,9 +85,9 @@ public class {{classname}} extends ApiClient {
8585
hosts.add(new Host(appId + ".algolia.net", EnumSet.of(CallType.WRITE)));
8686
8787
List<Host> commonHosts = new ArrayList<>();
88-
hosts.add(new Host(appId + "-1.algolianet.net", EnumSet.of(CallType.READ, CallType.WRITE)));
89-
hosts.add(new Host(appId + "-2.algolianet.net", EnumSet.of(CallType.READ, CallType.WRITE)));
90-
hosts.add(new Host(appId + "-3.algolianet.net", EnumSet.of(CallType.READ, CallType.WRITE)));
88+
commonHosts.add(new Host(appId + "-1.algolianet.net", EnumSet.of(CallType.READ, CallType.WRITE)));
89+
commonHosts.add(new Host(appId + "-2.algolianet.net", EnumSet.of(CallType.READ, CallType.WRITE)));
90+
commonHosts.add(new Host(appId + "-3.algolianet.net", EnumSet.of(CallType.READ, CallType.WRITE)));
9191
9292
Collections.shuffle(commonHosts, new Random());
9393

tests/CTS/client/search/api.json

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,30 @@
2323
}
2424
]
2525
},
26+
{
27+
"testName": "read transporter with POST method",
28+
"autoCreateClient": false,
29+
"steps": [
30+
{
31+
"type": "createClient",
32+
"parameters": {
33+
"appId": "test-app-id",
34+
"apiKey": "test-api-key"
35+
}
36+
},
37+
{
38+
"type": "method",
39+
"method": "searchSingleIndex",
40+
"parameters": {
41+
"indexName": "indexName"
42+
},
43+
"expected": {
44+
"type": "host",
45+
"match": "test-app-id-dsn.algolia.net"
46+
}
47+
}
48+
]
49+
},
2650
{
2751
"testName": "calls api with correct write host",
2852
"autoCreateClient": false,

0 commit comments

Comments
 (0)