2019-07-29 19:21:36 +03:00
|
|
|
module vweb
|
|
|
|
|
|
|
|
import (
|
|
|
|
os
|
|
|
|
strings
|
|
|
|
net
|
|
|
|
http
|
|
|
|
)
|
|
|
|
|
|
|
|
struct Context {
|
2019-07-31 07:10:53 +03:00
|
|
|
static_files map[string]string
|
|
|
|
static_mime_types map[string]string
|
2019-07-29 19:21:36 +03:00
|
|
|
pub:
|
|
|
|
req http.Request
|
|
|
|
conn net.Socket
|
|
|
|
post_form map[string]string
|
|
|
|
// TODO Response
|
2019-07-30 16:46:10 +03:00
|
|
|
headers []string // response headers
|
|
|
|
}
|
|
|
|
|
|
|
|
pub fn (ctx Context) text(s string) {
|
|
|
|
h := ctx.headers.join('\n')
|
|
|
|
ctx.conn.write('HTTP/1.1 200 OK
|
|
|
|
Content-Type: text/plain
|
|
|
|
$h
|
|
|
|
$s
|
|
|
|
')
|
2019-07-29 19:21:36 +03:00
|
|
|
}
|
|
|
|
|
2019-07-30 06:13:44 +03:00
|
|
|
pub fn (ctx Context) json(s string) {
|
|
|
|
h := ctx.headers.join('\n')
|
|
|
|
ctx.conn.write('HTTP/1.1 200 OK
|
|
|
|
Content-Type: application/json
|
|
|
|
$h
|
|
|
|
$s
|
|
|
|
')
|
2019-07-29 19:21:36 +03:00
|
|
|
}
|
|
|
|
|
|
|
|
pub fn (ctx Context) redirect(url string) {
|
|
|
|
h := ctx.headers.join('\n')
|
|
|
|
ctx.conn.write('
|
|
|
|
HTTP/1.1 302 Found
|
|
|
|
Location: $url
|
|
|
|
$h
|
|
|
|
')
|
|
|
|
}
|
|
|
|
|
2019-08-02 05:04:48 +03:00
|
|
|
pub fn (ctx Context) not_found(s string) {
|
|
|
|
ctx.conn.write('HTTP/1.1 404 Not Found')
|
|
|
|
}
|
|
|
|
|
2019-07-29 19:21:36 +03:00
|
|
|
pub fn (ctx mut Context) set_cookie(key, val string) {
|
|
|
|
ctx.set_header('Set-Cookie', '$key=$val')
|
|
|
|
}
|
|
|
|
|
|
|
|
pub fn (ctx Context) get_cookie(key string) string {
|
2019-08-01 19:36:36 +03:00
|
|
|
for h in ctx.req.headers2 {
|
|
|
|
if h.starts_with('Cookie:') {
|
|
|
|
cookie := h.right(7)
|
|
|
|
return cookie.find_between('$key=', ';')
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return ''
|
|
|
|
/*
|
2019-07-29 19:21:36 +03:00
|
|
|
cookie := ctx.req.headers['Cookie']
|
2019-08-01 19:36:36 +03:00
|
|
|
println('get cookie $key : "$cookie"')
|
2019-07-29 19:21:36 +03:00
|
|
|
return cookie.find_between('$key=', ';')
|
2019-08-01 19:36:36 +03:00
|
|
|
*/
|
2019-07-29 19:21:36 +03:00
|
|
|
}
|
|
|
|
|
|
|
|
fn (ctx mut Context) set_header(key, val string) {
|
|
|
|
// ctx.resp.headers[key] = val
|
|
|
|
ctx.headers << '$key: $val'
|
|
|
|
}
|
|
|
|
|
|
|
|
pub fn (ctx Context) html(html string) {
|
|
|
|
//tmpl := os.read_file(path) or {return}
|
2019-08-01 19:36:36 +03:00
|
|
|
h := ctx.headers.join('\n')
|
2019-07-29 19:21:36 +03:00
|
|
|
ctx.conn.write('HTTP/1.1 200 OK
|
|
|
|
Content-Type: text/html
|
2019-08-01 19:36:36 +03:00
|
|
|
$h
|
2019-07-29 19:21:36 +03:00
|
|
|
|
|
|
|
$html
|
|
|
|
')
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
pub fn run<T>(port int) {
|
2019-08-01 02:34:28 +03:00
|
|
|
println('Running vweb app on http://localhost:$port ...')
|
2019-07-29 19:21:36 +03:00
|
|
|
l := net.listen(port) or { panic('failed to listen') return }
|
2019-08-02 06:54:40 +03:00
|
|
|
mut app := T{}
|
|
|
|
app.init()
|
2019-07-29 19:21:36 +03:00
|
|
|
for {
|
|
|
|
conn := l.accept() or {
|
|
|
|
panic('accept() failed')
|
|
|
|
return
|
|
|
|
}
|
|
|
|
// TODO move this to handle_conn<T>(conn, app)
|
|
|
|
s := conn.read_line()
|
2019-08-01 19:36:36 +03:00
|
|
|
// Parse request headers
|
|
|
|
lines := s.split_into_lines()
|
|
|
|
mut headers := []string //map[string]string{}
|
|
|
|
for i, line in lines {
|
|
|
|
if i == 0 {
|
|
|
|
continue
|
|
|
|
}
|
|
|
|
words := line.split(':')
|
|
|
|
if words.len != 2 {
|
|
|
|
continue
|
|
|
|
}
|
|
|
|
headers << line
|
|
|
|
/*
|
|
|
|
key := words[0]
|
|
|
|
val := words[1]
|
|
|
|
headers[key] = val
|
|
|
|
*/
|
|
|
|
}
|
2019-07-29 19:21:36 +03:00
|
|
|
// Parse the first line
|
|
|
|
// "GET / HTTP/1.1"
|
|
|
|
first_line := s.all_before('\n')
|
|
|
|
vals := first_line.split(' ')
|
|
|
|
mut action := vals[1].right(1).all_before('/')
|
2019-08-01 18:57:01 +03:00
|
|
|
if action.contains('?') {
|
|
|
|
action = action.all_before('?')
|
|
|
|
}
|
2019-08-02 05:04:48 +03:00
|
|
|
if action == 'favicon.ico' {
|
|
|
|
println('favicon.ico')
|
|
|
|
conn.write('HTTP/1.1 404 Not Found')
|
|
|
|
conn.close()
|
|
|
|
continue
|
|
|
|
}
|
2019-07-29 19:21:36 +03:00
|
|
|
if action == '' {
|
|
|
|
action = 'index'
|
|
|
|
}
|
|
|
|
req := http.Request{
|
|
|
|
headers: map[string]string{}
|
2019-08-01 19:36:36 +03:00
|
|
|
headers2: headers
|
2019-07-29 19:21:36 +03:00
|
|
|
ws_func: 0
|
|
|
|
user_ptr: 0
|
|
|
|
method: vals[0]
|
|
|
|
url: vals[1]
|
|
|
|
}
|
2019-08-02 06:54:40 +03:00
|
|
|
//mut app := T{
|
|
|
|
app.vweb = Context{
|
|
|
|
req: req
|
|
|
|
conn: conn
|
|
|
|
post_form: map[string]string{}
|
|
|
|
static_files: map[string]string{}
|
|
|
|
static_mime_types: map[string]string{}
|
2019-07-29 19:21:36 +03:00
|
|
|
}
|
2019-08-02 06:54:40 +03:00
|
|
|
//}
|
2019-07-29 19:21:36 +03:00
|
|
|
if req.method == 'POST' {
|
|
|
|
app.vweb.parse_form(s)
|
|
|
|
}
|
|
|
|
println('vweb action = "$action"')
|
|
|
|
if vals.len < 2 {
|
|
|
|
println('no vals for http')
|
2019-08-02 05:04:48 +03:00
|
|
|
conn.close()
|
|
|
|
continue
|
2019-07-29 19:21:36 +03:00
|
|
|
}
|
2019-07-31 07:10:53 +03:00
|
|
|
|
2019-07-30 16:46:10 +03:00
|
|
|
// Serve a static file if it's one
|
2019-07-31 07:10:53 +03:00
|
|
|
// if app.vweb.handle_static() {
|
|
|
|
// conn.close()
|
|
|
|
// continue
|
|
|
|
// }
|
|
|
|
|
2019-07-30 16:46:10 +03:00
|
|
|
// Call the right action
|
2019-08-02 05:04:48 +03:00
|
|
|
app.$action() or {
|
|
|
|
conn.write('HTTP/1.1 404 Not Found
|
|
|
|
Content-Type: text/plain
|
|
|
|
|
|
|
|
404 not found
|
|
|
|
')
|
|
|
|
}
|
2019-07-29 19:21:36 +03:00
|
|
|
conn.close()
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
fn (ctx mut Context) parse_form(s string) {
|
|
|
|
if ctx.req.method != 'POST' {
|
|
|
|
return
|
|
|
|
}
|
|
|
|
pos := s.index('\r\n\r\n')
|
|
|
|
if pos > -1 {
|
|
|
|
mut str_form := s.substr(pos, s.len)
|
|
|
|
str_form = str_form.replace('+', ' ')
|
|
|
|
words := str_form.split('&')
|
|
|
|
for word in words {
|
2019-08-02 05:04:48 +03:00
|
|
|
println('parse form keyval="$word"')
|
2019-07-29 19:21:36 +03:00
|
|
|
keyval := word.split('=')
|
2019-08-02 05:04:48 +03:00
|
|
|
if keyval.len != 2 { continue }
|
2019-07-29 19:21:36 +03:00
|
|
|
key := keyval[0]
|
|
|
|
val := keyval[1]
|
|
|
|
//println('http form $key => $val')
|
2019-07-31 21:53:07 +03:00
|
|
|
ctx.post_form[key] = http.unescape_url(val)
|
2019-07-29 19:21:36 +03:00
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2019-07-31 07:10:53 +03:00
|
|
|
fn (ctx mut Context) scan_static_directory(directory_path, mount_path string) {
|
|
|
|
// mime types
|
|
|
|
mut mime_types := map[string]string{}
|
|
|
|
mime_types['.css'] = 'text/css; charset=utf-8'
|
|
|
|
mime_types['.gif'] = 'image/gif'
|
|
|
|
mime_types['.htm'] = 'text/html; charset=utf-8'
|
|
|
|
mime_types['.html'] = 'text/html; charset=utf-8'
|
|
|
|
mime_types['.jpg'] = 'image/jpeg'
|
|
|
|
mime_types['.js'] = 'application/javascript'
|
|
|
|
mime_types['.wasm'] = 'application/wasm'
|
|
|
|
mime_types['.pdf'] = 'application/pdf'
|
|
|
|
mime_types['.png'] = 'image/png'
|
|
|
|
mime_types['.svg'] = 'image/svg+xml'
|
|
|
|
mime_types['.xml'] = 'text/xml; charset=utf-8'
|
|
|
|
|
|
|
|
files := os.ls(directory_path)
|
|
|
|
|
|
|
|
if files.len > 0 {
|
|
|
|
for file in files {
|
|
|
|
mut ext := ''
|
|
|
|
mut i := file.len
|
|
|
|
mut flag := true
|
|
|
|
for i > 0 {
|
|
|
|
i--
|
|
|
|
if flag {
|
|
|
|
ext = file.substr(i, i + 1) + ext
|
|
|
|
}
|
|
|
|
if file.substr(i, i + 1) == '.' {
|
|
|
|
flag = false
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
// todo: os.is_dir is broken now
|
|
|
|
// so we expect that file is dir it has no extension
|
|
|
|
if flag {
|
|
|
|
ctx.scan_static_directory(directory_path + '/' + file, mount_path + '/' + file)
|
|
|
|
} else {
|
|
|
|
ctx.static_files[mount_path + '/' + file] = directory_path + '/' + file
|
|
|
|
ctx.static_mime_types[mount_path + '/' + file] = mime_types[ext]
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
pub fn (ctx mut Context) handle_static(directory_path string) bool {
|
|
|
|
ctx.scan_static_directory(directory_path, '')
|
|
|
|
|
2019-07-30 16:46:10 +03:00
|
|
|
static_file := ctx.static_files[ctx.req.url]
|
2019-07-31 07:10:53 +03:00
|
|
|
mime_type := ctx.static_mime_types[ctx.req.url]
|
|
|
|
|
2019-07-30 16:46:10 +03:00
|
|
|
if static_file != '' {
|
|
|
|
data := os.read_file(static_file) or { return false }
|
|
|
|
ctx.conn.write('HTTP/1.1 200 OK
|
2019-07-31 07:10:53 +03:00
|
|
|
Content-Type: $mime_type
|
2019-07-30 16:46:10 +03:00
|
|
|
|
|
|
|
$data
|
|
|
|
')
|
|
|
|
return true
|
|
|
|
}
|
|
|
|
return false
|
|
|
|
}
|
|
|
|
|
2019-07-31 07:10:53 +03:00
|
|
|
pub fn (ctx mut Context) serve_static(url, file_path, mime_type string) {
|
2019-07-30 16:46:10 +03:00
|
|
|
ctx.static_files[url] = file_path
|
2019-07-31 07:10:53 +03:00
|
|
|
ctx.static_mime_types[url] = mime_type
|
2019-07-30 16:46:10 +03:00
|
|
|
}
|
|
|
|
|
2019-07-29 19:21:36 +03:00
|
|
|
|