From f8c7812e400b5e8203911146c6ebd2244ae25cbc Mon Sep 17 00:00:00 2001 From: hrshjswniii Date: Wed, 20 May 2026 22:39:35 +0530 Subject: [PATCH 1/9] fix: Add Local History for Generated Dev.to Posts in Extension Popup --- extension/background.js | 21 +++++++++++---------- extension/popup.html | 22 ++++++++++++++++++++++ extension/popup.js | 24 ++++++++++++++++++++++++ 3 files changed, 57 insertions(+), 10 deletions(-) diff --git a/extension/background.js b/extension/background.js index 7abc0af..df163f9 100644 --- a/extension/background.js +++ b/extension/background.js @@ -44,17 +44,18 @@ chrome.runtime.onMessage.addListener((request, sender, sendResponse) => { .filter(result => result.status === 'success') .map(result => result.platform) .join(', '); + const devtoResult = platforms.find(r => r.platform === 'devto' && r.status === 'success'); chrome.storage.local.get({ publishHistory: [] }, (res) => { - const entry = { - title: title, - date: client_time || new Date().toISOString(), - platforms: postedPlatforms ? postedPlatforms.split(', ').filter(p => p) : [], - status: data.status - }; - const history = res.publishHistory; - history.unshift(entry); - chrome.storage.local.set({ publishHistory: history.slice(0, 100) }); -}); + const entry = { + title: title, + url: devtoResult?.url || null, + publishedAt: client_time || new Date().toISOString(), + platforms: postedPlatforms ? postedPlatforms.split(', ').filter(p => p) : [] + }; + const history = res.publishHistory; + history.unshift(entry); + chrome.storage.local.set({ publishHistory: history.slice(0, 10) }); + }); const failedPlatforms = platforms .filter(result => result.status === 'error') .map(result => result.platform) diff --git a/extension/popup.html b/extension/popup.html index 916d709..e477463 100644 --- a/extension/popup.html +++ b/extension/popup.html @@ -134,6 +134,23 @@ margin-top: 10px; padding-top: 10px; } + .history-item { + display: block; + padding: 7px 8px; + margin-bottom: 5px; + border: 1px solid var(--border); + border-radius: 6px; + font-size: 12px; + color: var(--text); + text-decoration: none; + background: #fafafa; + transition: background 0.15s; + cursor: pointer; + } + .history-item:hover { background: #fff3d6; border-color: var(--primary); } + .history-item-title { font-weight: 600; white-space: nowrap; overflow: hidden; text-overflow: ellipsis; } + .history-item-meta { font-size: 10px; color: var(--text-small); margin-top: 2px; } + .history-empty { font-size: 12px; color: var(--text-small); padding: 8px 0; text-align: center; } @@ -190,6 +207,11 @@

LeetLog AI

Ready to blog! 🚀
+ +
+ 📋 Recent Posts +
+
Powered by Gemini & LeetLog AI diff --git a/extension/popup.js b/extension/popup.js index b73e4a6..b4de81d 100644 --- a/extension/popup.js +++ b/extension/popup.js @@ -48,6 +48,30 @@ document.addEventListener('DOMContentLoaded', async () => { draftInput.addEventListener('change', savePublishingSettings); statusEl.innerText = "Publishing automation active"; + + // Load and render recent posts history + chrome.storage.local.get({ publishHistory: [] }, ({ publishHistory }) => { + const listEl = document.getElementById('historyList'); + if (!publishHistory.length) { + listEl.innerHTML = '
No posts yet. Generate your first blog! ✍️
'; + return; + } + listEl.innerHTML = publishHistory.map(entry => { + const date = new Date(entry.publishedAt).toLocaleDateString(undefined, { month: 'short', day: 'numeric', year: 'numeric' }); + const platforms = (entry.platforms || []).join(', ') || 'unknown'; + return `
+
${entry.title}
+
${date} · ${platforms}
+
`; + }).join(''); + + listEl.querySelectorAll('.history-item').forEach(item => { + item.addEventListener('click', () => { + const url = item.dataset.url; + if (url) chrome.tabs.create({ url }); + }); + }); + }); }); document.getElementById('generateBtn').addEventListener('click', async () => { From 433839673a92b40efea9d0b94f5abafd675f8de7 Mon Sep 17 00:00:00 2001 From: hrshjswniii Date: Wed, 20 May 2026 22:55:35 +0530 Subject: [PATCH 2/9] fix: ruff lint fixes --- backend/devto.py | 11 ++++++++--- backend/main.py | 12 ++---------- 2 files changed, 10 insertions(+), 13 deletions(-) diff --git a/backend/devto.py b/backend/devto.py index 4f55457..67ad46a 100644 --- a/backend/devto.py +++ b/backend/devto.py @@ -1,5 +1,5 @@ -import os import asyncio +import os from dataclasses import dataclass from typing import Any @@ -10,6 +10,7 @@ DEFAULT_TAGS = ["leetcode", "dsa", "programming", "tutorial"] + @dataclass(frozen=True) class PublishResult: platform: str @@ -56,7 +57,9 @@ async def _post_with_retries( async with httpx.AsyncClient() as client: for attempt in range(retries + 1): try: - response = await client.post(url, headers=headers, json=payload, timeout=20.0) + response = await client.post( + url, headers=headers, json=payload, timeout=20.0 + ) if response.status_code in (200, 201): return response.json() if attempt == retries: @@ -65,7 +68,9 @@ async def _post_with_retries( ) except httpx.RequestError as exc: if attempt == retries: - raise PublisherError(f"{platform} network error: {exc}") from exc + raise PublisherError( + f"{platform} network error: {exc}" + ) from exc await asyncio.sleep(1) raise PublisherError(f"{platform} API request failed.") diff --git a/backend/main.py b/backend/main.py index 88b15b3..899c7ae 100644 --- a/backend/main.py +++ b/backend/main.py @@ -4,8 +4,8 @@ import uvicorn from dotenv import load_dotenv from fastapi import FastAPI, HTTPException -from fastapi.middleware.cors import CORSMiddleware from fastapi.concurrency import run_in_threadpool +from fastapi.middleware.cors import CORSMiddleware from pydantic import BaseModel from twilio.rest import Client @@ -127,7 +127,6 @@ async def create_blog(problem: Problem): elif successful_results: overall_status = "partial_success" - return { "status": overall_status, "data": { @@ -174,13 +173,6 @@ async def unsubscribe(data: dict): # Run Server # ----------------------------- if __name__ == "__main__": - uvicorn.run("main:app", host="0.0.0.0", port=10000, reload=True) - uvicorn.run( - "main:app", - host="0.0.0.0", - port=10000, - reload=True - ) - + uvicorn.run("main:app", host="0.0.0.0", port=10000, reload=True) From 5084ac5de5d75ad50b9c1202757216ca113512ba Mon Sep 17 00:00:00 2001 From: hrshjswniii Date: Thu, 21 May 2026 10:49:05 +0530 Subject: [PATCH 3/9] fix: resolve async publish methods, imports, duplicate uvicorn call, ruff lint --- backend/ai.py | 113 +++++++++++++++++++++++------------------------ backend/devto.py | 10 ++--- backend/main.py | 6 +-- 3 files changed, 62 insertions(+), 67 deletions(-) diff --git a/backend/ai.py b/backend/ai.py index 610767f..20d968f 100644 --- a/backend/ai.py +++ b/backend/ai.py @@ -22,79 +22,76 @@ INITIAL_BACKOFF_SECONDS = 35 # Free tier asks to retry after ~35s +def _difficulty_badge(difficulty: str) -> str: + badges = {"Easy": "🟢 Easy", "Medium": "🟡 Medium", "Hard": "🔴 Hard"} + return badges.get(difficulty, f"⚪ {difficulty}") + + def _build_prompt(problem, current_time: str) -> str: """ - - Builds a structured prompt for Gemini AI using - LeetCode problem details, solution code, - author information, and optional custom instructions. + Builds a structured prompt for Gemini AI using LeetCode problem details, + solution code, author information, and optional custom instructions. Args: - problem: Object containing the LeetCode problem - title, description, code, author, and custom prompt. + problem: Object containing the LeetCode problem title, description, + code, author, difficulty, and custom prompt. current_time (str): Timestamp used in the generated blog footer. - - Build the prompt string to send to Gemini AI. - Args: - problem: LeetCode problem object containing title, description, code and author - current_time: Current timestamp string - Returns: str: Fully formatted prompt string for Gemini AI blog generation. """ + badge = _difficulty_badge(getattr(problem, "difficulty", None) or "Unknown") custom_instructions = "" default_prompt = f""" - You are a professional technical writer and competitive programmer. - - Generate a highly engaging, beginner-friendly Dev.to blog post about a LeetCode problem. - - Author Account: {problem.author} - Publishing Time: {current_time} - Title: {problem.title} - - Problem Description: - {problem.description} - - Solution Code: - {problem.code} - - Strictly follow this structure: - 1. Title (Use an engaging # Title instead of YAML) - 2. Problem Explanation (explain it simply, as if to a beginner) - 3. Intuition (the "aha!" moment) - 4. Approach (step-by-step logic) - 5. Code (formatted clearly inside markdown code blocks, specify language if obvious) - 6. Time & Space Complexity Analysis - 7. Key Takeaways - 8. Submission Details (MUST include the Author Account [{problem.author}] and the Time Published [{current_time}] in a concluding footnote) - - CRITICAL INSTRUCTIONS: - - DO NOT wrap the output in ```markdown or ``` tags. Return raw markdown text. - - DO NOT output YAML frontmatter (no --- blocks). - - TABLE FORMATTING (STRICT RULES): - - If you use a Markdown table, it MUST be perfectly formatted to render correctly. - - Each row (header, separator, or data) MUST start with `|` and end with `|`. - - A table row MUST be on exactly ONE single line. DO NOT use line breaks inside rows. - - The header row, separator row (e.g., `|---|---|`), and all data rows MUST have the EXACT same number of columns. - - CELL CONTENT: If a cell contains a bitwise OR operator `|` or any pipe character, you MUST escape it as `\\|` (e.g., `(a \\| b)`). Failing to escape pipes inside cells will break the table structure. - - Ensure the separator line is continuous (no line breaks) and uses at least 3 dashes per column. - - Always provide an EMPTY LINE before and after the table to ensure correct rendering. - """ +You are a professional technical writer and competitive programmer. + +Generate a highly engaging, beginner-friendly Dev.to blog post about a LeetCode problem. + +Author Account: {problem.author} +Publishing Time: {current_time} +Title: {problem.title} +Difficulty: {badge} + +Problem Description: +{problem.description} + +Solution Code: +{problem.code} + +Strictly follow this structure: +1. Title (Use an engaging # Title instead of YAML) +2. Difficulty Badge — render it prominently right below the title as: **Difficulty:** {badge} +3. Problem Explanation (explain it simply, as if to a beginner) +4. Intuition (the "aha!" moment) +5. Approach (step-by-step logic) +6. Code (formatted clearly inside markdown code blocks, specify language if obvious) +7. Time & Space Complexity Analysis +8. Key Takeaways +9. Submission Details (MUST include the Author Account [{problem.author}] and the Time Published [{current_time}] in a concluding footnote) + +CRITICAL INSTRUCTIONS: +- DO NOT wrap the output in ```markdown or ``` tags. Return raw markdown text. +- DO NOT output YAML frontmatter (no --- blocks). +- TABLE FORMATTING (STRICT RULES): + - If you use a Markdown table, it MUST be perfectly formatted to render correctly. + - Each row (header, separator, or data) MUST start with `|` and end with `|`. + - A table row MUST be on exactly ONE single line. DO NOT use line breaks inside rows. + - The header row, separator row (e.g., `|---|---|`), and all data rows MUST have the EXACT same number of columns. + - CELL CONTENT: If a cell contains a bitwise OR operator `|` or any pipe character, you MUST escape it as `\\|` (e.g., `(a \\| b)`). Failing to escape pipes inside cells will break the table structure. + - Ensure the separator line is continuous (no line breaks) and uses at least 3 dashes per column. + - Always provide an EMPTY LINE before and after the table to ensure correct rendering. +""" if hasattr(problem, "custom_prompt") and problem.custom_prompt: - cleaned_custom_prompt = problem.custom_prompt.strip() - if cleaned_custom_prompt: + cleaned = problem.custom_prompt.strip() + if cleaned: custom_instructions = f""" - Additional User Prompt Preferences: - {cleaned_custom_prompt} - """ - - return f""" - {default_prompt} - {custom_instructions} - """ +Additional User Prompt Preferences: +{cleaned} +""" + + return f"{default_prompt}{custom_instructions}" def _clean_response(text: str) -> str: diff --git a/backend/devto.py b/backend/devto.py index 67ad46a..abb9263 100644 --- a/backend/devto.py +++ b/backend/devto.py @@ -40,7 +40,7 @@ class PublisherError(Exception): class BasePublisher: platform = "base" - def publish( + async def publish( self, title: str, content: str, *, tags: list[str], published: bool ) -> PublishResult: raise NotImplementedError @@ -78,7 +78,7 @@ async def _post_with_retries( class DevToPublisher(BasePublisher): platform = "devto" - def publish( + async def publish( self, title: str, content: str, *, tags: list[str], published: bool ) -> PublishResult: api_key = os.getenv("DEVTO_API_KEY") @@ -114,7 +114,7 @@ def publish( class HashnodePublisher(BasePublisher): platform = "hashnode" - def publish( + async def publish( self, title: str, content: str, *, tags: list[str], published: bool ) -> PublishResult: token = os.getenv("HASHNODE_TOKEN") @@ -167,7 +167,7 @@ def publish( class MediumPublisher(BasePublisher): platform = "medium" - def publish( + async def publish( self, title: str, content: str, *, tags: list[str], published: bool ) -> PublishResult: token = os.getenv("MEDIUM_TOKEN") @@ -205,7 +205,7 @@ def publish( class WebhookPublisher(BasePublisher): platform = "webhook" - def publish( + async def publish( self, title: str, content: str, *, tags: list[str], published: bool ) -> PublishResult: webhook_url = os.getenv("BLOG_WEBHOOK_URL") diff --git a/backend/main.py b/backend/main.py index 899c7ae..6cf34e3 100644 --- a/backend/main.py +++ b/backend/main.py @@ -47,8 +47,8 @@ class Problem(BaseModel): description: str code: str author: str = "Anonymous Developer" - client_time: str = None # Optional client time string - custom_prompt: str = None # custom_prompt for the user + client_time: str | None = None + custom_prompt: str | None = None platforms: list[str] | None = None publish_as_draft: bool = False tags: list[str] | None = None @@ -174,5 +174,3 @@ async def unsubscribe(data: dict): # ----------------------------- if __name__ == "__main__": uvicorn.run("main:app", host="0.0.0.0", port=10000, reload=True) - - uvicorn.run("main:app", host="0.0.0.0", port=10000, reload=True) From c2471ba5f863bfa699db8bbe1a2e06c0bd096814 Mon Sep 17 00:00:00 2001 From: hrshjswniii Date: Thu, 21 May 2026 10:54:48 +0530 Subject: [PATCH 4/9] fix: use google-genai package and patch httpx in devto tests --- backend/requirements.txt | 5 ++--- backend/tests/conftest.py | 13 +++++++------ 2 files changed, 9 insertions(+), 9 deletions(-) diff --git a/backend/requirements.txt b/backend/requirements.txt index 99dd1a4..00e873f 100644 --- a/backend/requirements.txt +++ b/backend/requirements.txt @@ -1,7 +1,7 @@ fastapi uvicorn[standard] pydantic -google-generativeai +google-genai httpx python-dotenv twilio @@ -16,5 +16,4 @@ pytest pytest-asyncio pytest-mock responses -ruff - +ruff \ No newline at end of file diff --git a/backend/tests/conftest.py b/backend/tests/conftest.py index cdd448f..8480ab0 100644 --- a/backend/tests/conftest.py +++ b/backend/tests/conftest.py @@ -146,15 +146,16 @@ def mock_gemini_client(mocker): @pytest.fixture def mock_devto_request(mocker): - devto_module = importlib.import_module("devto") response = Mock(name="devto_response") response.status_code = 201 response.json.return_value = {"id": 123, "url": "https://dev.to/mock-post"} - request_mock = mocker.patch.object( - devto_module.requests, - "post", - autospec=True, - return_value=response, + + async def fake_post(*args, **kwargs): + return response + + request_mock = mocker.patch( + "httpx.AsyncClient.post", + side_effect=fake_post, ) return {"request": request_mock, "response": response} From 04a9d67827dd613026a17206a836143e6ac81e39 Mon Sep 17 00:00:00 2001 From: hrshjswniii Date: Tue, 26 May 2026 01:32:04 +0530 Subject: [PATCH 5/9] fix: solve CI workflow Python version, progress checker UnboundLocalError, missing Query import, and test mocks/wrappers --- .github/workflows/ci.yml | 4 ++-- backend/alerts/progress_checker.py | 5 +---- backend/main.py | 2 +- backend/tests/conftest.py | 8 ++++++++ backend/tests/test_devto.py | 16 ++++++++-------- 5 files changed, 20 insertions(+), 15 deletions(-) diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml index 247aa5d..42cb64e 100644 --- a/.github/workflows/ci.yml +++ b/.github/workflows/ci.yml @@ -17,7 +17,7 @@ jobs: - name: Set up Python uses: actions/setup-python@v5 with: - python-version: "3.14" + python-version: "3.12" - name: Cache pip dependencies uses: actions/cache@v4 @@ -56,7 +56,7 @@ jobs: - name: Set up Python uses: actions/setup-python@v5 with: - python-version: "3.14" + python-version: "3.12" - name: Cache pip dependencies uses: actions/cache@v4 diff --git a/backend/alerts/progress_checker.py b/backend/alerts/progress_checker.py index 6ba03de..d2dd35c 100644 --- a/backend/alerts/progress_checker.py +++ b/backend/alerts/progress_checker.py @@ -39,9 +39,6 @@ async def _check_unsolved_users_async(): lc_username = user.get("leetcode_username", "vanshaggarwal27") if not has_solved and lc_username: try: - import asyncio - import datetime - import requests def check_lc(): @@ -61,7 +58,7 @@ def check_lc(): submissions = data.get("data", {}).get("recentAcSubmissionList", []) # Check if any submission has a timestamp from today (UTC) - midnight_utc = datetime.datetime.now(datetime.timezone.utc).replace(hour=0, minute=0, second=0, microsecond=0) + midnight_utc = datetime.now(timezone.utc).replace(hour=0, minute=0, second=0, microsecond=0) midnight_timestamp = int(midnight_utc.timestamp()) for sub in submissions: diff --git a/backend/main.py b/backend/main.py index 6011216..766aa00 100644 --- a/backend/main.py +++ b/backend/main.py @@ -4,7 +4,7 @@ import motor.motor_asyncio import uvicorn from dotenv import load_dotenv -from fastapi import FastAPI, HTTPException +from fastapi import FastAPI, HTTPException, Query from fastapi.concurrency import run_in_threadpool from fastapi.middleware.cors import CORSMiddleware from fastapi.staticfiles import StaticFiles diff --git a/backend/tests/conftest.py b/backend/tests/conftest.py index 8680bbc..de31e80 100644 --- a/backend/tests/conftest.py +++ b/backend/tests/conftest.py @@ -27,9 +27,17 @@ def __init__(self) -> None: self.update_one = AsyncMock() +class FakeProblemInfoCollection: + def __init__(self) -> None: + self.find_one = AsyncMock(return_value=None) + self.update_one = AsyncMock() + self.count_documents = AsyncMock(return_value=0) + + class FakeDatabase: def __init__(self) -> None: self.preferences = FakePreferencesCollection() + self.problem_info = FakeProblemInfoCollection() class FakeMotorClient: diff --git a/backend/tests/test_devto.py b/backend/tests/test_devto.py index 9d9e0b8..579a1bc 100644 --- a/backend/tests/test_devto.py +++ b/backend/tests/test_devto.py @@ -14,33 +14,33 @@ class TestPostToPlatform: - def test_successful_publish_returns_dict(self, mock_devto_request): + async def test_successful_publish_returns_dict(self, mock_devto_request): """Successful publish returns parsed JSON dict.""" from devto import post_to_platform - result = post_to_platform("Two Sum", "# Blog content") + result = await post_to_platform("Two Sum", "# Blog content") assert isinstance(result, dict) assert result["id"] == 123 - def test_post_sends_correct_title(self, mock_devto_request): + async def test_post_sends_correct_title(self, mock_devto_request): """The title is included in the request body.""" from devto import post_to_platform - post_to_platform("Two Sum", "# Blog content") + await post_to_platform("Two Sum", "# Blog content") call_kwargs = mock_devto_request["request"].call_args[1] assert call_kwargs["json"]["article"]["title"] == "LeetCode Solution: Two Sum" - def test_post_sends_correct_content(self, mock_devto_request): + async def test_post_sends_correct_content(self, mock_devto_request): """The markdown content is included in the request body.""" from devto import post_to_platform - post_to_platform("Two Sum", "# Blog content here") + await post_to_platform("Two Sum", "# Blog content here") call_kwargs = mock_devto_request["request"].call_args[1] assert ( "# Blog content here" in (call_kwargs["json"]["article"]["body_markdown"]) ) - def test_devto_api_error_raises(self, mock_devto_request): + async def test_devto_api_error_raises(self, mock_devto_request): """Non-2xx response raises an exception.""" from devto import post_to_platform @@ -48,7 +48,7 @@ def test_devto_api_error_raises(self, mock_devto_request): mock_devto_request["response"].text = "Internal Server Error" with pytest.raises(Exception): - post_to_platform("Two Sum", "# Blog content") + await post_to_platform("Two Sum", "# Blog content") class TestNormalizePlatforms: From b62071e700900e3b885d90d261d36bd2115c650d Mon Sep 17 00:00:00 2001 From: hrshjswniii Date: Tue, 26 May 2026 01:34:41 +0530 Subject: [PATCH 6/9] fix: add missing openai and requests dependencies to requirements.txt --- backend/requirements.txt | 2 ++ 1 file changed, 2 insertions(+) diff --git a/backend/requirements.txt b/backend/requirements.txt index 3596681..a44267c 100644 --- a/backend/requirements.txt +++ b/backend/requirements.txt @@ -2,6 +2,8 @@ fastapi uvicorn[standard] pydantic google-genai +openai +requests httpx python-dotenv twilio From 82ef31d2f0426694aa4983cc2eadeecefc00a1d5 Mon Sep 17 00:00:00 2001 From: hrshjswniii Date: Tue, 2 Jun 2026 02:07:57 +0530 Subject: [PATCH 7/9] [Feature] : add Production Reminder Scheduler Never Starts Due to Mock Scheduler Initialization --- backend/alerts/init__.py | 0 backend/main.py | 42 +++++++++++-------- backend/ruff.toml | 2 +- backend/services/call_service.py | 13 ------ .../elevenlabs_service.py | 0 .../{alerts => services}/progress_checker.py | 8 ++-- backend/services/reminder_scheduler.py | 21 ---------- backend/{alerts => services}/scheduler.py | 6 ++- .../{alerts => services}/twilio_service.py | 0 backend/services/voice_service.py | 11 ----- backend/tests/conftest.py | 8 ++-- backend/utils/progress_checker.py | 7 ---- 12 files changed, 37 insertions(+), 81 deletions(-) delete mode 100644 backend/alerts/init__.py delete mode 100644 backend/services/call_service.py rename backend/{alerts => services}/elevenlabs_service.py (100%) rename backend/{alerts => services}/progress_checker.py (94%) delete mode 100644 backend/services/reminder_scheduler.py rename backend/{alerts => services}/scheduler.py (65%) rename backend/{alerts => services}/twilio_service.py (100%) delete mode 100644 backend/services/voice_service.py delete mode 100644 backend/utils/progress_checker.py diff --git a/backend/alerts/init__.py b/backend/alerts/init__.py deleted file mode 100644 index e69de29..0000000 diff --git a/backend/main.py b/backend/main.py index 766aa00..18b8e62 100644 --- a/backend/main.py +++ b/backend/main.py @@ -1,4 +1,5 @@ import os +from contextlib import asynccontextmanager from datetime import datetime, timedelta, timezone import motor.motor_asyncio @@ -15,12 +16,30 @@ from ai_core.blog_generator import generate_blog from devto import publish_to_platforms from models.reminder import PublishRecord -from services.reminder_scheduler import start_scheduler +from services.scheduler import start_scheduler from social import share_to_platforms load_dotenv() -app = FastAPI(title="LeetLog AI", version="1.0.0") + +@asynccontextmanager +async def lifespan(app: FastAPI): + try: + start_scheduler() + print("Reminder scheduler started successfully.") + except Exception as e: + print(f"Reminder scheduler failed to start: {e}") + yield + try: + from services.scheduler import scheduler + if scheduler.running: + scheduler.shutdown() + print("Reminder scheduler shut down successfully.") + except Exception as e: + print(f"Failed to shut down scheduler: {e}") + + +app = FastAPI(title="LeetLog AI", version="1.0.0", lifespan=lifespan) app.add_middleware( CORSMiddleware, @@ -70,19 +89,6 @@ class ReminderPreference(BaseModel): is_opted_in: bool = True -# ----------------------------- -# Startup Event -# ----------------------------- -@app.on_event("startup") -async def startup_event(): - """ - Start background schedulers when server starts. - """ - try: - start_scheduler() - print("Reminder scheduler started successfully.") - except Exception as e: - print(f"Reminder scheduler failed to start: {e}") # ----------------------------- @@ -298,7 +304,7 @@ def test_whatsapp(): try: import os - from alerts.twilio_service import send_whatsapp_message + from services.twilio_service import send_whatsapp_message phone = os.getenv("TEST_PHONE_NUMBER") if not phone: return {"status": "error", "message": "TEST_PHONE_NUMBER is not set in environment."} @@ -312,8 +318,8 @@ def test_call(): try: import os - from alerts.elevenlabs_service import generate_audio, generate_message - from alerts.twilio_service import make_call + from services.elevenlabs_service import generate_audio, generate_message + from services.twilio_service import make_call message = generate_message("Vansh") diff --git a/backend/ruff.toml b/backend/ruff.toml index 21b06a3..62a741f 100644 --- a/backend/ruff.toml +++ b/backend/ruff.toml @@ -6,4 +6,4 @@ select = ["E", "F", "W", "I"] ignore = ["E501"] [lint.isort] -known-first-party = ["ai", "devto", "services", "alerts", "models", "utils"] +known-first-party = ["ai", "devto", "services", "models"] diff --git a/backend/services/call_service.py b/backend/services/call_service.py deleted file mode 100644 index 4b3270b..0000000 --- a/backend/services/call_service.py +++ /dev/null @@ -1,13 +0,0 @@ -import os - -from twilio.rest import Client - -client = Client(os.getenv("TWILIO_ACCOUNT_SID"), os.getenv("TWILIO_AUTH_TOKEN")) - - -def make_call(to_number: str, audio_url: str): - return client.calls.create( - to=to_number, - from_=os.getenv("TWILIO_PHONE_NUMBER"), - twiml=f"{audio_url}", - ) diff --git a/backend/alerts/elevenlabs_service.py b/backend/services/elevenlabs_service.py similarity index 100% rename from backend/alerts/elevenlabs_service.py rename to backend/services/elevenlabs_service.py diff --git a/backend/alerts/progress_checker.py b/backend/services/progress_checker.py similarity index 94% rename from backend/alerts/progress_checker.py rename to backend/services/progress_checker.py index d2dd35c..6f7f417 100644 --- a/backend/alerts/progress_checker.py +++ b/backend/services/progress_checker.py @@ -4,8 +4,8 @@ import motor.motor_asyncio -from alerts.elevenlabs_service import generate_message -from alerts.twilio_service import send_whatsapp_message +from services.elevenlabs_service import generate_message +from services.twilio_service import send_whatsapp_message # Setup sync-to-async MongoDB connection mongo_client = motor.motor_asyncio.AsyncIOMotorClient(os.getenv("MONGODB_URI")) @@ -84,8 +84,8 @@ def check_lc(): try: # 1. Try to Generate Audio via ElevenLabs - from alerts.elevenlabs_service import generate_audio - from alerts.twilio_service import make_call + from services.elevenlabs_service import generate_audio + from services.twilio_service import make_call print("Generating audio via ElevenLabs...") try: diff --git a/backend/services/reminder_scheduler.py b/backend/services/reminder_scheduler.py deleted file mode 100644 index 2c64124..0000000 --- a/backend/services/reminder_scheduler.py +++ /dev/null @@ -1,21 +0,0 @@ -from apscheduler.schedulers.background import BackgroundScheduler - -from utils.progress_checker import has_completed_daily_problem - -scheduler = BackgroundScheduler() - - -def check_daily_progress(): - user_id = "demo-user" - - completed = has_completed_daily_problem(user_id) - - if not completed: - print("User missed daily problem. Trigger reminder call.") - - -scheduler.add_job(check_daily_progress, "interval", minutes=60) - - -def start_scheduler(): - scheduler.start() diff --git a/backend/alerts/scheduler.py b/backend/services/scheduler.py similarity index 65% rename from backend/alerts/scheduler.py rename to backend/services/scheduler.py index 6255b51..e217901 100644 --- a/backend/alerts/scheduler.py +++ b/backend/services/scheduler.py @@ -1,11 +1,13 @@ from apscheduler.schedulers.background import BackgroundScheduler from pytz import timezone -from alerts.progress_checker import check_unsolved_users +from services.progress_checker import check_unsolved_users scheduler = BackgroundScheduler() # Check daily at 11:00 PM IST scheduler.add_job(check_unsolved_users, "cron", hour=23, minute=0, timezone=timezone("Asia/Kolkata")) -scheduler.start() +def start_scheduler(): + if not scheduler.running: + scheduler.start() diff --git a/backend/alerts/twilio_service.py b/backend/services/twilio_service.py similarity index 100% rename from backend/alerts/twilio_service.py rename to backend/services/twilio_service.py diff --git a/backend/services/voice_service.py b/backend/services/voice_service.py deleted file mode 100644 index 96f1730..0000000 --- a/backend/services/voice_service.py +++ /dev/null @@ -1,11 +0,0 @@ -import os - -from elevenlabs.client import ElevenLabs - -client = ElevenLabs(api_key=os.getenv("ELEVENLABS_API_KEY")) - - -def generate_voice_message(text: str): - audio = client.text_to_speech.convert(voice_id="EXAVITQu4vr4xnSDxMaL", text=text) - - return audio diff --git a/backend/tests/conftest.py b/backend/tests/conftest.py index de31e80..784daff 100644 --- a/backend/tests/conftest.py +++ b/backend/tests/conftest.py @@ -78,10 +78,10 @@ def app_module(monkeypatch: pytest.MonkeyPatch): for module_name in [ "main", - "alerts.scheduler", - "alerts.progress_checker", - "alerts.elevenlabs_service", - "services.reminder_scheduler", + "services.scheduler", + "services.progress_checker", + "services.twilio_service", + "services.elevenlabs_service", ]: sys.modules.pop(module_name, None) diff --git a/backend/utils/progress_checker.py b/backend/utils/progress_checker.py deleted file mode 100644 index 8ddaee8..0000000 --- a/backend/utils/progress_checker.py +++ /dev/null @@ -1,7 +0,0 @@ -def has_completed_daily_problem(user_id: str): - """ - Temporary mock implementation. - Later this can connect to database/user activity. - """ - - return False From 324b848c5a1463e91f90ab46d574efc094798893 Mon Sep 17 00:00:00 2001 From: hrshjswniii Date: Tue, 2 Jun 2026 02:17:45 +0530 Subject: [PATCH 8/9] refactor(backend): Promote production scheduler, consolidate services, and modernize startup lifecycle --- backend/main.py | 4 ++-- backend/services/{progress_checker.py => progress_service.py} | 0 backend/services/{scheduler.py => scheduler_service.py} | 2 +- backend/tests/conftest.py | 4 ++-- 4 files changed, 5 insertions(+), 5 deletions(-) rename backend/services/{progress_checker.py => progress_service.py} (100%) rename backend/services/{scheduler.py => scheduler_service.py} (85%) diff --git a/backend/main.py b/backend/main.py index 18b8e62..8da5323 100644 --- a/backend/main.py +++ b/backend/main.py @@ -16,7 +16,7 @@ from ai_core.blog_generator import generate_blog from devto import publish_to_platforms from models.reminder import PublishRecord -from services.scheduler import start_scheduler +from services.scheduler_service import start_scheduler from social import share_to_platforms load_dotenv() @@ -31,7 +31,7 @@ async def lifespan(app: FastAPI): print(f"Reminder scheduler failed to start: {e}") yield try: - from services.scheduler import scheduler + from services.scheduler_service import scheduler if scheduler.running: scheduler.shutdown() print("Reminder scheduler shut down successfully.") diff --git a/backend/services/progress_checker.py b/backend/services/progress_service.py similarity index 100% rename from backend/services/progress_checker.py rename to backend/services/progress_service.py diff --git a/backend/services/scheduler.py b/backend/services/scheduler_service.py similarity index 85% rename from backend/services/scheduler.py rename to backend/services/scheduler_service.py index e217901..623d3f2 100644 --- a/backend/services/scheduler.py +++ b/backend/services/scheduler_service.py @@ -1,7 +1,7 @@ from apscheduler.schedulers.background import BackgroundScheduler from pytz import timezone -from services.progress_checker import check_unsolved_users +from services.progress_service import check_unsolved_users scheduler = BackgroundScheduler() diff --git a/backend/tests/conftest.py b/backend/tests/conftest.py index 784daff..628f74a 100644 --- a/backend/tests/conftest.py +++ b/backend/tests/conftest.py @@ -78,8 +78,8 @@ def app_module(monkeypatch: pytest.MonkeyPatch): for module_name in [ "main", - "services.scheduler", - "services.progress_checker", + "services.scheduler_service", + "services.progress_service", "services.twilio_service", "services.elevenlabs_service", ]: From 7d36a2313cda8eeb04ee3351ed208e024072ef4c Mon Sep 17 00:00:00 2001 From: hrshjswniii Date: Tue, 2 Jun 2026 02:36:48 +0530 Subject: [PATCH 9/9] fix(lint): Resolve syntax errors and format imports --- backend/ai.py | 2 ++ backend/tasks/reminder_tasks.py | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/backend/ai.py b/backend/ai.py index 549379c..2017782 100644 --- a/backend/ai.py +++ b/backend/ai.py @@ -27,6 +27,8 @@ def _difficulty_badge(difficulty: str) -> str: return badges.get(difficulty, f"⚪ {difficulty}") +def _build_prompt(problem, current_time: str) -> str: + """ Builds a structured prompt for Gemini AI using LeetCode problem details, solution code, author information, and optional custom instructions. diff --git a/backend/tasks/reminder_tasks.py b/backend/tasks/reminder_tasks.py index 980b31e..4ee4ddd 100644 --- a/backend/tasks/reminder_tasks.py +++ b/backend/tasks/reminder_tasks.py @@ -1,7 +1,7 @@ import asyncio -from services.progress_service import check_user_progress_and_alert from celery_app import celery_app +from services.progress_service import check_user_progress_and_alert @celery_app.task(