feat(OGBEE-81): Implement push_event and hypertable init (OGBEE-89)

modules/analytics/module.json

@@ -9,6 +9,9 @@
 		"ABCxFF"
 	],
 	"scripts": {
+		"push_event": {
+			"public": true
+		}
 	},
 	"errors": {},
 	"dependencies": {}

modules/analytics/scripts/push_event.ts

@@ -0,0 +1,31 @@
+import { ScriptContext } from "../module.gen.ts";
+import { createHypertable } from "../utils/hypertable_init.ts";
+
+export interface Request {
+    name: string,
+    metadata: any,
+    timestampOverride?: string,
+}
+
+export interface Response {
+    id: string,
+    timestamp: number,
+}
+
+export async function run(
+    ctx: ScriptContext,
+    req: Request,
+): Promise<Response> {
+	createHypertable(ctx);
+    const timestamp = req.timestampOverride ? new Date(req.timestampOverride) : new Date();
+    const event = await ctx.db.event.create({
+        data: {
+            name: req.name,
+            timestamp,
+            metadata: req.metadata
+        }
+    });
+
+    return { id: event.id, timestamp: timestamp.getTime() };
+}
+

modules/analytics/utils/hypertable_init.ts

@@ -0,0 +1,10 @@
+import { ScriptContext } from "../module.gen.ts";
+
+let hasDefinitelyRun = false;
+export const createHypertable = async (ctx: ScriptContext) => {
+    if (hasDefinitelyRun) return;
+
+    await ctx.db.$queryRaw`SELECT create_hypertable('event', 'timestamp');`;
+
+    hasDefinitelyRun = true;
+}