u1iM(dZddlZddlZddlmZddlmZmZmZddlm Z m Z m Z m Z ejddZde d efd Zde d eeeffd Zde d efd Zde d eefd Zde d e fdZy)zN Performance and Reporting Node Generates campaign reports and tracks metrics N)datetime)AnyDictList)SEOCampaignState CampaignPhasetransition_phase add_error NEXT_API_URLzhttp://127.0.0.1:3000statereturncpK tjd4d{}|jtdddt j ddi|d |d |d |d ||d t jjk(rd nd|jdd|jdd|jdd|jddd d{}|jdvcdddd{S77%7 #1d{7swYyxYw#t$r}td|Yd}~yd}~wwxYww)z'Save campaign state to database via APIg>@)timeoutNz/api/admin/seo/campaigns/save AuthorizationzBearer INTERNAL_API_TOKEN campaign_idsite_id campaign_type current_phase completedactivepages_generatedrsnippets_capturedlinks_approvedlinks_acquired) campaignIdsiteId campaignType currentPhase stateSnapshotstatuspagesGeneratedsnippetsCaptured linksApproved linksAcquired)headersjson)z[PerformanceNode] Save error: F) httpx AsyncClientpostr osgetenvr COMPLETEDvalueget status_code Exceptionprint)r clientresponsees 9/var/www/html/langgraph-service/nodes/performance_node.pysave_campaign_to_dbr:sN4$$T2 6 6f#[[. =>(GBII>RTV4W3X*YZ"' "6#I.$)/$:$)/$:%*-2?-C}G^G^GdGd-dkjr&+ii0A1&E(- 2Eq(I%*YY/?%C%*YY/?%C )H '':5# 6 6 6 6 6 6 6(  4 .qc233 4sD6DC7DB1C=C9C=% D1C;2D6D67D9C=;D=DD D DD6D D3D.)D6.D33D6c2|jdg}t|Dcgc]}|jddk(s|c}}t|Dcgc]}|jddk(s|c}}t|Dcgc]}|jddk(s|c}}|jdg}t|Dcgc]}|jddk(s|c}}t|Dcgc]}|jdd k(s|c}} |jd g} t| D cgc]} | jddk(s| c} } t| D cgc]} | jdd k(s| c} } |jd g}t|Dcgc]}|jdd k(s|c}}t|Dcgc]}|jdd k(s|c}}t|Dcgc]}|jddk(s|c}}t|Dcgc]}|jds|c}}|jd}d}|r^|jdd|jddt|jdddzdt|jdddd}g}|jdgD]N}|j|jd|jdt|jdgdP|d |d!|d"|jd#gt ||||t|d$|| |jd%dd&| | |jd'dd(t|||||d)||t|jd*gt|jd+gt j jd,Scc}wcc}wcc}wcc}wcc}wcc} wcc} wcc}wcc}wcc}wcc}w)-z+Generate a metrics summary for the campaignserp_features_data feature_typesnippetpaa ai_overview content_queuer"queuedroptimization_queuelink_opportunitiesapprovedrejectedpending link_acquiredgsc_dataNtotal_impressionsr total_clicks average_ctrdaverage_position)rJrKrLrOcompetitor_datadomaindomain_authority content_gaps)rRrScontent_gaps_foundrrrphases_completed)snippet_opportunitiespaa_opportunitiesai_overview_opportunitiestotal_opportunitiesr) pages_queuedpages_completedrpages_optimized)optimizations_queuedoptimizations_completedr])opportunities_foundpending_approvalrErFacquirederrorswarnings)rrrrVduration_seconds serp_featurescontent optimizationlinksgsccompetitors_analyzedrcrd generated_at)r2lenroundappendcalculate_durationrutcnow isoformat)r rff snippet_oppspaa_oppsai_overview_oppsrAccontent_queuedcontent_completed opt_queueo opt_queued opt_completed link_oppslrlinks_rejected links_pendingrrI gsc_summarycompetitor_summarycomps r9generate_metrics_summaryr0sII2B7M=WaAEE.4IY4VWXL}O!n0E0NAOPH}_!n8MQ^8^A_`IIor2M]RaeeHo6Q!RSN X1xK9WQXY .3IJAaeeHo.IaJKJIPqxK1OPQM .3IYP!%%/Z2O!PQNYP!%%/Z2O!PQNINqxI1MNOMYI!%%2H!IJNyy$HK!).A1!E$LL; mQ!?#!EqI %hll3Eq&I1 M   +R0 !!hhx( $); <"%dhh~r&B"C#   ]+#/!II&8"=.u5&2!))9#&}#5  +0$yy):A> %/'4$yy):A> $'y> -&&&   2eii"-. *b12 )335Q) )SXO_SXKPQPNIsO"O" O'$O'8O,O,8O1O1&O6O6&O;O;P.PP.PP P 0P PP5Pc tj|jdd}tj|jdd}t||z j S#t $rYywxYw)z&Calculate campaign duration in seconds started_atr updated_atr)r fromisoformatr2int total_secondsr4)r startedendeds r9rprpsg((<)DE&&uyyr'BCEGO22455 sA%A(( A43A4cg}|jdg}|Dcgc]+}|jddk(s|jdr*|-}}|r|jdt|d|Dcgc]}|jddk(s|}}|r|jdt|d |jd g}|Dcgc]}|jd d d k\s|}}|r|jdt|d|jdg} | D cgc]} | jddk(s| } } | r|jdt| d|jd} | rL| jdd dkr|jd| jdddkDr|jd|s|jd|Scc}wcc}wcc}wcc} w)z=Generate actionable recommendations based on campaign resultsr<r=r>capturedz Optimize zd pages for featured snippets - focus on 'What is' and 'How to' query formats with 40-60 word answersr@zTarget z^ AI Overview opportunities - ensure content has unique data points and clear authority signalsrApriorityrz Prioritize zJ high-priority content pieces - these have the best SERP feature potentialrDr"rGzReview zV pending link opportunities - all opportunities require human approval before outreachrIrLgQ?zdCTR is below 3% - consider optimizing title tags and meta descriptions for click-through improvementrOrMzfAverage position is outside top 15 - focus on content quality and internal linking to improve rankingszfContinue monitoring SERP features and competitor movements - run this campaign weekly for best results)r2rorm) r recommendationsrfrsuncaptured_snippetsrvrArw high_priorityr~rrGrIs r9generate_recommendationsrs!OII2B7M&3tquu^7LPY7Ybcbgbghrbs1tt/012T U $1[aAEE.4I]4Z[[c*+,-P Q IIor2M -K1z11E1JQKMK#m,-.9 :  .3I#DQquuX)'CqDGDc'l^$G H yy$H << q )D 0  " "0  <<*C 02 5  " ";   8 ku\LEs4GGG/G GG GG6Gc Ktd|dtjj} t |}td|ddd|ddd t |}td t |d |jd i|d <|||jd g|jdgd|d d< t|d{}|s tdt|tj}||d<||d<td|S7B#t$r}td|Yd}~Od}~wwxYw#t$r}td|t|ddt|}|jd i|d <dt|idg|jd g|jdgd|d d<Yd}~d}~wwxYww)z Report generation phase node - Generates comprehensive campaign metrics - Creates actionable recommendations - Saves final state to database - Marks campaign as completed z1[PerformanceNode] Generating report for campaign rzerformanceNode] Metrics: rgrz pages, rir`z link opportunitiesz[PerformanceNode] Generated z recommendationsconfigrcrd)metricsrrcrd final_reportNzB[PerformanceNode] Warning: Could not save campaign to database APIz3[PerformanceNode] Database save error (non-fatal): z+[PerformanceNode] Error generating report: reportzReport generation error: errorz$Check system configuration and retry completed_atrz$[PerformanceNode] Campaign completed)r5rrqrrrrrmr2r:r4r strr rr0)r nowrrsavedr8s r9generate_report_phasers =eM>R=S TU //  % % 'C% *51 +GI,>?P,Q+RRZ!"7899LN O359 ,S-A,BBRST ))Hb1h.ii"- *b1 + h' M-e44EZ[" UM$;$; rs  ""ryy)@A %5$4W$4Wc3hWt.3;$4;c;|;'7;