src/pkg/podman/container.go - main - githubmirror/toolbox

src/pkg/podman/container.go
307 строк7 KB
Debarshi Ray
cmd, pkg/podman: Remove getContainers()
24 мар 2026, 17:59
24 мар 2026, 17:59966c823
/*
 * Copyright © 2024 – 2026 Red Hat Inc.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *    http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package podman

import (
	"encoding/json"
	"time"

	"github.com/containers/toolbox/pkg/utils"
)

type Container interface {
	Created() string
	EntryPoint() string
	EntryPointPID() int
	ID() string
	Image() string
	IsToolbx() bool
	Labels() map[string]string
	Mounts() []string
	Name() string
	Names() []string
	Status() string
}

type containerInspect struct {
	created       string
	entryPoint    string
	entryPointPID int
	id            string
	image         string
	labels        map[string]string
	mounts        []string
	name          string
	status        string
}

type containerPS struct {
	created       string
	entryPoint    string
	entryPointPID int
	id            string
	image         string
	labels        map[string]string
	mounts        []string
	names         []string
	status        string
}

type Containers struct {
	data []containerPS
	i    int
}

func (container *containerInspect) Created() string {
	return container.created
}

func (container *containerInspect) EntryPoint() string {
	return container.entryPoint
}

func (container *containerInspect) EntryPointPID() int {
	return container.entryPointPID
}

func (container *containerInspect) ID() string {
	return container.id
}

func (container *containerInspect) Image() string {
	return container.image
}

func (container *containerInspect) IsToolbx() bool {
	if isToolbx(container.labels) {
		return true
	}

	return false
}

func (container *containerInspect) Labels() map[string]string {
	return container.labels
}

func (container *containerInspect) Mounts() []string {
	return container.mounts
}

func (container *containerInspect) Name() string {
	return container.name
}

func (container *containerInspect) Names() []string {
	return []string{container.name}
}

func (container *containerInspect) Status() string {
	return container.status
}

func (container *containerInspect) UnmarshalJSON(data []byte) error {
	var raw struct {
		Config struct {
			Cmd    []string
			Labels map[string]string
		}
		Created   time.Time
		ID        string
		ImageName string
		Mounts    []struct {
			Destination string
		}
		Name  string
		State struct {
			PID    int
			Status string
		}
	}

	if err := json.Unmarshal(data, &raw); err != nil {
		return err
	}

	if len(raw.Config.Cmd) > 0 {
		container.entryPoint = raw.Config.Cmd[0]
	}

	container.entryPointPID = raw.State.PID

	created := raw.Created.Unix()
	container.created = utils.HumanDuration(created)

	container.id = raw.ID
	container.image = raw.ImageName
	container.labels = raw.Config.Labels

	for _, mount := range raw.Mounts {
		if mount.Destination != "" {
			container.mounts = append(container.mounts, mount.Destination)
		}
	}

	container.name = raw.Name
	container.status = raw.State.Status
	return nil
}

func (container *containerPS) Created() string {
	return container.created
}

func (container *containerPS) EntryPoint() string {
	return container.entryPoint
}

func (container *containerPS) EntryPointPID() int {
	return container.entryPointPID
}

func (container *containerPS) ID() string {
	return container.id
}

func (container *containerPS) Image() string {
	return container.image
}

func (container *containerPS) IsToolbx() bool {
	if isToolbx(container.labels) {
		return true
	}

	return false
}

func (container *containerPS) Labels() map[string]string {
	return container.labels
}

func (container *containerPS) Mounts() []string {
	return container.mounts
}

func (container *containerPS) Name() string {
	return container.names[0]
}

func (container *containerPS) Names() []string {
	return container.names
}

func (container *containerPS) Status() string {
	return container.status
}

func (container *containerPS) UnmarshalJSON(data []byte) error {
	var raw struct {
		Command []string
		Created interface{}
		ID      string
		Image   string
		Labels  map[string]string
		Mounts  []string
		Names   interface{}
		PID     int
		State   interface{}
		Status  string
	}

	if err := json.Unmarshal(data, &raw); err != nil {
		return err
	}

	if len(raw.Command) > 0 {
		container.entryPoint = raw.Command[0]
	}

	container.entryPointPID = raw.PID

	// In Podman V1 the field 'Created' held a human-readable string in format
	// "5 minutes ago". Since Podman V2 the field holds an integer with Unix time.
	// After a discussion in https://github.com/containers/podman/issues/6594 the
	// previous value was moved to field 'CreatedAt'. Since we're already using
	// the 'github.com/docker/go-units' library, we'll stop using the provided
	// human-readable string and assemble it ourselves. Go interprets numbers in
	// JSON as float64.
	switch value := raw.Created.(type) {
	case string:
		container.created = value
	case float64:
		container.created = utils.HumanDuration(int64(value))
	}

	container.id = raw.ID
	container.image = raw.Image
	container.labels = raw.Labels
	container.mounts = raw.Mounts

	// In Podman V1 the field 'Names' held a single string but since Podman V2 the
	// field holds an array of strings
	switch value := raw.Names.(type) {
	case string:
		container.names = append(container.names, value)
	case []interface{}:
		for _, v := range value {
			container.names = append(container.names, v.(string))
		}
	}

	// In Podman V1 the field holding a string about the container's state was
	// called 'Status' and field 'State' held a number representing the state. In
	// Podman V2 the string was moved to 'State' and field 'Status' was dropped.
	switch value := raw.State.(type) {
	case string:
		container.status = value
	case float64:
		container.status = raw.Status
	}

	return nil
}

func (containers *Containers) Get() Container {
	if containers.i < 1 {
		panic("called Containers.Get() without calling Containers.Next()")
	}

	container := containers.data[containers.i-1]
	return &container
}

func (containers *Containers) Len() int {
	if containers == nil {
		return 0
	}

	return len(containers.data)
}

func (containers *Containers) Next() bool {
	available := containers.i < len(containers.data)
	if available {
		containers.i++
	}

	return available
}

func (containers *Containers) Reset() {
	containers.i = 0
}