@@ -12,6 +12,7 @@ from ml_model.services.fluxproultra import Fluxproultra
 from ml_model.services.gemini import Gemini
 from ml_model.services.geminiimage import Geminiimage
 from ml_model.services.gptimage import Gptimage
+from ml_model.services.hailuo import Hailuo
 from ml_model.services.sora import Sora
 from ml_model.services.speedance import Speedance
 from ml_model.services.granite import Granite
@@ -0,0 +1,70 @@
+import base64
+import time
+from datetime import timedelta
+from decimal import Decimal
+from io import BytesIO
+
+import filetype
+import requests
+from django.core.files import File
+
+from messages.models import Message
+from ml_model.services.base import SimpleService
+from ml_model.tasks import replicate_run
+
+from payments.exceptions.insufficient_balance import InsufficientBalance
+from payments.selectors.payment_plan_selector import PaymentPlanSelector
+
+
+class Hailuo(SimpleService):
+    TOKENS_COST = {
+        'hailuo-2.3': {
+            '768p': Decimal('84'),
+            '1080p': Decimal('147')
+        },
+        'hailuo-2.3-fast': {
+            '768p': Decimal('57'),
+            '1080p': Decimal('99')
+        }
+    }
+
+    def calculate_price(self, version: str,  resolution: str) -> Decimal:
+        price = self.TOKENS_COST[version][resolution]
+        return price.quantize(Decimal('0.1'), rounding='ROUND_UP')
+
+    def save_results(self, content: str, t: timedelta, video: str, save: bool = True) -> list[Message]:
+        msg = Message(
+            content=content,
+            content_object=self.store,
+            elapsed_time=t,
+            file=File(BytesIO(requests.get(video).content), '.mp4'),
+        )
+        if save:
+            return Message.objects.bulk_create([msg])
+        return [msg]
+
+    def make(self, input_message: Message, save: bool = True) -> list[Message]:
+        version = input_message.info.get('version', 'hailuo-2.3-fast')
+        resolution = input_message.info.get('resolution', '768p')
+        if (
+            (balance := PaymentPlanSelector(self.store.user).get_current_balance())
+            < (cost := self.TOKENS_COST[version][resolution])
+        ):
+            raise InsufficientBalance(balance, cost)
+        callback_data = {'prompt': self.translate_prompt(input_message.content), 'duration': 6, **input_message.info}
+        if input_message.file:
+            kind = filetype.guess(input_message.file.read(20))
+            mime = kind.mime if kind else 'application/octet-stream'
+            input_message.file.seek(0)
+            image = f'data:{mime};base64,{base64.b64encode(input_message.file.read()).decode("utf-8")}'
+            input_message.file.close()
+            callback_data.update({'first_frame_image': image})
+        start_time = time.time()
+        video = replicate_run(
+            f'minimax/{version}',
+            callback_data
+        )
+        process_time = timedelta(seconds=(time.time() - start_time))
+        self.handle_invoice(input_message.content_object.model, version=version, resolution=resolution)
+        msgs = self.save_results(input_message.content, process_time, video, save)
+        return msgs