tpbproxy/app.js
2020-02-16 13:05:52 -05:00

70 lines
1.9 KiB
JavaScript

const zlib = require('zlib');
const fs = require('fs');
const express = require('express');
const proxy = require('http-proxy-middleware');
const app = express();
app.use(express.json());
const port = process.env.NODE_PORT || '3000';
const inject = fs.readFileSync('./inject.html', 'utf8');
const Transmission = require('transmission-promise')
var tr_client = new Transmission({
host:'192.168.1.176',
username: 'william',
password: 'palm7',
})
app.post("/__api/torrent", async function(req, res, next){
if(req.body.password !== '4412'){
return res.status(421);
}
try{
let cres = await tr_client.addUrl(Buffer.from(req.body.magnet, 'base64').toString('binary'));
res.json(cres)
}catch(e){
console.error('error', e)
res.status(500).json({message: e})
}
});
app.all("/*.js", function(req, res){res.send('')});
app.all("/*", proxy({
target: 'http://piratebayztemzmv.onion',
autoRewrite: true,
selfHandleResponse: true, // so that the onProxyRes takes care of sending the response
onProxyRes: function(proxyRes, req, res){
for(let key of Object.keys(proxyRes.headers)){
if(['content-encoding'].includes(key)) continue;
res.set(key, proxyRes.headers[key].toString().replace('http://', 'https://'))
}
let body = new Buffer('');
proxyRes.on('data', function(data){
body = Buffer.concat([body, data]);
});
proxyRes.on('end', function(){
body = proxyRes.headers['content-encoding'] === 'gzip' ? zlib.gunzipSync(body).toString('utf8') : body;
if(proxyRes.headers['content-type'] && proxyRes.headers['content-type'].match('html')){
body = body.toString().replace(/<\s*script[^]*?script>/igm, '');
body = body.replace(/<\s*iframe[^]*?iframe>/igm, '');
body = body.replace("</html>", '');
body = body+inject+"</html>";
}
res.status(proxyRes.statusCode).end(body);
});
}
}));
app.listen(port, () => console.log(`The Pirate Bay TOR proxy listening on ${port}!`))