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

Author: abcxff

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;
+}

tests/basic/deno.json

@@ -0,0 +1,20 @@
+{
+    "lint": {
+        "include": [
+            "src/"
+        ],
+        "exclude": [
+            "tests/"
+        ],
+        "rules": {
+            "exclude": [
+                "no-empty-interface",
+                "no-explicit-any",
+                "require-await"
+            ]
+        }
+    },
+    "fmt": {
+        "useTabs": true
+    }
+}