global reset event

Author: alex-abanin

apps/chaingraph-frontend/src/providers/RootProvider.tsx

@@ -91,7 +91,8 @@ export function RootProvider({
     }
 
     return () => {
-      reset()
+      if (isInitializedRef.current)
+        reset()
     }
   }, [nodeRegistry, sessionToken, superjsonCustom, trpcURL])
 

apps/chaingraph-frontend/src/store/categories/stores.ts

@@ -10,6 +10,7 @@ import type { CategorizedNodes, CategoryMetadata } from '@badaitech/chaingraph-t
 import type { FetchCategoriesError } from './types'
 import { NODE_CATEGORIES } from '@badaitech/chaingraph-nodes'
 import { combine } from 'effector'
+import { globalReset } from '../common'
 import { categoriesDomain } from '../domains'
 import { $trpcClient } from '../trpc/store'
 
@@ -29,6 +30,7 @@ export const fetchCategorizedNodesFx = categoriesDomain.createEffect(() => {
 const $categorizedNodes = categoriesDomain.createStore<CategorizedNodes[]>([])
   .on(fetchCategorizedNodesFx.doneData, (_, nodes) => nodes)
   .reset(resetCategories)
+  .reset(globalReset)
 
 export const $categoryMetadata = categoriesDomain.createStore<Map<string, CategoryMetadata>>(new Map())
   .on(fetchCategorizedNodesFx.doneData, (_, nodes) => {
@@ -39,6 +41,7 @@ export const $categoryMetadata = categoriesDomain.createStore<Map<string, Catego
     return map
   })
   .reset(resetCategories)
+  .reset(globalReset)
 
 const $isLoading = fetchCategorizedNodesFx.pending
 
@@ -48,6 +51,7 @@ const $error = categoriesDomain.createStore<FetchCategoriesError | null>(null)
     timestamp: new Date(),
   }))
   .reset(fetchCategorizedNodesFx.doneData)
+  .reset(globalReset)
 
 // Computed stores
 export const $categoriesState = combine({

apps/chaingraph-frontend/src/store/common.ts

@@ -0,0 +1,11 @@
+/*
+ * Copyright (c) 2025 BadLabs
+ *
+ * Use of this software is governed by the Business Source License 1.1 included in the file LICENSE.txt.
+ *
+ * As of the Change Date specified in that file, in accordance with the Business Source License, use of this software will be governed by the Apache License, version 2.0.
+ */
+
+import { createEvent } from 'effector'
+
+export const globalReset = createEvent()

apps/chaingraph-frontend/src/store/edges/stores.ts

@@ -11,6 +11,7 @@ import type { Edge } from '@xyflow/react'
 import type { AddEdgeEventData, EdgeData, RemoveEdgeEventData } from './types'
 import { edgesDomain } from '@/store/domains'
 import { attach, combine, sample } from 'effector'
+import { globalReset } from '../common'
 import { $executionNodes, $executionState, $highlightedEdgeId, $highlightedNodeId } from '../execution'
 import { $xyflowNodes } from '../nodes'
 import { $trpcClient } from '../trpc/store'
@@ -71,6 +72,7 @@ export const $edges = edgesDomain.createStore<EdgeData[]>([])
     edge => edge.edgeId !== event.edgeId,
   ))
   .reset(resetEdges)
