From f8b3c8c2ca2a51100c7b7649acf5aa90a47623bc Mon Sep 17 00:00:00 2001
From: Christian Pointner <equinox@helsinki.at>
Date: Fri, 30 Dec 2016 17:37:33 +0100
Subject: added fix volume factor to player


diff --git a/player/player.go b/player/player.go
index 77f34a3..67e5de2 100644
--- a/player/player.go
+++ b/player/player.go
@@ -154,6 +154,7 @@ type player struct {
 	level                     *gst.Element
 	bus                       *gst.Bus
 	basepath                  string
+	volume                    float64
 	stdlog                    *log.Logger
 	dbglog                    *log.Logger
 	state                     State
@@ -391,7 +392,7 @@ func (p *player) createPipeline() (err error) {
 		return
 	}
 
-	var conv1, conv2, sink *gst.Element
+	var conv1, conv2, volume, sink *gst.Element
 	if p.src, err = gst.ElementFactoryMake("uridecodebin", "source"); err != nil {
 		return
 	}
@@ -408,6 +409,10 @@ func (p *player) createPipeline() (err error) {
 	if conv2, err = gst.ElementFactoryMake("audioconvert", "conv2"); err != nil {
 		return
 	}
+	if volume, err = gst.ElementFactoryMake("volume", "volume"); err != nil {
+		return
+	}
+	volume.SetProperty("volume", p.volume)
 	if sink, err = gst.ElementFactoryMake("autoaudiosink", "sink"); err != nil {
 		return
 	}
@@ -416,6 +421,7 @@ func (p *player) createPipeline() (err error) {
 	p.pipe.Add(conv1)
 	p.pipe.Add(p.level)
 	p.pipe.Add(conv2)
+	p.pipe.Add(volume)
 	p.pipe.Add(sink)
 
 	sinkpad, err := conv1.GetStaticPad("sink")
@@ -430,7 +436,8 @@ func (p *player) createPipeline() (err error) {
 	})
 	conv1.Link(p.level)
 	p.level.Link(conv2)
-	conv2.Link(sink)
+	conv2.Link(volume)
+	volume.Link(sink)
 
 	if p.bus, err = p.pipe.GetBus(); err != nil {
 		return
@@ -591,9 +598,10 @@ func (p *player) GetInterface() *Player {
 	return ch
 }
 
-func NewPlayer(basepath string, stdlog *log.Logger, dbglog *log.Logger) (p *player, err error) {
+func NewPlayer(basepath string, volume float64, stdlog *log.Logger, dbglog *log.Logger) (p *player, err error) {
 	p = &player{}
 	p.basepath = path.Clean(basepath)
+	p.volume = volume
 	p.state = IDLE
 	p.duration = 0
 	if stdlog != nil {
-- 
cgit v0.10.2