Chat · Repositories

C

9 modules · 32 exports · 1 repository · 16 e2e tests · 5 routes

OverviewModulesRepositoriesPermissionsSearch params & storageE2E tests

Every table a function queries, its own helpers included, read or written. Calls to other repositories are listed apart, their tables are on their own page.

ChatRepository

app/features/chat/ChatRepository.server.ts

Tables

ChatMessageChatMessageReadIndicatorChatRoomGroupGroupMatchGroupMemberScrimPostScrimPostRequestScrimPostRequestUserScrimPostUserTournamentMatchTournamentTeamTournamentTeamMemberUserUserSubmittedImage

Calls

no other repositories

Imports

no other modules

Used by

1 action3 routes5 repositories1 routine2 scripts6 other

Functions & values

function

findAllRoomsByIds

:27

Chat rooms by id.

export async function findAllRoomsByIds(roomIds: number[])

TablesChatRoom

Scriptsscripts/benchmark-db/cases.ts

Otherchat/ChatRoomResolver.server.ts

function

findAllOpenRoomIdsByUserId

:42

Ids of the open rooms the user participates in. Membership-first: every branch starts from the user's own membership rows so the cost tracks their participation, not the site's open room count. SendouQ branches narrow further to {@link SQ_MEMBERSHIP_LOOKBACK_HOURS}.

export async function findAllOpenRoomIdsByUserId(
	userId: number,
): Promise<number[]>

TablesChatRoomGroupGroupMatchGroupMemberScrimPostScrimPostRequestScrimPostRequestUserScrimPostUserTournamentMatchTournamentTeamTournamentTeamMember

Scriptsscripts/benchmark-db/cases.tsscripts/benchmark-db/fixtures.ts

Otherchat/ChatRoomResolver.server.ts

function

findAllMessagesByRoomId

:142

Returns the latest limit messages of a room, oldest first, authors resolved live.

export async function findAllMessagesByRoomId(
	roomId: number,
	{ limit = MESSAGES_DEFAULT_LIMIT }: { limit?: number } = {},
)

TablesChatMessageUserUserSubmittedImage

Unit tests (3)

• returns messages oldest first with authors resolved
• keeps the latest messages when over the limit
• does not return another room's messages

Actions/to/:id/matches/:mid

Routes/api/chat/rooms/:id/messages

Scriptsscripts/benchmark-db/cases.ts

Otherchat/RouteChatRooms.server.ts

function

findMessageById

:158

Returns a message with its author resolved live.

export function findMessageById(messageId: number)

TablesChatMessageUserUserSubmittedImage

Unit tests (2)

• returns
  • the message with its author resolved
  • undefined for an unknown id

Routes/api/chat/rooms/:id/messages

Scriptsscripts/benchmark-db/cases.ts

Otherchat/ChatSystemMessage.server.ts

function

findAllParticipantsByUserIds

:167

Users as rooms list their participants, for mentioning them.

export async function findAllParticipantsByUserIds(userIds: number[])

TablesUserUserSubmittedImage

Scriptsscripts/benchmark-db/cases.ts

Otherchat/chat-room-list.server.ts

function

findMessageStatsByRoomIds

:178

Per-room message stats for the user: unread count (messages newer than their read indicator) and the latest message. Rooms with no messages are left out.

export async function findMessageStatsByRoomIds(
	userId: number,
	roomIds: number[],
): Promise<
	Array<{
		roomId: number;
		unreadCount: number;
		latestMessageId: number;
		latestMessageCreatedAt: number;
	}>
>

TablesChatMessageChatMessageReadIndicator

Unit tests (4)

• counts messages newer than the user's read indicator per room
• returns
  • a zero unread count once everything is read
  • an empty array for no room ids
• leaves out rooms with no messages

Routes/api/chat/rooms/:id

Scriptsscripts/benchmark-db/cases.ts

Otherchat/RouteChatRooms.server.tschat/chat-room-list.server.ts

function

insertRoom

:223

Inserts a chat room, returning the row. Called in the owning entity's insert transaction.

