Mercurial Hosting > luan

annotate src/luan/modules/Rpc.luan @ 1088:bae2d0c2576c

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
change module naming convention
author Franklin Schmidt <fschmidt@gmail.com>
date Mon, 26 Dec 2016 22:29:36 -0700
parents 1a68fc55a80c
children e8fc6712b468
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
610
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
1 java()
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
2 local RpcLuan = require "java:luan.modules.RpcLuan"
693
ca169567ce07 module URIs must now include ".luan"
Franklin Schmidt <fschmidt@gmail.com>
parents: 610
diff changeset
3 local Luan = require "luan:Luan.luan"
610
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
4 local error = Luan.error
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
5 local set_metatable = Luan.set_metatable or error()
762
3f461f85243d better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents: 743
diff changeset
6 local try = Luan.try or error()
693
ca169567ce07 module URIs must now include ".luan"
Franklin Schmidt <fschmidt@gmail.com>
parents: 610
diff changeset
7 local Io = require "luan:Io.luan"
ca169567ce07 module URIs must now include ".luan"
Franklin Schmidt <fschmidt@gmail.com>
parents: 610
diff changeset
8 local Thread = require "luan:Thread.luan"
762
3f461f85243d better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents: 743
diff changeset
9 local Logging = require "luan:logging/Logging.luan" -- external dependency
3f461f85243d better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents: 743
diff changeset
10 local logger = Logging.logger "Rpc"
610
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
11
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
12
1088
bae2d0c2576c change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents: 775
diff changeset
13 local Rpc = {}
610
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
14
1088
bae2d0c2576c change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents: 775
diff changeset
15 Rpc.port = 9101
743
2c41f2aec92f improve Rpc and implement rpc call for local webserver
Franklin Schmidt <fschmidt@gmail.com>
parents: 693
diff changeset
16
1088
bae2d0c2576c change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents: 775
diff changeset
17 Rpc.call = RpcLuan.call -- Rpc.call(socket,fn_name,...)
743
2c41f2aec92f improve Rpc and implement rpc call for local webserver
Franklin Schmidt <fschmidt@gmail.com>
parents: 693
diff changeset
18
1088
bae2d0c2576c change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents: 775
diff changeset
19 Rpc.functions = {}
610
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
20
1088
bae2d0c2576c change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents: 775
diff changeset
21 function Rpc.respond(socket,fns)
bae2d0c2576c change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents: 775
diff changeset
22 RpcLuan.respond( socket, fns or Rpc.functions )
743
2c41f2aec92f improve Rpc and implement rpc call for local webserver
Franklin Schmidt <fschmidt@gmail.com>
parents: 693
diff changeset
23 end
2c41f2aec92f improve Rpc and implement rpc call for local webserver
Franklin Schmidt <fschmidt@gmail.com>
parents: 693
diff changeset
24
1088
bae2d0c2576c change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents: 775
diff changeset
25 function Rpc.remote_socket(socket_uri)
610
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
26 local mt = {}
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
27 function mt.__index(_,key)
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
28 return function(...)
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
29 local socket = Io.uri(socket_uri)
1088
bae2d0c2576c change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents: 775
diff changeset
30 return Rpc.call(socket,key,...)
610
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
31 end
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
32 end
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
33 local t = {}
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
34 set_metatable(t,mt)
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
35 return t
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
36 end
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff changeset
37
1088
bae2d0c2576c change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents: 775
diff changeset
38 function Rpc.remote(domain)
bae2d0c2576c change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents: 775
diff changeset
39 local socket = "socket:" .. domain .. ":" .. Rpc.port
bae2d0c2576c change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents: 775
diff changeset
40 return Rpc.remote_socket(socket)
743
2c41f2aec92f improve Rpc and implement rpc call for local webserver
Franklin Schmidt <fschmidt@gmail.com>
parents: 693
diff changeset
41 end
2c41f2aec92f improve Rpc and implement rpc call for local webserver
Franklin Schmidt <fschmidt@gmail.com>
parents: 693
diff changeset
42
1088
bae2d0c2576c change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents: 775
diff changeset
43 function Rpc.serve(port,fns)
bae2d0c2576c change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents: 775
diff changeset
44 local server = Io.socket_server(port or Rpc.port)
762
3f461f85243d better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents: 743
diff changeset
45 while true do
3f461f85243d better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents: 743
diff changeset
46 try {
3f461f85243d better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents: 743
diff changeset
47 function()
3f461f85243d better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents: 743
diff changeset
48 local socket = server()
3f461f85243d better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents: 743
diff changeset
49 local function respond()
3f461f85243d better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents: 743
diff changeset
50 try {
3f461f85243d better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents: 743
diff changeset
51 function()
1088
bae2d0c2576c change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents: 775
diff changeset
52 Rpc.respond(socket,fns)
762
3f461f85243d better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents: 743
diff changeset
53 end
3f461f85243d better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents: 743
diff changeset
54 catch = function(e)
3f461f85243d better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents: 743
diff changeset
55 logger.error(e)
3f461f85243d better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents: 743
diff changeset
56 end
3f461f85243d better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents: 743
diff changeset
57 }
3f461f85243d better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents: 743
diff changeset
58 end
3f461f85243d better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents: 743
diff changeset
59 Thread.fork(respond)
3f461f85243d better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents: 743
diff changeset
60 end
3f461f85243d better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents: 743
diff changeset
61 catch = function(e)
3f461f85243d better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents: 743
diff changeset
62 logger.error(e)
3f461f85243d better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents: 743
diff changeset
63 end
3f461f85243d better rpc thread handling
Franklin Schmidt <fschmidt@gmail.com>
parents: 743
diff changeset
64 }
743
2c41f2aec92f improve Rpc and implement rpc call for local webserver
Franklin Schmidt <fschmidt@gmail.com>
parents: 693
diff changeset
65 end
2c41f2aec92f improve Rpc and implement rpc call for local webserver
Franklin Schmidt <fschmidt@gmail.com>
parents: 693
diff changeset
66 end
2c41f2aec92f improve Rpc and implement rpc call for local webserver
Franklin Schmidt <fschmidt@gmail.com>
parents: 693
diff changeset
67
1088
bae2d0c2576c change module naming convention
Franklin Schmidt <fschmidt@gmail.com>
parents: 775
diff changeset
68 return Rpc