u

src/store/lang/create.js

@@ -1,10 +1,10 @@
 import sql from 'mssql';
 import { CREATE } from '../../sql/language.js';
+import request from '../request.js';
 
 export default function create(pool) {
-  return async (iso639) => {
-    const result = await pool
-      .request()
+  return async (iso639, tx) => {
+    const result = await request(pool, tx)
       .input('iso639', sql.NVarChar(10), iso639)
       .query(CREATE);
 

src/store/lang/ensure.js

@@ -0,0 +1,12 @@
+import getByIso639 from './getByIso639.js';
+import create from './create.js';
+
+export default function ensure(pool) {
+  const get = getByIso639(pool);
+  const add = create(pool);
+  return async (iso639, tx) => {
+    const row = await get(iso639, tx);
+    if (row) return row.id;
+    return add(iso639, tx);
+  };
+}

src/store/lang/getByIso639.js

@@ -0,0 +1,13 @@
+import sql from 'mssql';
+import { GET_BY_ISO639 } from '../../sql/language.js';
+import request from '../request.js';
+
+export default function getByIso639(pool) {
+  return async (iso639, tx) => {
+    const result = await request(pool, tx)
+      .input('iso639', sql.NVarChar(10), iso639)
+      .query(GET_BY_ISO639);
+
+    return result.recordset[0];
+  };
+}