Mercurial Hosting > luan

annotate core/src/luan/modules/host/Hosting.luan @ 619:cc3a68033179

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
fix hosting delete logging
author Franklin Schmidt <fschmidt@gmail.com>
date Sun, 03 Jan 2016 02:03:54 -0700
parents abc3198c86dd
children c5baaa525897
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
276
e5a0dd95f3e7 rename Reactionary to Hosting
fschmidt@gmail.com <fschmidt@gmail.com@21e917c8-12df-6dd8-5cb6-c86387c605b9>
parents: 275
diff changeset
1 -- Hosting
144
2e92f0a6fcac add Reactionary.luan
fschmidt@gmail.com <fschmidt@gmail.com@21e917c8-12df-6dd8-5cb6-c86387c605b9>
parents:
diff changeset
2
379
e9e445e28f0b add error checking to Hosting
Franklin Schmidt <fschmidt@gmail.com>
parents: 348
diff changeset
3 local Luan = require "luan:Luan"
e9e445e28f0b add error checking to Hosting
Franklin Schmidt <fschmidt@gmail.com>
parents: 348
diff changeset
4 local error = Luan.error
610
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
5 local ipairs = Luan.ipairs or error()
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
6 local pairs = Luan.pairs or error()
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
7 local Io = require "luan:Io"
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
8 local print = Io.print or error()
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
9 local Rpc = require "luan:Rpc"
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
10
379
e9e445e28f0b add error checking to Hosting
Franklin Schmidt <fschmidt@gmail.com>
parents: 348
diff changeset
11
503
92c3d22745b8 make _ENV optional
Franklin Schmidt <fschmidt@gmail.com>
parents: 435
diff changeset
12 local M = {}
189
fschmidt@gmail.com <fschmidt@gmail.com@21e917c8-12df-6dd8-5cb6-c86387c605b9>
parents: 184
diff changeset
13
503
92c3d22745b8 make _ENV optional
Franklin Schmidt <fschmidt@gmail.com>
parents: 435
diff changeset
14 M.port = 9101
144
2e92f0a6fcac add Reactionary.luan
fschmidt@gmail.com <fschmidt@gmail.com@21e917c8-12df-6dd8-5cb6-c86387c605b9>
parents:
diff changeset
15
503
92c3d22745b8 make _ENV optional
Franklin Schmidt <fschmidt@gmail.com>
parents: 435
diff changeset
16 function M.push(domain,password,dir)
610
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
17 local my_dir = Io.uri("file:"..dir)
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
18 my_dir.exists() or error("directory '"..dir.."' not found")
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
19 my_dir.is_directory() or error("'"..dir.."' is not a directory")
503
92c3d22745b8 make _ENV optional
Franklin Schmidt <fschmidt@gmail.com>
parents: 435
diff changeset
20 local socket = "socket:" .. domain .. ":" .. M.port
610
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
21 local host = Rpc.remote(socket)
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
22 local tree = host.get(domain,password)
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
23 if tree == nil then
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
24 print("creating "..domain)
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
25 tree = host.create(domain,password)
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
26 end
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
27
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
28 local function process(there_parent,there,here)
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
29 if here.is_file() then
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
30 if there == nil or there.last_modified < here.last_modified() then
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
31 print("copying "..here.to_string())
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
32 host.copy_file(domain,password,there_parent.path,here.name(),here.read_binary())
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
33 end
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
34 elseif here.is_directory() then
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
35 if here.name() == "local" then
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
36 return
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
37 end
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
38 if there == nil then
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
39 there = host.mkdir(domain,password,there_parent.path,here.name())
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
40 end
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
41 for _, here_child in ipairs(here.children()) do
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
42 local name = here_child.name()
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
43 process(there,there.children[name],here_child)
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
44 there.children[name] = nil
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
45 end
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
46 for _, there_child in pairs(there.children) do
619
cc3a68033179 fix hosting delete logging
Franklin Schmidt <fschmidt@gmail.com>
parents: 615
diff changeset
47 if host.delete_unused(domain,password,there_child.path)==true then -- remove ==true later
cc3a68033179 fix hosting delete logging
Franklin Schmidt <fschmidt@gmail.com>
parents: 615
diff changeset
48 print("deleted "..there_child.name)
cc3a68033179 fix hosting delete logging
Franklin Schmidt <fschmidt@gmail.com>
parents: 615
diff changeset
49 end
610
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
50 end
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
51 else
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
52 error "not file or dir"
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
53 end
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
54 end
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
55
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
56 process( nil, tree, my_dir )
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
57
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
58 host.remove_handler(domain,password)
144
2e92f0a6fcac add Reactionary.luan
fschmidt@gmail.com <fschmidt@gmail.com@21e917c8-12df-6dd8-5cb6-c86387c605b9>
parents:
diff changeset
59 end
2e92f0a6fcac add Reactionary.luan
fschmidt@gmail.com <fschmidt@gmail.com@21e917c8-12df-6dd8-5cb6-c86387c605b9>
parents:
diff changeset
60
503
92c3d22745b8 make _ENV optional
Franklin Schmidt <fschmidt@gmail.com>
parents: 435
diff changeset
61 function M.delete(domain,password)
92c3d22745b8 make _ENV optional
Franklin Schmidt <fschmidt@gmail.com>
parents: 435
diff changeset
62 local socket = "socket:" .. domain .. ":" .. M.port
610
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
63 local host = Rpc.remote(socket)
b4f3dbe1c6e3 add Rpc and change Hosting to use Rpc
Franklin Schmidt <fschmidt@gmail.com>
parents: 503
diff changeset
64 host.delete(domain,password)
144
2e92f0a6fcac add Reactionary.luan
fschmidt@gmail.com <fschmidt@gmail.com@21e917c8-12df-6dd8-5cb6-c86387c605b9>
parents:
diff changeset
65 end
503
92c3d22745b8 make _ENV optional
Franklin Schmidt <fschmidt@gmail.com>
parents: 435
diff changeset
66
615
abc3198c86dd fix tail recursion bug;
Franklin Schmidt <fschmidt@gmail.com>
parents: 610
diff changeset
67 function M.exists(domain)
abc3198c86dd fix tail recursion bug;
Franklin Schmidt <fschmidt@gmail.com>
parents: 610
diff changeset
68 local socket = "socket:" .. domain .. ":" .. M.port
abc3198c86dd fix tail recursion bug;
Franklin Schmidt <fschmidt@gmail.com>
parents: 610
diff changeset
69 local host = Rpc.remote(socket)
abc3198c86dd fix tail recursion bug;
Franklin Schmidt <fschmidt@gmail.com>
parents: 610
diff changeset
70 return host.exists(domain)
abc3198c86dd fix tail recursion bug;
Franklin Schmidt <fschmidt@gmail.com>
parents: 610
diff changeset
71 end
abc3198c86dd fix tail recursion bug;
Franklin Schmidt <fschmidt@gmail.com>
parents: 610
diff changeset
72
503
92c3d22745b8 make _ENV optional
Franklin Schmidt <fschmidt@gmail.com>
parents: 435
diff changeset
73 return M