projects
/
websub-hub
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Merge branch 'v1.3-dev'
[websub-hub]
/
test-e2e
/
test-one.js
diff --git
a/test-e2e/test-one.js
b/test-e2e/test-one.js
index 8c6fdf2e34fdd6b9dfff1c172a1cd657db80fe51..e0519832337717f28da9958d5fdf5e258bb3073f 100644
(file)
--- a/
test-e2e/test-one.js
+++ b/
test-e2e/test-one.js
@@
-1,7
+1,6
@@
'use strict';
'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 FakeServersClient = require('./fake-servers-client');
const subscriberPort = process.env.FAKE_SUBSCRIBER_PORT || 9876;
@@
-14,14
+13,14
@@
const hubUrl = `http://${hubAddress}:${hubPort}/`;
const client = new FakeServersClient(listenAddress, subscriberPort, topicPort);
async function newTopic() {
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() {
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;
await client.subscriberSetVerify(id);
console.log('created fake subscriber', id);
return id;
@@
-32,7
+31,7
@@
async function newSubscriber() {
const subscriberId = await newSubscriber();
const result = await client.subscribe(hubUrl, subscriberId, topicId);
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.status
Code, headers: result.headers, body: result.body
});
console.log('done');
})().catch((e) => {
console.log('done');
})().catch((e) => {