pjQldZddlZddlZddlZddlZddlZddlZddlZddlm Z m Z ddl m Z m Z ejjdxs4ej j#ej j%eZej j+edZej j+edZd\ZZZd \ZZZZd Zed zZ d Z!d ddddZ"dddddZ#ejHdZ%dZ&dZ'dZ(dZ)dZ*dZ+dZ,d'dZ-dZ.dZ/dZ0d Z1Gd!d"e Z2d'd#Z3d$Z4d%Z5e6d&k(re5yy)(a< The remote INBOX: the user chats with the two Stickbash coordinators from inbox.html (local or https://bashatest.howincloud.com/inbox.html), this tiny server stores everything on the VM, and each coordinator picks its messages up over ssh (_tools/inbox.sh) and posts replies, questions and status lines back. Python stdlib only. Two coordinators ("lanes"): kills (the kill coordinator: kills, builds, engine, the game app) and live (the live-game coordinator: online, shop, seasons, saves, accounts). The user addresses a message to kills, live or both. python3 inbox_server.py serve [port] the HTTP API on 127.0.0.1 (Caddy proxies /api/inbox* to it) python3 inbox_server.py pull [--to LANE] NEW user messages for LANE (default kills) as JSON, marked seen by LANE python3 inbox_server.py reply ID [--to LANE] reply text on stdin; threads under message ID, marks it replied python3 inbox_server.py status [--to LANE] LANE's "now" status line on stdin (shown on top of the page) python3 inbox_server.py ask JSON on stdin {to, topic, text, choices[], multi?}: a question for the user (multi: true = the user may tick several choices; needs 2+ choices) python3 inbox_server.py post JSON on stdin {to, topic, text}: a note to the user (no answer needed) python3 inbox_server.py answers [--to LANE] answers to LANE's questions not fetched before, marked fetched python3 inbox_server.py unask ID withdraw an open question python3 inbox_server.py topics the topic list as JSON python3 inbox_server.py list everything, as JSON INBOX_DIR=/some/dir overrides where data.json + token live (tests). HTTP (every call needs the header X-Inbox-Token = the token in ./token): GET /api/inbox[?rev=N] -> {rev, status, statusTs, statuses:{kills:{text,ts},live:{text,ts}}, topics:[...], messages:[...]} (with ?rev=N equal to the current rev: just {rev, unchanged:true}) POST /api/inbox {text, topic?, to?, parent?} -> adds a user message (old pages send only {text}: topic general, to kills) POST /api/inbox/answer {id, answer} -> the user answers question id (a single question: answer = text, one of the choices or typed; a multi question: answer = a list of choices plus at most one typed item; one string is taken as a one-item list) POST /api/inbox/topic {title} -> creates (or returns the existing) topic Message fields: id, ts, kind (message|question|note), from (user|kills|live), to (kills|live|both|user), topic, parent, text, state (message: new|seen|replied; question: open|answered|withdrawn; note: posted), seenTs, seenBy{lane:ts}, replies[{by,text,ts}], reply + replyTs (the latest coordinator reply, for the old pages), choices[], answer, answeredTs; a multi-choice question also has multi: true and its answer is a list (single questions keep answer as text, no multi). N)BaseHTTPRequestHandlerThreadingHTTPServer)urlparseparse_qs INBOX_DIRz data.jsontoken)ipi i)xi,)killslive)bothgeneralGeneralsystemidtitletsbyz page-sendszSent from pagesz^[A-Z][A-Z0-9 _/-]{2,40} v\d+\bcRtjdtjS)Nz%Y-%m-%dT%H:%M:%SZ)timestrftimegmtime+/srv/stickbash-pages/_tools/inbox_server.pynowr 4s ==-t{{} ==rc|tjdd|jjddd}|xsdS)Nz [^a-z0-9]+-0topic)resublowerstrip)rss rslugr*8s6 }c5;;=1779??STSXSXY_acSdCetktAgJ Xt$ Wb! Y# A XYZaXb7AgJa lSThjAiL 1 Y<]quuW~AT/TAdGZ\D-17D/rAhK XAhKs1X;#5#5#78RPQAcF H) $s> I c tt5}tj|}dddt S#1swYxYw#ttj f$ri}Yt |SwxYwN)openDATAjsonloadFileNotFoundErrorJSONDecodeErrorrX)frRs rr^r^asf $Z 1 ! A  1:    t33 4  1:s$A:AAAA.-A.cttdzd5}tj|tjt }||}|j dddz|d<tdz}t|d5}tj||ddd d d tj|t|cd d d S#1swY.xYw#1swYy xYw) zbRead-modify-write data.json under an exclusive lock, written atomically (no torn file on a crash).z.lockwr1rr/z.tmpF ensure_asciiindentN) r[r\fcntlflockLOCK_EXr^rNr]dumposreplace)fnlkrRouttmpras rupdaterqjs dWnc " b B & Fe55?Q&%Vm #s^ :q IIaq 9 : 3    : :  s$A$C 8B?#C ?C C  Cctt5}|jjcdddS#1swYyxYwrZ)r[ TOKEN_FILEreadr()ras rrrxs1 j  Qvvx~~   s 8Acbt||ndjddjd|S)Nrz  )strrlr()r)limits rcleanry}s0 AMqr * 2 264 @ F F H% PPrct|t}|sy|j}|dD]'}|d|k(s|dj|k(s"|dcS|syt|dtk\ryt ||dDchc]}|d }}}|d}}||vrd||fz|dz}}||vr|dj ||t|d |Scc}w) zaA topic by id or title (case-insensitive); created when create_by is given and it does not exist.rr5rrNrz%s-%dr/r)ry MAX_TITLEr'len MAX_TOPICSr*appendr ) rRref create_bylowrUbaserVtidns r find_topicrs Y C  ))+C x[ T7c>QwZ--/36T7N  1X;:%S Qx[9AdG9#9D 1C *D!9$a!eQ *hKcCsuINO J :s= Cc |dtdddddddddgidd}|j||dxxd z cc<|d j||d t d|d <|S) Nr.r7r9r rrnew)rrr6r8r:r$r;r4rAr<r=r>r@rDr/r0)r rqr~ MAX_MESSAGES)rRkwrWs rnew_msgrsxyy&PWbkw{ebRBZ\hj lAHHRLfINIjMjM<-.1AjM HrcRt|jdt}|s td|jdxsd}|tvr td|jdd}dvr1 t tfd |d Dd}|s td d|r|d }nSd |vr/|jd d vrt||d }|+tdtj|r tdnd}t||||S#t tf$r tdwxYw)Nr4z empty messager:r zto must be kills, live or bothr;)Nrrz bad parentc34K|]}|dk(s |ywrNr).0rWr;s r z#add_user_message..sAqw&/@1A r0zno such parent messager$)Nrz no such topicrr)r4r:r$r;) ryrNMAX_TEXT ValueErrorTO_USERint TypeErrorr.rrLrMrIr)rRbodyr4r:pmr$r;s @radd_user_messagers. &!8 ,D )) $ "7B 9:: XXh F B ]" +[FAa mA4 H56 6 7  DTXXg.j@1d7m, =_- -(t4d ) 14BeF CC:& +\* * +s . D D&c t|jdt fd|dDd}|s td|ddk(r td|jd }|jd r t ||}nKt |trt|d k7r td |d }t|t}|s td|tddf\|d <|d<|d<|d<|S#ttf$r tdwxYw)Nrzbad idc3FK|]}|dk(s |ddk(s|yw)rr6questionNr)rrWqids rrz"answer_question..s& UA!D'S.QvY*=Ta Us !!!r0zno such questionrA withdrawnzthat question was withdrawnanswermultir/zthat question takes one answerrz empty answeransweredF answeredTs answerPulled) rrNrrr. multi_answer isinstancelistr|ryrr )rRrqrawansrs @ranswer_questionrs#$((4.! U: UW[\A +,,z[ 677 ((8 CuuW~1c" c4 3x1} !ABBa&CC"^, ,BEsujZ_B_?AhK<!G*a.? H' z "#""#s C00D c>t|tr|g}t|ts tdt |t dzkDr td|j dxsg}tg}}|D]\}t|ts tdt|t}|s1||vr|j|G||vsL|j|^t |dkDrtd|dddz|Dcgc] }||vs| c}|z}|s td |Scc}w) zA multi question's answer: a list of its choices (kept in the choices' order) plus at most one typed "other" answer (last), the same free text a single question takes. An old page sends one string: a one-item list.zanswer must be a listr/ztoo many answerschoiceszeach answer must be textz:not one of the choices (only one typed answer allowed): %sNPzpick at least one) rrwrrr| MAX_CHOICESrNsetryraddr~) rrrpickedothersitemr)crs rrrs##se c4 011 3x+/!+,,eeI$"GUBFF $$78 8 $ !  < JJqM f_ MM!   6{QUX^_`XabeceXffgg -f1 - 6C ,-- J .s 7 DDc@eZdZdZdZdZdZdZdZdZ dZ d Z y ) ApizStickbashInbox/2cvtj|dj}|j||j dd|j dt t ||j dd|j|j|jj|y)NF)rez Content-Typezapplication/json; charset=utf-8Content-Lengthz Cache-Controlzno-store) r]dumpsencode send_response send_headerrwr|_cors end_headerswfilewrite)selfcodeobjrs r_sendz Api._sendszz#E299; 4  )JK )3s4y>: *5   rcp|jdd|jdd|jddy)NzAccess-Control-Allow-Origin*zAccess-Control-Allow-MethodszGET, POST, OPTIONSzAccess-Control-Allow-HeaderszContent-Type, X-Inbox-Token)rrs rrz Api._corss7 6< 79MN 79VWrc|jjdd}t|xr:tj|j t j S)Nz X-Inbox-Tokenr)headersrNboolhmaccompare_digestrr)rgivens r_authedz Api._authedsC   "5E{Tt225<<>57>>CSTTrc t|j}|jjd}|dk(rdt|jfS|j dr#|t ddt|jfSdifS)N/z /api/inboxrz /api/inbox/)rpathrstriprquery startswithr|)rprs r_routez Api._route st TYY vv}}S! < x(( ( ??= )M*+,hqww.?? ?Rxrcf|jd|j|jy)N)rrrrs r do_OPTIONSzApi.do_OPTIONSs% 3  rc |j\}}|dk7r|jdddiS|js|jdddiSt}|j ddgdt |dk(r|jd |dd d S|jd |d|d |d |d|d|ddy)Nrerror not foundwrong or missing tokenr1rr T)r1 unchangedr,r-r2r5r0)r1r,r-r2r5r0)rrrr^rNrw)rr&qsrRs rdo_GETz Api.do_GETs++-R "9::cG[#9: :||~::cG-E#FG G F 66%" q !S5] 2::c1U8$#GH H 3%AhKQz]hijthu#$X;AjMK Lrc|j\}}|dvr|jdddiS|js|jdddiS t|jj dd}|t kDr|jd dd iStj|jj|xsd ttst |dk(rtfd}nY|dk(rtfd}nEt!j dt"s|jd ddiSfd}t|}|jd|y#ttjf$r|jd dd icYSwxYw#t$r'}|jd dt%|icYd}~Sd}~wwxYw)N)rrr$rrrrrr0iztoo bigs{}zbad jsonrct|SrZ)rrRrs rzApi.do_POST..6s'74'@rrct|SrZ)rrs rrzApi.do_POST..8sq$'?rrz empty titlecPt|dtfd|dDS)Nr9rc34K|]}|dk(s |ywrr)rrUrs rrz*Api.do_POST..mk..@sIa!D'S.Irr5)rr.)rRrrs @rmkzApi.do_POST..mk>s&$Q@CI1X;IIIrr )rrrrrrNMAX_BODYr]loadsrfilertrrKrr`rqryr{rw) rr&_rrorerrs @@rdo_POSTz Api.do_POST%sQ - -::cG[#9: :||~::cG-E#FG G :DLL$$%5s;.take..us*,fAPQRVPW[\]d[ePeQwZ,fs r5r$) topicTitler;c3:K|]}|ddk(s|yw)rr;Nr)rxrWs rrz$cli..take..vs Nqw!H+7M1Nsr4r parentText parentFromc3xK|]1}|ddk(s |dk(s|ddk(r|jdsd3yw)r6rr8rArrr/N)rN)rrWrTs rrz$cli..take..{sKVai:6MRSTZR[_cRcjJ6quu^?TVs :: :)r rNrKr.r~sum)rRrUroorpendingrWrTs @rtakezcli..takehsLUBsAz] V9 )QvY&-@AdGTXZ`SaDaX;??4(T7d?qzU':$%( D!k.Q( W:&!'AgJt,f8,fhijqhr'stYZ[cYdTNa mNPTUjn&(j#&6AlO&(jAlO 1 ! "VQz]VVG< rFrdzHinbox: %d new answer(s) to your questions: run inbox.sh answers --to %s r<z+usage: reply ID [--to LANE] (text on stdin)z empty replyc|dD]g}|dk(s t}|dj|d|c|d<|d<|dj||dxs||d<|d d k(rd |d <y y)Nr0rr>r?r<r=r@rDr6r7rCrATF)r r~rF)rRrWrUrTmidr4s rrepzcli..repsz] T7c>AiL''tT(KL/3Q,AgJ) hK**43"#H+"2AhKyI-%.'  rr,icRt}|d|d<dk(r |c|d<|d<yy)Nr3r2r r,r-)r )rRrUrTr4s rrSzcli..sts=A+/q"9AjM$ w-11*( Qz]r)askpostz{}zbad json on stdinr:r r zto must be kills or liver4z empty textrr#rTrz"--multi needs at least 2 --choicesc t|jdxsd}dk(r7rdgdni}t|fddid id | d d d d d}|j||St|fddid id | dd}|S)Nr$rrr#T)rrr6rr8r9r[rF)r:r$r4rArrrrnoteposted)r:r$r4rA)rrNrrq) rRr$extrarWrrcmdrTrr4s rr#zcli..asksq$((7"3"@yDQEe|9>$"5BA[J[64.[VSX_ckq$+B2TY[HApFpvtnpu[_gopHrrr$r6)rr$r6answersc"g}|dD]}|ddk(s |dk(s|ddk(s|jdr0d|d<|d |d |d |jd g|d |dd}|jdrd|d<|j||S)Nr0r6rr8rArrTrr$r4rrr)rr$rrrrr)rNr~)rRrorWarTs rrzcli..anssCz] "V9 *qyD/@QwZS]E]fgfkfklzf{(,An% w76_`_d_denpr_s#$X;a oOAuuW~%)' JJqM "Jrunaskc\|dD]#}|dk(s |ddk(s|ddk(sd|d<yy ) Nr0rr6rrAr[rTFr)rRrWrs rwdzcli..wdsIz] T7c>ai:&=!G*PVBV!,AgJ rr5zpusage: inbox_server.py serve [port] | pull | reply ID | status | ask | post | answers | unask ID | topics | list) rargvpoprrr serve_foreverrrqprintr]rrrrrystdinrtrrr`rNrkrrG MAX_CHOICErrrKfromkeysr|r^)rportrrorr!rSrr#rWrr/rrr)rTr rrr4s @@@@@@@@rclir8_s 88ABCL djjo t}  djj5CD $q'l  fRj(a(  djj)aHI  djjeA>? D Ey## * HH( ) *fs 5R"R28R2(R/.R/__main__rZ)7__doc__rgrr]rkr%rr http.serverrr urllib.parserrrrNrdirnameabspath__file__HEREjoinr\rsrrrr{rr5r}rGrrQrHrIcompilerLr r*rXr^rqrryrrrrrrr rr8rrrrrCsK B,+++C+ zz~~k"Pbggoobggooh6O&P ww||D+& WW\\$ ( #8 ,1A. ; J )  Yb I&7rR BJJ9 : > ! H  Q* D< 2:SN SNl AEH zEr