Mercurial Hosting > luan
annotate src/luan/host/main.luan @ 1520:d9a5405a3102
try statement
| author | Franklin Schmidt <fschmidt@gmail.com> |
|---|---|
| date | Sun, 21 Jun 2020 18:14:13 -0600 |
| parents | e48290f3d9fb |
| children | d6a50ed9604f |
| rev | line source |
|---|---|
|
1353
8d95711f6615
replace java() with require "java"
Franklin Schmidt <fschmidt@gmail.com>
parents:
1277
diff
changeset
|
1 require "java" |
| 1135 | 2 local Luan = require "luan:Luan.luan" |
| 3 local error = Luan.error | |
| 1164 | 4 local type = Luan.type or error() |
| 1135 | 5 local ipairs = Luan.ipairs or error() |
| 6 local Io = require "luan:Io.luan" | |
| 7 local Rpc = require "luan:Rpc.luan" | |
| 8 local Thread = require "luan:Thread.luan" | |
| 9 local String = require "luan:String.luan" | |
| 1422 | 10 local regex_quote = String.regex_quote or error() |
| 1135 | 11 local lower = String.lower or error() |
| 12 local matches = String.matches or error() | |
| 1418 | 13 local Hosted = require "luan:host/Hosted.luan" |
| 1135 | 14 local Logging = require "luan:logging/Logging.luan" |
| 15 local logger = Logging.logger "main" | |
| 1418 | 16 local WebHandler = Hosted.WebHandler or error() |
|
1181
51d1342e25ad
luanhost password handling
Franklin Schmidt <fschmidt@gmail.com>
parents:
1164
diff
changeset
|
17 local Util = require "classpath:luan/host/Util.luan" |
|
51d1342e25ad
luanhost password handling
Franklin Schmidt <fschmidt@gmail.com>
parents:
1164
diff
changeset
|
18 local read_password = Util.read_password or error() |
|
1394
8fe777ba5045
change postgres password
Franklin Schmidt <fschmidt@gmail.com>
parents:
1353
diff
changeset
|
19 local set_password = Util.set_password or error() |
|
1396
a5f61890ad84
add check_postgres_password
Franklin Schmidt <fschmidt@gmail.com>
parents:
1394
diff
changeset
|
20 local set_postgres_password = Util.set_postgres_password or error() |
|
a5f61890ad84
add check_postgres_password
Franklin Schmidt <fschmidt@gmail.com>
parents:
1394
diff
changeset
|
21 local check_postgres_password = Util.check_postgres_password or error() |
| 1135 | 22 |
| 23 | |
| 1418 | 24 local sites_dir = Io.schemes.file(Hosted.sites_dir) |
| 1135 | 25 |
| 26 sites_dir.mkdir() | |
| 27 | |
| 28 local function delete_unused(file) | |
| 29 if file.is_directory() then | |
| 30 if file.name() == "local" then | |
| 31 return false | |
| 32 end | |
| 33 local all_deleted = true | |
| 34 for _,child in ipairs(file.children()) do | |
| 35 all_deleted = delete_unused(child) and all_deleted | |
| 36 end | |
| 37 if not all_deleted then | |
| 38 return false | |
| 39 end | |
| 40 end | |
| 41 file.delete() | |
| 42 return true | |
| 43 end | |
| 44 | |
| 45 | |
| 46 local fns = Rpc.functions | |
| 47 | |
| 48 local function get_dir(domain,password) | |
| 1164 | 49 type(domain)=="string" or error() |
| 50 type(password)=="string" or error() | |
| 1135 | 51 domain = lower(domain) |
| 52 local dir = sites_dir.child(domain) | |
| 53 if dir.exists() then | |
|
1181
51d1342e25ad
luanhost password handling
Franklin Schmidt <fschmidt@gmail.com>
parents:
1164
diff
changeset
|
54 local pwd = read_password(domain) |
| 1135 | 55 if pwd ~= password then |
| 56 error "wrong password" | |
| 57 end | |
| 58 return dir.child("site") | |
| 59 else | |
| 60 return nil | |
| 61 end | |
| 62 end | |
| 63 | |
| 64 function fns.get(domain,password) | |
| 65 local site_dir = get_dir(domain,password) | |
| 66 if site_dir == nil then | |
| 67 return nil | |
| 68 end | |
| 69 | |
| 70 local children, file_info | |
| 71 | |
| 72 function children(dir) | |
| 73 if dir.name() == "local" then | |
| 74 return {} | |
| 75 end | |
| 76 local rtn = {} | |
| 77 for _,child in ipairs(dir.children()) do | |
| 78 local info = file_info(child) | |
| 79 if info ~= nil then | |
| 80 rtn[info.name] = info | |
| 81 end | |
| 82 end | |
| 83 return rtn | |
| 84 end | |
| 85 | |
| 86 function file_info(file) | |
| 87 local info = { name = file.name(), path = file.to_string() } | |
| 88 if file.is_directory() then | |
| 89 info.children = children(file) | |
| 90 elseif file.is_file() then | |
| 91 info.checksum = file.checksum() | |
| 92 else | |
| 93 return nil | |
| 94 end | |
| 95 return info | |
| 96 end | |
| 97 | |
| 98 return file_info(site_dir) | |
| 99 end | |
| 100 | |
| 101 function fns.create(domain,password) | |
| 1164 | 102 type(domain)=="string" or error() |
| 103 type(password)=="string" or error() | |
| 1135 | 104 domain = lower(domain) |
| 105 local dir = sites_dir.child(domain) | |
| 106 dir.exists() and error "already exists" | |
|
1396
a5f61890ad84
add check_postgres_password
Franklin Schmidt <fschmidt@gmail.com>
parents:
1394
diff
changeset
|
107 check_postgres_password(domain,password) |
| 1135 | 108 dir.mkdir() |
|
1394
8fe777ba5045
change postgres password
Franklin Schmidt <fschmidt@gmail.com>
parents:
1353
diff
changeset
|
109 set_password(domain,password) |
| 1135 | 110 dir = dir.child("site") |
| 111 dir.mkdir() | |
| 112 return { name = dir.name(), path = dir.to_string(), children = {} } | |
| 113 end | |
| 114 | |
| 115 local function security(site_dir,file) | |
| 1422 | 116 matches( file.to_string(), "^"..regex_quote(site_dir.to_string()) ) or error "security violation" |
| 1135 | 117 end |
| 118 | |
| 119 function fns.copy_file(domain,password,dir,name,content) | |
| 120 local site_dir = get_dir(domain,password) | |
| 121 site_dir or error "domain not found" | |
| 122 local file = Io.schemes.file(dir).child(name) | |
| 123 security(site_dir,file) | |
| 124 file.write(content) | |
| 125 end | |
| 126 | |
| 127 function fns.mkdir(domain,password,dir,name) | |
| 128 local site_dir = get_dir(domain,password) | |
| 129 site_dir or error "domain not found" | |
| 130 local file = Io.schemes.file(dir).child(name) | |
| 131 security(site_dir,file) | |
| 132 file.mkdir() | |
| 133 return { name = file.name(), path = file.to_string(), children = {} } | |
| 134 end | |
| 135 | |
| 136 function fns.delete_unused(domain,password,path) | |
| 137 local site_dir = get_dir(domain,password) | |
| 138 site_dir or error "domain not found" | |
| 139 local file = Io.schemes.file(path) | |
| 140 security(site_dir,file) | |
| 141 return delete_unused(file) | |
| 142 end | |
| 143 | |
| 144 function fns.update_handler(domain,password) | |
| 145 local site_dir = get_dir(domain,password) | |
| 146 site_dir or error "domain not found" | |
| 147 domain = lower(domain) | |
| 148 WebHandler.removeHandler(domain) | |
| 149 WebHandler.loadHandler(domain) | |
| 150 end | |
| 151 | |
| 152 function fns.delete(domain,password) | |
| 153 local site_dir = get_dir(domain,password) | |
| 154 site_dir or error "domain not found" | |
| 155 site_dir.parent().delete() | |
| 156 domain = lower(domain) | |
| 157 WebHandler.removeHandler(domain) | |
| 158 end | |
| 159 | |
| 160 function fns.exists(domain) | |
| 1164 | 161 type(domain)=="string" or error() |
| 1135 | 162 domain = lower(domain) |
| 163 return sites_dir.child(domain).exists() | |
| 164 end | |
| 165 | |
| 166 function fns.change_domain(old_domain,new_domain,password) | |
| 167 local old_dir = get_dir(old_domain,password) | |
| 168 old_dir or error "domain not found" | |
| 169 old_dir = old_dir.parent() | |
| 1164 | 170 type(new_domain)=="string" or error() |
| 1135 | 171 new_domain = lower(new_domain) |
| 172 local new_dir = sites_dir.child(new_domain) | |
| 173 new_dir.exists() and error "new_domain already exists" | |
| 174 WebHandler.removeHandler(old_domain) | |
| 175 old_dir.rename_to(new_dir.to_string()) | |
| 176 WebHandler.removeHandler(old_domain) | |
| 177 WebHandler.loadHandler(new_domain) | |
| 178 end | |
| 179 | |
| 180 function fns.change_password(domain,old_password,new_password) | |
| 181 local site_dir = get_dir(domain,old_password) | |
| 182 site_dir or error "domain not found" | |
|
1394
8fe777ba5045
change postgres password
Franklin Schmidt <fschmidt@gmail.com>
parents:
1353
diff
changeset
|
183 set_password(domain,new_password) |
|
1396
a5f61890ad84
add check_postgres_password
Franklin Schmidt <fschmidt@gmail.com>
parents:
1394
diff
changeset
|
184 set_postgres_password(domain,new_password) |
| 1135 | 185 WebHandler.removeHandler(domain) |
| 186 WebHandler.loadHandler(domain) | |
| 187 end | |
| 188 | |
| 189 fns.call = WebHandler.callSite | |
| 190 | |
| 191 Thread.fork(Rpc.serve) |