Java_query

package org.example;


import okhttp3.*;

import java.io.IOException;

public class BitqueryWebsocketClient {

    private static final String BEARER_TOKEN = "*************************************************";

    private final OkHttpClient client;
    private final MediaType mediaType;
    private final RequestBody body;
    private final Request request;

    public BitqueryWebsocketClient() {
        client = new OkHttpClient().newBuilder().build();
        mediaType = MediaType.parse("application/json");

        String jsonBody = "{"
                + "\"query\":\"query BalanceUpdateNewHolderOrPositionUp($netzwerk: evm_network!, $tokenContractAddress: String!, $fromAddress: String!) {"
                + "  EVM(network: $netzwerk, dataset: combined) {"
                + "    BalanceUpdates("
                + "      where: {Currency: {SmartContract: {is: $tokenContractAddress}}, BalanceUpdate: {Address: {is: $fromAddress}}}"
                + "    ) {"
                + "      BalanceUpdate {"
                + "        Address"
                + "      }"
                + "      Balance: sum(of: BalanceUpdate_Amount)"
                + "    }"
                + "  }"
                + "}\","
                + "\"variables\":{"
                + "\"fromAddress\":\"0x2c7737b55557e9be17240183fef5c1d377a581c4\","
                + "\"tokenContractAddress\":\"0xd1f17b7a6bff962659ed608bcd6d318bb5fbb249\","
                + "\"netzwerk\":\"eth\""
                + "}"
                + "}";
        body = RequestBody.create(mediaType, jsonBody);

        request = new Request.Builder()
                .url("https://streaming.bitquery.io/graphql")
                .method("POST", body)
                .header("Authorization", "Bearer " + BEARER_TOKEN)
                .header("Content-Type", "application/json")
                .build();
    }

    public void executeRequest() {
        try {
            Response response = client.newCall(request).execute();
            System.out.println(response.body().string());
            response.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    public static void main(String[] args) {
        BitqueryWebsocketClient client = new BitqueryWebsocketClient();
        client.executeRequest();
    }
}