refactor: less obscure transport names
This commit is contained in:
parent
c8c0b4a320
commit
6d8c7fee78
6 changed files with 16 additions and 16 deletions
|
@ -12,8 +12,8 @@ export * from './obfuscated'
|
||||||
export let defaultTransportFactory: TransportFactory
|
export let defaultTransportFactory: TransportFactory
|
||||||
if (typeof process !== 'undefined') {
|
if (typeof process !== 'undefined') {
|
||||||
// we are in node, use tcp transport by default
|
// we are in node, use tcp transport by default
|
||||||
const { TcpIntermediateTransport } = require('./tcp')
|
const { TcpTransport } = require('./tcp')
|
||||||
defaultTransportFactory = () => new TcpIntermediateTransport()
|
defaultTransportFactory = () => new TcpTransport()
|
||||||
} else {
|
} else {
|
||||||
// we are in browser (probably), use websocket
|
// we are in browser (probably), use websocket
|
||||||
// if no websocket, throw an error i guess ¯\_(ツ)_/¯
|
// if no websocket, throw an error i guess ¯\_(ツ)_/¯
|
||||||
|
@ -25,7 +25,7 @@ if (typeof process !== 'undefined') {
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
const { WebSocketIntermediateTransport } = require('./websocket')
|
const { WebSocketTransport } = require('./websocket')
|
||||||
defaultTransportFactory = () => new WebSocketIntermediateTransport()
|
defaultTransportFactory = () => new WebSocketTransport()
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -11,7 +11,7 @@ const debug = require('debug')('mtcute:tcp')
|
||||||
* Base for TCP transports.
|
* Base for TCP transports.
|
||||||
* Subclasses must provide packet codec in `_packetCodec` property
|
* Subclasses must provide packet codec in `_packetCodec` property
|
||||||
*/
|
*/
|
||||||
export abstract class TcpTransport
|
export abstract class BaseTcpTransport
|
||||||
extends EventEmitter
|
extends EventEmitter
|
||||||
implements ICuteTransport {
|
implements ICuteTransport {
|
||||||
protected _currentDc: tl.RawDcOption | null = null
|
protected _currentDc: tl.RawDcOption | null = null
|
||||||
|
@ -109,6 +109,6 @@ export abstract class TcpTransport
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
export class TcpIntermediateTransport extends TcpTransport {
|
export class TcpTransport extends BaseTcpTransport {
|
||||||
_packetCodec = new IntermediatePacketCodec()
|
_packetCodec = new IntermediatePacketCodec()
|
||||||
}
|
}
|
||||||
|
|
|
@ -34,7 +34,7 @@ const subdomainsMap: Record<string, string> = {
|
||||||
* Base for WebSocket transports.
|
* Base for WebSocket transports.
|
||||||
* Subclasses must provide packet codec in `_packetCodec` property
|
* Subclasses must provide packet codec in `_packetCodec` property
|
||||||
*/
|
*/
|
||||||
export abstract class WebSocketTransport
|
export abstract class BaseWebSocketTransport
|
||||||
extends EventEmitter
|
extends EventEmitter
|
||||||
implements ICuteTransport {
|
implements ICuteTransport {
|
||||||
private _currentDc: tl.RawDcOption | null = null
|
private _currentDc: tl.RawDcOption | null = null
|
||||||
|
@ -150,6 +150,6 @@ export abstract class WebSocketTransport
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
export class WebSocketIntermediateTransport extends WebSocketTransport {
|
export class WebSocketTransport extends BaseWebSocketTransport {
|
||||||
_packetCodec = new ObfuscatedPacketCodec(new IntermediatePacketCodec())
|
_packetCodec = new ObfuscatedPacketCodec(new IntermediatePacketCodec())
|
||||||
}
|
}
|
||||||
|
|
|
@ -1,6 +1,6 @@
|
||||||
import {
|
import {
|
||||||
IntermediatePacketCodec,
|
IntermediatePacketCodec,
|
||||||
TcpTransport,
|
BaseTcpTransport,
|
||||||
TransportState,
|
TransportState,
|
||||||
} from '@mtcute/core'
|
} from '@mtcute/core'
|
||||||
import { tl } from '@mtcute/tl'
|
import { tl } from '@mtcute/tl'
|
||||||
|
@ -66,7 +66,7 @@ export interface HttpProxySettings {
|
||||||
/**
|
/**
|
||||||
* TCP transport that connects via an HTTP(S) proxy.
|
* TCP transport that connects via an HTTP(S) proxy.
|
||||||
*/
|
*/
|
||||||
export abstract class HttpProxiedTcpTransport extends TcpTransport {
|
export abstract class BaseHttpProxyTcpTransport extends BaseTcpTransport {
|
||||||
readonly _proxy: HttpProxySettings
|
readonly _proxy: HttpProxySettings
|
||||||
|
|
||||||
constructor(proxy: HttpProxySettings) {
|
constructor(proxy: HttpProxySettings) {
|
||||||
|
@ -173,6 +173,6 @@ export abstract class HttpProxiedTcpTransport extends TcpTransport {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
export class HttpProxiedIntermediateTcpTransport extends HttpProxiedTcpTransport {
|
export class HttpProxyTcpTransport extends BaseHttpProxyTcpTransport {
|
||||||
_packetCodec = new IntermediatePacketCodec()
|
_packetCodec = new IntermediatePacketCodec()
|
||||||
}
|
}
|
||||||
|
|
|
@ -4,7 +4,7 @@ import {
|
||||||
IPacketCodec,
|
IPacketCodec,
|
||||||
PaddedIntermediatePacketCodec,
|
PaddedIntermediatePacketCodec,
|
||||||
parseUrlSafeBase64,
|
parseUrlSafeBase64,
|
||||||
TcpTransport,
|
BaseTcpTransport,
|
||||||
TransportState,
|
TransportState,
|
||||||
} from '@mtcute/core'
|
} from '@mtcute/core'
|
||||||
import { tl } from '@mtcute/tl'
|
import { tl } from '@mtcute/tl'
|
||||||
|
@ -37,7 +37,7 @@ const TLS_START = [
|
||||||
/**
|
/**
|
||||||
* TCP transport that connects via an MTProxy
|
* TCP transport that connects via an MTProxy
|
||||||
*/
|
*/
|
||||||
export class MtProxyTcpTransport extends TcpTransport {
|
export class MtProxyTcpTransport extends BaseTcpTransport {
|
||||||
readonly _proxy: MtProxySettings
|
readonly _proxy: MtProxySettings
|
||||||
|
|
||||||
private _rawSecret: Buffer
|
private _rawSecret: Buffer
|
||||||
|
|
|
@ -1,6 +1,6 @@
|
||||||
import {
|
import {
|
||||||
IntermediatePacketCodec,
|
IntermediatePacketCodec,
|
||||||
TcpTransport,
|
BaseTcpTransport,
|
||||||
TransportState,
|
TransportState,
|
||||||
} from '@mtcute/core'
|
} from '@mtcute/core'
|
||||||
import { tl } from '@mtcute/tl'
|
import { tl } from '@mtcute/tl'
|
||||||
|
@ -178,7 +178,7 @@ const SOCKS5_ERRORS: Record<number, string> = {
|
||||||
/**
|
/**
|
||||||
* TCP transport that connects via a SOCKS4/5 proxy.
|
* TCP transport that connects via a SOCKS4/5 proxy.
|
||||||
*/
|
*/
|
||||||
export abstract class SocksProxiedTcpTransport extends TcpTransport {
|
export abstract class BaseSocksTcpTransport extends BaseTcpTransport {
|
||||||
readonly _proxy: SocksProxySettings
|
readonly _proxy: SocksProxySettings
|
||||||
|
|
||||||
constructor(proxy: SocksProxySettings) {
|
constructor(proxy: SocksProxySettings) {
|
||||||
|
@ -472,6 +472,6 @@ export abstract class SocksProxiedTcpTransport extends TcpTransport {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
export class SocksProxiedIntermediateTcpTransport extends SocksProxiedTcpTransport {
|
export class SocksTcpTransport extends BaseSocksTcpTransport {
|
||||||
_packetCodec = new IntermediatePacketCodec()
|
_packetCodec = new IntermediatePacketCodec()
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue