Compare commits
No commits in common. "6cb4833dbd81696e8564b4f34a4a46183d798f6a" and "48e07c15d43c5c3b59e004476b864bdc3b7cea93" have entirely different histories.
6cb4833dbd
...
48e07c15d4
36
README.md
36
README.md
@ -1,36 +0,0 @@
|
|||||||
# Run from scratch
|
|
||||||
|
|
||||||
## Database
|
|
||||||
|
|
||||||
Create an empty database. The configured user needs to be able to create and alter stuff.
|
|
||||||
|
|
||||||
## Configuration
|
|
||||||
Create a configuration file `$HOME/.config/notes.yaml` with the following content:
|
|
||||||
|
|
||||||
```yaml
|
|
||||||
websocket:
|
|
||||||
domains:
|
|
||||||
- notes.com
|
|
||||||
|
|
||||||
database:
|
|
||||||
host: 127.0.0.1
|
|
||||||
port: 5432
|
|
||||||
name: notes.com
|
|
||||||
username: notes
|
|
||||||
password: SomePassword
|
|
||||||
|
|
||||||
application:
|
|
||||||
directories:
|
|
||||||
static: /usr/local/share/notes
|
|
||||||
upload: /usr/local/lib/notes/upload
|
|
||||||
|
|
||||||
session:
|
|
||||||
daysvalid: 31
|
|
||||||
```
|
|
||||||
|
|
||||||
## User
|
|
||||||
|
|
||||||
Create a user by running
|
|
||||||
```
|
|
||||||
notes --createuser
|
|
||||||
```
|
|
1
TODO
1
TODO
@ -4,6 +4,7 @@
|
|||||||
- per file
|
- per file
|
||||||
- when deleting node and child nodes
|
- when deleting node and child nodes
|
||||||
* Move node
|
* Move node
|
||||||
|
* Tree titles should be user-select none
|
||||||
|
|
||||||
|
|
||||||
Long term
|
Long term
|
||||||
|
4
db.go
4
db.go
@ -6,6 +6,7 @@ import (
|
|||||||
_ "github.com/lib/pq"
|
_ "github.com/lib/pq"
|
||||||
|
|
||||||
// Standard
|
// Standard
|
||||||
|
"embed"
|
||||||
"errors"
|
"errors"
|
||||||
"fmt"
|
"fmt"
|
||||||
"log"
|
"log"
|
||||||
@ -15,6 +16,9 @@ import (
|
|||||||
var (
|
var (
|
||||||
dbConn string
|
dbConn string
|
||||||
db *sqlx.DB
|
db *sqlx.DB
|
||||||
|
|
||||||
|
//go:embed sql/*
|
||||||
|
embedded embed.FS
|
||||||
)
|
)
|
||||||
|
|
||||||
func dbInit() (err error) {// {{{
|
func dbInit() (err error) {// {{{
|
||||||
|
247
main.go
247
main.go
@ -3,8 +3,8 @@ package main
|
|||||||
import (
|
import (
|
||||||
// Standard
|
// Standard
|
||||||
"crypto/md5"
|
"crypto/md5"
|
||||||
"embed"
|
|
||||||
"encoding/hex"
|
"encoding/hex"
|
||||||
|
"path/filepath"
|
||||||
"flag"
|
"flag"
|
||||||
"fmt"
|
"fmt"
|
||||||
"html/template"
|
"html/template"
|
||||||
@ -13,47 +13,41 @@ import (
|
|||||||
"net/http"
|
"net/http"
|
||||||
"os"
|
"os"
|
||||||
"path"
|
"path"
|
||||||
"path/filepath"
|
|
||||||
"regexp"
|
"regexp"
|
||||||
"strconv"
|
|
||||||
"strings"
|
"strings"
|
||||||
|
"strconv"
|
||||||
"time"
|
"time"
|
||||||
|
_ "embed"
|
||||||
)
|
)
|
||||||
|
|
||||||
const LISTEN_HOST = "0.0.0.0"
|
const VERSION = "v13";
|
||||||
|
const LISTEN_HOST = "0.0.0.0";
|
||||||
const DB_SCHEMA = 13
|
const DB_SCHEMA = 13
|
||||||
|
|
||||||
var (
|
var (
|
||||||
flagPort int
|
flagPort int
|
||||||
flagVersion bool
|
flagVersion bool
|
||||||
flagCreateUser bool
|
|
||||||
flagConfig string
|
|
||||||
|
|
||||||
connectionManager ConnectionManager
|
connectionManager ConnectionManager
|
||||||
static http.Handler
|
static http.Handler
|
||||||
config Config
|
config Config
|
||||||
VERSION string
|
|
||||||
|
|
||||||
//go:embed version sql/*
|
|
||||||
embedded embed.FS
|
|
||||||
)
|
)
|
||||||
|
|
||||||
func init() { // {{{
|
func init() {// {{{
|
||||||
version, _ := embedded.ReadFile("version")
|
flag.IntVar(
|
||||||
VERSION = strings.TrimSpace(string(version))
|
&flagPort,
|
||||||
|
"port",
|
||||||
configFilename := os.Getenv("HOME") + "/.config/notes.yaml"
|
1371,
|
||||||
flag.IntVar(&flagPort, "port", 1371, "TCP port to listen on")
|
"TCP port to listen on",
|
||||||
|
)
|
||||||
flag.BoolVar(&flagVersion, "version", false, "Shows Notes version and exists")
|
flag.BoolVar(&flagVersion, "version", false, "Shows Notes version and exists")
|
||||||
flag.BoolVar(&flagCreateUser, "createuser", false, "Create a user and exit")
|
|
||||||
flag.StringVar(&flagConfig, "config", configFilename, "Filename of configuration file")
|
|
||||||
flag.Parse()
|
flag.Parse()
|
||||||
|
|
||||||
if false {
|
if false {
|
||||||
time.Sleep(time.Second * 1)
|
time.Sleep(time.Second*1)
|
||||||
}
|
}
|
||||||
} // }}}
|
}// }}}
|
||||||
func main() { // {{{
|
func main() {// {{{
|
||||||
var err error
|
var err error
|
||||||
|
|
||||||
if flagVersion {
|
if flagVersion {
|
||||||
@ -63,7 +57,7 @@ func main() { // {{{
|
|||||||
|
|
||||||
log.Printf("\x1b[32mNotes\x1b[0m %s\n", VERSION)
|
log.Printf("\x1b[32mNotes\x1b[0m %s\n", VERSION)
|
||||||
|
|
||||||
config, err = ConfigRead(flagConfig)
|
config, err = ConfigRead(os.Getenv("HOME")+"/.config/notes.yaml")
|
||||||
if err != nil {
|
if err != nil {
|
||||||
fmt.Printf("%s\n", err)
|
fmt.Printf("%s\n", err)
|
||||||
os.Exit(1)
|
os.Exit(1)
|
||||||
@ -74,36 +68,27 @@ func main() { // {{{
|
|||||||
os.Exit(1)
|
os.Exit(1)
|
||||||
}
|
}
|
||||||
|
|
||||||
if flagCreateUser {
|
|
||||||
err = createUser()
|
|
||||||
if err != nil {
|
|
||||||
fmt.Println(err)
|
|
||||||
os.Exit(1)
|
|
||||||
}
|
|
||||||
os.Exit(0)
|
|
||||||
}
|
|
||||||
|
|
||||||
connectionManager = NewConnectionManager()
|
connectionManager = NewConnectionManager()
|
||||||
go connectionManager.BroadcastLoop()
|
go connectionManager.BroadcastLoop()
|
||||||
|
|
||||||
static = http.FileServer(http.Dir(config.Application.Directories.Static))
|
static = http.FileServer(http.Dir(config.Application.Directories.Static))
|
||||||
http.HandleFunc("/css_updated", cssUpdateHandler)
|
http.HandleFunc("/css_updated", cssUpdateHandler)
|
||||||
http.HandleFunc("/session/create", sessionCreate)
|
http.HandleFunc("/session/create", sessionCreate)
|
||||||
http.HandleFunc("/session/retrieve", sessionRetrieve)
|
http.HandleFunc("/session/retrieve", sessionRetrieve)
|
||||||
http.HandleFunc("/session/authenticate", sessionAuthenticate)
|
http.HandleFunc("/session/authenticate", sessionAuthenticate)
|
||||||
http.HandleFunc("/user/password", userPassword)
|
http.HandleFunc("/user/password", userPassword)
|
||||||
http.HandleFunc("/node/tree", nodeTree)
|
http.HandleFunc("/node/tree", nodeTree)
|
||||||
http.HandleFunc("/node/retrieve", nodeRetrieve)
|
http.HandleFunc("/node/retrieve", nodeRetrieve)
|
||||||
http.HandleFunc("/node/create", nodeCreate)
|
http.HandleFunc("/node/create", nodeCreate)
|
||||||
http.HandleFunc("/node/update", nodeUpdate)
|
http.HandleFunc("/node/update", nodeUpdate)
|
||||||
http.HandleFunc("/node/rename", nodeRename)
|
http.HandleFunc("/node/rename", nodeRename)
|
||||||
http.HandleFunc("/node/delete", nodeDelete)
|
http.HandleFunc("/node/delete", nodeDelete)
|
||||||
http.HandleFunc("/node/upload", nodeUpload)
|
http.HandleFunc("/node/upload", nodeUpload)
|
||||||
http.HandleFunc("/node/download", nodeDownload)
|
http.HandleFunc("/node/download", nodeDownload)
|
||||||
http.HandleFunc("/node/search", nodeSearch)
|
http.HandleFunc("/node/search", nodeSearch)
|
||||||
http.HandleFunc("/key/retrieve", keyRetrieve)
|
http.HandleFunc("/key/retrieve", keyRetrieve)
|
||||||
http.HandleFunc("/key/create", keyCreate)
|
http.HandleFunc("/key/create", keyCreate)
|
||||||
http.HandleFunc("/key/counter", keyCounter)
|
http.HandleFunc("/key/counter", keyCounter)
|
||||||
http.HandleFunc("/ws", websocketHandler)
|
http.HandleFunc("/ws", websocketHandler)
|
||||||
http.HandleFunc("/", staticHandler)
|
http.HandleFunc("/", staticHandler)
|
||||||
|
|
||||||
@ -111,17 +96,13 @@ func main() { // {{{
|
|||||||
log.Printf("\x1b[32mNotes\x1b[0m Listening on %s\n", listen)
|
log.Printf("\x1b[32mNotes\x1b[0m Listening on %s\n", listen)
|
||||||
log.Printf("\x1b[32mNotes\x1b[0m Answer for domains %s\n", strings.Join(config.Websocket.Domains, ", "))
|
log.Printf("\x1b[32mNotes\x1b[0m Answer for domains %s\n", strings.Join(config.Websocket.Domains, ", "))
|
||||||
http.ListenAndServe(listen, nil)
|
http.ListenAndServe(listen, nil)
|
||||||
} // }}}
|
}// }}}
|
||||||
|
|
||||||
func cssUpdateHandler(w http.ResponseWriter, r *http.Request) { // {{{
|
func cssUpdateHandler(w http.ResponseWriter, r *http.Request) {// {{{
|
||||||
log.Println("[BROADCAST] CSS updated")
|
log.Println("[BROADCAST] CSS updated")
|
||||||
connectionManager.Broadcast(struct {
|
connectionManager.Broadcast(struct{ Ok bool; ID string; Op string }{ Ok: true, Op: "css_reload" })
|
||||||
Ok bool
|
}// }}}
|
||||||
ID string
|
func websocketHandler(w http.ResponseWriter, r *http.Request) {// {{{
|
||||||
Op string
|
|
||||||
}{Ok: true, Op: "css_reload"})
|
|
||||||
} // }}}
|
|
||||||
func websocketHandler(w http.ResponseWriter, r *http.Request) { // {{{
|
|
||||||
var err error
|
var err error
|
||||||
|
|
||||||
_, err = connectionManager.NewConnection(w, r)
|
_, err = connectionManager.NewConnection(w, r)
|
||||||
@ -129,9 +110,9 @@ func websocketHandler(w http.ResponseWriter, r *http.Request) { // {{{
|
|||||||
log.Printf("[Connection] %s\n", err)
|
log.Printf("[Connection] %s\n", err)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
} // }}}
|
}// }}}
|
||||||
func staticHandler(w http.ResponseWriter, r *http.Request) { // {{{
|
func staticHandler(w http.ResponseWriter, r *http.Request) {// {{{
|
||||||
data := struct {
|
data := struct{
|
||||||
VERSION string
|
VERSION string
|
||||||
}{
|
}{
|
||||||
VERSION: VERSION,
|
VERSION: VERSION,
|
||||||
@ -168,9 +149,9 @@ func staticHandler(w http.ResponseWriter, r *http.Request) { // {{{
|
|||||||
if err = tmpl.Execute(w, data); err != nil {
|
if err = tmpl.Execute(w, data); err != nil {
|
||||||
w.Write([]byte(err.Error()))
|
w.Write([]byte(err.Error()))
|
||||||
}
|
}
|
||||||
} // }}}
|
}// }}}
|
||||||
|
|
||||||
func sessionCreate(w http.ResponseWriter, r *http.Request) { // {{{
|
func sessionCreate(w http.ResponseWriter, r *http.Request) {// {{{
|
||||||
log.Println("/session/create")
|
log.Println("/session/create")
|
||||||
session, err := CreateSession()
|
session, err := CreateSession()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@ -178,11 +159,11 @@ func sessionCreate(w http.ResponseWriter, r *http.Request) { // {{{
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
responseData(w, map[string]interface{}{
|
responseData(w, map[string]interface{}{
|
||||||
"OK": true,
|
"OK": true,
|
||||||
"Session": session,
|
"Session": session,
|
||||||
})
|
})
|
||||||
} // }}}
|
}// }}}
|
||||||
func sessionRetrieve(w http.ResponseWriter, r *http.Request) { // {{{
|
func sessionRetrieve(w http.ResponseWriter, r *http.Request) {// {{{
|
||||||
log.Println("/session/retrieve")
|
log.Println("/session/retrieve")
|
||||||
var err error
|
var err error
|
||||||
var found bool
|
var found bool
|
||||||
@ -194,12 +175,12 @@ func sessionRetrieve(w http.ResponseWriter, r *http.Request) { // {{{
|
|||||||
}
|
}
|
||||||
|
|
||||||
responseData(w, map[string]interface{}{
|
responseData(w, map[string]interface{}{
|
||||||
"OK": true,
|
"OK": true,
|
||||||
"Valid": found,
|
"Valid": found,
|
||||||
"Session": session,
|
"Session": session,
|
||||||
})
|
})
|
||||||
} // }}}
|
}// }}}
|
||||||
func sessionAuthenticate(w http.ResponseWriter, r *http.Request) { // {{{
|
func sessionAuthenticate(w http.ResponseWriter, r *http.Request) {// {{{
|
||||||
log.Println("/session/authenticate")
|
log.Println("/session/authenticate")
|
||||||
var err error
|
var err error
|
||||||
var session Session
|
var session Session
|
||||||
@ -211,10 +192,7 @@ func sessionAuthenticate(w http.ResponseWriter, r *http.Request) { // {{{
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
req := struct {
|
req := struct{ Username string; Password string }{}
|
||||||
Username string
|
|
||||||
Password string
|
|
||||||
}{}
|
|
||||||
if err = parseRequest(r, &req); err != nil {
|
if err = parseRequest(r, &req); err != nil {
|
||||||
responseError(w, err)
|
responseError(w, err)
|
||||||
return
|
return
|
||||||
@ -226,13 +204,13 @@ func sessionAuthenticate(w http.ResponseWriter, r *http.Request) { // {{{
|
|||||||
}
|
}
|
||||||
|
|
||||||
responseData(w, map[string]interface{}{
|
responseData(w, map[string]interface{}{
|
||||||
"OK": true,
|
"OK": true,
|
||||||
"Authenticated": authenticated,
|
"Authenticated": authenticated,
|
||||||
"Session": session,
|
"Session": session,
|
||||||
})
|
})
|
||||||
} // }}}
|
}// }}}
|
||||||
|
|
||||||
func userPassword(w http.ResponseWriter, r *http.Request) { // {{{
|
func userPassword(w http.ResponseWriter, r *http.Request) {// {{{
|
||||||
var err error
|
var err error
|
||||||
var ok bool
|
var ok bool
|
||||||
var session Session
|
var session Session
|
||||||
@ -244,7 +222,7 @@ func userPassword(w http.ResponseWriter, r *http.Request) { // {{{
|
|||||||
|
|
||||||
req := struct {
|
req := struct {
|
||||||
CurrentPassword string
|
CurrentPassword string
|
||||||
NewPassword string
|
NewPassword string
|
||||||
}{}
|
}{}
|
||||||
if err = parseRequest(r, &req); err != nil {
|
if err = parseRequest(r, &req); err != nil {
|
||||||
responseError(w, err)
|
responseError(w, err)
|
||||||
@ -258,12 +236,12 @@ func userPassword(w http.ResponseWriter, r *http.Request) { // {{{
|
|||||||
}
|
}
|
||||||
|
|
||||||
responseData(w, map[string]interface{}{
|
responseData(w, map[string]interface{}{
|
||||||
"OK": true,
|
"OK": true,
|
||||||
"CurrentPasswordOK": ok,
|
"CurrentPasswordOK": ok,
|
||||||
})
|
})
|
||||||
} // }}}
|
}// }}}
|
||||||
|
|
||||||
func nodeTree(w http.ResponseWriter, r *http.Request) { // {{{
|
func nodeTree(w http.ResponseWriter, r *http.Request) {// {{{
|
||||||
var err error
|
var err error
|
||||||
var session Session
|
var session Session
|
||||||
|
|
||||||
@ -272,7 +250,7 @@ func nodeTree(w http.ResponseWriter, r *http.Request) { // {{{
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
req := struct{ StartNodeID int }{}
|
req := struct { StartNodeID int }{}
|
||||||
if err = parseRequest(r, &req); err != nil {
|
if err = parseRequest(r, &req); err != nil {
|
||||||
responseError(w, err)
|
responseError(w, err)
|
||||||
return
|
return
|
||||||
@ -285,11 +263,11 @@ func nodeTree(w http.ResponseWriter, r *http.Request) { // {{{
|
|||||||
}
|
}
|
||||||
|
|
||||||
responseData(w, map[string]interface{}{
|
responseData(w, map[string]interface{}{
|
||||||
"OK": true,
|
"OK": true,
|
||||||
"Nodes": nodes,
|
"Nodes": nodes,
|
||||||
})
|
})
|
||||||
} // }}}
|
}// }}}
|
||||||
func nodeRetrieve(w http.ResponseWriter, r *http.Request) { // {{{
|
func nodeRetrieve(w http.ResponseWriter, r *http.Request) {// {{{
|
||||||
log.Println("/node/retrieve")
|
log.Println("/node/retrieve")
|
||||||
var err error
|
var err error
|
||||||
var session Session
|
var session Session
|
||||||
@ -299,7 +277,7 @@ func nodeRetrieve(w http.ResponseWriter, r *http.Request) { // {{{
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
req := struct{ ID int }{}
|
req := struct { ID int }{}
|
||||||
if err = parseRequest(r, &req); err != nil {
|
if err = parseRequest(r, &req); err != nil {
|
||||||
responseError(w, err)
|
responseError(w, err)
|
||||||
return
|
return
|
||||||
@ -312,11 +290,11 @@ func nodeRetrieve(w http.ResponseWriter, r *http.Request) { // {{{
|
|||||||
}
|
}
|
||||||
|
|
||||||
responseData(w, map[string]interface{}{
|
responseData(w, map[string]interface{}{
|
||||||
"OK": true,
|
"OK": true,
|
||||||
"Node": node,
|
"Node": node,
|
||||||
})
|
})
|
||||||
} // }}}
|
}// }}}
|
||||||
func nodeCreate(w http.ResponseWriter, r *http.Request) { // {{{
|
func nodeCreate(w http.ResponseWriter, r *http.Request) {// {{{
|
||||||
log.Println("/node/create")
|
log.Println("/node/create")
|
||||||
var err error
|
var err error
|
||||||
var session Session
|
var session Session
|
||||||
@ -327,7 +305,7 @@ func nodeCreate(w http.ResponseWriter, r *http.Request) { // {{{
|
|||||||
}
|
}
|
||||||
|
|
||||||
req := struct {
|
req := struct {
|
||||||
Name string
|
Name string
|
||||||
ParentID int
|
ParentID int
|
||||||
}{}
|
}{}
|
||||||
if err = parseRequest(r, &req); err != nil {
|
if err = parseRequest(r, &req); err != nil {
|
||||||
@ -342,11 +320,11 @@ func nodeCreate(w http.ResponseWriter, r *http.Request) { // {{{
|
|||||||
}
|
}
|
||||||
|
|
||||||
responseData(w, map[string]interface{}{
|
responseData(w, map[string]interface{}{
|
||||||
"OK": true,
|
"OK": true,
|
||||||
"Node": node,
|
"Node": node,
|
||||||
})
|
})
|
||||||
} // }}}
|
}// }}}
|
||||||
func nodeUpdate(w http.ResponseWriter, r *http.Request) { // {{{
|
func nodeUpdate(w http.ResponseWriter, r *http.Request) {// {{{
|
||||||
log.Println("/node/update")
|
log.Println("/node/update")
|
||||||
var err error
|
var err error
|
||||||
var session Session
|
var session Session
|
||||||
@ -357,8 +335,8 @@ func nodeUpdate(w http.ResponseWriter, r *http.Request) { // {{{
|
|||||||
}
|
}
|
||||||
|
|
||||||
req := struct {
|
req := struct {
|
||||||
NodeID int
|
NodeID int
|
||||||
Content string
|
Content string
|
||||||
CryptoKeyID int
|
CryptoKeyID int
|
||||||
}{}
|
}{}
|
||||||
if err = parseRequest(r, &req); err != nil {
|
if err = parseRequest(r, &req); err != nil {
|
||||||
@ -375,8 +353,8 @@ func nodeUpdate(w http.ResponseWriter, r *http.Request) { // {{{
|
|||||||
responseData(w, map[string]interface{}{
|
responseData(w, map[string]interface{}{
|
||||||
"OK": true,
|
"OK": true,
|
||||||
})
|
})
|
||||||
} // }}}
|
}// }}}
|
||||||
func nodeRename(w http.ResponseWriter, r *http.Request) { // {{{
|
func nodeRename(w http.ResponseWriter, r *http.Request) {// {{{
|
||||||
var err error
|
var err error
|
||||||
var session Session
|
var session Session
|
||||||
|
|
||||||
@ -387,7 +365,7 @@ func nodeRename(w http.ResponseWriter, r *http.Request) { // {{{
|
|||||||
|
|
||||||
req := struct {
|
req := struct {
|
||||||
NodeID int
|
NodeID int
|
||||||
Name string
|
Name string
|
||||||
}{}
|
}{}
|
||||||
if err = parseRequest(r, &req); err != nil {
|
if err = parseRequest(r, &req); err != nil {
|
||||||
responseError(w, err)
|
responseError(w, err)
|
||||||
@ -403,8 +381,8 @@ func nodeRename(w http.ResponseWriter, r *http.Request) { // {{{
|
|||||||
responseData(w, map[string]interface{}{
|
responseData(w, map[string]interface{}{
|
||||||
"OK": true,
|
"OK": true,
|
||||||
})
|
})
|
||||||
} // }}}
|
}// }}}
|
||||||
func nodeDelete(w http.ResponseWriter, r *http.Request) { // {{{
|
func nodeDelete(w http.ResponseWriter, r *http.Request) {// {{{
|
||||||
var err error
|
var err error
|
||||||
var session Session
|
var session Session
|
||||||
|
|
||||||
@ -430,8 +408,8 @@ func nodeDelete(w http.ResponseWriter, r *http.Request) { // {{{
|
|||||||
responseData(w, map[string]interface{}{
|
responseData(w, map[string]interface{}{
|
||||||
"OK": true,
|
"OK": true,
|
||||||
})
|
})
|
||||||
} // }}}
|
}// }}}
|
||||||
func nodeUpload(w http.ResponseWriter, r *http.Request) { // {{{
|
func nodeUpload(w http.ResponseWriter, r *http.Request) {// {{{
|
||||||
log.Println("/node/upload")
|
log.Println("/node/upload")
|
||||||
var err error
|
var err error
|
||||||
var session Session
|
var session Session
|
||||||
@ -466,17 +444,18 @@ func nodeUpload(w http.ResponseWriter, r *http.Request) { // {{{
|
|||||||
md5sumBytes := md5.Sum(fileBytes)
|
md5sumBytes := md5.Sum(fileBytes)
|
||||||
md5sum := hex.EncodeToString(md5sumBytes[:])
|
md5sum := hex.EncodeToString(md5sumBytes[:])
|
||||||
|
|
||||||
|
|
||||||
var nodeID int
|
var nodeID int
|
||||||
if nodeID, err = strconv.Atoi(r.PostFormValue("NodeID")); err != nil {
|
if nodeID, err = strconv.Atoi(r.PostFormValue("NodeID")); err != nil {
|
||||||
responseError(w, err)
|
responseError(w, err)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
nodeFile := File{
|
nodeFile := File{
|
||||||
NodeID: nodeID,
|
NodeID: nodeID,
|
||||||
Filename: handler.Filename,
|
Filename: handler.Filename,
|
||||||
Size: handler.Size,
|
Size: handler.Size,
|
||||||
MIME: handler.Header.Get("Content-Type"),
|
MIME: handler.Header.Get("Content-Type"),
|
||||||
MD5: md5sum,
|
MD5: md5sum,
|
||||||
}
|
}
|
||||||
if err = session.AddFile(&nodeFile); err != nil {
|
if err = session.AddFile(&nodeFile); err != nil {
|
||||||
responseError(w, err)
|
responseError(w, err)
|
||||||
@ -511,11 +490,11 @@ func nodeUpload(w http.ResponseWriter, r *http.Request) { // {{{
|
|||||||
}
|
}
|
||||||
|
|
||||||
responseData(w, map[string]interface{}{
|
responseData(w, map[string]interface{}{
|
||||||
"OK": true,
|
"OK": true,
|
||||||
"File": nodeFile,
|
"File": nodeFile,
|
||||||
})
|
})
|
||||||
} // }}}
|
}// }}}
|
||||||
func nodeDownload(w http.ResponseWriter, r *http.Request) { // {{{
|
func nodeDownload(w http.ResponseWriter, r *http.Request) {// {{{
|
||||||
log.Println("/node/download")
|
log.Println("/node/download")
|
||||||
var err error
|
var err error
|
||||||
var session Session
|
var session Session
|
||||||
@ -545,7 +524,7 @@ func nodeDownload(w http.ResponseWriter, r *http.Request) { // {{{
|
|||||||
responseError(w, fmt.Errorf("File not found"))
|
responseError(w, fmt.Errorf("File not found"))
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
var file *os.File
|
var file *os.File
|
||||||
fname := filepath.Join(
|
fname := filepath.Join(
|
||||||
config.Application.Directories.Upload,
|
config.Application.Directories.Upload,
|
||||||
@ -581,8 +560,8 @@ func nodeDownload(w http.ResponseWriter, r *http.Request) { // {{{
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
} // }}}
|
}// }}}
|
||||||
func nodeFiles(w http.ResponseWriter, r *http.Request) { // {{{
|
func nodeFiles(w http.ResponseWriter, r *http.Request) {// {{{
|
||||||
var err error
|
var err error
|
||||||
var session Session
|
var session Session
|
||||||
var files []File
|
var files []File
|
||||||
@ -607,11 +586,11 @@ func nodeFiles(w http.ResponseWriter, r *http.Request) { // {{{
|
|||||||
}
|
}
|
||||||
|
|
||||||
responseData(w, map[string]interface{}{
|
responseData(w, map[string]interface{}{
|
||||||
"OK": true,
|
"OK": true,
|
||||||
"Files": files,
|
"Files": files,
|
||||||
})
|
})
|
||||||
} // }}}
|
}// }}}
|
||||||
func nodeSearch(w http.ResponseWriter, r *http.Request) { // {{{
|
func nodeSearch(w http.ResponseWriter, r *http.Request) {// {{{
|
||||||
log.Println("/node/search")
|
log.Println("/node/search")
|
||||||
var err error
|
var err error
|
||||||
var session Session
|
var session Session
|
||||||
@ -637,12 +616,12 @@ func nodeSearch(w http.ResponseWriter, r *http.Request) { // {{{
|
|||||||
}
|
}
|
||||||
|
|
||||||
responseData(w, map[string]interface{}{
|
responseData(w, map[string]interface{}{
|
||||||
"OK": true,
|
"OK": true,
|
||||||
"Nodes": nodes,
|
"Nodes": nodes,
|
||||||
})
|
})
|
||||||
} // }}}
|
}// }}}
|
||||||
|
|
||||||
func keyRetrieve(w http.ResponseWriter, r *http.Request) { // {{{
|
func keyRetrieve(w http.ResponseWriter, r *http.Request) {// {{{
|
||||||
log.Println("/key/retrieve")
|
log.Println("/key/retrieve")
|
||||||
var err error
|
var err error
|
||||||
var session Session
|
var session Session
|
||||||
@ -659,11 +638,11 @@ func keyRetrieve(w http.ResponseWriter, r *http.Request) { // {{{
|
|||||||
}
|
}
|
||||||
|
|
||||||
responseData(w, map[string]interface{}{
|
responseData(w, map[string]interface{}{
|
||||||
"OK": true,
|
"OK": true,
|
||||||
"Keys": keys,
|
"Keys": keys,
|
||||||
})
|
})
|
||||||
} // }}}
|
}// }}}
|
||||||
func keyCreate(w http.ResponseWriter, r *http.Request) { // {{{
|
func keyCreate(w http.ResponseWriter, r *http.Request) {// {{{
|
||||||
log.Println("/key/create")
|
log.Println("/key/create")
|
||||||
var err error
|
var err error
|
||||||
var session Session
|
var session Session
|
||||||
@ -675,7 +654,7 @@ func keyCreate(w http.ResponseWriter, r *http.Request) { // {{{
|
|||||||
|
|
||||||
req := struct {
|
req := struct {
|
||||||
Description string
|
Description string
|
||||||
Key string
|
Key string
|
||||||
}{}
|
}{}
|
||||||
if err = parseRequest(r, &req); err != nil {
|
if err = parseRequest(r, &req); err != nil {
|
||||||
responseError(w, err)
|
responseError(w, err)
|
||||||
@ -689,11 +668,11 @@ func keyCreate(w http.ResponseWriter, r *http.Request) { // {{{
|
|||||||
}
|
}
|
||||||
|
|
||||||
responseData(w, map[string]interface{}{
|
responseData(w, map[string]interface{}{
|
||||||
"OK": true,
|
"OK": true,
|
||||||
"Key": key,
|
"Key": key,
|
||||||
})
|
})
|
||||||
} // }}}
|
}// }}}
|
||||||
func keyCounter(w http.ResponseWriter, r *http.Request) { // {{{
|
func keyCounter(w http.ResponseWriter, r *http.Request) {// {{{
|
||||||
log.Println("/key/counter")
|
log.Println("/key/counter")
|
||||||
var err error
|
var err error
|
||||||
var session Session
|
var session Session
|
||||||
@ -714,9 +693,9 @@ func keyCounter(w http.ResponseWriter, r *http.Request) { // {{{
|
|||||||
// Javascript uses int32, thus getting a string counter for Javascript BigInt to parse.
|
// Javascript uses int32, thus getting a string counter for Javascript BigInt to parse.
|
||||||
"Counter": strconv.FormatInt(counter, 10),
|
"Counter": strconv.FormatInt(counter, 10),
|
||||||
})
|
})
|
||||||
} // }}}
|
}// }}}
|
||||||
|
|
||||||
func newTemplate(requestPath string) (tmpl *template.Template, err error) { // {{{
|
func newTemplate(requestPath string) (tmpl *template.Template, err error) {// {{{
|
||||||
// Append index.html if needed for further reading of the file
|
// Append index.html if needed for further reading of the file
|
||||||
p := requestPath
|
p := requestPath
|
||||||
if p[len(p)-1] == '/' {
|
if p[len(p)-1] == '/' {
|
||||||
@ -725,11 +704,9 @@ func newTemplate(requestPath string) (tmpl *template.Template, err error) { // {
|
|||||||
p = config.Application.Directories.Static + p
|
p = config.Application.Directories.Static + p
|
||||||
|
|
||||||
base := path.Base(p)
|
base := path.Base(p)
|
||||||
if tmpl, err = template.New(base).ParseFiles(p); err != nil {
|
if tmpl, err = template.New(base).ParseFiles(p); err != nil { return }
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
return
|
return
|
||||||
} // }}}
|
}// }}}
|
||||||
|
|
||||||
// vim: foldmethod=marker
|
// vim: foldmethod=marker
|
||||||
|
@ -205,7 +205,6 @@ header .menu {
|
|||||||
#tree .node .name {
|
#tree .node .name {
|
||||||
white-space: nowrap;
|
white-space: nowrap;
|
||||||
cursor: pointer;
|
cursor: pointer;
|
||||||
user-select: none;
|
|
||||||
}
|
}
|
||||||
#tree .node .name:hover {
|
#tree .node .name:hover {
|
||||||
color: #ecbf00;
|
color: #ecbf00;
|
||||||
|
@ -232,7 +232,6 @@ header {
|
|||||||
.name {
|
.name {
|
||||||
white-space: nowrap;
|
white-space: nowrap;
|
||||||
cursor: pointer;
|
cursor: pointer;
|
||||||
user-select: none;
|
|
||||||
|
|
||||||
&:hover {
|
&:hover {
|
||||||
color: @accent_2;
|
color: @accent_2;
|
||||||
|
42
user.go
42
user.go
@ -3,7 +3,6 @@ package main
|
|||||||
import (
|
import (
|
||||||
// Standard
|
// Standard
|
||||||
"database/sql"
|
"database/sql"
|
||||||
"fmt"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
func (session Session) UpdatePassword(currPass, newPass string) (ok bool, err error) {
|
func (session Session) UpdatePassword(currPass, newPass string) (ok bool, err error) {
|
||||||
@ -25,9 +24,9 @@ func (session Session) UpdatePassword(currPass, newPass string) (ok bool, err er
|
|||||||
password=password_hash(SUBSTRING(password FROM 1 FOR 32), $3::bytea)
|
password=password_hash(SUBSTRING(password FROM 1 FOR 32), $3::bytea)
|
||||||
RETURNING id
|
RETURNING id
|
||||||
`,
|
`,
|
||||||
newPass,
|
newPass,
|
||||||
session.UserID,
|
session.UserID,
|
||||||
currPass,
|
currPass,
|
||||||
)
|
)
|
||||||
|
|
||||||
if rowsAffected, err = result.RowsAffected(); err != nil {
|
if rowsAffected, err = result.RowsAffected(); err != nil {
|
||||||
@ -36,38 +35,3 @@ func (session Session) UpdatePassword(currPass, newPass string) (ok bool, err er
|
|||||||
|
|
||||||
return rowsAffected > 0, nil
|
return rowsAffected > 0, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func createUser() (err error) {
|
|
||||||
var username, password string
|
|
||||||
fmt.Printf("Username: ")
|
|
||||||
fmt.Scanln(&username)
|
|
||||||
fmt.Printf("Password: ")
|
|
||||||
fmt.Scanln(&password)
|
|
||||||
|
|
||||||
err = CreateDbUser(username, password)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
func CreateDbUser(username string, password string) (err error) {
|
|
||||||
var result sql.Result
|
|
||||||
|
|
||||||
result, err = db.Exec(`
|
|
||||||
INSERT INTO public.user(username, password)
|
|
||||||
VALUES(
|
|
||||||
$1,
|
|
||||||
password_hash(
|
|
||||||
/* salt in hex */
|
|
||||||
ENCODE(gen_random_bytes(16), 'hex'),
|
|
||||||
|
|
||||||
/* password */
|
|
||||||
$2::bytea
|
|
||||||
)
|
|
||||||
)
|
|
||||||
`,
|
|
||||||
username,
|
|
||||||
password,
|
|
||||||
)
|
|
||||||
|
|
||||||
_, err = result.RowsAffected()
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
Loading…
Reference in New Issue
Block a user