Add category image add/delete with categorypic SQL layer

src/index.js

@@ -12,6 +12,8 @@ import categoryRename from './store/category/rename.js';
 import categoryMove from './store/category/move.js';
 import categoryOrder from './store/category/order.js';
 import categoryDelete from './store/category/delete.js';
+import categoryAddImage from './store/category/addImage.js';
+import categoryDeleteImage from './store/category/deleteImage.js';
 import articleDelete from './store/article/delete.js';
 import articleDeleteImage from './store/article/deleteImage.js';
 import articleOrderImages from './store/article/orderImages.js';
@@ -86,6 +88,8 @@ export default class LibDashStore {
       move: categoryMove(pool),
       order: categoryOrder(pool),
       delete: categoryDelete(pool),
+      addImage: categoryAddImage(pool),
+      deleteImage: categoryDeleteImage(pool),
     };
 
     this.article = {

src/sql/category.js

@@ -16,6 +16,7 @@ SELECT
     t.sort,
     ct.name,
     ct.slug,
+    p.hash AS fullHash,
     p.thumbw AS thumbW,
     p.thumbh AS thumbH,
     p.thumbhash AS thumbHash

src/sql/categorypic.js

@@ -0,0 +1,23 @@
+export const GET_NEXT_SORT = `
+SELECT ISNULL(MAX(sort), -1) + 1 AS sort
+FROM categorypic
+WHERE category_id = @categoryId
+`;
+
+export const ADD = `
+INSERT INTO categorypic (category_id, pic_id, sort)
+VALUES (@categoryId, @picId, @sort)
+`;
+
+export const DELETE_BY_CATEGORY = `
+DELETE FROM categorypic
+WHERE category_id = @categoryId
+`;
+
+export const GET_FIRST_PIC_BY_CATEGORY = `
+SELECT TOP 1 p.id AS picId, p.thumbw AS thumbW, p.thumbh AS thumbH, p.thumbhash AS thumbHash
+FROM categorypic cp
+INNER JOIN pic p ON p.id = cp.pic_id
+WHERE cp.category_id = @categoryId
+ORDER BY cp.sort ASC, cp.id ASC
+`;

src/store/category/addImage.js

@@ -0,0 +1,66 @@
+import { ADD as ADD_CATEGORYPIC, GET_NEXT_SORT } from '../../sql/categorypic.js';
+import { CREATE as CREATE_PIC } from '../../sql/pic.js';
+import processAvifImage from '../../util/processAvifImage.js';
+import newFullHash from '../../util/newFullHash.js';
+import request from '../request.js';
+import resolveCategoryAccess from './resolveCategoryAccess.js';
+
+export default function addImage(pool) {
+  const access = resolveCategoryAccess(pool);
+
+  return async (googleAuthId, categoryId, image) => {
+    await access(googleAuthId, categoryId);
+
+    const processed = await processAvifImage(image);
+
+    const tx = pool.transaction();
+    await tx.begin();
+
+    try {
+      const sortResult = await request(pool, tx)
+        .input('categoryId', categoryId)
+        .query(GET_NEXT_SORT);
+
+      const sort = sortResult.recordset[0].sort;
+      const fullHash = newFullHash();
+
+      const picResult = await request(pool, tx)
+        .input('w', processed.full.w)
+        .input('h', processed.full.h)
+        .input('size', processed.full.size)
+        .input('hash', fullHash)
+        .input('thumbw', processed.thumb.w)
+        .input('thumbh', processed.thumb.h)
+        .input('thumbhash', processed.thumb.hash)
+        .input('source', '')
+        .input('fullbinary', processed.full.buffer)
+        .input('thumbbinary', processed.thumb.buffer)
+        .query(CREATE_PIC);
+
+      const picId = picResult.recordset[0].id;
+
+      await request(pool, tx)
+        .input('categoryId', categoryId)
+        .input('picId', picId)
+        .input('sort', sort)
+        .query(ADD_CATEGORYPIC);
+
+      await tx.commit();
+
+      return {
+        id: categoryId,
+        fullHash,
+        thumbW: processed.thumb.w,
+        thumbH: processed.thumb.h,
+        thumbHash: processed.thumb.hash,
+      };
+    } catch (err) {
+      try {
+        await tx.rollback();
+      } catch {
+        // ignore
+      }
+      throw err;
+    }
+  };
+}

src/store/category/deleteImage.js

@@ -0,0 +1,26 @@
+import { DELETE_BY_CATEGORY } from '../../sql/categorypic.js';
+import resolveCategoryAccess from './resolveCategoryAccess.js';
+
+export default function deleteImage(pool) {
+  const access = resolveCategoryAccess(pool);
+
+  return async (googleAuthId, categoryId) => {
+    await access(googleAuthId, categoryId);
+
+    const result = await pool
+      .request()
+      .input('categoryId', categoryId)
+      .query(DELETE_BY_CATEGORY);
+
+    if (!result.rowsAffected[0]) {
+      throw new Error('Image not found');
+    }
+
+    return {
+      id: categoryId,
+      thumbW: null,
+      thumbH: null,
+      thumbHash: null,
+    };
+  };
+}