Compare commits

...

4 Commits

Author SHA1 Message Date
Magnus Åhall
6cb4833dbd Added structure to readme 2023-12-28 08:13:21 +01:00
Magnus Åhall
aef8f1a572 Create a user from command line 2023-12-28 08:08:59 +01:00
Magnus Åhall
392aff5956 Version handling from file 2023-12-28 07:47:23 +01:00
Magnus Åhall
ac58fa0fc8 Tree nodes aren't selectable 2023-07-22 10:50:24 +02:00
8 changed files with 213 additions and 120 deletions

36
README.md Normal file
View File

@ -0,0 +1,36 @@
# 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
View File

@ -4,7 +4,6 @@
- per file
- when deleting node and child nodes
* Move node
* Tree titles should be user-select none
Long term

4
db.go
View File

@ -6,7 +6,6 @@ import (
_ "github.com/lib/pq"
// Standard
"embed"
"errors"
"fmt"
"log"
@ -16,9 +15,6 @@ import (
var (
dbConn string
db *sqlx.DB
//go:embed sql/*
embedded embed.FS
)
func dbInit() (err error) {// {{{

157
main.go
View File

@ -3,8 +3,8 @@ package main
import (
// Standard
"crypto/md5"
"embed"
"encoding/hex"
"path/filepath"
"flag"
"fmt"
"html/template"
@ -13,41 +13,47 @@ import (
"net/http"
"os"
"path"
"path/filepath"
"regexp"
"strings"
"strconv"
"strings"
"time"
_ "embed"
)
const VERSION = "v13";
const LISTEN_HOST = "0.0.0.0";
const LISTEN_HOST = "0.0.0.0"
const DB_SCHEMA = 13
var (
flagPort int
flagVersion bool
flagCreateUser bool
flagConfig string
connectionManager ConnectionManager
static http.Handler
config Config
VERSION string
//go:embed version sql/*
embedded embed.FS
)
func init() {// {{{
flag.IntVar(
&flagPort,
"port",
1371,
"TCP port to listen on",
)
flag.BoolVar(&flagVersion, "version", false, "Shows Notes version and exists")
func init() { // {{{
version, _ := embedded.ReadFile("version")
VERSION = strings.TrimSpace(string(version))
configFilename := os.Getenv("HOME") + "/.config/notes.yaml"
flag.IntVar(&flagPort, "port", 1371, "TCP port to listen on")
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()
if false {
time.Sleep(time.Second*1)
time.Sleep(time.Second * 1)
}
}// }}}
func main() {// {{{
} // }}}
func main() { // {{{
var err error
if flagVersion {
@ -57,7 +63,7 @@ func main() {// {{{
log.Printf("\x1b[32mNotes\x1b[0m %s\n", VERSION)
config, err = ConfigRead(os.Getenv("HOME")+"/.config/notes.yaml")
config, err = ConfigRead(flagConfig)
if err != nil {
fmt.Printf("%s\n", err)
os.Exit(1)
@ -68,6 +74,15 @@ func main() {// {{{
os.Exit(1)
}
if flagCreateUser {
err = createUser()
if err != nil {
fmt.Println(err)
os.Exit(1)
}
os.Exit(0)
}
connectionManager = NewConnectionManager()
go connectionManager.BroadcastLoop()
@ -96,13 +111,17 @@ func main() {// {{{
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, ", "))
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")
connectionManager.Broadcast(struct{ Ok bool; ID string; Op string }{ Ok: true, Op: "css_reload" })
}// }}}
func websocketHandler(w http.ResponseWriter, r *http.Request) {// {{{
connectionManager.Broadcast(struct {
Ok bool
ID string
Op string
}{Ok: true, Op: "css_reload"})
} // }}}
func websocketHandler(w http.ResponseWriter, r *http.Request) { // {{{
var err error
_, err = connectionManager.NewConnection(w, r)
@ -110,9 +129,9 @@ func websocketHandler(w http.ResponseWriter, r *http.Request) {// {{{
log.Printf("[Connection] %s\n", err)
return
}
}// }}}
func staticHandler(w http.ResponseWriter, r *http.Request) {// {{{
data := struct{
} // }}}
func staticHandler(w http.ResponseWriter, r *http.Request) { // {{{
data := struct {
VERSION string
}{
VERSION: VERSION,
@ -149,9 +168,9 @@ func staticHandler(w http.ResponseWriter, r *http.Request) {// {{{
if err = tmpl.Execute(w, data); err != nil {
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")
session, err := CreateSession()
if err != nil {
@ -162,8 +181,8 @@ func sessionCreate(w http.ResponseWriter, r *http.Request) {// {{{
"OK": true,
"Session": session,
})
}// }}}
func sessionRetrieve(w http.ResponseWriter, r *http.Request) {// {{{
} // }}}
func sessionRetrieve(w http.ResponseWriter, r *http.Request) { // {{{
log.Println("/session/retrieve")
var err error
var found bool
@ -179,8 +198,8 @@ func sessionRetrieve(w http.ResponseWriter, r *http.Request) {// {{{
"Valid": found,
"Session": session,
})
}// }}}
func sessionAuthenticate(w http.ResponseWriter, r *http.Request) {// {{{
} // }}}
func sessionAuthenticate(w http.ResponseWriter, r *http.Request) { // {{{
log.Println("/session/authenticate")
var err error
var session Session
@ -192,7 +211,10 @@ func sessionAuthenticate(w http.ResponseWriter, r *http.Request) {// {{{
return
}
req := struct{ Username string; Password string }{}
req := struct {
Username string
Password string
}{}
if err = parseRequest(r, &req); err != nil {
responseError(w, err)
return
@ -208,9 +230,9 @@ func sessionAuthenticate(w http.ResponseWriter, r *http.Request) {// {{{
"Authenticated": authenticated,
"Session": session,
})
}// }}}
} // }}}
func userPassword(w http.ResponseWriter, r *http.Request) {// {{{
func userPassword(w http.ResponseWriter, r *http.Request) { // {{{
var err error
var ok bool
var session Session
@ -239,9 +261,9 @@ func userPassword(w http.ResponseWriter, r *http.Request) {// {{{
"OK": true,
"CurrentPasswordOK": ok,
})
}// }}}
} // }}}
func nodeTree(w http.ResponseWriter, r *http.Request) {// {{{
func nodeTree(w http.ResponseWriter, r *http.Request) { // {{{
var err error
var session Session
@ -250,7 +272,7 @@ func nodeTree(w http.ResponseWriter, r *http.Request) {// {{{
return
}
req := struct { StartNodeID int }{}
req := struct{ StartNodeID int }{}
if err = parseRequest(r, &req); err != nil {
responseError(w, err)
return
@ -266,8 +288,8 @@ func nodeTree(w http.ResponseWriter, r *http.Request) {// {{{
"OK": true,
"Nodes": nodes,
})
}// }}}
func nodeRetrieve(w http.ResponseWriter, r *http.Request) {// {{{
} // }}}
func nodeRetrieve(w http.ResponseWriter, r *http.Request) { // {{{
log.Println("/node/retrieve")
var err error
var session Session
@ -277,7 +299,7 @@ func nodeRetrieve(w http.ResponseWriter, r *http.Request) {// {{{
return
}
req := struct { ID int }{}
req := struct{ ID int }{}
if err = parseRequest(r, &req); err != nil {
responseError(w, err)
return
@ -293,8 +315,8 @@ func nodeRetrieve(w http.ResponseWriter, r *http.Request) {// {{{
"OK": true,
"Node": node,
})
}// }}}
func nodeCreate(w http.ResponseWriter, r *http.Request) {// {{{
} // }}}
func nodeCreate(w http.ResponseWriter, r *http.Request) { // {{{
log.Println("/node/create")
var err error
var session Session
@ -323,8 +345,8 @@ func nodeCreate(w http.ResponseWriter, r *http.Request) {// {{{
"OK": true,
"Node": node,
})
}// }}}
func nodeUpdate(w http.ResponseWriter, r *http.Request) {// {{{
} // }}}
func nodeUpdate(w http.ResponseWriter, r *http.Request) { // {{{
log.Println("/node/update")
var err error
var session Session
@ -353,8 +375,8 @@ func nodeUpdate(w http.ResponseWriter, r *http.Request) {// {{{
responseData(w, map[string]interface{}{
"OK": true,
})
}// }}}
func nodeRename(w http.ResponseWriter, r *http.Request) {// {{{
} // }}}
func nodeRename(w http.ResponseWriter, r *http.Request) { // {{{
var err error
var session Session
@ -381,8 +403,8 @@ func nodeRename(w http.ResponseWriter, r *http.Request) {// {{{
responseData(w, map[string]interface{}{
"OK": true,
})
}// }}}
func nodeDelete(w http.ResponseWriter, r *http.Request) {// {{{
} // }}}
func nodeDelete(w http.ResponseWriter, r *http.Request) { // {{{
var err error
var session Session
@ -408,8 +430,8 @@ func nodeDelete(w http.ResponseWriter, r *http.Request) {// {{{
responseData(w, map[string]interface{}{
"OK": true,
})
}// }}}
func nodeUpload(w http.ResponseWriter, r *http.Request) {// {{{
} // }}}
func nodeUpload(w http.ResponseWriter, r *http.Request) { // {{{
log.Println("/node/upload")
var err error
var session Session
@ -444,7 +466,6 @@ func nodeUpload(w http.ResponseWriter, r *http.Request) {// {{{
md5sumBytes := md5.Sum(fileBytes)
md5sum := hex.EncodeToString(md5sumBytes[:])
var nodeID int
if nodeID, err = strconv.Atoi(r.PostFormValue("NodeID")); err != nil {
responseError(w, err)
@ -493,8 +514,8 @@ func nodeUpload(w http.ResponseWriter, r *http.Request) {// {{{
"OK": true,
"File": nodeFile,
})
}// }}}
func nodeDownload(w http.ResponseWriter, r *http.Request) {// {{{
} // }}}
func nodeDownload(w http.ResponseWriter, r *http.Request) { // {{{
log.Println("/node/download")
var err error
var session Session
@ -560,8 +581,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 session Session
var files []File
@ -589,8 +610,8 @@ func nodeFiles(w http.ResponseWriter, r *http.Request) {// {{{
"OK": true,
"Files": files,
})
}// }}}
func nodeSearch(w http.ResponseWriter, r *http.Request) {// {{{
} // }}}
func nodeSearch(w http.ResponseWriter, r *http.Request) { // {{{
log.Println("/node/search")
var err error
var session Session
@ -619,9 +640,9 @@ func nodeSearch(w http.ResponseWriter, r *http.Request) {// {{{
"OK": true,
"Nodes": nodes,
})
}// }}}
} // }}}
func keyRetrieve(w http.ResponseWriter, r *http.Request) {// {{{
func keyRetrieve(w http.ResponseWriter, r *http.Request) { // {{{
log.Println("/key/retrieve")
var err error
var session Session
@ -641,8 +662,8 @@ func keyRetrieve(w http.ResponseWriter, r *http.Request) {// {{{
"OK": true,
"Keys": keys,
})
}// }}}
func keyCreate(w http.ResponseWriter, r *http.Request) {// {{{
} // }}}
func keyCreate(w http.ResponseWriter, r *http.Request) { // {{{
log.Println("/key/create")
var err error
var session Session
@ -671,8 +692,8 @@ func keyCreate(w http.ResponseWriter, r *http.Request) {// {{{
"OK": true,
"Key": key,
})
}// }}}
func keyCounter(w http.ResponseWriter, r *http.Request) {// {{{
} // }}}
func keyCounter(w http.ResponseWriter, r *http.Request) { // {{{
log.Println("/key/counter")
var err error
var session Session
@ -693,9 +714,9 @@ func keyCounter(w http.ResponseWriter, r *http.Request) {// {{{
// Javascript uses int32, thus getting a string counter for Javascript BigInt to parse.
"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
p := requestPath
if p[len(p)-1] == '/' {
@ -704,9 +725,11 @@ func newTemplate(requestPath string) (tmpl *template.Template, err error) {// {{
p = config.Application.Directories.Static + p
base := path.Base(p)
if tmpl, err = template.New(base).ParseFiles(p); err != nil { return }
if tmpl, err = template.New(base).ParseFiles(p); err != nil {
return
}
return
}// }}}
} // }}}
// vim: foldmethod=marker

View File

@ -205,6 +205,7 @@ header .menu {
#tree .node .name {
white-space: nowrap;
cursor: pointer;
user-select: none;
}
#tree .node .name:hover {
color: #ecbf00;

View File

@ -232,6 +232,7 @@ header {
.name {
white-space: nowrap;
cursor: pointer;
user-select: none;
&:hover {
color: @accent_2;

36
user.go
View File

@ -3,6 +3,7 @@ package main
import (
// Standard
"database/sql"
"fmt"
)
func (session Session) UpdatePassword(currPass, newPass string) (ok bool, err error) {
@ -35,3 +36,38 @@ func (session Session) UpdatePassword(currPass, newPass string) (ok bool, err er
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
}

1
version Normal file
View File

@ -0,0 +1 @@
v14