v0.8.2: rabbitmq, code hygiene, new kb connectors

Author: waleedlatif1

apps/desktop/src/main/browser-agent/driver.ts

@@ -29,7 +29,7 @@ import type { BrowserDownloadsState, BrowserToolbarCommand } from '@sim/desktop-
 import { createLogger } from '@sim/logger'
 import { getErrorMessage } from '@sim/utils/errors'
 import { sleep } from '@sim/utils/helpers'
-import { isRecordLike, omit } from '@sim/utils/object'
+import { isRecordLike, omit, toRecord } from '@sim/utils/object'
 import type { BrowserWindow, MenuItemConstructorOptions, WebContents, WebFrameMain } from 'electron'
 import { Menu } from 'electron'
 import * as cdp from '@/main/browser-agent/cdp'
@@ -1015,7 +1015,7 @@ function raceAgainstWatchdog<T>(
  */
 async function activeElementState(target: PageExecutionTarget): Promise<Record<string, unknown>> {
   const state = await execInPage(target, readActiveElementState, []).catch(() => null)
-  return isRecordLike(state) ? state : {}
+  return toRecord(state)
 }
 
 function requireSnapshotForElementAction(): void {
@@ -1191,7 +1191,7 @@ async function pageActionState(
     resetMutationRevision,
     elementId,
   ]).catch(() => null)
-  return isRecordLike(state) ? state : {}
+  return toRecord(state)
 }
 
 function pageEffect(
@@ -2565,7 +2565,7 @@ async function executeToolInner(
           },
         }
         return {
-          ...(isRecordLike(fallback) ? fallback : {}),
+          ...fallback,
           trusted,
           ...state,
           ...combinedObservation,
@@ -2849,12 +2849,11 @@ async function executeToolInner(
       await sleep(50)
       const state = unwrapPageResult(await execInPage(target, readSelectElementState, [elementId]))
       const effectObserved =
-        isRecordLike(selected) &&
         isRecordLike(state) &&
         selected.selected === state.selected &&
         selected.value === state.value
       return {
-        ...(isRecordLike(selected) ? selected : {}),
+        ...selected,
         effectObserved,
         readback: state,
         ...(!effectObserved
@@ -2994,7 +2993,7 @@ async function executeToolInner(
           : {}),
       }
       return {
-        ...(isRecordLike(result) ? result : {}),
+        ...result,
         trusted,
         effect,
         possibleEffectObserved,

apps/desktop/src/main/browser-import/browser-sources.ts

@@ -77,23 +77,6 @@ export function userDataDirFor(source: BrowserSource, home: string = homedir()):
   return join(home, ...source.userDataSegments)
 }
 
-/**
- * Splits a bridge profile id back into its browser and profile directory.
- *
- * Ids are namespaced (`arc:Profile 1`) because profile directory names repeat
- * across browsers — every one of them has a `Default`. Returns null for
- * anything malformed; the caller then resolves against discovered profiles
- * anyway, so a bad id can never become a path.
- */
-export function parseProfileId(profileId: string): { sourceId: string; directory: string } | null {
-  const separator = profileId.indexOf(':')
-  if (separator <= 0 || separator === profileId.length - 1) return null
-  return {
-    sourceId: profileId.slice(0, separator),
-    directory: profileId.slice(separator + 1),
-  }
-}
-
 export function formatProfileId(sourceId: string, directory: string): string {
   return `${sourceId}:${directory}`
 }

apps/desktop/src/main/browser-import/chromium-profiles.ts

@@ -2,6 +2,7 @@ import { constants } from 'node:fs'
 import { access, lstat, readdir, readFile, realpath } from 'node:fs/promises'
 import { homedir } from 'node:os'
 import { join } from 'node:path'
+import { isRecordLike } from '@sim/utils/object'
 import {
   BROWSER_SOURCES,
   type BrowserSource,
@@ -134,7 +135,7 @@ async function readProfileDisplayNames(userDataDir: string): Promise<Map<string,
     const raw = await readFile(join(userDataDir, 'Local State'), 'utf8')
     const infoCache = (JSON.parse(raw) as { profile?: { info_cache?: unknown } }).profile
       ?.info_cache
-    if (infoCache && typeof infoCache === 'object' && !Array.isArray(infoCache)) {
+    if (isRecordLike(infoCache)) {
       for (const [dir, info] of Object.entries(infoCache as Record<string, unknown>)) {
         if (!PROFILE_DIR_PATTERN.test(dir)) continue
         const name = (info as { name?: unknown })?.name

apps/desktop/src/main/terminal/index.ts

@@ -32,7 +32,6 @@ import {
   type TerminalToolResponse,
 } from '@sim/terminal-protocol'
 import { sleep } from '@sim/utils/helpers'
-import { isRecordLike } from '@sim/utils/object'
 import type { BrowserWindow, WebContents } from 'electron'
 import {
   type FocusedResourceShortcut,
@@ -1201,8 +1200,3 @@ export class TerminalService {
 function unknownTerminal(terminalId: string): string {
   return `No terminal with id ${terminalId}. Call terminal_list for the open ones.`
 }
-
-/** Narrows an IPC payload to the tool-call shape without trusting the sender. */
-export function parseToolParams(value: unknown): Record<string, unknown> {
-  return isRecordLike(value) ? value : {}
-}

apps/docs/components/icons.tsx

@@ -3898,6 +3898,138 @@ export const ClaudeIcon = (props: SVGProps<SVGSVGElement>) => (
   </svg>
 )
 
+export function AzureDataExplorerIcon(props: SVGProps<SVGSVGElement>) {
+  const id = useId()
+  const wedgeGradient = `adx_wedge_${id}`
+  const dashLongGradient = `adx_dash_long_${id}`
+  const dashTopGradient = `adx_dash_top_${id}`
+  const dashBottomGradient = `adx_dash_bottom_${id}`
+
+  return (
+    <svg
+      {...props}
+      width='18'
+      height='18'
+      viewBox='0 0 18 18'
+      fill='none'
+      xmlns='http://www.w3.org/2000/svg'
+    >
+      <path
+        d='M1.47,1.47,16.53,16.53a.57.57,0,0,0,1-.4V1.07A.57.57,0,0,0,16.93.5H1.87A.57.57,0,0,0,1.47,1.47Z'
+        fill={`url(#${wedgeGradient})`}
+      />
+      <path d='M5.53,5.53l6.94,6.94,5-5V1.07A.57.57,0,0,0,16.93.5H10.56Z' fill='#50e6ff' />
+      <rect
+        x='-0.38'
+        y='12.85'
+        width='9.37'
+        height='1.7'
+        rx='0.27'
+        transform='translate(-8.43 7.06) rotate(-45)'
+        fill={`url(#${dashLongGradient})`}
+      />
+      <rect
+        x='0.12'
+        y='9.23'
+        width='5.99'
+        height='1.7'
+        rx='0.27'
+        transform='translate(-6.22 5.15) rotate(-45)'
+        fill={`url(#${dashTopGradient})`}
+      />
+      <rect
+        x='4.89'
+        y='14.04'
+        width='5.99'
+        height='1.7'
+        rx='0.27'
+        transform='translate(-8.22 9.93) rotate(-45)'
+        fill={`url(#${dashBottomGradient})`}
+      />
+      <rect
+        x='9.19'
+        y='4.75'
+        width='1.7'
+        height='1.7'
+        rx='0.38'
+        transform='translate(-1.02 8.74) rotate(-45)'
+        fill='#fff'
+      />
+      <rect
+        x='11.59'
+        y='2.35'
+        width='1.7'
+        height='1.7'
+        rx='0.38'
+        transform='translate(1.38 9.73) rotate(-45)'
+        fill='#fff'
+      />
+      <rect
+        x='11.59'
+        y='7.15'
+        width='1.7'
+        height='1.7'
+        rx='0.38'
+        transform='translate(-2.01 11.14) rotate(-45)'
+        fill='#fff'
+      />
+      <path
+        d='M13.91,5.33l.66-.66a.38.38,0,0,1,.54,0l.66.66a.38.38,0,0,1,0,.54l-.66.66a.38.38,0,0,1-.54,0l-.66-.66a.38.38,0,0,1,0-.54'
+        fill='#fff'
+      />
+      <defs>
+        <linearGradient
+          id={wedgeGradient}
+          x1='1.3'
+          y1='8.6'
+          x2='17.5'
+          y2='8.6'
+          gradientUnits='userSpaceOnUse'
+        >
+          <stop offset='0.1' stopColor='#54aef0' />
+          <stop offset='1' stopColor='#1988d9' />
+        </linearGradient>
+        <linearGradient
+          id={dashLongGradient}
+          x1='0.5'
+          y1='13.7'
+          x2='8.11'
+          y2='13.7'
+          gradientTransform='translate(10.95 0.97) rotate(45)'
+          gradientUnits='userSpaceOnUse'
+        >
+          <stop offset='0' stopColor='#b3b2b3' />
+          <stop offset='1' stopColor='#979797' />
+        </linearGradient>
+        <linearGradient
+          id={dashTopGradient}
+          x1='0.5'
+          y1='10.08'
+          x2='5.72'
+          y2='10.08'
+          gradientTransform='translate(8.04 0.75) rotate(45)'
+          gradientUnits='userSpaceOnUse'
+        >
+          <stop offset='0' stopColor='#b3b2b3' />
+          <stop offset='1' stopColor='#979797' />
+        </linearGradient>
+        <linearGradient
+          id={dashBottomGradient}
+          x1='5.28'
+          y1='14.89'
+          x2='10.49'
+          y2='14.89'
+          gradientTransform='translate(12.84 -1.21) rotate(45)'
+          gradientUnits='userSpaceOnUse'
+        >
+          <stop offset='0' stopColor='#b3b2b3' />
+          <stop offset='1' stopColor='#979797' />
+        </linearGradient>
+      </defs>
+    </svg>
+  )
+}
+
 export function AzureIcon(props: SVGProps<SVGSVGElement>) {
   const id = useId()
   const gradient0 = `azure_paint0_${id}`
@@ -7406,26 +7538,6 @@ export function BedrockIcon(props: SVGProps<SVGSVGElement>) {
   )
 }
 
-export function TableIcon(props: SVGProps<SVGSVGElement>) {
-  return (
-    <svg
-      xmlns='http://www.w3.org/2000/svg'
-      viewBox='0 0 24 24'
-      fill='none'
-      stroke='currentColor'
-      strokeWidth={2}
-      strokeLinecap='round'
-      strokeLinejoin='round'
-      {...props}
-    >
-      <rect width='18' height='18' x='3' y='3' rx='2' />
-      <path d='M3 9h18' />
-      <path d='M3 15h18' />
-      <path d='M9 3v18' />
-      <path d='M15 3v18' />
-    </svg>
-  )
-}
 export function ReductoIcon(props: SVGProps<SVGSVGElement>) {
   return (
     <svg
@@ -8578,6 +8690,22 @@ export function HexIcon(props: SVGProps<SVGSVGElement>) {
   )
 }
 
+export function RabbitmqIcon(props: SVGProps<SVGSVGElement>) {
+  return (
+    <svg
+      {...props}
+      viewBox='-7.5 0 271 271'
+      preserveAspectRatio='xMidYMid'
+      xmlns='http://www.w3.org/2000/svg'
+    >
+      <path
+        d='M245.44 108.308h-85.09a7.738 7.738 0 0 1-7.735-7.734v-88.68C152.615 5.327 147.29 0 140.726 0h-30.375c-6.568 0-11.89 5.327-11.89 11.894v88.143c0 4.573-3.697 8.29-8.27 8.31l-27.885.133c-4.612.025-8.359-3.717-8.35-8.325l.173-88.241C54.144 5.337 48.817 0 42.24 0H11.89C5.321 0 0 5.327 0 11.894V260.21c0 5.834 4.726 10.56 10.555 10.56H245.44c5.834 0 10.56-4.726 10.56-10.56V118.868c0-5.834-4.726-10.56-10.56-10.56zm-39.902 93.233c0 7.645-6.198 13.844-13.843 13.844H167.69c-7.646 0-13.844-6.199-13.844-13.844v-24.005c0-7.646 6.198-13.844 13.844-13.844h24.005c7.645 0 13.843 6.198 13.843 13.844v24.005z'
+        fill='#F60'
+      />
+    </svg>
+  )
+}
+
 export function RailwayIcon(props: SVGProps<SVGSVGElement>) {
   return (
     <svg {...props} xmlns='http://www.w3.org/2000/svg' fill='currentColor' viewBox='0 0 24 24'>

apps/docs/components/ui/icon-mapping.ts

@@ -3,7 +3,7 @@
 // Maps block types to their icon component references
 
 import type { ComponentType, SVGProps } from 'react'
-import { Library, Rocket } from '@sim/emcn/icons'
+import { Library, Rocket, Table } from '@sim/emcn/icons'
 import {
   A2AIcon,
   AgentMailIcon,
@@ -22,6 +22,7 @@ import {
   AshbyIcon,
   AthenaIcon,
   AttioIcon,
+  AzureDataExplorerIcon,
   AzureIcon,
   BoxCompanyIcon,
   BrainIcon,
@@ -182,6 +183,7 @@ import {
   QdrantIcon,
   QuartrIcon,
   QuiverIcon,
+  RabbitmqIcon,
   RailwayIcon,
   RB2BIcon,
   RDSIcon,
@@ -223,7 +225,6 @@ import {
   StagehandIcon,
   StripeIcon,
   SupabaseIcon,
-  TableIcon,
   TailscaleIcon,
   TavilyIcon,
   TelegramIcon,
@@ -280,6 +281,7 @@ export const blockTypeToIconMap: Record<string, IconComponent> = {
   ashby: AshbyIcon,
   athena: AthenaIcon,
   attio: AttioIcon,
+  azure_data_explorer: AzureDataExplorerIcon,
   azure_devops: AzureIcon,
   box: BoxCompanyIcon,
   brandfetch: BrandfetchIcon,
@@ -469,6 +471,7 @@ export const blockTypeToIconMap: Record<string, IconComponent> = {
   qdrant: QdrantIcon,
   quartr: QuartrIcon,
   quiver: QuiverIcon,
+  rabbitmq: RabbitmqIcon,
   railway: RailwayIcon,
   rb2b: RB2BIcon,
   rds: RDSIcon,
@@ -514,7 +517,7 @@ export const blockTypeToIconMap: Record<string, IconComponent> = {
   stt: STTIcon,
   stt_v2: STTIcon,
   supabase: SupabaseIcon,
-  table: TableIcon,
+  table: Table,
   tailscale: TailscaleIcon,
   tavily: TavilyIcon,
   telegram: TelegramIcon,