Merge beta updates

src/ainize.ts

@@ -49,6 +49,7 @@ export default class Ainize {
   async loginWithSigner() {
     const signer = new AinWalletSigner;
     this.ain.setSigner(signer);
+    await this.handler.connect();
     console.log('login success! address: ', await this.ain.getAddress());
   }
 

src/middlewares/middleware.ts

@@ -21,19 +21,28 @@ export default class Middleware {
    */
   blockchainTriggerFilter = async (req: Request, res: Response, next: NextFunction) => {
     //check if request is from blockchain trigger
-    const { triggerPath, triggerValue, txHash } = extractTriggerDataFromRequest(req);
-    if(!triggerPath || !triggerValue || !txHash) {
-      res.send("Not from blockchain");
+    try {
+      const { triggerPath, triggerValue, txHash } = extractTriggerDataFromRequest(req);
+      if(!triggerPath || !triggerValue || !txHash) {
+        throw new Error("Not from blockchain");
+      }
+      // NOTE(yoojin): Validation will changed. Temp comment out.
+      // const result = await this.ain.getValue(triggerPath);
+
+      // If request is first reque st, set cache 
+      if (this.cache.get(txHash) && this.cache.get(txHash) !== "error") {
+        res.send("Duplicated");
+        return;
+      }
+      this.cache.set(txHash, "in_progress", 500);
+      // NOTE(yoojin): Validation will changed. Temp comment out.
+      // _.isEqual(result, triggerValue) ? next(): res.send("Not from blockchain");
+      next();
+    } catch (e) {
+      console.log("Filtering Error ", e)
+      res.send(e);
       return;
     }
-    const result = await this.ain.getValue(triggerPath);
-    // if request is first reque st, set cache 
-    if (this.cache.get(txHash) && this.cache.get(txHash) !== "error") {
-      res.send("Duplicated");
-      return;
-    }
-    this.cache.set(txHash, "in_progress", 500);
-    _.isEqual(result, triggerValue) ? next(): res.send("Not from blockchain");
   }
   /**
    *  DEPRECATED