jj)dZddlZddlmZmZmZddlZddlmZddlm Z ddl m Z eje ZdZdZd Zd efd Zd ed efd ZdZdZdZefdededefdZdededefdZddededefdZy)aKA tenant's connected Google Calendar account: reading it, refreshing its access token when expired, and everything below this module needs to call the Calendar API. The connection is written by the dashboard's generic OAuth connect flow into the tenant's own schema -- the same galaxiq_tenants database and per-tenant `integrations` table mailchimp.py's connection lives beside (see app/services/infra/database.py's get_setting). That connect flow lives in a different service, not this one; this module only ever reads what it wrote, and writes back a refreshed access token in place. N)datetime timedeltatimezone)sql)settings)get_db_connectionz#https://oauth2.googleapis.com/tokenz8https://www.googleapis.com/calendar/v3/calendars/primaryzgoogle-calendar tenant_idc  t} |j 5}|j t jdjt j|tdf|j}ddd|jsy|\}}}|5|tjtj krt#||}|sy t%j&t(dd|id }|j+|j-} || j'd xsd | j'd xsddS#t$r%}tjd|d|Yd}~yd}~wwxYw#1swYxYw#t$r5}tjd|d|Yd}~|jyd}~wwxYw#|jwxYw#t$r%}tjd |d|Yd}~yd}~wwxYw)adThis tenant's active Google Calendar connection, refreshed if its access token has expired. Returns {"access_token", "calendar_email", "timezone"} -- everything check_availability/create_event/cancel_event need. None covers every reason it cannot be used: no connection, a disconnected one, or a refresh failure (revoked consent). z2Could not read the Google Calendar connection for : NzjSELECT "accessToken", "refreshToken", "expiresAt" FROM {}.integrations WHERE provider = %s AND status = %sACTIVE AuthorizationBearer headerstimeoutz'Could not read the Google Calendar for idtimeZoneUTC) access_tokencalendar_emailr)r ExceptionloggererrorcursorexecuterSQLformat IdentifierPROVIDERfetchoneclosernowrutc_refreshhttpxget CALENDAR_URLraise_for_statusjson) r connexcurrowr refresh_token expires_atresponsecalendars H/var/www/html/strategist-ai/app/services/integrations/google_calendar.pyget_google_calendar_connectionr5s "  [[] !c KKNOy128$  & ,,.C  ! .1+L-* X\\0J"J =9  99 $ ~&>?  !!#==? %",,t,2LL,5 O  I)TVWYVZ[\  ! !  I)TVWYVZ[\  &  >ykB4PQsq EE>AE2;E>AG E/ E**E/2E;7E>> F<F7"F?7F<<F??G HG==Hr0c" tjttjtj |ddd}|j |j}|jd}|sytjtjt!|jd xsd z} t#} |j%5}|j't)j*d j-t)j.|||t0fddd|j3|j7|S#t$r%}tjd|d|Yd}~yd}~wwxYw#t$r'}tjd |d||cYd}~Sd}~wwxYw#1swYxYw#t$r5}|j5tjd |d|Yd}~d}~wwxYw#|j7wxYw)aExchanges a refresh token for a new access token, and writes the new token + expiry back onto the same row so the next call doesn't refresh again. Returns the new access token, or None on failure (a revoked refresh token is the same as never having connected).r0) client_id client_secretr0 grant_typer)datarz0Could not refresh the Google Calendar token for r Nr expires_ini)secondsz:Could not persist the refreshed Google Calendar token for zSUPDATE {}.integrations SET "accessToken" = %s, "expiresAt" = %s WHERE provider = %s)r'post TOKEN_URLrGOOGLE_CALENDAR_CLIENT_IDGOOGLE_CALENDAR_CLIENT_SECRETr*r+rrrr(rr$rr%rrrrrrrr r!commitrollbackr#) r r0r2payloadr-rr1r,r.s r4r&r&Vs :: %??!)!G!G!.-     !!#--/ ;;~.L hll+i L)1T/33J "  [[] 6c KK?@y12z84  6 6 C  G {RTUWTXYZ  %;b. /  6 6 /  %;b. / // syAE 7 E<F;AF/!F; E9E44E9< F,F'!F,'F,/F84F;; G9+G4/G<4G99G<<Hz/https://www.googleapis.com/calendar/v3/freeBusyz?https://www.googleapis.com/calendar/v3/calendars/primary/events connectionduration_minutesreturnc  tjtdd|di|j|jd|digdd}|j |j d |dd }|Dcgc]2}t j|d t j|d f4}}g}| t| } | z|kr< | z t fd|Ds|j d | z | z|kr<|Scc}w#t$r$} tjd| gcYd} ~ Sd} ~ wwxYw)aOpen duration_minutes-long slots inside [start, end], starting at `start` and stepping forward every duration_minutes -- slots land on the half hour only when the caller passes a midnight- or half-hour-aligned `start`, e.g. a business-timezone day boundary. Returns [] on any API failure -- an empty list of slots reads to the model as "nothing available", which is the safe failure mode (never claims a slot is free when the check itself failed).r rrrr)timeMintimeMaxitemsr)rr+r calendarsbusystartend)minutesc3<K|]\}}|kxr|kDywN).0b_startb_endrslot_ends r4 z%check_availability..s&X%v~<(W*<<Xs)rNrOz.Could not check Google Calendar availability: N)r'r= FREEBUSY_URL isoformatr*r+r fromisoformatranyappendrrr) rErNrOrFr2 busy_blocksbrMslotsstepr-rrWs @@r4check_availabilityrbsg:: $ >0J/K&LM ??,==?,?    !!#mmok2:>N3OPQWX %&''' 3X5K5KAeH5UV&&!12tms"}HXSWXX vh?@ dNF tms"  &  EbTJK s7A;D?7D6AD DD ED;5E;E visitor_email visitor_namec tjtdd|didddd|d|jid|jid |igd d |d |jiid d}|j |j }|j d}|stjdy||j ddS#t$r"}tjd|Yd}~yd}~wwxYw)aBooks the slot and emails the visitor a calendar invite (sendUpdates 'all' is what makes Calendar actually send it) with an auto-attached Meet link (conferenceDataVersion 1). Returns None on failure -- never raises, matching every other provider call in this module.r rrall) sendUpdatesconferenceDataVersionz Meeting with dateTimeemail createRequest requestId-)summaryrNrO attendeesconferenceDatar)rparamsr+rrzACould not create the Google Calendar event: response missing 'id'N hangoutLink)event_id meeting_linkz,Could not create the Google Calendar event: ) r'r= EVENTS_URLrZr*r+r(rrr) rErNrOrcrdr2eventrtr-s r4 create_eventrxs :: $ >0J/K&LM#(1E*<.9$eoo&78"CMMO4& 67#km_AeooFWEX3Y%Z#\    !!# 99T? LL\ ]$eii 6NOO  CB4HIsB4C 7C C6C11C6c d|i}|@|tdz j|d<|tdzj|d< tjtdd|d i|d }|j |j jd xsg}|j g}|D][}t|ts|jd }t|ts6t fd|DsK|j|] t!|dk7ry tj"td|dddd|d id }|j y#t$r"} tjd| Yd} ~ yd} ~ wwxYw#t$r"} tjd| Yd} ~ yd} ~ wwxYw)aFinds the event by attendee email (narrowed to a window around near_time when given) and deletes it. Returns False -- does not guess -- when zero or more than one event matches. The `q` full-text search only narrows candidates -- it also matches an event that merely mentions the email in its summary/description text without the visitor actually being an attendee. The final match is always confirmed client-side against each candidate's `attendees` list. qN)hoursrIrJr rrr)rrrrrKrpc3K|]<}t|txr&|jdxsdjk(>yw)rkrN) isinstancedictr(lower)rTattendeevisitor_email_lowers r4rXzcancel_event..sL.h-T W-3::<@SST.sAAz7Could not search the Google Calendar for cancellation: Frg/rrrTz,Could not delete the Google Calendar event: )rrZr'r(rvr*r+rr~rlistr\r]rrrlendelete) rErc near_timerrr2 candidatesrKrwrpr-rs @r4 cancel_eventrs= !F&);;FFHy&);;FFHy99 $ >0J/K&LM   !!#]]_((17R ,113 $EeT* +.Ii..#,.. U# $ 5zQ <<l!E!HTN+ ,$ >0J/K&LM  !!#  NrdST  CB4HIs7 B6E$E$$?F$ F-F  F F=F88F=rR)__doc__loggingrrrr'psycopg2rapp.core.configrapp.services.infra.databaser getLogger__name__rr>r)r!strr5r&rYrv SLOT_MINUTESrintrrbrxboolrrSr4rs 22 $9   8 $ 1 I 6c6r33C3lA N  NZ$4$s$^b$NTcQT@:T:#:$:r