add: base

.gitignore

@@ -0,0 +1,2 @@
+.DS_Store
+.env

app.py

@@ -0,0 +1,7 @@
+import gradio as gr
+
+def greet(name):
+    return "Hello " + name + "!!"
+
+iface = gr.Interface(fn=greet, inputs="text", outputs="text")
+iface.launch()

codebase-polywrap.ipynb

@@ -0,0 +1,271 @@
+{
+ "cells": [
+  {
+   "cell_type": "code",
+   "execution_count": 1,
+   "metadata": {},
+   "outputs": [],
+   "source": [
+    "import os\n",
+    "import getpass\n",
+    "\n",
+    "from langchain.embeddings.openai import OpenAIEmbeddings\n",
+    "from langchain.vectorstores import DeepLake\n",
+    "\n",
+    "import dotenv\n",
+    "dotenv.load_dotenv()\n",
+    "\n",
+    "os.environ['ACTIVELOOP_TOKEN'] = \"eyJhbGciOiJIUzUxMiIsImlhdCI6MTY4NDAxNjM2NCwiZXhwIjoxNjg1NDg1MTM5fQ.eyJpZCI6InJpaHAifQ.1rzZgsiqjiMz2UidXm1M-JBTMwJbNnah00PeQgGG-Op__xZl1uDpEKhaBxw98bXD9c2MGNIBreMT_pLxZXQSJA\" # replace with your API key from app.activeloop.ai\n",
+    "username = \"rihp\" # replace with your username from app.activeloop.ai\n",
+    "projectname = \"polywrap5\" # replace with your project name from app.activeloop.ai\n"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 2,
+   "metadata": {},
+   "outputs": [],
+   "source": [
+    "embeddings = OpenAIEmbeddings(disallowed_special=())\n"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 3,
+   "metadata": {},
+   "outputs": [
+    {
+     "name": "stdout",
+     "output_type": "stream",
+     "text": [
+      "Cloning into 'ens'...\n",
+      "remote: Enumerating objects: 152, done.\u001b[K\n",
+      "remote: Counting objects: 100% (152/152), done.\u001b[K\n",
+      "remote: Compressing objects: 100% (104/104), done.\u001b[K\n",
+      "remote: Total 152 (delta 66), reused 119 (delta 40), pack-reused 0\u001b[K\n",
+      "Receiving objects: 100% (152/152), 132.52 KiB | 1.56 MiB/s, done.\n",
+      "Resolving deltas: 100% (66/66), done.\n"
+     ]
+    }
+   ],
+   "source": [
+    "# !git clone https://github.com/makerdao/dai.js/ # replace any repository of your choice \n",
+    "# !git clone https://github.com/polywrap/ethereum/\n",
+    "# !git clone https://github.com/polywrap/safe-contracts-wrapper\n",
+    "# !git clone https://github.com/polywrap/uniswap/\n",
+    "# !git clone https://github.com/cbrzn/account-abstraction-wrapper/\n",
+    "# !git clone https://github.com/krisbitney/gelato-relay-polywrap\n",
+    "#!git clone https://github.com/ProjectOpenSea/opensea-js\n",
+    "#!git clone https://github.com/polywrap/ens.git"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 4,
+   "metadata": {},
+   "outputs": [],
+   "source": [
+    "import os\n",
+    "from langchain.document_loaders import TextLoader\n",
+    "\n",
+    "root_dir = './polywrapgpt' # Specify where your data is stored\n",
+    "docs = []\n",
+    "for dirpath, dirnames, filenames in os.walk(root_dir):\n",
+    "    for file in filenames:\n",
+    "        try: \n",
+    "            loader = TextLoader(os.path.join(dirpath, file), encoding='utf-8')\n",
+    "            docs.extend(loader.load_and_split())\n",
+    "        except Exception as e: \n",
+    "            pass"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 5,
+   "metadata": {},
+   "outputs": [],
+   "source": [
+    "%%capture\n",
+    "\n",
+    "from langchain.text_splitter import CharacterTextSplitter\n",
+    "\n",
+    "text_splitter = CharacterTextSplitter(chunk_size=1000, chunk_overlap=0)\n",
+    "texts = text_splitter.split_documents(docs)"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 6,
+   "metadata": {},
+   "outputs": [],
+   "source": [
+    "%%capture\n",
+    "db = DeepLake(dataset_path=f\"hub://{username}/{projectname}\", embedding_function=embeddings, public=True) #dataset would be publicly available\n",
+    "db.add_documents(texts)"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": null,
+   "metadata": {},
+   "outputs": [
+    {
+     "name": "stderr",
+     "output_type": "stream",
+     "text": [
+      " \r"
+     ]
+    },
+    {
+     "ename": "KeyboardInterrupt",
+     "evalue": "",
+     "output_type": "error",
+     "traceback": [
+      "\u001b[0;31m---------------------------------------------------------------------------\u001b[0m",
+      "\u001b[0;31mKeyboardInterrupt\u001b[0m                         Traceback (most recent call last)",
+      "Cell \u001b[0;32mIn[7], line 1\u001b[0m\n\u001b[0;32m----> 1\u001b[0m db \u001b[39m=\u001b[39m DeepLake(dataset_path\u001b[39m=\u001b[39;49m\u001b[39mf\u001b[39;49m\u001b[39m\"\u001b[39;49m\u001b[39mhub://\u001b[39;49m\u001b[39m{\u001b[39;49;00musername\u001b[39m}\u001b[39;49;00m\u001b[39m/\u001b[39;49m\u001b[39m{\u001b[39;49;00mprojectname\u001b[39m}\u001b[39;49;00m\u001b[39m\"\u001b[39;49m, read_only\u001b[39m=\u001b[39;49m\u001b[39mTrue\u001b[39;49;00m, embedding_function\u001b[39m=\u001b[39;49membeddings)\n",
+      "File \u001b[0;32m/Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/site-packages/langchain/vectorstores/deeplake.py:127\u001b[0m, in \u001b[0;36mDeepLake.__init__\u001b[0;34m(self, dataset_path, token, embedding_function, read_only, ingestion_batch_size, num_workers, verbose, **kwargs)\u001b[0m\n\u001b[1;32m    121\u001b[0m creds_args \u001b[39m=\u001b[39m {\u001b[39m\"\u001b[39m\u001b[39mcreds\u001b[39m\u001b[39m\"\u001b[39m: kwargs[\u001b[39m\"\u001b[39m\u001b[39mcreds\u001b[39m\u001b[39m\"\u001b[39m]} \u001b[39mif\u001b[39;00m \u001b[39m\"\u001b[39m\u001b[39mcreds\u001b[39m\u001b[39m\"\u001b[39m \u001b[39min\u001b[39;00m kwargs \u001b[39melse\u001b[39;00m {}\n\u001b[1;32m    123\u001b[0m \u001b[39mif\u001b[39;00m (\n\u001b[1;32m    124\u001b[0m     deeplake\u001b[39m.\u001b[39mexists(dataset_path, token\u001b[39m=\u001b[39mtoken, \u001b[39m*\u001b[39m\u001b[39m*\u001b[39mcreds_args)\n\u001b[1;32m    125\u001b[0m     \u001b[39mand\u001b[39;00m \u001b[39m\"\u001b[39m\u001b[39moverwrite\u001b[39m\u001b[39m\"\u001b[39m \u001b[39mnot\u001b[39;00m \u001b[39min\u001b[39;00m kwargs\n\u001b[1;32m    126\u001b[0m ):\n\u001b[0;32m--> 127\u001b[0m     \u001b[39mself\u001b[39m\u001b[39m.\u001b[39mds \u001b[39m=\u001b[39m deeplake\u001b[39m.\u001b[39;49mload(\n\u001b[1;32m    128\u001b[0m         dataset_path,\n\u001b[1;32m    129\u001b[0m         token\u001b[39m=\u001b[39;49mtoken,\n\u001b[1;32m    130\u001b[0m         read_only\u001b[39m=\u001b[39;49mread_only,\n\u001b[1;32m    131\u001b[0m         verbose\u001b[39m=\u001b[39;49m\u001b[39mself\u001b[39;49m\u001b[39m.\u001b[39;49mverbose,\n\u001b[1;32m    132\u001b[0m         \u001b[39m*\u001b[39;49m\u001b[39m*\u001b[39;49mkwargs,\n\u001b[1;32m    133\u001b[0m     )\n\u001b[1;32m    134\u001b[0m     logger\u001b[39m.\u001b[39minfo(\u001b[39mf\u001b[39m\u001b[39m\"\u001b[39m\u001b[39mLoading deeplake \u001b[39m\u001b[39m{\u001b[39;00mdataset_path\u001b[39m}\u001b[39;00m\u001b[39m from storage.\u001b[39m\u001b[39m\"\u001b[39m)\n\u001b[1;32m    135\u001b[0m     \u001b[39mif\u001b[39;00m \u001b[39mself\u001b[39m\u001b[39m.\u001b[39mverbose:\n",
+      "File \u001b[0;32m/Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/site-packages/deeplake/util/spinner.py:139\u001b[0m, in \u001b[0;36mspinner.<locals>.inner\u001b[0;34m(*args, **kwargs)\u001b[0m\n\u001b[1;32m    136\u001b[0m     spinner \u001b[39m=\u001b[39m Spinner()\n\u001b[1;32m    138\u001b[0m     \u001b[39mwith\u001b[39;00m run_spinner(spinner):\n\u001b[0;32m--> 139\u001b[0m         \u001b[39mreturn\u001b[39;00m func(\u001b[39m*\u001b[39;49margs, \u001b[39m*\u001b[39;49m\u001b[39m*\u001b[39;49mkwargs)\n\u001b[1;32m    140\u001b[0m \u001b[39melse\u001b[39;00m:\n\u001b[1;32m    141\u001b[0m     \u001b[39mreturn\u001b[39;00m func(\u001b[39m*\u001b[39margs, \u001b[39m*\u001b[39m\u001b[39m*\u001b[39mkwargs)\n",
+      "File \u001b[0;32m/Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/site-packages/deeplake/api/dataset.py:584\u001b[0m, in \u001b[0;36mdataset.load\u001b[0;34m(path, read_only, memory_cache_size, local_cache_size, creds, token, org_id, verbose, access_method, reset)\u001b[0m\n\u001b[1;32m    570\u001b[0m     dataset_kwargs\u001b[39m.\u001b[39mupdate(\n\u001b[1;32m    571\u001b[0m         {\n\u001b[1;32m    572\u001b[0m             \u001b[39m\"\u001b[39m\u001b[39maccess_method\u001b[39m\u001b[39m\"\u001b[39m: access_method,\n\u001b[0;32m   (...)\u001b[0m\n\u001b[1;32m    580\u001b[0m         }\n\u001b[1;32m    581\u001b[0m     )\n\u001b[1;32m    583\u001b[0m \u001b[39mtry\u001b[39;00m:\n\u001b[0;32m--> 584\u001b[0m     \u001b[39mreturn\u001b[39;00m dataset\u001b[39m.\u001b[39;49m_load(dataset_kwargs, access_method)\n\u001b[1;32m    585\u001b[0m \u001b[39mexcept\u001b[39;00m (AgreementError, CheckoutError, LockedException) \u001b[39mas\u001b[39;00m e:\n\u001b[1;32m    586\u001b[0m     \u001b[39mraise\u001b[39;00m e \u001b[39mfrom\u001b[39;00m \u001b[39mNone\u001b[39;00m\n",
+      "File \u001b[0;32m/Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/site-packages/deeplake/api/dataset.py:653\u001b[0m, in \u001b[0;36mdataset._load\u001b[0;34m(dataset_kwargs, access_method, create)\u001b[0m\n\u001b[1;32m    650\u001b[0m \u001b[39m@staticmethod\u001b[39m\n\u001b[1;32m    651\u001b[0m \u001b[39mdef\u001b[39;00m \u001b[39m_load\u001b[39m(dataset_kwargs, access_method\u001b[39m=\u001b[39m\u001b[39mNone\u001b[39;00m, create\u001b[39m=\u001b[39m\u001b[39mFalse\u001b[39;00m):\n\u001b[1;32m    652\u001b[0m     \u001b[39mif\u001b[39;00m access_method \u001b[39min\u001b[39;00m (\u001b[39m\"\u001b[39m\u001b[39mstream\u001b[39m\u001b[39m\"\u001b[39m, \u001b[39mNone\u001b[39;00m):\n\u001b[0;32m--> 653\u001b[0m         ret \u001b[39m=\u001b[39m dataset_factory(\u001b[39m*\u001b[39;49m\u001b[39m*\u001b[39;49mdataset_kwargs)\n\u001b[1;32m    654\u001b[0m         \u001b[39mif\u001b[39;00m create:\n\u001b[1;32m    655\u001b[0m             dataset_created(ret)\n",
+      "File \u001b[0;32m/Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/site-packages/deeplake/core/dataset/__init__.py:23\u001b[0m, in \u001b[0;36mdataset_factory\u001b[0;34m(path, *args, **kwargs)\u001b[0m\n\u001b[1;32m     20\u001b[0m     clz \u001b[39m=\u001b[39m Dataset\n\u001b[1;32m     22\u001b[0m \u001b[39mif\u001b[39;00m clz \u001b[39min\u001b[39;00m {Dataset, DeepLakeCloudDataset}:\n\u001b[0;32m---> 23\u001b[0m     ds \u001b[39m=\u001b[39m clz(path\u001b[39m=\u001b[39;49mpath, \u001b[39m*\u001b[39;49margs, \u001b[39m*\u001b[39;49m\u001b[39m*\u001b[39;49mkwargs)\n\u001b[1;32m     24\u001b[0m     \u001b[39mif\u001b[39;00m ds\u001b[39m.\u001b[39mroot\u001b[39m.\u001b[39minfo\u001b[39m.\u001b[39mget(\u001b[39m\"\u001b[39m\u001b[39mvirtual-datasource\u001b[39m\u001b[39m\"\u001b[39m, \u001b[39mFalse\u001b[39;00m):\n\u001b[1;32m     25\u001b[0m         ds \u001b[39m=\u001b[39m ds\u001b[39m.\u001b[39m_get_view()\n",
+      "File \u001b[0;32m/Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/site-packages/deeplake/core/dataset/dataset.py:241\u001b[0m, in \u001b[0;36mDataset.__init__\u001b[0;34m(self, storage, index, group_index, read_only, public, token, org_id, verbose, version_state, path, address, is_iteration, link_creds, pad_tensors, lock, enabled_tensors, view_base, libdeeplake_dataset, **kwargs)\u001b[0m\n\u001b[1;32m    238\u001b[0m dct\u001b[39m.\u001b[39mupdate(d)\n\u001b[1;32m    240\u001b[0m \u001b[39mtry\u001b[39;00m:\n\u001b[0;32m--> 241\u001b[0m     \u001b[39mself\u001b[39;49m\u001b[39m.\u001b[39;49m_set_derived_attributes(address\u001b[39m=\u001b[39;49maddress)\n\u001b[1;32m    242\u001b[0m \u001b[39mexcept\u001b[39;00m LockedException:\n\u001b[1;32m    243\u001b[0m     \u001b[39mraise\u001b[39;00m LockedException(\n\u001b[1;32m    244\u001b[0m         \u001b[39m\"\u001b[39m\u001b[39mThis dataset cannot be open for writing as it is locked by another machine. Try loading the dataset with `read_only=True`.\u001b[39m\u001b[39m\"\u001b[39m\n\u001b[1;32m    245\u001b[0m     )\n",
+      "File \u001b[0;32m/Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/site-packages/deeplake/core/dataset/dataset.py:2199\u001b[0m, in \u001b[0;36mDataset._set_derived_attributes\u001b[0;34m(self, verbose, address)\u001b[0m\n\u001b[1;32m   2195\u001b[0m \u001b[39mself\u001b[39m\u001b[39m.\u001b[39m_load_link_creds()\n\u001b[1;32m   2196\u001b[0m \u001b[39mself\u001b[39m\u001b[39m.\u001b[39m_set_read_only(\n\u001b[1;32m   2197\u001b[0m     \u001b[39mself\u001b[39m\u001b[39m.\u001b[39m_read_only, err\u001b[39m=\u001b[39m\u001b[39mself\u001b[39m\u001b[39m.\u001b[39m_read_only_error\n\u001b[1;32m   2198\u001b[0m )  \u001b[39m# TODO: weird fix for dataset unpickling\u001b[39;00m\n\u001b[0;32m-> 2199\u001b[0m \u001b[39mself\u001b[39;49m\u001b[39m.\u001b[39;49m_populate_meta(verbose)  \u001b[39m# TODO: use the same scheme as `load_info`\u001b[39;00m\n\u001b[1;32m   2200\u001b[0m \u001b[39mif\u001b[39;00m \u001b[39mself\u001b[39m\u001b[39m.\u001b[39mindex\u001b[39m.\u001b[39mis_trivial():\n\u001b[1;32m   2201\u001b[0m     \u001b[39mself\u001b[39m\u001b[39m.\u001b[39mindex \u001b[39m=\u001b[39m Index\u001b[39m.\u001b[39mfrom_json(\u001b[39mself\u001b[39m\u001b[39m.\u001b[39mmeta\u001b[39m.\u001b[39mdefault_index)\n",
+      "File \u001b[0;32m/Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/site-packages/deeplake/core/dataset/dataset.py:1742\u001b[0m, in \u001b[0;36mDataset._populate_meta\u001b[0;34m(self, verbose)\u001b[0m\n\u001b[1;32m   1740\u001b[0m \u001b[39m\u001b[39m\u001b[39m\"\"\"Populates the meta information for the dataset.\"\"\"\u001b[39;00m\n\u001b[1;32m   1741\u001b[0m \u001b[39mif\u001b[39;00m dataset_exists(\u001b[39mself\u001b[39m\u001b[39m.\u001b[39mstorage):\n\u001b[0;32m-> 1742\u001b[0m     load_meta(\u001b[39mself\u001b[39;49m)\n\u001b[1;32m   1744\u001b[0m \u001b[39melif\u001b[39;00m \u001b[39mnot\u001b[39;00m \u001b[39mself\u001b[39m\u001b[39m.\u001b[39mstorage\u001b[39m.\u001b[39mempty():\n\u001b[1;32m   1745\u001b[0m     \u001b[39m# dataset does not exist, but the path was not empty\u001b[39;00m\n\u001b[1;32m   1746\u001b[0m     \u001b[39mraise\u001b[39;00m PathNotEmptyException\n",
+      "File \u001b[0;32m/Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/site-packages/deeplake/util/version_control.py:828\u001b[0m, in \u001b[0;36mload_meta\u001b[0;34m(dataset)\u001b[0m\n\u001b[1;32m    826\u001b[0m \u001b[39mif\u001b[39;00m tensor_key\u001b[39m.\u001b[39mstartswith(\u001b[39m\"\u001b[39m\u001b[39m__temp\u001b[39m\u001b[39m\"\u001b[39m):\n\u001b[1;32m    827\u001b[0m     dataset\u001b[39m.\u001b[39m_temp_tensors\u001b[39m.\u001b[39mappend(tensor_key)\n\u001b[0;32m--> 828\u001b[0m _tensors[tensor_key] \u001b[39m=\u001b[39m Tensor(tensor_key, dataset)\n",
+      "File \u001b[0;32m/Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/site-packages/deeplake/core/tensor.py:238\u001b[0m, in \u001b[0;36mTensor.__init__\u001b[0;34m(self, key, dataset, index, is_iteration, chunk_engine)\u001b[0m\n\u001b[1;32m    235\u001b[0m \u001b[39mself\u001b[39m\u001b[39m.\u001b[39mis_iteration \u001b[39m=\u001b[39m is_iteration\n\u001b[1;32m    236\u001b[0m commit_id \u001b[39m=\u001b[39m \u001b[39mself\u001b[39m\u001b[39m.\u001b[39mversion_state[\u001b[39m\"\u001b[39m\u001b[39mcommit_id\u001b[39m\u001b[39m\"\u001b[39m]\n\u001b[0;32m--> 238\u001b[0m \u001b[39mif\u001b[39;00m \u001b[39mnot\u001b[39;00m \u001b[39mself\u001b[39m\u001b[39m.\u001b[39mis_iteration \u001b[39mand\u001b[39;00m \u001b[39mnot\u001b[39;00m tensor_exists(\n\u001b[1;32m    239\u001b[0m     \u001b[39mself\u001b[39;49m\u001b[39m.\u001b[39;49mkey, \u001b[39mself\u001b[39;49m\u001b[39m.\u001b[39;49mstorage, commit_id\n\u001b[1;32m    240\u001b[0m ):\n\u001b[1;32m    241\u001b[0m     \u001b[39mraise\u001b[39;00m TensorDoesNotExistError(\u001b[39mself\u001b[39m\u001b[39m.\u001b[39mkey)\n\u001b[1;32m    243\u001b[0m meta_key \u001b[39m=\u001b[39m get_tensor_meta_key(\u001b[39mself\u001b[39m\u001b[39m.\u001b[39mkey, commit_id)\n",
+      "File \u001b[0;32m/Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/site-packages/deeplake/util/keys.py:197\u001b[0m, in \u001b[0;36mtensor_exists\u001b[0;34m(key, storage, commit_id)\u001b[0m\n\u001b[1;32m    195\u001b[0m \u001b[39mdef\u001b[39;00m \u001b[39mtensor_exists\u001b[39m(key: \u001b[39mstr\u001b[39m, storage, commit_id: \u001b[39mstr\u001b[39m) \u001b[39m-\u001b[39m\u001b[39m>\u001b[39m \u001b[39mbool\u001b[39m:\n\u001b[1;32m    196\u001b[0m     \u001b[39mtry\u001b[39;00m:\n\u001b[0;32m--> 197\u001b[0m         storage[get_tensor_meta_key(key, commit_id)]\n\u001b[1;32m    198\u001b[0m         \u001b[39mreturn\u001b[39;00m \u001b[39mTrue\u001b[39;00m\n\u001b[1;32m    199\u001b[0m     \u001b[39mexcept\u001b[39;00m \u001b[39mKeyError\u001b[39;00m:\n",
+      "File \u001b[0;32m/Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/site-packages/deeplake/core/storage/lru_cache.py:211\u001b[0m, in \u001b[0;36mLRUCache.__getitem__\u001b[0;34m(self, path)\u001b[0m\n\u001b[1;32m    208\u001b[0m \u001b[39melse\u001b[39;00m:\n\u001b[1;32m    209\u001b[0m     \u001b[39mif\u001b[39;00m \u001b[39mself\u001b[39m\u001b[39m.\u001b[39mnext_storage \u001b[39mis\u001b[39;00m \u001b[39mnot\u001b[39;00m \u001b[39mNone\u001b[39;00m:\n\u001b[1;32m    210\u001b[0m         \u001b[39m# fetch from storage, may throw KeyError\u001b[39;00m\n\u001b[0;32m--> 211\u001b[0m         result \u001b[39m=\u001b[39m \u001b[39mself\u001b[39;49m\u001b[39m.\u001b[39;49mnext_storage[path]\n\u001b[1;32m    213\u001b[0m         \u001b[39mif\u001b[39;00m _get_nbytes(result) \u001b[39m<\u001b[39m\u001b[39m=\u001b[39m \u001b[39mself\u001b[39m\u001b[39m.\u001b[39mcache_size:  \u001b[39m# insert in cache if it fits\u001b[39;00m\n\u001b[1;32m    214\u001b[0m             \u001b[39mself\u001b[39m\u001b[39m.\u001b[39m_insert_in_cache(path, result)\n",
+      "File \u001b[0;32m/Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/site-packages/deeplake/core/storage/s3.py:215\u001b[0m, in \u001b[0;36mS3Provider.__getitem__\u001b[0;34m(self, path)\u001b[0m\n\u001b[1;32m    202\u001b[0m \u001b[39mdef\u001b[39;00m \u001b[39m__getitem__\u001b[39m(\u001b[39mself\u001b[39m, path):\n\u001b[1;32m    203\u001b[0m \u001b[39m    \u001b[39m\u001b[39m\"\"\"Gets the object present at the path.\u001b[39;00m\n\u001b[1;32m    204\u001b[0m \n\u001b[1;32m    205\u001b[0m \u001b[39m    Args:\u001b[39;00m\n\u001b[0;32m   (...)\u001b[0m\n\u001b[1;32m    213\u001b[0m \u001b[39m        S3GetError: Any other error other than KeyError while retrieving the object.\u001b[39;00m\n\u001b[1;32m    214\u001b[0m \u001b[39m    \"\"\"\u001b[39;00m\n\u001b[0;32m--> 215\u001b[0m     \u001b[39mreturn\u001b[39;00m \u001b[39mself\u001b[39;49m\u001b[39m.\u001b[39;49mget_bytes(path)\n",
+      "File \u001b[0;32m/Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/site-packages/deeplake/core/storage/s3.py:258\u001b[0m, in \u001b[0;36mS3Provider.get_bytes\u001b[0;34m(self, path, start_byte, end_byte)\u001b[0m\n\u001b[1;32m    256\u001b[0m path \u001b[39m=\u001b[39m \u001b[39m\"\u001b[39m\u001b[39m\"\u001b[39m\u001b[39m.\u001b[39mjoin((\u001b[39mself\u001b[39m\u001b[39m.\u001b[39mpath, path))\n\u001b[1;32m    257\u001b[0m \u001b[39mtry\u001b[39;00m:\n\u001b[0;32m--> 258\u001b[0m     \u001b[39mreturn\u001b[39;00m \u001b[39mself\u001b[39;49m\u001b[39m.\u001b[39;49m_get_bytes(path, start_byte, end_byte)\n\u001b[1;32m    259\u001b[0m \u001b[39mexcept\u001b[39;00m botocore\u001b[39m.\u001b[39mexceptions\u001b[39m.\u001b[39mClientError \u001b[39mas\u001b[39;00m err:\n\u001b[1;32m    260\u001b[0m     \u001b[39mif\u001b[39;00m err\u001b[39m.\u001b[39mresponse[\u001b[39m\"\u001b[39m\u001b[39mError\u001b[39m\u001b[39m\"\u001b[39m][\u001b[39m\"\u001b[39m\u001b[39mCode\u001b[39m\u001b[39m\"\u001b[39m] \u001b[39m==\u001b[39m \u001b[39m\"\u001b[39m\u001b[39mNoSuchKey\u001b[39m\u001b[39m\"\u001b[39m:\n",
+      "File \u001b[0;32m/Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/site-packages/deeplake/core/storage/s3.py:230\u001b[0m, in \u001b[0;36mS3Provider._get_bytes\u001b[0;34m(self, path, start_byte, end_byte)\u001b[0m\n\u001b[1;32m    228\u001b[0m \u001b[39melse\u001b[39;00m:\n\u001b[1;32m    229\u001b[0m     \u001b[39mrange\u001b[39m \u001b[39m=\u001b[39m \u001b[39m\"\u001b[39m\u001b[39m\"\u001b[39m\n\u001b[0;32m--> 230\u001b[0m resp \u001b[39m=\u001b[39m \u001b[39mself\u001b[39;49m\u001b[39m.\u001b[39;49mclient\u001b[39m.\u001b[39;49mget_object(Bucket\u001b[39m=\u001b[39;49m\u001b[39mself\u001b[39;49m\u001b[39m.\u001b[39;49mbucket, Key\u001b[39m=\u001b[39;49mpath, Range\u001b[39m=\u001b[39;49m\u001b[39mrange\u001b[39;49m)\n\u001b[1;32m    231\u001b[0m \u001b[39mreturn\u001b[39;00m resp[\u001b[39m\"\u001b[39m\u001b[39mBody\u001b[39m\u001b[39m\"\u001b[39m]\u001b[39m.\u001b[39mread()\n",
+      "File \u001b[0;32m/Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/site-packages/botocore/client.py:530\u001b[0m, in \u001b[0;36mClientCreator._create_api_method.<locals>._api_call\u001b[0;34m(self, *args, **kwargs)\u001b[0m\n\u001b[1;32m    526\u001b[0m     \u001b[39mraise\u001b[39;00m \u001b[39mTypeError\u001b[39;00m(\n\u001b[1;32m    527\u001b[0m         \u001b[39mf\u001b[39m\u001b[39m\"\u001b[39m\u001b[39m{\u001b[39;00mpy_operation_name\u001b[39m}\u001b[39;00m\u001b[39m() only accepts keyword arguments.\u001b[39m\u001b[39m\"\u001b[39m\n\u001b[1;32m    528\u001b[0m     )\n\u001b[1;32m    529\u001b[0m \u001b[39m# The \"self\" in this scope is referring to the BaseClient.\u001b[39;00m\n\u001b[0;32m--> 530\u001b[0m \u001b[39mreturn\u001b[39;00m \u001b[39mself\u001b[39;49m\u001b[39m.\u001b[39;49m_make_api_call(operation_name, kwargs)\n",
+      "File \u001b[0;32m/Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/site-packages/botocore/client.py:943\u001b[0m, in \u001b[0;36mBaseClient._make_api_call\u001b[0;34m(self, operation_name, api_params)\u001b[0m\n\u001b[1;32m    941\u001b[0m \u001b[39melse\u001b[39;00m:\n\u001b[1;32m    942\u001b[0m     apply_request_checksum(request_dict)\n\u001b[0;32m--> 943\u001b[0m     http, parsed_response \u001b[39m=\u001b[39m \u001b[39mself\u001b[39;49m\u001b[39m.\u001b[39;49m_make_request(\n\u001b[1;32m    944\u001b[0m         operation_model, request_dict, request_context\n\u001b[1;32m    945\u001b[0m     )\n\u001b[1;32m    947\u001b[0m \u001b[39mself\u001b[39m\u001b[39m.\u001b[39mmeta\u001b[39m.\u001b[39mevents\u001b[39m.\u001b[39memit(\n\u001b[1;32m    948\u001b[0m     \u001b[39m'\u001b[39m\u001b[39mafter-call.\u001b[39m\u001b[39m{service_id}\u001b[39;00m\u001b[39m.\u001b[39m\u001b[39m{operation_name}\u001b[39;00m\u001b[39m'\u001b[39m\u001b[39m.\u001b[39mformat(\n\u001b[1;32m    949\u001b[0m         service_id\u001b[39m=\u001b[39mservice_id, operation_name\u001b[39m=\u001b[39moperation_name\n\u001b[0;32m   (...)\u001b[0m\n\u001b[1;32m    954\u001b[0m     context\u001b[39m=\u001b[39mrequest_context,\n\u001b[1;32m    955\u001b[0m )\n\u001b[1;32m    957\u001b[0m \u001b[39mif\u001b[39;00m http\u001b[39m.\u001b[39mstatus_code \u001b[39m>\u001b[39m\u001b[39m=\u001b[39m \u001b[39m300\u001b[39m:\n",
+      "File \u001b[0;32m/Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/site-packages/botocore/client.py:966\u001b[0m, in \u001b[0;36mBaseClient._make_request\u001b[0;34m(self, operation_model, request_dict, request_context)\u001b[0m\n\u001b[1;32m    964\u001b[0m \u001b[39mdef\u001b[39;00m \u001b[39m_make_request\u001b[39m(\u001b[39mself\u001b[39m, operation_model, request_dict, request_context):\n\u001b[1;32m    965\u001b[0m     \u001b[39mtry\u001b[39;00m:\n\u001b[0;32m--> 966\u001b[0m         \u001b[39mreturn\u001b[39;00m \u001b[39mself\u001b[39;49m\u001b[39m.\u001b[39;49m_endpoint\u001b[39m.\u001b[39;49mmake_request(operation_model, request_dict)\n\u001b[1;32m    967\u001b[0m     \u001b[39mexcept\u001b[39;00m \u001b[39mException\u001b[39;00m \u001b[39mas\u001b[39;00m e:\n\u001b[1;32m    968\u001b[0m         \u001b[39mself\u001b[39m\u001b[39m.\u001b[39mmeta\u001b[39m.\u001b[39mevents\u001b[39m.\u001b[39memit(\n\u001b[1;32m    969\u001b[0m             \u001b[39m'\u001b[39m\u001b[39mafter-call-error.\u001b[39m\u001b[39m{service_id}\u001b[39;00m\u001b[39m.\u001b[39m\u001b[39m{operation_name}\u001b[39;00m\u001b[39m'\u001b[39m\u001b[39m.\u001b[39mformat(\n\u001b[1;32m    970\u001b[0m                 service_id\u001b[39m=\u001b[39m\u001b[39mself\u001b[39m\u001b[39m.\u001b[39m_service_model\u001b[39m.\u001b[39mservice_id\u001b[39m.\u001b[39mhyphenize(),\n\u001b[0;32m   (...)\u001b[0m\n\u001b[1;32m    974\u001b[0m             context\u001b[39m=\u001b[39mrequest_context,\n\u001b[1;32m    975\u001b[0m         )\n",
+      "File \u001b[0;32m/Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/site-packages/botocore/endpoint.py:119\u001b[0m, in \u001b[0;36mEndpoint.make_request\u001b[0;34m(self, operation_model, request_dict)\u001b[0m\n\u001b[1;32m    113\u001b[0m \u001b[39mdef\u001b[39;00m \u001b[39mmake_request\u001b[39m(\u001b[39mself\u001b[39m, operation_model, request_dict):\n\u001b[1;32m    114\u001b[0m     logger\u001b[39m.\u001b[39mdebug(\n\u001b[1;32m    115\u001b[0m         \u001b[39m\"\u001b[39m\u001b[39mMaking request for \u001b[39m\u001b[39m%s\u001b[39;00m\u001b[39m with params: \u001b[39m\u001b[39m%s\u001b[39;00m\u001b[39m\"\u001b[39m,\n\u001b[1;32m    116\u001b[0m         operation_model,\n\u001b[1;32m    117\u001b[0m         request_dict,\n\u001b[1;32m    118\u001b[0m     )\n\u001b[0;32m--> 119\u001b[0m     \u001b[39mreturn\u001b[39;00m \u001b[39mself\u001b[39;49m\u001b[39m.\u001b[39;49m_send_request(request_dict, operation_model)\n",
+      "File \u001b[0;32m/Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/site-packages/botocore/endpoint.py:199\u001b[0m, in \u001b[0;36mEndpoint._send_request\u001b[0;34m(self, request_dict, operation_model)\u001b[0m\n\u001b[1;32m    197\u001b[0m \u001b[39mself\u001b[39m\u001b[39m.\u001b[39m_update_retries_context(context, attempts)\n\u001b[1;32m    198\u001b[0m request \u001b[39m=\u001b[39m \u001b[39mself\u001b[39m\u001b[39m.\u001b[39mcreate_request(request_dict, operation_model)\n\u001b[0;32m--> 199\u001b[0m success_response, exception \u001b[39m=\u001b[39m \u001b[39mself\u001b[39;49m\u001b[39m.\u001b[39;49m_get_response(\n\u001b[1;32m    200\u001b[0m     request, operation_model, context\n\u001b[1;32m    201\u001b[0m )\n\u001b[1;32m    202\u001b[0m \u001b[39mwhile\u001b[39;00m \u001b[39mself\u001b[39m\u001b[39m.\u001b[39m_needs_retry(\n\u001b[1;32m    203\u001b[0m     attempts,\n\u001b[1;32m    204\u001b[0m     operation_model,\n\u001b[0;32m   (...)\u001b[0m\n\u001b[1;32m    207\u001b[0m     exception,\n\u001b[1;32m    208\u001b[0m ):\n\u001b[1;32m    209\u001b[0m     attempts \u001b[39m+\u001b[39m\u001b[39m=\u001b[39m \u001b[39m1\u001b[39m\n",
+      "File \u001b[0;32m/Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/site-packages/botocore/endpoint.py:241\u001b[0m, in \u001b[0;36mEndpoint._get_response\u001b[0;34m(self, request, operation_model, context)\u001b[0m\n\u001b[1;32m    235\u001b[0m \u001b[39mdef\u001b[39;00m \u001b[39m_get_response\u001b[39m(\u001b[39mself\u001b[39m, request, operation_model, context):\n\u001b[1;32m    236\u001b[0m     \u001b[39m# This will return a tuple of (success_response, exception)\u001b[39;00m\n\u001b[1;32m    237\u001b[0m     \u001b[39m# and success_response is itself a tuple of\u001b[39;00m\n\u001b[1;32m    238\u001b[0m     \u001b[39m# (http_response, parsed_dict).\u001b[39;00m\n\u001b[1;32m    239\u001b[0m     \u001b[39m# If an exception occurs then the success_response is None.\u001b[39;00m\n\u001b[1;32m    240\u001b[0m     \u001b[39m# If no exception occurs then exception is None.\u001b[39;00m\n\u001b[0;32m--> 241\u001b[0m     success_response, exception \u001b[39m=\u001b[39m \u001b[39mself\u001b[39;49m\u001b[39m.\u001b[39;49m_do_get_response(\n\u001b[1;32m    242\u001b[0m         request, operation_model, context\n\u001b[1;32m    243\u001b[0m     )\n\u001b[1;32m    244\u001b[0m     kwargs_to_emit \u001b[39m=\u001b[39m {\n\u001b[1;32m    245\u001b[0m         \u001b[39m'\u001b[39m\u001b[39mresponse_dict\u001b[39m\u001b[39m'\u001b[39m: \u001b[39mNone\u001b[39;00m,\n\u001b[1;32m    246\u001b[0m         \u001b[39m'\u001b[39m\u001b[39mparsed_response\u001b[39m\u001b[39m'\u001b[39m: \u001b[39mNone\u001b[39;00m,\n\u001b[1;32m    247\u001b[0m         \u001b[39m'\u001b[39m\u001b[39mcontext\u001b[39m\u001b[39m'\u001b[39m: context,\n\u001b[1;32m    248\u001b[0m         \u001b[39m'\u001b[39m\u001b[39mexception\u001b[39m\u001b[39m'\u001b[39m: exception,\n\u001b[1;32m    249\u001b[0m     }\n\u001b[1;32m    250\u001b[0m     \u001b[39mif\u001b[39;00m success_response \u001b[39mis\u001b[39;00m \u001b[39mnot\u001b[39;00m \u001b[39mNone\u001b[39;00m:\n",
+      "File \u001b[0;32m/Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/site-packages/botocore/endpoint.py:281\u001b[0m, in \u001b[0;36mEndpoint._do_get_response\u001b[0;34m(self, request, operation_model, context)\u001b[0m\n\u001b[1;32m    279\u001b[0m     http_response \u001b[39m=\u001b[39m first_non_none_response(responses)\n\u001b[1;32m    280\u001b[0m     \u001b[39mif\u001b[39;00m http_response \u001b[39mis\u001b[39;00m \u001b[39mNone\u001b[39;00m:\n\u001b[0;32m--> 281\u001b[0m         http_response \u001b[39m=\u001b[39m \u001b[39mself\u001b[39;49m\u001b[39m.\u001b[39;49m_send(request)\n\u001b[1;32m    282\u001b[0m \u001b[39mexcept\u001b[39;00m HTTPClientError \u001b[39mas\u001b[39;00m e:\n\u001b[1;32m    283\u001b[0m     \u001b[39mreturn\u001b[39;00m (\u001b[39mNone\u001b[39;00m, e)\n",
+      "File \u001b[0;32m/Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/site-packages/botocore/endpoint.py:377\u001b[0m, in \u001b[0;36mEndpoint._send\u001b[0;34m(self, request)\u001b[0m\n\u001b[1;32m    376\u001b[0m \u001b[39mdef\u001b[39;00m \u001b[39m_send\u001b[39m(\u001b[39mself\u001b[39m, request):\n\u001b[0;32m--> 377\u001b[0m     \u001b[39mreturn\u001b[39;00m \u001b[39mself\u001b[39;49m\u001b[39m.\u001b[39;49mhttp_session\u001b[39m.\u001b[39;49msend(request)\n",
+      "File \u001b[0;32m/Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/site-packages/botocore/httpsession.py:455\u001b[0m, in \u001b[0;36mURLLib3Session.send\u001b[0;34m(self, request)\u001b[0m\n\u001b[1;32m    452\u001b[0m     conn\u001b[39m.\u001b[39mproxy_headers[\u001b[39m'\u001b[39m\u001b[39mhost\u001b[39m\u001b[39m'\u001b[39m] \u001b[39m=\u001b[39m host\n\u001b[1;32m    454\u001b[0m request_target \u001b[39m=\u001b[39m \u001b[39mself\u001b[39m\u001b[39m.\u001b[39m_get_request_target(request\u001b[39m.\u001b[39murl, proxy_url)\n\u001b[0;32m--> 455\u001b[0m urllib_response \u001b[39m=\u001b[39m conn\u001b[39m.\u001b[39;49murlopen(\n\u001b[1;32m    456\u001b[0m     method\u001b[39m=\u001b[39;49mrequest\u001b[39m.\u001b[39;49mmethod,\n\u001b[1;32m    457\u001b[0m     url\u001b[39m=\u001b[39;49mrequest_target,\n\u001b[1;32m    458\u001b[0m     body\u001b[39m=\u001b[39;49mrequest\u001b[39m.\u001b[39;49mbody,\n\u001b[1;32m    459\u001b[0m     headers\u001b[39m=\u001b[39;49mrequest\u001b[39m.\u001b[39;49mheaders,\n\u001b[1;32m    460\u001b[0m     retries\u001b[39m=\u001b[39;49mRetry(\u001b[39mFalse\u001b[39;49;00m),\n\u001b[1;32m    461\u001b[0m     assert_same_host\u001b[39m=\u001b[39;49m\u001b[39mFalse\u001b[39;49;00m,\n\u001b[1;32m    462\u001b[0m     preload_content\u001b[39m=\u001b[39;49m\u001b[39mFalse\u001b[39;49;00m,\n\u001b[1;32m    463\u001b[0m     decode_content\u001b[39m=\u001b[39;49m\u001b[39mFalse\u001b[39;49;00m,\n\u001b[1;32m    464\u001b[0m     chunked\u001b[39m=\u001b[39;49m\u001b[39mself\u001b[39;49m\u001b[39m.\u001b[39;49m_chunked(request\u001b[39m.\u001b[39;49mheaders),\n\u001b[1;32m    465\u001b[0m )\n\u001b[1;32m    467\u001b[0m http_response \u001b[39m=\u001b[39m botocore\u001b[39m.\u001b[39mawsrequest\u001b[39m.\u001b[39mAWSResponse(\n\u001b[1;32m    468\u001b[0m     request\u001b[39m.\u001b[39murl,\n\u001b[1;32m    469\u001b[0m     urllib_response\u001b[39m.\u001b[39mstatus,\n\u001b[1;32m    470\u001b[0m     urllib_response\u001b[39m.\u001b[39mheaders,\n\u001b[1;32m    471\u001b[0m     urllib_response,\n\u001b[1;32m    472\u001b[0m )\n\u001b[1;32m    474\u001b[0m \u001b[39mif\u001b[39;00m \u001b[39mnot\u001b[39;00m request\u001b[39m.\u001b[39mstream_output:\n\u001b[1;32m    475\u001b[0m     \u001b[39m# Cause the raw stream to be exhausted immediately. We do it\u001b[39;00m\n\u001b[1;32m    476\u001b[0m     \u001b[39m# this way instead of using preload_content because\u001b[39;00m\n\u001b[1;32m    477\u001b[0m     \u001b[39m# preload_content will never buffer chunked responses\u001b[39;00m\n",
+      "File \u001b[0;32m/Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/site-packages/urllib3/connectionpool.py:703\u001b[0m, in \u001b[0;36mHTTPConnectionPool.urlopen\u001b[0;34m(self, method, url, body, headers, retries, redirect, assert_same_host, timeout, pool_timeout, release_conn, chunked, body_pos, **response_kw)\u001b[0m\n\u001b[1;32m    700\u001b[0m     \u001b[39mself\u001b[39m\u001b[39m.\u001b[39m_prepare_proxy(conn)\n\u001b[1;32m    702\u001b[0m \u001b[39m# Make the request on the httplib connection object.\u001b[39;00m\n\u001b[0;32m--> 703\u001b[0m httplib_response \u001b[39m=\u001b[39m \u001b[39mself\u001b[39;49m\u001b[39m.\u001b[39;49m_make_request(\n\u001b[1;32m    704\u001b[0m     conn,\n\u001b[1;32m    705\u001b[0m     method,\n\u001b[1;32m    706\u001b[0m     url,\n\u001b[1;32m    707\u001b[0m     timeout\u001b[39m=\u001b[39;49mtimeout_obj,\n\u001b[1;32m    708\u001b[0m     body\u001b[39m=\u001b[39;49mbody,\n\u001b[1;32m    709\u001b[0m     headers\u001b[39m=\u001b[39;49mheaders,\n\u001b[1;32m    710\u001b[0m     chunked\u001b[39m=\u001b[39;49mchunked,\n\u001b[1;32m    711\u001b[0m )\n\u001b[1;32m    713\u001b[0m \u001b[39m# If we're going to release the connection in ``finally:``, then\u001b[39;00m\n\u001b[1;32m    714\u001b[0m \u001b[39m# the response doesn't need to know about the connection. Otherwise\u001b[39;00m\n\u001b[1;32m    715\u001b[0m \u001b[39m# it will also try to release it and we'll have a double-release\u001b[39;00m\n\u001b[1;32m    716\u001b[0m \u001b[39m# mess.\u001b[39;00m\n\u001b[1;32m    717\u001b[0m response_conn \u001b[39m=\u001b[39m conn \u001b[39mif\u001b[39;00m \u001b[39mnot\u001b[39;00m release_conn \u001b[39melse\u001b[39;00m \u001b[39mNone\u001b[39;00m\n",
+      "File \u001b[0;32m/Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/site-packages/urllib3/connectionpool.py:449\u001b[0m, in \u001b[0;36mHTTPConnectionPool._make_request\u001b[0;34m(self, conn, method, url, timeout, chunked, **httplib_request_kw)\u001b[0m\n\u001b[1;32m    444\u001b[0m             httplib_response \u001b[39m=\u001b[39m conn\u001b[39m.\u001b[39mgetresponse()\n\u001b[1;32m    445\u001b[0m         \u001b[39mexcept\u001b[39;00m \u001b[39mBaseException\u001b[39;00m \u001b[39mas\u001b[39;00m e:\n\u001b[1;32m    446\u001b[0m             \u001b[39m# Remove the TypeError from the exception chain in\u001b[39;00m\n\u001b[1;32m    447\u001b[0m             \u001b[39m# Python 3 (including for exceptions like SystemExit).\u001b[39;00m\n\u001b[1;32m    448\u001b[0m             \u001b[39m# Otherwise it looks like a bug in the code.\u001b[39;00m\n\u001b[0;32m--> 449\u001b[0m             six\u001b[39m.\u001b[39;49mraise_from(e, \u001b[39mNone\u001b[39;49;00m)\n\u001b[1;32m    450\u001b[0m \u001b[39mexcept\u001b[39;00m (SocketTimeout, BaseSSLError, SocketError) \u001b[39mas\u001b[39;00m e:\n\u001b[1;32m    451\u001b[0m     \u001b[39mself\u001b[39m\u001b[39m.\u001b[39m_raise_timeout(err\u001b[39m=\u001b[39me, url\u001b[39m=\u001b[39murl, timeout_value\u001b[39m=\u001b[39mread_timeout)\n",
+      "File \u001b[0;32m<string>:3\u001b[0m, in \u001b[0;36mraise_from\u001b[0;34m(value, from_value)\u001b[0m\n",
+      "File \u001b[0;32m/Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/site-packages/urllib3/connectionpool.py:444\u001b[0m, in \u001b[0;36mHTTPConnectionPool._make_request\u001b[0;34m(self, conn, method, url, timeout, chunked, **httplib_request_kw)\u001b[0m\n\u001b[1;32m    441\u001b[0m \u001b[39mexcept\u001b[39;00m \u001b[39mTypeError\u001b[39;00m:\n\u001b[1;32m    442\u001b[0m     \u001b[39m# Python 3\u001b[39;00m\n\u001b[1;32m    443\u001b[0m     \u001b[39mtry\u001b[39;00m:\n\u001b[0;32m--> 444\u001b[0m         httplib_response \u001b[39m=\u001b[39m conn\u001b[39m.\u001b[39;49mgetresponse()\n\u001b[1;32m    445\u001b[0m     \u001b[39mexcept\u001b[39;00m \u001b[39mBaseException\u001b[39;00m \u001b[39mas\u001b[39;00m e:\n\u001b[1;32m    446\u001b[0m         \u001b[39m# Remove the TypeError from the exception chain in\u001b[39;00m\n\u001b[1;32m    447\u001b[0m         \u001b[39m# Python 3 (including for exceptions like SystemExit).\u001b[39;00m\n\u001b[1;32m    448\u001b[0m         \u001b[39m# Otherwise it looks like a bug in the code.\u001b[39;00m\n\u001b[1;32m    449\u001b[0m         six\u001b[39m.\u001b[39mraise_from(e, \u001b[39mNone\u001b[39;00m)\n",
+      "File \u001b[0;32m/Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/http/client.py:1375\u001b[0m, in \u001b[0;36mHTTPConnection.getresponse\u001b[0;34m(self)\u001b[0m\n\u001b[1;32m   1373\u001b[0m \u001b[39mtry\u001b[39;00m:\n\u001b[1;32m   1374\u001b[0m     \u001b[39mtry\u001b[39;00m:\n\u001b[0;32m-> 1375\u001b[0m         response\u001b[39m.\u001b[39;49mbegin()\n\u001b[1;32m   1376\u001b[0m     \u001b[39mexcept\u001b[39;00m \u001b[39mConnectionError\u001b[39;00m:\n\u001b[1;32m   1377\u001b[0m         \u001b[39mself\u001b[39m\u001b[39m.\u001b[39mclose()\n",
+      "File \u001b[0;32m/Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/http/client.py:318\u001b[0m, in \u001b[0;36mHTTPResponse.begin\u001b[0;34m(self)\u001b[0m\n\u001b[1;32m    316\u001b[0m \u001b[39m# read until we get a non-100 response\u001b[39;00m\n\u001b[1;32m    317\u001b[0m \u001b[39mwhile\u001b[39;00m \u001b[39mTrue\u001b[39;00m:\n\u001b[0;32m--> 318\u001b[0m     version, status, reason \u001b[39m=\u001b[39m \u001b[39mself\u001b[39;49m\u001b[39m.\u001b[39;49m_read_status()\n\u001b[1;32m    319\u001b[0m     \u001b[39mif\u001b[39;00m status \u001b[39m!=\u001b[39m CONTINUE:\n\u001b[1;32m    320\u001b[0m         \u001b[39mbreak\u001b[39;00m\n",
+      "File \u001b[0;32m/Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/http/client.py:279\u001b[0m, in \u001b[0;36mHTTPResponse._read_status\u001b[0;34m(self)\u001b[0m\n\u001b[1;32m    278\u001b[0m \u001b[39mdef\u001b[39;00m \u001b[39m_read_status\u001b[39m(\u001b[39mself\u001b[39m):\n\u001b[0;32m--> 279\u001b[0m     line \u001b[39m=\u001b[39m \u001b[39mstr\u001b[39m(\u001b[39mself\u001b[39m\u001b[39m.\u001b[39mfp\u001b[39m.\u001b[39mreadline(_MAXLINE \u001b[39m+\u001b[39m \u001b[39m1\u001b[39m), \u001b[39m\"\u001b[39m\u001b[39miso-8859-1\u001b[39m\u001b[39m\"\u001b[39m)\n\u001b[1;32m    280\u001b[0m     \u001b[39mif\u001b[39;00m \u001b[39mlen\u001b[39m(line) \u001b[39m>\u001b[39m _MAXLINE:\n\u001b[1;32m    281\u001b[0m         \u001b[39mraise\u001b[39;00m LineTooLong(\u001b[39m\"\u001b[39m\u001b[39mstatus line\u001b[39m\u001b[39m\"\u001b[39m)\n",
+      "File \u001b[0;32m/Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/socket.py:706\u001b[0m, in \u001b[0;36mSocketIO.readinto\u001b[0;34m(self, b)\u001b[0m\n\u001b[1;32m    704\u001b[0m \u001b[39mwhile\u001b[39;00m \u001b[39mTrue\u001b[39;00m:\n\u001b[1;32m    705\u001b[0m     \u001b[39mtry\u001b[39;00m:\n\u001b[0;32m--> 706\u001b[0m         \u001b[39mreturn\u001b[39;00m \u001b[39mself\u001b[39;49m\u001b[39m.\u001b[39;49m_sock\u001b[39m.\u001b[39;49mrecv_into(b)\n\u001b[1;32m    707\u001b[0m     \u001b[39mexcept\u001b[39;00m timeout:\n\u001b[1;32m    708\u001b[0m         \u001b[39mself\u001b[39m\u001b[39m.\u001b[39m_timeout_occurred \u001b[39m=\u001b[39m \u001b[39mTrue\u001b[39;00m\n",
+      "File \u001b[0;32m/Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/ssl.py:1278\u001b[0m, in \u001b[0;36mSSLSocket.recv_into\u001b[0;34m(self, buffer, nbytes, flags)\u001b[0m\n\u001b[1;32m   1274\u001b[0m     \u001b[39mif\u001b[39;00m flags \u001b[39m!=\u001b[39m \u001b[39m0\u001b[39m:\n\u001b[1;32m   1275\u001b[0m         \u001b[39mraise\u001b[39;00m \u001b[39mValueError\u001b[39;00m(\n\u001b[1;32m   1276\u001b[0m           \u001b[39m\"\u001b[39m\u001b[39mnon-zero flags not allowed in calls to recv_into() on \u001b[39m\u001b[39m%s\u001b[39;00m\u001b[39m\"\u001b[39m \u001b[39m%\u001b[39m\n\u001b[1;32m   1277\u001b[0m           \u001b[39mself\u001b[39m\u001b[39m.\u001b[39m\u001b[39m__class__\u001b[39m)\n\u001b[0;32m-> 1278\u001b[0m     \u001b[39mreturn\u001b[39;00m \u001b[39mself\u001b[39;49m\u001b[39m.\u001b[39;49mread(nbytes, buffer)\n\u001b[1;32m   1279\u001b[0m \u001b[39melse\u001b[39;00m:\n\u001b[1;32m   1280\u001b[0m     \u001b[39mreturn\u001b[39;00m \u001b[39msuper\u001b[39m()\u001b[39m.\u001b[39mrecv_into(buffer, nbytes, flags)\n",
+      "File \u001b[0;32m/Library/Frameworks/Python.framework/Versions/3.11/lib/python3.11/ssl.py:1134\u001b[0m, in \u001b[0;36mSSLSocket.read\u001b[0;34m(self, len, buffer)\u001b[0m\n\u001b[1;32m   1132\u001b[0m \u001b[39mtry\u001b[39;00m:\n\u001b[1;32m   1133\u001b[0m     \u001b[39mif\u001b[39;00m buffer \u001b[39mis\u001b[39;00m \u001b[39mnot\u001b[39;00m \u001b[39mNone\u001b[39;00m:\n\u001b[0;32m-> 1134\u001b[0m         \u001b[39mreturn\u001b[39;00m \u001b[39mself\u001b[39;49m\u001b[39m.\u001b[39;49m_sslobj\u001b[39m.\u001b[39;49mread(\u001b[39mlen\u001b[39;49m, buffer)\n\u001b[1;32m   1135\u001b[0m     \u001b[39melse\u001b[39;00m:\n\u001b[1;32m   1136\u001b[0m         \u001b[39mreturn\u001b[39;00m \u001b[39mself\u001b[39m\u001b[39m.\u001b[39m_sslobj\u001b[39m.\u001b[39mread(\u001b[39mlen\u001b[39m)\n",
+      "\u001b[0;31mKeyboardInterrupt\u001b[0m: "
+     ]
+    }
+   ],
+   "source": [
+    "db = DeepLake(dataset_path=f\"hub://{username}/{projectname}\", read_only=True, embedding_function=embeddings)"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": null,
+   "metadata": {},
+   "outputs": [],
+   "source": [
+    "retriever = db.as_retriever()\n",
+    "retriever.search_kwargs['distance_metric'] = 'cos'\n",
+    "retriever.search_kwargs['fetch_k'] = 100\n",
+    "retriever.search_kwargs['maximal_marginal_relevance'] = True\n",
+    "retriever.search_kwargs['k'] = 10"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": null,
+   "metadata": {},
+   "outputs": [],
+   "source": [
+    "from langchain.chat_models import ChatOpenAI\n",
+    "from langchain.chains import ConversationalRetrievalChain\n",
+    "\n",
+    "model = ChatOpenAI(model_name='gpt-3.5-turbo') # switch to 'gpt-4'\n",
+    "qa = ConversationalRetrievalChain.from_llm(model, retriever=retriever)"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": null,
+   "metadata": {},
+   "outputs": [
+    {
+     "name": "stdout",
+     "output_type": "stream",
+     "text": [
+      "-> **Question**: 1. Crease a sample polywrap client invokation text snippet. \n",
+      "\n",
+      "**Answer**: ```typescript\n",
+      "const client = new PolywrapClient();\n",
+      "\n",
+      "const result = await client.invoke({\n",
+      "  uri: \"ens/wraps.eth:logger@1.0.0\",\n",
+      "  method: \"log\",\n",
+      "  args: {\n",
+      "    message: \"Hello Polywrap!\",\n",
+      "  },\n",
+      "});\n",
+      "\n",
+      "console.log(result);\n",
+      "``` \n",
+      "\n"
+     ]
+    }
+   ],
+   "source": [
+    "questions = [\n",
+    "    \"\"\"1. Crease a sample polywrap client invokation text snippet to register the ENS domain `rihp.eth`.\"\"\",  \n",
+    "] \n",
+    "chat_history = []\n",
+    "\n",
+    "for question in questions:  \n",
+    "    result = qa({\"question\": question, \"chat_history\": chat_history})\n",
+    "    chat_history.append((question, result['answer']))\n",
+    "    print(f\"-> **Question**: {question} \\n\")\n",
+    "    print(f\"**Answer**: {result['answer']} \\n\")"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": null,
+   "metadata": {},
+   "outputs": [],
+   "source": []
+  }
+ ],
+ "metadata": {
+  "kernelspec": {
+   "display_name": "Python 3.11.3 64-bit",
+   "language": "python",
+   "name": "python3"
+  },
+  "language_info": {
+   "codemirror_mode": {
+    "name": "ipython",
+    "version": 3
+   },
+   "file_extension": ".py",
+   "mimetype": "text/x-python",
+   "name": "python",
+   "nbconvert_exporter": "python",
+   "pygments_lexer": "ipython3",
+   "version": "3.11.3"
+  },
+  "orig_nbformat": 4,
+  "vscode": {
+   "interpreter": {
+    "hash": "aee8b7b246df8f9039afb4144a1f6fd8d2ca17a180786b69acc140d282b71a49"
+   }
+  }
+ },
+ "nbformat": 4,
+ "nbformat_minor": 2
+}

polywrapgpt/e2e.spec.ts

@@ -0,0 +1,765 @@
+import {
+    providers as testEnvProviders,
+    ensAddresses,
+  } from "@polywrap/test-env-js";
+  import { PolywrapClient } from "@polywrap/client-js";
+  import path from "path";
+  import { providers } from "ethers";
+  
+  import { getConfig } from "./utils";
+  import { initInfra, stopInfra } from "./infra";
+  
+  jest.setTimeout(900000);
+  
+  describe("ENS Wrapper", () => {
+    // We will have two clients because we need two
+    // different signers in order to test ENS functions
+    let ownerClient: PolywrapClient;
+    let anotherOwnerClient: PolywrapClient;
+  
+    let fsUri: string;
+    let ethersProvider: providers.JsonRpcProvider;
+    let registryAddress: string;
+    let registrarAddress: string;
+    let resolverAddress: string;
+    let reverseRegistryAddress: string;
+    let customFifsRegistrarAddress: string;
+  
+    let owner: string;
+    let anotherOwner: string;
+  
+    const customTld: string = "doe.eth";
+    const openSubdomain: string = "open." + customTld;
+    const customSubdomain: string = "john." + customTld;
+  
+    const network: string = "testnet";
+  
+    beforeAll(async () => {
+      await initInfra();
+  
+      // get ens wrapepr uri
+      const apiPath: string = path.resolve(__dirname + "/../../");
+      fsUri = `fs/${apiPath}/build`;
+  
+      // set up ethers provider
+      ethersProvider = providers.getDefaultProvider(
+        testEnvProviders.ethereum
+      ) as providers.JsonRpcProvider;
+      owner = (await ethersProvider.getSigner(0).getAddress()).toLowerCase();
+      anotherOwner = (await ethersProvider.getSigner(1).getAddress()).toLowerCase();
+      registryAddress = ensAddresses.ensAddress;
+      registrarAddress = ensAddresses.registrarAddress;
+      resolverAddress = ensAddresses.resolverAddress.toLowerCase();
+      reverseRegistryAddress = ensAddresses.reverseAddress;
+  
+      // get client
+      const config = getConfig(testEnvProviders.ethereum, ensAddresses.ensAddress, testEnvProviders.ipfs);
+      ownerClient = new PolywrapClient(config, { noDefaults: true });
+  
+      const anotherOwnerConfig = getConfig(
+        testEnvProviders.ethereum,
+        ensAddresses.ensAddress,
+        testEnvProviders.ipfs,
+        anotherOwner
+      );
+      anotherOwnerClient = new PolywrapClient(anotherOwnerConfig, { noDefaults: true });
+    });
+  
+    afterAll(async () => {
+      await stopInfra();
+    });
+  
+    it("should register domain", async () => {
+      const result = await ownerClient.invoke<string>({
+        uri: fsUri,
+        method: "registerDomain",
+        args: {
+          domain: customTld,
+          owner,
+          registrarAddress,
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+      if (result.ok === false) throw result.error;
+      expect(result.value).toBeDefined();
+    });
+  
+    it("should set and get resolver", async () => {
+      const setResult = await ownerClient.invoke({
+        uri: fsUri,
+        method: "setResolver", 
+        args: {
+          domain: customTld,
+          owner,
+          registryAddress,
+          resolverAddress: resolverAddress,
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+      if (setResult.ok === false) throw setResult.error;
+      expect(setResult.value).toBeDefined();
+  
+      const getResult = await ownerClient.invoke({
+        uri: fsUri,
+        method: "getResolver",
+        args: {
+          domain: customTld,
+          registryAddress,
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+      if (getResult.ok === false) throw getResult.error;
+      expect(getResult.value).toEqual(resolverAddress);
+    });
+  
+    it("should set owner of subdomain and fetch it", async () => {
+      const subdomain = "bob." + customTld;
+  
+      const setResult = await ownerClient.invoke({
+        uri: fsUri,
+        method: "setSubdomainOwner",
+        args: {
+          subdomain,
+          owner,
+          registryAddress,
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+      if (setResult.ok === false) throw setResult.error;
+      expect(setResult.value).toBeDefined();
+  
+      const getResult = await ownerClient.invoke({
+        uri: fsUri,
+        method: "getOwner",
+        args: {
+          domain: subdomain,
+          registryAddress,
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+      if (getResult.ok === false) throw getResult.error;
+      expect(getResult.value).toBeDefined();
+    });
+  
+    it("should register domain with subdomains recursively and fetch it", async () => {
+      const domain = "foo.bar.baz.mydomain.eth";
+  
+      const registerDomainAndSubdomainsRecursivelyResult = await ownerClient.invoke<any[]>({
+        uri: fsUri,
+        method: "registerDomainAndSubdomainsRecursively",
+        args: {
+          domain,
+          owner,
+          registryAddress,
+          resolverAddress,
+          registrarAddress,
+          ttl: '0',
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+      if (registerDomainAndSubdomainsRecursivelyResult.ok === false) throw registerDomainAndSubdomainsRecursivelyResult.error;
+      expect(registerDomainAndSubdomainsRecursivelyResult.value).toBeDefined();
+      
+      const resultingRegistrations = registerDomainAndSubdomainsRecursivelyResult.value;
+  
+      expect(resultingRegistrations[0]?.name).toBe("mydomain.eth")
+      expect(resultingRegistrations[0]?.didRegister).toBe(true)
+      expect(resultingRegistrations[1]?.name).toBe("baz.mydomain.eth")
+      expect(resultingRegistrations[1]?.didRegister).toBe(true)
+      expect(resultingRegistrations[2]?.name).toBe("bar.baz.mydomain.eth")
+      expect(resultingRegistrations[2]?.didRegister).toBe(true)
+      expect(resultingRegistrations[3]?.name).toBe("foo.bar.baz.mydomain.eth")
+      expect(resultingRegistrations[3]?.didRegister).toBe(true)
+  
+      const getOwnerResult = await ownerClient.invoke({
+        uri: fsUri,
+        method: "getOwner",
+        args: {
+          domain,
+          registryAddress,
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+      if (getOwnerResult.ok === false) throw getOwnerResult.error;
+      expect(getOwnerResult.value).toBeDefined();
+      expect(getOwnerResult.value).toBe(owner);
+  
+      // No subdomain
+  
+      const domainWithNoSubdomain = "sumtin.eth";
+    
+      const domainWithNoSubdomainResult = await ownerClient.invoke<any[]>({
+        uri: fsUri,
+        method: "registerDomainAndSubdomainsRecursively",
+        args: {
+          domain: domainWithNoSubdomain,
+          owner,
+          registryAddress,
+          resolverAddress,
+          registrarAddress,
+          ttl: '0',
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+      if (domainWithNoSubdomainResult.ok === false) throw domainWithNoSubdomainResult.error;
+      expect(domainWithNoSubdomainResult.value).toBeDefined();
+      
+      const domainWithNoSubdomainRegistrations = domainWithNoSubdomainResult.value;
+  
+      expect(domainWithNoSubdomainRegistrations[0]?.name).toBe("sumtin.eth")
+    });
+  
+    it("should not attempt to re-register registered subdomains/domains when recursively registering", async () => {
+      const rootDomain = "domain.eth"
+      const label = "sub"
+      const tld = `${label}.${rootDomain}`
+      const subdomain = `already.registered.${tld}`;
+  
+      await ownerClient.invoke<string>({
+        uri: fsUri,
+        method: "",
+        args: {
+          domain: tld,
+          owner,
+          registryAddress,
+          registrarAddress,
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+      await ownerClient.invoke<string>({
+        uri: fsUri,
+        method: "registerDomain",
+        args: {
+          domain: rootDomain,
+          owner,
+          registryAddress,
+          registrarAddress,
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+      await ownerClient.invoke({
+        uri: fsUri,
+        method: "setSubdomainRecord",
+        args: {
+          domain: rootDomain,
+          label,
+          owner,
+          registryAddress,
+          resolverAddress,
+          ttl: '0',
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+      const registerDomainAndSubdomainsRecursivelyResult = await ownerClient.invoke<any[]>({
+        uri: fsUri,
+        method: "registerDomainAndSubdomainsRecursively",
+        args: {
+          domain: subdomain,
+          owner,
+          registryAddress,
+          resolverAddress,
+          registrarAddress,
+          ttl: '0',
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+      if (registerDomainAndSubdomainsRecursivelyResult.ok === false) throw registerDomainAndSubdomainsRecursivelyResult.error;
+      expect(registerDomainAndSubdomainsRecursivelyResult.value).toBeDefined();
+  
+      const resultingRegistrations = registerDomainAndSubdomainsRecursivelyResult.value;
+  
+      expect(resultingRegistrations[0]?.name).toBe("domain.eth")
+      expect(resultingRegistrations[0]?.didRegister).toBe(false)
+      expect(resultingRegistrations[1]?.name).toBe("sub.domain.eth")
+      expect(resultingRegistrations[1]?.didRegister).toBe(false)
+      expect(resultingRegistrations[2]?.name).toBe("registered.sub.domain.eth")
+      expect(resultingRegistrations[2]?.didRegister).toBe(true)
+      expect(resultingRegistrations[3]?.name).toBe("already.registered.sub.domain.eth")
+      expect(resultingRegistrations[3]?.didRegister).toBe(true)
+  
+      const getOwnerResult = await ownerClient.invoke({
+        uri: fsUri,
+        method: "getOwner",
+        args: {
+          domain: subdomain,
+          registryAddress,
+          connection: {
+            networkNameOrChainId: network
+          }
+        },
+      });
+  
+      if (getOwnerResult.ok === false) throw getOwnerResult.error;
+      expect(getOwnerResult.value).toBeDefined();
+      expect(getOwnerResult.value).toBe(owner);
+    });
+  
+    it("should register subdomain recursively and fetch it", async () => {
+      const tld = "basedomain.eth";
+      const subdomain = `aaa.bbb.ccc.${tld}`;
+  
+      await ownerClient.invoke<string>({
+        uri: fsUri,
+        method: "registerDomain",
+        args: {
+          domain: tld,
+          owner,
+          registrarAddress,
+          registryAddress,
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+      const registerSubdomainsRecursivelyResult = await ownerClient.invoke<any[]>({
+        uri: fsUri,
+        method: "registerSubdomainsRecursively",
+        args: {
+          domain: subdomain,
+          owner,
+          registryAddress,
+          resolverAddress,
+          registrarAddress,
+          ttl: '0',
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+      if (registerSubdomainsRecursivelyResult.ok === false) throw registerSubdomainsRecursivelyResult.error;
+      expect(registerSubdomainsRecursivelyResult.value).toBeDefined();
+      
+      const resultingRegistrations = registerSubdomainsRecursivelyResult.value;
+  
+      expect(resultingRegistrations[0]?.name).toBe("ccc.basedomain.eth")
+      expect(resultingRegistrations[0]?.didRegister).toBe(true)
+      expect(resultingRegistrations[1]?.name).toBe("bbb.ccc.basedomain.eth")
+      expect(resultingRegistrations[1]?.didRegister).toBe(true)
+      expect(resultingRegistrations[2]?.name).toBe("aaa.bbb.ccc.basedomain.eth")
+      expect(resultingRegistrations[2]?.didRegister).toBe(true)
+  
+      const getOwnerResult = await ownerClient.invoke({
+        uri: fsUri,
+        method: "getOwner",
+        args: {
+          domain: subdomain,
+          registryAddress,
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+      if (getOwnerResult.ok === false) throw getOwnerResult.error;
+      expect(getOwnerResult.value).toBeDefined();
+      expect(getOwnerResult.value).toBe(owner);
+    });
+  
+    it("should set subdomain owner, resolver and ttl", async () => {
+      const setSubdomainRecordResult = await ownerClient.invoke({
+        uri: fsUri,
+        method: "setSubdomainRecord",
+        args: {
+          domain: customTld,
+          label: "john",
+          owner: anotherOwner,
+          registryAddress,
+          resolverAddress,
+          ttl: '0',
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+      if (setSubdomainRecordResult.ok === false) throw setSubdomainRecordResult.error;
+      expect(setSubdomainRecordResult.value).toBeDefined();
+  
+      const getOwnerResult = await ownerClient.invoke({
+        uri: fsUri,
+        method: "getOwner",
+        args: {
+          domain: customSubdomain,
+          registryAddress,
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+      if (getOwnerResult.ok === false) throw getOwnerResult.error;
+      expect(getOwnerResult.value).toEqual(anotherOwner);
+    });
+  
+    it("should update and fetch owner", async () => {
+      const getOldOwnerResult = await anotherOwnerClient.invoke({
+        uri: fsUri,
+        method: "getOwner",
+        args: {
+          domain: customSubdomain,
+          registryAddress,
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+      if (getOldOwnerResult.ok === false) throw getOldOwnerResult.error;
+      expect(getOldOwnerResult.value).toEqual(anotherOwner);
+  
+      const setOwnerResult = await anotherOwnerClient.invoke({
+        uri: fsUri,
+        method: "setOwner",
+        args: {
+          domain: customSubdomain,
+          newOwner: owner,
+          registryAddress,
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+      if (setOwnerResult.ok === false) throw setOwnerResult.error;
+      expect(setOwnerResult.value).toBeDefined();
+  
+      const getNewOwnerResult = await ownerClient.invoke({
+        uri: fsUri,
+        method: "getOwner",
+        args: {
+          domain: customSubdomain,
+          registryAddress,
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+      if (getNewOwnerResult.ok === false) throw getNewOwnerResult.error;
+      expect(getNewOwnerResult.value).toBe(owner);
+    });
+  
+    it("should set content hash and fetch it", async () => {
+      const cid = "0x64EC88CA00B268E5BA1A35678A1B5316D212F4F366B2477232534A8AECA37F3C".toLowerCase();
+  
+      const setContentHashResult = await ownerClient.invoke({
+        uri: fsUri,
+        method: "setContentHash",
+        args: {
+          domain: customSubdomain,
+          cid,
+          resolverAddress,
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+      if (setContentHashResult.ok === false) throw setContentHashResult.error;
+      expect(setContentHashResult.value).toBeDefined();
+  
+      const getContentHashResult  = await ownerClient.invoke({
+        uri: fsUri,
+        method: "getContentHash",
+        args: {
+          domain: customSubdomain,
+          resolverAddress,
+          connection: {
+            networkNameOrChainId: network
+          }
+        },
+      });
+  
+      if (getContentHashResult.ok === false) throw getContentHashResult.error;
+      expect(getContentHashResult.value).toEqual(cid);
+  
+      const getContentHashFromDomainResult = await ownerClient.invoke({
+        uri: fsUri,
+        method: "getContentHashFromDomain",
+        args: {
+          domain: customSubdomain,
+          registryAddress,
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+      if (getContentHashFromDomainResult.ok === false) throw getContentHashFromDomainResult.error;
+      expect(getContentHashFromDomainResult.value).toEqual(cid);
+    });
+  
+    it("should set address and fetch it", async () => {
+      const setAddressResult = await ownerClient.invoke({
+        uri: fsUri,
+        method: "setAddress",
+        args: {
+          domain: customTld,
+          address: anotherOwner,
+          resolverAddress,
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+      if (setAddressResult.ok === false) throw setAddressResult.error;
+      expect(setAddressResult.value).toBeDefined();
+  
+      const getAddressResult = await ownerClient.invoke({
+        uri: fsUri,
+        method: "getAddress",
+        args: {
+          domain: customTld,
+          resolverAddress,
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+      if (getAddressResult.ok === false) throw getAddressResult.error;
+      expect(getAddressResult.value).toEqual(anotherOwner);
+  
+      const getAddressFromDomainResult = await ownerClient.invoke({
+        uri: fsUri,
+        method: "getAddressFromDomain",
+        args: {
+          domain: customTld,
+          registryAddress,
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+      if (getAddressFromDomainResult.ok === false) throw getAddressFromDomainResult.error;
+      expect(getAddressFromDomainResult.value).toEqual(anotherOwner);
+    });
+  
+    it("should set reverse registry", async () => {
+      const reverseRegistryResult = await ownerClient.invoke({
+        uri: fsUri,
+        method: "reverseRegisterDomain",
+        args: {
+          domain: customTld,
+          reverseRegistryAddress,
+          owner,
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+      if (reverseRegistryResult.ok === false) throw reverseRegistryResult.error;
+      expect(reverseRegistryResult.value).toBeDefined();
+    });
+  
+    it("should fetch name based on address from registry and resolver", async () => {
+      const getNameFromAddressResult = await ownerClient.invoke({
+        uri: fsUri,
+        method: "getNameFromAddress",
+        args: {
+          address: owner,
+          registryAddress,
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+      if (getNameFromAddressResult.ok === false) throw getNameFromAddressResult.error;
+      expect(getNameFromAddressResult.value).toEqual(customTld);
+  
+      const getNameFromReverseResolverResult = await ownerClient.invoke({
+        uri: fsUri,
+        method: "getNameFromReverseResolver",
+        args: {
+          address: owner,
+          resolverAddress,
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+      if (getNameFromReverseResolverResult.ok === false) throw getNameFromReverseResolverResult.error;
+      expect(getNameFromReverseResolverResult.value).toEqual(customTld);
+    });
+  
+    it("should set and get text record from subdomain", async () => {
+      const key = "snapshot";
+      const value = "QmHash";
+  
+      const setTextRecordResult = await ownerClient.invoke({
+        uri: fsUri,
+        method: "setTextRecord",
+        args: {
+          domain: customTld,
+          resolverAddress,
+          key,
+          value,
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+      if (setTextRecordResult.ok === false) throw setTextRecordResult.error;
+      expect(setTextRecordResult.value).toBeDefined();
+  
+      const getTextRecordResult = await ownerClient.invoke({
+        uri: fsUri,
+        method: "getTextRecord",
+        args: {
+          domain: customTld,
+          resolverAddress,
+          key,
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+      if (getTextRecordResult.ok === false) throw getTextRecordResult.error;
+      expect(getTextRecordResult.value).toEqual(value);
+    });
+  
+    it("should configure open domain", async () => {
+      const configureOpenDomainResult = await ownerClient.invoke<{
+          fifsRegistrarAddress: string;
+          setOwnerTxReceipt: any;
+        }>({
+        uri: fsUri,
+        method: "configureOpenDomain",
+        args: {
+          tld: openSubdomain,
+          owner,
+          registryAddress,
+          resolverAddress,
+          registrarAddress,
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+      if (configureOpenDomainResult.ok === false) throw configureOpenDomainResult.error;
+      expect(configureOpenDomainResult.value).toBeDefined();
+  
+      const getOwnerResult = await ownerClient.invoke({
+        uri: fsUri,
+        method: "getOwner",
+        args: {
+          domain: openSubdomain,
+          registryAddress,
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+      if (getOwnerResult.ok === false) throw getOwnerResult.error;
+      expect(getOwnerResult.value).toEqual( configureOpenDomainResult.value.fifsRegistrarAddress);
+  
+      customFifsRegistrarAddress = configureOpenDomainResult.value.fifsRegistrarAddress;
+    });
+  
+    it("should create subdomain in open domain", async () => {
+      const result = await anotherOwnerClient.invoke({
+        uri: fsUri,
+        method: "createSubdomainInOpenDomain",
+        args: {
+          label: "label",
+          domain: openSubdomain,
+          owner: anotherOwner,
+          fifsRegistrarAddress: customFifsRegistrarAddress,
+          registryAddress,
+          resolverAddress,
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+      if (result.ok === false) throw result.error;
+      expect(result.value).toBeDefined();
+    });
+  
+    it("should create subdomain in open domain and set content hash", async () => {
+      const cid = "0x64EC88CA00B268E5BA1A35678A1B5316D212F4F366B2477232534A8AECA37F3C".toLowerCase();
+  
+      const createAndSetResult = await anotherOwnerClient.invoke({
+        uri: fsUri,
+        method: "createSubdomainInOpenDomainAndSetContentHash",
+        args: {
+          cid,
+          label: "label2",
+          domain: openSubdomain,
+          owner: anotherOwner,
+          fifsRegistrarAddress: customFifsRegistrarAddress,
+          registryAddress,
+          resolverAddress,
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+      if (createAndSetResult.ok === false) throw createAndSetResult.error;
+      expect(createAndSetResult.value).toBeDefined();
+  
+      const getResult = await ownerClient.invoke({
+        uri: fsUri,
+        method: "getContentHashFromDomain",
+        args: {
+          domain: "label2." + openSubdomain,
+          registryAddress,
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+      if (getResult.ok === false) throw getResult.error;
+      expect(getResult.value).toEqual(cid);
+    });
+  });

polywrapgpt/ens

@@ -0,0 +1 @@
+Subproject commit 49331d87f4cdafde395f5073b885764b133994c0

polywrapgpt/examples.md

@@ -0,0 +1,59 @@
+# This is a sample integration of Polywrap. We can see how we can invoke wrappers using the 
+
+This is an example of how you can answer given each input.
+
+You will get a prompt like the following `Prompt_input-0`:
+
+`Prompt_input-0`: "I want to register `juan.eth` as a domain and set this as a content hash `Qmasjdhaisud923847923`"
+
+For this input the steps you have to look at the schema.graphql which is located in `src/schema.graphql` inside the ens repo.
+ 
+
+The first part you have to investigate before creating an output for this prompt:
+
+```ts
+# These are the inputs needed for executing the invokation
+registerDomain(
+    domain: String! # This should be equal to "juan.eth"
+    registrarAddress: String!
+    owner: String!
+    connection: Ethereum_Connection  #Ignore because it doesnt have an exclamation mark
+    txOptions: TxOptions #Ignore because it doesnt have an exclamation mark
+  ): Ethereum_TxResponse!
+```
+
+After researching the `schema.graphql` you should then prepare an invokation that looks like the one below with the same structure, but with the mapping of the variables that were researched in the previous step.
+
+```ts
+    const result = await ownerClient.invoke<string>({
+        uri: fsUri,
+        method: "registerDomain",
+        args: {
+          domain: customTld,
+          owner,
+          registrarAddress,
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+  
+```
+
+The output that we will be looking for:
+
+
+```ts
+    const result = await ownerClient.invoke<string>({
+        uri: fsUri,
+        method: "registerDomain",
+        args: {
+          domain: "juan.eth",
+          owner,
+          registrarAddress,
+          connection: {
+            networkNameOrChainId: network
+          }
+        }
+      });
+```

polywrapgpt/schema.graphql

@@ -0,0 +1,301 @@
+#import { Module, Connection } into Ethereum from "wrap://ipfs/QmS4Z679ZE8WwZSoYB8w9gDSERHAoWG1fX94oqdWpfpDq3"
+#import { Module } into UTS46 from "wrap://ipfs/QmPL9Njg3rGkpoJyoy8pZ5fTavjvHxNuuuiGRApzyGESZB"
+#import { Module } into SHA3 from "wrap://ipfs/QmThRxFfr7Hj9Mq6WmcGXjkRrgqMG3oD93SLX27tinQWy5"
+
+type Module {
+  getResolver(
+    registryAddress: String!
+    domain: String!
+    connection: Ethereum_Connection
+  ): String!
+
+  getOwner(
+    domain: String!
+    registryAddress: String!
+    connection: Ethereum_Connection
+  ): String!
+
+  checkIfRecordExists(
+    domain: String!
+    registryAddress: String!
+    connection: Ethereum_Connection
+  ): Boolean!
+
+  getAddress(
+    domain: String!
+    resolverAddress: String!
+    connection: Ethereum_Connection
+  ): String!
+
+  getAddressFromDomain(
+    domain: String!
+    registryAddress: String!
+    connection: Ethereum_Connection
+  ): String!
+
+  getContentHash(
+    domain: String!
+    resolverAddress: String!
+    connection: Ethereum_Connection
+  ): String!
+
+  getContentHashFromDomain(
+    domain: String!
+    registryAddress: String!
+    connection: Ethereum_Connection
+  ): String!
+
+  getExpiryTimes(
+    domain: String!
+    registrarAddress: String!
+    connection: Ethereum_Connection
+  ): String!
+
+  getReverseResolver(
+    address: String!
+    registryAddress: String!
+    connection: Ethereum_Connection
+  ): String!
+
+  getNameFromReverseResolver(
+    address: String!
+    resolverAddress: String!
+    connection: Ethereum_Connection
+  ): String!
+
+  getNameFromAddress(
+    address: String!
+    registryAddress: String!
+    connection: Ethereum_Connection
+  ): String!
+
+  getTextRecord(
+    domain: String!
+    resolverAddress: String!
+    key: String!
+    connection: Ethereum_Connection
+  ): String!
+
+  setResolver(
+    domain: String!
+    resolverAddress: String!
+    registryAddress: String!
+    connection: Ethereum_Connection
+    txOptions: TxOptions
+  ): Ethereum_TxResponse!
+
+  registerDomain(
+    domain: String!
+    registrarAddress: String!
+    owner: String!
+    connection: Ethereum_Connection
+    txOptions: TxOptions
+  ): Ethereum_TxResponse!
+
+  reverseRegisterDomain(
+    domain: String!
+    reverseRegistryAddress: String!
+    owner: String!
+    connection: Ethereum_Connection
+    txOptions: TxOptions
+  ): Ethereum_TxResponse!
+
+  setName(
+    domain: String!
+    reverseRegistryAddress: String!
+    connection: Ethereum_Connection
+    txOptions: TxOptions
+  ): Ethereum_TxResponse!
+
+  setAddress(
+    domain: String!
+    address: String!
+    resolverAddress: String!
+    connection: Ethereum_Connection
+    txOptions: TxOptions
+  ): Ethereum_TxResponse!
+
+  setOwner(
+    domain: String!
+    newOwner: String!
+    registryAddress: String!
+    connection: Ethereum_Connection
+    txOptions: TxOptions
+  ): Ethereum_TxResponse!
+
+  setSubdomainOwner(
+    subdomain: String!
+    owner: String!
+    registryAddress: String!
+    connection: Ethereum_Connection
+    txOptions: TxOptions
+  ): Ethereum_TxResponse!
+
+  setRecord(
+    domain: String!
+    owner: String!
+    resolverAddress: String!
+    ttl: String!
+    registryAddress: String!
+    connection: Ethereum_Connection
+    txOptions: TxOptions
+  ): Ethereum_TxResponse!
+
+  setSubdomainRecord(
+    domain: String!
+    label: String!
+    owner: String!
+    resolverAddress: String!
+    ttl: String!
+    registryAddress: String!
+    connection: Ethereum_Connection
+    txOptions: TxOptions
+  ): Ethereum_TxResponse!
+
+  registerSubdomainsRecursively(
+    domain: String!
+    owner: String!
+    resolverAddress: String!
+    ttl: String!
+    registryAddress: String!
+    connection: Ethereum_Connection
+    txOptions: TxOptions
+  ): [RegistrationResult!]!
+
+  registerDomainAndSubdomainsRecursively(
+    domain: String!
+    owner: String!
+    resolverAddress: String!
+    ttl: String!
+    registrarAddress: String!
+    registryAddress: String!
+    connection: Ethereum_Connection
+    txOptions: TxOptions
+  ): [RegistrationResult!]!
+
+  setContentHash(
+    domain: String!
+    cid: String!
+    resolverAddress: String!
+    connection: Ethereum_Connection
+    txOptions: TxOptions
+  ): Ethereum_TxResponse!
+
+  setAddressFromDomain(
+    domain: String!
+    address: String!
+    registryAddress: String!
+    connection: Ethereum_Connection
+    txOptions: TxOptions
+  ): Ethereum_TxResponse!
+
+  setContentHashFromDomain(
+    domain: String!
+    cid: String!
+    registryAddress: String!
+    connection: Ethereum_Connection
+    txOptions: TxOptions
+  ): Ethereum_TxResponse!
+
+  deployFIFSRegistrar(
+    registryAddress: String!
+    tld: String!
+    connection: Ethereum_Connection
+    txOptions: TxOptions
+  ): String!
+
+  registerSubnodeOwnerWithFIFSRegistrar(
+    label: String!
+    owner: String!
+    fifsRegistrarAddress: String!
+    connection: Ethereum_Connection
+    txOptions: TxOptions
+  ): Ethereum_TxResponse!
+
+  setTextRecord(
+    domain: String!
+    resolverAddress: String!
+    key: String!
+    value: String!
+    connection: Ethereum_Connection
+    txOptions: TxOptions
+  ): Ethereum_TxResponse!
+
+  configureOpenDomain(
+    tld: String!
+    owner: String!
+    registryAddress: String!
+    resolverAddress: String!
+    registrarAddress: String!
+    connection: Ethereum_Connection
+    txOptions: TxOptions
+  ): ConfigureOpenDomainResponse!
+
+  createSubdomainInOpenDomain(
+    label: String!
+    domain: String!
+    owner: String!
+    fifsRegistrarAddress: String!
+    registryAddress: String!
+    resolverAddress: String!
+    connection: Ethereum_Connection
+    txOptions: TxOptions
+  ): CreateSubdomainInOpenDomainResponse!
+
+  createSubdomainInOpenDomainAndSetContentHash(
+    label: String!
+    domain: String!
+    owner: String!
+    fifsRegistrarAddress: String!
+    registryAddress: String!
+    resolverAddress: String!
+    cid: String!
+    connection: Ethereum_Connection
+    txOptions: TxOptions
+  ): CreateSubdomainInOpenDomainAndSetContentHashResponse
+}
+
+type ConfigureOpenDomainResponse {
+  fifsRegistrarAddress: String!
+  registerOpenDomainTxReceipt: Ethereum_TxResponse!
+  setSubdomainRecordTxReceipt: Ethereum_TxResponse!
+}
+
+type CreateSubdomainInOpenDomainResponse {
+  registerSubdomainTxReceipt: Ethereum_TxResponse!
+  setResolverTxReceipt: Ethereum_TxResponse!
+}
+
+type CreateSubdomainInOpenDomainAndSetContentHashResponse implements CreateSubdomainInOpenDomainResponse {
+  setContentHashReceiptTx: Ethereum_TxResponse!
+}
+
+type RegistrationResult {
+  name: String!
+  didRegister: Boolean!
+  tx: Ethereum_TxResponse
+}
+
+type TxOptions {
+  """Gas supplied for the transaction"""
+  gasLimit: BigInt
+  """
+  The max total fee to pay per unit of gas.
+  The difference between maxFeePerGas and baseFeePerGas + maxPriorityFeePerGas is “refunded” to the user.
+  This property is ignored when gasPrice is not null.
+  """
+  maxFeePerGas: BigInt
+  """
+  The gas price paid is baseFeePerGas + maxPriorityFeePerGas.
+  The difference between maxFeePerGas and baseFeePerGas + maxPriorityFeePerGas is “refunded” to the user.
+  This property is ignored when gasPrice is not null.
+  """
+  maxPriorityFeePerGas: BigInt
+  """
+  The gas price for legacy transactions.
+  If this property is not null, a legacy transaction will be sent and maxFeePerGas and maxPriorityFeePerGas will be ignored.
+  """
+  gasPrice: BigInt
+  """Override default nonce"""
+  nonce: UInt32
+}