From d7be997fae5847669c60718838d69e497d7516e1 Mon Sep 17 00:00:00 2001
From: onyx-and-iris <75868496+onyx-and-iris@users.noreply.github.com>
Date: Sat, 25 Jun 2022 20:11:15 +0100
Subject: [PATCH] add support for observers.

init/end pooler on login, logout
---
 examples/observer/observer.go | 26 ++++++++++++++++
 voicemeeter/publisher.go      | 56 +++++++++++++++++++++++++++++++++++
 voicemeeter/remote.go         | 10 ++++---
 3 files changed, 88 insertions(+), 4 deletions(-)
 create mode 100644 examples/observer/observer.go
 create mode 100644 voicemeeter/publisher.go

diff --git a/examples/observer/observer.go b/examples/observer/observer.go
new file mode 100644
index 0000000..fec0d38
--- /dev/null
+++ b/examples/observer/observer.go
@@ -0,0 +1,26 @@
+package main
+
+import (
+	"fmt"
+	"time"
+
+	"github.com/onyx-and-iris/voicemeeter-api-go/voicemeeter"
+)
+
+type observer struct{}
+
+func (o observer) OnUpdate(subject string) {
+	fmt.Println(subject)
+}
+
+func main() {
+	vmRem := voicemeeter.GetRemote("banana")
+	vmRem.Login()
+
+	o := observer{}
+	vmRem.Pooler.Publisher.Register(o)
+
+	time.Sleep(10 * time.Second)
+
+	vmRem.Logout()
+}
diff --git a/voicemeeter/publisher.go b/voicemeeter/publisher.go
new file mode 100644
index 0000000..015714b
--- /dev/null
+++ b/voicemeeter/publisher.go
@@ -0,0 +1,56 @@
+package voicemeeter
+
+type observer interface {
+	OnUpdate(subject string)
+}
+
+type Publisher struct {
+	observerList []observer
+}
+
+func (p *Publisher) Register(o observer) {
+	p.observerList = append(p.observerList, o)
+}
+
+func (p *Publisher) Deregister(o observer) {
+	var indexToRemove int
+
+	for i, observer := range p.observerList {
+		if observer == o {
+			indexToRemove = i
+			break
+		}
+	}
+
+	p.observerList = append(p.observerList[:indexToRemove], p.observerList[indexToRemove+1:]...)
+}
+
+func (p *Publisher) notify(subject string) {
+	for _, observer := range p.observerList {
+		observer.OnUpdate(subject)
+	}
+}
+
+type Pooler struct {
+	run bool
+	Publisher
+}
+
+func newPooler() *Pooler {
+	p := &Pooler{
+		run: true,
+	}
+	go p.runner()
+	return p
+}
+
+func (r *Pooler) runner() {
+	for r.run {
+		if pdirty() {
+			r.Publisher.notify("pdirty")
+		}
+		if mdirty() {
+			r.Publisher.notify("mdirty")
+		}
+	}
+}
diff --git a/voicemeeter/remote.go b/voicemeeter/remote.go
index 5d32026..6df3e34 100644
--- a/voicemeeter/remote.go
+++ b/voicemeeter/remote.go
@@ -14,6 +14,8 @@ type remote struct {
 	Button  []button
 	Command *command
 	Vban    *vban
+
+	Pooler *Pooler
 }
 
 // String implements the stringer interface
@@ -22,10 +24,12 @@ func (r *remote) String() string {
 }
 
 func (r *remote) Login() {
+	r.Pooler = newPooler()
 	login(r.kind.name)
 }
 
 func (r *remote) Logout() {
+	r.Pooler.run = false
 	logout()
 }
 
@@ -117,15 +121,13 @@ func (b *genericBuilder) makeButton() remoteBuilder {
 
 func (b *genericBuilder) makeCommand() remoteBuilder {
 	fmt.Println("building command")
-	_command := newCommand()
-	b.r.Command = _command
+	b.r.Command = newCommand()
 	return b
 }
 
 func (b *genericBuilder) makeVban() remoteBuilder {
 	fmt.Println("building vban")
-	_vban := newVban(b.k)
-	b.r.Vban = _vban
+	b.r.Vban = newVban(b.k)
 	return b
 }