Merge branch 'main' into discordBot/main

Author: Vivekgupta008

backend/app/core/events/enums.py

@@ -16,6 +16,7 @@ class EventType(str, Enum):
     PR_UPDATED = "pr.updated"
     PR_COMMENTED = "pr.commented"
     PR_MERGED = "pr.merged"
+
     PR_REVIEWED = "pr.reviewed"
 
     MESSAGE_CREATED = "message.created"
@@ -28,4 +29,8 @@ class EventType(str, Enum):
     ONBOARDING_COMPLETED = "onboarding.completed"
     FAQ_REQUESTED = "faq.requested"
     KNOWLEDGE_UPDATED = "knowledge.updated"
-    ANALYTICS_COLLECTED = "analytics.collected"
+
+    ANALYTICS_COLLECTED = "analytics.collected"
+
+    ANALYTICS_COLLECTED = "analytics.collected"
+

backend/app/services/vector_db/service.py

@@ -1,9 +1,9 @@
-import logging
 import os
 from typing import List, Dict, Any, Optional
+from uuid import UUID
+from pydantic import BaseModel, Field
 from dotenv import load_dotenv
 from supabase import create_client, Client
-from embedding_service.service import EmbeddingItem
 
 load_dotenv()
 
@@ -12,6 +12,14 @@
 
 logger = logging.getLogger(__name__)
 
+class EmbeddingItem(BaseModel):
+    id: str
+
+    collection: str
+    content: str
+    metadata: Dict[str, Any] = Field(default_factory=dict)
+    embedding: Optional[List[float]] = None
+
 
 class VectorDBService:
     """Service for interacting with Supabase Vector DB via RPC"""

backend/main.py

@@ -3,9 +3,9 @@
 import uvicorn
 
 app = FastAPI()
-
 # Include GitHub webhook routes
 app.include_router(router)
 
 if __name__ == "__main__":
-    uvicorn.run(app, host="127.0.0.1", port=8000)
+    uvicorn.run(app, host="127.0.0.1", port=8000)
+

backend/routes.py

@@ -0,0 +1,94 @@
+import asyncio
+import uuid
+import logging
+from fastapi import APIRouter, Request, HTTPException
+from app.core.events.event_bus import EventBus
+from app.core.events.enums import EventType, PlatformType
+from app.core.events.base import BaseEvent
+from app.core.handler.handler_registry import HandlerRegistry
+from pydantic import BaseModel
+
+router = APIRouter()
+
+class RepoRequest(BaseModel):
+    repo_url: str
+
+logging.basicConfig(level=logging.INFO)
+handler_registry = HandlerRegistry()
+event_bus = EventBus(handler_registry)
+
+# Sample handler function to process events
+async def sample_handler(event: BaseEvent):
+    logging.info(f"Handler received event: {event.event_type} with data: {event.raw_data}")
+
+# Register all the event handlers for issues and pull requests
+def register_event_handlers():
+    # Issue events
+    event_bus.register_handler(EventType.ISSUE_CREATED, sample_handler, PlatformType.GITHUB)
+    event_bus.register_handler(EventType.ISSUE_CLOSED, sample_handler, PlatformType.GITHUB)
+    event_bus.register_handler(EventType.ISSUE_UPDATED, sample_handler, PlatformType.GITHUB)
+    event_bus.register_handler(EventType.ISSUE_COMMENTED, sample_handler, PlatformType.GITHUB)
+    # Pull request events
+    event_bus.register_handler(EventType.PR_CREATED, sample_handler, PlatformType.GITHUB)
+    event_bus.register_handler(EventType.PR_UPDATED, sample_handler, PlatformType.GITHUB)
+    event_bus.register_handler(EventType.PR_COMMENTED, sample_handler, PlatformType.GITHUB)
+    event_bus.register_handler(EventType.PR_MERGED, sample_handler, PlatformType.GITHUB)
+
+@router.post("/github/webhook")
+async def github_webhook(request: Request):
+    payload = await request.json()
+    event_header = request.headers.get("X-GitHub-Event")
+    logging.info(f"Received GitHub event: {event_header}")
+
+    event_type = None
+
+    # Handle issue events
+    if event_header == "issues":
+        action = payload.get("action")
+        if action == "opened":
+            event_type = EventType.ISSUE_CREATED
+        elif action == "closed":
+            event_type = EventType.ISSUE_CLOSED
+        elif action == "edited":
+            event_type = EventType.ISSUE_UPDATED
+
+    # Handle issue comment events
+    elif event_header == "issue_comment":
+        action = payload.get("action")
+        if action == "created":
+            event_type = EventType.ISSUE_COMMENTED
+
+    # Handle pull request events
+    elif event_header == "pull_request":
+        action = payload.get("action")
+        if action == "opened":
+            event_type = EventType.PR_CREATED
+        elif action == "edited":
+            event_type = EventType.PR_UPDATED
+        elif action == "closed":
+            # Determine if the PR was merged or simply closed
+            if payload.get("pull_request", {}).get("merged"):
+                event_type = EventType.PR_MERGED
+            else:
+                logging.info("Pull request closed without merge; no event dispatched.")
+    
+    # Handle pull request comment events
+    elif event_header in ["pull_request_review_comment", "pull_request_comment"]:
+        action = payload.get("action")
+        if action == "created":
+            event_type = EventType.PR_COMMENTED
+
+    # Dispatch the event if we have a matching type
+    if event_type:
+        event = BaseEvent(
+            id=str(uuid.uuid4()),
+            actor_id=str(payload.get("sender", {}).get("id", "unknown")),
+            event_type=event_type,
+            platform=PlatformType.GITHUB,
+            raw_data=payload
+        )
+        await event_bus.dispatch(event)
+    else:
+        logging.info(f"No matching event type for header: {event_header} with action: {payload.get('action')}")
+
+    return {"status": "ok"}

