summaryrefslogtreecommitdiff
path: root/src/rhrdlibrary
diff options
context:
space:
mode:
authorChristian Pointner <equinox@helsinki.at>2016-01-13 13:41:28 (GMT)
committerChristian Pointner <equinox@helsinki.at>2016-01-13 13:41:28 (GMT)
commitb2398fd830443fa2930de0605d153b8a1264be95 (patch)
treef7c9c35a3c340b424919cd705ebd3d54b5da8109 /src/rhrdlibrary
parentd95d4579b749b7fd3729099e8751ea9584ffdea0 (diff)
renamed rhrdlibrary to rhlibrary
Diffstat (limited to 'src/rhrdlibrary')
-rw-r--r--src/rhrdlibrary/main.go112
-rw-r--r--src/rhrdlibrary/player.go73
2 files changed, 0 insertions, 185 deletions
diff --git a/src/rhrdlibrary/main.go b/src/rhrdlibrary/main.go
deleted file mode 100644
index 4209b8a..0000000
--- a/src/rhrdlibrary/main.go
+++ /dev/null
@@ -1,112 +0,0 @@
-//
-// 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"
-)
-
-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()
-
- player, _ := NewPlayer("/home/equinox/helsinki/rivenhell/contrib/rhrdlibrary/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
- }
-}
diff --git a/src/rhrdlibrary/player.go b/src/rhrdlibrary/player.go
deleted file mode 100644
index 3463190..0000000
--- a/src/rhrdlibrary/player.go
+++ /dev/null
@@ -1,73 +0,0 @@
-//
-// 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 (
- "fmt"
- "github.com/revmischa/gst"
- "github.com/ziutek/glib"
- "path"
-)
-
-type Player struct {
- pipe *gst.Element
- bus *gst.Bus
- basepath string
-}
-
-func (p *Player) onMessage(bus *gst.Bus, msg *gst.Message) {
- switch msg.GetType() {
- case gst.MESSAGE_EOS:
- rhdl.Printf("EOS reached!")
- p.pipe.SetState(gst.STATE_NULL)
- case gst.MESSAGE_ERROR:
- p.pipe.SetState(gst.STATE_NULL)
- _, errstr := msg.ParseError()
- rhdl.Printf("Error: %s\n", errstr)
- }
-}
-
-func (p *Player) Play(cart, cut uint) (err error) {
- filename := path.Join(p.basepath, fmt.Sprintf("%06d_%03d.wav", cart, cut))
- rhdl.Printf("trying to play file: %s", filename)
-
- p.pipe.SetProperty("uri", "file://"+filename)
- p.pipe.SetState(gst.STATE_PLAYING)
- glib.NewMainLoop(nil).Run()
- return
-}
-
-func NewPlayer(basepath string) (p *Player, err error) {
- p = &Player{}
- p.basepath = path.Clean(basepath)
-
- p.pipe = gst.ElementFactoryMake("playbin", "autoplay")
- p.bus = p.pipe.GetBus()
-
- p.bus.AddSignalWatch()
- p.bus.Connect("message", (*Player).onMessage, p)
-
- return
-}