Dagger With Socket Sharing

main.go

package main

import (
	"bufio"
	"context"
	"errors"
	"fmt"
	"io"
	"log"
	"os"
	"path/filepath"
	"strings"
	"time"

	"dagger.io/dagger"
)

func main() {
	ctx := context.Background()
	client, err := dagger.Connect(ctx, dagger.WithLogOutput(os.Stdout))
	if err != nil {
		panic(err)
	}
	defer client.Close()

	directory := client.Directory()
	// create socket
	//socket := client.Host().UnixSocket("/tmp/my_socket")
	// create consumer container
	consumer := client.Container().From("alpine:latest").
		WithExec(strings.Split("apk add netcat-openbsd socat", " ")).
		WithDirectory("/tmp", directory).
		WithExec(strings.Split("nc -lU /tmp/my_socket", " "))

	// create producer container
	stdout, err := client.Container().From("alpine:latest").
		WithServiceBinding("consumer", consumer.AsService()).
		WithDirectory("/tmp", directory).
		WithExec(strings.Split("apk add netcat-openbsd socat", " ")).
		WithExec(strings.Split(`printf Yee | nc -U /tmp/my_socket`, " ")).
		Stdout(ctx)
	if err != nil {
		panic(err)
	}
	fmt.Println(stdout)
}

But switching the path to /my_socket and extracting just that File and re-mounting using WithFile hangs

package main

import (
	"bufio"
	"context"
	"errors"
	"fmt"
	"io"
	"log"
	"os"
	"path/filepath"
	"strings"
	"time"

	"dagger.io/dagger"
)

func main() {
	ctx := context.Background()
	client, err := dagger.Connect(ctx, dagger.WithLogOutput(os.Stdout))
	if err != nil {
		panic(err)
	}
	defer client.Close()

	directory := client.Directory()
	// create socket
	//socket := client.Host().UnixSocket("/tmp/my_socket")
	// create consumer container
	consumer := client.Container().From("alpine:latest").
		WithExec(strings.Split("apk add netcat-openbsd socat", " ")).
		WithDirectory("/tmp", directory).
		WithExec(strings.Split("nc -lU /my_socket", " "))

	file := consumer.File("/my_socket")

	// create producer container
	stdout, err := client.Container().From("alpine:latest").
		WithServiceBinding("consumer", consumer.AsService()).
		WithDirectory("/tmp", directory).
		WithFile("/my_socket", file).
		WithExec(strings.Split("apk add netcat-openbsd socat", " ")).
		WithExec(strings.Split(`printf Yee | nc -U /my_socket`, " ")).
		Stdout(ctx)
	if err != nil {
		panic(err)
	}
	fmt.Println(stdout)
}