Compare commits
36 Commits
Author | SHA1 | Date | |
---|---|---|---|
|
139aa3a377 | ||
|
f207e7a258 | ||
|
135b9f079a | ||
|
46c2467368 | ||
|
0ad65e9dcc | ||
|
6c882a44cc | ||
|
666f2361c8 | ||
|
d3747cc654 | ||
|
687dfa84e9 | ||
|
b7da515969 | ||
|
e2c291c040 | ||
|
87f2c5290f | ||
|
4fdddc8c92 | ||
|
d53a5c5e26 | ||
|
9772b3b1fd | ||
|
84fe91adbb | ||
|
b6cd85eab0 | ||
|
209b3aaa45 | ||
|
4912ce6f61 | ||
|
013ffa318f | ||
|
ac2f953b90 | ||
|
a25c71a04a | ||
|
836d4751ad | ||
|
2983a14038 | ||
|
6e71ba4b5b | ||
|
5dc6aa5660 | ||
|
6d4b6b1609 | ||
|
1e3b63fe5b | ||
|
9fb9d442fe | ||
|
abcc417d78 | ||
|
d6651b7437 | ||
|
f838637d7a | ||
|
404f440f48 | ||
|
14ed711b6a | ||
|
13dd515522 | ||
|
391bd22121 |
@ -1,8 +0,0 @@
|
||||
MATRIX_SERVER_URL=
|
||||
BOT_DISPLAY_NAME=
|
||||
BOT_USERNAME=
|
||||
BOT_PASSWORD=
|
||||
BOT_USERID=
|
||||
FACILITATOR_GROUP_ID=
|
||||
FACILITATOR_ROOM_ID=
|
||||
CAPTURE_TRANSCRIPTS
|
1
.gitignore
vendored
1
.gitignore
vendored
@ -3,3 +3,4 @@ node_modules
|
||||
*.log
|
||||
__mocks__/test_transcript.txt
|
||||
transcripts/*.txt
|
||||
config.json
|
@ -1,5 +1,10 @@
|
||||
FROM node:10-alpine
|
||||
|
||||
RUN apk add g++ make python
|
||||
RUN apk add tzdata
|
||||
|
||||
ENV TZ America/Montreal
|
||||
|
||||
RUN mkdir -p /home/node/app/node_modules && chown -R node:node /home/node/app
|
||||
|
||||
WORKDIR /home/node/app
|
||||
|
27
README.md
27
README.md
@ -1,20 +1,10 @@
|
||||
# Safe Support Chat Bot
|
||||
|
||||
A simple Matrix bot that handles inviting, uninviting, and notifying Riot users on the recieving end of the [Safe Support chatbox](https://github.com/nomadic-labs/safesupport-chatbox).
|
||||
A simple Matrix bot that handles inviting, uninviting, and notifying Riot users on the recieving end of the [Safe Support chatbox](https://github.com/Safe-Support-Chat/ocrcc-chatbox).
|
||||
|
||||
The bot configuration file is `config.json`. It can also pull in user-set configurations from the Safe Support Chat Admin app. To do so, run the command `yarn setup` before starting the bot.
|
||||
|
||||
The bot can be configured with an `.env` file with the following variables:
|
||||
|
||||
```
|
||||
MATRIX_SERVER_URL=
|
||||
BOT_DISPLAY_NAME=
|
||||
BOT_USERNAME=
|
||||
BOT_PASSWORD=
|
||||
BOT_USERID=
|
||||
FACILITATOR_ROOM_ID=
|
||||
FACILITATOR_GROUP_ID=
|
||||
CHAT_OFFLINE_MESSAGE=
|
||||
CAPTURE_TRANSCRIPTS=
|
||||
```
|
||||
## What does the bot do?
|
||||
* The bot receives an invitation to every chatroom created by the embedded chatbox, and automatically accepts
|
||||
* Upon joining a new room, the bot invites all of the members of the Facilitators community
|
||||
@ -40,7 +30,7 @@ If you prefer to develop locally instead of on Glitch:
|
||||
|
||||
Clone the project
|
||||
```
|
||||
git clone https://github.com/nomadic-labs/safesupport-bot.git
|
||||
git clone https://github.com/Safe-Support-Chat/ocrcc-bot.git
|
||||
```
|
||||
|
||||
Install dependencies
|
||||
@ -49,9 +39,14 @@ cd safesupport-bot
|
||||
yarn
|
||||
```
|
||||
|
||||
Copy the sample `.env` file and add in your own variables
|
||||
Copy the sample config file and add in the missing values.
|
||||
```
|
||||
cp .env.sample .env
|
||||
cp sample.config.json config.json
|
||||
```
|
||||
|
||||
Pull in the user-defined settings (if there are any).
|
||||
```
|
||||
yarn setup
|
||||
```
|
||||
|
||||
Start the local server
|
||||
|
@ -157,6 +157,10 @@ export const mockGetGroupUsers = jest.fn(() => {
|
||||
|
||||
export const mockGetUser = jest.fn().mockReturnValue({ presence: 'online'});
|
||||
|
||||
export const mockSendStateEvent = jest.fn(() => {
|
||||
return Promise.resolve();
|
||||
});
|
||||
|
||||
export const mockClient = {
|
||||
registerRequest: mockRegisterRequest,
|
||||
initCrypto: mockInitCrypto,
|
||||
@ -186,6 +190,7 @@ export const mockClient = {
|
||||
getJoinedRoomMembers: mockGetJoinedRoomMembers,
|
||||
getUser: mockGetUser,
|
||||
getGroupUsers: mockGetGroupUsers,
|
||||
sendStateEvent: mockSendStateEvent,
|
||||
}
|
||||
|
||||
export const WebStorageSessionStore = jest.fn()
|
||||
|
480
dist/bot.js
vendored
480
dist/bot.js
vendored
@ -23,18 +23,22 @@ var matrix = _interopRequireWildcard(require("matrix-js-sdk"));
|
||||
|
||||
var _logger = _interopRequireDefault(require("./logger"));
|
||||
|
||||
var _encryptAttachment = _interopRequireDefault(require("./encrypt-attachment"));
|
||||
|
||||
global.Olm = require("olm");
|
||||
const BOT_SIGNAL_END_CHAT = 'END_CHAT';
|
||||
const BOT_SIGNAL_CHAT_OFFLINE = 'CHAT_OFFLINE';
|
||||
|
||||
class OcrccBot {
|
||||
constructor(botConfig) {
|
||||
this.config = botConfig;
|
||||
this.awaitingFacilitator = {};
|
||||
this.client = matrix.createClient(this.config.MATRIX_SERVER_URL);
|
||||
constructor(config) {
|
||||
this.config = config;
|
||||
this.client = matrix.createClient(this.config.matrixServerUrl);
|
||||
this.joinedRooms = [];
|
||||
this.inactivityTimers = {};
|
||||
}
|
||||
|
||||
createLocalStorage() {
|
||||
const storageLoc = `matrix-chatbot-${this.config.BOT_USERNAME}`;
|
||||
const storageLoc = `matrix-chatbot-${this.config.botUsername}`;
|
||||
const dir = path.resolve(path.join(os.homedir(), ".local-storage"));
|
||||
|
||||
if (!fs.existsSync(dir)) {
|
||||
@ -45,20 +49,47 @@ class OcrccBot {
|
||||
return new _nodeLocalstorage.LocalStorage(localStoragePath);
|
||||
}
|
||||
|
||||
sendTextMessage(roomId, msgText, showToUser = null) {
|
||||
async sendTextMessage(roomId, msgText, showToUser = null) {
|
||||
const content = {
|
||||
msgtype: "m.text",
|
||||
body: msgText,
|
||||
showToUser: showToUser
|
||||
};
|
||||
this.sendMessage(roomId, content);
|
||||
await this.sendMessage(roomId, content);
|
||||
}
|
||||
|
||||
async sendNotice(roomId, message) {
|
||||
try {
|
||||
await this.client.sendNotice(roomId, message);
|
||||
|
||||
_logger.default.log("info", `SENT *NOTICE*: ${message}`);
|
||||
} catch (err) {
|
||||
switch (err["name"]) {
|
||||
case "UnknownDeviceError":
|
||||
Object.keys(err.devices).forEach(userId => {
|
||||
Object.keys(err.devices[userId]).map(async deviceId => {
|
||||
try {
|
||||
await this.client.setDeviceVerified(userId, deviceId, true);
|
||||
} catch (err) {
|
||||
_logger.default.log("error", `ERROR VERIFYING DEVICE: ${err}`);
|
||||
}
|
||||
});
|
||||
});
|
||||
await this.sendNotice(roomId, message);
|
||||
|
||||
default:
|
||||
_logger.default.log("error", `ERROR SENDING *NOTICE*: ${err}`);
|
||||
|
||||
break;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
async sendMessage(roomId, content) {
|
||||
_logger.default.log("info", `SENDING MESSAGE: ${content.body}`);
|
||||
|
||||
try {
|
||||
await this.client.sendMessage(roomId, content);
|
||||
|
||||
_logger.default.log("info", `SENT MESSAGE: ${content.body}`);
|
||||
} catch (err) {
|
||||
switch (err["name"]) {
|
||||
case "UnknownDeviceError":
|
||||
@ -74,24 +105,16 @@ class OcrccBot {
|
||||
await this.sendMessage(roomId, content);
|
||||
|
||||
default:
|
||||
_logger.default.log("error", `ERROR SENDING MESSAGE: ${err}`);
|
||||
_logger.default.log("error", `ERROR SENDING MESSAGE ${content.body}: ${err}`);
|
||||
|
||||
break;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
inviteUserToRoom(roomId, member) {
|
||||
try {
|
||||
this.client.invite(roomId, member);
|
||||
} catch (err) {
|
||||
this.handleBotCrash(roomId, err);
|
||||
}
|
||||
}
|
||||
|
||||
kickUserFromRoom(roomId, member) {
|
||||
try {
|
||||
this.client.kick(roomId, member, this.config.KICK_REASON);
|
||||
this.client.kick(roomId, member, this.config.kickReason);
|
||||
} catch (err) {
|
||||
this.handleBotCrash(roomId, err);
|
||||
|
||||
@ -99,27 +122,50 @@ class OcrccBot {
|
||||
}
|
||||
}
|
||||
|
||||
async inviteFacilitators(roomId) {
|
||||
this.localStorage.setItem(`${roomId}-waiting`, 'true');
|
||||
let chatOffline = true;
|
||||
|
||||
try {
|
||||
const data = await this.client.getGroupUsers(this.config.FACILITATOR_GROUP_ID);
|
||||
const members = data.chunk;
|
||||
members.forEach(member => {
|
||||
const memberId = member.user_id;
|
||||
async inviteFacilitatorIfOnline(roomId, memberId) {
|
||||
const user = this.client.getUser(memberId);
|
||||
|
||||
if (user && user.presence === "online" && memberId !== this.config.BOT_USERID) {
|
||||
chatOffline = false;
|
||||
this.inviteUserToRoom(roomId, memberId);
|
||||
if (user && user.presence !== "offline" && memberId !== this.config.botUserId) {
|
||||
try {
|
||||
this.client.invite(roomId, memberId);
|
||||
|
||||
_logger.default.log("info", `CHAT INVITATION SENT TO ${memberId} FOR ROOM ${roomId}`);
|
||||
|
||||
return memberId;
|
||||
} catch (err) {
|
||||
this.handleBotCrash(roomId, err);
|
||||
return null;
|
||||
}
|
||||
} else {
|
||||
return null;
|
||||
}
|
||||
}
|
||||
});
|
||||
|
||||
if (chatOffline) {
|
||||
_logger.default.log('info', "NO FACILITATORS ONLINE");
|
||||
async inviteFacilitators(roomId) {
|
||||
try {
|
||||
this.localStorage.setItem(`${roomId}-waiting`, 'true');
|
||||
let invitations = [];
|
||||
const roomMembers = await this.client.getJoinedRoomMembers(this.config.facilitatorRoomId);
|
||||
const members = Object.keys(roomMembers["joined"]);
|
||||
|
||||
this.sendTextMessage(roomId, this.config.CHAT_OFFLINE_MESSAGE);
|
||||
for (const memberId of members) {
|
||||
const invited = await this.inviteFacilitatorIfOnline(roomId, memberId);
|
||||
invitations.push(invited);
|
||||
}
|
||||
|
||||
if (invitations.filter(i => i).length > 0) {
|
||||
this.localStorage.setItem(`${roomId}-invitations`, invitations);
|
||||
} else {
|
||||
this.sendBotSignal(roomId, BOT_SIGNAL_CHAT_OFFLINE); // send notification to Support Chat Notifications room
|
||||
|
||||
const currentDate = new Date();
|
||||
const closedTime = currentDate.toLocaleTimeString();
|
||||
const roomRef = roomId.split(':')[0];
|
||||
const notification = `No facilitators were online, chat closed at ${closedTime} (room ID: ${roomRef})`;
|
||||
|
||||
_logger.default.log('info', `NO FACILITATORS ONLINE, CHAT CLOSED AT ${closedTime} (room ID: ${roomRef})`);
|
||||
|
||||
this.sendTextMessage(this.config.facilitatorRoomId, notification);
|
||||
}
|
||||
} catch (err) {
|
||||
this.handleBotCrash(roomId, err);
|
||||
@ -129,15 +175,15 @@ class OcrccBot {
|
||||
}
|
||||
|
||||
async uninviteFacilitators(roomId) {
|
||||
this.localStorage.removeItem(`${roomId}-waiting`);
|
||||
|
||||
try {
|
||||
const groupUsers = await this.client.getGroupUsers(this.config.FACILITATOR_GROUP_ID);
|
||||
const roomMembers = await this.client.getJoinedRoomMembers(roomId);
|
||||
const membersIds = Object.keys(roomMembers["joined"]);
|
||||
const facilitatorsIds = groupUsers.chunk.map(f => f.user_id);
|
||||
this.localStorage.removeItem(`${roomId}-waiting`);
|
||||
const facilitatorsRoomMembers = await this.client.getJoinedRoomMembers(this.config.facilitatorRoomId);
|
||||
const supportRoomMembers = await this.client.getJoinedRoomMembers(roomId);
|
||||
const roomMembersIds = Object.keys(supportRoomMembers["joined"]);
|
||||
const facilitatorsIds = Object.keys(facilitatorsRoomMembers["joined"]);
|
||||
if (!roomMembersIds || !facilitatorsIds) return;
|
||||
facilitatorsIds.forEach(f => {
|
||||
if (!membersIds.includes(f)) {
|
||||
if (!roomMembersIds.includes(f)) {
|
||||
this.kickUserFromRoom(roomId, f);
|
||||
}
|
||||
});
|
||||
@ -150,17 +196,27 @@ class OcrccBot {
|
||||
|
||||
handleBotCrash(roomId, error) {
|
||||
if (roomId) {
|
||||
this.sendTextMessage(roomId, this.config.BOT_ERROR_MESSAGE);
|
||||
this.sendTextMessage(roomId, this.config.botErrorMessage);
|
||||
this.sendBotSignal(roomId, BOT_SIGNAL_END_CHAT);
|
||||
}
|
||||
|
||||
this.sendTextMessage(this.config.FACILITATOR_ROOM_ID, `The Help Bot ran into an error: ${error}. Please verify that the chat service is working.`);
|
||||
this.sendTextMessage(this.config.facilitatorRoomId, `${this.config.botDisplayName} ran into an error: ${error}. Please verify that the chat service is working.`);
|
||||
}
|
||||
|
||||
handleMessageEvent(event) {
|
||||
const content = event.getContent(); // do nothing if there's no content
|
||||
const content = event.getContent();
|
||||
const sender = event.getSender();
|
||||
const roomId = event.getRoomId(); // do nothing if there's no content
|
||||
|
||||
if (!content) {
|
||||
return;
|
||||
} // if it's a chat message and the facilitator has joined, reset the inactivity timeout
|
||||
|
||||
|
||||
const facilitatorId = this.localStorage.getItem(`${roomId}-facilitator`);
|
||||
|
||||
if (Boolean(facilitatorId) && sender !== this.config.botUserId) {
|
||||
this.setInactivityTimeout(roomId);
|
||||
} // bot commands
|
||||
|
||||
|
||||
@ -169,7 +225,7 @@ class OcrccBot {
|
||||
} // write to transcript
|
||||
|
||||
|
||||
if (this.config.CAPTURE_TRANSCRIPTS) {
|
||||
if (this.config.captureTranscripts) {
|
||||
return this.writeToTranscript(event);
|
||||
}
|
||||
}
|
||||
@ -186,7 +242,7 @@ class OcrccBot {
|
||||
const filepath = this.localStorage.getItem(`${roomId}-transcript`);
|
||||
|
||||
if (!filepath) {
|
||||
return _logger.default.log("error", `NO TRANSCRIPT FILE FOR ROOM: ${roomId}`);
|
||||
return _logger.default.log("error", `NO TRANSCRIPT FILE FOR ROOM: ${roomId}. This message will not be added: ${content.body}`);
|
||||
}
|
||||
|
||||
const message = `${sender} [${time}]: ${content.body}\n`;
|
||||
@ -197,37 +253,56 @@ class OcrccBot {
|
||||
}
|
||||
|
||||
handleBotCommand(event) {
|
||||
const botCommands = [{
|
||||
keyword: 'transcript',
|
||||
function: (senderId, roomId) => {
|
||||
this.sendTranscript(senderId, roomId);
|
||||
}
|
||||
}, {
|
||||
keyword: 'delete transcript',
|
||||
function: (senderId, roomId) => {
|
||||
this.deleteTranscript(senderId, roomId, true);
|
||||
} // delete transcript and send confirmation message
|
||||
|
||||
}, {
|
||||
keyword: 'say',
|
||||
function: (senderId, roomId, message) => {
|
||||
this.sendTextMessage(roomId, message, senderId);
|
||||
}
|
||||
}, {
|
||||
keyword: 'hi',
|
||||
function: (senderId, roomId) => {
|
||||
const responses = ["Hi!", "Hello", "Hey :)", "Hi there", "Bleep bloop"];
|
||||
const message = responses[Math.floor(Math.random() * responses.length)];
|
||||
this.sendTextMessage(roomId, message, senderId);
|
||||
}
|
||||
}, {
|
||||
keyword: 'bug',
|
||||
function: (senderId, roomId) => {
|
||||
const message = `Please report the issue at ${this.config.bugReportUrl}`;
|
||||
this.sendTextMessage(roomId, message, senderId);
|
||||
}
|
||||
}];
|
||||
|
||||
try {
|
||||
const senderId = event.getSender();
|
||||
const roomId = event.getRoomId();
|
||||
const content = event.getContent();
|
||||
const command = content.body.substring("!bot".length).trim();
|
||||
const commandText = content.body.substring("!bot".length).trim();
|
||||
const command = botCommands.find(c => commandText.startsWith(c.keyword));
|
||||
|
||||
switch (command) {
|
||||
case "transcript":
|
||||
this.sendTranscript(senderId, roomId);
|
||||
break;
|
||||
|
||||
case "transcript please":
|
||||
this.sendTranscript(senderId, roomId);
|
||||
break;
|
||||
|
||||
case "hi":
|
||||
const responses = ["Hi!", "Hello", "Hey :)", "Hi there", "Bleep bloop"];
|
||||
const message = responses[Math.floor(Math.random() * responses.length)];
|
||||
this.sendTextMessage(roomId, message, senderId);
|
||||
break;
|
||||
|
||||
default:
|
||||
if (!command) {
|
||||
this.sendTextMessage(roomId, `Sorry, I don't know that command. I'm not a very smart bot.`, senderId);
|
||||
break;
|
||||
}
|
||||
|
||||
const args = commandText.substring(command.keyword.length).trim();
|
||||
command.function(senderId, roomId, args);
|
||||
} catch (err) {
|
||||
_logger.default.log("error", `ERROR EXECUTING BOT COMMAND: ${err}`);
|
||||
}
|
||||
}
|
||||
|
||||
async leaveEmptyRooms(senderId) {
|
||||
async leaveEmptyRooms() {
|
||||
try {
|
||||
const roomData = await this.client.getJoinedRooms();
|
||||
const joinedRoomsIds = roomData["joined_rooms"];
|
||||
@ -236,16 +311,16 @@ class OcrccBot {
|
||||
|
||||
if (room && room.getJoinedMemberCount() === 1) {
|
||||
try {
|
||||
_logger.default.log('info', "LEAVING EMPTY ROOM => " + roomId);
|
||||
|
||||
await this.client.leave(roomId);
|
||||
|
||||
_logger.default.log('info', `LEAVING EMPTY ROOM => ${roomId}`);
|
||||
} catch (err) {
|
||||
_logger.default.log('error', "ERROR LEAVING EMPTY ROOM => " + err);
|
||||
_logger.default.log('error', `ERROR LEAVING ROOM ${roomId} => ${err}`);
|
||||
}
|
||||
}
|
||||
});
|
||||
} catch (err) {
|
||||
_logger.default.log("error", `ERROR GETTING JOINED ROOMS: ${err}`);
|
||||
_logger.default.log("error", `ERROR LEAVING EMPTY ROOMS: ${err}`);
|
||||
}
|
||||
}
|
||||
|
||||
@ -254,22 +329,58 @@ class OcrccBot {
|
||||
const transcriptFile = this.localStorage.getItem(`${roomId}-transcript`);
|
||||
|
||||
if (!transcriptFile) {
|
||||
this.sendTextMessage(roomId, "There is no transcript for this chat.", senderId);
|
||||
this.sendTextMessage(roomId, "Cannot send transcript, there is no transcript for this chat.", senderId);
|
||||
}
|
||||
|
||||
if (this.client.isRoomEncrypted(roomId)) {
|
||||
let encryptInfo;
|
||||
const filename = path.basename(transcriptFile) || "Transcript";
|
||||
const stream = fs.createReadStream(transcriptFile);
|
||||
const contentUrl = await this.client.uploadContent({
|
||||
stream: stream,
|
||||
const data = fs.readFileSync(transcriptFile);
|
||||
const encryptResult = await _encryptAttachment.default.encryptAttachment(data);
|
||||
const buffer = Buffer.from(encryptResult.data);
|
||||
encryptInfo = encryptResult.info;
|
||||
const url = await this.client.uploadContent(buffer, {
|
||||
rawResponse: false,
|
||||
name: filename
|
||||
});
|
||||
encryptInfo.url = url.content_uri;
|
||||
encryptInfo.mimetype = 'text/plain';
|
||||
const content = {
|
||||
msgtype: "m.file",
|
||||
body: filename,
|
||||
url: JSON.parse(contentUrl).content_uri,
|
||||
showToUser: senderId
|
||||
info: {
|
||||
mimetype: 'text/plain'
|
||||
},
|
||||
file: encryptInfo,
|
||||
url: url.content_uri,
|
||||
showToUser: senderId,
|
||||
mimetype: 'text/plain'
|
||||
};
|
||||
this.sendMessage(roomId, content);
|
||||
} else {
|
||||
const filename = path.basename(transcriptFile) || "Transcript";
|
||||
const file = fs.readFileSync(transcriptFile);
|
||||
const stats = fs.statSync(transcriptFile);
|
||||
const url = await this.client.uploadContent(file, {
|
||||
rawResponse: false,
|
||||
name: filename
|
||||
});
|
||||
|
||||
_logger.default.log('info', url);
|
||||
|
||||
const content = {
|
||||
msgtype: "m.file",
|
||||
body: filename,
|
||||
info: {
|
||||
size: stats.size,
|
||||
mimetype: 'text/plain'
|
||||
},
|
||||
url: url.content_uri,
|
||||
showToUser: senderId,
|
||||
mimetype: 'text/plain'
|
||||
};
|
||||
this.sendMessage(roomId, content);
|
||||
}
|
||||
} catch (err) {
|
||||
_logger.default.log("error", `ERROR UPLOADING CONTENT: ${err}`);
|
||||
|
||||
@ -277,6 +388,32 @@ class OcrccBot {
|
||||
}
|
||||
}
|
||||
|
||||
deleteTranscript(senderId, roomId, sendConfirmation = false) {
|
||||
const transcriptFile = this.localStorage.getItem(`${roomId}-transcript`);
|
||||
|
||||
if (!transcriptFile) {
|
||||
return this.sendTextMessage(roomId, "Cannot delete transcript, there is no transcript for this chat.", senderId);
|
||||
}
|
||||
|
||||
fs.unlink(transcriptFile, err => {
|
||||
if (err) {
|
||||
_logger.default.log('error', "UNABLE TO DELETE TRANSCRIPT FILE => " + transcriptFile);
|
||||
|
||||
_logger.default.log('error', err);
|
||||
|
||||
return this.sendTextMessage(roomId, `There was an error deleting the transcript: ${err}`, senderId);
|
||||
}
|
||||
|
||||
if (sendConfirmation) {
|
||||
this.sendTextMessage(roomId, `The transcript file has been deleted.`, senderId);
|
||||
}
|
||||
|
||||
_logger.default.log('info', "DELETED TRANSCRIPT FILE => " + transcriptFile);
|
||||
|
||||
this.localStorage.removeItem(`${roomId}-transcript`);
|
||||
});
|
||||
}
|
||||
|
||||
async deleteOldDevices() {
|
||||
const currentDeviceId = this.client.getDeviceId();
|
||||
const deviceData = await this.client.getDevices();
|
||||
@ -291,12 +428,12 @@ class OcrccBot {
|
||||
const auth = {
|
||||
session: err.data.session,
|
||||
type: "m.login.password",
|
||||
user: this.config.BOT_USERID,
|
||||
user: this.config.botUserId,
|
||||
identifier: {
|
||||
type: "m.id.user",
|
||||
user: this.config.BOT_USERID
|
||||
user: this.config.botUserId
|
||||
},
|
||||
password: this.config.BOT_PASSWORD
|
||||
password: this.config.botPassword
|
||||
};
|
||||
await this.client.deleteMultipleDevices(oldDevices, auth);
|
||||
|
||||
@ -314,22 +451,39 @@ class OcrccBot {
|
||||
async setMembershipListeners() {
|
||||
// Automatically accept all room invitations
|
||||
this.client.on("RoomMember.membership", async (event, member) => {
|
||||
if (member.membership === "invite" && member.userId === this.config.BOT_USERID && !this.joinedRooms.includes(member.roomId)) {
|
||||
if (member.membership === "invite" && member.userId === this.config.botUserId && !this.joinedRooms.includes(member.roomId)) {
|
||||
try {
|
||||
const roomData = await this.client.getJoinedRooms();
|
||||
const joinedRooms = roomData["joined_rooms"];
|
||||
|
||||
if (!joinedRooms.includes(member.roomId)) {
|
||||
const room = await this.client.joinRoom(member.roomId);
|
||||
|
||||
_logger.default.log("info", "AUTO JOINED ROOM => " + room.roomId);
|
||||
|
||||
this.sendTextMessage(this.config.FACILITATOR_ROOM_ID, `A support seeker requested a chat (Room ID: ${room.roomId})`);
|
||||
const inviteDate = event.getDate();
|
||||
const chatDate = inviteDate.toLocaleDateString();
|
||||
const chatTime = inviteDate.toLocaleTimeString();
|
||||
const roomId = room.roomId.split(':')[0];
|
||||
const notification = `Incoming support chat at ${chatTime} (room ID: ${roomId})`;
|
||||
this.sendTextMessage(this.config.facilitatorRoomId, notification);
|
||||
this.inviteFacilitators(room.roomId);
|
||||
this.setTimeoutforFacilitator(room.roomId);
|
||||
}
|
||||
} catch (err) {
|
||||
_logger.default.log("error", "ERROR JOINING ROOM => " + err);
|
||||
}
|
||||
} // When a facilitator joins a support session, make them a moderator
|
||||
// revoke the other invitations
|
||||
}
|
||||
|
||||
if (member.membership === "join" && member.userId !== this.config.botUserId && this.localStorage.getItem(`${member.roomId}-waiting`)) {
|
||||
try {
|
||||
// make sure it's a facilitator joining
|
||||
const roomMembers = await this.client.getJoinedRoomMembers(this.config.facilitatorRoomId);
|
||||
const members = Object.keys(roomMembers["joined"]);
|
||||
const isFacilitator = members.includes(member.userId);
|
||||
|
||||
if (member.membership === "join" && member.userId !== this.config.BOT_USERID && this.localStorage.getItem(`${member.roomId}-waiting`)) {
|
||||
if (isFacilitator) {
|
||||
// made facilitator a moderator in the room
|
||||
this.localStorage.setItem(`${member.roomId}-facilitator`, member.userId);
|
||||
const event = {
|
||||
getType: () => {
|
||||
@ -338,18 +492,25 @@ class OcrccBot {
|
||||
getContent: () => {
|
||||
return {
|
||||
users: {
|
||||
[this.config.BOT_USERID]: 100,
|
||||
[this.config.botUserId]: 100,
|
||||
[member.userId]: 50
|
||||
}
|
||||
};
|
||||
}
|
||||
};
|
||||
this.client.setPowerLevel(member.roomId, member.userId, 50, event);
|
||||
this.sendTextMessage(member.roomId, `${member.name} has joined the chat.`);
|
||||
this.sendTextMessage(this.config.FACILITATOR_ROOM_ID, `${member.name} joined the chat (Room ID: ${member.roomId})`);
|
||||
this.uninviteFacilitators(member.roomId);
|
||||
this.client.setPowerLevel(member.roomId, member.userId, 50, event); // send notification to Support Chat Notifications room
|
||||
|
||||
if (this.config.CAPTURE_TRANSCRIPTS) {
|
||||
const currentDate = new Date();
|
||||
const chatTime = currentDate.toLocaleTimeString();
|
||||
const roomId = member.roomId.split(':')[0];
|
||||
const notification = `${member.name} joined the chat at ${chatTime} (room ID: ${roomId})`;
|
||||
this.sendTextMessage(this.config.facilitatorRoomId, notification); // send notification to chat room
|
||||
|
||||
this.sendTextMessage(member.roomId, `${member.name} has joined the chat.`); // revoke the other invitations
|
||||
|
||||
this.uninviteFacilitators(member.roomId); // set transcript file
|
||||
|
||||
if (this.config.captureTranscripts) {
|
||||
const currentDate = new Date();
|
||||
const dateOpts = {
|
||||
year: "numeric",
|
||||
@ -365,31 +526,112 @@ class OcrccBot {
|
||||
this.localStorage.setItem(`${member.roomId}-transcript`, filepath);
|
||||
}
|
||||
}
|
||||
} catch (err) {
|
||||
_logger.default.log("error", `ERROR WHEN FACILITATOR JOINED ROOM ==> ${err}`);
|
||||
}
|
||||
}
|
||||
|
||||
if (member.membership === "leave" && member.userId !== this.config.BOT_USERID) {
|
||||
if (member.membership === "leave" && member.userId !== this.config.botUserId) {
|
||||
// notify room if the facilitator has left
|
||||
try {
|
||||
const facilitatorId = this.localStorage.getItem(`${member.roomId}-facilitator`);
|
||||
|
||||
if (member.userId === facilitatorId) {
|
||||
this.sendTextMessage(member.roomId, `${member.name} has left the chat.`);
|
||||
} // leave if there is nobody in the room
|
||||
this.sendTextMessage(member.roomId, `${member.name} has left the chat.`); // send notification to Support Chat Notifications room
|
||||
|
||||
const currentDate = new Date();
|
||||
const chatTime = currentDate.toLocaleTimeString();
|
||||
const roomId = member.roomId.split(':')[0];
|
||||
const notification = `${member.name} left the chat at ${chatTime} (room ID: ${roomId})`;
|
||||
await this.sendTextMessage(this.config.facilitatorRoomId, notification);
|
||||
}
|
||||
} catch (err) {
|
||||
_logger.default.log("error", `ERROR NOTIFYING THAT FACLITATOR HAS LEFT THE ROOM ==> ${err}`);
|
||||
}
|
||||
|
||||
const room = this.client.getRoom(member.roomId);
|
||||
if (!room) return;
|
||||
const memberCount = room.getJoinedMemberCount();
|
||||
const roomMembers = await room.getJoinedMembers(); // array
|
||||
// leave if there is nobody in the room
|
||||
|
||||
if (memberCount === 1) {
|
||||
// just the bot
|
||||
_logger.default.log("info", `LEAVING EMPTY ROOM ==> ${member.roomId}`);
|
||||
try {
|
||||
const memberCount = roomMembers.length;
|
||||
const isBotInRoom = Boolean(roomMembers.find(member => member.userId === this.config.botUserId));
|
||||
|
||||
this.client.leave(member.roomId);
|
||||
if (memberCount === 1 && isBotInRoom) {
|
||||
// just the bot left
|
||||
_logger.default.log("info", `LEAVING EMPTY ROOM: ${member.roomId}`);
|
||||
|
||||
this.deleteTranscript(member.userId, member.roomId);
|
||||
this.localStorage.removeItem(`${member.roomId}-facilitator`);
|
||||
this.localStorage.removeItem(`${member.roomId}-transcript`);
|
||||
this.localStorage.removeItem(`${member.roomId}-waiting`);
|
||||
return await this.client.leave(member.roomId);
|
||||
}
|
||||
} catch (err) {
|
||||
return _logger.default.log("error", `ERROR LEAVING EMPTY ROOM ==> ${err}`);
|
||||
} // send signal to close the chat if there are no facilitators in the room
|
||||
|
||||
|
||||
try {
|
||||
const facilitatorRoomMembers = await this.client.getJoinedRoomMembers(this.config.facilitatorRoomId); // object
|
||||
|
||||
const facilitators = facilitatorRoomMembers['joined'];
|
||||
let facilitatorInRoom = false;
|
||||
roomMembers.forEach(member => {
|
||||
if (member.userId !== this.config.botUserId && Boolean(facilitators[member.userId])) {
|
||||
facilitatorInRoom = true;
|
||||
}
|
||||
});
|
||||
|
||||
if (!facilitatorInRoom) {
|
||||
_logger.default.log("info", `NO FACILITATORS LEFT, SENDING SIGNAL TO END CHAT`);
|
||||
|
||||
this.sendBotSignal(member.roomId, BOT_SIGNAL_END_CHAT);
|
||||
}
|
||||
} catch (err) {
|
||||
_logger.default.log("error", `ERROR SENDING BOT SIGNAL ==> ${err}`);
|
||||
}
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
setTimeoutforFacilitator(roomId) {
|
||||
setTimeout(async () => {
|
||||
const stillWaiting = this.localStorage.getItem(`${roomId}-waiting`);
|
||||
|
||||
if (stillWaiting) {
|
||||
await this.sendTextMessage(roomId, this.config.chatNotAvailableMessage);
|
||||
this.sendBotSignal(roomId, BOT_SIGNAL_END_CHAT); // send notification to Support Chat Notifications room
|
||||
|
||||
const currentDate = new Date();
|
||||
const closedTime = currentDate.toLocaleTimeString();
|
||||
const roomRef = roomId.split(':')[0];
|
||||
const notification = `No facilitators joined the chat within the maximum wait time, chat closed at ${closedTime} (room ID: ${roomRef})`;
|
||||
this.sendTextMessage(this.config.facilitatorRoomId, notification);
|
||||
|
||||
_logger.default.log("info", `NO FACILITATORS JOINED THE CHAT WITHIN THE MAXIMUM WAIT TIME, CHAT CLOSED AT ${closedTime} (room ID: ${roomRef})`);
|
||||
}
|
||||
}, this.config.maxWaitTime * 1000); // convert seconds to milliseconds
|
||||
}
|
||||
|
||||
setInactivityTimeout(roomId) {
|
||||
const oldTimeout = this.inactivityTimers[roomId];
|
||||
|
||||
if (oldTimeout) {
|
||||
clearTimeout(oldTimeout);
|
||||
}
|
||||
|
||||
const newTimeout = setTimeout(async () => {
|
||||
_logger.default.log("info", `CHAT IS INACTIVE, SENDING SIGNAL TO END CHAT`);
|
||||
|
||||
await this.sendTextMessage(roomId, this.config.chatInactiveMessage);
|
||||
this.sendBotSignal(roomId, BOT_SIGNAL_END_CHAT);
|
||||
}, this.config.maxInactiveTime * 1000); // convert seconds to milliseconds
|
||||
|
||||
this.inactivityTimers[roomId] = newTimeout;
|
||||
}
|
||||
|
||||
async setMessageListeners() {
|
||||
// encrypted messages
|
||||
this.client.on("Event.decrypted", (event, err) => {
|
||||
@ -409,47 +651,55 @@ class OcrccBot {
|
||||
});
|
||||
}
|
||||
|
||||
async leaveOldRooms() {
|
||||
const roomData = await this.client.getJoinedRooms();
|
||||
roomData["joined_rooms"].forEach(async roomId => {
|
||||
async sendBotSignal(roomId, signal, args) {
|
||||
let content = {
|
||||
signal: signal,
|
||||
args: args
|
||||
};
|
||||
|
||||
try {
|
||||
await this.client.leave(roomId);
|
||||
await this.client.sendStateEvent(roomId, 'm.bot.signal', content);
|
||||
} catch (err) {
|
||||
_logger.default.log('error', "ERROR LEAVING ROOM => " + err);
|
||||
_logger.default.log('error', "ERROR SENDING BOT SIGNAL => " + err);
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
async start() {
|
||||
try {
|
||||
const localStorage = this.createLocalStorage();
|
||||
this.localStorage = localStorage;
|
||||
|
||||
try {
|
||||
const auth = {
|
||||
user: this.config.BOT_USERNAME,
|
||||
password: this.config.BOT_PASSWORD,
|
||||
initial_device_display_name: this.config.BOT_DISPLAY_NAME
|
||||
user: this.config.botUsername,
|
||||
password: this.config.botPassword,
|
||||
initial_device_display_name: this.config.botDisplayName
|
||||
};
|
||||
const account = await this.client.login("m.login.password", auth);
|
||||
|
||||
_logger.default.log("info", `ACCOUNT ==> ${JSON.stringify(account)}`);
|
||||
|
||||
let opts = {
|
||||
baseUrl: this.config.MATRIX_SERVER_URL,
|
||||
baseUrl: this.config.matrixServerUrl,
|
||||
accessToken: account.access_token,
|
||||
userId: this.config.BOT_USERID,
|
||||
userId: this.config.botUserId,
|
||||
deviceId: account.device_id,
|
||||
sessionStore: new matrix.WebStorageSessionStore(localStorage)
|
||||
};
|
||||
this.client = matrix.createClient(opts);
|
||||
await this.deleteOldDevices();
|
||||
await this.trackJoinedRooms();
|
||||
await this.client.initCrypto();
|
||||
await this.setMembershipListeners();
|
||||
await this.setMessageListeners();
|
||||
this.client.startClient({
|
||||
initialSyncLimit: 0
|
||||
});
|
||||
this.client.once('sync', async (state, prevState, data) => {
|
||||
_logger.default.log("info", `SYNC STATUS: ${state}`);
|
||||
|
||||
if (state === 'PREPARED') {
|
||||
await this.deleteOldDevices();
|
||||
await this.leaveEmptyRooms();
|
||||
await this.trackJoinedRooms();
|
||||
await this.setMembershipListeners();
|
||||
await this.setMessageListeners();
|
||||
}
|
||||
});
|
||||
} catch (err) {
|
||||
this.handleBotCrash(undefined, err);
|
||||
|
||||
|
72
dist/bot.test.js
vendored
72
dist/bot.test.js
vendored
@ -18,6 +18,36 @@ var _bot = _interopRequireDefault(require("./bot"));
|
||||
|
||||
require('dotenv').config();
|
||||
|
||||
const ENCRYPTION_CONFIG = {
|
||||
algorithm: "m.megolm.v1.aes-sha2"
|
||||
};
|
||||
const KICK_REASON = "A facilitator has already joined this chat.";
|
||||
const BOT_ERROR_MESSAGE = "Something went wrong on our end, please restart the chat and try again.";
|
||||
const MAX_RETRIES = 3;
|
||||
const {
|
||||
MATRIX_SERVER_URL,
|
||||
BOT_USERNAME,
|
||||
BOT_USERID,
|
||||
BOT_PASSWORD,
|
||||
BOT_DISPLAY_NAME,
|
||||
FACILITATOR_ROOM_ID,
|
||||
CHAT_OFFLINE_MESSAGE,
|
||||
CAPTURE_TRANSCRIPTS
|
||||
} = process.env;
|
||||
const botConfig = {
|
||||
ENCRYPTION_CONFIG,
|
||||
KICK_REASON,
|
||||
BOT_ERROR_MESSAGE,
|
||||
MAX_RETRIES,
|
||||
MATRIX_SERVER_URL,
|
||||
BOT_USERNAME,
|
||||
BOT_USERID,
|
||||
BOT_PASSWORD,
|
||||
BOT_DISPLAY_NAME,
|
||||
FACILITATOR_ROOM_ID,
|
||||
CHAT_OFFLINE_MESSAGE,
|
||||
CAPTURE_TRANSCRIPTS
|
||||
};
|
||||
const mockAppendFileSync = jest.fn();
|
||||
fs.appendFileSync = mockAppendFileSync;
|
||||
describe('OcrccBot', () => {
|
||||
@ -73,21 +103,21 @@ describe('OcrccBot', () => {
|
||||
mockAppendFileSync.mockClear();
|
||||
|
||||
_matrixJsSdk.mockGetGroupUsers.mockClear();
|
||||
|
||||
_matrixJsSdk.mockSendStateEvent.mockClear();
|
||||
});
|
||||
test('constructor should inititialize class variables', () => {
|
||||
const bot = new _bot.default();
|
||||
const bot = new _bot.default(botConfig);
|
||||
expect(bot.joinedRooms).toEqual([]);
|
||||
expect(bot.awaitingFacilitator).toEqual({});
|
||||
expect(bot.activeChatrooms).toEqual({});
|
||||
});
|
||||
test('#createLocalStorage should have correct storage location', () => {
|
||||
const bot = new _bot.default();
|
||||
const bot = new _bot.default(botConfig);
|
||||
const localStorage = bot.createLocalStorage();
|
||||
const localStoragePath = path.resolve(path.join(os.homedir(), ".local-storage", `matrix-chatbot-${process.env.BOT_USERNAME}`));
|
||||
expect(localStorage._location).toBe(localStoragePath);
|
||||
});
|
||||
test('#sendMessage should send a text message', () => {
|
||||
const bot = new _bot.default();
|
||||
const bot = new _bot.default(botConfig);
|
||||
bot.start();
|
||||
(0, _waitForExpect.default)(() => {
|
||||
expect(_matrixJsSdk.mockStartClient).toHaveBeenCalled();
|
||||
@ -103,7 +133,7 @@ describe('OcrccBot', () => {
|
||||
});
|
||||
});
|
||||
test('#inviteUserToRoom should add member to room and retry on rate limit error', () => {
|
||||
const bot = new _bot.default();
|
||||
const bot = new _bot.default(botConfig);
|
||||
bot.start();
|
||||
(0, _waitForExpect.default)(() => {
|
||||
expect(_matrixJsSdk.mockStartClient).toHaveBeenCalled();
|
||||
@ -114,7 +144,7 @@ describe('OcrccBot', () => {
|
||||
});
|
||||
});
|
||||
test('#kickUserFromRoom should remove member from room and retry on rate limit error', () => {
|
||||
const bot = new _bot.default();
|
||||
const bot = new _bot.default(botConfig);
|
||||
bot.start();
|
||||
(0, _waitForExpect.default)(() => {
|
||||
expect(_matrixJsSdk.mockStartClient).toHaveBeenCalled();
|
||||
@ -125,7 +155,7 @@ describe('OcrccBot', () => {
|
||||
});
|
||||
});
|
||||
test('#inviteFacilitators should invite all members from Facilitator room', () => {
|
||||
const bot = new _bot.default();
|
||||
const bot = new _bot.default(botConfig);
|
||||
bot.start();
|
||||
(0, _waitForExpect.default)(() => {
|
||||
expect(_matrixJsSdk.mockStartClient).toHaveBeenCalled();
|
||||
@ -142,7 +172,7 @@ describe('OcrccBot', () => {
|
||||
});
|
||||
});
|
||||
test('#uninviteFacilitators should remove all members that have not accepted the invite', () => {
|
||||
const bot = new _bot.default();
|
||||
const bot = new _bot.default(botConfig);
|
||||
bot.start();
|
||||
(0, _waitForExpect.default)(() => {
|
||||
expect(_matrixJsSdk.mockStartClient).toHaveBeenCalled();
|
||||
@ -159,7 +189,7 @@ describe('OcrccBot', () => {
|
||||
});
|
||||
});
|
||||
test('#handleBotCrash should notify rooms', () => {
|
||||
const bot = new _bot.default();
|
||||
const bot = new _bot.default(botConfig);
|
||||
bot.start();
|
||||
(0, _waitForExpect.default)(() => {
|
||||
expect(_matrixJsSdk.mockStartClient).toHaveBeenCalled();
|
||||
@ -173,11 +203,9 @@ describe('OcrccBot', () => {
|
||||
});
|
||||
});
|
||||
test('#writeToTranscript should parse event and write to transcript file', () => {
|
||||
const bot = new _bot.default();
|
||||
const bot = new _bot.default(botConfig);
|
||||
bot.start();
|
||||
bot.activeChatrooms['test_room_id'] = {
|
||||
transcriptFile: '__mocks__/test_transcript.txt'
|
||||
};
|
||||
bot.localStorage.setItem(`test_room_id-transcript`, '__mocks__/test_transcript.txt');
|
||||
(0, _waitForExpect.default)(() => {
|
||||
expect(_matrixJsSdk.mockStartClient).toHaveBeenCalled();
|
||||
});
|
||||
@ -199,7 +227,7 @@ describe('OcrccBot', () => {
|
||||
});
|
||||
});
|
||||
test('#deleteOldDevices should delete old sessions', () => {
|
||||
const bot = new _bot.default();
|
||||
const bot = new _bot.default(botConfig);
|
||||
bot.start();
|
||||
(0, _waitForExpect.default)(() => {
|
||||
expect(_matrixJsSdk.mockStartClient).toHaveBeenCalled();
|
||||
@ -217,7 +245,7 @@ describe('OcrccBot', () => {
|
||||
}); // TODO test listeners for membership events and message events
|
||||
|
||||
test('#start should start bot and set up listeners', () => {
|
||||
const bot = new _bot.default();
|
||||
const bot = new _bot.default(botConfig);
|
||||
bot.start();
|
||||
(0, _waitForExpect.default)(() => {
|
||||
expect(_matrixJsSdk.mockLogin).toHaveBeenCalled();
|
||||
@ -250,4 +278,16 @@ describe('OcrccBot', () => {
|
||||
expect(_matrixJsSdk.mockStartClient).toHaveBeenCalled();
|
||||
});
|
||||
});
|
||||
test('#sendBotSignal should send custom state event', () => {
|
||||
const bot = new _bot.default(botConfig);
|
||||
bot.start();
|
||||
const test_room_id = 'test_room_id';
|
||||
const signal = 'END_CHAT';
|
||||
bot.sendBotSignal(test_room_id, signal);
|
||||
(0, _waitForExpect.default)(() => {
|
||||
expect(_matrixJsSdk.mockSendStateEvent).toHaveBeenCalledWith(test_room_id, 'm.bot.signal', {
|
||||
signal
|
||||
});
|
||||
});
|
||||
});
|
||||
});
|
173
dist/encrypt-attachment.js
vendored
Normal file
173
dist/encrypt-attachment.js
vendored
Normal file
@ -0,0 +1,173 @@
|
||||
"use strict";
|
||||
|
||||
// this is from https://github.com/matrix-org/browser-encrypt-attachment
|
||||
// which is the library used by matrix-reack-sdk to encrypt and decrypt attachments
|
||||
// just dropped in node-webcrypto-ossl to replace window.crypto
|
||||
// and Buffer for base64 encoding/decoding instead of window.btoa/window.atob
|
||||
|
||||
/**
|
||||
* Encrypt an attachment.
|
||||
* @param {ArrayBuffer} plaintextBuffer The attachment data buffer.
|
||||
* @return {Promise} A promise that resolves with an object when the attachment is encrypted.
|
||||
* The object has a "data" key with an ArrayBuffer of encrypted data and an "info" key
|
||||
* with an object containing the info needed to decrypt the data.
|
||||
*/
|
||||
const {
|
||||
Crypto
|
||||
} = require("node-webcrypto-ossl");
|
||||
|
||||
const crypto = new Crypto();
|
||||
|
||||
function encryptAttachment(plaintextBuffer) {
|
||||
var cryptoKey; // The AES key object.
|
||||
|
||||
var exportedKey; // The AES key exported as JWK.
|
||||
|
||||
var ciphertextBuffer; // ArrayBuffer of encrypted data.
|
||||
|
||||
var sha256Buffer; // ArrayBuffer of digest.
|
||||
|
||||
var ivArray; // Uint8Array of AES IV
|
||||
// Generate an IV where the first 8 bytes are random and the high 8 bytes
|
||||
// are zero. We set the counter low bits to 0 since it makes it unlikely
|
||||
// that the 64 bit counter will overflow.
|
||||
|
||||
ivArray = new Uint8Array(16);
|
||||
crypto.getRandomValues(ivArray.subarray(0, 8)); // Load the encryption key.
|
||||
|
||||
return crypto.subtle.generateKey({
|
||||
"name": "AES-CTR",
|
||||
length: 256
|
||||
}, true, ["encrypt", "decrypt"]).then(function (generateKeyResult) {
|
||||
cryptoKey = generateKeyResult; // Export the Key as JWK.
|
||||
|
||||
return crypto.subtle.exportKey("jwk", cryptoKey);
|
||||
}).then(function (exportKeyResult) {
|
||||
exportedKey = exportKeyResult; // Encrypt the input ArrayBuffer.
|
||||
// Use half of the iv as the counter by setting the "length" to 64.
|
||||
|
||||
return crypto.subtle.encrypt({
|
||||
name: "AES-CTR",
|
||||
counter: ivArray,
|
||||
length: 64
|
||||
}, cryptoKey, plaintextBuffer);
|
||||
}).then(function (encryptResult) {
|
||||
ciphertextBuffer = encryptResult; // SHA-256 the encrypted data.
|
||||
|
||||
return crypto.subtle.digest("SHA-256", ciphertextBuffer);
|
||||
}).then(function (digestResult) {
|
||||
sha256Buffer = digestResult;
|
||||
return {
|
||||
data: ciphertextBuffer,
|
||||
info: {
|
||||
v: "v2",
|
||||
key: exportedKey,
|
||||
iv: encodeBase64(ivArray),
|
||||
hashes: {
|
||||
sha256: encodeBase64(new Uint8Array(sha256Buffer))
|
||||
}
|
||||
}
|
||||
};
|
||||
});
|
||||
}
|
||||
/**
|
||||
* Decrypt an attachment.
|
||||
* @param {ArrayBuffer} ciphertextBuffer The encrypted attachment data buffer.
|
||||
* @param {Object} info The information needed to decrypt the attachment.
|
||||
* @param {Object} info.key AES-CTR JWK key object.
|
||||
* @param {string} info.iv Base64 encoded 16 byte AES-CTR IV.
|
||||
* @param {string} info.hashes.sha256 Base64 encoded SHA-256 hash of the ciphertext.
|
||||
* @return {Promise} A promise that resolves with an ArrayBuffer when the attachment is decrypted.
|
||||
*/
|
||||
|
||||
|
||||
function decryptAttachment(ciphertextBuffer, info) {
|
||||
if (info === undefined || info.key === undefined || info.iv === undefined || info.hashes === undefined || info.hashes.sha256 === undefined) {
|
||||
throw new Error("Invalid info. Missing info.key, info.iv or info.hashes.sha256 key");
|
||||
}
|
||||
|
||||
var cryptoKey; // The AES key object.
|
||||
|
||||
var ivArray = decodeBase64(info.iv);
|
||||
var expectedSha256base64 = info.hashes.sha256; // Load the AES from the "key" key of the info object.
|
||||
|
||||
return crypto.subtle.importKey("jwk", info.key, {
|
||||
"name": "AES-CTR"
|
||||
}, false, ["encrypt", "decrypt"]).then(function (importKeyResult) {
|
||||
cryptoKey = importKeyResult; // Check the sha256 hash
|
||||
|
||||
return crypto.subtle.digest("SHA-256", ciphertextBuffer);
|
||||
}).then(function (digestResult) {
|
||||
if (encodeBase64(new Uint8Array(digestResult)) != expectedSha256base64) {
|
||||
throw new Error("Mismatched SHA-256 digest");
|
||||
}
|
||||
|
||||
var counterLength;
|
||||
|
||||
if (info.v == "v1" || info.v == "v2") {
|
||||
// Version 1 and 2 use a 64 bit counter.
|
||||
counterLength = 64;
|
||||
} else {
|
||||
// Version 0 uses a 128 bit counter.
|
||||
counterLength = 128;
|
||||
}
|
||||
|
||||
return crypto.subtle.decrypt({
|
||||
name: "AES-CTR",
|
||||
counter: ivArray,
|
||||
length: counterLength
|
||||
}, cryptoKey, ciphertextBuffer);
|
||||
});
|
||||
}
|
||||
/**
|
||||
* Encode a typed array of uint8 as base64.
|
||||
* @param {Uint8Array} uint8Array The data to encode.
|
||||
* @return {string} The base64 without padding.
|
||||
*/
|
||||
|
||||
|
||||
function encodeBase64(uint8Array) {
|
||||
// Misinterpt the Uint8Array as Latin-1.
|
||||
// window.btoa expects a unicode string with codepoints in the range 0-255.
|
||||
var latin1String = String.fromCharCode.apply(null, uint8Array); // Use the builtin base64 encoder.
|
||||
// var paddedBase64 = window.btoa(latin1String);
|
||||
|
||||
var paddedBase64 = Buffer.from(latin1String, 'binary').toString('base64'); // Calculate the unpadded length.
|
||||
|
||||
var inputLength = uint8Array.length;
|
||||
var outputLength = 4 * Math.floor((inputLength + 2) / 3) + (inputLength + 2) % 3 - 2; // Return the unpadded base64.
|
||||
|
||||
return paddedBase64.slice(0, outputLength);
|
||||
}
|
||||
/**
|
||||
* Decode a base64 string to a typed array of uint8.
|
||||
* This will decode unpadded base64, but will also accept base64 with padding.
|
||||
* @param {string} base64 The unpadded base64 to decode.
|
||||
* @return {Uint8Array} The decoded data.
|
||||
*/
|
||||
|
||||
|
||||
function decodeBase64(base64) {
|
||||
// Pad the base64 up to the next multiple of 4.
|
||||
var paddedBase64 = base64 + "===".slice(0, (4 - base64.length % 4) % 4); // Decode the base64 as a misinterpreted Latin-1 string.
|
||||
// window.atob returns a unicode string with codepoints in the range 0-255.
|
||||
// var latin1String = window.atob(paddedBase64);
|
||||
|
||||
var latin1String = Buffer.from(paddedBase64, 'base64').toString('binary'); // Encode the string as a Uint8Array as Latin-1.
|
||||
|
||||
var uint8Array = new Uint8Array(latin1String.length);
|
||||
|
||||
for (var i = 0; i < latin1String.length; i++) {
|
||||
uint8Array[i] = latin1String.charCodeAt(i);
|
||||
}
|
||||
|
||||
return uint8Array;
|
||||
}
|
||||
|
||||
try {
|
||||
exports.encryptAttachment = encryptAttachment;
|
||||
exports.decryptAttachment = decryptAttachment;
|
||||
} catch (e) {// Ignore unknown variable "exports" errors when this is loaded directly into a browser
|
||||
// This means that we can test it without having to use browserify.
|
||||
// The intention is that the library is used using browserify.
|
||||
}
|
43
dist/index.js
vendored
43
dist/index.js
vendored
@ -2,41 +2,14 @@
|
||||
|
||||
var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");
|
||||
|
||||
var _config = _interopRequireDefault(require("../config.json"));
|
||||
|
||||
var _bot = _interopRequireDefault(require("./bot"));
|
||||
|
||||
require('dotenv').config();
|
||||
const bot = new _bot.default(_config.default);
|
||||
|
||||
const ENCRYPTION_CONFIG = {
|
||||
algorithm: "m.megolm.v1.aes-sha2"
|
||||
};
|
||||
const KICK_REASON = "A facilitator has already joined this chat.";
|
||||
const BOT_ERROR_MESSAGE = "Something went wrong on our end, please restart the chat and try again.";
|
||||
const MAX_RETRIES = 3;
|
||||
const {
|
||||
MATRIX_SERVER_URL,
|
||||
BOT_USERNAME,
|
||||
BOT_USERID,
|
||||
BOT_PASSWORD,
|
||||
BOT_DISPLAY_NAME,
|
||||
FACILITATOR_GROUP_ID,
|
||||
FACILITATOR_ROOM_ID,
|
||||
CHAT_OFFLINE_MESSAGE,
|
||||
CAPTURE_TRANSCRIPTS
|
||||
} = process.env;
|
||||
const botConfig = {
|
||||
ENCRYPTION_CONFIG,
|
||||
KICK_REASON,
|
||||
BOT_ERROR_MESSAGE,
|
||||
MAX_RETRIES,
|
||||
MATRIX_SERVER_URL,
|
||||
BOT_USERNAME,
|
||||
BOT_USERID,
|
||||
BOT_PASSWORD,
|
||||
BOT_DISPLAY_NAME,
|
||||
FACILITATOR_GROUP_ID,
|
||||
FACILITATOR_ROOM_ID,
|
||||
CHAT_OFFLINE_MESSAGE,
|
||||
CAPTURE_TRANSCRIPTS
|
||||
};
|
||||
const bot = new _bot.default(botConfig);
|
||||
bot.start();
|
||||
try {
|
||||
bot.start();
|
||||
} catch (err) {
|
||||
console.log("Unable to start bot", err);
|
||||
}
|
54
dist/setup.js
vendored
Normal file
54
dist/setup.js
vendored
Normal file
@ -0,0 +1,54 @@
|
||||
"use strict";
|
||||
|
||||
const fs = require('fs');
|
||||
|
||||
const fetch = require('node-fetch');
|
||||
|
||||
const config = require('../config.json');
|
||||
|
||||
const getSettings = async () => {
|
||||
try {
|
||||
const url = `${config.settingsEndpoint}?homeserver=${encodeURIComponent(config.matrixServerUrl)}`;
|
||||
|
||||
if (!config.matrixServerUrl) {
|
||||
throw new Error("The matrix server url is not provided");
|
||||
}
|
||||
|
||||
console.log(`Fetching settings for ${config.matrixServerUrl}`);
|
||||
const res = await fetch(url);
|
||||
const data = await res.json();
|
||||
const {
|
||||
fields,
|
||||
schedule = []
|
||||
} = data;
|
||||
return Object.entries(fields).reduce((settingsObj, [k, v]) => {
|
||||
const [scope, key] = k.split('_');
|
||||
|
||||
if (scope === 'platform') {
|
||||
settingsObj[key] = v;
|
||||
}
|
||||
|
||||
return settingsObj;
|
||||
}, {});
|
||||
} catch (err) {
|
||||
console.log("Error fetching settings", err);
|
||||
return null;
|
||||
}
|
||||
};
|
||||
|
||||
const writeConfig = async () => {
|
||||
const settings = await getSettings();
|
||||
|
||||
if (!settings) {
|
||||
return console.log('No settings to update');
|
||||
}
|
||||
|
||||
const updatedSettings = Object.assign(config, settings);
|
||||
fs.writeFile('config.json', JSON.stringify(updatedSettings, null, 2), function (err) {
|
||||
if (err) return console.log("Error updating settings", err);
|
||||
console.log(`Updated settings to config.json`);
|
||||
console.log(updatedSettings);
|
||||
});
|
||||
};
|
||||
|
||||
writeConfig();
|
@ -1,11 +1,12 @@
|
||||
{
|
||||
"name": "private-safesupport-bot",
|
||||
"version": "1.1.3",
|
||||
"version": "3.1.0",
|
||||
"description": "Chatbot to manage interactions on Safe Support Chat",
|
||||
"main": "dist/index.js",
|
||||
"scripts": {
|
||||
"develop": "nodemon --exec babel-node src/index.js",
|
||||
"build": "babel src -d dist",
|
||||
"setup": "node src/setup.js",
|
||||
"start": "yarn build && node dist/index.js",
|
||||
"test": "jest"
|
||||
},
|
||||
@ -14,7 +15,9 @@
|
||||
"dependencies": {
|
||||
"dotenv": "^8.2.0",
|
||||
"matrix-js-sdk": "^6.2.1",
|
||||
"node-fetch": "^2.6.1",
|
||||
"node-localstorage": "^2.1.5",
|
||||
"node-webcrypto-ossl": "^2.1.0",
|
||||
"olm": "https://packages.matrix.org/npm/olm/olm-3.1.4.tgz",
|
||||
"uuidv4": "^6.0.2",
|
||||
"winston": "^3.2.1"
|
||||
|
16
sample.config.json
Normal file
16
sample.config.json
Normal file
@ -0,0 +1,16 @@
|
||||
{
|
||||
"matrixServerUrl": "",
|
||||
"settingsEndpoint": "",
|
||||
"facilitatorRoomId": "",
|
||||
"kickReason": "A facilitator has already joined this chat.",
|
||||
"botErrorMessage": "Something went wrong on our end, please restart the chat and try again.",
|
||||
"botUserId": "",
|
||||
"botUsername": "",
|
||||
"botPassword": "",
|
||||
"botDisplayName": "Help Bot",
|
||||
"captureTranscripts": true,
|
||||
"chatNotAvailableMessage": "The support chat is not available right now.",
|
||||
"chatInactiveMessage": "This chat has been closed due to inactivity.",
|
||||
"maxWaitTime": 180,
|
||||
"maxInactiveTime": 3600
|
||||
}
|
398
src/bot.js
398
src/bot.js
@ -9,17 +9,21 @@ global.Olm = require("olm");
|
||||
import * as matrix from "matrix-js-sdk";
|
||||
|
||||
import logger from "./logger";
|
||||
import encrypt from "./encrypt-attachment";
|
||||
|
||||
const BOT_SIGNAL_END_CHAT = 'END_CHAT'
|
||||
const BOT_SIGNAL_CHAT_OFFLINE = 'CHAT_OFFLINE'
|
||||
|
||||
class OcrccBot {
|
||||
constructor(botConfig) {
|
||||
this.config = botConfig
|
||||
this.client = matrix.createClient(this.config.MATRIX_SERVER_URL);
|
||||
constructor(config) {
|
||||
this.config = config
|
||||
this.client = matrix.createClient(this.config.matrixServerUrl);
|
||||
this.joinedRooms = [];
|
||||
this.inactivityTimers = {};
|
||||
}
|
||||
|
||||
createLocalStorage() {
|
||||
const storageLoc = `matrix-chatbot-${this.config.BOT_USERNAME}`;
|
||||
const storageLoc = `matrix-chatbot-${this.config.botUsername}`;
|
||||
const dir = path.resolve(path.join(os.homedir(), ".local-storage"));
|
||||
if (!fs.existsSync(dir)) {
|
||||
fs.mkdirSync(dir);
|
||||
@ -28,21 +32,20 @@ class OcrccBot {
|
||||
return new LocalStorage(localStoragePath);
|
||||
}
|
||||
|
||||
sendTextMessage(roomId, msgText, showToUser = null) {
|
||||
async sendTextMessage(roomId, msgText, showToUser = null) {
|
||||
const content = {
|
||||
msgtype: "m.text",
|
||||
body: msgText,
|
||||
showToUser: showToUser
|
||||
};
|
||||
|
||||
this.sendMessage(roomId, content);
|
||||
await this.sendMessage(roomId, content);
|
||||
}
|
||||
|
||||
|
||||
async sendNotice(roomId, message) {
|
||||
logger.log("info", `SENDING *NOTICE*: ${message}`)
|
||||
try {
|
||||
await this.client.sendNotice(roomId, message)
|
||||
logger.log("info", `SENT *NOTICE*: ${message}`)
|
||||
} catch(err) {
|
||||
switch (err["name"]) {
|
||||
case "UnknownDeviceError":
|
||||
@ -64,9 +67,9 @@ class OcrccBot {
|
||||
}
|
||||
|
||||
async sendMessage(roomId, content) {
|
||||
logger.log("info", `SENDING MESSAGE: ${content.body}`)
|
||||
try {
|
||||
await this.client.sendMessage(roomId, content)
|
||||
logger.log("info", `SENT MESSAGE: ${content.body}`)
|
||||
} catch(err) {
|
||||
switch (err["name"]) {
|
||||
case "UnknownDeviceError":
|
||||
@ -81,54 +84,65 @@ class OcrccBot {
|
||||
});
|
||||
await this.sendMessage(roomId, content);
|
||||
default:
|
||||
logger.log("error", `ERROR SENDING MESSAGE: ${err}`);
|
||||
logger.log("error", `ERROR SENDING MESSAGE ${content.body}: ${err}`);
|
||||
break;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
inviteUserToRoom(roomId, member) {
|
||||
try {
|
||||
this.client.invite(roomId, member)
|
||||
} catch(err) {
|
||||
this.handleBotCrash(roomId, err);
|
||||
}
|
||||
}
|
||||
|
||||
kickUserFromRoom(roomId, member) {
|
||||
try {
|
||||
this.client.kick(roomId, member, this.config.KICK_REASON)
|
||||
this.client.kick(roomId, member, this.config.kickReason)
|
||||
} catch(err) {
|
||||
this.handleBotCrash(roomId, err);
|
||||
logger.log("error", `ERROR KICKING OUT MEMBER: ${err}`);
|
||||
}
|
||||
}
|
||||
|
||||
async inviteFacilitators(roomId) {
|
||||
this.localStorage.setItem(`${roomId}-waiting`, 'true')
|
||||
let invitations = []
|
||||
|
||||
try {
|
||||
const roomMembers = await this.client.getJoinedRoomMembers(this.config.FACILITATOR_ROOM_ID)
|
||||
const members = Object.keys(roomMembers["joined"]);
|
||||
|
||||
members.forEach(memberId => {
|
||||
async inviteFacilitatorIfOnline(roomId, memberId) {
|
||||
const user = this.client.getUser(memberId);
|
||||
if (
|
||||
user &&
|
||||
(user.presence !== "offline") &&
|
||||
memberId !== this.config.BOT_USERID
|
||||
memberId !== this.config.botUserId
|
||||
) {
|
||||
invitations.push(memberId)
|
||||
this.inviteUserToRoom(roomId, memberId);
|
||||
try {
|
||||
this.client.invite(roomId, memberId)
|
||||
logger.log("info", `CHAT INVITATION SENT TO ${memberId} FOR ROOM ${roomId}`)
|
||||
return memberId
|
||||
} catch(err) {
|
||||
this.handleBotCrash(roomId, err);
|
||||
return null
|
||||
}
|
||||
} else {
|
||||
return null
|
||||
}
|
||||
}
|
||||
});
|
||||
|
||||
if (invitations.length > 0) {
|
||||
async inviteFacilitators(roomId) {
|
||||
try {
|
||||
this.localStorage.setItem(`${roomId}-waiting`, 'true')
|
||||
let invitations = []
|
||||
const roomMembers = await this.client.getJoinedRoomMembers(this.config.facilitatorRoomId)
|
||||
const members = Object.keys(roomMembers["joined"]);
|
||||
|
||||
for (const memberId of members) {
|
||||
const invited = await this.inviteFacilitatorIfOnline(roomId, memberId)
|
||||
invitations.push(invited)
|
||||
}
|
||||
|
||||
if (invitations.filter(i => i).length > 0) {
|
||||
this.localStorage.setItem(`${roomId}-invitations`, invitations)
|
||||
} else {
|
||||
logger.log('info', "NO FACILITATORS ONLINE")
|
||||
this.sendNotice(roomId, "CHAT_OFFLINE")
|
||||
this.sendBotSignal(roomId, BOT_SIGNAL_CHAT_OFFLINE)
|
||||
|
||||
// send notification to Support Chat Notifications room
|
||||
const currentDate = new Date()
|
||||
const closedTime = currentDate.toLocaleTimeString()
|
||||
const roomRef = roomId.split(':')[0]
|
||||
const notification = `No facilitators were online, chat closed at ${closedTime} (room ID: ${roomRef})`
|
||||
logger.log('info', `NO FACILITATORS ONLINE, CHAT CLOSED AT ${closedTime} (room ID: ${roomRef})`)
|
||||
this.sendTextMessage(this.config.facilitatorRoomId, notification);
|
||||
}
|
||||
|
||||
} catch(err) {
|
||||
@ -139,10 +153,9 @@ class OcrccBot {
|
||||
|
||||
|
||||
async uninviteFacilitators(roomId) {
|
||||
this.localStorage.removeItem(`${roomId}-waiting`)
|
||||
|
||||
try {
|
||||
const facilitatorsRoomMembers = await this.client.getJoinedRoomMembers(this.config.FACILITATOR_ROOM_ID)
|
||||
this.localStorage.removeItem(`${roomId}-waiting`)
|
||||
const facilitatorsRoomMembers = await this.client.getJoinedRoomMembers(this.config.facilitatorRoomId)
|
||||
const supportRoomMembers = await this.client.getJoinedRoomMembers(roomId)
|
||||
|
||||
const roomMembersIds = Object.keys(supportRoomMembers["joined"]);
|
||||
@ -164,30 +177,39 @@ class OcrccBot {
|
||||
|
||||
handleBotCrash(roomId, error) {
|
||||
if (roomId) {
|
||||
this.sendTextMessage(roomId, this.config.BOT_ERROR_MESSAGE);
|
||||
this.sendTextMessage(roomId, this.config.botErrorMessage);
|
||||
this.sendBotSignal(roomId, BOT_SIGNAL_END_CHAT)
|
||||
}
|
||||
|
||||
this.sendTextMessage(
|
||||
this.config.FACILITATOR_ROOM_ID,
|
||||
`The Help Bot ran into an error: ${error}. Please verify that the chat service is working.`
|
||||
this.config.facilitatorRoomId,
|
||||
`${this.config.botDisplayName} ran into an error: ${error}. Please verify that the chat service is working.`
|
||||
);
|
||||
}
|
||||
|
||||
handleMessageEvent(event) {
|
||||
const content = event.getContent();
|
||||
const sender = event.getSender()
|
||||
const roomId = event.getRoomId();
|
||||
|
||||
// do nothing if there's no content
|
||||
if (!content) {
|
||||
return;
|
||||
}
|
||||
|
||||
// if it's a chat message and the facilitator has joined, reset the inactivity timeout
|
||||
const facilitatorId = this.localStorage.getItem(`${roomId}-facilitator`)
|
||||
if (Boolean(facilitatorId) && sender !== this.config.botUserId) {
|
||||
this.setInactivityTimeout(roomId)
|
||||
}
|
||||
|
||||
// bot commands
|
||||
if (content.body.startsWith("!bot")) {
|
||||
return this.handleBotCommand(event);
|
||||
}
|
||||
|
||||
// write to transcript
|
||||
if (this.config.CAPTURE_TRANSCRIPTS) {
|
||||
if (this.config.captureTranscripts) {
|
||||
return this.writeToTranscript(event);
|
||||
}
|
||||
}
|
||||
@ -204,7 +226,7 @@ class OcrccBot {
|
||||
const filepath = this.localStorage.getItem(`${roomId}-transcript`)
|
||||
|
||||
if (!filepath) {
|
||||
return logger.log("error", `NO TRANSCRIPT FILE FOR ROOM: ${roomId}`);
|
||||
return logger.log("error", `NO TRANSCRIPT FILE FOR ROOM: ${roomId}. This message will not be added: ${content.body}`);
|
||||
}
|
||||
|
||||
const message = `${sender} [${time}]: ${content.body}\n`;
|
||||
@ -216,23 +238,24 @@ class OcrccBot {
|
||||
}
|
||||
|
||||
handleBotCommand(event) {
|
||||
try {
|
||||
const senderId = event.getSender();
|
||||
const roomId = event.getRoomId();
|
||||
const content = event.getContent();
|
||||
const command = content.body.substring("!bot".length).trim();
|
||||
|
||||
switch (command) {
|
||||
case "transcript":
|
||||
this.sendTranscript(senderId, roomId);
|
||||
break;
|
||||
case "transcript please":
|
||||
this.sendTranscript(senderId, roomId);
|
||||
break;
|
||||
case "delete transcript":
|
||||
this.deleteTranscript(senderId, roomId);
|
||||
break;
|
||||
case "hi":
|
||||
const botCommands = [
|
||||
{
|
||||
keyword: 'transcript',
|
||||
function: (senderId, roomId) => { this.sendTranscript(senderId, roomId) }
|
||||
},
|
||||
{
|
||||
keyword: 'delete transcript',
|
||||
function: (senderId, roomId) => { this.deleteTranscript(senderId, roomId, true) } // delete transcript and send confirmation message
|
||||
},
|
||||
{
|
||||
keyword: 'say',
|
||||
function: (senderId, roomId, message) => {
|
||||
this.sendTextMessage(roomId, message, senderId);
|
||||
}
|
||||
},
|
||||
{
|
||||
keyword: 'hi',
|
||||
function: (senderId, roomId) => {
|
||||
const responses = [
|
||||
"Hi!",
|
||||
"Hello",
|
||||
@ -240,24 +263,41 @@ class OcrccBot {
|
||||
"Hi there",
|
||||
"Bleep bloop"
|
||||
];
|
||||
const message =
|
||||
responses[Math.floor(Math.random() * responses.length)];
|
||||
const message = responses[Math.floor(Math.random() * responses.length)];
|
||||
this.sendTextMessage(roomId, message, senderId);
|
||||
break;
|
||||
default:
|
||||
}
|
||||
},
|
||||
{
|
||||
keyword: 'bug',
|
||||
function: (senderId, roomId) => {
|
||||
const message = `Please report the issue at ${this.config.bugReportUrl}`
|
||||
this.sendTextMessage(roomId, message, senderId);
|
||||
}
|
||||
}
|
||||
]
|
||||
try {
|
||||
const senderId = event.getSender();
|
||||
const roomId = event.getRoomId();
|
||||
const content = event.getContent();
|
||||
const commandText = content.body.substring("!bot".length).trim();
|
||||
const command = botCommands.find(c => commandText.startsWith(c.keyword))
|
||||
|
||||
if (!command) {
|
||||
this.sendTextMessage(
|
||||
roomId,
|
||||
`Sorry, I don't know that command. I'm not a very smart bot.`,
|
||||
senderId
|
||||
);
|
||||
break;
|
||||
}
|
||||
|
||||
const args = commandText.substring(command.keyword.length).trim()
|
||||
command.function(senderId, roomId, args)
|
||||
} catch (err) {
|
||||
logger.log("error", `ERROR EXECUTING BOT COMMAND: ${err}`);
|
||||
}
|
||||
}
|
||||
|
||||
async leaveEmptyRooms(senderId) {
|
||||
async leaveEmptyRooms() {
|
||||
try {
|
||||
const roomData = await this.client.getJoinedRooms()
|
||||
const joinedRoomsIds = roomData["joined_rooms"]
|
||||
@ -265,15 +305,15 @@ class OcrccBot {
|
||||
const room = this.client.getRoom(roomId)
|
||||
if (room && room.getJoinedMemberCount() === 1) {
|
||||
try {
|
||||
logger.log('info', "LEAVING EMPTY ROOM => " + roomId)
|
||||
await this.client.leave(roomId)
|
||||
logger.log('info', `LEAVING EMPTY ROOM => ${roomId}`)
|
||||
} catch(err) {
|
||||
logger.log('error', "ERROR LEAVING EMPTY ROOM => " + err)
|
||||
logger.log('error', `ERROR LEAVING ROOM ${roomId} => ${err}`)
|
||||
}
|
||||
}
|
||||
})
|
||||
} catch(err) {
|
||||
logger.log("error", `ERROR GETTING JOINED ROOMS: ${err}`);
|
||||
logger.log("error", `ERROR LEAVING EMPTY ROOMS: ${err}`);
|
||||
}
|
||||
}
|
||||
|
||||
@ -284,16 +324,42 @@ class OcrccBot {
|
||||
if (!transcriptFile) {
|
||||
this.sendTextMessage(
|
||||
roomId,
|
||||
"There is no transcript for this chat.",
|
||||
"Cannot send transcript, there is no transcript for this chat.",
|
||||
senderId
|
||||
);
|
||||
}
|
||||
|
||||
if (this.client.isRoomEncrypted(roomId)) {
|
||||
let encryptInfo;
|
||||
const filename = path.basename(transcriptFile) || "Transcript";
|
||||
const data = fs.readFileSync(transcriptFile);
|
||||
const encryptResult = await encrypt.encryptAttachment(data)
|
||||
const buffer = Buffer.from(encryptResult.data)
|
||||
encryptInfo = encryptResult.info;
|
||||
const url = await this.client.uploadContent(buffer, { rawResponse: false, name: filename })
|
||||
encryptInfo.url = url.content_uri;
|
||||
encryptInfo.mimetype = 'text/plain'
|
||||
|
||||
const content = {
|
||||
msgtype: "m.file",
|
||||
body: filename,
|
||||
info: {
|
||||
mimetype: 'text/plain'
|
||||
},
|
||||
file: encryptInfo,
|
||||
url: url.content_uri,
|
||||
showToUser: senderId,
|
||||
mimetype: 'text/plain'
|
||||
};
|
||||
|
||||
this.sendMessage(roomId, content);
|
||||
|
||||
} else {
|
||||
const filename = path.basename(transcriptFile) || "Transcript";
|
||||
const file = fs.readFileSync(transcriptFile);
|
||||
const stats = fs.statSync(transcriptFile);
|
||||
|
||||
const url = await this.client.uploadContent(file, { rawResponse: false, type: 'text/plain' })
|
||||
const url = await this.client.uploadContent(file, { rawResponse: false, name: filename })
|
||||
logger.log('info', url)
|
||||
|
||||
const content = {
|
||||
@ -304,10 +370,13 @@ class OcrccBot {
|
||||
mimetype: 'text/plain'
|
||||
},
|
||||
url: url.content_uri,
|
||||
showToUser: senderId
|
||||
showToUser: senderId,
|
||||
mimetype: 'text/plain'
|
||||
};
|
||||
|
||||
this.sendMessage(roomId, content);
|
||||
}
|
||||
|
||||
} catch(err) {
|
||||
logger.log("error", `ERROR UPLOADING CONTENT: ${err}`);
|
||||
this.sendTextMessage(
|
||||
@ -318,13 +387,13 @@ class OcrccBot {
|
||||
}
|
||||
}
|
||||
|
||||
deleteTranscript(senderId, roomId) {
|
||||
deleteTranscript(senderId, roomId, sendConfirmation=false) {
|
||||
const transcriptFile = this.localStorage.getItem(`${roomId}-transcript`)
|
||||
|
||||
if (!transcriptFile) {
|
||||
return this.sendTextMessage(
|
||||
roomId,
|
||||
"There is no transcript for this chat.",
|
||||
"Cannot delete transcript, there is no transcript for this chat.",
|
||||
senderId
|
||||
);
|
||||
}
|
||||
@ -340,13 +409,17 @@ class OcrccBot {
|
||||
senderId
|
||||
);
|
||||
}
|
||||
this.localStorage.removeItem(`${roomId}-transcript`)
|
||||
logger.log('info', "DELETED TRANSCRIPT FILE => " + transcriptFile)
|
||||
|
||||
if (sendConfirmation) {
|
||||
this.sendTextMessage(
|
||||
roomId,
|
||||
`The transcript file has been deleted.`,
|
||||
senderId
|
||||
);
|
||||
}
|
||||
|
||||
logger.log('info', "DELETED TRANSCRIPT FILE => " + transcriptFile)
|
||||
this.localStorage.removeItem(`${roomId}-transcript`)
|
||||
});
|
||||
}
|
||||
|
||||
@ -363,9 +436,9 @@ class OcrccBot {
|
||||
const auth = {
|
||||
session: err.data.session,
|
||||
type: "m.login.password",
|
||||
user: this.config.BOT_USERID,
|
||||
identifier: { type: "m.id.user", user: this.config.BOT_USERID },
|
||||
password: this.config.BOT_PASSWORD
|
||||
user: this.config.botUserId,
|
||||
identifier: { type: "m.id.user", user: this.config.botUserId },
|
||||
password: this.config.botPassword
|
||||
};
|
||||
|
||||
await this.client.deleteMultipleDevices(oldDevices, auth)
|
||||
@ -384,19 +457,24 @@ class OcrccBot {
|
||||
this.client.on("RoomMember.membership", async (event, member) => {
|
||||
if (
|
||||
member.membership === "invite" &&
|
||||
member.userId === this.config.BOT_USERID &&
|
||||
member.userId === this.config.botUserId &&
|
||||
!this.joinedRooms.includes(member.roomId)
|
||||
) {
|
||||
try {
|
||||
const roomData = await this.client.getJoinedRooms()
|
||||
const joinedRooms = roomData["joined_rooms"]
|
||||
if (!joinedRooms.includes(member.roomId)) {
|
||||
const room = await this.client.joinRoom(member.roomId)
|
||||
logger.log("info", "AUTO JOINED ROOM => " + room.roomId)
|
||||
const currentDate = new Date()
|
||||
const chatDate = currentDate.toLocaleDateString()
|
||||
const chatTime = currentDate.toLocaleTimeString()
|
||||
const inviteDate = event.getDate()
|
||||
const chatDate = inviteDate.toLocaleDateString()
|
||||
const chatTime = inviteDate.toLocaleTimeString()
|
||||
const roomId = room.roomId.split(':')[0]
|
||||
const notification = `Incoming support chat at ${chatTime} (room ID: ${roomId})`
|
||||
this.sendTextMessage(this.config.FACILITATOR_ROOM_ID, notification);
|
||||
this.sendTextMessage(this.config.facilitatorRoomId, notification);
|
||||
this.inviteFacilitators(room.roomId)
|
||||
this.setTimeoutforFacilitator(room.roomId)
|
||||
}
|
||||
} catch(err) {
|
||||
logger.log("error", "ERROR JOINING ROOM => " + err)
|
||||
}
|
||||
@ -404,11 +482,12 @@ class OcrccBot {
|
||||
|
||||
if (
|
||||
member.membership === "join" &&
|
||||
member.userId !== this.config.BOT_USERID &&
|
||||
member.userId !== this.config.botUserId &&
|
||||
this.localStorage.getItem(`${member.roomId}-waiting`)
|
||||
) {
|
||||
try {
|
||||
// make sure it's a facilitator joining
|
||||
const roomMembers = await this.client.getJoinedRoomMembers(this.config.FACILITATOR_ROOM_ID)
|
||||
const roomMembers = await this.client.getJoinedRoomMembers(this.config.facilitatorRoomId)
|
||||
const members = Object.keys(roomMembers["joined"]);
|
||||
const isFacilitator = members.includes(member.userId)
|
||||
|
||||
@ -422,7 +501,7 @@ class OcrccBot {
|
||||
getContent: () => {
|
||||
return {
|
||||
users: {
|
||||
[this.config.BOT_USERID]: 100,
|
||||
[this.config.botUserId]: 100,
|
||||
[member.userId]: 50
|
||||
}
|
||||
};
|
||||
@ -435,7 +514,7 @@ class OcrccBot {
|
||||
const chatTime = currentDate.toLocaleTimeString()
|
||||
const roomId = member.roomId.split(':')[0]
|
||||
const notification = `${member.name} joined the chat at ${chatTime} (room ID: ${roomId})`
|
||||
this.sendTextMessage(this.config.FACILITATOR_ROOM_ID, notification);
|
||||
this.sendTextMessage(this.config.facilitatorRoomId, notification);
|
||||
|
||||
// send notification to chat room
|
||||
this.sendTextMessage(
|
||||
@ -447,7 +526,7 @@ class OcrccBot {
|
||||
this.uninviteFacilitators(member.roomId);
|
||||
|
||||
// set transcript file
|
||||
if (this.config.CAPTURE_TRANSCRIPTS) {
|
||||
if (this.config.captureTranscripts) {
|
||||
const currentDate = new Date();
|
||||
const dateOpts = {
|
||||
year: "numeric",
|
||||
@ -463,37 +542,119 @@ class OcrccBot {
|
||||
this.localStorage.setItem(`${member.roomId}-transcript`, filepath)
|
||||
}
|
||||
}
|
||||
} catch(err) {
|
||||
logger.log("error", `ERROR WHEN FACILITATOR JOINED ROOM ==> ${err}`);
|
||||
}
|
||||
}
|
||||
|
||||
if (
|
||||
member.membership === "leave" &&
|
||||
member.userId !== this.config.BOT_USERID
|
||||
member.userId !== this.config.botUserId
|
||||
) {
|
||||
|
||||
// notify room if the facilitator has left
|
||||
try {
|
||||
const facilitatorId = this.localStorage.getItem(`${member.roomId}-facilitator`)
|
||||
if (member.userId === facilitatorId) {
|
||||
this.sendTextMessage(
|
||||
member.roomId,
|
||||
`${member.name} has left the chat.`
|
||||
);
|
||||
// send notification to Support Chat Notifications room
|
||||
const currentDate = new Date()
|
||||
const chatTime = currentDate.toLocaleTimeString()
|
||||
const roomId = member.roomId.split(':')[0]
|
||||
const notification = `${member.name} left the chat at ${chatTime} (room ID: ${roomId})`
|
||||
await this.sendTextMessage(this.config.facilitatorRoomId, notification);
|
||||
}
|
||||
} catch(err) {
|
||||
logger.log("error", `ERROR NOTIFYING THAT FACLITATOR HAS LEFT THE ROOM ==> ${err}`);
|
||||
}
|
||||
|
||||
// leave if there is nobody in the room
|
||||
const room = this.client.getRoom(member.roomId)
|
||||
if (!room) return
|
||||
if (!room) return;
|
||||
const roomMembers = await room.getJoinedMembers() // array
|
||||
|
||||
const memberCount = room.getJoinedMemberCount()
|
||||
|
||||
if (memberCount === 1) { // just the bot left
|
||||
logger.log("info", `LEAVING EMPTY ROOM ==> ${member.roomId}`);
|
||||
// leave if there is nobody in the room
|
||||
try {
|
||||
const memberCount = roomMembers.length
|
||||
const isBotInRoom = Boolean(roomMembers.find(member => member.userId === this.config.botUserId))
|
||||
if (memberCount === 1 && isBotInRoom) { // just the bot left
|
||||
logger.log("info", `LEAVING EMPTY ROOM: ${member.roomId}`);
|
||||
this.deleteTranscript(member.userId, member.roomId);
|
||||
this.localStorage.removeItem(`${member.roomId}-facilitator`)
|
||||
this.localStorage.removeItem(`${member.roomId}-transcript`)
|
||||
this.client.leave(member.roomId)
|
||||
this.localStorage.removeItem(`${member.roomId}-waiting`)
|
||||
return await this.client.leave(member.roomId)
|
||||
}
|
||||
} catch(err) {
|
||||
return logger.log("error", `ERROR LEAVING EMPTY ROOM ==> ${err}`);
|
||||
}
|
||||
|
||||
// send signal to close the chat if there are no facilitators in the room
|
||||
try {
|
||||
const facilitatorRoomMembers = await this.client.getJoinedRoomMembers(this.config.facilitatorRoomId) // object
|
||||
const facilitators = facilitatorRoomMembers['joined']
|
||||
let facilitatorInRoom = false;
|
||||
|
||||
roomMembers.forEach(member => {
|
||||
if (member.userId !== this.config.botUserId && Boolean(facilitators[member.userId])) {
|
||||
facilitatorInRoom = true
|
||||
}
|
||||
})
|
||||
|
||||
if (!facilitatorInRoom) {
|
||||
logger.log("info", `NO FACILITATORS LEFT, SENDING SIGNAL TO END CHAT`);
|
||||
this.sendBotSignal(member.roomId, BOT_SIGNAL_END_CHAT)
|
||||
}
|
||||
|
||||
} catch(err) {
|
||||
logger.log("error", `ERROR SENDING BOT SIGNAL ==> ${err}`);
|
||||
}
|
||||
}
|
||||
})
|
||||
}
|
||||
|
||||
setTimeoutforFacilitator(roomId) {
|
||||
setTimeout(async() => {
|
||||
const stillWaiting = this.localStorage.getItem(`${roomId}-waiting`)
|
||||
if (stillWaiting) {
|
||||
await this.sendTextMessage(
|
||||
roomId,
|
||||
this.config.chatNotAvailableMessage
|
||||
);
|
||||
this.sendBotSignal(roomId, BOT_SIGNAL_END_CHAT)
|
||||
|
||||
// send notification to Support Chat Notifications room
|
||||
const currentDate = new Date()
|
||||
const closedTime = currentDate.toLocaleTimeString()
|
||||
const roomRef = roomId.split(':')[0]
|
||||
const notification = `No facilitators joined the chat within the maximum wait time, chat closed at ${closedTime} (room ID: ${roomRef})`;
|
||||
this.sendTextMessage(this.config.facilitatorRoomId, notification);
|
||||
logger.log("info", `NO FACILITATORS JOINED THE CHAT WITHIN THE MAXIMUM WAIT TIME, CHAT CLOSED AT ${closedTime} (room ID: ${roomRef})`);
|
||||
}
|
||||
}, this.config.maxWaitTime * 1000) // convert seconds to milliseconds
|
||||
}
|
||||
|
||||
setInactivityTimeout(roomId) {
|
||||
const oldTimeout = this.inactivityTimers[roomId];
|
||||
|
||||
if (oldTimeout) {
|
||||
clearTimeout(oldTimeout);
|
||||
}
|
||||
|
||||
const newTimeout = setTimeout(async() => {
|
||||
logger.log("info", `CHAT IS INACTIVE, SENDING SIGNAL TO END CHAT`);
|
||||
await this.sendTextMessage(
|
||||
roomId,
|
||||
this.config.chatInactiveMessage
|
||||
);
|
||||
this.sendBotSignal(roomId, BOT_SIGNAL_END_CHAT)
|
||||
}, this.config.maxInactiveTime * 1000) // convert seconds to milliseconds
|
||||
|
||||
this.inactivityTimers[roomId] = newTimeout;
|
||||
}
|
||||
|
||||
async setMessageListeners() {
|
||||
// encrypted messages
|
||||
this.client.on("Event.decrypted", (event, err) => {
|
||||
@ -512,46 +673,53 @@ class OcrccBot {
|
||||
});
|
||||
}
|
||||
|
||||
async leaveOldRooms() {
|
||||
const roomData = await this.client.getJoinedRooms()
|
||||
|
||||
roomData["joined_rooms"].forEach(async roomId => {
|
||||
try {
|
||||
await this.client.leave(roomId)
|
||||
} catch(err) {
|
||||
logger.log('error', "ERROR LEAVING ROOM => " + err)
|
||||
async sendBotSignal (roomId, signal, args) {
|
||||
let content = {
|
||||
signal: signal,
|
||||
args: args,
|
||||
}
|
||||
try {
|
||||
await this.client.sendStateEvent(roomId, 'm.bot.signal', content)
|
||||
} catch(err) {
|
||||
logger.log('error', "ERROR SENDING BOT SIGNAL => " + err)
|
||||
}
|
||||
})
|
||||
}
|
||||
|
||||
async start() {
|
||||
try {
|
||||
const localStorage = this.createLocalStorage();
|
||||
this.localStorage = localStorage
|
||||
|
||||
try {
|
||||
const auth = {
|
||||
user: this.config.BOT_USERNAME,
|
||||
password: this.config.BOT_PASSWORD,
|
||||
initial_device_display_name: this.config.BOT_DISPLAY_NAME
|
||||
user: this.config.botUsername,
|
||||
password: this.config.botPassword,
|
||||
initial_device_display_name: this.config.botDisplayName
|
||||
}
|
||||
const account = await this.client.login("m.login.password", auth)
|
||||
logger.log("info", `ACCOUNT ==> ${JSON.stringify(account)}`);
|
||||
|
||||
let opts = {
|
||||
baseUrl: this.config.MATRIX_SERVER_URL,
|
||||
baseUrl: this.config.matrixServerUrl,
|
||||
accessToken: account.access_token,
|
||||
userId: this.config.BOT_USERID,
|
||||
userId: this.config.botUserId,
|
||||
deviceId: account.device_id,
|
||||
sessionStore: new matrix.WebStorageSessionStore(localStorage)
|
||||
};
|
||||
|
||||
this.client = matrix.createClient(opts);
|
||||
await this.deleteOldDevices()
|
||||
await this.trackJoinedRooms()
|
||||
await this.client.initCrypto()
|
||||
this.client.startClient({ initialSyncLimit: 0 })
|
||||
|
||||
this.client.once('sync', async (state, prevState, data) => {
|
||||
logger.log("info", `SYNC STATUS: ${state}`)
|
||||
if (state === 'PREPARED') {
|
||||
await this.deleteOldDevices()
|
||||
await this.leaveEmptyRooms()
|
||||
await this.trackJoinedRooms()
|
||||
await this.setMembershipListeners();
|
||||
await this.setMessageListeners();
|
||||
this.client.startClient({ initialSyncLimit: 0 })
|
||||
}
|
||||
});
|
||||
} catch(err) {
|
||||
this.handleBotCrash(undefined, err);
|
||||
logger.log("error", `ERROR INITIALIZING CLIENT: ${err}`);
|
||||
|
@ -32,7 +32,8 @@ import {
|
||||
mockKick,
|
||||
mockGetJoinedRoomMembers,
|
||||
mockGetUser,
|
||||
mockGetGroupUsers
|
||||
mockGetGroupUsers,
|
||||
mockSendStateEvent,
|
||||
} from "matrix-js-sdk";
|
||||
|
||||
import OcrccBot from './bot'
|
||||
@ -48,7 +49,6 @@ const {
|
||||
BOT_USERID,
|
||||
BOT_PASSWORD,
|
||||
BOT_DISPLAY_NAME,
|
||||
FACILITATOR_GROUP_ID,
|
||||
FACILITATOR_ROOM_ID,
|
||||
CHAT_OFFLINE_MESSAGE,
|
||||
CAPTURE_TRANSCRIPTS
|
||||
@ -64,7 +64,6 @@ const botConfig = {
|
||||
BOT_USERID,
|
||||
BOT_PASSWORD,
|
||||
BOT_DISPLAY_NAME,
|
||||
FACILITATOR_GROUP_ID,
|
||||
FACILITATOR_ROOM_ID,
|
||||
CHAT_OFFLINE_MESSAGE,
|
||||
CAPTURE_TRANSCRIPTS
|
||||
@ -102,6 +101,7 @@ describe('OcrccBot', () => {
|
||||
mockSendTextMessage.mockClear()
|
||||
mockAppendFileSync.mockClear()
|
||||
mockGetGroupUsers.mockClear()
|
||||
mockSendStateEvent.mockClear()
|
||||
})
|
||||
|
||||
|
||||
@ -327,4 +327,17 @@ describe('OcrccBot', () => {
|
||||
expect(mockStartClient).toHaveBeenCalled()
|
||||
})
|
||||
})
|
||||
|
||||
test('#sendBotSignal should send custom state event', () => {
|
||||
const bot = new OcrccBot(botConfig)
|
||||
bot.start()
|
||||
const test_room_id = 'test_room_id'
|
||||
const signal = 'END_CHAT'
|
||||
|
||||
bot.sendBotSignal(test_room_id, signal)
|
||||
|
||||
waitForExpect(() => {
|
||||
expect(mockSendStateEvent).toHaveBeenCalledWith(test_room_id, 'm.bot.signal', { signal })
|
||||
})
|
||||
})
|
||||
})
|
156
src/encrypt-attachment.js
Normal file
156
src/encrypt-attachment.js
Normal file
@ -0,0 +1,156 @@
|
||||
// this is from https://github.com/matrix-org/browser-encrypt-attachment
|
||||
// which is the library used by matrix-reack-sdk to encrypt and decrypt attachments
|
||||
// just dropped in node-webcrypto-ossl to replace window.crypto
|
||||
// and Buffer for base64 encoding/decoding instead of window.btoa/window.atob
|
||||
|
||||
|
||||
/**
|
||||
* Encrypt an attachment.
|
||||
* @param {ArrayBuffer} plaintextBuffer The attachment data buffer.
|
||||
* @return {Promise} A promise that resolves with an object when the attachment is encrypted.
|
||||
* The object has a "data" key with an ArrayBuffer of encrypted data and an "info" key
|
||||
* with an object containing the info needed to decrypt the data.
|
||||
*/
|
||||
|
||||
const { Crypto } = require("node-webcrypto-ossl");
|
||||
const crypto = new Crypto();
|
||||
|
||||
function encryptAttachment(plaintextBuffer) {
|
||||
var cryptoKey; // The AES key object.
|
||||
var exportedKey; // The AES key exported as JWK.
|
||||
var ciphertextBuffer; // ArrayBuffer of encrypted data.
|
||||
var sha256Buffer; // ArrayBuffer of digest.
|
||||
var ivArray; // Uint8Array of AES IV
|
||||
// Generate an IV where the first 8 bytes are random and the high 8 bytes
|
||||
// are zero. We set the counter low bits to 0 since it makes it unlikely
|
||||
// that the 64 bit counter will overflow.
|
||||
ivArray = new Uint8Array(16);
|
||||
crypto.getRandomValues(ivArray.subarray(0,8));
|
||||
// Load the encryption key.
|
||||
return crypto.subtle.generateKey(
|
||||
{"name": "AES-CTR", length: 256}, true, ["encrypt", "decrypt"]
|
||||
).then(function(generateKeyResult) {
|
||||
cryptoKey = generateKeyResult;
|
||||
// Export the Key as JWK.
|
||||
return crypto.subtle.exportKey("jwk", cryptoKey);
|
||||
}).then(function(exportKeyResult) {
|
||||
exportedKey = exportKeyResult;
|
||||
// Encrypt the input ArrayBuffer.
|
||||
// Use half of the iv as the counter by setting the "length" to 64.
|
||||
return crypto.subtle.encrypt(
|
||||
{name: "AES-CTR", counter: ivArray, length: 64}, cryptoKey, plaintextBuffer
|
||||
);
|
||||
}).then(function(encryptResult) {
|
||||
ciphertextBuffer = encryptResult;
|
||||
// SHA-256 the encrypted data.
|
||||
return crypto.subtle.digest("SHA-256", ciphertextBuffer);
|
||||
}).then(function (digestResult) {
|
||||
sha256Buffer = digestResult;
|
||||
|
||||
return {
|
||||
data: ciphertextBuffer,
|
||||
info: {
|
||||
v: "v2",
|
||||
key: exportedKey,
|
||||
iv: encodeBase64(ivArray),
|
||||
hashes: {
|
||||
sha256: encodeBase64(new Uint8Array(sha256Buffer)),
|
||||
},
|
||||
},
|
||||
};
|
||||
});
|
||||
}
|
||||
|
||||
/**
|
||||
* Decrypt an attachment.
|
||||
* @param {ArrayBuffer} ciphertextBuffer The encrypted attachment data buffer.
|
||||
* @param {Object} info The information needed to decrypt the attachment.
|
||||
* @param {Object} info.key AES-CTR JWK key object.
|
||||
* @param {string} info.iv Base64 encoded 16 byte AES-CTR IV.
|
||||
* @param {string} info.hashes.sha256 Base64 encoded SHA-256 hash of the ciphertext.
|
||||
* @return {Promise} A promise that resolves with an ArrayBuffer when the attachment is decrypted.
|
||||
*/
|
||||
function decryptAttachment(ciphertextBuffer, info) {
|
||||
|
||||
if (info === undefined || info.key === undefined || info.iv === undefined
|
||||
|| info.hashes === undefined || info.hashes.sha256 === undefined) {
|
||||
throw new Error("Invalid info. Missing info.key, info.iv or info.hashes.sha256 key");
|
||||
}
|
||||
|
||||
var cryptoKey; // The AES key object.
|
||||
var ivArray = decodeBase64(info.iv);
|
||||
var expectedSha256base64 = info.hashes.sha256;
|
||||
// Load the AES from the "key" key of the info object.
|
||||
return crypto.subtle.importKey(
|
||||
"jwk", info.key, {"name": "AES-CTR"}, false, ["encrypt", "decrypt"]
|
||||
).then(function (importKeyResult) {
|
||||
cryptoKey = importKeyResult;
|
||||
// Check the sha256 hash
|
||||
return crypto.subtle.digest("SHA-256", ciphertextBuffer);
|
||||
}).then(function (digestResult) {
|
||||
if (encodeBase64(new Uint8Array(digestResult)) != expectedSha256base64) {
|
||||
throw new Error("Mismatched SHA-256 digest");
|
||||
}
|
||||
var counterLength;
|
||||
if (info.v == "v1" || info.v == "v2") {
|
||||
// Version 1 and 2 use a 64 bit counter.
|
||||
counterLength = 64;
|
||||
} else {
|
||||
// Version 0 uses a 128 bit counter.
|
||||
counterLength = 128;
|
||||
}
|
||||
return crypto.subtle.decrypt(
|
||||
{name: "AES-CTR", counter: ivArray, length: counterLength}, cryptoKey, ciphertextBuffer
|
||||
);
|
||||
});
|
||||
}
|
||||
|
||||
/**
|
||||
* Encode a typed array of uint8 as base64.
|
||||
* @param {Uint8Array} uint8Array The data to encode.
|
||||
* @return {string} The base64 without padding.
|
||||
*/
|
||||
function encodeBase64(uint8Array) {
|
||||
// Misinterpt the Uint8Array as Latin-1.
|
||||
// window.btoa expects a unicode string with codepoints in the range 0-255.
|
||||
var latin1String = String.fromCharCode.apply(null, uint8Array);
|
||||
// Use the builtin base64 encoder.
|
||||
// var paddedBase64 = window.btoa(latin1String);
|
||||
var paddedBase64 = Buffer.from(latin1String, 'binary').toString('base64')
|
||||
// Calculate the unpadded length.
|
||||
var inputLength = uint8Array.length;
|
||||
var outputLength = 4 * Math.floor((inputLength + 2) / 3) + (inputLength + 2) % 3 - 2;
|
||||
// Return the unpadded base64.
|
||||
return paddedBase64.slice(0, outputLength);
|
||||
}
|
||||
|
||||
/**
|
||||
* Decode a base64 string to a typed array of uint8.
|
||||
* This will decode unpadded base64, but will also accept base64 with padding.
|
||||
* @param {string} base64 The unpadded base64 to decode.
|
||||
* @return {Uint8Array} The decoded data.
|
||||
*/
|
||||
function decodeBase64(base64) {
|
||||
// Pad the base64 up to the next multiple of 4.
|
||||
var paddedBase64 = base64 + "===".slice(0, (4 - base64.length % 4) % 4);
|
||||
// Decode the base64 as a misinterpreted Latin-1 string.
|
||||
// window.atob returns a unicode string with codepoints in the range 0-255.
|
||||
// var latin1String = window.atob(paddedBase64);
|
||||
var latin1String = Buffer.from(paddedBase64, 'base64').toString('binary')
|
||||
// Encode the string as a Uint8Array as Latin-1.
|
||||
var uint8Array = new Uint8Array(latin1String.length);
|
||||
for (var i = 0; i < latin1String.length; i++) {
|
||||
uint8Array[i] = latin1String.charCodeAt(i);
|
||||
}
|
||||
return uint8Array;
|
||||
}
|
||||
|
||||
try {
|
||||
exports.encryptAttachment = encryptAttachment;
|
||||
exports.decryptAttachment = decryptAttachment;
|
||||
}
|
||||
catch (e) {
|
||||
// Ignore unknown variable "exports" errors when this is loaded directly into a browser
|
||||
// This means that we can test it without having to use browserify.
|
||||
// The intention is that the library is used using browserify.
|
||||
}
|
42
src/index.js
42
src/index.js
@ -1,37 +1,9 @@
|
||||
require('dotenv').config()
|
||||
import config from '../config.json';
|
||||
import OcrccBot from './bot';
|
||||
|
||||
const ENCRYPTION_CONFIG = { algorithm: "m.megolm.v1.aes-sha2" };
|
||||
const KICK_REASON = "A facilitator has already joined this chat.";
|
||||
const BOT_ERROR_MESSAGE =
|
||||
"Something went wrong on our end, please restart the chat and try again.";
|
||||
const MAX_RETRIES = 3;
|
||||
const {
|
||||
MATRIX_SERVER_URL,
|
||||
BOT_USERNAME,
|
||||
BOT_USERID,
|
||||
BOT_PASSWORD,
|
||||
BOT_DISPLAY_NAME,
|
||||
FACILITATOR_GROUP_ID,
|
||||
FACILITATOR_ROOM_ID,
|
||||
CAPTURE_TRANSCRIPTS,
|
||||
} = process.env;
|
||||
|
||||
const botConfig = {
|
||||
ENCRYPTION_CONFIG,
|
||||
KICK_REASON,
|
||||
BOT_ERROR_MESSAGE,
|
||||
MAX_RETRIES,
|
||||
MATRIX_SERVER_URL,
|
||||
BOT_USERNAME,
|
||||
BOT_USERID,
|
||||
BOT_PASSWORD,
|
||||
BOT_DISPLAY_NAME,
|
||||
FACILITATOR_GROUP_ID,
|
||||
FACILITATOR_ROOM_ID,
|
||||
CAPTURE_TRANSCRIPTS,
|
||||
const bot = new OcrccBot(config);
|
||||
try {
|
||||
bot.start();
|
||||
} catch(err) {
|
||||
console.log("Unable to start bot", err)
|
||||
}
|
||||
|
||||
import OcrccBot from './bot'
|
||||
|
||||
const bot = new OcrccBot(botConfig);
|
||||
bot.start();
|
||||
|
50
src/setup.js
Normal file
50
src/setup.js
Normal file
@ -0,0 +1,50 @@
|
||||
const fs = require('fs');
|
||||
const fetch = require('node-fetch');
|
||||
const config = require('../config.json');
|
||||
|
||||
const getSettings = async () => {
|
||||
try {
|
||||
const url = `${config.settingsEndpoint}?homeserver=${encodeURIComponent(config.matrixServerUrl)}`;
|
||||
|
||||
if (!config.matrixServerUrl) {
|
||||
throw new Error("The matrix server url is not provided")
|
||||
}
|
||||
|
||||
console.log(`Fetching settings for ${config.matrixServerUrl}`);
|
||||
|
||||
const res = await fetch(url);
|
||||
const data = await res.json();
|
||||
|
||||
const { fields, schedule = [] } = data;
|
||||
|
||||
return Object.entries(fields).reduce(((settingsObj, [k,v]) => {
|
||||
const [scope, key] = k.split('_');
|
||||
|
||||
if (scope === 'platform') {
|
||||
settingsObj[key] = v;
|
||||
}
|
||||
|
||||
return settingsObj
|
||||
}), {});
|
||||
} catch (err) {
|
||||
console.log("Error fetching settings", err);
|
||||
return null
|
||||
}
|
||||
};
|
||||
|
||||
const writeConfig = async () => {
|
||||
const settings = await getSettings()
|
||||
if (!settings) {
|
||||
return console.log('No settings to update')
|
||||
}
|
||||
|
||||
const updatedSettings = Object.assign(config, settings)
|
||||
|
||||
fs.writeFile('config.json', JSON.stringify(updatedSettings, null, 2), function (err) {
|
||||
if (err) return console.log("Error updating settings", err);
|
||||
console.log(`Updated settings to config.json`);
|
||||
console.log(updatedSettings);
|
||||
});
|
||||
}
|
||||
|
||||
writeConfig();
|
92
yarn.lock
92
yarn.lock
@ -1257,6 +1257,23 @@
|
||||
"@types/yargs" "^15.0.0"
|
||||
chalk "^3.0.0"
|
||||
|
||||
"@peculiar/asn1-schema@^2.0.1":
|
||||
version "2.0.8"
|
||||
resolved "https://registry.yarnpkg.com/@peculiar/asn1-schema/-/asn1-schema-2.0.8.tgz#bafb74388590f6ec3d53d1b2a4fdbe66d44224a4"
|
||||
integrity sha512-D8ZqT61DdzuXfrILNvtdf7MUcTY2o9WHwmF0WgTKPEGNY5SDxNAjBY3enuwV9SXcSuCAwWac9c9v0vsswB1NIw==
|
||||
dependencies:
|
||||
"@types/asn1js" "^0.0.1"
|
||||
asn1js "^2.0.26"
|
||||
pvtsutils "^1.0.10"
|
||||
tslib "^1.11.1"
|
||||
|
||||
"@peculiar/json-schema@^1.1.10":
|
||||
version "1.1.12"
|
||||
resolved "https://registry.yarnpkg.com/@peculiar/json-schema/-/json-schema-1.1.12.tgz#fe61e85259e3b5ba5ad566cb62ca75b3d3cd5339"
|
||||
integrity sha512-coUfuoMeIB7B8/NMekxaDzLhaYmp0HZNPEjYRm9goRou8UZIC3z21s0sL9AWoCw4EG876QyO3kYrc61WNF9B/w==
|
||||
dependencies:
|
||||
tslib "^2.0.0"
|
||||
|
||||
"@sinonjs/commons@^1.7.0":
|
||||
version "1.7.1"
|
||||
resolved "https://registry.yarnpkg.com/@sinonjs/commons/-/commons-1.7.1.tgz#da5fd19a5f71177a53778073978873964f49acf1"
|
||||
@ -1264,6 +1281,13 @@
|
||||
dependencies:
|
||||
type-detect "4.0.8"
|
||||
|
||||
"@types/asn1js@^0.0.1":
|
||||
version "0.0.1"
|
||||
resolved "https://registry.yarnpkg.com/@types/asn1js/-/asn1js-0.0.1.tgz#ef8b9f9708cb1632a1c3a9cd27717caabe793bc2"
|
||||
integrity sha1-74uflwjLFjKhw6nNJ3F8qr55O8I=
|
||||
dependencies:
|
||||
"@types/pvutils" "*"
|
||||
|
||||
"@types/babel__core@^7.1.0":
|
||||
version "7.1.6"
|
||||
resolved "https://registry.yarnpkg.com/@types/babel__core/-/babel__core-7.1.6.tgz#16ff42a5ae203c9af1c6e190ed1f30f83207b610"
|
||||
@ -1322,6 +1346,11 @@
|
||||
"@types/istanbul-lib-coverage" "*"
|
||||
"@types/istanbul-lib-report" "*"
|
||||
|
||||
"@types/pvutils@*":
|
||||
version "0.0.2"
|
||||
resolved "https://registry.yarnpkg.com/@types/pvutils/-/pvutils-0.0.2.tgz#e21684962cfa58ac920fd576d90556032dc86009"
|
||||
integrity sha512-CgQAm7pjyeF3Gnv78ty4RBVIfluB+Td+2DR8iPaU0prF18pkzptHHP+DoKPfpsJYknKsVZyVsJEu5AuGgAqQ5w==
|
||||
|
||||
"@types/stack-utils@^1.0.1":
|
||||
version "1.0.1"
|
||||
resolved "https://registry.yarnpkg.com/@types/stack-utils/-/stack-utils-1.0.1.tgz#0a851d3bd96498fa25c33ab7278ed3bd65f06c3e"
|
||||
@ -1486,6 +1515,13 @@ asn1@~0.2.3:
|
||||
dependencies:
|
||||
safer-buffer "~2.1.0"
|
||||
|
||||
asn1js@^2.0.26:
|
||||
version "2.0.26"
|
||||
resolved "https://registry.yarnpkg.com/asn1js/-/asn1js-2.0.26.tgz#0a6d435000f556a96c6012969d9704d981b71251"
|
||||
integrity sha512-yG89F0j9B4B0MKIcFyWWxnpZPLaNTjCj4tkE3fjbAoo0qmpGw0PYYqSbX/4ebnd9Icn8ZgK4K1fvDyEtW1JYtQ==
|
||||
dependencies:
|
||||
pvutils latest
|
||||
|
||||
assert-plus@1.0.0, assert-plus@^1.0.0:
|
||||
version "1.0.0"
|
||||
resolved "https://registry.yarnpkg.com/assert-plus/-/assert-plus-1.0.0.tgz#f12e0f3c5d77b0b1cdd9146942e4e96c1e4dd525"
|
||||
@ -3863,6 +3899,11 @@ mkdirp@^0.5.1:
|
||||
dependencies:
|
||||
minimist "0.0.8"
|
||||
|
||||
mkdirp@^1.0.4:
|
||||
version "1.0.4"
|
||||
resolved "https://registry.yarnpkg.com/mkdirp/-/mkdirp-1.0.4.tgz#3eb5ed62622756d79a5f0e2a221dfebad75c2f7e"
|
||||
integrity sha512-vVqVZQyf3WLx2Shd0qJ9xuvqgAyKPLAiqITEtqW0oIUjzo3PePDd6fW9iFz30ef7Ysp/oiWqbhszeGWW2T6Gzw==
|
||||
|
||||
ms@2.0.0:
|
||||
version "2.0.0"
|
||||
resolved "https://registry.yarnpkg.com/ms/-/ms-2.0.0.tgz#5608aeadfc00be6c2901df5f9861788de0d597c8"
|
||||
@ -3873,7 +3914,7 @@ ms@^2.1.1:
|
||||
resolved "https://registry.yarnpkg.com/ms/-/ms-2.1.2.tgz#d09d1f357b443f493382a8eb3ccd183872ae6009"
|
||||
integrity sha512-sGkPx+VjMtmA6MX27oA4FBFELFCZZ4S4XqeGOXCv68tT+jb3vk/RyaKWP0PTKyWtmLSM0b+adUTEvbs1PEaH2w==
|
||||
|
||||
nan@^2.12.1:
|
||||
nan@^2.12.1, nan@^2.14.1:
|
||||
version "2.14.1"
|
||||
resolved "https://registry.yarnpkg.com/nan/-/nan-2.14.1.tgz#d7be34dfa3105b91494c3147089315eff8874b01"
|
||||
integrity sha512-isWHgVjnFjh2x2yuJ/tj3JbwoHu3UC2dX5G/88Cm24yB6YopVgxvBObDY7n5xW6ExmFhJpSEQqFPvq9zaXc8Jw==
|
||||
@ -3913,6 +3954,11 @@ node-environment-flags@^1.0.5:
|
||||
object.getownpropertydescriptors "^2.0.3"
|
||||
semver "^5.7.0"
|
||||
|
||||
node-fetch@^2.6.1:
|
||||
version "2.6.1"
|
||||
resolved "https://registry.yarnpkg.com/node-fetch/-/node-fetch-2.6.1.tgz#045bd323631f76ed2e2b55573394416b639a0052"
|
||||
integrity sha512-V4aYg89jEoVRxRb2fJdAg8FHvI7cEyYdVAh94HH0UIK8oJxUfkjlDQN9RbMx+bEjP7+ggMiFRprSti032Oipxw==
|
||||
|
||||
node-int64@^0.4.0:
|
||||
version "0.4.0"
|
||||
resolved "https://registry.yarnpkg.com/node-int64/-/node-int64-0.4.0.tgz#87a9065cdb355d3182d8f94ce11188b825c68a3b"
|
||||
@ -3953,6 +3999,17 @@ node-releases@^1.1.53:
|
||||
resolved "https://registry.yarnpkg.com/node-releases/-/node-releases-1.1.53.tgz#2d821bfa499ed7c5dffc5e2f28c88e78a08ee3f4"
|
||||
integrity sha512-wp8zyQVwef2hpZ/dJH7SfSrIPD6YoJz6BDQDpGEkcA0s3LpAQoxBIYmfIq6QAhC1DhwsyCgTaTTcONwX8qzCuQ==
|
||||
|
||||
node-webcrypto-ossl@^2.1.0:
|
||||
version "2.1.0"
|
||||
resolved "https://registry.yarnpkg.com/node-webcrypto-ossl/-/node-webcrypto-ossl-2.1.0.tgz#cee0e22fa9d9325a19f260539d0854ba143595db"
|
||||
integrity sha512-diC2LLQKKo41XxrgdT2MmH4mxWNoeCwjS0+uSLfui3rCtxai8cdLLs0TKT0z9Mq8LZ4eMAkuU4FFmEOHk6CbsQ==
|
||||
dependencies:
|
||||
mkdirp "^1.0.4"
|
||||
nan "^2.14.1"
|
||||
pvtsutils "^1.0.10"
|
||||
tslib "^1.11.2"
|
||||
webcrypto-core "^1.1.0"
|
||||
|
||||
nodemon@^2.0.2:
|
||||
version "2.0.2"
|
||||
resolved "https://registry.yarnpkg.com/nodemon/-/nodemon-2.0.2.tgz#9c7efeaaf9b8259295a97e5d4585ba8f0cbe50b0"
|
||||
@ -4354,6 +4411,18 @@ punycode@^2.1.0, punycode@^2.1.1:
|
||||
resolved "https://registry.yarnpkg.com/punycode/-/punycode-2.1.1.tgz#b58b010ac40c22c5657616c8d2c2c02c7bf479ec"
|
||||
integrity sha512-XRsRjdf+j5ml+y/6GKHPZbrF/8p2Yga0JPtdqTIY2Xe5ohJPD9saDJJLPvp9+NSBprVvevdXZybnj2cv8OEd0A==
|
||||
|
||||
pvtsutils@^1.0.10:
|
||||
version "1.0.10"
|
||||
resolved "https://registry.yarnpkg.com/pvtsutils/-/pvtsutils-1.0.10.tgz#157d0fcb853f570d32e0f8788179f3057eacdf38"
|
||||
integrity sha512-8ZKQcxnZKTn+fpDh7wL4yKax5fdl3UJzT8Jv49djZpB/dzPxacyN1Sez90b6YLdOmvIr9vaySJ5gw4aUA1EdSw==
|
||||
dependencies:
|
||||
tslib "^1.10.0"
|
||||
|
||||
pvutils@latest:
|
||||
version "1.0.17"
|
||||
resolved "https://registry.yarnpkg.com/pvutils/-/pvutils-1.0.17.tgz#ade3c74dfe7178944fe44806626bd2e249d996bf"
|
||||
integrity sha512-wLHYUQxWaXVQvKnwIDWFVKDJku9XDCvyhhxoq8dc5MFdIlRenyPI9eSfEtcvgHgD7FlvCyGAlWgOzRnZD99GZQ==
|
||||
|
||||
qs@^6.5.2:
|
||||
version "6.9.1"
|
||||
resolved "https://registry.yarnpkg.com/qs/-/qs-6.9.1.tgz#20082c65cb78223635ab1a9eaca8875a29bf8ec9"
|
||||
@ -5161,6 +5230,16 @@ triple-beam@^1.2.0, triple-beam@^1.3.0:
|
||||
resolved "https://registry.yarnpkg.com/triple-beam/-/triple-beam-1.3.0.tgz#a595214c7298db8339eeeee083e4d10bd8cb8dd9"
|
||||
integrity sha512-XrHUvV5HpdLmIj4uVMxHggLbFSZYIn7HEWsqePZcI50pco+MPqJ50wMGY794X7AOOhxOBAjbkqfAbEe/QMp2Lw==
|
||||
|
||||
tslib@^1.10.0, tslib@^1.11.1, tslib@^1.11.2:
|
||||
version "1.13.0"
|
||||
resolved "https://registry.yarnpkg.com/tslib/-/tslib-1.13.0.tgz#c881e13cc7015894ed914862d276436fa9a47043"
|
||||
integrity sha512-i/6DQjL8Xf3be4K/E6Wgpekn5Qasl1usyw++dAA35Ue5orEn65VIxOA+YvNNl9HV3qv70T7CNwjODHZrLwvd1Q==
|
||||
|
||||
tslib@^2.0.0:
|
||||
version "2.0.0"
|
||||
resolved "https://registry.yarnpkg.com/tslib/-/tslib-2.0.0.tgz#18d13fc2dce04051e20f074cc8387fd8089ce4f3"
|
||||
integrity sha512-lTqkx847PI7xEDYJntxZH89L2/aXInsyF2luSafe/+0fHOMjlBNXdH6th7f70qxLDhul7KZK0zC8V5ZIyHl0/g==
|
||||
|
||||
tunnel-agent@^0.6.0:
|
||||
version "0.6.0"
|
||||
resolved "https://registry.yarnpkg.com/tunnel-agent/-/tunnel-agent-0.6.0.tgz#27a5dea06b36b04a0a9966774b290868f0fc40fd"
|
||||
@ -5392,6 +5471,17 @@ walker@^1.0.7, walker@~1.0.5:
|
||||
dependencies:
|
||||
makeerror "1.0.x"
|
||||
|
||||
webcrypto-core@^1.1.0:
|
||||
version "1.1.2"
|
||||
resolved "https://registry.yarnpkg.com/webcrypto-core/-/webcrypto-core-1.1.2.tgz#c522a9e5596688f2b6bb19e2d336f68efa8bdd57"
|
||||
integrity sha512-LxM/dTcXr/ZnwwKLox0tGEOIqvP7KIJ4Hk/fFPX20tr1EgqTmpEFZinmu4FzoGVbs6e4jI1priQKCDrOBD3L6w==
|
||||
dependencies:
|
||||
"@peculiar/asn1-schema" "^2.0.1"
|
||||
"@peculiar/json-schema" "^1.1.10"
|
||||
asn1js "^2.0.26"
|
||||
pvtsutils "^1.0.10"
|
||||
tslib "^1.11.2"
|
||||
|
||||
webidl-conversions@^4.0.2:
|
||||
version "4.0.2"
|
||||
resolved "https://registry.yarnpkg.com/webidl-conversions/-/webidl-conversions-4.0.2.tgz#a855980b1f0b6b359ba1d5d9fb39ae941faa63ad"
|
||||
|
Loading…
Reference in New Issue
Block a user