Kaizen
Browse modulesFormsforms/serverClasses

Class: FormSubmissionVersionRepository

Defined in: server/forms/form-submission-version-repository.ts:29

Repository for version entities in parent-child versioning patterns.

Use for entities that:

  • link to a parent entity via parentId
  • order versions by versionNumber
  • are append-only (immutable once created)

Provides findByParentId, findLatestByParentId, getNextVersionNumber, countByParentId, and an audit-aware create.

Extends

  • VersionRepository<PrismaClient, FormSubmissionVersions, CreateInput, string, Tx<PrismaClient>>

Constructors

Constructor

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

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

Parameters

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

Returns

FormSubmissionVersionRepository

Inherited from

VersionRepository.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

VersionRepository.ENTITY_TYPE


logger?

protected readonly optional logger?: Logger;

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

Inherited from

VersionRepository.logger


prismaClient

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

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

Inherited from

VersionRepository.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

VersionRepository.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

VersionRepository.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

VersionRepository.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

VersionRepository.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

VersionRepository.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

VersionRepository.tx

Methods

_count()

protected _count(): Promise<number>;

Defined in: server/forms/form-submission-version-repository.ts:55

Returns

Promise<number>

Overrides

VersionRepository._count


_countByParentId()

protected _countByParentId(formSubmissionId: string): Promise<number>;

Defined in: server/forms/form-submission-version-repository.ts:85

Parameters

ParameterType
formSubmissionIdstring

Returns

Promise<number>

Overrides

VersionRepository._countByParentId


_create()

protected _create(input: CreateInput): Promise<{
  changeReason: string | null;
  createdAt: Date;
  createdBy: string | null;
  currentStepKey: string | null;
  data: JsonValue;
  deletedAt: Date | null;
  deletedBy: string | null;
  formSchemaVersionId: string;
  formSubmissionId: string;
  id: string;
  isComplete: boolean;
  lastActivityAt: Date;
  versionNumber: number;
  visitedStepKeys: string[];
}>;

Defined in: server/forms/form-submission-version-repository.ts:91

Parameters

ParameterType
inputCreateInput

Returns

Promise<{ changeReason: string | null; createdAt: Date; createdBy: string | null; currentStepKey: string | null; data: JsonValue; deletedAt: Date | null; deletedBy: string | null; formSchemaVersionId: string; formSubmissionId: string; id: string; isComplete: boolean; lastActivityAt: Date; versionNumber: number; visitedStepKeys: string[]; }>

Overrides

VersionRepository._create


_exists()

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

Defined in: server/forms/form-submission-version-repository.ts:48

Parameters

ParameterType
idstring

Returns

Promise<boolean>

Overrides

VersionRepository._exists


_findById()

protected _findById(id: string): Promise<
  | {
  changeReason: string | null;
  createdAt: Date;
  createdBy: string | null;
  currentStepKey: string | null;
  data: JsonValue;
  deletedAt: Date | null;
  deletedBy: string | null;
  formSchemaVersionId: string;
  formSubmissionId: string;
  id: string;
  isComplete: boolean;
  lastActivityAt: Date;
  versionNumber: number;
  visitedStepKeys: string[];
}
| null>;

Defined in: server/forms/form-submission-version-repository.ts:40

Parameters

ParameterType
idstring

Returns

Promise< | { changeReason: string | null; createdAt: Date; createdBy: string | null; currentStepKey: string | null; data: JsonValue; deletedAt: Date | null; deletedBy: string | null; formSchemaVersionId: string; formSubmissionId: string; id: string; isComplete: boolean; lastActivityAt: Date; versionNumber: number; visitedStepKeys: string[]; } | null>

Overrides

VersionRepository._findById


_findByParentId()

protected _findByParentId(formSubmissionId: string): Promise<{
  changeReason: string | null;
  createdAt: Date;
  createdBy: string | null;
  currentStepKey: string | null;
  data: JsonValue;
  deletedAt: Date | null;
  deletedBy: string | null;
  formSchemaVersionId: string;
  formSubmissionId: string;
  id: string;
  isComplete: boolean;
  lastActivityAt: Date;
  versionNumber: number;
  visitedStepKeys: string[];
}[]>;

Defined in: server/forms/form-submission-version-repository.ts:76

Parameters

ParameterType
formSubmissionIdstring

Returns

Promise<{ changeReason: string | null; createdAt: Date; createdBy: string | null; currentStepKey: string | null; data: JsonValue; deletedAt: Date | null; deletedBy: string | null; formSchemaVersionId: string; formSubmissionId: string; id: string; isComplete: boolean; lastActivityAt: Date; versionNumber: number; visitedStepKeys: string[]; }[]>

Overrides

VersionRepository._findByParentId


_findMany()

