Adding built protobuf stuff and related helpers etc.

Common/package.json

@@ -6,8 +6,10 @@
     "types": "types/pixelstreamingcommon.d.ts",
     "sideEffects": false,
     "scripts": {
+        "build_proto": "npx protoc --ts_out src/Messages --proto_path protobuf protobuf/signalling_messages.proto",
         "compile": "tsc --build --clean && tsc",
         "build": "tsc --build --clean && tsc",
+        "build-all": "npm run build_proto && npm run build",
         "test": "echo \"Error: no test specified\" && exit 1",
         "lint": "eslint . --ext .js,.jsx,.ts,.tsx"
     },
@@ -30,5 +32,8 @@
     "license": "MIT",
     "publishConfig": {
         "access": "public"
+    },
+    "dependencies": {
+        "@protobuf-ts/plugin": "^2.9.3"
     }
 }

Common/src/Messages/base_message.ts

@@ -0,0 +1,3 @@
+export interface BaseMessage {
+    type: string;
+} 

Common/src/Messages/message_helpers.ts

@@ -0,0 +1,11 @@
+import { IMessageType } from "@protobuf-ts/runtime";
+import { BaseMessage } from './base_message';
+
+export function createMessage(messageType: IMessageType<BaseMessage>, params?: any) {
+    const message = messageType.create();
+    message.type = messageType.typeName;
+    if (params) {
+        messageType.mergePartial(message, params);
+    }
+    return message;
+}

Common/src/Messages/message_registry.ts

@@ -0,0 +1,28 @@
+import { IMessageType } from "@protobuf-ts/runtime";
+import * as Messages from './signalling_messages';
+import { BaseMessage } from './base_message';
+
+export const MessageRegistry: Record<string, IMessageType<BaseMessage>> = {
+    'answer': Messages.answer,
+    'config': Messages.config,
+    'dataChannelRequest': Messages.dataChannelRequest,
+    'disconnectPlayer': Messages.disconnectPlayer,
+    'endpointId': Messages.endpointId,
+    'iceCandidate': Messages.iceCandidate,
+    'identify': Messages.identify,
+    'layerPreference': Messages.layerPreference,
+    'listStreamers': Messages.listStreamers,
+    'offer': Messages.offer,
+    'peerDataChannelsReady': Messages.peerDataChannelsReady,
+    'ping': Messages.ping,
+    'playerConnected': Messages.playerConnected,
+    'playerCount': Messages.playerCount,
+    'playerDisconnected': Messages.playerDisconnected,
+    'pong': Messages.pong,
+    'stats': Messages.stats,
+    'streamerDataChannels': Messages.streamerDataChannels,
+    'streamerDisconnected': Messages.streamerDisconnected,
+    'streamerList': Messages.streamerList,
+    'subscribe': Messages.subscribe,
+    'unsubscribe': Messages.unsubscribe,
+}