@@ -13,6 +13,7 @@ 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.sora import Sora +from ml_model.services.speedance import Speedance from ml_model.services.granite import Granite from ml_model.services.grok import Grok from ml_model.services.iconic import Iconic @@ -0,0 +1,63 @@ +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 Speedance(SimpleService): + + TOKENS_COST = { + '480p': Decimal('4.5'), + '720p': Decimal('7.5'), + '1080p': Decimal('18'), + } + + def calculate_price(self, resolution: str, duration: int) -> Decimal: + price = self.TOKENS_COST[resolution] * duration + 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]: + resolution = input_message.info.get('resolution', '720p') + duration = input_message.info.get('duration', 8) + if (balance := PaymentPlanSelector(self.store.user).get_current_balance()) < (cost := self.TOKENS_COST[resolution] * duration): + raise InsufficientBalance(balance, cost) + callback_data = dict({'prompt': self.translate_prompt(input_message.content), **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({'image': image}) + start_time = time.time() + video = replicate_run( + f'bytedance/{input_message.info.get("version", "seedance-1-pro-fast")}', + callback_data + ) + process_time = timedelta(seconds=(time.time() - start_time)) + self.handle_invoice(input_message.content_object.model, resolution=resolution, duration=duration) + msgs = self.save_results(input_message.content, process_time, video, save) + return msgs