Merge pull request #51 from Tebrihk/auto_reclaim

Auto-Reclaim Worker

Author: elizabetheonoja-art

.env.example

@@ -0,0 +1,7 @@
+# Algorand Network Configuration
+ALGOD_TOKEN=
+ALGOD_SERVER=https://testnet-api.algonode.cloud
+ALGOD_PORT=443
+
+# Owner Account (for executing reclaim transactions)
+OWNER_MNEMONIC=

index.js

@@ -1,22 +1,41 @@
 const express = require('express');
 const cors = require('cors');
+const AutoReclaimWorker = require('./services/autoReclaimWorker');
+
 const app = express();
 const port = 3000;
 
 app.use(cors());
 app.use(express.json());
 
 app.get('/', (req, res) => {
-  res.json({ 
-    project: 'LeaseFlow Protocol', 
+  res.json({
+    project: 'LeaseFlow Protocol',
     status: 'Active',
     contract_id: 'CAEGD57WVTVQSYWYB23AISBW334QO7WNA5XQ56S45GH6BP3D2AVHKUG4'
   });
 });
 
+app.get('/status', (req, res) => {
+  res.json({
+    auto_reclaim_worker: 'Active',
+    schedule: 'Every 10 minutes',
+    last_check: new Date().toISOString()
+  });
+});
+
 if (require.main === module) {
-  app.listen(port, () => {
-    console.log(`LeaseFlow Backend listening at http://localhost:${port}`);
+  const autoReclaimWorker = new AutoReclaimWorker();
+
+  autoReclaimWorker.initialize().then(() => {
+    autoReclaimWorker.start();
+    app.listen(port, () => {
+      console.log(`LeaseFlow Backend listening at http://localhost:${port}`);
+      console.log('Auto-Reclaim Worker started');
+    });
+  }).catch(error => {
+    console.error('Failed to initialize Auto-Reclaim Worker:', error);
+    process.exit(1);
   });
 }
 

package-lock.json

@@ -8,12 +8,14 @@
     "test": "jest"
   },
   "dependencies": {
+    "algosdk": "^2.0.0",
     "cors": "^2.8.6",
     "dotenv": "^17.3.1",
-    "express": "^5.2.1"
+    "express": "^5.2.1",
+    "node-cron": "^3.0.3"
   },
   "devDependencies": {
     "jest": "^30.3.0",
     "supertest": "^7.2.2"
   }
-}
+}