RSDK-5228 - allow setting sdp values (#181)

package.json

@@ -45,7 +45,7 @@
   },
   "homepage": "https://github.com/viamrobotics/viam-typescript-sdk#readme",
   "dependencies": {
-    "@viamrobotics/rpc": "^0.1.37",
+    "@viamrobotics/rpc": "^0.1.38",
     "exponential-backoff": "^3.1.1"
   },
   "devDependencies": {

src/robot/client.ts

@@ -55,6 +55,12 @@ interface SessionOptions {
   disabled: boolean;
 }
 
+export interface ConnectOptions {
+  authEntity?: string;
+  creds?: Credentials;
+  priority?: number;
+}
+
 abstract class ServiceClient {
   constructor(public serviceHost: string, public options?: grpc.RpcOptions) {}
 }
@@ -369,10 +375,11 @@ export class RobotClient extends EventDispatcher implements Robot {
     return this.peerConn?.iceConnectionState === 'connected';
   }
 
-  public async connect(
+  public async connect({
     authEntity = this.savedAuthEntity,
-    creds = this.savedCreds
-  ) {
+    creds = this.savedCreds,
+    priority,
+  }: ConnectOptions = {}) {
     if (this.connecting) {
       // This lint is clearly wrong due to how the event loop works such that after an await, the condition may no longer be true.
       // eslint-disable-next-line @typescript-eslint/no-unnecessary-condition
@@ -407,6 +414,11 @@ export class RobotClient extends EventDispatcher implements Robot {
         },
       };
 
+      // Webrtcoptions will always be defined, but TS doesn't know this
+      if (priority !== undefined && opts.webrtcOptions) {
+        opts.webrtcOptions.additionalSdpFields = { 'x-priority': priority };
+      }
+
       // Save authEntity, creds
       this.savedAuthEntity = authEntity;
       this.savedCreds = creds;

src/robot/dial.ts

@@ -58,7 +58,7 @@ const dialDirect = async (conf: DialDirectConf): Promise<RobotClient> => {
   if (conf.credential) {
     creds = conf.credential;
   }
-  await client.connect(conf.authEntity, creds);
+  await client.connect({ authEntity: conf.authEntity, creds });
 
   // eslint-disable-next-line no-console
   console.debug('connected via gRPC');
@@ -90,6 +90,7 @@ export interface DialWebRTCConf {
   // WebRTC
   signalingAddress: string;
   iceServers?: ICEServer[];
+  priority?: number;
 }
 
 const dialWebRTC = async (conf: DialWebRTCConf): Promise<RobotClient> => {
@@ -120,7 +121,11 @@ const dialWebRTC = async (conf: DialWebRTCConf): Promise<RobotClient> => {
   if (conf.credential) {
     creds = conf.credential;
   }
-  await client.connect(conf.authEntity || impliedURL, creds);
+  await client.connect({
+    authEntity: conf.authEntity || impliedURL,
+    creds,
+    priority: conf.priority,
+  });
 
   // eslint-disable-next-line no-console
   console.debug('connected via WebRTC');