backend/temp/Perspective

@@ -0,0 +1 @@
+Subproject commit cd9f19d40e9bdd25172c09d6093386778959690c

frontend/.gitignore

@@ -1,23 +1,24 @@
-# See https://help.github.com/articles/ignoring-files/ for more about ignoring files.
-
-# dependencies
-/node_modules
-/.pnp
-.pnp.js
-
-# testing
-/coverage
-
-# production
-/build
-
-# misc
-.DS_Store
-.env.local
-.env.development.local
-.env.test.local
-.env.production.local
-
+# Logs
+logs
+*.log
 npm-debug.log*
 yarn-debug.log*
 yarn-error.log*
+pnpm-debug.log*
+lerna-debug.log*
+
+node_modules
+dist
+dist-ssr
+*.local
+
+# Editor directories and files
+.vscode/*
+!.vscode/extensions.json
+.idea
+.DS_Store
+*.suo
+*.ntvs*
+*.njsproj
+*.sln
+*.sw?

frontend/README.md

@@ -0,0 +1,28 @@
+import js from '@eslint/js';
+import globals from 'globals';
+import reactHooks from 'eslint-plugin-react-hooks';
+import reactRefresh from 'eslint-plugin-react-refresh';
+import tseslint from 'typescript-eslint';
+
+export default tseslint.config(
+  { ignores: ['dist'] },
+  {
+    extends: [js.configs.recommended, ...tseslint.configs.recommended],
+    files: ['**/*.{ts,tsx}'],
+    languageOptions: {
+      ecmaVersion: 2020,
+      globals: globals.browser,
+    },
+    plugins: {
+      'react-hooks': reactHooks,
+      'react-refresh': reactRefresh,
+    },
+    rules: {
+      ...reactHooks.configs.recommended.rules,
+      'react-refresh/only-export-components': [
+        'warn',
+        { allowConstantExport: true },
+      ],
+    },
+  }
+);

frontend/eslint.config.js

@@ -0,0 +1,13 @@
+<!doctype html>
+<html lang="en">
+  <head>
+    <meta charset="UTF-8" />
+    <link rel="icon" type="image/svg+xml" href="/vite.svg" />
+    <meta name="viewport" content="width=device-width, initial-scale=1.0" />
+    <title>Devr.AI</title>
+  </head>
+  <body>
+    <div id="root"></div>
+    <script type="module" src="/src/main.tsx"></script>
+  </body>
+</html>