feat(rpc/server): adds server types and defaults

packages/rpc/src/index.ts

@@ -1,2 +1,3 @@
+export * from './server';
 export * from './validate';
 export * from './types';

packages/rpc/src/server/defaults.ts

@@ -0,0 +1,16 @@
+import { RPCServerOptions } from './types';
+import { DataOutput, DataInput } from '~/types';
+
+export function createDefaults(): Required<Omit<RPCServerOptions, 'default'>> {
+  return {
+    children: true,
+    parser: {
+      serialize(data: object): DataOutput {
+        return JSON.stringify(data);
+      },
+      deserialize(data: DataInput): object {
+        return JSON.parse(String(data));
+      }
+    }
+  };
+}

packages/rpc/src/server/index.ts

@@ -0,0 +1 @@
+export * from './types';

packages/rpc/src/server/types.ts

@@ -0,0 +1,31 @@
+import { QueryServiceImplementation } from '@karmic/core';
+import { DataOutput, DataInput, DataParser } from '~/types';
+
+export interface RPCServerOptions {
+  /**
+   * Whether to create routes for type's children services.
+   * Default: `true`.
+   */
+  children?: boolean;
+  /**
+   * Serializer and deserializer
+   */
+  parser?: DataParser;
+  /**
+   * A default service for adapters to use when the route is non existent.
+   * Defaults to a `ClientNotFound` error throwing service.
+   */
+  default?: QueryServiceImplementation;
+}
+
+export interface RPCServerConnect {
+  send: (data: DataOutput) => void | Promise<void>;
+  fatal: (error: Error) => void;
+}
+
+export type RPCServerProvideContext<T = any> = () => Promise<T> | T;
+
+export interface RPCServerConnection {
+  request: (data: DataInput) => void;
+  close: () => void;
+}