import 'mocha'
import * as chai from 'chai'
import {
- addUserSubscription,
addVideoCommentThread,
cleanupTests,
createUser,
flushAndRunMultipleServers,
getUserNotifications,
markAsReadAllNotifications,
- removeUserSubscription,
ServerInfo,
setAccessTokensToServers,
uploadVideo,
async function resetState () {
try {
- await removeUserSubscription(servers[1].url, remoteUserToken, 'user1_channel@' + servers[0].host)
- await removeUserSubscription(servers[1].url, remoteUserToken, 'user2_channel@' + servers[0].host)
+ await servers[1].subscriptionsCommand.remove({ token: remoteUserToken, uri: 'user1_channel@' + servers[0].host })
+ await servers[1].subscriptionsCommand.remove({ token: remoteUserToken, uri: 'user2_channel@' + servers[0].host })
} catch {}
await waitJobs(servers)
{
- await addUserSubscription(servers[1].url, remoteUserToken, 'user1_channel@' + servers[0].host)
- await addUserSubscription(servers[1].url, remoteUserToken, 'user2_channel@' + servers[0].host)
+ await servers[1].subscriptionsCommand.add({ token: remoteUserToken, targetUri: 'user1_channel@' + servers[0].host })
+ await servers[1].subscriptionsCommand.add({ token: remoteUserToken, targetUri: 'user2_channel@' + servers[0].host })
}
await waitJobs(servers)