v2.0.9

actions/chapter-page.js

@@ -15,10 +15,19 @@ composer.action([
   const copy = ctx.match[3] === 'true'
   const offset = ctx.match[4]
   const history = ctx.match[5]
+  if (getFiles.getCacheBlockingValue()) {
+    return ctx.answerCbQuery(
+      `Sorry, caching isn't available right now.\nThis can be because of bot update or malfunction.`,
+      true,
+      { cache_time: 10 }
+    )
+  }
   let chapter = await getChapter(chapterId)
   const manga = await getManga(chapter.manga_id, false)
   chapter = await getFiles(chapter, manga, ctx, offset, history)
-  if (!chapter) { return ctx.answerCbQuery('') }
+  if (!chapter) {
+    return ctx.answerCbQuery('')
+  }
   const keyboard = [
     [
       {

actions/choosen-inline-query.js

@@ -0,0 +1,10 @@
+const { Composer } = require('telegraf').default
+const composer = new Composer()
+
+// composer.on('chosen_inline_result', async ctx => {
+//   console.log(ctx.update.chosen_inline_result)
+// })
+
+module.exports = app => {
+  app.use(composer.middleware())
+}

actions/index.js

@@ -6,4 +6,5 @@ module.exports = app => {
   require('./chapter-list')(app)
   require('./delete')(app)
   require('./mark-as-read')(app)
+  require('./choosen-inline-query')(app)
 }

actions/inline-query.js

@@ -127,10 +127,18 @@ composer.on('inline_query', async ctx => {
       },
       reply_markup: {
         inline_keyboard: [
-          [{
-            text: 'Read manga',
-            url: `https://t.me/${ctx.me}?start=${buffer.encode(`manga:${title.id}`)}`
-          }]
+          [
+            {
+              text: 'Read manga',
+              url: `https://t.me/${ctx.me}?start=${buffer.encode(`manga:${title.id}`)}`
+            }
+          ]
+          // ,[
+          //   {
+          //     text: 'Want to read',
+          //     callback_data: `test:1`
+          //   }
+          // ]
         ]
       },
       thumb_url: title.image_url
@@ -143,6 +151,11 @@ composer.on('inline_query', async ctx => {
   }
 })
 
+// composer.action(/test:(\S+)/i, async ctx => {
+//   console.log(ctx.update)
+//   ctx.answerCbQuery('Hello there!')
+// })
+
 module.exports = app => {
   app.use(composer.middleware())
 }

actions/user-reading-list.js

@@ -0,0 +1,3 @@
+const Composer = require('telegraf/composer')
+const composer = new Composer()
+const getFiles = require('../lib/get-files')

commands/get-cache-pool.js

@@ -0,0 +1,76 @@
+const Composer = require('telegraf/composer')
+const composer = new Composer()
+const getFiles = require('../lib/get-files')
+
+composer.command('pool', async ctx => {
+  if (ctx.from.id === Number.parseInt(process.env.ADMIN_ID)) {
+    ctx.reply(`Here's ${Object.keys(getFiles.cachePool()).length} chapters waiting to be cached.`, {
+      reply_markup: {
+        inline_keyboard: cacheKeyboard(
+          getFiles.getCacheBlockingValue(),
+          getFiles.getUpdateCachingBlockingValue()
+        )
+      }
+    })
+  }
+})
+composer.action(/^cachepool=(\S+)$/i, async ctx => {
+  if (ctx.from.id === Number.parseInt(process.env.ADMIN_ID)) {
+    switch (ctx.match[1]) {
+      case 'on':
+        getFiles.setCachingBlocking(true)
+        break
+      case 'off':
+        getFiles.setCachingBlocking(false)
+        break
+    }
+    ctx.editMessageReplyMarkup({
+      inline_keyboard: cacheKeyboard(
+        getFiles.getCacheBlockingValue(),
+        getFiles.getUpdateCachingBlockingValue()
+      )
+    })
+  } else {
+    return ctx.editMessageReplyMarkup({ inline_keyboard: [] })
+  }
+})
+
+composer.action(/^updatecache=(\S+)$/i, async ctx => {
+  if (ctx.from.id === Number.parseInt(process.env.ADMIN_ID)) {
+    switch (ctx.match[1]) {
+      case 'on':
+        getFiles.setUpdateCachingBlocking(true)
+        break
+      case 'off':
+        getFiles.setUpdateCachingBlocking(false)
+        break
+    }
+    ctx.editMessageReplyMarkup({
+      inline_keyboard: cacheKeyboard(
+        getFiles.getCacheBlockingValue(),
+        getFiles.getUpdateCachingBlockingValue()
+      )
+    })
+  } else {
+    return ctx.editMessageReplyMarkup({ inline_keyboard: [] })
+  }
+})
+
+module.exports = app => {
+  app.use(composer.middleware())
+}
+
+function cacheKeyboard (cacheBlock, updateBlock) {
+  return [
+    [
+      {
+        text: `${cacheBlock ? 'Enable' : 'Disable'} caching`,
+        callback_data: `cachepool=${cacheBlock ? 'off' : 'on'}`
+      },
+      {
+        text: `${updateBlock ? 'Enable' : 'Disable'} updating`,
+        callback_data: `updatecache=${updateBlock ? 'off' : 'on'}`
+      }
+    ]
+  ]
+}

commands/index.js

@@ -1,4 +1,5 @@
 module.exports = app => {
   require('./start')(app)
   require('./search')(app)
+  require('./get-cache-pool')(app)
 }

core/database/index.js

@@ -131,4 +131,4 @@ module.exports = collectionName => {
   } else {
     throw new Error('Collection not found')
   }
-}
+}