fix(analytics): fix posthog in useCallback deps and fire block events for bulk operations

Author: waleedlatif1

apps/sim/app/workspace/[workspaceId]/home/home.tsx

@@ -30,6 +30,7 @@ export function Home({ chatId }: HomeProps = {}) {
   const router = useRouter()
   const { data: session } = useSession()
   const posthog = usePostHog()
+  const posthogRef = useRef(posthog)
   const [initialPrompt, setInitialPrompt] = useState('')
   const hasCheckedLandingStorageRef = useRef(false)
   const initialViewInputRef = useRef<HTMLDivElement>(null)
@@ -202,12 +203,16 @@ export function Home({ chatId }: HomeProps = {}) {
     return () => cancelAnimationFrame(id)
   }, [resources])
 
+  useEffect(() => {
+    posthogRef.current = posthog
+  }, [posthog])
+
   const handleSubmit = useCallback(
     (text: string, fileAttachments?: FileAttachmentForApi[], contexts?: ChatContext[]) => {
       const trimmed = text.trim()
       if (!trimmed && !(fileAttachments && fileAttachments.length > 0)) return
 
-      captureEvent(posthog, 'task_message_sent', {
+      captureEvent(posthogRef.current, 'task_message_sent', {
         has_attachments: !!(fileAttachments && fileAttachments.length > 0),
         has_contexts: !!(contexts && contexts.length > 0),
         is_new_task: !chatId,
@@ -219,7 +224,7 @@ export function Home({ chatId }: HomeProps = {}) {
 
       sendMessage(trimmed || 'Analyze the attached file(s).', fileAttachments, contexts)
     },
-    [sendMessage, posthog]
+    [sendMessage]
   )
 
   useEffect(() => {

apps/sim/stores/workflows/workflow/store.ts

@@ -316,17 +316,15 @@ export const useWorkflowStore = create<WorkflowStore>()(
           }
         }
 
-        if (blocks.length === 1) {
-          const workflowId = get().currentWorkflowId ?? 'unknown'
-          import('@/lib/posthog/client')
-            .then(({ captureClientEvent }) => {
-              captureClientEvent('block_added', {
-                block_type: blocks[0].type,
-                workflow_id: workflowId,
-              })
-            })
-            .catch(() => {})
-        }
+        const workflowId = get().currentWorkflowId ?? 'unknown'
+        const uniqueBlockTypes = [...new Set(blocks.map((b) => b.type))]
+        import('@/lib/posthog/client')
+          .then(({ captureClientEvent }) => {
+            for (const blockType of uniqueBlockTypes) {
+              captureClientEvent('block_added', { block_type: blockType, workflow_id: workflowId })
+            }
+          })
+          .catch(() => {})
 
         get().updateLastSaved()
       },
@@ -387,19 +385,21 @@ export const useWorkflowStore = create<WorkflowStore>()(
           parallels: generateParallelBlocks(newBlocks),
         })
 
-        if (ids.length === 1) {
-          const blockType = currentBlocks[ids[0]]?.type
-          if (blockType) {
-            const workflowId = get().currentWorkflowId ?? 'unknown'
-            import('@/lib/posthog/client')
-              .then(({ captureClientEvent }) => {
+        const workflowId = get().currentWorkflowId ?? 'unknown'
+        const uniqueRemovedTypes = [
+          ...new Set(ids.map((id) => currentBlocks[id]?.type).filter((t): t is string => !!t)),
+        ]
+        if (uniqueRemovedTypes.length > 0) {
+          import('@/lib/posthog/client')
+            .then(({ captureClientEvent }) => {
+              for (const blockType of uniqueRemovedTypes) {
                 captureClientEvent('block_removed', {
                   block_type: blockType,
                   workflow_id: workflowId,
                 })
-              })
-              .catch(() => {})
-          }
+              }
+            })
+            .catch(() => {})
         }
 
         get().updateLastSaved()