Troubleshoot button

Author: krystian-panek-vmltech

core/src/main/java/dev/vml/es/acm/core/script/ScriptScheduler.java

@@ -163,19 +163,8 @@ public void onChange(List<ResourceChange> changes) {
  @Override
  public void onEvent(Event event) {
  EventType eventType = EventType.of(event.getName()).orElse(null);
- if (eventType == null) {
- return;
- }
- switch (eventType) {
- case SCRIPT_SCHEDULER_BOOT:
- bootOnDemand();
- break;
- case EXECUTOR_RESET:
- reset();
- break;
- default:
- // ignore else
- break;
+ if (eventType == EventType.SCRIPT_SCHEDULER_BOOT) {
+ bootOnDemand();
  }
  }
 
@@ -437,13 +426,4 @@ private boolean awaitInstanceHealthy(String operation, long retryMaxCount, long
  }
  return true;
  }
-
- public void reset() {
- findJobs().forEach(job -> jobManager.removeJobById(job.getId()));
- }
-
- @SuppressWarnings("unchecked")
- private Stream<Job> findJobs() {
- return jobManager.findJobs(JobManager.QueryType.ALL, JOB_TOPIC, -1, Collections.emptyMap()).stream();
- }
 }

ui.frontend/src/components/CodeExecutor.tsx

@@ -19,7 +19,8 @@ import { intervalToTimeout } from '../utils/spectrum.ts';
 import DateExplained from './DateExplained';
 import ExecutableIdValue from './ExecutableIdValue';
 import ExecutionsAbortButton from './ExecutionsAbortButton';
-import ExecutionsResetButton from './ExecutionsResetButton';
+import ExecutorResetButton from './ExecutorResetButton';
+import ExecutorBootButton from './ExecutorBootButton';
 import ExecutionStatusBadge from './ExecutionStatusBadge';
 import UserInfo from './UserInfo';
 
@@ -98,7 +99,8 @@ const CodeExecutor = () => {
  </Item>
  </Menu>
  </MenuTrigger>
- <ExecutionsResetButton />
+ <ExecutorResetButton />
+ <ExecutorBootButton />
  </ButtonGroup>
  </Flex>
  <Flex flex="1" justifyContent="center" alignItems="center">

ui.frontend/src/components/ExecutorBootButton.tsx

@@ -0,0 +1,76 @@
+import { Button, ButtonGroup, Content, Dialog, DialogTrigger, Divider, Heading, Text } from '@adobe/react-spectrum';
+import Alert from '@spectrum-icons/workflow/Alert';
+import Cancel from '@spectrum-icons/workflow/Cancel';
+import Checkmark from '@spectrum-icons/workflow/Checkmark';
+import Launch from '@spectrum-icons/workflow/Launch';
+import React, { useState } from 'react';
+import { toastRequest } from '../utils/api.ts';
+import { EventType, QueueOutput } from '../utils/api.types.ts';
+
+type ExecutionsBootButtonProps = {
+ onBoot?: () => void;
+};
+
+const ExecutorBootButton: React.FC<ExecutionsBootButtonProps> = ({ onBoot }) => {
+ const [bootDialogOpen, setBootDialogOpen] = useState(false);
+ const [isLoading, setIsLoading] = useState(false);
+
+ const handleConfirm = async () => {
+ setIsLoading(true);
+ try {
+ await toastRequest<QueueOutput>({
+ method: 'POST',
+ url: `/apps/acm/api/event.json?name=${EventType.SCRIPT_SCHEDULER_BOOT}`,
+ operation: 'Boot script scheduler',
+ });
+ if (onBoot) onBoot();
+ } catch (error) {
+ console.error('Boot script scheduler error:', error);
+ } finally {
+ setIsLoading(false);
+ setBootDialogOpen(false);
+ }
+ };
+
+ const renderBootDialog = () => (
+ <>
+ <Heading>
+ <Text>Confirmation</Text>
+ </Heading>
+ <Divider />
+ <Content>
+ <Text>
+ <p>
+ Are you sure you want to force boot the script scheduler? This may be useful if the automatic scheduler has reached a timeout.
+ <br />
+ </p>
+ <p>
+ <Alert size="XS" /> This action will <strong>affect all instances</strong>.
+ </p>
+ </Text>
+ </Content>
+ <ButtonGroup>
+ <Button variant="secondary" onPress={() => setBootDialogOpen(false)} isDisabled={isLoading}>
+ <Cancel />
+ <Text>Cancel</Text>
+ </Button>
+ <Button variant="negative" style="fill" onPress={handleConfirm} isPending={isLoading}>
+ <Checkmark />
+ <Text>Confirm</Text>
+ </Button>
+ </ButtonGroup>
+ </>
+ );
+
+ return (
+ <DialogTrigger isOpen={bootDialogOpen} onOpenChange={setBootDialogOpen}>
+ <Button variant="secondary" style="fill" onPress={() => setBootDialogOpen(true)}>
+ <Launch />
+ <Text>Boot</Text>
+ </Button>
+ <Dialog>{renderBootDialog()}</Dialog>
+ </DialogTrigger>
+ );
+};
+
+export default ExecutorBootButton;

ui.frontend/src/components/ExecutionsResetButton.tsx renamed to ui.frontend/src/components/ExecutorResetButton.tsx

@@ -4,14 +4,14 @@ import Cancel from '@spectrum-icons/workflow/Cancel';
 import Checkmark from '@spectrum-icons/workflow/Checkmark';
 import GearsDelete from '@spectrum-icons/workflow/GearsDelete';
 import React, { useState } from 'react';
-import { toastRequest } from '../utils/api';
+import { toastRequest } from '../utils/api.ts';
 import { EventType, QueueOutput } from '../utils/api.types.ts';
 
 type ExecutionsResetButtonProps = {
  onReset?: () => void;
 };
 
-const ExecutionsResetButton: React.FC<ExecutionsResetButtonProps> = ({ onReset }) => {
+const ExecutorResetButton: React.FC<ExecutionsResetButtonProps> = ({ onReset }) => {
  const [resetDialogOpen, setResetDialogOpen] = useState(false);
  const [isLoading, setIsLoading] = useState(false);
 
@@ -73,4 +73,4 @@ const ExecutionsResetButton: React.FC<ExecutionsResetButtonProps> = ({ onReset }
  );
 };
 
-export default ExecutionsResetButton;
+export default ExecutorResetButton;

ui.frontend/src/utils/api.types.ts

@@ -440,4 +440,5 @@ export type FileOutput = {
 export enum EventType {
  EXECUTOR_RESET = 'executor_reset',
  HISTORY_CLEAR = 'history_clear',
+ SCRIPT_SCHEDULER_BOOT = 'script_scheduler_boot',
 }