diff options
Diffstat (limited to 'src/rhlibrary/main.go')
-rw-r--r-- | src/rhlibrary/main.go | 112 |
1 files changed, 112 insertions, 0 deletions
diff --git a/src/rhlibrary/main.go b/src/rhlibrary/main.go new file mode 100644 index 0000000..85e5b8a --- /dev/null +++ b/src/rhlibrary/main.go @@ -0,0 +1,112 @@ +// +// rhlibrary +// +// The Radio Helsinki Rivendell Library +// +// +// Copyright (C) 2016 Christian Pointner <equinox@helsinki.at> +// +// This file is part of rhlibrary. +// +// rhlibrary 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. +// +// rhlibrary 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 rhlibrary. 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" +) + +var ( + rhl = log.New(os.Stderr, "[rhlibrary]\t", log.LstdFlags) + rhdl = log.New(ioutil.Discard, "[rhlibrary-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() + + player, _ := NewPlayer("/home/equinox/helsinki/rivenhell/contrib/rhlibrary/snd") + + var wg sync.WaitGroup + + wg.Add(1) + go func() { + defer wg.Done() + player.Play(1, 1) + }() + + 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 + } +} |