feat: inspect container

golang/internal/grpc/grpc.go

@@ -91,6 +91,7 @@ type (
 	ContainerCommandFunc     func(context.Context, *common.ContainerCommandRequest) error
 	DeleteContainersFunc     func(context.Context, *common.DeleteContainersRequest) error
 	ContainerLogFunc         func(context.Context, *agent.ContainerLogRequest) (*ContainerLogContext, error)
+	ContainerInspectFunc     func(context.Context, *agent.ContainerInspectRequest) (string, error)
 	ReplaceTokenFunc         func(context.Context, *agent.ReplaceTokenRequest) error
 )
 
@@ -105,6 +106,7 @@ type WorkerFunctions struct {
 	ContainerCommand     ContainerCommandFunc
 	DeleteContainers     DeleteContainersFunc
 	ContainerLog         ContainerLogFunc
+	ContainerInspect     ContainerInspectFunc
 }
 
 type contextKey int
@@ -271,6 +273,8 @@ func (cl *ClientLoop) grpcProcessCommand(command *agent.AgentCommand) {
 		go executeDeleteMultipleContainers(cl.Ctx, command.GetDeleteContainers(), cl.WorkerFuncs.DeleteContainers)
 	case command.GetContainerLog() != nil:
 		go executeContainerLog(cl.Ctx, command.GetContainerLog(), cl.WorkerFuncs.ContainerLog)
+	case command.GetContainerInspect() != nil:
+		go executeContainerInspect(cl.Ctx, command.GetContainerInspect(), cl.WorkerFuncs.ContainerInspect)
 	case command.GetReplaceToken() != nil:
 		// NOTE(@m8vago): should be sync?
 		err := cl.executeReplaceToken(command.GetReplaceToken())
@@ -837,6 +841,35 @@ func executeContainerLog(ctx context.Context, command *agent.ContainerLogRequest
 	log.Trace().Str("prefix", prefix).Str("name", name).Msg("Container log exited")
 }
 
+func executeContainerInspect(ctx context.Context, command *agent.ContainerInspectRequest, inspectFunc ContainerInspectFunc) {
+	if inspectFunc == nil {
+		log.Error().Msg("Container inspect function not implemented")
+		return
+	}
+
+	prefix := command.Container.Prefix
+	name := command.Container.Name
+
+	log.Info().Str("prefix", prefix).Str("name", name).Msg("Getting container inspection")
+
+	inspection, err := inspectFunc(ctx, command)
+	if err != nil {
+		log.Error().Stack().Err(err).Msg("Failed to inspect container")
+	}
+
+	resp := &common.ContainerInspectMessage{
+		Prefix:     prefix,
+		Name:       name,
+		Inspection: inspection,
+	}
+
+	_, err = grpcConn.Client.ContainerInspect(ctx, resp)
+	if err != nil {
+		log.Error().Stack().Err(err).Msg("Container inspection response error")
+		return
+	}
+}
+
 func (cl *ClientLoop) executeReplaceToken(command *agent.ReplaceTokenRequest) error {
 	log.Debug().Msg("Replace token requested")
 

golang/pkg/dagent/dagent.go

@@ -46,6 +46,7 @@ func Serve(cfg *config.Configuration) {
 		ContainerCommand:     utils.ContainerCommand,
 		DeleteContainers:     utils.DeleteContainers,
 		ContainerLog:         utils.ContainerLog,
+		ContainerInspect:     utils.ContainerInspect,
 	}, cfg)
 }
 

golang/pkg/dagent/utils/docker.go

@@ -6,6 +6,7 @@ import (
 	"bytes"
 	"context"
 	"encoding/binary"
+	"encoding/json"
 	"errors"
 	"fmt"
 	"io"
@@ -785,3 +786,34 @@ func ContainerLog(ctx context.Context, request *agent.ContainerLogRequest) (*grp
 
 	return logContext, nil
 }
+
+func ContainerInspect(ctx context.Context, request *agent.ContainerInspectRequest) (string, error) {
+	cli, err := client.NewClientWithOpts(client.FromEnv, client.WithAPIVersionNegotiation())
+	if err != nil {
+		return "", err
+	}
+
+	prefix := request.Container.Prefix
+	name := request.Container.Name
+
+	cont, err := GetContainerByPrefixAndName(ctx, cli, prefix, name)
+	if cont == nil {
+		return "", &UnknownContainerError{}
+	}
+	if err != nil {
+		return "", err
+	}
+
+	containerInfo, err := cli.ContainerInspect(ctx, cont.ID)
+	if err != nil {
+		return "", err
+	}
+
+	inspectionJSON, err := json.Marshal(containerInfo)
+	if err != nil {
+		return "", err
+	}
+	inspection := string(inspectionJSON)
+
+	return inspection, nil
+}