Function runContainerCommandStream

agent/app/service/container.go:1556–1596

(cli *client.Client, containerID string, command []string)

}

func runContainerCommandStream(cli *client.Client, containerID string, command []string) (io.ReadCloser, error) {
	ctx := context.Background()
	resp, err := cli.ContainerExecCreate(ctx, containerID, container.ExecOptions{
		Cmd:          command,
		AttachStdout: true,
		AttachStderr: true,
	})
	if err != nil {
		return nil, err
	}
	hijack, err := cli.ContainerExecAttach(ctx, resp.ID, container.ExecAttachOptions{})
	if err != nil {
		return nil, err
	}

	pipeReader, pipeWriter := io.Pipe()
	go func() {
		defer hijack.Close()
		var stderr bytes.Buffer
		_, copyErr := stdcopy.StdCopy(pipeWriter, &stderr, hijack.Reader)
		if copyErr != nil {
			_ = pipeWriter.CloseWithError(copyErr)
			return
		}
		info, inspectErr := cli.ContainerExecInspect(ctx, resp.ID)
		if inspectErr != nil {
			_ = pipeWriter.CloseWithError(inspectErr)
			return
		}
		if info.ExitCode != 0 {
			msg := strings.TrimSpace(stderr.String())
			if len(msg) == 0 {
				msg = fmt.Sprintf("container command failed with exit code %d", info.ExitCode)
			}
			_ = pipeWriter.CloseWithError(fmt.Errorf("%s", msg))
			return
		}
		_ = pipeWriter.Close()
	}()
	return pipeReader, nil
}

func toContainerFileInfo(filePath string, stat container.PathStat, isDir bool) dto.ContainerFileInfo {
	name := stat.Name