* Reapply "Add ping pong health, remove a timeout interval, fix up netwo… (#1771)
This reverts commit 1913519f68
.
* Fix build errors
* Add new error states to network status notification
* Remove unused variable
* Refactor to use Context API for network status
* Don't do any stream events if network is not ok
* Catch LSP errors on bad auth
* Show when authentication is bad (cookie header only)
* Fix formatting
* Fix up types
* Revert awaiting on lsp failure
* Fix tsc
* wip
* wip
* fmt
* Fix typing
* Incorporate ping health; yarn make:dev; faster video stream loss notice
* A snapshot a day keeps the bugs away! 📷🐛 (OS: ubuntu)
* run ci pls
* run ci pls
* A snapshot a day keeps the bugs away! 📷🐛 (OS: ubuntu)
* run ci pls again
* Remove unused variables
* Add new instructions on running Playwright anywhere
* Please the Playwright. Praise the Playwright.
* Correct a vitest
* A snapshot a day keeps the bugs away! 📷🐛 (OS: ubuntu)
* ci again
* Fix tests unrelated to this PR
* Fix flakiness in for segments tests
* Bump to 2 workers
* fmt
* A snapshot a day keeps the bugs away! 📷🐛 (OS: ubuntu)
* fmt
* fmt
* Fixups
* A snapshot a day keeps the bugs away! 📷🐛 (OS: ubuntu)
* ci
* Set workers to 1
* Wait for network status listeners before connecting
* Fix initial connection requirements and trying 2 workers again
---------
Co-authored-by: github-actions[bot] <github-actions[bot]@users.noreply.github.com>
86 lines
2.6 KiB
TypeScript
86 lines
2.6 KiB
TypeScript
import { useEffect } from 'react'
|
|
import { AnyStateMachine, InterpreterFrom, StateFrom } from 'xstate'
|
|
import { createMachineCommand } from '../lib/createMachineCommand'
|
|
import { useCommandsContext } from './useCommandsContext'
|
|
import { modelingMachine } from 'machines/modelingMachine'
|
|
import { authMachine } from 'machines/authMachine'
|
|
import { settingsMachine } from 'machines/settingsMachine'
|
|
import { homeMachine } from 'machines/homeMachine'
|
|
import { Command, CommandSetConfig, CommandSetSchema } from 'lib/commandTypes'
|
|
import { useKclContext } from 'lang/KclProvider'
|
|
import { useStore } from 'useStore'
|
|
import { useNetworkContext } from 'hooks/useNetworkContext'
|
|
import { NetworkHealthState } from 'hooks/useNetworkStatus'
|
|
|
|
// This might not be necessary, AnyStateMachine from xstate is working
|
|
export type AllMachines =
|
|
| typeof modelingMachine
|
|
| typeof settingsMachine
|
|
| typeof authMachine
|
|
| typeof homeMachine
|
|
|
|
interface UseStateMachineCommandsArgs<
|
|
T extends AllMachines,
|
|
S extends CommandSetSchema<T>
|
|
> {
|
|
machineId: T['id']
|
|
state: StateFrom<T>
|
|
send: Function
|
|
actor: InterpreterFrom<T>
|
|
commandBarConfig?: CommandSetConfig<T, S>
|
|
allCommandsRequireNetwork?: boolean
|
|
onCancel?: () => void
|
|
}
|
|
|
|
export default function useStateMachineCommands<
|
|
T extends AnyStateMachine,
|
|
S extends CommandSetSchema<T>
|
|
>({
|
|
machineId,
|
|
state,
|
|
send,
|
|
actor,
|
|
commandBarConfig,
|
|
allCommandsRequireNetwork = false,
|
|
onCancel,
|
|
}: UseStateMachineCommandsArgs<T, S>) {
|
|
const { commandBarSend } = useCommandsContext()
|
|
const { overallState } = useNetworkContext()
|
|
const { isExecuting } = useKclContext()
|
|
const { isStreamReady } = useStore((s) => ({
|
|
isStreamReady: s.isStreamReady,
|
|
}))
|
|
|
|
useEffect(() => {
|
|
const disableAllButtons =
|
|
(overallState !== NetworkHealthState.Ok &&
|
|
overallState !== NetworkHealthState.Weak) ||
|
|
isExecuting ||
|
|
!isStreamReady
|
|
const newCommands = state.nextEvents
|
|
.filter((_) => !allCommandsRequireNetwork || !disableAllButtons)
|
|
.filter((e) => !['done.', 'error.'].some((n) => e.includes(n)))
|
|
.map((type) =>
|
|
createMachineCommand<T, S>({
|
|
ownerMachine: machineId,
|
|
type,
|
|
state,
|
|
send,
|
|
actor,
|
|
commandBarConfig,
|
|
onCancel,
|
|
})
|
|
)
|
|
.filter((c) => c !== null) as Command[] // TS isn't smart enough to know this filter removes nulls
|
|
|
|
commandBarSend({ type: 'Add commands', data: { commands: newCommands } })
|
|
|
|
return () => {
|
|
commandBarSend({
|
|
type: 'Remove commands',
|
|
data: { commands: newCommands },
|
|
})
|
|
}
|
|
}, [state, overallState, isExecuting, isStreamReady])
|
|
}
|