add openrouter client, promt generator, etc

.env.example

@@ -1,4 +1,5 @@
 TELEGRAM_TOKEN=
 FINNHUB_API_TOKEN=
 ACCESS_TOKEN=
-SPACE_ID=
+SPACE_ID=
+OPENROUTER_API_TOKEN=

src/api/openrouter/openrouter_client.py

@@ -0,0 +1,80 @@
+import logging
+import time
+import requests
+import json
+import os
+
+from api.finnhub.financial_news_requester import fetch_comp_financial_news
+from api.openrouter.prompt_generator import PromptGenerator
+
+
+class OpenRouterClient:
+    def __init__(self, model: str = "tngtech/deepseek-r1t2-chimera:free", api_key: str | None = None):
+        self._api_key = api_key or os.getenv("OPENROUTER_API_KEY")
+        if not self._api_key:
+            raise ValueError("OpenRouter API key is required")
+        self._api_url = "https://openrouter.ai/api/v1/chat/completions"
+        self.model = model
+
+    def chat(self, user_message: str, role: str = "user") -> str:
+        """
+        Sends a message to the OpenRouter API and returns the response.
+        Raises RuntimeError for HTTP errors and ValueError for unexpected response formats.
+
+        Args:
+            user_message (str): The message to send to the model.
+        Returns:
+            str: The response from the model.
+        Raises:
+            RuntimeError: If the API request fails.
+            ValueError: If the response format is unexpected.
+        """
+        headers = {
+            "Authorization": f"Bearer {self._api_key}",
+            "Content-Type": "application/json"
+        }
+        payload = {
+            "model": self.model,
+            "messages": [
+                {
+                    "role": role,
+                    "content": user_message
+                }
+            ]
+        }
+        try:
+            response = requests.post(
+                url=self._api_url,
+                headers=headers,
+                data=json.dumps(payload),
+                timeout=10
+            )
+            response.raise_for_status()
+        except requests.exceptions.RequestException as e:
+            logging.error(f"OpenRouter request error: {e}")
+            raise RuntimeError(f"Request error: {e}")
+        response_json = response.json()
+        try:
+            return response_json["choices"][0]["message"]["content"]
+        except (KeyError, IndexError):
+            logging.error(f"Unexpected response format: {response_json}")
+            raise ValueError(f"Unexpected response format: {response_json}")
+
+
+if __name__ == "__main__":
+    sample_news = fetch_comp_financial_news(ticker='NVDA', date_from='2025-08-04', date_to='2025-08-05')
+    print(sample_news)
+    print(len(sample_news))
+    # Example usage
+    client = OpenRouterClient()
+    try:
+        for news in sample_news:
+            start_time = time.perf_counter()
+            prompt = PromptGenerator.format_prompt(news)
+            print(f"Prompt: {prompt}")
+            response = client.chat(prompt)
+            print(f"Response: {response}")
+            elapsed = time.perf_counter() - start_time
+            print(f"Processing time: {elapsed:.2f} seconds")
+    except (RuntimeError, ValueError) as e:
+        print(f"Error: {e}")

src/api/openrouter/prompt_generator.py

@@ -0,0 +1,7 @@
+from src.api.openrouter.system_prompt import system_prompt_template
+
+
+class PromptGenerator:
+    @staticmethod
+    def format_prompt(news_text: str) -> str:
+        return system_prompt_template.format(news_text=news_text).strip()

src/api/openrouter/system_prompt.py

@@ -0,0 +1,16 @@
+system_prompt_template = """
+You are an experienced trader and long-term investor holding NVDA stock.
+
+Analyze the following financial news from the perspective of its potential impact on NVDA (ticker: NVDA). Consider direct and indirect effects, including market sentiment, sector influence, regulatory risks, macroeconomic context, and technological competition.
+
+---
+
+News:
+"{news_text}"
+
+---
+
+Answer in one of the following categories only: **Positive**, **Negative**, or **Neutral** — depending on the implications for NVDA.
+
+Also include a very short explanation (1-2 sentences) why you classified it that way.
+"""

src/core/news_analysis/lexicon_based_sentiment_analyzer.py

@@ -47,7 +47,7 @@ from nltk.stem import WordNetLemmatizer
 from src.core.news_analysis.data.news_item import NewsItem
 from src.core.news_analysis.data.sentiment_result import SentimentResult
 from src.core.news_analysis.data.news_analysis import NewsAnalysis
-from src.api.financial_news_requester import fetch_comp_financial_news
+from api.finnhub.financial_news_requester import fetch_comp_financial_news
 
 
 class FinnhubSentimentAnalyzer:

src/telegram_bot.py

@@ -5,7 +5,7 @@ from typing import Any
 from telegram import Update
 from telegram.ext import Application, CommandHandler, ContextTypes
 from dotenv import load_dotenv
-from api.financial_news_requester import fetch_comp_financial_news
+from api.finnhub.financial_news_requester import fetch_comp_financial_news
 from fastapi import FastAPI, Request
 import uvicorn
 import httpx