J1i # LdZddlZddlZddlZddlmZddlmZmZmZddl m Z m Z m Z m Z mZmZmZej"ddZdgd d d d gd dddgdgdddgddddZddddZd dgddZd ed!ed"efd#Zd$ed"eeeffd%Zd&ed'ed!ed(ed$ed"edzf d)Zd*e d"e fd+Zy),z` SERP Features Optimization Node Optimizes content for featured snippets, PAA, and AI Overviews N)datetime)AnyDictList)SEOCampaignState CampaignPhasetransition_phase add_error add_warningOptimizationQueueItemSERPFeatureData NEXT_API_URLzhttp://127.0.0.1:3000zCWhat is X? X is [40-60 word direct answer]. This [benefit/context].) direct_answer expansioncontext)(<)format structure word_countz%Numbered list with clear action verbs)intronumbered_steps conclusion))rr step_countz*Table with clear headers and concise cells)rcomparison_tablerecommendation)FeaturezOption AzOption B)rrcolumnsz'Bulleted list with consistent structure)intro_sentence bullet_itemssummary)r )rr item_count) definitionhow_to comparisonlist)2dz,Question -> Direct Answer -> Brief Expansionr) answer_lengthr max_questionsz2Direct statement -> Evidence/Data -> Brand mention)zUnique data pointzProprietary methodologyzExpert authority signal)r,rdifferentiationfeaturekeywordreturnc(|j}|jddk(rD|jdry|jdryd|vsd|vsd |vry |jd ry y |jddk(ry|jddk(ryy)z7Determine the best optimization type for a SERP feature feature_typesnippet)zwhat iszwhat aredefinez meaning ofsnippet_definition)zhow tozhow dozsteps tozguide tosnippet_how_tovsz compared to differencesnippet_comparison)besttopzlist ofztypes of snippet_listsnippet_paragraphpaa paa_expansion ai_overviewai_overview_citationgeneral_optimization)lowerget startswith)r/r0 keyword_lowers ;/var/www/html/langgraph-service/nodes/serp_features_node.py!get_optimization_type_for_featurerICs MMOM{{>"i/  # #$S T'  % %&R S# ] "m}&D XeHe'  % %&L M!& ^ $ - ^ $ 5% !site_idc XKi} tjd4d{}|jtdddt j ddid d d  d{}|j d k(rd|j}|jdgD]?}|||jdd<|jds*|||dj<Adddd{|S777 #1d{7swY|SxYw#t$r}td|Yd}~|Sd}~wwxYww)z%Fetch existing pages for optimization>@timeoutNz/api/admin/seo/pages AuthorizationBearer INTERNAL_API_TOKEN PUBLISHEDr+)statuslimit)headersparamspagesslug targetKeywordz&[SERPFeaturesNode] Fetch pages error: ) httpx AsyncClientrErosgetenv status_codejsonrD Exceptionprint)rKrZclientresponsedatapagees rHfetch_existing_pagesrj`sM E<$$T2 D Df#ZZ. 45(GBII>RTV4W3X*YZ"-<(H ##s*}} HHWb1DD26E$((62./xx0?Cd?399;< D D D L! D D D D D L < 6qc:;; L(GBII>RTV4W3X*YZ%%(9%, (; )  H##z1}}xx( ) ) ) ) )$ % )  ) ) ) ) )$  C =aSABB CsC8CB7C?B?!B9"2B? C B;!C%C8& C1B=2C6C87C9B?;C=C?CC C CC8C C5C0+C80C55C8statec Ktd|d|d}tjj}g}d} t |d{}tdt |d|j dgD]z}|j dd j}|j d r6|j d rH|j |}|s@|jD]-\} } || jvs| j|vs+| }nt||} |j d d } | d k(rd} n| dk(rd} n | dk(rd} nd} |r|j dnd}tttj|| || |rdndd}|j||s.|j dij dd}||ksW t|| || |d{}|r d|d<|dz }}|dk(r|rt#|d d!t |d"}td#|d$t |d%||d(<||d)<t'|t(j*}||d*<|S77}#t $r}td|d|Yd}~ d}~wwxYw#t $r1}td&|t%|d d't|}Yd}~d}~wwxYww)+z SERP Features Optimization phase node - Analyzes existing content for SERP feature optimization opportunities - Queues optimizations for snippets, PAA, and AI Overviews - Tracks optimization queue in state z7[SERPFeaturesNode] Starting SERP optimization for site rKrNz[SERPFeaturesNode] Found z existing pagesserp_features_datar0rScaptured optimizedr3rAr$r4 r?ridpending needs_content)rrkrltarget_keywordrmrU completed_atconfigmax_optimizations_per_runqueuedrUz5[SERPFeaturesNode] Failed to queue optimization for 'z': serp_featuresz$SERP optimization API unavailable - z opportunities identifiedz[SERPFeaturesNode] Queued z optimizations, z total opportunitiesz9[SERPFeaturesNode] Error during SERP optimization phase: z SERP optimization phase failed: optimization_queuepages_optimized updated_at)rdrutcnow isoformatrjlenrErDitemsrIr struuiduuid4appendrwrcr r r r LINK_OPPS)rxrKnowroptimized_countexisting_pagesr/r0rhr[prlr3rmrkopt_item max_to_queuejob_idris rHserp_optimization_phasers8 CE)DTCU VWIG //  % % 'C68OL_3G<< )#n*=)>oNOyy!5r:; gGkk)R0668G{{:&{{;'"%%g.D-335GD!$**,.$**,'2I  !B'7 S #;;~r:L},*&)-dhhtn$G,tzz|$"3&!$+y!H  % %h /$yy26::;VXZ[ "\1g'9#%67(""19HX.+q0Os; g| a $66s;M7N6OOhikE *?*;;KCPbLcKddxyz#5E .E  UM$;$; rsF  ""ryy)@A X> :> ?D6 <B !0?B" " " ":S$Y.      4Z NfrJ