feat: sqlite v2

Author: jog1t

.gitignore

@@ -184,3 +184,5 @@ Cargo.lock
 **/.wrangler
 **/.DS_Store
 .aider*
+
+packages/**/tsup.config.bundled_*.mjs

examples/drizzle/drizzle/0000_wonderful_iron_patriot.sql renamed to examples/drizzle/drizzle/0000_moaning_tomorrow_man.sql

@@ -1,7 +1,7 @@
 {
   "version": "6",
   "dialect": "sqlite",
-  "id": "22f3d49c-97d5-46ca-b0f1-99950c3efec7",
+  "id": "5175c351-75eb-4f1d-9211-7ee520f0b9c2",
   "prevId": "00000000-0000-0000-0000-000000000000",
   "tables": {
     "users_table": {

examples/drizzle/drizzle/meta/0000_snapshot.json

@@ -5,15 +5,8 @@
     {
       "idx": 0,
       "version": "6",
-      "when": 1750711614205,
-      "tag": "0000_wonderful_iron_patriot",
-      "breakpoints": true
-    },
-    {
-      "idx": 1,
-      "version": "6",
-      "when": 1750716663518,
-      "tag": "0001_rich_susan_delgado",
+      "when": 1750976447195,
+      "tag": "0000_moaning_tomorrow_man",
       "breakpoints": true
     }
   ]

examples/drizzle/drizzle/meta/_journal.json

@@ -1,10 +1,10 @@
 import journal from './meta/_journal.json';
-import m0000 from './0000_wonderful_iron_patriot.sql';
+import m0000 from './0000_moaning_tomorrow_man.sql';
 
   export default {
     journal,
     migrations: {
-      m0000,
+      m0000
     }
   }
 

examples/drizzle/drizzle/migrations.js

@@ -4,17 +4,19 @@
   "private": true,
   "type": "module",
   "scripts": {
-    "dev": "tsx --watch src/server.ts",
+    "dev": "tsx --loader @rivetkit/sql-loader --watch src/server.ts",
     "check-types": "tsc --noEmit"
   },
   "devDependencies": {
+    "@rivetkit/actor": "workspace:*",
+    "@rivetkit/sql-loader": "workspace:*",
     "@types/node": "^22.13.9",
-    "rivetkit": "workspace:*",
     "tsx": "^3.12.7",
     "typescript": "^5.5.2"
   },
   "dependencies": {
     "@rivetkit/db": "workspace:0.9.0-rc.1",
+    "better-sqlite3": "^12.1.1",
     "drizzle-kit": "^0.31.2",
     "drizzle-orm": "^0.44.2"
   },

examples/drizzle/hooks.js

@@ -0,0 +1,30 @@
+/// <reference types="node" />
+import { createClient } from "@rivetkit/actor/client";
+import type { Registry } from "../src/registry";
+
+async function main() {
+	const client = createClient<Registry>(
+		process.env.ENDPOINT ?? "http://127.0.0.1:8080",
+	);
+
+	const contacts = client.contacts.getOrCreate();
+
+	// counter.on("newCount", (count: number) => console.log("Event:", count));
+
+	for (let i = 0; i < 5; i++) {
+		const out = await contacts.insert({
+			name: `User ${i}`,
+			age: 20 + i,
+			email: `example+${i}@example.com`,
+		});
+		console.log("Inserted:", out);
+	}
+
+	console.log("Reading all users:");
+	const users = await contacts.read();
+	console.log(users);
+
+	// await counter.dispose();
+}
+
+main();

examples/drizzle/package.json

@@ -1,9 +1,8 @@
-// import { int, sqliteTable, text } from "@rivetkit/db/drizzle";
+import { int, sqliteTable, text } from "@rivetkit/db/drizzle";
 
-// export const usersTable = sqliteTable("users_table", {
-// 	id: int().primaryKey({ autoIncrement: true }),
-// 	name: text().notNull(),
-// 	age: int().notNull(),
-// 	email: text().notNull().unique(),
-// 	email2: text().notNull().unique(),
-// });
+export const usersTable = sqliteTable("users_table", {
+	id: int().primaryKey({ autoIncrement: true }),
+	name: text().notNull(),
+	age: int().notNull(),
+	email: text().notNull().unique(),
+});