miniprogram-zego - npm Package Compare versions

Comparing version 1.4.0 to 1.5.0

package.json

 {
   "name": "miniprogram-zego",
-  "version": "1.4.0",
+  "version": "1.5.0",
   "description": "zego miniprogram sdk",
@@ -5,0 +5,0 @@ "main": "./jZego-wx.js",

readme.md

@@ -0,1 +1,2 @@
+
  
@@ -5,2 +6,5 @@ ### 日志更新
 
+### 2020-08-27(version 1.5.0)
+ 1. 优化小程序拉流推流日志上报
+
 ### 2019-12-09(version 1.4.0)
@@ -7,0 +11,0 @@ 1. 优化中途断网处理

sdk/common/clientBase/heartBeatHandler.d.ts

@@ -21,2 +21,3 @@ import { SocketCenter } from './socketCenter';
     private fetchStreamList;
+    private patchUserList;
     handleFetchStreamListRsp(msg: any): void;
@@ -23,0 +24,0 @@ fetchUserList(): void;

sdk/common/clientBase/index.d.ts

@@ -1,3 +0,3 @@
-import { Common } from "./common";
-import { ChatInfo, Config, ERRO, MessageInfo, StreamInfo, StreamQuality, UserInfo, CdnPushConfig } from "../zego.entity";
+import { Common } from './common';
+import { ChatInfo, Config, ERRO, MessageInfo, StreamInfo, StreamQuality, UserInfo, CdnPushConfig } from '../zego.entity';
 export declare abstract class BaseCenter extends Common {
@@ -58,5 +58,25 @@ constructor();
     onVideoSizeChanged(streamId: string, videoWidth: number, videoHeight: number): void;
+    onRemoteCameraStatusUpdate(streamID: string, status: number): void;
+    onRemoteMicStatusUpdate(streamID: string, status: number): void;
     onPlayQualityUpdate(streamId: string, streamQuality: StreamQuality): void;
     onPublishStateUpdate(type: number, streamid: string, error: ERRO | number): void;
     onPublishQualityUpdate(streamId: string, streamQuality: StreamQuality): void;
+    onSoundLevelUpdate(soundLevelList: Array<{
+        streamID: string;
+        soundLevel: number;
+    }>): void;
+    onDeviceError(msg: {
+        deviceName: string;
+        deviceType: string;
+        errorCode: number;
+    }): void;
+    OnAudioDeviceStateChanged(msg: {
+        deviceType: string;
+        deviceInfo: any;
+        state: string;
+    }): void;
+    OnVideoDeviceStateChanged(msg: {
+        deviceInfo: any;
+        state: string;
+    }): void;
     /********
@@ -63,0 +83,0 @@ *

sdk/common/clientBase/roomHandler.d.ts

@@ -1,5 +0,5 @@
-import { ENUM_RUN_STATE, ERRO, StreamInfo, UserInfo } from "../zego.entity";
-import { SocketCenter } from "./socketCenter";
-import { StateCenter } from "./stateCenter";
-import { Logger } from "../zego.logger";
+import { ENUM_RUN_STATE, ERRO, StreamInfo, UserInfo } from '../zego.entity';
+import { SocketCenter } from './socketCenter';
+import { StateCenter } from './stateCenter';
+import { Logger } from '../zego.logger';
 export declare class RoomHandler {
@@ -36,2 +36,4 @@ private socketCenter;
     onUserStateUpdate(roomId: string, userList: UserInfo[]): void;
+    private mergeUserByUserSeq;
+    private mergeUser;
 }

sdk/common/clientBase/stateCenter.d.ts

@@ -14,2 +14,3 @@ import { ENUM_RUN_STATE, LinkedList } from "../zego.entity";
     server: string;
+    serverBak: string;
     idName: string;
@@ -31,2 +32,8 @@ nickName: string;
     userSeq: number;
+    userSeqMergeMap: any;
+    userSeqMergeTimer: any;
+    userQueryTimer: any;
+    lastUserQueryTime: number;
+    userListInterval: number;
+    userListMergeInterval: number;
     anchor_info: {
@@ -37,2 +44,5 @@ anchor_id: string;
     };
+    deviceInfos: any;
+    deviceChangeTimer: any;
+    deviceStateOut: boolean;
     sendCommandMap: {};
@@ -46,3 +56,3 @@ sendCommandList: LinkedList;
     cmdCallback: {};
-    customUrl: string;
+    customUrl: Array<string>;
     transSeqMap: {};
@@ -59,3 +69,6 @@ realyMessageList: any[];
     bigImMessageList: any[];
-    screenShotStream: MediaStream;
+    screenShotStreamList: {
+        stream: MediaStream;
+        type: number;
+    }[];
     tryLoginCount: number;
@@ -62,0 +75,0 @@ tryLoginTimer: any;

sdk/common/zego.entity.d.ts

@@ -1,4 +0,5 @@
-import { ZegoSignal } from "./zego.signal";
-import { ZegoPlayWeb } from "../webrtc/zego.play.web";
+import { ZegoSignal } from './zego.signal';
+import { ZegoPlayWeb } from '../webrtc/zego.play.web';
 import { ZegoVideoDecodeType } from '../../types/index';
+import { ZegoPublish } from '../webrtc/zego.publish';
 export declare const PROTO_VERSION: any;
@@ -21,3 +22,3 @@ export declare const ROOMVERSION: any;
     appid: number;
-    server: string;
+    server: string | string[];
     idName: string;
@@ -30,2 +31,10 @@ nickName: string;
 }
+export interface Device {
+    deviceName: string;
+    deviceID: string;
+}
+export interface DeviceStates {
+    camera: number;
+    microphone: number;
+}
 export interface UsabilityDedection {
@@ -247,2 +256,10 @@ webRtc: boolean;
 };
+export declare const ENUM_PUBLISH_STATE_NEGO: {
+    stop: number;
+    start: number;
+    waiterAnswer: number;
+    waitingCandidate: number;
+    sendCandidate: number;
+    iceConnected: number;
+};
 export declare const ENUM_PLAY_STATE: {
@@ -259,2 +276,10 @@ start: number;
 };
+export declare const ENUM_PLAY_STATE_NEGO: {
+    stop: number;
+    start: number;
+    waiterAnswer: number;
+    waitingCandidate: number;
+    sendCandidate: number;
+    iceConnected: number;
+};
 export interface VideoInfo {
@@ -264,3 +289,4 @@ width: number;
     frameRate: number;
-    bitRate: number;
+    minBitRate: number;
+    maxBitRate: number;
 }
@@ -272,3 +298,3 @@ export declare const ENUM_CONNECT_STATE: {
 };
-export declare const MAX_TRY_CONNECT_COUNT = 3;
+export declare const MAX_TRY_CONNECT_COUNT = 1;
 export declare const SEND_MSG_RESET = 2;
@@ -350,5 +376,17 @@ export declare const SEND_MSG_TIMEOUT = 1;
     tokenInfo: any;
+    isTimeOut: boolean;
 }
+export interface PublishInfo {
+    localVideo: HTMLMediaElement;
+    publisher: ZegoPublish;
+    serverUrls: string[];
+    retryCount: number;
+    streamId: string;
+    playOption: PlayOption;
+    tryCountConnect: number;
+    countConnectTimer: any;
+}
 export interface PlayerInfo {
     player: ZegoPlayWeb;
+    streamId: string;
     remoteVideo: HTMLElement;
@@ -360,2 +398,4 @@ audioOutput: string;
     playOption: PlayOption;
+    tryCountConnect: number;
+    countConnectTimer: any;
 }
@@ -380,3 +420,8 @@ export declare enum QUALITYLEVEL {
     width?: number;
-    bitRate?: number;
+    bitRate?: number | {
+        minBitRate: number;
+        maxBitRate: number;
+    };
+    minBitRate?: number;
+    maxBitRate?: number;
     audioBitRate?: number;
@@ -406,2 +451,20 @@ externalMediaStream?: MediaStream;
 };
+export interface ChargeInfo {
+    is_publishing: number;
+    play_stream_resolution_infos: Array<ResolutionInfo>;
+    play_max_audio_bitrate: number;
+}
+export interface ResolutionInfo {
+    video_width: number;
+    video_height: number;
+    count: number;
+}
+export interface ChargeInfos {
+    itemtype: 'ChargeInfos';
+    timestamp_begin: number;
+    timestamp_end: number;
+    timestamp_diff_flag: number;
+    timestamp_diff: number;
+    infos: Array<ChargeInfo>;
+}
 export interface ChatInfo {
@@ -422,3 +485,3 @@ id_name: string;
     role: 1 | 2;
-    logintime: string;
+    loginTime: string;
 }
@@ -451,2 +514,6 @@ export interface MessageInfo {
 }
+export declare enum ENUM_BROADCASTER_STATUS {
+    stop = 0,
+    start = 1
+}
 export declare enum ENUM_DISPATCH_TYPE {
@@ -453,0 +520,0 @@ cdn = 0,

sdk/common/zego.extern.d.ts

@@ -54,2 +54,6 @@ export declare let playErrorList: {
     };
+    SERVER_NEGO_TIMEOUT: {
+        code: string;
+        msg: string;
+    };
     SERVER_CANDIDATE_TIMEOUT: {
@@ -133,2 +137,6 @@ code: string;
     };
+    SERVER_NEGO_TIMEOUT: {
+        code: string;
+        msg: string;
+    };
     SERVER_CANDIDATE_ERROR: {
@@ -150,2 +158,6 @@ code: string;
     };
+    MEDIA_CONNECTION_DISCONNECTED: {
+        code: string;
+        msg: string;
+    };
     WEBSOCKET_ERROR: {
@@ -152,0 +164,0 @@ code: string;

sdk/common/zego.signal.d.ts

@@ -1,4 +0,4 @@
-import { LinkedList } from "./zego.entity";
-import { Logger } from "./zego.logger";
-import { StateCenter } from "./clientBase/stateCenter";
+import { LinkedList } from './zego.entity';
+import { Logger } from './zego.logger';
+import { StateCenter } from './clientBase/stateCenter';
 export declare class ZegoSignal {
@@ -33,2 +33,5 @@ logger: Logger;
     websocket: WebSocket;
+    negoInterval: number;
+    negoTryCount: number;
+    negoTryMaxCount: number;
     globalHeader: {
@@ -35,0 +38,0 @@ [indes: string]: number | string;

sdk/common/ZegoStreamCenter.d.ts

 import { Logger } from "./zego.logger";
-import { ERRO, PlayerInfo, StreamQuality } from "./zego.entity";
+import { ERRO, PlayerInfo, StreamQuality, PublishInfo } from "./zego.entity";
 import { StateCenter } from "./clientBase/stateCenter";
@@ -8,3 +8,5 @@ export declare abstract class ZegoStreamCenter {
     };
-    publisherList: {};
+    publisherList: {
+        [index: string]: PublishInfo;
+    };
     constructor(log: Logger, stateCenter: StateCenter);
@@ -21,3 +23,23 @@ abstract stopPlayingStream(streamId: string): any;
     abstract onVideoSizeChanged(streamId: string, videoWidth: number, videoHeight: number): any;
+    abstract onRemoteCameraStatusUpdate(streamID: string, status: number): any;
+    abstract onRemoteMicStatusUpdate(streamID: string, status: number): any;
+    abstract onSoundLevelUpdate(soundLevelList: Array<{
+        streamID: string;
+        soundLevel: number;
+    }>): any;
+    abstract onDeviceError(msg: {
+        deviceName: string;
+        deviceType: string;
+        errorCode: number;
+    }): any;
+    abstract OnAudioDeviceStateChanged(msg: {
+        deviceType: string;
+        deviceInfo: any;
+        state: string;
+    }): any;
+    abstract OnVideoDeviceStateChanged(msg: {
+        deviceInfo: any;
+        state: string;
+    }): any;
     setSessionInfo(appid: number, userid: string, token: string, testEnvironment: boolean): void;
 }

sdk/util/audioMixUtil.d.ts

@@ -9,2 +9,3 @@ import { ZegoAudioContext } from '../../types/index';
     audioBuffer: AudioBuffer;
+    audioBufferList: Array<AudioBuffer>;
     loop: boolean;
@@ -20,2 +21,3 @@ replace: boolean;
     isMixAudio: boolean;
+    isMixingBuffer: boolean;
     private streamSource;
@@ -26,5 +28,8 @@ private gainNode;
     private micTrack;
-    constructor(log: LoggerWeb);
+    constructor(log: LoggerWeb, ac: ZegoAudioContext);
     preloadEffect(effectUrl: string, callBack: Function): void;
     playEffect(playTime?: number, loop?: boolean, replace?: boolean, start?: Function, end?: Function): void;
+    mixingBuffer(ab: ArrayBuffer, callBack?: Function): void;
+    stopMingBuffer(): boolean;
+    playRealTimeEffect(ab: AudioBuffer): void;
     pauseEffect(): void;
@@ -31,0 +36,0 @@ resumeEffect(): void;

sdk/util/client-util.d.ts

@@ -1,6 +0,7 @@
-import { Config } from "../common/zego.entity";
-import { Logger } from "../common/zego.logger";
+import { Config, MediaStreamConstraints, ERRO } from '../common/zego.entity';
+import { Logger } from '../common/zego.logger';
 export declare class ClientUtil {
     static checkConfigParam(option: Config, logger: Logger): boolean;
     static checkLoginParam(roomid: string, token: string): boolean;
+    static checkPreviewParam(mediaStreamConstraints: MediaStreamConstraints, logger: Logger): boolean;
     static registerCallback(fName: any, option: {
@@ -18,2 +19,3 @@ success?: Function;
     }): Function;
+    static getDevices(deviceInfoCallback: Function, error: (err: ERRO) => void): void;
     /**
@@ -34,9 +36,8 @@ 错误管理
     static uuid(len?: number, radix?: number): string;
-    static isSupportWebrtc(): boolean;
-    static isSupportH264(sucCall: any, errCall: any): void;
     static supportDetection(screenShotReady: boolean, success: Function, error: Function): void;
     static compareVersion(v1: any, v2: any): 1 | 0 | -1;
     static isSupportLive(sucCall: any, errCall: any): void;
+    static isSupportQQLive(sucCall: any, errCall: any): void;
     static supportVideoCodeType(sucCall: any, errCall: any): void;
     static inlineWorker(func: Function): Worker;
 }

sdk/webrtc/zego.client.web.d.ts

 /// <reference path="../../types/global.d.ts" />
-import { E_CLIENT_TYPE, MediaStreamConstraints, PlayOption, audioMixConfig } from "../common/zego.entity";
-import { ZegoStreamCenterWeb } from "./zego.streamCenter.web";
-import { audioMixUtil } from "../util/audioMixUtil";
-import { BaseCenter } from "../common/clientBase/index";
-import { MediaUtil } from "../util/mediaUtil";
-import { ZegoMediaElement, ZegoHTMLAudioElement } from "../../types/index";
-import { ZegoPublish } from "./zego.publish";
+import { E_CLIENT_TYPE, MediaStreamConstraints, PlayOption, audioMixConfig } from '../common/zego.entity';
+import { ZegoStreamCenterWeb } from './zego.streamCenter.web';
+import { audioMixUtil } from '../util/audioMixUtil';
+import { BaseCenter } from '../common/clientBase/index';
+import { MediaUtil } from '../util/mediaUtil';
+import { ZegoMediaElement, ZegoHTMLAudioElement, ZegoAudioContext } from '../../types/index';
+import { ZegoPublish } from './zego.publish';
 export declare class ZegoClient extends BaseCenter {
     streamCenter: ZegoStreamCenterWeb;
     audioMixing: audioMixUtil;
+    ac: ZegoAudioContext;
     constructor();
@@ -16,2 +17,3 @@ static screenShotReady: boolean;
     static recordedBlobs: Blob[];
+    static recordType: string;
     getSocket(server: string): WebSocket;
@@ -22,3 +24,3 @@ enableCamera(localVideo: HTMLElement, enable: boolean): boolean;
     setPlayAudioOutput(streamid: string, audioOutput: string): boolean;
-    setCustomSignalUrl(signalUrl: string): boolean;
+    setCustomSignalUrl(signalUrl: Array<string>): boolean;
     setQualityMonitorCycle(timeInMs: number): void;
@@ -36,4 +38,6 @@ startPlayingStream(streamid: string, remoteVideo: HTMLElement, audioOutput?: string, playOption?: PlayOption): boolean;
     unloadEffect(effecId: number): boolean;
-    startMixingAudio(streamid: string, audio: ZegoHTMLAudioElement, replace: boolean): boolean;
-    stopMixingAudio(streamid: string): boolean;
+    startMixingAudio(streamID: string, audio: ZegoHTMLAudioElement, replace: boolean): boolean;
+    stopMixingAudio(streamID: string, audio?: Array<HTMLMediaElement>): boolean;
+    mixingBuffer(streamID: string, sourceID: string, arrayBuffer: ArrayBuffer, callBack?: Function): void;
+    stopMixingBuffer(streamID: string, source: Array<string>): boolean;
     setMixingAudioVolume(streamid: string, volume: number): boolean;
@@ -43,2 +47,4 @@ getPublisher(streamid: any): ZegoPublish;
     startScreenSharing(screenConfig: {
+        width?: number;
+        height?: number;
         frameRate?: number;
@@ -52,4 +58,4 @@ displaySurface?: string;
         bitRate?: number;
-    }, mediaSource: 'screen' | 'application' | 'window', audio: any, callBack: (suc: boolean, stream: MediaStream) => void): void;
-    stopScreenShot(): void;
+    }, mediaSource: 'screen' | 'application' | 'window', audio: boolean, callBack: (suc: boolean, stream: MediaStream) => void): void;
+    stopScreenShot(stream: MediaStream): void;
     switchDevice(type: 'audio' | 'video', localVideo: HTMLMediaElement, deviceId: string, success: Function, error: Function): void;
@@ -73,12 +79,13 @@ WebrtcOnPublishStateUpdateHandle(type: 0 | 1 | 2, streamid: string, error: {
     }): void;
+    onScreenSharingEnded(stream: any): void;
     loginBodyData(): {
-        "id_name": string;
-        "nick_name": string;
-        "role": 1 | 2;
-        "token": string;
-        "version": any;
-        "room_name": string;
-        "user_state_flag": number;
-        "room_create_flag": number;
-        "client_type": E_CLIENT_TYPE;
+        'id_name': string;
+        'nick_name': string;
+        'role': 1 | 2;
+        'token': string;
+        'version': any;
+        'room_name': string;
+        'user_state_flag': number;
+        'room_create_flag': number;
+        'client_type': E_CLIENT_TYPE;
         third_token: string;
@@ -90,4 +97,4 @@ };
     voiceBack(streamid: string): void;
-    static isSupportWebrtc(): boolean;
-    static isSupportH264(sucCall: any, errCall: any): void;
+    setPublishStreamConstraints(streamID: string, constraints: MediaStreamConstraints, success: Function, error: Function): void;
+    setSoundLevelDelegate(bool: boolean, timeInMs?: number): void;
     static supportDetection(success: Function, error: Function): void;
@@ -104,7 +111,13 @@ enumDevices(deviceInfoCallback: any, error: any): void;
     private static handleDataAvailable;
-    static startRecord(el: ZegoMediaElement): void;
+    static startRecord(el: ZegoMediaElement, constraints?: {
+        audio?: false;
+        audioInput?: string;
+    }, callBack?: (err?: any) => void): Promise<void>;
     static stopRecord(): void;
     static resumeRecord(): void;
     static pauseRecord(): void;
-    static saveRecord(name: string): void;
+    static saveRecord(name?: string): string;
+    static resumeRecordAudio(): void;
+    static pauseRecordAudio(): void;
+    static getRecordAudio(): string;
     static takeSnapShot(el: HTMLVideoElement, img: HTMLImageElement): void;
@@ -111,0 +124,0 @@ static saveSnapShot(el: HTMLVideoElement, name: string): void;

sdk/webrtc/zego.play.web.d.ts

@@ -1,6 +0,6 @@
-import { PlayOption } from '../common/zego.entity';
+import { PlayOption, ENUM_BROADCASTER_STATUS } from '../common/zego.entity';
 import { ZegoDataReport } from '../common/zego.datareport';
 import { ZegoSignal } from '../common/zego.signal';
 import { Logger } from '../common/zego.logger';
-import { ZegoStreamCenter } from '../common/ZegoStreamCenter';
+import { ZegoStreamCenterWeb } from './zego.streamCenter.web';
 export declare class ZegoPlayWeb {
@@ -10,3 +10,3 @@ logger: Logger;
     state: number;
-    streamCenter: ZegoStreamCenter;
+    streamCenter: ZegoStreamCenterWeb;
     candidateInfo: any[];
@@ -34,2 +34,3 @@ waitICETimer: any;
         framesDropped: number;
+        audioBitrate: number;
     };
@@ -45,2 +46,3 @@ dataReport: ZegoDataReport;
     retryState: number;
+    streamGoogInfo: any;
     remoteVideo: any;
@@ -57,3 +59,22 @@ remoteStream: MediaStream;
     closeSessionSignal: boolean;
-    constructor(log: Logger, signal: ZegoSignal, dataReport: ZegoDataReport, qualityTimeInterval: number, streamCenter: ZegoStreamCenter);
+    stateNego: number;
+    negoTimer: any;
+    negoInterval: number;
+    negoTryCount: number;
+    negoTryMaxCount: number;
+    broadcasterStatus: ENUM_BROADCASTER_STATUS;
+    cameraStatus: any;
+    micStatus: any;
+    playEvent: boolean;
+    nextSignalTryCount: number;
+    waittingConnectedTimer: any;
+    waittingConnectedInerval: number;
+    streamStatus: any;
+    gotStreamStatus: boolean;
+    tryingNexitSignal: boolean;
+    ac: AudioContext | null;
+    soundLevel: number;
+    mic: any;
+    script: any;
+    constructor(log: Logger, signal: ZegoSignal, dataReport: ZegoDataReport, qualityTimeInterval: number, streamCenter: ZegoStreamCenterWeb);
     setAudioDestination(audioOutput: string): boolean;
@@ -68,2 +89,3 @@ startPlay(streamId: string, remoteVideo: HTMLElement, audioOutput?: string, playOption?: PlayOption): void;
     private onRecvCandidateInfo;
+    private onRecvPlayEvent;
     private onIceCandidate;
@@ -80,2 +102,4 @@ private onConnectionStateChange;
     private setPlayQualityTimer;
+    peerConnectionGetStats(supportStatsCallback: boolean): void;
+    getOldGoogStats(results: any): void;
     private getPlayStats;
@@ -94,4 +118,9 @@ private getNetQuality;
     onVideoSizeChanged(streamId: any, videoWidth: any, videoHeight: any): void;
+    onRemoteCameraStatusUpdate(streamID: string, status: number): void;
+    onRemoteMicStatusUpdate(streamID: string, status: number): void;
     stopPlay(): void;
     onDisconnect(): void;
+    tryNextSignal(error: any): void;
+    startSoundLevel(): void;
+    stopSoundLevel(): void;
 }

sdk/webrtc/zego.preview.d.ts

@@ -1,2 +0,2 @@
-import { MediaStreamConstraints } from '../common/zego.entity';
+import { MediaStreamConstraints, VideoInfo } from '../common/zego.entity';
 import { Logger } from '../common/zego.logger';
@@ -9,3 +9,3 @@ import { ZegoStreamCenter } from '../common/ZegoStreamCenter';
     localStream: MediaStream;
-    videoInfo: {};
+    videoInfo: VideoInfo;
     mediaStreamConfig: MediaStreamConstraints;
@@ -19,7 +19,7 @@ previewSuc: boolean;
     startPreview(localVideo: HTMLElement, mediaStreamConfig: MediaStreamConstraints, successCallback: Function, errorCallback: Function): void;
-    captureStream(localVideo: HTMLElement): boolean;
+    captureStream(localVideo: HTMLElement, mediaStreamConfig: MediaStreamConstraints): boolean;
     stopPreview(): void;
-    enableMicrophone: (enable: boolean) => boolean;
+    enableMicrophone: (enable: boolean, streamCenter: ZegoStreamCenter) => boolean;
     enableCamera: (enable: boolean, streamCenter: ZegoStreamCenter) => boolean;
     setAudioDestination: (audioOutput: any) => boolean;
 }

sdk/webrtc/zego.publish.d.ts

@@ -1,9 +0,9 @@
-import { ZegoDataReport } from "../common/zego.datareport";
-import { VideoInfo, PlayOption, audioMixConfig } from "../common/zego.entity";
-import { ZegoSignal } from "../common/zego.signal";
-import { Logger } from "../common/zego.logger";
-import { audioMixUtil } from "../util/audioMixUtil";
-import { ZegoHTMLAudioElement, ZegoVideoDecodeType } from '../../types/index';
+import { ZegoDataReport } from '../common/zego.datareport';
+import { VideoInfo, PlayOption, audioMixConfig } from '../common/zego.entity';
+import { ZegoSignal } from '../common/zego.signal';
+import { Logger } from '../common/zego.logger';
+import { audioMixUtil } from '../util/audioMixUtil';
+import { ZegoVideoDecodeType, ZegoAudioContext } from '../../types/index';
 import { pitchUtil } from '../util/pitchUtil';
-import { ZegoStreamCenter } from "../common/ZegoStreamCenter";
+import { ZegoStreamCenterWeb } from './zego.streamCenter.web';
 export declare class ZegoPublish {
@@ -13,3 +13,3 @@ logger: Logger;
     state: number;
-    streamCenter: ZegoStreamCenter;
+    streamCenter: ZegoStreamCenterWeb;
     sessionId: number;
@@ -32,2 +32,3 @@ waitingICETimeInterval: number;
     qualitySeq: number;
+    RTCRtpSender: RTCRtpSender;
     maxRetryCount: number;
@@ -39,2 +40,4 @@ currentRetryCount: number;
     videoInfo: VideoInfo;
+    localVideo: HTMLMediaElement;
+    streamGoogInfo: any;
     mediaStreamConfig: any;
@@ -45,2 +48,9 @@ offerSeq: number;
     audioMixing: audioMixUtil;
+    audioMixList: Array<{
+        audioMix: audioMixUtil;
+        media: HTMLMediaElement;
+    }>;
+    arrayBufferMap: {
+        [index: string]: audioMixUtil;
+    };
     sessionSeq: number;
@@ -55,3 +65,18 @@ peerConnection: RTCPeerConnection | any;
     videoDecodeType: ZegoVideoDecodeType;
-    constructor(log: Logger, signal: ZegoSignal, dataReport: ZegoDataReport, qualityTimeInterval: number, streamCenter: ZegoStreamCenter);
+    stateNego: number;
+    negoTimer: any;
+    negoInterval: number;
+    negoTryCount: number;
+    negoTryMaxCount: number;
+    playOption: PlayOption;
+    publishEvent: boolean;
+    nextSignalTryCount: number;
+    waittingConnectedTimer: any;
+    waittingConnectedInerval: number;
+    tryingNexitSignal: boolean;
+    soundLevel: number;
+    ac: ZegoAudioContext;
+    script: any;
+    mic: any;
+    constructor(log: Logger, signal: ZegoSignal, dataReport: ZegoDataReport, qualityTimeInterval: number, streamCenter: ZegoStreamCenterWeb);
     private publishStateUpdateError;
@@ -78,2 +103,3 @@ private resetPublish;
     onRecvResetSession(seq: number, sessionId: number, data: any): void;
+    onRecvPublishEvent(seq: number, sessionId: number, data: any): void;
     shouldRetryPublish(): boolean;
@@ -84,2 +110,4 @@ startRetryPublish(): void;
     setPublishQualityTimer(): void;
+    peerConnectionGetStats(supportStatsCallback: boolean): void;
+    getOldGoogStats(results: any): void;
     getPublishStats(results: any): void;
@@ -94,6 +122,12 @@ uploadPublishQuality(publishData: any): void;
     resumeEffect(): void;
-    startMixingAudio(audio: ZegoHTMLAudioElement, replace: boolean): boolean;
-    stopMixingAudio(): boolean;
+    stopMixingBuffer(): boolean;
+    mixingBuffer(arrayBuffer: ArrayBuffer, callBack?: Function): void;
     voiceChange(mult: number): boolean;
     voiceBack(): void;
+    publishSuccess(): void;
+    tryNextSignal(error: any): void;
+    startSoundLevel(): void;
+    stopSoundLevel(): void;
+    startMixingAudio(mediaList: Array<HTMLMediaElement>): boolean;
+    stopMixingAudio(media?: Array<HTMLMediaElement>): boolean;
 }

sdk/webrtc/zego.streamCenter.web.d.ts

 import { ZegoDataReport } from '../common/zego.datareport';
 import { ZegoPreview } from './zego.preview';
-import { MediaStreamConstraints, PlayOption, SignalInfo } from '../common/zego.entity';
+import { MediaStreamConstraints, PlayOption, SignalInfo, ChargeInfos, DeviceStates } from '../common/zego.entity';
 import { ZegoStreamCenter } from '../common/ZegoStreamCenter';
 import { LoggerWeb } from './zego.logger.webrtc';
 import { StateCenter } from '../common/clientBase/stateCenter';
+import { ZegoAudioContext } from '../../types';
 export declare class ZegoStreamCenterWeb extends ZegoStreamCenter {
@@ -14,2 +15,6 @@ logger: LoggerWeb;
     heartbeatInterval: number;
+    chargeInfos: ChargeInfos;
+    chargeInfosTimer: any;
+    chargeInfosInterval: number;
+    chargeInfoSeq: 0;
     qualityTimerInterval: number;
@@ -21,2 +26,5 @@ maxRetryCount: number;
     };
+    videoDeviceName: string;
+    audioDeviceName: string;
+    deviceStates: DeviceStates;
     appid: number;
@@ -26,3 +34,7 @@ userid: string;
     server: string;
-    constructor(log: LoggerWeb, stateCenter: StateCenter);
+    soundLevelDelegate: boolean;
+    soundLevelInterval: number;
+    soundLevelTimer: any;
+    ac: ZegoAudioContext;
+    constructor(log: LoggerWeb, stateCenter: StateCenter, ac: ZegoAudioContext);
     onSignalDisconnected(server: any): void;
@@ -39,10 +51,12 @@ setQualityMonitorCycle(timeInMs: number): void;
     enableCamera(localVideo: HTMLElement, enable: boolean): boolean;
+    recordDevices(localVideo: any): void;
     startPreview(localVideo: HTMLElement, mediaStreamConstraints: MediaStreamConstraints, success: Function, error: Function): boolean;
     stopPreview(localVideo: HTMLElement): boolean;
     setPublishStateStart(streamid: any, localVideo: any, playOption: PlayOption): boolean;
-    getTotalStreamId(streamid: any): any;
+    getTotalStreamId(streamid: string): string;
+    getBackStreamId(streamid: any): any;
     startPublishingStream(streamid: string, serverUrls: string[], preferPublishSourceType?: number): boolean;
     updateWaitingList(signalInfo: SignalInfo, isPublish: boolean, streamId: string, success: Function, error: Function): void;
     publishStream(streamid: any): void;
-    connectPublishServer(streamId: string, serverUrl: string): boolean;
+    connectPublishServer(streamId: string): boolean;
     shouldRetry(stream: {
@@ -59,6 +73,10 @@ serverUrls: string[];
     startPlayingStream(streamid: string, serverUrls: string[], currentPlaySourceType?: number): boolean;
-    private connectPlayServer;
+    connectPlayServer(streamId: string): boolean;
+    private tryCountConnectInterval;
+    private connetWithReuseSignalServerTimer;
     private playStream;
     private removeStreamFromSignal;
     private stopSignalHeartbeat;
+    private stopChargeInfosUpload;
+    private getPublisher;
     stopPlayingStream(streamid: any): void;
@@ -71,6 +89,36 @@ reset(): void;
     checkSignalHeartbeat(): void;
+    startChargeInfosUpload(): void;
+    checkChargeInfos(): void;
+    startSoundLevel(): void;
+    checkSoundLevel(): void;
+    setSoundLevelDelegate(bool: boolean, timeInMs?: number): void;
+    stopSoundLevel(): void;
     checkPreview(localVideo: HTMLElement): ZegoPreview;
     removePreview(preview: ZegoPreview): void;
+    onDeviceError(msg: {
+        deviceName: string;
+        deviceType: string;
+        errorCode: number;
+    }): void;
+    OnAudioDeviceStateChanged(msg: {
+        deviceType: string;
+        deviceInfo: any;
+        state: string;
+    }): void;
+    OnVideoDeviceStateChanged(msg: {
+        deviceInfo: any;
+        state: string;
+    }): void;
     onPlayerStreamUrlUpdate(streamid: string, url: string, type: string): void;
     onVideoSizeChanged(streamId: string, videoWidth: number, videoHeight: number): void;
+    onRemoteCameraStatusUpdate(streamID: string, status: number): void;
+    onRemoteMicStatusUpdate(streamID: string, status: number): void;
+    onSoundLevelUpdate(soundLevelList: Array<{
+        streamID: string;
+        soundLevel: number;
+    }>): void;
+    setPublishStreamConstraints(streamID: string, constraints: MediaStreamConstraints, success: Function, error: Function): void;
+    setVideoBitRate(sender: any, minBitRate: number, maxBitRate: number): boolean;
+    startMixingAudio(streamID: string, mediaList: Array<HTMLMediaElement>): boolean;
+    stopMixingAudio(streamID: string, audio?: Array<HTMLMediaElement>): boolean;
 }

sdk/wechatMini/zego.play.wechat.d.ts

@@ -23,7 +23,12 @@ import { Logger } from "../common/zego.logger";
     publishQualitySeq: number;
+    playQualitySeq: number;
     publishQualityCount: number;
+    playQualityCount: number;
     publishQulaityMaxCount: number;
+    playQulaityMaxCount: number;
     everSuccess: boolean;
     dataReport: ZegoDataReport;
     playerInfo: any;
+    publishQualityTimer: number;
+    playQualityTimer: number;
     playerLogUploadTime: number;
@@ -40,5 +45,6 @@ constructor(logger: Logger, streamid: string, urls: string[], params: any, reconnectLimit: number, streamcenter: ZegoStreamCenterWechat, sourceType: number, playerType: number, dataReport: ZegoDataReport);
     updateEvent(event: any): void;
-    updatePlayerNetStatus(event: any): void;
+    updatePlayerNetStatus(event: any, qu: any): void;
     getCurrentPlayerUrl(): string;
     reportQualityStatics(this: any): void;
+    reportPlayQualityStatics(this: any): void;
 }

sdk/wechatMini/zego.streamcenter.wechat.d.ts

@@ -46,2 +46,21 @@ /**
     onVideoSizeChanged(streamid: any): void;
+    onRemoteCameraStatusUpdate(streamID: string, status: number): void;
+    onRemoteMicStatusUpdate(streamID: string, status: number): void;
+    onSoundLevelUpdate(soundLevelList: Array<{
+        streamID: string;
+        soundLevel: number;
+    }>): void;
+    onDeviceError(msg: {
+        deviceName: string;
+        errorCode: number;
+    }): void;
+    OnAudioDeviceStateChanged(msg: {
+        deviceType: string;
+        deviceInfo: any;
+        state: string;
+    }): void;
+    OnVideoDeviceStateChanged(msg: {
+        deviceInfo: any;
+        state: string;
+    }): void;
     getReconnectLimit(sourceType: number): number;
@@ -48,0 +67,0 @@ onPlayerStart(streamid: any, playerType: any): void;

New alerts

New author

Supply chain risk

A new npm collaborator published a version of the package for the first time. New collaborators are usually benign additions to a project, but do indicate a change to the security surface area of a package.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

212719

increased by9.41%

Lines of code

2298

increased by14.73%

Number of lines in readme file

48

increased by9.09%

Worsened metrics

Number of medium supply chain risk alerts

1

increased byInfinity%

No dependency changes