Converted all functions from Mongo to CouchDB

Author: JayLohokare

.ipynb_checkpoints/Untitled-checkpoint.ipynb

@@ -64,7 +64,7 @@
   },
   {
    "cell_type": "code",
-   "execution_count": 33,
+   "execution_count": 2,
    "metadata": {},
    "outputs": [],
    "source": [
@@ -87,24 +87,14 @@
   },
   {
    "cell_type": "code",
-   "execution_count": 34,
+   "execution_count": null,
    "metadata": {},
-   "outputs": [
-    {
-     "name": "stdout",
-     "output_type": "stream",
-     "text": [
-      "a2bd5c89-e9cb-490e-a8d0-c6c1f40153a6-bluemix 20e2923d8817e8c5bb111c39e477d6275e278a792a40339e3fe5c9ca8127055c https://a2bd5c89-e9cb-490e-a8d0-c6c1f40153a6-bluemix.cloudantnosqldb.appdomain.cloud/\n"
-     ]
-    }
-   ],
-   "source": [
-    "print (username, password, url)"
-   ]
+   "outputs": [],
+   "source": []
   },
   {
    "cell_type": "code",
-   "execution_count": 35,
+   "execution_count": 4,
    "metadata": {},
    "outputs": [],
    "source": [
@@ -115,7 +105,7 @@
   },
   {
    "cell_type": "code",
-   "execution_count": 40,
+   "execution_count": 5,
    "metadata": {},
    "outputs": [
     {
@@ -135,7 +125,7 @@
   },
   {
    "cell_type": "code",
-   "execution_count": 86,
+   "execution_count": 6,
    "metadata": {},
    "outputs": [],
    "source": [
@@ -152,7 +142,7 @@
   },
   {
    "cell_type": "code",
-   "execution_count": 89,
+   "execution_count": 8,
    "metadata": {},
    "outputs": [
     {
@@ -161,28 +151,28 @@
      "text": [
       "User ID not found, creating new document\n",
       "{\n",
-      "  \"session_id\": \"793de5df-a016-45dc-80fa-9b9cddd33103\"\n",
+      "  \"session_id\": \"1ae29197-9939-42aa-ac5b-aa7c334e2dee\"\n",
       "}\n"
      ]
     },
     {
      "data": {
       "text/plain": [
-       "'793de5df-a016-45dc-80fa-9b9cddd33103'"
+       "'1ae29197-9939-42aa-ac5b-aa7c334e2dee'"
       ]
      },
-     "execution_count": 89,
+     "execution_count": 8,
      "metadata": {},
      "output_type": "execute_result"
     }
    ],
    "source": [
-    "getSessionID('test6')"
+    "getSessionID('test')"
    ]
   },
   {
    "cell_type": "code",
-   "execution_count": 73,
+   "execution_count": 9,
    "metadata": {},
    "outputs": [],
    "source": [
@@ -197,27 +187,27 @@
   },
   {
    "cell_type": "code",
-   "execution_count": 80,
+   "execution_count": 14,
    "metadata": {},
    "outputs": [
     {
      "data": {
       "text/plain": [
-       "'ibm_assistant'"
+       "'test'"
       ]
      },
-     "execution_count": 80,
+     "execution_count": 14,
      "metadata": {},
      "output_type": "execute_result"
     }
    ],
    "source": [
-    "getReceiver('test2')"
+    "getReceiver('test')"
    ]
   },
   {
    "cell_type": "code",
-   "execution_count": 77,
+   "execution_count": 12,
    "metadata": {},
    "outputs": [],
    "source": [
@@ -232,7 +222,47 @@
   },
   {
    "cell_type": "code",
-   "execution_count": 78,
+   "execution_count": 26,
+   "metadata": {},
+   "outputs": [
+    {
+     "data": {
+      "text/plain": [
+       "True"
+      ]
+     },
+     "execution_count": 26,
+     "metadata": {},
+     "output_type": "execute_result"
+    }
+   ],
+   "source": [
+    "updateUserType('test2','doctor')"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 18,
+   "metadata": {},
+   "outputs": [],
+   "source": [
+    "def setupConnection(user1, user2):    \n",
+    "    if user1 not in usersDB or user2 not in usersDB:\n",
+    "        return False\n",
+    "    \n",
+    "    userDoc1 = usersDB[user1]\n",
+    "    userDoc1['receiver'] = user2\n",
+    "    userDoc1.save()\n",
+    "    userDoc2 = usersDB[user2]\n",
+    "    userDoc2['receiver'] = user1\n",
+    "    userDoc2.save()\n",
+    "    \n",
+    "    return True"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 20,
    "metadata": {},
    "outputs": [
     {
@@ -241,21 +271,97 @@
        "True"
       ]
      },
-     "execution_count": 78,
+     "execution_count": 20,
      "metadata": {},
      "output_type": "execute_result"
     }
    ],
    "source": [
-    "updateUserType('test','Community')"
+    "setupConnection('test','test2')"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 21,
+   "metadata": {},
+   "outputs": [],
+   "source": [
+    "def breakConnection(user1, user2):\n",
+    "    if user1 not in usersDB or user2 not in usersDB:\n",
+    "        return False\n",
+    "    \n",
+    "    userDoc1 = usersDB[user1]\n",
+    "    userDoc1['receiver'] = IBM_RECEIVER\n",
+    "    userDoc1.save()\n",
+    "    userDoc2 = usersDB[user2]\n",
+    "    userDoc2['receiver'] = IBM_RECEIVER\n",
+    "    userDoc2.save()\n",
+    "    \n",
+    "    return True"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 22,
+   "metadata": {},
+   "outputs": [
+    {
+     "data": {
+      "text/plain": [
+       "True"
+      ]
+     },
+     "execution_count": 22,
+     "metadata": {},
+     "output_type": "execute_result"
+    }
+   ],
+   "source": [
+    "breakConnection('test','test2')"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 29,
+   "metadata": {},
+   "outputs": [],
+   "source": [
+    "def findDoctor():\n",
+    "    for user in usersDB:\n",
+    "        if user['type'] == TYPE_DOCTOR and user['receiver'] == IBM_RECEIVER:\n",
+    "            return user['_id']\n",
+    "    return None"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 30,
+   "metadata": {},
+   "outputs": [
+    {
+     "name": "stdout",
+     "output_type": "stream",
+     "text": [
+      "test2\n"
+     ]
+    }
+   ],
+   "source": [
+    "print (findDoctor())"
    ]
   },
   {
    "cell_type": "code",
    "execution_count": null,
    "metadata": {},
    "outputs": [],
-   "source": []
+   "source": [
+    "def findCommunity():\n",
+    "    for user in usersDB:\n",
+    "        if user['type'] == TYPE_COMMUNITY and user['receiver'] == IBM_RECEIVER:\n",
+    "            return user['_id']\n",
+    "    return None"
+   ]
   },
   {
    "cell_type": "code",