110 lines
3.2 KiB
TypeScript
110 lines
3.2 KiB
TypeScript
// The handlers of the module's procedures: each takes the service its kind may use and calls one use
|
|
// case. No rule lives here.
|
|
|
|
import { implement } from "@conusai-kit/core"
|
|
import { filesDeps } from "@conusai-kit/files"
|
|
import {
|
|
disposalList,
|
|
documentDispose,
|
|
documentGet,
|
|
documentHold,
|
|
documentList,
|
|
documentRegister,
|
|
retentionCreate,
|
|
retentionList,
|
|
versionAdd,
|
|
} from "../contract/index.js"
|
|
import {
|
|
addVersion,
|
|
createRetentionClass,
|
|
disposeDocument,
|
|
getDocument,
|
|
listDisposalDue,
|
|
listDocuments,
|
|
listRetentionClasses,
|
|
registerDocument,
|
|
setLegalHold,
|
|
} from "../core/archive.js"
|
|
import { archiveServiceOf } from "./service.js"
|
|
|
|
const paged = (input: { after?: string | undefined; limit?: number | undefined }) => ({
|
|
...(input.after === undefined ? {} : { after: input.after }),
|
|
...(input.limit === undefined ? {} : { limit: input.limit }),
|
|
})
|
|
|
|
export const documentListImpl = implement(documentList, ({ input, ctx }) =>
|
|
listDocuments(archiveServiceOf(ctx.container, ctx.kind), {
|
|
...(input.q === undefined ? {} : { q: input.q }),
|
|
...paged(input),
|
|
}),
|
|
)
|
|
|
|
export const documentGetImpl = implement(documentGet, ({ input, ctx }) =>
|
|
getDocument(archiveServiceOf(ctx.container, ctx.kind), input.documentId),
|
|
)
|
|
|
|
export const documentRegisterImpl = implement(documentRegister, ({ input, ctx }) =>
|
|
registerDocument(archiveServiceOf(ctx.container, "effect"), filesDeps(ctx.container), ctx.scope, {
|
|
title: input.title,
|
|
...(input.kind === undefined ? {} : { kind: input.kind }),
|
|
retentionClass: input.retentionClass,
|
|
fileId: input.fileId,
|
|
requestId: input.requestId,
|
|
}),
|
|
)
|
|
|
|
export const versionAddImpl = implement(versionAdd, ({ input, ctx }) =>
|
|
addVersion(archiveServiceOf(ctx.container, "effect"), filesDeps(ctx.container), ctx.scope, {
|
|
documentId: input.documentId,
|
|
revision: input.revision,
|
|
fileId: input.fileId,
|
|
requestId: input.requestId,
|
|
}),
|
|
)
|
|
|
|
export const documentHoldImpl = implement(documentHold, ({ input, ctx }) =>
|
|
setLegalHold(archiveServiceOf(ctx.container, "effect"), ctx.scope, {
|
|
documentId: input.documentId,
|
|
revision: input.revision,
|
|
legalHold: input.legalHold,
|
|
requestId: input.requestId,
|
|
}),
|
|
)
|
|
|
|
export const documentDisposeImpl = implement(documentDispose, ({ input, ctx }) =>
|
|
disposeDocument(archiveServiceOf(ctx.container, "effect"), ctx.scope, {
|
|
documentId: input.documentId,
|
|
revision: input.revision,
|
|
requestId: input.requestId,
|
|
}),
|
|
)
|
|
|
|
export const retentionListImpl = implement(retentionList, ({ input, ctx }) =>
|
|
listRetentionClasses(archiveServiceOf(ctx.container, ctx.kind), paged(input)),
|
|
)
|
|
|
|
export const retentionCreateImpl = implement(retentionCreate, ({ input, ctx }) =>
|
|
createRetentionClass(archiveServiceOf(ctx.container, "effect"), ctx.scope, {
|
|
code: input.code,
|
|
keepFor: input.keepFor,
|
|
from: input.from,
|
|
requestId: input.requestId,
|
|
}),
|
|
)
|
|
|
|
export const disposalListImpl = implement(disposalList, ({ input, ctx }) =>
|
|
listDisposalDue(archiveServiceOf(ctx.container, ctx.kind), paged(input)),
|
|
)
|
|
|
|
export const ARCHIVE_PROCEDURES = [
|
|
documentListImpl,
|
|
documentGetImpl,
|
|
documentRegisterImpl,
|
|
versionAddImpl,
|
|
documentHoldImpl,
|
|
documentDisposeImpl,
|
|
retentionListImpl,
|
|
retentionCreateImpl,
|
|
disposalListImpl,
|
|
]
|