feat/chore/breaking-changes!: move remaining backends to Hono, massive cleanup (#447)

## What does this PR do?

Moves remaining backends to Hono
Massive Cleanup of everything
Preparation for removing Nuxt app from main branch and do hot-fixes only on prod 

<!-- If there isn't an issue for this PR, please re-review our Contributing Guide and create an issue -->

## Type of change

<!-- Please mark the relevant points by using [x] -->

- [ ] Bug fix (non-breaking change which fixes an issue)
- [x] Chore (refactoring code, technical debt, workflow improvements)
- [x] Enhancement (small improvements)
- [ ] New feature (non-breaking change which adds functionality)
- [x] Breaking change (fix or feature that would cause existing functionality to not work as expected)
- [x] This change requires a documentation update

## Checklist

<!-- We're starting to get more and more contributions. Please help us making this efficient for all of us and go through this checklist. Please tick off what you did  -->

### Required

- [ ] Read [Contributing Guide](https://github.com/un/inbox/blob/main/CONTRIBUTING.md)
- [ ] Self-reviewed my own code
- [ ] Tested my code in a local environment
- [ ] Commented on my code in hard-to-understand areas
- [ ] Checked for warnings, there are none
- [ ] Removed all `console.logs`
- [ ] Merged the latest changes from main onto my branch with `git pull origin main`
- [ ] My changes don't cause any responsiveness issues

### Appreciated

- [ ] If a UI change was made: Added a screen recording or screenshots to this PR
- [ ] Updated the UnInbox Docs if changes were necessary

Author: BlankParticle

.npmrc

@@ -1,2 +1 @@
-shamefully-hoist=true
 auto-install-peers=true

.prettierignore

@@ -2,4 +2,6 @@ node_modules
 .turbo
 .pnpm-store
 .nuxt
-pnpm-lock.yaml
+pnpm-lock.yaml
+.next
+packages/database/migrations

apps/mail-bridge/package.json

@@ -1,11 +1,11 @@
 {
   "name": "@u22n/mail-bridge",
   "private": true,
-  "types": "types.ts",
   "type": "module",
-  "engines": {
-    "node": ">=20",
-    "pnpm": ">=8"
+  "exports": {
+    "./trpc": {
+      "types": "./trpc/index.ts"
+    }
   },
   "scripts": {
     "dev": "tsx watch --clear-screen=false app.ts",
@@ -25,17 +25,16 @@
     "@u22n/realtime": "workspace:^",
     "@u22n/tiptap": "workspace:^",
     "@u22n/tsconfig": "^0.0.2",
-    "@u22n/types": "workspace:*",
     "@u22n/utils": "workspace:*",
-    "drizzle-kit": "^0.20.17",
     "drizzle-orm": "^0.30.3",
     "hono": "^4.2.8",
     "mailauth": "^4.6.5",
     "mailparser": "^3.6.9",
     "mysql2": "^3.9.7",
+    "nanoid": "^5.0.6",
     "nodemailer": "^6.9.13",
     "superjson": "^2.2.1",
-    "zod": "^3.22.4"
+    "zod": "^3.23.8"
   },
   "devDependencies": {
     "@types/node": "^20.12.7",

apps/platform/.gitignore

@@ -0,0 +1,57 @@
+import type { Ctx } from './ctx';
+import { env } from './env';
+import { Hono } from 'hono';
+import { serve } from '@hono/node-server';
+import { cors } from 'hono/cors';
+import { authApi } from './routes/auth';
+import { realtimeApi } from './routes/realtime';
+import { trpcPlatformRouter } from './trpc';
+import { db } from '@u22n/database';
+import { fetchRequestHandler } from '@trpc/server/adapters/fetch';
+import { authMiddleware } from './middlewares';
+
+const app = new Hono<Ctx>();
+
+// CORS middleware
+app.use(
+  '*',
+  cors({
+    origin: env.WEBAPP_URL,
+    credentials: true
+  })
+);
+
+// Auth middleware
+app.use('*', authMiddleware);
+
+// Health check endpoint
+app.get('/', (c) => c.json({ status: "I'm Alive 🏝️" }));
+
+// Routes
+app.route('/auth', authApi);
+app.route('/realtime', realtimeApi);
+
+// TRPC handler
+app.use('/trpc/*', async (c) =>
+  fetchRequestHandler({
+    router: trpcPlatformRouter,
+    createContext: () => ({
+      db,
+      account: c.get('account'),
+      org: null,
+      event: c
+    }),
+    endpoint: '/trpc',
+    req: c.req.raw
+  }).then((res) => c.body(res.body, res))
+);
+
+// 404 handler
+app.notFound((c) => c.json({ message: 'Not Found' }, 404));
+
+serve({
+  fetch: app.fetch,
+  port: env.PORT
+}).on('listening', () => {
+  console.info(`Server listening on port ${env.PORT}`);
+});

apps/platform/app.ts

@@ -1,4 +1,16 @@
+import type { HttpBindings } from '@hono/node-server';
 import type { DatabaseSession } from 'lucia';
+
+export type Ctx = {
+  Bindings: HttpBindings;
+  Variables: {
+    account: {
+      id: number;
+      session: any;
+    } | null;
+  };
+};
+
 export type OrgContext = {
   id: number;
   publicId: string;
@@ -12,16 +24,8 @@ export type OrgContext = {
     role: 'admin' | 'member';
   }[];
 } | null;
+
 export type AccountContext = {
   id: number;
   session: DatabaseSession;
 } | null;
-export type AuthH3SessionData = {
-  isUserLoggedIn: boolean;
-  userId?: number | null;
-};
-export interface MailDomainEntries {
-  name: string;
-  postalId: string;
-}
-export type { TrpcMailBridgeRouter } from '../../apps/mail-bridge';

packages/types/index.ts apps/platform/ctx.ts

@@ -0,0 +1,55 @@
+import { createEnv } from '@t3-oss/env-core';
+import { z } from 'zod';
+
+const stringToJSON = z.string().transform((str, ctx) => {
+  try {
+    return JSON.parse(str) as unknown;
+  } catch (e) {
+    ctx.addIssue({ code: 'custom', message: 'Invalid JSON' });
+    return z.NEVER;
+  }
+});
+
+export const env = createEnv({
+  server: {
+    WEBAPP_URL: z.string().url(),
+    APP_NAME: z.string().min(1).default('UnInbox'),
+    PRIMARY_DOMAIN: z.string(),
+    REALTIME_HOST: z.string().min(1),
+    REALTIME_PORT: z.string(),
+    REALTIME_APP_ID: z.string().min(1),
+    REALTIME_APP_KEY: z.string().min(1),
+    REALTIME_APP_SECRET: z.string().min(1),
+    MAILBRIDGE_URL: z.string().url(),
+    MAILBRIDGE_KEY: z.string().min(1),
+    MAILBRIDGE_POSTAL_SERVERS_DNS_ROOT_URL: z.string().min(1),
+    MAILBRIDGE_POSTAL_LOCAL_MODE: z.coerce.boolean().default(false),
+    MAIL_DOMAINS: stringToJSON.pipe(
+      z.object({
+        free: z.array(z.string()),
+        premium: z.array(z.string()),
+        fwd: z.array(z.string())
+      })
+    ),
+    MAILBRIDGE_TRANSACTIONAL_CREDENTIALS: stringToJSON.pipe(
+      z.object({
+        apiUrl: z.string().url(),
+        apiKey: z.string().min(1),
+        sendAsName: z.string().min(1),
+        sendAsEmail: z.string().email()
+      })
+    ),
+    STORAGE_URL: z.string().url(),
+    STORAGE_KEY: z.string().min(1),
+    DB_REDIS_CONNECTION_STRING: z.string().min(1),
+    UNKEY_ROOT_KEY: z.string().nullable().default(null),
+    EE_LICENSE_KEY: z.string().nullable().default(null),
+    BILLING_KEY: z.string().nullable().default(null),
+    BILLING_URL: z.string().url().nullable().default(null),
+    PORT: z.coerce.number().int().min(1).max(65535).default(3300),
+    NODE_ENV: z.enum(['development', 'production']).default('development')
+  },
+  client: {},
+  clientPrefix: '_', // Not used, just for making TS happy
+  runtimeEnv: process.env
+});

apps/platform/env.ts

@@ -0,0 +1,25 @@
+import { getCookie } from 'hono/cookie';
+import { storage } from './storage';
+import { createMiddleware } from 'hono/factory';
+import type { Ctx } from './ctx';
+
+export const authMiddleware = createMiddleware<Ctx>(async (c, next) => {
+  const sessionCookie = getCookie(c, 'unsession');
+  if (!sessionCookie) {
+    c.set('account', null);
+    await next();
+  } else {
+    const sessionObject = await storage.session.getItem(sessionCookie);
+    if (!sessionObject) {
+      c.set('account', null);
+      await next();
+    } else {
+      c.set('account', {
+        // @ts-expect-error, not typed properly yet
+        id: Number(sessionObject.attributes.account.id),
+        session: sessionObject
+      });
+      await next();
+    }
+  }
+});