Make storage backend configurable via -storage.url
Same mechanism as for configuring the auth backend.
This commit is contained in:
parent
3e464747d8
commit
edd01ff7a3
@ -16,15 +16,16 @@ import (
|
|||||||
|
|
||||||
func main() {
|
func main() {
|
||||||
var (
|
var (
|
||||||
addr string
|
addr string
|
||||||
authURL string
|
authURL string
|
||||||
|
storageURL string
|
||||||
)
|
)
|
||||||
flag.StringVar(&addr, "addr", ":8080", "listening address")
|
flag.StringVar(&addr, "addr", ":8080", "listening address")
|
||||||
// TODO: make flag mandatory instead of default value
|
flag.StringVar(&authURL, "auth.url", "", "auth backend URL (required)")
|
||||||
flag.StringVar(&authURL, "auth.url", "imaps://imap.migadu.com:993", "auth backend URL")
|
flag.StringVar(&storageURL, "storage.url", "", "storage backend URL (required)")
|
||||||
flag.Parse()
|
flag.Parse()
|
||||||
|
|
||||||
if len(flag.Args()) != 0 {
|
if len(flag.Args()) != 0 || authURL == "" || storageURL == "" {
|
||||||
flag.Usage()
|
flag.Usage()
|
||||||
os.Exit(1)
|
os.Exit(1)
|
||||||
}
|
}
|
||||||
@ -41,8 +42,7 @@ func main() {
|
|||||||
}
|
}
|
||||||
mux.Use(authProvider.Middleware())
|
mux.Use(authProvider.Middleware())
|
||||||
|
|
||||||
//backend := storage.NewPostgreSQL()
|
backend, err := storage.NewFromURL(storageURL)
|
||||||
backend, err := storage.NewFilesystem("./teststorage")
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatalf("failed to load storage backend: %s", err.Error())
|
log.Fatalf("failed to load storage backend: %s", err.Error())
|
||||||
}
|
}
|
||||||
|
24
storage/url.go
Normal file
24
storage/url.go
Normal file
@ -0,0 +1,24 @@
|
|||||||
|
package storage
|
||||||
|
|
||||||
|
import (
|
||||||
|
"fmt"
|
||||||
|
"net/url"
|
||||||
|
|
||||||
|
"github.com/emersion/go-webdav/carddav"
|
||||||
|
)
|
||||||
|
|
||||||
|
func NewFromURL(storageURL string) (carddav.Backend, error) {
|
||||||
|
u, err := url.Parse(storageURL)
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("error parsing storage URL: %s", err.Error())
|
||||||
|
}
|
||||||
|
|
||||||
|
switch u.Scheme {
|
||||||
|
case "file":
|
||||||
|
return NewFilesystem(u.Path)
|
||||||
|
case "postgresql":
|
||||||
|
return NewPostgreSQL(), nil
|
||||||
|
default:
|
||||||
|
return nil, fmt.Errorf("no storage provider found for %s:// URL", u.Scheme)
|
||||||
|
}
|
||||||
|
}
|
Loading…
Reference in New Issue
Block a user