john
48 lines
1.8 KiB
JavaScript
48 lines
1.8 KiB
JavaScript
function registryError(message, code) {
|
|
return Object.assign(new Error(message), { code });
|
|
}
|
|
|
|
function requireMethod(target, methodName, code) {
|
|
if (!target || typeof target[methodName] !== 'function') {
|
|
throw registryError(`MindSpace conversation package registry requires ${methodName}`, code);
|
|
}
|
|
}
|
|
|
|
export function createConversationPackageRegistry({ store, service } = {}) {
|
|
requireMethod(store, 'upsertPackage', 'missing_conversation_package_store');
|
|
requireMethod(store, 'upsertArtifact', 'missing_conversation_package_store');
|
|
requireMethod(store, 'getPackageBySession', 'missing_conversation_package_store');
|
|
requireMethod(store, 'listArtifacts', 'missing_conversation_package_store');
|
|
requireMethod(service, 'putConversationManifest', 'missing_mindspace_service');
|
|
requireMethod(service, 'buildConversationManifest', 'missing_mindspace_service');
|
|
|
|
return {
|
|
async ensurePackage(input) {
|
|
return store.upsertPackage(input);
|
|
},
|
|
|
|
async recordArtifact(input) {
|
|
return store.upsertArtifact(input);
|
|
},
|
|
|
|
async writeManifestForSession({ userId, sessionId }) {
|
|
const packageRecord = await store.getPackageBySession(userId, sessionId);
|
|
if (!packageRecord) return null;
|
|
const artifacts = await store.listArtifacts(packageRecord.id);
|
|
return service.putConversationManifest({ packageRecord, artifacts });
|
|
},
|
|
|
|
async readManifestForSession({ userId, sessionId }) {
|
|
const packageRecord = await store.getPackageBySession(userId, sessionId);
|
|
if (!packageRecord) return null;
|
|
const artifacts = await store.listArtifacts(packageRecord.id);
|
|
return service.buildConversationManifest({ packageRecord, artifacts });
|
|
},
|
|
};
|
|
}
|
|
|
|
export const conversationPackageRegistryInternals = {
|
|
registryError,
|
|
requireMethod,
|
|
};
|