diff options
Diffstat (limited to 'src/rhrdlibrary')
| -rw-r--r-- | src/rhrdlibrary/main.go | 11 | ||||
| -rw-r--r-- | src/rhrdlibrary/player.go | 75 |
2 files changed, 81 insertions, 5 deletions
diff --git a/src/rhrdlibrary/main.go b/src/rhrdlibrary/main.go index cae8954..4209b8a 100644 --- a/src/rhrdlibrary/main.go +++ b/src/rhrdlibrary/main.go @@ -33,7 +33,6 @@ import ( "os" "os/signal" "sync" - "time" ) var ( @@ -42,9 +41,9 @@ var ( ) func init() { - if _, exists := os.LookupEnv("RHRDLIBRARY_DEBUG"); exists { - rhdl.SetOutput(os.Stderr) - } + // if _, exists := os.LookupEnv("RHRDLIBRARY_DEBUG"); exists { + rhdl.SetOutput(os.Stderr) + // } } type envStringValue string @@ -84,12 +83,14 @@ func main() { } defer db.Cleanup() + player, _ := NewPlayer("/home/equinox/helsinki/rivenhell/contrib/rhrdlibrary/snd") + var wg sync.WaitGroup wg.Add(1) go func() { defer wg.Done() - time.Sleep(10 * time.Second) + player.Play(1, 1) }() alldone := make(chan bool) diff --git a/src/rhrdlibrary/player.go b/src/rhrdlibrary/player.go new file mode 100644 index 0000000..8a97ed3 --- /dev/null +++ b/src/rhrdlibrary/player.go @@ -0,0 +1,75 @@ +// +// 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/ziutek/glib" + "github.com/ziutek/gst" + "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: + rhdl.Printf("Error: received gst error message") + p.pipe.SetState(gst.STATE_NULL) + // TODO: this crashes the program + // err, debug := msg.ParseError() + // rhdl.Printf("Error: %s (debug: %s)\n", err, debug) + } +} + +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 +} |