diff --git a/src/main/java/io/getstream/models/AppResponseFields.java b/src/main/java/io/getstream/models/AppResponseFields.java index cf2557d..6746639 100644 --- a/src/main/java/io/getstream/models/AppResponseFields.java +++ b/src/main/java/io/getstream/models/AppResponseFields.java @@ -72,6 +72,9 @@ public class AppResponseFields { @JsonProperty("moderation_enabled") private Boolean moderationEnabled; + @JsonProperty("moderation_flood_rules_enabled") + private Boolean moderationFloodRulesEnabled; + @JsonProperty("moderation_llm_configurability_enabled") private Boolean moderationLlmConfigurabilityEnabled; @@ -173,6 +176,10 @@ public class AppResponseFields { @JsonProperty("before_message_send_hook_url") private String beforeMessageSendHookUrl; + @Nullable + @JsonProperty("chat_primary_use_case") + private String chatPrimaryUseCase; + @Nullable @JsonProperty("moderation_onboarding_complete") private Boolean moderationOnboardingComplete; diff --git a/src/main/java/io/getstream/models/BanInfoResponse.java b/src/main/java/io/getstream/models/BanInfoResponse.java index 2594899..d68c3f1 100644 --- a/src/main/java/io/getstream/models/BanInfoResponse.java +++ b/src/main/java/io/getstream/models/BanInfoResponse.java @@ -26,6 +26,10 @@ public class BanInfoResponse { @JsonProperty("created_at") private Date createdAt; + @Nullable + @JsonProperty("channel_cid") + private String channelCid; + @Nullable @JsonProperty("expires") private Date expires; @@ -38,6 +42,10 @@ public class BanInfoResponse { @JsonProperty("shadow") private Boolean shadow; + @Nullable + @JsonProperty("channel") + private ChannelMetadata channel; + @Nullable @JsonProperty("created_by") private UserResponse createdBy; diff --git a/src/main/java/io/getstream/models/BlockListResponse.java b/src/main/java/io/getstream/models/BlockListResponse.java index 8e5cb45..56bc7b4 100644 --- a/src/main/java/io/getstream/models/BlockListResponse.java +++ b/src/main/java/io/getstream/models/BlockListResponse.java @@ -53,6 +53,10 @@ public class BlockListResponse { @JsonProperty("id") private String id; + @Nullable + @JsonProperty("owner_user_id") + private String ownerUserID; + @Nullable @JsonProperty("team") private String team; diff --git a/src/main/java/io/getstream/models/CallSettingsRequest.java b/src/main/java/io/getstream/models/CallSettingsRequest.java index 616ef76..7dd6399 100644 --- a/src/main/java/io/getstream/models/CallSettingsRequest.java +++ b/src/main/java/io/getstream/models/CallSettingsRequest.java @@ -33,6 +33,10 @@ public class CallSettingsRequest { @JsonProperty("broadcasting") private BroadcastSettingsRequest broadcasting; + @Nullable + @JsonProperty("encryption") + private EncryptionSettingsRequest encryption; + @Nullable @JsonProperty("frame_recording") private FrameRecordingSettingsRequest frameRecording; diff --git a/src/main/java/io/getstream/models/CallSettingsResponse.java b/src/main/java/io/getstream/models/CallSettingsResponse.java index 3fc7d7e..c41168c 100644 --- a/src/main/java/io/getstream/models/CallSettingsResponse.java +++ b/src/main/java/io/getstream/models/CallSettingsResponse.java @@ -30,6 +30,9 @@ public class CallSettingsResponse { @JsonProperty("broadcasting") private BroadcastSettingsResponse broadcasting; + @JsonProperty("encryption") + private EncryptionSettingsResponse encryption; + @JsonProperty("frame_recording") private FrameRecordingSettingsResponse frameRecording; diff --git a/src/main/java/io/getstream/models/ChannelMemberPartialResponse.java b/src/main/java/io/getstream/models/ChannelMemberPartialResponse.java new file mode 100644 index 0000000..124ae52 --- /dev/null +++ b/src/main/java/io/getstream/models/ChannelMemberPartialResponse.java @@ -0,0 +1,28 @@ +/* + * ======================================================================== + * WARNING: GENERATED CODE -- DO NOT EDIT! + * ======================================================================== + * + * This file was auto-generated by GetStream internal OpenAPI + * + * Any modifications to this file will be lost upon regeneration. + * To make changes, please modify the source templates and regenerate. + * + * ======================================================================== + */ +package io.getstream.models; + +import com.fasterxml.jackson.annotation.JsonProperty; + +@lombok.Data +@lombok.Builder +@lombok.NoArgsConstructor +@lombok.AllArgsConstructor +public class ChannelMemberPartialResponse { + + @JsonProperty("channel_role") + private String channelRole; + + @JsonProperty("notifications_muted") + private Boolean notificationsMuted; +} diff --git a/src/main/java/io/getstream/models/ChannelMetadata.java b/src/main/java/io/getstream/models/ChannelMetadata.java new file mode 100644 index 0000000..9ce137e --- /dev/null +++ b/src/main/java/io/getstream/models/ChannelMetadata.java @@ -0,0 +1,57 @@ +/* + * ======================================================================== + * WARNING: GENERATED CODE -- DO NOT EDIT! + * ======================================================================== + * + * This file was auto-generated by GetStream internal OpenAPI + * + * Any modifications to this file will be lost upon regeneration. + * To make changes, please modify the source templates and regenerate. + * + * ======================================================================== + */ +package io.getstream.models; + +import com.fasterxml.jackson.annotation.JsonProperty; +import java.util.Date; +import java.util.Map; +import org.jetbrains.annotations.Nullable; + +@lombok.Data +@lombok.Builder +@lombok.NoArgsConstructor +@lombok.AllArgsConstructor +public class ChannelMetadata { + + @JsonProperty("cid") + private String cid; + + @JsonProperty("id") + private String id; + + @JsonProperty("type") + private String type; + + @JsonProperty("custom") + private Map custom; + + @Nullable + @JsonProperty("last_message_at") + private Date lastMessageAt; + + @Nullable + @JsonProperty("member_count") + private Integer memberCount; + + @Nullable + @JsonProperty("message_count") + private Integer messageCount; + + @Nullable + @JsonProperty("push_level") + private String pushLevel; + + @Nullable + @JsonProperty("team") + private String team; +} diff --git a/src/main/java/io/getstream/models/ChatMessageResponse.java b/src/main/java/io/getstream/models/ChatMessageResponse.java index 3569e2b..c0e1630 100644 --- a/src/main/java/io/getstream/models/ChatMessageResponse.java +++ b/src/main/java/io/getstream/models/ChatMessageResponse.java @@ -167,7 +167,7 @@ public class ChatMessageResponse { @Nullable @JsonProperty("member") - private ChannelMemberResponse member; + private ChannelMemberPartialResponse member; @Nullable @JsonProperty("moderation") diff --git a/src/main/java/io/getstream/models/ClientEvent.java b/src/main/java/io/getstream/models/ClientEvent.java index 9061d36..b66cbb5 100644 --- a/src/main/java/io/getstream/models/ClientEvent.java +++ b/src/main/java/io/getstream/models/ClientEvent.java @@ -63,6 +63,10 @@ public class ClientEvent { @JsonProperty("join_attempt_id") private String joinAttemptID; + @Nullable + @JsonProperty("join_reason") + private String joinReason; + @Nullable @JsonProperty("microphone_permission_status") private String microphonePermissionStatus; diff --git a/src/main/java/io/getstream/models/EncryptionSettingsRequest.java b/src/main/java/io/getstream/models/EncryptionSettingsRequest.java new file mode 100644 index 0000000..aed4a07 --- /dev/null +++ b/src/main/java/io/getstream/models/EncryptionSettingsRequest.java @@ -0,0 +1,27 @@ +/* + * ======================================================================== + * WARNING: GENERATED CODE -- DO NOT EDIT! + * ======================================================================== + * + * This file was auto-generated by GetStream internal OpenAPI + * + * Any modifications to this file will be lost upon regeneration. + * To make changes, please modify the source templates and regenerate. + * + * ======================================================================== + */ +package io.getstream.models; + +import com.fasterxml.jackson.annotation.JsonProperty; +import org.jetbrains.annotations.Nullable; + +@lombok.Data +@lombok.Builder +@lombok.NoArgsConstructor +@lombok.AllArgsConstructor +public class EncryptionSettingsRequest { + + @Nullable + @JsonProperty("enabled") + private Boolean enabled; +} diff --git a/src/main/java/io/getstream/models/EncryptionSettingsResponse.java b/src/main/java/io/getstream/models/EncryptionSettingsResponse.java new file mode 100644 index 0000000..826c860 --- /dev/null +++ b/src/main/java/io/getstream/models/EncryptionSettingsResponse.java @@ -0,0 +1,26 @@ +/* + * ======================================================================== + * WARNING: GENERATED CODE -- DO NOT EDIT! + * ======================================================================== + * + * This file was auto-generated by GetStream internal OpenAPI + * + * Any modifications to this file will be lost upon regeneration. + * To make changes, please modify the source templates and regenerate. + * + * ======================================================================== + */ +package io.getstream.models; + +import com.fasterxml.jackson.annotation.JsonProperty; + +/** EncryptionSettings is the payload for end-to-end encryption settings */ +@lombok.Data +@lombok.Builder +@lombok.NoArgsConstructor +@lombok.AllArgsConstructor +public class EncryptionSettingsResponse { + + @JsonProperty("enabled") + private Boolean enabled; +} diff --git a/src/main/java/io/getstream/models/FloodIdenticalRuleParameters.java b/src/main/java/io/getstream/models/FloodIdenticalRuleParameters.java new file mode 100644 index 0000000..601bd4b --- /dev/null +++ b/src/main/java/io/getstream/models/FloodIdenticalRuleParameters.java @@ -0,0 +1,31 @@ +/* + * ======================================================================== + * WARNING: GENERATED CODE -- DO NOT EDIT! + * ======================================================================== + * + * This file was auto-generated by GetStream internal OpenAPI + * + * Any modifications to this file will be lost upon regeneration. + * To make changes, please modify the source templates and regenerate. + * + * ======================================================================== + */ +package io.getstream.models; + +import com.fasterxml.jackson.annotation.JsonProperty; +import org.jetbrains.annotations.Nullable; + +@lombok.Data +@lombok.Builder +@lombok.NoArgsConstructor +@lombok.AllArgsConstructor +public class FloodIdenticalRuleParameters { + + @Nullable + @JsonProperty("threshold") + private Integer threshold; + + @Nullable + @JsonProperty("time_window") + private String timeWindow; +} diff --git a/src/main/java/io/getstream/models/FloodSimilarRuleParameters.java b/src/main/java/io/getstream/models/FloodSimilarRuleParameters.java new file mode 100644 index 0000000..01f7c79 --- /dev/null +++ b/src/main/java/io/getstream/models/FloodSimilarRuleParameters.java @@ -0,0 +1,35 @@ +/* + * ======================================================================== + * WARNING: GENERATED CODE -- DO NOT EDIT! + * ======================================================================== + * + * This file was auto-generated by GetStream internal OpenAPI + * + * Any modifications to this file will be lost upon regeneration. + * To make changes, please modify the source templates and regenerate. + * + * ======================================================================== + */ +package io.getstream.models; + +import com.fasterxml.jackson.annotation.JsonProperty; +import org.jetbrains.annotations.Nullable; + +@lombok.Data +@lombok.Builder +@lombok.NoArgsConstructor +@lombok.AllArgsConstructor +public class FloodSimilarRuleParameters { + + @Nullable + @JsonProperty("similarity_distance") + private Integer similarityDistance; + + @Nullable + @JsonProperty("threshold") + private Integer threshold; + + @Nullable + @JsonProperty("time_window") + private String timeWindow; +} diff --git a/src/main/java/io/getstream/models/GetActivityRequest.java b/src/main/java/io/getstream/models/GetActivityRequest.java index d96ecca..5b3fc7f 100644 --- a/src/main/java/io/getstream/models/GetActivityRequest.java +++ b/src/main/java/io/getstream/models/GetActivityRequest.java @@ -22,14 +22,6 @@ @lombok.AllArgsConstructor public class GetActivityRequest { - @Query("language") - @JsonIgnore - private String Language; - - @Query("translate_text") - @JsonIgnore - private Boolean TranslateText; - @Query("comment_sort") @JsonIgnore private String CommentSort; @@ -41,4 +33,12 @@ public class GetActivityRequest { @Query("user_id") @JsonIgnore private String UserID; + + @Query("language") + @JsonIgnore + private String Language; + + @Query("translate_text") + @JsonIgnore + private Boolean TranslateText; } diff --git a/src/main/java/io/getstream/models/GetCommentRequest.java b/src/main/java/io/getstream/models/GetCommentRequest.java index 31bc08e..1c75f12 100644 --- a/src/main/java/io/getstream/models/GetCommentRequest.java +++ b/src/main/java/io/getstream/models/GetCommentRequest.java @@ -22,6 +22,10 @@ @lombok.AllArgsConstructor public class GetCommentRequest { + @Query("user_id") + @JsonIgnore + private String UserID; + @Query("language") @JsonIgnore private String Language; @@ -29,8 +33,4 @@ public class GetCommentRequest { @Query("translate_text") @JsonIgnore private Boolean TranslateText; - - @Query("user_id") - @JsonIgnore - private String UserID; } diff --git a/src/main/java/io/getstream/models/IPContentCountRuleParameters.java b/src/main/java/io/getstream/models/IPContentCountRuleParameters.java new file mode 100644 index 0000000..e4de023 --- /dev/null +++ b/src/main/java/io/getstream/models/IPContentCountRuleParameters.java @@ -0,0 +1,31 @@ +/* + * ======================================================================== + * WARNING: GENERATED CODE -- DO NOT EDIT! + * ======================================================================== + * + * This file was auto-generated by GetStream internal OpenAPI + * + * Any modifications to this file will be lost upon regeneration. + * To make changes, please modify the source templates and regenerate. + * + * ======================================================================== + */ +package io.getstream.models; + +import com.fasterxml.jackson.annotation.JsonProperty; +import org.jetbrains.annotations.Nullable; + +@lombok.Data +@lombok.Builder +@lombok.NoArgsConstructor +@lombok.AllArgsConstructor +public class IPContentCountRuleParameters { + + @Nullable + @JsonProperty("threshold") + private Integer threshold; + + @Nullable + @JsonProperty("time_window") + private String timeWindow; +} diff --git a/src/main/java/io/getstream/models/IPFlagCountRuleParameters.java b/src/main/java/io/getstream/models/IPFlagCountRuleParameters.java new file mode 100644 index 0000000..1d73899 --- /dev/null +++ b/src/main/java/io/getstream/models/IPFlagCountRuleParameters.java @@ -0,0 +1,40 @@ +/* + * ======================================================================== + * WARNING: GENERATED CODE -- DO NOT EDIT! + * ======================================================================== + * + * This file was auto-generated by GetStream internal OpenAPI + * + * Any modifications to this file will be lost upon regeneration. + * To make changes, please modify the source templates and regenerate. + * + * ======================================================================== + */ +package io.getstream.models; + +import com.fasterxml.jackson.annotation.JsonProperty; +import java.util.List; +import org.jetbrains.annotations.Nullable; + +@lombok.Data +@lombok.Builder +@lombok.NoArgsConstructor +@lombok.AllArgsConstructor +public class IPFlagCountRuleParameters { + + @Nullable + @JsonProperty("severity") + private String severity; + + @Nullable + @JsonProperty("threshold") + private Integer threshold; + + @Nullable + @JsonProperty("time_window") + private String timeWindow; + + @Nullable + @JsonProperty("harm_labels") + private List harmLabels; +} diff --git a/src/main/java/io/getstream/models/ImportBlockListRequest.java b/src/main/java/io/getstream/models/ImportBlockListRequest.java new file mode 100644 index 0000000..4ca4a4b --- /dev/null +++ b/src/main/java/io/getstream/models/ImportBlockListRequest.java @@ -0,0 +1,38 @@ +/* + * ======================================================================== + * WARNING: GENERATED CODE -- DO NOT EDIT! + * ======================================================================== + * + * This file was auto-generated by GetStream internal OpenAPI + * + * Any modifications to this file will be lost upon regeneration. + * To make changes, please modify the source templates and regenerate. + * + * ======================================================================== + */ +package io.getstream.models; + +import com.fasterxml.jackson.annotation.JsonProperty; +import java.util.List; +import org.jetbrains.annotations.Nullable; + +/** + * Import block list items Enqueues an asynchronous bulk import of items into an existing blocklist. + * Returns a task ID that can be polled via GET /tasks/{id} to observe progress. AddItems is + * idempotent: items already present are skipped without error. For lists exceeding the HTTP + * request-body cap, issue repeated import calls each carrying a bounded slice of items — the task + * result accumulates correctly. + */ +@lombok.Data +@lombok.Builder +@lombok.NoArgsConstructor +@lombok.AllArgsConstructor +public class ImportBlockListRequest { + + @JsonProperty("items") + private List items; + + @Nullable + @JsonProperty("chunk_size") + private Integer chunkSize; +} diff --git a/src/main/java/io/getstream/models/ImportBlockListResponse.java b/src/main/java/io/getstream/models/ImportBlockListResponse.java new file mode 100644 index 0000000..c12d105 --- /dev/null +++ b/src/main/java/io/getstream/models/ImportBlockListResponse.java @@ -0,0 +1,29 @@ +/* + * ======================================================================== + * WARNING: GENERATED CODE -- DO NOT EDIT! + * ======================================================================== + * + * This file was auto-generated by GetStream internal OpenAPI + * + * Any modifications to this file will be lost upon regeneration. + * To make changes, please modify the source templates and regenerate. + * + * ======================================================================== + */ +package io.getstream.models; + +import com.fasterxml.jackson.annotation.JsonProperty; + +/** Basic response information */ +@lombok.Data +@lombok.Builder +@lombok.NoArgsConstructor +@lombok.AllArgsConstructor +public class ImportBlockListResponse { + + @JsonProperty("duration") + private String duration; + + @JsonProperty("task_id") + private String taskID; +} diff --git a/src/main/java/io/getstream/models/ImportV2TaskSettings.java b/src/main/java/io/getstream/models/ImportV2TaskSettings.java index 6da2fb5..9ad1ba0 100644 --- a/src/main/java/io/getstream/models/ImportV2TaskSettings.java +++ b/src/main/java/io/getstream/models/ImportV2TaskSettings.java @@ -37,10 +37,6 @@ public class ImportV2TaskSettings { @JsonProperty("skip_references_check") private Boolean skipReferencesCheck; - @Nullable - @JsonProperty("source") - private String source; - @Nullable @JsonProperty("use_import_time_as_op_time") private Boolean useImportTimeAsOpTime; diff --git a/src/main/java/io/getstream/models/ListBlockListResponse.java b/src/main/java/io/getstream/models/ListBlockListResponse.java index 51ae20b..23723f6 100644 --- a/src/main/java/io/getstream/models/ListBlockListResponse.java +++ b/src/main/java/io/getstream/models/ListBlockListResponse.java @@ -14,6 +14,7 @@ import com.fasterxml.jackson.annotation.JsonProperty; import java.util.List; +import org.jetbrains.annotations.Nullable; /** Basic response information */ @lombok.Data @@ -27,4 +28,8 @@ public class ListBlockListResponse { @JsonProperty("blocklists") private List blocklists; + + @Nullable + @JsonProperty("next_cursor") + private String nextCursor; } diff --git a/src/main/java/io/getstream/models/ListBlockListsRequest.java b/src/main/java/io/getstream/models/ListBlockListsRequest.java index 2a78108..41a8f97 100644 --- a/src/main/java/io/getstream/models/ListBlockListsRequest.java +++ b/src/main/java/io/getstream/models/ListBlockListsRequest.java @@ -25,4 +25,12 @@ public class ListBlockListsRequest { @Query("team") @JsonIgnore private String Team; + + @Query("cursor") + @JsonIgnore + private String Cursor; + + @Query("limit") + @JsonIgnore + private Integer Limit; } diff --git a/src/main/java/io/getstream/models/MessageResponse.java b/src/main/java/io/getstream/models/MessageResponse.java index 0d1f389..0f98329 100644 --- a/src/main/java/io/getstream/models/MessageResponse.java +++ b/src/main/java/io/getstream/models/MessageResponse.java @@ -168,7 +168,7 @@ public class MessageResponse { @Nullable @JsonProperty("member") - private ChannelMemberResponse member; + private ChannelMemberPartialResponse member; @Nullable @JsonProperty("moderation") diff --git a/src/main/java/io/getstream/models/MessageWithChannelResponse.java b/src/main/java/io/getstream/models/MessageWithChannelResponse.java index ceeb9ee..8b378e0 100644 --- a/src/main/java/io/getstream/models/MessageWithChannelResponse.java +++ b/src/main/java/io/getstream/models/MessageWithChannelResponse.java @@ -171,7 +171,7 @@ public class MessageWithChannelResponse { @Nullable @JsonProperty("member") - private ChannelMemberResponse member; + private ChannelMemberPartialResponse member; @Nullable @JsonProperty("moderation") diff --git a/src/main/java/io/getstream/models/RuleBuilderCondition.java b/src/main/java/io/getstream/models/RuleBuilderCondition.java index d611b62..7ef478f 100644 --- a/src/main/java/io/getstream/models/RuleBuilderCondition.java +++ b/src/main/java/io/getstream/models/RuleBuilderCondition.java @@ -65,6 +65,14 @@ public class RuleBuilderCondition { @JsonProperty("content_flag_count_rule_params") private FlagCountRuleParameters contentFlagCountRuleParams; + @Nullable + @JsonProperty("flood_identical_params") + private FloodIdenticalRuleParameters floodIdenticalParams; + + @Nullable + @JsonProperty("flood_similar_params") + private FloodSimilarRuleParameters floodSimilarParams; + @Nullable @JsonProperty("image_content_params") private ImageContentParameters imageContentParams; @@ -73,6 +81,14 @@ public class RuleBuilderCondition { @JsonProperty("image_rule_params") private ImageRuleParameters imageRuleParams; + @Nullable + @JsonProperty("ip_content_count_rule_params") + private IPContentCountRuleParameters ipContentCountRuleParams; + + @Nullable + @JsonProperty("ip_flag_count_rule_params") + private IPFlagCountRuleParameters ipFlagCountRuleParams; + @Nullable @JsonProperty("keyframe_ocr_rule_params") private KeyframeOCRRuleParameters keyframeOcrRuleParams; diff --git a/src/main/java/io/getstream/models/SearchResultMessage.java b/src/main/java/io/getstream/models/SearchResultMessage.java index 2bc5c3e..99191e8 100644 --- a/src/main/java/io/getstream/models/SearchResultMessage.java +++ b/src/main/java/io/getstream/models/SearchResultMessage.java @@ -171,7 +171,7 @@ public class SearchResultMessage { @Nullable @JsonProperty("member") - private ChannelMemberResponse member; + private ChannelMemberPartialResponse member; @Nullable @JsonProperty("moderation") diff --git a/src/main/java/io/getstream/models/UpdateAppRequest.java b/src/main/java/io/getstream/models/UpdateAppRequest.java index e5d2b30..6ac6bc3 100644 --- a/src/main/java/io/getstream/models/UpdateAppRequest.java +++ b/src/main/java/io/getstream/models/UpdateAppRequest.java @@ -49,6 +49,10 @@ public class UpdateAppRequest { @JsonProperty("channel_hide_members_only") private Boolean channelHideMembersOnly; + @Nullable + @JsonProperty("chat_primary_use_case") + private String chatPrimaryUseCase; + @Nullable @JsonProperty("custom_action_handler_url") private String customActionHandlerUrl; diff --git a/src/main/java/io/getstream/services/ChatImpl.java b/src/main/java/io/getstream/services/ChatImpl.java index 6045b04..76649e1 100644 --- a/src/main/java/io/getstream/services/ChatImpl.java +++ b/src/main/java/io/getstream/services/ChatImpl.java @@ -32,9 +32,7 @@ public StreamRequest createCampaign(CreateCampaignReques throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/campaigns", request, @@ -47,9 +45,7 @@ public StreamRequest queryCampaigns(QueryCampaignsReques throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/campaigns/query", request, @@ -68,9 +64,7 @@ public StreamRequest deleteCampaign( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/chat/campaigns/{id}", request, @@ -90,9 +84,7 @@ public StreamRequest getCampaign( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/chat/campaigns/{id}", request, @@ -111,9 +103,7 @@ public StreamRequest updateCampaign( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PUT", "/api/v2/chat/campaigns/{id}", request, @@ -127,9 +117,7 @@ public StreamRequest startCampaign( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/campaigns/{id}/start", request, @@ -149,9 +137,7 @@ public StreamRequest stopCampaign( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/campaigns/{id}/stop", request, @@ -169,9 +155,7 @@ public StreamRequest queryChannels(QueryChannelsRequest r throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/channels", request, @@ -189,9 +173,7 @@ public StreamRequest channelBatchUpdate( ChannelBatchUpdateRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PUT", "/api/v2/chat/channels/batch", request, @@ -204,9 +186,7 @@ public StreamRequest deleteChannels(DeleteChannelsReques throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/channels/delete", request, @@ -219,9 +199,7 @@ public StreamRequest markDelivered(MarkDeliveredRequest r throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/channels/delivered", request, @@ -239,9 +217,7 @@ public StreamRequest groupedQueryChannels( GroupedQueryChannelsRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/channels/grouped", request, @@ -259,9 +235,7 @@ public StreamRequest markChannelsRead(MarkChannelsReadRequest throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/channels/read", request, @@ -280,9 +254,7 @@ public StreamRequest getOrCreateDistinctChannel( var pathParams = Map.of("type", type); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/channels/{type}/query", request, @@ -306,9 +278,7 @@ public StreamRequest deleteChannel( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/chat/channels/{type}/{id}", request, @@ -331,9 +301,7 @@ public StreamRequest getChannel( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/chat/channels/{type}/{id}", request, @@ -357,9 +325,7 @@ public StreamRequest updateChannelPartial( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PATCH", "/api/v2/chat/channels/{type}/{id}", request, @@ -383,9 +349,7 @@ public StreamRequest updateChannel( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/channels/{type}/{id}", request, @@ -408,9 +372,7 @@ public StreamRequest deleteDraft( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/chat/channels/{type}/{id}/draft", request, @@ -433,9 +395,7 @@ public StreamRequest getDraft( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/chat/channels/{type}/{id}/draft", request, @@ -458,9 +418,7 @@ public StreamRequest sendEvent( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/channels/{type}/{id}/event", request, @@ -478,9 +436,7 @@ public StreamRequest deleteChannelFile( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/chat/channels/{type}/{id}/file", request, @@ -504,9 +460,7 @@ public StreamRequest uploadChannelFile( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/channels/{type}/{id}/file", request, @@ -529,9 +483,7 @@ public StreamRequest hideChannel( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/channels/{type}/{id}/hide", request, @@ -555,9 +507,7 @@ public StreamRequest deleteChannelImage( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/chat/channels/{type}/{id}/image", request, @@ -581,9 +531,7 @@ public StreamRequest uploadChannelImage( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/channels/{type}/{id}/image", request, @@ -607,9 +555,7 @@ public StreamRequest updateMemberPartial( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PATCH", "/api/v2/chat/channels/{type}/{id}/member", request, @@ -632,9 +578,7 @@ public StreamRequest sendMessage( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/channels/{type}/{id}/message", request, @@ -652,9 +596,7 @@ public StreamRequest getManyMessages( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/chat/channels/{type}/{id}/messages", request, @@ -672,9 +614,7 @@ public StreamRequest getOrCreateChannel( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/channels/{type}/{id}/query", request, @@ -697,9 +637,7 @@ public StreamRequest markRead( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/channels/{type}/{id}/read", request, @@ -722,9 +660,7 @@ public StreamRequest showChannel( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/channels/{type}/{id}/show", request, @@ -748,9 +684,7 @@ public StreamRequest truncateChannel( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/channels/{type}/{id}/truncate", request, @@ -773,9 +707,7 @@ public StreamRequest markUnread( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/channels/{type}/{id}/unread", request, @@ -794,9 +726,7 @@ public StreamRequest listChannelTypes(ListChannelTypes throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/chat/channeltypes", request, @@ -814,9 +744,7 @@ public StreamRequest createChannelType( CreateChannelTypeRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/channeltypes", request, @@ -830,9 +758,7 @@ public StreamRequest deleteChannelType( var pathParams = Map.of("name", name); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/chat/channeltypes/{name}", request, @@ -851,9 +777,7 @@ public StreamRequest getChannelType( var pathParams = Map.of("name", name); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/chat/channeltypes/{name}", request, @@ -873,9 +797,7 @@ public StreamRequest updateChannelType( var pathParams = Map.of("name", name); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PUT", "/api/v2/chat/channeltypes/{name}", request, @@ -888,9 +810,7 @@ public StreamRequest listCommands(ListCommandsRequest requ throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/chat/commands", request, @@ -908,9 +828,7 @@ public StreamRequest createCommand(CreateCommandRequest r throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/commands", request, @@ -924,9 +842,7 @@ public StreamRequest deleteCommand( var pathParams = Map.of("name", name); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/chat/commands/{name}", request, @@ -946,9 +862,7 @@ public StreamRequest getCommand( var pathParams = Map.of("name", name); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/chat/commands/{name}", request, @@ -967,9 +881,7 @@ public StreamRequest updateCommand( var pathParams = Map.of("name", name); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PUT", "/api/v2/chat/commands/{name}", request, @@ -982,9 +894,7 @@ public StreamRequest queryDrafts(QueryDraftsRequest request throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/drafts/query", request, @@ -1002,9 +912,7 @@ public StreamRequest exportChannels(ExportChannelsReques throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/export_channels", request, @@ -1017,9 +925,7 @@ public StreamRequest queryMembers(QueryMembersRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/chat/members", request, @@ -1037,9 +943,7 @@ public StreamRequest queryMessageHistory( QueryMessageHistoryRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/messages/history", request, @@ -1053,9 +957,7 @@ public StreamRequest deleteMessage( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/chat/messages/{id}", request, @@ -1075,9 +977,7 @@ public StreamRequest getMessage(@NotNull String id, GetMessa var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/chat/messages/{id}", request, @@ -1096,9 +996,7 @@ public StreamRequest updateMessage( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/messages/{id}", request, @@ -1112,9 +1010,7 @@ public StreamRequest updateMessagePartial( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PUT", "/api/v2/chat/messages/{id}", request, @@ -1134,9 +1030,7 @@ public StreamRequest runMessageAction( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/messages/{id}/action", request, @@ -1150,9 +1044,7 @@ public StreamRequest commitMessage( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/messages/{id}/commit", request, @@ -1172,9 +1064,7 @@ public StreamRequest ephemeralMessageUpdate( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PATCH", "/api/v2/chat/messages/{id}/ephemeral", request, @@ -1194,9 +1084,7 @@ public StreamRequest sendReaction( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/messages/{id}/reaction", request, @@ -1214,9 +1102,7 @@ public StreamRequest deleteReaction( "type", type); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/chat/messages/{id}/reaction/{type}", request, @@ -1236,9 +1122,7 @@ public StreamRequest getReactions( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/chat/messages/{id}/reactions", request, @@ -1258,9 +1142,7 @@ public StreamRequest queryReactions( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/messages/{id}/reactions", request, @@ -1280,9 +1162,7 @@ public StreamRequest translateMessage( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/messages/{id}/translate", request, @@ -1296,9 +1176,7 @@ public StreamRequest undeleteMessage( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/messages/{id}/undelete", request, @@ -1316,9 +1194,7 @@ public StreamRequest castPollVote( "poll_id", pollID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/messages/{message_id}/polls/{poll_id}/vote", request, @@ -1346,9 +1222,7 @@ public StreamRequest deletePollVote( "vote_id", voteID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/chat/messages/{message_id}/polls/{poll_id}/vote/{vote_id}", request, @@ -1369,9 +1243,7 @@ public StreamRequest deleteReminder( var pathParams = Map.of("message_id", messageID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/chat/messages/{message_id}/reminders", request, @@ -1391,9 +1263,7 @@ public StreamRequest updateReminder( var pathParams = Map.of("message_id", messageID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PATCH", "/api/v2/chat/messages/{message_id}/reminders", request, @@ -1413,9 +1283,7 @@ public StreamRequest createReminder( var pathParams = Map.of("message_id", messageID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/messages/{message_id}/reminders", request, @@ -1435,9 +1303,7 @@ public StreamRequest getReplies( var pathParams = Map.of("parent_id", parentID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/chat/messages/{parent_id}/replies", request, @@ -1456,9 +1322,7 @@ public StreamRequest queryMessageFlags( QueryMessageFlagsRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/chat/moderation/flags/message", request, @@ -1476,9 +1340,7 @@ public StreamRequest muteChannel(MuteChannelRequest request throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/moderation/mute/channel", request, @@ -1496,9 +1358,7 @@ public StreamRequest unmuteChannel(UnmuteChannelRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/moderation/unmute/channel", request, @@ -1516,9 +1376,7 @@ public StreamRequest queryBannedUsers(QueryBannedUsers throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/chat/query_banned_users", request, @@ -1536,9 +1394,7 @@ public StreamRequest queryFutureChannelBans( QueryFutureChannelBansRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/chat/query_future_channel_bans", request, @@ -1557,9 +1413,7 @@ public StreamRequest queryReminders(QueryRemindersReques throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/reminders/query", request, @@ -1577,9 +1431,7 @@ public StreamRequest getRetentionPolicy( GetRetentionPolicyRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/chat/retention_policy", request, @@ -1597,9 +1449,7 @@ public StreamRequest setRetentionPolicy( SetRetentionPolicyRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/retention_policy", request, @@ -1612,9 +1462,7 @@ public StreamRequest deleteRetentionPolicy( DeleteRetentionPolicyRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/retention_policy/delete", request, @@ -1627,9 +1475,7 @@ public StreamRequest getRetentionPolicyRuns( GetRetentionPolicyRunsRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/retention_policy/runs", request, @@ -1647,9 +1493,7 @@ public StreamRequest getRetentionPolicyRuns() public StreamRequest search(SearchRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/chat/search", request, @@ -1667,9 +1511,7 @@ public StreamRequest createSegment(CreateSegmentRequest r throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/segments", request, @@ -1682,9 +1524,7 @@ public StreamRequest querySegments(QuerySegmentsRequest r throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/segments/query", request, @@ -1698,9 +1538,7 @@ public StreamRequest deleteSegment(@NotNull String id, DeleteSegmentRe var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/chat/segments/{id}", request, @@ -1719,9 +1557,7 @@ public StreamRequest getSegment(@NotNull String id, GetSegme var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/chat/segments/{id}", request, @@ -1740,9 +1576,7 @@ public StreamRequest updateSegment( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PUT", "/api/v2/chat/segments/{id}", request, @@ -1762,9 +1596,7 @@ public StreamRequest addSegmentTargets( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/segments/{id}/addtargets", request, @@ -1778,9 +1610,7 @@ public StreamRequest deleteSegmentTargets( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/segments/{id}/deletetargets", request, @@ -1798,9 +1628,7 @@ public StreamRequest segmentTargetExists( "target_id", targetID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/chat/segments/{id}/target/{target_id}", request, @@ -1820,9 +1648,7 @@ public StreamRequest querySegmentTargets( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/segments/{id}/targets/query", request, @@ -1841,9 +1667,7 @@ public StreamRequest queryTeamUsageStats( QueryTeamUsageStatsRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/stats/team_usage", request, @@ -1861,9 +1685,7 @@ public StreamRequest queryThreads(QueryThreadsRequest requ throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/threads", request, @@ -1882,9 +1704,7 @@ public StreamRequest getThread( var pathParams = Map.of("message_id", messageID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/chat/threads/{message_id}", request, @@ -1904,9 +1724,7 @@ public StreamRequest updateThreadPartial( var pathParams = Map.of("message_id", messageID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PATCH", "/api/v2/chat/threads/{message_id}", request, @@ -1925,9 +1743,7 @@ public StreamRequest unreadCounts(UnreadCountsReque throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/chat/unread", request, @@ -1945,9 +1761,7 @@ public StreamRequest unreadCountsBatch( UnreadCountsBatchRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/unread_batch", request, @@ -1961,9 +1775,7 @@ public StreamRequest sendUserCustomEvent( var pathParams = Map.of("user_id", userID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/chat/users/{user_id}/event", request, diff --git a/src/main/java/io/getstream/services/Common.java b/src/main/java/io/getstream/services/Common.java index a319d3f..71367d7 100644 --- a/src/main/java/io/getstream/services/Common.java +++ b/src/main/java/io/getstream/services/Common.java @@ -45,6 +45,10 @@ public StreamRequest listBlockLists(ListBlockListsRequest public StreamRequest createBlockList(CreateBlockListRequest request) throws StreamException; + @NotNull + public StreamRequest importBlockList( + @NotNull String id, ImportBlockListRequest request) throws StreamException; + @NotNull public StreamRequest deleteBlockList( @NotNull String name, DeleteBlockListRequest request) throws StreamException; @@ -168,34 +172,6 @@ public StreamRequest listImportV2Tasks( public StreamRequest createImportV2Task( CreateImportV2TaskRequest request) throws StreamException; - @NotNull - public StreamRequest deleteImporterExternalStorage( - DeleteImporterExternalStorageRequest request) throws StreamException; - - @NotNull - public StreamRequest deleteImporterExternalStorage() - throws StreamException; - - @NotNull - public StreamRequest getImporterExternalStorage( - GetImporterExternalStorageRequest request) throws StreamException; - - @NotNull - public StreamRequest getImporterExternalStorage() - throws StreamException; - - @NotNull - public StreamRequest upsertImporterExternalStorage( - UpsertImporterExternalStorageRequest request) throws StreamException; - - @NotNull - public StreamRequest validateImporterExternalStorage( - ValidateImporterExternalStorageRequest request) throws StreamException; - - @NotNull - public StreamRequest validateImporterExternalStorage() - throws StreamException; - @NotNull public StreamRequest deleteImportV2Task( @NotNull String id, DeleteImportV2TaskRequest request) throws StreamException; diff --git a/src/main/java/io/getstream/services/CommonImpl.java b/src/main/java/io/getstream/services/CommonImpl.java index 97a47bc..93d41dd 100644 --- a/src/main/java/io/getstream/services/CommonImpl.java +++ b/src/main/java/io/getstream/services/CommonImpl.java @@ -32,9 +32,7 @@ public StreamRequest getApp(GetAppRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/app", request, @@ -51,14 +49,7 @@ public StreamRequest getApp() throws StreamException { public StreamRequest updateApp(UpdateAppRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), - "PATCH", - "/api/v2/app", - request, - null, - new TypeReference() {}); + client, "PATCH", "/api/v2/app", request, null, new TypeReference() {}); } @NotNull @@ -71,9 +62,7 @@ public StreamRequest listBlockLists(ListBlockListsRequest throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/blocklists", request, @@ -91,9 +80,7 @@ public StreamRequest createBlockList(CreateBlockListReq throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/blocklists", request, @@ -101,15 +88,27 @@ public StreamRequest createBlockList(CreateBlockListReq new TypeReference() {}); } + @NotNull + public StreamRequest importBlockList( + @NotNull String id, ImportBlockListRequest request) throws StreamException { + var pathParams = Map.of("id", id); + + return new StreamRequest( + client, + "POST", + "/api/v2/blocklists/{id}/import", + request, + pathParams, + new TypeReference() {}); + } + @NotNull public StreamRequest deleteBlockList( @NotNull String name, DeleteBlockListRequest request) throws StreamException { var pathParams = Map.of("name", name); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/blocklists/{name}", request, @@ -128,9 +127,7 @@ public StreamRequest getBlockList( var pathParams = Map.of("name", name); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/blocklists/{name}", request, @@ -150,9 +147,7 @@ public StreamRequest updateBlockList( var pathParams = Map.of("name", name); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PUT", "/api/v2/blocklists/{name}", request, @@ -171,9 +166,7 @@ public StreamRequest checkPush(CheckPushRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/check_push", request, @@ -190,9 +183,7 @@ public StreamRequest checkPush() throws StreamException { public StreamRequest checkSNS(CheckSNSRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/check_sns", request, @@ -209,9 +200,7 @@ public StreamRequest checkSNS() throws StreamException { public StreamRequest checkSQS(CheckSQSRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/check_sqs", request, @@ -228,14 +217,7 @@ public StreamRequest checkSQS() throws StreamException { public StreamRequest deleteDevice(DeleteDeviceRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), - "DELETE", - "/api/v2/devices", - request, - null, - new TypeReference() {}); + client, "DELETE", "/api/v2/devices", request, null, new TypeReference() {}); } @NotNull @@ -243,9 +225,7 @@ public StreamRequest listDevices(ListDevicesRequest request throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/devices", request, @@ -262,14 +242,7 @@ public StreamRequest listDevices() throws StreamException { public StreamRequest createDevice(CreateDeviceRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), - "POST", - "/api/v2/devices", - request, - null, - new TypeReference() {}); + client, "POST", "/api/v2/devices", request, null, new TypeReference() {}); } @NotNull @@ -277,9 +250,7 @@ public StreamRequest exportUsers(ExportUsersRequest request throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/export/users", request, @@ -292,9 +263,7 @@ public StreamRequest listExternalStorage( ListExternalStorageRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/external_storage", request, @@ -312,9 +281,7 @@ public StreamRequest createExternalStorage( CreateExternalStorageRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/external_storage", request, @@ -328,9 +295,7 @@ public StreamRequest deleteExternalStorage( var pathParams = Map.of("name", name); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/external_storage/{name}", request, @@ -350,9 +315,7 @@ public StreamRequest updateExternalStorage( var pathParams = Map.of("name", name); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PUT", "/api/v2/external_storage/{name}", request, @@ -366,9 +329,7 @@ public StreamRequest checkExternalStorage( var pathParams = Map.of("name", name); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/external_storage/{name}/check", request, @@ -387,9 +348,7 @@ public StreamRequest createGuest(CreateGuestRequest request throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/guest", request, @@ -402,9 +361,7 @@ public StreamRequest createImportURL(CreateImportURLReq throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/import_urls", request, @@ -422,9 +379,7 @@ public StreamRequest listImports(ListImportsRequest request throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/imports", request, @@ -442,9 +397,7 @@ public StreamRequest createImport(CreateImportRequest requ throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/imports", request, @@ -457,9 +410,7 @@ public StreamRequest listImportV2Tasks( ListImportV2TasksRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/imports/v2", request, @@ -477,9 +428,7 @@ public StreamRequest createImportV2Task( CreateImportV2TaskRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/imports/v2", request, @@ -487,93 +436,13 @@ public StreamRequest createImportV2Task( new TypeReference() {}); } - @NotNull - public StreamRequest deleteImporterExternalStorage( - DeleteImporterExternalStorageRequest request) throws StreamException { - - return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), - "DELETE", - "/api/v2/imports/v2/external-storage", - request, - null, - new TypeReference() {}); - } - - @NotNull - public StreamRequest deleteImporterExternalStorage() - throws StreamException { - return deleteImporterExternalStorage(new DeleteImporterExternalStorageRequest()); - } - - @NotNull - public StreamRequest getImporterExternalStorage( - GetImporterExternalStorageRequest request) throws StreamException { - - return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), - "GET", - "/api/v2/imports/v2/external-storage", - request, - null, - new TypeReference() {}); - } - - @NotNull - public StreamRequest getImporterExternalStorage() - throws StreamException { - return getImporterExternalStorage(new GetImporterExternalStorageRequest()); - } - - @NotNull - public StreamRequest upsertImporterExternalStorage( - UpsertImporterExternalStorageRequest request) throws StreamException { - - return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), - "PUT", - "/api/v2/imports/v2/external-storage", - request, - null, - new TypeReference() {}); - } - - @NotNull - public StreamRequest validateImporterExternalStorage( - ValidateImporterExternalStorageRequest request) throws StreamException { - - return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), - "POST", - "/api/v2/imports/v2/external-storage/validate", - request, - null, - new TypeReference() {}); - } - - @NotNull - public StreamRequest validateImporterExternalStorage() - throws StreamException { - return validateImporterExternalStorage(new ValidateImporterExternalStorageRequest()); - } - @NotNull public StreamRequest deleteImportV2Task( @NotNull String id, DeleteImportV2TaskRequest request) throws StreamException { var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/imports/v2/{id}", request, @@ -593,9 +462,7 @@ public StreamRequest getImportV2Task( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/imports/v2/{id}", request, @@ -615,9 +482,7 @@ public StreamRequest cancelImportV2Task( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/imports/v2/{id}/cancel", request, @@ -637,9 +502,7 @@ public StreamRequest getImport(@NotNull String id, GetImportR var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/imports/{id}", request, @@ -656,14 +519,7 @@ public StreamRequest getImport(@NotNull String id) throws Str public StreamRequest getOG(GetOGRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), - "GET", - "/api/v2/og", - request, - null, - new TypeReference() {}); + client, "GET", "/api/v2/og", request, null, new TypeReference() {}); } @NotNull @@ -671,9 +527,7 @@ public StreamRequest listPermissions(ListPermissionsReq throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/permissions", request, @@ -692,9 +546,7 @@ public StreamRequest getPermission( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/permissions/{id}", request, @@ -712,28 +564,14 @@ public StreamRequest getPermission(@NotNull String public StreamRequest createPoll(CreatePollRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), - "POST", - "/api/v2/polls", - request, - null, - new TypeReference() {}); + client, "POST", "/api/v2/polls", request, null, new TypeReference() {}); } @NotNull public StreamRequest updatePoll(UpdatePollRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), - "PUT", - "/api/v2/polls", - request, - null, - new TypeReference() {}); + client, "PUT", "/api/v2/polls", request, null, new TypeReference() {}); } @NotNull @@ -741,9 +579,7 @@ public StreamRequest queryPolls(QueryPollsRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/polls/query", request, @@ -762,9 +598,7 @@ public StreamRequest deletePoll(@NotNull String pollID, DeletePollRequ var pathParams = Map.of("poll_id", pollID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/polls/{poll_id}", request, @@ -783,9 +617,7 @@ public StreamRequest getPoll(@NotNull String pollID, GetPollReques var pathParams = Map.of("poll_id", pollID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/polls/{poll_id}", request, @@ -804,9 +636,7 @@ public StreamRequest updatePollPartial( var pathParams = Map.of("poll_id", pollID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PATCH", "/api/v2/polls/{poll_id}", request, @@ -826,9 +656,7 @@ public StreamRequest createPollOption( var pathParams = Map.of("poll_id", pollID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/polls/{poll_id}/options", request, @@ -842,9 +670,7 @@ public StreamRequest updatePollOption( var pathParams = Map.of("poll_id", pollID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PUT", "/api/v2/polls/{poll_id}/options", request, @@ -862,9 +688,7 @@ public StreamRequest deletePollOption( "option_id", optionID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/polls/{poll_id}/options/{option_id}", request, @@ -888,9 +712,7 @@ public StreamRequest getPollOption( "option_id", optionID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/polls/{poll_id}/options/{option_id}", request, @@ -910,9 +732,7 @@ public StreamRequest queryPollVotes( var pathParams = Map.of("poll_id", pollID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/polls/{poll_id}/votes", request, @@ -931,9 +751,7 @@ public StreamRequest updatePushNotificationPrefer UpdatePushNotificationPreferencesRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/push_preferences", request, @@ -946,9 +764,7 @@ public StreamRequest listPushProviders( ListPushProvidersRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/push_providers", request, @@ -966,9 +782,7 @@ public StreamRequest upsertPushProvider( UpsertPushProviderRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/push_providers", request, @@ -991,9 +805,7 @@ public StreamRequest deletePushProvider( "name", name); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/push_providers/{type}/{name}", request, @@ -1012,9 +824,7 @@ public StreamRequest getPushTemplates(GetPushTemplates throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/push_templates", request, @@ -1027,9 +837,7 @@ public StreamRequest upsertPushTemplate( UpsertPushTemplateRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/push_templates", request, @@ -1042,9 +850,7 @@ public StreamRequest getRateLimits(GetRateLimitsRequest r throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/rate_limits", request, @@ -1062,14 +868,7 @@ public StreamRequest listRoles(ListRolesRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), - "GET", - "/api/v2/roles", - request, - null, - new TypeReference() {}); + client, "GET", "/api/v2/roles", request, null, new TypeReference() {}); } @NotNull @@ -1082,14 +881,7 @@ public StreamRequest createRole(CreateRoleRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), - "POST", - "/api/v2/roles", - request, - null, - new TypeReference() {}); + client, "POST", "/api/v2/roles", request, null, new TypeReference() {}); } @NotNull @@ -1097,9 +889,7 @@ public StreamRequest searchRoles(SearchRolesRequest request throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/roles/search", request, @@ -1113,9 +903,7 @@ public StreamRequest deleteRole(@NotNull String name, DeleteRoleReques var pathParams = Map.of("name", name); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/roles/{name}", request, @@ -1134,9 +922,7 @@ public StreamRequest getTask(@NotNull String id, GetTaskRequest var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/tasks/{id}", request, @@ -1153,14 +939,7 @@ public StreamRequest getTask(@NotNull String id) throws StreamE public StreamRequest deleteFile(DeleteFileRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), - "DELETE", - "/api/v2/uploads/file", - request, - null, - new TypeReference() {}); + client, "DELETE", "/api/v2/uploads/file", request, null, new TypeReference() {}); } @NotNull @@ -1173,9 +952,7 @@ public StreamRequest uploadFile(UploadFileRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/uploads/file", request, @@ -1192,14 +969,7 @@ public StreamRequest uploadFile() throws StreamException { public StreamRequest deleteImage(DeleteImageRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), - "DELETE", - "/api/v2/uploads/image", - request, - null, - new TypeReference() {}); + client, "DELETE", "/api/v2/uploads/image", request, null, new TypeReference() {}); } @NotNull @@ -1212,9 +982,7 @@ public StreamRequest uploadImage(UploadImageRequest request throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/uploads/image", request, @@ -1232,9 +1000,7 @@ public StreamRequest listUserGroups(ListUserGroupsReques throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/usergroups", request, @@ -1252,9 +1018,7 @@ public StreamRequest createUserGroup(CreateUserGroupReq throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/usergroups", request, @@ -1267,9 +1031,7 @@ public StreamRequest searchUserGroups(SearchUserGroups throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/usergroups/search", request, @@ -1283,9 +1045,7 @@ public StreamRequest deleteUserGroup(@NotNull String id, DeleteUserGro var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/usergroups/{id}", request, @@ -1304,9 +1064,7 @@ public StreamRequest getUserGroup( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/usergroups/{id}", request, @@ -1326,9 +1084,7 @@ public StreamRequest updateUserGroup( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PUT", "/api/v2/usergroups/{id}", request, @@ -1348,9 +1104,7 @@ public StreamRequest addUserGroupMembers( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/usergroups/{id}/members", request, @@ -1364,9 +1118,7 @@ public StreamRequest removeUserGroupMembers( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/usergroups/{id}/members/delete", request, @@ -1379,14 +1131,7 @@ public StreamRequest queryUsers(QueryUsersRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), - "GET", - "/api/v2/users", - request, - null, - new TypeReference() {}); + client, "GET", "/api/v2/users", request, null, new TypeReference() {}); } @NotNull @@ -1399,9 +1144,7 @@ public StreamRequest updateUsersPartial(UpdateUsersPartialR throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PATCH", "/api/v2/users", request, @@ -1414,9 +1157,7 @@ public StreamRequest updateUsers(UpdateUsersRequest request throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/users", request, @@ -1429,9 +1170,7 @@ public StreamRequest getBlockedUsers(GetBlockedUsersReq throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/users/block", request, @@ -1449,9 +1188,7 @@ public StreamRequest blockUsers(BlockUsersRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/users/block", request, @@ -1464,9 +1201,7 @@ public StreamRequest deactivateUsers(DeactivateUsersReq throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/users/deactivate", request, @@ -1479,9 +1214,7 @@ public StreamRequest deleteUsers(DeleteUsersRequest request throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/users/delete", request, @@ -1494,9 +1227,7 @@ public StreamRequest getUserLiveLocations( GetUserLiveLocationsRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/users/live_locations", request, @@ -1514,9 +1245,7 @@ public StreamRequest updateLiveLocation(UpdateLiveLocati throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PUT", "/api/v2/users/live_locations", request, @@ -1529,9 +1258,7 @@ public StreamRequest reactivateUsers(ReactivateUsersReq throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/users/reactivate", request, @@ -1543,14 +1270,7 @@ public StreamRequest reactivateUsers(ReactivateUsersReq public StreamRequest restoreUsers(RestoreUsersRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), - "POST", - "/api/v2/users/restore", - request, - null, - new TypeReference() {}); + client, "POST", "/api/v2/users/restore", request, null, new TypeReference() {}); } @NotNull @@ -1558,9 +1278,7 @@ public StreamRequest unblockUsers(UnblockUsersRequest requ throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/users/unblock", request, @@ -1574,9 +1292,7 @@ public StreamRequest deactivateUser( var pathParams = Map.of("user_id", userID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/users/{user_id}/deactivate", request, @@ -1596,9 +1312,7 @@ public StreamRequest exportUser( var pathParams = Map.of("user_id", userID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/users/{user_id}/export", request, @@ -1618,9 +1332,7 @@ public StreamRequest reactivateUser( var pathParams = Map.of("user_id", userID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/users/{user_id}/reactivate", request, diff --git a/src/main/java/io/getstream/services/FeedsImpl.java b/src/main/java/io/getstream/services/FeedsImpl.java index d2ab776..81aaf4d 100644 --- a/src/main/java/io/getstream/services/FeedsImpl.java +++ b/src/main/java/io/getstream/services/FeedsImpl.java @@ -32,9 +32,7 @@ public StreamRequest addActivity(AddActivityRequest request throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/activities", request, @@ -47,9 +45,7 @@ public StreamRequest upsertActivities(UpsertActivities throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/activities/batch", request, @@ -62,9 +58,7 @@ public StreamRequest updateActivitiesParti UpdateActivitiesPartialBatchRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PATCH", "/api/v2/feeds/activities/batch/partial", request, @@ -77,9 +71,7 @@ public StreamRequest deleteActivities(DeleteActivities throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/activities/delete", request, @@ -92,9 +84,7 @@ public StreamRequest trackActivityMetrics( TrackActivityMetricsRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/activities/metrics/track", request, @@ -107,9 +97,7 @@ public StreamRequest queryActivities(QueryActivitiesReq throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/activities/query", request, @@ -127,9 +115,7 @@ public StreamRequest batchQueryActivityReac BatchQueryActivityReactionsRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/activities/reactions/query", request, @@ -143,9 +129,7 @@ public StreamRequest deleteBookmark( var pathParams = Map.of("activity_id", activityID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/feeds/activities/{activity_id}/bookmarks", request, @@ -165,9 +149,7 @@ public StreamRequest updateBookmark( var pathParams = Map.of("activity_id", activityID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PATCH", "/api/v2/feeds/activities/{activity_id}/bookmarks", request, @@ -187,9 +169,7 @@ public StreamRequest addBookmark( var pathParams = Map.of("activity_id", activityID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/activities/{activity_id}/bookmarks", request, @@ -209,9 +189,7 @@ public StreamRequest activityFeedback( var pathParams = Map.of("activity_id", activityID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/activities/{activity_id}/feedback", request, @@ -235,9 +213,7 @@ public StreamRequest castPollVote( "poll_id", pollID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/activities/{activity_id}/polls/{poll_id}/vote", request, @@ -265,9 +241,7 @@ public StreamRequest deletePollVote( "vote_id", voteID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/feeds/activities/{activity_id}/polls/{poll_id}/vote/{vote_id}", request, @@ -288,9 +262,7 @@ public StreamRequest addActivityReaction( var pathParams = Map.of("activity_id", activityID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/activities/{activity_id}/reactions", request, @@ -304,9 +276,7 @@ public StreamRequest queryActivityReactions( var pathParams = Map.of("activity_id", activityID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/activities/{activity_id}/reactions/query", request, @@ -330,9 +300,7 @@ public StreamRequest deleteActivityReaction( "type", type); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/feeds/activities/{activity_id}/reactions/{type}", request, @@ -352,9 +320,7 @@ public StreamRequest queryActivityShares( var pathParams = Map.of("activity_id", activityID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/feeds/activities/{activity_id}/shares", request, @@ -374,9 +340,7 @@ public StreamRequest deleteActivity( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/feeds/activities/{id}", request, @@ -396,9 +360,7 @@ public StreamRequest getActivity( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/feeds/activities/{id}", request, @@ -417,9 +379,7 @@ public StreamRequest updateActivityPartial( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PATCH", "/api/v2/feeds/activities/{id}", request, @@ -439,9 +399,7 @@ public StreamRequest updateActivity( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PUT", "/api/v2/feeds/activities/{id}", request, @@ -461,9 +419,7 @@ public StreamRequest restoreActivity( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/activities/{id}/restore", request, @@ -483,9 +439,7 @@ public StreamRequest translateActivity( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/activities/{id}/translate", request, @@ -498,9 +452,7 @@ public StreamRequest queryBookmarkFolders( QueryBookmarkFoldersRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/bookmark_folders/query", request, @@ -519,9 +471,7 @@ public StreamRequest deleteBookmarkFolder( var pathParams = Map.of("folder_id", folderID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/feeds/bookmark_folders/{folder_id}", request, @@ -541,9 +491,7 @@ public StreamRequest updateBookmarkFolder( var pathParams = Map.of("folder_id", folderID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PATCH", "/api/v2/feeds/bookmark_folders/{folder_id}", request, @@ -562,9 +510,7 @@ public StreamRequest queryBookmarks(QueryBookmarksReques throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/bookmarks/query", request, @@ -582,9 +528,7 @@ public StreamRequest deleteCollections( DeleteCollectionsRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/feeds/collections", request, @@ -597,9 +541,7 @@ public StreamRequest readCollections(ReadCollectionsReq throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/feeds/collections", request, @@ -617,9 +559,7 @@ public StreamRequest updateCollections( UpdateCollectionsRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PATCH", "/api/v2/feeds/collections", request, @@ -632,9 +572,7 @@ public StreamRequest createCollections( CreateCollectionsRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/collections", request, @@ -647,9 +585,7 @@ public StreamRequest upsertCollections( UpsertCollectionsRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PUT", "/api/v2/feeds/collections", request, @@ -662,9 +598,7 @@ public StreamRequest queryCollections(QueryCollections throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/collections/query", request, @@ -682,9 +616,7 @@ public StreamRequest getComments(GetCommentsRequest request throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/feeds/comments", request, @@ -697,9 +629,7 @@ public StreamRequest addComment(AddCommentRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/comments", request, @@ -717,9 +647,7 @@ public StreamRequest addCommentsBatch(AddCommentsBatch throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/comments/batch", request, @@ -732,9 +660,7 @@ public StreamRequest queryComments(QueryCommentsRequest r throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/comments/query", request, @@ -747,9 +673,7 @@ public StreamRequest batchQueryCommentReacti BatchQueryCommentReactionsRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/comments/reactions/query", request, @@ -763,9 +687,7 @@ public StreamRequest deleteCommentBookmark( var pathParams = Map.of("comment_id", commentID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/feeds/comments/{comment_id}/bookmarks", request, @@ -785,9 +707,7 @@ public StreamRequest updateCommentBookmark( var pathParams = Map.of("comment_id", commentID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PATCH", "/api/v2/feeds/comments/{comment_id}/bookmarks", request, @@ -807,9 +727,7 @@ public StreamRequest addCommentBookmark( var pathParams = Map.of("comment_id", commentID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/comments/{comment_id}/bookmarks", request, @@ -829,9 +747,7 @@ public StreamRequest deleteComment( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/feeds/comments/{id}", request, @@ -851,9 +767,7 @@ public StreamRequest getComment(@NotNull String id, GetComme var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/feeds/comments/{id}", request, @@ -872,9 +786,7 @@ public StreamRequest updateComment( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PATCH", "/api/v2/feeds/comments/{id}", request, @@ -894,9 +806,7 @@ public StreamRequest updateCommentPartial( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/comments/{id}/partial", request, @@ -916,9 +826,7 @@ public StreamRequest addCommentReaction( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/comments/{id}/reactions", request, @@ -932,9 +840,7 @@ public StreamRequest queryCommentReactions( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/comments/{id}/reactions/query", request, @@ -958,9 +864,7 @@ public StreamRequest deleteCommentReaction( "type", type); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/feeds/comments/{id}/reactions/{type}", request, @@ -980,9 +884,7 @@ public StreamRequest getCommentReplies( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/feeds/comments/{id}/replies", request, @@ -1002,9 +904,7 @@ public StreamRequest restoreComment( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/comments/{id}/restore", request, @@ -1024,9 +924,7 @@ public StreamRequest translateComment( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/comments/{id}/translate", request, @@ -1039,9 +937,7 @@ public StreamRequest listFeedGroups(ListFeedGroupsReques throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/feeds/feed_groups", request, @@ -1059,9 +955,7 @@ public StreamRequest createFeedGroup(CreateFeedGroupReq throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/feed_groups", request, @@ -1079,9 +973,7 @@ public StreamRequest deleteFeed( "feed_id", feedID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/feeds/feed_groups/{feed_group_id}/feeds/{feed_id}", request, @@ -1105,9 +997,7 @@ public StreamRequest getOrCreateFeed( "feed_id", feedID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/feed_groups/{feed_group_id}/feeds/{feed_id}", request, @@ -1131,9 +1021,7 @@ public StreamRequest updateFeed( "feed_id", feedID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PUT", "/api/v2/feeds/feed_groups/{feed_group_id}/feeds/{feed_id}", request, @@ -1157,9 +1045,7 @@ public StreamRequest markActivity( "feed_id", feedID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/feed_groups/{feed_group_id}/feeds/{feed_id}/activities/mark/batch", request, @@ -1187,9 +1073,7 @@ public StreamRequest unpinActivity( "activity_id", activityID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/feeds/feed_groups/{feed_group_id}/feeds/{feed_id}/activities/{activity_id}/pin", request, @@ -1218,9 +1102,7 @@ public StreamRequest pinActivity( "activity_id", activityID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/feed_groups/{feed_group_id}/feeds/{feed_id}/activities/{activity_id}/pin", request, @@ -1245,9 +1127,7 @@ public StreamRequest changeFeedVisibility( "feed_id", feedID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/feed_groups/{feed_group_id}/feeds/{feed_id}/change_visibility", request, @@ -1265,9 +1145,7 @@ public StreamRequest updateFeedMembers( "feed_id", feedID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PATCH", "/api/v2/feeds/feed_groups/{feed_group_id}/feeds/{feed_id}/members", request, @@ -1285,9 +1163,7 @@ public StreamRequest acceptFeedMemberInvite( "feed_group_id", feedGroupID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/feed_groups/{feed_group_id}/feeds/{feed_id}/members/accept", request, @@ -1311,9 +1187,7 @@ public StreamRequest queryFeedMembers( "feed_id", feedID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/feed_groups/{feed_group_id}/feeds/{feed_id}/members/query", request, @@ -1337,9 +1211,7 @@ public StreamRequest rejectFeedMemberInvite( "feed_id", feedID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/feed_groups/{feed_group_id}/feeds/{feed_id}/members/reject", request, @@ -1363,9 +1235,7 @@ public StreamRequest queryPinnedActivities( "feed_id", feedID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/feed_groups/{feed_group_id}/feeds/{feed_id}/pinned_activities/query", request, @@ -1385,9 +1255,7 @@ public StreamRequest getFollowSuggestions( var pathParams = Map.of("feed_group_id", feedGroupID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/feeds/feed_groups/{feed_group_id}/follow_suggestions", request, @@ -1407,9 +1275,7 @@ public StreamRequest restoreFeedGroup( var pathParams = Map.of("feed_group_id", feedGroupID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/feed_groups/{feed_group_id}/restore", request, @@ -1429,9 +1295,7 @@ public StreamRequest deleteFeedGroup( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/feeds/feed_groups/{id}", request, @@ -1451,9 +1315,7 @@ public StreamRequest getFeedGroup( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/feeds/feed_groups/{id}", request, @@ -1473,9 +1335,7 @@ public StreamRequest getOrCreateFeedGroup( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/feed_groups/{id}", request, @@ -1495,9 +1355,7 @@ public StreamRequest updateFeedGroup( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PUT", "/api/v2/feeds/feed_groups/{id}", request, @@ -1516,9 +1374,7 @@ public StreamRequest listFeedViews(ListFeedViewsRequest r throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/feeds/feed_views", request, @@ -1536,9 +1392,7 @@ public StreamRequest createFeedView(CreateFeedViewReques throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/feed_views", request, @@ -1552,9 +1406,7 @@ public StreamRequest deleteFeedView( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/feeds/feed_views/{id}", request, @@ -1574,9 +1426,7 @@ public StreamRequest getFeedView( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/feeds/feed_views/{id}", request, @@ -1595,9 +1445,7 @@ public StreamRequest getOrCreateFeedView( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/feed_views/{id}", request, @@ -1617,9 +1465,7 @@ public StreamRequest updateFeedView( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PUT", "/api/v2/feeds/feed_views/{id}", request, @@ -1638,9 +1484,7 @@ public StreamRequest listFeedVisibilities( ListFeedVisibilitiesRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/feeds/feed_visibilities", request, @@ -1659,9 +1503,7 @@ public StreamRequest getFeedVisibility( var pathParams = Map.of("name", name); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/feeds/feed_visibilities/{name}", request, @@ -1681,9 +1523,7 @@ public StreamRequest updateFeedVisibility( var pathParams = Map.of("name", name); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PUT", "/api/v2/feeds/feed_visibilities/{name}", request, @@ -1702,9 +1542,7 @@ public StreamRequest createFeedsBatch(CreateFeedsBatch throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/feeds/batch", request, @@ -1717,9 +1555,7 @@ public StreamRequest deleteFeedsBatch(DeleteFeedsBatch throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/feeds/delete", request, @@ -1731,9 +1567,7 @@ public StreamRequest deleteFeedsBatch(DeleteFeedsBatch public StreamRequest ownBatch(OwnBatchRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/feeds/own/batch", request, @@ -1746,9 +1580,7 @@ public StreamRequest queryFeeds(QueryFeedsRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/feeds/query", request, @@ -1766,9 +1598,7 @@ public StreamRequest getFeedsRateLimits( GetFeedsRateLimitsRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/feeds/feeds/rate_limits", request, @@ -1786,9 +1616,7 @@ public StreamRequest updateFollow(UpdateFollowRequest requ throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PATCH", "/api/v2/feeds/follows", request, @@ -1800,9 +1628,7 @@ public StreamRequest updateFollow(UpdateFollowRequest requ public StreamRequest follow(FollowRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/follows", request, @@ -1815,9 +1641,7 @@ public StreamRequest acceptFollow(AcceptFollowRequest requ throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/follows/accept", request, @@ -1830,9 +1654,7 @@ public StreamRequest followBatch(FollowBatchRequest request throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/follows/batch", request, @@ -1845,9 +1667,7 @@ public StreamRequest getOrCreateFollows(GetOrCreateFollowsR throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/follows/batch/upsert", request, @@ -1860,9 +1680,7 @@ public StreamRequest queryFollows(QueryFollowsRequest requ throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/follows/query", request, @@ -1880,9 +1698,7 @@ public StreamRequest rejectFollow(RejectFollowRequest requ throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/follows/reject", request, @@ -1895,9 +1711,7 @@ public StreamRequest getOrCreateFollow( GetOrCreateFollowRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/follows/upsert", request, @@ -1915,9 +1729,7 @@ public StreamRequest unfollow( "target", target); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/feeds/follows/{source}/{target}", request, @@ -1936,9 +1748,7 @@ public StreamRequest createMembershipLevel( CreateMembershipLevelRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/membership_levels", request, @@ -1951,9 +1761,7 @@ public StreamRequest queryMembershipLevels( QueryMembershipLevelsRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/membership_levels/query", request, @@ -1973,9 +1781,7 @@ public StreamRequest deleteMembershipLevel( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/feeds/membership_levels/{id}", request, @@ -1994,9 +1800,7 @@ public StreamRequest updateMembershipLevel( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PATCH", "/api/v2/feeds/membership_levels/{id}", request, @@ -2015,9 +1819,7 @@ public StreamRequest queryRevisionHistory( QueryRevisionHistoryRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/revisions/query", request, @@ -2030,9 +1832,7 @@ public StreamRequest queryFeedsUsageStats( QueryFeedsUsageStatsRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/stats/usage", request, @@ -2050,9 +1850,7 @@ public StreamRequest unfollowBatch(UnfollowBatchRequest r throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/unfollow/batch", request, @@ -2065,9 +1863,7 @@ public StreamRequest getOrCreateUnfollows( GetOrCreateUnfollowsRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/unfollow/batch/upsert", request, @@ -2080,9 +1876,7 @@ public StreamRequest getOrCreateUnfollow( GetOrCreateUnfollowRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/unfollow/upsert", request, @@ -2096,9 +1890,7 @@ public StreamRequest deleteFeedUserData( var pathParams = Map.of("user_id", userID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/users/{user_id}/delete", request, @@ -2118,9 +1910,7 @@ public StreamRequest exportFeedUserData( var pathParams = Map.of("user_id", userID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/feeds/users/{user_id}/export", request, @@ -2140,9 +1930,7 @@ public StreamRequest getUserInterests( var pathParams = Map.of("user_id", userID); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/feeds/users/{user_id}/interests", request, diff --git a/src/main/java/io/getstream/services/Moderation.java b/src/main/java/io/getstream/services/Moderation.java index 51e46d4..4657fab 100644 --- a/src/main/java/io/getstream/services/Moderation.java +++ b/src/main/java/io/getstream/services/Moderation.java @@ -187,17 +187,19 @@ public StreamRequest upsertModerationRule( @NotNull public StreamRequest deleteModerationRule( - DeleteModerationRuleRequest request) throws StreamException; + @NotNull String id, DeleteModerationRuleRequest request) throws StreamException; @NotNull - public StreamRequest deleteModerationRule() throws StreamException; + public StreamRequest deleteModerationRule(@NotNull String id) + throws StreamException; @NotNull public StreamRequest getModerationRule( - GetModerationRuleRequest request) throws StreamException; + @NotNull String id, GetModerationRuleRequest request) throws StreamException; @NotNull - public StreamRequest getModerationRule() throws StreamException; + public StreamRequest getModerationRule(@NotNull String id) + throws StreamException; @NotNull public StreamRequest queryModerationRules( diff --git a/src/main/java/io/getstream/services/ModerationImpl.java b/src/main/java/io/getstream/services/ModerationImpl.java index b5e6406..b8d16a5 100644 --- a/src/main/java/io/getstream/services/ModerationImpl.java +++ b/src/main/java/io/getstream/services/ModerationImpl.java @@ -32,9 +32,7 @@ public StreamRequest getActionConfig(GetActionConfigReq throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/moderation/action_config", request, @@ -52,9 +50,7 @@ public StreamRequest upsertActionConfig( UpsertActionConfigRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/moderation/action_config", request, @@ -67,9 +63,7 @@ public StreamRequest bulkUpsertActionConfig( BulkUpsertActionConfigRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/moderation/action_config/bulk", request, @@ -82,9 +76,7 @@ public StreamRequest bulkDeleteActionConfig( BulkDeleteActionConfigRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/moderation/action_config/bulk_delete", request, @@ -98,9 +90,7 @@ public StreamRequest deleteActionConfig( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/moderation/action_config/{id}", request, @@ -119,9 +109,7 @@ public StreamRequest insertActionLog(InsertActionLogReq throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/moderation/action_logs", request, @@ -133,9 +121,7 @@ public StreamRequest insertActionLog(InsertActionLogReq public StreamRequest analyze(AnalyzeRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/moderation/analyze", request, @@ -152,9 +138,7 @@ public StreamRequest analyze() throws StreamException { public StreamRequest appeal(AppealRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/moderation/appeal", request, @@ -168,9 +152,7 @@ public StreamRequest getAppeal(@NotNull String id, GetAppealR var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/moderation/appeal/{id}", request, @@ -188,9 +170,7 @@ public StreamRequest queryAppeals(QueryAppealsRequest requ throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/moderation/appeals", request, @@ -208,9 +188,7 @@ public StreamRequest bulkActionAppeals( BulkActionAppealsRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/moderation/appeals/bulk_action", request, @@ -222,9 +200,7 @@ public StreamRequest bulkActionAppeals( public StreamRequest ban(BanRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/moderation/ban", request, @@ -237,9 +213,7 @@ public StreamRequest bulkImageModeration( BulkImageModerationRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/moderation/bulk_image_moderation", request, @@ -251,9 +225,7 @@ public StreamRequest bulkImageModeration( public StreamRequest bypass(BypassRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/moderation/bypass", request, @@ -265,9 +237,7 @@ public StreamRequest bypass(BypassRequest request) throws Stream public StreamRequest check(CheckRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/moderation/check", request, @@ -280,9 +250,7 @@ public StreamRequest checkS3Access(CheckS3AccessRequest r throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/moderation/check_s3_access", request, @@ -300,9 +268,7 @@ public StreamRequest upsertConfig(UpsertConfigRequest requ throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/moderation/config", request, @@ -316,9 +282,7 @@ public StreamRequest deleteConfig( var pathParams = Map.of("key", key); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/moderation/config/{key}", request, @@ -338,9 +302,7 @@ public StreamRequest getConfig(@NotNull String key, GetConfig var pathParams = Map.of("key", key); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/moderation/config/{key}", request, @@ -358,9 +320,7 @@ public StreamRequest queryModerationConfigs( QueryModerationConfigsRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/moderation/configs", request, @@ -379,9 +339,7 @@ public StreamRequest customCheck(CustomCheckRequest request throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/moderation/custom_check", request, @@ -394,9 +352,7 @@ public StreamRequest v2DeleteTemplate( V2DeleteTemplateRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/moderation/feeds_moderation_template", request, @@ -414,9 +370,7 @@ public StreamRequest v2QueryTemplates( V2QueryTemplatesRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/moderation/feeds_moderation_template", request, @@ -435,9 +389,7 @@ public StreamRequest v2UpsertTemplate( V2UpsertTemplateRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/moderation/feeds_moderation_template", request, @@ -449,9 +401,7 @@ public StreamRequest v2UpsertTemplate( public StreamRequest flag(FlagRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/moderation/flag", request, @@ -464,9 +414,7 @@ public StreamRequest getFlagCount(GetFlagCountRequest requ throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/moderation/flag_count", request, @@ -479,9 +427,7 @@ public StreamRequest queryModerationFlags( QueryModerationFlagsRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/moderation/flags", request, @@ -498,9 +444,7 @@ public StreamRequest queryModerationFlags() throws public StreamRequest labels(LabelsRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/moderation/labels", request, @@ -513,9 +457,7 @@ public StreamRequest queryLabelResults( QueryLabelResultsRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/moderation/labels/results", request, @@ -533,9 +475,7 @@ public StreamRequest queryModerationLogs( QueryModerationLogsRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/moderation/logs", request, @@ -553,9 +493,7 @@ public StreamRequest upsertModerationRule( UpsertModerationRuleRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/moderation/moderation_rule", request, @@ -565,42 +503,42 @@ public StreamRequest upsertModerationRule( @NotNull public StreamRequest deleteModerationRule( - DeleteModerationRuleRequest request) throws StreamException { + @NotNull String id, DeleteModerationRuleRequest request) throws StreamException { + var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/moderation/moderation_rule/{id}", request, - null, + pathParams, new TypeReference() {}); } @NotNull - public StreamRequest deleteModerationRule() throws StreamException { - return deleteModerationRule(new DeleteModerationRuleRequest()); + public StreamRequest deleteModerationRule(@NotNull String id) + throws StreamException { + return deleteModerationRule(id, new DeleteModerationRuleRequest()); } @NotNull public StreamRequest getModerationRule( - GetModerationRuleRequest request) throws StreamException { + @NotNull String id, GetModerationRuleRequest request) throws StreamException { + var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/moderation/moderation_rule/{id}", request, - null, + pathParams, new TypeReference() {}); } @NotNull - public StreamRequest getModerationRule() throws StreamException { - return getModerationRule(new GetModerationRuleRequest()); + public StreamRequest getModerationRule(@NotNull String id) + throws StreamException { + return getModerationRule(id, new GetModerationRuleRequest()); } @NotNull @@ -608,9 +546,7 @@ public StreamRequest queryModerationRules( QueryModerationRulesRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/moderation/moderation_rules", request, @@ -627,9 +563,7 @@ public StreamRequest queryModerationRules() throws public StreamRequest mute(MuteRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/moderation/mute", request, @@ -642,9 +576,7 @@ public StreamRequest listQueues(ListQueuesRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/moderation/queues", request, @@ -662,9 +594,7 @@ public StreamRequest createQueue(CreateQueueRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/moderation/queues", request, @@ -678,9 +608,7 @@ public StreamRequest getQueue(@NotNull String id, GetQueueRequest var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/moderation/queues/{id}", request, @@ -699,9 +627,7 @@ public StreamRequest updateQueue(@NotNull String id, UpdateQueueR var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PATCH", "/api/v2/moderation/queues/{id}", request, @@ -720,9 +646,7 @@ public StreamRequest deleteQueue(@NotNull String id, DeleteQueueR var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/moderation/queues/{id}/delete", request, @@ -740,9 +664,7 @@ public StreamRequest queryReviewQueue(QueryReviewQueue throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/moderation/review_queue", request, @@ -761,9 +683,7 @@ public StreamRequest getReviewQueueItem( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/moderation/review_queue/{id}", request, @@ -782,9 +702,7 @@ public StreamRequest getSetupSession(GetSetupSessionReq throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/moderation/setup", request, @@ -802,9 +720,7 @@ public StreamRequest upsertSetupSession( UpsertSetupSessionRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/moderation/setup", request, @@ -817,9 +733,7 @@ public StreamRequest submitAction(SubmitActionRequest requ throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/moderation/submit_action", request, @@ -832,9 +746,7 @@ public StreamRequest submitModerationFeedback( SubmitModerationFeedbackRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/moderation/submit_moderation_feedback", request, @@ -846,9 +758,7 @@ public StreamRequest submitModerationFeedback( public StreamRequest unban(UnbanRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/moderation/unban", request, @@ -860,9 +770,7 @@ public StreamRequest unban(UnbanRequest request) throws StreamExc public StreamRequest unmute(UnmuteRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/moderation/unmute", request, diff --git a/src/main/java/io/getstream/services/VideoImpl.java b/src/main/java/io/getstream/services/VideoImpl.java index 1cdcfe1..3ea77de 100644 --- a/src/main/java/io/getstream/services/VideoImpl.java +++ b/src/main/java/io/getstream/services/VideoImpl.java @@ -32,9 +32,7 @@ public StreamRequest getActiveCallsStatus( GetActiveCallsStatusRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/video/active_calls_status", request, @@ -52,9 +50,7 @@ public StreamRequest queryUserFeedback( QueryUserFeedbackRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call/feedback", request, @@ -72,9 +68,7 @@ public StreamRequest queryCallMembers(QueryCallMembers throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call/members", request, @@ -87,9 +81,7 @@ public StreamRequest queryCallStats(QueryCallStatsReques throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call/stats", request, @@ -111,9 +103,7 @@ public StreamRequest getCall( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/video/call/{type}/{id}", request, @@ -136,9 +126,7 @@ public StreamRequest updateCall( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PATCH", "/api/v2/video/call/{type}/{id}", request, @@ -162,9 +150,7 @@ public StreamRequest getOrCreateCall( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call/{type}/{id}", request, @@ -187,9 +173,7 @@ public StreamRequest blockUser( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call/{type}/{id}/block", request, @@ -207,9 +191,7 @@ public StreamRequest sendClosedCaption( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call/{type}/{id}/closed_captions", request, @@ -226,9 +208,7 @@ public StreamRequest deleteCall( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call/{type}/{id}/delete", request, @@ -252,9 +232,7 @@ public StreamRequest sendCallEvent( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call/{type}/{id}/event", request, @@ -278,9 +256,7 @@ public StreamRequest collectUserFeedback( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call/{type}/{id}/feedback", request, @@ -297,9 +273,7 @@ public StreamRequest goLive( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call/{type}/{id}/go_live", request, @@ -322,9 +296,7 @@ public StreamRequest kickUser( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call/{type}/{id}/kick", request, @@ -341,9 +313,7 @@ public StreamRequest endCall( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call/{type}/{id}/mark_ended", request, @@ -367,9 +337,7 @@ public StreamRequest updateCallMembers( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call/{type}/{id}/members", request, @@ -392,9 +360,7 @@ public StreamRequest muteUsers( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call/{type}/{id}/mute_users", request, @@ -418,9 +384,7 @@ public StreamRequest queryCallParticipants( "type", type); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call/{type}/{id}/participants", request, @@ -443,9 +407,7 @@ public StreamRequest videoPin( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call/{type}/{id}/pin", request, @@ -463,9 +425,7 @@ public StreamRequest listRecordings( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/video/call/{type}/{id}/recordings", request, @@ -493,9 +453,7 @@ public StreamRequest startRecording( "recording_type", recordingType); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call/{type}/{id}/recordings/{recording_type}/start", request, @@ -524,9 +482,7 @@ public StreamRequest stopRecording( "recording_type", recordingType); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call/{type}/{id}/recordings/{recording_type}/stop", request, @@ -551,9 +507,7 @@ public StreamRequest getCallReport( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/video/call/{type}/{id}/report", request, @@ -576,9 +530,7 @@ public StreamRequest ringCall( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call/{type}/{id}/ring", request, @@ -602,9 +554,7 @@ public StreamRequest startRTMPBroadcasts( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call/{type}/{id}/rtmp_broadcasts", request, @@ -622,9 +572,7 @@ public StreamRequest stopAllRTMPBroadcasts( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call/{type}/{id}/rtmp_broadcasts/stop", request, @@ -652,9 +600,7 @@ public StreamRequest stopRTMPBroadcast( "name", name); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call/{type}/{id}/rtmp_broadcasts/{name}/stop", request, @@ -686,9 +632,7 @@ public StreamRequest getCallParticipan "user_session", userSession); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/video/call/{type}/{id}/session/{session}/participant/{user}/{user_session}/details/track", request, @@ -722,9 +666,7 @@ public StreamRequest queryCallParticipantS "session", session); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/video/call/{type}/{id}/session/{session}/participant_sessions", request, @@ -749,9 +691,7 @@ public StreamRequest startHLSBroadcasting( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call/{type}/{id}/start_broadcasting", request, @@ -775,9 +715,7 @@ public StreamRequest startClosedCaptions( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call/{type}/{id}/start_closed_captions", request, @@ -801,9 +739,7 @@ public StreamRequest startFrameRecording( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call/{type}/{id}/start_frame_recording", request, @@ -827,9 +763,7 @@ public StreamRequest startTranscription( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call/{type}/{id}/start_transcription", request, @@ -853,9 +787,7 @@ public StreamRequest stopHLSBroadcasting( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call/{type}/{id}/stop_broadcasting", request, @@ -879,9 +811,7 @@ public StreamRequest stopClosedCaptions( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call/{type}/{id}/stop_closed_captions", request, @@ -905,9 +835,7 @@ public StreamRequest stopFrameRecording( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call/{type}/{id}/stop_frame_recording", request, @@ -930,9 +858,7 @@ public StreamRequest stopLive( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call/{type}/{id}/stop_live", request, @@ -956,9 +882,7 @@ public StreamRequest stopTranscription( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call/{type}/{id}/stop_transcription", request, @@ -982,9 +906,7 @@ public StreamRequest listTranscriptions( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/video/call/{type}/{id}/transcriptions", request, @@ -1007,9 +929,7 @@ public StreamRequest unblockUser( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call/{type}/{id}/unblock", request, @@ -1026,9 +946,7 @@ public StreamRequest videoUnpin( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call/{type}/{id}/unpin", request, @@ -1046,9 +964,7 @@ public StreamRequest updateUserPermissions( "id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call/{type}/{id}/user_permissions", request, @@ -1072,9 +988,7 @@ public StreamRequest deleteRecording( "filename", filename); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/video/call/{type}/{id}/{session}/recordings/{filename}", request, @@ -1105,9 +1019,7 @@ public StreamRequest deleteTranscription( "filename", filename); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/video/call/{type}/{id}/{session}/transcriptions/{filename}", request, @@ -1127,9 +1039,7 @@ public StreamRequest reportClientCallEvent( ReportClientCallEventRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call_client_event", request, @@ -1142,9 +1052,7 @@ public StreamRequest queryCallSessionStats( QueryCallSessionStatsRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/call_stats", request, @@ -1172,9 +1080,7 @@ public StreamRequest getCallStatsMap( "session", session); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/video/call_stats/{call_type}/{call_id}/{session}/map", request, @@ -1208,9 +1114,7 @@ public StreamRequest getCallStatsMap( "user_session", userSession); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/video/call_stats/{call_type}/{call_id}/{session}/participant/{user}/{user_session}/details", request, @@ -1250,9 +1154,7 @@ public StreamRequest queryCallSessionP "session", session); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/video/call_stats/{call_type}/{call_id}/{session}/participants", request, @@ -1287,9 +1189,7 @@ public StreamRequest queryCallSessionP "user_session", userSession); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/video/call_stats/{call_type}/{call_id}/{session}/participants/{user}/{user_session}/timeline", request, @@ -1320,9 +1220,7 @@ public StreamRequest queryCalls(QueryCallsRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/calls", request, @@ -1340,9 +1238,7 @@ public StreamRequest listCallTypes(ListCallTypesRequest re throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/video/calltypes", request, @@ -1360,9 +1256,7 @@ public StreamRequest createCallType(CreateCallTypeReques throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/calltypes", request, @@ -1376,9 +1270,7 @@ public StreamRequest deleteCallType(@NotNull String name, DeleteCallTy var pathParams = Map.of("name", name); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/video/calltypes/{name}", request, @@ -1397,9 +1289,7 @@ public StreamRequest getCallType( var pathParams = Map.of("name", name); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/video/calltypes/{name}", request, @@ -1419,9 +1309,7 @@ public StreamRequest updateCallType( var pathParams = Map.of("name", name); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PUT", "/api/v2/video/calltypes/{name}", request, @@ -1439,9 +1327,7 @@ public StreamRequest updateCallType(@NotNull String name public StreamRequest getEdges(GetEdgesRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/video/edges", request, @@ -1459,9 +1345,7 @@ public StreamRequest resolveSipAuth(ResolveSipAuthReques throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/sip/auth", request, @@ -1474,9 +1358,7 @@ public StreamRequest listSIPInboundRoutingRul ListSIPInboundRoutingRuleRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/video/sip/inbound_routing_rules", request, @@ -1495,9 +1377,7 @@ public StreamRequest createSIPInboundRoutingRule( CreateSIPInboundRoutingRuleRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/sip/inbound_routing_rules", request, @@ -1511,9 +1391,7 @@ public StreamRequest deleteSIPInboundRoutin var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/video/sip/inbound_routing_rules/{id}", request, @@ -1533,9 +1411,7 @@ public StreamRequest updateSIPInboundRoutin var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PUT", "/api/v2/video/sip/inbound_routing_rules/{id}", request, @@ -1548,9 +1424,7 @@ public StreamRequest listSIPTrunks(ListSIPTrunksRequest r throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "GET", "/api/v2/video/sip/inbound_trunks", request, @@ -1568,9 +1442,7 @@ public StreamRequest createSIPTrunk(CreateSIPTrunkReques throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/sip/inbound_trunks", request, @@ -1584,9 +1456,7 @@ public StreamRequest deleteSIPTrunk( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "DELETE", "/api/v2/video/sip/inbound_trunks/{id}", request, @@ -1606,9 +1476,7 @@ public StreamRequest updateSIPTrunk( var pathParams = Map.of("id", id); return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "PUT", "/api/v2/video/sip/inbound_trunks/{id}", request, @@ -1621,9 +1489,7 @@ public StreamRequest resolveSipInbound( ResolveSipInboundRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/sip/resolve", request, @@ -1636,9 +1502,7 @@ public StreamRequest queryAggregateCallStats( QueryAggregateCallStatsRequest request) throws StreamException { return new StreamRequest( - client.getHttpClient(), - client.getObjectMapper(), - client.getBaseUrl(), + client, "POST", "/api/v2/video/stats", request,