add start/stop AD job api

public/models/interfaces.ts

@@ -98,6 +98,9 @@ export type Detector = {
   windowDelay: { period: Schedule };
   detectionInterval: { period: Schedule };
   uiMetadata: UiMetaData;
+  enabled?: boolean;
+  enabledTime?: Date;
+  disabledTime?: Date;
 };
 
 export type DetectorListItem = {

public/redux/reducers/ad.ts

@@ -31,6 +31,8 @@ const GET_DETECTOR_LIST = 'ad/GET_DETECTOR_LIST';
 const UPDATE_DETECTOR = 'ad/UPDATE_DETECTOR';
 const SEARCH_DETECTOR = 'ad/SEARCH_DETECTOR';
 const DELETE_DETECTOR = 'ad/DELETE_DETECTOR';
+const START_DETECTOR = 'ad/START_DETECTOR';
+const STOP_DETECTOR = 'ad/STOP_DETECTOR';
 
 export interface Detectors {
   requesting: boolean;
@@ -92,6 +94,51 @@ const reducer = handleActions<Detectors>(
         errorMessage: action.error.data.error,
       }),
     },
+    [START_DETECTOR]: {
+      REQUEST: (state: Detectors): Detectors => {
+        const newState = { ...state, requesting: true, errorMessage: '' };
+        return newState;
+      },
+      SUCCESS: (state: Detectors, action: APIResponseAction): Detectors => ({
+        ...state,
+        requesting: false,
+        detectors: {
+          ...state.detectors,
+          [action.detectorId]: {
+            ...[action.detectorId],
+            enabled: true,
+          },
+        },
+      }),
+      FAILURE: (state: Detectors, action: APIErrorAction): Detectors => ({
+        ...state,
+        requesting: false,
+        errorMessage: action.error,
+      }),
+    },
+
+    [STOP_DETECTOR]: {
+      REQUEST: (state: Detectors): Detectors => {
+        const newState = { ...state, requesting: true, errorMessage: '' };
+        return newState;
+      },
+      SUCCESS: (state: Detectors, action: APIResponseAction): Detectors => ({
+        ...state,
+        requesting: false,
+        detectors: {
+          ...state.detectors,
+          [action.detectorId]: {
+            ...[action.detectorId],
+            enabled: false,
+          },
+        },
+      }),
+      FAILURE: (state: Detectors, action: APIErrorAction): Detectors => ({
+        ...state,
+        requesting: false,
+        errorMessage: action.error,
+      }),
+    },
     [SEARCH_DETECTOR]: {
       REQUEST: (state: Detectors): Detectors => ({
         ...state,
@@ -233,4 +280,22 @@ export const deleteDetector = (detectorId: string): APIAction => ({
   detectorId,
 });
 
+export const startDetector = (detectorId: string): APIAction => ({
+  type: START_DETECTOR,
+  request: (client: IHttpService) =>
+    client.post(`..${AD_NODE_API.DETECTOR}/${detectorId}/_start`, {
+      detectorId: detectorId,
+    }),
+  detectorId,
+});
+
+export const stopDetector = (detectorId: string): APIAction => ({
+  type: STOP_DETECTOR,
+  request: (client: IHttpService) =>
+    client.post(`..${AD_NODE_API.DETECTOR}/${detectorId}/_stop`, {
+      detectorId: detectorId,
+    }),
+  detectorId,
+});
+
 export default reducer;

server/cluster/ad/adPlugin.ts

@@ -83,7 +83,7 @@ export default function adPlugin(Client: any, config: any, components: any) {
   });
   ad.getDetector = ca({
     url: {
-      fmt: `${API.DETECTOR_BASE}/<%=detectorId%>`,
+      fmt: `${API.DETECTOR_BASE}/<%=detectorId%>?job=true`,
       req: {
         detectorId: {
           type: 'string',
@@ -100,4 +100,30 @@ export default function adPlugin(Client: any, config: any, components: any) {
     needBody: true,
     method: 'POST',
   });
+
+  ad.startDetector = ca({
+    url: {
+      fmt: `${API.DETECTOR_BASE}/<%=detectorId%>/_start`,
+      req: {
+        detectorId: {
+          type: 'string',
+          required: true,
+        },
+      },
+    },
+    method: 'POST',
+  });
+
+  ad.stopDetector = ca({
+    url: {
+      fmt: `${API.DETECTOR_BASE}/<%=detectorId%>/_stop`,
+      req: {
+        detectorId: {
+          type: 'string',
+          required: true,
+        },
+      },
+    },
+    method: 'POST',
+  });
 }

server/models/types.ts

@@ -62,6 +62,9 @@ export type Detector = {
   windowDelay?: { period: Schedule };
   detectionInterval?: { period: Schedule };
   uiMetadata?: { [key: string]: any };
+  enabled: boolean;
+  enabledTime?: Date;
+  disabledTime?: Date;
 };
 
 export type GetDetectorsQueryParams = {

server/routes/ad.ts

@@ -55,6 +55,8 @@ export default function (apiRouter: Router) {
   apiRouter.post('/detectors/{detectorId}/preview', previewDetector);
   apiRouter.get('/detectors/{detectorId}/results', getAnomalyResults);
   apiRouter.delete('/detectors/{detectorId}', deleteDetector);
+  apiRouter.post('/detectors/{detectorId}/_start', startDetector);
+  apiRouter.post('/detectors/{detectorId}/_stop', stopDetector);
 }
 
 const deleteDetector = async (
@@ -165,6 +167,7 @@ const getDetector = async (
       id: response._id,
       primaryTerm: response._primary_term,
       seqNo: response._seq_no,
+      adJob: { ...response.anomaly_detector_job },
     };
     return {
       ok: true,
@@ -176,6 +179,46 @@ const getDetector = async (
   }
 };
 
+const startDetector = async (
+  req: Request,
+  h: ResponseToolkit,
+  callWithRequest: CallClusterWithRequest
+): Promise<ServerResponse<AnomalyResults>> => {
+  try {
+    const { detectorId } = req.params;
+    const response = await callWithRequest(req, 'ad.startDetector', {
+      detectorId,
+    });
+    return {
+      ok: true,
+      response: response,
+    };
+  } catch (err) {
+    console.log('Anomaly detector - strartDetector', err);
+    return { ok: false, error: err.body || err.message };
+  }
+};
+
+const stopDetector = async (
+  req: Request,
+  h: ResponseToolkit,
+  callWithRequest: CallClusterWithRequest
+): Promise<ServerResponse<AnomalyResults>> => {
+  try {
+    const { detectorId } = req.params;
+    const response = await callWithRequest(req, 'ad.stopDetector', {
+      detectorId,
+    });
+    return {
+      ok: true,
+      response: response,
+    };
+  } catch (err) {
+    console.log('Anomaly detector - stopDetector', err);
+    return { ok: false, error: err.body || err.message };
+  }
+};
+
 const searchDetector = async (
   req: Request,
   h: ResponseToolkit,

server/routes/utils/adHelpers.ts

@@ -45,6 +45,7 @@ export const convertDetectorKeysToCamelCase = (response: object) => {
         'ui_metadata',
         'feature_query',
         'feature_attributes',
+        'adJob',
       ]),
       toCamel
     ),
@@ -56,6 +57,13 @@ export const convertDetectorKeysToCamelCase = (response: object) => {
       })
     ),
     uiMetadata: get(response, 'ui_metadata', {}),
+    enabled: get(response, 'adJob.enabled', false),
+    enabledTime: get(response, 'adJob.enabled_time')
+      ? new Date(get(response, 'adJob.enabled_time'))
+      : undefined,
+    disabledTime: get(response, 'adJob.disabled_time')
+      ? new Date(get(response, 'adJob.disabled_time'))
+      : undefined,
   };
 };