Migrate Source -> Server in protocol

Author: balloob

server.js

@@ -76,7 +76,7 @@ async function main() {
     // Create and start the Source server
     const server = new Server(
       {
-        source_id: generateUniqueId("server"),
+        server_id: generateUniqueId("server"),
         name: "SDKSample",
       },
       logger,

src/messages.ts

@@ -28,8 +28,8 @@ export interface PlayerTimeInfo {
 
 export interface ServerTimeInfo {
   player_transmitted: number;
-  source_received: number;
-  source_transmitted: number;
+  server_received: number;
+  server_transmitted: number;
 }
 
 export interface PlayerTimeMessage {
@@ -38,17 +38,17 @@ export interface PlayerTimeMessage {
 }
 
 export interface ServerInfo {
-  source_id: string;
+  server_id: string;
   name: string;
 }
 
 export interface ServerHelloMessage {
-  type: "source/hello";
+  type: "server/hello";
   payload: ServerInfo;
 }
 
 export interface ServerTimeMessage {
-  type: "source/time";
+  type: "server/time";
   payload: ServerTimeInfo;
 }
 

src/player/player.ts

@@ -149,7 +149,7 @@ export class Player extends EventEmitter<Events> {
   handleTextMessage(message: ServerMessages, receivedAt: number) {
     this.logger.log("Received text message:", message);
     switch (message.type) {
-      case "source/hello":
+      case "server/hello":
         this.serverInfo = message.payload;
         this.logger.log("Server connected:", this.serverInfo);
         this.fire("server-update", this.serverInfo);
@@ -175,7 +175,7 @@ export class Player extends EventEmitter<Events> {
         this.fire("metadata-update", this.metadata);
         break;
 
-      case "source/time":
+      case "server/time":
         // Pass player_received time to the handler
         this.handleServerTime(message.payload, receivedAt);
         break;
@@ -329,13 +329,13 @@ export class Player extends EventEmitter<Events> {
   }
 
   handleServerTime(payload: ServerTimeInfo, receivedAt: number) {
-    const { player_transmitted, source_received, source_transmitted } = payload;
+    const { player_transmitted, server_received, server_transmitted } = payload;
 
     // Calculate the raw offset from this message (in seconds)
     const offset =
-      (source_received -
+      (server_received -
         player_transmitted +
-        (source_transmitted - receivedAt)) /
+        (server_transmitted - receivedAt)) /
       2 /
       1000000;
 

src/server/server-client.ts

@@ -89,13 +89,13 @@ export class ServerClient extends EventEmitter<ServerClientEvents> {
 
   private handlePlayerTime(playerTimeInfo: PlayerTimeInfo) {
     const timeResponseMessage = {
-      type: "source/time" as const,
+      type: "server/time" as const,
       payload: {
         player_transmitted: playerTimeInfo.player_transmitted,
-        source_received: Math.round(
+        server_received: Math.round(
           (performance.timeOrigin + performance.now()) * 1000,
         ),
-        source_transmitted: Math.round(
+        server_transmitted: Math.round(
           (performance.timeOrigin + performance.now()) * 1000,
         ),
       },

src/server/server.ts

@@ -12,7 +12,7 @@ export class Server {
 
   addClient(client: ServerClient) {
     client.send({
-      type: "source/hello" as const,
+      type: "server/hello" as const,
       payload: this.getServerInfo(),
     });
     this.clients.set(client.clientId, client);