58 lines
1.6 KiB
TypeScript
58 lines
1.6 KiB
TypeScript
// Copyright 2018-2020 Signal Messenger, LLC
|
|
// SPDX-License-Identifier: AGPL-3.0-only
|
|
|
|
import { ipcMain } from 'electron';
|
|
|
|
import { remove as removeUserConfig } from './user_config';
|
|
import { remove as removeEphemeralConfig } from './ephemeral_config';
|
|
|
|
type SQLType = {
|
|
sqlCall(callName: string, args: ReadonlyArray<unknown>): unknown;
|
|
};
|
|
|
|
let sql: SQLType | undefined;
|
|
|
|
let initialized = false;
|
|
|
|
const SQL_CHANNEL_KEY = 'sql-channel';
|
|
const ERASE_SQL_KEY = 'erase-sql-key';
|
|
|
|
export function initialize(mainSQL: SQLType): void {
|
|
if (initialized) {
|
|
throw new Error('sqlChannels: already initialized!');
|
|
}
|
|
initialized = true;
|
|
|
|
sql = mainSQL;
|
|
|
|
ipcMain.on(SQL_CHANNEL_KEY, async (event, jobId, callName, ...args) => {
|
|
try {
|
|
if (!sql) {
|
|
throw new Error(`${SQL_CHANNEL_KEY}: Not yet initialized!`);
|
|
}
|
|
const result = await sql.sqlCall(callName, args);
|
|
event.sender.send(`${SQL_CHANNEL_KEY}-done`, jobId, null, result);
|
|
} catch (error) {
|
|
const errorForDisplay = error && error.stack ? error.stack : error;
|
|
console.log(
|
|
`sql channel error with call ${callName}: ${errorForDisplay}`
|
|
);
|
|
if (!event.sender.isDestroyed()) {
|
|
event.sender.send(`${SQL_CHANNEL_KEY}-done`, jobId, errorForDisplay);
|
|
}
|
|
}
|
|
});
|
|
|
|
ipcMain.on(ERASE_SQL_KEY, async event => {
|
|
try {
|
|
removeUserConfig();
|
|
removeEphemeralConfig();
|
|
event.sender.send(`${ERASE_SQL_KEY}-done`);
|
|
} catch (error) {
|
|
const errorForDisplay = error && error.stack ? error.stack : error;
|
|
console.log(`sql-erase error: ${errorForDisplay}`);
|
|
event.sender.send(`${ERASE_SQL_KEY}-done`, error);
|
|
}
|
|
});
|
|
}
|