From d0a05046d186c4383cd880e53d7e0f4fd83c202d Mon Sep 17 00:00:00 2001
From: dextmorgn <dexxterrmorgan@proton.me>
Date: Tue, 18 Nov 2025 12:55:44 +0100
Subject: [PATCH] feat(api): add Port type and ip_to_port transform to
 available items

---
 flowsint-api/app/api/routes/flows.py | 15 +++++++++++++--
 flowsint-api/app/api/routes/types.py |  2 ++
 2 files changed, 15 insertions(+), 2 deletions(-)

diff --git a/flowsint-api/app/api/routes/flows.py b/flowsint-api/app/api/routes/flows.py
index 485059d..cd46afc 100644
--- a/flowsint-api/app/api/routes/flows.py
+++ b/flowsint-api/app/api/routes/flows.py
@@ -6,7 +6,16 @@ from datetime import datetime
 from flowsint_core.utils import extract_input_schema_flow
 from flowsint_core.core.registry import TransformRegistry
 from flowsint_core.core.celery import celery
-from flowsint_types import Domain, Phrase, Ip, SocialAccount, Organization, Email, Phone, Username
+from flowsint_types import (
+    Domain,
+    Phrase,
+    Ip,
+    SocialAccount,
+    Organization,
+    Email,
+    Phone,
+    Username,
+)
 from flowsint_core.core.types import Node, Edge, FlowStep, FlowBranch
 from sqlalchemy.orm import Session
 from flowsint_core.core.postgre_db import get_db
@@ -22,6 +31,7 @@ from flowsint_types import (
     CryptoNFT,
     Website,
     Individual,
+    Port,
 )
 
 
@@ -76,7 +86,7 @@ def get_flows(
             }
             for flow in flows
         ]
-        
+
     flows = db.query(Flow).order_by(Flow.last_updated_at.desc()).all()
     return [
         flow
@@ -118,6 +128,7 @@ async def get_material_list():
         extract_input_schema_flow(Domain),
         extract_input_schema_flow(Website),
         extract_input_schema_flow(Ip),
+        extract_input_schema_flow(Port),
         extract_input_schema_flow(Phone),
         extract_input_schema_flow(ASN),
         extract_input_schema_flow(CIDR),
diff --git a/flowsint-api/app/api/routes/types.py b/flowsint-api/app/api/routes/types.py
index ad06a06..1ddb7db 100644
--- a/flowsint-api/app/api/routes/types.py
+++ b/flowsint-api/app/api/routes/types.py
@@ -9,6 +9,7 @@ from app.api.deps import get_current_user
 from flowsint_types import (
     Domain,
     Ip,
+    Port,
     SocialAccount,
     Organization,
     Email,
@@ -117,6 +118,7 @@ async def get_types_list(
                 extract_input_schema(Domain, label_key="domain"),
                 extract_input_schema(Website, label_key="url"),
                 extract_input_schema(Ip, label_key="address"),
+                extract_input_schema(Port, label_key="number"),
                 extract_input_schema(DNSRecord, label_key="name", icon="dns"),
                 extract_input_schema(SSLCertificate, label_key="subject", icon="ssl"),
                 extract_input_schema(WebTracker, label_key="name", icon="webtracker"),