docker-compose/context/store/storedefault.go

package store

import (
	"bytes"
	"encoding/json"
	"os/exec"

	"github.com/pkg/errors"
)

// Represents a context as created by the docker cli
type defaultContext struct {
	Metadata  TypedContext
	Endpoints endpoints
}

// Normally (in docker/cli code), the endpoints are mapped as map[string]interface{}
// but docker cli contexts always have a "docker" and "kubernetes" key so we
// create real types for those to no have to juggle around with interfaces.
type endpoints struct {
	Docker     endpoint `json:"docker,omitempty"`
	Kubernetes endpoint `json:"kubernetes,omitempty"`
}

// Both "docker" and "kubernetes" endpoints in the docker cli created contexts
// have a "Host", only kubernetes has the "DefaultNamespace", we put both of
// those here for easier manipulation and to not have to create two distinct
// structs
type endpoint struct {
	Host             string
	DefaultNamespace string
}

func dockerDefaultContext() (*Metadata, error) {
	cmd := exec.Command("docker", "context", "inspect", "default")
	var stdout bytes.Buffer
	cmd.Stdout = &stdout
	err := cmd.Run()
	if err != nil {
		return nil, err
	}

	var ctx []defaultContext
	err = json.Unmarshal(stdout.Bytes(), &ctx)
	if err != nil {
		return nil, err
	}

	if len(ctx) != 1 {
		return nil, errors.New("found more than one default context")
	}

	defaultCtx := ctx[0]

	meta := Metadata{
		Name: "default",
		Endpoints: map[string]Endpoint{
			"docker": {
				Host: defaultCtx.Endpoints.Docker.Host,
			},
			"kubernetes": {
				Host:             defaultCtx.Endpoints.Kubernetes.Host,
				DefaultNamespace: defaultCtx.Endpoints.Kubernetes.DefaultNamespace,
			},
		},
		Metadata: TypedContext{
			Description:       "Current DOCKER_HOST based configuration",
			Type:              "docker",
			StackOrchestrator: defaultCtx.Metadata.StackOrchestrator,
			Data:              defaultCtx.Metadata,
		},
	}

	return &meta, nil
}