owner-handles.js
1.43 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
const TABLE = 'vk_owner_handles'
/** 主人 id 的格式：小写字母、数字、下划线、连字符，2–32 位，字母或数字开头。与 DB CHECK 一致。 */
export const HANDLE_PATTERN = /^[a-z0-9][a-z0-9_-]{1,31}$/
/**
* 主人的 id（handle）。Agent 的全名是「名字@主人 id」，如 小火子@yibo。
* @param {{ db: import('knex').Knex }} deps
*/
export function createOwnerHandles({ db }) {
if (typeof db !== 'function') throw new Error('createOwnerHandles: db is required')
/**
* @param {object} _ctx
* @param {{ handle: string }} input
* @returns {Promise<boolean>}
*/
async function isTaken(_ctx, { handle }) {
return (await db(TABLE).where({ handle }).first('user_id')) !== undefined
}
/**
* 注册时在同一事务里登记；handle 被占用由 UNIQUE 裁决（调用方应先用 isTaken 给出友好提示）。
* @param {object} _ctx
* @param {import('knex').Knex} trx
* @param {{ user_id: string, handle: string }} input
*/
async function assign(_ctx, trx, { user_id, handle }) {
await trx(TABLE).insert({ user_id, handle, created_at: new Date() })
}
/**
* @param {object} _ctx
* @param {{ user_id: string }} input
* @returns {Promise<string|null>}
*/
async function get(_ctx, { user_id }) {
const row = await db(TABLE).where({ user_id }).first('handle')
return row === undefined ? null : row.handle
}
return { isTaken, assign, get }
}