srt url generation

vagruchi · vagruchi · commit 47dbacf1cad2 · 2025-09-24T15:43:01.000+02:00
diff --git a/src/main/java/io/getstream/models/FeedResponse.java b/src/main/java/io/getstream/models/FeedResponse.java
@@ -72,11 +72,19 @@ public class FeedResponse {
   @JsonProperty("filter_tags")
   private List<String> filterTags;
 
+  @Nullable
+  @JsonProperty("own_capabilities")
+  private List<FeedOwnCapability> ownCapabilities;
+
   @Nullable
   @JsonProperty("own_follows")
   private List<FollowResponse> ownFollows;
 
   @Nullable
   @JsonProperty("custom")
   private Map<String, Object> custom;
+
+  @Nullable
+  @JsonProperty("own_membership")
+  private FeedMemberResponse ownMembership;
 }
diff --git a/src/main/java/io/getstream/models/GetOrCreateFeedResponse.java b/src/main/java/io/getstream/models/GetOrCreateFeedResponse.java
@@ -43,9 +43,6 @@ public class GetOrCreateFeedResponse {
   @JsonProperty("members")
   private List<FeedMemberResponse> members;
 
-  @JsonProperty("own_capabilities")
-  private List<FeedOwnCapability> ownCapabilities;
-
   @JsonProperty("pinned_activities")
   private List<ActivityPinResponse> pinnedActivities;
 
@@ -60,10 +57,6 @@ public class GetOrCreateFeedResponse {
   @JsonProperty("prev")
   private String prev;
 
-  @Nullable
-  @JsonProperty("own_follows")
-  private List<FollowResponse> ownFollows;
-
   @Nullable
   @JsonProperty("followers_pagination")
   private PagerResponse followersPagination;
@@ -79,8 +72,4 @@ public class GetOrCreateFeedResponse {
   @Nullable
   @JsonProperty("notification_status")
   private NotificationStatusResponse notificationStatus;
-
-  @Nullable
-  @JsonProperty("own_membership")
-  private FeedMemberResponse ownMembership;
 }
diff --git a/src/main/java/io/getstream/services/Call.java b/src/main/java/io/getstream/services/Call.java
@@ -29,6 +29,22 @@ public Call(String callType, String callID, Video service) {
     this.service = service;
   }
 
+  public String createSRTToken(@NotNull String userID) throws StreamException {
+    StreamResponse<GetCallResponse> data = this.get();
+
+    String token = this.service.getClient().tokenBuilder().createToken(userID);
+    String[] segments = token.split("$.", 3);
+    String passphrase = segments[2];
+
+    return data.getData()
+        .getCall()
+        .getIngress()
+        .getSrt()
+        .getAddress()
+        .replace("{passphrase}", passphrase)
+        .replace("{token}", token);
+  }
+
   @NotNull
   public StreamResponse<GetCallResponse> get(GetCallRequest request) throws StreamException {
     return service.getCall(this.callType, this.callID, request).execute();
diff --git a/src/main/java/io/getstream/services/Chat.java b/src/main/java/io/getstream/services/Chat.java
@@ -15,10 +15,13 @@
 import io.getstream.exceptions.StreamException;
 import io.getstream.models.*;
 import io.getstream.services.framework.StreamRequest;
+import io.getstream.services.framework.StreamSDKClient;
 import java.util.*;
 import org.jetbrains.annotations.NotNull;
 
 public interface Chat {
+  public StreamSDKClient getClient();
+
   @NotNull
   public StreamRequest<QueryCampaignsResponse> queryCampaigns(QueryCampaignsRequest request)
       throws StreamException;
diff --git a/src/main/java/io/getstream/services/ChatImpl.java b/src/main/java/io/getstream/services/ChatImpl.java
@@ -17,14 +17,26 @@
 import io.getstream.models.*;
 import io.getstream.services.framework.StreamHTTPClient;
 import io.getstream.services.framework.StreamRequest;
+import io.getstream.services.framework.StreamSDKClient;
 import java.util.*;
 import org.jetbrains.annotations.NotNull;
 
 public class ChatImpl implements Chat {
   private StreamHTTPClient client;
+  private StreamSDKClient sdkClient;
 
   public ChatImpl(StreamHTTPClient client) {
     this.client = client;
+    this.sdkClient = new StreamSDKClient(client);
+  }
+
+  public ChatImpl(StreamSDKClient client) {
+    this.sdkClient = client;
+    this.client = client.getHttpClient();
+  }
+
+  public StreamSDKClient getClient() {
+    return sdkClient;
   }
 
   @NotNull
diff --git a/src/main/java/io/getstream/services/Common.java b/src/main/java/io/getstream/services/Common.java
@@ -15,10 +15,13 @@
 import io.getstream.exceptions.StreamException;
 import io.getstream.models.*;
 import io.getstream.services.framework.StreamRequest;
+import io.getstream.services.framework.StreamSDKClient;
 import java.util.*;
 import org.jetbrains.annotations.NotNull;
 
 public interface Common {
+  public StreamSDKClient getClient();
+
   @NotNull
   public StreamRequest<GetApplicationResponse> getApp(GetAppRequest request) throws StreamException;
 
diff --git a/src/main/java/io/getstream/services/CommonImpl.java b/src/main/java/io/getstream/services/CommonImpl.java
@@ -17,14 +17,26 @@
 import io.getstream.models.*;
 import io.getstream.services.framework.StreamHTTPClient;
 import io.getstream.services.framework.StreamRequest;
+import io.getstream.services.framework.StreamSDKClient;
 import java.util.*;
 import org.jetbrains.annotations.NotNull;
 
 public class CommonImpl implements Common {
   private StreamHTTPClient client;
+  private StreamSDKClient sdkClient;
 
   public CommonImpl(StreamHTTPClient client) {
     this.client = client;
+    this.sdkClient = new StreamSDKClient(client);
+  }
+
+  public CommonImpl(StreamSDKClient client) {
+    this.sdkClient = client;
+    this.client = client.getHttpClient();
+  }
+
+  public StreamSDKClient getClient() {
+    return sdkClient;
   }
 
   @NotNull
diff --git a/src/main/java/io/getstream/services/Feeds.java b/src/main/java/io/getstream/services/Feeds.java
@@ -15,10 +15,13 @@
 import io.getstream.exceptions.StreamException;
 import io.getstream.models.*;
 import io.getstream.services.framework.StreamRequest;
+import io.getstream.services.framework.StreamSDKClient;
 import java.util.*;
 import org.jetbrains.annotations.NotNull;
 
 public interface Feeds {
+  public StreamSDKClient getClient();
+
   @NotNull
   public StreamRequest<AddActivityResponse> addActivity(AddActivityRequest request)
       throws StreamException;
diff --git a/src/main/java/io/getstream/services/FeedsImpl.java b/src/main/java/io/getstream/services/FeedsImpl.java
@@ -17,14 +17,26 @@
 import io.getstream.models.*;
 import io.getstream.services.framework.StreamHTTPClient;
 import io.getstream.services.framework.StreamRequest;
+import io.getstream.services.framework.StreamSDKClient;
 import java.util.*;
 import org.jetbrains.annotations.NotNull;
 
 public class FeedsImpl implements Feeds {
   private StreamHTTPClient client;
+  private StreamSDKClient sdkClient;
 
   public FeedsImpl(StreamHTTPClient client) {
     this.client = client;
+    this.sdkClient = new StreamSDKClient(client);
+  }
+
+  public FeedsImpl(StreamSDKClient client) {
+    this.sdkClient = client;
+    this.client = client.getHttpClient();
+  }
+
+  public StreamSDKClient getClient() {
+    return sdkClient;
   }
 
   @NotNull
diff --git a/src/main/java/io/getstream/services/Video.java b/src/main/java/io/getstream/services/Video.java
@@ -15,10 +15,13 @@
 import io.getstream.exceptions.StreamException;
 import io.getstream.models.*;
 import io.getstream.services.framework.StreamRequest;
+import io.getstream.services.framework.StreamSDKClient;
 import java.util.*;
 import org.jetbrains.annotations.NotNull;
 
 public interface Video {
+  public StreamSDKClient getClient();
+
   @NotNull
   public StreamRequest<GetActiveCallsStatusResponse> getActiveCallsStatus(
       GetActiveCallsStatusRequest request) throws StreamException;
diff --git a/src/main/java/io/getstream/services/VideoImpl.java b/src/main/java/io/getstream/services/VideoImpl.java
@@ -17,14 +17,26 @@
 import io.getstream.models.*;
 import io.getstream.services.framework.StreamHTTPClient;
 import io.getstream.services.framework.StreamRequest;
+import io.getstream.services.framework.StreamSDKClient;
 import java.util.*;
 import org.jetbrains.annotations.NotNull;
 
 public class VideoImpl implements Video {
   private StreamHTTPClient client;
+  private StreamSDKClient sdkClient;
 
   public VideoImpl(StreamHTTPClient client) {
     this.client = client;
+    this.sdkClient = new StreamSDKClient(client);
+  }
+
+  public VideoImpl(StreamSDKClient client) {
+    this.sdkClient = client;
+    this.client = client.getHttpClient();
+  }
+
+  public StreamSDKClient getClient() {
+    return sdkClient;
   }
 
   @NotNull
diff --git a/src/main/java/io/getstream/services/framework/StreamSDKClient.java b/src/main/java/io/getstream/services/framework/StreamSDKClient.java
@@ -19,13 +19,17 @@ public StreamSDKClient(Properties properties) {
     this(new StreamHTTPClient(properties));
   }
 
-  private StreamSDKClient(StreamHTTPClient httpClient) {
+  public StreamSDKClient(StreamHTTPClient httpClient) {
     super(httpClient);
     this.httpClient = httpClient;
   }
 
   public Video video() {
-    return new VideoImpl(httpClient);
+    return new VideoImpl(this);
+  }
+
+  public StreamHTTPClient getHttpClient() {
+    return httpClient;
   }
 
   public Chat chat() {
diff --git a/src/test/java/io/getstream/CallTest.java b/src/test/java/io/getstream/CallTest.java
@@ -285,4 +285,16 @@ void testSendCustomEvent() {
         SendCallEventRequest.builder().userID(testUser.getId()).custom(customEvent).build();
     Assertions.assertDoesNotThrow(() -> testCall.sendCallEvent(sendEventRequest));
   }
+
+  @Test
+  void testGenerateSRTToken() {
+    Assertions.assertNotNull(testUser, "User should not be null");
+    String callID = "call-" + RandomStringUtils.randomAlphanumeric(10);
+    Call testCall = video.call(callType, callID);
+    Assertions.assertDoesNotThrow(() -> testCall.getOrCreate());
+    String srtToken = "";
+    srtToken = Assertions.assertDoesNotThrow(() -> testCall.createSRTToken(testUser.getId()));
+    Assertions.assertNotNull(srtToken);
+    Assertions.assertNotEquals("", srtToken);
+  }
 }