+  .reset(globalReset)
   // .reset(clearActiveFlow)
 
 /**

apps/chaingraph-frontend/src/store/execution/stores.ts

@@ -17,6 +17,7 @@ import type {
 } from './types'
 import { ExecutionEventEnum } from '@badaitech/chaingraph-types'
 import { attach, combine, sample } from 'effector'
+import { globalReset } from '../common'
 import { executionDomain } from '../domains'
 import { $trpcClient } from '../trpc/store'
 import { ExecutionStatus, ExecutionSubscriptionStatus, isTerminalStatus } from './types'
@@ -67,7 +68,7 @@ const initialState: ExecutionState = {
   },
 }
 
-export const $executionState = executionDomain.createStore<ExecutionState>(initialState)
+export const $executionState = executionDomain.createStore<ExecutionState>(initialState).reset(globalReset)
 
 // Control effects
 export const createExecutionFx = executionDomain.createEffect(async (payload: CreateExecutionOptions) => {
@@ -185,6 +186,7 @@ export const $executionEvents = executionDomain.createStore<ExecutionEventImpl[]
   .reset(clearExecutionState)
   .reset(stopExecutionFx.done)
   .reset(createExecutionFx.doneData)
+  .reset(globalReset)
 
 export const $executionNodes = executionDomain.createStore<Record<string, NodeExecutionState>>({}, {
   updateFilter: (prev, next) => {
@@ -307,6 +309,7 @@ export const $executionNodes = executionDomain.createStore<Record<string, NodeEx
   .reset(clearExecutionState)
   .reset(stopExecutionFx.done)
   .reset(createExecutionFx.doneData)
+  .reset(globalReset)
 
 export const $executionEdges = executionDomain.createStore<Record<string, EdgeExecutionState>>({})
   .on(newExecutionEvent, (state, event) => {
@@ -365,6 +368,7 @@ export const $executionEdges = executionDomain.createStore<Record<string, EdgeEx
   .reset(clearExecutionState)
   .reset(stopExecutionFx.done)
   .reset(createExecutionFx.doneData)
+  .reset(globalReset)
 
 // Handle execution status changes
 $executionState
@@ -521,12 +525,14 @@ export const $highlightedNodeId = executionDomain.createStore<string[] | null>(n
     typeof highlightedNodeId === 'string'
       ? [highlightedNodeId]
       : highlightedNodeId)
+  .reset(globalReset)
 
 export const $highlightedEdgeId = executionDomain.createStore<string[] | null>(null)
   .on(setHighlightedEdgeId, (state, highlightedEdgeId) =>
     typeof highlightedEdgeId === 'string'
       ? [highlightedEdgeId]
       : highlightedEdgeId)
+  .reset(globalReset)
 
 // Computed stores
 export const $isExecuting = $executionState.map(
@@ -578,7 +584,7 @@ export const $autoStartConditions = combine({
 })
 
 // Store to prevent multiple start attempts
-export const $startAttempted = executionDomain.createStore(false)
+export const $startAttempted = executionDomain.createStore(false).reset(globalReset)
 
 // export const $highlightedNodeId = $executionState.map(state => state.ui.highlightedNodeId)
 // export const $highlightedEdgeId = $executionState.map(state => state.ui.highlightedEdgeId)

apps/chaingraph-frontend/src/store/flow/stores.ts

@@ -10,6 +10,7 @@ import type { FlowMetadata } from '@badaitech/chaingraph-types'
 import type { CreateFlowEvent, FlowSubscriptionError, UpdateFlowEvent } from './types'
 import { flowDomain } from '@/store/domains'
 import { combine, sample } from 'effector'
+import { globalReset } from '../common'
 import { $trpcClient } from '../trpc/store'
 import { FlowSubscriptionStatus } from './types'
 
@@ -118,45 +119,55 @@ export const $flows = flowDomain.createStore<FlowMetadata[]>([])
   })
   .on(deleteFlow, (flows, id) =>
     flows.filter(f => f.id !== id))
+  .reset(globalReset)
 
 // Currently active flow ID
 export const $activeFlowId = flowDomain.createStore<string | null>(null)
   .on(setActiveFlowId, (_, id) => id)
   .reset(clearActiveFlow)
+  .reset(globalReset)
 
 // Main loading state
 export const $isFlowsLoading = flowDomain.createStore<boolean>(false)
   .on(setFlowsLoading, (_, isLoading) => isLoading)
   .on(loadFlowsListFx.pending, (_, isPending) => isPending)
+  .reset(globalReset)
 
 // Main error state
 export const $flowsError = flowDomain.createStore<Error | null>(null)
   .on(setFlowsError, (_, error) => error)
   .on(loadFlowsListFx.failData, (_, error) => error)
   .reset(loadFlowsListFx.done)
+  .reset(globalReset)
 
 // Specific operation error stores
 export const $createFlowError = flowDomain.createStore<Error | null>(null)
   .on(createFlowFx.failData, (_, error) => error)
   .reset(createFlowFx.done)
+  .reset(globalReset)
 
 export const $updateFlowError = flowDomain.createStore<Error | null>(null)
   .on(editFlowFx.failData, (_, error) => error)
   .reset(editFlowFx.done)
+  .reset(globalReset)
 
 export const $deleteFlowError = flowDomain.createStore<Error | null>(null)
   .on(deleteFlowFx.failData, (_, error) => error)
   .reset(deleteFlowFx.done)
+  .reset(globalReset)
 
 // Specific operation loading states
 export const $isCreatingFlow = flowDomain.createStore<boolean>(false)
   .on(createFlowFx.pending, (_, isPending) => isPending)
+  .reset(globalReset)
 
 export const $isUpdatingFlow = flowDomain.createStore<boolean>(false)
   .on(editFlowFx.pending, (_, isPending) => isPending)
+  .reset(globalReset)
 
 export const $isDeletingFlow = flowDomain.createStore<boolean>(false)
   .on(deleteFlowFx.pending, (_, isPending) => isPending)
+  .reset(globalReset)
 
 // Combined error store
 export const $allFlowsErrors = combine(
@@ -180,9 +191,13 @@ export const $activeFlowMetadata = combine(
 // Subscription related stores
 export const $flowSubscriptionStatus = flowDomain.createStore<FlowSubscriptionStatus>(
   FlowSubscriptionStatus.IDLE,
-).on(setFlowSubscriptionStatus, (_, status) => status).reset(resetFlowSubscription).reset(clearActiveFlow)
+).on(setFlowSubscriptionStatus, (_, status) => status).reset(resetFlowSubscription).reset(clearActiveFlow).reset(globalReset)
 
-export const $flowSubscriptionError = flowDomain.createStore<FlowSubscriptionError | null>(null).on(setFlowSubscriptionError, (_, error) => error).reset(resetFlowSubscription).reset(clearActiveFlow)
+export const $flowSubscriptionError = flowDomain.createStore<FlowSubscriptionError | null>(null)
+  .on(setFlowSubscriptionError, (_, error) => error)
+  .reset(resetFlowSubscription)
+  .reset(clearActiveFlow)
+  .reset(globalReset)
 
 // Derived store to check if subscription is active
 export const $isFlowSubscribed = $flowSubscriptionStatus.map(

apps/chaingraph-frontend/src/store/init.ts

@@ -7,11 +7,10 @@
  */
 
 import type { CategorizedNodes, FlowMetadata } from '@badaitech/chaingraph-types'
