mirror of
https://github.com/windmill-labs/windmill.git
synced 2026-09-07 08:02:40 +00:00
feat(frontend): wire WebsocketTrigger editor to UserDraft
Same pattern as the other triggers. Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
This commit is contained in:
co-authored by
Claude Opus 4.7
parent
dfc1651327
commit
b5ba3f2abb
@@ -42,6 +42,7 @@
|
||||
import TriggerRetriesAndErrorHandler from '../TriggerRetriesAndErrorHandler.svelte'
|
||||
import TriggerAdvancedBadges from '../TriggerAdvancedBadges.svelte'
|
||||
import { deepEqual } from 'fast-equals'
|
||||
import { UserDraft } from '$lib/userDraft.svelte'
|
||||
import TriggerSuspendedJobsAlert from '../TriggerSuspendedJobsAlert.svelte'
|
||||
import TriggerSuspendedJobsModal from '../TriggerSuspendedJobsModal.svelte'
|
||||
import { capitalize } from '$lib/utils'
|
||||
@@ -176,13 +177,17 @@
|
||||
dirtyPath = false
|
||||
dirtyUrl = false
|
||||
await loadTrigger(defaultConfig)
|
||||
originalConfig = structuredClone($state.snapshot(getSaveCfg()))
|
||||
} catch (err) {
|
||||
sendUserToast(`Could not load websocket trigger: ${err}`, true)
|
||||
} finally {
|
||||
if (!defaultConfig) {
|
||||
initialConfig = structuredClone($state.snapshot(getSaveCfg()))
|
||||
}
|
||||
originalConfig = structuredClone($state.snapshot(getSaveCfg()))
|
||||
const localCfg = UserDraft.get<Record<string, any>>('schedule_websocket', ePath)
|
||||
if (localCfg && !deepEqual(localCfg, getSaveCfg())) {
|
||||
loadTriggerConfig(localCfg)
|
||||
}
|
||||
} catch (err) {
|
||||
sendUserToast(`Could not load websocket trigger: ${err}`, true)
|
||||
} finally {
|
||||
clearTimeout(loadingTimeout)
|
||||
drawerLoading = false
|
||||
showLoading = false
|
||||
@@ -342,6 +347,7 @@
|
||||
|
||||
async function updateTrigger(): Promise<void> {
|
||||
deploymentLoading = true
|
||||
const previousPath = initialPath
|
||||
const saveCfg = getSaveCfg()
|
||||
const isSaved = await saveWebsocketTriggerFromCfg(
|
||||
initialPath,
|
||||
@@ -351,6 +357,7 @@
|
||||
usedTriggerKinds
|
||||
)
|
||||
if (isSaved) {
|
||||
UserDraft.remove('schedule_websocket', previousPath)
|
||||
onUpdate?.(saveCfg.path)
|
||||
originalConfig = structuredClone($state.snapshot(getSaveCfg()))
|
||||
initialPath = saveCfg.path
|
||||
@@ -405,6 +412,11 @@
|
||||
handleConfigChange(websocketCfg, initialConfig, saveDisabled, edit, onConfigChange)
|
||||
}
|
||||
})
|
||||
|
||||
$effect(() => {
|
||||
if (drawerLoading || !initialPath) return
|
||||
UserDraft.save('schedule_websocket', initialPath, websocketCfg)
|
||||
})
|
||||
</script>
|
||||
|
||||
{#if mode === 'suspended'}
|
||||
|
||||
Reference in New Issue
Block a user