From 69b734c0636948b35d4501fd30bc06df8a866c7c Mon Sep 17 00:00:00 2001
From: Flatlogic Bot <support@flatlogic.com>
Date: Sun, 22 Mar 2026 23:51:15 +0000
Subject: [PATCH] Autosave: 20260322-235115

---
 .../__pycache__/resolution.cpython-311.pyc    | Bin 5339 -> 5292 bytes
 core/services/resolution.py                   | 103 ++++++++++--------
 2 files changed, 55 insertions(+), 48 deletions(-)

diff --git a/core/services/__pycache__/resolution.cpython-311.pyc b/core/services/__pycache__/resolution.cpython-311.pyc
index 0d33cccbaf50ef6cc12c043fb4f50e84571beb66..7d58b8cab7fb50a91a384f6ebccf664792cbe7ba 100644
GIT binary patch
delta 2896
zcmZ{lZEO?C8OLYe?6tjiUhLS(1rtXxNlYMykV`q<LP{W@3%+XtL~sG0@opT06PwvJ
zfoR>J>Q3?@Bm#R96<mc?QJM-q^uAry7oF6oA1ga@mDN^}_<G+Q9Z0C3`pnu%F3^s5
z|2zB4JkLBcJM;6uLoY+l-#eXl1m()Y_sJ*UI=$3!?nXAPNO5A^C{(TT<4&kNLK3<}
ziRcn7QkNK!{sLWMMFx};*>M!&v=nujqO=O*@!T@ID;w_cc8z*Sw>arqJfxy)wDvvU
ztwrc36sNtRdj-m1Whpf!6DRFM=Bi}`DtD0fjF}j+LY0C0$0>;L2#M5BL#xzt@OiO0
z*c0>{I!7y;V<A+awFkVLLn5ux+CJ99*pRB7<=a0{X_0x!K8LO^HoNB-l__w<L9^0z
z{S;E1FmkP^%r%mWSw!v~M>c_SoXQq>;@pZv%l5p6(dC((MYR-cq}_)^>-P4Xb)&5f
ziTpclylTaRDvyt<T)|$QjcP48YH8L}yjJh<j*7PJZle7gdb@=}_hwaY9CaY2d1E37
z1rZMAY}=O1Ssg@ls5Y`>3kejbFCtOM*?wsouRZ6eIdqG;h~}t}bN-Y)P%EEGcq)x&
z0<nOcoXMtQiX;YPDTd?If%I%(B%MyAq(D|q&L#p_x{;M+Mef~no)1hbN=7~u4$sZa
z^(M^Dz47$IOt>0i@W#=3*9jb(OA-I`W21)xKah<aq718&oRQL5W!^EZ%%plVF)T}X
zo)eQddlLpdeZZh%20M+VsSs^&N>WKl29w39`MU9Ha#OKnN)itRA|V&%A*5kRr4tDW
z8*FlR0cPYPHYOn{Mm>%tWhn}_sI0`4tc=O-G+0Htr5G02#!_4{?A2#9Ju4ZOSSBOQ
ziUtqfQL~rr<gK`rQIhFdgOe~$<B%OUkRWgjC48HBlNF0Xf(DPJ1v!(Rl_fYM>1@WZ
zVoA=X6xpB>hTWV=6vmt}Y_KTTt5r&p$+B#GlRyABlIV~e2|M2~Azd|BQNq1dlN*}l
z2{=V}P=!a{5$dnpchaAPzX-*qQ^lr*Q+fLu@4D}}>nM8m7cPOoRpR@~d|#38tFUgH
zSNFAkt*-jIR(xGc_V0dP^mUbdgJs`f{<JQ5R)t+F!mg6gRTjF6Lf4u*P-uSU|D&_y
zK2~-g%MVv9$k&n|dDYbN=(C5P6?~<pP`N2oK~|@a$bxT?()~N1PClMo3YPrgvOm0N
z*LV1zjy@h;a+h}OE$`U7Xw%*P3St|41#pCi?rD7#c^J{#dsf@~SK9ka?E~fZ0llsJ
zY3^}u=|ZWkzueYe;h3Pef<V?0)8u<i1YVnbZ($ict@+5?wYuiYHALH>*M_VKjrT|I
zjuu;bm-d6eRT9EwAzT!~y1OZVX6yGBN`(VIc*+E$-=1)sIEwy$)IPkAS+?#R?qQa9
zQKa6(fkr|W?Vpz3De^V&evm&P>>+jX^)UIOrr4k&9|5_u`K!=0$3uo77M63s0&Ixz
z0SBqSFW95qw$2H+Os3ipVd_KLt9kj08pk)-C&8X$a;#$4{>JYPij0a>LQB}{FUWQ`
zi`j|Gu_C9Uf`u@n3&00x+s0IaWR;6<q7xuyLXr^nAca&K*!VeNqsX^xL`I@bw0}u&
zy#pVuD!OhCjZasz3P4uY|C1FDsW(FEJwM}AUUZ1UOXqVIa)-NGfQ7Ld3&|4K3b3#T
zSm=d+p}b?~5z(chCrGSQZ7>P;U6=w9ZG?y-VWL_42@~tJZsD-@E1|X1uzY%QZ2Xf*
zh%p?}EF9R|QRQ|<GPs+uR2Jv}hZ@Hv?H|HN9j%Z?<cB^`qi$$?{F4)BhR&TFj!v98
zcREqc@Rb&JrWTyl%|NyYwvgV|^wn#C9ocXa#sHb(SOWB7GF<|UOez+a3|nS8t)xw=
zuyX9CggFwRlZc;47YLB38y<!=PB07nbJbW>qYgfX&=4}HsA0)SSO$VI&|)}avYd`5
zVazB@%dl;};(ZY9JsN5ET_d~AmfKb6*gI{_Yu><v)Yqx}i0%(Qz4G|V(#ev)uk7#3
zM>M|9zwpL_TH3yGtv2_sH23Q}g1Wa=_xUSU)bimvVq09ViF|b?e`;~4Vn=}#RUDgG
z9gD7vMT?)ui_&yyELk2)7Td1Fl|NM$cIa@9Kfe3%S7+~?&7TDXHFs7}y%SCg$RhJ9
z&`}t9CM=CFU0oV42lhu6ojP#q<cd2~bcfbDLeGw^b_}j`4C=u>`pzD`Z5N~xJWfF_
zK`-PI^gb9}JoD=tZ(OLUz3k~;^$e_d2K3H7dS_VQeOQ~T_tW{a+MnysFAP(|ELvvm
z!yhrruE20Vv)s=?Jrd$D*$empk$&=31oDrQjL%5QbXvsY#6Cb|ixLOPE0HkV@?MZF
zO6Xieh2G6IR}jcLgDj0-OoG8(vzX>;sDs*X8}3m9TDWnDYSeBt4xYP0!V&VoKZFI<
zd-96eGZLck1X$lo6`unuo+R>4h8Kv9$YqUnA9k9llh;rK7PL|Kg#+fC%?)WH&zzCz
zG(bEzr}`iM$V^(yrle!|s`fAUd2d${{f|pK?(zI0NWo`)U)G83^;W|uwTFV$d0*Cv
Q?e$i}r1m>cA4^jCFN%=tdjJ3c

literal 5339
zcmbstTWlN0agXGY$CsYe!=hxLEhQGMn3QE%ex!*ZTe7U!rX9(V8zISo;;pE&PdsMt
zXh|$p2!&Cofq^JN3a5#K@XK{-1NBEg^69_iqXkHTfQSPO7$|}wKtE{M0Stc>ojvj>
zQnC=FT^?t5XLk2yXJ%(+@6TSZ3qkqM(nBfjMd+WjV-{Pv@$_%dxP?R{GBTPj)yy;l
zeT!_Fw@zCbinGeLd3Ktew@=&W9n%g2XOp>k=d^R)HSJ=M1!3l@+gu!b?l1`5gMX<^
zdo5@TiR=v|+V5C^0{=3l&Y(De!fm0{8x$u{Tw5p&A~T5s?jPwA;Q*t1PvJ;XlV+3h
zq>@Yoth#+Pu1VUG?wP=HM3a=bIwvJ`J5Wg!2Q0cHN#v`F6xTUuBqBt`(K0_qW%B*B
z2fDWqMpPct7Ll2@ik2H_+9p~7vZ4*3U1Wh5yY9MzXHJvIf{aNj?Bb!6d%ULbcu^yf
zsK!h2S%u6S9PzV6ndh}R%rD>>enHaal%&QJEH6p%7_Y?n;Y;Ic&{!y1kruE+^=5_t
z)88AsrI|Dmpj9dwrIgFn%B(wpxo4sgjIWGJqpOwnRnsC+hOG>)YKV+zk(gS&Qaga%
zTf-^WJ1QmzhhsRdrIZUwN|NPB=t!`i@4X_$MP)(d!<YF({lWg%c|Z&ezRoWW4F>q(
zL_)?OxpR^hI&%1E@bD1dd+zMz3+G?sW$7B`$8hwT65vnIfv|As(4pf&SOQj^jLb%e
zRGtFTcdA;1XaZ<c=Lr5ViB(P29g|p9LHW8vH5+p{B4VQI_GChgXw(#JDwb!72R5ow
zf${u{*F$skWyzUjTuX-VB910Cg@hIqa!pM{qBs;)2oAw^uS-#^h6q*_8LUr<2NO#=
zCkRqp(gY#ZylD_Y6A6b9sbK&ssIY6_s_kaoqqaTyw*9%bK)x*ieNTb&-1OwR&JC`6
zo$D@m+KUMJ&s&OC%PX!Y$l`QAqo7y|p2CXg<yJBalv_xn1Ii_1TDOTXYLQ7ZU!t!p
zTlJepnTj1%Pe^aE1h4{2YS1uOYWo)=Qk(}{AWM7#&Y8x8-5Z7;rAGuTykyyQXv#N9
zbw{n<Akv{HczTFsB^JX(x6xChHw&sXpM=wl1yNF?%5_YZzOj%dU`l5};bf_-KhkWV
zjI~k?RZ1{0J|L<`0IZ;&IOMGV*!__^>l?Ux1OPla?r@$voaGJ|In?0WsNcU{zyB_q
zs}JVugIO*}T3}|4py^RDj^hwCz>R_!MT=;?ZH41vOEW3JiY)ENEI=_acF_SCM&xc=
zKyc2mZof1-F?lhZ;;xLIIygRZ@DS|ZrY$9~&R&nmNvyjh5yUCYO5k3+!>X!8B@hL#
z%<`2v1A6`N<mAQE<HMInM}#Zmm(Nlms)o<g?I7bA*2o@U2&|r?i)j*8buYM_ii=dg
zL8JplREv`A0z_(el^|cDiQRP41b`I;lIz%acl2RLw&6THg<X5^Ui=p4UOSzgd_UXp
z0X#+4x~s0}LY)=L1wae%fSK>EE4sM`R}qzf(`Cp!9B|O16_3ngLC{@-Ft3P7nYKNG
z@L@6{mnjZG5S6GP5UOX=NdaY_?5BV#&#(?c!=eG4&`{3-SgHJq77NS40Rv!XSvYDH
zP{*+$;L8L)7Yl4|2c`GWS481oDdsWS5>zl)$_-TOq9MRgyRhnQVXRTVGh$l&WXbD9
ztIx0lUSXKvfQ_1<6KPdck-5L+OfQ3pzT5|-QSIqpwrH@TSvDg@rV49P!OX4qZME~?
zgDo#xmu(`u%%&|nL=}4s)kgOb^!{hdc8z-Ea{0M8r{OqJEtd-PxT>D@zVi-9=N^@i
zQ4Fpez?G|ZWQNLdTM^x&r<OnJCDRUpGl!<_JM7FW*4560S=8Q)l6GW_+|2Bob*&*V
zsCI8+{WZgk2yn2>-u&Z^Qf+vNRKH&4c93c%Z!@`|b(#|!H|2Q0saCg{D*bHEs^xy!
z`3v9I{C~dBm3ET8w2K5Z>cq<BXRXJXcEMh&EJ*a-Z@B|Dey?KZ47!;~vx!5$Xg}zG
zk=Z2bMjG{7<<f&l-?Cey{<T~(4Q8vl7F*NkOC+|X-C&<v&LM-|g&?%-{;iwls-@Nf
zvw#+@@1g}J(4IP0iQAVjp&6>mS7I!mRB31i_g_kAYh!oooTeqz6QR(;!a^{nC@~oa
zqsn}MF*2%DQ)L<^{AfHT#WAGoHtMXy<Q3rGh)0Bn7I-_i5tNn$8uttw=>|fo-+V_T
zAq7Rqxn^*L(6@w+1{XsKX%Wi@A%O^~*JCGDjKw!zF#HRqkL-oXy5pVjx$wm+VL~NH
zUZsF83JmhJ-2))@kH6FM?~?(W?k$B&p~Q*qEk#YU+gKed4K{WA0+wQPS}HI~2&6c`
zIF%oj*aDt8I1^E^SS3rK@hJ;rH;ttbWCSQX@Sr=CnX5PoNvjv4w4e|nN-zX?-AaQt
zwL{%Oa6*RkQ+Foj6iqR5-TKX}K!_?LhHN%+9qaa4N!B29VrM0yYJ}z}x^r|fiW4+V
zC2h3NV#;v9L;S|#Msh@xEl7(ahKO`V(Cx4v6%uHgE(nyO+sl%HEL$#NIMoynr<pAV
ztJFWx^v*1$w9Ho)kf4B7X@UxxjLxNA+ab&aUpBfA7FPSf4MM8n>T$L|YUQ(ir?agi
zxz>?<>&WU@p}FJM8=t<BX~{M3&o}R19r>Ys_wBlk_QCb`!R(1}wtX<yelg#E@ekvx
zXV!)vx9nOyQ|RQsKKsSl%=Ck%T<2iEbFhfq-W~(2agRFp-41Vb9$W7`R^WT@w&wZ%
zLdU+$(R@c=!N0fYKwZb5AX`_{GYUR&uGv3lAi3#DGuf#RvchbBDz-7DtWPP~gqlq*
z=BAeNQ%l+I-@vnG&o}Uez@fi({-yJQ{BS%M2<HP~ihZ@v(0a@LsrwV}XWljM<7WTo
zXY$S6nZ@<yP_{W#=;~fO^Zap{Y2m?4uJd@l^Ef0U-c|zu)Be4;-`w!`ulxHSEI#D&
zN5`}N{+$1<y#K8Y|D|>RrJR2v@1OVu1A&PmvNyJ7AUT5Sk&n;&dN+JS>%O7Ft3mo4
z7<e$0KX9V3XJ65YT8=(JY)k7i3LuASX?<R-L%xn|^VnBYw?EkE8d&cd__ih6HIVB%
zneRHe(KWi>HJa-h%Xf`sJ!8**sE3=6#aRU&d73^x|IzvEuD2h)0|1`yBc(d$naF!4
zvYv@TbKBaW`Fjqf$ifm(tL<PkzZ=^<wikW3*LAkl`duG?w$b{1BMa?tfF->^Cjkl$
z0MI>foz$f0Jce7jNG?$PmJISB#Zf@VtF*D1K^EA?qNSGw-T^$ZB74(~_cjp*wv;2%
zX;JuBikYN5rH*Rz!vo}qkP+TsYQro23;|gptGA6BUppo$7twN-_^&ViM9YsSqvpEw
zMKn32{ioFL&>IWAx`i(r8w4lpsd6cin%<1wk|4@VWJZ$V+lrvg!OeG0kwulR2FJW~
z!W)eH@O3Pd*3p(yy*scM+&c0KtfSHl2~M^hu3xKKIrnGC+koAsCPHu0WQu|<+POq=
z6i}i%0AP!DEUb^F_$5$Lk%=%!B^A*{z*~Ev(jD|d3a(wZ&ZvWg?pk-#ZvjELj9^(c
z+_d3riQ&>c@HIk~W`f4|B|@`HLX$?_2`>G-akVX(9d*a0a6s+BV0+7cUU0uE-FMz3
z@4*nNLG>p9MJvNF1ysLc{0gXU#rPFaSGM*kpuz0UPXQgszU+DI>{xBfJ3Br<mUH&x
zojoh|qHPZYcb@Iw3B^6zB%ERnFkt`N!4rymwn_LkV`D%I+X1*##s@BS8`aRue*tcB
B?O*@^

diff --git a/core/services/resolution.py b/core/services/resolution.py
index a1ab8ad..571c2a2 100644
--- a/core/services/resolution.py
+++ b/core/services/resolution.py
@@ -2,7 +2,7 @@ import requests
 import logging
 from bs4 import BeautifulSoup
 from core.models import Entity, Relationship, Source
-from urllib.parse import urljoin, urlparse
+from urllib.parse import urljoin, quote
 
 logger = logging.getLogger(__name__)
 
@@ -10,34 +10,39 @@ class WebCrawler:
     """
     Crawler to extract information from the web without relying on APIs.
     """
-    def __init__(self, start_url):
-        self.start_url = start_url
+    def __init__(self):
         self.session = requests.Session()
         self.session.headers.update({
             "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/119.0.0.0 Safari/537.36"
         })
 
-    def crawl(self, query):
+    def search(self, query):
         """
-        Main entry point for web crawling.
+        Perform a simulated search on Google using requests.
         """
-        logger.info(f"Starting crawl for: {query}")
-        # 1. Perform search queries on Google/Bing or specialized sites
-        # 2. Extract links and parse content
-        # 3. Identify new entities and relationships
-        return self._simulate_discovery(query)
-
-    def _simulate_discovery(self, query):
-        # This will be replaced by actual logic using BeautifulSoup/requests
-        return {
-            "entities": [
-                {"type": "PERSON", "value": query, "identifier": "WEB-ID-1"},
-                {"type": "PERSON", "value": "Associate of " + query, "identifier": "WEB-ID-2"},
-            ],
-            "relationships": [
-                {"source": query, "target": "Associate of " + query, "type": "ASSOCIATED_WITH"}
-            ]
-        }
+        search_url = f"https://www.google.com/search?q={quote(query)}"
+        logger.info(f"Crawling URL: {search_url}")
+        
+        try:
+            response = self.session.get(search_url, timeout=10)
+            response.raise_for_status()
+            soup = BeautifulSoup(response.text, "html.parser")
+            
+            # Simple extraction of titles/links from Google search results
+            results = []
+            # Selector for Google search result titles
+            for g in soup.select("div.g"):
+                title_elem = g.select_one("h3")
+                link_elem = g.select_one("a")
+                if title_elem and link_elem:
+                    results.append({
+                        "title": title_elem.get_text(),
+                        "url": link_elem.get("href")
+                    })
+            return results
+        except Exception as e:
+            logger.error(f"Search failed: {e}")
+            return []
 
 class NetworkDiscoveryService:
     @staticmethod
@@ -46,38 +51,40 @@ class NetworkDiscoveryService:
         Performs discovery using Web Crawling.
         """
         try:
-            crawler = WebCrawler(start_url="https://www.google.com")
-            data = crawler.crawl(query)
+            crawler = WebCrawler()
+            search_results = crawler.search(query)
             
             source, _ = Source.objects.get_or_create(name='Web Crawler Engine')
             
-            person = None
-            for ent_data in data.get("entities", []):
-                entity, _ = Entity.objects.get_or_create(
-                    entity_type=ent_data['type'], 
-                    value=ent_data['value'], 
-                    source=source
-                )
-                entity.photo_url = f"https://api.dicebear.com/7.x/pixel-art/svg?seed={ent_data['value'].replace(' ', '+')}"
-                entity.identifier_code = ent_data.get('identifier', 'UNKNOWN')
-                entity.save()
-                
-                if ent_data['type'] == 'PERSON':
-                    person = entity
+            # 1. Create main entity
+            person, _ = Entity.objects.get_or_create(
+                entity_type='PERSON',
+                value=query,
+                source=source
+            )
+            person.photo_url = f"https://api.dicebear.com/7.x/pixel-art/svg?seed={query.replace(' ', '+')}"
+            person.save()
 
-            for rel_data in data.get("relationships", []):
-                s_entity = Entity.objects.filter(value=rel_data['source']).first()
-                t_entity = Entity.objects.filter(value=rel_data['target']).first()
-                
-                if s_entity and t_entity:
+            # 2. Extract potential associates from titles
+            for res in search_results:
+                # Naive associate detection
+                associate_val = res['title'][:50]
+                if associate_val != query:
+                    associate, _ = Entity.objects.get_or_create(
+                        entity_type='PERSON',
+                        value=associate_val,
+                        source=source
+                    )
+                    
+                    # 3. Create relationship
                     Relationship.objects.get_or_create(
-                        source_entity=s_entity,
-                        target_entity=t_entity,
-                        relationship_type=rel_data['type'],
-                        weight=0.9
+                        source_entity=person,
+                        target_entity=associate,
+                        relationship_type='ASSOCIATED_WITH',
+                        weight=0.5
                     )
             
-            return person or Entity.objects.filter(value=query).first()
+            return person
 
         except Exception as e:
             logger.error(f"Error performing web-based discovery for {query}: {e}")
@@ -87,4 +94,4 @@ class EntityResolutionService:
     @staticmethod
     def resolve_identity(identifier_a, identifier_b, probability_threshold=0.8):
         # Implementation remains unchanged
-        return True
+        return True
\ No newline at end of file