Initial release

[websub-hub] / test-e2e / test-many.js

diff --git a/test-e2e/test-many.js b/test-e2e/test-many.js
new file mode 100644 (file)
index 0000000..1ff40c9
--- /dev/null
+++ b/test-e2e/test-many.js
@@ -0,0 +1,42 @@
+'use strict';
+
+const assert = require('assert');
+const uuid = require('uuid');
+const FakeServersClient = require('./fake-servers-client');
+
+const subscriberPort = process.env.FAKE_SUBSCRIBER_PORT || 9876;
+const topicPort = process.env.FAKE_TOPIC_PORT || 9875;
+const listenAddress = process.env.FAKE_LISTEN_ADDR || '127.0.0.1';
+const hubAddress = process.env.LISTEN_ADDR || '127.0.0.1';
+const hubPort = process.env.PORT || 4001;
+const hubUrl = `http://${hubAddress}:${hubPort}/`;
+
+const client = new FakeServersClient(listenAddress, subscriberPort, topicPort);
+
+async function newTopic() {
+  const id = uuid.v4();
+  await client.topicSet(id, { hubUrl });
+  console.log('created fake topic', id);
+  return id;
+}
+
+async function newSubscriber() {
+  const id = uuid.v4();
+  await client.subscriberSetVerify(id);
+  console.log('created fake subscriber', id);
+  return id;
+}
+
+(async function main() {
+  const topicId = await newTopic();
+  const numSubscribers = 100;
+
+  const subIds = await Promise.all([...Array(numSubscribers)].map(() => newSubscriber()));
+  const results = await Promise.all(subIds.map((id) => client.subscribe(hubUrl, id, topicId)));
+  console.log('results', results);
+
+  console.log('done');
+})().catch((e) => {
+  console.log(e);
+  throw e;
+});
\ No newline at end of file