|
| 1 | +/// <reference types="node" /> |
| 2 | +/// <reference types="node" /> |
| 3 | +/// <reference types="node" /> |
| 4 | +/// <reference types="node" /> |
| 5 | +import * as net from "net"; |
| 6 | +import * as tls from "tls"; |
| 7 | +type SocketUnion = net.Socket | tls.TLSSocket; |
| 8 | +import { EventEmitter } from "events"; |
| 9 | +import * as util from "./util"; |
| 10 | +import { Transport } from "./util"; |
| 11 | +import * as transform from "sdp-transform"; |
| 12 | +declare enum ReadStates { |
| 13 | + SEARCHING = 0, |
| 14 | + READING_RTSP_HEADER = 1, |
| 15 | + READING_RTSP_PAYLOAD = 2, |
| 16 | + READING_RAW_PACKET_SIZE = 3, |
| 17 | + READING_RAW_PACKET = 4 |
| 18 | +} |
| 19 | +type Connection = "udp" | "tcp"; |
| 20 | +type AuthOptions = { |
| 21 | + type: "Digest" | "Basic"; |
| 22 | + realm?: string; |
| 23 | + nonce?: string; |
| 24 | + qop?: string; |
| 25 | + algorithm?: "MD5" | "SHA-256"; |
| 26 | +}; |
| 27 | +type Headers = { |
| 28 | + [key: string]: string | number | undefined; |
| 29 | + Session?: string; |
| 30 | + Location?: string; |
| 31 | + CSeq?: number; |
| 32 | + "WWW-Authenticate"?: string; |
| 33 | + Transport?: string; |
| 34 | + Unsupported?: string; |
| 35 | +}; |
| 36 | +type Detail = { |
| 37 | + codec: string; |
| 38 | + mediaSource: ({ |
| 39 | + type: string; |
| 40 | + port: number; |
| 41 | + protocol: string; |
| 42 | + payloads?: string | undefined; |
| 43 | + } & transform.MediaDescription); |
| 44 | + transport: Transport['parameters']; |
| 45 | + isH264: boolean; |
| 46 | + rtpChannel: number; |
| 47 | + rtcpChannel: number; |
| 48 | + sr_ntpMSW?: number; |
| 49 | + sr_ntpLSW?: number; |
| 50 | + sr_rtptimestamp?: number; |
| 51 | +}; |
| 52 | +export default class RTSPClient extends EventEmitter { |
| 53 | + username: string; |
| 54 | + password: string; |
| 55 | + headers: { |
| 56 | + [key: string]: string; |
| 57 | + }; |
| 58 | + isConnected: boolean; |
| 59 | + closed: boolean; |
| 60 | + _url?: string; |
| 61 | + _client?: SocketUnion; |
| 62 | + _cSeq: number; |
| 63 | + _unsupportedExtensions?: string[]; |
| 64 | + _authOpions?: AuthOptions; |
| 65 | + _session?: string; |
| 66 | + _keepAliveID?: NodeJS.Timeout; |
| 67 | + _nextFreeInterleavedChannel: number; |
| 68 | + _nextFreeUDPPort: number; |
| 69 | + readState: ReadStates; |
| 70 | + messageBytes: number[]; |
| 71 | + rtspContentLength: number; |
| 72 | + rtspStatusLine: string; |
| 73 | + rtspHeaders: Headers; |
| 74 | + rtspPacketLength: number; |
| 75 | + rtspPacket: Buffer; |
| 76 | + rtspPacketPointer: number; |
| 77 | + clientSSRC: number; |
| 78 | + tcpSocket: SocketUnion; |
| 79 | + setupResult: Array<Detail>; |
| 80 | + constructor(username: string, password: string, headers?: { |
| 81 | + [key: string]: string; |
| 82 | + }); |
| 83 | + _netConnect(hostname: string, port: number, secure?: boolean): Promise<this>; |
| 84 | + connect(url: string, { keepAlive, connection, secure, }?: { |
| 85 | + keepAlive: boolean; |
| 86 | + connection?: Connection; |
| 87 | + secure: boolean; |
| 88 | + }): Promise<Detail[]>; |
| 89 | + request(requestName: string, headersParam?: Headers, url?: string): Promise<{ |
| 90 | + headers: Headers; |
| 91 | + mediaHeaders?: string[]; |
| 92 | + } | void>; |
| 93 | + respond(status: string, headersParam?: Headers): void; |
| 94 | + play(): Promise<void>; |
| 95 | + pause(): Promise<void>; |
| 96 | + sendAudioBackChannel(audioChunk: Buffer): Promise<void>; |
| 97 | + close(isImmediate?: boolean): Promise<void>; |
| 98 | + _onData(data: Buffer): void; |
| 99 | + _sendInterleavedData(channel: number, buffer: Buffer): void; |
| 100 | + _sendUDPData(host: string, port: number, buffer: Buffer): void; |
| 101 | + _emptyReceiverReport(): Buffer; |
| 102 | + _socketWrite(socket: SocketUnion, data: Buffer): Promise<any>; |
| 103 | + private _generateAuthString; |
| 104 | + ntpBaseDate_ms: number; |
| 105 | + GetWallClockTime(packet: util.RTPPacket, detail: Detail): Date | undefined; |
| 106 | +} |
| 107 | +export { RTPPacket, RTCPPacket } from "./util"; |
0 commit comments