Merge branch 'staging' into fix-search-element

Author: Anchel123

.github/dependabot.yml

@@ -8,5 +8,6 @@ updates:
   - package-ecosystem: "npm" # See documentation for possible values
     directory: "/" # Location of package manifests
     schedule:
-      interval: "weekly"
+      interval: "daily"
+    target-branch: "staging"
 

.github/workflows/playwright.yml

@@ -0,0 +1,41 @@
+name: Playwright Tests
+on:
+  push:
+    branches: [ main, staging ]
+  pull_request:
+    branches: [ main, staging ]
+jobs:
+  test:
+    timeout-minutes: 60
+    runs-on: ubuntu-latest
+    services:
+      falkordb:
+        image: falkordb/falkordb:latest
+        ports:
+          - 6379:6379
+    steps:
+    - uses: actions/checkout@v4
+    - uses: actions/setup-node@v4
+      with:
+        node-version: lts/*
+    - name: Install dependencies
+      run: npm ci
+    - name: Install Playwright Browsers
+      run: npx playwright install --with-deps
+    - name: Set up environment variables and run tests
+      env:
+        FALKORDB_URL: ${{ secrets.FALKORDB_URL }}
+        OPENAI_API_KEY: ${{ secrets.OPENAI_API_KEY }}
+        SECRET_TOKEN: ${{ secrets.SECRET_TOKEN }}
+        NEXT_PUBLIC_MODE: UNLIMITED
+        BACKEND_URL: ${{ secrets.BACKEND_URL }}
+      run: |
+        npm install
+        npm run build
+        NEXTAUTH_SECRET=SECRET npm start & npx playwright test --reporter=dot,list
+    - uses: actions/upload-artifact@v4
+      if: ${{ !cancelled() }}
+      with:
+        name: playwright-report
+        path: playwright-report/
+        retention-days: 30

.gitignore

@@ -37,4 +37,9 @@ next-env.d.ts
 
 
 # vscode
-/.vscode/
+/.vscode/
+node_modules/
+/test-results/
+/playwright-report/
+/blob-report/
+/playwright/.cache/

app/api/chat/[graph]/route.ts

@@ -1,19 +1,28 @@
 import { NextRequest, NextResponse } from "next/server"
+import { getEnvVariables } from "../../utils"
 
 
-export async function POST(request: NextRequest, { params }: { params: { graph: string } }) {
+export async function POST(request: NextRequest, { params }: { params: Promise<{ graph: string }> }) {
 
-    const graphName = params.graph
+    const repo = (await params).graph
     const msg = request.nextUrl.searchParams.get('msg')
 
     try {
-        const result = await fetch(`${process.env.BACKEND_URL}/chat`, {
+
+        if (!msg) {
+            throw new Error("Message parameter is required")
+        }
+
+        const { url, token } = getEnvVariables()
+
+        const result = await fetch(`${url}/chat`, {
             method: 'POST',
-            body: JSON.stringify({ repo: graphName, msg }),
+            body: JSON.stringify({ repo, msg }),
             headers: {
-                "Authorization": process.env.SECRET_TOKEN!,
+                "Authorization": token,
                 "Content-Type": 'application/json'
-            }
+            },
+            cache: 'no-store'
         })
 
         if (!result.ok) {
@@ -24,6 +33,7 @@ export async function POST(request: NextRequest, { params }: { params: { graph:
 
         return NextResponse.json({ result: json }, { status: 200 })
     } catch (err) {
-        return NextResponse.json({ message: (err as Error).message }, { status: 400 })
+        console.error(err)
+        return NextResponse.json((err as Error).message, { status: 400 })
     }
 }

app/api/repo/[graph]/[node]/route.ts

@@ -1,45 +1,34 @@
+import { getEnvVariables } from "@/app/api/utils";
 import { NextRequest, NextResponse } from "next/server";
 
-export async function GET(request: NextRequest, { params }: { params: { graph: string, node: string } }) {
+export async function POST(request: NextRequest, { params }: { params: Promise<{ graph: string, node: string }> }) {
 
-    const nodeId = parseInt(params.node);
-    const graphId = params.graph;
-    try {
-
-        const result = await fetch(`${process.env.BACKEND_URL}/get_neighbors?repo=${graphId}&node_id=${nodeId}`, {
-            method: 'GET',
-            headers: {
-                "Authorization": process.env.SECRET_TOKEN!,
-            }
-        })
-
-        const json = await result.json()
+    const p = await params;
 
-        return NextResponse.json({ result: json }, { status: 200 })
-    } catch (err) {
-        return NextResponse.json({ massage: (err as Error).message }, { status: 400 })
-    }
-}
+    const repo = p.graph;
+    const src = Number(p.node);
+    const dest = Number(request.nextUrl.searchParams.get('targetId'))
 
-export async function POST(request: NextRequest, { params }: { params: { graph: string, node: string } }) {
+    try {
 
-    const nodeId = params.node;
-    const graphId = params.graph;
-    const targetId = request.nextUrl.searchParams.get('targetId')
+        if (!dest) {
+            throw new Error("targetId is required");
+        }
 
-    try {
+        const { url, token } = getEnvVariables()
 
-        const result = await fetch(`${process.env.BACKEND_URL}/find_paths`, {
+        const result = await fetch(`${url}/find_paths`, {
             method: 'POST',
             headers: {
-                "Authorization": process.env.SECRET_TOKEN!,
+                "Authorization": token,
                 'Content-Type': 'application/json'
             },
             body: JSON.stringify({
-                repo: graphId,
-                src: Number(nodeId),
-                dest: Number(targetId!)
-            })
+                repo,
+                src,
+                dest
+            }),
+            cache: 'no-store'
         })
 
         if (!result.ok) {
@@ -50,6 +39,7 @@ export async function POST(request: NextRequest, { params }: { params: { graph:
 
         return NextResponse.json({ result: json }, { status: 200 })
     } catch (err) {
-        return NextResponse.json({ massage: (err as Error).message }, { status: 200 })
+        console.error(err)
+        return NextResponse.json((err as Error).message, { status: 400 })
     }
 }

app/api/repo/[graph]/commit/route.ts

@@ -0,0 +1,37 @@
+import { getEnvVariables } from "@/app/api/utils";
+import { NextRequest, NextResponse } from "next/server";
+
+export async function GET(request: NextRequest, { params }: { params: Promise<{ graph: string }> }) {
+
+    const repo = (await params).graph
+
+    try {
+
+        const { url, token } = getEnvVariables()
+
+        const result = await fetch(`${url}/list_commits`, {
+            method: 'POST',
+            body: JSON.stringify({ repo }),
+            headers: {
+                "Authorization": token,
+                "Content-Type": 'application/json'
+            },
+            cache: 'no-store'
+        })
+
+        if (!result.ok) {
+            throw new Error(await result.text())
+        }
+
+        const json = await result.json()
+
+        return NextResponse.json({ result: json }, { status: 200 })
+    } catch (err) {
+        console.error(err)
+        return NextResponse.json((err as Error).message, { status: 400 })
+    }
+}
+
+export async function POST(request: NextRequest, { params }: { params: Promise<{ graph: string }> }) {
+
+}

app/api/repo/[graph]/info/route.ts

@@ -0,0 +1,33 @@
+import { NextRequest, NextResponse } from "next/server";
+import { getEnvVariables } from "@/app/api/utils";
+
+export async function GET(request: NextRequest, { params }: { params: Promise<{ graph: string }> }) {
+
+    const repo = (await params).graph
+
+    try {
+
+        const { url, token } = getEnvVariables();
+
+        const result = await fetch(`${url}/repo_info`, {
+            method: 'POST',
+            body: JSON.stringify({ repo }),
+            headers: {
+                "Authorization": token,
+                "Content-Type": 'application/json'
+            },
+            cache: 'no-store'
+        })
+
+        if (!result.ok) {
+            throw new Error(await result.text())
+        }
+
+        const json = await result.json()
+
+        return NextResponse.json({ result: json }, { status: 200 })
+    } catch (err) {
+        console.error(err)
+        return NextResponse.json((err as Error).message, { status: 400 })
+    }
+}

app/api/repo/[graph]/neighbors/route.ts

@@ -0,0 +1,34 @@
+import { NextRequest, NextResponse } from "next/server";
+import { getEnvVariables } from "@/app/api/utils";
+
+export async function POST(request: NextRequest, { params }: { params: Promise<{ graph: string }> }) {
+
+    const repo = (await params).graph;
+    const node_ids = (await request.json()).nodeIds.map((id: string) => Number(id));
+
+    try {
+
+        const { url, token } = getEnvVariables();
+
+        if (node_ids.length === 0) {
+            throw new Error("nodeIds is required");
+        }
+
+        const result = await fetch(`${url}/get_neighbors`, {
+            method: 'POST',
+            body: JSON.stringify({ node_ids, repo }),
+            headers: {
+                "Content-Type": 'application/json',
+                "Authorization": token,
+            },
+            cache: 'no-store'
+        })
+
+        const json = await result.json()
+
+        return NextResponse.json({ result: json }, { status: 200 })
+    } catch (err) {
+        console.error(err)
+        return NextResponse.json((err as Error).message, { status: 400 })
+    }
+}