Create an example for starting mongodb as a replica set

[makesbuckets]

Preflight checklist

• I could not find a solution in the existing issues, docs, nor discussions.
• I agree to follow this project's Code of Conduct.
• I have read and am following this repository's Contribution Guidelines.
• I have joined the Ory Community Slack.
• I am signed up to the Ory Security Patch Newsletter.

Ory Network Project

No response

Describe your problem

I use dockertest/v3 extensively in my testing of api servers in go.

I am getting to the point where I want to do more interesting things the backing mongodb database (e.g. change streams, transactions) and still would like to containerize the mongo instance for tests. I feel like I'm close to figuring this out but I'd like to successfully run rs.initiate() inside the mongodb container after creating the test resource, but have been running into issues successfully using the resource.Exec function.

Describe your ideal solution

Spin up a mongodb container, programmatically in go, with replica set configuration and execute the rs.initiate() command so that the repl set is connectable in code. Was hoping something like this would work:

.Exec([]string{`echo "rs.initiate().ok || rs.status().ok" | mongo`}

Workarounds or alternatives

While troubleshooting, I have tried removing the "pipe to mongo shell" at first with no success, so I think I am just going about resource.Exec incorrectly here.

When calling: .Exec([]string{echo "rs.initiate().ok || rs.status().ok"}, I see output:

OCI runtime exec failed: exec failed: unable to start container process: exec: "echo \"rs.initiate().ok || rs.status().ok\"": executable file not found in $PATH: unknown

When adding "/bin/bash" in front: Exec([]string{"/bin/bash", echo "rs.initiate().ok || rs.status().ok"}:

/bin/bash: echo "rs.initiate().ok || rs.status().ok": No such file or directory

Version

github.com/ory/dockertest/v3 v3.10.0

Additional Context

No response

[makesbuckets]

Updated context: when originally posting this, I ran with the options:

var out bytes.Buffer
dockertest.ExecOptions{
	StdOut: &out,
	StdErr: &out,
}

I have since tried adding TTY: true and see a new error:

Start exec failed: Unrecognized input header: 47

Again, I feel I am close here, just missing probably one or two (obvious) things here

[t2y]

I am trying to initialize a replica set for testing, too. Does anyone have a good solution?

[t2y]

IIRC, --keyFile also is needed to specify with a replica set together.

• https://www.mongodb.com/docs/manual/reference/program/mongod/#std-option-mongod.--keyFile

[github-actions]

Hello contributors!

I am marking this issue as stale as it has not received any engagement from the community or maintainers for a year. That does not imply that the issue has no merit! If you feel strongly about this issue

• open a PR referencing and resolving the issue;
• leave a comment on it and discuss ideas on how you could contribute towards resolving it;
• leave a comment and describe in detail why this issue is critical for your use case;
• open a new issue with updated details and a plan for resolving the issue.

Throughout its lifetime, Ory has received over 10.000 issues and PRs. To sustain that growth, we need to prioritize and focus on issues that are important to the community. A good indication of importance, and thus priority, is activity on a topic.

Unfortunately, burnout has become a topic of concern amongst open-source projects.

It can lead to severe personal and health issues as well as opening catastrophic attack vectors.

The motivation for this automation is to help prioritize issues in the backlog and not ignore, reject, or belittle anyone.

If this issue was marked as stale erroneously you can exempt it by adding the backlog label, assigning someone, or setting a milestone for it.

Thank you for your understanding and to anyone who participated in the conversation! And as written above, please do participate in the conversation if this topic is important to you!

Thank you 🙏✌️

[mmelitzer]

Was quite the pain to get this to work. Unfortunately I wasn't able to get dyn. ports to work so can only run a single instance at a time but it works.

        pool, err := dt.NewPool("")

        // set up container
	resource, err := pool.RunWithOptions(&dt.RunOptions{
		Repository: "mongo",
		Cmd:        []string{"--replSet", "rs0", "--bind_ip_all"},
		PortBindings: map[docker.Port][]docker.PortBinding{
			"27017/tcp": {{HostIP: "127.0.0.1", HostPort: "27017/tcp"}},
		},
	}, func(config *docker.HostConfig) {
		// set AutoRemove to true so that stopped container goes away by itself
		config.AutoRemove = true
		config.RestartPolicy = docker.RestartPolicy{
			Name: "no",
		}
	})

        // initialize rs
	if err := pool.Retry(func() error {
		buf := bytes.NewBuffer(nil)
		code, err := resource.Exec([]string{`/bin/bash`}, dt.ExecOptions{
			StdIn:  bytes.NewBufferString(`mongosh --eval "try{rs.initiate({ _id: \"rs0\", members: [{ _id: 0, host: \"localhost:27017\"}]}).ok} catch {rs.status().ok}"`),
			StdOut: buf,
			StdErr: buf,
		})
		if err != nil || code != 0 {
			return fmt.Errorf("failed command: %w, code: %d", err, code)
		}
		if result, err := strconv.Atoi(strings.TrimSpace(buf.String())); err != nil || result != 1 {
			return fmt.Errorf("failed to initiate %w, result: %s", err, buf.String())
		}
		mongoDbTestUri = "mongodb://" + resource.GetHostPort("27017/tcp")
		ctx := context.Background()
		mongoClient, err := mongo.Connect(ctx, options.Client().ApplyURI(mongoDbTestUri))
		if err != nil {
			return err
		}
		defer func() {
			_ = mongoClient.Disconnect(ctx)
		}()
		return mongoClient.Ping(ctx, nil)
	}); err != nil {
		return "", nil, nil, fmt.Errorf("could not connect to docker: %w", err)
	}

If anyone figures out how to use dyn. ports let me know