diff --git a/sql/PARSE_ABI_EVENTS_UDF.sql b/sql/PARSE_ABI_EVENTS_UDF.sql
new file mode 100644
index 0000000..ce5ff4b
--- /dev/null
+++ b/sql/PARSE_ABI_EVENTS_UDF.sql
@@ -0,0 +1,82 @@
+CREATE OR REPLACE FUNCTION `blocktrekker.udfs.PARSE_ABI_EVENTS`(abi STRING, dune_name STRING) RETURNS ARRAY<STRUCT<name STRING, anonymous BOOL, hash_id STRING, inputs STRING, types STRING>> LANGUAGE js
+OPTIONS (library=["gs://blockchain-etl-bigquery/ethers.js"]) AS R"""
+abi = JSON.parse(abi);
+  res = [];
+  const typeMap = {
+    "uint32[]": "INT64",
+    "uint16[]": "INT64",
+    "uint8[]": "INT64",
+    "uint64[]": "INT64",
+    "uint128[]": "INT64",
+    "uint256[]": "BIGNUMERIC",
+    "bool[]": "BOOL",
+    "address[]": "STRING",
+    "string[]": "STRING",
+    "bytes[]": "BYTES",
+    "bytes4": "BYTES",
+    "bytes32": "BYTES",
+    "uint32": "INT64",
+    "uint16": "INT64",
+    "uint8": "INT64",
+    "uint64": "INT64",
+    "unit80": "INT64",
+    "uint112": "INT64",
+    "uint128": "INT64",
+    "uint168": "BIGNUMERIC",
+    "uint256": "BIGNUMERIC",
+    "BIGNUMERIC": "BIGNUMERIC",
+    "bool": "BOOL",
+    "address": "STRING",
+    "STRING": "STRING",
+    "string": "STRING",
+    "bytes": "BYTES"
+  };
+
+    const nameMap = {
+    "from": "from_address",
+    "to": "to_address",
+    "limit": "_limit",
+    "all": "_all"
+  };
+  
+  abi.forEach(function(x){
+    tuple = [];
+    tuple['name'] = dune_name + "_evt_" + x.name;
+    tuple['orig_name'] = x.name;
+    tuple['anonymous'] = x.anonymous;
+
+    if (x.type != 'event') {
+      return;
+    }
+    
+    argtypes = [];
+    argpairs = [];
+    let count = 1;
+    x.inputs.forEach(function(y){
+      pair = {};
+      argtypes.push(y.type);
+      if (y.name in nameMap) {
+        pair.name = nameMap[y.name];
+      } else if (y.name == "") {
+        pair.name = `input_${count}`;
+      } else {
+        pair.name = y.name ? y.name : `input_${count}`;
+      }
+      if (y.type in typeMap) {
+        pair.type = typeMap[y.type];
+      } else {
+        if (y.type.slice(0, 4).toLowerCase() === "uint") {
+          pair.type = "BIGNUMERIC";
+        } else {
+          pair.type = "STRING";
+        }
+      }
+      argpairs.push(JSON.stringify(pair));
+      count = count + 1;
+    });
+    tuple['inputs'] = argpairs.join(",");
+    tuple['hash_id'] = ethers.utils.keccak256(ethers.utils.toUtf8Bytes(tuple['orig_name'] + '(' + argtypes.join(',') + ')'));
+    res.push(tuple);
+  });
+  return res;
+""";
diff --git a/sql/PARSE_ABI_FUNCTIONS_UDF.sql b/sql/PARSE_ABI_FUNCTIONS_UDF.sql
new file mode 100644
index 0000000..7277d40
--- /dev/null
+++ b/sql/PARSE_ABI_FUNCTIONS_UDF.sql
@@ -0,0 +1,106 @@
+CREATE OR REPLACE FUNCTION `blocktrekker.udfs.PARSE_ABI_FUNCTIONS`(abi STRING, dune_name STRING) RETURNS ARRAY<STRUCT<name STRING, hash_id STRING, constant BOOL, payable BOOL, inputs STRING, outputs STRING>> LANGUAGE js
+OPTIONS (library=["gs://blockchain-etl-bigquery/ethers.js"]) AS R"""
+abi = JSON.parse(abi);
+  res = [];
+  const typeMap = {
+    "uint32[]": "INT64",
+    "uint16[]": "INT64",
+    "uint8[]": "INT64",
+    "uint64[]": "INT64",
+    "uint128[]": "INT64",
+    "uint256[]": "BIGNUMERIC",
+    "bool[]": "BOOL",
+    "address[]": "STRING",
+    "string[]": "STRING",
+    "bytes[]": "BYTES",
+    "bytes4": "BYTES",
+    "bytes32": "BYTES",
+    "uint32": "INT64",
+    "uint16": "INT64",
+    "uint8": "INT64",
+    "uint64": "INT64",
+    "unit80": "INT64",
+    "uint112": "INT64",
+    "uint128": "INT64",
+    "uint168": "BIGNUMERIC",
+    "uint256": "BIGNUMERIC",
+    "BIGNUMERIC": "BIGNUMERIC",
+    "bool": "BOOL",
+    "address": "STRING",
+    "STRING": "STRING",
+    "string": "STRING",
+    "bytes": "BYTES"
+  };
+
+
+  const nameMap = {
+    "from": "from_address",
+    "to": "to_address",
+    "limit": "_limit",
+    "all": "_all"
+  };
+  
+  abi.forEach(function(x){
+    tuple = [];
+    tuple['constant'] = x.constant;
+    tuple['payable'] = x.payable;
+    if (x.type != 'function') {
+      return;
+    }
+
+    argtypes = [];
+    argpairs = [];
+    let count = 1;
+    x.inputs.forEach(function(y){
+      pair = {};
+      argtypes.push(y.type);
+      if (y.name in nameMap) {
+        pair.name = nameMap[y.name];
+      } else if (y.name == "") {
+        pair.name = `input_${count}`;
+      } else {
+        pair.name = y.name ? y.name : `input_${count}`;
+      }
+      if (y.type in typeMap) {
+        pair.type = typeMap[y.type];
+      } else {
+        if (y.type.slice(0, 4).toLowerCase() === "uint") {
+          pair.type = "BIGNUMERIC";
+        } else {
+          pair.type = "STRING";
+        }
+      }
+      argpairs.push(JSON.stringify(pair));
+      count = count + 1;
+    });
+
+    outpairs = [];
+    if (x.outputs) {
+      let count = 1;
+      x.outputs.forEach(function(y){
+        pair = {};
+        if (y.name in nameMap) {
+          pair.name = nameMap[y.name];
+        } else if (y.name == "") {
+          pair.name = `output_${count}`
+        } else {
+          pair.name = y.name ? y.name : `output_${count}`;
+        }
+        if (y.type in typeMap) {
+          pair.type = typeMap[y.type];
+        } else if (y.type.slice(0, 4).toLowerCase() === "uint") {
+          pair.type = "BIGNUMERIC";
+        } else {
+          pair.type = "STRING";
+        }
+          outpairs.push(JSON.stringify(pair));
+      });
+    }
+    tuple['inputs'] = argpairs.join(",");
+    tuple['outputs'] = outpairs.join(",");
+    tuple['hash_id'] = ethers.utils.keccak256(ethers.utils.toUtf8Bytes(x.name + '(' + argtypes.join(',') + ')')).substr(0,10);
+    tuple['name'] = dune_name + "_call_" + x.name;
+    res.push(tuple);
+  });
+  return res;
+""";