export function insertRoom(
	args: { type: Tables["ChatRoom"]["type"]; expiresAt: Date },
	trx?: Transaction<DB>,
)

TablesChatRoom

Repositoriesscrims/ScrimPostRepository.server.tssendouq/SQGroupRepository.server.tssendouq-match/SQMatchRepository.server.tstournament-lfg/TournamentLFGRepository.server.ts

Otherapp/db/ChatRoomFactory.ts

function

insertRooms

:240

Inserts count chat rooms of one type, returning their ids in insertion order. Called in the owning entity's insert transaction.

export async function insertRooms(
	args: {
		type: Tables["ChatRoom"]["type"];
		expiresAt: Date;
		count: number;
	},
	trx?: Transaction<DB>,
): Promise<number[]>

TablesChatRoom

Repositoriestournament-bracket/BracketRepository.server.ts

function

updateRoomExpiresAt

:269

Extends a room's lifetime, e.g. when a successor group carries its chat over.

export async function updateRoomExpiresAt(
	args: { roomId: number; expiresAt: Date },
	trx?: Transaction<DB>,
)

TablesChatRoom

Repositoriessendouq/SQGroupRepository.server.ts

function

updateRoomsExpiresAt

:283

Sets rooms' expiry, e.g. to wind down league match rooms once their set is decided.

export async function updateRoomsExpiresAt(
	roomIds: Array<number | null>,
	expiresAt: Date,
	trx?: Transaction<DB>,
)

TablesChatRoom

Repositoriestournament-bracket/BracketRepository.server.ts

function

updateRoomsInactive

:301

Marks rooms' owner activity as concluded, or active again (a reopened tournament match).

export async function updateRoomsInactive(
	roomIds: Array<number | null>,
	inactive: boolean,
	trx?: Transaction<DB>,
)

TablesChatRoom

Unit tests (2)

• marks the given rooms inactive and back active
• ignores null room ids

Repositoriesscrims/ScrimPostRepository.server.tssendouq-match/SQMatchRepository.server.tstournament-bracket/BracketRepository.server.ts

function

insertMessage

:327

Inserts a user message. A publicId conflict (retried send) returns the existing row instead.

export async function insertMessage(args: InsertMessageArgs)

TablesChatMessage

Unit tests (2)

• returns the inserted row
• retried insert with the same publicId returns the existing row without double-inserting

Routes/api/chat/rooms/:id/messages

Otherapp/db/ChatMessageFactory.ts

function

insertSystemMessage

:345

Inserts a system message rendered client-side from its type; authorUserId is the actor it describes.

export function insertSystemMessage(
	args: {
		roomId: number;
		type: PersistedSystemMessageType;
		authorUserId: number;
	},
	trx?: Transaction<DB>,
)

TablesChatMessage

Unit tests (1)

• inserts a typed message with no contents

Otherchat/ChatSystemMessage.server.ts

function

upsertReadIndicator

:363

Marks the newest message a user has seen in a room. Never regresses: upserts keep the MAX.

export async function upsertReadIndicator(
	args: TablesInsertable["ChatMessageReadIndicator"],
)

TablesChatMessageReadIndicator

Unit tests (2)

• creates the indicator on first upsert
• never regresses to an older message

Routes/api/chat/rooms/:id/messages/api/chat/rooms/:id/read

Otherchat/ChatSystemMessage.server.ts

function

closeExpiredRooms

:378

Closes rooms whose expiry is before expiredBefore, returning how many. Messages are kept; access narrows.

export async function closeExpiredRooms(expiredBefore: Date)

TablesChatRoom

Unit tests (2)

• closes only rooms expired before the cutoff
• leaves already-closed rooms untouched

Routinesapp/routines/closeExpiredChatRooms.ts

function

deleteOrphanedRooms

:390

Deletes rooms no owner row points at any more (backstop for owner deletes that missed their room), returning how many. A room's type names its one owner table.

export async function deleteOrphanedRooms()

TablesChatRoom

Unit tests (2)

• deletes an orphaned %s room
• keeps a room its owner still points at

Routinesapp/routines/closeExpiredChatRooms.ts