Feature network load balancer

.github/prompts

@@ -0,0 +1,24 @@
+# Load Balancer Network Feature Documentation
+# Feature: Network Load Balancer (NLB)
+# Version: 1.0.0
+
+## Overview
+The Network Load Balancer (NLB) feature provides high availability and scalability for network traffic by distributing incoming requests across multiple servers. It operates at the transport layer (Layer 4) and is designed to handle millions of requests per second while maintaining ultra-low latencies.
+
+## Key Features
+- Tích hợp với nền tảng hiện tại một cách liền mạch
+- Hỗ trợ cân bằng tải TCP và UDP
+- Giao diện quản lý dễ sử dụng tương thích với giao diện hiện tại nghiêm cấm phá vỡ giao diện
+- tính năng đầy đủ để người dùng điền đầy đủ các thông tin để đảm bảo tính năng có thể hoạt động
+- một port người dùng có thể bật cả TCP và UDP
+- giao diện quản lý có các chức năng 
+## Requirements
+
+- Follow the project code flow, git flow, 
+- Do not create test files, debug files, or unnecessary files
+- If a file has errors, fix the file - do not delete it
+- Do not creat document file
+- optimize database query statements
+- NLB must use port above 10000 incoming 
+
+

apps/api/prisma/migrations/20251011072500_add_network_load_balancer/migration.sql

@@ -0,0 +1,100 @@
+-- CreateEnum
+CREATE TYPE "NLBStatus" AS ENUM ('active', 'inactive', 'error');
+
+-- CreateEnum
+CREATE TYPE "NLBProtocol" AS ENUM ('tcp', 'udp', 'tcp_udp');
+
+-- CreateEnum
+CREATE TYPE "NLBAlgorithm" AS ENUM ('round_robin', 'least_conn', 'ip_hash', 'hash');
+
+-- CreateEnum
+CREATE TYPE "NLBUpstreamStatus" AS ENUM ('up', 'down', 'checking');
+
+-- CreateTable
+CREATE TABLE "network_load_balancers" (
+    "id" TEXT NOT NULL,
+    "name" TEXT NOT NULL,
+    "description" TEXT,
+    "port" INTEGER NOT NULL,
+    "protocol" "NLBProtocol" NOT NULL DEFAULT 'tcp',
+    "algorithm" "NLBAlgorithm" NOT NULL DEFAULT 'round_robin',
+    "status" "NLBStatus" NOT NULL DEFAULT 'inactive',
+    "enabled" BOOLEAN NOT NULL DEFAULT true,
+    "proxyTimeout" INTEGER NOT NULL DEFAULT 3,
+    "proxyConnectTimeout" INTEGER NOT NULL DEFAULT 1,
+    "proxyNextUpstream" BOOLEAN NOT NULL DEFAULT true,
+    "proxyNextUpstreamTimeout" INTEGER NOT NULL DEFAULT 0,
+    "proxyNextUpstreamTries" INTEGER NOT NULL DEFAULT 0,
+    "healthCheckEnabled" BOOLEAN NOT NULL DEFAULT true,
+    "healthCheckInterval" INTEGER NOT NULL DEFAULT 10,
+    "healthCheckTimeout" INTEGER NOT NULL DEFAULT 5,
+    "healthCheckRises" INTEGER NOT NULL DEFAULT 2,
+    "healthCheckFalls" INTEGER NOT NULL DEFAULT 3,
+    "createdAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "updatedAt" TIMESTAMP(3) NOT NULL,
+
+    CONSTRAINT "network_load_balancers_pkey" PRIMARY KEY ("id")
+);
+
+-- CreateTable
+CREATE TABLE "nlb_upstreams" (
+    "id" TEXT NOT NULL,
+    "nlbId" TEXT NOT NULL,
+    "host" TEXT NOT NULL,
+    "port" INTEGER NOT NULL,
+    "weight" INTEGER NOT NULL DEFAULT 1,
+    "maxFails" INTEGER NOT NULL DEFAULT 3,
+    "failTimeout" INTEGER NOT NULL DEFAULT 10,
+    "maxConns" INTEGER NOT NULL DEFAULT 0,
+    "backup" BOOLEAN NOT NULL DEFAULT false,
+    "down" BOOLEAN NOT NULL DEFAULT false,
+    "status" "NLBUpstreamStatus" NOT NULL DEFAULT 'checking',
+    "lastCheck" TIMESTAMP(3),
+    "lastError" TEXT,
+    "responseTime" DOUBLE PRECISION,
+    "createdAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "updatedAt" TIMESTAMP(3) NOT NULL,
+
+    CONSTRAINT "nlb_upstreams_pkey" PRIMARY KEY ("id")
+);
+
+-- CreateTable
+CREATE TABLE "nlb_health_checks" (
+    "id" TEXT NOT NULL,
+    "nlbId" TEXT NOT NULL,
+    "upstreamHost" TEXT NOT NULL,
+    "upstreamPort" INTEGER NOT NULL,
+    "status" "NLBUpstreamStatus" NOT NULL,
+    "responseTime" DOUBLE PRECISION,
+    "error" TEXT,
+    "checkedAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
+
+    CONSTRAINT "nlb_health_checks_pkey" PRIMARY KEY ("id")
+);
+
+-- CreateIndex
+CREATE UNIQUE INDEX "network_load_balancers_name_key" ON "network_load_balancers"("name");
+
+-- CreateIndex
+CREATE INDEX "network_load_balancers_status_idx" ON "network_load_balancers"("status");
+
+-- CreateIndex
+CREATE INDEX "network_load_balancers_port_idx" ON "network_load_balancers"("port");
+
+-- CreateIndex
+CREATE INDEX "nlb_upstreams_nlbId_idx" ON "nlb_upstreams"("nlbId");
+
+-- CreateIndex
+CREATE INDEX "nlb_upstreams_status_idx" ON "nlb_upstreams"("status");
+
+-- CreateIndex
+CREATE INDEX "nlb_health_checks_nlbId_checkedAt_idx" ON "nlb_health_checks"("nlbId", "checkedAt");
+
+-- CreateIndex
+CREATE INDEX "nlb_health_checks_upstreamHost_upstreamPort_idx" ON "nlb_health_checks"("upstreamHost", "upstreamPort");
+
+-- AddForeignKey
+ALTER TABLE "nlb_upstreams" ADD CONSTRAINT "nlb_upstreams_nlbId_fkey" FOREIGN KEY ("nlbId") REFERENCES "network_load_balancers"("id") ON DELETE CASCADE ON UPDATE CASCADE;
+
+-- AddForeignKey
+ALTER TABLE "nlb_health_checks" ADD CONSTRAINT "nlb_health_checks_nlbId_fkey" FOREIGN KEY ("nlbId") REFERENCES "network_load_balancers"("id") ON DELETE CASCADE ON UPDATE CASCADE;

