Notifies flows for template creation and deletion

marketplace/services/flows/service.py

@@ -62,3 +62,15 @@
         return self.client.create_wac_channel(
             user, project_uuid, phone_number_id, config
         )
+
+    # TODO: need implement methods on client
+    def create_facebook_template(self, flow_object_uuid, template_data, template_name):
+        return self.client.create_facebook_template(
+            flow_object_uuid, template_data, template_name
+        )
+
+    # TODO: need implement methods on client
+    def delete_facebook_template(self, flow_object_uuid, template_data, template_name):
+        return self.client.delete_facebook_template(
+            flow_object_uuid, template_data, template_name
+        )

marketplace/wpp_templates/serializers.py

@@ -1,5 +1,6 @@
 import re
 import base64
+import logging
 
 from typing import List, Any
 
@@ -12,16 +13,21 @@
 from rest_framework import serializers
 
 from marketplace.applications.models import App
+from marketplace.services.flows.service import FlowsService
 from marketplace.wpp_templates.models import (
     TemplateMessage,
     TemplateTranslation,
     TemplateButton,
     TemplateHeader,
 )
+from marketplace.clients.flows.client import FlowsClient
 from marketplace.clients.facebook.client import FacebookClient
 from marketplace.services.facebook.service import TemplateService, PhotoAPIService
+from marketplace.wpp_templates.utils import extract_template_data
 
 
+logger = logging.getLogger(__name__)
+
 WHATSAPP_VERSION = settings.WHATSAPP_VERSION
 
 User = get_user_model()
@@ -172,6 +178,25 @@
                 hh.pop("example")
             TemplateHeader.objects.create(translation=translation, **hh)
 
+        if translation:
+            try:
+                # Send template to flows
+                flows_service = FlowsService(FlowsClient())
+                template_data = extract_template_data(translation)
+                flows_service.create_facebook_template(
+                    flow_object_uuid=str(translation.template.app.flow_object_uuid),
+                    template_data=template_data,
+                    template_name=translation.template.name,
+                )
+                logger.info(f"A new template {template.name} has sent to flows.")
+            except Exception as e:
+                logger.error(
+                    f"Fail to sends a new template to flows: {template.name}, translation: {translation.language},"
+                    f"translation ID: {translation.message_template_id}. Error: {e}",
+                    exc_info=True,
+                    stack_info=True,
+                )
+
         return translation