fix(services): rename publish flow for platform content

Author: PromiseFru

rest_services/v1/routes.py

@@ -20,20 +20,22 @@
     PublishContentResponse,
     ServerStaticPublicKey,
 )
-from rest_services.v1.services import publish_content, store_segment_and_try_join
+from rest_services.v1.services import (
+    publish_platform_content,
+    store_segment_and_try_join,
+)
 
 logger = get_logger(__name__)
 
 router = APIRouter()
 
 ALLOWED_PLATFORM_MANIFEST_KEYS = [
+    "display_name",
     "name",
-    "shortcode",
     "proto_id",
     "cat_id",
     "icon_svg",
     "icon_png",
-    "support_url_scheme",
 ]
 ALLOWED_PLATFORMS_WITH_CLIENT_METADATA = ["bluesky"]
 
@@ -195,7 +197,7 @@ def create_publications(
                 )
 
             with get_session() as db:
-                publish_content(
+                publish_platform_content(
                     token_id=t_id,
                     key_id=payload.get_kid(),
                     len_att=payload.get_len_att(),
@@ -228,7 +230,7 @@ def create_publications(
                         status_code=400, detail="Payload is missing token ID"
                     )
 
-                publish_content(
+                publish_platform_content(
                     token_id=t_id,
                     key_id=joined.get_kid(),
                     len_att=joined.get_len_att(),

rest_services/v1/services.py

@@ -41,12 +41,13 @@ def _get_adapter_params(
 
     match cat_id:
         case rrs.V1ContentCategories.EMAIL:
+            to = content.get_to().decode()
             return {
                 "from_email": token_data["account_id"],
-                "to_email": content.get_to().decode(),
+                "to_email": to,
+                "recipient": to,
                 "subject": content.get_subject().decode(),
                 "message": content.get_body().decode(),
-                "recipient": content.get_to().decode(),
                 **extra_params,
             }
         case rrs.V1ContentCategories.MESSAGE:
@@ -78,7 +79,7 @@ def _consume_used_keys(token_hash: TokenHash, key_index: int, session: Session)
     mark_ss_kid_used(key_index, session)
 
 
-def publish_content(
+def publish_platform_content(
     token_id: int,
     key_id: int,
     len_att: int,
@@ -146,8 +147,8 @@ def publish_content(
                 },
             )
         case _:
-            logger.error("unsupported protocol: %r", token.protocol)
-            raise ValueError(f"unsupported protocol: {token.protocol!r}")
+            logger.error("unsupported protocol: %r", proto_id)
+            raise ValueError(f"unsupported protocol: {proto_id!r}")
 
     pipe = AdapterIPCHandler.invoke(
         adapter_path=adapter.path,