improvement(config): consolidate socket server URL into getSocketServerUrl/getSocketUrl

Replace all inline `env.SOCKET_SERVER_URL || 'http://localhost:3002'` and
`getEnv('NEXT_PUBLIC_SOCKET_URL') || 'http://localhost:3002'` with centralized
utility functions in urls.ts, matching the getBaseUrl() pattern.

Author: waleedlatif1

apps/sim/app/api/workflows/[id]/state/route.ts

@@ -7,6 +7,7 @@ import { z } from 'zod'
 import { checkSessionOrInternalAuth } from '@/lib/auth/hybrid'
 import { env } from '@/lib/core/config/env'
 import { generateRequestId } from '@/lib/core/utils/request'
+import { getSocketServerUrl } from '@/lib/core/utils/urls'
 import { extractAndPersistCustomTools } from '@/lib/workflows/persistence/custom-tools-persistence'
 import {
   loadWorkflowFromNormalizedTables,
@@ -305,8 +306,7 @@ export async function PUT(request: NextRequest, { params }: { params: Promise<{
     logger.info(`[${requestId}] Successfully saved workflow ${workflowId} state in ${elapsed}ms`)
 
     try {
-      const socketUrl = env.SOCKET_SERVER_URL || 'http://localhost:3002'
-      const notifyResponse = await fetch(`${socketUrl}/api/workflow-updated`, {
+      const notifyResponse = await fetch(`${getSocketServerUrl()}/api/workflow-updated`, {
         method: 'POST',
         headers: {
           'Content-Type': 'application/json',

apps/sim/app/workspace/providers/socket-provider.tsx

@@ -13,7 +13,7 @@ import {
 import { createLogger } from '@sim/logger'
 import { useParams } from 'next/navigation'
 import type { Socket } from 'socket.io-client'
-import { getEnv } from '@/lib/core/config/env'
+import { getSocketUrl } from '@/lib/core/utils/urls'
 import { generateId } from '@/lib/core/utils/uuid'
 import {
   type SocketJoinCommand,
@@ -340,7 +340,7 @@ export function SocketProvider({ children, user }: SocketProviderProps) {
     const initializeSocket = async () => {
       try {
         const { io } = await import('socket.io-client')
-        const socketUrl = getEnv('NEXT_PUBLIC_SOCKET_URL') || 'http://localhost:3002'
+        const socketUrl = getSocketUrl()
 
         logger.info('Attempting to connect to Socket.IO server', {
           url: socketUrl,

apps/sim/lib/copilot/tools/handlers/workflow/mutations.ts

@@ -6,6 +6,7 @@ import { AuditAction, AuditResourceType, recordAudit } from '@/lib/audit/log'
 import type { ExecutionContext, ToolCallResult } from '@/lib/copilot/request/types'
 import { env } from '@/lib/core/config/env'
 import { generateRequestId } from '@/lib/core/utils/request'
+import { getSocketServerUrl } from '@/lib/core/utils/urls'
 import { generateId } from '@/lib/core/utils/uuid'
 import { executeWorkflow } from '@/lib/workflows/executor/execute-workflow'
 import {
@@ -147,8 +148,7 @@ function findDescendants(containerId: string, blocksById: Record<string, BlockSt
 }
 
 function notifyWorkflowUpdated(workflowId: string): void {
-  const socketUrl = env.SOCKET_SERVER_URL || 'http://localhost:3002'
-  fetch(`${socketUrl}/api/workflow-updated`, {
+  fetch(`${getSocketServerUrl()}/api/workflow-updated`, {
     method: 'POST',
     headers: {
       'Content-Type': 'application/json',

apps/sim/lib/copilot/tools/server/workflow/edit-workflow/index.ts

@@ -9,6 +9,7 @@ import {
   type ServerToolContext,
 } from '@/lib/copilot/tools/server/base-tool'
 import { env } from '@/lib/core/config/env'
+import { getSocketServerUrl } from '@/lib/core/utils/urls'
 import {
   applyTargetedLayout,
   getTargetedLayoutImpact,
@@ -284,8 +285,7 @@ export const editWorkflowServerTool: BaseServerTool<EditWorkflowParams, unknown>
 
     logger.info('Workflow state persisted to database', { workflowId })
 
-    const socketUrl = env.SOCKET_SERVER_URL || 'http://localhost:3002'
-    fetch(`${socketUrl}/api/workflow-updated`, {
+    fetch(`${getSocketServerUrl()}/api/workflow-updated`, {
       method: 'POST',
       headers: {
         'Content-Type': 'application/json',

apps/sim/lib/core/utils/urls.ts

@@ -1,4 +1,4 @@
-import { getEnv } from '@/lib/core/config/env'
+import { env, getEnv } from '@/lib/core/config/env'
 import { isProd } from '@/lib/core/config/feature-flags'
 
 /** Canonical base URL for the public-facing marketing site. No trailing slash. */
@@ -100,3 +100,21 @@ export function getEmailDomain(): string {
     return isProd ? 'sim.ai' : 'localhost:3000'
   }
 }
+
+const DEFAULT_SOCKET_URL = 'http://localhost:3002'
+
+/**
+ * Returns the socket server URL for server-side internal API calls.
+ * Reads from SOCKET_SERVER_URL with a localhost fallback for development.
+ */
+export function getSocketServerUrl(): string {
+  return env.SOCKET_SERVER_URL || DEFAULT_SOCKET_URL
+}
+
+/**
+ * Returns the socket server URL for client-side Socket.IO connections.
+ * Reads from NEXT_PUBLIC_SOCKET_URL with a localhost fallback for development.
+ */
+export function getSocketUrl(): string {
+  return getEnv('NEXT_PUBLIC_SOCKET_URL') || DEFAULT_SOCKET_URL
+}

apps/sim/lib/workflows/lifecycle.ts

@@ -18,6 +18,7 @@ import { env } from '@/lib/core/config/env'
 import { getRedisClient } from '@/lib/core/config/redis'
 import { PlatformEvents } from '@/lib/core/telemetry'
 import { generateRequestId } from '@/lib/core/utils/request'
+import { getSocketServerUrl } from '@/lib/core/utils/urls'
 import { mcpPubSub } from '@/lib/mcp/pubsub'
 import { getWorkflowById } from '@/lib/workflows/utils'
 
@@ -31,8 +32,7 @@ interface ArchiveWorkflowOptions {
 
 async function notifyWorkflowArchived(workflowId: string, requestId: string): Promise<void> {
   try {
-    const socketUrl = env.SOCKET_SERVER_URL || 'http://localhost:3002'
-    const socketResponse = await fetch(`${socketUrl}/api/workflow-deleted`, {
+    const socketResponse = await fetch(`${getSocketServerUrl()}/api/workflow-deleted`, {
       method: 'POST',
       headers: {
         'Content-Type': 'application/json',

apps/sim/lib/workflows/orchestration/deploy.ts

@@ -5,7 +5,7 @@ import { NextRequest } from 'next/server'
 import { AuditAction, AuditResourceType, recordAudit } from '@/lib/audit/log'
 import { env } from '@/lib/core/config/env'
 import { generateRequestId } from '@/lib/core/utils/request'
-import { getBaseUrl } from '@/lib/core/utils/urls'
+import { getBaseUrl, getSocketServerUrl } from '@/lib/core/utils/urls'
 import { removeMcpToolsForWorkflow, syncMcpToolsForWorkflow } from '@/lib/mcp/workflow-mcp-sync'
 import { captureServerEvent } from '@/lib/posthog/server'
 import {
@@ -37,8 +37,7 @@ const logger = createLogger('DeployOrchestration')
  */
 export async function notifySocketDeploymentChanged(workflowId: string): Promise<void> {
   try {
-    const socketServerUrl = env.SOCKET_SERVER_URL || 'http://localhost:3002'
-    const response = await fetch(`${socketServerUrl}/api/workflow-deployed`, {
+    const response = await fetch(`${getSocketServerUrl()}/api/workflow-deployed`, {
       method: 'POST',
       headers: {
         'Content-Type': 'application/json',
@@ -47,7 +46,9 @@ export async function notifySocketDeploymentChanged(workflowId: string): Promise
       body: JSON.stringify({ workflowId }),
     })
     if (!response.ok) {
-      logger.warn(`Socket deployment notification failed (${response.status}) for workflow ${workflowId}`)
+      logger.warn(
+        `Socket deployment notification failed (${response.status}) for workflow ${workflowId}`
+      )
     }
   } catch (error) {
     logger.error('Error sending workflow deployed event to socket server', error)
@@ -625,8 +626,7 @@ export async function performRevertToVersion(
     .where(eq(workflowTable.id, workflowId))
 
   try {
-    const socketServerUrl = env.SOCKET_SERVER_URL || 'http://localhost:3002'
-    await fetch(`${socketServerUrl}/api/workflow-reverted`, {
+    await fetch(`${getSocketServerUrl()}/api/workflow-reverted`, {
       method: 'POST',
       headers: {
         'Content-Type': 'application/json',