urbit/shrub
1
1
Fork 0
mirror of https://github.com/urbit/shrub.git synced 2024-12-14 20:02:51 +03:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'radio' of github.com:urbit/urbit-new into radio

Browse Source
This commit is contained in:
Galen Wolfe-Pauly 2014-12-10 20:43:32 -08:00
commit 88e2ce9cf2
2 changed files with 567 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

47
main/app/rodeo/core.hook
View File

@ -3,6 +3,7 @@
::
/? 314
/- *radio
/+ twitter
::
::::
::
@ -39,7 +40,10 @@
[%nice ~] :: accept
== ::
++ sign :: response
$? $: %g :: application
$% $: %e :: from %eyre
$% [%thou p=httr] :: HTTP response
== == ::
$: %g :: application
$% [%mean p=ares] :: cancel
[%nice ~] :: acknowledge
[%rust %radio-report report] :: refresh
@ -47,13 +51,29 @@
++ move ,[p=bone q=(mold note gift)] :: all actions
++ hapt ,[p=ship q=path] :: app instance
++ note :: requests
$? $: %g :: network
$% $: %e :: through %eyre
$% [%them p=(unit hiss)] :: HTTP request
== == ::
$: %g :: network
$% [%mess p=hapt q=ship r=cage] :: message
[%nuke p=hapt q=ship] :: cancel
[%show p=hapt q=ship r=path] :: subscribe
== == == ::
--
|_ [hid=hide house]
++ ti
=+ ^= key
:* :- 'AP3G1t8ki6rPzeeAqdWCTw03F'
'VV784LPwZSaAxtF16RWWTnST4F85BHN8VqQKNyv7MprCkA0xZD'
:- '2821727326-RZGXSeTn7hCFQfJqR0ViivM3YYpu2O1M71gelBl'
'jW9VygFPOTsEK0WmrJDHYSoEnofOPdCE1oQRzueemVTl8'
==
|%
++ post
|= txt=cord ^- hiss
(~(stat-upda twit key lat.hid `@`eny.hid) [%status txt]~ ~)
--
::
++ ra :: transaction core
|_ [ost=bone moves=(list move)]
++ ra-abet :: resolve core
@ -214,9 +234,19 @@
+>
(ra-record q.p.tay p.p.tay tip)
%| ?. pub +>
~& [%conduct-twitters]
!!
==
?- -.p.tay
%twitter
~& [%conduct-twitters]
=+ ^= msg
?+ -.q.r.tip !!
%say "@{(trip p.p.tay)} {<her>}: {(trip p.q.r.tip)}"
%own "@{(trip p.p.tay)} {<her>} {(trip p.q.r.tip)}"
==
?< (gth (lent msg) 140)
%+ ra-emit ost
:+ %pass /tweet/(scot %ud ost)
[%e [%them ~ (post:ti (crip msg))]]
== ==
::
++ ra-record :: add to party
|= [man=span gam=telegram]
@ -487,6 +517,13 @@
:: ~& sih=sih
=+ sih=((hard sign) sih)
?+ pax ~& [%rodeo-strange-path pax] !!
[%tweet ^]
?> ?=(%thou +<.sih)
~& ?: =(2 (div p.p.sih 100))
[%tweet-ack p.p.sih]
~! sih
[%tweet-lost [p `(unit ,[@ @t])`r]:[p.sih .]]
[~ +>.$]
[%friend *]
?> ?=([@ @ @ ~] t.pax)
?. =(%show i.t.pax)

525
main/lib/twitter/core.hook Normal file
View File

