run.ts

import { TransactionType } from 'typedb-driver';
import { getSessionOrOpenNewOne } from '../../../adapters/typeDB/helpers';
import type { BormConfig, DBHandles } from '../../../types';

export type TqlMutation = {
	deletions: string;
	deletionMatches: string;
	insertions: string;
	insertionMatches: string;
};

export const runTQLMutation = async (tqlMutation: TqlMutation, dbHandles: DBHandles, config: BormConfig) => {
	if (!tqlMutation) {
		throw new Error('TQL request not built');
	}
	if (!((tqlMutation.deletions && tqlMutation.deletionMatches) || tqlMutation.insertions)) {
		throw new Error('TQL request error, no things');
	}

	//console.log('tqlMutation', tqlMutation);
	const { session } = await getSessionOrOpenNewOne(dbHandles, config);
	const mutateTransaction = await session.transaction(TransactionType.WRITE);

	// deletes and pre-update deletes
	const tqlDeletion =
		tqlMutation.deletionMatches &&
		tqlMutation.deletions &&
		`match ${tqlMutation.deletionMatches} delete ${tqlMutation.deletions}`;

	// insertions and updates
	const tqlInsertion =
		tqlMutation.insertions &&
		`${tqlMutation.insertionMatches ? `match ${tqlMutation.insertionMatches}` : ''} insert ${tqlMutation.insertions}`;

	try {
		// does not receive a result
		if (tqlDeletion) {
			await mutateTransaction.query.delete(tqlDeletion);
		}

		const insertionsStream = tqlInsertion && mutateTransaction.query.insert(tqlInsertion);
		const insertionsRes = insertionsStream ? await insertionsStream.collect() : undefined;

		await mutateTransaction.commit();
		return { insertions: insertionsRes };
	} catch (e: any) {
		throw new Error(`Transaction failed: ${e.message}`);
	} finally {
		await mutateTransaction.close();
	}
};