@@ -16,6 +16,7 @@ from ml_model.services.logoai import Logoai
 from ml_model.services.midjourney import Midjourney
 from ml_model.services.mistral import Mistral
 from ml_model.services.musicgen import Musicgen
+from ml_model.services.perplexity import Perplexity
 from ml_model.services.pulid import Pulid
 from ml_model.services.qwen import Qwen
 from ml_model.services.recraft import Recraft
@@ -0,0 +1,103 @@
+import time
+from datetime import timedelta
+from decimal import Decimal
+from typing import Iterator, Any, Dict
+
+from messages.models import Message
+from ml_model.models import ModelCategory, ModelVersion, ModelInput, ModelParameter
+from ml_model.services.base import SimpleService
+from ml_model.tasks import openrouter_run
+from tools.chats.models import Chat
+from tools.copywrite.models import Copywrite
+from tools.public_api.models import APIStore
+
+
+class Perplexity(SimpleService):
+    """
+    Perplexity Service
+    contains abstract method make, which makes a generation
+    """
+
+    TOKENS_COST = {
+        'sonar': {'input': Decimal('200'), 'output': Decimal('200')},  # 1M tokens
+    }
+
+    def calculate_price(
+            self, version: str, input_tokens: int, output_tokens: int
+    ) -> Decimal:
+        price_map = self.TOKENS_COST[version.split('/')[1]]
+        price = (
+                input_tokens * price_map['input'] / 1_000_000
+                + output_tokens * price_map['output'] / 1_000_000
+        )
+        return price.quantize(Decimal('0.1'), rounding='ROUND_UP')
+
+    def save_results(
+            self, content: Iterator[Any], t: timedelta, save: bool = True
+    ) -> list[Message]:
+        msgs = [
+            Message(
+                content=content,
+                content_object=self.store,
+                elapsed_time=t,
+            )
+        ]
+        if save:
+            return Message.objects.bulk_create(msgs)
+        return msgs
+
+    def make(self, input_message: Message, save: bool = True) -> list[Message]:
+        start_time = time.time()
+        version = f'perplexity/{input_message.info.pop('version', 'sonar')}'
+        callback_data = {
+            'provider': {
+                'order': ['Perplexity']
+            },
+            **input_message.info
+        }
+        messages = self.get_chat_history()
+        result = openrouter_run(version, messages, callback_data, self.title)
+        process_time = timedelta(seconds=(time.time() - start_time))
+        self.handle_invoice(
+            input_message.content_object.model,
+            version=version,
+            input_tokens=result[1],
+            output_tokens=result[2]
+        )
+        msgs = self.save_results(result[0], process_time)
+        return msgs
+
+    def get_chat_history(self, message_limit: int = 10, max_character_limit: int = 1500) -> list[Dict]:
+        if isinstance(self.store, Chat):
+            air_messages = list(
+                reversed(
+                    Message.objects.filter(
+                        chats_chats_messages=self.store, is_deleted=False, is_sent=True
+                    ).order_by('-created_at')[:message_limit]
+                )
+            )
+        elif isinstance(self.store, APIStore):
+            air_messages = []
+        elif isinstance(self.store, Copywrite):
+            air_messages = list(
+                reversed(
+                    Message.objects.filter(
+                        copywrite_copywrites_messages=self.store,
+                        is_deleted=False,
+                        is_sent=True,
+                    ).order_by('-created_at')[:message_limit]
+                )
+            )
+        memory = []
+        for msg in air_messages:
+            content = msg.content or ''
+            if msg.from_model:
+                memory.append({"role": "assistant", "content": content})
+            else:
+                memory.append({"role": "user", "content": content})
+        character_length = sum(len(content['content']) for content in memory)
+        while character_length > max_character_limit:
+            memory.pop(0)
+            character_length = sum(len(content['content']) for content in memory)
+
+        return memory