Container preparation

testcontainers_test.go

func prepareContainer(ctx context.Context, image image) (testcontainers.Container, string, error) {
	req := testcontainers.ContainerRequest{
		Image:        image.name,
		ExposedPorts: []string{image.port + "/tcp"},
		WaitingFor:   wait.ForListeningPort(nat.Port(image.port)),
	}

	container, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{
		ContainerRequest: req,
		Started:          true,
	})
	if err != nil {
		return nil, "", err
	}

	hostIP, err := container.Host(ctx)
	if err != nil {
		return nil, "", err
	}

	mappedPort, err := container.MappedPort(ctx, nat.Port(image.port))
	if err != nil {
		return nil, "", err
	}

	var uri string
	switch image {
	case mongoDB:
		uri = fmt.Sprintf("mongodb://%s:%s", hostIP, mappedPort.Port())
	default:
		return nil, "", errors.New("TestContainers: unsupported image: " + image.name)
	}

	log.Printf("TestContainers: container %s is now running at %s\n", req.Image, uri)
	return container, uri, nil
}