diff --git a/src/parsers/vulcanize/index.ts b/src/parsers/vulcanize/index.ts
index 48d7eb3..a32979c 100644
--- a/src/parsers/vulcanize/index.ts
+++ b/src/parsers/vulcanize/index.ts
@@ -1,21 +1,30 @@
 import StorageAdapter from "../../storage-adapter";
 var kik = require('kikstart-graphql-client');
 
-const query = `subscription SubscriptionEvents {
-    listen(topic: "events") {
-      relatedNode {
-        ... on ContractId1EventId1 {
-          eventId
-          mhKey
-          dataUploader
-          dataCid
-          dataConfig
-          id
-          headerId
+const query = `
+  subscription SubscriptionEvents {
+    onEvent {
+      block {
+        hash
+        number
+      }
+      tx {
+        hash
+        from
+        to
+      }
+      event {
+        __typename
+        ... on StorageRequestEvent {
+          uploader
+          cid
+          config
+          fileCost
         }
       }
     }
-  }`
+  }
+`
   
 const client = new kik.GraphQLClient({
   uri: 'https://lighthouse.vdb.to/graphql',
@@ -44,16 +53,17 @@ class Vulcanize {
     .subscribe({
       next: res => {
         console.log(JSON.stringify(res.data));
-        console.log('cid:', res.data.listen.relatedNode.dataCid);
-        console.log('config:', res.data.listen.relatedNode.dataConfig);
-        console.log('address:', res.data.listen.relatedNode.dataUploader);
-        let cid = res.data.listen.relatedNode.dataCid;
-        // let config = JSON.parse(res.data.listen.relatedNode.dataConfig); // parse the config stringified object
-        let configString = res.data.listen.relatedNode.dataConfig;
+        console.log('cid:', res.data.onEvent.event.cid);
+        console.log('config:', res.data.onEvent.event.config);
+        console.log('address:', res.data.onEvent.event.uploader);
+        console.log('fileCost:', res.data.onEvent.event.fileCost);
+        const cid = res.data.onEvent.event.cid;
+        const configString = res.data.onEvent.event.config;
+        const address = res.data.onEvent.event.uploader;
+        const fileCost = res.data.onEvent.event.fileCost;
+        
         let config = JSON.parse(this.modifyConfig(configString));
-        let address = '0x' + res.data.listen.relatedNode.dataUploader;
         const jobId = this.storageAdapter.store(address, cid, config);
-        console.log('cid:', res.data.listen.relatedNode.dataCid); //, '& jobId:', jobId)
       },
       error: error => console.error(error),
       complete: () => console.log('done'),