Merge pull request #183 from iExecBlockchainComputing/feature/dapp/add-checkEmailPreviousCheck-and-add-Callbackresult

Feature/dapp/add check email previous check and add callbackresult

Author: SeddikBellamine

.drone.yml

@@ -560,7 +560,7 @@ steps:
       - npm run check-format
 
   - name: lint
-    image: node:18.19
+    image: node:14-alpine3.11
     commands:
       - cd dapp
       - npm run lint
@@ -576,6 +576,8 @@ steps:
         from_secret: mj_sender
       MAILGUN_APIKEY:
         from_secret: mailgun_apikey
+      WEB3MAIL_WHITELISTED_APPS:
+        from_secret: web3mail_whitelisted_apps
     commands:
       - cd dapp
       - npm run ctest
@@ -644,6 +646,8 @@ steps:
         from_secret: mj_sender
       MAILGUN_APIKEY:
         from_secret: mailgun_apikey
+      WEB3MAIL_WHITELISTED_APPS:
+        from_secret: web3mail_whitelisted_apps
     commands:
       - cd dapp
       - npm run ctest
@@ -714,6 +718,8 @@ steps:
         from_secret: mj_sender
       MAILGUN_APIKEY:
         from_secret: mailgun_apikey
+      WEB3MAIL_WHITELISTED_APPS:
+        from_secret: web3mail_whitelisted_apps
     commands:
       - cd dapp
       - npm run ctest

dapp/.eslintrc.json

@@ -11,6 +11,13 @@
   "env": {
     "jest": true
   },
+  "settings": {
+    "import/resolver": {
+      "node": {
+        "extensions": [".js", ".json"]
+      }
+    }
+  },
   "overrides": [
     {
       "files": ["./tests/**/*.js"],

dapp/package-lock.json

@@ -21,6 +21,8 @@
   "license": "ISC",
   "dependencies": {
     "@iexec/dataprotector-deserializer": "^0.1.0",
+    "graphql": "^16.11.0",
+    "graphql-request": "^3.7.0",
     "joi": "^17.9.2",
     "jszip": "^3.10.1",
     "node-fetch": "^2.7.0",

dapp/package.json

@@ -0,0 +1,51 @@
+const { request, gql } = require('graphql-request');
+
+async function checkEmailPreviousValidation({ datasetAddress, dappAddresses }) {
+  const pocoSubgraphUrl =
+    'https://thegraph.bellecour.iex.ec/subgraphs/name/bellecour/poco-v5';
+
+  const query = gql`
+    query checkSuccessfulTaskQuery($apps: [String!], $dataset: String!) {
+      tasks(
+        where: {
+          resultsCallback_not: "0x"
+          status: "COMPLETED"
+          deal_: { dataset: $dataset, app_in: $apps }
+        }
+      ) {
+        resultsCallback
+      }
+    }
+  `;
+
+  const variables = {
+    apps: dappAddresses,
+    dataset: datasetAddress.toLowerCase(),
+  };
+
+  try {
+    const data = await request(pocoSubgraphUrl, query, variables);
+    const tasks = data?.tasks || [];
+
+    return tasks.some((task) => {
+      const callback = task.resultsCallback?.toLowerCase();
+      return (
+        callback &&
+        callback.startsWith('0x') &&
+        callback.endsWith(
+          '0000000000000000000000000000000000000000000000000000000000000001'
+        )
+      );
+    });
+  } catch (error) {
+    console.error(
+      'GraphQL error:',
+      error.response?.errors || error.message || error
+    );
+    return false;
+  }
+}
+
+module.exports = {
+  checkEmailPreviousValidation,
+};