&idZddlmZddlmZmZmZddlmZddl m Z m Z m Z m Z mZddlmZmZmZmZde de fd Zde de fd Zde de fd Zde ded fd Zde de fdZddedzfdZy)z] Link Approval Subgraph Dedicated workflow for link opportunity discovery and human approval )Literal) StateGraphSTARTEND)BaseCheckpointSaver)SEOCampaignState CampaignPhaseLinkOpportunityLinkOpportunityStatustransition_phase)link_discovery_phaseis_quality_opportunitygenerate_pitchLINK_QUALITY_THRESHOLDSstatereturnc Ktdt|jdgd|jdg}g}g}|D]}t|jdddz d}t|jddd z d}|jd d}|d z|d zz|d zz}t |r!t |d |d<|j |tjj|d<d|d<|j ||jddtdt|dt|||z|d<||d<|Sw)z Score and filter link opportunities Applies strict quality filters: - Domain Authority >= 40 - Monthly Traffic >= 5,000 - Relevance Score >= 0.8 - No blacklisted patterns z[ScoreOpportunities] Scoring link_opportunities opportunitiesdomain_authorityrdg?monthly_trafficiPrelevance_scoreg333333?g?composite_scorestatuszDid not meet quality thresholdsrejection_reasonc&|jddS)Nrr)get)xs I/var/www/html/eventheodds/langgraph-service/graphs/link_approval_graph.pyz%score_opportunities..;saee$5q9T)keyreversez [ScoreOpportunities] Qualified: z , Rejected: pending_approvals) printlenrminrroundappendr REJECTEDvaluesort) r opportunitiesscoredrejectedoppda_score traffic_score relevancers r!score_opportunitiesr6sd )#eii8Lb.Q*R)SSa bcII2B7M FH!sww115;SACGG$5q9EA3G GG-q1 #c>mc.ABiRUoV "# &%*?A%>C! " MM# 1::@@CM&GC" # OOC !$ KK94KH ,S[Mc(m_ UV"(8"3E !'E  LsE Ec Ktdt|jdgddddd}|jdgD]-}|jdrt||d {}||d</td |S7w) zC Generate personalized pitches for qualified opportunities z)[GeneratePitches] Generating pitches for r&rzeventheodds.aizsports betting analyticszAFree sports analytics tools with data from 50,000+ games analyzed)domaintopic value_prop pitch_draftNz#[GeneratePitches] Pitches generated)r'r(rr)r site_infor2pitchs r!generate_pitchesr>Es 5c%))DWY[:\6]5^^l mn#+YI yy,b1'ww}%(i88E!&C '  /1 L 9sABB'B(Bc <Ktdt|jdgd|jdg}|Dcgc]1}|jdtjj k(s0|3}}|Dcgc]1}|jdtj j k(s0|3}}|Dcgc]1}|jdtjj k(s0|3}}t||d<||d<|sd|d<|Scc}wcc}wcc}ww)z Human approval interrupt point Waits for human to: - Approve opportunities (optionally edit pitch) - Reject opportunities (provide reason) z([AwaitApproval] Waiting for approval of r&rrlinks_approvedFrequires_human_review)r'r(rr APPROVEDr-r,PENDING)rpendingoapprovedr1 still_pendings r!await_approvalrH[s 4SCVXZ9[5\4]]k lmii+R0G"^aaeeHo9N9W9W9]9]&]^H^"^aaeeHo9N9W9W9]9]&]^H^ 'b1155?>S>[>[>a>a+aQbMb!(mE !.E  ).%& L_^bs;?D1D 3D 7D=1D/D3D91D+D/-DexecuterDdonec|jdg}|jdgDcgc]0}|jdtjjk(r|2}}|ry|ryycc}w)z+Check if we should execute, wait, or finishr&rrrDrJrK)rr rBr-)rrDrErFs r!check_approval_statusrMtsrii+R0G 99%92>La55?&;&D&D&J&JJLHL Ls5A%c8Ktdddlm}|jj}|j dgD]Q}|j dt j jk(s0t jj|d<||d<S|Sw)z Execute outreach for approved opportunities In a full implementation, this would: - Send emails via the email service - Track delivery status - Log to compliance system z-[ExecuteApproved] Executing approved outreachr)datetimerr executed_at) r'rOutcnow isoformatrr rBr-EXECUTED)rrOnowr2s r!execute_approvedrUs 9;! //  % % 'Cyy-r2% 778  5 > > D D D1::@@CM!$C  % Ls A1B4&BN checkpointerc2tt}|jdt|jdt|jdt |jdt |jdt|jtd|jdd|jdd|jdd|jdtdttd|jdt|j|dg}|S)ab Create the link approval subgraph Flow: 1. Discover - Find link opportunities 2. Score - Apply quality filters 3. Pitch - Generate personalized pitches 4. Approval (INTERRUPT) - Wait for human approval 5. Execute - Send approved outreach This graph can be used standalone or as a subgraph within the main campaign. discoverscorer>rHrJrI)rVinterrupt_before)rradd_noder r6r>rHrUadd_edgeradd_conditional_edgesrMrcompile)rVgraphcompileds r!create_link_approval_graphras ' (E NN:34 NN7/0 NN%'78 NN#^4 NN9./ NN5*% NN:w' NN7./ NN%'78    NN9c"}}!*+H Or#)N)__doc__typingrlanggraph.graphrrrlanggraph.checkpoint.baserstate.campaign_staterr r r r nodes.link_discovery_noder rrrr6r>rHrMrUrar#r!ris 229)%5):J)X"27G, 05E2 !1 g>Z6[ "27G4/-@4-G/r#