Class DockerTaskOperations

apps/docker-provider/src/index.ts:35–283

}

class DockerTaskOperations implements TaskOperations {
  #initialized = false;
  #canCheckpoint = false;

  constructor(private opts = { forceSimulate: false }) {}

  async #initialize(): Promise<InitializeReturn> {
    if (this.#initialized) {
      return this.#getInitializeReturn();
    }

    logger.log("Initializing task operations");

    if (this.opts.forceSimulate) {
      logger.log("Forced simulation enabled. Will simulate regardless of checkpoint support.");
    }

    try {
      await $`criu --version`;
    } catch (error) {
      logger.error("No checkpoint support: Missing CRIU binary. Will simulate instead.");
      this.#canCheckpoint = false;
      this.#initialized = true;

      return this.#getInitializeReturn();
    }

    try {
      await $`docker checkpoint`;
    } catch (error) {
      logger.error("No checkpoint support: Docker needs to have experimental features enabled");
      logger.error("Will simulate instead");
      this.#canCheckpoint = false;
      this.#initialized = true;

      return this.#getInitializeReturn();
    }

    logger.log("Full checkpoint support!");

    this.#initialized = true;
    this.#canCheckpoint = true;

    return this.#getInitializeReturn();
  }

  #getInitializeReturn(): InitializeReturn {
    return {
      canCheckpoint: this.#canCheckpoint,
      willSimulate: !this.#canCheckpoint || this.opts.forceSimulate,
    };
  }

  async index(opts: TaskOperationsIndexOptions) {
    await this.#initialize();

    const containerName = this.#getIndexContainerName(opts.shortCode);