Class: BackgroundJobRunRepository

Defined in: server/background-jobs/background-job-run-repository.ts:29

Repository for background_job_runs rows — the opt-in job-runs audit table.

Extends BaseRepository<PrismaClient, Tx<PrismaClient>> so this.tx resolves to the active transaction handle when called inside a TransactionManager scope, and falls back to the raw client otherwise. Audit columns are populated via the inherited auditCreate / auditUpdate getters (sourced from the constructor-time actor), not direct actorId access.

Extends BaseRepository directly rather than CrudRepository / WriteRepository: this is a status-tracking audit log written from the lifecycle subscriber (upsert-on-queue, then monotonic status updates by jobId). One row per (queueName, jobId) represents the latest run — a reused custom jobId (BullMQ's dedup pattern) resets the row to a fresh run rather than accumulating duplicates. It has no read/ownership/soft-delete lifecycle, so the CRUD template machinery would be unused.

NOTE: this repo requires the consumer's Prisma client to expose the backgroundJobRun model (run taproot db:setup). Audit writes are best-effort — the lifecycle subscriber catches and logs failures rather than throwing — so a misconfigured consumer surfaces as a per-job console.error rather than failing fast. Pass repo only when the model is present.

ExtendsCopy Anchor Link

• BaseRepository<PrismaClient, Tx<PrismaClient>>

ConstructorsCopy Anchor Link

ConstructorCopy Anchor Link

new BackgroundJobRunRepository(prismaClient: PrismaClientLike<Tx<PrismaClient<PrismaClientOptions, never, DefaultArgs>>> & PrismaClient<PrismaClientOptions, never, DefaultArgs>, options?: RepositoryOptions): BackgroundJobRunRepository;

Defined in: server/persistence/base-repository.ts:68

ParametersCopy Anchor Link

ReturnsCopy Anchor Link

BackgroundJobRunRepository

Inherited fromCopy Anchor Link

BaseRepository.constructor

PropertiesCopy Anchor Link

ENTITY_TYPE?Copy Anchor Link

protected readonly optional ENTITY_TYPE?: string;

Defined in: server/persistence/base-repository.ts:61

Set ENTITY_TYPE in child repositories to enable automatic activity logging. When set, create/update/delete operations auto-log unless silenced with .silent. Requires an activity model on the consumer's Prisma schema.

Inherited fromCopy Anchor Link

BaseRepository.ENTITY_TYPE

logger?Copy Anchor Link

protected readonly optional logger?: Logger;

Defined in: server/persistence/base-repository.ts:64

Inherited fromCopy Anchor Link

BaseRepository.logger

prismaClientCopy Anchor Link

protected prismaClient: PrismaClientLike<Tx<PrismaClient<PrismaClientOptions, never, DefaultArgs>>> & PrismaClient<PrismaClientOptions, never, DefaultArgs>;

Defined in: server/persistence/base-repository.ts:69

Inherited fromCopy Anchor Link

BaseRepository.prismaClient

AccessorsCopy Anchor Link

actorIdCopy Anchor Link

Get SignatureCopy Anchor Link

get protected actorId(): string | null | undefined;

Defined in: server/persistence/base-repository.ts:76

ReturnsCopy Anchor Link

string | null | undefined

Inherited fromCopy Anchor Link

BaseRepository.actorId

auditCreateCopy Anchor Link

Get SignatureCopy Anchor Link

get protected auditCreate(): {
  createdBy: string | null | undefined;
  updatedBy: string | null | undefined;
};

Defined in: server/persistence/base-repository.ts:90

ReturnsCopy Anchor Link

{
  createdBy: string | null | undefined;
  updatedBy: string | null | undefined;
}

createdByCopy Anchor Link

createdBy: string | null | undefined = actorId;

updatedByCopy Anchor Link

updatedBy: string | null | undefined = actorId;

Inherited fromCopy Anchor Link

BaseRepository.auditCreate

auditDeleteCopy Anchor Link

Get SignatureCopy Anchor Link

get protected auditDelete(): {
  deletedAt: Date;
  deletedBy: string | null | undefined;
};

Defined in: server/persistence/base-repository.ts:99

ReturnsCopy Anchor Link

{
  deletedAt: Date;
  deletedBy: string | null | undefined;
}

deletedAtCopy Anchor Link

deletedAt: Date;

deletedByCopy Anchor Link

deletedBy: string | null | undefined;

Inherited fromCopy Anchor Link

BaseRepository.auditDelete

auditUpdateCopy Anchor Link

Get SignatureCopy Anchor Link

get protected auditUpdate(): {
  updatedBy: string | null | undefined;
};

Defined in: server/persistence/base-repository.ts:95

ReturnsCopy Anchor Link

{
  updatedBy: string | null | undefined;
}

updatedByCopy Anchor Link

updatedBy: string | null | undefined;

Inherited fromCopy Anchor Link

BaseRepository.auditUpdate

silentCopy Anchor Link

Get SignatureCopy Anchor Link

get silent(): this;

Defined in: server/persistence/base-repository.ts:115

Suppress activity logging for the next mutation call. One-shot: the flag is consumed by the next create/update/delete.

ExampleCopy Anchor Link

await repo.silent.update(id, data);   // no activity logged
await repo.update(id, data);          // activity logged normally

ReturnsCopy Anchor Link

this

Inherited fromCopy Anchor Link

BaseRepository.silent

txCopy Anchor Link

Get SignatureCopy Anchor Link

get protected tx(): TTx;

Defined in: server/persistence/base-repository.ts:86

The current Prisma handle: the active transaction if one is running on this async context, otherwise the raw client.

ReturnsCopy Anchor Link

TTx

Inherited fromCopy Anchor Link

BaseRepository.tx

MethodsCopy Anchor Link

consumeSilent()Copy Anchor Link

protected consumeSilent(): boolean;

Defined in: server/persistence/base-repository.ts:128

Consume and reset the silent flag. Called by template methods.

ReturnsCopy Anchor Link

boolean

Inherited fromCopy Anchor Link

BaseRepository.consumeSilent

logActivity()Copy Anchor Link

protected logActivity(
   _entityId: string, 
   _action: string, 
   _metadata?: Record<string, unknown>
): Promise<void>;

Defined in: server/persistence/base-repository.ts:140

Log an activity entry.

NOTE: This is not implemented because there's no activity model implemented in taproot yet! https://linear.app/kaizenlabs/issue/ENG-7846/add-activity-log-tables

ParametersCopy Anchor Link

ReturnsCopy Anchor Link

Promise<void>

Inherited fromCopy Anchor Link

BaseRepository.logActivity

recordCompletion()Copy Anchor Link

recordCompletion(queueName: string, jobId: string): Promise<void>;

Defined in: server/background-jobs/background-job-run-repository.ts:64

ParametersCopy Anchor Link

ReturnsCopy Anchor Link

Promise<void>

recordFailure()Copy Anchor Link

recordFailure(
   queueName: string, 
   jobId: string, 
   error: string
): Promise<void>;

Defined in: server/background-jobs/background-job-run-repository.ts:76

ParametersCopy Anchor Link

ReturnsCopy Anchor Link

Promise<void>

recordQueued()Copy Anchor Link

recordQueued(params: {
  jobId: string;
  jobName: string;
  organizationId?: string;
  queueName: string;
}): Promise<void>;

Defined in: server/background-jobs/background-job-run-repository.ts:33

ParametersCopy Anchor Link

ReturnsCopy Anchor Link

Promise<void>

recordStalled()Copy Anchor Link

recordStalled(queueName: string, jobId: string): Promise<void>;

Defined in: server/background-jobs/background-job-run-repository.ts:93

ParametersCopy Anchor Link

ReturnsCopy Anchor Link

Promise<void>