Delete code instances and introduce ballooning to KVM egg!

Author: thenoname-gurl

backend/src/app.ts

@@ -12,7 +12,6 @@ import { setupConfig } from './config';
 import { createActivityLog } from './handlers/logHandler';
 import { AppDataSource } from './config/typeorm';
 import { scheduleStudentReverifyJob } from './jobs/studentReverifyJob';
-import { scheduleCodeInstanceIdleJob } from './jobs/codeInstanceIdleJob';
 import { scheduleMetricsCollectionJob } from './jobs/metricsCollectionJob';
 import { scheduleExportJobRunner } from './jobs/exportJobRunner';
 import { scheduleDeletionExecutionJob } from './jobs/deletionExecutionJob';
@@ -488,7 +487,6 @@ export async function initApp() {
   setupMiddleware(app);
   registerRoutes(app);
   try { scheduleStudentReverifyJob(); } catch (e) { console.error('Failed to schedule student reverify job:', e); }
-  try { scheduleCodeInstanceIdleJob(); } catch (e) { console.error('Failed to schedule code instance idle job:', e); }
   try { scheduleMetricsCollectionJob(); } catch (e) { console.error('Failed to schedule metrics collection job:', e); }
   try { scheduleExportJobRunner(); } catch (e) { console.error('Failed to schedule export job runner:', e); }
   try { scheduleDeletionExecutionJob(); } catch (e) { console.error('Failed to schedule deletion execution job:', e); }

backend/src/handlers/adminHandler.ts

@@ -4886,12 +4886,10 @@ isSuspicious: true if fraudScore >= 50`;
       try { portalDescriptions = JSON.parse(map['portalDescriptions']); } catch { }
     }
     const featureToggles = await getPanelFeatureToggles();
-    const codeInstancesEnabled = map['codeInstancesEnabled'] !== 'false';
     return {
       registrationEnabled: map['registrationEnabled'] !== 'false',
       registrationNotice: map['registrationNotice'] || '',
       portalDescriptions: portalDescriptions || null,
-      codeInstancesEnabled,
       geoBlockCountries: map['geoBlockCountries'] || '',
       countryAgeRules: map['countryAgeRules'] || '',
       billingCurrency: (map['billingCurrency'] || 'USD').toUpperCase(),
@@ -4907,7 +4905,6 @@ isSuspicious: true if fraudScore >= 50`;
         registrationEnabled: t.Boolean(),
         registrationNotice: t.String(),
         portalDescriptions: t.Optional(t.Any()),
-        codeInstancesEnabled: t.Boolean(),
         featureToggles: t.Record(t.String(), t.Boolean()),
         geoBlockCountries: t.String(),
         countryAgeRules: t.Optional(t.String()),
@@ -4943,11 +4940,9 @@ isSuspicious: true if fraudScore >= 50`;
       try { portalDescriptions = JSON.parse(map['portalDescriptions']); } catch { }
     }
     const featureToggles = await getPanelFeatureToggles();
-    const codeInstancesEnabled = map['codeInstancesEnabled'] !== 'false';
     return {
       registrationEnabled: map['registrationEnabled'] !== 'false',
       registrationNotice: map['registrationNotice'] || '',
-      codeInstancesEnabled,
       portalDescriptions: portalDescriptions || null,
       geoBlockCountries: map['geoBlockCountries'] || '',
       countryAgeRules: map['countryAgeRules'] || '',
@@ -4964,7 +4959,6 @@ isSuspicious: true if fraudScore >= 50`;
       200: t.Object({
         registrationEnabled: t.Boolean(),
         registrationNotice: t.String(),
-        codeInstancesEnabled: t.Boolean(),
         portalDescriptions: t.Optional(t.Any()),
         geoBlockCountries: t.String(),
         countryAgeRules: t.Optional(t.String()),
@@ -5068,7 +5062,7 @@ isSuspicious: true if fraudScore >= 50`;
     if (adminErr !== true) return adminErr;
     const repo = AppDataSource.getRepository(PanelSetting);
     const body = ctx.body as any;
-    const allowed = ['registrationEnabled', 'registrationNotice', 'codeInstancesEnabled', 'geoBlockCountries', 'countryAgeRules', 'billingCurrency', 'billingTaxRules', 'gamblingEnabled', 'gamblingResourceLuckyChance', 'gamblingPowerDenyChance'];
+    const allowed = ['registrationEnabled', 'registrationNotice', 'geoBlockCountries', 'countryAgeRules', 'billingCurrency', 'billingTaxRules', 'gamblingEnabled', 'gamblingResourceLuckyChance', 'gamblingPowerDenyChance'];
     for (const key of allowed) {
       if (body[key] !== undefined) {
         let value = typeof body[key] === 'boolean' ? String(body[key]) : String(body[key]);
@@ -5106,7 +5100,6 @@ isSuspicious: true if fraudScore >= 50`;
         registrationEnabled: map['registrationEnabled'] !== 'false',
         registrationNotice: map['registrationNotice'] || '',
         portalDescriptions: portalDescriptions || null,
-        codeInstancesEnabled: map['codeInstancesEnabled'] !== 'false',
         geoBlockCountries: map['geoBlockCountries'] || '',
         countryAgeRules: map['countryAgeRules'] || '',
         billingCurrency: (map['billingCurrency'] || 'USD').toUpperCase(),
@@ -5124,7 +5117,6 @@ isSuspicious: true if fraudScore >= 50`;
         registrationEnabled: t.Optional(t.Boolean()),
         registrationNotice: t.Optional(t.String()),
         portalDescriptions: t.Optional(t.Any()),
-        codeInstancesEnabled: t.Optional(t.Boolean()),
         geoBlockCountries: t.Optional(t.String()),
         billingCurrency: t.Optional(t.String()),
         billingTaxRules: t.Optional(t.String()),

backend/src/handlers/remoteHandler.ts

@@ -875,9 +875,7 @@ export async function saveServerConfig(params: {
   kvmPassthroughEnabled?: boolean;
   allocations?: Record<string, any>;
   processConfig?: Record<string, any>;
-  isCodeInstance?: boolean;
   lastActivityAt?: Date;
-  codeInstanceMinutesUsed?: number;
   hibernated?: boolean;
 }): Promise<ServerConfig> {
   if (!Number.isFinite(params.memory) || params.memory < 0) throw new Error('Invalid memory value');
@@ -908,9 +906,7 @@ export async function saveServerConfig(params: {
       kvmPassthroughEnabled: params.kvmPassthroughEnabled ?? false,
       allocations: params.allocations ?? null,
       processConfig: normalizeProcessConfig(params.processConfig ?? null),
-      isCodeInstance: params.isCodeInstance ?? false,
       lastActivityAt: params.lastActivityAt ?? null,
-      codeInstanceMinutesUsed: params.codeInstanceMinutesUsed ?? 0,
     });
     return r.save(cfg);
   }
@@ -928,10 +924,7 @@ export async function saveServerConfig(params: {
   keep.disk = params.disk;
   keep.cpu = params.cpu;
   keep.swap = params.swap ?? keep.swap ?? 0;
-  keep.ioWeight = params.ioWeight ?? keep.ioWeight ?? 500;
-  keep.isCodeInstance = params.isCodeInstance ?? keep.isCodeInstance;
   keep.lastActivityAt = params.lastActivityAt ?? keep.lastActivityAt;
-  keep.codeInstanceMinutesUsed = params.codeInstanceMinutesUsed ?? keep.codeInstanceMinutesUsed ?? 0;
   keep.hibernated = params.hibernated ?? keep.hibernated ?? false;
   keep.eggId = params.eggId ?? keep.eggId;
   keep.skipEggScripts = params.skipEggScripts ?? keep.skipEggScripts ?? false;

backend/src/handlers/serverHandler.ts

@@ -469,7 +469,7 @@ export async function serverRoutes(app: any, prefix = '') {
         const where: any[] = [{ userId: user.id }];
         if (subuserUuids.length) where.push({ uuid: In(subuserUuids) });
         const found = await cfgRepo.find({ where });
-        return found.filter((c: any) => !c.isCodeInstance);
+        return found;
       })();
 
     const cfgMap = new Map(configs.map((c: any) => [c.uuid, c]));
@@ -1188,64 +1188,10 @@ export async function serverRoutes(app: any, prefix = '') {
       };
     }
 
-    let isCodeInstance = !!body.isCodeInstance || Number(body.eggId) === 264;
-
-    if (isCodeInstance && !isAdmin) {
-      const settingRepo = AppDataSource.getRepository(
-        require('../models/panelSetting.entity').PanelSetting
-      );
-      const setting = await settingRepo.findOneBy({ key: 'codeInstancesEnabled' });
-      if (setting?.value === 'false') {
-        ctx.set.status = 403;
-        return { error: 'Code instance creation is temporarily disabled by an administrator.' };
-      }
-    }
-
-    const allUserServers = !isAdmin
+    const existingRegularServers = !isAdmin
       ? await cfgRepo().find({ where: { userId: ownerId } })
       : [];
 
-    const existingCodeInstances = allUserServers.filter((s: any) => s.isCodeInstance);
-    const existingRegularServers = allUserServers.filter((s: any) => !s.isCodeInstance);
-
-    if (isCodeInstance && !isAdmin) {
-      const allowedPortalTypes = ['educational', 'paid', 'enterprise'];
-      if (!allowedPortalTypes.includes(effectivePortalType)) {
-        ctx.set.status = 403;
-        return { error: 'Code Instances are available only for educational or higher plans.' };
-      }
-
-      if (existingCodeInstances.length >= 2) {
-        ctx.set.status = 403;
-        return { error: 'Maximum 2 Code Instances are allowed concurrently.' };
-      }
-
-      const existingCIMem = existingCodeInstances.reduce((sum: number, i: any) => sum + (i.memory || 0), 0);
-      const existingCICpu = existingCodeInstances.reduce((sum: number, i: any) => sum + (i.cpu || 0), 0);
-      const existingCIDisk = existingCodeInstances.reduce((sum: number, i: any) => sum + (i.disk || 0), 0);
-
-      if (existingCIMem + memory > 8192) {
-        ctx.set.status = 403;
-        return { error: 'Total Code Instance memory limit is 8192 MB.' };
-      }
-      if (existingCICpu + cpu > 6) {
-        ctx.set.status = 403;
-        return { error: 'Total Code Instance CPU limit is 6 cores.' };
-      }
-      if (existingCIDisk + disk > 102400) {
-        ctx.set.status = 403;
-        return { error: 'Total Code Instance disk limit is 100000 MB.' };
-      }
-
-      const usedMinutes = existingCodeInstances.reduce(
-        (sum: number, i: any) => sum + (i.codeInstanceMinutesUsed || 0), 0
-      );
-      if (usedMinutes >= 150 * 60) {
-        ctx.set.status = 403;
-        return { error: 'Monthly Code Instance usage limit of 150 hours reached.' };
-      }
-    }
-
     if (!isAdmin) {
       if (limits.serverLimit != null && limits.serverLimit > 0) {
         if (existingRegularServers.length >= limits.serverLimit) {
@@ -1272,10 +1218,6 @@ export async function serverRoutes(app: any, prefix = '') {
       }
     }
 
-    if (isCodeInstance) {
-      eggId = 264;
-    }
-
     if (!eggId) {
       ctx.set.status = 400;
       return { error: 'eggId is required' };
@@ -1480,9 +1422,7 @@ export async function serverRoutes(app: any, prefix = '') {
       disk,
       cpu,
       eggId: egg.id,
-      isCodeInstance,
       kvmPassthroughEnabled,
-      lastActivityAt: isCodeInstance ? new Date() : undefined,
       ...(autoAllocation ? { allocations: autoAllocation } : {}),
     });
 
@@ -4320,88 +4260,4 @@ export async function serverRoutes(app: any, prefix = '') {
     response: { 200: t.Object({ host: t.String(), port: t.Number(), username: t.String(), proxied: t.Boolean() }), 401: t.Object({ error: t.String() }), 403: t.Object({ error: t.String() }), 404: t.Object({ error: t.String() }), 500: t.Object({ error: t.String() }) },
     detail: { summary: 'Get SFTP connection info', tags: ['Servers'] }
   });
-
-  app.get(prefix + '/infrastructure/code-instances', async (ctx: any) => {
-    const user = ctx.user as User;
-    if (!user) {
-      ctx.set.status = 401;
-      return { error: 'Unauthorized' };
-    }
-
-    const instances = await cfgRepo().find({ where: { userId: user.id, isCodeInstance: true } });
-    return instances.map((cfg) => ({
-      uuid: cfg.uuid,
-      name: cfg.name,
-      nodeId: cfg.nodeId,
-      memory: cfg.memory,
-      disk: cfg.disk,
-      cpu: cfg.cpu,
-      status: cfg.hibernated ? 'hibernated' : 'active',
-      lastActivityAt: cfg.lastActivityAt,
-      createdAt: cfg.createdAt,
-      codeInstanceMinutesUsed: cfg.codeInstanceMinutesUsed,
-    }));
-  }, {
-    beforeHandle: [authenticate],
-    response: { 200: t.Array(t.Any()), 401: t.Object({ error: t.String() }) },
-    detail: { summary: 'List code instances for the current user', tags: ['Code Instances'] }
-  });
-
-  app.post(prefix + '/infrastructure/code-instances/:uuid/ping', async (ctx: any) => {
-    const { uuid } = ctx.params as any;
-    const user = ctx.user as User;
-    if (!user) {
-      ctx.set.status = 401;
-      return { error: 'Unauthorized' };
-    }
-
-    const cfg = await cfgRepo().findOneBy({ uuid, isCodeInstance: true });
-    if (!cfg || cfg.userId !== user.id) {
-      ctx.set.status = 404;
-      return { error: 'Code Instance not found' };
-    }
-
-    cfg.lastActivityAt = new Date();
-    await cfgRepo().save(cfg);
-
-    await createActivityLog({ userId: user.id, action: 'codeInstance:ping', targetId: uuid, targetType: 'code-instance', ipAddress: ctx.ip });
-    return { success: true };
-  }, {
-    beforeHandle: [authenticate],
-    response: { 200: t.Object({ success: t.Boolean() }), 401: t.Object({ error: t.String() }), 404: t.Object({ error: t.String() }) },
-    detail: { summary: 'Ping code instance activity', tags: ['Code Instances'] }
-  });
-
-  app.post(prefix + '/infrastructure/code-instances/:uuid/stop', async (ctx: any) => {
-    const { uuid } = ctx.params as any;
-    const user = ctx.user as User;
-    if (!user) {
-      ctx.set.status = 401;
-      return { error: 'Unauthorized' };
-    }
-
-    const cfg = await cfgRepo().findOneBy({ uuid, isCodeInstance: true });
-    if (!cfg || cfg.userId !== user.id) {
-      ctx.set.status = 404;
-      return { error: 'Code Instance not found' };
-    }
-
-    try {
-      const svc = await serviceFor(uuid);
-      await svc.powerServer(uuid, 'stop').catch(() => { });
-      await svc.serverRequest(uuid, '', 'delete').catch(() => { });
-    } catch (e: any) {
-      // skip
-    }
-
-    await removeServerConfig(uuid).catch(() => { });
-    await nodeSvc.unmapServer(uuid).catch(() => { });
-
-    await createActivityLog({ userId: user.id, action: 'codeInstance:stop', targetId: uuid, targetType: 'code-instance', ipAddress: ctx.ip });
-    return { success: true };
-  }, {
-    beforeHandle: [authenticate],
-    response: { 200: t.Object({ success: t.Boolean() }), 401: t.Object({ error: t.String() }), 404: t.Object({ error: t.String() }) },
-    detail: { summary: 'Stop and delete code instance', tags: ['Code Instances'] }
-  });
-}
+}

backend/src/handlers/ticketHandler.ts

@@ -431,6 +431,9 @@ export async function ticketRoutes(app: any, prefix = '') {
       }
 
       ticket.aiTouched = true;
+      if (dir.escalate) {
+        ticket.aiDisabled = true;
+      }
       ticket.status = dir.escalate || changes.applied.priority === 'urgent' ? 'awaiting_staff_reply' : 'replied';
       await repo.save(ticket);
 
@@ -1162,6 +1165,7 @@ Valid subpaths: /dashboard/*, /wings, /billing, /organisations, /docs, /ai, /inf
 
       if (pushedSender === 'user' && userEscalated) {
         saved.status = 'awaiting_staff_reply';
+        saved.aiDisabled = true;
         await repo.save(saved);
         try { await createActivityLog({ userId: user.id, action: 'ticket:escalate:user', targetId: String(saved.id), targetType: 'ticket', metadata: { reason: 'user requested escalation/no access' }, ipAddress: '' }); } catch (e) { }
       } else {

backend/src/jobs/codeInstanceIdleJob.ts

@@ -101,15 +101,9 @@ export class ServerConfig {
   @Column('json', { nullable: true })
   processConfig?: Record<string, any>;
 
-  @Column({ default: false })
-  isCodeInstance: boolean;
-
   @Column({ nullable: true, type: 'datetime' })
   lastActivityAt?: Date;
 
-  @Column({ default: 0 })
-  codeInstanceMinutesUsed: number;
-
   @Column({ default: 0 })
   maxDatabases: number;