1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
|
import { serve } from "https://deno.land/std@0.192.0/http/server.ts";
import "../../util/string.ts";
import RawCore from "../raw/api.ts";
import { ConnectionProps, ConnectionPropsDefault } from "./props.ts";
import { CoreRequest, CoreRequestParseSentence, CoreResponseParseSentence } from "./types.ts";
export default class RemoteCoreServer extends RawCore {
private props: ConnectionProps;
private handlers: Record<string, (req: CoreRequest) => Promise<Response>> = {
parseSentence: async _req => {
var req = _req as CoreRequestParseSentence;
var input = req.options?.input
var options = req.options?.options;
if (!input) return new Response("", { status: 404 });
return new Response(JSON.stringify({
command: "parseSentence",
response: await this.parseSentence(input, options),
} as CoreResponseParseSentence));
},
};
constructor(options?: ConnectionProps) {
super();
this.props = { ...ConnectionPropsDefault, ...options };
}
async start() {
serve(async (req) => {
if (req.method != "POST") return new Response("", { status: 400 }); // wrong request (not post)
var request = (await req.text()).json({}) as CoreRequest;
if (!request.command) return new Response("", { status: 400 }); // wrong request (no command)
var handler = this.handlers[request.command];
if (!handler) return new Response("", { status: 404 }); // not found (unknown command)
return await handler(request);
}, {
port: this.props.port,
onListen: () => { }
});
}
}
|