Add view counter

packages/view-storage/package.json

@@ -3,15 +3,15 @@
   "module": "src/index.ts",
   "types": "src/index.ts",
   "type": "module",
+  "dependencies": {
+    "@libsql/client": "^0.6.0",
+    "drizzle-orm": "^0.30.7"
+  },
   "devDependencies": {
     "@types/bun": "latest",
     "drizzle-kit": "^0.20.14"
   },
   "peerDependencies": {
     "typescript": "^5.0.0"
-  },
-  "dependencies": {
-    "@planetscale/database": "^1.16.0",
-    "drizzle-orm": "^0.29.4"
   }
 }

packages/view-storage/src/client.ts

@@ -1,17 +1,15 @@
-import { Client } from "@planetscale/database";
-import { drizzle } from "drizzle-orm/planetscale-serverless";
+import { createClient } from "@libsql/client";
+import { drizzle } from "drizzle-orm/libsql";
 
 export type CreateDbOptions = {
-  host: string;
-  username: string;
-  password: string;
+  authToken: string;
+  url: string;
 };
 
-export function createDb({ host, username, password }: CreateDbOptions) {
-  const client = new Client({
-    host: host,
-    username: username,
-    password: password,
+export function createDb({ authToken, url }: CreateDbOptions) {
+  const client = createClient({
+    authToken,
+    url,
   });
   return drizzle(client);
 }

packages/view-storage/src/schema.ts

@@ -1,21 +1,20 @@
 import { sql } from "drizzle-orm";
 import {
   index,
-  mysqlTableCreator,
-  serial,
-  timestamp,
-  varchar,
-} from "drizzle-orm/mysql-core";
+  integer,
+  sqliteTableCreator,
+  text,
+} from "drizzle-orm/sqlite-core";
 
-const mysqlTable = mysqlTableCreator((name) => `timsexperiments_${name}`);
+const mysqlTable = sqliteTableCreator((name) => `timsexperiments_${name}`);
 
 export const views = mysqlTable(
   "views",
   {
-    id: serial("id").primaryKey(),
-    page: varchar("page", { length: 256 }).notNull(),
-    ipAddress: varchar("ip_address", { length: 40 }).notNull(),
-    viewedAt: timestamp("viewed_at")
+    id: integer("id").primaryKey({ autoIncrement: true }),
+    page: text("page", { length: 256 }).notNull(),
+    ipAddress: text("ip_address", { length: 40 }).notNull(),
+    viewedAt: integer("viewedAt", { mode: "timestamp_ms" })
       .default(sql`CURRENT_TIMESTAMP()`)
       .notNull(),
   },

packages/view-storage/src/views.ts

@@ -25,7 +25,7 @@ export class ViewsStorage {
    * @param {ViewsDatabase} db - The ViewsDatabase instance used for storing views data.
    */
   async add(...viewList: View[]) {
-    return (await this.db.insert(views).values(viewList)).insertId;
+    return (await this.db.insert(views).values(viewList)).lastInsertRowid;
   }
 
   /**