style: apply prettier formatting
This commit is contained in:
@@ -22,9 +22,15 @@ export const SENDER_ALLOWLIST_PATH = path.join(
|
|||||||
'nanoclaw',
|
'nanoclaw',
|
||||||
'sender-allowlist.json',
|
'sender-allowlist.json',
|
||||||
);
|
);
|
||||||
export const STORE_DIR = path.resolve(process.env.NANOCLAW_STORE_DIR || path.join(PROJECT_ROOT, 'store'));
|
export const STORE_DIR = path.resolve(
|
||||||
export const GROUPS_DIR = path.resolve(process.env.NANOCLAW_GROUPS_DIR || path.join(PROJECT_ROOT, 'groups'));
|
process.env.NANOCLAW_STORE_DIR || path.join(PROJECT_ROOT, 'store'),
|
||||||
export const DATA_DIR = path.resolve(process.env.NANOCLAW_DATA_DIR || path.join(PROJECT_ROOT, 'data'));
|
);
|
||||||
|
export const GROUPS_DIR = path.resolve(
|
||||||
|
process.env.NANOCLAW_GROUPS_DIR || path.join(PROJECT_ROOT, 'groups'),
|
||||||
|
);
|
||||||
|
export const DATA_DIR = path.resolve(
|
||||||
|
process.env.NANOCLAW_DATA_DIR || path.join(PROJECT_ROOT, 'data'),
|
||||||
|
);
|
||||||
|
|
||||||
export const CONTAINER_TIMEOUT = parseInt(
|
export const CONTAINER_TIMEOUT = parseInt(
|
||||||
process.env.CONTAINER_TIMEOUT || '1800000',
|
process.env.CONTAINER_TIMEOUT || '1800000',
|
||||||
|
|||||||
52
src/index.ts
52
src/index.ts
@@ -244,40 +244,30 @@ async function processGroupMessages(chatJid: string): Promise<boolean> {
|
|||||||
|
|
||||||
await channel.setTyping?.(chatJid, true);
|
await channel.setTyping?.(chatJid, true);
|
||||||
|
|
||||||
const output = await runAgent(
|
const output = await runAgent(group, prompt, chatJid, async (result) => {
|
||||||
group,
|
if (result.result) {
|
||||||
prompt,
|
const raw =
|
||||||
chatJid,
|
typeof result.result === 'string'
|
||||||
async (result) => {
|
? result.result
|
||||||
if (result.result) {
|
: JSON.stringify(result.result);
|
||||||
const raw =
|
const text = raw.replace(/<internal>[\s\S]*?<\/internal>/g, '').trim();
|
||||||
typeof result.result === 'string'
|
logger.info({ group: group.name }, `Agent output: ${raw.slice(0, 200)}`);
|
||||||
? result.result
|
if (text) {
|
||||||
: JSON.stringify(result.result);
|
await channel.sendMessage(chatJid, text);
|
||||||
const text = raw
|
outputSentToUser = true;
|
||||||
.replace(/<internal>[\s\S]*?<\/internal>/g, '')
|
|
||||||
.trim();
|
|
||||||
logger.info(
|
|
||||||
{ group: group.name },
|
|
||||||
`Agent output: ${raw.slice(0, 200)}`,
|
|
||||||
);
|
|
||||||
if (text) {
|
|
||||||
await channel.sendMessage(chatJid, text);
|
|
||||||
outputSentToUser = true;
|
|
||||||
}
|
|
||||||
await channel.setTyping?.(chatJid, false);
|
|
||||||
resetIdleTimer();
|
|
||||||
}
|
}
|
||||||
|
await channel.setTyping?.(chatJid, false);
|
||||||
|
resetIdleTimer();
|
||||||
|
}
|
||||||
|
|
||||||
if (result.status === 'success') {
|
if (result.status === 'success') {
|
||||||
queue.notifyIdle(chatJid);
|
queue.notifyIdle(chatJid);
|
||||||
}
|
}
|
||||||
|
|
||||||
if (result.status === 'error') {
|
if (result.status === 'error') {
|
||||||
hadError = true;
|
hadError = true;
|
||||||
}
|
}
|
||||||
},
|
});
|
||||||
);
|
|
||||||
|
|
||||||
await channel.setTyping?.(chatJid, false);
|
await channel.setTyping?.(chatJid, false);
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user