diff --git a/app/components/CopyButton.tsx b/app/components/CopyButton.tsx
index ce98f26e..cb4c967f 100644
--- a/app/components/CopyButton.tsx
+++ b/app/components/CopyButton.tsx
@@ -1,42 +1,58 @@
 import { VisuallyHidden } from '@radix-ui/react-visually-hidden'
-import type { FC } from 'react'
-import { useState } from 'react'
+import {
+	type ComponentProps,
+	type ElementRef,
+	forwardRef,
+	type ReactNode,
+	useState,
+} from 'react'
 import { useTimeoutFn } from 'react-use'
-import { useRoomUrl } from '~/hooks/useRoomUrl'
 import { Button } from './Button'
 import { Icon } from './Icon/Icon'
-import { Tooltip } from './Tooltip'
 
-interface CopyButtonProps {}
-
-export const CopyButton: FC<CopyButtonProps> = () => {
-	const [copied, setCopied] = useState(false)
+interface CopyButtonProps extends ComponentProps<'button'> {
+	contentValue: string
+	copiedMessage?: ReactNode
+}
 
-	const roomUrl = useRoomUrl()
+export const CopyButton = forwardRef<ElementRef<'button'>, CopyButtonProps>(
+	(
+		{
+			children = <VisuallyHidden>Copy</VisuallyHidden>,
+			copiedMessage = <VisuallyHidden>Copied!</VisuallyHidden>,
+			contentValue,
+			onClick,
+			...rest
+		},
+		ref
+	) => {
+		const [copied, setCopied] = useState(false)
 
-	const [_isReady, _cancel, reset] = useTimeoutFn(() => {
-		setCopied(false)
-	}, 2000)
+		const [_isReady, _cancel, reset] = useTimeoutFn(() => {
+			setCopied(false)
+		}, 2000)
 
-	return (
-		<Tooltip
-			content={copied ? 'Copied!' : 'Copy URL'}
-			open={copied ? true : undefined}
-		>
+		return (
 			<Button
 				displayType="secondary"
-				onClick={() => {
-					navigator.clipboard.writeText(roomUrl)
+				onClick={(e) => {
+					onClick && onClick(e)
+					navigator.clipboard.writeText(contentValue)
 					setCopied(true)
 					reset()
 				}}
+				ref={ref}
+				className="flex items-center gap-2 text-xs"
+				{...rest}
 			>
 				<Icon
 					type={copied ? 'ClipboardDocumentCheckIcon' : 'ClipboardDocumentIcon'}
 					className="text-xl"
 				/>
-				<VisuallyHidden>{copied ? 'Copied!' : 'Copy URL'}</VisuallyHidden>
+				{copied ? copiedMessage : children}
 			</Button>
-		</Tooltip>
-	)
-}
+		)
+	}
+)
+
+CopyButton.displayName = 'CopyButton'
diff --git a/app/components/LeaveRoomButton.tsx b/app/components/LeaveRoomButton.tsx
index 86b0934d..01da2d46 100644
--- a/app/components/LeaveRoomButton.tsx
+++ b/app/components/LeaveRoomButton.tsx
@@ -7,10 +7,12 @@ import { Tooltip } from './Tooltip'
 
 interface LeaveRoomButtonProps {
 	navigateToFeedbackPage: boolean
+	meetingId?: string
 }
 
 export const LeaveRoomButton: FC<LeaveRoomButtonProps> = ({
 	navigateToFeedbackPage,
+	meetingId,
 }) => {
 	const navigate = useNavigate()
 	return (
@@ -18,7 +20,11 @@ export const LeaveRoomButton: FC<LeaveRoomButtonProps> = ({
 			<Button
 				displayType="danger"
 				onClick={() => {
-					navigate(navigateToFeedbackPage ? '/call-quality-feedback' : '/')
+					const params = new URLSearchParams()
+					if (meetingId) params.set('meetingId', meetingId)
+					navigate(
+						navigateToFeedbackPage ? `/call-quality-feedback?${params}` : '/'
+					)
 				}}
 			>
 				<VisuallyHidden>Leave</VisuallyHidden>
diff --git a/app/durableObjects/ChatRoom.server.ts b/app/durableObjects/ChatRoom.server.ts
index 87267b6a..b1e1fa42 100644
--- a/app/durableObjects/ChatRoom.server.ts
+++ b/app/durableObjects/ChatRoom.server.ts
@@ -5,12 +5,18 @@ import assertNever from '~/utils/assertNever'
 import { assertNonNullable } from '~/utils/assertNonNullable'
 import getUsername from '~/utils/getUsername.server'
 
+import { eq, sql } from 'drizzle-orm'
+import type { DrizzleD1Database } from 'drizzle-orm/d1'
 import {
 	Server,
 	type Connection,
 	type ConnectionContext,
 	type WSMessage,
 } from 'partyserver'
+import { getDb, Meetings } from 'schema'
+import { log } from '~/utils/logging'
+
+const alarmInterval = 30_000
 
 /**
  * The ChatRoom Durable Object Class
@@ -21,6 +27,15 @@ import {
  * to all others.
  */
 export class ChatRoom extends Server<Env> {
+	env: Env
+	db: DrizzleD1Database<Record<string, never>> | null
+
+	constructor(ctx: DurableObjectState, env: Env) {
+		super(ctx, env)
+		this.env = env
+		this.db = getDb(this)
+	}
+
 	static options = {
 		hibernate: true,
 	}
@@ -31,6 +46,9 @@ export class ChatRoom extends Server<Env> {
 	}
 
 	async onStart(): Promise<void> {
+		const meetingId = await this.getMeetingId()
+		log({ eventName: 'onStart', meetingId })
+		this.db = getDb(this)
 		// TODO: make this a part of partyserver
 		this.ctx.setWebSocketAutoResponse(
 			new WebSocketRequestResponsePair(
@@ -38,13 +56,8 @@ export class ChatRoom extends Server<Env> {
 				JSON.stringify({ type: 'partyserver-pong' })
 			)
 		)
-
-		// cleaning out storage used by older versions of this code
-		await this.ctx.storage.delete('sessions').catch(() => {
-			console.warn('Failed to delete old sessions storage')
-		})
-		// We can remove this line later
 	}
+
 	async onConnect(
 		connection: Connection<User>,
 		ctx: ConnectionContext
@@ -52,14 +65,15 @@ export class ChatRoom extends Server<Env> {
 		// let's start the periodic alarm if it's not already started
 		if (!(await this.ctx.storage.getAlarm())) {
 			// start the alarm to broadcast state every 30 seconds
-			this.ctx.storage.setAlarm(Date.now() + 30000)
+			this.ctx.storage.setAlarm(Date.now() + alarmInterval)
 		}
 
 		const username = await getUsername(ctx.request)
 		assertNonNullable(username)
 
 		let user = await this.ctx.storage.get<User>(`session-${connection.id}`)
-		if (user === undefined) {
+		const foundInStorage = user !== undefined
+		if (!foundInStorage) {
 			user = {
 				id: connection.id,
 				name: username,
@@ -76,22 +90,84 @@ export class ChatRoom extends Server<Env> {
 
 		// store the user's data in storage
 		await this.ctx.storage.put(`session-${connection.id}`, user)
-
+		await this.trackPeakUserCount()
 		await this.broadcastRoomState()
+		const meetingId = await this.getMeetingId()
+		log({
+			eventName: 'onConnect',
+			meetingId,
+			foundInStorage,
+			connectionId: connection.id,
+		})
+	}
+
+	async trackPeakUserCount() {
+		let meetingId = await this.getMeetingId()
+		const meeting = meetingId
+			? await this.getMeeting(meetingId)
+			: await this.createMeeting()
+		await this.cleanupOldConnections()
+		if (this.db) {
+			if (!meeting) return
+			if (meeting.ended !== null) {
+				await this.db
+					.update(Meetings)
+					.set({ ended: null })
+					.where(eq(Meetings.id, meeting.id))
+			}
+
+			const previousCount = meeting.peakUserCount
+			const userCount = (await this.getUsers()).size
+			if (userCount > previousCount) {
+				await this.db
+					.update(Meetings)
+					.set({
+						peakUserCount: userCount,
+					})
+					.where(eq(Meetings.id, meeting.id))
+			}
+		}
+		return meetingId
+	}
+
+	async getMeetingId() {
+		return this.ctx.storage.get<string>('meetingId')
+	}
+
+	async createMeeting() {
+		const meetingId = crypto.randomUUID()
+		await this.ctx.storage.put('meetingId', meetingId)
+		log({ eventName: 'startingMeeting', meetingId })
+		if (this.db) {
+			return this.db
+				.insert(Meetings)
+				.values({
+					id: meetingId,
+					peakUserCount: 1,
+				})
+				.returning()
+				.then(([m]) => m)
+		}
+	}
+
+	async getMeeting(meetingId: string) {
+		if (!this.db) return null
+		const [meeting] = await this.db
+			.select()
+			.from(Meetings)
+			.where(eq(Meetings.id, meetingId))
+
+		return meeting
 	}
 
 	async broadcastRoomState() {
 		let didSomeoneQuit = false
+		const meetingId = await this.getMeetingId()
 		const roomState = {
 			type: 'roomState',
 			state: {
-				users: [
-					...(
-						await this.ctx.storage.list<User>({
-							prefix: 'session-',
-						})
-					).values(),
-				],
+				meetingId,
+				users: [...(await this.getUsers()).values()],
 			},
 		} satisfies ServerMessage
 
@@ -102,6 +178,11 @@ export class ChatRoom extends Server<Env> {
 				connection.send(roomStateMessage)
 			} catch (err) {
 				connection.close(1011, 'Failed to broadcast state')
+				log({
+					eventName: 'errorBroadcastingToUser',
+					meetingId,
+					connectionId: connection.id,
+				})
 				await this.ctx.storage.delete(`session-${connection.id}`)
 				didSomeoneQuit = true
 			}
@@ -118,6 +199,7 @@ export class ChatRoom extends Server<Env> {
 		message: WSMessage
 	): Promise<void> {
 		try {
+			const meetingId = await this.getMeetingId()
 			if (typeof message !== 'string') {
 				console.warn('Received non-string message')
 				return
@@ -135,6 +217,8 @@ export class ChatRoom extends Server<Env> {
 								`Failed to delete session session-${connection.id} on userLeft`
 							)
 						})
+					log({ eventName: 'userLeft', meetingId, connectionId: connection.id })
+
 					await this.broadcastRoomState()
 					break
 				}
@@ -210,46 +294,91 @@ export class ChatRoom extends Server<Env> {
 					break
 				}
 			}
-		} catch (err) {
-			assertError(err)
+		} catch (error) {
+			const meetingId = await this.getMeetingId()
+			log({
+				eventName: 'errorHandlingMessage',
+				meetingId,
+				connectionId: connection.id,
+				error,
+			})
+			assertError(error)
 			// TODO: should this even be here?
 			// Report any exceptions directly back to the client. As with our handleErrors() this
 			// probably isn't what you'd want to do in production, but it's convenient when testing.
 			this.sendMessage(connection, {
 				type: 'error',
-				error: err.stack,
+				error: error.stack,
 			} satisfies ServerMessage)
 		}
 	}
 
-	onClose() {
-		// while it makes sense to broadcast immediately on close,
-		// it's possible that the websocket just closed for an instant
-		// and will reconnect momentarily.
-		// so let's just let the alarm handler do the broadcasting.
-		// this.broadcastRoomState()
+	onError(connection: Connection, error: unknown): void | Promise<void> {
+		return this.getMeetingId().then((meetingId) => {
+			log({
+				eventName: 'onErrorHandler',
+				meetingId,
+				connectionId: connection.id,
+				error,
+			})
+			this.broadcastRoomState()
+		})
+	}
+
+	getUsers() {
+		return this.ctx.storage.list<User>({
+			prefix: 'session-',
+		})
 	}
 
-	onError(): void | Promise<void> {
-		this.broadcastRoomState()
+	async endMeeting(meetingId: string) {
+		log({ eventName: 'endingMeeting', meetingId })
+		await this.ctx.storage.delete('meetingId')
+		if (this.db) {
+			// stamp meeting as ended
+			await this.db
+				.update(Meetings)
+				.set({
+					ended: sql`CURRENT_TIMESTAMP`,
+				})
+				.where(eq(Meetings.id, meetingId))
+		}
 	}
 
 	async cleanupOldConnections() {
+		const meetingId = await this.getMeetingId()
+		if (!meetingId) log({ eventName: 'meetingIdNotFoundInCleanup' })
 		const connections = [...this.getConnections()]
-		const sessionsToCleanUp = await this.ctx.storage.list<User>()
+		const sessionsToCleanUp = await this.getUsers()
+
 		connections.forEach((connection) =>
 			sessionsToCleanUp.delete(`session-${connection.id}`)
 		)
-		return this.ctx.storage
+
+		sessionsToCleanUp.forEach((user) => {
+			log({ eventName: 'userTimedOut', connectionId: user.id, meetingId })
+		})
+
+		await this.ctx.storage
 			.delete([...sessionsToCleanUp.keys()])
 			.catch(() => console.warn('Failed to clean up orphaned sessions'))
+
+		const activeUserCount = (await this.getUsers()).size
+
+		if (meetingId && activeUserCount === 0) {
+			this.endMeeting(meetingId)
+		}
+
+		return activeUserCount
 	}
 
 	async alarm(): Promise<void> {
-		await this.cleanupOldConnections()
+		const meetingId = await this.getMeetingId()
+		log({ eventName: 'alarm', meetingId })
+		const activeUserCount = await this.cleanupOldConnections()
 		await this.broadcastRoomState()
-		if ([...this.getConnections()].length !== 0) {
-			this.ctx.storage.setAlarm(Date.now() + 30000)
+		if (activeUserCount !== 0) {
+			this.ctx.storage.setAlarm(Date.now() + alarmInterval)
 		}
 	}
 }
diff --git a/app/routes/_room.$roomName._index.tsx b/app/routes/_room.$roomName._index.tsx
index 8c31a284..8c1d9464 100644
--- a/app/routes/_room.$roomName._index.tsx
+++ b/app/routes/_room.$roomName._index.tsx
@@ -17,6 +17,7 @@ import { Spinner } from '~/components/Spinner'
 import { Tooltip } from '~/components/Tooltip'
 import { useSubscribedState } from '~/hooks/rxjsHooks'
 import { useRoomContext } from '~/hooks/useRoomContext'
+import { useRoomUrl } from '~/hooks/useRoomUrl'
 import { errorMessageMap } from '~/hooks/useUserMedia'
 import getUsername from '~/utils/getUsername.server'
 
@@ -62,6 +63,8 @@ export default function Lobby() {
 		? errorMessageMap[userMedia.audioUnavailableReason]
 		: null
 
+	const roomUrl = useRoomUrl()
+
 	return (
 		<div className="flex flex-col items-center justify-center h-full p-4">
 			<div className="flex-1"></div>
@@ -167,7 +170,9 @@ export default function Lobby() {
 					<MicButton />
 					<CameraButton />
 					<SettingsButton />
-					<CopyButton></CopyButton>
+					<Tooltip content="Copy URL">
+						<CopyButton contentValue={roomUrl}></CopyButton>
+					</Tooltip>
 				</div>
 			</div>
 			<div className="flex flex-col justify-end flex-1">
diff --git a/app/routes/_room.$roomName.room.tsx b/app/routes/_room.$roomName.room.tsx
index ebdaa99f..3a442792 100644
--- a/app/routes/_room.$roomName.room.tsx
+++ b/app/routes/_room.$roomName.room.tsx
@@ -7,6 +7,7 @@ import { Flipper } from 'react-flip-toolkit'
 import { useMeasure, useMount, useWindowSize } from 'react-use'
 import { Button } from '~/components/Button'
 import { CameraButton } from '~/components/CameraButton'
+import { CopyButton } from '~/components/CopyButton'
 import { HighPacketLossWarningsToast } from '~/components/HighPacketLossWarningsToast'
 import { IceDisconnectedToast } from '~/components/IceDisconnectedToast'
 import { Icon } from '~/components/Icon/Icon'
@@ -130,7 +131,12 @@ function JoinedRoom({ bugReportsEnabled }: { bugReportsEnabled: boolean }) {
 		peer,
 		dataSaverMode,
 		pushedTracks,
-		room: { otherUsers, websocket, identity },
+		room: {
+			otherUsers,
+			websocket,
+			identity,
+			roomState: { meetingId },
+		},
 	} = useRoomContext()
 
 	const debugEnabled = useDebugEnabled()
@@ -326,7 +332,13 @@ function JoinedRoom({ bugReportsEnabled }: { bugReportsEnabled: boolean }) {
 						className="hidden md:block"
 					></ParticipantsButton>
 					<OverflowMenu bugReportsEnabled={bugReportsEnabled} />
-					<LeaveRoomButton navigateToFeedbackPage={hasDb} />
+					<LeaveRoomButton
+						navigateToFeedbackPage={hasDb}
+						meetingId={meetingId}
+					/>
+					{debugEnabled && meetingId && (
+						<CopyButton contentValue={meetingId}>Meeting Id</CopyButton>
+					)}
 				</div>
 			</div>
 			<HighPacketLossWarningsToast />
diff --git a/app/routes/call-quality-feedback.tsx b/app/routes/call-quality-feedback.tsx
index c2f93e86..dc3a7237 100644
--- a/app/routes/call-quality-feedback.tsx
+++ b/app/routes/call-quality-feedback.tsx
@@ -1,6 +1,7 @@
 import { type ActionFunctionArgs } from '@remix-run/cloudflare'
-import { Form } from '@remix-run/react'
+import { Form, useSearchParams } from '@remix-run/react'
 import { AnalyticsSimpleCallFeedback, getDb } from 'schema'
+import invariant from 'tiny-invariant'
 import { Button } from '~/components/Button'
 import { RELEASE } from '~/utils/constants'
 
@@ -17,26 +18,46 @@ export const action = async ({ request, context }: ActionFunctionArgs) => {
 
 	const formData = await request.formData()
 	const experiencedIssues = formData.get('experiencedIssues') === 'true'
+	const meetingId = formData.get('meetingId')
+	invariant(typeof meetingId === 'string')
 	await db.insert(AnalyticsSimpleCallFeedback).values({
 		experiencedIssues: Number(experiencedIssues),
 		version: RELEASE ?? 'dev',
+		meetingId,
 	})
 
 	return redirectToHome
 }
 
 export default function SetUsername() {
+	const [params] = useSearchParams()
+	const meetingId = params.get('meetingId')
 	return (
 		<div className="grid h-full gap-4 place-content-center">
-			<h1 className="text-3xl font-bold">Experience any issues?</h1>
-			<Form className="flex items-end gap-4" method="post">
-				<Button displayType="secondary" value="true" name="experiencedIssues">
-					Yes
-				</Button>
-				<Button displayType="secondary" value="false" name="experiencedIssues">
-					No
-				</Button>
-			</Form>
+			{meetingId ? (
+				<>
+					<h1 className="text-3xl font-bold">Experience any issues?</h1>
+					<Form className="flex items-end gap-4" method="post">
+						<Button
+							displayType="secondary"
+							value="true"
+							name="experiencedIssues"
+						>
+							Yes
+						</Button>
+						<Button
+							displayType="secondary"
+							value="false"
+							name="experiencedIssues"
+						>
+							No
+						</Button>
+						<input type="hidden" name="meetingId" value={meetingId} />
+					</Form>
+				</>
+			) : (
+				<h1>Missing meetingId</h1>
+			)}
 		</div>
 	)
 }
diff --git a/app/types/Messages.ts b/app/types/Messages.ts
index f08bd898..b262f0ea 100644
--- a/app/types/Messages.ts
+++ b/app/types/Messages.ts
@@ -16,6 +16,7 @@ export type User = {
 }
 
 export type RoomState = {
+	meetingId?: string
 	users: User[]
 }
 
diff --git a/app/utils/logging.ts b/app/utils/logging.ts
new file mode 100644
index 00000000..c11094cc
--- /dev/null
+++ b/app/utils/logging.ts
@@ -0,0 +1,57 @@
+export type LogEvent =
+	| {
+			eventName: 'onStart'
+			meetingId?: string
+	  }
+	| {
+			eventName: 'alarm'
+			meetingId?: string
+	  }
+	| {
+			eventName: 'onConnect'
+			meetingId?: string
+			foundInStorage: boolean
+			connectionId: string
+	  }
+	| {
+			eventName: 'userLeft'
+			meetingId?: string
+			connectionId: string
+	  }
+	| {
+			eventName: 'userTimedOut'
+			meetingId?: string
+			connectionId: string
+	  }
+	| {
+			eventName: 'startingMeeting'
+			meetingId?: string
+	  }
+	| {
+			eventName: 'endingMeeting'
+			meetingId?: string
+	  }
+	| {
+			eventName: 'meetingIdNotFoundInCleanup'
+	  }
+	| {
+			eventName: 'errorBroadcastingToUser'
+			meetingId?: string
+			connectionId: string
+	  }
+	| {
+			eventName: 'onErrorHandler'
+			meetingId?: string
+			connectionId: string
+			error: unknown
+	  }
+	| {
+			eventName: 'errorHandlingMessage'
+			meetingId?: string
+			connectionId: string
+			error: unknown
+	  }
+
+export function log(event: LogEvent) {
+	console.log(event)
+}
diff --git a/migrations/0001_calm_cloak.sql b/migrations/0001_calm_cloak.sql
new file mode 100644
index 00000000..8e09e76a
--- /dev/null
+++ b/migrations/0001_calm_cloak.sql
@@ -0,0 +1,17 @@
+CREATE TABLE `Meetings` (
+	`id` text PRIMARY KEY NOT NULL,
+	`created` text DEFAULT CURRENT_TIMESTAMP NOT NULL,
+	`modified` text DEFAULT CURRENT_TIMESTAMP NOT NULL,
+	`deleted` text,
+	`userCount` integer NOT NULL,
+	`ended` text
+);
+--> statement-breakpoint
+ALTER TABLE `AnalyticsSimpleCallFeedback` ADD `meetingId` text REFERENCES Meetings(id);--> statement-breakpoint
+/*
+ SQLite does not support "Creating foreign key on existing column" out of the box, we do not generate automatic migration for that, so it has to be done manually
+ Please refer to: https://www.techonthenet.com/sqlite/tables/alter_table.php
+                  https://www.sqlite.org/lang_altertable.html
+
+ Due to that we don't generate migration automatically and it has to be done manually
+*/
\ No newline at end of file
diff --git a/migrations/meta/0001_snapshot.json b/migrations/meta/0001_snapshot.json
new file mode 100644
index 00000000..8a49cc0a
--- /dev/null
+++ b/migrations/meta/0001_snapshot.json
@@ -0,0 +1,190 @@
+{
+  "version": "6",
+  "dialect": "sqlite",
+  "id": "09e3ebdf-2b4c-466e-9e47-679c8f22b42d",
+  "prevId": "fe0342f9-5cae-44a5-86d3-368c43bf7869",
+  "tables": {
+    "AnalyticsRefreshes": {
+      "name": "AnalyticsRefreshes",
+      "columns": {
+        "id": {
+          "name": "id",
+          "type": "integer",
+          "primaryKey": true,
+          "notNull": true,
+          "autoincrement": true
+        },
+        "created": {
+          "name": "created",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true,
+          "autoincrement": false,
+          "default": "CURRENT_TIMESTAMP"
+        },
+        "modified": {
+          "name": "modified",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true,
+          "autoincrement": false,
+          "default": "CURRENT_TIMESTAMP"
+        },
+        "deleted": {
+          "name": "deleted",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false,
+          "autoincrement": false
+        },
+        "version": {
+          "name": "version",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true,
+          "autoincrement": false
+        }
+      },
+      "indexes": {},
+      "foreignKeys": {},
+      "compositePrimaryKeys": {},
+      "uniqueConstraints": {}
+    },
+    "AnalyticsSimpleCallFeedback": {
+      "name": "AnalyticsSimpleCallFeedback",
+      "columns": {
+        "id": {
+          "name": "id",
+          "type": "integer",
+          "primaryKey": true,
+          "notNull": true,
+          "autoincrement": true
+        },
+        "created": {
+          "name": "created",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true,
+          "autoincrement": false,
+          "default": "CURRENT_TIMESTAMP"
+        },
+        "modified": {
+          "name": "modified",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true,
+          "autoincrement": false,
+          "default": "CURRENT_TIMESTAMP"
+        },
+        "deleted": {
+          "name": "deleted",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false,
+          "autoincrement": false
+        },
+        "version": {
+          "name": "version",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true,
+          "autoincrement": false
+        },
+        "experiencedIssues": {
+          "name": "experiencedIssues",
+          "type": "integer",
+          "primaryKey": false,
+          "notNull": true,
+          "autoincrement": false
+        },
+        "meetingId": {
+          "name": "meetingId",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false,
+          "autoincrement": false
+        }
+      },
+      "indexes": {},
+      "foreignKeys": {
+        "AnalyticsSimpleCallFeedback_meetingId_Meetings_id_fk": {
+          "name": "AnalyticsSimpleCallFeedback_meetingId_Meetings_id_fk",
+          "tableFrom": "AnalyticsSimpleCallFeedback",
+          "tableTo": "Meetings",
+          "columnsFrom": [
+            "meetingId"
+          ],
+          "columnsTo": [
+            "id"
+          ],
+          "onDelete": "no action",
+          "onUpdate": "no action"
+        }
+      },
+      "compositePrimaryKeys": {},
+      "uniqueConstraints": {}
+    },
+    "Meetings": {
+      "name": "Meetings",
+      "columns": {
+        "id": {
+          "name": "id",
+          "type": "text",
+          "primaryKey": true,
+          "notNull": true,
+          "autoincrement": false
+        },
+        "created": {
+          "name": "created",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true,
+          "autoincrement": false,
+          "default": "CURRENT_TIMESTAMP"
+        },
+        "modified": {
+          "name": "modified",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true,
+          "autoincrement": false,
+          "default": "CURRENT_TIMESTAMP"
+        },
+        "deleted": {
+          "name": "deleted",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false,
+          "autoincrement": false
+        },
+        "userCount": {
+          "name": "userCount",
+          "type": "integer",
+          "primaryKey": false,
+          "notNull": true,
+          "autoincrement": false
+        },
+        "ended": {
+          "name": "ended",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false,
+          "autoincrement": false
+        }
+      },
+      "indexes": {},
+      "foreignKeys": {},
+      "compositePrimaryKeys": {},
+      "uniqueConstraints": {}
+    }
+  },
+  "enums": {},
+  "_meta": {
+    "schemas": {},
+    "tables": {},
+    "columns": {}
+  },
+  "internal": {
+    "indexes": {}
+  }
+}
\ No newline at end of file
diff --git a/migrations/meta/_journal.json b/migrations/meta/_journal.json
index 9c25e5d4..35b6822a 100644
--- a/migrations/meta/_journal.json
+++ b/migrations/meta/_journal.json
@@ -8,6 +8,13 @@
       "when": 1726697068248,
       "tag": "0000_warm_siren",
       "breakpoints": true
+    },
+    {
+      "idx": 1,
+      "version": "6",
+      "when": 1727550987318,
+      "tag": "0001_calm_cloak",
+      "breakpoints": true
     }
   ]
 }
\ No newline at end of file
diff --git a/schema.ts b/schema.ts
index f8cf2784..0298187f 100644
--- a/schema.ts
+++ b/schema.ts
@@ -1,7 +1,7 @@
-import type { AppLoadContext } from '@remix-run/cloudflare'
 import { sql } from 'drizzle-orm'
 import { drizzle } from 'drizzle-orm/d1'
 import { integer, sqliteTable, text } from 'drizzle-orm/sqlite-core'
+import type { Env } from '~/types/Env'
 
 const metadataColumns = {
 	id: integer('id').primaryKey({ autoIncrement: true }),
@@ -25,10 +25,18 @@ export const AnalyticsSimpleCallFeedback = sqliteTable(
 		...metadataColumns,
 		version: text('version').notNull(),
 		experiencedIssues: integer('experiencedIssues').notNull(),
+		meetingId: text('meetingId').references(() => Meetings.id),
 	}
 )
 
-export function getDb(context: AppLoadContext) {
+export const Meetings = sqliteTable('Meetings', {
+	...metadataColumns,
+	id: text('id').primaryKey(),
+	peakUserCount: integer('userCount').notNull(),
+	ended: text('ended'),
+})
+
+export function getDb(context: { env: Env }) {
 	if (!context.env.DB) {
 		return null
 	}
diff --git a/wrangler.development.toml b/wrangler.development.toml
index 84775937..92ce8e36 100644
--- a/wrangler.development.toml
+++ b/wrangler.development.toml
@@ -51,6 +51,9 @@ new_classes = ["ChatRoom", "RateLimiter"]
 tag = "v2"
 deleted_classes = ["RateLimiter"] 
 
+[observability]
+enabled = true
+
 # The necessary secrets are:
 # - CALLS_APP_SECRET
 # Run `echo <VALUE> | wrangler secret put <NAME>` for each of these
diff --git a/wrangler.production.toml b/wrangler.production.toml
index 41e18e08..ad9ac40f 100644
--- a/wrangler.production.toml
+++ b/wrangler.production.toml
@@ -51,6 +51,9 @@ new_classes = ["ChatRoom", "RateLimiter"]
 tag = "v2"
 deleted_classes = ["RateLimiter"] 
 
+[observability]
+enabled = true
+
 # The necessary secrets are:
 # - CALLS_APP_SECRET
 # Run `echo <VALUE> | wrangler secret put <NAME>` for each of these
diff --git a/wrangler.staging.toml b/wrangler.staging.toml
index 957e4f94..0e661581 100644
--- a/wrangler.staging.toml
+++ b/wrangler.staging.toml
@@ -51,6 +51,9 @@ new_classes = ["ChatRoom", "RateLimiter"]
 tag = "v2"
 deleted_classes = ["RateLimiter"] 
 
+[observability]
+enabled = true
+
 # The necessary secrets are:
 # - CALLS_APP_SECRET
 # Run `echo <VALUE> | wrangler secret put <NAME>` for each of these