add analytics report logging

Author: lherman-cs

peer/generate.bash

@@ -0,0 +1,6 @@
+#!/bin/bash
+set -e
+
+protoc --ts_out=src --experimental_allow_proto3_optional --ts_opt=client_generic --proto_path proto/v1 ./proto/v1/signaling.proto
+node ./scripts/patch.cjs
+sed -i '1s;^;// @ts-nocheck\n;' ./src/google/protobuf/timestamp.ts

peer/package.json

@@ -19,7 +19,7 @@
     }
   },
   "scripts": {
-    "gen": "protoc --ts_out=src --experimental_allow_proto3_optional --ts_opt=client_generic --proto_path proto/v1 ./proto/v1/signaling.proto && node ./scripts/patch.cjs",
+    "gen": "bash ./generate.bash",
     "dev": "vite",
     "build": "tsup src/index.ts --format esm,cjs --dts --minify",
     "clean": "rm -rf dist",

peer/proto

@@ -1,3 +1,4 @@
+// @ts-nocheck
 // @generated by protobuf-ts 2.9.4 with parameter client_generic
 // @generated from protobuf file "google/protobuf/timestamp.proto" (package "google.protobuf", syntax proto3)
 // tslint:disable

peer/src/google/protobuf/timestamp.ts

@@ -19,7 +19,7 @@ import { Timestamp } from "./google/protobuf/timestamp.ts";
 
 export type { PeerInfo } from "./signaling.ts";
 
-const ANALYTICS_POLL_INTERVAL_MS = 60_000;
+const ANALYTICS_POLL_INTERVAL_MS = 5_000;
 
 /**
  * Streamline real-time application development.`@pulsebeam/peer` abstracts
@@ -313,10 +313,11 @@ export class Peer {
   start() {
     if (this._state === "closed") throw new Error("peer is already closed");
     this.transport.listen();
-    if (
-      this.opts.disableAnalytics != undefined ||
-      this.opts.disableAnalytics === false
-    ) {
+    const analyticsEnabled = this.opts.disableAnalytics == undefined ||
+      this.opts.disableAnalytics === false;
+
+    this.logger.info(`analytics ${analyticsEnabled ? "enabled" : "disabled"}`);
+    if (analyticsEnabled) {
       this.analyticsLoop();
     }
   }

peer/src/peer.ts

@@ -334,9 +334,9 @@ export interface AnalyticsEvent {
      */
     tags?: AnalyticsTags;
     /**
-     * @generated from protobuf field: pulsebeam.v1.AnalyticsMetric metrics = 3;
+     * @generated from protobuf field: pulsebeam.v1.AnalyticsMetrics metrics = 3;
      */
-    metrics?: AnalyticsMetric;
+    metrics?: AnalyticsMetrics;
 }
 /**
  * @generated from protobuf message pulsebeam.v1.AnalyticsTags
@@ -354,9 +354,9 @@ export interface AnalyticsTags {
 /**
  * "scaled" = trunc(X * 10^3)
  *
- * @generated from protobuf message pulsebeam.v1.AnalyticsMetric
+ * @generated from protobuf message pulsebeam.v1.AnalyticsMetrics
  */
-export interface AnalyticsMetric {
+export interface AnalyticsMetrics {
     /**
      * The overall derived quality score:
      * - 80-100: excellent
@@ -690,7 +690,7 @@ class AnalyticsEvent$Type extends MessageType<AnalyticsEvent> {
         super("pulsebeam.v1.AnalyticsEvent", [
             { no: 1, name: "timestamp", kind: "message", T: () => Timestamp },
             { no: 2, name: "tags", kind: "message", T: () => AnalyticsTags },
-            { no: 3, name: "metrics", kind: "message", T: () => AnalyticsMetric }
+            { no: 3, name: "metrics", kind: "message", T: () => AnalyticsMetrics }
         ]);
     }
 }
@@ -712,17 +712,17 @@ class AnalyticsTags$Type extends MessageType<AnalyticsTags> {
  */
 export const AnalyticsTags = new AnalyticsTags$Type();
 // @generated message type with reflection information, may provide speed optimized methods
-class AnalyticsMetric$Type extends MessageType<AnalyticsMetric> {
+class AnalyticsMetrics$Type extends MessageType<AnalyticsMetrics> {
     constructor() {
-        super("pulsebeam.v1.AnalyticsMetric", [
+        super("pulsebeam.v1.AnalyticsMetrics", [
             { no: 1, name: "quality_score", kind: "scalar", T: 18 /*ScalarType.SINT64*/, L: 0 /*LongType.BIGINT*/ }
         ]);
     }
 }
 /**
- * @generated MessageType for protobuf message pulsebeam.v1.AnalyticsMetric
+ * @generated MessageType for protobuf message pulsebeam.v1.AnalyticsMetrics
  */
-export const AnalyticsMetric = new AnalyticsMetric$Type();
+export const AnalyticsMetrics = new AnalyticsMetrics$Type();
 // @generated message type with reflection information, may provide speed optimized methods
 class AnalyticsReportResp$Type extends MessageType<AnalyticsReportResp> {
     constructor() {