refactor: consolidate local isRecord guards onto shared isRecordLike

Nineteen files had re-declared a local `isRecord` guard rather than using the
shared one from `@sim/utils/object`, drift that reappeared after #5061 first
consolidated them. Two more imported the shared guard under an `isRecordLike as
isRecord` alias.

The copies were not interchangeable. Nine matched `isRecordLike` exactly. The
rest omitted the array exclusion (`typeof x === 'object' && x !== null`, or
`Boolean(x) && typeof x === 'object'`), so arrays passed the guard. Each of
those call sites was reviewed individually: in every case the guard is followed
by string/number field checks that an array fails anyway, so the outcome is
unchanged.

The one exception is `isOptionsTagData`, where `Object.values` on an array of
option items really did make an array-form `<options>` tag render. It now
accepts arrays explicitly rather than by accident.

`executor/handlers/pi/search/extension-source.ts` keeps its own copy: it is
source text written into an E2B/Daytona sandbox at runtime and cannot import.

Author: waleedlatif1

apps/sim/app/workspace/[workspaceId]/home/components/message-content/components/special-tags/special-tags.tsx

@@ -14,6 +14,7 @@ import {
   toast,
 } from '@sim/emcn'
 import { TerminalWindow } from '@sim/emcn/icons'
+import { isRecordLike } from '@sim/utils/object'
 import { useParams } from 'next/navigation'
 import { ThinkingLoader } from '@/components/ui'
 import { useSession } from '@/lib/auth/auth-client'
@@ -353,22 +354,23 @@ export const SPECIAL_TAG_NAMES = [
   'question',
 ] as const
 
-function isRecord(value: unknown): value is Record<string, unknown> {
-  return typeof value === 'object' && value !== null
-}
-
 function isOptionsItemData(value: unknown): value is OptionsItemData {
-  if (!isRecord(value)) return false
+  if (!isRecordLike(value)) return false
   return typeof value.title === 'string' && typeof value.description === 'string'
 }
 
