Merge pull request #3 from RooCodeInc/cte/events-api

Author: cte

.docker/scripts/postgres/create-databases.sh

@@ -6,6 +6,6 @@ set -u
 if [ -n "$POSTGRES_DATABASES" ]; then
   for db in $(echo $POSTGRES_DATABASES | tr ',' ' '); do
     echo "Creating $db..."
-    psql -v ON_ERROR_STOP=1 -c "CREATE DATABASE $db;"
+    psql -U postgres -v ON_ERROR_STOP=1 -c "CREATE DATABASE $db;"
   done
 fi

.env

@@ -1,6 +1,7 @@
 BILLING_PLAN_ENV=dev
 
 VSCODE_EXTENSION_BASE_URL=vscode://RooVeterinaryInc.roo-cline
+CURSOR_EXTENSION_BASE_URL=cursor://RooVeterinaryInc.roo-cline
 
 # Clerk
 # https://clerk.com/docs/deployments/clerk-environment-variables#sign-in-and-sign-up-redirects

.storybook/preview.ts

@@ -1,4 +1,4 @@
-import '../src/styles/global.css';
+import '../src/styles/globals.css';
 
 import type { Preview } from '@storybook/react';
 

eslint.config.mjs

@@ -28,7 +28,7 @@ export default [
     },
   },
   {
-    ignores: ['dist/**', '.next'],
+    ignores: ['dist/**', '.next', 'storybook-static'],
   },
   {
     ...pluginReact.configs.flat.recommended,

migrations/0000_hesitant_kylun.sql

@@ -0,0 +1,8 @@
+CREATE TABLE "events" (
+	"id" integer PRIMARY KEY GENERATED ALWAYS AS IDENTITY (sequence name "events_id_seq" INCREMENT BY 1 MINVALUE 1 MAXVALUE 2147483647 START WITH 1 CACHE 1),
+	"type" text NOT NULL,
+	"timestamp" bigint NOT NULL,
+	"properties" json NOT NULL,
+	"created_at" timestamp DEFAULT now() NOT NULL,
+	"updated_at" timestamp DEFAULT now() NOT NULL
+);

migrations/0000_misty_leo.sql

@@ -1,81 +1,64 @@
 {
-  "id": "013accf9-070a-47cd-9b49-1318a1c8a237",
+  "id": "5ab333f5-a980-4564-a919-3d15608505d0",
   "prevId": "00000000-0000-0000-0000-000000000000",
   "version": "7",
   "dialect": "postgresql",
   "tables": {
-    "public.organization": {
-      "name": "organization",
+    "public.events": {
+      "name": "events",
       "schema": "",
       "columns": {
         "id": {
           "name": "id",
-          "type": "text",
+          "type": "integer",
           "primaryKey": true,
-          "notNull": true
-        },
-        "stripe_customer_id": {
-          "name": "stripe_customer_id",
-          "type": "text",
-          "primaryKey": false,
-          "notNull": false
+          "notNull": true,
+          "identity": {
+            "type": "always",
+            "name": "events_id_seq",
+            "schema": "public",
+            "increment": "1",
+            "startWith": "1",
+            "minValue": "1",
+            "maxValue": "2147483647",
+            "cache": "1",
+            "cycle": false
+          }
         },
-        "stripe_subscription_id": {
-          "name": "stripe_subscription_id",
+        "type": {
+          "name": "type",
           "type": "text",
           "primaryKey": false,
-          "notNull": false
+          "notNull": true
         },
-        "stripe_subscription_price_id": {
-          "name": "stripe_subscription_price_id",
-          "type": "text",
+        "timestamp": {
+          "name": "timestamp",
+          "type": "bigint",
           "primaryKey": false,
-          "notNull": false
+          "notNull": true
         },
-        "stripe_subscription_status": {
-          "name": "stripe_subscription_status",
-          "type": "text",
+        "properties": {
+          "name": "properties",
+          "type": "json",
           "primaryKey": false,
-          "notNull": false
-        },
-        "stripe_subscription_current_period_end": {
-          "name": "stripe_subscription_current_period_end",
-          "type": "bigint",
-          "primaryKey": false,
-          "notNull": false
+          "notNull": true
         },
-        "updated_at": {
-          "name": "updated_at",
+        "created_at": {
+          "name": "created_at",
           "type": "timestamp",
           "primaryKey": false,
           "notNull": true,
           "default": "now()"
         },
-        "created_at": {
-          "name": "created_at",
+        "updated_at": {
+          "name": "updated_at",
           "type": "timestamp",
           "primaryKey": false,
           "notNull": true,
           "default": "now()"
         }
       },
-      "indexes": {
-        "stripe_customer_id_idx": {
-          "name": "stripe_customer_id_idx",
-          "columns": [
-            {
-              "expression": "stripe_customer_id",
-              "isExpression": false,
-              "asc": true,
-              "nulls": "last"
-            }
-          ],
-          "isUnique": true,
-          "concurrently": false,
-          "method": "btree",
-          "with": {}
-        }
-      },
+      "indexes": {},
       "foreignKeys": {},
       "compositePrimaryKeys": {},
       "uniqueConstraints": {},

migrations/meta/0000_snapshot.json

@@ -5,8 +5,8 @@
     {
       "idx": 0,
       "version": "7",
-      "when": 1747031111132,
-      "tag": "0000_misty_leo",
+      "when": 1747204609794,
+      "tag": "0000_hesitant_kylun",
       "breakpoints": true
     }
   ]

migrations/meta/_journal.json

@@ -0,0 +1,28 @@
+import { auth } from '@clerk/nextjs/server';
+import { NextRequest, NextResponse } from 'next/server';
+
+import { eventSchema } from '@/schemas';
+import { db } from '@/db';
+import { eventsTable } from '@/db/schema';
+
+export async function POST(request: NextRequest) {
+  const { userId } = await auth();
+
+  if (!userId) {
+    return NextResponse.json(
+      { error: 'Unauthorized request' },
+      { status: 401 },
+    );
+  }
+
+  const payload = await request.json();
+  const result = eventSchema.safeParse(payload);
+
+  if (!result.success) {
+    return NextResponse.json({ success: false });
+  }
+
+  const [record] = await db.insert(eventsTable).values(result.data).returning();
+
+  return NextResponse.json({ success: true, id: record?.id });
+}