apps/api/prisma/schema.prisma

@@ -632,3 +632,112 @@ model ConfigVersion {
   @@index([createdAt])
   @@map("config_versions")
 }
+
+// Network Load Balancer Models
+
+enum NLBStatus {
+  active
+  inactive
+  error
+}
+
+enum NLBProtocol {
+  tcp
+  udp
+  tcp_udp // Both TCP and UDP
+}
+
+enum NLBAlgorithm {
+  round_robin
+  least_conn
+  ip_hash
+  hash
+}
+
+enum NLBUpstreamStatus {
+  up
+  down
+  checking
+}
+
+model NetworkLoadBalancer {
+  id          String      @id @default(cuid())
+  name        String      @unique
+  description String?     @db.Text
+  port        Int // Listen port (must be >= 10000)
+  protocol    NLBProtocol @default(tcp)
+  algorithm   NLBAlgorithm @default(round_robin)
+  status      NLBStatus   @default(inactive)
+  enabled     Boolean     @default(true)
+
+  // Advanced settings
+  proxyTimeout        Int @default(3) // seconds
+  proxyConnectTimeout Int @default(1) // seconds
+  proxyNextUpstream   Boolean @default(true)
+  proxyNextUpstreamTimeout Int @default(0) // seconds, 0 = disabled
+  proxyNextUpstreamTries   Int @default(0) // 0 = unlimited
+
+  // Health check settings
+  healthCheckEnabled  Boolean @default(true)
+  healthCheckInterval Int     @default(10) // seconds
+  healthCheckTimeout  Int     @default(5) // seconds
+  healthCheckRises    Int     @default(2) // Number of successful checks to mark as up
+  healthCheckFalls    Int     @default(3) // Number of failed checks to mark as down
+
+  // Relations
+  upstreams    NLBUpstream[]
+  healthChecks NLBHealthCheck[]
+
+  createdAt DateTime @default(now())
+  updatedAt DateTime @updatedAt
+
+  @@index([status])
+  @@index([port])
+  @@map("network_load_balancers")
+}
+
+model NLBUpstream {
+  id    String @id @default(cuid())
+  nlbId String
+  nlb   NetworkLoadBalancer @relation(fields: [nlbId], references: [id], onDelete: Cascade)
+
+  host        String
+  port        Int
+  weight      Int               @default(1) // 1-100
+  maxFails    Int               @default(3)
+  failTimeout Int               @default(10) // seconds
+  maxConns    Int               @default(0) // 0 = unlimited
+  backup      Boolean           @default(false)
+  down        Boolean           @default(false) // Manually mark as down
+  status      NLBUpstreamStatus @default(checking)
+
+  // Metadata
+  lastCheck   DateTime?
+  lastError   String?  @db.Text
+  responseTime Float?  // milliseconds
+
+  createdAt DateTime @default(now())
+  updatedAt DateTime @updatedAt
+
+  @@index([nlbId])
+  @@index([status])
+  @@map("nlb_upstreams")
+}
+
+model NLBHealthCheck {
+  id    String @id @default(cuid())
+  nlbId String
+  nlb   NetworkLoadBalancer @relation(fields: [nlbId], references: [id], onDelete: Cascade)
+
+  upstreamHost String
+  upstreamPort Int
+  status       NLBUpstreamStatus
+  responseTime Float? // milliseconds
+  error        String? @db.Text
+
+  checkedAt DateTime @default(now())
+
+  @@index([nlbId, checkedAt])
+  @@index([upstreamHost, upstreamPort])
+  @@map("nlb_health_checks")
+}