@ -0,0 +1,525 @@
:: A Twitter API library.
::
:::: /hook/core/twitter/lib
::
/? 314
::
:::: structures
::
|%
++ keys :: twitter-key type
$: con=[tok=@t sec=@t] :: user key pair
acc=[tok=@t sec=@t] :: app key pair
==
--
!:
:::: functions
::
|%
++ fass :: rewrite path
|= a=path
%- trip
%^ gsub '-' '_'
%+ reel a
|= [p=@t q=@t]
(cat 3 '/' (cat 3 p q))
::
++ gsub :: replace chars
|= [a=@t b=@t t=@t]
^- @t
?~ t t
%+ add (lsh 3 1 $(t (rsh 3 1 t)))
=+ c=(mod t (bex 8))
?:(=(a c) b c)
::
++ oauth :: OAuth 1.0 header
|= $: med=meth
url=tape
pas=(list tape)
key=keys
zet=@
ken=@
==
^- @t
=+ non=(turn (rip 2 (shaw zet 128 ken)) |=(a=@ ~(x ne a)))
=+ tim=(slag 2 (scow %ui (unt zet)))
=+ sky=(crip :(weld (urle (trip sec.con.key)) "&" (urle (trip sec.acc.key))))
=+ ^= bas
^- tape
=+ ^= hds
%- reel :_ |=([p=tape q=tape] :(weld p "&" q))
%- sort :_ aor
%- weld :- pas
^- (list tape)
:~ :(weld "oauth_consumer_key=" (trip tok.con.key))
:(weld "oauth_nonce=" non)
:(weld "oauth_signature_method=HMAC-SHA1")
:(weld "oauth_timestamp=" tim)
:(weld "oauth_token=" (trip tok.acc.key))
:(weld "oauth_version=1.0")
==
;: weld
(trip (cuss (trip `@t`med))) "&"
(urle url) "&"
(urle (scag (dec (lent hds)) `tape`hds))
==
=+ sig=`tape`(sifo (swap 3 (hmac (swap 3 sky) (crip bas))))
%- crip
;: weld "OAuth "
"oauth_consumer_key=" "\"" (trip tok.con.key) "\", "
"oauth_nonce=" "\"" non "\", "
"oauth_signature=" "\"" (urle sig) "\", "
"oauth_signature_method=\"HMAC-SHA1\", "
"oauth_timestamp=" "\"" tim "\", "
"oauth_token=" "\"" (trip tok.acc.key) "\", "
"oauth_version=1.0"
==
::
++ valve :: produce request
|= $: med=meth
[rus=tape quy=quay]
key=keys
est=time
eny=@
==
^- hiss
=+ url="https://api.twitter.com/1.1{rus}.json"
=+ req=|=(a=tape (scan a auri:epur))
=+ ^= help
|= quy=(list ,[tape tape])
^- (list tape)
%+ turn quy
|= a=[p=tape q=tape]
:(weld (urle p.a) "=" (urle q.a))
=+ tan=(turn quy |=([p=@t q=@t] [(trip p) (trip q)]))
=+ har=(help (turn tan |=(p=[p=tape q=tape] [p.p (urle q.p)])))
=+ hab=(help tan)
=+ lav=(reel har |=([p=tape q=tape] :(weld p "&" q)))
=+ voy=?:(=(0 (lent lav)) ~ (scag (dec (lent lav)) `tape`lav))
=+ vab=(reel hab |=([p=tape q=tape] :(weld p "&" q)))
=+ vur=(crip ?:(=(0 (lent vab)) ~ (scag (dec (lent vab)) `tape`vab)))
=+ ^= head
%- ~(gas by *math)
:~ ['authorization' [(oauth med url hab key est eny) ~]]
['content-type' ['application/x-www-form-urlencoded' ~]]
==
?: =(%get med)
?~ voy
[(req url) med head ~]
[(req :(weld url "?" voy)) med head ~]
[(req url) med head (some [(met 3 vur) vur])]
--
!:
:::: library
::
|%
++ twit
=> |% :: request structures
++ dev ,@t :: device name
++ gat ,@t :: grant type
++ lat ,@t :: latitude
++ lid (list tid)
++ lon ,@t :: longitude
++ lsc (list scr)
++ lst (list ,@t)
++ nam ,@t :: location name
++ pla ,@t :: place-id
++ scr ,@t :: screen name
++ slu ,@t :: category name
++ tid ,@u
++ tok ,@t :: oauth token
++ url ,@t :: callback url
::
++ at ,[%access-token p=tok]
++ de ,[%device p=dev]
++ fo ,[%follow p=lid]
++ gr ,[%grant-type p=gat]
++ id ,[%id p=tid]
++ ii ,[%'!inline' p=@t]
++ is ,[%id p=lid]
++ la ,[%lat p=lat]
++ lo ,[%long p=lon]
++ na ,[%name p=lid]
++ oa ,[%oauth-callback p=url]
++ os ,[%source-screen-name p=scr]
++ pl ,[%place-id p=pla]
++ qq ,[%q p=@t]
++ sc ,[%screen-name p=scr]
++ sd ?(ui sc)
++ ss ,[%screen-name p=lsc]
++ sl ,[%slug p=slu]
++ si ,[%source-id p=tid]
++ st ,[%status p=@t]
++ te ,[%text p=@t]
++ ti ,[%target-id p=tid]
++ ts ,[%target-screen-name p=scr]
++ tr ,[%track p=lst]
++ ur ,[%url p=url]
++ ui ,[%user-id p=tid]
++ us ,[%user-id p=lid]
--
|_ [key=keys est=time eny=@uw]
++ lutt |=(@ `@t`(rsh 3 2 (scot %ui +<)))
++ llsc
|= (list scr)
(roll +< |=([p=scr q=@t] (cat 3 (cat 3 q ',') p)))
::
++ llst
|= (list ,@t)
(roll +< |=([p=@t q=@t] (cat 3 (cat 3 q ',') p)))
::
++ llid
|= (list tid)
(roll +< |=([p=tid q=@t] (cat 3 (cat 3 q ',') (lutt p))))
::
++ mold :: construct request
|* [med=meth pax=path a=$+(* *)]
|= [args=a quy=quay]
(valve med (cowl pax args quy) key est eny)
::
++ cowl :: handle parameters
|= $: pax=path
ban=(list ,[p=@t q=?(@ (list ,@))])
quy=quay
==
^- [path quay]
?~ ban
[(fass pax) quy]
?: =('!inline' p.i.ban)
?@ q.i.ban
[(fass (welp pax /[`@t`q.i.ban])) quy]
!!
:- (fass pax)
%+ welp quy
%+ turn `(list ,[p=@t q=?(@ (list ,@))])`ban
|= [p=@t q=?(@ (list ,@))]
^- [@t @t]
:- (gsub '-' '_' p)
?@ q
?- p
?(%id %source-id %target-id %user-id) (lutt q)
@ `@t`q
==
?- p
?(%follow %id %name %user-id) (llid q)
%track (llst q)
%screen-name (llsc q)
* !!
==
::
++ stat-ment
(mold %get /statuses/mentions-timeline ,~)
::
++ stat-user
(mold %get /statuses/user-timeline ,[sd ~])
::
++ stat-home
(mold %get /statuses/home-timeline ,~)
::
++ stat-retw
(mold %get /statuses/retweets-of-me ,~)
::
++ stat-rets-iddd
(mold %get /statuses/retweets ,[ii ~])
::
++ stat-show
(mold %get /statuses/show ,[id ~])
::
++ stat-dest-iddd
(mold %post /statuses/destroy ,[ii ~])
::
++ stat-upda
(mold %post /statuses/update ,[st ~])
::
++ stat-retw-iddd
(mold %post /statuses/retweet ,[ii ~])
::
++ stat-oemb-iddd
(mold %get /statuses/oembed ,[id ~])
::
++ stat-oemb-urll
(mold %get /statuses/oembed ,[ur ~])
::
++ stat-retw-idss
(mold %get /statuses/retweeters/ids ,[id ~])
::
++ sear-twee
(mold %get /search/tweets ,[qq ~])
::
++ stat-filt-foll
(mold %post /statuses/filter ,[?(fo tr) ~])
::
++ stat-samp
(mold %get /statuses/sample ,~)
::
++ stat-fire
(mold %get /statuses/firehose ,~)
::
++ user
(mold %get /user ,~)
::
++ site
(mold %get /site ,[fo ~])
::
++ dire
(mold %get /direct-messages ,~)
::
++ dire-sent
(mold %get /direct-messages/sent ,~)
::
++ dire-show
(mold %get /direct-messages/show ,[id ~])
::
++ dire-dest
(mold %post /direct-messages/destroy ,[id ~])
::
++ dire-neww
(mold %post /direct-messages/new ,[sd te ~])
::
++ frie-nore-idss
(mold %get /friendships/no-retweets/ids ,~)
::
++ frie-idss
(mold %get /friends/ids ,[sd ~])
::
++ foll-idss
(mold %get /followers/ids ,[sd ~])
::
++ frie-inco
(mold %get /friendships/incoming ,~)
::
++ frie-outg
(mold %get /friendships/outgoing ,~)
::
++ frie-crea
(mold %post /friendships/create ,[sd ~])
::
++ frie-dest
(mold %post /friendships/destroy ,[sd ~])
::
++ frie-upda
(mold %post /friendships/update ,[sd ~])
::
++ frie-show
(mold %get /friendships/show ,[?(si os) ?(ti ts) ~])
::
++ frie-list
(mold %get /friends/list ,[sd ~])
::
++ foll-list
(mold %get /followers/list ,[sd ~])
::
++ frie-look
(mold %get /friendships/lookup ,[?(us ss) ~])
::
++ acco-sett-gett
(mold %get /account/settings ,~)
::
++ acco-veri
(mold %get /account/verify-credentials ,~)
::
++ acco-sett-post
(mold %post /account/settings ,~)
::
++ acco-upda-deli
(mold %post /account/update-delivery-device ,[de ~])
::
++ acco-upda-prof
(mold %post /account/update-profile ,~)
::
++ acco-upda-prof-back
(mold %post /account/update-profile-background-image ,~)
::
++ acco-upda-prof-colo
(mold %post /account/update-profile-colors ,~)
::
++ bloc-list
(mold %get /blocks/list ,~)
::
++ bloc-idss
(mold %get /blocks/ids ,~)
::
++ bloc-crea
(mold %post /blocks/create ,[sd ~])
::
++ bloc-dest
(mold %post /blocks/destroy ,[sd ~])
::
++ user-look
(mold %get /users/lookup ,[?(us ss) ~])
::
++ user-show
(mold %get /users/show ,[sd ~])
::
++ user-sear
(mold %get /users/search ,[qq ~])
::
++ user-cont-tees
(mold %get /users/contributees ,[sd ~])
::
++ user-cont-tors
(mold %get /users/contributors ,[sd ~])
::
++ acco-remo
(mold %post /account/remove-profile-banner ,~)
::
++ user-prof
(mold %get /users/profile-banner ,[sd ~])
::
++ mute-user-crea
(mold %post /mutes/users/create ,[sd ~])
::
++ mute-user-dest
(mold %post /mutes/users/destroy ,[sd ~])
::
++ mute-user-idss
(mold %get /mutes/users/ids ,~)
::
++ mute-user-list
(mold %get /mutes/users/list ,~)
::
++ user-sugg-slug
(mold %get /users/suggestions ,[sl ~])
::
++ user-sugg
(mold %get /users/suggestions ,~)
::
++ favo-list
(mold %get /favorites/list ,~)
::
++ favo-dest
(mold %post /favorites/destroy ,[id ~])
::
++ favo-crea
(mold %post /favorites/create ,[id ~])
::
++ list-list
(mold %get /lists/list ,~)
::
++ list-stat
(mold %get /lists/statuses ,~)
::
++ list-memb-dest
(mold %post /lists/members/destroy ,~)
::
++ list-memb-hips
(mold %get /lists/memberships ,[sd ~])
::
++ list-subs-bers
(mold %get /lists/subscribers ,~)
::
++ list-subs-crea
(mold %post /lists/subscribers/create ,~)
::
++ list-subs-show
(mold %get /lists/subscribers/show ,[sd ~])
::
++ list-subs-dest
(mold %post /lists/subscribers/destroy ,~)
::
++ list-memb-crea-alll
(mold %post /lists/members/create-all ,[?(us ss) ~])
::
++ list-memb-show
(mold %get /lists/members/show ,[sd ~])
::
++ list-memb-bers
(mold %get /lists/members ,~)
::
++ list-memb-crea
(mold %post /lists/members/create ,[sd ~])
::
++ list-dest
(mold %post /lists/destroy ,~)
::
++ list-upda
(mold %post /lists/update ,~)
::
++ list-crea
(mold %post /lists/create ,[na ~])
::
++ list-show
(mold %get /lists/show ,~)
::
++ list-subs-ions
(mold %get /lists/subscriptions ,[sd ~])
::
++ list-memb-dest-alll
(mold %post /lists/members/destroy-all ,[?(us ss) ~])
::
++ list-owne
(mold %get /lists/ownerships ,[sd ~])
::
++ save-list
(mold %get /saved-searches/list ,~)
::
++ save-show-iddd
(mold %get /saved-searches/show ,[ii ~])
::
++ save-crea
(mold %post /saved-searches/create ,[qq ~])
::
++ save-dest-iddd
(mold %post /saved-searches/destroy ,[ii ~])
::
++ geoo-iddd-plac
(mold %get /geo/id ,[ii ~])
::
++ geoo-reve
(mold %get /geo/reverse-geocode ,[la lo ~])
::
++ geoo-sear
(mold %get /geo/search ,~)
::
++ geoo-simi
(mold %get /geo/similar-places ,[la lo na ~])
::
++ tren-plac
(mold %get /trends/place ,[id ~])
::
++ tren-avai
(mold %get /trends/available ,~)
::
++ tren-clos
(mold %get /trends/closest ,[la lo ~])
::
++ user-repo
(mold %post /users/report-spam ,[sd ~])
::
++ oaut-auth-cate
(mold %get /oauth/authenticate ,~)
::
++ oaut-auth-rize
(mold %get /oauth/authorize ,~)
::
++ oaut-acce
(mold %post /oauth/access-token ,~)
::
++ oaut-requ
(mold %post /oauth/request-token ,[oa ~])
::
++ oaut-toke
(mold %post /oauth2/token ,[gr ~])
::
++ oaut-inva
(mold %post /oauth2/invalidate-token ,[at ~])
::
++ help-conf
(mold %get /help/configuration ,~)
::
++ help-lang
(mold %get /help/languages ,~)
::
++ help-priv
(mold %get /help/privacy ,~)
::
++ help-toss
(mold %get /help/tos ,~)
::
++ appl-rate
(mold %get /application/rate-limit-status ,~)
::
++ stat-look
(mold %get /statuses/lookup ,[us ~])
--
--