mirror of
https://github.com/urbit/shrub.git
synced 2024-12-24 03:14:30 +03:00
148 lines
3.6 KiB
Plaintext
148 lines
3.6 KiB
Plaintext
:: Little app to demonstrate the structure of programs written with the
|
|
:: transaction monad.
|
|
::
|
|
:: Fetches the top comment of each of the top 10 stories from Hacker News
|
|
::
|
|
/+ tapp, stdio
|
|
::
|
|
:: Preamble
|
|
::
|
|
=>
|
|
|%
|
|
+$ state
|
|
$: top-comments=(list tape)
|
|
==
|
|
+$ peek-data _!!
|
|
+$ in-poke-data [%noun =cord]
|
|
+$ out-poke-data ~
|
|
+$ in-peer-data ~
|
|
+$ out-peer-data
|
|
$% [%comments (list tape)]
|
|
==
|
|
++ tapp (^tapp state peek-data in-poke-data out-poke-data in-peer-data out-peer-data)
|
|
++ stdio (^stdio out-poke-data out-peer-data)
|
|
--
|
|
=>
|
|
|%
|
|
:: Helper function to print a comment
|
|
::
|
|
++ comment-to-tang
|
|
|= =tape
|
|
^- tang
|
|
%+ welp
|
|
%+ turn (rip 10 (crip tape))
|
|
|= line=cord
|
|
leaf+(trip line)
|
|
[leaf+""]~
|
|
::
|
|
:: All the URLs we fetch from
|
|
::
|
|
++ urls
|
|
=/ base "https://hacker-news.firebaseio.com/v0/"
|
|
:* top-stories=(weld base "topstories.json")
|
|
item=|=(item=@ud `tape`:(welp base "item/" +>:(scow %ui item) ".json"))
|
|
==
|
|
--
|
|
=, async=async:tapp
|
|
=, tapp-async=tapp-async:tapp
|
|
=, stdio
|
|
::
|
|
:: The app
|
|
::
|
|
%- create-tapp-poke-peer-take:tapp
|
|
^- tapp-core-poke-peer-take:tapp
|
|
|_ [=bowl:gall state]
|
|
::
|
|
:: Main function
|
|
::
|
|
++ handle-poke
|
|
|= =in-poke-data
|
|
=/ m tapp-async
|
|
^- form:m
|
|
::
|
|
:: If requested to print, just print what we have in our state
|
|
::
|
|
?: =(cord.in-poke-data 'print')
|
|
~& 'drumroll please...'
|
|
;< now=@da bind:m get-time
|
|
;< ~ bind:m (wait (add now ~s3))
|
|
~& 'Top comments:'
|
|
%- (slog (zing (turn top-comments comment-to-tang)))
|
|
(pure:m top-comments)
|
|
?: =(cord.in-poke-data 'poll')
|
|
;< ~ bind:m (wait-effect (add now.bowl ~s15))
|
|
(pure:m top-comments)
|
|
::
|
|
:: Otherwise, fetch the top HN stories
|
|
::
|
|
=. top-comments ~
|
|
::
|
|
:: If this whole thing takes more than 15 seconds, cancel it
|
|
::
|
|
%+ (set-timeout _top-comments) (add now.bowl ~s15)
|
|
;< =top-stories=json bind:m (fetch-json top-stories:urls)
|
|
=/ top-stories=(list @ud)
|
|
((ar ni):dejs:format top-stories-json)
|
|
::
|
|
:: Loop through the first 5 stories
|
|
::
|
|
=. top-stories (scag 5 top-stories)
|
|
|- ^- form:m
|
|
=* loop $
|
|
::
|
|
:: If done, tell subscribers and print the results
|
|
::
|
|
?~ top-stories
|
|
;< ~ bind:m (give-result /comments %comments top-comments)
|
|
(handle-poke %noun 'print')
|
|
::
|
|
:: Else, fetch the story info
|
|
::
|
|
~& "fetching item #{+>:(scow %ui i.top-stories)}"
|
|
;< =story-info=json bind:m (fetch-json (item:urls i.top-stories))
|
|
=/ story-comments=(unit (list @ud))
|
|
((ot kids+(ar ni) ~):dejs-soft:format story-info-json)
|
|
::
|
|
:: If no comments, say so
|
|
::
|
|
?: |(?=(~ story-comments) ?=(~ u.story-comments))
|
|
=. top-comments ["<no top comment>" top-comments]
|
|
loop(top-stories t.top-stories)
|
|
::
|
|
:: Else, fetch comment info
|
|
::
|
|
;< =comment-info=json bind:m (fetch-json (item:urls i.u.story-comments))
|
|
=/ comment-text=(unit tape)
|
|
((ot text+sa ~):dejs-soft:format comment-info-json)
|
|
::
|
|
:: If no text (eg comment deleted), record that
|
|
::
|
|
?~ comment-text
|
|
=. top-comments ["<top comment has no text>" top-comments]
|
|
loop(top-stories t.top-stories)
|
|
::
|
|
:: Else, add text to state
|
|
::
|
|
=. top-comments [u.comment-text top-comments]
|
|
loop(top-stories t.top-stories)
|
|
::
|
|
++ handle-peer
|
|
|= =path
|
|
=/ m tapp-async
|
|
^- form:m
|
|
~& [%tapp-fetch-take-peer path]
|
|
(pure:m top-comments)
|
|
::
|
|
++ handle-take
|
|
|= =sign:tapp
|
|
=/ m tapp-async
|
|
^- form:m
|
|
:: ignore %poke/peer acknowledgements
|
|
::
|
|
?. ?=(%wake -.sign)
|
|
(pure:m top-comments)
|
|
;< =state bind:m (handle-poke %noun 'fetch')
|
|
=. top-comments state
|
|
(pure:m top-comments)
|
|
--
|