Chris Arderne
c7861be520
Once this is merged, oxlint is at a pretty sensible baseline. **Enable `no-unused-vars`, `typescript/consistent-type-imports`, and `import/no-duplicates` lint rules** Turns on three previously-disabled oxlint rules across the monorepo and fixes all violations: - **`no-unused-vars`** – enabled as an error with standard ignore patterns: unused function arguments are ignored by default (`args: "none"`), variables/caught errors/destructured array elements prefixed with `_` are allowed, and rest siblings are permitted. - **`typescript/consistent-type-imports`** – enforced as an error; all type-only imports now use the `import type` syntax. - **`import/no-duplicates`** – enforced as an error; duplicate import statements from the same module have been merged. The remaining commits clean up the violations found across the codebase: removing unused variables/imports/type aliases, adding `_` prefixes to intentionally unused bindings, fixing duplicate imports, and converting value imports to `import type` where appropriate.
29 lines
851 B
TypeScript
29 lines
851 B
TypeScript
import type { z } from "zod";
|
|
import type { PrismaClient } from "~/db.server";
|
|
import { prisma } from "~/db.server";
|
|
import { logger } from "~/services/logger.server";
|
|
import type { NotificationCatalog, NotificationChannel } from "./types";
|
|
|
|
export class PgNotifyService {
|
|
#prismaClient: PrismaClient;
|
|
|
|
constructor(prismaClient: PrismaClient = prisma) {
|
|
this.#prismaClient = prismaClient;
|
|
}
|
|
|
|
public async call<TChannel extends NotificationChannel>(
|
|
channelName: TChannel,
|
|
payload: z.infer<NotificationCatalog[TChannel]>
|
|
) {
|
|
this.#logDebug("Sending notification", { channelName, notifyPayload: payload });
|
|
|
|
await this.#prismaClient.$executeRaw`
|
|
SELECT pg_notify(${channelName}, ${JSON.stringify(payload)})
|
|
`;
|
|
}
|
|
|
|
#logDebug(message: string, args?: any) {
|
|
logger.debug(`[pgNotify] ${message}`, args);
|
|
}
|
|
}
|