seerr/server/utils/requestLock.ts

import type { MediaType } from '@server/constants/media';
import AsyncLock from '@server/utils/asyncLock';

// Keyed on user id or request id. Never dispatch from a subscriber or
// transaction as a waiter would block while holding the save's connection.
const requestLock = new AsyncLock();

// keyed on media. always taken inside requestLock, never around it.
export const mediaLock = new AsyncLock();

export const userKey = (userId: number) => `user:${userId}`;
export const requestKey = (requestId: number) => `request:${requestId}`;
export const mediaKey = (mediaType: MediaType, mediaId: number) =>
  `${mediaType}:${mediaId}`;

export default requestLock;