v2 restart.ts

0% Statements 0/82

0% Branches 0/1

0% Functions 0/1

0% Lines 0/82

Press n or j to go to the next uncovered block, b, p or k for the previous block.

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108

import {
  LambdaApiFunction,
  handleResourceApi
} from './_base';
 
import { generateApi400Body } from '@/types/api/_shared';
import {
  DidRestartApi, GetShouldRestartApi,
  restartApiValidator
} from '@/types/api/restart';
import { getCachedAlarmData } from '@/utils/backend/alarmStatus';
import { sendAlertMessage } from '@/utils/backend/texts';
import { validateObject } from '@/utils/backend/validation';
import { getLogger } from '@/utils/common/logger';
 
const logger = getLogger('resources/api/v2/restart');
 
const alarmKeyMap: {
  [key in GetShouldRestartApi['params']['tower']]: string;
} = {
  PoolTable: 'Crestone Recorder Status',
  Saguache: 'Saguache Recorder Status',
  SanAntonio: 'Crestone Recorder Status',
};
 
const GET: LambdaApiFunction<GetShouldRestartApi> = async function (event) {
  logger.trace('GET', ...arguments);
 
  // Validate the parameters
  const [
    params,
    paramsErrors,
  ] = validateObject<GetShouldRestartApi['params']>(
    event.pathParameters,
    restartApiValidator
  );
  if (
    params === null ||
    paramsErrors.length > 0
  ) {
    return [
      400,
      generateApi400Body(paramsErrors),
    ];
  }
 
  // Determine the response
  const alarmStatus = await getCachedAlarmData();
  const alarmName = alarmKeyMap[params.tower];
  const status = alarmStatus[alarmName];
  if (
    typeof status === 'undefined' ||
    typeof status.lastAlarm === 'undefined' ||
    (
      typeof status.lastOk !== 'undefined' &&
      status.lastOk > status.lastAlarm
    )
  ) {
    return [
      204,
      '0',
    ];
  }
 
  logger.log(`Restarting ${params.tower}:`, status);
 
  return [
    205,
    '1',
    {},
    'text/plain',
  ];
};
 
const POST: LambdaApiFunction<DidRestartApi> = async function (event) {
  logger.trace('POST', ...arguments);
 
  // Validate the parameters
  const [
    params,
    paramsErrors,
  ] = validateObject<GetShouldRestartApi['params']>(
    event.pathParameters,
    restartApiValidator
  );
  if (
    params === null ||
    paramsErrors.length > 0
  ) {
    return [
      400,
      generateApi400Body(paramsErrors),
    ];
  }
 
  await sendAlertMessage('Dtr', `${params.tower} restarted`);
 
  return [
    200,
    '',
  ];
};
 
export const main = handleResourceApi.bind(null, {
  GET,
  POST,
});