{j] bddlZddlZddlmZmZdZGddeZd dZdZ d dZ d d Z d Z y) N)Requesturlopenzhttps://api.buffer.comc eZdZy) BufferErrorN)__name__ __module__ __qualname__+/opt/struktur/asol-runtime/buffer_bridge.pyrrsr rcd|i}|||d<tttj|j dd|zdd}t |d 5}tj |}dddjd r!t|d d jd d |jdxsiS#1swYPxYw)Nquery variableszutf-8zBearer zapplication/json) Authorizationz Content-Type)dataheaders)timeouterrorsrmessagezBuffer GraphQL errorr) rAPI_URLjsondumpsencoderloadgetr)tokenrrpayloadreqresponsers r _gqlr! sG(  ' 7 3 : :7 C"U**N C b !#Xyy"# xx$x.+// ;QRSS 88F  !r! ##s B88Cct|dS)Nz){ account { organizations { id name } } })r!)rs r _accountr#s B CCr c|sLt|jdijdg}t|dk7r td|dd}d}t ||d|ijd gS) Naccount organizationsz3Buffer account must expose exactly one organizationridzquery Channels($org: OrganizationId!) { channels(input: {organizationId: $org}) { id name displayName service isQueuePaused } }orgchannels)r#rlenrr!)rorganization_idorgsrs r r*r*sv ""9b155orJ t9>ST Tq'$- E uuo6 7 ; ;J KKr c,|dk(rdn|}t||Dcgc]}|jd|k(s|}}t|dk7rtd|dt||d}d}d ||d d d d di} t ||| jdxsi} | jdrt| d| jd} | r| jd s td| d |d |jdxs|jd|dScc}w)Nreels instagramservicer'z(Expected exactly one Buffer channel for z, found rzmutation CreateDraft($input: CreatePostInput!) { createPost(input: $input) { ... on PostActionSuccess { post { id text } } ... on MutationError { message } } }inputr( automatic addToQueueT)text channelIdschedulingTypemode saveToDraft createPostrpostzBuffer returned no post id displayNamename)post_id channel_idchannelr1)r*rr+rr!) rplatformr5r,r1cmatchesr@mutationrresultr;s r create_draftrF&sC%0khG"5/:ZQaeeI>NRY>YqZGZ 7|qDWIXVYZaVbUcdeeajG H T]% I%9 - 1 1, ? E2F zz)&+,, ::f D txx~677Dz7;;WdKeK|ipititu{i|JQ RR/[s DDctjj|dj}|st d||S)NzMissing )osenvironrstripr)r=rs r token_from_envrLAs9 JJNN4 $ * * ,E HTF+,, Lr )N) rrIurllib.requestrrr RuntimeErrorrr!r#r*rFrLr r r rOs; + " ,  "D LR6r