feat(rpc): adds RPC schemas validation

packages/rpc/package.json

@@ -74,7 +74,8 @@
     "typescript": "^3.6.4"
   },
   "dependencies": {
-    "@karmic/core": "0.0.0"
+    "@karmic/core": "0.0.0",
+    "ajv": "^6.10.2"
   },
   "peerDependencies": {
     "rxjs": "6.x"

packages/rpc/src/index.ts

@@ -1,3 +1,2 @@
-export default function main(): null {
-  return null;
-}
+export * from './validate';
+export * from './types';

packages/rpc/src/validate/index.ts

@@ -0,0 +1,23 @@
+import Ajv from 'ajv';
+import draft04 from 'ajv/lib/refs/json-schema-draft-04.json';
+import { notification, request, response } from './schemas';
+import { RPCSpecNotification, RPCSpecRequest, RPCSpecResponse } from '~/types';
+
+const ajv = new Ajv({ schemaId: 'id', logger: false });
+ajv.addMetaSchema(draft04);
+
+const validateNotification = ajv.compile(notification);
+const validateRequest = ajv.compile(request);
+const validateResponse = ajv.compile(response);
+
+export const validate = {
+  notification(data: object): data is RPCSpecNotification {
+    return validateNotification(data) as boolean;
+  },
+  request(data: object): data is RPCSpecRequest {
+    return validateRequest(data) as boolean;
+  },
+  response(data: object): data is RPCSpecResponse {
+    return validateResponse(data) as boolean;
+  }
+};

packages/rpc/src/validate/schemas.ts

@@ -0,0 +1,61 @@
+import { Schema } from '@karmic/core';
+
+export const id: Schema = {
+  anyOf: [{ type: 'number' }, { type: 'string' }, { type: 'null' }]
+};
+
+export const notification: Schema = {
+  type: 'object',
+  required: ['jsonrpc', 'method'],
+  properties: {
+    jsonrpc: { type: 'string', enum: ['2.0'] },
+    method: { type: 'string' },
+    params: { anyOf: [{ type: 'array' }, { type: 'object' }] }
+  },
+  not: { required: ['id'] }
+};
+
+export const request: Schema = {
+  type: 'object',
+  required: ['jsonrpc', 'id', 'method'],
+  properties: {
+    jsonrpc: { type: 'string', enum: ['2.0'] },
+    id,
+    method: { type: 'string' },
+    params: { anyOf: [{ type: 'array' }, { type: 'object' }] }
+  }
+};
+
+export const response: Schema = {
+  definitions: {
+    success: {
+      type: 'object',
+      required: ['jsonrpc', 'id', 'result'],
+      properties: {
+        jsonrpc: { type: 'string', enum: ['2.0'] },
+        id: id,
+        result: {},
+        error: { not: {} }
+      }
+    },
+    error: {
+      type: 'object',
+      required: ['jsonrpc', 'id', 'error'],
+      properties: {
+        jsonrpc: { type: 'string', enum: ['2.0'] },
+        id,
+        result: { not: {} },
+        error: {
+          type: 'object',
+          required: ['code', 'message'],
+          properties: {
+            code: { type: 'number' },
+            message: { type: 'string' },
+            data: {}
+          }
+        }
+      }
+    }
+  },
+  anyOf: [{ $ref: '#/definitions/success' }, { $ref: '#/definitions/error' }]
+};