Develop

apps/leafcutter/app/api/auth/[...nextauth]/route.ts

@@ -0,0 +1,6 @@
+import NextAuth from "next-auth";
+import { authOptions } from "app/_lib/auth";
+
+const handler = NextAuth(authOptions);
+
+export { handler as GET, handler as POST };

apps/leafcutter/app/api/proxy/[[...path]].ts

@@ -0,0 +1,38 @@
+import { createProxyMiddleware } from "http-proxy-middleware";
+import { NextApiRequest, NextApiResponse } from "next";
+import { getToken } from "next-auth/jwt";
+
+const withAuthInfo =
+  (handler: any) => async (req: NextApiRequest, res: NextApiResponse) => {
+    const session: any = await getToken({
+      req,
+      secret: process.env.NEXTAUTH_SECRET,
+    });
+
+    if (!session) {
+      return res.redirect("/login");
+    }
+
+    req.headers["x-proxy-user"] = session.email.toLowerCase();
+    req.headers["x-proxy-roles"] = "leafcutter_user";
+    const auth = `${session.email.toLowerCase()}:${process.env.OPENSEARCH_USER_PASSWORD}`;
+    const buff = Buffer.from(auth);
+    const base64data = buff.toString("base64");
+    req.headers.Authorization = `Basic ${base64data}`;
+    return handler(req, res);
+  };
+
+const proxy = createProxyMiddleware({
+  target: process.env.OPENSEARCH_DASHBOARDS_URL,
+  changeOrigin: true,
+  xfwd: true,
+});
+
+export default withAuthInfo(proxy);
+
+export const config = {
+  api: {
+    bodyParser: false,
+    externalResolver: true,
+  },
+};

apps/leafcutter/app/api/searches/create/route.ts

@@ -0,0 +1,22 @@
+import { NextRequest, NextResponse } from "next/server";
+import { getServerSession } from "next-auth";
+import { authOptions } from "app/_lib/auth";
+import { getUserMetadata, saveUserMetadata } from "app/_lib/opensearch";
+
+export const POST = async (req: NextRequest) => {
+    const session = await getServerSession(authOptions);
+    const { user: { email } }: any = session;
+    const { name, query } = await req.json();
+    const result = await getUserMetadata(email);
+    const { savedSearches } = result;
+    await saveUserMetadata(email, {
+        savedSearches: [...savedSearches, { name, query }]
+    });
+    const { savedSearches: updatedSavedSearches } = await getUserMetadata(email);
+
+    return NextResponse.json(updatedSavedSearches);
+};
+
+
+
+

apps/leafcutter/app/api/searches/delete/route.ts

@@ -0,0 +1,19 @@
+import { NextRequest, NextResponse } from "next/server";
+import { getServerSession } from "next-auth";
+import { authOptions } from "app/_lib/auth";
+import { getUserMetadata, saveUserMetadata } from "app/_lib/opensearch";
+
+export const POST = async (req: NextRequest) => {
+    const session = await getServerSession(authOptions);
+    const { user: { email } }: any = session;
+    const { name } = await req.json();
+    const { savedSearches } = await getUserMetadata(email);
+    const updatedSavedSearches = savedSearches.filter((search: any) => search.name !== name);
+    const result = await saveUserMetadata(email, { savedSearches: updatedSavedSearches });
+
+    return NextResponse.json({ result });
+};
+
+
+
+

apps/leafcutter/app/api/searches/list/route.ts

@@ -0,0 +1,12 @@
+import { NextResponse } from "next/server";
+import { getServerSession } from "next-auth";
+import { authOptions } from "app/_lib/auth";
+import { getUserMetadata } from "app/_lib/opensearch";
+
+export const GET = async () => {
+    const session = await getServerSession(authOptions);
+    const { user: { email } }: any = session;
+    const { savedSearches } = await getUserMetadata(email);
+
+    return NextResponse.json(savedSearches);
+};

apps/leafcutter/app/api/trends/recent/_route.ts

@@ -0,0 +1,9 @@
+import { NextResponse } from "next/server";
+import { getTrends } from "app/_lib/opensearch";
+
+export const GET = async () => {
+    const results = await getTrends(5);
+
+    NextResponse.json(results);
+};
+

apps/leafcutter/app/api/upload/index.ts

