Something went wrong. Try again.
ATProto-based AI Assistant Chat interface.
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778import type { Db } from '../db/index.ts'import type { SecretBox } from '../secrets.ts'
/** A configured plugin, with its options split into plain values and secrets. */export type PluginInstance = { id: string package: string enabled: boolean options: Record<string, unknown> secrets: Record<string, unknown> /** * Stored secrets no current or retired key can decrypt, which read as unset. They are written * back as they are until an admin enters a secret, so a restored key brings them back. */ unreadableSecrets?: string}
/** Every plugin instance, in load order, with secrets decrypted. */export async function readInstances(db: Db, box: SecretBox): Promise<PluginInstance[]> { const rows = await db.selectFrom('plugin_instance').selectAll().orderBy('position').execute() return rows.map((row) => { const instance = { id: row.id, package: row.package, enabled: row.enabled === 1, options: JSON.parse(row.options_json) as Record<string, unknown>, } if (!row.secrets_encrypted) return { ...instance, secrets: {} } const decrypted = box.tryDecrypt(row.secrets_encrypted) if (decrypted === undefined) return { ...instance, secrets: {}, unreadableSecrets: row.secrets_encrypted } return { ...instance, secrets: JSON.parse(decrypted) as Record<string, unknown> } })}
/** Replace the stored instances with this list, in this order. */export async function writeInstances( db: Db, box: SecretBox, instances: PluginInstance[], adminDid: string,): Promise<void> { await db.transaction().execute((tx) => replaceInstances(tx, box, instances, adminDid))}
/** `writeInstances` within a transaction the caller holds. */export async function replaceInstances( db: Db, box: SecretBox, instances: PluginInstance[], adminDid: string,): Promise<void> { const now = new Date().toISOString() const ids = instances.map((instance) => instance.id) let removal = db.deleteFrom('plugin_instance') if (ids.length) removal = removal.where('id', 'not in', ids) await removal.execute() for (const [position, instance] of instances.entries()) { const entered = Object.keys(instance.secrets).length > 0 const row = { package: instance.package, position, enabled: instance.enabled ? 1 : 0, options_json: JSON.stringify(instance.options), secrets_encrypted: entered ? box.encrypt(JSON.stringify(instance.secrets)) : (instance.unreadableSecrets ?? null), updated_at: now, updated_by: adminDid, } await db .insertInto('plugin_instance') .values({ id: instance.id, created_at: now, ...row }) .onConflict((oc) => oc.column('id').doUpdateSet(row)) .execute() }}