143 lines
3.5 KiB
TypeScript
143 lines
3.5 KiB
TypeScript
import type { ApiOnProgress, ApiUpdate } from '../../types';
|
|
import type { OriginMessageEvent, WorkerMessageData } from './types';
|
|
|
|
import { DEBUG } from '../../../config';
|
|
import { initApi, callApi, cancelApiProgress } from '../provider';
|
|
import { log } from '../helpers';
|
|
|
|
declare const self: WorkerGlobalScope;
|
|
|
|
handleErrors();
|
|
|
|
const callbackState = new Map<string, ApiOnProgress>();
|
|
|
|
if (DEBUG) {
|
|
// eslint-disable-next-line no-console
|
|
console.log('>>> FINISH LOAD WORKER');
|
|
}
|
|
|
|
onmessage = async (message: OriginMessageEvent) => {
|
|
const { data } = message;
|
|
|
|
switch (data.type) {
|
|
case 'initApi': {
|
|
const { messageId, args } = data;
|
|
await initApi(onUpdate, args[0], args[1]);
|
|
if (messageId) {
|
|
sendToOrigin({
|
|
type: 'methodResponse',
|
|
messageId,
|
|
response: true,
|
|
});
|
|
}
|
|
break;
|
|
}
|
|
case 'callMethod': {
|
|
const {
|
|
messageId, name, args, withCallback,
|
|
} = data;
|
|
try {
|
|
if (messageId && withCallback) {
|
|
const callback = (...callbackArgs: any[]) => {
|
|
const lastArg = callbackArgs[callbackArgs.length - 1];
|
|
|
|
sendToOrigin({
|
|
type: 'methodCallback',
|
|
messageId,
|
|
callbackArgs,
|
|
}, lastArg instanceof ArrayBuffer ? lastArg : undefined);
|
|
};
|
|
|
|
callbackState.set(messageId, callback);
|
|
|
|
args.push(callback as never);
|
|
}
|
|
|
|
const response = await callApi(name, ...args);
|
|
|
|
if (DEBUG && typeof response === 'object' && 'CONSTRUCTOR_ID' in response) {
|
|
log('UNEXPECTED RESPONSE', `${name}: ${response.className}`);
|
|
}
|
|
|
|
const { arrayBuffer } = (typeof response === 'object' && 'arrayBuffer' in response && response) || {};
|
|
|
|
if (messageId) {
|
|
sendToOrigin({
|
|
type: 'methodResponse',
|
|
messageId,
|
|
response,
|
|
}, arrayBuffer);
|
|
}
|
|
} catch (error: any) {
|
|
if (DEBUG) {
|
|
// eslint-disable-next-line no-console
|
|
console.error(error);
|
|
}
|
|
|
|
if (messageId) {
|
|
sendToOrigin({
|
|
type: 'methodResponse',
|
|
messageId,
|
|
error: { message: error.message },
|
|
});
|
|
}
|
|
}
|
|
|
|
if (messageId) {
|
|
callbackState.delete(messageId);
|
|
}
|
|
|
|
break;
|
|
}
|
|
case 'cancelProgress': {
|
|
const callback = callbackState.get(data.messageId);
|
|
if (callback) {
|
|
cancelApiProgress(callback);
|
|
}
|
|
|
|
break;
|
|
}
|
|
case 'ping': {
|
|
sendToOrigin({
|
|
type: 'methodResponse',
|
|
messageId: data.messageId!,
|
|
});
|
|
|
|
break;
|
|
}
|
|
}
|
|
};
|
|
|
|
function handleErrors() {
|
|
self.onerror = (e) => {
|
|
// eslint-disable-next-line no-console
|
|
console.error(e);
|
|
sendToOrigin({ type: 'unhandledError', error: { message: e.error.message || 'Uncaught exception in worker' } });
|
|
};
|
|
|
|
self.addEventListener('unhandledrejection', (e) => {
|
|
// eslint-disable-next-line no-console
|
|
console.error(e);
|
|
sendToOrigin({ type: 'unhandledError', error: { message: e.reason.message || 'Uncaught rejection in worker' } });
|
|
});
|
|
}
|
|
|
|
function onUpdate(update: ApiUpdate) {
|
|
sendToOrigin({
|
|
type: 'update',
|
|
update,
|
|
});
|
|
|
|
if (DEBUG && update['@type'] !== 'updateUserStatus' && update['@type'] !== 'updateServerTimeOffset') {
|
|
log('UPDATE', update['@type'], update);
|
|
}
|
|
}
|
|
|
|
function sendToOrigin(data: WorkerMessageData, arrayBuffer?: ArrayBuffer) {
|
|
if (arrayBuffer) {
|
|
postMessage(data, [arrayBuffer]);
|
|
} else {
|
|
postMessage(data);
|
|
}
|
|
}
|