|
24 | 24 | },
|
25 | 25 | {
|
26 | 26 | "cell_type": "code",
|
27 |
| - "execution_count": 9, |
| 27 | + "execution_count": null, |
28 | 28 | "metadata": {},
|
29 |
| - "outputs": [ |
30 |
| - { |
31 |
| - "name": "stdout", |
32 |
| - "output_type": "stream", |
33 |
| - "text": [ |
34 |
| - "IPython autoawait is `on`, and set to use `asyncio`\n" |
35 |
| - ] |
36 |
| - } |
37 |
| - ], |
| 29 | + "outputs": [], |
38 | 30 | "source": [
|
39 | 31 | "%autoawait\n",
|
40 | 32 | "import time\n",
|
|
67 | 59 | },
|
68 | 60 | {
|
69 | 61 | "cell_type": "code",
|
70 |
| - "execution_count": 10, |
| 62 | + "execution_count": null, |
71 | 63 | "metadata": {},
|
72 | 64 | "outputs": [],
|
73 | 65 | "source": [
|
|
91 | 83 | },
|
92 | 84 | {
|
93 | 85 | "cell_type": "code",
|
94 |
| - "execution_count": 26, |
| 86 | + "execution_count": null, |
95 | 87 | "metadata": {},
|
96 |
| - "outputs": [ |
97 |
| - { |
98 |
| - "name": "stdout", |
99 |
| - "output_type": "stream", |
100 |
| - "text": [ |
101 |
| - "Results : [{'connection_id': 'e3fcd9fd-61cd-4c08-a184-9e5aa9601c0e', 'their_label': 'Bob', 'state': 'active', 'their_did': 'GXtAUZQTioTE1mds53Nd6u', 'invitation_mode': 'once', 'created_at': '2020-11-11 23:05:18.072570Z', 'updated_at': '2020-11-11 23:05:38.233456Z', 'initiator': 'external', 'my_did': 'NVYLd8LThRKaFDHURBKf3R', 'invitation_key': 'Gr35rUaqwhfcq6BBsknBCJcr1aug3k339uPRrvjPho2Z', 'request_id': '920642ae-6343-4d89-b821-ad8b8888bce3', 'accept': 'manual', 'routing_state': 'none'}]\n", |
102 |
| - "Connection : {'connection_id': 'e3fcd9fd-61cd-4c08-a184-9e5aa9601c0e', 'their_label': 'Bob', 'state': 'active', 'their_did': 'GXtAUZQTioTE1mds53Nd6u', 'invitation_mode': 'once', 'created_at': '2020-11-11 23:05:18.072570Z', 'updated_at': '2020-11-11 23:05:38.233456Z', 'initiator': 'external', 'my_did': 'NVYLd8LThRKaFDHURBKf3R', 'invitation_key': 'Gr35rUaqwhfcq6BBsknBCJcr1aug3k339uPRrvjPho2Z', 'request_id': '920642ae-6343-4d89-b821-ad8b8888bce3', 'accept': 'manual', 'routing_state': 'none'}\n", |
103 |
| - "Active Connection ID : e3fcd9fd-61cd-4c08-a184-9e5aa9601c0e\n" |
104 |
| - ] |
105 |
| - } |
106 |
| - ], |
| 88 | + "outputs": [], |
107 | 89 | "source": [
|
108 | 90 | "response = await agent_controller.connections.get_connections()\n",
|
109 | 91 | "results = response['results']\n",
|
|
129 | 111 | },
|
130 | 112 | {
|
131 | 113 | "cell_type": "code",
|
132 |
| - "execution_count": 27, |
| 114 | + "execution_count": null, |
133 | 115 | "metadata": {},
|
134 |
| - "outputs": [ |
135 |
| - { |
136 |
| - "data": { |
137 |
| - "text/plain": [ |
138 |
| - "{}" |
139 |
| - ] |
140 |
| - }, |
141 |
| - "execution_count": 27, |
142 |
| - "metadata": {}, |
143 |
| - "output_type": "execute_result" |
144 |
| - } |
145 |
| - ], |
| 116 | + "outputs": [], |
146 | 117 | "source": [
|
147 | 118 | "await agent_controller.action_menu.request_menu(connection_id)"
|
148 | 119 | ]
|
|
165 | 136 | },
|
166 | 137 | {
|
167 | 138 | "cell_type": "code",
|
168 |
| - "execution_count": 23, |
| 139 | + "execution_count": null, |
169 | 140 | "metadata": {},
|
170 |
| - "outputs": [ |
171 |
| - { |
172 |
| - "data": { |
173 |
| - "text/plain": [ |
174 |
| - "{'result': None}" |
175 |
| - ] |
176 |
| - }, |
177 |
| - "execution_count": 23, |
178 |
| - "metadata": {}, |
179 |
| - "output_type": "execute_result" |
180 |
| - } |
181 |
| - ], |
| 141 | + "outputs": [], |
182 | 142 | "source": [
|
183 | 143 | "# retrieve the menu options sent from Bob\n",
|
184 | 144 | "menu = await agent_controller.action_menu.get_menu(connection_id)\n",
|
|
187 | 147 | },
|
188 | 148 | {
|
189 | 149 | "cell_type": "code",
|
190 |
| - "execution_count": 22, |
| 150 | + "execution_count": null, |
191 | 151 | "metadata": {},
|
192 |
| - "outputs": [ |
193 |
| - { |
194 |
| - "ename": "TypeError", |
195 |
| - "evalue": "'NoneType' object is not subscriptable", |
196 |
| - "output_type": "error", |
197 |
| - "traceback": [ |
198 |
| - "\u001b[0;31m---------------------------------------------------------------------------\u001b[0m", |
199 |
| - "\u001b[0;31mTypeError\u001b[0m Traceback (most recent call last)", |
200 |
| - "\u001b[0;32m<ipython-input-22-aa2da0a0ca14>\u001b[0m in \u001b[0;36m<module>\u001b[0;34m\u001b[0m\n\u001b[0;32m----> 1\u001b[0;31m \u001b[0mmenu_options\u001b[0m \u001b[0;34m=\u001b[0m \u001b[0mmenu\u001b[0m\u001b[0;34m[\u001b[0m\u001b[0;34m\"result\"\u001b[0m\u001b[0;34m]\u001b[0m\u001b[0;34m[\u001b[0m\u001b[0;34m\"options\"\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 2\u001b[0m \u001b[0mmenu_options\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n", |
201 |
| - "\u001b[0;31mTypeError\u001b[0m: 'NoneType' object is not subscriptable" |
202 |
| - ] |
203 |
| - } |
204 |
| - ], |
| 152 | + "outputs": [], |
205 | 153 | "source": [
|
206 | 154 | "menu_options = menu[\"result\"][\"options\"]\n",
|
207 | 155 | "menu_options"
|
208 | 156 | ]
|
209 | 157 | },
|
210 | 158 | {
|
211 | 159 | "cell_type": "code",
|
212 |
| - "execution_count": 16, |
| 160 | + "execution_count": null, |
213 | 161 | "metadata": {},
|
214 |
| - "outputs": [ |
215 |
| - { |
216 |
| - "data": { |
217 |
| - "text/plain": [ |
218 |
| - "{}" |
219 |
| - ] |
220 |
| - }, |
221 |
| - "execution_count": 16, |
222 |
| - "metadata": {}, |
223 |
| - "output_type": "execute_result" |
224 |
| - } |
225 |
| - ], |
| 162 | + "outputs": [], |
226 | 163 | "source": [
|
227 | 164 | "# as an example, we work with the first menu option\n",
|
228 | 165 | "menu_params = {\n",
|
229 |
| - " \"delay\": \"5\",\n", |
230 |
| - " \"visibility\": \"True\"\n", |
| 166 | + " \"begin_issue_cred\": \"True\"\n", |
231 | 167 | "}\n",
|
232 | 168 | "\n",
|
233 | 169 | "await agent_controller.action_menu.perform(\n",
|
|
237 | 173 | ")"
|
238 | 174 | ]
|
239 | 175 | },
|
240 |
| - { |
241 |
| - "cell_type": "code", |
242 |
| - "execution_count": 20, |
243 |
| - "metadata": { |
244 |
| - "scrolled": true |
245 |
| - }, |
246 |
| - "outputs": [ |
247 |
| - { |
248 |
| - "data": { |
249 |
| - "text/plain": [ |
250 |
| - "{}" |
251 |
| - ] |
252 |
| - }, |
253 |
| - "execution_count": 20, |
254 |
| - "metadata": {}, |
255 |
| - "output_type": "execute_result" |
256 |
| - } |
257 |
| - ], |
258 |
| - "source": [ |
259 |
| - "await agent_controller.action_menu.close_menu(connection_id=connection_id)" |
260 |
| - ] |
261 |
| - }, |
262 | 176 | {
|
263 | 177 | "cell_type": "markdown",
|
264 | 178 | "metadata": {},
|
|
270 | 184 | },
|
271 | 185 | {
|
272 | 186 | "cell_type": "code",
|
273 |
| - "execution_count": 30, |
| 187 | + "execution_count": null, |
274 | 188 | "metadata": {},
|
275 |
| - "outputs": [ |
276 |
| - { |
277 |
| - "data": { |
278 |
| - "text/plain": [ |
279 |
| - "{}" |
280 |
| - ] |
281 |
| - }, |
282 |
| - "execution_count": 30, |
283 |
| - "metadata": {}, |
284 |
| - "output_type": "execute_result" |
285 |
| - } |
286 |
| - ], |
| 189 | + "outputs": [], |
287 | 190 | "source": [
|
288 | 191 | "# close active menu\n",
|
289 | 192 | "await agent_controller.action_menu.close_menu(connection_id)"
|
290 | 193 | ]
|
291 | 194 | },
|
| 195 | + { |
| 196 | + "cell_type": "markdown", |
| 197 | + "metadata": {}, |
| 198 | + "source": [ |
| 199 | + "Retrieving the active menu now would return `None`." |
| 200 | + ] |
| 201 | + }, |
292 | 202 | {
|
293 | 203 | "cell_type": "code",
|
294 |
| - "execution_count": 31, |
| 204 | + "execution_count": null, |
295 | 205 | "metadata": {
|
296 | 206 | "scrolled": true
|
297 | 207 | },
|
298 |
| - "outputs": [ |
299 |
| - { |
300 |
| - "data": { |
301 |
| - "text/plain": [ |
302 |
| - "{'result': None}" |
303 |
| - ] |
304 |
| - }, |
305 |
| - "execution_count": 31, |
306 |
| - "metadata": {}, |
307 |
| - "output_type": "execute_result" |
308 |
| - } |
309 |
| - ], |
| 208 | + "outputs": [], |
310 | 209 | "source": [
|
311 |
| - "# getting the active menu would return none\n", |
312 | 210 | "menu = await agent_controller.action_menu.get_menu(connection_id)\n",
|
313 |
| - "menu\n" |
| 211 | + "menu" |
314 | 212 | ]
|
315 | 213 | },
|
316 | 214 | {
|
|
324 | 222 | },
|
325 | 223 | {
|
326 | 224 | "cell_type": "code",
|
327 |
| - "execution_count": 6, |
| 225 | + "execution_count": null, |
328 | 226 | "metadata": {},
|
329 |
| - "outputs": [ |
330 |
| - { |
331 |
| - "ename": "RuntimeError", |
332 |
| - "evalue": "Site <aiohttp.web_runner.TCPSite object at 0x7fee28bec250> is not registered in runner <aiohttp.web_runner.AppRunner object at 0x7fee28c25cb0>", |
333 |
| - "output_type": "error", |
334 |
| - "traceback": [ |
335 |
| - "\u001b[0;31m---------------------------------------------------------------------------\u001b[0m", |
336 |
| - "\u001b[0;31mRuntimeError\u001b[0m Traceback (most recent call last)", |
337 |
| - "\u001b[0;32m<ipython-input-6-5870155ffed5>\u001b[0m in \u001b[0;36masync-def-wrapper\u001b[0;34m()\u001b[0m\n\u001b[1;32m 2\u001b[0m \u001b[0mprint\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mresponse\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n", |
338 |
| - "\u001b[0;32m/aries_basic_controller/aries_controller.py\u001b[0m in \u001b[0;36mterminate\u001b[0;34m(self)\u001b[0m\n\u001b[1;32m 113\u001b[0m \u001b[0;32mawait\u001b[0m \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mclient_session\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[1;32m 114\u001b[0m \u001b[0;32mif\u001b[0m \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mwebhook_site\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m--> 115\u001b[0;31m \u001b[0;32mawait\u001b[0m \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mwebhook_site\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0mstop\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 116\u001b[0m \u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m 117\u001b[0m \u001b[0;34m\u001b[0m\u001b[0m\n", |
339 |
| - "\u001b[0;32m/opt/conda/lib/python3.7/site-packages/aiohttp/web_runner.py\u001b[0m in \u001b[0;36mstop\u001b[0;34m(self)\u001b[0m\n\u001b[1;32m 54\u001b[0m \u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m 55\u001b[0m \u001b[0;32masync\u001b[0m \u001b[0;32mdef\u001b[0m \u001b[0mstop\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mself\u001b[0m\u001b[0;34m)\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---> 56\u001b[0;31m \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0m_runner\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0m_check_site\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[0m\u001b[1;32m 57\u001b[0m \u001b[0;32mif\u001b[0m \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0m_server\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 58\u001b[0m \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0m_runner\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0m_unreg_site\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", |
340 |
| - "\u001b[0;32m/opt/conda/lib/python3.7/site-packages/aiohttp/web_runner.py\u001b[0m in \u001b[0;36m_check_site\u001b[0;34m(self, site)\u001b[0m\n\u001b[1;32m 276\u001b[0m \u001b[0;32mif\u001b[0m \u001b[0msite\u001b[0m \u001b[0;32mnot\u001b[0m \u001b[0;32min\u001b[0m \u001b[0mself\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0m_sites\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 raise RuntimeError(\"Site {} is not registered in runner {}\"\n\u001b[0;32m--> 278\u001b[0;31m .format(site, self))\n\u001b[0m\u001b[1;32m 279\u001b[0m \u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m 280\u001b[0m \u001b[0;32mdef\u001b[0m \u001b[0m_unreg_site\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0mself\u001b[0m\u001b[0;34m,\u001b[0m \u001b[0msite\u001b[0m\u001b[0;34m:\u001b[0m \u001b[0mBaseSite\u001b[0m\u001b[0;34m)\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", |
341 |
| - "\u001b[0;31mRuntimeError\u001b[0m: Site <aiohttp.web_runner.TCPSite object at 0x7fee28bec250> is not registered in runner <aiohttp.web_runner.AppRunner object at 0x7fee28c25cb0>" |
342 |
| - ] |
343 |
| - } |
344 |
| - ], |
| 227 | + "outputs": [], |
345 | 228 | "source": [
|
346 | 229 | "response = await agent_controller.terminate()\n",
|
347 | 230 | "print(response)"
|
|
0 commit comments