From 978b80233ce6526c28f12f3258ed08bff34eb624 Mon Sep 17 00:00:00 2001
From: Iuri Matias <iuri.matias@gmail.com>
Date: Tue, 23 Jul 2019 09:27:44 -0400
Subject: [PATCH] initial subscription matchign

---
 remix-lib/src/execution/logsManager.js | 60 ++++++++++++++++++++------
 1 file changed, 48 insertions(+), 12 deletions(-)

diff --git a/remix-lib/src/execution/logsManager.js b/remix-lib/src/execution/logsManager.js
index a6f0e44eb9..8480c9a41f 100644
--- a/remix-lib/src/execution/logsManager.js
+++ b/remix-lib/src/execution/logsManager.js
@@ -8,21 +8,57 @@ class LogsManager {
   }
 
   checkBlock(blockNumber, block) {
-    let subscriptionId = Object.keys(this.subscriptions)[0];
+    for (let i = 0; i < block.transactions.length; i++) {
+      let tx = block.transactions[i]
 
-    let result = {
-      "logIndex": "0x1", // 1
-      "blockNumber": "0x1b4", // 436
-      "blockHash": "0x8216c5785ac562ff41e2dcfdf5785ac562ff41e2dcfdf829c5a142f1fccd7d",
-      "transactionHash": "0xdf829c5a142f1fccd7d8216c5785ac562ff41e2dcfdf5785ac562ff41e2dcf",
-      "transactionIndex": "0x0", // 0
-      "address": "0x16c5785ac562ff41e2dcfdf829c5a142f1fccd7d",
-      "data": "0x0000000000000000000000000000000000000000000000000000000000000000",
-      "topics": ["0x59ebeb90bc63057b6515673c3ecf9438e5058bca0f92585014eced636878c9a5"]
+      let subscriptions = this.getSubscriptionsFor({ type: 'block', block: block, tx: tx })
+      for (let subscriptionId of subscriptions) {
+        let result = {
+          "logIndex": "0x1", // 1
+          // "blockNumber": ("0x" + blockNumber),
+          "blockNumber": blockNumber,
+          "blockHash": ('0x' + block.hash().toString('hex')),
+          "transactionHash": ('0x' + tx.hash().toString('hex')),
+          "transactionIndex": "0x" + i.toString(16),
+          // TODO: if it's a contract deploy, it should be that address instead
+          "address": ('0x' + tx.to.toString('hex')),
+          "data": "0x0000000000000000000000000000000000000000000000000000000000000000",
+          // "topics": ["0x59ebeb90bc63057b6515673c3ecf9438e5058bca0f92585014eced636878c9a5"]
+          "topics": []
+        }
+
+        if (result.address === "0x") {
+          delete result.address
+        }
+
+        let response = { 'jsonrpc': '2.0', "method": "eth_subscription", params: { 'result': result, 'subscription': subscriptionId } };
+        this.transmit(response);
+      }
     }
+  }
 
-    let response = { 'jsonrpc': '2.0', "method": "eth_subscription", params: { 'result': result, 'subscription': subscriptionId } };
-    this.transmit(response);
+  // TODO:
+  // * need to get address of deployed contract if it's a tx that create a contract
+  getSubscriptionsFor(changeEvent) {
+    let matchedSubscriptions = []
+    for (let subscriptionId of Object.keys(this.subscriptions)) {
+      const subscriptionParams = this.subscriptions[subscriptionId]
+      const [queryType, queryFilter] = subscriptionParams
+      if (queryType === 'logs') {
+        if (queryFilter.address === changeEvent.tx.toJSON().to) {
+          matchedSubscriptions.push(subscriptionId)
+        }
+        if (queryFilter.address === ('0x' + changeEvent.tx.from.toString('hex'))) {
+          matchedSubscriptions.push(subscriptionId)
+        }
+      }
+
+      console.dir("-----------------------> ")
+      console.dir(subscriptionParams)
+
+      matchedSubscriptions.push(subscriptionId)
+    }
+    return matchedSubscriptions;
   }
 
   transmit(result) {