diff options
| -rw-r--r-- | .gitignore | 1 | ||||
| -rw-r--r-- | Makefile | 4 | ||||
| -rw-r--r-- | src/rhrdlibrary/main.go | 11 | ||||
| -rw-r--r-- | src/rhrdlibrary/player.go | 75 |
4 files changed, 85 insertions, 6 deletions
@@ -1,4 +1,5 @@ bin/ pkg/ +snd/ src/github.com src/code.helsinki.at @@ -27,7 +27,9 @@ GOCMD := GOPATH=$(curdir) go EXECUTEABLE := rhrdlibrary -LIBS := "code.helsinki.at/rhrd-go/rddb" +LIBS := "code.helsinki.at/rhrd-go/rddb" \ + "github.com/ziutek/glib" \ + "github.com/ziutek/gst" .PHONY: getlibs updatelibs vet format build clean distclean 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 +} |