#4040

Committed 17 Oct 2024 12:51PM CUT coverage: 71.745% (-0.002%) from 71.747%

Build # #4040

Build Type

push

github

Committed by

web-flow

Commit Message

chore: release 4.12.0 (#1267)

Run Details

8039 of 11205 relevant lines covered (71.74%)

0.72 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

77.78

/src/main/java/com/box/sdk/RealtimeServerConnection.java

package com.box.sdk;

import com.eclipsesource.json.Json;
import com.eclipsesource.json.JsonArray;
import com.eclipsesource.json.JsonObject;
import java.net.MalformedURLException;
import java.net.URL;

class RealtimeServerConnection {
    public static final URLTemplate EVENT_URL = new URLTemplate("events");
    public static final URLTemplate EVENT_POSITION_URL = new URLTemplate("events?stream_position=%s");

    private final BoxAPIConnection api;
    private final int timeout;
    private final String serverURLString;

    private int retries;

    RealtimeServerConnection(BoxAPIConnection api) {
        BoxJSONRequest request = new BoxJSONRequest(api, EVENT_URL.build(api.getBaseURL()), "OPTIONS");
        try (BoxJSONResponse response = request.send()) {
            JsonObject jsonObject = Json.parse(response.getJSON()).asObject();
            JsonArray entries = jsonObject.get("entries").asArray();
            JsonObject firstEntry = entries.get(0).asObject();
            this.serverURLString = firstEntry.get("url").asString();
            this.retries = Integer.parseInt(firstEntry.get("max_retries").asString());
            this.timeout = firstEntry.get("retry_timeout").asInt();
            this.api = api;
        }
    }

    int getRemainingRetries() {
        return this.retries;
    }

    boolean waitForChange(long position) {
        if (this.retries < 1) {
            throw new IllegalStateException("No more retries are allowed.");
        }

        URL url;
        try {
            String u = this.serverURLString + "&stream_position=" + position;
            url = new URL(u);
        } catch (MalformedURLException e) {
            throw new BoxAPIException("The long poll URL was malformed.", e);
        }

        while (this.retries > 0) {
            this.retries--;
            BoxJSONRequest request = new BoxJSONRequest(this.api, url, "GET");
            request.setConnectTimeout(this.timeout * 1000);
            request.setReadTimeout(this.timeout * 1000);
            try (BoxJSONResponse response = request.send()) {
                JsonObject jsonObject = Json.parse(response.getJSON()).asObject();
                String message = jsonObject.get("message").asString();
                if (message.equals("new_change")) {
                    return true;
                }
            } catch (BoxAPIException e) {
                break;
            }
        }

        return false;
    }
}

1	package com.box.sdk;
2
3	import com.eclipsesource.json.Json;
4	import com.eclipsesource.json.JsonArray;
5	import com.eclipsesource.json.JsonObject;
6	import java.net.MalformedURLException;
7	import java.net.URL;
8
9	class RealtimeServerConnection {
10	public static final URLTemplate EVENT_URL = new URLTemplate("events");	1✔
11	public static final URLTemplate EVENT_POSITION_URL = new URLTemplate("events?stream_position=%s");	1✔
12
13	private final BoxAPIConnection api;
14	private final int timeout;
15	private final String serverURLString;
16
17	private int retries;
18
19	RealtimeServerConnection(BoxAPIConnection api) {	1✔
20	BoxJSONRequest request = new BoxJSONRequest(api, EVENT_URL.build(api.getBaseURL()), "OPTIONS");	1✔
21	try (BoxJSONResponse response = request.send()) {	1✔
22	JsonObject jsonObject = Json.parse(response.getJSON()).asObject();	1✔
23	JsonArray entries = jsonObject.get("entries").asArray();	1✔
24	JsonObject firstEntry = entries.get(0).asObject();	1✔
25	this.serverURLString = firstEntry.get("url").asString();	1✔
26	this.retries = Integer.parseInt(firstEntry.get("max_retries").asString());	1✔
27	this.timeout = firstEntry.get("retry_timeout").asInt();	1✔
28	this.api = api;	1✔
29	}
30	}	1✔
31
32	int getRemainingRetries() {
33	return this.retries;	1✔
34	}
35
36	boolean waitForChange(long position) {
37	if (this.retries < 1) {	1✔
38	throw new IllegalStateException("No more retries are allowed.");	×
39	}
40
41	URL url;
42	try {
43	String u = this.serverURLString + "&stream_position=" + position;	1✔
44	url = new URL(u);	1✔
45	} catch (MalformedURLException e) {	×
46	throw new BoxAPIException("The long poll URL was malformed.", e);	×
47	}	1✔
48
49	while (this.retries > 0) {	1✔
50	this.retries--;	1✔
51	BoxJSONRequest request = new BoxJSONRequest(this.api, url, "GET");	1✔
52	request.setConnectTimeout(this.timeout * 1000);	1✔
53	request.setReadTimeout(this.timeout * 1000);	1✔
54	try (BoxJSONResponse response = request.send()) {	1✔
55	JsonObject jsonObject = Json.parse(response.getJSON()).asObject();	1✔
56	String message = jsonObject.get("message").asString();	1✔
57	if (message.equals("new_change")) {	1✔
58	return true;	1✔
59	}
60	} catch (BoxAPIException e) {	×
61	break;	×
62	}	×
63	}	×
64
65	return false;	×
66	}
67	}

box / box-java-sdk / #4040

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous