r4sas/tweb-i2p
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Rollback push

Browse Source
This commit is contained in:
morethanwords 2021-06-18 14:08:27 +03:00
parent 38f9cf920e
commit 822fc8e13e
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/lib/serviceWorker/index.service.ts
View File

@ -11,12 +11,12 @@ import '../mtproto/mtproto.worker';
import type { WorkerTaskTemplate, WorkerTaskVoidTemplate } from '../../types';
import type { InputFileLocation, UploadFile } from '../../layer';
import type { WebPushApiManager } from '../mtproto/webPushApiManager';
import type { PushNotificationObject } from './push';
import { logger, LogTypes } from '../logger';
import { CancellablePromise } from '../../helpers/cancellablePromise';
import './push';
import { CACHE_ASSETS_NAME, requestCache } from './cache';
import onStreamFetch from './stream';
import { closeAllNotifications, onPing, PushNotificationObject } from './push';
// import { closeAllNotifications, onPing } from './push';
export const log = logger('SW', LogTypes.Error | LogTypes.Debug | LogTypes.Log | LogTypes.Warn);
const ctx = self as any as ServiceWorkerGlobalScope;
@ -62,10 +62,10 @@ const taskListeners: {
[type in ServiceWorkerTask['type']]: (task: any, event: ExtendableMessageEvent) => void
} = {
notifications_clear: () => {
closeAllNotifications();
// closeAllNotifications();
},
ping: (task: ServiceWorkerPingTask, event) => {
onPing(task, event);
// onPing(task, event);
},
requestFilePart: (task: RequestFilePartTaskResponse) => {
const promise = deferredPromises[task.id];