cloudfunctions/SegmentPortraitPic/node_modules/@cloudbase/database/src/realtime/websocket-client.ts

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

import { VirtualWebSocketClient } from './virtual-websocket-client'
import { sleep } from '../utils/utils'
import { genRequestId } from './message'
import {
  IDatabaseServiceContext,
  IWatchOptions,
  DBRealtimeListener
} from '../typings/index'
import {
  IRequestMessage,
  IResponseMessage,
  IRequestMessagePingMsg,
  IRequestMessageLoginMsg,
  IResponseMessageLoginResMsg,
  IRequestMessageLoginData
} from '../typings/realtime'
import {
  CLOSE_EVENT_CODE,
  CLOSE_EVENT_CODE_INFO,
  getWSCloseError
} from './ws-event'
import { CloudSDKError, TimeoutError } from '../utils/error'
// import { CloudSDKError } from "./utils/error"
import { RealtimeErrorMessageError } from './error'
import { ERR_CODE } from '../config/error.config'
import { Db } from '../';

// =============== Realtime WebSocket Client (Internal) ====================

export interface IRealtimeWebSocketClientConstructorOptions {
  maxReconnect?: number
  reconnectInterval?: number
  context: IDatabaseServiceContext
}

export interface ISignature {
  envId: string
  secretVersion: number
  signStr: string
  wsUrl: string
  expireTS: number
}

export interface ILoginInfo {
  loggedIn: boolean
  loggingInPromise?: Promise<ILoginResult>
  loginStartTS?: number
  loginResult?: ILoginResult
}

export interface ILoginResult {
  envId: string
}

export interface IWSSendOptions {
  msg: IRequestMessage
  waitResponse?: boolean
  // when waitResponse is set to true, if skipOnMessage is true, general onMessage handler will be skipped
  skipOnMessage?: boolean
  timeout?: number