+/**
+ * Arrays are accepted alongside keyed objects: an agent that emits
+ * `<options>[{title,description},…]</options>` still renders, with the array
+ * index standing in as the option key.
+ */
 function isOptionsTagData(value: unknown): value is OptionsTagData {
-  if (!isRecord(value)) return false
+  if (!isRecordLike(value) && !Array.isArray(value)) return false
   return Object.values(value).every(isOptionsItemData)
 }
 
 function isUsageUpgradeTagData(value: unknown): value is UsageUpgradeTagData {
-  if (!isRecord(value)) return false
+  if (!isRecordLike(value)) return false
   return (
     typeof value.reason === 'string' &&
     typeof value.message === 'string' &&
@@ -378,7 +380,7 @@ function isUsageUpgradeTagData(value: unknown): value is UsageUpgradeTagData {
 }
 
 function isCredentialItemData(value: unknown): value is CredentialItemData {
-  if (!isRecord(value)) return false
+  if (!isRecordLike(value)) return false
   if (
     typeof value.type !== 'string' ||
     !(CREDENTIAL_TAG_TYPES as readonly string[]).includes(value.type)
@@ -452,7 +454,7 @@ export function parseLastCredentialTag(content: string): CredentialTagData | nul
 }
 
 function isMothershipErrorTagData(value: unknown): value is MothershipErrorTagData {
-  if (!isRecord(value)) return false
+  if (!isRecordLike(value)) return false
   return (
     typeof value.message === 'string' &&
     (value.code === undefined || typeof value.code === 'string') &&
@@ -461,7 +463,7 @@ function isMothershipErrorTagData(value: unknown): value is MothershipErrorTagDa
 }
 
 function isWorkspaceResourceTagData(value: unknown): value is WorkspaceResourceTagData {
-  if (!isRecord(value)) return false
+  if (!isRecordLike(value)) return false
   if (
     typeof value.type !== 'string' ||
     !(WORKSPACE_RESOURCE_TAG_TYPES as readonly string[]).includes(value.type)
@@ -479,7 +481,7 @@ function isWorkspaceResourceTagData(value: unknown): value is WorkspaceResourceT
 }
 
 function isQuestionOption(value: unknown): value is QuestionOption {
-  if (!isRecord(value)) return false
+  if (!isRecordLike(value)) return false
   return typeof value.id === 'string' && typeof value.label === 'string'
 }
 
@@ -497,7 +499,7 @@ const SELF_PROVIDED_OPTION_LABELS = new Set([
 ])
 
 function isQuestionItem(value: unknown): value is QuestionItem {
-  if (!isRecord(value)) return false
+  if (!isRecordLike(value)) return false
   if (
     typeof value.type !== 'string' ||
     !(QUESTION_TYPES as readonly string[]).includes(value.type)
@@ -551,7 +553,7 @@ function recoverQuestionPrompts(body: string): string | null {
     const parsed = JSON.parse(body) as unknown
     const items = Array.isArray(parsed) ? parsed : [parsed]
     const prompts = items
-      .filter(isRecord)
+      .filter(isRecordLike)
       .map((item) => (typeof item.prompt === 'string' ? item.prompt.trim() : ''))
       .filter((prompt) => prompt.length > 0)
     return prompts.length > 0 ? prompts.join('\n\n') : null

apps/sim/app/workspace/[workspaceId]/home/hooks/stream/turn-model.ts

@@ -1,4 +1,4 @@
-import { isRecordLike as isRecord } from '@sim/utils/object'
+import { isRecordLike } from '@sim/utils/object'
 import { resolveStreamToolOutcome } from '@/lib/copilot/chat/stream-tool-outcome'
 import {
   MothershipStreamV1CompletionStatus,
@@ -220,10 +220,10 @@ function rebindResolvedIntegrationCall(node: ToolNode, toolName: string): void {
 /**
  * Reads a wire event payload as a generic record. The payload is a wide
  * discriminated union; the reducer accesses fields uniformly, so this narrows
- * through the `unknown`-typed {@link isRecord} guard rather than a double cast.
+ * through the `unknown`-typed {@link isRecordLike} guard rather than a double cast.
  */
 function payloadRecord(payload: unknown): Record<string, unknown> {
-  return isRecord(payload) ? payload : {}
+  return isRecordLike(payload) ? payload : {}
 }
 
 /** Parses a wire `ts` to epoch ms, or undefined when absent/unparseable. */
@@ -523,15 +523,15 @@ export function reduceEvent(model: TurnModel, envelope: PersistedStreamEventEnve
           // back into an ordinary running row without waiting for the result.
           node.status = 'running'
         }
-        if (isRecord(payload.arguments)) node.args = payload.arguments
+        if (isRecordLike(payload.arguments)) node.args = payload.arguments
         // Only the snapshot-replay path (contentBlocksToModel) carries this
         // field — the live wire never does; it restores the rebound gateway
         // description across a preserve-state rebuild.
         const restoredDescription = asString(payload.integrationDescription)
         if (restoredDescription) node.integrationDescription = restoredDescription
         // Tool-call titles are derived from the tool name (+args) at serialize
         // time; the stream only carries behavioral flags now.
-        const ui = isRecord(payload.ui) ? payload.ui : undefined
+        const ui = isRecordLike(payload.ui) ? payload.ui : undefined
         if (ui?.hidden === true) node.hidden = true
       } else if (phase === MothershipStreamV1ToolPhase.args_delta) {
         const node = upsertToolNode(
@@ -559,7 +559,7 @@ export function reduceEvent(model: TurnModel, envelope: PersistedStreamEventEnve
     case MothershipStreamV1EventType.span: {
       const payload = envelope.payload
       if (payload.kind !== MothershipStreamV1SpanPayloadKind.subagent) break
-      const data = isRecord(payload.data) ? payload.data : undefined
+      const data = isRecordLike(payload.data) ? payload.data : undefined
       const triggerToolCallId =
         scope?.parentToolCallId ?? asString(data?.tool_call_id) ?? asString(data?.toolCallId)
       const agentId = asString(payload.agent) ?? scope?.agentId ?? ''
@@ -686,7 +686,7 @@ export function reduceEvent(model: TurnModel, envelope: PersistedStreamEventEnve
       const payload = payloadRecord(envelope.payload)
       // An async pause is not a turn terminal — the paused tools/subagents
       // legitimately stay open until a later resume leg completes them.
-      const response = isRecord(payload.response) ? payload.response : undefined
+      const response = isRecordLike(payload.response) ? payload.response : undefined
       if (response && 'async_pause' in response) break
       const status = payload.status
       if (status === MothershipStreamV1CompletionStatus.cancelled) {

apps/sim/app/workspace/[workspaceId]/w/[workflowId]/hooks/use-workflow-execution.ts

@@ -4,6 +4,7 @@ import { createLogger } from '@sim/logger'
 import { getErrorMessage, toError } from '@sim/utils/errors'
 import { sleep } from '@sim/utils/helpers'
 import { generateId } from '@sim/utils/id'
+import { isRecordLike } from '@sim/utils/object'
 import { useQueryClient } from '@tanstack/react-query'
 import { useParams } from 'next/navigation'
 import { useShallow } from 'zustand/react/shallow'
@@ -132,10 +133,6 @@ async function persistExecutionPointerProgress(
   await saveExecutionPointer({ workflowId, executionId, lastEventId })
 }
 
-function isRecord(value: unknown): value is Record<string, unknown> {
-  return typeof value === 'object' && value !== null
-}
-
 function isRecoverableStreamRecoveryError(
   error: unknown
 ): error is SSEEventHandlerError | SSEStreamInterruptedError {
@@ -158,12 +155,12 @@ function normalizeErrorMessage(error: unknown): string {
     if (message) return message
   }
 
-  if (isRecord(error)) {
+  if (isRecordLike(error)) {
     const directMessage = sanitizeMessage(error.message)
     if (directMessage) return directMessage
 
     const nestedError = error.error
-    if (isRecord(nestedError)) {
+    if (isRecordLike(nestedError)) {
       const nestedMessage = sanitizeMessage(nestedError.message)
       if (nestedMessage) return nestedMessage
     } else {
@@ -181,7 +178,7 @@ interface ChatWorkflowInput {
 }
 
 function isChatWorkflowInput(value: unknown): value is ChatWorkflowInput {
-  return isRecord(value) && 'input' in value
+  return isRecordLike(value) && 'input' in value
 }
 
 export interface ChatWorkflowRunResult {
@@ -199,7 +196,7 @@ export class WorkflowAttachmentUploadError extends Error {
 
 export function isChatWorkflowRunResult(value: unknown): value is ChatWorkflowRunResult {
   return (
-    isRecord(value) &&
+    isRecordLike(value) &&
     value.success === true &&
     value.stream instanceof ReadableStream &&
     Array.isArray(value.uploadedAttachments)
@@ -1688,10 +1685,11 @@ export function useWorkflowExecution() {
     }
 
     let notificationMessage = WORKFLOW_EXECUTION_FAILURE_MESSAGE
-    const requestError = isRecord(error) && isRecord(error.request) ? error.request : undefined
+    const requestError =
+      isRecordLike(error) && isRecordLike(error.request) ? error.request : undefined
     if (requestError && sanitizeMessage(requestError.url)) {
       notificationMessage += `: Request to ${(requestError.url as string).trim()} failed`
-      if (isRecord(error) && typeof error.status === 'number') {
+      if (isRecordLike(error) && typeof error.status === 'number') {
         notificationMessage += ` (Status: ${error.status})`
       }
     } else if (sanitizeMessage(errorResult.error)) {

apps/sim/ee/workspace-forking/lib/copy/cleanup-failed.ts

@@ -9,8 +9,9 @@ import {
 } from '@sim/db/schema'
 import { createLogger } from '@sim/logger'
 import { getErrorMessage } from '@sim/utils/errors'
+import { isRecordLike } from '@sim/utils/object'
 import { and, asc, eq, exists, gt, inArray, isNull, notExists, sql } from 'drizzle-orm'
-import { isRecord, type SubBlockRecord } from '@/lib/workflows/persistence/remap-internal-ids'
+import type { SubBlockRecord } from '@/lib/workflows/persistence/remap-internal-ids'
 import { invalidateDeployedStateCache } from '@/lib/workflows/persistence/utils'
 import {
   FORK_DOCUMENT_ID_PATTERN,
@@ -325,13 +326,13 @@ export function rewriteDeploymentVersionState(
   state: unknown,
   resolve: ForkCopyResolver
 ): { state: unknown; changed: boolean } {
-  if (!isRecord(state) || !isRecord(state.blocks)) return { state, changed: false }
+  if (!isRecordLike(state) || !isRecordLike(state.blocks)) return { state, changed: false }
 
   let nextBlocks: Record<string, unknown> | null = null
   for (const [blockId, block] of Object.entries(state.blocks)) {
-    if (!isRecord(block)) continue
+    if (!isRecordLike(block)) continue
     const blockType = typeof block.type === 'string' ? block.type : undefined
-    if (!blockType || !isRecord(block.subBlocks)) continue
+    if (!blockType || !isRecordLike(block.subBlocks)) continue
     const { subBlocks: cleared, changed } = clearFailedSubBlockReferences(
       block.subBlocks as SubBlockRecord,
       blockType,

apps/sim/ee/workspace-forking/lib/copy/copy-chats.ts

@@ -1,10 +1,10 @@
 import { chat } from '@sim/db/schema'
 import { createLogger } from '@sim/logger'
 import { generateId, generateShortId } from '@sim/utils/id'
+import { isRecordLike } from '@sim/utils/object'
 import { randomInt } from '@sim/utils/random'
 import { and, inArray, isNull } from 'drizzle-orm'
 import type { DbOrTx } from '@/lib/db/types'
-import { isRecord } from '@/lib/workflows/persistence/remap-internal-ids'
 
 const logger = createLogger('WorkspaceForkCopyChats')
 
@@ -47,7 +47,7 @@ function remapChatOutputConfigs(
 ): unknown {
   if (!Array.isArray(value)) return value
   return value.map((entry) => {
-    if (!isRecord(entry) || typeof entry.blockId !== 'string') return entry
+    if (!isRecordLike(entry) || typeof entry.blockId !== 'string') return entry
     return { ...entry, blockId: resolveBlockId(targetWorkflowId, entry.blockId) }
   })
 }

apps/sim/ee/workspace-forking/lib/copy/copy-resources.ts

@@ -20,7 +20,7 @@ import { createLogger } from '@sim/logger'
 import { sha256Hex } from '@sim/security/hash'
 import { getErrorMessage } from '@sim/utils/errors'
 import { generateId } from '@sim/utils/id'
-import { omit } from '@sim/utils/object'
+import { isRecordLike, omit } from '@sim/utils/object'
 import {
   and,
   asc,
@@ -71,7 +71,6 @@ import {
   recordKnowledgeBaseFileOwnership,
 } from '@/lib/uploads/server/metadata'
 import { MAX_FILE_SIZE } from '@/lib/uploads/utils/validation'
-import { isRecord } from '@/lib/workflows/persistence/remap-internal-ids'
 import {
   deleteCopiedResourceMappingsByTargets,
   type ForkMappingUpsert,
@@ -538,7 +537,7 @@ export async function copyForkResourceContainers(
     const inserts: (typeof mcpServers.$inferInsert)[] = []
     for (const row of rows) {
       const childId = generateId()
-      const headers = isRecord(row.headers)
+      const headers = isRecordLike(row.headers)
         ? Object.fromEntries(
             Object.entries(row.headers).map(([key, value]) => [
               key,
@@ -942,7 +941,7 @@ function remapTableRowResourceUrls(value: unknown, maps: ForkContentRefMaps): un
     })
     return changed ? next : value
   }
-  if (isRecord(value)) {
+  if (isRecordLike(value)) {
     let changed = false
     const next: Record<string, unknown> = {}
     for (const [key, item] of Object.entries(value)) {

apps/sim/ee/workspace-forking/lib/mapping/dependent-reconfigs.ts

@@ -1,5 +1,6 @@
+import { isRecordLike } from '@sim/utils/object'
 import type { ForkDependentReconfig, ForkResourceUsage } from '@/lib/api/contracts/workspace-fork'
-import { coerceObjectArray, isRecord } from '@/lib/workflows/persistence/remap-internal-ids'
+import { coerceObjectArray } from '@/lib/workflows/persistence/remap-internal-ids'
 import { getWorkflowSearchDependentClears } from '@/lib/workflows/search-replace/dependencies'
 import {
   buildSelectorContextFromBlock,
@@ -293,10 +294,10 @@ export function collectForkDependentReconfigs(
         if (!tools) continue
         for (let index = 0; index < tools.length; index++) {
           const tool = tools[index]
-          if (!isRecord(tool) || typeof tool.type !== 'string') continue
+          if (!isRecordLike(tool) || typeof tool.type !== 'string') continue
           const toolConfig = getBlock(tool.type)
           if (!toolConfig) continue
-          const toolParams = isRecord(tool.params) ? tool.params : {}
+          const toolParams = isRecordLike(tool.params) ? tool.params : {}
           // A tool's `operation` is stored at the tool level, not in params, but subblock
           // conditions reference it (e.g. a Gmail label only under `read_gmail`). Merge it
           // in so condition-gating matches the editor's `{ operation, ...params }`.

apps/sim/ee/workspace-forking/lib/promote/cleared-refs.ts

@@ -1,4 +1,5 @@
 import { mcpServers, workflow } from '@sim/db/schema'
+import { isRecordLike } from '@sim/utils/object'
 import { and, eq, inArray } from 'drizzle-orm'
 import type {
   ForkClearedRef,
@@ -8,7 +9,6 @@ import type {
 import type { DbOrTx } from '@/lib/db/types'
 import {
   coerceObjectArray,
-  isRecord,
   type SubBlockRecord,
 } from '@/lib/workflows/persistence/remap-internal-ids'
 import {
@@ -136,9 +136,9 @@ function collectForkWorkflowReferences(
       if (!array) continue
       for (const tool of array) {
         if (
-          isRecord(tool) &&
+          isRecordLike(tool) &&
           tool.type === 'workflow_input' &&
-          isRecord(tool.params) &&
+          isRecordLike(tool.params) &&
           typeof tool.params.workflowId === 'string' &&
           tool.params.workflowId
         ) {