From 00fab55ca3fc0654f5403963fed44779d0ed0bd2 Mon Sep 17 00:00:00 2001
From: Flatlogic Bot <support@flatlogic.com>
Date: Sun, 22 Mar 2026 22:04:10 +0000
Subject: [PATCH] RIPLEY

---
 core/__pycache__/admin.cpython-311.pyc        | Bin 212 -> 1115 bytes
 core/__pycache__/models.cpython-311.pyc       | Bin 209 -> 2288 bytes
 core/admin.py                                 |  12 +++++-
 core/migrations/0001_initial.py               |  40 ++++++++++++++++++
 .../__pycache__/0001_initial.cpython-311.pyc  | Bin 0 -> 2258 bytes
 core/models.py                                |  29 ++++++++++++-
 core/services/ingestion.py                    |  30 +++++++++++++
 core/services/resolution.py                   |  24 +++++++++++
 8 files changed, 133 insertions(+), 2 deletions(-)
 create mode 100644 core/migrations/0001_initial.py
 create mode 100644 core/migrations/__pycache__/0001_initial.cpython-311.pyc
 create mode 100644 core/services/ingestion.py
 create mode 100644 core/services/resolution.py

diff --git a/core/__pycache__/admin.cpython-311.pyc b/core/__pycache__/admin.cpython-311.pyc
index 5e8987a0cd478c226e501b5189550e758662c560..5ed0a0d66f073fd61031ec8756379c7d48d2a96c 100644
GIT binary patch
literal 1115
zcma)4Jx|;~5Z(0`zB>*s<OnDdmk23^i*R+MC{l_jMFI^)BsVML-2)SUT-J7y>#pDj
z(D4t5BK|<iNRd(#iQ=>sQYyMbP*G*Z#)J!3WbJ*P-I;lwdAnbl%{qax-TNMVqlEm%
zMK!Ez<Kib62ZR$&LlRM!Qo=Q^hgzh&dSti;B^nWQ*Q^qSeh6GgFw3El*Mu8;gqsjm
zv64d_Vqliz5I#rMg19sPFd9=BEnuAaZ$_Kjo5ZP|;XfRzOpixFe1<hTnzA;NT>3&;
zui`Ao2L4SUU{q~fJb=Xk5yYjOxEiOf&NbKII?x)bQ8K(lRv<KDFA}QmOW|dLGcR+f
ztU>;UV=9|5^fIREj7160L$qfZ`;dF#wP!XA(v0yS?T6k#HB;e9e~0w~5%Tmaxxo6a
zo_2SVNObe9JkIj2_$>T9OJw&`BHyQd&lg=kk)m7lxz-;@8*&OTz(|(?hBwdYeP{S~
z)Lt2`<0J1?q0@zU2<~Y@xF$D13{y2q8A~x>DGF6tHs}jwe)Pf|luk><TYeJv0xn`-
zuoMfHcp)8KE@BN!2*n1KDF23I$p-GtA~X@^092!ps~3cska8ZkTL?uT3uv_~z(Yt^
z0B$$`4w_$hHheQ`cWx_yNgGa0&GB6?-cHt_)Jz6j5-+W?;N(P@O1$+FFSW9z*oIRR
zQq|YdSF~TsUi^Ntq$~S*dG;@42eR>&r9S}1I;C_(9v@G>BeHrt?LDRQ!^OSMzV(YP
zozSJRrqRxr+=cxoCkw0R=(t2U*NL`#6K@l(HOZpWM`Lmqu35lwiQc~~6QPCfe*nCV
B{<Q!A

literal 212
zcmZ3^%ge<81a&?uGVOu%V-N=hn4pZ$LO{lJh7^Vr#vF!R#wbQch7_h?22JLdAO)I?
zw^$QXax?S%G?{MkrDP@MrRVD<=jW9aWhNCd0~M@f_zY6_OIJT5KQ~psG^sSNq*On(
zA~m_RB)>?%JijQrxF9h(RX;huC{-V9lwLvQFAkgB{FKt1RJ$S$pl(JWE|vunAD9^#
P8E-HsT)>8k*nlbkB)c`?

diff --git a/core/__pycache__/models.cpython-311.pyc b/core/__pycache__/models.cpython-311.pyc
index a251b5fb7c2b603c587f8162d643eb10596d2858..0a846fcabad4a30b77111596b1be7eaac49296ca 100644
GIT binary patch
literal 2288
zcmaJ?J#5=X6h2ZUMeE15B-d`@)Ckh1uz*5tQ@b#lw1JVxhMQP5VmE+=q6DqG*i<Oe
zIg*ZLWYCboLxyZA5ERHzqzU4|Lx+wXJ5m4#;eet;r)&zG$xHi=l<Z0ldJ^CLyzlP4
zdwlQXFX?mwLHmpRZU_=WfAdMV$(_OB4={LwFv5a~YC>5Mkcbu#79S!UBSKZ|Zg?I;
z=oLIsE5|~V1St7`P!d*FP(J>eZ^{cyso9vAPNj25*nwkVJA44$6GTv1z^E*Wh{UR0
z9XN-@{n&GG=GC!7WjVwso&DhQzVuuG1UykI$3ukLodZJdLkwW$Au1<u9NbiyvSNF*
zLSFv^J67`|OVsoo%_P=_yU7&KGVXZ<ZXvImx^?%Zz*4&B+L~qG*K~|4$7W$OAM;op
z4ug1t9-u1pQ3FFl2~LqLy++^=$sy()hi^E4RG8YdYh=n>_bk_&B0Ho42I$m%o8EP{
z^a`1(*py5~K`d<5SzOZ`mulMXVB~nAGv_yU_`7eQ)==(I-B;f~<kn01BvUnwTh=s|
z&@?#8Gx<2BY4<$cj5L(H&IYb+>U7>9CZ_3dzDjo7aL$sLI2CGaxrS}A^mW}Ot457P
zx<rK%SiqX@(hTf-iD(u&$|FH})`fywa4?9*@voH}-}@p+jz4n_rv2n>GdUY1XB*dB
z*$a<94zd?sjQH6?Gg}C<g~p9m=HlbgAafCrnb~G$Hpt92zG+K>e5Q>~i^u_PyC?IG
zOJEqHf0B7v;K@y-YF7`LMPjG2PwB%*Sl(CqGL+|^R6Wi=G61u%B*7Jg<NIn~Q6)os
zifehp1N(`-d`*Xl!AK7Xc|X~Q7&?VW^&y7C(oI9@4)*z*!9!3DSv(9$nqf-Oat*hh
zm!J}q<>IZCZ%fb<>ev>n$i=0(#hcL8bi;(X`rS(LR%vdj2qTA3o=LDOE-vpT7MIV@
zVN8kRydDA1^CFEy$KsVu+o%wS@)Cw}i&j;<t{E04J4_|qzCj!~XTY{Jpbp{^mZHQA
z6O5bKh$7Lx3KbQ{<c{u{F6AMHx!Ntyp10mD)5B3f^}cm1mL(j6yGuvO=<bCj;_6Hd
zC)|-3ONLI>HMhP+n7pl<9$|_T(ncvS(;OU1`6cOlAXsjj&~@7(QORwY9@R}Y6fueB
z+8e~(B$SSG{Be;mi5sN_SUdxd!^MB9WMa}+$6IHw><#f>v~30;J^aJVi$8}Sf#~I*
zr$DB_N8K=>r|2hsWwEp?et8~V!l$r<e#QmQvWS?X;^o!6JJ<<KhiN|G816qXO?DK@
z)E~M8|7ZB;YBciIOQDaYe6Bw@sbXn$adk~wU0W`$gq%b9J2~-yCFX(ej1B7ssfVn=
z;@9R@uFYL9(n|mYwQ1`eN*b=%)*S;At3ot~(<J3_qh~{$w}rcu#6uPGQeV_5zey;P
zFmV0^aT4^lD32(Oo9z_JeHf9^`fs23*@b3yA;>NO9i`6g%?GJ-FJcGSPhD=NE(fX0
zjbbZ3v3EO2PyD!jF#7AnA5}lS)=aMj>9xjuYi#oIb}%-1kn_i8nqxD;*o-fYypz_t
zi!WS1Gu_Ng2bpQkb)x)L8=V$!_}beOg(}FOb586RQR47RL)x+dT-B`&yMWgt?w6PN
zhdQF`FfhF-dZb>7z8qiEt8fC(C8rLe9TNnhh0giC|F)zEK+LDb-t9-<zv1g|Pn5$s
R0en3zA}p-GeTOo<&A%Bw7AF7z

delta 150
zcmew$c#$!EIWI340}#~ttjM$k(vLwL7+``jJ_`XE(-~42QW$d>av7r-85vTTf*CZK
zUxE~9GTvg#%}+_qDfZK3y2Y82m6(^Fua}Zk#0->N$?zGZX7WZx1JPd`Hb8ZyIjMF<
Z96&KfATE}joX;V}eStv+h>F;NA^_W*AK(B0

diff --git a/core/admin.py b/core/admin.py
index 8c38f3f..b540860 100644
--- a/core/admin.py
+++ b/core/admin.py
@@ -1,3 +1,13 @@
 from django.contrib import admin
+from .models import Source, Entity
 
-# Register your models here.
+@admin.register(Source)
+class SourceAdmin(admin.ModelAdmin):
+    list_display = ('name', 'created_at')
+    search_fields = ('name',)
+
+@admin.register(Entity)
+class EntityAdmin(admin.ModelAdmin):
+    list_display = ('entity_type', 'value', 'source', 'confidence_score', 'created_at')
+    list_filter = ('entity_type', 'source', 'created_at')
+    search_fields = ('value',)
\ No newline at end of file
diff --git a/core/migrations/0001_initial.py b/core/migrations/0001_initial.py
new file mode 100644
index 0000000..5380c8b
--- /dev/null
+++ b/core/migrations/0001_initial.py
@@ -0,0 +1,40 @@
+# Generated by Django 5.2.7 on 2026-03-22 21:58
+
+import django.db.models.deletion
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    initial = True
+
+    dependencies = [
+    ]
+
+    operations = [
+        migrations.CreateModel(
+            name='Source',
+            fields=[
+                ('id', models.BigAutoField(auto_created=True, primary_key=True, serialize=False, verbose_name='ID')),
+                ('name', models.CharField(max_length=255, unique=True)),
+                ('description', models.TextField(blank=True)),
+                ('created_at', models.DateTimeField(auto_now_add=True)),
+            ],
+        ),
+        migrations.CreateModel(
+            name='Entity',
+            fields=[
+                ('id', models.BigAutoField(auto_created=True, primary_key=True, serialize=False, verbose_name='ID')),
+                ('entity_type', models.CharField(choices=[('PERSON', 'Person'), ('EMAIL', 'Email'), ('USERNAME', 'Username'), ('IP', 'IP Address')], max_length=20)),
+                ('value', models.CharField(db_index=True, max_length=255)),
+                ('confidence_score', models.FloatField(default=1.0)),
+                ('created_at', models.DateTimeField(auto_now_add=True)),
+                ('updated_at', models.DateTimeField(auto_now=True)),
+                ('source', models.ForeignKey(on_delete=django.db.models.deletion.CASCADE, related_name='entities', to='core.source')),
+            ],
+            options={
+                'verbose_name_plural': 'Entities',
+                'unique_together': {('entity_type', 'value', 'source')},
+            },
+        ),
+    ]
diff --git a/core/migrations/__pycache__/0001_initial.cpython-311.pyc b/core/migrations/__pycache__/0001_initial.cpython-311.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..9525e9c30f5b384ebc35f5008c6c1ac0391d111f
GIT binary patch
literal 2258
zcmb7FJ#5=X6h2ZC^=n&l>?l%xBqw$e8G+?CfCCgx16#5Tr?G3qZc%6<Xx&++LXpam
za_meVI&{od4;_LIE{bUI&>>^SjugN_xG6xUYz*uvOZ$$rTsujD=19J~d-v|W@BQ5I
z_kn>Jf_6k+sZ9x?H+<4>p_9Q;83w-~jIf}gssO#HiOoPY&<s|C0us?8!hxR<4w68l
zzXu%z5PAWh->M-jtf4~aEuXFwL>6nRb*fmZp_@!<8klHi?L^k=k|&d+8Ijv2p53a5
zg=(OVszDKvPy_J#4U0GcoNyy@$`P=DgE-WY4uXIKKEG{>IP6JA`y3p>LMM6vR$jn&
zDi!mjyx4Fa$ixo>kb%!{pef<W#QPkO8Te499_$RB*A08lA|Lt;<jM2M>j<ZQ6Yy~7
z!g&jTY~;Ko#3Ire{YdJfCzUwGpYB}x5dZ)25obI-XXB9lNY7<YW}t723^s=P<3{*&
z)XzF<r20I31z+u4J6}zkVm*v=IKL&}v0uf`_4BKBu{w-zK(&pt=yJcx)|s?sv}uhn
zQN<M|E|m*GmQdQ3A=fBTEP`3QMb)N4cjZT9mqkrNRYg;u5|-E|bi*)-tSe2zf}Fnn
z8{m0WtnA1d(d*V0liIraxJ_6b6SGFu7O(Asz(O0EqCaA>6DzV}0n<0E8&6~f<AO*B
zK^>DeRia@y4hy=aTDvSxyk53;Tci*KYtrh%!?o{LpeNJ><su6$EYB@HfUc>i8q6c#
zuPr=WnOk0f5jeo10#{sGeHvR@&Cg*>iD|wa@xg~{TZURACgo9Qp>0KLbLj})kX0R%
z9iN}98TzJ*iC!bJSu-f9gETbv9{3T)WK(Ht7K^o8m<Q2!FXF`&++&jI2R-8Xq7w6I
zoa>nK*@Xa$8oCUJpI8uQN;FT07iZBjSj3A2>?#E4C9p}ab8-_1;Jk1)Epkh1Q$=G#
zeiCHMs1s|8P}s<0OD_UpVZ%#`xl*{mBC?lGS!OX=hWn?j5f~?A`Egs(H~^T1Rb929
z2v`D>7J-oHHNZmorN-hVuWFY0%|-e3!V>dpeGclW!n4Str7eY?4A;qy<qrqS;NZI2
zB>ps3(G2BeDOQ2FsCE5YC_V`{6uoXR5pO^`cyyqaShzH|R+=j>u$a*zCwJ!`=m>11
z_xFlhMw1lV8*SZc7s(E(0TNn#V$ersOR13}k9zUnJGVGJJ^dx5+4FCzwM+S3>Jfez
z%{Oq(?VUca2Z#3--Jmcc?LBZKD4P2@=0vXbQkmDOQ9C{PY}-jsz6|~~ZdYYnr*_)x
zrcEbp+DWUIO52&j{zWHKI9z)*VrMGdOvTAm?BrrEb<NICKbM^R^r2<vXS?}XCqHW^
z@Agtx?cDACZ6|jdcH}DET*b-p9d0x<GU$dP(bzi#<d_q8`19bL+H?{6dR_d0Dq@YZ
z#<2L#qsJZvPKt=V)FnGRx&MWeojfeRTC=lD-RzQ+U9yw+d#M}t#LV*_oQav2rae*W
zPL!O9lASF7rz>X`Uas4@`EG9B$<5oz5(L%0d~1KkxqRzz`_EnH&Z2W?)w%PdU4INP
zo(N@*@5%zl2NduD<@hS1I~0NFjG&ue^~NjqjYT&U7#(yGC+Q&`G9bsCxTD!&Y41LN
zXsMs|g2Xa@(M{ovDgS>w)vr8y7sOcfblp1vUeWtyGtaens>(2WADQ*f(>HVxru>I#
sZUAuuf*`mO62@$l_un46X@BZ<r7=Nr(Z}Rj%t?;F;|s^1SoJXc0|Aw0{Qv*}

literal 0
HcmV?d00001

diff --git a/core/models.py b/core/models.py
index 71a8362..fa9c11b 100644
--- a/core/models.py
+++ b/core/models.py
@@ -1,3 +1,30 @@
 from django.db import models
 
-# Create your models here.
+class Source(models.Model):
+    name = models.CharField(max_length=255, unique=True)
+    description = models.TextField(blank=True)
+    created_at = models.DateTimeField(auto_now_add=True)
+
+    def __str__(self):
+        return self.name
+
+class Entity(models.Model):
+    ENTITY_TYPES = (
+        ('PERSON', 'Person'),
+        ('EMAIL', 'Email'),
+        ('USERNAME', 'Username'),
+        ('IP', 'IP Address'),
+    )
+    entity_type = models.CharField(max_length=20, choices=ENTITY_TYPES)
+    value = models.CharField(max_length=255, db_index=True)
+    source = models.ForeignKey(Source, on_delete=models.CASCADE, related_name='entities')
+    confidence_score = models.FloatField(default=1.0)
+    created_at = models.DateTimeField(auto_now_add=True)
+    updated_at = models.DateTimeField(auto_now=True)
+
+    class Meta:
+        verbose_name_plural = "Entities"
+        unique_together = ('entity_type', 'value', 'source')
+
+    def __str__(self):
+        return f"{self.entity_type}: {self.value}"
\ No newline at end of file
diff --git a/core/services/ingestion.py b/core/services/ingestion.py
new file mode 100644
index 0000000..0ccf613
--- /dev/null
+++ b/core/services/ingestion.py
@@ -0,0 +1,30 @@
+from django.db import transaction
+from core.models import Source, Entity
+
+class IngestionService:
+    @staticmethod
+    def ingest_data(source_name, entity_type, raw_data):
+        """
+        Aggregates and normalizes raw data into the system.
+        """
+        with transaction.atomic():
+            source, _ = Source.objects.get_or_create(name=source_name)
+            
+            # Simple normalization logic: assume raw_data is a dict
+            # In a real scenario, this would be more complex depending on source schema
+            identifier = raw_data.get('identifier')
+            if not identifier:
+                raise ValueError("Missing identifier in raw_data")
+            
+            entity, created = Entity.objects.get_or_create(
+                identifier=identifier,
+                entity_type=entity_type,
+                defaults={'source': source, 'metadata': raw_data.get('metadata', {})}
+            )
+            
+            if not created:
+                # Update existing entity metadata
+                entity.metadata.update(raw_data.get('metadata', {}))
+                entity.save()
+                
+            return entity
diff --git a/core/services/resolution.py b/core/services/resolution.py
new file mode 100644
index 0000000..66c020f
--- /dev/null
+++ b/core/services/resolution.py
@@ -0,0 +1,24 @@
+from django.db import transaction
+from core.models import Entity
+
+class EntityResolutionService:
+    @staticmethod
+    def resolve_identity(identifier_a, identifier_b, probability_threshold=0.8):
+        """
+        Determines if two identities belong to the same physical person based on statistical probability.
+        """
+        # Logic for calculating match probability
+        # Placeholder for complex ML/Graph analysis logic
+        match_probability = 0.9 # Mock value
+        
+        if match_probability >= probability_threshold:
+            with transaction.atomic():
+                entity_a = Entity.objects.get(identifier=identifier_a)
+                entity_b = Entity.objects.get(identifier=identifier_b)
+                
+                # Logic to merge entities (e.g., link them)
+                # In a graph db, we would add a relationship.
+                # In Django, we might link via a 'resolved_to' field if existing
+                
+                return True
+        return False