protected _findMany(pagination: {
  page: number;
  pageSize: number;
}): Promise<{
  items: {
     changeReason: string | null;
     createdAt: Date;
     createdBy: string | null;
     currentStepKey: string | null;
     data: JsonValue;
     deletedAt: Date | null;
     deletedBy: string | null;
     formSchemaVersionId: string;
     formSubmissionId: string;
     id: string;
     isComplete: boolean;
     lastActivityAt: Date;
     versionNumber: number;
     visitedStepKeys: string[];
  }[];
  total: number;
}>;

Defined in: server/forms/form-submission-version-repository.ts:59

Parameters

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

Returns

Promise<{ items: { changeReason: string | null; createdAt: Date; createdBy: string | null; currentStepKey: string | null; data: JsonValue; deletedAt: Date | null; deletedBy: string | null; formSchemaVersionId: string; formSubmissionId: string; id: string; isComplete: boolean; lastActivityAt: Date; versionNumber: number; visitedStepKeys: string[]; }[]; total: number; }>

Overrides

VersionRepository._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

VersionRepository.consumeSilent


count()

count(): Promise<number>;

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

Returns

Promise<number>

Inherited from

VersionRepository.count


countByParentId()

countByParentId(parentId: string): Promise<number>;

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

Parameters

ParameterType
parentIdstring

Returns

Promise<number>

Inherited from

VersionRepository.countByParentId


create()

create(input: CreateInput): Promise<{
  changeReason: string | null;
  createdAt: Date;
  createdBy: string | null;
  currentStepKey: string | null;
  data: JsonValue;
  deletedAt: Date | null;
  deletedBy: string | null;
  formSchemaVersionId: string;
  formSubmissionId: string;
  id: string;
  isComplete: boolean;
  lastActivityAt: Date;
  versionNumber: number;
  visitedStepKeys: string[];
}>;

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

Parameters

ParameterType
inputCreateInput

Returns

Promise<{ changeReason: string | null; createdAt: Date; createdBy: string | null; currentStepKey: string | null; data: JsonValue; deletedAt: Date | null; deletedBy: string | null; formSchemaVersionId: string; formSubmissionId: string; id: string; isComplete: boolean; lastActivityAt: Date; versionNumber: number; visitedStepKeys: string[]; }>

Inherited from

VersionRepository.create


exists()

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

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

Parameters

ParameterType
idstring

Returns

Promise<boolean>

Inherited from

VersionRepository.exists


findActiveDraft()

findActiveDraft(formSubmissionId: string): Promise<
  | {
  changeReason: string | null;
  createdAt: Date;
  createdBy: string | null;
  currentStepKey: string | null;
  data: JsonValue;
  deletedAt: Date | null;
  deletedBy: string | null;
  formSchemaVersionId: string;
  formSubmissionId: string;
  id: string;
  isComplete: boolean;
  lastActivityAt: Date;
  versionNumber: number;
  visitedStepKeys: string[];
}
| null>;

Defined in: server/forms/form-submission-version-repository.ts:137

Returns the active (in-flight) draft for a submission, or null if the user has none. The createDraft flow enforces at-most-one active draft per submission, so this is safe to assume single-row.

Parameters

ParameterType
formSubmissionIdstring

Returns

Promise< | { changeReason: string | null; createdAt: Date; createdBy: string | null; currentStepKey: string | null; data: JsonValue; deletedAt: Date | null; deletedBy: string | null; formSchemaVersionId: string; formSubmissionId: string; id: string; isComplete: boolean; lastActivityAt: Date; versionNumber: number; visitedStepKeys: string[]; } | null>


findByFormSubmissionId()

findByFormSubmissionId(formSubmissionId: string): Promise<{
  changeReason: string | null;
  createdAt: Date;
  createdBy: string | null;
  currentStepKey: string | null;
  data: JsonValue;
  deletedAt: Date | null;
  deletedBy: string | null;
  formSchemaVersionId: string;
  formSubmissionId: string;
  id: string;
  isComplete: boolean;
  lastActivityAt: Date;
  versionNumber: number;
  visitedStepKeys: string[];
}[]>;

Defined in: server/forms/form-submission-version-repository.ts:116

Parameters

ParameterType
formSubmissionIdstring

Returns

Promise<{ changeReason: string | null; createdAt: Date; createdBy: string | null; currentStepKey: string | null; data: JsonValue; deletedAt: Date | null; deletedBy: string | null; formSchemaVersionId: string; formSubmissionId: string; id: string; isComplete: boolean; lastActivityAt: Date; versionNumber: number; visitedStepKeys: string[]; }[]>


findById()

findById(id: string): Promise<
  | {
  changeReason: string | null;
  createdAt: Date;
  createdBy: string | null;
  currentStepKey: string | null;
  data: JsonValue;
  deletedAt: Date | null;
  deletedBy: string | null;
  formSchemaVersionId: string;
  formSubmissionId: string;
  id: string;
  isComplete: boolean;
  lastActivityAt: Date;
  versionNumber: number;
  visitedStepKeys: string[];
}
| null>;

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

