Merge pull request #17 from devforth/add-zod-schemas

Add zod schemas

Author: yaroslav8765

index.ts

@@ -1,7 +1,25 @@
-import AdminForth, { AdminForthPlugin, Filters, suggestIfTypo, AdminForthDataTypes, RAMLock, filtersTools, AdminForthFilterOperators } from "adminforth";
+import AdminForth, { AdminForthPlugin, parseBody, Filters, suggestIfTypo, AdminForthDataTypes, RAMLock, filtersTools, AdminForthFilterOperators } from "adminforth";
 import type { IAdminForth, IHttpServer, AdminForthComponentDeclaration, AdminForthResourceColumn, AdminForthResource, BeforeLoginConfirmationFunction, AdminForthConfigMenuItem, AdminUser } from "adminforth";
 import type { PluginOptions, SupportedLanguage } from './types.js';
+import { z } from "zod";
 import iso6391 from 'iso-639-1';
+
+const updateFieldBodySchema = z.object({
+  resourceId: z.string(),
+  recordId: z.union([z.string(), z.number()]),
+  field: z.string(),
+  value: z.unknown(),
+  reviewed: z.boolean().nullish(),
+}).strict();
+
+const translateSelectedBodySchema = z.object({
+  selectedLanguages: z.array(z.string()).optional(),
+  selectedIds: z.array(z.union([z.string(), z.number()])),
+}).strict();
+
+const getFilteredIdsBodySchema = z.object({
+  filters: z.any(),
+}).passthrough();
 import { iso31661Alpha2ToAlpha3 } from 'iso-3166';
 import path from 'path';
 import fs from 'fs-extra';
@@ -1252,8 +1270,11 @@ export default class I18nPlugin extends AdminForthPlugin {
     server.endpoint({
       method: 'POST',
       path: `/plugin/${this.pluginInstanceId}/update-field`,
-      handler: async ({ body, adminUser, headers }) => {
-        const { resourceId, recordId, field, value, reviewed } = body;
+      handler: async ({ body, adminUser, headers, response }) => {
+        const parsed = parseBody(updateFieldBodySchema, body, response);
+        if ('error' in parsed) return parsed.error;
+        const data = parsed.data;
+        const { resourceId, recordId, field, value, reviewed } = data;
         if (resourceId !== this.resourceConfig.resourceId) {
           return { error: 'Invalid resourceId' };
         }
@@ -1274,7 +1295,7 @@ export default class I18nPlugin extends AdminForthPlugin {
         let result;
         await lock.run(`edit-trans-${recordId}`,  async () => {
           // put into lock so 2 editors will not update the same record at the same time
-          oldRecord = await connector.getRecordByPrimaryKey(resource, recordId)
+          oldRecord = await connector.getRecordByPrimaryKey(resource, recordId as string)
 
           if (!oldRecord) {
             result = { error: 'Record not found' };
@@ -1305,7 +1326,7 @@ export default class I18nPlugin extends AdminForthPlugin {
           return { error: result.error };
         }
 
-        const updatedRecord = await connector.getRecordByPrimaryKey(resource, recordId);
+        const updatedRecord = await connector.getRecordByPrimaryKey(resource, recordId as string);
 
         return { record: updatedRecord };
       }
@@ -1315,15 +1336,22 @@ export default class I18nPlugin extends AdminForthPlugin {
       method: 'POST',
       path: `/plugin/${this.pluginInstanceId}/translate-selected-to-languages`,
       noAuth: false,
-      handler: async ({ body, tr, adminUser }) => {
-        const selectedLanguages = body.selectedLanguages;
-        const selectedIds = body.selectedIds;
+      handler: async ({ body, tr, adminUser, response }) => {
+        const parsed = parseBody(translateSelectedBodySchema, body, response);
+        if ('error' in parsed) return parsed.error;
+        const data = parsed.data;
+        const selectedLanguages = data.selectedLanguages;
+        const selectedIds = data.selectedIds;
 
         if (!Array.isArray(selectedIds) || selectedIds.length === 0) {
           return { ok: false, error: 'No records selected' };
         }
 
-        const jobId = await this.bulkTranslate({ selectedIds, selectedLanguages, adminUser });
+        const jobId = await this.bulkTranslate({
+          selectedIds: selectedIds as string[],
+          selectedLanguages: selectedLanguages as SupportedLanguage[] | undefined,
+          adminUser,
+        });
 
         return { 
           ok: true, 
@@ -1335,7 +1363,10 @@ export default class I18nPlugin extends AdminForthPlugin {
     server.endpoint({
       method: 'POST',
       path: `/plugin/${this.pluginInstanceId}/get_filtered_ids`,
-      handler: async ({ body, adminUser, headers, query, cookies, requestUrl }) => {
+      handler: async ({ body, adminUser, headers, query, cookies, requestUrl, response }) => {
+        const parsed = parseBody(getFilteredIdsBodySchema, body, response);
+        if ('error' in parsed) return parsed.error;
+        const data = parsed.data;
         const resource = this.resourceConfig;
 
         for (const hook of resource.hooks?.list?.beforeDatasourceRequest || []) {

package.json

@@ -35,14 +35,15 @@
     "fs-extra": "^11.3.2",
     "iso-3166": "^4.3.0",
     "iso-639-1": "^3.1.3",
-    "p-limit": "^7.3.0"
+    "p-limit": "^7.3.0",
+    "zod": "^4.3.6"
   },
   "peerDependencies": {
-    "adminforth": "^3.6.21"
+    "adminforth": "^3.7.1"
   },
   "devDependencies": {
     "@types/node": "^22.10.7",
-    "adminforth": "^3.6.21",
+    "adminforth": "^3.7.1",
     "i18n-iso-countries": "^7.13.0",
     "semantic-release": "^24.2.1",
     "semantic-release-slack-bot": "^4.0.2",