feat: implement control plane

package.json

@@ -18,11 +18,13 @@
     "@types/express": "^4.17.17",
     "cors": "^2.8.5",
     "express": "^4.18.2",
+    "jsonwebtoken": "^9.0.0",
     "react": "^18.2.0",
     "react-dom": "^18.2.0",
     "zod": "^3.21.4"
   },
   "devDependencies": {
+    "@types/jsonwebtoken": "^9.0.1",
     "@types/react": "^18.0.28",
     "@types/react-dom": "^18.0.11",
     "@vitejs/plugin-react": "^3.1.0",

src/services/control-plane/adapters/drivens/index.ts

@@ -0,0 +1,2 @@
+export * from './logger-stub-adapter'
+export * from './repo-querier-stub-adapter'

src/services/control-plane/adapters/drivens/logger-stub-adapter.ts

@@ -0,0 +1,7 @@
+import { ForMonitoringAuthDetails } from '../../ports/drivens/for-monitoring'
+
+export class LoggerStubAdapter implements ForMonitoringAuthDetails {
+  log(event: string, message: string) {
+    console.log(event, message)
+  }
+}

src/services/control-plane/adapters/drivens/repo-querier-stub-adapter.ts

@@ -0,0 +1,16 @@
+import { ExternalUser } from '../../../repository/app/schemas'
+import { ForRepoQuerying } from '../../ports/drivens'
+
+const userMock: ExternalUser = {
+  id: '1',
+  name: 'John Doe',
+  email: '[email protected]',
+  admin: false,
+  user: true,
+}
+
+export class RepoQuerierAdapter implements ForRepoQuerying {
+  getUser(_email: string): Promise<ExternalUser> {
+    return Promise.resolve(userMock)
+  }
+}

src/services/control-plane/adapters/drivers/auth-details-proxy.ts

@@ -0,0 +1,15 @@
+import { ControlPlane } from '../../app/control-plane'
+import { AuthDetails, Permissions } from '../../app/schemas'
+import { ForManagingAuthDetails } from '../../ports/drivers/for-managing-auth-details'
+
+export class AuthDetailsProxy implements ForManagingAuthDetails {
+  constructor(private readonly controlPlane: ControlPlane) {}
+
+  async getAuthDetails(email: string, password: string): Promise<AuthDetails> {
+    return this.controlPlane.getAuthDetails(email, password)
+  }
+
+  async getPermissions(email: string): Promise<Permissions> {
+    return this.controlPlane.getPermissions(email)
+  }
+}

src/services/control-plane/adapters/drivers/index.ts

@@ -0,0 +1 @@
+export * from './auth-details-proxy'

src/services/control-plane/app/composition-root.ts

@@ -0,0 +1,30 @@
+import { LoggerStubAdapter } from '../adapters/drivens'
+import { RepoQuerierAdapter } from '../adapters/drivens/repo-querier-stub-adapter'
+import { AuthDetailsProxy } from '../adapters/drivers'
+import { ControlPlane } from './control-plane'
+
+const compositionMock = () => {
+  const monitorStub = new LoggerStubAdapter()
+  const repoQueryStub = new RepoQuerierAdapter()
+  const dashboardApiMock = new ControlPlane(monitorStub, repoQueryStub)
+
+  const authenticatorProxyAdapter = new AuthDetailsProxy(dashboardApiMock)
+
+  return {
+    authenticatorProxyAdapter,
+  }
+}
+
+export const { authenticatorProxyAdapter } = compositionMock()
+
+const registerMock = {
+  name: 'John',
+  email: '[email protected]',
+  password: 'password',
+}
+
+authenticatorProxyAdapter.getAuthDetails(
+  registerMock.email,
+  registerMock.password
+)
+authenticatorProxyAdapter.getPermissions(registerMock.email)

src/services/control-plane/app/control-plane.test.ts

@@ -0,0 +1,51 @@
+import { describe, expect, it } from 'vitest'
+import { RepoQuerierAdapter } from '../adapters/drivens/repo-querier-stub-adapter'
+import { LoggerStubAdapter } from '../adapters/drivens'
+import { ControlPlane } from './control-plane'
+import { AuthDetails, Permissions } from './schemas'
+
+describe('ControlPlane', () => {
+  const monitorStub = new LoggerStubAdapter()
+  const repoQueryStub = new RepoQuerierAdapter()
+  const controPlaneMock = new ControlPlane(monitorStub, repoQueryStub)
+
+  it.concurrent('should not expect a 123 token', async () => {
+    //GIVEN
+    const mockedParams = {
+      email: `12`,
+      password: '12345678',
+    }
+
+    const expectedResult: AuthDetails = {
+      token: '123',
+      refreshToken: '123',
+    }
+
+    //WHEN
+    let result
+    try {
+      result = await controPlaneMock.getAuthDetails(
+        mockedParams.email,
+        mockedParams.password
+      )
+    } catch (error) {}
+
+    //THEN
+    expect(result).not.toEqual(expectedResult)
+  })
+
+  it.concurrent('should get user permissions', async () => {
+    //GIVEN
+
+    const expectedResult: Permissions = {
+      admin: false,
+      user: true,
+    }
+
+    //WHEN
+    const result = await controPlaneMock.getPermissions('[email protected]')
+
+    //THEN
+    expect(result).toEqual(expectedResult)
+  })
+})

src/services/control-plane/app/control-plane.ts

@@ -0,0 +1,72 @@
+import { ForRepoQuerying } from '../ports/drivens'
+import { ForMonitoringAuthDetails } from '../ports/drivens/for-monitoring'
+import { ForManagingAuthDetails } from '../ports/drivers/for-managing-auth-details'
+import { AuthDetails, Permissions } from './schemas'
+import jwt from 'jsonwebtoken'
+
+export class ControlPlane implements ForManagingAuthDetails {
+  private secretKey: string = 'mySecretKey'
+  constructor(
+    private readonly logger: ForMonitoringAuthDetails,
+    private readonly repoQuerier: ForRepoQuerying
+  ) {}
+
+  async getAuthDetails(email: string, password: string): Promise<AuthDetails> {
+    const generateToken = (
+      payload: object,
+      secretKey: string,
+      expiresIn: string
+    ): string => {
+      const token = jwt.sign(payload, secretKey, { expiresIn })
+
+      return token
+    }
+    const generateRefreshToken = (
+      payload: object,
+      secretKey: string,
+      expiresIn: string
+    ): string => {
+      const refreshToken = jwt.sign(payload, secretKey, { expiresIn })
+
+      return refreshToken
+    }
+    const token = generateToken({ email, password }, this.secretKey, '30m')
+    if (!token) {
+      this.logger.log('Token creation', 'FAILED')
+      throw new Error('Failed creating token, please check credentials')
+    }
+
+    const refreshToken = generateRefreshToken(
+      { email, password },
+      this.secretKey,
+      '1d'
+    )
+
+    if (!refreshToken) {
+      this.logger.log('RefreshToken creation', 'FAILED')
+      throw new Error('Failed creating Refreshtoken, please check credentials')
+    }
+
+    const result = {
+      token,
+      refreshToken,
+    }
+
+    console.log('AUTHDETAILS', result)
+
+    return { token, refreshToken }
+  }
+
+  async getPermissions(email: string): Promise<Permissions> {
+    const user = await this.repoQuerier.getUser(email)
+
+    const result = {
+      admin: user?.admin,
+      user: user?.user,
+    }
+
+    console.log('PERMISSIONS', result)
+
+    return { admin: user?.admin, user: user?.user }
+  }
+}

src/services/control-plane/app/schemas/details.ts

@@ -0,0 +1,4 @@
+export interface AuthDetails {
+  token: string
+  refreshToken: string
+}

src/services/control-plane/app/schemas/index.ts

@@ -0,0 +1,2 @@
+export * from './details'
+export * from './permissions'

src/services/control-plane/app/schemas/permissions.ts

@@ -0,0 +1,4 @@
+export interface Permissions {
+  admin: boolean
+  user: boolean
+}

src/services/control-plane/ports/drivens/for-monitoring.ts

@@ -0,0 +1,3 @@
+export interface ForMonitoringAuthDetails {
+  log(event: string, message: string): void
+}

src/services/control-plane/ports/drivens/for-repo-querying.ts

@@ -0,0 +1,5 @@
+import { ExternalUser } from '../../../repository/app/schemas'
+
+export interface ForRepoQuerying {
+  getUser(email: string): Promise<ExternalUser>
+}

src/services/control-plane/ports/drivens/index.ts

@@ -0,0 +1,2 @@
+export * from './for-monitoring'
+export * from './for-repo-querying'

src/services/control-plane/ports/drivers/for-managing-auth-details.ts

@@ -0,0 +1,6 @@
+import { AuthDetails, Permissions } from '../../app/schemas'
+
+export interface ForManagingAuthDetails {
+  getAuthDetails(email: string, password: string): Promise<AuthDetails>
+  getPermissions(email: string): Promise<Permissions>
+}

src/services/control-plane/ports/drivers/index.ts

@@ -0,0 +1 @@
+export * from './for-managing-auth-details'

src/services/dashboard-api/adapters/drivens/index.ts

@@ -1,2 +1,2 @@
-export * from './control-authenticator-stub-adapter';
-export * from './repo-querier-stub-adapter';
+export * from './control-authenticator-stub-adapter'
+export * from './repo-querier-stub-adapter'

src/services/dashboard-api/adapters/drivens/repo-querier-stub-adapter.ts

@@ -1,19 +1,21 @@
-import { ExternalUser } from "../../../repository/app/schemas";
-import { User } from "../../app/schemas";
-import { ForRepoQuerying } from "../../ports/drivens";
+import { ExternalUser } from '../../../repository/app/schemas'
+import { User } from '../../app/schemas'
+import { ForRepoQuerying } from '../../ports/drivens'
 
 const userMock: ExternalUser = {
-  id: "1",
-  name: "John Doe",
-  email: "[email protected]",
-};
+  id: '1',
+  name: 'John Doe',
+  email: '[email protected]',
+  admin: false,
+  user: true,
+}
 
 export class RepoQuerierStub implements ForRepoQuerying {
   getUser(_email: string): Promise<ExternalUser> {
-    return Promise.resolve(userMock);
+    return Promise.resolve(userMock)
   }
 
   createUser(_user: User): Promise<ExternalUser> {
-    return Promise.resolve(userMock);
+    return Promise.resolve(userMock)
   }
 }