@@ -0,0 +1,55 @@
+/* eslint-disable no-restricted-syntax */
+import { NextRequest, NextResponse } from "next/server";
+import { Client } from "@opensearch-project/opensearch";
+import { v4 as uuid } from "uuid";
+import taxonomy from "app/_config/taxonomy.json";
+import unRegions from "app/_config/unRegions.json";
+
+export const POST = async (req: NextRequest) => {
+  const { tickets } = await req.json();
+  const authorization = req.headers.get("authorization");
+  const baseURL = `https://${process.env.OPENSEARCH_URL}`;
+  const client = new Client({
+    node: baseURL,
+    ssl: {
+      rejectUnauthorized: false,
+    },
+    headers: {
+      authorization
+    }
+  });
+
+  const succeeded = [];
+  const failed = [];
+
+  for await (const ticket of tickets) {
+    const { id } = ticket;
+    try {
+      const country = ticket.country[0] ?? "none";
+      // @ts-expect-error
+      const translatedCountry = taxonomy.country[country]?.display ?? "none";
+      const countryDetails: any = unRegions.find((c) => c.name === translatedCountry);
+      const augmentedTicket = {
+        ...ticket,
+        region: countryDetails['sub-region']?.toLowerCase().replace(" ", "-") ?? null,
+        continent: countryDetails.region?.toLowerCase().replace(" ", "-") ?? null,
+      };
+      const out = await client.create({
+        id: uuid(),
+        index: "sample_tagged_tickets",
+        refresh: true,
+        body: augmentedTicket,
+      });
+      console.log(out);
+      succeeded.push(id);
+    } catch (e) {
+      console.log(e);
+      failed.push(id);
+    }
+  }
+
+  const results = { succeeded, failed };
+
+  return NextResponse.json(results);
+};
+

apps/leafcutter/app/api/visualizations/create/route.ts

@@ -0,0 +1,20 @@
+import { NextRequest, NextResponse } from "next/server";
+import { getServerSession } from "next-auth";
+import { authOptions } from "app/_lib/auth";
+import { createUserVisualization } from "app/_lib/opensearch";
+
+export const POST = async (req: NextRequest) => {
+    const session = await getServerSession(authOptions);
+    const { user: { email } }: any = session;
+    const { visualizationID, title, description, query } = await req.json();
+    const id = await createUserVisualization({
+        email,
+        visualizationID,
+        title,
+        description,
+        query
+    });
+
+    return NextResponse.json({ id });
+};
+

apps/leafcutter/app/api/visualizations/delete/route.ts

@@ -0,0 +1,15 @@
+import { NextRequest, NextResponse } from "next/server";
+import { getServerSession } from "next-auth";
+import { authOptions } from "app/_lib/auth";
+import { deleteUserVisualization } from "app/_lib/opensearch";
+
+export const POST = async (req: NextRequest, res: NextResponse) => {
+    const session = await getServerSession(authOptions);
+    const { user: { email } }: any = session;
+    const { id } = await req.json();
+    await deleteUserVisualization(email as string, id);
+
+    return NextResponse.json({ id });
+};
+
+

apps/leafcutter/app/api/visualizations/query/route.ts

@@ -0,0 +1,12 @@
+import { NextRequest, NextResponse } from "next/server";
+import { performQuery } from "app/_lib/opensearch";
+
+export const GET = async (req: NextRequest) => {
+    const searchQuery = req.nextUrl.searchParams.get("searchQuery");
+    const rawQuery = await JSON.parse(decodeURI(searchQuery as string));
+    const results = await performQuery(rawQuery, 1000);
+
+    return NextResponse.json(results);
+};
+
+

apps/leafcutter/app/api/visualizations/update/route.ts

@@ -0,0 +1,21 @@
+import { NextRequest, NextResponse } from "next/server";
+import { getServerSession } from "next-auth";
+import { authOptions } from "app/_lib/auth";
+import { updateUserVisualization } from "app/_lib/opensearch";
+
+export const POST = async (req: NextRequest) => {
+    const session = await getServerSession(authOptions);
+    const { user: { email } }: any = session;
+    const { id, title, description, query } = await req.json();
+    await updateUserVisualization({
+        email,
+        id,
+        title,
+        description,
+        query
+    });
+
+    return NextResponse.json({ id });
+};
+
+