From 84fabe6690f02d31d7c4a7db6823f449288a7369 Mon Sep 17 00:00:00 2001
From: maany <imptodefeat@gmail.com>
Date: Sun, 4 Aug 2024 11:58:09 +0200
Subject: [PATCH] auth, list-research-context: use kp credentials from session
 #7

---
 .../_components/list-research-contexts.tsx    | 18 ++------
 src/app/page.tsx                              | 41 +++++++++--------
 src/lib/core/dto/auth-dto.ts                  | 14 +++++-
 .../secondary/auth-gateway-output-port.ts     |  3 +-
 .../server/config/auth/next-auth-config.ts    |  7 ++-
 .../server/gateway/next-auth-gateway.ts       | 46 +++++++++++++++----
 6 files changed, 85 insertions(+), 44 deletions(-)

diff --git a/src/app/_components/list-research-contexts.tsx b/src/app/_components/list-research-contexts.tsx
index 22dc696..5cc18d4 100644
--- a/src/app/_components/list-research-contexts.tsx
+++ b/src/app/_components/list-research-contexts.tsx
@@ -9,15 +9,11 @@ export type ListResearchContextsPageProps = {
   researchContexts: ResearchContext[];
   kernelPlancksterHost: string;
 };
- const IdiotPage = ({children}: {children: React.ReactNode}) => {
-  return (
-    <div>
-      {children}
-    </div>
-  )
- }
+
 export function ListResearchContextsPage(props: ListResearchContextsPageProps) {
-  const api = clientContainer.get<TClientComponentAPI>(TRPC.REACT_CLIENT_COMPONENTS_API);
+  const api = clientContainer.get<TClientComponentAPI>(
+    TRPC.REACT_CLIENT_COMPONENTS_API,
+  );
   const addNewContextMutation = api.kernel.researchContext.create.useMutation({
     onSuccess: () => {
       // TODO: handle success
@@ -25,14 +21,8 @@ export function ListResearchContextsPage(props: ListResearchContextsPageProps) {
     },
   });
 
-  const MySecyButton = (<button
-    
-  >Sexy</button>)
   return (
     <div>
-      <IdiotPage>
-        {MySecyButton}
-      </IdiotPage>
       <button disabled={false} />
       {addNewContextMutation.isError && (
         <div>Error: {addNewContextMutation.error.message}</div>
diff --git a/src/app/page.tsx b/src/app/page.tsx
index 027c17d..fb37092 100644
--- a/src/app/page.tsx
+++ b/src/app/page.tsx
@@ -4,36 +4,41 @@ import { ListResearchContextsPage } from "./_components/list-research-contexts";
 import type { ResearchContext } from "@maany_shr/kernel-planckster-sdk-ts";
 import serverContainer from "~/lib/infrastructure/server/config/ioc/server-container";
 import type AuthGatewayOutputPort from "~/lib/core/ports/secondary/auth-gateway-output-port";
-import { GATEWAYS, TRPC } from "~/lib/infrastructure/server/config/ioc/server-ioc-symbols";
+import {
+  GATEWAYS,
+  TRPC,
+} from "~/lib/infrastructure/server/config/ioc/server-ioc-symbols";
 import type { TServerComponentAPI } from "~/lib/infrastructure/server/trpc/server-api";
-export default async function Home() {
-  const authGateway = serverContainer.get<AuthGatewayOutputPort>(GATEWAYS.AUTH_GATEWAY);
+
+export default async function ListResearchContexts() {
+  const authGateway = serverContainer.get<AuthGatewayOutputPort>(
+    GATEWAYS.AUTH_GATEWAY,
+  );
   const sessionDTO = await authGateway.getSession();
   if (!sessionDTO.success) {
     redirect("/auth/login");
-  };
-  return (
-    <ListResearchContexts />
+  }
+  const kpCredentialsDTO = await authGateway.extractKPCredentials();
+  const api: TServerComponentAPI = serverContainer.get(
+    TRPC.REACT_SERVER_COMPONENTS_API,
   );
-}
-
-async function ListResearchContexts() {
-  const isConnected = false
-  const api: TServerComponentAPI = serverContainer.get(TRPC.REACT_SERVER_COMPONENTS_API);
-
+  const isConnected = await api.kernel.healthCheck.ping({});
+  const isAuthorizedKPUser = kpCredentialsDTO.success;
   let researchContexts: ResearchContext[] = [];
 
-  if (isConnected) {
-    researchContexts = await api.kernel.researchContext.list(
-      { id: env.KP_CLIENT_ID, xAuthToken: env.KP_AUTH_TOKEN },
-    );
+  if (isConnected && isAuthorizedKPUser) {
+    researchContexts = await api.kernel.researchContext.list({
+      id: kpCredentialsDTO.data.clientID,
+      xAuthToken: kpCredentialsDTO.data.xAuthToken,
+    });
   }
 
   return (
     <div>
-      <ListResearchContextsPage researchContexts={researchContexts}
+      <ListResearchContextsPage
+        researchContexts={researchContexts}
         kernelPlancksterHost={env.KP_HOST}
       />
     </div>
   );
-}
\ No newline at end of file
+}
diff --git a/src/lib/core/dto/auth-dto.ts b/src/lib/core/dto/auth-dto.ts
index d59e046..f13638f 100644
--- a/src/lib/core/dto/auth-dto.ts
+++ b/src/lib/core/dto/auth-dto.ts
@@ -10,4 +10,16 @@ export const GetSessionDTOSchema = DTOSchemaFactory(
     }),
 )
 
-export type GetSessionDTO = z.infer<typeof GetSessionDTOSchema>;
\ No newline at end of file
+export type GetSessionDTO = z.infer<typeof GetSessionDTOSchema>;
+
+export const ExtractKPCredentialsDTOSchema = DTOSchemaFactory(
+    z.object({
+        xAuthToken: z.string(),
+        clientID: z.number(),
+    }),
+    z.object({
+        message: z.string(),
+    })
+)
+
+export type ExtractKPCredentialsDTO = z.infer<typeof ExtractKPCredentialsDTOSchema>;
\ No newline at end of file
diff --git a/src/lib/core/ports/secondary/auth-gateway-output-port.ts b/src/lib/core/ports/secondary/auth-gateway-output-port.ts
index ab6dae8..d253471 100644
--- a/src/lib/core/ports/secondary/auth-gateway-output-port.ts
+++ b/src/lib/core/ports/secondary/auth-gateway-output-port.ts
@@ -1,8 +1,9 @@
-import type { GetSessionDTO } from "../../dto/auth-dto";
+import type { ExtractKPCredentialsDTO, GetSessionDTO } from "../../dto/auth-dto";
 
 /**
  * Represents the output port for the authentication gateway.
  */
 export default interface AuthGatewayOutputPort{
     getSession(): Promise<GetSessionDTO>;
+    extractKPCredentials(): Promise<ExtractKPCredentialsDTO>;
 }
\ No newline at end of file
diff --git a/src/lib/infrastructure/server/config/auth/next-auth-config.ts b/src/lib/infrastructure/server/config/auth/next-auth-config.ts
index 965bcce..9747bcb 100644
--- a/src/lib/infrastructure/server/config/auth/next-auth-config.ts
+++ b/src/lib/infrastructure/server/config/auth/next-auth-config.ts
@@ -1,6 +1,7 @@
 /* eslint-disable @typescript-eslint/no-unsafe-assignment */
 import type { NextAuthOptions } from "next-auth";
 import NextAuthCredentialsProvider from "./next-auth-credentials-provider";
+import { SessionSchema } from "~/lib/core/entity/auth/session";
 
 
 /**
@@ -11,8 +12,6 @@ import NextAuthCredentialsProvider from "./next-auth-credentials-provider";
 export const authOptions: NextAuthOptions = {
   callbacks: {
     jwt: async ({token, user}) => {
-      console.log("jwt", token);
-      console.log("user", user);
       user && (token.user = user)
       return token;
     },
@@ -20,6 +19,10 @@ export const authOptions: NextAuthOptions = {
       console.log("session", session);
       console.log("token", token);
       token.user &&  (session.user = token.user);
+      const validationResponse = SessionSchema.safeParse(session);
+      if (!validationResponse.success) {
+        throw new Error("Session schema validation failed");
+      }
       return session;
     },
   },
diff --git a/src/lib/infrastructure/server/gateway/next-auth-gateway.ts b/src/lib/infrastructure/server/gateway/next-auth-gateway.ts
index 7f1c641..229f59b 100644
--- a/src/lib/infrastructure/server/gateway/next-auth-gateway.ts
+++ b/src/lib/infrastructure/server/gateway/next-auth-gateway.ts
@@ -1,15 +1,15 @@
 import { inject, injectable } from "inversify";
 import { getServerSession, type NextAuthOptions } from "next-auth";
-import { TSession } from "~/lib/core/entity/auth/session";
+import { SessionSchema, TSession } from "~/lib/core/entity/auth/session";
 import AuthGatewayOutputPort from "~/lib/core/ports/secondary/auth-gateway-output-port";
 import { CONSTANTS } from "../config/ioc/server-ioc-symbols";
-import { GetSessionDTO } from "~/lib/core/dto/auth-dto";
+import { ExtractKPCredentialsDTO, GetSessionDTO } from "~/lib/core/dto/auth-dto";
 
 @injectable()
-export default class NextAuthGateway implements AuthGatewayOutputPort{
+export default class NextAuthGateway implements AuthGatewayOutputPort {
     constructor(
         @inject(CONSTANTS.NEXT_AUTH_OPTIONS) private authOptions: NextAuthOptions,
-    ) {}
+    ) { }
 
     async getSession(): Promise<GetSessionDTO> {
         const session = await getServerSession(this.authOptions);
@@ -17,17 +17,47 @@ export default class NextAuthGateway implements AuthGatewayOutputPort{
             return {
                 success: false,
                 data: {
-                notFound: true,
-                message: "Session not found",
+                    notFound: true,
+                    message: "Session not found",
                 },
             };
         }
         return {
             success: true,
             data: session as TSession
-            
+
         };
     }
-    
 
+    async extractKPCredentials(): Promise<ExtractKPCredentialsDTO> {
+        const sessionDTO = await this.getSession();
+        if (!sessionDTO.success) {
+            return {
+                success: false,
+                data: {
+                    message: "User not authenticated",
+                },
+            };
+        }
+        const session = sessionDTO.data;
+        const schemaValidationResult = SessionSchema.safeParse(session);
+        if (!schemaValidationResult.success) {
+            return {
+                success: false,
+                data: {
+                    message: "Session schema validation failed",
+                },
+            };
+        }
+
+        const user = sessionDTO.data.user;
+
+        return {
+            success: true,
+            data: {
+                clientID: user.kp.client_id,
+                xAuthToken: user.kp.auth_token,
+            },
+        };
+    }
 }
\ No newline at end of file