oneuptime/Worker/DataMigrations/DeleteOldTelelmetryTable.ts

import DataMigrationBase from "./DataMigrationBase";
import LogService from "Common/Server/Services/LogService";
import MetricService from "Common/Server/Services/MetricService";
import SpanService from "Common/Server/Services/SpanService";
import logger from "Common/Server/Utils/Logger";

export default class DeleteOldTelemetryTable extends DataMigrationBase {
  public constructor() {
    super("DeleteOldTelemetryTable");
  }

  public override async migrate(): Promise<void> {
    try {
      /*
       * delete old telemetry tables that are no longer needed
       * we have renamed these tables to new names
       */
      await MetricService.executeQuery("DROP TABLE IF EXISTS Metric");
      await SpanService.executeQuery("DROP TABLE IF EXISTS Span");
      await LogService.executeQuery("DROP TABLE IF EXISTS Log");
    } catch (err) {
      logger.error(err);
    }
  }

  public override async rollback(): Promise<void> {
    return;
  }
}