[{"_1":2,"_175":-5,"_176":-5},"loaderData",{"_3":4,"_92":93},"root",{"_5":6,"_35":36,"_65":66},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":20,"_34":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","notificationCount",0,"flagDenols","isTeamOrgMember","ENV",{"_37":38,"_39":40,"_41":42,"_43":44,"_45":46,"_47":48,"_49":50,"_51":52,"_53":54,"_55":56,"_57":58,"_59":60,"_61":62,"_63":64},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","8abab1f3bacc65052d6313ca736f41d897b49791","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","API_URL","https://api.val.town","clerkState",{"_67":68},"__internal_clerk_state",{"_69":70,"_71":46,"_72":73,"_74":73,"_75":20,"_76":73,"_77":73,"_78":73,"_79":73,"_80":81,"_90":20,"_91":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_82":20,"_19":20,"_83":73,"_84":85,"_86":73,"_87":46,"_88":20,"_89":73},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_94":95,"_96":97,"_98":99,"_100":101,"_151":152,"_172":173,"_174":-5},"handle","pinsar","name","feistyAmberRhinoceros","path","shared/utils.ts","project",{"_102":103,"_96":97,"_104":105,"_106":-5,"_107":20,"_108":109,"_110":-5,"_111":-5,"_12":112,"_113":114,"_115":116,"_117":-5,"_118":119,"_120":32,"_14":121,"_122":123,"_124":123,"_125":126,"_127":126,"_128":126,"_129":123,"_130":123,"_23":131,"_134":135,"_137":138,"_150":20},"id","2149c16a-277d-11f0-b46e-569c3dd06744","createdAt",["D",1746207883134],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","851f6760-f7af-11ef-9322-0fd6f1c36e70","pinnedFileId","214e03d8-277d-11f0-b46e-569c3dd06744","pinPreview",true,"pinMigrated","screenshotVersion",19,"likeCount","094b6920-183c-466c-985a-fe1516b5d507","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_94":95,"_132":133},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18ydG1LWVR3QzZpNUhHQkNmbzF5VlRvOGZweUQifQ","org",{"_94":95,"_136":133,"_12":112},"avatar","branch",{"_139":140,"_96":44,"_102":141,"_142":103,"_143":-5,"_144":-5,"_145":-5,"_146":-5,"_147":-5,"_148":97,"_149":95},"version",27,"214a9ba8-277d-11f0-b46e-569c3dd06744","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_102":153,"_96":154,"_155":156,"_157":158,"_159":141,"_160":161,"_162":116,"_104":163,"_139":32,"_164":165,"_166":167,"_168":20,"_169":-5,"_98":170},"39f826a8-3a05-11f0-b736-9e149126039e","utils.ts","fileId","39f82798-3a05-11f0-b736-9e149126039e","parentId","da4edb79-5d59-4320-842e-e6d469deea5a","branchId","branchVersion",21,"latest",["D",1748245457026],"fileType","script","content","// Shared utility functions for the real-time data processing system\n\n/**\n * Generate a unique event ID\n */\nexport function generateEventId(): string {\n return `evt_${Date.now()}_${Math.random().toString(36).substr(2, 9)}`;\n}\n\n/**\n * Generate a partition key for distributed processing\n */\nexport function generatePartitionKey(eventData: any, partitionCount: number = 16): string {\n const key = eventData.data?.user_id || eventData.type || 'default';\n return `partition_${hashString(key) % partitionCount}`;\n}\n\n/**\n * Hash a string to a number\n */\nexport function hashString(str: string): number {\n let hash = 0;\n for (let i = 0; i < str.length; i++) {\n const char = str.charCodeAt(i);\n hash = ((hash << 5) - hash) + char;\n hash = hash & hash; // Convert to 32-bit integer\n }\n return Math.abs(hash);\n}\n\n/**\n * Format a number with appropriate units (K, M, B)\n */\nexport function formatNumber(num: number): string {\n if (num >= 1000000000) {\n return `${(num / 1000000000).toFixed(1)}B`;\n } else if (num >= 1000000) {\n return `${(num / 1000000).toFixed(1)}M`;\n } else if (num >= 1000) {\n return `${(num / 1000).toFixed(1)}K`;\n } else {\n return num.toFixed(0);\n }\n}\n\n/**\n * Format uptime duration\n */\nexport function formatUptime(uptime: number): string {\n const seconds = Math.floor(uptime / 1000);\n const minutes = Math.floor(seconds / 60);\n const hours = Math.floor(minutes / 60);\n const days = Math.floor(hours / 24);\n \n if (days > 0) {\n return `${days}d ${hours % 24}h`;\n } else if (hours > 0) {\n return `${hours}h ${minutes % 60}m`;\n } else if (minutes > 0) {\n return `${minutes}m ${seconds % 60}s`;\n } else {\n return `${seconds}s`;\n }\n}\n\n/**\n * Format bytes to human readable format\n */\nexport function formatBytes(bytes: number): string {\n if (bytes === 0) return '0 B';\n \n const k = 1024;\n const sizes = ['B', 'KB', 'MB', 'GB', 'TB'];\n const i = Math.floor(Math.log(bytes) / Math.log(k));\n \n return `${parseFloat((bytes / Math.pow(k, i)).toFixed(1))} ${sizes[i]}`;\n}\n\n/**\n * Calculate percentile from an array of numbers\n */\nexport function calculatePercentile(numbers: number[], percentile: number): number {\n if (numbers.length === 0) return 0;\n \n const sorted = [...numbers].sort((a, b) => a - b);\n const index = Math.ceil((percentile / 100) * sorted.length) - 1;\n return sorted[Math.max(0, index)];\n}\n\n/**\n * Calculate average from an array of numbers\n */\nexport function calculateAverage(numbers: number[]): number {\n if (numbers.length === 0) return 0;\n return numbers.reduce((sum, n) => sum + n, 0) / numbers.length;\n}\n\n/**\n * Chunk an array into smaller arrays\n */\nexport function chunkArray(array: T[], chunkSize: number): T[][] {\n const chunks: T[][] = [];\n for (let i = 0; i < array.length; i += chunkSize) {\n chunks.push(array.slice(i, i + chunkSize));\n }\n return chunks;\n}\n\n/**\n * Debounce function calls\n */\nexport function debounce any>(\n func: T,\n wait: number\n): (...args: Parameters) => void {\n let timeout: number | undefined;\n \n return (...args: Parameters) => {\n clearTimeout(timeout);\n timeout = setTimeout(() => func(...args), wait);\n };\n}\n\n/**\n * Throttle function calls\n */\nexport function throttle any>(\n func: T,\n limit: number\n): (...args: Parameters) => void {\n let inThrottle: boolean;\n \n return (...args: Parameters) => {\n if (!inThrottle) {\n func(...args);\n inThrottle = true;\n setTimeout(() => inThrottle = false, limit);\n }\n };\n}\n\n/**\n * Sleep for a specified number of milliseconds\n */\nexport function sleep(ms: number): Promise {\n return new Promise(resolve => setTimeout(resolve, ms));\n}\n\n/**\n * Retry a function with exponential backoff\n */\nexport async function retryWithBackoff(\n fn: () => Promise,\n maxRetries: number = 3,\n baseDelay: number = 1000\n): Promise {\n let lastError: Error;\n \n for (let attempt = 0; attempt < maxRetries; attempt++) {\n try {\n return await fn();\n } catch (error) {\n lastError = error as Error;\n \n if (attempt < maxRetries - 1) {\n const delay = baseDelay * Math.pow(2, attempt);\n await sleep(delay);\n }\n }\n }\n \n throw lastError!;\n}\n\n/**\n * Validate event data structure\n */\nexport function validateEvent(eventData: any): boolean {\n if (!eventData || typeof eventData !== 'object') {\n return false;\n }\n \n // Required fields\n if (!eventData.type || typeof eventData.type !== 'string') {\n return false;\n }\n \n if (!eventData.source || typeof eventData.source !== 'string') {\n return false;\n }\n \n // Optional but should be valid if present\n if (eventData.timestamp && (typeof eventData.timestamp !== 'number' || eventData.timestamp <= 0)) {\n return false;\n }\n \n if (eventData.id && typeof eventData.id !== 'string') {\n return false;\n }\n \n return true;\n}\n\n/**\n * Sanitize event data to prevent injection attacks\n */\nexport function sanitizeEventData(eventData: any): any {\n if (typeof eventData !== 'object' || eventData === null) {\n return eventData;\n }\n \n const sanitized: any = {};\n \n for (const [key, value] of Object.entries(eventData)) {\n // Skip functions and undefined values\n if (typeof value === 'function' || value === undefined) {\n continue;\n }\n \n // Recursively sanitize objects\n if (typeof value === 'object' && value !== null) {\n sanitized[key] = sanitizeEventData(value);\n } else {\n sanitized[key] = value;\n }\n }\n \n return sanitized;\n}\n\n/**\n * Generate test event data\n */\nexport function generateTestEvent(type?: string, source?: string): any {\n const eventTypes = ['user_action', 'page_view', 'purchase', 'signup', 'login', 'api_call'];\n const sources = ['web_app', 'mobile_app', 'api', 'external'];\n const actions = ['click', 'scroll', 'hover', 'submit', 'navigate', 'search'];\n \n return {\n type: type || eventTypes[Math.floor(Math.random() * eventTypes.length)],\n source: source || sources[Math.floor(Math.random() * sources.length)],\n data: {\n user_id: Math.floor(Math.random() * 10000).toString(),\n action: actions[Math.floor(Math.random() * actions.length)],\n value: Math.random() * 100,\n metadata: {\n test: true,\n timestamp: Date.now(),\n random_id: Math.random().toString(36).substr(2, 9)\n }\n }\n };\n}\n\n/**\n * Calculate system health score based on metrics\n */\nexport function calculateHealthScore(metrics: {\n errorRate: number;\n avgLatency: number;\n throughput: number;\n cpuUsage: number;\n memoryUsage: number;\n}): number {\n let score = 100;\n \n // Error rate impact (0-30 points)\n if (metrics.errorRate > 0.05) score -= 30;\n else if (metrics.errorRate > 0.01) score -= 15;\n else if (metrics.errorRate > 0.001) score -= 5;\n \n // Latency impact (0-25 points)\n if (metrics.avgLatency > 1000) score -= 25;\n else if (metrics.avgLatency > 500) score -= 15;\n else if (metrics.avgLatency > 100) score -= 5;\n \n // Throughput impact (0-20 points)\n if (metrics.throughput === 0) score -= 20;\n else if (metrics.throughput < 10) score -= 10;\n else if (metrics.throughput < 100) score -= 5;\n \n // CPU usage impact (0-15 points)\n if (metrics.cpuUsage > 95) score -= 15;\n else if (metrics.cpuUsage > 80) score -= 10;\n else if (metrics.cpuUsage > 60) score -= 5;\n \n // Memory usage impact (0-10 points)\n if (metrics.memoryUsage > 2000) score -= 10;\n else if (metrics.memoryUsage > 1000) score -= 5;\n \n return Math.max(0, score);\n}","deleted","label",[171,154],"shared","permalink","https://www.val.town/x/pinsar/feistyAmberRhinoceros/code/shared/utils.ts","extension","actionData","errors"]