-import { fetchCategorizedNodesFx, resetCategories } from './categories'
-import { resetEdges } from './edges'
-import { clearExecutionState } from './execution'
-import { clearActiveFlow, loadFlowsListFx, setFlowsList } from './flow'
-import { clearNodes, initInterpolatorFx } from './nodes'
+import { fetchCategorizedNodesFx } from './categories'
+import { globalReset } from './common'
+import { loadFlowsListFx } from './flow'
+import { initInterpolatorFx } from './nodes'
 
 /**
  * Initialize all stores and load initial data
@@ -43,10 +42,5 @@ export async function initializeStores(callback?: (
 }
 
 export function reset() {
-  resetCategories()
-  clearNodes()
-  resetEdges()
-  clearActiveFlow()
-  setFlowsList([])
-  clearExecutionState()
+  globalReset()
 }

apps/chaingraph-frontend/src/store/nodes/stores.ts

@@ -14,6 +14,7 @@ import { DefaultPosition } from '@badaitech/chaingraph-types'
 
 import { combine, sample } from 'effector'
 import { $categoryMetadata } from '../categories'
+import { globalReset } from '../common'
 import { nodesDomain } from '../domains'
 import { updatePort, updatePortUI, updatePortValue } from '../ports'
 import { $trpcClient } from '../trpc/store'
@@ -294,6 +295,7 @@ export const $nodes = nodesDomain.createStore<Record<string, INode>>({})
 
     return { ...state, [nodeId]: updatedNode }
   })
+  .reset(globalReset)
 
 /**
  * Enhanced store for XYFlow nodes that preserves node references when only positions change.
@@ -480,15 +482,18 @@ export const $isNodesLoading = nodesDomain.createStore(false)
   .on(setNodesLoading, (_, isLoading) => isLoading)
   .on(addNodeToFlowFx.pending, (_, isPending) => isPending)
   .on(removeNodeFromFlowFx.pending, (_, isPending) => isPending)
+  .reset(globalReset)
 
 // Error states
 export const $addNodeError = nodesDomain.createStore<Error | null>(null)
   .on(addNodeToFlowFx.failData, (_, error) => error)
   .reset(addNodeToFlowFx.done)
+  .reset(globalReset)
 
 export const $removeNodeError = nodesDomain.createStore<Error | null>(null)
   .on(removeNodeFromFlowFx.failData, (_, error) => error)
   .reset(removeNodeFromFlowFx.done)
+  .reset(globalReset)
 
 // Combined error store
 export const $nodesError = combine(