Parameters

ParameterType
idstring

Returns

Promise< | { changeReason: string | null; createdAt: Date; createdBy: string | null; currentStepKey: string | null; data: JsonValue; deletedAt: Date | null; deletedBy: string | null; formSchemaVersionId: string; formSubmissionId: string; id: string; isComplete: boolean; lastActivityAt: Date; versionNumber: number; visitedStepKeys: string[]; } | null>

Inherited from

VersionRepository.findById


findByIdOrThrow()

findByIdOrThrow(id: string): Promise<{
  changeReason: string | null;
  createdAt: Date;
  createdBy: string | null;
  currentStepKey: string | null;
  data: JsonValue;
  deletedAt: Date | null;
  deletedBy: string | null;
  formSchemaVersionId: string;
  formSubmissionId: string;
  id: string;
  isComplete: boolean;
  lastActivityAt: Date;
  versionNumber: number;
  visitedStepKeys: string[];
}>;

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

Parameters

ParameterType
idstring

Returns

Promise<{ changeReason: string | null; createdAt: Date; createdBy: string | null; currentStepKey: string | null; data: JsonValue; deletedAt: Date | null; deletedBy: string | null; formSchemaVersionId: string; formSubmissionId: string; id: string; isComplete: boolean; lastActivityAt: Date; versionNumber: number; visitedStepKeys: string[]; }>

Inherited from

VersionRepository.findByIdOrThrow


findByParentId()

findByParentId(parentId: string): Promise<{
  changeReason: string | null;
  createdAt: Date;
  createdBy: string | null;
  currentStepKey: string | null;
  data: JsonValue;
  deletedAt: Date | null;
  deletedBy: string | null;
  formSchemaVersionId: string;
  formSubmissionId: string;
  id: string;
  isComplete: boolean;
  lastActivityAt: Date;
  versionNumber: number;
  visitedStepKeys: string[];
}[]>;

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

Parameters

ParameterType
parentIdstring

Returns

Promise<{ changeReason: string | null; createdAt: Date; createdBy: string | null; currentStepKey: string | null; data: JsonValue; deletedAt: Date | null; deletedBy: string | null; formSchemaVersionId: string; formSubmissionId: string; id: string; isComplete: boolean; lastActivityAt: Date; versionNumber: number; visitedStepKeys: string[]; }[]>

Inherited from

VersionRepository.findByParentId


findLatestByFormSubmissionId()

findLatestByFormSubmissionId(formSubmissionId: string): Promise<
  | {
  changeReason: string | null;
  createdAt: Date;
  createdBy: string | null;
  currentStepKey: string | null;
  data: JsonValue;
  deletedAt: Date | null;
  deletedBy: string | null;
  formSchemaVersionId: string;
  formSubmissionId: string;
  id: string;
  isComplete: boolean;
  lastActivityAt: Date;
  versionNumber: number;
  visitedStepKeys: string[];
}
| null>;

Defined in: server/forms/form-submission-version-repository.ts:122

Parameters

ParameterType
formSubmissionIdstring

Returns

Promise< | { changeReason: string | null; createdAt: Date; createdBy: string | null; currentStepKey: string | null; data: JsonValue; deletedAt: Date | null; deletedBy: string | null; formSchemaVersionId: string; formSubmissionId: string; id: string; isComplete: boolean; lastActivityAt: Date; versionNumber: number; visitedStepKeys: string[]; } | null>


findLatestByParentId()

findLatestByParentId(parentId: string): Promise<
  | {
  changeReason: string | null;
  createdAt: Date;
  createdBy: string | null;
  currentStepKey: string | null;
  data: JsonValue;
  deletedAt: Date | null;
  deletedBy: string | null;
  formSchemaVersionId: string;
  formSubmissionId: string;
  id: string;
  isComplete: boolean;
  lastActivityAt: Date;
  versionNumber: number;
  visitedStepKeys: string[];
}
| null>;

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

Parameters

ParameterType
parentIdstring

Returns

Promise< | { changeReason: string | null; createdAt: Date; createdBy: string | null; currentStepKey: string | null; data: JsonValue; deletedAt: Date | null; deletedBy: string | null; formSchemaVersionId: string; formSubmissionId: string; id: string; isComplete: boolean; lastActivityAt: Date; versionNumber: number; visitedStepKeys: string[]; } | null>

Inherited from

VersionRepository.findLatestByParentId


findMany()

