Kaizen
Browse modulesRulesrules/serverClasses

Class: RuleRepository

Defined in: server/rules/rule-repository.ts:32

Read-only repository for rule rows joined with their current version.

The engine consumes a flattened Rule shape (priority, scopes, condition_logic, domain_config live alongside the rule's identity fields). The DB normalizes those into rules + rule_versions, so every fetch path here joins to currentVersion and runs the result through the engine's Rule Zod schema before returning.

Rows whose currentVersionId is null are excluded — they cannot produce a valid Rule (no priority, scopes, etc.), and the engine has no notion of a "draft" rule.

Will become a CrudRepository in a follow-up PR when write methods land.

Extends

Constructors

Constructor

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

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

Parameters

ParameterType
prismaClientPrismaClientLike<Tx<PrismaClient<PrismaClientOptions, never, DefaultArgs>>> & PrismaClient<PrismaClientOptions, never, DefaultArgs>
optionsRepositoryOptions

Returns

RuleRepository

Inherited from

ReadRepository.constructor

Properties

ENTITY_TYPE?

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 from

ReadRepository.ENTITY_TYPE


logger?

protected readonly optional logger?: Logger;

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

Inherited from

ReadRepository.logger


prismaClient

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

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

Inherited from

ReadRepository.prismaClient

Accessors

actorId

Get Signature

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

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

Returns

string | null | undefined

Inherited from

ReadRepository.actorId


auditCreate

Get Signature

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

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

Returns
{
  createdBy: string | null | undefined;
  updatedBy: string | null | undefined;
}
createdBy
createdBy: string | null | undefined = actorId;
updatedBy
updatedBy: string | null | undefined = actorId;

Inherited from

ReadRepository.auditCreate


auditDelete

Get Signature

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

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

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

Inherited from

ReadRepository.auditDelete


auditUpdate

Get Signature

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

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

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

Inherited from

ReadRepository.auditUpdate


silent

Get Signature

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.

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

this

Inherited from

ReadRepository.silent


tx

Get Signature

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.

Returns

TTx

Inherited from

ReadRepository.tx

Methods

_count()

protected _count(): Promise<number>;

Defined in: server/rules/rule-repository.ts:57

Returns

Promise<number>

Overrides

ReadRepository._count


_exists()

protected _exists(id: string): Promise<boolean>;

Defined in: server/rules/rule-repository.ts:50

Parameters

ParameterType
idstring

Returns

Promise<boolean>

Overrides

ReadRepository._exists


_findById()

protected _findById(id: string): Promise<Rule | null>;

Defined in: server/rules/rule-repository.ts:42

Parameters

ParameterType
idstring

Returns

Promise<Rule | null>

Overrides

ReadRepository._findById


_findMany()

protected _findMany(pagination: {
  page: number;
  pageSize: number;
}): Promise<{
  items: Rule[];
  total: number;
}>;

Defined in: server/rules/rule-repository.ts:63

Parameters

ParameterType
pagination{ page: number; pageSize: number; }
pagination.pagenumber
pagination.pageSizenumber

Returns

Promise<{ items: Rule[]; total: number; }>

Overrides

ReadRepository._findMany


consumeSilent()

protected consumeSilent(): boolean;

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

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

Returns

boolean

Inherited from

ReadRepository.consumeSilent


count()

count(): Promise<number>;

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

Returns

Promise<number>

Inherited from

ReadRepository.count


exists()

exists(id: string): Promise<boolean>;

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

Parameters

ParameterType
idstring

Returns

Promise<boolean>

Inherited from

ReadRepository.exists


findActiveByDomainAndOrg()

findActiveByDomainAndOrg(domain: string, organizationId: string): Promise<Rule[]>;

Defined in: server/rules/rule-repository.ts:92

Fetch every active, non-deleted rule for the given domain + organization, with each rule's current version flattened in. Used by the server-side matchRules() to feed the engine's pure kernel.

Sorting is left to the engine — loadRules re-sorts by priority, so duplicating that work here would be wasted.

Parameters

ParameterType
domainstring
organizationIdstring

Returns

Promise<Rule[]>


findById()

findById(id: string): Promise<Rule | null>;

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

Parameters

ParameterType
idstring

Returns

Promise<Rule | null>

Inherited from

ReadRepository.findById


findByIdOrThrow()

findByIdOrThrow(id: string): Promise<Rule>;

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

Parameters

ParameterType
idstring

Returns

Promise<Rule>

Inherited from

ReadRepository.findByIdOrThrow


findMany()

findMany(pagination: {
  page: number;
  pageSize: number;
}): Promise<OffsetPaginatedResult<Rule>>;

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

Parameters

ParameterType
pagination{ page: number; pageSize: number; }
pagination.pagenumber
pagination.pageSizenumber

Returns

Promise<OffsetPaginatedResult<Rule>>

Inherited from

ReadRepository.findMany


logActivity()

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

Parameters

ParameterType
_entityIdstring
_actionstring
_metadata?Record<string, unknown>

Returns

Promise<void>

Inherited from

ReadRepository.logActivity


notFoundError()

protected notFoundError(id: string): Error;

Defined in: server/rules/rule-repository.ts:38

Create a not-found error. Override to provide custom error types.

Parameters

ParameterType
idstring

Returns

Error

Overrides

ReadRepository.notFoundError

On this page