Function writeMutations

src/services/messenger.ts:362–399

(serializedMutations: SerializedMutation[])

}

async function writeMutations(serializedMutations: SerializedMutation[]) {
	const response = {
		tabId: serializedMutations[0].tabId,
		outcome: 'success',
		errorMessage: '',
	}

	if (!database) {
		response.outcome = 'error';
		response.errorMessage = 'No database selected';
		return response
	}

	const transaction = (database.getType()) === 'sqlite'
		? await (database as SqliteEngine).transaction()
		: await (database.getConnection())?.transaction();

	if (!transaction) {
		response.outcome = 'error';
		response.errorMessage = 'Could not start transaction';
		return response
	}

	try {
		await Promise.all(serializedMutations.map(async (serializedMutation) => {
			if (!database) return;
			return database.commitChange(serializedMutation, transaction);
		}));

		await transaction.commit();
	} catch (error) {
		response.outcome = 'error';
		response.errorMessage = String(error);
		await transaction.rollback();
	}

	return response
}

async function reconnect(webviewView: vscode.WebviewView) {
	if (selectedProvider) {