This repository has been archived by the owner on Aug 18, 2020. It is now read-only.
/
server_table_handlers.go
65 lines (55 loc) · 2.09 KB
/
server_table_handlers.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
package skyd
import (
"errors"
"github.com/gorilla/mux"
"net/http"
)
func (s *Server) addTableHandlers() {
s.ApiHandleFunc("/tables", func(w http.ResponseWriter, req *http.Request, params map[string]interface{}) (interface{}, error) {
return s.getTablesHandler(w, req, params)
}).Methods("GET")
s.ApiHandleFunc("/tables/{name}", func(w http.ResponseWriter, req *http.Request, params map[string]interface{}) (interface{}, error) {
return s.getTableHandler(w, req, params)
}).Methods("GET")
s.ApiHandleFunc("/tables", func(w http.ResponseWriter, req *http.Request, params map[string]interface{}) (interface{}, error) {
return s.createTableHandler(w, req, params)
}).Methods("POST")
s.ApiHandleFunc("/tables/{name}", func(w http.ResponseWriter, req *http.Request, params map[string]interface{}) (interface{}, error) {
return s.deleteTableHandler(w, req, params)
}).Methods("DELETE")
}
// GET /tables
func (s *Server) getTablesHandler(w http.ResponseWriter, req *http.Request, params map[string]interface{}) (interface{}, error) {
return s.GetAllTables()
}
// GET /tables/:name
func (s *Server) getTableHandler(w http.ResponseWriter, req *http.Request, params map[string]interface{}) (interface{}, error) {
vars := mux.Vars(req)
return s.OpenTable(vars["name"])
}
// POST /tables
func (s *Server) createTableHandler(w http.ResponseWriter, req *http.Request, params map[string]interface{}) (interface{}, error) {
// Retrieve table parameters.
tableName, ok := params["name"].(string)
if !ok {
return nil, errors.New("Table name required.")
}
// Return an error if the table already exists.
table, err := s.OpenTable(tableName)
if table != nil {
return nil, errors.New("Table already exists.")
}
// Otherwise create it.
table = NewTable(tableName, s.TablePath(tableName))
err = table.Create()
if err != nil {
return nil, err
}
return table, nil
}
// DELETE /tables/:name
func (s *Server) deleteTableHandler(w http.ResponseWriter, req *http.Request, params map[string]interface{}) (interface{}, error) {
vars := mux.Vars(req)
tableName := vars["name"]
return nil, s.DeleteTable(tableName)
}