code-gen: add file validator support

.eslintignore

@@ -2,3 +2,4 @@ packages/cli/template/*
 coverage
 packages/code-gen/test-generated
 lerna.json
+generated/testing/client/anonymous-validators.js

packages/code-gen/src/generator/validator.js

@@ -170,10 +170,13 @@ function generateValidatorsForGroup(context, imports, anonymousImports, group) {
                 {},
               )} | undefined, errors: ({ key: string, info: any }[])|undefined}}`;
             }
-            return js`*
-             @returns {
-                ${getTypeNameForType(context.context, data[name], "", {})}
-             }`;
+            return js`
+             * @returns {${getTypeNameForType(
+               context.context,
+               data[name],
+               "",
+               {},
+             )}}`;
           }}
           */
          export function validate${data[name].uniqueName}(value${withTypescript(
@@ -390,8 +393,7 @@ function anonymousValidatorForType(context, imports, type) {
     case "date":
       return anonymousValidatorDate(context, imports);
     case "file":
-      // TODO: Implement for possible locations
-      return `return value;`;
+      return anonymousValidatorFile(context);
     case "generic":
       return anonymousValidatorGeneric(context, imports, type);
     case "number":
@@ -640,6 +642,44 @@ function anonymousValidatorDate(context, imports) {
    `;
 }
 
+/**
+ * @param {ValidatorContext} context
+ * @returns {string}
+ */
+function anonymousValidatorFile(context) {
+  if (context.context.options.isBrowser) {
+    return js`
+         // Blob result from api client
+         if (value instanceof Blob) {
+           return value;
+         }
+         // Blob input as post argument
+         if (value && value.blob instanceof Blob) {
+           return value;
+         }
+
+         ${buildError("unknown", "{ propertyPath }")}
+      `;
+  }
+
+  return js`
+      // ReadableStream input to api call
+      if (typeof value.data?.pipe === "function" && typeof value.data?._read === "function") {
+         return value;
+      }
+      // ReadableStream as output of an api call
+      if (typeof value?.pipe === "function" && typeof value?._read === "function") {
+         return value;
+      }
+      // Object as parsed by the file body parsers
+      if (typeof value?.path === "string" && typeof value?.size === "number") {
+         return value;
+      }
+
+      ${buildError("unknown", "{ propertyPath }")}
+  `;
+}
+
 /**
  * @param {ValidatorContext} context
  * @param {ImportCreator} imports

packages/code-gen/test/e2e-server.test.js

@@ -1,3 +1,4 @@
+import { createReadStream } from "fs";
 import { mainTestFn, test } from "@compas/cli";
 import {
   closeTestApp,
@@ -131,6 +132,17 @@ test("code-gen/e2e-server", async (t) => {
     },
   );
 
+  t.test("server - serverside validator of file is ok", async (t) => {
+    const { success } = await server.serverApi.setFile({
+      myFile: {
+        name: "foo.json",
+        data: createReadStream("./__fixtures__/code-gen/openapi.json"),
+      },
+    });
+
+    t.ok(success);
+  });
+
   t.test("server - router - tags are available", (t) => {
     t.deepEqual(server.serverTags.getId, ["tag"]);
     t.deepEqual(server.serverTags.create, []);
@@ -204,5 +216,13 @@ async function buildTestApp() {
     return next();
   };
 
+  server.serverHandlers.setFile = (ctx, next) => {
+    ctx.body = {
+      success: true,
+    };
+
+    return next();
+  };
+
   return app;
 }