[62] | 1 | package config
|
---|
| 2 |
|
---|
| 3 | import (
|
---|
| 4 | "bufio"
|
---|
| 5 | "fmt"
|
---|
| 6 | "io"
|
---|
| 7 | "os"
|
---|
[200] | 8 |
|
---|
| 9 | "github.com/google/shlex"
|
---|
[62] | 10 | )
|
---|
| 11 |
|
---|
| 12 | type TLS struct {
|
---|
| 13 | CertPath, KeyPath string
|
---|
| 14 | }
|
---|
| 15 |
|
---|
| 16 | type Server struct {
|
---|
[77] | 17 | Addr string
|
---|
| 18 | Hostname string
|
---|
| 19 | TLS *TLS
|
---|
| 20 | SQLDriver string
|
---|
| 21 | SQLSource string
|
---|
[178] | 22 | LogPath string
|
---|
[62] | 23 | }
|
---|
| 24 |
|
---|
| 25 | func Defaults() *Server {
|
---|
| 26 | hostname, err := os.Hostname()
|
---|
| 27 | if err != nil {
|
---|
| 28 | hostname = "localhost"
|
---|
| 29 | }
|
---|
| 30 | return &Server{
|
---|
[77] | 31 | Addr: ":6667",
|
---|
| 32 | Hostname: hostname,
|
---|
| 33 | SQLDriver: "sqlite3",
|
---|
[98] | 34 | SQLSource: "soju.db",
|
---|
[62] | 35 | }
|
---|
| 36 | }
|
---|
| 37 |
|
---|
| 38 | func Load(path string) (*Server, error) {
|
---|
| 39 | f, err := os.Open(path)
|
---|
| 40 | if err != nil {
|
---|
| 41 | return nil, err
|
---|
| 42 | }
|
---|
| 43 | defer f.Close()
|
---|
| 44 |
|
---|
| 45 | return Parse(f)
|
---|
| 46 | }
|
---|
| 47 |
|
---|
| 48 | func Parse(r io.Reader) (*Server, error) {
|
---|
[200] | 49 | scanner := bufio.NewScanner(r)
|
---|
| 50 |
|
---|
| 51 | var directives []directive
|
---|
| 52 | for scanner.Scan() {
|
---|
| 53 | words, err := shlex.Split(scanner.Text())
|
---|
| 54 | if err != nil {
|
---|
| 55 | return nil, fmt.Errorf("failed to parse config file: %v", err)
|
---|
| 56 | } else if len(words) == 0 {
|
---|
| 57 | continue
|
---|
| 58 | }
|
---|
| 59 |
|
---|
| 60 | name, params := words[0], words[1:]
|
---|
| 61 | directives = append(directives, directive{name, params})
|
---|
[62] | 62 | }
|
---|
[200] | 63 | if err := scanner.Err(); err != nil {
|
---|
| 64 | return nil, fmt.Errorf("failed to read config file: %v", err)
|
---|
| 65 | }
|
---|
[62] | 66 |
|
---|
| 67 | srv := Defaults()
|
---|
| 68 | for _, d := range directives {
|
---|
| 69 | switch d.Name {
|
---|
| 70 | case "listen":
|
---|
| 71 | if err := d.parseParams(&srv.Addr); err != nil {
|
---|
| 72 | return nil, err
|
---|
| 73 | }
|
---|
| 74 | case "hostname":
|
---|
| 75 | if err := d.parseParams(&srv.Hostname); err != nil {
|
---|
| 76 | return nil, err
|
---|
| 77 | }
|
---|
| 78 | case "tls":
|
---|
| 79 | tls := &TLS{}
|
---|
| 80 | if err := d.parseParams(&tls.CertPath, &tls.KeyPath); err != nil {
|
---|
| 81 | return nil, err
|
---|
| 82 | }
|
---|
| 83 | srv.TLS = tls
|
---|
[77] | 84 | case "sql":
|
---|
| 85 | if err := d.parseParams(&srv.SQLDriver, &srv.SQLSource); err != nil {
|
---|
| 86 | return nil, err
|
---|
| 87 | }
|
---|
[178] | 88 | case "log":
|
---|
| 89 | if err := d.parseParams(&srv.LogPath); err != nil {
|
---|
| 90 | return nil, err
|
---|
| 91 | }
|
---|
[62] | 92 | default:
|
---|
| 93 | return nil, fmt.Errorf("unknown directive %q", d.Name)
|
---|
| 94 | }
|
---|
| 95 | }
|
---|
| 96 |
|
---|
| 97 | return srv, nil
|
---|
| 98 | }
|
---|
| 99 |
|
---|
| 100 | type directive struct {
|
---|
| 101 | Name string
|
---|
| 102 | Params []string
|
---|
| 103 | }
|
---|
| 104 |
|
---|
| 105 | func (d *directive) parseParams(out ...*string) error {
|
---|
| 106 | if len(d.Params) != len(out) {
|
---|
| 107 | return fmt.Errorf("directive %q has wrong number of parameters: expected %v, got %v", d.Name, len(out), len(d.Params))
|
---|
| 108 | }
|
---|
| 109 | for i := range out {
|
---|
| 110 | *out[i] = d.Params[i]
|
---|
| 111 | }
|
---|
| 112 | return nil
|
---|
| 113 | }
|
---|