fix: add platform field to identity queries and update affiliation domain

Signed-off-by: Yeganathan S <63534555+skwowet@users.noreply.github.com>

Author: skwowet

services/apps/git_integration/src/crowdgit/database/crud.py

@@ -667,30 +667,32 @@ async def find_many_organization_ids_by_identities(identities: list[dict]) -> li
     param_index = 1
     for idx, identity in enumerate(identities):
         values_parts.append(
-            f"(${param_index}::int, ${param_index + 1}::text,"
-            f" ${param_index + 2}::boolean, ${param_index + 3}::text)"
+            f"(${param_index}::int, ${param_index + 1}::text, ${param_index + 2}::boolean,"
+            f" ${param_index + 3}::text, ${param_index + 4}::text)"
         )
         params.extend(
             [
                 idx,
                 identity["type"],
                 identity.get("verified", True),
+                identity["platform"],
                 identity["value"],
             ]
         )
-        param_index += 4
+        param_index += 5
 
     matches_by_idx: dict[int, set[str]] = {}
     rows = await query(
         f"""
-        WITH input_identities (idx, identity_type, verified, value) AS (
+        WITH input_identities (idx, identity_type, verified, platform, value) AS (
             VALUES {", ".join(values_parts)}
         )
         SELECT i.idx, oi."organizationId"
         FROM input_identities i
         LEFT JOIN "organizationIdentities" oi
             ON oi.type = i.identity_type
             AND oi.verified = i.verified
+            AND oi.platform = i.platform
             AND lower(oi.value) = lower(i.value)
         ORDER BY i.idx
         """,
@@ -708,6 +710,7 @@ async def find_many_organization_ids_by_identities(identities: list[dict]) -> li
         results.append(
             {
                 "type": identity["type"],
+                "platform": identity["platform"],
                 "value": identity["value"],
                 "verified": identity.get("verified", True),
                 "organization_id": organization_id,

services/apps/git_integration/src/crowdgit/services/affiliation/affiliation_service.py

@@ -412,7 +412,7 @@ def group_parse_rows(
             if is_unaffiliated:
                 stint = AffiliationOrganizationStint(
                     name="Individual",
-                    domain="individual-noaccount.com",
+                    domain="nonameaccount.com",
                     date_start=cls._parse_optional_date(organization.date_start),
                     date_end=cls._parse_optional_date(organization.date_end),
                     is_unaffiliated=True,
@@ -744,6 +744,7 @@ async def apply_affiliations(
                 organization_identity_inputs.append(
                     {
                         "type": "primary-domain",
+                        "platform": "email",
                         "value": organization.domain,
                         "verified": True,
                     }