src/services/dashboard-api/app/dashboard-api.test.ts

@@ -1,71 +1,75 @@
-import { describe, expect, it } from "vitest";
-import { ControlAuthenticatorStub } from "../adapters/drivens/control-authenticator-stub-adapter";
-import { RepoQuerierStub } from "../adapters/drivens/repo-querier-stub-adapter";
-import { DashboardApi } from "./dashboard-api";
-import { AuthenticatedUser, User } from "./schemas";
+import { describe, expect, it } from 'vitest'
+import { ControlAuthenticatorStub } from '../adapters/drivens/control-authenticator-stub-adapter'
+import { RepoQuerierStub } from '../adapters/drivens/repo-querier-stub-adapter'
+import { DashboardApi } from './dashboard-api'
+import { AuthenticatedUser, User } from './schemas'
 
-describe("DashboardApi", () => {
-  const controlAuthenticatorStub = new ControlAuthenticatorStub();
-  const repoQuerierStub = new RepoQuerierStub();
+describe('DashboardApi', () => {
+  const controlAuthenticatorStub = new ControlAuthenticatorStub()
+  const repoQuerierStub = new RepoQuerierStub()
   const dashboardApiMock = new DashboardApi(
     controlAuthenticatorStub,
     repoQuerierStub
-  );
+  )
 
-  it.concurrent("should login", async () => {
+  it.concurrent('should login', async () => {
     //GIVEN
     const mockedParams = {
-      email: "[email protected]",
-      password: "12345678",
-    };
+      email: '[email protected]',
+      password: '12345678',
+    }
 
     const expectedResult: AuthenticatedUser = {
-      id: "1",
-      name: "John Doe",
-      email: "[email protected]",
-      token: "token",
-      refreshToken: "refreshToken",
+      id: '1',
+      name: 'John Doe',
+      email: '[email protected]',
+      token: 'token',
+      refreshToken: 'refreshToken',
       permissions: {
         admin: true,
         user: true,
       },
-    };
+      admin: false,
+      user: true,
+    }
 
     //WHEN
     const result = await dashboardApiMock.login(
       mockedParams.email,
       mockedParams.password
-    );
+    )
 
     //THEN
-    expect(result).toEqual(expectedResult);
-  });
+    expect(result).toEqual(expectedResult)
+  })
 
-  it.concurrent("should register", async () => {
+  it.concurrent('should register', async () => {
     //GIVEN
 
     const mockedUser: User = {
-      name: "John",
-      email: "[email protected]",
-      password: "password",
-    };
+      name: 'John',
+      email: '[email protected]',
+      password: 'password',
+    }
 
     const expectedResult: AuthenticatedUser = {
-      id: "1",
-      name: "John Doe",
-      email: "[email protected]",
-      token: "token",
-      refreshToken: "refreshToken",
+      id: '1',
+      name: 'John Doe',
+      email: '[email protected]',
+      token: 'token',
+      refreshToken: 'refreshToken',
       permissions: {
         admin: true,
         user: true,
       },
-    };
+      admin: false,
+      user: true,
+    }
 
     //WHEN
-    const result = await dashboardApiMock.register(mockedUser);
+    const result = await dashboardApiMock.register(mockedUser)
 
     //THEN
-    expect(result).toEqual(expectedResult);
-  });
-});
+    expect(result).toEqual(expectedResult)
+  })
+})