Add stdio server, mcploader and JSON-RPC extract

Introduce a StdioServer module and mcploader entry script, and extend jsonrpc2 with an extract() helper. stdio-server.js provides an EventTarget-based wrapper for reading/writing via WScript stdio. mcploader.js uses the server and JsonRpc2.extract to parse incoming JSON-RPC messages and respond. Also change DEFAULT_JSONRPC2_URL to http://localhost:5555, export the new extract function, and bump jsonrpc2 version to 0.1.6.
This commit is contained in:
Namhyeon, Go 2026-04-12 19:11:30 +09:00
parent e0e713d975
commit 4c48fdbb4d
3 changed files with 140 additions and 2 deletions

View File

@ -38,6 +38,55 @@ function JsonRpc2(url) {
} }
} }
function extract(message, callback) {
var data;
if (typeof callback !== "function") {
throw new Error("Invalid callback");
}
try {
data = JSON.parse(message);
} catch (e) {
throw new Error("Invalid JSON: " + e.message);
}
if (!data || typeof data !== "object") {
throw new Error("Invalid request object");
}
if (data.jsonrpc !== "2.0") {
throw new Error("Invalid JSON-RPC version");
}
if (!data.method || typeof data.method !== "string") {
throw new Error("Missing or invalid method");
}
var params = data.params !== undefined ? data.params : null;
var id = data.id !== undefined ? data.id : null;
try {
var result = callback(data.method, params, id);
return {
jsonrpc: "2.0",
result: result === undefined ? null : result,
id: id
};
} catch (e) {
return {
jsonrpc: "2.0",
error: {
code: -32603,
message: e && e.message ? e.message : "Internal error"
},
id: id
};
}
}
function wrap(method, params, id) { function wrap(method, params, id) {
return { return {
"jsonrpc": "2.0", "jsonrpc": "2.0",
@ -51,14 +100,15 @@ function create(url) {
return new JsonRpc2(url); return new JsonRpc2(url);
} }
var DEFAULT_JSONRPC2_URL = "https://azure-ashlan-40.tiiny.io/"; var DEFAULT_JSONRPC2_URL = "http://localhost:5555";
exports.extract = extract;
exports.wrap = wrap; exports.wrap = wrap;
exports.create = create; exports.create = create;
exports.DEFAULT_JSONRPC2_URL = DEFAULT_JSONRPC2_URL; exports.DEFAULT_JSONRPC2_URL = DEFAULT_JSONRPC2_URL;
exports.VERSIONINFO = "JSON-RPC 2.0 wrapper (jsonrpc2.js) version 0.1.5"; exports.VERSIONINFO = "JSON-RPC 2.0 wrapper (jsonrpc2.js) version 0.1.6";
exports.AUTHOR = "gnh1201@catswords.re.kr"; exports.AUTHOR = "gnh1201@catswords.re.kr";
exports.global = global; exports.global = global;
exports.require = global.require; exports.require = global.require;

58
lib/stdio-server.js Normal file
View File

@ -0,0 +1,58 @@
// stdio-server.js
// Copyright 2019-2026, Namhyeon Go <gnh1201@catswords.re.kr> and the WelsonJS contributors.
// SPDX-License-Identifier: GPL-3.0-or-later
// https://github.com/gnh1201/welsonjs
//
var STD = require("lib/std");
function StdioServer() {
// Set event-attachable object
STD.EventTarget.apply(this, arguments);
this.messages = [];
this.receive = function () {
return this.messages.shift();
};
this.send = function (message) {
WScript.StdOut.WriteLine(message);
};
this.listen = function () {
while (!WScript.StdIn.AtEndOfStream) {
this.messages.push(WScript.StdIn.ReadLine());
this.dispatchEvent(new STD.Event("message"));
}
};
}
StdioServer.prototype = new STD.EventTarget();
StdioServer.prototype.constructor = StdioServer;
/*
// For example
var server = new StdioServer();
server.addEventListener("message", function(e) {
// receive message
var message = e.target.receive();
console.log(message);
// send message
e.target.send("Hello world");
});
server.listen();
*/
exports.create = function () {
return new StdioServer();
};
exports.VERSIONINFO = "Stdio Server (stdio-server.js) version 0.1";
exports.AUTHOR = "gnh1201@catswords.re.kr";
exports.global = global;
exports.require = global.require;

30
mcploader.js Normal file
View File

@ -0,0 +1,30 @@
// mcploader.js
// Copyright 2019-2026, Namhyeon Go <gnh1201@catswords.re.kr> and the WelsonJS contributors.
// SPDX-License-Identifier: GPL-3.0-or-later
// https://github.com/gnh1201/welsonjs
//
var StdioServer = require("lib/stdio-server");
var JsonRpc2 = require("lib/jsonrpc2");
function main(args) {
var server = StdioServer.create();
server.addEventListener("message", function(e) {
var message = e.target.receive();
try {
JsonRpc2.extract(message, function(method, params, id) {
console.log("Received method: " + method);
});
} catch (e) {
console.log("Ignored");
}
// send message
e.target.send("Hello world");
});
server.listen();
}
exports.main = main;