alezmad/claudemesh
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(db): rename mesh.member export to meshMember to avoid collision with auth.member

Browse Source 
The schema/index.ts barrel does `export * from "./mesh"` + `export *
from "./auth"`. Both modules exported a symbol named `member`, which
caused TypeScript to silently exclude the ambiguous re-export and
drizzle-kit's introspection couldn't see mesh.member — its generated
migration was missing that table entirely.

Fix: rename the TypeScript binding only. The DB table name stays
"member" inside pgSchema "mesh" (still mesh.member in SQL):
- `export const member = schema.table("member", ...)` →
  `export const meshMember = schema.table("member", ...)`
- Internal references in mesh.ts updated (FK lambdas, relations,
  Zod schemas, inferred TS types)
- apps/broker/src/broker.ts import updated to meshMember as memberTable
- migrations/0000_sloppy_stryfe.sql regenerated — now includes all 7
  mesh.* tables (audit_log, invite, member, mesh, message_queue,
  pending_status, presence)

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
This commit is contained in:
Alejandro Gutiérrez
2026-04-04 21:47:02 +01:00
parent cde08ea3c3
commit beeaa3b3c6
5 changed files with 3227 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
apps/broker/src/broker.ts
View File

@@ -17,7 +17,7 @@
import { and, asc, eq, inArray, isNull, lt, or, sql } from "drizzle-orm";
import { db } from "./db";
import {
member as memberTable,
meshMember as memberTable,
messageQueue,
pendingStatus,
presence,

392
packages/db/migrations/0000_sloppy_stryfe.sql Normal file
View File

@@ -0,0 +1,392 @@
CREATE SCHEMA "pdf";
--> statement-breakpoint
CREATE TYPE "public"."credit_transaction_type" AS ENUM('signup', 'purchase', 'usage', 'admin_grant', 'admin_deduct', 'refund', 'promo', 'referral', 'expiry');--> statement-breakpoint
CREATE TYPE "public"."status" AS ENUM('active', 'canceled', 'incomplete', 'incomplete_expired', 'past_due', 'paused', 'trialing', 'unpaid');--> statement-breakpoint
CREATE TYPE "public"."plan" AS ENUM('free', 'premium', 'enterprise');--> statement-breakpoint
CREATE TYPE "chat"."role" AS ENUM('system', 'assistant', 'user');--> statement-breakpoint
CREATE TYPE "pdf"."role" AS ENUM('user', 'assistant', 'system');--> statement-breakpoint
CREATE TYPE "pdf"."processing_status" AS ENUM('pending', 'processing', 'ready', 'failed');--> statement-breakpoint
CREATE TYPE "pdf"."unit_type" AS ENUM('prose', 'heading', 'list', 'table', 'code');--> statement-breakpoint
CREATE TYPE "image"."aspect_ratio" AS ENUM('square', 'standard', 'landscape', 'portrait');--> statement-breakpoint
CREATE TYPE "mesh"."role" AS ENUM('admin', 'member');--> statement-breakpoint
CREATE TYPE "mesh"."tier" AS ENUM('free', 'pro', 'team', 'enterprise');--> statement-breakpoint
CREATE TYPE "mesh"."transport" AS ENUM('managed', 'tailscale', 'self_hosted');--> statement-breakpoint
CREATE TYPE "mesh"."visibility" AS ENUM('private', 'public');--> statement-breakpoint
CREATE TYPE "mesh"."message_priority" AS ENUM('now', 'next', 'low');--> statement-breakpoint
CREATE TYPE "mesh"."presence_status" AS ENUM('idle', 'working', 'dnd');--> statement-breakpoint
CREATE TYPE "mesh"."presence_status_source" AS ENUM('hook', 'manual', 'jsonl');--> statement-breakpoint
CREATE TABLE "account" (
"id" text PRIMARY KEY NOT NULL,
"account_id" text NOT NULL,
"provider_id" text NOT NULL,
"user_id" text NOT NULL,
"access_token" text,
"refresh_token" text,
"id_token" text,
"access_token_expires_at" timestamp,
"refresh_token_expires_at" timestamp,
"scope" text,
"password" text,
"created_at" timestamp DEFAULT now() NOT NULL,
"updated_at" timestamp NOT NULL
);
--> statement-breakpoint
CREATE TABLE "invitation" (
"id" text PRIMARY KEY NOT NULL,
"organization_id" text NOT NULL,
"email" text NOT NULL,
"role" text,
"status" text DEFAULT 'pending' NOT NULL,
"expires_at" timestamp NOT NULL,
"created_at" timestamp DEFAULT now() NOT NULL,
"inviter_id" text NOT NULL
);
--> statement-breakpoint
CREATE TABLE "member" (
"id" text PRIMARY KEY NOT NULL,
"organization_id" text NOT NULL,
"user_id" text NOT NULL,
"role" text DEFAULT 'member' NOT NULL,
"created_at" timestamp NOT NULL
);
--> statement-breakpoint
CREATE TABLE "organization" (
"id" text PRIMARY KEY NOT NULL,
"name" text NOT NULL,
"slug" text NOT NULL,
"logo" text,
"created_at" timestamp NOT NULL,
"metadata" text,
CONSTRAINT "organization_slug_unique" UNIQUE("slug")
);
--> statement-breakpoint
CREATE TABLE "passkey" (
"id" text PRIMARY KEY NOT NULL,
"name" text,
"public_key" text NOT NULL,
"user_id" text NOT NULL,
"credential_id" text NOT NULL,
"counter" integer NOT NULL,
"device_type" text NOT NULL,
"backed_up" boolean NOT NULL,
"transports" text,
"created_at" timestamp,
"aaguid" text
);
--> statement-breakpoint
CREATE TABLE "session" (
"id" text PRIMARY KEY NOT NULL,
"expires_at" timestamp NOT NULL,
"token" text NOT NULL,
"created_at" timestamp DEFAULT now() NOT NULL,
"updated_at" timestamp NOT NULL,
"ip_address" text,
"user_agent" text,
"user_id" text NOT NULL,
"impersonated_by" text,
"active_organization_id" text,
CONSTRAINT "session_token_unique" UNIQUE("token")
);
--> statement-breakpoint
CREATE TABLE "two_factor" (
"id" text PRIMARY KEY NOT NULL,
"secret" text NOT NULL,
"backup_codes" text NOT NULL,
"user_id" text NOT NULL
);
--> statement-breakpoint
CREATE TABLE "user" (
"id" text PRIMARY KEY NOT NULL,
"name" text NOT NULL,
"email" text NOT NULL,
"email_verified" boolean DEFAULT false NOT NULL,
"image" text,
"created_at" timestamp DEFAULT now() NOT NULL,
"updated_at" timestamp DEFAULT now() NOT NULL,
"two_factor_enabled" boolean DEFAULT false,
"is_anonymous" boolean DEFAULT false,
"role" text,
"banned" boolean DEFAULT false,
"ban_reason" text,
"ban_expires" timestamp,
CONSTRAINT "user_email_unique" UNIQUE("email")
);
--> statement-breakpoint
CREATE TABLE "verification" (
"id" text PRIMARY KEY NOT NULL,
"identifier" text NOT NULL,
"value" text NOT NULL,
"expires_at" timestamp NOT NULL,
"created_at" timestamp DEFAULT now() NOT NULL,
"updated_at" timestamp DEFAULT now() NOT NULL
);
--> statement-breakpoint
CREATE TABLE "credit_transaction" (
"id" text PRIMARY KEY NOT NULL,
"customer_id" text NOT NULL,
"amount" integer NOT NULL,
"type" "credit_transaction_type" NOT NULL,
"reason" text,
"metadata" text,
"balance_after" integer NOT NULL,
"created_at" timestamp DEFAULT now() NOT NULL,
"created_by" text
);
--> statement-breakpoint
CREATE TABLE "customer" (
"id" text PRIMARY KEY NOT NULL,
"user_id" text NOT NULL,
"customer_id" text NOT NULL,
"status" "status",
"plan" "plan",
"credits" integer DEFAULT 100 NOT NULL,
"created_at" timestamp DEFAULT now() NOT NULL,
"updated_at" timestamp NOT NULL,
CONSTRAINT "customer_userId_unique" UNIQUE("user_id"),
CONSTRAINT "customer_customerId_unique" UNIQUE("customer_id")
);
--> statement-breakpoint
CREATE TABLE "chat"."chat" (
"id" text PRIMARY KEY NOT NULL,
"name" text,
"user_id" text NOT NULL,
"created_at" timestamp DEFAULT now()
);
--> statement-breakpoint
CREATE TABLE "chat"."message" (
"id" text PRIMARY KEY NOT NULL,
"chat_id" text NOT NULL,
"role" "chat"."role" NOT NULL,
"created_at" timestamp DEFAULT now()
);
--> statement-breakpoint
CREATE TABLE "chat"."part" (
"id" text PRIMARY KEY NOT NULL,
"message_id" text NOT NULL,
"type" text NOT NULL,
"order" integer NOT NULL,
"details" jsonb NOT NULL,
"created_at" timestamp DEFAULT now()
);
--> statement-breakpoint
CREATE TABLE "pdf"."chat" (
"id" text PRIMARY KEY NOT NULL,
"name" text,
"user_id" text NOT NULL,
"created_at" timestamp DEFAULT now()
);
--> statement-breakpoint
CREATE TABLE "pdf"."citation_unit" (
"id" text PRIMARY KEY NOT NULL,
"document_id" text NOT NULL,
"retrieval_chunk_id" text,
"content" text NOT NULL,
"page_number" integer NOT NULL,
"paragraph_index" integer NOT NULL,
"char_start" integer NOT NULL,
"char_end" integer NOT NULL,
"bbox_x" real,
"bbox_y" real,
"bbox_width" real,
"bbox_height" real,
"section_title" text,
"unit_type" "pdf"."unit_type" DEFAULT 'prose',
"created_at" timestamp DEFAULT now()
);
--> statement-breakpoint
CREATE TABLE "pdf"."document" (
"id" text PRIMARY KEY NOT NULL,
"chat_id" text NOT NULL,
"name" text NOT NULL,
"path" text NOT NULL,
"processing_status" "pdf"."processing_status" DEFAULT 'pending' NOT NULL,
"processing_error" text,
"created_at" timestamp DEFAULT now()
);
--> statement-breakpoint
CREATE TABLE "pdf"."embedding" (
"id" text PRIMARY KEY NOT NULL,
"document_id" text NOT NULL,
"content" text NOT NULL,
"embedding" vector(1536) NOT NULL,
"page_number" integer,
"char_start" integer,
"char_end" integer,
"section_title" text,
"created_at" timestamp DEFAULT now()
);
--> statement-breakpoint
CREATE TABLE "pdf"."message" (
"id" text PRIMARY KEY NOT NULL,
"chat_id" text NOT NULL,
"content" text NOT NULL,
"role" "pdf"."role" NOT NULL,
"created_at" timestamp DEFAULT now()
);
--> statement-breakpoint
CREATE TABLE "pdf"."retrieval_chunk" (
"id" text PRIMARY KEY NOT NULL,
"document_id" text NOT NULL,
"content" text NOT NULL,
"embedding" vector(1536),
"page_start" integer NOT NULL,
"page_end" integer NOT NULL,
"section_hierarchy" text[],
"chunk_type" text DEFAULT 'prose',
"created_at" timestamp DEFAULT now()
);
--> statement-breakpoint
CREATE TABLE "image"."generation" (
"id" text PRIMARY KEY NOT NULL,
"prompt" text NOT NULL,
"model" text NOT NULL,
"aspect_ratio" "image"."aspect_ratio" DEFAULT 'square' NOT NULL,
"count" integer DEFAULT 1 NOT NULL,
"user_id" text NOT NULL,
"created_at" timestamp DEFAULT now(),
"completed_at" timestamp
);
--> statement-breakpoint
CREATE TABLE "image"."image" (
"id" text PRIMARY KEY NOT NULL,
"generation_id" text NOT NULL,
"url" text NOT NULL,
"created_at" timestamp DEFAULT now()
);
--> statement-breakpoint
CREATE TABLE "mesh"."audit_log" (
"id" text PRIMARY KEY NOT NULL,
"mesh_id" text NOT NULL,
"event_type" text NOT NULL,
"actor_peer_id" text,
"target_peer_id" text,
"metadata" jsonb DEFAULT '{}'::jsonb NOT NULL,
"created_at" timestamp DEFAULT now() NOT NULL
);
--> statement-breakpoint
CREATE TABLE "mesh"."invite" (
"id" text PRIMARY KEY NOT NULL,
"mesh_id" text NOT NULL,
"token" text NOT NULL,
"max_uses" integer DEFAULT 1 NOT NULL,
"used_count" integer DEFAULT 0 NOT NULL,
"role" "mesh"."role" DEFAULT 'member' NOT NULL,
"expires_at" timestamp NOT NULL,
"created_by" text NOT NULL,
"created_at" timestamp DEFAULT now() NOT NULL,
"revoked_at" timestamp,
CONSTRAINT "invite_token_unique" UNIQUE("token")
);
--> statement-breakpoint
CREATE TABLE "mesh"."mesh" (
"id" text PRIMARY KEY NOT NULL,
"name" text NOT NULL,
"slug" text NOT NULL,
"owner_user_id" text NOT NULL,
"visibility" "mesh"."visibility" DEFAULT 'private' NOT NULL,
"transport" "mesh"."transport" DEFAULT 'managed' NOT NULL,
"max_peers" integer,
"tier" "mesh"."tier" DEFAULT 'free' NOT NULL,
"created_at" timestamp DEFAULT now() NOT NULL,
"archived_at" timestamp,
CONSTRAINT "mesh_slug_unique" UNIQUE("slug")
);
--> statement-breakpoint
CREATE TABLE "mesh"."member" (
"id" text PRIMARY KEY NOT NULL,
"mesh_id" text NOT NULL,
"user_id" text,
"peer_pubkey" text NOT NULL,
"display_name" text NOT NULL,
"role" "mesh"."role" DEFAULT 'member' NOT NULL,
"joined_at" timestamp DEFAULT now() NOT NULL,
"last_seen_at" timestamp,
"revoked_at" timestamp
);
--> statement-breakpoint
CREATE TABLE "mesh"."message_queue" (
"id" text PRIMARY KEY NOT NULL,
"mesh_id" text NOT NULL,
"sender_member_id" text NOT NULL,
"target_spec" text NOT NULL,
"priority" "mesh"."message_priority" DEFAULT 'next' NOT NULL,
"nonce" text NOT NULL,
"ciphertext" text NOT NULL,
"created_at" timestamp DEFAULT now() NOT NULL,
"delivered_at" timestamp,
"expires_at" timestamp
);
--> statement-breakpoint
CREATE TABLE "mesh"."pending_status" (
"id" text PRIMARY KEY NOT NULL,
"pid" integer NOT NULL,
"cwd" text NOT NULL,
"status" text NOT NULL,
"status_source" text NOT NULL,
"created_at" timestamp DEFAULT now() NOT NULL,
"applied_at" timestamp
);
--> statement-breakpoint
CREATE TABLE "mesh"."presence" (
"id" text PRIMARY KEY NOT NULL,
"member_id" text NOT NULL,
"session_id" text NOT NULL,
"pid" integer NOT NULL,
"cwd" text NOT NULL,
"status" "mesh"."presence_status" DEFAULT 'idle' NOT NULL,
"status_source" "mesh"."presence_status_source" DEFAULT 'jsonl' NOT NULL,
"status_updated_at" timestamp DEFAULT now() NOT NULL,
"connected_at" timestamp DEFAULT now() NOT NULL,
"last_ping_at" timestamp DEFAULT now() NOT NULL,
"disconnected_at" timestamp
);
--> statement-breakpoint
ALTER TABLE "account" ADD CONSTRAINT "account_user_id_user_id_fk" FOREIGN KEY ("user_id") REFERENCES "public"."user"("id") ON DELETE cascade ON UPDATE no action;--> statement-breakpoint
ALTER TABLE "invitation" ADD CONSTRAINT "invitation_organization_id_organization_id_fk" FOREIGN KEY ("organization_id") REFERENCES "public"."organization"("id") ON DELETE cascade ON UPDATE no action;--> statement-breakpoint
ALTER TABLE "invitation" ADD CONSTRAINT "invitation_inviter_id_user_id_fk" FOREIGN KEY ("inviter_id") REFERENCES "public"."user"("id") ON DELETE cascade ON UPDATE no action;--> statement-breakpoint
ALTER TABLE "member" ADD CONSTRAINT "member_organization_id_organization_id_fk" FOREIGN KEY ("organization_id") REFERENCES "public"."organization"("id") ON DELETE cascade ON UPDATE no action;--> statement-breakpoint
ALTER TABLE "member" ADD CONSTRAINT "member_user_id_user_id_fk" FOREIGN KEY ("user_id") REFERENCES "public"."user"("id") ON DELETE cascade ON UPDATE no action;--> statement-breakpoint
ALTER TABLE "passkey" ADD CONSTRAINT "passkey_user_id_user_id_fk" FOREIGN KEY ("user_id") REFERENCES "public"."user"("id") ON DELETE cascade ON UPDATE no action;--> statement-breakpoint
ALTER TABLE "session" ADD CONSTRAINT "session_user_id_user_id_fk" FOREIGN KEY ("user_id") REFERENCES "public"."user"("id") ON DELETE cascade ON UPDATE no action;--> statement-breakpoint
ALTER TABLE "two_factor" ADD CONSTRAINT "two_factor_user_id_user_id_fk" FOREIGN KEY ("user_id") REFERENCES "public"."user"("id") ON DELETE cascade ON UPDATE no action;--> statement-breakpoint
ALTER TABLE "credit_transaction" ADD CONSTRAINT "credit_transaction_customer_id_customer_id_fk" FOREIGN KEY ("customer_id") REFERENCES "public"."customer"("id") ON DELETE cascade ON UPDATE no action;--> statement-breakpoint
ALTER TABLE "customer" ADD CONSTRAINT "customer_user_id_user_id_fk" FOREIGN KEY ("user_id") REFERENCES "public"."user"("id") ON DELETE cascade ON UPDATE no action;--> statement-breakpoint
ALTER TABLE "chat"."chat" ADD CONSTRAINT "chat_user_id_user_id_fk" FOREIGN KEY ("user_id") REFERENCES "public"."user"("id") ON DELETE cascade ON UPDATE cascade;--> statement-breakpoint
ALTER TABLE "chat"."message" ADD CONSTRAINT "message_chat_id_chat_id_fk" FOREIGN KEY ("chat_id") REFERENCES "chat"."chat"("id") ON DELETE cascade ON UPDATE cascade;--> statement-breakpoint
ALTER TABLE "chat"."part" ADD CONSTRAINT "part_message_id_message_id_fk" FOREIGN KEY ("message_id") REFERENCES "chat"."message"("id") ON DELETE cascade ON UPDATE cascade;--> statement-breakpoint
ALTER TABLE "pdf"."chat" ADD CONSTRAINT "chat_user_id_user_id_fk" FOREIGN KEY ("user_id") REFERENCES "public"."user"("id") ON DELETE cascade ON UPDATE cascade;--> statement-breakpoint
ALTER TABLE "pdf"."citation_unit" ADD CONSTRAINT "citation_unit_document_id_document_id_fk" FOREIGN KEY ("document_id") REFERENCES "pdf"."document"("id") ON DELETE cascade ON UPDATE cascade;--> statement-breakpoint
ALTER TABLE "pdf"."citation_unit" ADD CONSTRAINT "citation_unit_retrieval_chunk_id_retrieval_chunk_id_fk" FOREIGN KEY ("retrieval_chunk_id") REFERENCES "pdf"."retrieval_chunk"("id") ON DELETE set null ON UPDATE cascade;--> statement-breakpoint
ALTER TABLE "pdf"."document" ADD CONSTRAINT "document_chat_id_chat_id_fk" FOREIGN KEY ("chat_id") REFERENCES "pdf"."chat"("id") ON DELETE cascade ON UPDATE cascade;--> statement-breakpoint
ALTER TABLE "pdf"."embedding" ADD CONSTRAINT "embedding_document_id_document_id_fk" FOREIGN KEY ("document_id") REFERENCES "pdf"."document"("id") ON DELETE cascade ON UPDATE cascade;--> statement-breakpoint
ALTER TABLE "pdf"."message" ADD CONSTRAINT "message_chat_id_chat_id_fk" FOREIGN KEY ("chat_id") REFERENCES "pdf"."chat"("id") ON DELETE cascade ON UPDATE cascade;--> statement-breakpoint
ALTER TABLE "pdf"."retrieval_chunk" ADD CONSTRAINT "retrieval_chunk_document_id_document_id_fk" FOREIGN KEY ("document_id") REFERENCES "pdf"."document"("id") ON DELETE cascade ON UPDATE cascade;--> statement-breakpoint
ALTER TABLE "image"."generation" ADD CONSTRAINT "generation_user_id_user_id_fk" FOREIGN KEY ("user_id") REFERENCES "public"."user"("id") ON DELETE cascade ON UPDATE cascade;--> statement-breakpoint
ALTER TABLE "image"."image" ADD CONSTRAINT "image_generation_id_generation_id_fk" FOREIGN KEY ("generation_id") REFERENCES "image"."generation"("id") ON DELETE cascade ON UPDATE cascade;--> statement-breakpoint
ALTER TABLE "mesh"."audit_log" ADD CONSTRAINT "audit_log_mesh_id_mesh_id_fk" FOREIGN KEY ("mesh_id") REFERENCES "mesh"."mesh"("id") ON DELETE cascade ON UPDATE cascade;--> statement-breakpoint
ALTER TABLE "mesh"."invite" ADD CONSTRAINT "invite_mesh_id_mesh_id_fk" FOREIGN KEY ("mesh_id") REFERENCES "mesh"."mesh"("id") ON DELETE cascade ON UPDATE cascade;--> statement-breakpoint
ALTER TABLE "mesh"."invite" ADD CONSTRAINT "invite_created_by_user_id_fk" FOREIGN KEY ("created_by") REFERENCES "public"."user"("id") ON DELETE cascade ON UPDATE cascade;--> statement-breakpoint
ALTER TABLE "mesh"."mesh" ADD CONSTRAINT "mesh_owner_user_id_user_id_fk" FOREIGN KEY ("owner_user_id") REFERENCES "public"."user"("id") ON DELETE cascade ON UPDATE cascade;--> statement-breakpoint
ALTER TABLE "mesh"."member" ADD CONSTRAINT "member_mesh_id_mesh_id_fk" FOREIGN KEY ("mesh_id") REFERENCES "mesh"."mesh"("id") ON DELETE cascade ON UPDATE cascade;--> statement-breakpoint
ALTER TABLE "mesh"."member" ADD CONSTRAINT "member_user_id_user_id_fk" FOREIGN KEY ("user_id") REFERENCES "public"."user"("id") ON DELETE set null ON UPDATE cascade;--> statement-breakpoint
ALTER TABLE "mesh"."message_queue" ADD CONSTRAINT "message_queue_mesh_id_mesh_id_fk" FOREIGN KEY ("mesh_id") REFERENCES "mesh"."mesh"("id") ON DELETE cascade ON UPDATE cascade;--> statement-breakpoint
ALTER TABLE "mesh"."message_queue" ADD CONSTRAINT "message_queue_sender_member_id_member_id_fk" FOREIGN KEY ("sender_member_id") REFERENCES "mesh"."member"("id") ON DELETE cascade ON UPDATE cascade;--> statement-breakpoint
ALTER TABLE "mesh"."presence" ADD CONSTRAINT "presence_member_id_member_id_fk" FOREIGN KEY ("member_id") REFERENCES "mesh"."member"("id") ON DELETE cascade ON UPDATE cascade;--> statement-breakpoint
CREATE INDEX "account_userId_idx" ON "account" USING btree ("user_id");--> statement-breakpoint
CREATE INDEX "invitation_organizationId_idx" ON "invitation" USING btree ("organization_id");--> statement-breakpoint
CREATE INDEX "invitation_email_idx" ON "invitation" USING btree ("email");--> statement-breakpoint
CREATE INDEX "member_organizationId_idx" ON "member" USING btree ("organization_id");--> statement-breakpoint
CREATE INDEX "member_userId_idx" ON "member" USING btree ("user_id");--> statement-breakpoint
CREATE INDEX "passkey_userId_idx" ON "passkey" USING btree ("user_id");--> statement-breakpoint
CREATE INDEX "passkey_credentialID_idx" ON "passkey" USING btree ("credential_id");--> statement-breakpoint
CREATE INDEX "session_userId_idx" ON "session" USING btree ("user_id");--> statement-breakpoint
CREATE INDEX "twoFactor_secret_idx" ON "two_factor" USING btree ("secret");--> statement-breakpoint
CREATE INDEX "twoFactor_userId_idx" ON "two_factor" USING btree ("user_id");--> statement-breakpoint
CREATE INDEX "verification_identifier_idx" ON "verification" USING btree ("identifier");--> statement-breakpoint
CREATE INDEX "idx_cu_document" ON "pdf"."citation_unit" USING btree ("document_id");--> statement-breakpoint
CREATE INDEX "idx_cu_retrieval" ON "pdf"."citation_unit" USING btree ("retrieval_chunk_id");--> statement-breakpoint
CREATE INDEX "idx_cu_page" ON "pdf"."citation_unit" USING btree ("document_id","page_number");--> statement-breakpoint
CREATE UNIQUE INDEX "idx_cu_unique" ON "pdf"."citation_unit" USING btree ("document_id","page_number","paragraph_index");--> statement-breakpoint
CREATE INDEX "pdf_embeddingIndex" ON "pdf"."embedding" USING hnsw ("embedding" vector_cosine_ops);--> statement-breakpoint
CREATE INDEX "idx_rc_document" ON "pdf"."retrieval_chunk" USING btree ("document_id");--> statement-breakpoint
CREATE INDEX "idx_rc_embedding" ON "pdf"."retrieval_chunk" USING hnsw ("embedding" vector_cosine_ops);

2806
packages/db/migrations/meta/0000_snapshot.json Normal file
View File

File diff suppressed because it is too large Load Diff

13
packages/db/migrations/meta/_journal.json Normal file
View File

@@ -0,0 +1,13 @@
{
"version": "7",
"dialect": "postgresql",
"entries": [
{
"idx": 0,
"version": "7",
"when": 1775335397081,
"tag": "0000_sloppy_stryfe",
"breakpoints": true
}
]
}

30
packages/db/src/schema/mesh.ts
View File

@@ -77,7 +77,7 @@ export const mesh = schema.table("mesh", {
* A member is a peer that has joined a mesh. user_id is nullable to
* allow anonymous/invite-only peers (identity is the ed25519 pubkey).
*/
export const member = schema.table("member", {
export const meshMember = schema.table("member", {
id: text().primaryKey().notNull().$defaultFn(generateId),
meshId: text()
.references(() => mesh.id, { onDelete: "cascade", onUpdate: "cascade" })
@@ -140,7 +140,7 @@ export const auditLog = schema.table("audit_log", {
export const presence = schema.table("presence", {
id: text().primaryKey().notNull().$defaultFn(generateId),
memberId: text()
.references(() => member.id, { onDelete: "cascade", onUpdate: "cascade" })
.references(() => meshMember.id, { onDelete: "cascade", onUpdate: "cascade" })
.notNull(),
sessionId: text().notNull(),
pid: integer().notNull(),
@@ -168,7 +168,7 @@ export const messageQueue = schema.table("message_queue", {
.references(() => mesh.id, { onDelete: "cascade", onUpdate: "cascade" })
.notNull(),
senderMemberId: text()
.references(() => member.id, { onDelete: "cascade", onUpdate: "cascade" })
.references(() => meshMember.id, { onDelete: "cascade", onUpdate: "cascade" })
.notNull(),
targetSpec: text().notNull(),
priority: messagePriorityEnum().notNull().default("next"),
@@ -202,19 +202,19 @@ export const meshRelations = relations(mesh, ({ one, many }) => ({
fields: [mesh.ownerUserId],
references: [user.id],
}),
members: many(member),
members: many(meshMember),
invites: many(invite),
auditLogs: many(auditLog),
messageQueue: many(messageQueue),
}));
export const memberRelations = relations(member, ({ one, many }) => ({
export const memberRelations = relations(meshMember, ({ one, many }) => ({
mesh: one(mesh, {
fields: [member.meshId],
fields: [meshMember.meshId],
references: [mesh.id],
}),
user: one(user, {
fields: [member.userId],
fields: [meshMember.userId],
references: [user.id],
}),
presences: many(presence),
@@ -222,9 +222,9 @@ export const memberRelations = relations(member, ({ one, many }) => ({
}));
export const presenceRelations = relations(presence, ({ one }) => ({
member: one(member, {
member: one(meshMember, {
fields: [presence.memberId],
references: [member.id],
references: [meshMember.id],
}),
}));
@@ -233,9 +233,9 @@ export const messageQueueRelations = relations(messageQueue, ({ one }) => ({
fields: [messageQueue.meshId],
references: [mesh.id],
}),
sender: one(member, {
sender: one(meshMember, {
fields: [messageQueue.senderMemberId],
references: [member.id],
references: [meshMember.id],
}),
}));
@@ -259,8 +259,8 @@ export const auditLogRelations = relations(auditLog, ({ one }) => ({
export const selectMeshSchema = createSelectSchema(mesh);
export const insertMeshSchema = createInsertSchema(mesh);
export const selectMemberSchema = createSelectSchema(member);
export const insertMemberSchema = createInsertSchema(member);
export const selectMemberSchema = createSelectSchema(meshMember);
export const insertMemberSchema = createInsertSchema(meshMember);
export const selectInviteSchema = createSelectSchema(invite);
export const insertInviteSchema = createInsertSchema(invite);
export const selectAuditLogSchema = createSelectSchema(auditLog);
@@ -274,8 +274,8 @@ export const insertPendingStatusSchema = createInsertSchema(pendingStatus);
export type SelectMesh = typeof mesh.$inferSelect;
export type InsertMesh = typeof mesh.$inferInsert;
export type SelectMember = typeof member.$inferSelect;
export type InsertMember = typeof member.$inferInsert;
export type SelectMember = typeof meshMember.$inferSelect;
export type InsertMember = typeof meshMember.$inferInsert;
export type SelectInvite = typeof invite.$inferSelect;
export type InsertInvite = typeof invite.$inferInsert;
export type SelectAuditLog = typeof auditLog.$inferSelect;