wip

packages/signals/browser-signals/src/core/processor/processor.ts

@@ -0,0 +1,44 @@
+//    class SignalsEventProcessor {
+//     private sandbox: Sandbox
+//     private signalsRuntime: SignalsRuntime
+//     constructor(public analyticsInstance: Analytics) {
+//         this.sandbox = new Sandbox(analyticsInstance.cdnSettings.edgeFn)
+//         this.signalsRuntime = new SignalsRuntime(new SignalBuffer())
+//     }
+
+//     process(signal: Signal) {
+//         // todo: think about loop protection
+//         const events = await this.sandbox.process(signal)
+//         // proxy arguments to real analytics instance
+//         Object.keys(events).forEach((eventName) => this.analyticsInstance[eventName](events[eventName]))
+//     }
+
+//     cleanup() {
+//       this.sandbox.destroy()
+// }
+// }
+
+//      class Sandbox {
+//     	edgeFn: Promise<string>
+//     	jsSandbox = createWorkerBox()
+//        signalsRuntime: Signals
+
+//        constructor(edgeFnDownloadURL: URL, signals: Signals) {
+//           this.edgeFn = fetch(edgeFnDownloadURL).then(res => res.text())
+//        }
+
+//     async process(signal: Signal): SegmentEvents => {
+//         const scope = {
+//             Signals: this.signalsRuntime,
+//             analytics: new AnalyticsStub(),
+//             processSignal: await edgeFn,
+//         }
+
+//         await this.sandbox.run("processSignal(" + JSON.stringify(signal) + ");", scope)
+//         return analyticsStub.events
+//     }
+
+//     cleanup() {
+//         return this.jsSandbox.destroy()
+//     }
+// }

packages/signals/browser-signals/src/core/processor/sandbox.ts

@@ -0,0 +1,80 @@
+import { Signal } from '../../types'
+
+// could be the buffered signals object?
+class SignalsRuntime {
+  find(...args: any[]) {
+    throw new Error('nope')
+  }
+  // getNextIndex(...) {}
+}
+interface BufferedSegmentEvents {
+  track: any[]
+  identify: any[]
+}
+
+class AnalyticsRuntime {
+  events: BufferedSegmentEvents = { track: [], identify: [] }
+  track(...args: any[]) {
+    this.events.track.push(args)
+  }
+}
+
+interface SandboxSettings {
+  edgeFnDownloadUrl: string | URL
+  signalsRuntime: SignalsRuntime
+}
+interface JavascriptSandbox {
+  run: (fn: string, scope: Record<string, any>) => Promise<any>
+}
+
+export class Sandbox {
+  edgeFn: Promise<string>
+  signalsRuntime: SignalsRuntime
+  jsSandbox: JavascriptSandbox
+
+  constructor(settings: SandboxSettings) {
+    this.edgeFn = fetch(settings.edgeFnDownloadUrl).then((res) => res.text())
+    this.jsSandbox = {} as any // TODO
+    this.signalsRuntime = settings.signals
+  }
+
+  async process(signal: Signal): Promise<BufferedSegmentEvents> {
+    const analytics = new AnalyticsRuntime()
+    const scope = {
+      Signals: this.signalsRuntime,
+      analytics,
+      processSignal: await this.edgeFn,
+    }
+
+    await this.jsSandbox.run(
+      'processSignal(' + JSON.stringify(signal) + ');',
+      scope
+    )
+    return analytics.events
+  }
+}
+
+//      class Sandbox {
+//     	edgeFn: Promise<string>
+//     	jsSandbox = createWorkerBox()
+//        signalsRuntime: Signals
+
+//        constructor(edgeFnDownloadURL: URL, signals: Signals) {
+//           this.edgeFn = fetch(edgeFnDownloadURL).then(res => res.text())
+//        }
+
+//     async process(signal: Signal): SegmentEvents => {
+//         const scope = {
+//             Signals: this.signalsRuntime,
+//             analytics: new AnalyticsStub(),
+//             processSignal: await edgeFn,
+//         }
+
+//         await this.sandbox.run("processSignal(" + JSON.stringify(signal) + ");", scope)
+//         return analyticsStub.events
+//     }
+
+//     cleanup() {
+//         return this.jsSandbox.destroy()
+//     }
+// }

packages/signals/browser-signals/src/core/signals/index.ts

@@ -12,6 +12,7 @@ import { AnalyticsService } from '../analytics-service'
 
 interface SignalsSettings {
   maxBufferSize?: number
+  edgeFn__experimental?: string
 }
 
 export class Signals {