Added a keepers cloud func responsible for triggering expiration, fin…

…alization and withdraw process. Added supportive api endpoints for getting all vouchers and checking for voucher payments

.firebaserc

@@ -0,0 +1,5 @@
+{
+  "projects": {
+    "default": "boson-protocol-prototype-test"
+  }
+}

.gitignore

@@ -4,4 +4,6 @@
 package-lock.json
 .DS_Store
 yarn.lock
-/tests
+/tests
+
+.idea

firebase.json

@@ -0,0 +1,7 @@
+{
+  "functions": {
+    "predeploy": [
+      "npm --prefix \"$RESOURCE_DIR\" run lint"
+    ]
+  }
+}

src/api/controllers/payment-controller.js

@@ -6,7 +6,7 @@ class UserController {
 
     static async getPaymentActors(req, res, next) {
         const objectId = req.params.voucherID
-        
+
 
         let actors = {
             buyer: 0,
@@ -32,7 +32,7 @@ class UserController {
 
         } catch (error) {
             console.error(error)
-            return next(new APIError(400, `Get payment actors for voucher id: ${userVoucher._tokenIdVoucher} could not be completed.`))
+            return next(new APIError(400, `Get payment actors for voucher id: ${ userVoucher._tokenIdVoucher } could not be completed.`))
         }
 
         res.status(200).send({ actors });
@@ -51,12 +51,20 @@ class UserController {
 
         } catch (error) {
             console.error(error)
-            return next(new APIError(400, `Create payment operation for voucher id: ${events[0]._tokenIdVoucher} could not be completed.`))
+            return next(new APIError(400, `Create payment operation for voucher id: ${ events[0]._tokenIdVoucher } could not be completed.`))
         }
 
         res.status(200).send({ updated: true });
     }
 
+    static async getPaymentsByVoucherID(req, res, next) {
+        const tokenIdVoucher = req.params.tokenIdVoucher;
+
+        const payments = await mongooseService.getPaymentsByVoucherID(tokenIdVoucher);
+
+        res.status(200).send({ payments })
+    }
+
 }
 
-module.exports = UserController;
+module.exports = UserController;

src/api/controllers/user-vouchers-controller.js

@@ -6,11 +6,11 @@ const voucherUtils = require('../../utils/voucherUtils')
 const statuses = require('../../utils/userVoucherStatus');
 
 class UserVoucherController {
-    
+
     static async getMyVouchers(req, res, next) {
         const voucherData = []
         const address = res.locals.address;
-        
+
         const userVouchersDocuments = await mongooseService.getMyVouchers(address)
 
         const promises = []
@@ -38,7 +38,7 @@ class UserVoucherController {
 
     static async getVoucherDetails(req, res, next) {
         const myVoucherID = req.params.voucherID
-        
+
         const myVoucherDocument = await mongooseService.getMyVoucherByID(myVoucherID)
         const voucherDetailsDocument = await mongooseService.getVoucher(myVoucherDocument.voucherID)
 
@@ -73,12 +73,12 @@ class UserVoucherController {
         }
 
         res.status(200).send({ voucher })
-    } 
+    }
 
     static async updateMyVoucher(req, res, next) {
         const userVoucherID = res.locals.userVoucher.id;
         const status = req.body.status
-        
+
         try {
             const myVoucherDocument = await mongooseService.updateMyVoucherStatus(userVoucherID, status)
         } catch (error) {
@@ -103,6 +103,12 @@ class UserVoucherController {
         res.status(200).send({ updated: true })
     }
 
+    static async getAllVouchers(req, res, next) {
+        const vouchersDocuments = await mongooseService.getAllVouchers();
+
+        res.status(200).send({ vouchersDocuments })
+    }
+
 }
 
-module.exports = UserVoucherController;
+module.exports = UserVoucherController;

src/api/middlewares/authentication.js

@@ -8,7 +8,7 @@ class Authentication {
 
         const authHeader = req.headers['authorization']
         const token = authHeader && authHeader.split(' ')[1]
-        
+
         if (token == null) {
             return next(new APIError(401, 'Unauthorized.'))
         }
@@ -19,7 +19,7 @@ class Authentication {
         } catch (error) {
             return next(new APIError(403, 'Forbidden.'))
         }
-        
+
         next();
     }
 
@@ -38,7 +38,7 @@ class Authentication {
         //         return next(new APIError(403, 'Forbidden.'))
         //     }
 
-            res.locals.events = req.body;
+        res.locals.events = req.body;
 
         // } catch (error) {
         //     console.log(error);
@@ -50,4 +50,4 @@ class Authentication {
 
 }
 
-module.exports = Authentication;
+module.exports = Authentication;

src/api/routes/payments-route.js

@@ -6,9 +6,12 @@ class UserVoucherController {
 
     static route(expressApp) {
         let router = expressApp.Router();
+        router.get('/check-payment/:tokenIdVoucher',
+            ErrorHandlers.globalErrorHandler(authenticationMiddleware.authenticateGCLOUDService),
+            ErrorHandlers.globalErrorHandler(paymentsController.getPaymentsByVoucherID));
 
         router.get('/:voucherID',
-            ErrorHandlers.globalErrorHandler(authenticationMiddleware.authenticateToken), 
+            ErrorHandlers.globalErrorHandler(authenticationMiddleware.authenticateToken),
             ErrorHandlers.globalErrorHandler(paymentsController.getPaymentActors));
 
         router.post('/create-payment',
@@ -20,4 +23,4 @@ class UserVoucherController {
     }
 }
 
-module.exports = UserVoucherController;
+module.exports = UserVoucherController;

src/api/routes/user-vouchers-route.js

@@ -20,6 +20,10 @@ class UserVoucherController {
             ErrorHandlers.globalErrorHandler(authenticationMiddleware.authenticateToken),
             ErrorHandlers.globalErrorHandler(userVoucherController.getBuyersByVoucherID));
 
+        router.get('/all',
+            ErrorHandlers.globalErrorHandler(authenticationMiddleware.authenticateGCLOUDService),
+            ErrorHandlers.globalErrorHandler(userVoucherController.getAllVouchers));
+
         router.patch('/update',
             ErrorHandlers.globalErrorHandler(authenticationMiddleware.authenticateToken),
             ErrorHandlers.globalErrorHandler(userValidator.ValidateVoucherHolder),

src/database/Payment/payment.js

@@ -10,7 +10,7 @@ class PaymentService {
             _payee: metadata._payee,
             _payment: metadata._payment,
             txHash: metadata.txHash
-        }) 
+        })
 
         await payment.save();
     }
@@ -19,7 +19,7 @@ class PaymentService {
         return await Payment
             .where('_tokenIdVoucher').equals(_tokenIdVoucher)
     }
-  
+
 }
 
-module.exports = PaymentService
+module.exports = PaymentService

src/database/UserVoucher/userVoucher.js

@@ -1,5 +1,6 @@
 const UserVoucher = require('../models/UserVoucher')
 const status = require('../../utils/userVoucherStatus')
+
 class UserVoucherService {
     static async createUserVoucher(metadata, voucherID) {
         return await UserVoucher.findOneAndUpdate(
@@ -61,6 +62,10 @@ class UserVoucherService {
             { useFindAndModify: false, new: true, upsert: true, }
         )
     }
+
+    static async getAllVouchers() {
+        return UserVoucher.find({});
+    }
 }
 
-module.exports = UserVoucherService;
+module.exports = UserVoucherService;

src/database/index.js

@@ -29,7 +29,8 @@ const MongooseService = {
     findAllUsersByVoucherID: UserVoucher.findAllUsersByVoucherID,
     finalizeVoucher: UserVoucher.finalizeVoucher,
     createPayment: Payment.createPayment,
-    getPaymentsByVoucherID: Payment.getPaymentsByVoucherID
+    getPaymentsByVoucherID: Payment.getPaymentsByVoucherID,
+    getAllVouchers: UserVoucher.getAllVouchers
 }
 
-module.exports = MongooseService;
+module.exports = MongooseService;