/* * https://github.com/morethanwords/tweb * Copyright (C) 2019-2021 Eduard Kuzmenko * https://github.com/morethanwords/tweb/blob/master/LICENSE */ import MTProtoWorker from 'worker-loader!./mtproto.worker'; //import './mtproto.worker'; import { isObject } from '../../helpers/object'; import type { MethodDeclMap } from '../../layer'; import type { InvokeApiOptions } from '../../types'; import CryptoWorkerMethods from '../crypto/crypto_methods'; import { logger } from '../logger'; import rootScope from '../rootScope'; import webpWorkerController from '../webp/webpWorkerController'; import type { DownloadOptions } from './apiFileManager'; import { ApiError } from './apiManager'; import type { ServiceWorkerTask, ServiceWorkerTaskResponse } from './mtproto.service'; import { UserAuth } from './mtproto_config'; import type { MTMessage } from './networker'; import referenceDatabase from './referenceDatabase'; import appDocsManager from '../appManagers/appDocsManager'; import DEBUG, { MOUNT_CLASS_TO } from '../../config/debug'; import Socket from './transports/websocket'; type Task = { taskId: number, task: string, args: any[] }; type HashResult = { hash: number, result: any }; type HashOptions = { [queryJSON: string]: HashResult }; export class ApiManagerProxy extends CryptoWorkerMethods { public worker: /* Window */Worker; public postMessage: (...args: any[]) => void; private afterMessageIdTemp = 0; private taskId = 0; private awaiting: { [id: number]: { resolve: any, reject: any, taskName: string } } = {} as any; private pending: Array = []; public updatesProcessor: (obj: any) => void = null; private log = logger('API-PROXY'); private hashes: {[method: string]: HashOptions} = {}; private apiPromisesSingle: { [q: string]: Promise } = {}; private apiPromisesCacheable: { [method: string]: { [queryJSON: string]: { timestamp: number, promise: Promise, fulfilled: boolean, timeout?: number, params: any } } } = {}; private isSWRegistered = true; private debug = DEBUG /* && false */; private sockets: Map = new Map(); constructor() { super(); this.log('constructor'); this.registerServiceWorker(); /// #if !MTPROTO_SW this.registerWorker(); /// #endif } public isServiceWorkerOnline() { return this.isSWRegistered; } private registerServiceWorker() { if(!('serviceWorker' in navigator)) return; const worker = navigator.serviceWorker; worker.register('./sw.js', {scope: './'}).then(registration => { this.log('SW registered', registration); this.isSWRegistered = true; const sw = registration.installing || registration.waiting || registration.active; sw.addEventListener('statechange', (e) => { this.log('SW statechange', e); }); /// #if MTPROTO_SW const controller = worker.controller || registration.installing || registration.waiting || registration.active; this.onWorkerFirstMessage(controller); /// #endif }, (err) => { this.isSWRegistered = false; this.log.error('SW registration failed!', err); appDocsManager.onServiceWorkerFail(); }); worker.addEventListener('controllerchange', () => { this.log.warn('controllerchange'); this.releasePending(); worker.controller.addEventListener('error', (e) => { this.log.error('controller error:', e); }); }); /// #if MTPROTO_SW worker.addEventListener('message', this.onWorkerMessage); /// #else worker.addEventListener('message', (e) => { const task: ServiceWorkerTask = e.data; if(!isObject(task)) { return; } this.postMessage(task); }); /// #endif worker.addEventListener('messageerror', (e) => { this.log.error('SW messageerror:', e); }); } private onWorkerFirstMessage(worker: any) { if(!this.worker) { this.worker = worker; this.log('set webWorker'); this.postMessage = this.worker.postMessage.bind(this.worker); const isWebpSupported = webpWorkerController.isWebpSupported(); this.log('WebP supported:', isWebpSupported); this.postMessage({type: 'webpSupport', payload: isWebpSupported}); this.releasePending(); } } private onWorkerMessage = (e: MessageEvent) => { //this.log('got message from worker:', e.data); const task = e.data; if(!isObject(task)) { return; } if(task.update) { if(this.updatesProcessor) { this.updatesProcessor(task.update); } } else if(task.progress) { rootScope.broadcast('download_progress', task.progress); } else if(task.type === 'reload') { location.reload(); } else if(task.type === 'connectionStatusChange') { rootScope.broadcast('connection_status_change', task.payload); } else if(task.type === 'convertWebp') { webpWorkerController.postMessage(task); } else if((task as ServiceWorkerTaskResponse).type === 'requestFilePart') { const _task = task as ServiceWorkerTaskResponse; if(_task.error) { const onError = (error: ApiError) => { if(error?.type === 'FILE_REFERENCE_EXPIRED') { // @ts-ignore const bytes = _task.originalPayload[1].file_reference; referenceDatabase.refreshReference(bytes).then(() => { // @ts-ignore _task.originalPayload[1].file_reference = referenceDatabase.getReferenceByLink(bytes); const newTask: ServiceWorkerTask = { type: _task.type, id: _task.id, payload: _task.originalPayload }; this.postMessage(newTask); }).catch(onError); } else { navigator.serviceWorker.controller.postMessage(task); } }; onError(_task.error); } else { navigator.serviceWorker.controller.postMessage(task); } } else if(task.type === 'socketProxy') { const socketTask = task.payload; const id = socketTask.id; //console.log('socketProxy', socketTask, id); if(socketTask.type === 'send') { const socket = this.sockets.get(id); socket.send(socketTask.payload); } else if(socketTask.type === 'close') { const socket = this.sockets.get(id); socket.close(); } else if(socketTask.type === 'setup') { const socket = new Socket(socketTask.payload.dcId, socketTask.payload.url, socketTask.payload.logSuffix); const onOpen = () => { //console.log('socketProxy onOpen'); this.postMessage({ type: 'socketProxy', payload: { type: 'open', id } }); }; const onClose = () => { this.postMessage({ type: 'socketProxy', payload: { type: 'close', id } }); socket.removeEventListener('open', onOpen); socket.removeEventListener('close', onClose); socket.removeEventListener('message', onMessage); this.sockets.delete(id); }; const onMessage = (buffer: ArrayBuffer) => { this.postMessage({ type: 'socketProxy', payload: { type: 'message', id, payload: buffer } }); }; socket.addEventListener('open', onOpen); socket.addEventListener('close', onClose); socket.addEventListener('message', onMessage); this.sockets.set(id, socket); } } else if(task.hasOwnProperty('result') || task.hasOwnProperty('error')) { this.finalizeTask(task.taskId, task.result, task.error); } }; /// #if !MTPROTO_SW private registerWorker() { //return; const worker = new MTProtoWorker(); //const worker = window; worker.addEventListener('message', this.onWorkerFirstMessage.bind(this, worker), {once: true}); worker.addEventListener('message', this.onWorkerMessage); worker.addEventListener('error', (err) => { this.log.error('WORKER ERROR', err); }); } /// #endif private finalizeTask(taskId: number, result: any, error: any) { const deferred = this.awaiting[taskId]; if(deferred !== undefined) { this.debug && this.log.debug('done', deferred.taskName, result, error); error ? deferred.reject(error) : deferred.resolve(result); delete this.awaiting[taskId]; } } public performTaskWorker(task: string, ...args: any[]) { this.debug && this.log.debug('start', task, args); return new Promise((resolve, reject) => { this.awaiting[this.taskId] = {resolve, reject, taskName: task}; const params = { task, taskId: this.taskId, args }; this.pending.push(params); this.releasePending(); this.taskId++; }); } private releasePending() { if(this.postMessage) { this.debug && this.log.debug('releasing tasks, length:', this.pending.length); this.pending.forEach(pending => { this.postMessage(pending); }); this.debug && this.log.debug('released tasks'); this.pending.length = 0; } } public setUpdatesProcessor(callback: (obj: any) => void) { this.updatesProcessor = callback; } public invokeApi(method: T, params: MethodDeclMap[T]['req'] = {}, options: InvokeApiOptions = {}): Promise { //console.log('will invokeApi:', method, params, options); return this.performTaskWorker('invokeApi', method, params, options); } public invokeApiAfter(method: T, params: MethodDeclMap[T]['req'] = {}, options: InvokeApiOptions = {}): Promise { let o = options; o.prepareTempMessageId = '' + ++this.afterMessageIdTemp; o = {...options}; (options as MTMessage).messageId = o.prepareTempMessageId; //console.log('will invokeApi:', method, params, options); return this.invokeApi(method, params, o); } public invokeApiHashable(method: T, params: Omit = {} as any, options: InvokeApiOptions = {}): Promise { //console.log('will invokeApi:', method, params, options); const queryJSON = JSON.stringify(params); let cached: HashResult; if(this.hashes[method]) { cached = this.hashes[method][queryJSON]; if(cached) { (params as any).hash = cached.hash; } } return this.invokeApi(method, params, options).then((result: any) => { if(result._.includes('NotModified')) { this.debug && this.log.warn('NotModified saved!', method, queryJSON); return cached.result; } if(result.hash/* || result.messages */) { const hash = result.hash/* || this.computeHash(result.messages) */; if(!this.hashes[method]) this.hashes[method] = {}; this.hashes[method][queryJSON] = { hash, result }; } return result; }); } public invokeApiSingle(method: T, params: MethodDeclMap[T]['req'] = {} as any, options: InvokeApiOptions = {}): Promise { const q = method + '-' + JSON.stringify(params); if(this.apiPromisesSingle[q]) { return this.apiPromisesSingle[q]; } return this.apiPromisesSingle[q] = this.invokeApi(method, params, options).finally(() => { delete this.apiPromisesSingle[q]; }); } public invokeApiCacheable(method: T, params: MethodDeclMap[T]['req'] = {} as any, options: InvokeApiOptions & Partial<{cacheSeconds: number, override: boolean}> = {}): Promise { const cache = this.apiPromisesCacheable[method] ?? (this.apiPromisesCacheable[method] = {}); const queryJSON = JSON.stringify(params); const item = cache[queryJSON]; if(item && (!options.override || !item.fulfilled)) { return item.promise; } if(options.override) { if(item && item.timeout) { clearTimeout(item.timeout); delete item.timeout; } delete options.override; } let timeout: number; if(options.cacheSeconds) { timeout = window.setTimeout(() => { delete cache[queryJSON]; }, options.cacheSeconds * 1000); delete options.cacheSeconds; } const promise = this.invokeApi(method, params, options); cache[queryJSON] = { timestamp: Date.now(), fulfilled: false, timeout, promise, params }; return promise; } public clearCache(method: T, verify: (params: MethodDeclMap[T]['req']) => boolean) { const cache = this.apiPromisesCacheable[method]; if(cache) { for(const queryJSON in cache) { const item = cache[queryJSON]; if(verify(item.params)) { if(item.timeout) { clearTimeout(item.timeout); } delete cache[queryJSON]; } } } } /* private computeHash(smth: any[]) { smth = smth.slice().sort((a, b) => a.id - b.id); //return smth.reduce((hash, v) => (((hash * 0x4F25) & 0x7FFFFFFF) + v.id) & 0x7FFFFFFF, 0); return smth.reduce((hash, v) => ((hash * 20261) + 0x80000000 + v.id) % 0x80000000, 0); } */ public setBaseDcId(dcId: number) { return this.performTaskWorker('setBaseDcId', dcId); } public setQueueId(queueId: number) { return this.performTaskWorker('setQueueId', queueId); } public setUserAuth(userAuth: UserAuth) { rootScope.broadcast('user_auth', userAuth); return this.performTaskWorker('setUserAuth', userAuth); } public getNetworker(dc_id: number, options?: InvokeApiOptions) { return this.performTaskWorker('getNetworker', dc_id, options); } public logOut(): Promise { return this.performTaskWorker('logOut'); } public cancelDownload(fileName: string) { return this.performTaskWorker('cancelDownload', fileName); } public downloadFile(options: DownloadOptions) { return this.performTaskWorker('downloadFile', options); } public uploadFile(options: {file: Blob | File, fileName: string}) { return this.performTaskWorker('uploadFile', options); } public toggleStorage(enabled: boolean) { return this.performTaskWorker('toggleStorage', enabled); } } const apiManagerProxy = new ApiManagerProxy(); MOUNT_CLASS_TO.apiManagerProxy = apiManagerProxy; export default apiManagerProxy;