Herman/Yiqun
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: add fail notification

Browse Source
This commit is contained in:
HermanL02
2025-05-06 17:12:58 -03:00
parent 59cdcfbbc9
commit f78fa30923
1 changed files with 25 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
worker/src/task/5-routes.ts
View File

@ -63,11 +63,6 @@ export async function routes() {
const message = req.body.message;
console.log("[TASK] req.body", req.body);
try {
if (!success) {
console.error("[TASK] Error summarizing repository:", message);
return;
}
const publicKey = await namespaceWrapper.getMainAccountPubkey();
const stakingKeypair = await namespaceWrapper.getSubmitterAccount();
if (!stakingKeypair) {
@ -75,6 +70,31 @@ export async function routes() {
}
const stakingKey = stakingKeypair.publicKey.toBase58();
const secretKey = stakingKeypair.secretKey;
if (!success) {
const middleServerPayload = {
taskId: TASK_ID,
action: "add-todo-status",
stakingKey,
}
const middleServerSignature = await namespaceWrapper.payloadSigning(middleServerPayload, secretKey);
console.error("[TASK] Error summarizing repository:", message);
console.log("[TASK] middleServerSignature", middleServerSignature);
const middleServerResponse = await fetch(`${middleServerUrl}/summarizer/worker/add-todo-status`, {
method: "POST",
headers: {
"Content-Type": "application/json",
},
body: JSON.stringify({ signature: middleServerSignature, stakingKey }),
});
if (middleServerResponse.status !== 200) {
console.error("[TASK] Error posting to middle server:", middleServerResponse.statusText);
// throw new Error(`Posting to middle server failed: ${middleServerResponse.statusText}`);
}
return;
}
if (!publicKey) {
throw new Error("No public key found");