feat(core): dev schema

packages/core/package.json

@@ -60,6 +60,7 @@
     "@dfinity/candid": "^2.3.0",
     "@dfinity/identity": "^2.3.0",
     "@dfinity/principal": "^2.3.0",
-    "@dfinity/utils": "^2"
+    "@dfinity/utils": "^2",
+    "@standard-schema/spec": "^1.0.0"
   }
 }

packages/core/src/types/doc-data.ts

@@ -0,0 +1 @@
+export type DocDataSchema = {}

packages/core/src/types/errors.ts

@@ -1,7 +1,19 @@
+import {StandardSchemaV1} from '@standard-schema/spec';
+
 export class SignInError extends Error {}
 export class SignInInitError extends Error {}
 export class SignInUserInterruptError extends Error {}
 
 export class InitError extends Error {}
 
 export class ListError extends Error {}
+
+export class SchemaError extends Error {
+  readonly issues: ReadonlyArray<StandardSchemaV1.Issue>;
+
+  constructor(issues: ReadonlyArray<StandardSchemaV1.Issue>) {
+    super(issues[0]?.message);
+
+    this.issues = issues;
+  }
+}

packages/core/src/utils/schema.utils.ts

@@ -0,0 +1,44 @@
+import {nonNullish} from '@dfinity/utils';
+import type {StandardSchemaV1} from '@standard-schema/spec';
+import {SchemaError} from '../types/errors';
+
+export const assertDataSchema = async <T extends StandardSchemaV1>({
+  input,
+  schema
+}: {
+  input: StandardSchemaV1.InferInput<T>;
+  schema?: T;
+}): Promise<void> => {
+  const withSchema =
+    nonNullish(schema) && nonNullish(schema['~standard']) && 'validate' in schema['~standard'];
+
+  if (withSchema) {
+    await validateSchema({input, schema});
+  }
+};
+
+const validateSchema = async <T extends StandardSchemaV1>({
+  input,
+  schema
+}: {
+  input: StandardSchemaV1.InferInput<T>;
+  schema: T;
+}): Promise<StandardSchemaV1.InferOutput<T>> => {
+  const validate = async (): Promise<StandardSchemaV1.Result<unknown>> => {
+    const result = schema['~standard'].validate(input);
+
+    if (result instanceof Promise) {
+      return await result;
+    }
+
+    return result;
+  };
+
+  const {issues, ...value} = await validate();
+
+  if (issues !== undefined) {
+    throw new SchemaError(issues);
+  }
+
+  return value;
+};