PeerTube/shared/extra-utils/miscs/webtorrent.ts

47 lines
1.3 KiB
TypeScript
Raw Normal View History

2021-07-15 03:02:54 -05:00
import { readFile } from 'fs-extra'
2021-08-27 07:32:44 -05:00
import parseTorrent from 'parse-torrent'
2021-07-23 04:20:00 -05:00
import { basename, join } from 'path'
2021-07-13 02:43:59 -05:00
import * as WebTorrent from 'webtorrent'
2021-07-23 04:20:00 -05:00
import { VideoFile } from '@shared/models'
2021-07-16 02:47:51 -05:00
import { PeerTubeServer } from '../server'
2021-07-13 02:43:59 -05:00
let webtorrent: WebTorrent.Instance
2021-09-02 02:53:27 -05:00
function webtorrentAdd (torrentId: string, refreshWebTorrent = false) {
2021-07-13 02:43:59 -05:00
const WebTorrent = require('webtorrent')
if (!webtorrent) webtorrent = new WebTorrent()
if (refreshWebTorrent === true) webtorrent = new WebTorrent()
2021-09-02 02:53:27 -05:00
webtorrent.on('error', err => console.error('Error in webtorrent', err))
return new Promise<WebTorrent.Torrent>(res => {
const torrent = webtorrent.add(torrentId, res)
torrent.on('error', err => console.error('Error in webtorrent torrent', err))
torrent.on('warning', warn => {
const msg = typeof warn === 'string'
? warn
: warn.message
if (msg.includes('Unsupported')) return
console.error('Warning in webtorrent torrent', warn)
})
})
2021-07-13 02:43:59 -05:00
}
2021-07-23 04:20:00 -05:00
async function parseTorrentVideo (server: PeerTubeServer, file: VideoFile) {
const torrentName = basename(file.torrentUrl)
2021-07-16 02:04:35 -05:00
const torrentPath = server.servers.buildDirectory(join('torrents', torrentName))
2021-07-15 03:02:54 -05:00
const data = await readFile(torrentPath)
return parseTorrent(data)
}
2021-07-13 02:43:59 -05:00
export {
2021-07-15 03:02:54 -05:00
webtorrentAdd,
parseTorrentVideo
2021-07-13 02:43:59 -05:00
}