135}
136
137// Database Models
138export interface DBThoughtFork extends Omit<ThoughtFork, 'explorations'> {
139 explorations: string; // JSON string
205}
206
207// Database models for user-scoped entities
208export interface DBUserScopedThoughtFork extends Omit<UserScopedThoughtFork, 'explorations'> {
209 explorations: string; // JSON string
1import { Hono } from "https://esm.sh/hono@3.11.7";
2import { runMigrations, insertSampleData } from "./database/migrations.ts";
3import auth from "./routes/auth.ts";
4import apartments from "./routes/apartments.ts";
13});
14
15// Initialize database on startup
16let dbInitialized = false;
17async function initializeDatabase() {
18 if (!dbInitialized) {
19 console.log("Initializing Saint Benedict Joseph database...");
20 await runMigrations();
21 await insertSampleData();
22 dbInitialized = true;
23 console.log("Database initialization complete!");
24 }
25}
26
27// Initialize database before handling requests
28app.use("*", async (c, next) => {
29 await initializeDatabase();
30 await next();
31});
1import { Hono } from "https://esm.sh/hono@3.11.7";
2import { requireAuth } from "./auth.ts";
3import { getUserSettings, updateUserSettings } from "../database/queries.ts";
4import type { ApiResponse, UserSettings } from "../../shared/types.ts";
5
26โโโ backend/
27โ โโโ index.ts # Main Hono server
28โ โโโ database/
29โ โ โโโ migrations.ts # Database schema
30โ โ โโโ queries.ts # Database operations
31โ โโโ routes/
32โ โโโ auth.ts # Authentication routes
54- **Backend**: Hono (TypeScript API framework)
55- **Frontend**: React with TypeScript
56- **Database**: SQLite
57- **Real-time**: WebSocket connections
58- **Styling**: TailwindCSS
1import { sqlite } from "https://esm.town/v/stevekrouse/sqlite";
2
3// Database schema for RChat application
4export async function runMigrations() {
5 console.log("Running database migrations...");
6
7 // Users table
164 await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_chatroom_replies_post_id ON chatroom_replies (post_id)`);
165
166 console.log("Database migrations completed successfully!");
167}
1import { Hono } from "https://esm.sh/hono@3.11.7";
2import { readFile, serveFile } from "https://esm.town/v/std/utils@85-main/index.ts";
3import { runMigrations } from "./database/migrations.ts";
4import { authRoutes } from "./routes/auth.ts";
5import { chatRoutes } from "./routes/chat.ts";
16});
17
18// Initialize database on startup
19await runMigrations();
20
95// Helper functions for WebSocket broadcasting
96function broadcastToChat(chatId: string, message: any, excludeUserId?: string) {
97 // In a real implementation, you'd query the database for chat participants
98 // For now, broadcast to all connected clients except the sender
99 for (const [userId, socket] of connectedClients.entries()) {
105
106function broadcastToContacts(userId: string, message: any) {
107 // In a real implementation, you'd query the database for user's contacts
108 // For now, broadcast to all connected clients
109 for (const [contactId, socket] of connectedClients.entries()) {
7 getUserById,
8 getUserContacts
9} from "../database/queries.ts";
10import type { ApiResponse, Chat } from "../../shared/types.ts";
11
239 }
240
241 // In a real implementation, you'd remove the participant from the database
242 // For now, just return success
243 return c.json<ApiResponse>({
306 }
307
308 // In a real implementation, you'd update the group details in the database
309 // For now, just return success
310 return c.json<ApiResponse>({
1import { Hono } from "https://esm.sh/hono@3.11.7";
2import { requireAuth } from "./auth.ts";
3import { addContact, getUserContacts, getUserByUsername, getUserByEmail } from "../database/queries.ts";
4import type { ApiResponse, Contact } from "../../shared/types.ts";
5
8 getChatMessages,
9 getUserById
10} from "../database/queries.ts";
11import type { ApiResponse, Chat, Message } from "../../shared/types.ts";
12
194 }
195
196 // In a real implementation, you'd mark messages as read in the database
197 // For now, just return success
198 return c.json<ApiResponse>({
6 createChatRoomReply,
7 getChatRoomReplies
8} from "../database/queries.ts";
9import type { ApiResponse, ChatRoomPost, ChatRoomReply } from "../../shared/types.ts";
10