123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141
import { DockerClient } from "./lib/client/client.ts";import { ListContainerResponse } from "./lib/types/container/list.ts";import {ContainerCreate, ContainerCreateResponse} from "./lib/types/container/create.ts";import {InspectResponse} from "./lib/types/container/inspect.ts";
export interface ListOptions {  // Return all containers. By default, only running containers are shown  all?: boolean;  // Return this number of most recently created containers, including non-running ones.  limit?: number;  // Return the size of container as fields SizeRw and SizeRootFs.  size?: number;  // Filters to process on the container list, encoded as JSON (a map[string][]string). For example, {"status": ["paused"]} will only return paused containers.  filters?: string;}
export class Container {  private client: DockerClient;
  constructor(client: DockerClient) {    this.client = client;  }
  async list(options?: ListOptions): Promise<ListContainerResponse[]> {    const res = await this.client.get("/containers/json", [      {name: "all", value: options?.all ? "true" : ""},      {name: "limit", value: options?.limit ? options.limit.toString() : ""},      {name: "size", value: options?.size ? options.size.toString() : ""},      {name: "filters", value: options?.filters ?? ""},    ]);    if (!res.body || !res.body.length) {      return [];    }    return JSON.parse(res.body);  }
  async create(    name: string,    config: ContainerCreate,  ): Promise<ContainerCreateResponse> {    const res = await this.client.post(      "/containers/create",      JSON.stringify(config),      [{ name: "name", value: name }],    );    if (!res.body || !res.body.length) {      return {};    }    return JSON.parse(res.body);  }
  async start(id: string) {    const res = await this.client.post(`/containers/${id}/start`, "");    if (!res.body || !res.body.length) {      return {};    }    return JSON.parse(res.body);  }
  async stop(id: string, timeout = 10) {    const res = await this.client.post(      `/containers/${id}/stop`,      "",      [{ name: "t", value: timeout.toString() }],    );    if (!res.body || !res.body.length) {      return {};    }    return JSON.parse(res.body);  }
  async restart(id: string, timeout = 10) {    const res = await this.client.post(      `/containers/${id}/restart`,      "",      [{ name: "t", value: timeout.toString() }],    );    if (!res.body || !res.body.length) {      return {};    }    return JSON.parse(res.body);  }
  async kill(id: string, signal = "SIGKILL") {    const res = await this.client.post(      `/containers/${id}/restart`,      "",      [{ name: "signal", value: signal }],    );    if (!res.body || !res.body.length) {      return {};    }    return JSON.parse(res.body);  }
  async wait(id: string, condition = "not-running") {    const res = await this.client.post(      `/containers/${id}/wait`,      "",      [{ name: "condition", value: condition }],    );    if (!res.body || !res.body.length) {      return {};    }    return JSON.parse(res.body);  }
  async rm(id: string, condition = "not-running") {    const res = await this.client.delete(      `/containers/${id}`,      "",      [{ name: "condition", value: condition }],    );    if (!res.body || !res.body.length) {      return {};    }    return JSON.parse(res.body);  }
  async inspect(id: string, size = false): Promise<InspectResponse> {    const res = await this.client.get(      `/containers/${id}/json`,      [{name: "size", value: (Boolean(size)).toString()}]    );    if (!res.body) {      return {};    }    return JSON.parse(res.body)  }
  async stats(id: string) {    const res = await this.client.get(`/containers/${id}/stats`, [        {name: "stream", value: "false"},    ]);    if (!res.body) {      return {};    }    return JSON.parse(res.body)  }}