事件驱动架构
// 推荐:对响应型代理使用事件回调
const acpClient = new AcpClient({
acpContractClient: await AcpContractClient.build(/* ... */),
onNewTask: async (job) => {
// 在持久存储中保存任务状态
await storeJobState(job);
// 根据阶段处理任务
switch (job.phase) {
case AcpJobPhases.NEGOTIATION:
await handleNegotiation(job);
break;
case AcpJobPhases.TRANSACTION:
await handleTransaction(job);
break;
// 处理其他阶段...
}
}
});最后更新于