|
|
@ -7,7 +7,7 @@ |
|
|
|
import type { LocalStorageProxyTask, LocalStorageProxyTaskResponse } from '../localStorage'; |
|
|
|
import type { LocalStorageProxyTask, LocalStorageProxyTaskResponse } from '../localStorage'; |
|
|
|
//import type { LocalStorageProxyDeleteTask, LocalStorageProxySetTask } from '../storage';
|
|
|
|
//import type { LocalStorageProxyDeleteTask, LocalStorageProxySetTask } from '../storage';
|
|
|
|
import type { Awaited, InvokeApiOptions, WorkerTaskVoidTemplate } from '../../types'; |
|
|
|
import type { Awaited, InvokeApiOptions, WorkerTaskVoidTemplate } from '../../types'; |
|
|
|
import type { InputFile, MethodDeclMap } from '../../layer'; |
|
|
|
import type { Config, InputFile, MethodDeclMap } from '../../layer'; |
|
|
|
import MTProtoWorker from 'worker-loader!./mtproto.worker'; |
|
|
|
import MTProtoWorker from 'worker-loader!./mtproto.worker'; |
|
|
|
//import './mtproto.worker';
|
|
|
|
//import './mtproto.worker';
|
|
|
|
import { isObject } from '../../helpers/object'; |
|
|
|
import { isObject } from '../../helpers/object'; |
|
|
@ -99,6 +99,8 @@ export class ApiManagerProxy extends CryptoWorkerMethods { |
|
|
|
|
|
|
|
|
|
|
|
private postMessagesWaiting: any[][] = []; |
|
|
|
private postMessagesWaiting: any[][] = []; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
private getConfigPromise: Promise<Config.config>; |
|
|
|
|
|
|
|
|
|
|
|
constructor() { |
|
|
|
constructor() { |
|
|
|
super(); |
|
|
|
super(); |
|
|
|
this.log('constructor'); |
|
|
|
this.log('constructor'); |
|
|
@ -210,6 +212,10 @@ export class ApiManagerProxy extends CryptoWorkerMethods { |
|
|
|
/// #if !MTPROTO_SW
|
|
|
|
/// #if !MTPROTO_SW
|
|
|
|
this.registerWorker(); |
|
|
|
this.registerWorker(); |
|
|
|
/// #endif
|
|
|
|
/// #endif
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
setTimeout(() => { |
|
|
|
|
|
|
|
this.getConfig(); |
|
|
|
|
|
|
|
}, 5000); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
public isServiceWorkerOnline() { |
|
|
|
public isServiceWorkerOnline() { |
|
|
@ -597,6 +603,14 @@ export class ApiManagerProxy extends CryptoWorkerMethods { |
|
|
|
public forceReconnect() { |
|
|
|
public forceReconnect() { |
|
|
|
this.postMessage({type: 'forceReconnect'}); |
|
|
|
this.postMessage({type: 'forceReconnect'}); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public getConfig() { |
|
|
|
|
|
|
|
if(this.getConfigPromise) return this.getConfigPromise; |
|
|
|
|
|
|
|
return this.getConfigPromise = this.invokeApi('help.getConfig').then(config => { |
|
|
|
|
|
|
|
rootScope.config = config; |
|
|
|
|
|
|
|
return config; |
|
|
|
|
|
|
|
}); |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
const apiManagerProxy = new ApiManagerProxy(); |
|
|
|
const apiManagerProxy = new ApiManagerProxy(); |
|
|
|