neo4j_parser.ipynb

{
 "cells": [
  {
   "cell_type": "code",
   "execution_count": 3,
   "metadata": {},
   "outputs": [],
   "source": [
    "from neo4j import GraphDatabase"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 4,
   "metadata": {},
   "outputs": [],
   "source": [
    "class BlockChainDB(object):\n",
    "\n",
    "    def __init__(self, uri, user, password):\n",
    "        self._driver = GraphDatabase.driver(uri, auth=(user, password), encrypted=False)#REVISE LATER FOR ENCRYPTION!!!\n",
    "\n",
    "    def close(self):\n",
    "        self._driver.close()\n",
    "        \n",
    "        \n",
    "    @staticmethod\n",
    "    def _new_address(tx, address,i,change_addr):\n",
    "        if change_addr: addr_type = \"change\"\n",
    "        else: addr_type = \"recipient\"\n",
    "        result = tx.run(\"CREATE a = (:address {address:$address, acc_index:$index, type:$kind, created:timestamp()}) \"\n",
    "                        \"RETURN a \", address=address, index = i, kind = addr_type)\n",
    "        return result.single()\n",
    "    \n",
    "    \n",
    "    @staticmethod\n",
    "    def _new_output(tx, amount, script_pubkey,tx_id,out_index):\n",
    "        result = tx.run(\"MATCH (n:transaction {id : $tx_id}) \"\n",
    "                        \"CREATE p = (:output {out_index:$out_index, script_pubkey=$script_pubkey})<-[:CREATES]-(n) \"\n",
    "                        \"RETURN p \", tx_id = tx_id, script_pubkey=script_pubkey, out_index=out_index, local_index=local_index)\n",
    "        return result.single()\n",
    "    \n",
    "    \n",
    "    @staticmethod\n",
    "    def _new_tx(version, locktime, tx_id, inputs, outputs, segwit):\n",
    "        result = tx.run(\"CREATE (n:transaction {id:$tx_id, version:$version, segwit:$segwit, locktime=$locktime}) \"\n",
    "                        \"RETURN n\",\n",
    "                        tx_id=tx_id, segwit=segwit, version=version, locktime=locktime)\n",
    "        \n",
    "        for index,tx_out in enumerate(outputs):\n",
    "            self._new_output(tx_out.amount, tx_out.script_pubkey, tx_id, index)\n",
    "            \n",
    "        for tx_in in inputs:\n",
    "            result = tx.run(\"MATCH (t:transaction {id:$tx_id}), (o:output {index:$input_index})--(:transaction {id:$prev_tx}) \"\n",
    "                        \"CREATE (t)-[:SPENT]->(o)\",\n",
    "                        tx_id=tx_id  input_index=tx_in.prev_index, prev_tx=tx.prev_tx)\n",
    "        \n",
    "        return result.single()\n",
    "    \n",
    "    \n",
    "    @staticmethod\n",
    "    def _new_block(block_id,version, prev_block,merkle_root,timestamp,bits,nonce,n_tx):\n",
    "        _height = tx.run( \"MATCH (u:block) RETURN COUNT (u) \").single()[0] \n",
    "        result = tx.run(\"CREATE (n:block {id:$block_id, version:$version , prev_block:$prev_block, merkle_root:$merkle_root, timestamp:$timestamp, bits:$bits, nonce:$nonce, n_tx:n_tx, height=_height})<-[r:LINKS]-(p:block{id:$prev_block}) \"\n",
    "                        \"RETURN n,r,p\",\n",
    "                        block_id=block_id, version=version, prev_block=prev_block, merkle_root=merkle_root, timestamp=timestamp, \n",
    "                        bits=bits, nonce=nonce, n_tx=n_tx)\n",
    "        return result.single()\n",
    "\n",
    "    def new_address(self, address,i,change_addr):\n",
    "        with self._driver.session() as session:\n",
    "            result = session.write_transaction(self._new_address, address,i,change_addr)\n",
    "            print(result)\n",
    "            \n",
    "    def new_output(self, address,tx_id,out_index):\n",
    "        with self._driver.session() as session:\n",
    "            result = session.write_transaction(self._new_utxo, address,tx_id,out_index)\n",
    "            print(result)\n",
    "            \n",
    "    def new_tx(self, version, locktime, tx_id, inputs, outputs, segwit):\n",
    "        with self._driver.session() as session:\n",
    "            result = session.write_transaction(self._new_tx, tx_id,utxo_local_index_list, outputs)\n",
    "            print(result)\n",
    "            \n",
    "    def new_block(self,block_id,version, prev_block,merkle_root,timestamp,bits,nonce,n_tx):\n",
    "        with self._driver.session() as session:\n",
    "            result = session.write_transaction(self._new_block,block_id,version, prev_block,merkle_root,timestamp,bits,nonce,n_tx)\n",
    "            print(result)\n",
    "  \n",
    "      "
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 5,
   "metadata": {},
   "outputs": [
    {
     "ename": "OSError",
     "evalue": "[Errno 0] Error",
     "output_type": "error",
     "traceback": [
      "\u001b[0;31m---------------------------------------------------------------------------\u001b[0m",
      "\u001b[0;31mOSError\u001b[0m                                   Traceback (most recent call last)",
      "\u001b[0;32m<ipython-input-5-f299bb86f849>\u001b[0m in \u001b[0;36m<module>\u001b[0;34m\u001b[0m\n\u001b[0;32m----> 1\u001b[0;31m \u001b[0mdb\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0mWalletDB\u001b[0m\u001b[0;34m(\u001b[0m \u001b[0;34m\"neo4j://localhost:7687\"\u001b[0m \u001b[0;34m,\u001b[0m \u001b[0;34m\"neo4j\"\u001b[0m \u001b[0;34m,\u001b[0m \u001b[0;34m\"wallet\"\u001b[0m \u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m",
      "\u001b[0;32m<ipython-input-4-b751e86ebe20>\u001b[0m in \u001b[0;36m__init__\u001b[0;34m(self, uri, user, password)\u001b[0m\n\u001b[1;32m      2\u001b[0m \u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m      3\u001b[0m     \u001b[0;32mdef\u001b[0m \u001b[0m__init__\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mself\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0muri\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0muser\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0mpassword\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m----> 4\u001b[0;31m         \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0m_driver\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0mGraphDatabase\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mdriver\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0muri\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0mauth\u001b[0m\u001b[0;34m=\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0muser\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0mpassword\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0mencrypted\u001b[0m\u001b[0;34m=\u001b[0m\u001b[0;32mTrue\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;31m#REVISE LATER FOR ENCRYPTION!!!\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m      5\u001b[0m \u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m      6\u001b[0m     \u001b[0;32mdef\u001b[0m \u001b[0mclose\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mself\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n",
      "\u001b[0;32m/anaconda3/envs/mlenv/lib/python3.7/site-packages/neo4j/__init__.py\u001b[0m in \u001b[0;36mdriver\u001b[0;34m(cls, uri, **config)\u001b[0m\n\u001b[1;32m    118\u001b[0m         \u001b[0;34m:\u001b[0m\u001b[0;32mclass\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;31m`\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mDriver\u001b[0m\u001b[0;31m`\u001b[0m \u001b[0msubclass\u001b[0m \u001b[0minstance\u001b[0m \u001b[0mdirectly\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    119\u001b[0m         \"\"\"\n\u001b[0;32m--> 120\u001b[0;31m         \u001b[0;32mreturn\u001b[0m \u001b[0mDriver\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0muri\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0;34m**\u001b[0m\u001b[0mconfig\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m    121\u001b[0m \u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    122\u001b[0m \u001b[0;34m\u001b[0m\u001b[0m\n",
      "\u001b[0;32m/anaconda3/envs/mlenv/lib/python3.7/site-packages/neo4j/__init__.py\u001b[0m in \u001b[0;36m__new__\u001b[0;34m(cls, uri, **config)\u001b[0m\n\u001b[1;32m    159\u001b[0m         \u001b[0;32mfor\u001b[0m \u001b[0msubclass\u001b[0m \u001b[0;32min\u001b[0m \u001b[0mDriver\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0m__subclasses__\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    160\u001b[0m             \u001b[0;32mif\u001b[0m \u001b[0mparsed_scheme\u001b[0m \u001b[0;32min\u001b[0m \u001b[0msubclass\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0muri_schemes\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m--> 161\u001b[0;31m                 \u001b[0;32mreturn\u001b[0m \u001b[0msubclass\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0muri\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0;34m**\u001b[0m\u001b[0mconfig\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m    162\u001b[0m         \u001b[0;32mraise\u001b[0m \u001b[0mValueError\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m\"URI scheme %r not supported\"\u001b[0m \u001b[0;34m%\u001b[0m \u001b[0mparsed\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mscheme\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    163\u001b[0m \u001b[0;34m\u001b[0m\u001b[0m\n",
      "\u001b[0;32m/anaconda3/envs/mlenv/lib/python3.7/site-packages/neo4j/__init__.py\u001b[0m in \u001b[0;36m__new__\u001b[0;34m(cls, uri, **config)\u001b[0m\n\u001b[1;32m    276\u001b[0m         \u001b[0mpool\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0mRoutingConnectionPool\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mconnector\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0minitial_address\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0mrouting_context\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0minitial_address\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0;34m**\u001b[0m\u001b[0mconfig\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    277\u001b[0m         \u001b[0;32mtry\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m--> 278\u001b[0;31m             \u001b[0mpool\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mupdate_routing_table\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m    279\u001b[0m         \u001b[0;32mexcept\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    280\u001b[0m             \u001b[0mpool\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mclose\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n",
      "\u001b[0;32m/anaconda3/envs/mlenv/lib/python3.7/site-packages/neobolt/routing.py\u001b[0m in \u001b[0;36mupdate_routing_table\u001b[0;34m(self)\u001b[0m\n\u001b[1;32m    373\u001b[0m                 \u001b[0;32mreturn\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    374\u001b[0m \u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m--> 375\u001b[0;31m         \u001b[0;32mif\u001b[0m \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mupdate_routing_table_from\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m*\u001b[0m\u001b[0mexisting_routers\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m    376\u001b[0m             \u001b[0;32mreturn\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    377\u001b[0m \u001b[0;34m\u001b[0m\u001b[0m\n",
      "\u001b[0;32m/anaconda3/envs/mlenv/lib/python3.7/site-packages/neobolt/routing.py\u001b[0m in \u001b[0;36mupdate_routing_table_from\u001b[0;34m(self, *routers)\u001b[0m\n\u001b[1;32m    352\u001b[0m                   \"{}\".format(\", \".join(map(repr, routers))))\n\u001b[1;32m    353\u001b[0m         \u001b[0;32mfor\u001b[0m \u001b[0mrouter\u001b[0m \u001b[0;32min\u001b[0m \u001b[0mrouters\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m--> 354\u001b[0;31m             \u001b[0mnew_routing_table\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mfetch_routing_table\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mrouter\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m    355\u001b[0m             \u001b[0;32mif\u001b[0m \u001b[0mnew_routing_table\u001b[0m \u001b[0;32mis\u001b[0m \u001b[0;32mnot\u001b[0m \u001b[0;32mNone\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    356\u001b[0m                 \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mrouting_table\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mupdate\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mnew_routing_table\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n",
      "\u001b[0;32m/anaconda3/envs/mlenv/lib/python3.7/site-packages/neobolt/routing.py\u001b[0m in \u001b[0;36mfetch_routing_table\u001b[0;34m(self, address)\u001b[0m\n\u001b[1;32m    317\u001b[0m         \u001b[0;34m:\u001b[0m\u001b[0;32mraise\u001b[0m \u001b[0mProtocolError\u001b[0m\u001b[0;34m:\u001b[0m \u001b[0;32mif\u001b[0m \u001b[0mthe\u001b[0m \u001b[0mrouting\u001b[0m \u001b[0minformation\u001b[0m \u001b[0mreceived\u001b[0m \u001b[0;32mis\u001b[0m \u001b[0munusable\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    318\u001b[0m         \"\"\"\n\u001b[0;32m--> 319\u001b[0;31m         \u001b[0mnew_routing_info\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mfetch_routing_info\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0maddress\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m    320\u001b[0m         \u001b[0;32mif\u001b[0m \u001b[0mnew_routing_info\u001b[0m \u001b[0;32mis\u001b[0m \u001b[0;32mNone\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    321\u001b[0m             \u001b[0;32mreturn\u001b[0m \u001b[0;32mNone\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n",
      "\u001b[0;32m/anaconda3/envs/mlenv/lib/python3.7/site-packages/neobolt/routing.py\u001b[0m in \u001b[0;36mfetch_routing_info\u001b[0;34m(self, address)\u001b[0m\n\u001b[1;32m    291\u001b[0m \u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    292\u001b[0m         \u001b[0;32mtry\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m--> 293\u001b[0;31m             \u001b[0;32mwith\u001b[0m \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0macquire_direct\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0maddress\u001b[0m\u001b[0;34m)\u001b[0m \u001b[0;32mas\u001b[0m \u001b[0mcx\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m    294\u001b[0m                 \u001b[0m_\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0m_\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0mserver_version\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0;34m(\u001b[0m\u001b[0mcx\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mserver\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0magent\u001b[0m \u001b[0;32mor\u001b[0m \u001b[0;34m\"\"\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mpartition\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m\"/\"\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    295\u001b[0m                 \u001b[0;32mif\u001b[0m \u001b[0mserver_version\u001b[0m \u001b[0;32mand\u001b[0m \u001b[0mVersion\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mparse\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mserver_version\u001b[0m\u001b[0;34m)\u001b[0m \u001b[0;34m>=\u001b[0m \u001b[0mVersion\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;36m3\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0;36m2\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n",
      "\u001b[0;32m/anaconda3/envs/mlenv/lib/python3.7/site-packages/neobolt/direct.py\u001b[0m in \u001b[0;36macquire_direct\u001b[0;34m(self, address)\u001b[0m\n\u001b[1;32m    606\u001b[0m                 \u001b[0;32mif\u001b[0m \u001b[0mcan_create_new_connection\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    607\u001b[0m                     \u001b[0;32mtry\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m--> 608\u001b[0;31m                         \u001b[0mconnection\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mconnector\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0maddress\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0merror_handler\u001b[0m\u001b[0;34m=\u001b[0m\u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mconnection_error_handler\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m    609\u001b[0m                     \u001b[0;32mexcept\u001b[0m \u001b[0mServiceUnavailable\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    610\u001b[0m                         \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mremove\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0maddress\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n",
      "\u001b[0;32m/anaconda3/envs/mlenv/lib/python3.7/site-packages/neo4j/__init__.py\u001b[0m in \u001b[0;36mconnector\u001b[0;34m(address, **kwargs)\u001b[0m\n\u001b[1;32m    272\u001b[0m \u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    273\u001b[0m         \u001b[0;32mdef\u001b[0m \u001b[0mconnector\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0maddress\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0;34m**\u001b[0m\u001b[0mkwargs\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m--> 274\u001b[0;31m             \u001b[0;32mreturn\u001b[0m \u001b[0mconnect\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0maddress\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0;34m**\u001b[0m\u001b[0mdict\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mconfig\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0;34m**\u001b[0m\u001b[0mkwargs\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m    275\u001b[0m \u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    276\u001b[0m         \u001b[0mpool\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0mRoutingConnectionPool\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mconnector\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0minitial_address\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0mrouting_context\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0minitial_address\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0;34m**\u001b[0m\u001b[0mconfig\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n",
      "\u001b[0;32m/anaconda3/envs/mlenv/lib/python3.7/site-packages/neobolt/direct.py\u001b[0m in \u001b[0;36mconnect\u001b[0;34m(address, **config)\u001b[0m\n\u001b[1;32m    970\u001b[0m         \u001b[0;32mraise\u001b[0m \u001b[0mServiceUnavailable\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m\"Failed to resolve addresses for %s\"\u001b[0m \u001b[0;34m%\u001b[0m \u001b[0maddress\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    971\u001b[0m     \u001b[0;32melse\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m--> 972\u001b[0;31m         \u001b[0;32mraise\u001b[0m \u001b[0mlast_error\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m",
      "\u001b[0;32m/anaconda3/envs/mlenv/lib/python3.7/site-packages/neobolt/direct.py\u001b[0m in \u001b[0;36mconnect\u001b[0;34m(address, **config)\u001b[0m\n\u001b[1;32m    961\u001b[0m             \u001b[0mhost\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0maddress\u001b[0m\u001b[0;34m[\u001b[0m\u001b[0;36m0\u001b[0m\u001b[0;34m]\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    962\u001b[0m             \u001b[0ms\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0m_connect\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mresolved_address\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0;34m**\u001b[0m\u001b[0mconfig\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m--> 963\u001b[0;31m             \u001b[0ms\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0mder_encoded_server_certificate\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0m_secure\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0ms\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0mhost\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0msecurity_plan\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mssl_context\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0;34m**\u001b[0m\u001b[0mconfig\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m    964\u001b[0m             \u001b[0mconnection\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0m_handshake\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0ms\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0maddress\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0mder_encoded_server_certificate\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0;34m**\u001b[0m\u001b[0mconfig\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    965\u001b[0m         \u001b[0;32mexcept\u001b[0m \u001b[0mException\u001b[0m \u001b[0;32mas\u001b[0m \u001b[0merror\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n",
      "\u001b[0;32m/anaconda3/envs/mlenv/lib/python3.7/site-packages/neobolt/direct.py\u001b[0m in \u001b[0;36m_secure\u001b[0;34m(s, host, ssl_context, **config)\u001b[0m\n\u001b[1;32m    852\u001b[0m         \u001b[0mlog_debug\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m\"[#%04X]  C: <SECURE> %s\"\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0mlocal_port\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0mhost\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    853\u001b[0m         \u001b[0;32mtry\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m--> 854\u001b[0;31m             \u001b[0ms\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0mssl_context\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mwrap_socket\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0ms\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0mserver_hostname\u001b[0m\u001b[0;34m=\u001b[0m\u001b[0mhost\u001b[0m \u001b[0;32mif\u001b[0m \u001b[0mHAS_SNI\u001b[0m \u001b[0;32mand\u001b[0m \u001b[0mhost\u001b[0m \u001b[0;32melse\u001b[0m \u001b[0;32mNone\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m    855\u001b[0m         \u001b[0;32mexcept\u001b[0m \u001b[0mSSLError\u001b[0m \u001b[0;32mas\u001b[0m \u001b[0mcause\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    856\u001b[0m             \u001b[0ms\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mclose\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n",
      "\u001b[0;32m/anaconda3/envs/mlenv/lib/python3.7/ssl.py\u001b[0m in \u001b[0;36mwrap_socket\u001b[0;34m(self, sock, server_side, do_handshake_on_connect, suppress_ragged_eofs, server_hostname, session)\u001b[0m\n\u001b[1;32m    421\u001b[0m             \u001b[0mserver_hostname\u001b[0m\u001b[0;34m=\u001b[0m\u001b[0mserver_hostname\u001b[0m\u001b[0;34m,\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    422\u001b[0m             \u001b[0mcontext\u001b[0m\u001b[0;34m=\u001b[0m\u001b[0mself\u001b[0m\u001b[0;34m,\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m--> 423\u001b[0;31m             \u001b[0msession\u001b[0m\u001b[0;34m=\u001b[0m\u001b[0msession\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m    424\u001b[0m         )\n\u001b[1;32m    425\u001b[0m \u001b[0;34m\u001b[0m\u001b[0m\n",
      "\u001b[0;32m/anaconda3/envs/mlenv/lib/python3.7/ssl.py\u001b[0m in \u001b[0;36m_create\u001b[0;34m(cls, sock, server_side, do_handshake_on_connect, suppress_ragged_eofs, server_hostname, context, session)\u001b[0m\n\u001b[1;32m    868\u001b[0m                         \u001b[0;31m# non-blocking\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    869\u001b[0m                         \u001b[0;32mraise\u001b[0m \u001b[0mValueError\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m\"do_handshake_on_connect should not be specified for non-blocking sockets\"\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m--> 870\u001b[0;31m                     \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mdo_handshake\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m    871\u001b[0m             \u001b[0;32mexcept\u001b[0m \u001b[0;34m(\u001b[0m\u001b[0mOSError\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0mValueError\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    872\u001b[0m                 \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mclose\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n",
      "\u001b[0;32m/anaconda3/envs/mlenv/lib/python3.7/ssl.py\u001b[0m in \u001b[0;36mdo_handshake\u001b[0;34m(self, block)\u001b[0m\n\u001b[1;32m   1137\u001b[0m             \u001b[0;32mif\u001b[0m \u001b[0mtimeout\u001b[0m \u001b[0;34m==\u001b[0m \u001b[0;36m0.0\u001b[0m \u001b[0;32mand\u001b[0m \u001b[0mblock\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m   1138\u001b[0m                 \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0msettimeout\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;32mNone\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m-> 1139\u001b[0;31m             \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0m_sslobj\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mdo_handshake\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m   1140\u001b[0m         \u001b[0;32mfinally\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m   1141\u001b[0m             \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0msettimeout\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mtimeout\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n",
      "\u001b[0;31mOSError\u001b[0m: [Errno 0] Error"
     ]
    }
   ],
   "source": [
    "db = WalletDB( \"neo4j://localhost:7687\" , \"neo4j\" , \"wallet\" )\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 140,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "<Record a=<Path start=<Node id=14 labels={'address'} properties={'address': 'test_address1', 'type': 'recipient', 'acc_index': 0, 'created': 1586244466132}> end=<Node id=14 labels={'address'} properties={'address': 'test_address1', 'type': 'recipient', 'acc_index': 0, 'created': 1586244466132}> size=0>>\n",
      "<Record a=<Path start=<Node id=15 labels={'address'} properties={'address': 'test_address2', 'type': 'recipient', 'acc_index': 777, 'created': 1586244466145}> end=<Node id=15 labels={'address'} properties={'address': 'test_address2', 'type': 'recipient', 'acc_index': 777, 'created': 1586244466145}> size=0>>\n",
      "<Record a=<Path start=<Node id=0 labels={'address'} properties={'address': 'test_address3', 'type': 'recipient', 'acc_index': 22222, 'created': 1586244466152}> end=<Node id=0 labels={'address'} properties={'address': 'test_address3', 'type': 'recipient', 'acc_index': 22222, 'created': 1586244466152}> size=0>>\n",
      "<Record a=<Path start=<Node id=8 labels={'address'} properties={'address': 'test_address4', 'type': 'change', 'acc_index': 92747, 'created': 1586244466161}> end=<Node id=8 labels={'address'} properties={'address': 'test_address4', 'type': 'change', 'acc_index': 92747, 'created': 1586244466161}> size=0>>\n",
      "<Record a=<Path start=<Node id=2 labels={'address'} properties={'address': 'test_address5', 'type': 'change', 'acc_index': 99199191, 'created': 1586244466169}> end=<Node id=2 labels={'address'} properties={'address': 'test_address5', 'type': 'change', 'acc_index': 99199191, 'created': 1586244466169}> size=0>>\n",
      "<Record a=<Path start=<Node id=3 labels={'address'} properties={'address': 'test_address6', 'type': 'change', 'acc_index': 666, 'created': 1586244466181}> end=<Node id=3 labels={'address'} properties={'address': 'test_address6', 'type': 'change', 'acc_index': 666, 'created': 1586244466181}> size=0>>\n",
      "<Record a=<Path start=<Node id=5 labels={'address'} properties={'address': 'test_address7', 'type': 'change', 'acc_index': 625, 'created': 1586244466188}> end=<Node id=5 labels={'address'} properties={'address': 'test_address7', 'type': 'change', 'acc_index': 625, 'created': 1586244466188}> size=0>>\n"
     ]
    }
   ],
   "source": [
    "db.new_address(\"test_address1\",0,False)\n",
    "db.new_address(\"test_address2\",777,False)\n",
    "db.new_address(\"test_address3\",22222,False)\n",
    "db.new_address(\"test_address4\",92747,True)\n",
    "db.new_address(\"test_address5\",99199191,True)\n",
    "db.new_address(\"test_address6\",666,True)\n",
    "db.new_address(\"test_address7\",625,True)"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 141,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "<Record p=<Path start=<Node id=6 labels={'utxo'} properties={'transaction_id': 1000, 'out_index': 2, 'local_index': 0, 'address': 'test_address1', 'spent': False}> end=<Node id=14 labels={'address'} properties={'address': 'test_address1', 'type': 'recipient', 'created': 1586244466132, 'acc_index': 0}> size=1>>\n",
      "<Record p=<Path start=<Node id=7 labels={'utxo'} properties={'transaction_id': 1001, 'out_index': 0, 'local_index': 1, 'address': 'test_address2', 'spent': False}> end=<Node id=15 labels={'address'} properties={'address': 'test_address2', 'type': 'recipient', 'created': 1586244466145, 'acc_index': 777}> size=1>>\n",
      "<Record p=<Path start=<Node id=9 labels={'utxo'} properties={'transaction_id': 1002, 'out_index': 1, 'local_index': 2, 'address': 'test_address3', 'spent': False}> end=<Node id=0 labels={'address'} properties={'address': 'test_address3', 'type': 'recipient', 'created': 1586244466152, 'acc_index': 22222}> size=1>>\n",
      "<Record p=<Path start=<Node id=10 labels={'utxo'} properties={'transaction_id': 1003, 'out_index': 8, 'local_index': 3, 'address': 'test_address4', 'spent': False}> end=<Node id=8 labels={'address'} properties={'address': 'test_address4', 'type': 'change', 'created': 1586244466161, 'acc_index': 92747}> size=1>>\n",
      "<Record p=<Path start=<Node id=11 labels={'utxo'} properties={'transaction_id': 1004, 'out_index': 5, 'local_index': 4, 'address': 'test_address5', 'spent': False}> end=<Node id=2 labels={'address'} properties={'address': 'test_address5', 'type': 'change', 'created': 1586244466169, 'acc_index': 99199191}> size=1>>\n"
     ]
    }
   ],
   "source": [
    "db.new_utxo(\"test_address1\",1000,2)\n",
    "db.new_utxo(\"test_address2\",1001,0)\n",
    "db.new_utxo(\"test_address3\",1002,1)\n",
    "db.new_utxo(\"test_address4\",1003,8)\n",
    "db.new_utxo(\"test_address5\",1004,5)"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 142,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "None\n"
     ]
    }
   ],
   "source": [
    "db.new_tx(2222,[0,1], [\"ouptut1\",\"output2\"])"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 143,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "<Record n=<Node id=12 labels={'TxOut'} properties={'outputs': ['ouptut1', 'output2'], 'id': 2222, 'confirmations': 7, 'created': 1586244466250, 'inputs': [0, 1]}>>\n"
     ]
    }
   ],
   "source": [
    "db.update_confirmations(2222,7)"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 144,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "<neo4j.BoltStatementResultSummary object at 0x114dffe90>\n"
     ]
    }
   ],
   "source": [
    "up = db.update_utxo(2222)"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 145,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "None\n"
     ]
    }
   ],
   "source": [
    "db.clean_addresses()"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 161,
   "metadata": {},
   "outputs": [],
   "source": [
    "add = db.look_for_coins()"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 162,
   "metadata": {},
   "outputs": [
    {
     "data": {
      "text/plain": [
       "[{'coin.transaction_id': 1002,\n",
       "  'coin.out_index': 1,\n",
       "  'coin.address': 'test_address3'},\n",
       " {'coin.transaction_id': 1003,\n",
       "  'coin.out_index': 8,\n",
       "  'coin.address': 'test_address4'},\n",
       " {'coin.transaction_id': 1004,\n",
       "  'coin.out_index': 5,\n",
       "  'coin.address': 'test_address5'}]"
      ]
     },
     "execution_count": 162,
     "metadata": {},
     "output_type": "execute_result"
    }
   ],
   "source": [
    "add"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 168,
   "metadata": {},
   "outputs": [
    {
     "data": {
      "text/plain": [
       "[{'unused_address.address': 'test_address6',\n",
       "  'unused_address.acc_index': 666,\n",
       "  'unused_address.type': 'change'},\n",
       " {'unused_address.address': 'test_address7',\n",
       "  'unused_address.acc_index': 625,\n",
       "  'unused_address.type': 'change'}]"
      ]
     },
     "execution_count": 168,
     "metadata": {},
     "output_type": "execute_result"
    }
   ],
   "source": [
    "unused_add = db.get_unused_addresses()\n",
    "unused_add"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {},
   "outputs": [],
   "source": []
  },
  {
   "cell_type": "code",
   "execution_count": 4,
   "metadata": {},
   "outputs": [],
   "source": [
    "driver = GraphDatabase.driver(\"neo4j://localhost:7687\" , auth=(\"neo4j\", \"wallet\"), encrypted=False)"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 30,
   "metadata": {},
   "outputs": [
    {
     "ename": "CypherSyntaxError",
     "evalue": "Invalid input ':': expected <init> (line 1, column 1 (offset: 0))\n\":use system RETURN a\"\n ^",
     "output_type": "error",
     "traceback": [
      "\u001b[0;31m---------------------------------------------------------------------------\u001b[0m",
      "\u001b[0;31mCypherSyntaxError\u001b[0m                         Traceback (most recent call last)",
      "\u001b[0;32m<ipython-input-30-10bdc7ead2db>\u001b[0m in \u001b[0;36m<module>\u001b[0;34m\u001b[0m\n\u001b[0;32m----> 1\u001b[0;31m \u001b[0mdb\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mrun_as_system\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m",
      "\u001b[0;32m<ipython-input-28-d56acf4b4236>\u001b[0m in \u001b[0;36mrun_as_system\u001b[0;34m(self)\u001b[0m\n\u001b[1;32m    123\u001b[0m     \u001b[0;32mdef\u001b[0m \u001b[0mrun_as_system\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mself\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    124\u001b[0m         \u001b[0;32mwith\u001b[0m \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0m_driver\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0msession\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m \u001b[0;32mas\u001b[0m \u001b[0msession\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m--> 125\u001b[0;31m             \u001b[0msession\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mwrite_transaction\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0m_run_as_system\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m    126\u001b[0m \u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    127\u001b[0m \u001b[0;34m\u001b[0m\u001b[0m\n",
      "\u001b[0;32m/anaconda3/envs/mlenv/lib/python3.7/site-packages/neo4j/__init__.py\u001b[0m in \u001b[0;36mwrite_transaction\u001b[0;34m(self, unit_of_work, *args, **kwargs)\u001b[0m\n\u001b[1;32m    716\u001b[0m     \u001b[0;32mdef\u001b[0m \u001b[0mwrite_transaction\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mself\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0munit_of_work\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0;34m*\u001b[0m\u001b[0margs\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0;34m**\u001b[0m\u001b[0mkwargs\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    717\u001b[0m         \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0m_assert_open\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m--> 718\u001b[0;31m         \u001b[0;32mreturn\u001b[0m \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0m_run_transaction\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mWRITE_ACCESS\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0munit_of_work\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0;34m*\u001b[0m\u001b[0margs\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0;34m**\u001b[0m\u001b[0mkwargs\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m    719\u001b[0m \u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    720\u001b[0m     \u001b[0;32mdef\u001b[0m \u001b[0m_assert_open\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mself\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n",
      "\u001b[0;32m/anaconda3/envs/mlenv/lib/python3.7/site-packages/neo4j/__init__.py\u001b[0m in \u001b[0;36m_run_transaction\u001b[0;34m(self, access_mode, unit_of_work, *args, **kwargs)\u001b[0m\n\u001b[1;32m    688\u001b[0m                         \u001b[0mtx\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0msuccess\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0;32mTrue\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    689\u001b[0m                 \u001b[0;32mfinally\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m--> 690\u001b[0;31m                     \u001b[0mtx\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mclose\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m    691\u001b[0m             \u001b[0;32mexcept\u001b[0m \u001b[0;34m(\u001b[0m\u001b[0mServiceUnavailable\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0mSessionExpired\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0mConnectionExpired\u001b[0m\u001b[0;34m)\u001b[0m \u001b[0;32mas\u001b[0m \u001b[0merror\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    692\u001b[0m                 \u001b[0merrors\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mappend\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0merror\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n",
      "\u001b[0;32m/anaconda3/envs/mlenv/lib/python3.7/site-packages/neo4j/__init__.py\u001b[0m in \u001b[0;36mclose\u001b[0;34m(self)\u001b[0m\n\u001b[1;32m    830\u001b[0m         \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0m_assert_open\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    831\u001b[0m         \u001b[0;32mtry\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m--> 832\u001b[0;31m             \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0msync\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m    833\u001b[0m         \u001b[0;32mexcept\u001b[0m \u001b[0mCypherError\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    834\u001b[0m             \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0msuccess\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0;32mFalse\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n",
      "\u001b[0;32m/anaconda3/envs/mlenv/lib/python3.7/site-packages/neo4j/__init__.py\u001b[0m in \u001b[0;36msync\u001b[0;34m(self)\u001b[0m\n\u001b[1;32m    795\u001b[0m         \"\"\"\n\u001b[1;32m    796\u001b[0m         \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0m_assert_open\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m--> 797\u001b[0;31m         \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0msession\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0msync\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m    798\u001b[0m \u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    799\u001b[0m     \u001b[0;32mdef\u001b[0m \u001b[0mcommit\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mself\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n",
      "\u001b[0;32m/anaconda3/envs/mlenv/lib/python3.7/site-packages/neo4j/__init__.py\u001b[0m in \u001b[0;36msync\u001b[0;34m(self)\u001b[0m\n\u001b[1;32m    540\u001b[0m         \u001b[0;32mif\u001b[0m \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0m_connection\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    541\u001b[0m             \u001b[0;32mtry\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m--> 542\u001b[0;31m                 \u001b[0mdetail_count\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0m_\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0m_connection\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0msync\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m    543\u001b[0m             \u001b[0;32mexcept\u001b[0m \u001b[0mConnectionExpired\u001b[0m \u001b[0;32mas\u001b[0m \u001b[0merror\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    544\u001b[0m                 \u001b[0;32mraise\u001b[0m \u001b[0mSessionExpired\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m*\u001b[0m\u001b[0merror\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0margs\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n",
      "\u001b[0;32m/anaconda3/envs/mlenv/lib/python3.7/site-packages/neobolt/direct.py\u001b[0m in \u001b[0;36msync\u001b[0;34m(self)\u001b[0m\n\u001b[1;32m    525\u001b[0m             \u001b[0mresponse\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mresponses\u001b[0m\u001b[0;34m[\u001b[0m\u001b[0;36m0\u001b[0m\u001b[0;34m]\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    526\u001b[0m             \u001b[0;32mwhile\u001b[0m \u001b[0;32mnot\u001b[0m \u001b[0mresponse\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mcomplete\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m--> 527\u001b[0;31m                 \u001b[0mdetail_delta\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0msummary_delta\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mfetch\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m    528\u001b[0m                 \u001b[0mdetail_count\u001b[0m \u001b[0;34m+=\u001b[0m \u001b[0mdetail_delta\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    529\u001b[0m                 \u001b[0msummary_count\u001b[0m \u001b[0;34m+=\u001b[0m \u001b[0msummary_delta\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n",
      "\u001b[0;32m/anaconda3/envs/mlenv/lib/python3.7/site-packages/neobolt/direct.py\u001b[0m in \u001b[0;36mfetch\u001b[0;34m(self)\u001b[0m\n\u001b[1;32m    417\u001b[0m     \u001b[0;32mdef\u001b[0m \u001b[0mfetch\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mself\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    418\u001b[0m         \u001b[0;32mtry\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m--> 419\u001b[0;31m             \u001b[0;32mreturn\u001b[0m \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0m_fetch\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m    420\u001b[0m         \u001b[0;32mexcept\u001b[0m \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0merror_handler\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mknown_errors\u001b[0m \u001b[0;32mas\u001b[0m \u001b[0merror\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    421\u001b[0m             \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0merror_handler\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mhandle\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0merror\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0munresolved_address\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n",
      "\u001b[0;32m/anaconda3/envs/mlenv/lib/python3.7/site-packages/neobolt/direct.py\u001b[0m in \u001b[0;36m_fetch\u001b[0;34m(self)\u001b[0m\n\u001b[1;32m    459\u001b[0m         \u001b[0;32melif\u001b[0m \u001b[0msummary_signature\u001b[0m \u001b[0;34m==\u001b[0m \u001b[0;34mb\"\\x7F\"\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    460\u001b[0m             \u001b[0mlog_debug\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m\"[#%04X]  S: FAILURE %r\"\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mlocal_port\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0msummary_metadata\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m--> 461\u001b[0;31m             \u001b[0mresponse\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mon_failure\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0msummary_metadata\u001b[0m \u001b[0;32mor\u001b[0m \u001b[0;34m{\u001b[0m\u001b[0;34m}\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m    462\u001b[0m         \u001b[0;32melse\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    463\u001b[0m             \u001b[0;32mraise\u001b[0m \u001b[0mProtocolError\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m\"Unexpected response message with signature %02X\"\u001b[0m \u001b[0;34m%\u001b[0m \u001b[0msummary_signature\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n",
      "\u001b[0;32m/anaconda3/envs/mlenv/lib/python3.7/site-packages/neobolt/direct.py\u001b[0m in \u001b[0;36mon_failure\u001b[0;34m(self, metadata)\u001b[0m\n\u001b[1;32m    753\u001b[0m         \u001b[0;32mif\u001b[0m \u001b[0mcallable\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mhandler\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    754\u001b[0m             \u001b[0mhandler\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m--> 755\u001b[0;31m         \u001b[0;32mraise\u001b[0m \u001b[0mCypherError\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mhydrate\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;34m**\u001b[0m\u001b[0mmetadata\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m\u001b[1;32m    756\u001b[0m \u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m    757\u001b[0m     \u001b[0;32mdef\u001b[0m \u001b[0mon_ignored\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mself\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0mmetadata\u001b[0m\u001b[0;34m=\u001b[0m\u001b[0;32mNone\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n",
      "\u001b[0;31mCypherSyntaxError\u001b[0m: Invalid input ':': expected <init> (line 1, column 1 (offset: 0))\n\":use system RETURN a\"\n ^"
     ]
    }
   ],
   "source": [
    "db.run_as_system()"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "trying to recover file from backup.\n",
      "succesfully recovered file from backup. Restored original file.\n",
      "9011520\n"
     ]
    }
   ],
   "source": [
    "import subprocess\n",
    "import os\n",
    "def parse_demo(file):\n",
    "    \n",
    "    with open(f\"blocks_demo/{file}\",\"br\") as blockfile:\n",
    "        c = 0\n",
    "        try:\n",
    "            coursor = open(\"blocks_demo/blk00000.txt\")\n",
    "            c = coursor.readline()\n",
    "            try:\n",
    "                c = int(c)\n",
    "            except:\n",
    "                if c == \"finished\":\n",
    "                    print(c)\n",
    "                    return True\n",
    "                else:\n",
    "                    try: \n",
    "                        print(\"trying to recover file from backup.\")\n",
    "                        coursor = open(\"blocks_demo/blk00000.txt.bck\")\n",
    "                        c = coursor.readline()\n",
    "                        try:\n",
    "                            c = int(c)\n",
    "                            subprocess.call(f\" cp blocks_demo/blk00000.txt.bck blocks_demo/blk00000.txt\", shell=True)\n",
    "                            print(\"succesfully recovered file from backup. Restored original file.\")\n",
    "                        except:\n",
    "                            if c == \"finished\":\n",
    "                                print(c)\n",
    "                                subprocess.call(f\" cp blocks_demo/blk00000.txt.bck blocks_demo/blk00000.txt\",shell=True)\n",
    "                                print(\"Finished. Succesfully updated original file.\")\n",
    "                                return True\n",
    "                            else:\n",
    "                                print(\"Corrupted coursor file.\")\n",
    "                                return False\n",
    "                        \n",
    "                    except:\n",
    "                        print(\"Corrupted coursor file.\")\n",
    "                        return False\n",
    "                            \n",
    "            print(c)\n",
    "            blockfile.read(c)\n",
    "            coursor.close()\n",
    "\n",
    "        except:\n",
    "            coursor  = open(\"blocks_demo/blk00000.txt\",\"w\")\n",
    "            print(\"No coursor file\")\n",
    "            coursor.write(\"\\n\"+str(c))\n",
    "            coursor.close()\n",
    "\n",
    "        #this is the while true in the parse block method:\n",
    "        while True:\n",
    "            ccc = blockfile.read(80)\n",
    "            if ccc == b'': \n",
    "                c = \"finished\"\n",
    "                coursor  = open(\"blocks_demo/blk00000.txt\",\"w\")\n",
    "                coursor.write(str(c)+f\"\\nLast block at {c} byte.\")\n",
    "                coursor.close()\n",
    "                print(f\"Last block at {prev}\\nFinished file {file}.\")\n",
    "                return True\n",
    "            else:c+=80\n",
    "            coursor  = open(\"blocks_demo/blk00000.txt\",\"w\")\n",
    "            coursor.write(str(c))\n",
    "            coursor.close()\n",
    "            subprocess.call(f\" cp blocks_demo/blk00000.txt blocks_demo/blk00000.txt.bck\",shell=True)\n",
    "    \n",
    "parse_demo(\"blk00000.dat\")        "
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 21,
   "metadata": {
    "collapsed": true,
    "jupyter": {
     "outputs_hidden": true
    }
   },
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "\n",
      "\n",
      "b'\\xf9\\xbe\\xb4\\xd9\\x1d\\x01\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00;\\xa3\\xed\\xfdz{\\x12\\xb2z\\xc7,>gv\\x8fa\\x7f\\xc8\\x1b\\xc3\\x88\\x8aQ2:\\x9f\\xb8\\xaaK\\x1e^J)\\xab_I\\xff\\xff\\x00\\x1d\\x1d\\xac+|\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00'\n",
      "\n",
      "\n",
      "b'\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xffM\\x04\\xff\\xff\\x00\\x1d\\x01\\x04EThe Times 03/Jan/2009 Chancellor on brink of second bailout f'\n",
      "\n",
      "\n",
      "b\"or banks\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04g\\x8a\\xfd\\xb0\\xfeUH'\\x19g\\xf1\\xa6q0\\xb7\\x10\\\\\\xd6\\xa8(\\xe09\\t\\xa6yb\\xe0\\xea\\x1fa\\xde\\xb6I\\xf6\\xbc?L\\xef8\\xc4\\xf3U\\x04\\xe5\\x1e\\xc1\\x12\\xde\\\\8M\\xf7\\xba\\x0b\\x8dW\\x8aLp+k\\xf1\\x1d_\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\"\n",
      "\n",
      "\n",
      "b'\\x00\\x01\\x00\\x00\\x00o\\xe2\\x8c\\n\\xb6\\xf1\\xb3r\\xc1\\xa6\\xa2F\\xaec\\xf7O\\x93\\x1e\\x83e\\xe1Z\\x08\\x9ch\\xd6\\x19\\x00\\x00\\x00\\x00\\x00\\x98 Q\\xfd\\x1eK\\xa7D\\xbb\\xbeh\\x0e\\x1f\\xee\\x14g{\\xa1\\xa3\\xc3T\\x0b\\xf7\\xb1\\xcd\\xb6\\x06\\xe8W#>\\x0ea\\xbcfI\\xff\\xff\\x00\\x1d\\x01\\xe3b\\x99\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00'\n",
      "\n",
      "\n",
      "b'\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x01\\x04\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04\\x96\\xb58\\xe8SQ\\x9crj,\\x91\\xe6\\x1e\\xc1\\x16\\x00\\xae\\x13\\x90\\x81:b|f\\xfb\\x8b\\xe7\\x94{\\xe6<R\\xdau\\x897\\x95\\x15\\xd4\\xe0\\xa6\\x04\\xf8\\x14\\x17\\x81\\xe6\"\\x94r\\x11f\\xbf'\n",
      "\n",
      "\n",
      "b'b\\x1es\\xa8,\\xbf#B\\xc8X\\xee\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00H`\\xeb\\x18\\xbf\\x1b\\x16 \\xe3~\\x94\\x90\\xfc\\x8aBu\\x14Ao\\xd7QY\\xab\\x86h\\x8e\\x9a\\x83\\x00\\x00\\x00\\x00\\xd5\\xfd\\xccT\\x1e%\\xde\\x1czZ\\xdd\\xed\\xf2HX\\xb8\\xbbf\\\\\\x9f6\\xeftN\\xe4,1`\"\\xc9\\x0f\\x9b\\xb0\\xbcfI\\xff\\xff\\x00\\x1d'\n",
      "\n",
      "\n",
      "b'\\x08\\xd2\\xbda\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x01\\x0b\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04r\\x11\\xa8$\\xf5[PR(\\xe4\\xc3\\xd5\\x19L\\x1f\\xcf\\xaa\\x15\\xa4V\\xab\\xdf7\\xf9\\xb9\\xd9z@@\\xaf'\n",
      "\n",
      "\n",
      "b'\\xc0s\\xde\\xe6\\xc8\\x90d\\x98O\\x038R7\\xd9!g\\xc1>#dF\\xb4\\x17\\xaby\\xa0\\xfc\\xaeA*\\xe31kw\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\xbd\\xdd\\x99\\xcc\\xfd\\xa3\\x9d\\xa1\\xb1\\x08\\xce\\x1a]p\\x03\\x8d\\n\\x96{\\xac\\xb6\\x8bkc\\x06_bj\\x00\\x00\\x00\\x00D\\xf6r\"`\\x90\\xd8]\\xb9\\xa9\\xf2\\xfb\\xfe_\\x0f\\x96\\t'\n",
      "\n",
      "\n",
      "b'\\xb3\\x87\\xaf{\\xe5\\xb7\\xfb\\xb7\\xa1v|\\x83\\x1c\\x9e\\x99]\\xbefI\\xff\\xff\\x00\\x1d\\x05\\xe0\\xedm\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x01\\x0e\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04\\x94\\xb9\\xd3\\xe7l[\\x16'\n",
      "\n",
      "\n",
      "b\")\\xec\\xf9\\x7f\\xff\\x95\\xd7\\xa4\\xbb\\xda\\xc8|\\xc2`\\x99\\xad\\xa2\\x80f\\xc6\\xff\\x1e\\xb9\\x19\\x12#\\xcd\\x89q\\x94\\xa0\\x8d\\x0c'&\\xc5t\\x7f\\x1d\\xb4\\x9e\\x8c\\xf9\\x0eu\\xdc>5P\\xae\\x9b0\\x08o<\\xd5\\xaa\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00IDF\\x95b\\xae\\x1c,t\\xd9\\xa55\\xe0\\x0bo>@\\xff\\xba\\xd4\\xf2\\xfd\\xa3\\x89U\\x01\"\n",
      "\n",
      "\n",
      "b'\\xb5\\x82\\x00\\x00\\x00\\x00z\\x06\\xea\\x98\\xcd@\\xba.2\\x88&+(c\\x8c\\xecS7\\xc1Ej\\xaf^\\xed\\xc8\\xe9\\xe5\\xa2\\x0f\\x06+\\xdf\\x8c\\xc1fI\\xff\\xff\\x00\\x1d+\\xfe\\xe0\\xa9\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x01\\x1a'\n",
      "\n",
      "\n",
      "b'\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04\\x18O2\\xb2\\x12\\x81\\\\nR.fhc$\\x03\\x0f\\xf7\\xe5\\xbf\\x08\\xef\\xb2\\x1f\\x8b\\x00aO\\xb7i\\x0e\\x19\\x13\\x1d\\xd3\\x13\\x04\\xc5O7\\xba\\xa4\\r\\xb21\\xc9\\x18\\x10k\\xb9\\xfdC7>7\\xae1\\xa0\\xbe\\xfcn\\xca\\xef\\xb8g\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x85\\x14J'\n",
      "\n",
      "\n",
      "b'\\x84H\\x8e\\xa8\\x8d\"\\x1c\\x8b\\xd6\\xc0Y\\xda\\t\\x0e\\x88\\xf8\\xa2\\xc9\\x96\\x90\\xeeU\\xdb\\xbaN\\x00\\x00\\x00\\x00\\xe1\\x1cH\\xfe\\xcd\\xd9\\xe7%\\x10\\xca\\x84\\xf0#7\\x0c\\x9a8\\xbf\\x91\\xac\\\\\\xae\\x88\\x01\\x9b\\xee\\x94\\xd2E(RcD\\xc3fI\\xff\\xff\\x00\\x1d\\x1d\\x03\\xe4w\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00'\n",
      "\n",
      "\n",
      "b'\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x01 \\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04VW\\x956\\xd1P\\xfb\\xce\\x94\\xeeb\\xb4}\\xb2\\xcaC\\xaf\\ns\\n\\x04g\\xbaU\\xc7\\x9e*~\\xc9\\xceJ\\xd2\\x97\\xe3\\\\\\xdb\\xb8\\xe4*FC\\xa6\\x0e\\xef|\\x9a\\xbe\\xe2\\xf5\\x82/\\x86\\xb1\\xda$-\\x9c#\\x01\\xc41'\n",
      "\n",
      "\n",
      "b'\\xfa\\xcf\\xd8\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\xfc3\\xf5\\x96\\xf8\"\\xa0\\xa1\\x95\\x1f\\xfd\\xbf*\\x89{\\tV6\\xad\\x87\\x17\\x07\\xbf]1br\\x9b\\x00\\x00\\x00\\x007\\x9d\\xfb\\x96\\xa5\\xea\\x8c\\x81p\\x0e\\xa4\\xack\\x97\\xae\\x9a\\x93\\x12\\xb2\\xd40\\x1a)X\\x0e\\x92N\\xe6v\\x1a% \\xad\\xc4fI\\xff\\xff\\x00\\x1d\\x18\\x9cL\\x97\\x01\\x01\\x00\\x00'\n",
      "\n",
      "\n",
      "b\"\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x01#\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04\\x08\\xce'\\x91t\\xb3L\\x07|{ C\\xe3\\xf3\\xd4ZX\\x8b\\x85\\xefL\\xa4ft\\x0f\\x84\\x8e\\xad\\x7f\\xb4\\x98\\xf0\\xa7\\x95\\xc9\\x82U/\"\n",
      "\n",
      "\n",
      "b'\\xdf\\xa4\\x16\\x16\\xa7\\xc03:&\\x9db\\x10\\x85\\x88\\xe2`\\xfdZH\\xac\\x8eM\\xbfI\\xe2\\xbc\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x8dw\\x8f\\xdc\\x15\\xa2\\xd3\\xfbv\\xb7\\x12*;U\\x82\\xbe\\xa4\\xf2\\x1fZ\\x0ci57\\xe7\\xa010\\x00\\x00\\x00\\x00?g@\\x05\\x10;B\\xf9\\x84\\x16\\x9c}\\x00\\x83p\\x96~\\x91\\x92\\nj]d\\xfdQ'\n",
      "\n",
      "\n",
      "b'(/u\\xbcs\\xa6\\x8a\\xf1\\xc6fI\\xff\\xff\\x00\\x1d9\\xa5\\x9c\\x86\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x01+\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04\\xa5\\x9ed\\xc7t\\x92=\\x00?\\xaet\\x91\\xb2\\xa7\\xf7'\n",
      "\n",
      "\n",
      "b']kz\\xa3\\xf3V\\x06\\xa8\\xff\\x1c\\xf0l\\xd31}\\x16\\xa4\\x1a\\xa1i(\\xb1\\xdf\\x1fc\\x1f1\\xf2\\x8c}\\xa3]N\\xda\\xd3`:\\xdb#8\\xc4\\xd4\\xdd&\\x8f1S\\x05U\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00D\\x94\\xc8\\xcfAT\\xbd\\xcc\\x07 \\xcdJY\\xd9\\xc9\\xb2\\x85\\xe4\\xb1F\\xd4_\\x06\\x1d+l\\x96q\\x00\\x00\\x00\\x00\\xe3\\x85'\n",
      "\n",
      "\n",
      "b'^\\xd8\\x86`[mJ\\x99\\xd5\\xfa.\\xf2\\xe9\\xb0\\xb1d\\xe6=\\xf3\\xc4\\x13k\\xeb\\xf2\\xd0\\xda\\xc0\\xf1\\xf7\\xa6g\\xc8fI\\xff\\xff\\x00\\x1d\\x1cKVf\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x01,\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05'\n",
      "\n",
      "\n",
      "b'*\\x01\\x00\\x00\\x00CA\\x04\\xcc\\x8d\\x85\\xf5\\xe7\\x93<\\xb1\\x8f\\x13\\xb9}\\x16^\\x11\\x89\\xc1\\xfb>\\x9c\\x98\\xb0\\xddTF\\xb2\\xa1\\x98\\x98\\x83\\xff\\x9et\\n\\x8au\\xda\\x99\\xccY\\xa2\\x10\\x16\\xca\\xf7\\xa7\\xaf\\xd3\\xe4\\xe9\\xe7\\x95)\\x83\\xe1\\x8d\\x1f\\xf7\\x05)\\xd6.\\x0b\\xa1\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\xc6\\r\\xde\\xf1\\xb7a\\x8c\\xa24\\x8aF'\n",
      "\n",
      "\n",
      "b'\\xe8h\\xaf\\xc2n>\\xfch\"lx\\xaaG\\xf8H\\x8c@\\x00\\x00\\x00\\x00\\xc9\\x97\\xa5\\xe5n\\x10A\\x02\\xfa \\x9cj\\x85-\\xd9\\x06`\\xa2\\x0b-\\x9c5$#\\xed\\xce%\\x85\\x7f\\xcd7\\x04\\x7f\\xcafI\\xff\\xff\\x00\\x1d(@OS\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00'\n",
      "\n",
      "\n",
      "b'\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x014\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04\\x11\\xdb\\x93\\xe1\\xdc\\xdb\\x8a\\x01kI\\x84\\x0f\\x8cS\\xbc\\x1e\\xb6\\x8a8.\\x97\\xb1H.\\xca\\xd7\\xb1H\\xa6\\x90\\x9a\\\\\\xb2\\xe0\\xea\\xdd\\xfb\\x84\\xcc\\xf9tDd\\xf8.\\x16\\x0b\\xfa\\x9b\\x8bd\\xf9\\xd4\\xc0?\\x99\\x9b\\x86C\\xf6V\\xb4\\x12\\xa3\\xac\\x00\\x00\\x00\\x00'\n",
      "\n",
      "\n",
      "b'\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x05\\x08\\x08\\\\G\\xcc\\x84\\x9e\\xb8\\x0e\\xa9\\x05\\xccx\\x00\\xa3\\xbegO\\xfcW&<\\xf2\\x10\\xc5\\x9d\\x8d\\x00\\x00\\x00\\x00\\x11+\\xa1u\\xa1\\xe0K\\x14\\xba\\x9e~\\xa5\\xf7j\\xb6@\\xaf\\xfe\\xef^\\xc9\\x81s\\xac\\x97\\x99\\xa8R\\xfa9\\xad\\xd3 \\xcdfI\\xff\\xff\\x00\\x1d\\x1e-\\xe5e\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00'\n",
      "\n",
      "\n",
      "b'\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x016\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04\\xfc\\xc2\\x88\\x8c\\xa9\\x1c\\xf0\\x10=\\x8cW\\x97\\xc2V\\xbf\\x97n\\x81\\xf2\\x80 ]\\x00-\\x85\\xb9\\xb6\"\\xed\\x1ao\\x82\\x08f\\xc7\\xb5\\xfe\\x12(\\\\\\xfax\\xc055]'\n",
      "\n",
      "\n",
      "b'u/\\xc9J9\\x8bgY}\\xc4\\xfb\\xb5\\xb3\\x86\\x81d%\\xdd\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\xe9\\x15\\xd9\\xa4x\\xe3\\xad\\xf3\\x18l\\x07\\xc6\\x1a\"\"\\x8b\\x10\\xfd\\x87\\xdf4<\\x92x.\\xcc\\x05,\\x00\\x00\\x00\\x00n\\x067<\\x80\\xde9t\\x06\\xdc=\\x19\\xc9\\rq\\xd20\\x05\\x8d()6\\x14\\xeaX\\xd6\\xa5\\x7f\\x8f]2\\xf8\\xb8'\n",
      "\n",
      "\n",
      "b'\\xcefI\\xff\\xff\\x00\\x1d\\x178\\x07\\xf8\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x01;\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04l\\xc8m\\xdc\\xd0\\x86\\x0b|\\xef\\x16\\xcb\\xaa\\xd7\\xfe1\\xfd\\xa1\\xbf\\x07<%\\xcb\\x83'\n",
      "\n",
      "\n",
      "b'?\\xa9\\xe4\\t\\xe7\\xf5\\x1e)o9\\xb6S\\xa9\\xc8\\x04\\n/\\x96s\\x19\\xff7\\xcf\\x14\\xb0\\x99\\x1b\\x86\\x174b\\xa2\\xd5\\x90|\\xb6\\xc5d\\x8b[v\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00s0\\xd7\\xad\\xf2a\\xc6\\x98\\x91\\xe6\\xab\\x086}\\x95~t\\xd4\\x04K\\xc5\\xd9\\xcd\\x06\\xd6V\\xbe\\x97\\x00\\x00\\x00\\x00\\xb8\\xc8uO\\xab\\xb0\\xff\\xeb\\x04\\xca'\n",
      "\n",
      "\n",
      "b'&:\\x13h\\xc3\\x9c\\x05\\x9c\\xa0\\xd4\\xaf1Q\\xb8v\\xf2~\\x19~\\xbb\\x96;\\xc8\\xd0fI\\xff\\xff\\x00\\x1d?Yj\\x0c\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x01\\x0c\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04'\n",
      "\n",
      "\n",
      "b'x\\xeb\\xe2\\xc2\\x86`\\xcd/\\xa1\\xba\\x17\\xcc\\x04\\xe5\\x8dc\\x12g\\x90\\x05\\xa7\\xca\\xd1\\xfdV\\xa7\\xb7\\xf4c\\x0b\\xd7\\x00\\xbc\\xdb\\x84\\xa8\\x88\\xa4?\\xe1\\xa2s\\x8e\\xa1\\xf3\\xd20\\x1d\\x02\\xfa\\xef5~\\x8a\\\\5\\xa7\\x06\\xe4\\xae\\x03R\\xa6\\xad\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00^+\\x80C\\xbd\\x9f\\x8d\\xb5X\\xc2\\x84\\xe0\\x0e\\xa2Ox\\x87\\x976'\n",
      "\n",
      "\n",
      "b\"\\xf4\\xac\\xd1\\x10%\\x8eH\\xc2'\\x00\\x00\\x00\\x00q\\xb2)\\x98\\x92\\x1e\\xfd\\xdf\\x90\\xc7Z\\xc3\\x15\\x1c\\xac\\xee\\x8f\\x80\\x84\\xd3\\xe9\\xcbd3$'\\xec\\x04\\xc7\\xd5b\\x99L\\xd1fI\\xff\\xff\\x00\\x1d7\\xd1\\xae\\x86\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\"\n",
      "\n",
      "\n",
      "b'\\x04\\xff\\xff\\x00\\x1d\\x01<\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04\\xc5\\xa6\\x8f_\\xa2\\x19+!P\\x16\\xc5\\xdf\\xb3\\x849\\x9a9GAe\\xee\\xa2&\\x03\\xcd9x\\x0ee;\\xaa\\xd9\\x10n6\\x94z\\x1b\\xa3\\xad]7\\x89\\xc5\\xce\\xad\\x18\\xa3\\x8aS\\x8a}\\x83J\\x8a+\\x9f\\x0e\\xa9F\\xfbNoh\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00'\n",
      "\n",
      "\n",
      "b'\\x01\\x00\\x00\\x00\\x890MK\\xa5T*\"\\xfbam\\x1c\\xa0\\x19\\xe9B\"\\xeeE\\xc1\\xad\\x95\\xa81 \\xdeQ\\\\\\x00\\x00\\x00\\x00V\\x01d\\xb8\\xba\\xd7gPa\\xaa\\x0fC\\xce\\xd7\\x18\\x88K\\xdd\\x85(\\xca\\xe0\\x7f$\\xc5\\x8b\\xb6\\x95\\x92\\xd8\\xaf\\xe1\\x85\\xd3fI\\xff\\xff\\x00\\x1d)\\xcb\\xad$\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00'\n",
      "\n",
      "\n",
      "b'\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x01>\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04>\\x8a\\xc6\\xb8\\xead\\xe8Y(\\xb6F\\x9f\\x17\\xdb\\x00\\x96\\xde\\x0b\\xca\\xe7\\xd0\\x9aD\\x97A=\\x9b\\xbaI\\xc0\\x0f\\xfd\\xf9\\xcb\\x0c\\xe0|@G\\x84\\x92\\x8b9v\\xf0\\xbe\\xeaB\\xfe&\\x91\\xa8\\xf0C'\n",
      "\n",
      "\n",
      "b\"\\x0b\\xcb+\\r\\xaa\\xf5\\xaa\\x02\\xb3\\x0e\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x007\\x8aoe\\x93\\xe2\\xf0%\\x112\\xd9f\\x16\\xe87\\xebi\\x99\\xbc\\xa9c\\xf6gZ\\x0cz\\xf1\\x80\\x00\\x00\\x00\\x00\\r\\x08\\x02`\\xd1\\x07\\xd2i\\xcc\\xba\\x92G\\xcf\\xc6L\\x95/\\x1d\\x13QKI\\xe9\\xf1#\\x0b:\\x19z\\x8btP\\xfa'hI\\xff\\xff\\x00\\x1d8\"\n",
      "\n",
      "\n",
      "b'\\xd8\\xfb\\x98\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x01\\n\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04\\xe0\\x04\\x1bKM\\x9bo\\xebr!\\x80:5\\xd9\\x97\\xef\\xad\\xa6\\xe2\\xb5\\xd2O_\\xc7 _.\\xa6\\xb6*\\x1a'\n",
      "\n",
      "\n",
      "b'\\xdc\\x99\\x83\\xa7\\xa7\\xda\\xb7\\xe9>\\xa7\\x91\\xbe\\xd5\\x92\\x8ez2(o\\xa4\\xfa\\xca\\xdd\\x161;u\\xb4g\\xae\\xa7t\\x99\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00s\\x84#\\x12W4?/\\xa3\\xc5^\\xe6\\x9e\\xa9\\xe6v\\xa7\\t\\xa0m\\xcf\\xd2\\xf7>\\x8c,2\\xb3\\x00\\x00\\x00\\x00D.\\xe9\\x1b+\\x99\\x9f\\xb1]a\\xf6\\xa8\\x8e\\xcf)\\x88\\xe9\\xc8'\n",
      "\n",
      "\n",
      "b'\\xedH\\xf0\\x02Ga(\\xe6p\\xd3\\xda\\xc1\\x9f\\xe7\\x06(hI\\xff\\xff\\x00\\x1d\\x04\\x9e\\x12\\xd6\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x01\\x0b\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04\\x97sg\\x16L\\xa2O\\x1f'\n",
      "\n",
      "\n",
      "b\"-\\xe2\\xe2\\xcf\\xb9\\xe5\\xc3\\xf2-Q\\r?3h=\\xe2\\x00(1\\x00\\xaf\\x0c\\x86g\\xdb\\xa7\\xe4\\xe3\\x89\\xfa\\x99S\\xc6\\xcb\\x83\\xd6\\xear\\x99\\x0e\\x13\\x9fR\\x9bX\\xcf\\xbb\\xac'`z( {*7\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\xf5\\xc4lA\\xc3\\r\\xf6\\xaa\\xff:\\xe9\\xf7M\\xa8>K\\x1c\\xff\\xde\\xc8\\x9c\\x00\\x9b9\\xbb%J\"\n",
      "\n",
      "\n",
      "b'\\x17\\x00\\x00\\x00\\x00]b\\x91\\xc3Z\\x88\\xfd\\x9a:\\xefXC\\x12D\\x00\\x93o\\xbf,\\x91f1J\\xdd\\xca\\xf5g\\x8eU\\xb7\\xe0\\xa3\\x0f,hI\\xff\\xff\\x00\\x1d\\x07`\\x84\\x93\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x01\\r\\xff'\n",
      "\n",
      "\n",
      "b'\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04\\\\\\xa3\\xb9>\\x90\\xfe\\x97\\x85sN\\x07\\xc8\\xe5d\\xfdr\\xa0\\xd6\\x8a \\x0b\\xf9\\x07\\xee\\x01\\xda\\xba\\xb7\\x84\\xadX\\x17\\xf5\\x9aA\\xf4\\xf7\\xe0N\\xdc>\\x9b\\x80\\xcc7\\x0c(\\x1b\\x0f@n\\xb5\\x81\\x87fK\\xdf\\x93\\xde\\xcc[\\xb62d\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\t\\xf8\\xfdk'\n",
      "\n",
      "\n",
      "b'\\xa6\\xf0\\xb6\\xd5\\xc2\\x07\\xe8\\xfc\\xbc\\xf5\\x0fF\\x87j]\\xef\\xfb\\xacG\\x01\\xd7\\xd0\\xf1?\\x00\\x00\\x00\\x00#\\xcac\\xb8Q\\xca\\xdf\\xd7\\t\\x9a\\xe6\\x8e\\xb2!G\\xd0\\x93\\x94\\xad\\xb7*x\\xe8ki\\xc4-\\xebm\\xf2%\\xf9..hI\\xff\\xff\\x00\\x1d27A\\xf2\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00'\n",
      "\n",
      "\n",
      "b'\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x01\\x12\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04\\xcf7\\xa4k0NM\\xad\\x17\\xe0\\x816\\x15\\x02\\xd0\\xef\\xf2\\n\\xf2\\xb16\\x0c{\\x189*)\\xf9\\xf0\\x8a\\xe5\\xa9Z\\xa2O\\x85\\x953\\xda\\xbb\\xc8XU\\x98\\xbf\\x8c\\\\q\\xc0\\xe8\\xd8\\x9d6U\\x88\\x9a\\xee\\x8cI\\xfd\\x94\\x8f'\n",
      "\n",
      "\n",
      "b'Y\\xfe\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x16\\x11&\\xf0\\xd3\\x9e\\xc0\\x82\\xe5\\x1b\\xbd)\\xa1\\xdf\\xb4\\x0bAkDZ\\xc8\\xe4\\x93\\xf8\\x8c\\xe9\\x93\\x86\\x00\\x00\\x00\\x000\\xe2\\xa3\\xe3*\\xbf\\x16c\\xa8T\\xef\\xbe\\xf1\\xb23\\xc6|\\x8c\\xdc\\xefVV\\xfe;O(\\xe5!\\x12F\\x9e\\x9b\\xae0hI\\xff\\xff\\x00\\x1d\\x16\\xd1\\xb4-\\x01\\x01\\x00\\x00\\x00'\n",
      "\n",
      "\n",
      "b'\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x01\\x16\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04\\xf5\\xef\\xde\\x0c-0\\xab(\\xe3\\xdb\\xe8\\x04\\xc1\\xa4\\xaa\\xf10f\\xf9\\xb1\\x98\\xa4\\x15\\x9cv\\xf8\\xf7\\x9b; \\xca\\xf9\\x9f|\\x97\\x9e\\xd6\\xc7\\x14'\n",
      "\n",
      "\n",
      "b'\\x81\\x06\\x12w\\xa6\\xfc\\x86f\\x97|$\\x9d\\xa9\\x99`\\xc9|\\x8d\\x87\\x14\\xfd\\xa9\\xf0\\xe8\\x83\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00o\\x18\\x7f\\xdd\\xd5\\xe2\\x8a\\xa1\\xb4\\x06]\\xaa]\\x9e\\xae\\x0cHp\\x94\\xfb \\xcf\\x97\\xca\\x02\\xb8\\x1c\\x84\\x00\\x00\\x00\\x00[{%\\xb5\\x17\\x97\\xf81\\x92\\xf9\\xfd,8q\\xbf\\xb2up\\xa7\\xd6\\xb5m:Pv\\x06'\n",
      "\n",
      "\n",
      "b'\\x13\\xd1\\xa2\\xfc\\x1a\\xee\\xab4hI\\xff\\xff\\x00\\x1d6\\xd9Pq\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x01 \\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04\\x08\\xab/V6\\x1f\\x83\\x06NL\\xe5\\x1a\\xcc)\\x1f\\xb5'\n",
      "\n",
      "\n",
      "b\"|,\\xbc\\xdb\\x1deb\\xf6'\\x8cC\\xa1@kT\\x8f\\xd6\\xce\\xfc\\x11\\xbc\\xc2\\x9e\\xb6 \\xd5\\x86\\x1c\\xb9\\xedi\\xdc9\\xf2B/T\\xb0j\\x8a\\xf4\\xf7\\x8c\\x82v\\xcf\\xdck\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\xd7\\xc84\\xe8\\xea\\x05\\xe2\\xc2\\xfd\\xdfM\\x82\\xfa\\xf4\\xc3\\xe9!\\x02\\x7f\\xa1\\x90\\xf1\\xb87*z\\xa9g\\x00\\x00\\x00\\x00\\xb4\\x10\\x92\"\n",
      "\n",
      "\n",
      "b'\\xb8p\\xcc\\t`p\\xff2\\x12\\xc2\\x07\\xc0\\x88\\x1e:*\\xba\\xfc\\x1b\\x92PyA\\xb4\\xefpY\\x17\\xe0\\xd96hI\\xff\\xff\\x00\\x1d+\\xd0!\\xd6\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x01%\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*'\n",
      "\n",
      "\n",
      "b'\\x01\\x00\\x00\\x00CA\\x04+\\x08\\xeb\\xb6\\xad\\xa0\\x05~G\\xa1%\\xd0\\xa2\\xe9\\x9d\\xd2\\xb8l \\x1dA\\xaa\\xf7\\xaa)\\\\b\\\\,/\\x19\\x97\\xa8\\xbcl\\xb9\\xdb\\xda\\x88\\x96i\\x98\\x9b\\x8d\\x12\\x80L@\\x01h\\xe5K\\t:\\xd0]\\x11p\\xc5\\x16\\xab\\xca}(\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00O)\\xf3\\x1em\\xac\\x13q\\n\\xe7-T'\n",
      "\n",
      "\n",
      "b\"'\\x8b\\\\\\x97\\xffl\\x16F\\xe9['\\xd1Bc\\x01o\\x00\\x00\\x00\\x00CI\\xd6\\xa4\\xe9O\\x05\\xa76\\xac\\x83\\x07T\\xe7m\\xfd\\xf7\\xf1@\\xc31\\xf3\\x16\\xd1\\xa2xQ~\\x1d\\xaf.\\x9ek:hI\\xff\\xff\\x00\\x1d(\\x14\\x0fb\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\"\n",
      "\n",
      "\n",
      "b'\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x010\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04\\xae\\xf9\\x05\\x80\\x9d\\x10\\x04\\xda+\\x01\\x87\\xddQ\\x98\\xe0\\xf5\\xb1\\x1a\\xb2\\x91#\\x0c\\xdc\\xd9`k\\xbc\\x99\\xac\\xd1[\\xc9\\x1f\\x95\\x1d\\xe60\\x7fZ\\xda\\xe0?.\\x18\\xd5#\\xec\\x87x\\xe7\\xd8\\xe9\\xb7\\xc2K\\xa2\\x82\\xc8\\xea\\xa9\\xbc\\xde\\xd8@\\xac\\x00\\x00\\x00\\x00\\xf9'\n",
      "\n",
      "\n",
      "b'\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00;^[\\x88\\x8c\\x8c=\\xa0\\xf1\\xd6\\xc3\\x96\\x9ec\\xa7\\xa9\\xc1!Z3`\\xc8\\x10zB\\x8d\\xb5\\x98\\x00\\x00\\x00\\x00\\x8cL\\xc1\\xb4,\\x9d\\xab\\x19s\\x89\\x0e\\xcd\\xfd\\xee\\x03 y\\xed9\\x89*\\xd5:eF\\x84M#v4\\xcf\\xe1\\xfb:hI\\xff\\xff\\x00\\x1d%Z\\xb4U\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00'\n",
      "\n",
      "\n",
      "b'\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x011\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04\\x1a$\\xb5c\\x9c\\x12\\xb2\\xb0\\xa6\\x12\\x01\\x1e\\xb7\\x80\\xa6\\x82\\x02\\x0bc\\x12x/\\xef\\x0b\\xc2\\x9au\\xee\\xe7\\xcff\\xab\\xd0\\x81\\x12\\x1a\\x0b{\\\\0v\\xe0Ud\\x83y\\xc2'\n",
      "\n",
      "\n",
      "b'^\\xd5.\\xff\\x8d+\\x11\\x87\\x1eZ~\\x0c\\x86\\x04\\xf4\\x05?\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x82!\\x9c\\xeb\\xbd\\xc9\\xbc\\xb7\\x15\\xef\\xeeS\\\\\\x13\\xa4DG\\xe9\\x9d\\xfa\\xffmU.\\x989\\xd3\\x0c\\x00\\x00\\x00\\x00>u\\xf6<cN\\xd5\\xfb=\\x8e!\\xde_\\xe1C\\xcf\\xa6<\\x80\\x18\\xfc\\xe0\\xfa&\\xcb\\xc6(7\\x8b\\x9b\\xc3C\\x95='\n",
      "\n",
      "\n",
      "b\"hI\\xff\\xff\\x00\\x1d'\\xba\\x00\\xb1\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x01?\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04\\x95#\\xafv]\\xa5@\\x8d\\nO\\x9d3\\xaf.\\x10<W\\xb8\\xb3\\x18w\\x96\\x91s\"\n",
      "\n",
      "\n",
      "b\"\\xe7\\xa7\\xc3\\x13\\xbf\\t\\xa9\\x80=\\xcc\\xee\\xc9\\xb2\\x9d\\x0f\\xabG7\\x17><\\xb6\\xdc\\xc1\\x1a\\xb7\\xf23\\xd8\\xb1\\xd7\\x15t\\x8c\\xa4\\xd7\\x15w\\n\\xc3\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00_A\\x1e\\rw\\x83\\xfc'KO\\xea\\x85\\x97 \\x9d1\\xd4\\xa5\\x11\\xe8\\x87\\xa4\\x89\\xce\\xbb\\x1f\\x05\\xfc\\x00\\x00\\x00\\x00\\xbe!#\\xadH\\x03\\x83\\x13\\xb8\\xb7&\"\n",
      "\n",
      "\n",
      "b'\\xa5\\x1c\\xb0\\x80\\xbbZ\\x8b\\x81\\xc4\\x16d\\x01I;\\x01}-3R\\x0f\\x9b\\x06?hI\\xff\\xff\\x00\\x1d#7\\xf11\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x01A\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04\\xbf'\n",
      "\n",
      "\n",
      "b'\\xf0c\\xa0\\x80\\xc0z\\xa9\\xd8\\xe7\\x03\\x8c\\x9d\\x1b\\xd7\\xe5\\x07o\\xc2\\x8d\\xd3\\xe9\\x05\\xb7e\\x17\\xad\\x95\\x8e\\x9d\\xf6^\\x83\\xab\\xef\\xcd\\xbd\\xcds\\x10#\\x1a\\xaa\\xf1jS\\xe9\\xbc$Y\\x88&\\xa3)\\x1e]\\xab3\\x86ua\\x8e\\x7f\\x12\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00& vo\\xa2EX\\xadG\\xe3\\xa9b<\\xd1\\x7f\\xf4b6hv'\n",
      "\n",
      "\n",
      "b'\\x8d\\xbe\\xa1\\x9e\\xd5\\xa15\\x8e\\x00\\x00\\x00\\x00\\xdc\\x14\\x90\\xb5\\xba\"{\\x1a\\xdb\\xb2Q?t\\xe0%.\\x8f\\xe6\\x8bl}\\xe7L\\x1a\"\\xad\\xb6;\\x14\\xe8\\xc1g\\x12FhI\\xff\\xff\\x00\\x1d4N\\xb7\\\\\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04'\n",
      "\n",
      "\n",
      "b'\\xff\\xff\\x00\\x1d\\x01\\x05\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04\\x0b\\xaf\\x81\\x98G\\x93\\xa5s$\\xf8\\x86\\xd6\\xa9\\xa0@Q2X\\xdc1\\x0f\\xd9^f\\x95_\\x98\\x90\\xd5\\x1aN\\xfc\\xc9\\xd5\\xbfi\\xda0\\xbei\\xe1nBgp\\xb9\\x92|\\x18\\xd0\\xa0la\\x0cm~\\xbf\\xbcjY\\x02:J\\xd0\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01'\n",
      "\n",
      "\n",
      "b'\\x00\\x00\\x00\\x98\\x10\\xf0\\xfa\\x18\\x17\\xa4\\xd2\\xd3q\\xa0i\\xad\\xda\\xaf\\xab,\\xa9\\x98\\x87\\xab\\xcc[\\xd2R\\x8eCA\\x00\\x00\\x00\\x00eO\\x00ZnKKW\\xb4#C\\xfb\\x0eG\\xf3 y\\xb4\\xeb\\xfed<.\\xa4\\xea \\xe4l:\\xf0\\x0c#\\x8dFhI\\xff\\xff\\x00\\x1d6L\\x8c\\xb3\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00'\n",
      "\n",
      "\n",
      "b'\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x01\\x10\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04\\xa4?M\\xe4Q\\xf2 \\xee&\\x06\\xedy\\x887\\x97\\x00\\x0eW\\xa1z\\xd8\\xd4\\x18\\xeb-\\xe2\\x139\\xa0E\\xfd\\x1e9\\x99S\\xa0\\xb9GK.\\x1f\\xa5\\x10il\\x1e\\xb4\\x81-\\xcd\\x0e\\xa4\\xfd\\xa1\\x93'\n",
      "\n",
      "\n",
      "b'#D\\xbb\\xd9\\x14\\xf5.N/\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x81 5 Al7\\x0f\\xde=mF\\xe8.\\xd43+P5\\xbf\\xba\\x84\\x8f\\xf9r\\x075q\\x00\\x00\\x00\\x00\\xbd\\xae\\xd8N\\x0c\\xba\\xb75\\x88\\rGc\\xa1\\xeb-\\xf1\\xec\\xd5\\x9d\\xc2a\\xf3Dm\\xb3{\\xed[l\\xcb\\x99\\xf31\\xbfhI\\xff\\xff\\x00\\x1d.['\n",
      "\n",
      "\n",
      "b'\\xd4\\x8e\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x01\\t\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04\\xd3\\xa4\\xfd\\'\"\\xf5uA\\x02\\xb9l\\xd8\\xb8\\xec~\\xa8p\\xc1\\x0e\\xd562\\x90\\xb8\\xac\\x92\\xea\\xf6\\xb1 *V'\n",
      "\n",
      "\n",
      "b'\\x9e\\xd9^\\xd4\\x95|dM\\xf7\\xfc\\x07\\x94wK\\x03\\xbf\\x9fc\\xba\\xf7\\xa5\\\\\\xde\\x9ePvwOg\\x98{4\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00D\\tp\\x9a\\xff\\x1b\\x15[\\xe4\\xf7\\xa9\\xcc\\xefa!4PP\\xbet\\xb4\\xba\\xd1\\xd30\\x94\\r\\xbb\\x00\\x00\\x00\\x00\\xecw\\xd3L\\xb2\\xf8O4G\\xc3~\\xc1\\xb4Gn\\x04N\\x88G'\n",
      "\n",
      "\n",
      "b'\\x83x\\x99\\x8b\\xd5]\\x03\\x1fX\\xf4\\xe2a\\xc3_\\xbfhI\\xff\\xff\\x00\\x1d2\\xcb9\\xa0\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x01\\r\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04\\x8e,:\\xd3\\x14*7^\\xe9'\n",
      "\n",
      "\n",
      "b\"i\\xec\\xcb>\\x14G\\tq\\xd8\\x98\\xbcg\\x07\\x7f()2E\\xb9z\\xfb\\xc5\\t\\xd1\\x80\\x82\\x9fL\\xd4\\x19\\xc2\\x08\\xc80'(\\xddQ\\xa6\\xd8\\x83\\x92\\xfb0\\xa0\\x9d>\\xc2}\\xd2?\\xb24m\\x03\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\xcb\\x9b\\xa5\\xa4RR\\xb35\\xfeG\\xa0\\x99\\xc8\\x93]\\x01\\xff\\x8e\\xef.Y\\x8c Qc\\x1bz\\xc5\"\n",
      "\n",
      "\n",
      "b'\\x00\\x00\\x00\\x001SOuq\\xb5\\xea\\x98\\xc11\\x8e\\xed\\x04\\x93}o\\xf1e\\x82\\xbar\\xc55RX\\x1c@\\x82\\x8bl\\xe2\\xf5\\xca\\xc1hI\\xff\\xff\\x00\\x1d\\x08\\x03\\x15\\xe8\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x01!\\xff\\xff'\n",
      "\n",
      "\n",
      "b'\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04,\\xf5\\x9f\\xaf\\xd0\\x89\\xa3H\\xc5\\x83B\\x83W6\\x08\\xe8\\x9a0\\\\`\\xa04`L}\"\\xdd\\xe5\\t\\x98\\xf1\\xb9\\xbbth\\x19\\x86\\xca\\x18\\x84\\xa6\\xb1\\xdf\\x8c\\xe7\\xf1\\xb7\\x9a\"w\\x05}\\xe8U\\xa64bnzXQ\\xc1\\xe7\\x16\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\xdbd?\\x07V'\n",
      "\n",
      "\n",
      "b'\\xbbOk%\\xceJG[S=\\x9e\\xf7\\\\\\xd56\\xe7-\\xf6d\\xfb\\x9c\\x91\\xbc\\x00\\x00\\x00\\x00\\xcbR{\\xd2\\x94\\x95\\xc0,\\x9de\\x15\\xde\\x91\\xef&M\\xf33D~H\\xefs\\x0f;f\\xff\\xa8\\xdb>\\xb3\\x860\\xc4hI\\xff\\xff\\x00\\x1d\\x15]\\xbb*\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00'\n",
      "\n",
      "\n",
      "b'\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x01)\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04\\xc2`5\\xa5\\xe1\\xe1\\xdb\\x8b\\x18\\x04=\\x1b1\\xce\\xf1\\n\\x8f\\xe6\\xf5\\x87W\\xe2\\xb3\\xe5\\x14qT\\xdfbz\\xe0 \\xf3\\x97 \\xad\\xc9\\xa6#\\x85}\\xb3y!pc\\x89n\\xf2\\x8e\\xa6\\xb8\\xa0\\xa4>\\x7f\\x1b\\xecJ6\\xdch\\x18'\n",
      "\n",
      "\n",
      "b'\\\\\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\xc4\\xd3i\\xb7#\\xc2\\xcf\\x9b\\xe3<\\xf0\\r\\xeb\\x1d\\xbf\\xea\\x0c\\x8c\\xcd\\x12\\xc4\\x15\\xf2\\x944\\xff\\x00\\x97\\x00\\x00\\x00\\x00\\xc9\\xc0\\xfd\\n\\xe7\\xb7\\x97<B\\xfc\\x9e=\\xdd\\xc9g\\xb6\\xe3\\tW\\x0br\\x0f\\xf1T\\x14\\xc0\\x83e\\xf0\\x05\\x99+\\xe3\\xc5hI\\xff\\xff\\x00\\x1d\\x08\\xe1\\xc0\\r\\x01\\x01\\x00\\x00\\x00\\x01'\n",
      "\n",
      "\n",
      "b'\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x016\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04\\xb9I\\x98\\x0b\\xb4j\\xee\\x11Q\\x05\\x19\\xb4\\xaf\\r\\xfc\\xc3\\xcctd\\xb3\\xed\\xe1_\\x18K|\\x81&\\xa9\\x8b\\xf6\\xd6\\xe6\\x98\\xea\\xf1k\\x93\\x88\\x14'\n",
      "\n",
      "\n",
      "b\"\\x17J\\x00+\\xa2M\\xaa\\x03\\xe5\\x9a|\\t'$\\x85\\x17\\xb5\\x81\\xc0\\x9e\\xc7\\x0f!n\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\xe3\\xf6fMZ\\xf3pb\\xb94\\xf9\\x83\\xed\\x103\\xe2\\x01\\x1bB\\xc9\\xb0G5'l|\\xcb\\xe5\\x00\\x00\\x00\\x00\\x10\\x12\\xaa\\xab>;\\xff\\xd3@U\\xaa\\xa1W\\xbfxy-\\\\\\x18\\xf0\\x85c^\\xdapF\\xd8\"\n",
      "\n",
      "\n",
      "b'\\x9c\\x08\\xa0\\xea\\xbd\\xe3\\xc8hI\\xff\\xff\\x00\\x1d\"\\x8c\"@\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x018\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04\\x80Mq\\xf6\\xa9\\x1c\\x90\\x8a\\x97<\\xae~\\xf46?v\\x89'\n",
      "\n",
      "\n",
      "b'R\\x01\\x16\\xb9\\x95\\xd6\\x93c(\\xde\\x00\\xbeV\\xf9+\\xae\\xe0\\xda\\xbf:$\\x0e\\x0e\\xd2\\xdc\\xe7\\xf3t\\xf1,\\xbb\\xa7d\\x98\\x08R\\x826\\xcb\\x04\\xc5X\\xf0(\\xdda\\xed\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00by\\x85\\xc0\\xfc\\x1aq\\xe0R\\xa5\\xaf\\x94 \\xc9\\xb9\\x98EC*\\xe0\\x99\\xf2z=\\xeasp\\xa8\\x00\\x00\\x00\\x00tT\\x9b1'\n",
      "\n",
      "\n",
      "b'Q\\xd6\\xddL\\xe7t\\x19\\xd0\\x17\\x10\\x92\\x1b2\\x11\\xed2\\x80\\xbf.:\\xf2\\xc1\\xf1\\xa8 \\x06;\"r\\xcahI\\xff\\xff\\x00\\x1d\"C\\xc0$\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x01G\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01'\n",
      "\n",
      "\n",
      "b'\\x00\\x00\\x00CA\\x04\\x18\\x0b\\xfaW\\xbf\\xf4b\\xc7d\\x1f\\xa0\\xb9\\x1e\\xfe)4Jw\\x08k\\x07<\\xd9\\xc5\\xf7i\\xcb#\\x93\\xac\\xc1Q\\xa4\\xe77~\\xaa\\xba\\xcc9\\xf5\\xb2\\xbd,\\xd4\\xbc\\xb5\\xed\\x18U\\x93\\x96\\x19\\xe4\\x91\\xc7\\x9c\\x0b\\xb5y=N\\xdb\\xf3\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x8f1\\xb4\\xc4\\x05\\xcf\\xc2\\x12\\xfaNb\\x84\\r'\n",
      "\n",
      "\n",
      "b'\\xc8\\xd0\\xc5)\\xedS2\\x8b\\xb1Bl;\\xb2?\\xa7\\x00\\x00\\x00\\x00\\xe0\\xaf;\\xba\\x9e\\x96,\\xe2\\x88\\xd9\\xe22\\xd2\\x8a\\x1b\\xa9\\xc8[\\xd1\\xe2\\x98\\x89\\x078\\xa6[\\x93\\xed\\x97\\x19+\\x85\\xa1\\xcdhI\\xff\\xff\\x00\\x1d\\x14\\xca\\xdd\\xe7\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00'\n",
      "\n",
      "\n",
      "b'\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x01M\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04\\xbb1Vb\\x91\\xce\\xb6>\\xd6\\x00\\xb0\\xc2\\x9dh%\\xd7\\x92Ns\\xc2e\\xab\\xacC\\xfa\\x08\\x8a\\xd3\\xe1\\xa4w\\xc6\\xfd\\x157?\\xc4\\x02)\\xcc\\x89W2\\xd4\\x17_m\\xb6\\x15\\xe4\\xa2\\xb6\\xe9A\\x1e\\x92\\x97Ki#\\xd7\\x98U\\x18\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe'\n",
      "\n",
      "\n",
      "b'\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x9b-2\\xc7\\x82\\x8a\\x80dK\\x92\\xb7s5{Utb\\xa1G\\rB\\x16\\xe8\\xb4e\\xa4r\\xb5\\x00\\x00\\x00\\x00ZM}\\x92\\xcd\\x83\\x9c\\xdb}\\xc4H\\x90$8\\xe4\\xa4\\x88W!H}\\xe39\\x00\\xb3EX\\xbdo%]\\xd0\\x1d\\xd0hI\\xff\\xff\\x00\\x1d.\\xc3\\x84/\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00'\n",
      "\n",
      "\n",
      "b'\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x01P\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04\\xce)\\xc2o\\xb5\\x9e\\xad\\xf6\\xb9\\xb3\\x8a>\\x7fRdhw\\xbc\\xdc\\xd7\\xb5\\xf2\\x90\\xa4zzaf\\x8b\\xda,\\x82\\xc8\\xf1?f\\xe8f\\\\\\xfeu\\x94\\xd7\\xdaQ\\xf41\\xdf'\n",
      "\n",
      "\n",
      "b'M\\xf2\\xf6\\r\\xf0\\x8e\\xcf\\xd5=/-\\x07kK\\xc2N\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\xdeD2M\\x0fp\\xa1I\\x858_C\\x99\\x84K\\x17\\x92\\\\\\xa2N\\x90\\xb4%\\xf5C\\xd6$\\xf8\\x00\\x00\\x00\\x00}( h\\xb7p\\xb3[Xz\\x9f\\xb45d\\x91\\xd5\\x85K\\xba;`\\xd7\\xc1\\xa1)\\xd3~\\xd6\\xb5N4m\\xea\\xd3h'\n",
      "\n",
      "\n",
      "b'I\\xff\\xff\\x00\\x1d\\x01>\\xca\\x85\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x01W\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04eW\\x98\\xe5\\xce\\x83\\xda/$\\x95^\\x169hFR\\x8d\\x91\\x9c\"<\\x9c)E\\xb2'\n",
      "\n",
      "\n",
      "b'\\x11\\xb7\"\\xd5Z\\x85\\xcc\\xb8\\x93\\x00f\\xea\\xf3LP\\x1a\\xc3|MA\\xc8\\xe5y\\xcc\\xc0\\x0fT\\xd5\\xa5\\xf1\\xb3\\xc2}\\xe5%\\xec\\xe5\\xa5\\xd5\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x86o\\x0c\\xc6y\\x17\\x0bj\\x99\\xe8\\xb9>X\\xdc\\'l\\xf6O\\x03y\\x11-\\x12\\x8e\\x12m\\xd9\\xdd\\x00\\x00\\x00\\x00h\\x9aD\\xcb\\x1ci\\xd8\\xaa\\xdej7\\xd4'\n",
      "\n",
      "\n",
      "b'\\x83\"\\xb3\\xe9p\\x99\\xc2^K\\xcb\"\\x8a\\x9d\\xd2s\\x9f\\xeb\\xda\\x90\\xe6\\xc0\\xd6hI\\xff\\xff\\x00\\x1d\\x00\\x03\\xe8\\xea\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x01\\x07\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04c\\x12'\n",
      "\n",
      "\n",
      "b'\\xc7D\\xcbeaGi\\x15\\x03\\tY\\x02W\\xc8\\x9c\\xf5\\xd2\\xeeO\\x04\\x8eZ\\x94O\\xa5\\x0cv\\x8d ^\\xe6\\x083\\x14\\xa5]\\x8b?\\x9c\\xaf\\xf59u\\x8c\\x13\\xa8\\xf7;\\xe4\\xaa\\xc6\\xa6\\xe8\\xc5\\xa9\\x17\\xdcg\\x0e\\x04/\\x11\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\xdd\\xd6O\\xea/\\xd6\\xe3\\xb1\\x0b\\x14V\\xf2\\xad*\\x87\\x0f\\xf5\\xff\\x8e\\xd5$'\n",
      "\n",
      "\n",
      "b'0M\\x92\\x8e\\xee\\x19|\\x00\\x00\\x00\\x00k\\xca\\xe7\\x12VV\\xcc\\rk=\\xc5c\\xab>\\x98\\xd5Im\\xcb\\xd8\\x97\\x85\\tQ8\\xb1C\\xa4\\x8b\\xc1\\x84\\x14\\xd7\\xd6hI\\xff\\xff\\x00\\x1d(\\x00\\x02`\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff'\n",
      "\n",
      "\n",
      "b\"\\xff\\x00\\x1d\\x01\\t\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04aT\\xd4\\xedg\\x8d\\xdf_\\xbb\\x9e\\t\\xef}\\x1c\\xf3\\xa8\\x05?Z\\t\\xfc\\x890=\\x15\\rNq[\\xc6\\x91\\xb2@\\xc97)\\xcdA-p|H\\xf7\\xba\\xfeA\\xdbhL/\\x9a9\\xaaY\\x95xh'\\xe9\\xedM\\x18^6\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\"\n",
      "\n",
      "\n",
      "b'\\x00\\x00\\x12\\xadb2mM\\x1d}2\\xd2\\xf1i\\xa1\\xa8\\x16\\x98Ob\\x98\\xfd\\xb5\\xcc\\xc3\\xf6\\x06\\xd5eV\\x00\\x00\\x00\\x00 \\x1e\\x1a\\xd4O\\n\\xe9Ww\\x1d.`\\xfa%%\\x94\\xe7\\xfc\\xc7ZQ\\xdbL\\xdf\\xb5\\xfb\\xae\\xb3\\x86\\x129\\x04\\x90\\xd9hI\\xff\\xff\\x00\\x1d\\x06!gq\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00'\n",
      "\n",
      "\n",
      "b\"\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x01\\x0e\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04'\\xdf\\x88*\\x15kL)\\xa4\\xd0^\\xec\\x8d\\x0cKS\\xf9v\\xf7\\xe0\\xee&9\\xdc\\x8c\\xbbc'E\\x1b\\x8c\\xf0\\x95z\\xbb4\\x18ibC\\xf3\\x92\\xe7;Xn\\xa4\\xb0t\\xe5\\xbd\\xc8V\\xa24\\xc9\"\n",
      "\n",
      "\n",
      "b'\\xe1ta^;\\xbc\\xea$\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\xaai\\x8b\\x96v\\x19\\xb9\\\\\\x91\\x81\\xeb\\xd2Vp\\x06Q\\xaa\\xa1%_\\xe5\\x03\\xf5\\x9b9\\x1f\\xf0\\xb2\\x00\\x00\\x00\\x00Z\\x8d\\xa0\\x00\\xe1\\xa2%\\x860\\xddo\\x02\\x86\\xdd\\xc2K{\\x0e\\xf8\\x97\\xf3Dq8\\xc9\\xa3\\xcc\\xb8\\xb3l\\xfa\\x9eG\\xdchI\\xff\\xff\\x00\\x1d\\x07\\xe8\\xfb'\n",
      "\n",
      "\n",
      "b'\\xd1\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x01\\x12\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04\\xa4I\\xee).Ft[n\\x8e5\\n\\x04w~\\xe98\\xf1Q\\xafC\\x8ak\\x80\\xc2\\xfb\\x86\\xa6^q\\xe6\\xa6w'\n",
      "\n",
      "\n",
      "b'\\x89~\\xf1\\xf8\\xe9\\x97\\xdc\\xdd\\xc0$\\xd9&9b\\x0e\\t\\x02\\x17\\x10\\xae0v\\x83l\\x90\\xf3\\xfa/\\xcd\\xed\\xd3\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x8bR\\xbb\\xd7,/IV\\x90Y\\xf5Y\\xc1\\xb1yM\\xe5\\x19.O}m+\\x03\\xc7H+\\xad\\x00\\x00\\x00\\x00\\x83\\xe4\\xf8\\xa9\\xd5\\x02\\xed\\x0cA\\x90u\\xc1\\xab\\xb5\\xd5o\\x87\\x8a.\\x90'\n",
      "\n",
      "\n",
      "b\"y\\xe5a+\\xfbv\\xa2\\xdc7\\xd9\\xc4'A\\xddhI\\xff\\xff\\x00\\x1d+\\x90\\x9d\\xd6\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x01\\x15\\xff\\xff\\xff\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04F+\\x00\\xd6{%NK\\x10\\xde\"\n",
      "\n",
      "\n",
      "b'o\\xe0\\xb2w\\xb6\\xa3O$8u\\x8f\\xc5\\xfc,\\x18\\xc5\\xb5>\\x93R2+\\x94\\xd2\\xbel\\xa5\\xa2U~\\xbfU\\x90_}\\xc6\\xcc\\xa6\\x99\\x16+\\x0f\\xaf\\x91\\x97T\\xb5\\xca6\\x9d1\\xd0\\xbb1\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\xf5(\\xfa\\xc1\\xbc\\xb6\\x85\\xd0\\xcdly# \\xaf\\x03\\x00\\xa5\\xce\\x15\\xd6\\x87\\xc7\\x14\\x95H\\x90N1\\x00'\n",
      "\n",
      "\n",
      "b'\\x00\\x00\\x00N\\x89\\x85\\xa7\\x86\\xd8d\\xf2\\x1e\\x9c\\xbb|\\xbd\\xf4\\xbc\\x92e\\xfeh\\x1bz\\x08\\x93\\xacU\\xa8\\xe9\\x19\\xce\\x03\\\\/\\x85\\xdehI\\xff\\xff\\x00\\x1d8\\\\\\xcb|\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\xff\\xff\\xff\\xff\\x07\\x04\\xff\\xff\\x00\\x1d\\x01\\x16\\xff\\xff\\xff'\n",
      "\n",
      "\n",
      "b'\\xff\\x01\\x00\\xf2\\x05*\\x01\\x00\\x00\\x00CA\\x04\\x92\\xad\\xe9\\xa7\\xa1\\xfd\\xe2P\\x16\\xc0-\">/\\x1cP\\x1d*\\xf1\\x1bI.\\n?\\x0c\\xd6\\x17\\xa0\\x17\\x98\\xc5\\xf5\\xea\\xbd\\x9dYW\\xa7\\xb2\\xd6m\\x1bB\\xf6\\x88\\xa6\\xfd]+\\xc6\\n\\xd0\\xd7\\xa0\\x0f`\\x06\\xfcH8\\xfbL$\\x8a\\xac\\x00\\x00\\x00\\x00\\xf9\\xbe\\xb4\\xd9\\xd7\\x00\\x00\\x00\\x01\\x00\\x00\\x00P\\xe5\\x93\\xd3\\xb2 '\n",
      "\n",
      "\n",
      "b'4\\xcf\\xc9\\x88M\\xf8B\\xe8]9\\x8b\\\\<\\xfdw\\xb1\\xaa*\\x86\\xf2!\\xac\\x00\\x00\\x00\\x00_\\xaf\\xe0\\xe1\\x82K\\xb9\\x99_\\x12\\xee\\xb4\\x18>\\xaa\\x1f\\xde\\x88\\x9fE\\x90\\x19\\x1c\\xd6:\\x92\\xa6\\x1a\\x1e\\xee\\x9aC\\xf9\\xe1hI\\xff\\xff\\x00\\x1d03\\x9e\\x19\\x01\\x01\\x00\\x00\\x00\\x01\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00\\x00'\n"
     ]
    }
   ],
   "source": [
    "with open(\"blocks_demo/blk00000.dat\",\"br\") as blockfile:\n",
    "    \n",
    "    for i in range(100):\n",
    "        print(\"\\n\")\n",
    "        print(blockfile.read(100))\n",
    "    "
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 66,
   "metadata": {},
   "outputs": [],
   "source": [
    "from multiprocessing import Pool\n",
    "from time import sleep\n",
    "import concurrent.futures\n",
    "\n",
    "def test_func(file):\n",
    "    sleep(1)\n",
    "    print(f\".\")\n",
    "    sleep(1)\n",
    "    print(f\"From {file}\")\n",
    "    sleep(1)\n",
    "    print(f\".\")\n",
    "    return\n",
    "    \n",
    "    \n",
    "def main(args):\n",
    "    n_threads = args[1]\n",
    "    n = args[0]\n",
    "    \n",
    "    file_list = [f\"{i:05}\" for i in range( n , n + n_threads )]\n",
    "    with concurrent.futures.ThreadPoolExecutor(max_workers=n_threads+1) as executor:\n",
    "        executor.map(test_func, file_list)  \n",
    "    \n",
    "def super_main(start_at,n_processes,n_threads):\n",
    "    batch_list = [start_at+n_threads*i for i in range(n_processes)]\n",
    "    arg_list = [(n,n_threads) for n in batch_list]\n",
    "    with Pool(5) as p:\n",
    "        p.map(main, arg_list)"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 68,
   "metadata": {
    "collapsed": true,
    "jupyter": {
     "outputs_hidden": true
    }
   },
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "batch_list [0, 8, 16, 24, 32, 40, 48, 56, 64, 72, 80, 88, 96]\n",
      "node 0 batch 0\n",
      "start at: 0\n",
      "batch list from supermain: [0, 2, 4, 6]\n",
      "arg_list from supermain: [(0, 2), (2, 2), (4, 2), (6, 2)]\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      "From 00004\n",
      "From 00003\n",
      "From 00006\n",
      "From 00000\n",
      "From 00001\n",
      "From 00005\n",
      "From 00007\n",
      "From 00002\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      "node 0 batch 8\n",
      "start at: 8\n",
      "batch list from supermain: [8, 10, 12, 14]\n",
      "arg_list from supermain: [(8, 2), (10, 2), (12, 2), (14, 2)]\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      "From 00014\n",
      "From 00008\n",
      "From 00009\n",
      "From 00015\n",
      "From 00010\n",
      "From 00012\n",
      "From 00011\n",
      "From 00013\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      "node 0 batch 16\n",
      "start at: 16\n",
      "batch list from supermain: [16, 18, 20, 22]\n",
      "arg_list from supermain: [(16, 2), (18, 2), (20, 2), (22, 2)]\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      "From 00021\n",
      "From 00023\n",
      "From 00022\n",
      "From 00017\n",
      "From 00018\n",
      "From 00016\n",
      "From 00020\n",
      "From 00019\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      "node 0 batch 24\n",
      "start at: 24\n",
      "batch list from supermain: [24, 26, 28, 30]\n",
      "arg_list from supermain: [(24, 2), (26, 2), (28, 2), (30, 2)]\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      "From 00028\n",
      "From 00024\n",
      "From 00025\n",
      "From 00029\n",
      "From 00027\n",
      "From 00030\n",
      "From 00031\n",
      "From 00026\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      "node 0 batch 32\n",
      "start at: 32\n",
      "batch list from supermain: [32, 34, 36, 38]\n",
      "arg_list from supermain: [(32, 2), (34, 2), (36, 2), (38, 2)]\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      "From 00034\n",
      "From 00032\n",
      "From 00033\n",
      "From 00036\n",
      "From 00035\n",
      "From 00038\n",
      "From 00039\n",
      "From 00037\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      "node 0 batch 40\n",
      "start at: 40\n",
      "batch list from supermain: [40, 42, 44, 46]\n",
      "arg_list from supermain: [(40, 2), (42, 2), (44, 2), (46, 2)]\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      "From 00045\n",
      "From 00043\n",
      "From 00041\n",
      "From 00046\n",
      "From 00040\n",
      "From 00042\n",
      "From 00047\n",
      "From 00044\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      "node 0 batch 48\n",
      "start at: 48\n",
      "batch list from supermain: [48, 50, 52, 54]\n",
      "arg_list from supermain: [(48, 2), (50, 2), (52, 2), (54, 2)]\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      "From 00054\n",
      "From 00055\n",
      "From 00051\n",
      "From 00052\n",
      "From 00048\n",
      "From 00049\n",
      "From 00050\n",
      "From 00053\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      "node 0 batch 56\n",
      "start at: 56\n",
      "batch list from supermain: [56, 58, 60, 62]\n",
      "arg_list from supermain: [(56, 2), (58, 2), (60, 2), (62, 2)]\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      "From 00063\n",
      "From 00057\n",
      "From 00060\n",
      "From 00061\n",
      "From 00062\n",
      "From 00056\n",
      "From 00059\n",
      "From 00058\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      "node 0 batch 64\n",
      "start at: 64\n",
      "batch list from supermain: [64, 66, 68, 70]\n",
      "arg_list from supermain: [(64, 2), (66, 2), (68, 2), (70, 2)]\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      "From 00070\n",
      "From 00068\n",
      "From 00066\n",
      "From 00064\n",
      "From 00067\n",
      "From 00069\n",
      "From 00065\n",
      "From 00071\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      "node 0 batch 72\n",
      "start at: 72\n",
      "batch list from supermain: [72, 74, 76, 78]\n",
      "arg_list from supermain: [(72, 2), (74, 2), (76, 2), (78, 2)]\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      "From 00077\n",
      "From 00074\n",
      "From 00079\n",
      "From 00072\n",
      "From 00076\n",
      "From 00075\n",
      "From 00078\n",
      "From 00073\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      "node 0 batch 80\n",
      "start at: 80\n",
      "batch list from supermain: [80, 82, 84, 86]\n",
      "arg_list from supermain: [(80, 2), (82, 2), (84, 2), (86, 2)]\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      "From 00085\n",
      "From 00082\n",
      "From 00080\n",
      "From 00087\n",
      "From 00083\n",
      "From 00084\n",
      "From 00081\n",
      "From 00086\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      "node 0 batch 88\n",
      "start at: 88\n",
      "batch list from supermain: [88, 90, 92, 94]\n",
      "arg_list from supermain: [(88, 2), (90, 2), (92, 2), (94, 2)]\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      "From 00094\n",
      "From 00093\n",
      "From 00090\n",
      "From 00089\n",
      "From 00092\n",
      "From 00088\n",
      "From 00091\n",
      "From 00095\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      "node 0 batch 96\n",
      "start at: 96\n",
      "batch list from supermain: [96, 98, 100, 102]\n",
      "arg_list from supermain: [(96, 2), (98, 2), (100, 2), (102, 2)]\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      "From 00098\n",
      "From 00096\n",
      "From 00103\n",
      "From 00099\n",
      "From 00100\n",
      "From 00097\n",
      "From 00102\n",
      "From 00101\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n",
      ".\n"
     ]
    }
   ],
   "source": [
    "def manager(total_files, n_processes, n_threads, n_nodes):\n",
    "    concurrent_files = n_processes*n_threads\n",
    "    batches = total_files//concurrent_files+1\n",
    "    batch_list = [concurrent_files*i for i in range(batches)]\n",
    "    print(f\"batch_list {batch_list}\")\n",
    "    for index,batch in enumerate(batch_list):\n",
    "        node = index%n_nodes\n",
    "        print(f\"node {node} batch {batch}\")\n",
    "        super_main(batch, n_processes, n_threads)\n",
    "    \n",
    "\n",
    "manager(100, 4,2,1)"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 57,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "first from file\n",
      "second from file\n",
      "Third from file\n",
      "first from file\n",
      "second from file\n",
      "Third from file\n",
      "first from file\n",
      "second from file\n",
      "Third from file\n",
      "first from file\n",
      "second from file\n",
      "Third from file\n",
      "first from file\n",
      "second from file\n",
      "Third from file\n",
      "first from file\n",
      "second from file\n",
      "Third from file\n",
      "first from file\n",
      "second from file\n",
      "Third from file\n",
      "first from file\n",
      "second from file\n",
      "Third from file\n"
     ]
    }
   ],
   "source": [
    "for c in range(8):\n",
    "    test_func(\"file\")"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {},
   "outputs": [],
   "source": []
  }
 ],
 "metadata": {
  "kernelspec": {
   "display_name": "Python 3",
   "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.7.7"
  }
 },
 "nbformat": 4,
 "nbformat_minor": 4
}