// This worker is used for one of the tests in test-sqlite-session.js

'use strict';

require('../common');

const { parentPort, workerData } = require('worker_threads');

const { DatabaseSync, constants } = require('node:sqlite');

const { changeset, mode, dbPath } = workerData;

const db = new DatabaseSync(dbPath);

const options = {};

if (mode !== constants.SQLITE_CHANGESET_ABORT && mode !== constants.SQLITE_CHANGESET_OMIT) {

throw new Error('Unexpected value for mode');

}

options.onConflict = () => mode;

try {

const result = db.applyChangeset(changeset, options);

parentPort.postMessage({ mode, result, error: null });

} catch (error) {

parentPort.postMessage({ mode, result: null, errorMessage: error.message, errcode: error.errcode });

} finally {

db.close(); // Just to make sure it is closed ASAP

}