VueTorrent/server/qbit.js

const api = require('qbittorrent-api-v2')
const dotenv = require('dotenv')
const Torrent = require('./models/torrent.class.js')
const Stat = require('./models/stat.class.js')

dotenv.config()

const connection = api.connect(process.env.QBIT_HOST, process.env.QBIT_USER, process.env.QBIT_PASS)


class Qbit {
  async get_all(prop) {
    try {
    const res = await (await connection).torrents('all', null, prop.name, String(prop.reverse), '20', null, null)
    const torrents = []
        res.forEach((el) => {
          const t = new Torrent(el)
          torrents.push(t)
        })
    return torrents
    } catch (err) {
      return `something went wrong:${err}`
    }
  }

  async get_session_stats() {
    try {
    const res = await (await connection).transferInfo()
    return new Stat(res)
    } catch (err) {
      return `something went wrong:${err}`
    }
  }

  async pause_torrents(torrents) {
    let _torrents = ''
    torrents.forEach((el) => {
      _torrents += `${el}|`
    })
    try {
      return await (await connection).pauseTorrents(_torrents)
      } catch (err) {
        return `something went wrong:${err}`
      }
  }

  async pause_all() {
    try {
      return await (await connection).pauseTorrents('all')
      } catch (err) {
        return `something went wrong:${err}`
      }
  }

  async resume_torrents(torrents) {
    let _torrents = ''
    torrents.forEach((el) => {
      _torrents += `${el}|`
    })
    console.log(_torrents)
    try {
      return await (await connection).resumeTorrents(_torrents)
      } catch (err) {
        return `something went wrong:${err}`
      }
  }

  async resume_all() {
    try {
      return await (await connection).resumeTorrents('all')
      } catch (err) {
        return `something went wrong:${err}`
      }
  }

  async remove_torrents(torrents) {
    let _torrents = ''
    torrents.forEach((el) => {
      _torrents += `${el}|`
    })
    console.log(_torrents)
    try {
      return await (await connection).deleteTorrents(_torrents, 'true')
      } catch (err) {
        return `something went wrong:${err}`
      }
  }

  async add(torrent) {
    return new Promise((resolve, reject) => {
      connection.add(torrent.path, null, null, (err, res) => {
        resolve(res)
        reject(err)
      })
    })
  }
}

const qbit = new Qbit()

module.exports = qbit