Add WebSocket v2 protocol support

Add fdr branch + main

Add Cloudflare deploy job for FDR

Author: haoruizhou

.github/workflows/telemetry-ci.yml

@@ -6,11 +6,13 @@ on:
     paths:
       - 'universal-telemetry-software/**'
       - 'pecan/**'
+      - 'flight-recorder/**'
       - '.github/workflows/telemetry-ci.yml'
   pull_request:
     paths:
       - 'universal-telemetry-software/**'
       - 'pecan/**'
+      - 'flight-recorder/**'
       - '.github/workflows/telemetry-ci.yml'
 
 jobs:
@@ -19,6 +21,7 @@ jobs:
     outputs:
       telemetry: ${{ steps.filter.outputs.telemetry }}
       pecan: ${{ steps.filter.outputs.pecan }}
+      fdr: ${{ steps.filter.outputs.fdr }}
     steps:
       - uses: actions/checkout@v4
       - uses: dorny/paths-filter@v3
@@ -29,6 +32,8 @@ jobs:
               - 'universal-telemetry-software/**'
             pecan:
               - 'pecan/**'
+            fdr:
+              - 'flight-recorder/**'
 
   # ── Build images once, share via artifact ───────────────────────────────
   build:
@@ -123,6 +128,12 @@ jobs:
         npm ci
         npx tsc --noEmit
 
+    - name: Build and typecheck FDR
+      working-directory: ./flight-recorder
+      run: |
+        npm ci
+        npx tsc --noEmit
+
     - name: Set up Python
       uses: actions/setup-python@v5
       with:
@@ -569,3 +580,40 @@ jobs:
           directory: './pecan/dist'
           gitHubToken: ${{ secrets.GITHUB_TOKEN }}
           branch: dev
+
+  deploy-fdr-cloudflare:
+    needs: [unit-tests, integration, vcan]
+    runs-on: ubuntu-latest
+    if: github.ref == 'refs/heads/main' || github.ref == 'refs/heads/fdr'
+    permissions:
+      contents: read
+      deployments: write
+    
+    steps:
+      - name: Checkout code
+        uses: actions/checkout@v4
+      
+      - name: Setup Node.js
+        uses: actions/setup-node@v4
+        with:
+          node-version: '20'
+          cache: 'npm'
+          cache-dependency-path: flight-recorder/package-lock.json
+      
+      - name: Install dependencies
+        working-directory: ./flight-recorder
+        run: npm ci
+      
+      - name: Build
+        working-directory: ./flight-recorder
+        run: npm run build
+      
+      - name: Deploy to Cloudflare Pages
+        uses: cloudflare/pages-action@v1
+        with:
+          apiToken: ${{ secrets.CLOUDFLARE_API_TOKEN }}
+          accountId: ${{ secrets.CLOUDFLARE_ACCOUNT_ID }}
+          projectName: 'wfr-fdr'
+          directory: './flight-recorder/dist'
+          gitHubToken: ${{ secrets.GITHUB_TOKEN }}
+          branch: ${{ github.ref_name }}

flight-recorder/src/utils/canProcessor.test.ts

@@ -0,0 +1,21 @@
+import { describe, it, expect } from 'vitest';
+import { createCanProcessor } from './canProcessor';
+
+describe('FDR Protocol V2 Compatibility', () => {
+    it('should process Protocol V2 enveloped messages from Dashboard', async () => {
+        const processor = await createCanProcessor();
+        const v2Message = {
+            type: 'can_data',
+            messages: [
+                { canId: 192, data: [0x05, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00], time: 1000 }
+            ]
+        };
+        const result = processor.processWebSocketMessage(v2Message);
+
+        expect(Array.isArray(result)).toBe(true);
+        expect(result?.length).toBe(1);
+        expect(result?.[0]?.messageName).toBe('M192_Command_Message');
+        expect(result?.[0]?.canId).toBe(192);
+        expect(result?.[0]?.time).toBe(1000);
+    });
+});

flight-recorder/src/utils/canProcessor.ts

@@ -88,6 +88,8 @@ interface WebSocketMessage {
   canId?: number;
   id?: number;
   data?: number[];
+  type?: string;
+  messages?: WebSocketMessage[];
 }
 
 type WebSocketInput = string | WebSocketMessage | WebSocketMessage[];
