+
    ӎi                         ^ RI t ^ RIt^ RIt^ RIHtHt ^ RItRtRt]P                  ! ]RR7       R t	RR lt
R	 tR
 t]R8X  d   ]! 4        ]! 4        R# R# )    N)datetime	timedeltazahmad@bigalc.comcrm_dataT)exist_okc                 Z   R .pVP                  V 4       \        RRP                  V4       24        \        P                  ! VRRRR7      pVP
                  #   \        P                   d=   p\        RRP                  T4       24       \        RTP                   24       ThRp?ii ; i)gogzRunning command:  T)capture_outputtextcheckzError running gog command: zStderr: N)extendprintjoin
subprocessrunstdoutCalledProcessErrorstderr)command_partsfull_commandresultes   &   scripts/crm_ingest.pyrun_gog_commandr      s    7L&	chh|45
67TTXY}}(( +CHH\,B+CDE
#$s   %A B*.7B%%B*c                 R    V '       g   R # \        V 4      V8:  d   V # V RV R,           # ) N...)len)r   
max_lengths   &&r   summarize_textr       s+    
4yJu$$    c                  X   \        R \         R24        \        RRR\        RR.4      p \        P                  ! V 4      p^ pV'       d   RV9   d   VR,           F  pVP                  R4      pVP                  R	R
4      pVP                  RR
4      pVP                  RR
4      p\        R4       \        RV 24       \        RV 24       \        RV 24       \        RV 24       V^,          pK  	  \        RV R24       R#   \         d   p\        RT 24        Rp?R# Rp?ii ; i)zIngesting emails for r   gmailsearchz	--accountzlabel:inboxz--jsonthreadsidfromr   subjectdatez
--- Email ---  ID: z  From: z  Subject: z  Date: 	Ingested z emails.zError ingesting emails: N)r   GOG_ACCOUNTr   jsonloadsget	Exception)	email_outputemailsingested_countthread
message_idsenderr(   date_valr   s	            r   ingest_emailsr8   $   s)   	!+c
23.&h[-R
 L)i6) ++#ZZ-
FB/ **Y3!::fb1 )zl+,)*G9-.
+,!# , 		.)23 .(,--.s   C.D D)D$$D)c                  (   \        R \         R24        \        RR.4      p V P                  4       P	                  R4      p\        V4      ^8  Ed   . pVR,           F  pVP                  4       '       g   K  \        P                  ! RVP                  4       ^R7      p\        V4      ^8  dx   V^ ,          P                  4       pV^,          P                  4       pV^,          P                  4       pV^,          P                  4       pVP                  RVR	VR
VRV/4       K  \        RVP                  4        R24       K  	  ^ p	V F  p
\        R4       \        RV
P                  R4       24       \        RV
P                  R4       24       \        RV
P                  R	4       RV
P                  R
4       24       V	^,          p	K  	  \        RV	 R24       R# \        R4       R#   \         d   p\        RT 24        Rp?R# Rp?ii ; i)z
Ingesting calendar events for r   calendarlist
:   NNz\s{2,})maxsplitIDSTARTENDSUMMARYzEWarning: Could not parse calendar line (split by 2+ spaces failed): ''z
--- Calendar Event ---r*   z  Summary: z  Time: z to r+   z calendar events.zNo calendar events found.z!Error ingesting calendar events: N)
r   r,   r   stripsplitr   reappendr/   r0   )calendar_outputlinesevents_datalinepartsevent_id
start_timeend_timesummaryr3   eventr   s               r   ingest_calendar_eventsrR   @   s   	,[M
=>&7) 
  %%'--d3u:>Kb		zz||DJJL1Eu:?$Qx~~/H!&q!1J$Qx~~/H#Ahnn.G&&hx!7	(  abfblblbnaoopqr! "$ N$02uyy/01EIIi$8#9:;7!3 4D59I8JKL!# % In-->?@-. 71!5667s   G	G-  G- -H8HH__main__)   )r-   r   osr   r   rF   r,   
OUTPUT_DIRmakedirsr   r    r8   rR   __name__ r!   r   <module>rZ      s_      	 ( 	 !
 J &%.8(7Z zO r!   