Bug: TestSimultaneousSubscriptions and related tests are flaky

[mkysel]

https://github.com/xmtp/xmtpd/actions/workflows/test.yml?query=branch%3Amain

=== RUN   TestSimultaneousSubscriptions
    store.go:50: creating database test_newtestapiserver_ktnwofzqgphe ...
2025-02-27T20:36:50.298Z	DEBUG	registrant/registrant.go:48	Running with public key 04dcd29b86da5ef5001d7db5c73597b82e6824608039e54a76269e34cda4de730a69b29a83e55027c6d1374609dfb2759eaa04aca7afeaaae1ff6b6bd8d2c4445c
2025-02-27T20:36:50.300Z	INFO	registrant/registrant.go:56	Registrant identified	{"nodeId": 100}
2025-02-27T20:36:50.309Z	INFO	api	api/server.go:62	Creating API server
2025-02-27T20:36:50.310Z	INFO	subscribeWorker	message/subscribeWorker.go:157	Starting subscribe worker
2025-02-27T20:36:50.333Z	INFO	api	api/server.go:111	enabling gRPC Server Reflection
2025-02-27T20:36:50.333Z	INFO	api	api/server.go:118	serving grpc	{"address": "127.0.0.1:36623"}
2025-02-27T20:36:50.440Z	DEBUG	subscribeWorker	message/subscribeWorker.go:214	Received new batch	{"numEnvelopes": 2}
2025-02-27T20:36:50.544Z	DEBUG	message/service.go:91	SubscribeEnvelopes	{"method": "subscribe", "request": "query:{}"}
2025-02-27T20:36:50.545Z	DEBUG	message/service.go:143	Skipping catch up	{"method": "subscribe", "stage": "catchUpFromCursor"}
2025-02-27T20:36:50.544Z	DEBUG	subscribeWorker	message/subscribeWorker.go:214	Received new batch	{"numEnvelopes": 1}
2025-02-27T20:36:50.545Z	DEBUG	message/service.go:91	SubscribeEnvelopes	{"method": "subscribe", "request": "query:{topics:\"\\x00topicB\"}"}
2025-02-27T20:36:50.546Z	DEBUG	subscribeWorker	message/subscribeWorker.go:59	Adding topic listener	{"topic": "group_messages_v1/746f70696342"}
2025-02-27T20:36:50.545Z	DEBUG	message/service.go:91	SubscribeEnvelopes	{"method": "subscribe", "request": "query:{originator_node_ids:2}"}
2025-02-27T20:36:50.546Z	DEBUG	message/service.go:143	Skipping catch up	{"method": "subscribe", "stage": "catchUpFromCursor"}
2025-02-27T20:36:50.546Z	DEBUG	message/service.go:143	Skipping catch up	{"method": "subscribe", "stage": "catchUpFromCursor"}
2025-02-27T20:36:50.647Z	DEBUG	subscribeWorker	message/subscribeWorker.go:214	Received new batch	{"numEnvelopes": 2}
    subscribe_test.go:120: 
        	Error Trace:	/home/runner/work/xmtpd/xmtpd/pkg/api/message/subscribe_test.go:120
        	            				/home/runner/work/xmtpd/xmtpd/pkg/api/message/subscribe_test.go:232
        	Error:      	Not equal: 
        	            	expected: 0x1
        	            	actual  : 0x2
        	Test:       	TestSimultaneousSubscriptions
2025-02-27T20:36:50.648Z	DEBUG	api	api/server.go:150	closing
2025-02-27T20:36:50.648Z	DEBUG	message/service.go:128	service closed	{"method": "subscribe"}
2025-02-27T20:36:50.648Z	DEBUG	message/service.go:128	service closed	{"method": "subscribe"}
2025-02-27T20:36:50.648Z	DEBUG	message/service.go:128	service closed	{"method": "subscribe"}
2025-02-27T20:36:50.649Z	DEBUG	subscribeWorker	db/subscription.go:70	Context done; stopping subscription
2025-02-27T20:36:50.649Z	DEBUG	publishWorker	db/subscription.go:70	Context done; stopping subscription
2025-02-27T20:36:50.649Z	DEBUG	api	api/server.go:166	closed
--- FAIL: TestSimultaneousSubscriptions (0.54s)