a

lib/index.js

@@ -354,7 +354,8 @@ class BankClient {
                 const itemsList = items.split(',').filter((x) => x.trim() !== '');
                 for (const itemId of itemsList) {
                     const processed = agentConfig.processed || [];
-                    if (processed.includes(itemId)) {
+                    const failed = agentConfig.failed || [];
+                    if (processed.includes(itemId) || failed.includes(itemId)) {
                         continue;
                     }
                     try {
@@ -366,6 +367,9 @@ class BankClient {
                     }
                     catch (e) {
                         console.error('error processing item', itemId, e);
+                        failed.push(itemId);
+                        agentConfig.failed = failed;
+                        yield storage.set('config', agentConfig);
                     }
                 }
             });

src/index.ts

@@ -351,7 +351,8 @@ export class BankClient {
 
       for (const itemId of itemsList) {
         const processed = agentConfig.processed || [];
-        if (processed.includes(itemId)) {
+        const failed = agentConfig.failed || [];
+        if (processed.includes(itemId) || failed.includes(itemId)) {
           continue;
         }
         try {
@@ -362,6 +363,9 @@ export class BankClient {
           await storage.set('config', agentConfig);
         } catch (e) {
           console.error('error processing item', itemId, e);
+          failed.push(itemId);
+          agentConfig.failed = failed;
+          await storage.set('config', agentConfig);
         }
       }
     }