Compare commits
11 Commits
v0.11.0
...
a952490188
| Author | SHA1 | Date | |
|---|---|---|---|
| a952490188 | |||
| 1f5cb683fb | |||
| b4328edd73 | |||
| a8878e1e20 | |||
| 656be379e4 | |||
| 279471a554 | |||
| d2672816cd | |||
| 92deac2d56 | |||
| 35636e9ca3 | |||
| 4fa29f2719 | |||
| 894f34e3ef |
@@ -6,8 +6,10 @@ import "flag"
|
|||||||
import "image"
|
import "image"
|
||||||
import "strings"
|
import "strings"
|
||||||
import "net/url"
|
import "net/url"
|
||||||
|
import "path/filepath"
|
||||||
import "git.tebibyte.media/tomo/tomo"
|
import "git.tebibyte.media/tomo/tomo"
|
||||||
import "git.tebibyte.media/tomo/objects"
|
import "git.tebibyte.media/tomo/objects"
|
||||||
|
import "git.tebibyte.media/tomo/nasin/config"
|
||||||
import "git.tebibyte.media/tomo/nasin/internal/registrar"
|
import "git.tebibyte.media/tomo/nasin/internal/registrar"
|
||||||
|
|
||||||
// Application represents an application object.
|
// Application represents an application object.
|
||||||
@@ -15,9 +17,12 @@ type Application interface {
|
|||||||
// Describe returns a description of the application.
|
// Describe returns a description of the application.
|
||||||
Describe () ApplicationDescription
|
Describe () ApplicationDescription
|
||||||
|
|
||||||
// Init performs the initial setup of the application. This behavior
|
// Init performs the initial setup of the application.
|
||||||
// should return a window if it creates one.
|
Init () (error)
|
||||||
Init () (tomo.Window, error)
|
|
||||||
|
// Stop stops the application and does not return until all ongoing
|
||||||
|
// operations have been completely shut down.
|
||||||
|
Stop ()
|
||||||
}
|
}
|
||||||
|
|
||||||
// ApplicationURLOpener is an application that can open a URL.
|
// ApplicationURLOpener is an application that can open a URL.
|
||||||
@@ -30,15 +35,11 @@ type ApplicationURLOpener interface {
|
|||||||
//
|
//
|
||||||
// Applications should support the file:// scheme at the very least, and
|
// Applications should support the file:// scheme at the very least, and
|
||||||
// should also support others like http:// and https:// if possible.
|
// should also support others like http:// and https:// if possible.
|
||||||
//
|
OpenURL (*url.URL) error
|
||||||
// This behavior should return a window if it creates one.
|
|
||||||
OpenURL (*url.URL) (tomo.Window, error)
|
|
||||||
|
|
||||||
// OpenNone is called when the application is launched without any URLs
|
// OpenNone is called when the application is launched without any URLs
|
||||||
// to open. The application may create some sort of default starting
|
// to open.
|
||||||
// window, or do nothing. This behavior should return a window if it
|
OpenNone () error
|
||||||
// creates one.
|
|
||||||
OpenNone () (tomo.Window, error)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// ApplicationFlagAdder is an application that supports reading command line
|
// ApplicationFlagAdder is an application that supports reading command line
|
||||||
@@ -152,18 +153,18 @@ func RunApplication (application Application) {
|
|||||||
if err != nil { log.Fatalln("nasin: could not set icon set:", err) }
|
if err != nil { log.Fatalln("nasin: could not set icon set:", err) }
|
||||||
err = reg.SetFaceSet()
|
err = reg.SetFaceSet()
|
||||||
if err != nil { log.Fatalln("nasin: could not set face set:", err) }
|
if err != nil { log.Fatalln("nasin: could not set face set:", err) }
|
||||||
window, err := application.Init()
|
err = application.Init()
|
||||||
if err != nil { log.Fatalln("nasin: could not run application:", err) }
|
if err != nil { log.Fatalln("nasin: could not run application:", err) }
|
||||||
manageWindow(window)
|
|
||||||
|
|
||||||
// open URLs
|
// open URLs
|
||||||
args := flag.Args()
|
args := flag.Args()
|
||||||
applicationOpenUrls(application, args...)
|
applicationOpenUrls(application, args...)
|
||||||
|
|
||||||
if windows > 0 {
|
if manager.count > 0 {
|
||||||
err = backend.Run()
|
err = backend.Run()
|
||||||
if err != nil { log.Fatalln("nasin: could not run application:", err) }
|
if err != nil { log.Fatalln("nasin: could not run application:", err) }
|
||||||
}
|
}
|
||||||
|
application.Stop()
|
||||||
}
|
}
|
||||||
|
|
||||||
// NewApplicationWindow creates a window for an application. It will
|
// NewApplicationWindow creates a window for an application. It will
|
||||||
@@ -181,17 +182,18 @@ func NewApplicationWindow (application Application, bounds image.Rectangle) (tom
|
|||||||
return window, nil
|
return window, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
var windows int
|
// ApplicationConfig opens a new config for the specified application. It must
|
||||||
|
// be closed when it is no longer needed.
|
||||||
func manageWindow (window tomo.Window) {
|
func ApplicationConfig (app ApplicationDescription) (config.ConfigCloser, error) {
|
||||||
if window == nil { return }
|
user, err := ApplicationUserConfigDir(app)
|
||||||
windows ++
|
if err != nil { return nil, err }
|
||||||
window.OnClose(func () {
|
user = filepath.Join(user, "config.conf")
|
||||||
windows --
|
system, err := ApplicationSystemConfigDirs(app)
|
||||||
if windows < 1 {
|
if err != nil { return nil, err }
|
||||||
tomo.Stop()
|
for index, path := range system {
|
||||||
|
system[index] = filepath.Join(path, "config.conf")
|
||||||
}
|
}
|
||||||
})
|
return config.NewConfig(user, system...)
|
||||||
}
|
}
|
||||||
|
|
||||||
func errorPopupf (title, format string, v ...any) func (func ()) {
|
func errorPopupf (title, format string, v ...any) func (func ()) {
|
||||||
@@ -203,7 +205,7 @@ func errorPopupf (title, format string, v ...any) func (func ()) {
|
|||||||
callback)
|
callback)
|
||||||
if err != nil { log.Fatal(err) }
|
if err != nil { log.Fatal(err) }
|
||||||
dialog.SetVisible(true)
|
dialog.SetVisible(true)
|
||||||
manageWindow(dialog)
|
WaitFor(dialog)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -217,12 +219,11 @@ func applicationOpenUrls (app Application, args ...string) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
openNone := func () bool {
|
openNone := func () bool {
|
||||||
window, err := application.OpenNone()
|
err := application.OpenNone()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatalf("nasin: could not open main window: %v", err)
|
log.Fatalf("nasin: could not open main window: %v", err)
|
||||||
return false
|
return false
|
||||||
}
|
}
|
||||||
manageWindow(window)
|
|
||||||
return true
|
return true
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -242,7 +243,7 @@ func applicationOpenUrls (app Application, args ...string) {
|
|||||||
if ur.Scheme == "" {
|
if ur.Scheme == "" {
|
||||||
ur.Scheme = "file"
|
ur.Scheme = "file"
|
||||||
}
|
}
|
||||||
window, err := application.OpenURL(ur)
|
err = application.OpenURL(ur)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
errorPopupf(
|
errorPopupf(
|
||||||
"Could Not Open URL",
|
"Could Not Open URL",
|
||||||
@@ -254,7 +255,6 @@ func applicationOpenUrls (app Application, args ...string) {
|
|||||||
}
|
}
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
manageWindow(window)
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
155
config/config.go
Normal file
155
config/config.go
Normal file
@@ -0,0 +1,155 @@
|
|||||||
|
// Package config provides a configuration system for applications.
|
||||||
|
package config
|
||||||
|
|
||||||
|
import "fmt"
|
||||||
|
import "math"
|
||||||
|
import "strconv"
|
||||||
|
import "git.tebibyte.media/tomo/tomo/event"
|
||||||
|
|
||||||
|
type configError string;
|
||||||
|
func (err configError) Error () string { return string(err) }
|
||||||
|
|
||||||
|
const (
|
||||||
|
// ErrClosed is returned when Get/Set/Reset is called after the config
|
||||||
|
// has been closed.
|
||||||
|
ErrClosed = configError("attempt to access a closed config")
|
||||||
|
// ErrNonexistentEntry is returned when an entry was not found.
|
||||||
|
ErrNonexistentEntry = configError("nonexistent entry")
|
||||||
|
// ErrMalformedEntry is returned when a config entry could not be
|
||||||
|
// parsed.
|
||||||
|
ErrMalformedEntry = configError("malformed entry")
|
||||||
|
// ErrMalformedKey is returned when a key has invalid runes.
|
||||||
|
ErrMalformedKey = configError("malformed key")
|
||||||
|
// ErrMalformedValue is returned when a value could not be parsed.
|
||||||
|
ErrMalformedValue = configError("malformed value")
|
||||||
|
// ErrMalformedString is returned when a string value could not be
|
||||||
|
// parsed.
|
||||||
|
ErrMalformedStringValue = configError("malformed string value")
|
||||||
|
// ErrMalformedNumber is returned when a number value could not be
|
||||||
|
// parsed.
|
||||||
|
ErrMalformedNumberValue = configError("malformed number value")
|
||||||
|
// ErrMalformedBool is returned when a boolean value could not be
|
||||||
|
// parsed.
|
||||||
|
ErrMalformedBoolValue = configError("malformed bool value")
|
||||||
|
// ErrMalformedEscapeSequence us returned when an escape sequence could
|
||||||
|
// not be parsed.
|
||||||
|
ErrMalformedEscapeSequence = configError("malformed escape sequence")
|
||||||
|
)
|
||||||
|
|
||||||
|
// Config provides access to an application's configuration, and can notify an
|
||||||
|
// application of changes to it.
|
||||||
|
type Config interface {
|
||||||
|
// Get gets a value, first considering the user-level config file, and
|
||||||
|
// then falling back to system level config files. If the value could
|
||||||
|
// not be found anywhere, the specified fallback value is returned. If
|
||||||
|
// the key is invalid, it returns nil, ErrMalformedKey.
|
||||||
|
Get (key string, fallback Value) (Value, error)
|
||||||
|
// GetString is like Get, but will only return strings. If the value is
|
||||||
|
// not a string, it will return fallback.
|
||||||
|
GetString (key string, fallback string) (string, error)
|
||||||
|
// GetNumber is like Get, but will only return numbers. If the value is
|
||||||
|
// not a number, it will return fallback.
|
||||||
|
GetNumber (key string, fallback float64) (float64, error)
|
||||||
|
// GetBool is like Get, but will only return booleans. If the value is
|
||||||
|
// not a boolean, it will return fallback.
|
||||||
|
GetBool (key string, fallback bool) (bool, error)
|
||||||
|
// Set sets a value in the user-level config file. If the key is
|
||||||
|
// invalid, it returns ErrMalformedKey.
|
||||||
|
Set (key string, value Value) error
|
||||||
|
// Reset removes the value from the user-level config file, resetting it
|
||||||
|
// to what is described by the system-level config files. If the key is
|
||||||
|
// invalid, it returns ErrMalformedKey.
|
||||||
|
Reset (key string) error
|
||||||
|
// OnChange specifies a function to be called whenever a value is
|
||||||
|
// changed. The callback is always run within the backend's event loop
|
||||||
|
// using tomo.Do. This could have been a channel but I didn't want to do
|
||||||
|
// that to people.
|
||||||
|
OnChange (func (key string)) event.Cookie
|
||||||
|
}
|
||||||
|
|
||||||
|
// ConfigCloser is a config with a Close behavior, which stops watching the
|
||||||
|
// config file and causes any subsequent sets/gets to return errors. Anything
|
||||||
|
// that receives a ConfigCloser must close it when done.
|
||||||
|
type ConfigCloser interface {
|
||||||
|
Config
|
||||||
|
// Close closes the config, causing it to stop watching for changes.
|
||||||
|
// Reads or writes to the config after this will return an error.
|
||||||
|
Close () error
|
||||||
|
}
|
||||||
|
|
||||||
|
var negativeZero = math.Copysign(0, -1)
|
||||||
|
|
||||||
|
// Value is a config value. Its String behavior produces a lossless and
|
||||||
|
// syntactically valid representation of the value.
|
||||||
|
type Value interface {
|
||||||
|
value ()
|
||||||
|
fmt.Stringer
|
||||||
|
Equals (Value) bool
|
||||||
|
}
|
||||||
|
|
||||||
|
// ValueString is a string value.
|
||||||
|
type ValueString string
|
||||||
|
var _ Value = ValueString("")
|
||||||
|
func (ValueString) value () { }
|
||||||
|
func (value ValueString) Equals (other Value) bool {
|
||||||
|
other, ok := other.(ValueString)
|
||||||
|
return ok && value == other
|
||||||
|
}
|
||||||
|
func (value ValueString) String () string {
|
||||||
|
return fmt.Sprintf("\"%s\"", escape(string(value)))
|
||||||
|
}
|
||||||
|
|
||||||
|
// ValueNumber is a number value.
|
||||||
|
type ValueNumber float64
|
||||||
|
var _ Value = ValueNumber(0)
|
||||||
|
func (ValueNumber) value () { }
|
||||||
|
func (value ValueNumber) Equals (other Value) bool {
|
||||||
|
other, ok := other.(ValueNumber)
|
||||||
|
return ok && value == other
|
||||||
|
}
|
||||||
|
func (value ValueNumber) String () string {
|
||||||
|
number := float64(value)
|
||||||
|
// the requirements I wrote said lossless in all cases. here's lossless
|
||||||
|
// in all cases!
|
||||||
|
switch {
|
||||||
|
case math.IsInf(number, 0):
|
||||||
|
if math.Signbit(number) {
|
||||||
|
return "-Inf"
|
||||||
|
} else {
|
||||||
|
return "Inf"
|
||||||
|
}
|
||||||
|
|
||||||
|
case math.IsNaN(number):
|
||||||
|
return "NaN"
|
||||||
|
|
||||||
|
case number == 0, number == negativeZero:
|
||||||
|
if math.Signbit(number) {
|
||||||
|
return "-0"
|
||||||
|
} else {
|
||||||
|
return "0"
|
||||||
|
}
|
||||||
|
|
||||||
|
case math.Round(number) == number:
|
||||||
|
return strconv.FormatInt(int64(number), 10)
|
||||||
|
|
||||||
|
default:
|
||||||
|
return strconv.FormatFloat(number, 'f', -1, 64)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
// ValueBool is a boolean value.
|
||||||
|
var _ Value = ValueBool(false)
|
||||||
|
type ValueBool bool
|
||||||
|
func (ValueBool) value () { }
|
||||||
|
func (value ValueBool) Equals (other Value) bool {
|
||||||
|
other, ok := other.(ValueBool)
|
||||||
|
return ok && value == other
|
||||||
|
}
|
||||||
|
func (value ValueBool) String () string {
|
||||||
|
if value {
|
||||||
|
return "true"
|
||||||
|
} else {
|
||||||
|
return "false"
|
||||||
|
}
|
||||||
|
}
|
||||||
97
config/escape.go
Normal file
97
config/escape.go
Normal file
@@ -0,0 +1,97 @@
|
|||||||
|
package config
|
||||||
|
|
||||||
|
import "fmt"
|
||||||
|
import "strings"
|
||||||
|
// import "unicode"
|
||||||
|
|
||||||
|
var escapeCodeToRune = map[rune] rune {
|
||||||
|
'\\': '\\',
|
||||||
|
'a': '\a',
|
||||||
|
'b': '\b',
|
||||||
|
't': '\t',
|
||||||
|
'n': '\n',
|
||||||
|
'v': '\v',
|
||||||
|
'f': '\f',
|
||||||
|
'r': '\r',
|
||||||
|
'"': '"',
|
||||||
|
}
|
||||||
|
|
||||||
|
var runeToEscapeCode = map[rune] rune { }
|
||||||
|
func init () {
|
||||||
|
for code, char := range escapeCodeToRune {
|
||||||
|
runeToEscapeCode[char] = code
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func escape (str string) string {
|
||||||
|
builder := strings.Builder { }
|
||||||
|
for _, char := range str {
|
||||||
|
code, escaped := runeToEscapeCode[char]
|
||||||
|
switch {
|
||||||
|
case escaped:
|
||||||
|
fmt.Fprintf(&builder, "\\%c", code)
|
||||||
|
// case !unicode.IsPrint(char):
|
||||||
|
// fmt.Fprintf(&builder, "\\%o", char)
|
||||||
|
default:
|
||||||
|
builder.WriteRune(char)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return builder.String()
|
||||||
|
}
|
||||||
|
|
||||||
|
func unescape (str string) (string, bool) {
|
||||||
|
runes := []rune(str)
|
||||||
|
builder := strings.Builder { }
|
||||||
|
|
||||||
|
end := func () bool {
|
||||||
|
return len(runes) < 1
|
||||||
|
}
|
||||||
|
next := func () {
|
||||||
|
if !end() { runes = runes[1:] }
|
||||||
|
}
|
||||||
|
|
||||||
|
for !end() {
|
||||||
|
if runes[0] == '\\' {
|
||||||
|
if end() { return "", false }
|
||||||
|
next()
|
||||||
|
char, isEscape := escapeCodeToRune[runes[0]]
|
||||||
|
switch {
|
||||||
|
case isEscape:
|
||||||
|
builder.WriteRune(char)
|
||||||
|
next()
|
||||||
|
// case isOctalDigit(runes[0]):
|
||||||
|
// char = 0
|
||||||
|
// for !end() && isOctalDigit(runes[0]) {
|
||||||
|
// char *= 8
|
||||||
|
// char += runes[0] - '0'
|
||||||
|
// next()
|
||||||
|
// }
|
||||||
|
// builder.WriteRune(char)
|
||||||
|
default:
|
||||||
|
return "", false
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
builder.WriteRune(runes[0])
|
||||||
|
next()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return builder.String(), true
|
||||||
|
}
|
||||||
|
|
||||||
|
func unquote (str string) (string, bool) {
|
||||||
|
if len(str) < 2 { return "", false }
|
||||||
|
if firstRune(str) != '"' { return "", false }
|
||||||
|
if str[len(str) - 1] != '"' { return "", false }
|
||||||
|
return str[1:len(str) - 1], true
|
||||||
|
}
|
||||||
|
|
||||||
|
func isOctalDigit (char rune) bool {
|
||||||
|
return char >= '0' && char <= '7'
|
||||||
|
}
|
||||||
|
|
||||||
|
func firstRune (str string) rune {
|
||||||
|
for _, char := range str {
|
||||||
|
return char
|
||||||
|
}
|
||||||
|
return 0
|
||||||
|
}
|
||||||
22
config/escape_test.go
Normal file
22
config/escape_test.go
Normal file
@@ -0,0 +1,22 @@
|
|||||||
|
package config
|
||||||
|
|
||||||
|
import "testing"
|
||||||
|
|
||||||
|
func TestEscape (test *testing.T) {
|
||||||
|
expected := `\\\a\bhello\t\n\vworld!\f\r\"`
|
||||||
|
got := escape("\\\a\bhello\t\n\vworld!\f\r\"")
|
||||||
|
if got != expected {
|
||||||
|
test.Fatalf("expected: [%s]\ngot:[%s]", expected, got)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestUnescape (test *testing.T) {
|
||||||
|
expected := "\\\a\bhello\t\n\vworld!\f\r\""
|
||||||
|
got, ok := unescape(`\\\a\bhello\t\n\vworld!\f\r\"`)
|
||||||
|
if !ok {
|
||||||
|
test.Fatalf("text could not be unescaped")
|
||||||
|
}
|
||||||
|
if got != expected {
|
||||||
|
test.Fatalf("expected: [%s]\ngot:[%s]", expected, got)
|
||||||
|
}
|
||||||
|
}
|
||||||
266
config/file.go
Normal file
266
config/file.go
Normal file
@@ -0,0 +1,266 @@
|
|||||||
|
package config
|
||||||
|
|
||||||
|
import "io"
|
||||||
|
import "fmt"
|
||||||
|
import "math"
|
||||||
|
import "bufio"
|
||||||
|
import "errors"
|
||||||
|
import "strconv"
|
||||||
|
import "strings"
|
||||||
|
import "unicode"
|
||||||
|
|
||||||
|
type line any
|
||||||
|
type comment string
|
||||||
|
type entry struct { key string; value Value }
|
||||||
|
|
||||||
|
// File represents a config file. It preserves the order of the lines, as well
|
||||||
|
// as blank lines and comments.
|
||||||
|
type File struct {
|
||||||
|
lines []line
|
||||||
|
keys map[string] int
|
||||||
|
}
|
||||||
|
|
||||||
|
// NewFile creates a blank file with nothing in it.
|
||||||
|
func NewFile () *File {
|
||||||
|
return &File {
|
||||||
|
keys: make(map[string] int),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Parse parses a config file from a reader. This function operates on a
|
||||||
|
// best-effort basis: A file will always be returned, and any errors encountered
|
||||||
|
// will be joined together.
|
||||||
|
//
|
||||||
|
// The general format of the file is as follows:
|
||||||
|
// - Encoded in UTF-8
|
||||||
|
// - Consists of lines, separated by \n, or \r\n
|
||||||
|
// - Lines can be any of these:
|
||||||
|
// - Blank line: has only whitespace
|
||||||
|
// - Comment: begins with a '#'
|
||||||
|
// - Entry: a key/value pair separated by an '=' sign
|
||||||
|
//
|
||||||
|
// For entries, all whitespace on either side of the '=' sign, the key, or the
|
||||||
|
// value is ignored. The key may contain any letter or digit, as well as '-'
|
||||||
|
// and '.'. The value is always identified by its first rune (after the
|
||||||
|
// preliminary whitespace of course) and can be one of:
|
||||||
|
// - String: either a double-quoted string, or any string of runes not
|
||||||
|
// identifiable as any other kind of value. The quoted string is always
|
||||||
|
// unquoted when it is read. Either way, these escape sequences are
|
||||||
|
// supported, and resolved when they are read:
|
||||||
|
// - '\\': a literal backslash
|
||||||
|
// - '\a': alert, bell
|
||||||
|
// - '\b': backspace
|
||||||
|
// - '\t': horizontal tab
|
||||||
|
// - '\n': line feed
|
||||||
|
// - '\v': vertical tab
|
||||||
|
// - '\f': form feed
|
||||||
|
// - '\r': carriage return
|
||||||
|
// - '\"': double quote
|
||||||
|
// - Number: a floating point value. It can be of the form:
|
||||||
|
// - Inf
|
||||||
|
// - -Inf
|
||||||
|
// - NaN
|
||||||
|
// - [0-9]+
|
||||||
|
// - [0-9]+\.[0-9]*
|
||||||
|
// - Bool: a boolean value. It can be one of:
|
||||||
|
// - true
|
||||||
|
// - false
|
||||||
|
//
|
||||||
|
// Be aware that some unquoted strings, within reason, are subject to being read
|
||||||
|
// as some other value in the future. For example, if there were suddenly a
|
||||||
|
// third boolean value called glorble, the unquoted string glorble would be read
|
||||||
|
// as a boolean value instead of a string.
|
||||||
|
func Parse (reader io.Reader) (*File, error) {
|
||||||
|
file := &File {
|
||||||
|
keys: make(map[string] int),
|
||||||
|
}
|
||||||
|
errs := []error { }
|
||||||
|
scanner := bufio.NewScanner(reader)
|
||||||
|
|
||||||
|
for scanner.Scan() {
|
||||||
|
text := strings.TrimSpace(scanner.Text())
|
||||||
|
switch {
|
||||||
|
case text == "", strings.HasPrefix(text, "#"):
|
||||||
|
file.lines = append(file.lines, comment(text))
|
||||||
|
default:
|
||||||
|
entry, err := parseEntry(text)
|
||||||
|
if err == nil {
|
||||||
|
file.keys[entry.key] = len(file.lines)
|
||||||
|
file.lines = append(file.lines, entry)
|
||||||
|
} else {
|
||||||
|
errs = append (errs, err )
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
errs = append(errs, scanner.Err())
|
||||||
|
return file, errors.Join(errs...)
|
||||||
|
}
|
||||||
|
|
||||||
|
func parseEntry (str string) (entry, error) {
|
||||||
|
key, value, ok := strings.Cut(str, "=")
|
||||||
|
if !ok { return entry { }, ErrMalformedEntry }
|
||||||
|
|
||||||
|
key = strings.TrimSpace(key)
|
||||||
|
if !KeyValid(key) { return entry { }, ErrMalformedKey }
|
||||||
|
|
||||||
|
value = strings.TrimSpace(value)
|
||||||
|
parsedValue, err := ParseValue(value)
|
||||||
|
if err != nil { return entry { }, err }
|
||||||
|
|
||||||
|
return entry { key: key, value: parsedValue }, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// ParseValue parses a value from a string. For any Value v,
|
||||||
|
// ParseValue(v.String()) should hold data exactly equal to v. This function
|
||||||
|
// does not trim whitespace.
|
||||||
|
func ParseValue (str string) (Value, error) {
|
||||||
|
first := firstRune(str)
|
||||||
|
switch {
|
||||||
|
case str == "":
|
||||||
|
return ValueString(""), nil
|
||||||
|
case first == '"':
|
||||||
|
value, ok := unescape(str)
|
||||||
|
if !ok { return nil, ErrMalformedEscapeSequence }
|
||||||
|
value, ok = unquote(value)
|
||||||
|
if !ok { return nil, ErrMalformedStringValue }
|
||||||
|
return ValueString(value), nil
|
||||||
|
case first == '-' || (first >= '0' && first <= '9'):
|
||||||
|
value, err := strconv.ParseFloat(str, 64)
|
||||||
|
if err != nil { return nil, ErrMalformedNumberValue }
|
||||||
|
return ValueNumber(value), nil
|
||||||
|
case str == "false":
|
||||||
|
return ValueBool(false), nil
|
||||||
|
case str == "true":
|
||||||
|
return ValueBool(true), nil
|
||||||
|
case str == "Inf":
|
||||||
|
return ValueNumber(math.Inf(1)), nil
|
||||||
|
case str == "NaN":
|
||||||
|
return ValueNumber(math.NaN()), nil
|
||||||
|
default:
|
||||||
|
value, ok := unescape(str)
|
||||||
|
if !ok { return nil, ErrMalformedEscapeSequence }
|
||||||
|
return ValueString(value), nil
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Has returns whether the key exists. If the key is invalid, it returns false,
|
||||||
|
// ErrMalformedKey.
|
||||||
|
func (this *File) Has (key string) (bool, error) {
|
||||||
|
if !KeyValid(key) { return false, ErrMalformedKey }
|
||||||
|
_, ok := this.keys[key]
|
||||||
|
return ok, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// Get gets the keyed value. If the value is unspecified, it returns nil,
|
||||||
|
// ErrNonexistentEntry. If the key is invalid, it returns nil, ErrMalformedKey.
|
||||||
|
func (this *File) Get (key string) (Value, error) {
|
||||||
|
if !KeyValid(key) { return nil, ErrMalformedKey }
|
||||||
|
if index, ok := this.keys[key]; ok {
|
||||||
|
if lin := this.lines[index].(entry); ok {
|
||||||
|
return lin.value, nil
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return nil, ErrNonexistentEntry
|
||||||
|
}
|
||||||
|
|
||||||
|
// Set sets a value. If the key is invalid, it returns ErrMalformedKey.
|
||||||
|
func (this *File) Set (key string, value Value) error {
|
||||||
|
if !KeyValid(key) { return ErrMalformedKey }
|
||||||
|
if index, ok := this.keys[key]; ok {
|
||||||
|
ent := this.lines[index].(entry)
|
||||||
|
ent.value = value
|
||||||
|
this.lines[index] = ent
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
this.keys[key] = len(this.lines)
|
||||||
|
this.lines = append(this.lines, value)
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// Reset removes the value from the file. If the value is set again, it will be
|
||||||
|
// added back at the same location. Note that because of this, the positions of
|
||||||
|
// lines are not forgotten until the file is written and reloaded. This is why
|
||||||
|
// the method is called Reset and not Remove. If the key is invalid, it returns
|
||||||
|
// ErrMalformedKey.
|
||||||
|
func (this *File) Reset (key string) error {
|
||||||
|
if !KeyValid(key) { return ErrMalformedKey }
|
||||||
|
for index, lin := range this.lines {
|
||||||
|
if lin, ok := lin.(entry); ok {
|
||||||
|
if lin.key == key {
|
||||||
|
this.lines[index] = nil
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// Map creates and returns a map of keys to values.
|
||||||
|
func (this *File) Map () map[string] Value {
|
||||||
|
mp := make(map[string] Value)
|
||||||
|
for key, index := range this.keys {
|
||||||
|
if lin, ok := this.lines[index].(entry); ok {
|
||||||
|
mp[key] = lin.value
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return mp
|
||||||
|
}
|
||||||
|
|
||||||
|
// Diff returns a set of keys that are different from the other file.
|
||||||
|
func (this *File) Diff (other *File) map[string] struct { } {
|
||||||
|
diff := make(map[string] struct { })
|
||||||
|
|
||||||
|
// - keys only we have
|
||||||
|
// - keys we both have, but are different
|
||||||
|
for key, index := range this.keys {
|
||||||
|
otherIndex, ok := other.keys[key]
|
||||||
|
if !ok {
|
||||||
|
diff[key] = struct { } { }
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
if !this.lines[index].(entry).value.Equals(other.lines[otherIndex].(entry).value) {
|
||||||
|
diff[key] = struct { } { }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// - keys only they have
|
||||||
|
for key := range other.keys {
|
||||||
|
if _, has := this.keys[key]; !has {
|
||||||
|
diff[key] = struct { } { }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return diff
|
||||||
|
}
|
||||||
|
|
||||||
|
// WriteTo writes the data in this file to an io.Writer.
|
||||||
|
func (file *File) WriteTo (writer io.Writer) (n int64, err error) {
|
||||||
|
for _, lin := range file.lines {
|
||||||
|
nint := 0
|
||||||
|
switch lin := lin.(type) {
|
||||||
|
case comment:
|
||||||
|
nint, err = fmt.Fprintln(writer, string(lin))
|
||||||
|
case entry:
|
||||||
|
nint, err = fmt.Fprintf(writer, "%s=%v\n", lin.key, lin.value)
|
||||||
|
}
|
||||||
|
n += int64(nint)
|
||||||
|
if err != nil { return n, err }
|
||||||
|
}
|
||||||
|
return n, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// KeyValid returns whether a key contains only valid runes. They are:
|
||||||
|
// - Letters
|
||||||
|
// - Digits
|
||||||
|
// - '-'
|
||||||
|
// - '.'
|
||||||
|
func KeyValid (key string) bool {
|
||||||
|
for _, char := range key {
|
||||||
|
valid :=
|
||||||
|
char == '.' ||
|
||||||
|
char == '-' ||
|
||||||
|
unicode.IsLetter(char) ||
|
||||||
|
unicode.IsDigit(char)
|
||||||
|
if !valid { return false }
|
||||||
|
}
|
||||||
|
return true
|
||||||
|
}
|
||||||
192
config/file_test.go
Normal file
192
config/file_test.go
Normal file
@@ -0,0 +1,192 @@
|
|||||||
|
package config
|
||||||
|
|
||||||
|
import "math"
|
||||||
|
import "maps"
|
||||||
|
import "strings"
|
||||||
|
import "testing"
|
||||||
|
|
||||||
|
func TestParseEntryUnquotedString (test *testing.T) {
|
||||||
|
testParseEntry(test, "stringValue = Unquoted\\nString", "stringValue", ValueString("Unquoted\nString"))
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestParseEntryQuotedString (test *testing.T) {
|
||||||
|
testParseEntry(test, "stringValue = \"Quoted\\nString\"", "stringValue", ValueString("Quoted\nString"))
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestParseEntryNumber (test *testing.T) {
|
||||||
|
testParseEntry(test, "numberValue = -349.29034", "numberValue", ValueNumber(-349.29034))
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestParseEntryNumberInf (test *testing.T) {
|
||||||
|
testParseEntry(test, "numberValue = Inf", "numberValue", ValueNumber(math.Inf(1)))
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestParseEntryNumberNegativeInf (test *testing.T) {
|
||||||
|
testParseEntry(test, "numberValue = -Inf", "numberValue", ValueNumber(math.Inf(-1)))
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestParseEntryNumberNaN (test *testing.T) {
|
||||||
|
testParseEntry(test, "numberValue = NaN", "numberValue", ValueNumber(math.NaN()))
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestParseEntryBoolTrue (test *testing.T) {
|
||||||
|
testParseEntry(test, "boolValue = true", "boolValue", ValueBool(true))
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestParseEntryBoolFalse (test *testing.T) {
|
||||||
|
testParseEntry(test, "boolValue = false", "boolValue", ValueBool(false))
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestParseEntryComplexKey (test *testing.T) {
|
||||||
|
testParseEntry (
|
||||||
|
test, "--Something.OtherThing...another-Thing-=value",
|
||||||
|
"--Something.OtherThing...another-Thing-", ValueString("value"))
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestParse (test *testing.T) {
|
||||||
|
testParse(test,
|
||||||
|
` thing =something
|
||||||
|
# comment
|
||||||
|
|
||||||
|
otherThing = otherValue
|
||||||
|
otherThing = otherValue1
|
||||||
|
otherThing = otherValue2 # not a comment
|
||||||
|
`,
|
||||||
|
`thing="something"
|
||||||
|
# comment
|
||||||
|
|
||||||
|
otherThing="otherValue"
|
||||||
|
otherThing="otherValue1"
|
||||||
|
otherThing="otherValue2 # not a comment"
|
||||||
|
`)
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestGetValue (test *testing.T) {
|
||||||
|
file := parseFileString(test,
|
||||||
|
`key=askdhj
|
||||||
|
# some comment
|
||||||
|
key = value
|
||||||
|
key1 = 7`)
|
||||||
|
got, err := file.Get("key")
|
||||||
|
if err != nil { test.Fatal(err) }
|
||||||
|
testValueString(test, got, `"value"`)
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestModifyValue (test *testing.T) {
|
||||||
|
file := parseFileString(test,
|
||||||
|
`key=askdhj
|
||||||
|
# some comment
|
||||||
|
key = value
|
||||||
|
key1 = 7`)
|
||||||
|
err := file.Set("key", ValueNumber(324980.2349))
|
||||||
|
if err != nil { test.Fatal(err) }
|
||||||
|
testFileString(test, file,
|
||||||
|
`key="askdhj"
|
||||||
|
# some comment
|
||||||
|
key=324980.2349
|
||||||
|
key1=7
|
||||||
|
`)
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestResetValue (test *testing.T) {
|
||||||
|
file := parseFileString(test,
|
||||||
|
`key=askdhj
|
||||||
|
# some comment
|
||||||
|
key = value
|
||||||
|
|
||||||
|
key1 = 7`)
|
||||||
|
err := file.Reset("key")
|
||||||
|
if err != nil { test.Fatal(err) }
|
||||||
|
testFileString(test, file,
|
||||||
|
`# some comment
|
||||||
|
|
||||||
|
key1=7
|
||||||
|
`)
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestDiffNone (test *testing.T) {
|
||||||
|
str := `
|
||||||
|
thing = something
|
||||||
|
|
||||||
|
otherThing = otherValue
|
||||||
|
# comment
|
||||||
|
otherThing = true
|
||||||
|
otherThing = 234
|
||||||
|
|
||||||
|
yetAnotherThing = 0.23498
|
||||||
|
`
|
||||||
|
file1 := parseFileString(test, str)
|
||||||
|
file2 := parseFileString(test, str)
|
||||||
|
diff := file1.Diff(file2)
|
||||||
|
if len(diff) != 0 {
|
||||||
|
test.Fatalf("diff not empty:\n%v", diff)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestDiff (test *testing.T) {
|
||||||
|
file1 := parseFileString(test,
|
||||||
|
`key4=0
|
||||||
|
key1=value1
|
||||||
|
# comment
|
||||||
|
key2=34`)
|
||||||
|
file2 := parseFileString(test,
|
||||||
|
`key1=value2
|
||||||
|
key2=34
|
||||||
|
# comment
|
||||||
|
|
||||||
|
key3=0.2`)
|
||||||
|
diff := file1.Diff(file2)
|
||||||
|
correct := map[string] struct { } {
|
||||||
|
"key1": struct { } { },
|
||||||
|
"key3": struct { } { },
|
||||||
|
"key4": struct { } { },
|
||||||
|
}
|
||||||
|
if !maps.Equal(diff, correct) {
|
||||||
|
test.Error("diffs do not match")
|
||||||
|
test.Errorf("EXPECTED:\n%v", correct)
|
||||||
|
test.Errorf("GOT:\n%v", diff)
|
||||||
|
test.Fail()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func testParseEntry (test *testing.T, str string, key string, value Value) {
|
||||||
|
ent, err := parseEntry(str)
|
||||||
|
if err != nil { test.Fatal(err) }
|
||||||
|
if ent.key != key {
|
||||||
|
test.Fatalf("expected key: [%s]\ngot key: [%s]", key, ent.key)
|
||||||
|
}
|
||||||
|
if ent.value.String() != value.String() {
|
||||||
|
test.Fatalf("expected value: [%s]\ngot value: [%s]", value.String(), ent.value.String())
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func testParse (test *testing.T, str, correct string) {
|
||||||
|
if correct == "" { correct = str }
|
||||||
|
testFileString(test, parseFileString(test, str), correct)
|
||||||
|
}
|
||||||
|
|
||||||
|
func parseFileString (test *testing.T, str string) *File {
|
||||||
|
file, err := Parse(strings.NewReader(str))
|
||||||
|
if err != nil { test.Fatal(err) }
|
||||||
|
return file
|
||||||
|
}
|
||||||
|
|
||||||
|
func testFileString (test *testing.T, file *File, correct string) {
|
||||||
|
got := strings.Builder { }
|
||||||
|
file.WriteTo(&got)
|
||||||
|
if got.String() != correct {
|
||||||
|
test.Error("strings do not match")
|
||||||
|
test.Errorf("EXPECTED:\n%s", correct)
|
||||||
|
test.Errorf("GOT:\n%s", got.String())
|
||||||
|
test.Fail()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func testValueString (test *testing.T, got Value, correct string) {
|
||||||
|
if got.String() != correct {
|
||||||
|
test.Error("strings do not match")
|
||||||
|
test.Errorf("EXPECTED:\n%s", correct)
|
||||||
|
test.Errorf("GOT:\n%s", got.String())
|
||||||
|
test.Fail()
|
||||||
|
}
|
||||||
|
}
|
||||||
307
config/impl.go
Normal file
307
config/impl.go
Normal file
@@ -0,0 +1,307 @@
|
|||||||
|
package config
|
||||||
|
|
||||||
|
import "os"
|
||||||
|
import "log"
|
||||||
|
import "sync"
|
||||||
|
import "slices"
|
||||||
|
import "path/filepath"
|
||||||
|
import "github.com/fsnotify/fsnotify"
|
||||||
|
import "git.tebibyte.media/tomo/tomo"
|
||||||
|
import "git.tebibyte.media/tomo/tomo/event"
|
||||||
|
|
||||||
|
// Goroutine model:
|
||||||
|
// All private methods (except for lockAndProcessEvent) do not lock the config,
|
||||||
|
// but all public methods do. Private methods may not call public methods.
|
||||||
|
// Locking must always be method-level, with a call to Lock at the start,
|
||||||
|
// directly followed by a deferred call to Unlock.
|
||||||
|
|
||||||
|
type config struct {
|
||||||
|
open bool
|
||||||
|
watcher *fsnotify.Watcher
|
||||||
|
lock sync.RWMutex
|
||||||
|
|
||||||
|
paths struct {
|
||||||
|
user string
|
||||||
|
system []string
|
||||||
|
watching map[string] struct { }
|
||||||
|
}
|
||||||
|
|
||||||
|
data struct {
|
||||||
|
user *File
|
||||||
|
system []map[string] Value
|
||||||
|
}
|
||||||
|
|
||||||
|
on struct {
|
||||||
|
change event.Broadcaster[func (string)]
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// NewConfig creates a new Config using paths to the user-level config file, and
|
||||||
|
// a set of system config files. These files need not exist: the user-level file
|
||||||
|
// will be created when Set is called for the first time if it does not exist
|
||||||
|
// already, and nonexistent system files are simply ignored (unless the Config
|
||||||
|
// finds them at any point to have been spontaneously created).
|
||||||
|
//
|
||||||
|
// The user file is written to when Set is called, and the system files are only
|
||||||
|
// read from. Values in the user file override those in the system files, and
|
||||||
|
// system files specified nearer to the start of the vararg list will override
|
||||||
|
// those farther down.
|
||||||
|
func NewConfig (user string, system ...string) (ConfigCloser, error) {
|
||||||
|
conf := new(config)
|
||||||
|
conf.paths.user = user
|
||||||
|
conf.paths.system = system
|
||||||
|
err := conf.init()
|
||||||
|
if err != nil { return nil, err }
|
||||||
|
go func () {
|
||||||
|
for event := range conf.watcher.Events {
|
||||||
|
conf.lockAndProcessEvent(event)
|
||||||
|
}
|
||||||
|
} ()
|
||||||
|
return conf, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// this method may only be run in the goroutine spawned by NewConfig.
|
||||||
|
func (this *config) lockAndProcessEvent (event fsnotify.Event) {
|
||||||
|
this.lock.Lock()
|
||||||
|
defer this.lock.Unlock()
|
||||||
|
if !(event.Has(fsnotify.Write)) { return }
|
||||||
|
if _, ok := this.paths.watching[event.Name]; !ok { return }
|
||||||
|
|
||||||
|
if event.Name == this.paths.user {
|
||||||
|
previousUser := this.data.user
|
||||||
|
this.reloadUser()
|
||||||
|
newUser := this.data.user
|
||||||
|
this.processUserDiff(newUser.Diff(previousUser))
|
||||||
|
} else {
|
||||||
|
index := slices.Index(this.paths.system, event.Name)
|
||||||
|
if index > 0 {
|
||||||
|
previousSystem := this.data.system[index]
|
||||||
|
this.reloadSystem(index)
|
||||||
|
newSystem := this.data.system[index]
|
||||||
|
this.processSystemDiff(index, diffValueMaps(newSystem, previousSystem))
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func (this *config) init () error {
|
||||||
|
watcher, err := fsnotify.NewWatcher()
|
||||||
|
if err != nil { return err }
|
||||||
|
this.watcher = watcher
|
||||||
|
|
||||||
|
this.paths.watching = make(map[string] struct { })
|
||||||
|
this.watcher.Add(filepath.Dir(this.paths.user))
|
||||||
|
this.paths.watching[this.paths.user] = struct { } { }
|
||||||
|
this.reloadUser()
|
||||||
|
for index, path := range this.paths.system {
|
||||||
|
this.watcher.Add(filepath.Dir(path))
|
||||||
|
this.paths.watching[path] = struct { } { }
|
||||||
|
this.reloadSystem(index)
|
||||||
|
}
|
||||||
|
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (this *config) errIfClosed () error {
|
||||||
|
if this.open {
|
||||||
|
return nil
|
||||||
|
} else {
|
||||||
|
return ErrClosed
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func (this *config) reloadUser () {
|
||||||
|
file, err := os.Open(this.paths.user)
|
||||||
|
if err != nil { return }
|
||||||
|
defer file.Close()
|
||||||
|
|
||||||
|
userFile, err := Parse(file)
|
||||||
|
if err != nil {
|
||||||
|
log.Printf("nasin: problems loading user config file %s: %v", this.paths.user, err)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
this.data.user = userFile
|
||||||
|
}
|
||||||
|
|
||||||
|
func (this *config) reloadSystem (index int) {
|
||||||
|
path := this.paths.system[index]
|
||||||
|
file, err := os.Open(path)
|
||||||
|
if err != nil { return }
|
||||||
|
defer file.Close()
|
||||||
|
|
||||||
|
systemFile, err := Parse(file)
|
||||||
|
if err != nil {
|
||||||
|
log.Printf("nasin: problems loading system config file %s: %v", path, err)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
this.data.system[index] = systemFile.Map()
|
||||||
|
}
|
||||||
|
|
||||||
|
func (this *config) saveUser () error {
|
||||||
|
// TODO set some sort of flag to ignore the next inotify event for the
|
||||||
|
// user file so we dont reload it immediately after. also need to
|
||||||
|
// broadacast Changed event.
|
||||||
|
enclosingDir := filepath.Dir(this.paths.user)
|
||||||
|
err := os.MkdirAll(enclosingDir, 755)
|
||||||
|
if err != nil { return err }
|
||||||
|
file, err := os.Create(this.paths.user)
|
||||||
|
if err != nil { return err }
|
||||||
|
defer file.Close()
|
||||||
|
_, err = this.data.user.WriteTo(file)
|
||||||
|
if err != nil { return err }
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (this *config) processUserDiff (changed map[string] struct { }) {
|
||||||
|
for key := range changed {
|
||||||
|
// this is the user file, and nothing has precedence over it, so
|
||||||
|
// the change always matters
|
||||||
|
this.broadcastChange(key)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func (this *config) processSystemDiff (index int, changed map[string] struct { }) {
|
||||||
|
for key := range changed {
|
||||||
|
// if specified in the user file, the change doesn't matter
|
||||||
|
if this.data.user != nil {
|
||||||
|
if has, _ := this.data.user.Has(key); has {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// if specified in any system files with precedence greater than
|
||||||
|
// this one, the change doesn't matter
|
||||||
|
for _, system := range this.data.system[:index] {
|
||||||
|
if _, has := system[key]; has {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// the change does matter
|
||||||
|
this.broadcastChange(key)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func (this *config) broadcastChange (key string) {
|
||||||
|
for _, listener := range this.on.change.Listeners() {
|
||||||
|
tomo.Do(func () { listener(key) })
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func (this *config) get (key string, fallback Value) (Value, error) {
|
||||||
|
// try user config
|
||||||
|
if !KeyValid(key) { return nil, ErrMalformedKey }
|
||||||
|
|
||||||
|
if this.data.user != nil {
|
||||||
|
value, err := this.data.user.Get(key)
|
||||||
|
if err == nil && err != ErrNonexistentEntry {
|
||||||
|
return value, nil
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// try system configs
|
||||||
|
for _, config := range this.data.system {
|
||||||
|
if value, ok := config[key]; ok {
|
||||||
|
return value, nil
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// use fallback
|
||||||
|
return fallback, nil
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
func (this *config) Get (key string, fallback Value) (Value, error) {
|
||||||
|
this.lock.Lock()
|
||||||
|
defer this.lock.Unlock()
|
||||||
|
return this.get(key, fallback)
|
||||||
|
}
|
||||||
|
|
||||||
|
func (this *config) Close () error {
|
||||||
|
this.lock.Lock()
|
||||||
|
defer this.lock.Unlock()
|
||||||
|
this.open = false
|
||||||
|
return this.watcher.Close()
|
||||||
|
}
|
||||||
|
|
||||||
|
func (this *config) GetString (key string, fallback string) (string, error) {
|
||||||
|
this.lock.Lock()
|
||||||
|
defer this.lock.Unlock()
|
||||||
|
value, err := this.get(key, ValueString(fallback))
|
||||||
|
if err != nil { return "", err }
|
||||||
|
if value, ok := value.(ValueString); ok {
|
||||||
|
return string(value), nil
|
||||||
|
}
|
||||||
|
return fallback, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (this *config) GetNumber (key string, fallback float64) (float64, error) {
|
||||||
|
this.lock.Lock()
|
||||||
|
defer this.lock.Unlock()
|
||||||
|
value, err := this.get(key, ValueNumber(fallback))
|
||||||
|
if err != nil { return 0, err }
|
||||||
|
if value, ok := value.(ValueNumber); ok {
|
||||||
|
return float64(value), nil
|
||||||
|
}
|
||||||
|
return fallback, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (this *config) GetBool (key string, fallback bool) (bool, error) {
|
||||||
|
this.lock.Lock()
|
||||||
|
defer this.lock.Unlock()
|
||||||
|
value, err := this.get(key, ValueBool(fallback))
|
||||||
|
if err != nil { return false, err }
|
||||||
|
if value, ok := value.(ValueBool); ok {
|
||||||
|
return bool(value), nil
|
||||||
|
}
|
||||||
|
return fallback, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (this *config) Set (key string, value Value) error {
|
||||||
|
this.lock.Lock()
|
||||||
|
defer this.lock.Unlock()
|
||||||
|
if this.data.user == nil { this.data.user = NewFile() }
|
||||||
|
err := this.data.user.Set(key, value)
|
||||||
|
if err != nil { return err }
|
||||||
|
return this.saveUser()
|
||||||
|
}
|
||||||
|
|
||||||
|
func (this *config) Reset (key string) error {
|
||||||
|
this.lock.Lock()
|
||||||
|
defer this.lock.Unlock()
|
||||||
|
if this.data.user == nil { this.data.user = NewFile() }
|
||||||
|
err := this.data.user.Reset(key)
|
||||||
|
if err != nil { return err }
|
||||||
|
return this.saveUser()
|
||||||
|
}
|
||||||
|
|
||||||
|
func (this *config) OnChange (callback func (string)) event.Cookie {
|
||||||
|
this.lock.Lock()
|
||||||
|
defer this.lock.Unlock()
|
||||||
|
return this.on.change.Connect(callback)
|
||||||
|
}
|
||||||
|
|
||||||
|
func diffValueMaps (first, second map[string] Value) map[string] struct { } {
|
||||||
|
diff := make(map[string] struct { })
|
||||||
|
|
||||||
|
// - keys only first has
|
||||||
|
// - keys both have, but are different
|
||||||
|
for key, firstValue := range first {
|
||||||
|
secondValue, ok := second[key]
|
||||||
|
if !ok {
|
||||||
|
diff[key] = struct { } { }
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
if !firstValue.Equals(secondValue) {
|
||||||
|
diff[key] = struct { } { }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// - keys only second has
|
||||||
|
for key := range second {
|
||||||
|
if _, has := first[key]; !has {
|
||||||
|
diff[key] = struct { } { }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return diff
|
||||||
|
}
|
||||||
53
config/impl_test.go
Normal file
53
config/impl_test.go
Normal file
@@ -0,0 +1,53 @@
|
|||||||
|
package config
|
||||||
|
|
||||||
|
import "maps"
|
||||||
|
import "testing"
|
||||||
|
|
||||||
|
func TestDiffValueMapsNone (test *testing.T) {
|
||||||
|
str := `
|
||||||
|
thing = something
|
||||||
|
|
||||||
|
otherThing = otherValue
|
||||||
|
# comment
|
||||||
|
otherThing = true
|
||||||
|
otherThing = 234
|
||||||
|
|
||||||
|
yetAnotherThing = 0.23498
|
||||||
|
`
|
||||||
|
file1 := parseFileString(test, str)
|
||||||
|
file2 := parseFileString(test, str)
|
||||||
|
diff := diffValueMaps(file1.Map(), file2.Map())
|
||||||
|
if len(diff) != 0 {
|
||||||
|
test.Fatalf("diff not empty:\n%v", diff)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestDiffValueMaps (test *testing.T) {
|
||||||
|
file1 := parseFileString(test,
|
||||||
|
`key4=0
|
||||||
|
key1=value1
|
||||||
|
# comment
|
||||||
|
key2=34`)
|
||||||
|
file2 := parseFileString(test,
|
||||||
|
`key1=value2
|
||||||
|
key2=34
|
||||||
|
# comment
|
||||||
|
|
||||||
|
key3=0.2`)
|
||||||
|
diff := diffValueMaps(file1.Map(), file2.Map())
|
||||||
|
correct := map[string] struct { } {
|
||||||
|
"key1": struct { } { },
|
||||||
|
"key3": struct { } { },
|
||||||
|
"key4": struct { } { },
|
||||||
|
}
|
||||||
|
if !maps.Equal(diff, correct) {
|
||||||
|
test.Error("diffs do not match")
|
||||||
|
test.Errorf("EXPECTED:\n%v", correct)
|
||||||
|
test.Errorf("GOT:\n%v", diff)
|
||||||
|
test.Fail()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// TODO we need way more tests!
|
||||||
|
// need to test watching files. maybe make a temp dir and do it there. remember
|
||||||
|
// to defer cleaning up the dir and closing of the config.
|
||||||
2
go.mod
2
go.mod
@@ -8,6 +8,7 @@ require (
|
|||||||
git.tebibyte.media/tomo/objects v0.22.0
|
git.tebibyte.media/tomo/objects v0.22.0
|
||||||
git.tebibyte.media/tomo/tomo v0.46.1
|
git.tebibyte.media/tomo/tomo v0.46.1
|
||||||
git.tebibyte.media/tomo/xdg v0.1.0
|
git.tebibyte.media/tomo/xdg v0.1.0
|
||||||
|
github.com/fsnotify/fsnotify v1.7.0
|
||||||
golang.org/x/image v0.11.0
|
golang.org/x/image v0.11.0
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -18,4 +19,5 @@ require (
|
|||||||
github.com/BurntSushi/graphics-go v0.0.0-20160129215708-b43f31a4a966 // indirect
|
github.com/BurntSushi/graphics-go v0.0.0-20160129215708-b43f31a4a966 // indirect
|
||||||
github.com/jezek/xgb v1.1.1 // indirect
|
github.com/jezek/xgb v1.1.1 // indirect
|
||||||
github.com/jezek/xgbutil v0.0.0-20231116234834-47f30c120111 // indirect
|
github.com/jezek/xgbutil v0.0.0-20231116234834-47f30c120111 // indirect
|
||||||
|
golang.org/x/sys v0.5.0 // indirect
|
||||||
)
|
)
|
||||||
|
|||||||
3
go.sum
3
go.sum
@@ -17,6 +17,8 @@ github.com/BurntSushi/freetype-go v0.0.0-20160129220410-b763ddbfe298 h1:1qlsVAQJ
|
|||||||
github.com/BurntSushi/freetype-go v0.0.0-20160129220410-b763ddbfe298/go.mod h1:D+QujdIlUNfa0igpNMk6UIvlb6C252URs4yupRUV4lQ=
|
github.com/BurntSushi/freetype-go v0.0.0-20160129220410-b763ddbfe298/go.mod h1:D+QujdIlUNfa0igpNMk6UIvlb6C252URs4yupRUV4lQ=
|
||||||
github.com/BurntSushi/graphics-go v0.0.0-20160129215708-b43f31a4a966 h1:lTG4HQym5oPKjL7nGs+csTgiDna685ZXjxijkne828g=
|
github.com/BurntSushi/graphics-go v0.0.0-20160129215708-b43f31a4a966 h1:lTG4HQym5oPKjL7nGs+csTgiDna685ZXjxijkne828g=
|
||||||
github.com/BurntSushi/graphics-go v0.0.0-20160129215708-b43f31a4a966/go.mod h1:Mid70uvE93zn9wgF92A/r5ixgnvX8Lh68fxp9KQBaI0=
|
github.com/BurntSushi/graphics-go v0.0.0-20160129215708-b43f31a4a966/go.mod h1:Mid70uvE93zn9wgF92A/r5ixgnvX8Lh68fxp9KQBaI0=
|
||||||
|
github.com/fsnotify/fsnotify v1.7.0 h1:8JEhPFa5W2WU7YfeZzPNqzMP6Lwt7L2715Ggo0nosvA=
|
||||||
|
github.com/fsnotify/fsnotify v1.7.0/go.mod h1:40Bi/Hjc2AVfZrqy+aj+yEI+/bRxZnMJyTJwOpGvigM=
|
||||||
github.com/jezek/xgb v1.1.0/go.mod h1:nrhwO0FX/enq75I7Y7G8iN1ubpSGZEiA3v9e9GyRFlk=
|
github.com/jezek/xgb v1.1.0/go.mod h1:nrhwO0FX/enq75I7Y7G8iN1ubpSGZEiA3v9e9GyRFlk=
|
||||||
github.com/jezek/xgb v1.1.1 h1:bE/r8ZZtSv7l9gk6nU0mYx51aXrvnyb44892TwSaqS4=
|
github.com/jezek/xgb v1.1.1 h1:bE/r8ZZtSv7l9gk6nU0mYx51aXrvnyb44892TwSaqS4=
|
||||||
github.com/jezek/xgb v1.1.1/go.mod h1:nrhwO0FX/enq75I7Y7G8iN1ubpSGZEiA3v9e9GyRFlk=
|
github.com/jezek/xgb v1.1.1/go.mod h1:nrhwO0FX/enq75I7Y7G8iN1ubpSGZEiA3v9e9GyRFlk=
|
||||||
@@ -42,6 +44,7 @@ golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7w
|
|||||||
golang.org/x/sys v0.0.0-20210615035016-665e8c7367d1/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
|
golang.org/x/sys v0.0.0-20210615035016-665e8c7367d1/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
|
||||||
golang.org/x/sys v0.0.0-20220520151302-bc2c85ada10a/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
|
golang.org/x/sys v0.0.0-20220520151302-bc2c85ada10a/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
|
||||||
golang.org/x/sys v0.0.0-20220722155257-8c9f86f7a55f/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
|
golang.org/x/sys v0.0.0-20220722155257-8c9f86f7a55f/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
|
||||||
|
golang.org/x/sys v0.5.0 h1:MUK/U/4lj1t1oPg0HfuXDN/Z1wv31ZJ/YcPiGccS4DU=
|
||||||
golang.org/x/sys v0.5.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
|
golang.org/x/sys v0.5.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
|
||||||
golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
|
golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
|
||||||
golang.org/x/term v0.0.0-20210927222741-03fcf44c2211/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8=
|
golang.org/x/term v0.0.0-20210927222741-03fcf44c2211/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8=
|
||||||
|
|||||||
Binary file not shown.
|
Before Width: | Height: | Size: 27 KiB After Width: | Height: | Size: 34 KiB |
Binary file not shown.
Binary file not shown.
|
Before Width: | Height: | Size: 12 KiB After Width: | Height: | Size: 13 KiB |
Binary file not shown.
@@ -6,6 +6,7 @@ import _ "embed"
|
|||||||
import _ "image/png"
|
import _ "image/png"
|
||||||
import "git.tebibyte.media/tomo/tomo"
|
import "git.tebibyte.media/tomo/tomo"
|
||||||
import "git.tebibyte.media/tomo/tomo/data"
|
import "git.tebibyte.media/tomo/tomo/data"
|
||||||
|
import "git.tebibyte.media/tomo/nasin/internal/util"
|
||||||
import "git.tebibyte.media/tomo/tomo/canvas"
|
import "git.tebibyte.media/tomo/tomo/canvas"
|
||||||
import "git.tebibyte.media/tomo/backend/style"
|
import "git.tebibyte.media/tomo/backend/style"
|
||||||
|
|
||||||
@@ -14,6 +15,26 @@ var atlasSmallBytes []byte
|
|||||||
//go:embed assets/icons-large.png
|
//go:embed assets/icons-large.png
|
||||||
var atlasLargeBytes []byte
|
var atlasLargeBytes []byte
|
||||||
|
|
||||||
|
const (
|
||||||
|
iconApplicationXGeneric = tomo.Icon("application/x-generic")
|
||||||
|
iconApplicationXExecutable = tomo.Icon("application/x-executable")
|
||||||
|
iconAudioXGeneric = tomo.Icon("audio/x-generic")
|
||||||
|
iconFontXGeneric = tomo.Icon("font/x-generic")
|
||||||
|
iconImageXGeneric = tomo.Icon("image/x-generic")
|
||||||
|
iconModelXGeneric = tomo.Icon("model/x-generic")
|
||||||
|
iconPackageXGeneric = tomo.Icon("package/x-generic")
|
||||||
|
iconTextXGeneric = tomo.Icon("text/x-generic")
|
||||||
|
iconTextHtml = tomo.Icon("text/html")
|
||||||
|
iconTextXGenericTemplate = tomo.Icon("text/x-generic-template")
|
||||||
|
iconTextXScript = tomo.Icon("text/x-script")
|
||||||
|
iconVideoXGeneric = tomo.Icon("video/x-generic")
|
||||||
|
iconXOfficeAddressBook = tomo.Icon("x-office-address-book")
|
||||||
|
iconXOfficeCalendar = tomo.Icon("x-office-calendar")
|
||||||
|
iconXOfficeDocument = tomo.Icon("x-office-document")
|
||||||
|
iconXOfficePresentation = tomo.Icon("x-office-presentation")
|
||||||
|
iconXOfficeSpreadsheet = tomo.Icon("x-office-spreadsheet")
|
||||||
|
)
|
||||||
|
|
||||||
func generateSource (data []byte, width int) map[tomo.Icon] canvas.Texture {
|
func generateSource (data []byte, width int) map[tomo.Icon] canvas.Texture {
|
||||||
atlasImage, _, err := image.Decode(bytes.NewReader(data))
|
atlasImage, _, err := image.Decode(bytes.NewReader(data))
|
||||||
if err != nil { panic(err) }
|
if err != nil { panic(err) }
|
||||||
@@ -37,7 +58,23 @@ func generateSource (data []byte, width int) map[tomo.Icon] canvas.Texture {
|
|||||||
}
|
}
|
||||||
|
|
||||||
col(tomo.IconUnknown)
|
col(tomo.IconUnknown)
|
||||||
col(tomo.Icon("File"))
|
col(iconApplicationXGeneric)
|
||||||
|
col(iconApplicationXExecutable)
|
||||||
|
col(iconAudioXGeneric)
|
||||||
|
col(iconFontXGeneric)
|
||||||
|
col(iconImageXGeneric)
|
||||||
|
col(iconModelXGeneric)
|
||||||
|
col(iconPackageXGeneric)
|
||||||
|
col(iconTextXGeneric)
|
||||||
|
col(iconTextHtml)
|
||||||
|
col(iconTextXGenericTemplate)
|
||||||
|
col(iconTextXScript)
|
||||||
|
col(iconVideoXGeneric)
|
||||||
|
col(iconXOfficeAddressBook)
|
||||||
|
col(iconXOfficeCalendar)
|
||||||
|
col(iconXOfficeDocument)
|
||||||
|
col(iconXOfficePresentation)
|
||||||
|
col(iconXOfficeSpreadsheet)
|
||||||
|
|
||||||
row()
|
row()
|
||||||
// actions
|
// actions
|
||||||
@@ -450,9 +487,16 @@ func (this *iconSet) Icon (icon tomo.Icon, size tomo.IconSize) canvas.Texture {
|
|||||||
func (this *iconSet) MimeIcon (mime data.Mime, size tomo.IconSize) canvas.Texture {
|
func (this *iconSet) MimeIcon (mime data.Mime, size tomo.IconSize) canvas.Texture {
|
||||||
this.ensure()
|
this.ensure()
|
||||||
source := this.selectSource(size)
|
source := this.selectSource(size)
|
||||||
|
|
||||||
|
if icon, ok := source[tomo.Icon(mime.String())]; ok {
|
||||||
|
return icon
|
||||||
|
}
|
||||||
|
|
||||||
if mime == data.M("inode", "directory") {
|
if mime == data.M("inode", "directory") {
|
||||||
return source[tomo.IconPlaceDirectory]
|
return source[tomo.IconPlaceDirectory]
|
||||||
|
} else if icon, ok := source[tomo.Icon(util.GeneralizeXDGIconMimeType(mime).String())]; ok {
|
||||||
|
return icon
|
||||||
} else {
|
} else {
|
||||||
return source[tomo.Icon("File")]
|
return source[tomo.Icon(iconApplicationXGeneric)]
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -11,6 +11,7 @@ import "git.tebibyte.media/tomo/tomo"
|
|||||||
import "git.tebibyte.media/tomo/tomo/data"
|
import "git.tebibyte.media/tomo/tomo/data"
|
||||||
import "git.tebibyte.media/tomo/tomo/canvas"
|
import "git.tebibyte.media/tomo/tomo/canvas"
|
||||||
import "git.tebibyte.media/tomo/backend/style"
|
import "git.tebibyte.media/tomo/backend/style"
|
||||||
|
import "git.tebibyte.media/tomo/nasin/internal/util"
|
||||||
import xdgIconTheme "git.tebibyte.media/tomo/xdg/icon-theme"
|
import xdgIconTheme "git.tebibyte.media/tomo/xdg/icon-theme"
|
||||||
|
|
||||||
type iconTheme struct {
|
type iconTheme struct {
|
||||||
@@ -113,7 +114,7 @@ func (this *iconTheme) mimeIcon (mime data.Mime, size tomo.IconSize) canvas.Text
|
|||||||
if texture, ok := this.xdgIcon(xdgFormatMime(mime), size); ok {
|
if texture, ok := this.xdgIcon(xdgFormatMime(mime), size); ok {
|
||||||
return texture
|
return texture
|
||||||
}
|
}
|
||||||
if texture, ok := this.xdgIcon(xdgFormatMime(generalizeMimeType(mime)), size); ok {
|
if texture, ok := this.xdgIcon(xdgFormatMime(util.GeneralizeXDGIconMimeType(mime)), size); ok {
|
||||||
return texture
|
return texture
|
||||||
}
|
}
|
||||||
if texture, ok := this.xdgIcon(xdgFormatMime(data.M("text", "x-generic")), size); ok {
|
if texture, ok := this.xdgIcon(xdgFormatMime(data.M("text", "x-generic")), size); ok {
|
||||||
@@ -166,13 +167,6 @@ func xdgFormatMime (mime data.Mime) string {
|
|||||||
return fmt.Sprintf("%s-%s", mime.Type, mime.Subtype)
|
return fmt.Sprintf("%s-%s", mime.Type, mime.Subtype)
|
||||||
}
|
}
|
||||||
|
|
||||||
func generalizeMimeType (mime data.Mime) data.Mime {
|
|
||||||
// FIXME make this more accurate
|
|
||||||
// https://specifications.freedesktop.org/icon-naming-spec/icon-naming-spec-latest.html
|
|
||||||
mime.Subtype = "x-generic"
|
|
||||||
return mime
|
|
||||||
}
|
|
||||||
|
|
||||||
func iconSizePixels (size tomo.IconSize) int {
|
func iconSizePixels (size tomo.IconSize) int {
|
||||||
// TODO: once Tomo has scaling support, take that into account here
|
// TODO: once Tomo has scaling support, take that into account here
|
||||||
switch size {
|
switch size {
|
||||||
|
|||||||
10
internal/util/util.go
Normal file
10
internal/util/util.go
Normal file
@@ -0,0 +1,10 @@
|
|||||||
|
package util
|
||||||
|
|
||||||
|
import "git.tebibyte.media/tomo/tomo/data"
|
||||||
|
|
||||||
|
func GeneralizeXDGIconMimeType (mime data.Mime) data.Mime {
|
||||||
|
// FIXME make this more accurate
|
||||||
|
// https://specifications.freedesktop.org/icon-naming-spec/icon-naming-spec-latest.html
|
||||||
|
mime.Subtype = "x-generic"
|
||||||
|
return mime
|
||||||
|
}
|
||||||
33
manager.go
Normal file
33
manager.go
Normal file
@@ -0,0 +1,33 @@
|
|||||||
|
package nasin
|
||||||
|
|
||||||
|
import "git.tebibyte.media/tomo/tomo"
|
||||||
|
import "git.tebibyte.media/tomo/tomo/event"
|
||||||
|
|
||||||
|
var manager struct {
|
||||||
|
count int
|
||||||
|
}
|
||||||
|
|
||||||
|
type funcCookie func ()
|
||||||
|
func (cookie funcCookie) Close () {
|
||||||
|
cookie()
|
||||||
|
}
|
||||||
|
|
||||||
|
// WaitFor ensures that the application will stay running while the given window
|
||||||
|
// is open.
|
||||||
|
func WaitFor (window tomo.Window) event.Cookie {
|
||||||
|
manager.count ++
|
||||||
|
|
||||||
|
isManaged := true
|
||||||
|
handleClose := func () {
|
||||||
|
if !isManaged { return }
|
||||||
|
isManaged = false
|
||||||
|
manager.count --
|
||||||
|
if manager.count < 1 {
|
||||||
|
tomo.Stop()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return event.MultiCookie (
|
||||||
|
window.OnClose(handleClose),
|
||||||
|
funcCookie(handleClose))
|
||||||
|
}
|
||||||
25
path.go
25
path.go
@@ -10,12 +10,27 @@ func ApplicationUserDataDir (app ApplicationDescription) (string, error) {
|
|||||||
return userMkdirAll(app.ID, userDataDir)
|
return userMkdirAll(app.ID, userDataDir)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// ApplicationSystemDataDirs returns a list of directory paths where an
|
||||||
|
// application can look for its system-level data files. These directories may
|
||||||
|
// or may not exist. This function may return an empty slice on some platforms.
|
||||||
|
func ApplicationSystemDataDirs (app ApplicationDescription) ([]string, error) {
|
||||||
|
return systemDirs(app.ID, systemDataDirs)
|
||||||
|
}
|
||||||
|
|
||||||
// ApplicationUserConfigDir returns the directory path where an application can
|
// ApplicationUserConfigDir returns the directory path where an application can
|
||||||
// store its user configuration files.
|
// store its user configuration files.
|
||||||
func ApplicationUserConfigDir (app ApplicationDescription) (string, error) {
|
func ApplicationUserConfigDir (app ApplicationDescription) (string, error) {
|
||||||
return userMkdirAll(app.ID, userConfigDir)
|
return userMkdirAll(app.ID, userConfigDir)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// ApplicationSystemDataDirs returns a list of directory paths where an
|
||||||
|
// application can look for its system-level configuration files. These
|
||||||
|
// directories may or may not exist. This function may return an empty slice on
|
||||||
|
// some platforms.
|
||||||
|
func ApplicationSystemConfigDirs (app ApplicationDescription) ([]string, error) {
|
||||||
|
return systemDirs(app.ID, systemConfigDirs)
|
||||||
|
}
|
||||||
|
|
||||||
// ApplicationUserCacheDir returns the directory path where an application can
|
// ApplicationUserCacheDir returns the directory path where an application can
|
||||||
// store its user cache files.
|
// store its user cache files.
|
||||||
func ApplicationUserCacheDir (app ApplicationDescription) (string, error) {
|
func ApplicationUserCacheDir (app ApplicationDescription) (string, error) {
|
||||||
@@ -30,3 +45,13 @@ func userMkdirAll (sub string, getter func () (string, error)) (string, error) {
|
|||||||
if err != nil { return "", err }
|
if err != nil { return "", err }
|
||||||
return path, nil
|
return path, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func systemDirs (sub string, getter func () ([]string, error)) ([]string, error) {
|
||||||
|
paths, err := getter()
|
||||||
|
if err != nil { return nil, err }
|
||||||
|
specificPaths := make([]string, len(paths))
|
||||||
|
for index, path := range paths {
|
||||||
|
specificPaths[index] = filepath.Join(path, sub)
|
||||||
|
}
|
||||||
|
return specificPaths, nil
|
||||||
|
}
|
||||||
|
|||||||
@@ -7,10 +7,18 @@ func userDataDir () (string, error) {
|
|||||||
return basedir.DataHome()
|
return basedir.DataHome()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func systemDataDirs () ([]string, error) {
|
||||||
|
return basedir.DataDirs()
|
||||||
|
}
|
||||||
|
|
||||||
func userConfigDir () (string, error) {
|
func userConfigDir () (string, error) {
|
||||||
return basedir.ConfigHome()
|
return basedir.ConfigHome()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func systemConfigDirs () ([]string, error) {
|
||||||
|
return basedir.ConfigDirs()
|
||||||
|
}
|
||||||
|
|
||||||
func userCacheDir () (string, error) {
|
func userCacheDir () (string, error) {
|
||||||
return basedir.CacheHome()
|
return basedir.CacheHome()
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user