Function createPubSubContainer

lib/gcppubsub/client_test.go:59–98

nolint:exhaustruct // WONTFIX: external struct

()

// nolint:exhaustruct // WONTFIX: external struct
func createPubSubContainer() error {
	ctx := context.Background()
	repoRoot, err := filepath.Abs(filepath.Join(".", "..", ".."))
	if err != nil {
		return err
	}

	goarch := runtime.GOARCH
	req := testcontainers.ContainerRequest{
		FromDockerfile: testcontainers.FromDockerfile{
			Dockerfile: filepath.Join(".dev", "pubsub", "Dockerfile"),
			Context:    repoRoot,
			BuildArgs:  map[string]*string{"TARGETARCH": &goarch},
			KeepImage:  true,
		},
		ExposedPorts: []string{"8060/tcp"},
		WaitingFor:   wait.ForLog("Pub/Sub setup for webstatus.dev finished"),
		Name:         "webstatus-dev-test-pubsub",
	}
	pubsubContainer, err = testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{
		ContainerRequest: req,
		Started:          true,
	})
	if err != nil {
		return err
	}

	mappedPort, err := pubsubContainer.MappedPort(ctx, "8060")
	if err != nil {
		return err
	}

	pubsubHost = fmt.Sprintf("localhost:%s", mappedPort.Port())
	err = newTestPubsubClient()
	if err != nil {
		return err
	}

	return nil
}

func newTestPubsubClient() error {
	var err error