diff options
Diffstat (limited to 'src/rhrdlibrary')
-rw-r--r-- | src/rhrdlibrary/main.go | 111 |
1 files changed, 111 insertions, 0 deletions
diff --git a/src/rhrdlibrary/main.go b/src/rhrdlibrary/main.go new file mode 100644 index 0000000..cae8954 --- /dev/null +++ b/src/rhrdlibrary/main.go @@ -0,0 +1,111 @@ +// +// rhrdlibrary +// +// The Radio Helsinki Rivendell Library +// +// +// Copyright (C) 2016 Christian Pointner <equinox@helsinki.at> +// +// This file is part of rhrdlibrary. +// +// rhrdlibrary is free software: you can redistribute it and/or modify +// it under the terms of the GNU General Public License as published by +// the Free Software Foundation, either version 3 of the License, or +// any later version. +// +// rhrdlibrary is distributed in the hope that it will be useful, +// but WITHOUT ANY WARRANTY; without even the implied warranty of +// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +// GNU General Public License for more details. +// +// You should have received a copy of the GNU General Public License +// along with rhrdlibrary. If not, see <http://www.gnu.org/licenses/>. +// + +package main + +import ( + "code.helsinki.at/rhrd-go/rddb" + "flag" + "fmt" + "io/ioutil" + "log" + "os" + "os/signal" + "sync" + "time" +) + +var ( + rhl = log.New(os.Stderr, "[rhrdlibrary]\t", log.LstdFlags) + rhdl = log.New(ioutil.Discard, "[rhrdlibrary-dbg]\t", log.LstdFlags) +) + +func init() { + if _, exists := os.LookupEnv("RHRDLIBRARY_DEBUG"); exists { + rhdl.SetOutput(os.Stderr) + } +} + +type envStringValue string + +func newEnvStringValue(key, dflt string) *envStringValue { + if envval, exists := os.LookupEnv(key); exists { + return (*envStringValue)(&envval) + } else { + return (*envStringValue)(&dflt) + } +} + +func (s *envStringValue) Set(val string) error { + *s = envStringValue(val) + return nil +} + +func (s *envStringValue) Get() interface{} { return string(*s) } + +func (s *envStringValue) String() string { return fmt.Sprintf("%s", *s) } + +func main() { + rdconf := newEnvStringValue("RHRDLIBRARY_RD_CONF", "/etc/rd.conf") + flag.Var(rdconf, "rdconf", "path to the Rivendell config file (environment: RHRDLIBRARY_RD_CONF)") + help := flag.Bool("help", false, "show usage") + + flag.Parse() + if *help { + flag.Usage() + return + } + + db, err := rddb.NewDB(rdconf.Get().(string)) + if err != nil { + rhl.Println("Error initializing Rivdenll DB:", err) + return + } + defer db.Cleanup() + + var wg sync.WaitGroup + + wg.Add(1) + go func() { + defer wg.Done() + time.Sleep(10 * time.Second) + }() + + alldone := make(chan bool) + go func() { + defer func() { alldone <- true }() + wg.Wait() + }() + + c := make(chan os.Signal, 1) + signal.Notify(c, os.Interrupt) + + select { + case <-c: + rhl.Println("received interrupt, shutdown") + return + case <-alldone: + return + } +} |