index.js

//require
var WebTorrent = require('webtorrent')
require('dotenv').config({path:'./config.env'})
const Telegraf = require('telegraf')
const commandParts = require('telegraf-command-parts')
const fileManager = require('file-manager-js')
const { DownloaderHelper } = require('node-downloader-helper')
const forever = require('forever-monitor')
const json2md = require('json2md')
const moveFile = require('move-file')
const ytdl = require('ytdl-core')
const fs = require('fs')

//converters
json2md.converters.files = function (input, json2md) {
	return '===== files =====' + '\n' + input
}
json2md.converters.dirs = function (input, json2md) {
	return '===== dirs =====' + '\n' + input
}

//new telegraf bot
const bot = new Telegraf(process.env.BOT_TOKEN)
//new torrent client
const client = new WebTorrent()
//mid_ware
bot.use(commandParts())
//normal
bot.start((ctx) => ctx.reply('Welcome! please check /help for more information'))
bot.help((ctx) => ctx.reply('just for personal use torrent client via telegram, if you want use please contact NightCandle for permission.'))

//movefile
bot.command('movefile',(ctx) => {
	files = ctx.state.command.args
	ctx.reply('input newPath')
	bot.command('newpath', async (ctx) => {
		let newpath = ctx.state.command.args
		try {
			await moveFile(`./file_save/${files}`, `./file_save/${newpath}`)
			ctx.reply('movefile successful')
		} catch {
			ctx.reply('movefile failed')
		}		
	})
})


//downloader
bot.command('download',(ctx) => {
	let http_url = ctx.state.command.args
	let dl = new DownloaderHelper(http_url, './file_save')
	dl.on('start',function(){
		ctx.reply('donwload start')
	})
	dl.on('end', function(){
		ctx.reply('download completed')
	})
	dl.on('error',function(){
		ctx.reply('download failed')
	})
	dl.on('timeout',function(){
		dl.stop()
		ctx.reply('download failed')
	})
	dl.start()
})

//torrent magnetic
bot.command('magnetic',(ctx) => {
	let magnetic_url = ctx.state.command.args
	client.add(magnetic_url,{path: './file_save'}, 
		function(torrent){
			ctx.reply('torrent download start')
			torrent.on('done',function(){
				ctx.reply('torrent download finished')
			})
		})
})

//youtube
bot.command('ytdl',(ctx) => {
	let url = ctx.state.command.args
	let name = url.match(/(?<=^.{17}).*/)
	try{
		ctx.reply('youtube download start')
		ytdl(url)
			.pipe(fs.createWriteStream(`./file_save/${name}.mp4`))
				.on('close', () => {
					ctx.reply('youtube download finished')
				})
	} catch (err){
		ctx.reply('youtube download failed')
		console.log(err)
	}
})

//state
bot.command('progress',(ctx) =>{
	console.log(client.progress)
	console.log(client.downloadSpeed)
	ctx.reply(`${client.progress}
${client.downloadSpeed}`)
})

//remove
bot.command('remove',(ctx) => {
	let torrentId = ctx.state.command.args
	try{
		client.remove(torrentId, (err) =>
		{	
			if(err){
				throw err
			} else{
				ctx.reply('torrent remove successful')
			}
		})
	} catch (err){
		ctx.reply('torrent remove failed')
	}
})

//list
bot.command('list',(ctx) => {
	fileManager.listDeep('./file_save')
		.then((entries) => {
			const regex = /,/gi

			let replymd = json2md(entries)
			let md1 = replymd.replace(regex,'\n')
			let md = md1.replace(new RegExp('file_save/', 'g'),'')

			ctx.reply(md)
		})
		.catch((error) => {ctx.reply(error.code)})
})

//listFolder
bot.command('ls',(ctx) => {
	let Path = ctx.state.command.args
	fileManager.listDeep(`./file_save/${Path}`)
		.then((entries) => {
			ctx.reply(entries)
		})
		.catch((error) => {ctx.reply(error.code)})
})

//uploadVideo
bot.command('uploadVideo',(ctx) => { 
	let Video = ctx.state.command.args
	ctx.telegram.sendDocument({
		source: `/home/telegram_torrent/file_save/${Video}`
	})
	.catch((error) => {ctx.reply('failed:reason maybe files too large(less than 50mb)')})
})

//removeFolder
bot.command('rmdir',(ctx) => {
	let dir = ctx.state.command.args
	fileManager.removeDir(`./file_save/${dir}`)
		.then((path) => {ctx.reply('remove folder successful')})
		.catch((error) => {ctx.reply('remove folder failed')})
})

//removeFiles
bot.command('rmfile',(ctx) => {
	let filename = ctx.state.command.args
	fileManager.removeFile(`./file_save/${filename}`)
		.then((path) => {ctx.reply('remove file successful')})
		.catch((error) => {ctx.reply('remove file failed')})
})

//rename
bot.command('rename',(ctx) => {
	file_name = ctx.state.command.args
	ctx.reply('input new name')
	bot.command('newname',(ctx) =>{
		let newname = ctx.state.command.args
		fileManager.rename(`./file_save/${file_name}`,`./file_save/${newname}`)
			.then((newPath) => {ctx.reply('rename successful')})
			.catch((error) => {ctx.reply('rename failed')})
	})
})

//restart

const serve = new (forever.Monitor)('./serve.js',{
	slient : true ,
	uid: '54123',
	max: 1
})

function online(){
	return new Promise(
		function(resolve,reject){
			serve.start(function(err,result){
				if(err){
					reject(err)
				}
				resolve('successful')
			})
		}
	)
}

function offline(){
	return new Promise(
		function(resolve,reject){
			serve.stop(function(err,result){
				if(err){
					reject(err)
				}
				resolve('successful')
			})
		}
	)
}



bot.command('serve',(ctx) => {
	try{
		online()
		ctx.reply('serve online')
	}catch(error){
		console.log(error)
	}			
})

bot.command('stop',(ctx) => {	
	try{
		offline()
		ctx.reply('serve offline')
	}catch(error){
		console.log(error)
	}
})

bot.startPolling()