diff --git a/frontend/app/player/MessageDistributor/MessageDistributor.ts b/frontend/app/player/MessageDistributor/MessageDistributor.ts index c5ac4f6b5..b342fd4bf 100644 --- a/frontend/app/player/MessageDistributor/MessageDistributor.ts +++ b/frontend/app/player/MessageDistributor/MessageDistributor.ts @@ -109,7 +109,7 @@ export default class MessageDistributor extends StatedScreen { if (live) { initListsDepr({}) - this.assistManager.connect(); + this.assistManager.connect(this.session.agentToken); } else { this.activityManager = new ActivityManager(this.session.duration.milliseconds); /* == REFACTOR_ME == */ diff --git a/frontend/app/player/MessageDistributor/managers/AssistManager.ts b/frontend/app/player/MessageDistributor/managers/AssistManager.ts index 5a4945fbe..d979d52f8 100644 --- a/frontend/app/player/MessageDistributor/managers/AssistManager.ts +++ b/frontend/app/player/MessageDistributor/managers/AssistManager.ts @@ -119,7 +119,7 @@ export default class AssistManager { } private socket: Socket | null = null - connect() { + connect(agentToken: string) { const jmr = new JSONRawMessageReader() const reader = new MStreamReader(jmr) let waitingForMessages = true @@ -146,6 +146,9 @@ export default class AssistManager { // @ts-ignore WTF, socket.io ??? const socket: Socket = this.socket = io(urlObject.origin, { path: '/ws-assist/socket', + auth: { + token: agentToken + }, query: { peerId: this.peerID, identity: "agent", diff --git a/frontend/app/types/session/session.ts b/frontend/app/types/session/session.ts index d66670963..9beee5cd0 100644 --- a/frontend/app/types/session/session.ts +++ b/frontend/app/types/session/session.ts @@ -81,7 +81,8 @@ export default Record({ revId: '', userSessionsCount: 0, agentIds: [], - isCallActive: false + isCallActive: false, + agentToken: '' }, { fromJS:({ startTs=0,