@pureproxy/utils
v2.1.0
Published
PureProxy utilities
Downloads
4
Maintainers
Readme
Utils
Collection of utills for PureProxy.
How To Install
You need to install this library as a dependency like this:
$ npm install @pureproxy/utils
How To Use
Here is a practical example how to intercept requests and responses:
const MitmProxy = require('@pureproxy/mitmproxy')
const Interceptor = require('@pureproxy/utils/lib/interceptor')
const { HTTPParser, methods } = process.binding('http_parser')
const kOnHeadersComplete = HTTPParser.kOnHeadersComplete | 0
const kOnBody = HTTPParser.kOnBody | 0
const kOnMessageComplete = HTTPParser.kOnMessageComplete | 0
const server = new class extends MitmProxy {
makeRequestParser() {
const requestParser = new HTTPParser(HTTPParser.REQUEST)
requestParser[kOnHeadersComplete] = (...args) => {
console.log('>>>', ...args)
}
requestParser[kOnBody] = (buffer, start, len) => {
buffer = buffer.slice(start, start + len)
console.log('>>>', buffer.toString())
}
requestParser[kOnMessageComplete] = () => {
console.log('>>> ~')
}
return requestParser
}
makeResponseParser() {
const responseParser = new HTTPParser(HTTPParser.RESPONSE)
responseParser[kOnHeadersComplete] = (...args) => {
console.log('<<<', ...args)
}
responseParser[kOnBody] = (buffer, start, len) => {
buffer = buffer.slice(start, start + len)
console.log('<<<', buffer.toString())
}
responseParser[kOnMessageComplete] = () => {
console.log('<<< ~')
}
return responseParser
}
wrapClientForObservableStreaming(client, { hostname, port, context }) {
const requestParser = this.makeRequestParser()
const responseParser = this.makeResponseParser()
return new class extends Interceptor {
constructor() {
super(client)
this.writeFore = this._writeFore
this.writeBack = this._writeBack
this.writeFore = this._sniffIt
}
_sniffIt(data) {
this.writeFore = this._writeFore
this.writeFore(data)
}
_writeFore(data) {
requestParser.execute(data)
super.writeFore(data)
}
_writeBack(data) {
responseParser.execute(data)
super.writeBack(data)
}
}
}
shouldIntercept(hostname, port, context) {
return true
}
}
server.listen(8080)