\``)
- sender.commandStatus = {
- action: "Phone code authentication",
- next: commands.enterCode,
- }
- } catch (err) {
- reply(`**Failed to send code:** ${err}`)
- if (err instanceof Error) {
- reply(["```", err.stack, "```"].join(""))
- console.error(err.stack)
- }
- }
-}
-
-commands.register = async (sender, args, reply) => {
- reply("Registration has not yet been implemented. Please use the official apps for now.")
-}
-
-commands.logout = async (sender, args, reply) => {
- try {
- sender.logOutFromTelegram()
- reply("Logged out successfully.")
- } catch (err) {
- reply(`**Failed to log out:** ${err}`)
- if (err instanceof Error) {
- reply(["```", err.stack, "```"].join(""))
- console.error(err.stack)
- }
- }
-}
-
-//////////////////////////////
-// General command handlers //
-//////////////////////////////
-
-commands.create = async (sender, args, reply, { app, roomID }) => {
- if (args.length < 1 || (args[0] !== "group" && args[0] !== "channel")) {
- reply("**Usage:** `$cmdprefix create `")
- return
- } else if (!sender._telegramPuppet) {
- reply("This command requires you to be logged in.")
- return
- } else if (args[0] === "channel") {
- reply("Creating channels is not yet supported.")
- return
- }
-
- if (args.length > 1) {
- roomID = args[1]
- }
-
- // TODO make sure that the AS bot is in the room.
-
- const title = await app.getRoomTitle(roomID)
- if (!title) {
- reply("Please set a room name before creating a Telegram chat.")
- return
- }
-
- let portal = await app.getPortalByRoomID(roomID)
- if (portal) {
- reply("This is already a portal room.")
- return
- }
-
- portal = new Portal(app, roomID)
- try {
- await portal.createTelegramChat(sender.telegramPuppet, title)
- reply(`Telegram chat created. ID: ${portal.id}`)
- if (app.managementRooms.includes(roomID)) {
- app.managementRooms.splice(app.managementRooms.indexOf(roomID), 1)
- }
- } catch (err) {
- reply(`Failed to create Telegram chat: ${err}`)
- }
-}
-
-commands.upgrade = async (sender, args, reply, { app, roomID }) => {
- if (!sender._telegramPuppet) {
- reply("This command requires you to be logged in.")
- return
- }
-
- const portal = await app.getPortalByRoomID(roomID)
- if (!portal) {
- reply("This is not a portal room.")
- return
- }
-
- await portal.upgradeTelegramChat(sender.telegramPuppet)
-}
-
-commands.search = async (sender, args, reply, { app }) => {
- if (args.length < 1) {
- reply("**Usage:** `$cmdprefix search [-r|--remote] `")
- return
- } else if (!sender._telegramPuppet) {
- reply("This command requires you to be logged in.")
- return
- }
- const msg = []
- if (args[0] !== "-r" && args[0] !== "--remote") {
- const contactResults = await sender.searchContacts(args.join(" "))
- if (contactResults.length > 0) {
- msg.push("**Following results found from local contacts:**")
- msg.push("")
- for (const { match, contact } of contactResults) {
- msg.push(`- ${contact.getDisplayName()}: ${contact.id} (${match}% match)`)
- }
- msg.push("")
- msg.push("To force searching from Telegram servers, add `-r` before the search query.")
- reply(msg.join("\n"), { allowHTML: true })
- return
- }
- } else {
- args.shift()
- msg.push("-r flag found: forcing remote search")
- msg.push("")
- }
- const query = args.join(" ")
- if (query.length < 5) {
- reply("Failed to search server: Query is too short.")
- return
- }
- const telegramResults = await sender.searchTelegram(query)
- if (telegramResults.length > 0) {
- msg.push("**Following results received from Telegram server:**")
- for (const user of telegramResults) {
- msg.push(`- ${user.getDisplayName()}: ${user.id}`)
- }
- } else {
- msg.push("**No users found.**")
- }
- reply(msg.join("\n"), { allowHTML: true })
-}
-
-commands.pm = async (sender, args, reply, { app }) => {
- if (args.length < 1) {
- reply("**Usage:** `$cmdprefix pm `")
- return
- } else if (!sender._telegramPuppet) {
- reply("This command requires you to be logged in.")
- return
- }
- const user = await app.getTelegramUser(+args[0], { createIfNotFound: false })
- if (!user) {
- reply("User info not saved. Try searching for the user first?")
- return
- }
- const peer = user.toPeer(sender.telegramPuppet)
-
- const userInfo = await peer.getInfo(sender.telegramPuppet)
- await user.updateInfo(sender.telegramPuppet, userInfo)
-
- const portal = await app.getPortalByPeer(peer)
- await portal.createMatrixRoom(sender.telegramPuppet, {
- invite: [sender.userID],
- })
-}
-
-////////////////////////////
-// Debug command handlers //
-////////////////////////////
-
-commands.api = async (sender, args, reply, { app }) => {
- if (!app.config.bridge.commands.allow_direct_api_calls) {
- reply("Direct API calls are forbidden on this mautrix-telegram instance.")
- return
- }
- const apiMethod = args.shift()
- let apiArgs
- try {
- apiArgs = JSON.parse(args.join(" "))
- } catch (err) {
- reply("Invalid API method parameters. Usage: $cmdprefix api ")
- return
- }
- try {
- reply(`Calling ${apiMethod} with the following arguments:\n${JSON.stringify(apiArgs, "", " ")}`)
- const response = await sender.telegramPuppet.client(apiMethod, apiArgs)
- reply(`API call successful. Response:
-
-
- ${JSON.stringify(response, "", " ")}
-
`, { allowHTML: true })
- } catch (err) {
- reply(`API call errored. Response:\n${JSON.stringify(err, "", " ")}`)
- }
-}
-
-function timeout(promise, ms = 2500) {
- return new Promise((resolve, reject) => {
- promise.then(resolve, reject)
- setTimeout(() => reject(new Error("API call response not received")), ms)
- })
-}
-
-commands.ping = async (sender, args, reply) => {
- try {
- await timeout(sender.telegramPuppet.client("contacts.getContacts", {}))
- reply("Connection seems OK.")
- } catch (err) {
- reply(`Not connected: ${err}`)
- }
-}
-
-module.exports = {
- commands,
- run,
-}
diff --git a/src/formatter.js b/src/formatter.js
deleted file mode 100644
index 4a057f63..00000000
--- a/src/formatter.js
+++ /dev/null
@@ -1,360 +0,0 @@
-// mautrix-telegram - A Matrix-Telegram puppeting bridge
-// Copyright (C) 2017 Tulir Asokan
-//
-// This program is free software: you can redistribute it and/or modify
-// it under the terms of the GNU General Public License as published by
-// the Free Software Foundation, either version 3 of the License, or
-// (at your option) any later version.
-//
-// This program is distributed in the hope that it will be useful,
-// but WITHOUT ANY WARRANTY; without even the implied warranty of
-// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
-// GNU General Public License for more details.
-//
-// You should have received a copy of the GNU General Public License
-// along with this program. If not, see
- * WARNING: This module contains headache-causing regular expressions and other duct tape.
- *
- * @module formatter
- */
-
-String.prototype.insert = function(at, str) {
- return this.slice(0, at) + str + this.slice(at)
-}
-
-/**
- * Add a simple HTML tag to the given tag list.
- *
- * @param {Object[]} tags The tag list.
- * @param {Object} entity The Telegram format entity.
- * @param {number} entity.offset The index where the format entity starts.
- * @param {number} entity.length The length of the format entity.
- * @param {string} tag The HTML tag to add.
- * @param {number} priority The tag priority to use when sorting tags at the same index.
- * @private
- */
-function addSimpleTag(tags, entity, tag, priority = 0) {
- tags.push([entity.offset, `<${tag}>`, -priority])
- tags.push([entity.offset + entity.length, ``, priority])
-}
-
-
-/**
- * Add a HTML tag to the given tag list.
- *
- * @param {Object[]} tags The tag list.
- * @param {Object} entity The Telegram format entity.
- * @param {number} entity.offset The index where the format entity starts.
- * @param {number} entity.length The length of the format entity.
- * @param {string} tag The HTML tag to add.
- * @param {string} attrs The HTML attributes to add to the tag.
- * @param {number} priority The tag priority to use when sorting tags at the same index.
- * @private
- */
-function addTag(tags, entity, tag, attrs, priority = 0) {
- tags.push([entity.offset, `<${tag} ${attrs}>`, -priority])
- tags.push([entity.offset + entity.length, ``, priority])
-}
-
-/**
- * Convert a Telegram entity-formatted message to a Matrix HTML-formatted message.
- *
- * WARNING: I am not responsible for possible severe headaches caused by reading any part of this function.
- *
- * @param {string} message The plaintext message.
- * @param {Array} entities The Telegram formatting entities.
- * @param {MautrixTelegram} app The app main class instance to use when reformatting mentions.
- */
-function telegramToMatrix(message, entities, app) {
- const tags = []
- // Decreasing priority counter used to ensure that formattings right next to eachother don't flip like this:
- // *bold*_italic_ --> bolditalic
- let pc = 9001
-
- // Convert Telegram formatting entities into a weird custom indexed HTML tag format thingy.
- for (const entity of entities) {
- let url, tag, mxid
- switch (entity._) {
- case "messageEntityBold":
- tag = tag || "strong"
- case "messageEntityItalic":
- tag = tag || "em"
- case "messageEntityCode":
- tag = tag || "code"
- addSimpleTag(tags, entity, tag, --pc)
- break
- case "messageEntityPre":
- pc--
- addSimpleTag(tags, entity, "pre", pc)
- addTag(tags, entity, "code", `class="language-${entity.language}"`, pc + 1)
- break
- case "messageEntityBotCommand":
- // TODO bridge bot commands differently?
- message = `${message.substr(0, entity.offset)}!${message.substr(entity.offset + 1)}`
- case "messageEntityHashtag":
- addTag(tags, entity, "font", "color=\"blue\"", --pc)
- break
- case "messageEntityMentionName":
- let user = app.matrixUsersByTelegramID.get(entity.user_id)
- if (!user) {
- // TODO this loop step should be made useless
- for (const userByMXID of app.matrixUsersByID.values()) {
- if (userByMXID.telegramUserID === entity.user_id) {
- user = userByMXID
- app.matrixUsersByTelegramID.set(userByMXID.telegramUserID, userByMXID)
- break
- }
- }
- }
- mxid = user ?
- user.userID :
- app.getMXIDForTelegramUser(entity.user_id)
- case "messageEntityMention":
- if (!mxid) {
- const username = message.substr(entity.offset + 1, entity.length - 1)
- for (const userByMXID of app.matrixUsersByID.values()) {
- if (userByMXID._telegramPuppet && userByMXID._telegramPuppet.data.username === username) {
- mxid = userByMXID.userID
- break
- }
- }
- if (!mxid) {
- for (const userByID of app.telegramUsersByID.values()) {
- if (userByID.username === username) {
- mxid = userByID.mxid
- break
- }
- }
- }
- }
-
- if (!mxid) {
- continue
- }
- addTag(tags, entity, "a", `href="https://matrix.to/#/${mxid}"`)
- break
- case "messageEntityEmail":
- url = url || `mailto:${message.substr(entity.offset, entity.length)}`
- case "messageEntityUrl":
- url = url || message.substr(entity.offset, entity.length)
- case "messageEntityTextUrl":
- url = url || entity.url
- addTag(tags, entity, "a", `href="${url}"`, --pc)
- break
- }
- }
-
- // Sort tags in a mysterious way (it seems to work, don't touch it!).
- //
- // The important thing is that the tags are sorted last to first,
- // so when replacing by index, the index doesn't need to be adapted.
- tags.sort(([aIndex, , aPriority], [bIndex, , bPriority]) => bIndex - aIndex || aPriority - bPriority)
-
- // Insert tags into message
- for (const [index, replacement] of tags) {
- message = message.insert(index, replacement)
- }
- message = message.replace(/\n/g, "
\n")
- return message
-}
-
-// Formatting that is converted back to text
-const linebreaks = /(\n)?/g
-const paragraphs = /([^]*?)<\/p>/g
-const headers = /([^]*?)<\/h[0-6]>/g
-const unorderedLists = /([^]*?)<\/ul>/g
-const orderedLists = /([^]*?)<\/ol>/g
-const listEntries = /- ([^]*?)<\/li>/g
-const blockquotes = /
([^]*?)<\/blockquote>/g
-
-// Formatting that is brutally murdered
-const strikedText = /([^]*?)<\/del>/g
-const underlinedText = /([^]*?)<\/u>/g
-
-// Formatting that is converted to Telegram entity formatting
-const boldText = /<(strong)>()([^]*?)<\/strong>/g
-const italicText = /<(em)>()([^]*?)<\/em>/g
-const codeblocks = /<(pre>()([^]*?)<\/code><\/pre>/g
-const codeblocksWithSyntaxHighlight = /<(pre>([^]*?)<\/code><\/pre>/g
-const inlineCode = /<(code)>()(.*?)<\/code>/g
-const emailAddresses = /([^]*?)<\/a>/g
-const mentions = /(.*?)<\/a>/g
-const hyperlinks = /<(a href)="(.*?)">([^]*?)<\/a>/g
-const commands = /(\s|^)!([^\s]+)/g
-const REGEX_CAPTURE_GROUP_COUNT = 3
-
-RegExp.any = function(...regexes) {
- let components = []
- for (const regex of regexes) {
- if (regex instanceof RegExp) {
- components = components.concat(regex._components || regex.source)
- }
- }
- return new RegExp(`(?:${components.join(")|(?:")})`)
-}
-
-const regexMonster = RegExp.any(boldText, italicText, codeblocks,
- codeblocksWithSyntaxHighlight, inlineCode, emailAddresses,
- mentions, hyperlinks)
-const NUMBER_OF_REGEXES_EATEN_BY_MONSTER = 8
-
-function regexMonsterMatchParser(match) {
- match.pop() // Remove full string
- const index = match.pop()
- let identifier, arg, text
- for (let i = 0; i < NUMBER_OF_REGEXES_EATEN_BY_MONSTER; i++) {
- if (match[i * REGEX_CAPTURE_GROUP_COUNT]) {
- identifier = match[i * REGEX_CAPTURE_GROUP_COUNT]
- arg = match[(i * REGEX_CAPTURE_GROUP_COUNT) + 1]
- text = match[(i * REGEX_CAPTURE_GROUP_COUNT) + 2]
- }
- }
- return { index, identifier, arg, text }
-}
-
-function regexMonsterHandler(identifier, arg, text, index, app) {
- let entity, entityClass, argField
- switch (identifier) {
- case "strong":
- entityClass = "Bold"
- break
- case "em":
- entityClass = "Italic"
- break
- case "pre> {
- entities.push({
- _: "messageEntityBotCommand",
- offset: index + prefix.length,
- length: command.length + 1,
- })
- return `${prefix}/${command}`
- })
-
- if (!isHTML) {
- return { message, entities }
- }
-
- // First replace all the things that don't get converted into Telegram entities
- message = message.replace(linebreaks, "\n")
- message = message.replace(paragraphs, "$1\n")
- message = message.replace(headers, (_, count, text) => `${"#".repeat(count)} ${text}`)
- message = message.replace(unorderedLists, (_, list) => list.replace(listEntries, "- $1"))
- message = message.replace(orderedLists, (_, list) => {
- let n = 0
- return list.replace(listEntries, (fullMatch, text) => `${++n}. ${text}`)
- })
- message = message.replace(blockquotes, (_, quote) => quote
- .split("\n")
- .map(line => line.trim())
- .filter(line => line.length > 0)
- .map(line => `> ${line}`)
- .join("\n"))
-
- // Just remove these, they have no textual or Telegramical representation.
- message = message.replace(strikedText, (_, text) => text)
- message = message.replace(underlinedText, (_, text) => text)
- message = message.trim()
-
- const regexMonsterReplacer = (match, ...args) => {
- const { index, identifier, arg, text } = regexMonsterMatchParser(args)
- if (!identifier) {
- // This shouldn't happen
- console.warn(`Warning: Match found but parsing failed for match "${match}"`)
- return match
- }
- const { replacement, entity } = regexMonsterHandler(identifier, arg, text, index, app)
- if (entity) {
- entities.push(entity)
- }
- return replacement || text
- }
-
- // We replace matches iteratively to make sure the indexes of matches are correct.
- let oldMessage = message
- message = message.replace(regexMonster, regexMonsterReplacer)
- while (oldMessage !== message) {
- oldMessage = message
- message = message.replace(regexMonster, regexMonsterReplacer)
- }
-
- return { message, entities }
-}
-
-module.exports = { telegramToMatrix, matrixToTelegram }
diff --git a/src/index.js b/src/index.js
deleted file mode 100755
index 60eb6209..00000000
--- a/src/index.js
+++ /dev/null
@@ -1,67 +0,0 @@
-#!/usr/bin/env node
-// mautrix-telegram - A Matrix-Telegram puppeting bridge
-// Copyright (C) 2017 Tulir Asokan
-//
-// This program is free software: you can redistribute it and/or modify
-// it under the terms of the GNU General Public License as published by
-// the Free Software Foundation, either version 3 of the License, or
-// (at your option) any later version.
-//
-// This program is distributed in the hope that it will be useful,
-// but WITHOUT ANY WARRANTY; without even the implied warranty of
-// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
-// GNU General Public License for more details.
-//
-// You should have received a copy of the GNU General Public License
-// along with this program. If not, see ", "the file to load the config from. defaults to ./config.yaml")
- .option("-g, --generate-registration", "generate a registration based on the config")
- .option("-r, --registration ", "the file to save the registration to. defaults to ./registration.yaml")
- .parse(process.argv)
-
-// commander doesn't seem to set default values automatically.
-program.registration = program.registration || "./registration.yaml"
-program.config = program.config || "./config.yaml"
-
-const config = YAML.load(program.config)
-
-if (program.generateRegistration) {
- const registration = {
- id: config.appservice.id,
- hs_token: AppServiceRegistration.generateToken(),
- as_token: AppServiceRegistration.generateToken(),
- namespaces: {
- users: [{
- exclusive: true,
- regex: `@${config.bridge.username_template.replace("${ID}", ".+")}:${config.homeserver.domain}`,
- }],
- aliases: [{
- exclusive: true,
- regex: `#${config.bridge.alias_template.replace("${NAME}", ".+")}:${config.homeserver.domain}`,
- }],
- rooms: [],
- },
- url: `${config.appservice.protocol}://${config.appservice.hostname}:${config.appservice.port}`,
- sender_localpart: config.bridge.bot_username,
- rate_limited: false,
- }
-
- fs.writeFileSync(program.registration, YAML.stringify(registration, 10))
- config.appservice.registration = program.registration
- fs.writeFileSync(program.config, YAML.stringify(config, 10))
-
- console.log("Registration generated and saved to", program.registration)
- process.exit()
-}
-
-const app = new MautrixTelegram(config)
-app.run()
diff --git a/src/matrix-user.js b/src/matrix-user.js
deleted file mode 100644
index 54960cdf..00000000
--- a/src/matrix-user.js
+++ /dev/null
@@ -1,402 +0,0 @@
-// mautrix-telegram - A Matrix-Telegram puppeting bridge
-// Copyright (C) 2017 Tulir Asokan
-//
-// This program is free software: you can redistribute it and/or modify
-// it under the terms of the GNU General Public License as published by
-// the Free Software Foundation, either version 3 of the License, or
-// (at your option) any later version.
-//
-// This program is distributed in the hope that it will be useful,
-// but WITHOUT ANY WARRANTY; without even the implied warranty of
-// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
-// GNU General Public License for more details.
-//
-// You should have received a copy of the GNU General Public License
-// along with this program. If not, see