connector_test.go

package docker_test

import (
	"context"
	"encoding/json"
	"io"
	"strings"
	"testing"

	"go.arcalot.io/assert"
	"go.arcalot.io/log/v2"
	docker "go.flow.arcalot.io/dockerdeployer"
)

func TestSimpleInOut(t *testing.T) {
	configJSON := `{}`
	var config any
	if err := json.Unmarshal([]byte(configJSON), &config); err != nil {
		t.Fatal(err)
	}

	factory := docker.NewFactory()
	schema := factory.ConfigurationSchema()
	unserializedConfig, err := schema.UnserializeType(config)
	assert.NoError(t, err)
	connector, err := factory.Create(unserializedConfig, log.NewTestLogger(t))
	assert.NoError(t, err)

	container, err := connector.Deploy(context.Background(), "quay.io/joconnel/io-test-script")
	assert.NoError(t, err)
	t.Cleanup(func() {
		assert.NoError(t, container.Close())
	})

	var containerInput = []byte("abc\n")
	_ = assert.NoErrorR[int](t)(container.Write(containerInput))

	buf := new(strings.Builder)
	_ = assert.NoErrorR[int64](t)(io.Copy(buf, container))
	assert.Contains(t, buf.String(), "This is what input was received: \"abc\"")
}