findMany(pagination: {
  page: number;
  pageSize: number;
}): Promise<OffsetPaginatedResult<{
  changeReason: string | null;
  createdAt: Date;
  createdBy: string | null;
  currentStepKey: string | null;
  data: JsonValue;
  deletedAt: Date | null;
  deletedBy: string | null;
  formSchemaVersionId: string;
  formSubmissionId: string;
  id: string;
  isComplete: boolean;
  lastActivityAt: Date;
  versionNumber: number;
  visitedStepKeys: string[];
}>>;

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

Parameters

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

Returns

Promise<OffsetPaginatedResult<{ changeReason: string | null; createdAt: Date; createdBy: string | null; currentStepKey: string | null; data: JsonValue; deletedAt: Date | null; deletedBy: string | null; formSchemaVersionId: string; formSubmissionId: string; id: string; isComplete: boolean; lastActivityAt: Date; versionNumber: number; visitedStepKeys: string[]; }>>

Inherited from

VersionRepository.findMany


getNextVersionNumber()

getNextVersionNumber(parentId: string): Promise<number>;

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

Next version number = highest versionNumber among the rows _findByParentId returns, plus one. Subclasses typically filter _findByParentId to deletedAt: null, so this counts only live rows.

That is collision-safe only while the subclass never soft-deletes version rows. If a subclass gains a discard/soft-delete path AND its @@unique(parentId, versionNumber) constraint counts soft-deleted rows (Postgres unique indexes do), reusing a discarded row's number will violate the constraint. Such a subclass must override to compute the max over all rows including soft-deleted — see FormSchemaVersionRepository.nextVersionNumber. Promote that into a shared abstract hook here once a second repo needs it.

Parameters

ParameterType
parentIdstring

Returns

Promise<number>

Inherited from

VersionRepository.getNextVersionNumber


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

VersionRepository.logActivity


markComplete()

markComplete(id: string, visitedStepKeys: string[]): Promise<{
  changeReason: string | null;
  createdAt: Date;
  createdBy: string | null;
  currentStepKey: string | null;
  data: JsonValue;
  deletedAt: Date | null;
  deletedBy: string | null;
  formSchemaVersionId: string;
  formSubmissionId: string;
  id: string;
  isComplete: boolean;
  lastActivityAt: Date;
  versionNumber: number;
  visitedStepKeys: string[];
}>;

Defined in: server/forms/form-submission-version-repository.ts:182

Flip a draft to completed. Freezes visitedStepKeys and clears currentStepKey (a completed submission is no longer "on" a step).

Parameters

ParameterType
idstring
visitedStepKeysstring[]

Returns

Promise<{ changeReason: string | null; createdAt: Date; createdBy: string | null; currentStepKey: string | null; data: JsonValue; deletedAt: Date | null; deletedBy: string | null; formSchemaVersionId: string; formSubmissionId: string; id: string; isComplete: boolean; lastActivityAt: Date; versionNumber: number; visitedStepKeys: string[]; }>


nextVersionNumber()

nextVersionNumber(formSubmissionId: string): Promise<number>;

Defined in: server/forms/form-submission-version-repository.ts:128

Parameters

ParameterType
formSubmissionIdstring

Returns

Promise<number>


notFoundError()

protected notFoundError(id: string): Error;

Defined in: server/forms/form-submission-version-repository.ts:36

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

Parameters

ParameterType
idstring

Returns

Error

Overrides

VersionRepository.notFoundError


updateDraft()

updateDraft(id: string, patch: {
  currentStepKey?: string | null;
  data?: FormDataRecord;
  visitedStepKeys?: string[];
}): Promise<{
  changeReason: string | null;
  createdAt: Date;
  createdBy: string | null;
  currentStepKey: string | null;
  data: JsonValue;
  deletedAt: Date | null;
  deletedBy: string | null;
  formSchemaVersionId: string;
  formSubmissionId: string;
  id: string;
  isComplete: boolean;
  lastActivityAt: Date;
  versionNumber: number;
  visitedStepKeys: string[];
}>;

Defined in: server/forms/form-submission-version-repository.ts:153

Patch a draft's mutable fields in place. lastActivityAt is bumped on every call so admin views can flag abandoned drafts. Never flips isComplete — that happens via markComplete at submit time.

Caller is expected to have verified the row is still a draft; this method does not re-check isComplete.

Parameters

ParameterType
idstring
patch{ currentStepKey?: string | null; data?: FormDataRecord; visitedStepKeys?: string[]; }
patch.currentStepKey?string | null
patch.data?FormDataRecord
patch.visitedStepKeys?string[]

Returns

Promise<{ changeReason: string | null; createdAt: Date; createdBy: string | null; currentStepKey: string | null; data: JsonValue; deletedAt: Date | null; deletedBy: string | null; formSchemaVersionId: string; formSubmissionId: string; id: string; isComplete: boolean; lastActivityAt: Date; versionNumber: number; visitedStepKeys: string[]; }>

On this page