1 import { readFile } from 'fs-extra'
2 import parseTorrent from 'parse-torrent'
3 import { basename, join } from 'path'
4 import * as WebTorrent from 'webtorrent'
5 import { VideoFile } from '@shared/models'
6 import { PeerTubeServer } from '../server'
8 let webtorrent: WebTorrent.Instance
10 function webtorrentAdd (torrentId: string, refreshWebTorrent = false) {
11 const WebTorrent = require('webtorrent')
13 if (webtorrent && refreshWebTorrent) webtorrent.destroy()
14 if (!webtorrent || refreshWebTorrent) webtorrent = new WebTorrent()
16 webtorrent.on('error', err => console.error('Error in webtorrent', err))
18 return new Promise<WebTorrent.Torrent>(res => {
19 const torrent = webtorrent.add(torrentId, res)
21 torrent.on('error', err => console.error('Error in webtorrent torrent', err))
22 torrent.on('warning', warn => {
23 const msg = typeof warn === 'string'
27 if (msg.includes('Unsupported')) return
29 console.error('Warning in webtorrent torrent', warn)
34 async function parseTorrentVideo (server: PeerTubeServer, file: VideoFile) {
35 const torrentName = basename(file.torrentUrl)
36 const torrentPath = server.servers.buildDirectory(join('torrents', torrentName))
38 const data = await readFile(torrentPath)
40 return parseTorrent(data)