51idZddlZddlZddlZddlmZddlmZmZmZddl m Z m Z m Z m Z mZmZej ddZde d eefd Zd ed ed edzfd Zde d e fdZy)zL Content Phase Node Generates and queues content based on research findings N)datetime)AnyDictList)SEOCampaignState CampaignPhasetransition_phase add_error add_warningContentQueueItem NEXT_API_URLzhttp://127.0.0.1:3000statereturnc4 g}tjj}|jdgD]}|jddrd}|jddk(rd}n-|jddk(rd}n|jdd k(rd }|j t t tj|jd d d |jdd g|dd||jd}|r|jdgddD]}|jdd  |jdd}|jdd}t fd|DrN|dkDr|dkDrd}n|dkDr|dkDrd}ni|j t t tj ddd g|dd||jdgD]} | jdgddD]} | jd d  t fd |Dr*| jd!d} | d"kDrd#}n | d$kDrd}nd%}|j t t tj d&dd g|dd||jd'd()|ddS)*a" Analyze research data and prioritize content opportunities. Priority factors: - Keywords with SERP features we don't own - High-volume keywords from GSC with low position - Content gaps from competitor analysis - Keywords where we have AI Overview opportunity serp_features_datacapturedF feature_type ai_overviewsnippet paakeywordserp_optimized_articlependingN)idr content_typetarget_serp_featuresprioritystatuspage_id created_atgsc_data top_queriesquerypositiond impressionsrc3.K|] }|dk(ywrN.0ors 5/var/www/html/langgraph-service/nodes/content_node.py z3prioritize_content_opportunities..GBq1Y<7*B2 seo_articlecompetitor_data content_gapsc3.K|] }|dk(ywr-r.r/s r2r3z3prioritize_content_opportunities..br4r5 searchVolumeiicompetitive_contentc |dS)Nr!r.)xs r2z2prioritize_content_opportunities..zs Qz]T)keyreverse) rutcnow isoformatgetappendr struuiduuid4anysort) r opportunitiesnowfeaturer!r%r(r)r+compgapvolumers @r2 prioritize_content_opportunitiesrVsM //  % % 'C99126{{:u-H{{>*m;^, 9^,5  !1tzz|$ Ir25&-kk."&E%F!  " 0yy$H\\-4Sb9 Eii,GyyS1H))M15KBMBB"}s!2B;#3  !1tzz|$*&/%7!  " # : +R088NB/4 Cggi,GBMBBWW^Q/F}#  !1tzz|$2&/%7!  "  82DA " rD opportunitysite_idc K tjd4d{}|jtdddt j ddi||d |d |d |d d dd{}|j dvr2|j}|jdcdddd{Sdddd{y77W77 #1d{7swYyxYw#t$r}td|d d|Yd}~yd}~wwxYww)z2Queue a content generation job via the Next.js APIg>@)timeoutNz/api/admin/seo/content/queue AuthorizationzBearer INTERNAL_API_TOKENrrrr r!langgraph_campaign)siteIdr contentTypetargetFeaturesr!source)headersjson)jobIdz[ContentNode] Queue error for '': ) httpx AsyncClientpostr osgetenv status_codercrI Exceptionprint)rWrXclientresponsedataes r2queue_content_generationrt~s8 P$$T2 ) )f#[[. <=(GBII>RTV4W3X*YZ%*95#.~#>&12H&I +J 72 )  H##z1}}xx( ) ) ) ) )$ % )  ) ) ) ) )$  P / I0F/Gs1#NOO PsD C CC A C -C.2C  C ,C-C 1D 2 C =C >C D C C C C CC CC D C D)D=D DD c DKtd|d|d}tjj} t |}tdt |d||d<d}|j dij dd }|d |D]#} t||d {}|r d |d <|d z }%|dk(r3|r1t|dd}|d dD]}d|d < tdt |}td|d||d<t|tj}||d<|S7#t$r+}td|j ddd|Yd }~d }~wwxYw#t$r;}td|t|ddt|}g|d<d|d<Yd }~d }~wwxYww)z Content phase node - Analyzes research data to prioritize content opportunities - Queues content generation jobs - Updates state with content queue z.[ContentNode] Starting content phase for site rXz[ContentNode] Prioritized z content opportunities content_queuerconfigmax_content_per_runrNqueuedr"z[ContentNode] Failed to queue 'rrrgcontentzAContent API unavailable - opportunities identified but not queuedr8rz[ContentNode] Queued z content generation jobspages_generatedz*[ContentNode] Error during content phase: zContent phase failed: updated_at)rorrGrHrVlenrIrtrnr minr rKr r SERP_FEATURES) rrXrQrP queued_count max_to_queueoppjob_idrss r2 content_phasers :5;K:L MNIG //  % % 'C'%8?  *3}+=*>>TUV"/o yy2.223H"M  ,/ C 7WEE$,CM A%L  1 y2uvE$Ra( * )H  *q#m"45L %l^3KLM#/  UM$?$? @EE, L?F  7 28N7OsSTRUVW  % :1#>?%.DSVH,MN!#o#$ %sl9F AED" D !D"1AE?!F  D"" E+!E EEE F"1FF FF )__doc__rkrLrhrtypingrrrstate.campaign_staterrr r r r rlr rVrKrtrr.rDr2rs  ""ryy)@A b,<bFVAWbJ!  4Z6:/:4D:rD