41 lines
1.2 KiB
TypeScript
41 lines
1.2 KiB
TypeScript
|
// json-rpc-engine
|
|||
|
|
// rpc-websockets
|
|||
|
|
import { Server as RpcWebsocketServer } from 'rpc-websockets'
|
|||
|
|
import { isFinite } from 'underscore'
|
|||
|
|
import { event } from '../event'
|
|||
|
|
import SysConf from '../utils/sys_conf'
|
|||
|
|
|
|||
|
|
// const rpc_token = SysConf.get('WS_JSON_RPC_SERVER_TOKEN')
|
|||
|
|
|
|||
|
|
// if(!rpc_token) {
|
|||
|
|
// throw new Error('缺少参数WS_JSON_RPC_SERVER_TOKEN')
|
|||
|
|
// }
|
|||
|
|
|
|||
|
|
function register (server:RpcWebsocketServer) {
|
|||
|
|
|
|||
|
|
server.setAuth(params=>params.token === SysConf.get('WS_JSON_RPC_SERVER_TOKEN'))
|
|||
|
|
|
|||
|
|
// server.register('snowflake',()=>snowflake.create().toString(10)).protected()
|
|||
|
|
|
|||
|
|
// server.register('shortid',()=>shortid.create().toString(10)).protected()
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
const host = process.env.WS_JSON_RPC_SERVER_HOST || '0.0.0.0'
|
|||
|
|
|
|||
|
|
const port = process.env.WS_JSON_RPC_SERVER_PORT || ''
|
|||
|
|
|
|||
|
|
if(!isFinite(port)) {
|
|||
|
|
throw new Error('缺少参数：json-rpc服务端口 [WS_JSON_RPC_SERVER_PORT]')
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// {"method":"shortid","id":"abcd","jsonrpc":"2.0"}
|
|||
|
|
// {"method":"rpc.login","id":"abcde","jsonrpc":"2.0","params":{"token":"zcj"}}
|
|||
|
|
|
|||
|
|
event.on('http-server-started',function () {
|
|||
|
|
const server = new RpcWebsocketServer({ port,host })
|
|||
|
|
|
|||
|
|
register(server)
|
|||
|
|
|
|||
|
|
console.log(`启动json-rpc服务，正在监听${host}:${port}`)
|
|||
|
|
})
|