'use strict';
-const assert = require('assert');
-const uuid = require('uuid');
+const crypto = require('crypto');
const FakeServersClient = require('./fake-servers-client');
const subscriberPort = process.env.FAKE_SUBSCRIBER_PORT || 9876;
const client = new FakeServersClient(listenAddress, subscriberPort, topicPort);
async function newTopic() {
- const id = uuid.v4();
+ const id = crypto.randomUUID();
await client.topicSet(id, { hubUrl });
console.log('created fake topic', id);
return id;
}
async function newSubscriber() {
- const id = uuid.v4();
+ const id = crypto.randomUUID();
await client.subscriberSetVerify(id);
console.log('created fake subscriber', id);
return id;
const subscriberId = await newSubscriber();
const result = await client.subscribe(hubUrl, subscriberId, topicId);
- console.log('subscribed', { status: result.status, headers: result.headers, data: result.data });
+ console.log('subscribed', { status: result.statusCode, headers: result.headers, body: result.body });
console.log('done');
})().catch((e) => {