runtime_exec_test.go RawHistoryFolder

1package docker
2
3import (
4	"bytes"
5	"context"
6	"encoding/binary"
7	"testing"
8
9	"github.com/stretchr/testify/assert"
10	"github.com/stretchr/testify/require"
11)
12
13func TestParseExecOutput_SplitsStdoutAndStderr(t *testing.T) {
14	stream := append(frameDockerStream(1, []byte("hello\n")), frameDockerStream(2, []byte("warn\n"))...)
15
16	stdout, stderr, err := parseExecOutput(bytes.NewReader(stream))
17
18	require.NoError(t, err)
19	assert.Equal(t, []byte("hello\n"), stdout)
20	assert.Equal(t, []byte("warn\n"), stderr)
21}
22
23func TestRuntime_ExecInContainer_RejectsEmptyCommand(t *testing.T) {
24	r := &Runtime{}
25
26	tests := []struct {
27		name string
28		cmd  []string
29	}{
30		{name: "nil", cmd: nil},
31		{name: "empty slice", cmd: []string{}},
32	}
33
34	for _, tt := range tests {
35		t.Run(tt.name, func(t *testing.T) {
36			result, err := r.ExecInContainer(context.Background(), "abc123", tt.cmd)
37			require.Error(t, err)
38			assert.Nil(t, result)
39		})
40	}
41}
42
43func frameDockerStream(streamID byte, payload []byte) []byte {
44	frame := make([]byte, 8+len(payload))
45	frame[0] = streamID
46	binary.BigEndian.PutUint32(frame[4:8], uint32(len(payload)))
47	copy(frame[8:], payload)
48	return frame
49}