Mercurial Hosting > luan
annotate src/luan/modules/Rpc.luan @ 1754:d179810c6148
add url get_content_type
author | Franklin Schmidt <fschmidt@gmail.com> |
---|---|
date | Sat, 04 Feb 2023 22:53:05 -0700 |
parents | a9ff30fb5d89 |
children | 8df0b80e715e |
rev | line source |
---|---|
1353
8d95711f6615
replace java() with require "java"
Franklin Schmidt <fschmidt@gmail.com>
parents:
1280
diff
changeset
|
1 require "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" |
1506
d80395468b4e
ssl security in code
Franklin Schmidt <fschmidt@gmail.com>
parents:
1408
diff
changeset
|
4 local IoUtils = require "java:goodjava.io.IoUtils" |
1402
27efb1fcbcb5
move luan.lib to goodjava
Franklin Schmidt <fschmidt@gmail.com>
parents:
1381
diff
changeset
|
5 local RpcClient = require "java:goodjava.rpc.RpcClient" |
27efb1fcbcb5
move luan.lib to goodjava
Franklin Schmidt <fschmidt@gmail.com>
parents:
1381
diff
changeset
|
6 local RpcServer = require "java:goodjava.rpc.RpcServer" |
27efb1fcbcb5
move luan.lib to goodjava
Franklin Schmidt <fschmidt@gmail.com>
parents:
1381
diff
changeset
|
7 local RpcCall = require "java:goodjava.rpc.RpcCall" |
27efb1fcbcb5
move luan.lib to goodjava
Franklin Schmidt <fschmidt@gmail.com>
parents:
1381
diff
changeset
|
8 local RpcResult = require "java:goodjava.rpc.RpcResult" |
27efb1fcbcb5
move luan.lib to goodjava
Franklin Schmidt <fschmidt@gmail.com>
parents:
1381
diff
changeset
|
9 local RpcException = require "java:goodjava.rpc.RpcException" |
27efb1fcbcb5
move luan.lib to goodjava
Franklin Schmidt <fschmidt@gmail.com>
parents:
1381
diff
changeset
|
10 local JavaRpc = require "java:goodjava.rpc.Rpc" |
1259
e8020216dee7
add Luan.to_luan and fix multipart/form-data
Franklin Schmidt <fschmidt@gmail.com>
parents:
1236
diff
changeset
|
11 local LuanJava = require "java:luan.Luan" |
1120
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
12 local JavaUtils = require "java:luan.modules.Utils" |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
13 local IoLuan = require "java:luan.modules.IoLuan" |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
14 local ByteArrayInputStream = require "java:java.io.ByteArrayInputStream" |
693
ca169567ce07
module URIs must now include ".luan"
Franklin Schmidt <fschmidt@gmail.com>
parents:
610
diff
changeset
|
15 local Luan = require "luan:Luan.luan" |
610
b4f3dbe1c6e3
add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
16 local error = Luan.error |
b4f3dbe1c6e3
add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
17 local set_metatable = Luan.set_metatable or error() |
1120
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
18 local ipairs = Luan.ipairs or error() |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
19 local type = Luan.type or error() |
1280 | 20 local Boot = require "luan:Boot.luan" |
693
ca169567ce07
module URIs must now include ".luan"
Franklin Schmidt <fschmidt@gmail.com>
parents:
610
diff
changeset
|
21 local Io = require "luan:Io.luan" |
ca169567ce07
module URIs must now include ".luan"
Franklin Schmidt <fschmidt@gmail.com>
parents:
610
diff
changeset
|
22 local Thread = require "luan:Thread.luan" |
1120
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
23 local Table = require "luan:Table.luan" |
1261
198d6af7330a
rename Luan.to_table to Table.java_to_table_shallow and Luan.to_luan to Table.java_to_table_deep
Franklin Schmidt <fschmidt@gmail.com>
parents:
1260
diff
changeset
|
24 local java_to_table_deep = Table.java_to_table_deep or error() |
1120
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
25 local unpack = Table.unpack or error() |
1381
8d7a39ca2c0c
add Rpc in_backup_read_lock
Franklin Schmidt <fschmidt@gmail.com>
parents:
1380
diff
changeset
|
26 local ThreadLuan = require "java:luan.modules.ThreadLuan" |
1120
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
27 local Logging = require "luan:logging/Logging.luan" |
762
3f461f85243d
better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents:
743
diff
changeset
|
28 local logger = Logging.logger "Rpc" |
610
b4f3dbe1c6e3
add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
29 |
b4f3dbe1c6e3
add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
30 |
1088
bae2d0c2576c
change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents:
775
diff
changeset
|
31 local Rpc = {} |
610
b4f3dbe1c6e3
add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
32 |
1088
bae2d0c2576c
change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents:
775
diff
changeset
|
33 Rpc.port = 9101 |
743
2c41f2aec92f
improve Rpc and implement rpc call for local webserver
Franklin Schmidt <fschmidt@gmail.com>
parents:
693
diff
changeset
|
34 |
1206
6dfaf4e9ce71
use many anonymous cipher_suites
Franklin Schmidt <fschmidt@gmail.com>
parents:
1205
diff
changeset
|
35 Rpc.cipher_suites = { |
6dfaf4e9ce71
use many anonymous cipher_suites
Franklin Schmidt <fschmidt@gmail.com>
parents:
1205
diff
changeset
|
36 "TLS_DH_anon_WITH_AES_128_GCM_SHA256" |
6dfaf4e9ce71
use many anonymous cipher_suites
Franklin Schmidt <fschmidt@gmail.com>
parents:
1205
diff
changeset
|
37 "TLS_DH_anon_WITH_AES_128_CBC_SHA256" |
6dfaf4e9ce71
use many anonymous cipher_suites
Franklin Schmidt <fschmidt@gmail.com>
parents:
1205
diff
changeset
|
38 "TLS_ECDH_anon_WITH_AES_128_CBC_SHA" |
6dfaf4e9ce71
use many anonymous cipher_suites
Franklin Schmidt <fschmidt@gmail.com>
parents:
1205
diff
changeset
|
39 "TLS_DH_anon_WITH_AES_128_CBC_SHA" |
6dfaf4e9ce71
use many anonymous cipher_suites
Franklin Schmidt <fschmidt@gmail.com>
parents:
1205
diff
changeset
|
40 "TLS_ECDH_anon_WITH_3DES_EDE_CBC_SHA" |
6dfaf4e9ce71
use many anonymous cipher_suites
Franklin Schmidt <fschmidt@gmail.com>
parents:
1205
diff
changeset
|
41 "SSL_DH_anon_WITH_3DES_EDE_CBC_SHA" |
6dfaf4e9ce71
use many anonymous cipher_suites
Franklin Schmidt <fschmidt@gmail.com>
parents:
1205
diff
changeset
|
42 "TLS_ECDH_anon_WITH_RC4_128_SHA" |
6dfaf4e9ce71
use many anonymous cipher_suites
Franklin Schmidt <fschmidt@gmail.com>
parents:
1205
diff
changeset
|
43 "SSL_DH_anon_WITH_RC4_128_MD5" |
6dfaf4e9ce71
use many anonymous cipher_suites
Franklin Schmidt <fschmidt@gmail.com>
parents:
1205
diff
changeset
|
44 "SSL_DH_anon_WITH_DES_CBC_SHA" |
6dfaf4e9ce71
use many anonymous cipher_suites
Franklin Schmidt <fschmidt@gmail.com>
parents:
1205
diff
changeset
|
45 "SSL_DH_anon_EXPORT_WITH_DES40_CBC_SHA" |
6dfaf4e9ce71
use many anonymous cipher_suites
Franklin Schmidt <fschmidt@gmail.com>
parents:
1205
diff
changeset
|
46 "SSL_DH_anon_EXPORT_WITH_RC4_40_MD5" |
6dfaf4e9ce71
use many anonymous cipher_suites
Franklin Schmidt <fschmidt@gmail.com>
parents:
1205
diff
changeset
|
47 } |
1204
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
48 |
1509 | 49 local function java_array(list) |
1120
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
50 for i,v in ipairs(list) do |
1259
e8020216dee7
add Luan.to_luan and fix multipart/form-data
Franklin Schmidt <fschmidt@gmail.com>
parents:
1236
diff
changeset
|
51 list[i] = LuanJava.toJava(v) |
1120
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
52 end |
1509 | 53 return list |
54 end | |
55 | |
56 local function java_args(list) | |
57 return unpack(java_array(list)) | |
1120
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 |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
60 local function luan_args(list,binary_in) |
1261
198d6af7330a
rename Luan.to_table to Table.java_to_table_shallow and Luan.to_luan to Table.java_to_table_deep
Franklin Schmidt <fschmidt@gmail.com>
parents:
1260
diff
changeset
|
61 list = java_to_table_deep(list) |
1120
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
62 if binary_in ~= nil then |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
63 local i_in = list[#list] |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
64 list[#list] = nil |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
65 local type = list[i_in] |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
66 if type == "binary" then |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
67 list[i_in] = JavaUtils.readAll(binary_in) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
68 elseif type == "input" then |
1280 | 69 list[i_in] = Boot.new_LuanIn( IoLuan.LuanInput.new(binary_in) ) |
1120
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
70 else |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
71 error(type) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
72 end |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
73 end |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
74 return unpack(list) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
75 end |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
76 |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
77 local function encode_binary(args) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
78 local binary_in, len_in, i_in |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
79 for i,v in ipairs(args) do |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
80 if type(v) == "binary" then |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
81 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
|
82 i_in = i |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
83 binary_in = ByteArrayInputStream.new(v) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
84 len_in = #v |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
85 args[i] = "binary" |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
86 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
|
87 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
|
88 i_in = i |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
89 binary_in = v.java.inputStream() |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
90 len_in = v.length() |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
91 args[i] = "input" |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
92 end |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
93 end |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
94 args[#args+1] = i_in |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
95 return binary_in, len_in |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
96 end |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
97 |
1204
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
98 local function rpc_caller(socket) |
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
99 local client = RpcClient.new(socket) |
1120
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
100 return function(fn_name,...) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
101 local args = {...} |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
102 local binary_in, len_in = encode_binary(args) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
103 local call |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
104 if binary_in == nil then |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
105 call = RpcCall.new(fn_name,java_args(args)) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
106 else |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
107 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
|
108 end |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
109 client.write(call) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
110 if fn_name == "close" then |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
111 client.close() |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
112 return |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
113 end |
1520 | 114 try |
115 local result = client.read() | |
116 return luan_args(result.returnValues,result["in"]) | |
117 catch e | |
118 local cause = e.java.getCause() | |
119 if cause ~= nil and cause.instanceof(RpcException) and cause.getMessage() == "luan" then | |
120 error(cause.values.get(0)) | |
121 else | |
122 e.throw() | |
1120
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
123 end |
1520 | 124 end |
1120
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
125 end_function |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
126 end_function |
743
2c41f2aec92f
improve Rpc and implement rpc call for local webserver
Franklin Schmidt <fschmidt@gmail.com>
parents:
693
diff
changeset
|
127 |
1088
bae2d0c2576c
change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents:
775
diff
changeset
|
128 Rpc.functions = {} |
1578 | 129 Luan.set_metatable( Rpc.functions, Boot.local_metatable ) |
610
b4f3dbe1c6e3
add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
130 |
1204
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
131 local function rpc_responder(socket,fns) |
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
132 local server = RpcServer.new(socket) |
1120
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
133 local responder = {} |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
134 function responder.is_closed() |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
135 return server.isClosed() |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
136 end_function |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
137 function responder.respond() |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
138 local call = server.read() |
1381
8d7a39ca2c0c
add Rpc in_backup_read_lock
Franklin Schmidt <fschmidt@gmail.com>
parents:
1380
diff
changeset
|
139 if call==nil then |
8d7a39ca2c0c
add Rpc in_backup_read_lock
Franklin Schmidt <fschmidt@gmail.com>
parents:
1380
diff
changeset
|
140 return |
8d7a39ca2c0c
add Rpc in_backup_read_lock
Franklin Schmidt <fschmidt@gmail.com>
parents:
1380
diff
changeset
|
141 end |
1120
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
142 local cmd = call.cmd |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
143 if cmd == "close" then |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
144 server.close() |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
145 return |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
146 end_if |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
147 local fn = fns[cmd] |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
148 if fn == nil then |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
149 server.write(JavaRpc.COMMAND_NOT_FOUND) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
150 return |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
151 end_if |
1520 | 152 local rtn |
153 try | |
154 rtn = {fn(luan_args(call.args,call["in"]))} | |
155 catch e | |
156 logger.warn(e) | |
157 local ex = RpcException.new("luan",e.get_message()) | |
158 server.write(ex) | |
159 return | |
160 end | |
1120
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
161 local binary_in, len_in = encode_binary(rtn) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
162 local result |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
163 if binary_in == nil then |
1509 | 164 result = RpcResult.new(java_array(rtn)) |
1120
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
165 else |
1509 | 166 result = RpcResult.new(binary_in,len_in,java_array(rtn)) |
1120
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
167 end |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
168 server.write(result) |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
169 end |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
170 return responder |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
171 end_function |
743
2c41f2aec92f
improve Rpc and implement rpc call for local webserver
Franklin Schmidt <fschmidt@gmail.com>
parents:
693
diff
changeset
|
172 |
1204
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
173 function Rpc.remote(domain) |
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
174 local socket |
1206
6dfaf4e9ce71
use many anonymous cipher_suites
Franklin Schmidt <fschmidt@gmail.com>
parents:
1205
diff
changeset
|
175 if Rpc.cipher_suites == nil then |
1204
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
176 socket = Socket.new(domain,Rpc.port) |
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
177 else |
1596
a9ff30fb5d89
add Hosting.push_file
Franklin Schmidt <fschmidt@gmail.com>
parents:
1578
diff
changeset
|
178 try |
a9ff30fb5d89
add Hosting.push_file
Franklin Schmidt <fschmidt@gmail.com>
parents:
1578
diff
changeset
|
179 socket = IoUtils.getSSLSocketFactory().createSocket(domain,Rpc.port) |
a9ff30fb5d89
add Hosting.push_file
Franklin Schmidt <fschmidt@gmail.com>
parents:
1578
diff
changeset
|
180 catch e |
a9ff30fb5d89
add Hosting.push_file
Franklin Schmidt <fschmidt@gmail.com>
parents:
1578
diff
changeset
|
181 e.java.showCause = false |
a9ff30fb5d89
add Hosting.push_file
Franklin Schmidt <fschmidt@gmail.com>
parents:
1578
diff
changeset
|
182 e.throw() |
a9ff30fb5d89
add Hosting.push_file
Franklin Schmidt <fschmidt@gmail.com>
parents:
1578
diff
changeset
|
183 end |
1206
6dfaf4e9ce71
use many anonymous cipher_suites
Franklin Schmidt <fschmidt@gmail.com>
parents:
1205
diff
changeset
|
184 socket.setEnabledCipherSuites(Rpc.cipher_suites) |
1204
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
185 end |
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
186 local call = rpc_caller(socket) |
610
b4f3dbe1c6e3
add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
187 local mt = {} |
b4f3dbe1c6e3
add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
188 function mt.__index(_,key) |
b4f3dbe1c6e3
add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
189 return function(...) |
1120
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
190 return call(key,...) |
610
b4f3dbe1c6e3
add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
191 end |
b4f3dbe1c6e3
add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
192 end |
1381
8d7a39ca2c0c
add Rpc in_backup_read_lock
Franklin Schmidt <fschmidt@gmail.com>
parents:
1380
diff
changeset
|
193 local err = Luan.new_error("not closed") |
8d7a39ca2c0c
add Rpc in_backup_read_lock
Franklin Schmidt <fschmidt@gmail.com>
parents:
1380
diff
changeset
|
194 function mt.__gc(_) |
8d7a39ca2c0c
add Rpc in_backup_read_lock
Franklin Schmidt <fschmidt@gmail.com>
parents:
1380
diff
changeset
|
195 socket.isClosed() or logger.error(err) |
8d7a39ca2c0c
add Rpc in_backup_read_lock
Franklin Schmidt <fschmidt@gmail.com>
parents:
1380
diff
changeset
|
196 end |
610
b4f3dbe1c6e3
add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
197 local t = {} |
b4f3dbe1c6e3
add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
198 set_metatable(t,mt) |
b4f3dbe1c6e3
add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
199 return t |
1120
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
200 end_function |
610
b4f3dbe1c6e3
add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
201 |
1088
bae2d0c2576c
change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents:
775
diff
changeset
|
202 function Rpc.serve(port,fns) |
1204
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
203 port = port or Rpc.port |
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
204 fns = fns or Rpc.functions |
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
205 local socket_server |
1206
6dfaf4e9ce71
use many anonymous cipher_suites
Franklin Schmidt <fschmidt@gmail.com>
parents:
1205
diff
changeset
|
206 if Rpc.cipher_suites == nil then |
1204
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
207 socket_server = ServerSocket.new(port) |
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
208 else |
1506
d80395468b4e
ssl security in code
Franklin Schmidt <fschmidt@gmail.com>
parents:
1408
diff
changeset
|
209 socket_server = IoUtils.getSSLServerSocketFactory().createServerSocket(port) |
1206
6dfaf4e9ce71
use many anonymous cipher_suites
Franklin Schmidt <fschmidt@gmail.com>
parents:
1205
diff
changeset
|
210 socket_server.setEnabledCipherSuites(Rpc.cipher_suites) |
1204
5d0cbd908582
remove Io socket support
Franklin Schmidt <fschmidt@gmail.com>
parents:
1201
diff
changeset
|
211 end |
762
3f461f85243d
better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents:
743
diff
changeset
|
212 while true do |
1520 | 213 try |
214 local socket = socket_server.accept() | |
215 local function server() | |
216 local responder = nil | |
217 try | |
218 responder = rpc_responder(socket,fns) | |
219 while not responder.is_closed() do | |
220 responder.respond() | |
221 end | |
222 catch e | |
223 logger.warn(e) | |
224 finally | |
225 responder and responder.after_close and responder.after_close() | |
762
3f461f85243d
better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents:
743
diff
changeset
|
226 end |
3f461f85243d
better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents:
743
diff
changeset
|
227 end |
1520 | 228 Thread.fork(server) |
229 catch e | |
230 logger.error(e) | |
231 end | |
1120
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
232 end_while |
e8fc6712b468
luan Rpc uses luan.lib.rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
1088
diff
changeset
|
233 end_function |
743
2c41f2aec92f
improve Rpc and implement rpc call for local webserver
Franklin Schmidt <fschmidt@gmail.com>
parents:
693
diff
changeset
|
234 |
1088
bae2d0c2576c
change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents:
775
diff
changeset
|
235 return Rpc |