summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--.gitignore1
-rw-r--r--Makefile4
-rw-r--r--src/rhrdlibrary/main.go11
-rw-r--r--src/rhrdlibrary/player.go75
4 files changed, 85 insertions, 6 deletions
diff --git a/.gitignore b/.gitignore
index bc88ec7..0cdf92d 100644
--- a/.gitignore
+++ b/.gitignore
@@ -1,4 +1,5 @@
bin/
pkg/
+snd/
src/github.com
src/code.helsinki.at
diff --git a/Makefile b/Makefile
index e4242c5..77025e4 100644
--- a/Makefile
+++ b/Makefile
@@ -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
+}