Handler to create firebase dynamic link for connection invitations.

Signed-off-by: George J Padayatti <[email protected]>

Author: georgepadayatti

mydata_did/v1_0/manager.py

@@ -3805,3 +3805,67 @@ async def create_invitation(
         await connection.attach_invitation(self.context, invitation)
 
         return connection, invitation
+    
+
+    async def generate_firebase_dynamic_link_for_connection_invitation(self, conn_id: str) -> str:
+        """Generate a Firebase Dynamic Link for a connection invitation."""
+
+        # Fetch config from os environ
+        config = await self.fetch_firebase_config_from_os_environ()
+
+        # Fetch connection record
+
+        try:
+
+            connection_record: ConnectionRecord = await ConnectionRecord.retrieve_by_id(
+                self.context,
+                conn_id
+            )
+        
+        except StorageError as err:
+            raise ADAManagerError(
+                f"Failed to fetch connection record: {err}"
+            )
+
+        # Retreive connection invitation
+
+        connection_invitation: ConnectionInvitation = await connection_record.retrieve_invitation(self.context)
+
+        # Get the invitation url
+
+        invitation_url = connection_invitation.to_url()
+
+        # Generate the dynamic link
+
+        # Construct firebase payload
+        payload = {
+            "dynamicLinkInfo": {
+                "domainUriPrefix": config["firebase_domain_uri_prefix"],
+                "link": invitation_url,
+                "androidInfo": {
+                    "androidPackageName": config["firebase_android_android_package_name"],
+                },
+                "iosInfo": {
+                    "iosBundleId": config["firebase_ios_bundle_id"],
+                    "iosAppStoreId": config["firebase_ios_appstore_id"],
+                }
+            },
+            "suffix": {
+                "option": "UNGUESSABLE"
+            }
+        }
+
+        firebase_dynamic_link_endpoint = "https://firebasedynamiclinks.googleapis.com/v1/shortLinks?key=" + \
+            config["firebase_web_api_key"]
+
+        jresp = {}
+        async with aiohttp.ClientSession() as session:
+            async with session.post(firebase_dynamic_link_endpoint, json=payload) as resp:
+                if resp.status == 200:
+                    jresp = await resp.json()
+                else:
+                    raise ADAManagerError(
+                        f"Failed to generate firebase dynamic link for connection-invitation: {resp.status} {await resp.text()}"
+                    )
+
+        return jresp["shortLink"]

mydata_did/v1_0/routes.py

@@ -2784,6 +2784,55 @@ async def v2_connections_create_invitation(request: web.BaseRequest):
 
     return web.json_response(result)
 
+class GenerateFirebaseDynamicLinkForConnectionInvitationMatchInfoSchema(OpenAPISchema):
+    """Schema for matching path parameters in generate firebase dynamic link for connection invitation handler"""
+
+    conn_id = fields.Str(
+        description="Connection identifier", example=UUIDFour.EXAMPLE, required=True
+    )
+
+class GenerateFirebaseDynamicLinkForConnectionInvitationResponseSchema(OpenAPISchema):
+    """Schema for response of generate firebase dynamic link for connection invitation handler"""
+
+    # Firebase dynamic link
+    firebase_dynamic_link = fields.Str(
+        description="Firebase dynamic link", example="https://example.page.link/UVWXYZuvwxyz12345"
+    )
+
+@docs(
+    tags=["connection"],
+    summary="Generate firebase dynamic link for connection invitation",
+)
+@match_info_schema(GenerateFirebaseDynamicLinkForConnectionInvitationMatchInfoSchema())
+@response_schema(GenerateFirebaseDynamicLinkForConnectionInvitationResponseSchema(), 200)
+async def generate_firebase_dynamic_link_for_connection_invitation_handler(request: web.BaseRequest):
+    """
+    Request handler for generating firebase dynamic link for connection invitation.
+
+    Args:
+        request: aiohttp request object
+
+    Returns:
+        The firebase dynamic link
+
+    """
+
+    context = request.app["request_context"]
+    conn_id = request.match_info["conn_id"]
+
+    # Initialise MyData DID Manager.
+    mydata_did_manager: ADAManager = ADAManager(context=context)
+    try:
+        # Call the function
+        firebase_dynamic_link = await mydata_did_manager.generate_firebase_dynamic_link_for_connection_invitation(conn_id)
+    
+    except (ConnectionManagerError, BaseModelError) as err:
+        raise web.HTTPBadRequest(reason=err.roll_up) from err
+
+    return web.json_response({
+        "firebase_dynamic_link": firebase_dynamic_link
+    })
+
 
 async def register(app: web.Application):
 
@@ -2966,8 +3015,14 @@ async def register(app: web.Application):
                 "/json-ld/didcomm/processed-data/connections/{connection_id}",
                 send_json_ld_didcomm_processed_data_message_handler,
             ),
-            web.post("/connections/create-invitation/v2",
-                     v2_connections_create_invitation),
+            web.post(
+                "/connections/create-invitation/v2",
+                v2_connections_create_invitation
+            ),
+            web.post(
+                "/connections/{conn_id}/invitation/firebase",
+                generate_firebase_dynamic_link_for_connection_invitation_handler
+            )
         ]
     )