#4768

Committed 04 Sep 2025 02:54PM UTC coverage: 37.242% (+0.003%) from 37.239%

Build # #4768

Build Type

push

github

Committed by

web-flow

Commit Message

feat: Support event with long polling (box/box-codegen#807) (#1409)

Run Details

32 of 422 new or added lines in 7 files covered. (7.58%)

6 existing lines in 3 files now uncovered.

18481 of 49624 relevant lines covered (37.24%)

0.37 hits per line

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

86.44

/src/main/java/com/box/sdkgen/managers/events/EventsManager.java

package com.box.sdkgen.managers.events;

import static com.box.sdkgen.internal.utils.UtilsManager.convertToString;
import static com.box.sdkgen.internal.utils.UtilsManager.entryOf;
import static com.box.sdkgen.internal.utils.UtilsManager.mapOf;
import static com.box.sdkgen.internal.utils.UtilsManager.mergeMaps;
import static com.box.sdkgen.internal.utils.UtilsManager.prepareParams;

import com.box.sdkgen.box.eventstream.EventStream;
import com.box.sdkgen.networking.auth.Authentication;
import com.box.sdkgen.networking.fetchoptions.FetchOptions;
import com.box.sdkgen.networking.fetchoptions.ResponseFormat;
import com.box.sdkgen.networking.fetchresponse.FetchResponse;
import com.box.sdkgen.networking.network.NetworkSession;
import com.box.sdkgen.schemas.events.Events;
import com.box.sdkgen.schemas.realtimeservers.RealtimeServers;
import com.box.sdkgen.serialization.json.JsonManager;
import java.util.Map;

public class EventsManager {

  public Authentication auth;

  public NetworkSession networkSession;

  public EventsManager() {
    this.networkSession = new NetworkSession();
  }

  protected EventsManager(Builder builder) {
    this.auth = builder.auth;
    this.networkSession = builder.networkSession;
  }

  public RealtimeServers getEventsWithLongPolling() {
    return getEventsWithLongPolling(new GetEventsWithLongPollingHeaders());
  }

  public RealtimeServers getEventsWithLongPolling(GetEventsWithLongPollingHeaders headers) {
    Map<String, String> headersMap = prepareParams(mergeMaps(mapOf(), headers.getExtraHeaders()));
    FetchResponse response =
        this.networkSession
            .getNetworkClient()
            .fetch(
                new FetchOptions.Builder(
                        String.join(
                            "", this.networkSession.getBaseUrls().getBaseUrl(), "/2.0/events"),
                        "OPTIONS")
                    .headers(headersMap)
                    .responseFormat(ResponseFormat.JSON)
                    .auth(this.auth)
                    .networkSession(this.networkSession)
                    .build());
    return JsonManager.deserialize(response.getData(), RealtimeServers.class);
  }

  public Events getEvents() {
    return getEvents(new GetEventsQueryParams(), new GetEventsHeaders());
  }

  public Events getEvents(GetEventsQueryParams queryParams) {
    return getEvents(queryParams, new GetEventsHeaders());
  }

  public Events getEvents(GetEventsHeaders headers) {
    return getEvents(new GetEventsQueryParams(), headers);
  }

  public Events getEvents(GetEventsQueryParams queryParams, GetEventsHeaders headers) {
    Map<String, String> queryParamsMap =
        prepareParams(
            mapOf(
                entryOf("stream_type", convertToString(queryParams.getStreamType())),
                entryOf("stream_position", convertToString(queryParams.getStreamPosition())),
                entryOf("limit", convertToString(queryParams.getLimit())),
                entryOf("event_type", convertToString(queryParams.getEventType())),
                entryOf("created_after", convertToString(queryParams.getCreatedAfter())),
                entryOf("created_before", convertToString(queryParams.getCreatedBefore()))));
    Map<String, String> headersMap = prepareParams(mergeMaps(mapOf(), headers.getExtraHeaders()));
    FetchResponse response =
        this.networkSession
            .getNetworkClient()
            .fetch(
                new FetchOptions.Builder(
                        String.join(
                            "", this.networkSession.getBaseUrls().getBaseUrl(), "/2.0/events"),
                        "GET")
                    .params(queryParamsMap)
                    .headers(headersMap)
                    .responseFormat(ResponseFormat.JSON)
                    .auth(this.auth)
                    .networkSession(this.networkSession)
                    .build());
    return JsonManager.deserialize(response.getData(), Events.class);
  }

  public EventStream getEventStream() {
    return getEventStream(new GetEventStreamQueryParams(), new GetEventStreamHeaders());
  }

  public EventStream getEventStream(GetEventStreamQueryParams queryParams) {
    return getEventStream(queryParams, new GetEventStreamHeaders());
  }

  public EventStream getEventStream(GetEventStreamHeaders headers) {
    return getEventStream(new GetEventStreamQueryParams(), headers);
  }

  public EventStream getEventStream(
      GetEventStreamQueryParams queryParams, GetEventStreamHeaders headers) {
    return new EventStream.Builder(this, queryParams).headersInput(headers).build();
  }

  public Authentication getAuth() {
    return auth;
  }

  public NetworkSession getNetworkSession() {
    return networkSession;
  }

  public static class Builder {

    protected Authentication auth;

    protected NetworkSession networkSession;

    public Builder() {
      this.networkSession = new NetworkSession();
    }

    public Builder auth(Authentication auth) {
      this.auth = auth;
      return this;
    }

    public Builder networkSession(NetworkSession networkSession) {
      this.networkSession = networkSession;
      return this;
    }

    public EventsManager build() {
      return new EventsManager(this);
    }
  }
}

1	package com.box.sdkgen.managers.events;
2
3	import static com.box.sdkgen.internal.utils.UtilsManager.convertToString;
4	import static com.box.sdkgen.internal.utils.UtilsManager.entryOf;
5	import static com.box.sdkgen.internal.utils.UtilsManager.mapOf;
6	import static com.box.sdkgen.internal.utils.UtilsManager.mergeMaps;
7	import static com.box.sdkgen.internal.utils.UtilsManager.prepareParams;
8
9	import com.box.sdkgen.box.eventstream.EventStream;
10	import com.box.sdkgen.networking.auth.Authentication;
11	import com.box.sdkgen.networking.fetchoptions.FetchOptions;
12	import com.box.sdkgen.networking.fetchoptions.ResponseFormat;
13	import com.box.sdkgen.networking.fetchresponse.FetchResponse;
14	import com.box.sdkgen.networking.network.NetworkSession;
15	import com.box.sdkgen.schemas.events.Events;
16	import com.box.sdkgen.schemas.realtimeservers.RealtimeServers;
17	import com.box.sdkgen.serialization.json.JsonManager;
18	import java.util.Map;
19
20	public class EventsManager {
21
22	public Authentication auth;
23
24	public NetworkSession networkSession;
25
UNCOV 26	public EventsManager() {	×
27	this.networkSession = new NetworkSession();	×
28	}	×
29
30	protected EventsManager(Builder builder) {	1✔
31	this.auth = builder.auth;	1✔
32	this.networkSession = builder.networkSession;	1✔
33	}	1✔
34
35	public RealtimeServers getEventsWithLongPolling() {
36	return getEventsWithLongPolling(new GetEventsWithLongPollingHeaders());	1✔
37	}
38
39	public RealtimeServers getEventsWithLongPolling(GetEventsWithLongPollingHeaders headers) {
40	Map<String, String> headersMap = prepareParams(mergeMaps(mapOf(), headers.getExtraHeaders()));	1✔
41	FetchResponse response =	1✔
42	this.networkSession
43	.getNetworkClient()	1✔
44	.fetch(	1✔
45	new FetchOptions.Builder(
46	String.join(	1✔
47	"", this.networkSession.getBaseUrls().getBaseUrl(), "/2.0/events"),	1✔
48	"OPTIONS")
49	.headers(headersMap)	1✔
50	.responseFormat(ResponseFormat.JSON)	1✔
51	.auth(this.auth)	1✔
52	.networkSession(this.networkSession)	1✔
53	.build());	1✔
54	return JsonManager.deserialize(response.getData(), RealtimeServers.class);	1✔
55	}
56
57	public Events getEvents() {
58	return getEvents(new GetEventsQueryParams(), new GetEventsHeaders());	1✔
59	}
60
61	public Events getEvents(GetEventsQueryParams queryParams) {
62	return getEvents(queryParams, new GetEventsHeaders());	1✔
63	}
64
65	public Events getEvents(GetEventsHeaders headers) {
UNCOV 66	return getEvents(new GetEventsQueryParams(), headers);	×
67	}
68
69	public Events getEvents(GetEventsQueryParams queryParams, GetEventsHeaders headers) {
70	Map<String, String> queryParamsMap =	1✔
71	prepareParams(	1✔
72	mapOf(	1✔
73	entryOf("stream_type", convertToString(queryParams.getStreamType())),	1✔
74	entryOf("stream_position", convertToString(queryParams.getStreamPosition())),	1✔
75	entryOf("limit", convertToString(queryParams.getLimit())),	1✔
76	entryOf("event_type", convertToString(queryParams.getEventType())),	1✔
77	entryOf("created_after", convertToString(queryParams.getCreatedAfter())),	1✔
78	entryOf("created_before", convertToString(queryParams.getCreatedBefore()))));	1✔
79	Map<String, String> headersMap = prepareParams(mergeMaps(mapOf(), headers.getExtraHeaders()));	1✔
80	FetchResponse response =	1✔
81	this.networkSession
82	.getNetworkClient()	1✔
83	.fetch(	1✔
84	new FetchOptions.Builder(
85	String.join(	1✔
86	"", this.networkSession.getBaseUrls().getBaseUrl(), "/2.0/events"),	1✔
87	"GET")
88	.params(queryParamsMap)	1✔
89	.headers(headersMap)	1✔
90	.responseFormat(ResponseFormat.JSON)	1✔
91	.auth(this.auth)	1✔
92	.networkSession(this.networkSession)	1✔
93	.build());	1✔
94	return JsonManager.deserialize(response.getData(), Events.class);	1✔
95	}
96
97	public EventStream getEventStream() {
98	return getEventStream(new GetEventStreamQueryParams(), new GetEventStreamHeaders());	1✔
99	}
100
101	public EventStream getEventStream(GetEventStreamQueryParams queryParams) {
NEW 102	return getEventStream(queryParams, new GetEventStreamHeaders());	×
103	}
104
105	public EventStream getEventStream(GetEventStreamHeaders headers) {
NEW 106	return getEventStream(new GetEventStreamQueryParams(), headers);	×
107	}
108
109	public EventStream getEventStream(
110	GetEventStreamQueryParams queryParams, GetEventStreamHeaders headers) {
111	return new EventStream.Builder(this, queryParams).headersInput(headers).build();	1✔
112	}
113
114	public Authentication getAuth() {
UNCOV 115	return auth;	×
116	}
117
118	public NetworkSession getNetworkSession() {
UNCOV 119	return networkSession;	×
120	}
121
122	public static class Builder {
123
124	protected Authentication auth;
125
126	protected NetworkSession networkSession;
127
128	public Builder() {	1✔
129	this.networkSession = new NetworkSession();	1✔
130	}	1✔
131
132	public Builder auth(Authentication auth) {
133	this.auth = auth;	1✔
134	return this;	1✔
135	}
136
137	public Builder networkSession(NetworkSession networkSession) {
138	this.networkSession = networkSession;	1✔
139	return this;	1✔
140	}
141
142	public EventsManager build() {
143	return new EventsManager(this);	1✔
144	}
145	}
146	}

box / box-java-sdk / #4768

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