Skip to main content
Module

x/enzastdlib/rpc-http/mod.ts>makeHTTPServer

enzastdlib is a set of TypeScript modules that follow a common design API philosophy aiming at sane defaults and ease-of-use targeting the Deno TypeScript runtime.
Latest
function makeHTTPServer
import { makeHTTPServer } from "https://deno.land/x/enzastdlib@v0.0.4/rpc-http/mod.ts";

Makes a HTTP server that can respond to clients in enzastdlib's RPC protocol.

Examples

add.schema.ts

import type { JSONSchema, typeofschema } from 'https://deno.land/x/enzastdlib/schema/mod.ts';

export const SCHEMA_ADD_PARAMETERS = {
    type: 'object',
    required: ['a', 'b'],

    additionalProperties: false,

    properties: {
        a: {
            type: 'number',
        },

        b: {
            type: 'number',
        },
    },
} as const satisfies JSONSchema;

export type AddParametersType = typeofschema<typeof SCHEMA_ADD_PARAMETERS>;

export const SCHEMA_ADD_RETURN = {
    type: 'object',
    required: ['sum'],

    additionalProperties: false,

    properties: {
        sum: {
            type: 'number',
        },
    },
} as const satisfies JSONSchema;

export type AddReturnType = typeofschema<typeof SCHEMA_ADD_RETURN>;

add.procedure.ts

import type { Procedure } from 'https://deno.land/x/enzastdlib/rpc-protocol/mod.ts';
import { parametersschema, resultschema } from 'https://deno.land/x/enzastdlib/rpc-protocol/mod.ts';

import type { AddParametersType, AddReturnType } from './add.schema.ts';
import { SCHEMA_ADD_PARAMETERS, SCHEMA_ADD_RETURN } from './add.schema.ts';

parametersschema(add, SCHEMA_ADD_PARAMETERS);
resultschema(add, SCHEMA_ADD_RETURN);
export function add(
    _payload: Procedure,
    parameters: AddParametersType,
): AddReturnType {
    const { a, b } = parameters;

    return {
        sum: a + b,
    };
}

mod.ts

import { makeHTTPServer } from 'https://deno.land/x/enzastdlib/rpc-http/mod.ts';

import { add } from './add.procedure.ts';

const server = makeHTTPServer({
    http: {
        hostname: '127.0.0.1',
        port: 8080,
    },

    procedures: {
        add,
    },
});

server.serve();