Mercurial Hosting > luan
annotate src/luan/modules/Rpc.luan @ 1205:8f14426f8ada
change cipher_suite
author | Franklin Schmidt <fschmidt@gmail.com> |
---|---|
date | Tue, 06 Mar 2018 20:15:02 -0700 |
parents | 5d0cbd908582 |
children | 6dfaf4e9ce71 |
rev | line source |
---|---|
610
b4f3dbe1c6e3
add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
1 java() |
1204
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
2 local Socket = require "java:java.net.Socket" |
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
3 local ServerSocket = require "java:java.net.ServerSocket" |
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
4 local SSLSocketFactory = require "java:javax.net.ssl.SSLSocketFactory" |
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
5 local SSLServerSocketFactory = require "java:javax.net.ssl.SSLServerSocketFactory" |
1120
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
6 local RpcClient = require "java:luan.lib.rpc.RpcClient" |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
7 local RpcServer = require "java:luan.lib.rpc.RpcServer" |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
8 local RpcCall = require "java:luan.lib.rpc.RpcCall" |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
9 local RpcResult = require "java:luan.lib.rpc.RpcResult" |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
10 local RpcException = require "java:luan.lib.rpc.RpcException" |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
11 local JavaRpc = require "java:luan.lib.rpc.Rpc" |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
12 local JavaLuan = require "java:luan.Luan" |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
13 local JavaUtils = require "java:luan.modules.Utils" |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
14 local IoLuan = require "java:luan.modules.IoLuan" |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
15 local ByteArrayInputStream = require "java:java.io.ByteArrayInputStream" |
693
ca169567ce07
module URIs must now include ".luan"
Franklin Schmidt <fschmidt@gmail.com>
parents:
610
diff
changeset
|
16 local Luan = require "luan:Luan.luan" |
610
b4f3dbe1c6e3
add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
17 local error = Luan.error |
b4f3dbe1c6e3
add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
18 local set_metatable = Luan.set_metatable or error() |
762
3f461f85243d
better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents:
743
diff
changeset
|
19 local try = Luan.try or error() |
1120
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
20 local ipairs = Luan.ipairs or error() |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
21 local type = Luan.type or error() |
693
ca169567ce07
module URIs must now include ".luan"
Franklin Schmidt <fschmidt@gmail.com>
parents:
610
diff
changeset
|
22 local Io = require "luan:Io.luan" |
ca169567ce07
module URIs must now include ".luan"
Franklin Schmidt <fschmidt@gmail.com>
parents:
610
diff
changeset
|
23 local Thread = require "luan:Thread.luan" |
1120
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
24 local Table = require "luan:Table.luan" |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
25 local unpack = Table.unpack or error() |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
26 local Logging = require "luan:logging/Logging.luan" |
762
3f461f85243d
better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents:
743
diff
changeset
|
27 local logger = Logging.logger "Rpc" |
610
b4f3dbe1c6e3
add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
28 |
b4f3dbe1c6e3
add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
29 |
1088
bae2d0c2576c
change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents:
775
diff
changeset
|
30 local Rpc = {} |
610
b4f3dbe1c6e3
add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
31 |
1088
bae2d0c2576c
change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents:
775
diff
changeset
|
32 Rpc.port = 9101 |
743
2c41f2aec92f
improve Rpc and implement rpc call for local webserver
Franklin Schmidt <fschmidt@gmail.com>
parents:
693
diff
changeset
|
33 |
1205 | 34 Rpc.cipher_suite = "SSL_DH_anon_WITH_DES_CBC_SHA" |
1204
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
35 |
1120
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
36 local function java_args(list) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
37 for i,v in ipairs(list) do |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
38 list[i] = JavaLuan.toJava(v) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
39 end |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
40 return unpack(list) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
41 end |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
42 |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
43 local function luan_args(list,binary_in) |
1164 | 44 list = JavaLuan.table(list) |
1120
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
45 for i,v in ipairs(list) do |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
46 list[i] = JavaLuan.toLuan(v) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
47 end |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
48 if binary_in ~= nil then |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
49 local i_in = list[#list] |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
50 list[#list] = nil |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
51 local type = list[i_in] |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
52 if type == "binary" then |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
53 list[i_in] = JavaUtils.readAll(binary_in) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
54 elseif type == "input" then |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
55 list[i_in] = IoLuan.LuanInput.new(binary_in).table() |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
56 else |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
57 error(type) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
58 end |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
59 end |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
60 return unpack(list) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
61 end |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
62 |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
63 local function encode_binary(args) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
64 local binary_in, len_in, i_in |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
65 for i,v in ipairs(args) do |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
66 if type(v) == "binary" then |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
67 binary_in==nil or error "can't have multiple binary args" |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
68 i_in = i |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
69 binary_in = ByteArrayInputStream.new(v) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
70 len_in = #v |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
71 args[i] = "binary" |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
72 elseif type(v) == "table" and v.java ~= nil and v.java.instanceof(IoLuan.LuanFile) then |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
73 binary_in==nil or error "can't have multiple binary args" |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
74 i_in = i |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
75 binary_in = v.java.inputStream() |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
76 len_in = v.length() |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
77 args[i] = "input" |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
78 end |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
79 end |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
80 args[#args+1] = i_in |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
81 return binary_in, len_in |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
82 end |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
83 |
1204
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
84 local function rpc_caller(socket) |
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
85 local client = RpcClient.new(socket) |
1120
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
86 return function(fn_name,...) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
87 local args = {...} |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
88 local binary_in, len_in = encode_binary(args) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
89 local call |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
90 if binary_in == nil then |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
91 call = RpcCall.new(fn_name,java_args(args)) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
92 else |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
93 call = RpcCall.new(binary_in,len_in,fn_name,java_args(args)) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
94 end |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
95 client.write(call) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
96 if fn_name == "close" then |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
97 client.close() |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
98 return |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
99 end |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
100 return try { |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
101 function() |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
102 local result = client.read() |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
103 return luan_args(result.returnValues,result["in"]) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
104 end |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
105 catch = function(e) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
106 local cause = e.java.getCause() |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
107 if cause ~= nil and cause.instanceof(RpcException) and cause.getMessage() == "luan" then |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
108 error(cause.values.get(0)) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
109 else |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
110 e.throw() |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
111 end |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
112 end |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
113 } |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
114 end_function |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
115 end_function |
743
2c41f2aec92f
improve Rpc and implement rpc call for local webserver
Franklin Schmidt <fschmidt@gmail.com>
parents:
693
diff
changeset
|
116 |
1088
bae2d0c2576c
change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents:
775
diff
changeset
|
117 Rpc.functions = {} |
610
b4f3dbe1c6e3
add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
118 |
1204
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
119 local function rpc_responder(socket,fns) |
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
120 local server = RpcServer.new(socket) |
1120
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
121 local responder = {} |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
122 function responder.is_closed() |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
123 return server.isClosed() |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
124 end_function |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
125 function responder.respond() |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
126 local call = server.read() |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
127 if call==nil then return end |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
128 local cmd = call.cmd |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
129 if cmd == "close" then |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
130 server.close() |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
131 return |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
132 end_if |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
133 local fn = fns[cmd] |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
134 if fn == nil then |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
135 server.write(JavaRpc.COMMAND_NOT_FOUND) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
136 return |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
137 end_if |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
138 local rtn = try { |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
139 function() |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
140 return {fn(luan_args(call.args,call["in"]))} |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
141 end |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
142 catch = function(e) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
143 logger.warn(e) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
144 local ex = RpcException.new("luan",e.get_message()) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
145 server.write(ex) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
146 return nil |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
147 end |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
148 } |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
149 if rtn==nil then return end |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
150 local binary_in, len_in = encode_binary(rtn) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
151 local result |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
152 if binary_in == nil then |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
153 result = RpcResult.new(java_args(rtn)) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
154 else |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
155 result = RpcResult.new(binary_in,len_in,java_args(rtn)) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
156 end |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
157 server.write(result) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
158 end |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
159 return responder |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
160 end_function |
743
2c41f2aec92f
improve Rpc and implement rpc call for local webserver
Franklin Schmidt <fschmidt@gmail.com>
parents:
693
diff
changeset
|
161 |
1204
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
162 function Rpc.remote(domain) |
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
163 local socket |
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
164 if Rpc.cipher_suite == nil then |
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
165 socket = Socket.new(domain,Rpc.port) |
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
166 else |
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
167 socket = SSLSocketFactory.getDefault().createSocket(domain,Rpc.port) |
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
168 socket.setEnabledCipherSuites{Rpc.cipher_suite} |
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
169 end |
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
170 local call = rpc_caller(socket) |
610
b4f3dbe1c6e3
add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
171 local mt = {} |
b4f3dbe1c6e3
add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
172 function mt.__index(_,key) |
b4f3dbe1c6e3
add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
173 return function(...) |
1120
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
174 return call(key,...) |
610
b4f3dbe1c6e3
add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
175 end |
b4f3dbe1c6e3
add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
176 end |
b4f3dbe1c6e3
add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
177 local t = {} |
b4f3dbe1c6e3
add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
178 set_metatable(t,mt) |
b4f3dbe1c6e3
add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
179 return t |
1120
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
180 end_function |
610
b4f3dbe1c6e3
add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
181 |
1088
bae2d0c2576c
change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents:
775
diff
changeset
|
182 function Rpc.serve(port,fns) |
1204
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
183 port = port or Rpc.port |
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
184 fns = fns or Rpc.functions |
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
185 local socket_server |
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
186 if Rpc.cipher_suite == nil then |
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
187 socket_server = ServerSocket.new(port) |
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
188 else |
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
189 socket_server = SSLServerSocketFactory.getDefault().createServerSocket(port) |
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
190 socket_server.setEnabledCipherSuites{Rpc.cipher_suite} |
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
191 end |
762
3f461f85243d
better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents:
743
diff
changeset
|
192 while true do |
3f461f85243d
better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents:
743
diff
changeset
|
193 try { |
3f461f85243d
better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents:
743
diff
changeset
|
194 function() |
1204
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
195 local socket = socket_server.accept() |
1120
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
196 local function server() |
762
3f461f85243d
better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents:
743
diff
changeset
|
197 try { |
3f461f85243d
better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents:
743
diff
changeset
|
198 function() |
1204
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
199 local responder = rpc_responder(socket,fns) |
1120
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
200 while not responder.is_closed() do |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
201 responder.respond() |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
202 end |
762
3f461f85243d
better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents:
743
diff
changeset
|
203 end |
3f461f85243d
better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents:
743
diff
changeset
|
204 catch = function(e) |
3f461f85243d
better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents:
743
diff
changeset
|
205 logger.error(e) |
3f461f85243d
better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents:
743
diff
changeset
|
206 end |
3f461f85243d
better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents:
743
diff
changeset
|
207 } |
3f461f85243d
better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents:
743
diff
changeset
|
208 end |
1120
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
209 Thread.fork(server) |
762
3f461f85243d
better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents:
743
diff
changeset
|
210 end |
3f461f85243d
better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents:
743
diff
changeset
|
211 catch = function(e) |
3f461f85243d
better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents:
743
diff
changeset
|
212 logger.error(e) |
3f461f85243d
better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents:
743
diff
changeset
|
213 end |
3f461f85243d
better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents:
743
diff
changeset
|
214 } |
1120
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
215 end_while |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
216 end_function |
743
2c41f2aec92f
improve Rpc and implement rpc call for local webserver
Franklin Schmidt <fschmidt@gmail.com>
parents:
693
diff
changeset
|
217 |
1088
bae2d0c2576c
change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents:
775
diff
changeset
|
218 return Rpc |