blob: ebb7926d697190917addad285339f95518604cc9 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
|
/- spider, nsur=nostr
/+ strandio
=, strand=strand:spider
^- thread:spider
|= arg=vase
=/ m (strand ,vase)
^- form:m
:: =/ [url=@t req=client-msg:nsur] (need !<((unit [@t client-msg:nsur]) arg))
=/ [url=@t wev=websocket-event:eyre] !<([@t websocket-event:eyre] arg)
~& > url=url
~& > req=wev
;< =bowl:spider bind:m get-bowl:strandio
=/ desk q.byk.bowl
=/ =task:iris [%websocket-connect desk url]
=/ =card:agent:gall [%pass /ws-req/nostrill %arvo %i task]
;< ~ bind:m (send-raw-card:strandio card)
;< res=(pair wire sign-arvo) bind:m take-sign-arvo:strandio
~& > res=res
:: confirm connection was established
?. ?=([%iris %websocket-response id=@ud websocket-event:eyre] q.res)
(strand-fail:strand %bad-sign ~)
~& > ted-ws-res=+>.q.res
?. ?=(%accept +>+<.q.res)
(pure:m !>([%ng '']))
:: (strand-fail:strand %bad-sign ~)
:: :: ~& ws-handshake=[id.q.res url.q.res]
:: TODO this might fail if the subscription is not set yet
~& >>> "sleeping"
;< ~ bind:m (sleep:strandio ~s3)
~& >>> "slept"
=/ subwire=path /websocket-server/(scot %ud id.q.res)
=/ =cage [%websocket-response !>(+>.q.res)]
=/ gf=gift:agent:gall [%fact :~(subwire) cage]
=/ =card:agent:gall [%give gf]
~& >> ws-ted-ok-sending-msg=id.q.res
;< ~ bind:m (send-raw-card:strandio card)
;< res2=(pair wire sign-arvo) bind:m take-sign-arvo:strandio
?. ?=([%iris %websocket-response id=@ud %message wm=websocket-message:eyre] q.res2)
(strand-fail:strand %bad-sign ~)
=/ wm=websocket-message:eyre +>+>.q.res2
(pure:m !>([%ok id.q.res]))
|
