client.go RawHistoryFolder

1package docker
2
3import (
4	"context"
5	"fmt"
6	"os"
7	"time"
8
9	"github.com/docker/docker/api/types"
10	"github.com/docker/docker/api/types/container"
11	"github.com/docker/docker/client"
12)
13
14type Config struct {
15	Sock         string
16	PodmanEnable bool
17}
18
19var (
20	dockerCli     *client.Client
21	currentConfig *Config
22)
23
24func InitializeClient(config *Config) error {
25	if config.Sock == "" {
26		return fmt.Errorf("sock field in Config is empty")
27	}
28
29	if _, err := os.Stat(config.Sock); os.IsNotExist(err) {
30		return err
31	}
32
33	cli, err := client.NewClientWithOpts(
34		client.WithAPIVersionNegotiation(),
35		client.WithHost("unix://"+config.Sock),
36	)
37	if err != nil {
38		return fmt.Errorf("error initializing Docker client: %s", err)
39	}
40	dockerCli = cli
41	currentConfig = config
42	return nil
43}
44
45func CheckIfInitialized() error {
46	if currentConfig == nil || currentConfig.Sock == "" {
47		return fmt.Errorf("docker client is not initialized or configuration is missing")
48	}
49
50	socketPath := currentConfig.Sock
51	if _, err := os.Stat(socketPath); os.IsNotExist(err) {
52		return fmt.Errorf("sock file does not exist: %s", socketPath)
53	}
54
55	if dockerCli == nil {
56		return fmt.Errorf("docker client is not initialized")
57	}
58
59	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
60	defer cancel()
61
62	_, err := dockerCli.ContainerList(ctx, container.ListOptions{})
63	if err != nil {
64		return fmt.Errorf("cannot connect to Docker daemon: %s", err)
65	}
66
67	return nil
68}
69
70func ListContainers(ctx context.Context) ([]types.Container, error) {
71	if dockerCli == nil {
72		return nil, fmt.Errorf("Docker client is not initialized")
73	}
74
75	containers, err := dockerCli.ContainerList(ctx, container.ListOptions{})
76	if err != nil {
77		return nil, fmt.Errorf("error listing containers: %w", err)
78	}
79
80	return containers, nil
81}