@@ -581,6 +583,11 @@ export async function createCanProcessor(): Promise<any> {
 
       // If it's an object with time, canId/id and data properties
       if (typeof wsMessage === "object") {
+        // Handle Protocol V2 envelope: {"type": "can_data", "messages": [...]}
+        if ((wsMessage as any).type === "can_data" && Array.isArray((wsMessage as any).messages)) {
+          return this.processWebSocketMessage((wsMessage as any).messages);
+        }
+
         const time = wsMessage.time || wsMessage.timestamp || Date.now();
         const canId = wsMessage.canId || wsMessage.id;
         const data = wsMessage.data;

flight-recorder/tsconfig.app.json

@@ -0,0 +1,28 @@
+{
+  "compilerOptions": {
+    "tsBuildInfoFile": "./node_modules/.tmp/tsconfig.app.tsbuildinfo",
+    "target": "ES2022",
+    "useDefineForClassFields": true,
+    "lib": ["ES2022", "DOM", "DOM.Iterable"],
+    "module": "ESNext",
+    "types": ["vite/client"],
+    "skipLibCheck": true,
+
+    /* Bundler mode */
+    "moduleResolution": "bundler",
+    "allowImportingTsExtensions": true,
+    "verbatimModuleSyntax": true,
+    "moduleDetection": "force",
+    "noEmit": true,
+    "jsx": "react-jsx",
+
+    /* Linting */
+    "strict": true,
+    "noUnusedLocals": true,
+    "noUnusedParameters": true,
+    "erasableSyntaxOnly": true,
+    "noFallthroughCasesInSwitch": true,
+    "noUncheckedSideEffectImports": true
+  },
+  "include": ["src"]
+}

flight-recorder/tsconfig.json

@@ -0,0 +1,7 @@
+{
+  "files": [],
+  "references": [
+    { "path": "./tsconfig.app.json" },
+    { "path": "./tsconfig.node.json" }
+  ]
+}

flight-recorder/tsconfig.node.json

@@ -0,0 +1,26 @@
+{
+  "compilerOptions": {
+    "tsBuildInfoFile": "./node_modules/.tmp/tsconfig.node.tsbuildinfo",
+    "target": "ES2023",
+    "lib": ["ES2023"],
+    "module": "ESNext",
+    "types": [],
+    "skipLibCheck": true,
+
+    /* Bundler mode */
+    "moduleResolution": "bundler",
+    "allowImportingTsExtensions": true,
+    "verbatimModuleSyntax": true,
+    "moduleDetection": "force",
+    "noEmit": true,
+
+    /* Linting */
+    "strict": true,
+    "noUnusedLocals": true,
+    "noUnusedParameters": true,
+    "erasableSyntaxOnly": true,
+    "noFallthroughCasesInSwitch": true,
+    "noUncheckedSideEffectImports": true
+  },
+  "include": ["vite.config.ts"]
+}

pecan/src/utils/canProcessor.test.ts

@@ -330,6 +330,23 @@ describe('CAN Processor Unit Tests', () => {
             expect(result.length).toBe(3); // 2 valid CAN messages + 1 unknown CAN message
             expect(result[1].messageName).toBe('Unknown_CAN_0x0000270F');
         });
+
+        it('should process Protocol V2 enveloped messages from Dashboard', async () => {
+            const processor = await createCanProcessor();
+            const v2Message = {
+                type: 'can_data',
+                messages: [
+                    { canId: 192, data: [0x05, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00], time: 1000 }
+                ]
+            };
+            const result = processor.processWebSocketMessage(v2Message);
+
+            expect(Array.isArray(result)).toBe(true);
+            expect(result?.length).toBe(1);
+            expect(result?.[0]?.messageName).toBe('M192_Command_Message');
+            expect(result?.[0]?.canId).toBe(192);
+            expect(result?.[0]?.time).toBe(1000);
+        });
     });
 
     describe('DBC File Loading', () => {

pecan/src/utils/canProcessor.ts

@@ -132,6 +132,8 @@ interface WebSocketMessage {
   canId?: number;
   id?: number;
   data?: number[];
+  type?: string;
+  messages?: WebSocketMessage[];
 }
 
 type WebSocketInput = string | WebSocketMessage | WebSocketMessage[];
@@ -625,6 +627,11 @@ export async function createCanProcessor(): Promise<any> {
 
       // If it's an object with time, canId/id and data properties
       if (typeof wsMessage === "object") {
+        // Handle Protocol V2 envelope: {"type": "can_data", "messages": [...]}
+        if ((wsMessage as any).type === "can_data" && Array.isArray((wsMessage as any).messages)) {
+          return this.processWebSocketMessage((wsMessage as any).messages);
+        }
+
         const time = wsMessage.time || wsMessage.timestamp || Date.now();
         const canId = wsMessage.canId || wsMessage.id;
         const data = wsMessage.data;