Fix script execution issues and improve container creation

- Fixed syntax errors in build.func (duplicate export, unmatched quotes)
- Fixed color variable initialization by calling load_functions in core.func
- Replaced undefined function calls (post_to_api, post_update_to_api) with echo statements
- Fixed install script execution by copying scripts into container first
- Made create_lxc.sh executable
- Improved error handling and script sourcing
- Added missing core functions and tools
- Enhanced script downloader and local script management

src/server/api/routers/scripts.ts

@@ -219,5 +219,65 @@ export const scriptsRouter = createTRPCRouter({
           files: []
         };
       }
+    }),
+
+  // Compare local and remote script content
+  compareScriptContent: publicProcedure
+    .input(z.object({ slug: z.string() }))
+    .query(async ({ input }) => {
+      try {
+        const script = await localScriptsService.getScriptBySlug(input.slug);
+        if (!script) {
+          return {
+            success: false,
+            error: 'Script not found',
+            hasDifferences: false,
+            differences: []
+          };
+        }
+
+        const result = await scriptDownloaderService.compareScriptContent(script);
+        return {
+          success: true,
+          ...result
+        };
+      } catch (error) {
+        console.error('Error in compareScriptContent:', error);
+        return {
+          success: false,
+          error: error instanceof Error ? error.message : 'Failed to compare script content',
+          hasDifferences: false,
+          differences: []
+        };
+      }
+    }),
+
+  // Get diff content for a specific script file
+  getScriptDiff: publicProcedure
+    .input(z.object({ slug: z.string(), filePath: z.string() }))
+    .query(async ({ input }) => {
+      try {
+        const script = await localScriptsService.getScriptBySlug(input.slug);
+        if (!script) {
+          return {
+            success: false,
+            error: 'Script not found',
+            diff: null
+          };
+        }
+
+        const result = await scriptDownloaderService.getScriptDiff(script, input.filePath);
+        return {
+          success: true,
+          ...result
+        };
+      } catch (error) {
+        console.error('Error in getScriptDiff:', error);
+        return {
+          success: false,
+          error: error instanceof Error ? error.message : 'Failed to get script diff',
+          diff: null
+        };
+      }
     })
 });

src/server/api/trpc.ts

@@ -73,28 +73,6 @@ export const createCallerFactory = t.createCallerFactory;
  */
 export const createTRPCRouter = t.router;
 
-/**
- * Middleware for timing procedure execution and adding an artificial delay in development.
- *
- * You can remove this if you don't like it, but it can help catch unwanted waterfalls by simulating
- * network latency that would occur in production but not in local development.
- */
-const timingMiddleware = t.middleware(async ({ next, path }) => {
-  const start = Date.now();
-
-  if (t._config.isDev) {
-    // artificial delay in dev
-    const waitMs = Math.floor(Math.random() * 400) + 100;
-    await new Promise((resolve) => setTimeout(resolve, waitMs));
-  }
-
-  const result = await next();
-
-  const end = Date.now();
-  console.log(`[TRPC] ${path} took ${end - start}ms to execute`);
-
-  return result;
-});
 
 /**
  * Public (unauthenticated) procedure
@@ -103,4 +81,4 @@ const timingMiddleware = t.middleware(async ({ next, path }) => {
  * guarantee that a user querying is authorized, but you can still access user session data if they
  * are logged in.
  */
-export const publicProcedure = t.procedure.use(timingMiddleware);
+export const publicProcedure = t.procedure;

src/server/api/websocket/handler.ts

@@ -1,7 +1,6 @@
-import { WebSocketServer, WebSocket } from 'ws';
-import { IncomingMessage } from 'http';
+import { WebSocketServer, type WebSocket } from 'ws';
+import type { IncomingMessage } from 'http';
 import { scriptManager } from '~/server/lib/scripts';
-import { env } from '~/env.js';
 
 interface ScriptExecutionMessage {
   type: 'start' | 'output' | 'error' | 'end';
@@ -22,8 +21,7 @@ export class ScriptExecutionHandler {
     this.wss.on('connection', this.handleConnection.bind(this));
   }
 
-  private handleConnection(ws: WebSocket, request: IncomingMessage) {
-    console.log('New WebSocket connection for script execution');
+  private handleConnection(ws: WebSocket, _request: IncomingMessage) {
     
     ws.on('message', (data) => {
       try {
@@ -40,7 +38,6 @@ export class ScriptExecutionHandler {
     });
 
     ws.on('close', () => {
-      console.log('WebSocket connection closed');
       // Clean up any active executions for this connection
       this.cleanupActiveExecutions(ws);
     });