Skip to content

Commit

Permalink
Some comments and small fix
Browse files Browse the repository at this point in the history
  • Loading branch information
savely-krasovsky committed Jun 3, 2017
1 parent 986a3e7 commit 0f71764
Show file tree
Hide file tree
Showing 3 changed files with 38 additions and 8 deletions.
2 changes: 1 addition & 1 deletion .gitignore
Original file line number Diff line number Diff line change
Expand Up @@ -62,4 +62,4 @@ typings/
config.js

.idea
torrents
torrents
36 changes: 29 additions & 7 deletions index.js
Original file line number Diff line number Diff line change
Expand Up @@ -25,12 +25,7 @@ const keyboard = {

// Либа для работы с Телеграмом
const TelegramBot = require('node-telegram-bot-api');
global.bot = new TelegramBot(config.private.token, {
webHook: {
port: 5000
}
});
//{ polling: true });
global.bot = new TelegramBot(config.private.token, config.private.bot);

// Драйвер для работы с базой данных RethinkDB
global.r = require('rethinkdbdash')({
Expand All @@ -48,7 +43,11 @@ require('./push')();

const parseTorrent = require('parse-torrent');

// Конвертирует ID из string в int для правильной сортировки в БД
/**
* Конвертирует ID из string в int для правильной сортировки в БД
* @param body
* @returns {Array}
*/
global.fixId = function fixId(body) {
let temp = [];
for (let i in body.data)
Expand Down Expand Up @@ -178,6 +177,17 @@ bot.onText(/^\/login/, function (msg) {
});
});

/**
* Функция для загрузки торрент-файлов и упаковки их в zip-архив.
* Последний параметр torrentOnly не обязателен и требуется только для обладателей
* личного бота. Берет нужное качество из конфига и загружает только его.
* @param from_id
* @param serial
* @param season
* @param episode
* @param torrentOnly
* @returns {Promise}
*/
global.download = function(from_id, serial, season, episode, torrentOnly) {
// Флаг для пользователей личного бота.
// Требуется, когда нужна загрузка определенного торрента, а не архива.
Expand Down Expand Up @@ -518,6 +528,12 @@ bot.onText(/^\/update/, async function () {
});

bot.onText(/^\/search|🔍Поиск/, function (msg) {
/**
* Возвращает нужный запрос в зависимости от детектированного языка
* @param type
* @param text
* @returns {Promise}
*/
function dbRequest(type, text) {
if (type === 'cyrillic')
type = 'title';
Expand Down Expand Up @@ -566,6 +582,12 @@ bot.onText(/^\/search|🔍Поиск/, function (msg) {
});
});

/**
* Парсит расписание из объекта $, который понимает cheerio.
* На выходе готовый массив.
* @param $
* @returns {Array}
*/
function parseSchedule($) {
const table = $('tbody > tr');

Expand Down
8 changes: 8 additions & 0 deletions push.js
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,11 @@ function hashCode(str){
}

module.exports = function () {
/**
* Функция ничего не принимает и не возвращает.
* Однако изменения, к которым её выполнение приводит, изменяет данные в базе.
* И это приводит к срабатыванию блок ниже.
*/
function fetch() {
const feedparser = new FeedParser();

Expand Down Expand Up @@ -125,6 +130,9 @@ module.exports = function () {

setInterval(fetch, 1000 * 60 * 3);

/**
* Этот блок обрабатывает изменения в базе и начинает рассылку.
*/
r.table('feed').changes()
.then(function (cursor) {
cursor.each(function(err, row) {
Expand Down

0 comments on commit 0f71764

Please sign in to comment.