voicemeeter/publisher.go

141 lines
2.5 KiB
Go
Raw Normal View History

package voicemeeter
2022-06-30 23:20:15 +01:00
import (
"time"
)
// observer defines the interface any registered observers must satisfy
type observer interface {
OnUpdate(subject string)
}
// publisher defines methods that support observers
2022-06-26 01:41:05 +01:00
type publisher struct {
observerList []observer
}
// Register adds an observer to observerList
2022-06-26 01:41:05 +01:00
func (p *publisher) Register(o observer) {
p.observerList = append(p.observerList, o)
}
// Deregister removes an observer from observerList
2022-06-26 01:41:05 +01:00
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:]...)
}
// notify updates observers of any changes
2022-06-26 01:41:05 +01:00
func (p *publisher) notify(subject string) {
for _, observer := range p.observerList {
observer.OnUpdate(subject)
}
}
type event struct {
pdirty bool
mdirty bool
midi bool
ldirty bool
}
func newEvent() *event {
return &event{true, true, true, false}
}
func (e *event) Add(ev string) {
switch ev {
case "pdirty":
e.pdirty = true
case "mdirty":
e.mdirty = true
case "midi":
e.midi = true
case "ldirty":
e.ldirty = true
}
}
func (e *event) Remove(ev string) {
switch ev {
case "pdirty":
e.pdirty = false
case "mdirty":
e.mdirty = false
case "midi":
e.midi = false
case "ldirty":
e.ldirty = false
}
}
// pooler continuously polls the dirty paramters
// it is expected to be run in a goroutine
2022-06-26 01:41:05 +01:00
type pooler struct {
k *kind
run bool
event *event
2022-06-26 01:41:05 +01:00
publisher
}
func newPooler(k *kind) *pooler {
2022-06-26 01:41:05 +01:00
p := &pooler{
k: k,
run: true,
event: newEvent(),
}
go p.parameters()
go p.macrobuttons()
go p.midi()
go p.levels()
return p
}
func (p *pooler) parameters() {
for p.run {
if p.event.pdirty && pdirty() {
p.notify("pdirty")
}
time.Sleep(33 * time.Millisecond)
}
}
func (p *pooler) macrobuttons() {
for p.run {
if p.event.mdirty && mdirty() {
p.notify("mdirty")
}
2022-06-30 23:20:15 +01:00
time.Sleep(33 * time.Millisecond)
}
}
func (p *pooler) midi() {
for p.run {
if getMidiMessage() {
p.notify("midi")
}
time.Sleep(33 * time.Millisecond)
}
}
func (p *pooler) levels() {
_levelCache = newLevelCache(p.k)
for p.run {
if p.event.ldirty && ldirty(p.k) {
update(_levelCache.stripLevels, _levelCache.stripLevelsBuff, (2*p.k.PhysIn)+(8*p.k.VirtIn))
update(_levelCache.busLevels, _levelCache.busLevelsBuff, 8*p.k.NumBus())
p.notify("ldirty")
}
time.Sleep(33 * time.Millisecond)
}
}