43 Commits

Author SHA1 Message Date
onyx-and-iris
10d7cea523 Merge branch 'dev' of https://github.com/onyx-and-iris/voicemeeter-api-go into dev 2022-09-22 22:55:24 +01:00
onyx-and-iris
8a9b5f9a97 rename dir structure to match package name
update examples, readme
2022-09-22 22:55:08 +01:00
norm
8a611e39aa change func and var names 2022-09-21 07:30:14 +01:00
norm
ff56dd16f5 upd readme with new default delay 2022-09-19 03:05:02 +01:00
norm
440c3b8eec increae default delay to 20 2022-09-19 03:03:51 +01:00
onyx-and-iris
a5f653f569 add error message if config not found 2022-09-18 20:57:59 +01:00
onyx-and-iris
73893209a1 upd dependency ver 2022-09-18 05:53:08 +01:00
onyx-and-iris
303f1a871c md fix 2022-09-18 05:45:09 +01:00
onyx-and-iris
2c6baf20e4 vm-cli reworked.
now accepts -kind and -delay flags.

arg parsing moved into separate run_commands function.

README added to vm-cli example
2022-09-18 05:39:42 +01:00
onyx-and-iris
c05bf500ee obs example now reads conn info from toml.
vm, obs connect logic moved into separate functions.

README added for obs example.
2022-09-18 05:38:22 +01:00
onyx-and-iris
2533f1c162 refactor observer example.
newObserver factory method added
2022-09-18 05:37:10 +01:00
onyx-and-iris
21fb2ad597 refactor example in readme 2022-09-18 05:36:24 +01:00
onyx-and-iris
1284c92680 refactor hotkeys example. 2022-09-18 05:35:53 +01:00
onyx-and-iris
a87c11099c config.toml added to gitignore 2022-09-18 05:35:27 +01:00
onyx-and-iris
00f66e8f9e GetFloat, SetFloat now return error type on error
GetString, SetString now return error type on error

SendText now returns error type on error

remote_test updated.
2022-09-18 05:35:04 +01:00
onyx-and-iris
e16a51c0da Fade and App methods added to readme. 2022-09-17 03:47:54 +01:00
onyx-and-iris
8a03904ab8 add readme to vm-cli example 2022-09-17 03:21:04 +01:00
onyx-and-iris
5fb7f5e4db remove redundant files 2022-09-17 03:13:50 +01:00
onyx-and-iris
915e3a9609 add vm-cli example 2022-09-17 03:11:53 +01:00
onyx-and-iris
0a7b8e0662 fix whitespace 2022-09-14 21:17:20 +01:00
onyx-and-iris
c32e3995db add hotkeys example 2022-09-14 21:16:29 +01:00
onyx-and-iris
07218472df obs example updated 2022-09-14 16:43:04 +01:00
onyx-and-iris
db7826dab6 reword in readme 2022-09-14 16:11:34 +01:00
onyx-and-iris
32780f11e4 changelog, readme updated to reflect changes
minor bump.
2022-09-14 16:05:49 +01:00
onyx-and-iris
8ca545b1c4 NewRemote now accepts delay param
getters clear dirty params sync enabled.

examples and tests updated
2022-09-14 16:05:15 +01:00
onyx-and-iris
a4b84f289e higher methods/functions now accept/return float64
update tests

update readme, changelog
2022-09-14 00:58:05 +01:00
onyx-and-iris
67cb8509b4 Update README.md 2022-09-07 22:32:37 +01:00
onyx-and-iris
e4de1d49cb upd go.mod for obs example 2022-09-07 21:10:42 +01:00
onyx-and-iris
50d045d823 fix ver in changelog 2022-09-07 21:04:14 +01:00
onyx-and-iris
6ed4e38dae changes to error handling
readme, changelog updated to reflect changes

version bump
2022-09-07 20:59:55 +01:00
onyx-and-iris
505b5969a2 go fmt all files.
add midi event toggle to the pooler
2022-08-23 14:03:07 +01:00
onyx-and-iris
7f992a1a87 only check subject once per update 2022-08-23 03:58:49 +01:00
onyx-and-iris
fa8e9f3e76 obs example added. 2022-08-23 03:53:51 +01:00
onyx-and-iris
7a79555cb8 use log.Fatal during setup procedures.
update readme example
2022-08-23 03:35:34 +01:00
onyx-and-iris
6fabc43998 return err from NewRemote\
pass Kind.Name to logout

update examples/tests to reflect changes
2022-08-23 03:16:43 +01:00
onyx-and-iris
3fd08ff606 fix deregister in observer example 2022-08-22 22:54:38 +01:00
onyx-and-iris
7744971a10 changelog updated to reflect changes
minor version bump
2022-08-22 22:40:08 +01:00
onyx-and-iris
82bbcd06b1 tested against version updated.
Get/Set Float/String, EventAdd() + EventRemote() added to README

Midi and Events sections added to README.
2022-08-22 22:39:35 +01:00
onyx-and-iris
cba2ac85ec observer example updated with midi event.
ldirty now enabled explicitly in observer example.
2022-08-22 22:34:32 +01:00
onyx-and-iris
dd895daffb float/string getter/setter tests added
test helper added
2022-08-22 22:34:03 +01:00
onyx-and-iris
87a05d81e4 getter/setter method forwarders added to Remote
EventAdd() and EventRemote() added to Remote

method chaining in builder types split across lines.
2022-08-22 22:33:22 +01:00
onyx-and-iris
3ea4aee863 event type added for toggline evet subscriptions.
level updates now disabled by default.

each event updater runs in its own goroutine.
2022-08-22 22:29:30 +01:00
onyx-and-iris
69476ffcd9 getMidiMessage implemented
midi type added.
2022-08-22 22:28:11 +01:00
33 changed files with 1124 additions and 278 deletions

3
.gitignore vendored
View File

@@ -1,6 +1,9 @@
# quick tests # quick tests
quick quick
#config
config.toml
# Binaries for programs and plugins # Binaries for programs and plugins
*.exe *.exe
*.exe~ *.exe~

View File

@@ -11,6 +11,42 @@ Before any major/minor/patch bump all unit tests will be run to verify they pass
- [x] - [x]
## [1.7.0] - 2022-09-14
### Added
- voicemeeter.NewRemote now accepts a delay int argument (milliseconds).
- vm.Sync() can now be used to force the dirty parameters to clear.
### Changed
- higher level methods/functions now accept/return float64
- tests updated to reflect changes.
## [1.5.0] - 2022-09-07
### Changed
- changes to error handling.
- functions that wrap capi calls now return error types.
- higher level functions print error messages
## [1.4.0] - 2022-08-22
### Added
- midi type, supports midi devices
- midi updates added to the pooler
- event type, supports toggling event updates through EventAdd() and EventRemove() methods.
- Forwarder methods for get/set float/string parameters added to Remote type
- Midi, Events sections added to README.
### Changed
- macrobutton updates moved into its own goroutine
- observer example updated to include midi updates
- level updates are now disabled by default, should be enabled explicitly
## [1.2.0] - 2022-07-10 ## [1.2.0] - 2022-07-10
### Added ### Added

167
README.md
View File

@@ -1,4 +1,4 @@
[![Go Reference](https://pkg.go.dev/badge/github.com/onyx-and-iris/voicemeeter-api-go.svg)](https://pkg.go.dev/github.com/onyx-and-iris/voicemeeter-api-go) [![Go Reference](https://pkg.go.dev/badge/github.com/onyx-and-iris/voicemeeter.svg)](https://pkg.go.dev/github.com/onyx-and-iris/voicemeeter)
# A Go Wrapper for Voicemeeter API # A Go Wrapper for Voicemeeter API
@@ -8,9 +8,9 @@ For an outline of past/future changes refer to: [CHANGELOG](CHANGELOG.md)
## Tested against ## Tested against
- Basic 1.0.8.2 - Basic 1.0.8.4
- Banana 2.0.6.2 - Banana 2.0.6.4
- Potato 3.0.2.2 - Potato 3.0.2.4
## Requirements ## Requirements
@@ -19,19 +19,13 @@ For an outline of past/future changes refer to: [CHANGELOG](CHANGELOG.md)
## Installation ## Installation
#### GO.MOD
Add to your `go.mod` file:
`require github.com/onyx-and-iris/voicemeeter-api-go vX.X.X`
where `vX.X.X` is the version you require.
#### GO GET #### GO GET
Install voicemeeter-api-go package from your console to download the latest version. Install voicemeeter-api-go package from your console to download the latest version.
`go get github.com/onyx-and-iris/voicemeeter-api-go` `go get github.com/onyx-and-iris/voicemeeter`
or add it to your `go.mod` file.
## `Use` ## `Use`
@@ -42,25 +36,41 @@ package main
import ( import (
"fmt" "fmt"
"log"
"github.com/onyx-and-iris/voicemeeter-api-go" "github.com/onyx-and-iris/voicemeeter"
) )
func main() { func main() {
kindId := "banana" vm, err := vmConnect()
vm := voicemeeter.NewRemote(kindId) if err != nil {
log.Fatal(err)
vm.Login() }
defer vm.Logout()
vm.Strip[0].SetLabel("rode podmic") vm.Strip[0].SetLabel("rode podmic")
vm.Strip[0].SetMute(true) vm.Strip[0].SetMute(true)
fmt.Printf("Strip 0 (%s) mute was set to %v\n", vm.Strip[0].GetLabel(), vm.Strip[0].GetMute()) fmt.Printf("Strip 0 (%s) mute was set to %v\n", vm.Strip[0].GetLabel(), vm.Strip[0].GetMute())
}
vm.Logout() func vmConnect() (*voicemeeter.Remote, error) {
vm, err := voicemeeter.NewRemote("banana", 15)
if err != nil {
return nil, err
}
err = vm.Login()
if err != nil {
return nil, err
}
return vm, nil
} }
``` ```
## `kindId` ## `voicemeeter.NewRemote(<kindId>, <delay>)`
### `kindId`
Pass the kind of Voicemeeter as an argument. kindId may be: Pass the kind of Voicemeeter as an argument. kindId may be:
@@ -68,6 +78,12 @@ Pass the kind of Voicemeeter as an argument. kindId may be:
- `banana` - `banana`
- `potato` - `potato`
### `delay`
Pass a delay in milliseconds to force the getters to wait for dirty parameters to clear.
Useful if not running callbacks.
## `Remote Type` ## `Remote Type`
#### `vm.Strip` #### `vm.Strip`
@@ -98,6 +114,10 @@ pointer to device type, represents physical input/output hardware devices
pointer to recorder type, represents the recorder pointer to recorder type, represents the recorder
#### `vm.Midi`
pointer to midi type, represents a connected midi device
#### `vm.Type()` #### `vm.Type()`
returns the type of Voicemeeter as a string returns the type of Voicemeeter as a string
@@ -106,6 +126,22 @@ returns the type of Voicemeeter as a string
returns the version of Voicemeeter as a string returns the version of Voicemeeter as a string
#### `vm.GetFloat(<param>)`
gets a float parameter value
#### `vm.SetFloat(<param>, <value>)`
sets a float parameter value eg. vm.SetFloat("strip[0].mute", 1)
#### `vm.GetString(<param>)`
gets a string parameter value
#### `vm.SetString(<param>, <value>)`
sets a string parameter value eg. vm.SetString("strip[0].label", "podmic")
#### `vm.SendText(<script>)` #### `vm.SendText(<script>)`
sets many parameters in script format eg. ("Strip[0].Mute=1;Bus[3].Gain=3.6") sets many parameters in script format eg. ("Strip[0].Mute=1;Bus[3].Gain=3.6")
@@ -118,13 +154,25 @@ register an object as an observer
deregister an object as an observer deregister an object as an observer
#### `vm.EventAdd(<event>)`
adds an event to the pooler eg. vm.EventAdd("ldirty")
#### `vm.EventRemove(<event>)`
removes an event to the pooler eg. vm.EventRemove("pdirty")
#### `vm.Pdirty()` #### `vm.Pdirty()`
returns True iff a GUI parameter has changed returns True iff a GUI parameter has changed
#### `vm.Mdirty()` #### `vm.Mdirty()`
returns True iff a macrobutton paramter has changed returns True iff a macrobutton parameter has changed
#### `vm.Sync()`
Use this to force dirty parameters to clear after a delay in milliseconds.
## `Available commands` ## `Available commands`
@@ -143,17 +191,19 @@ The following methods are available
- `GetLabel() string` - `GetLabel() string`
- `SetLabel(val string)` - `SetLabel(val string)`
- `GetGain() float64` - `GetGain() float64`
- `SetGain(val float32)` from -60.0 to 12.0 - `SetGain(val float64)` from -60.0 to 12.0
- `GetMc() bool` - `GetMc() bool`
- `SetMc(val bool)` - `SetMc(val bool)`
- `GetComp() float64` - `GetComp() float64`
- `SetComp(val float32)` from 0.0 to 10.0 - `SetComp(val float64)` from 0.0 to 10.0
- `GetGate() float64` - `GetGate() float64`
- `SetGate(val float32)` from 0.0 to 10.0 - `SetGate(val float64)` from 0.0 to 10.0
- `GetAudibility() float64` - `GetAudibility() float64`
- `SetAudibility(val float32)` from 0.0 to 10.0 - `SetAudibility(val float64)` from 0.0 to 10.0
- `GetA1() bool - GetA5() bool` - `GetA1() bool - GetA5() bool`
- `SetA1(val bool) - SetA5(val bool)` - `SetA1(val bool) - SetA5(val bool)`
- `AppGain(name string, gain float64)`
- `AppMute(name string, val bool)`
example: example:
@@ -161,6 +211,9 @@ example:
vm.Strip[3].SetGain(3.7) vm.Strip[3].SetGain(3.7)
fmt.Println(vm.Strip[0].GetLabel()) fmt.Println(vm.Strip[0].GetLabel())
vm.Strip[4].SetA1(true) vm.Strip[4].SetA1(true)
vm.Strip[5].AppGain("Spotify", 0.5)
vm.Strip[5].AppMute("Spotify", true)
``` ```
##### Gainlayers ##### Gainlayers
@@ -170,7 +223,7 @@ vm.Strip[4].SetA1(true)
The following methods are available The following methods are available
- `Get() float64` - `Get() float64`
- `Set(val float32)` - `Set(val float64)`
example: example:
@@ -184,9 +237,9 @@ vm.Strip[6].GainLayer()[3].Set(-13.6)
The following methods are available The following methods are available
- `PreFader() []float32` - `PreFader() []float64`
- `PostFader() []float32` - `PostFader() []float64`
- `PostMute() []float32` - `PostMute() []float64`
example: example:
@@ -208,7 +261,7 @@ The following methods are available
- `GetLabel() string` - `GetLabel() string`
- `SetLabel(val string)` - `SetLabel(val string)`
- `GetGain() float64` - `GetGain() float64`
- `SetGain(val float32)` from -60.0 to 12.0 - `SetGain(val float64)` from -60.0 to 12.0
```go ```go
vm.Bus[3].SetEq(true) vm.Bus[3].SetEq(true)
@@ -259,7 +312,7 @@ vm.Bus[4].Mode().SetCenterOnly(true)
The following methods are available The following methods are available
- `All() []float32` - `All() []float64`
example: example:
@@ -267,6 +320,22 @@ example:
fmt.Println(vm.Bus[1].Levels().All()) fmt.Println(vm.Bus[1].Levels().All())
``` ```
### Strip | Bus
The following methods are available.
- `FadeTo(target float64, time_ int)`: float, int
- `FadeBy(change float64, time_ int)`: float, int
Modify gain to or by the selected amount in db over a time interval in ms.
example:
```go
vm.Strip[3].FadeBy(-8.3, 500)
vm.Bus[3].FadeTo(-12.8, 500)
```
### Button ### Button
The following methods are available The following methods are available
@@ -348,8 +417,8 @@ vm.Vban.OutStream[3].SetBit(24)
The following methods are available The following methods are available
- `Ins` - `Ins()`
- `Outs` - `Outs()`
- `Input(val int)` - `Input(val int)`
- `Output(val int)` - `Output(val int)`
@@ -386,6 +455,38 @@ vm.Recorder.Loop(true)
vm.Recorder.SetB2(false) vm.Recorder.SetB2(false)
``` ```
### Midi
The following methods are available
- `Channel()` returns the current midi channel
- `Current()` returns the most recently pressed midi button
- `Get(<button>)` returns the value in cache for the midi button
example:
```go
var current = vm.Midi.Current()
var val = vm.Midi.Get(current)
```
### Events
By default level updates are disabled. Any event may be enabled or disabled. The following events exist:
- `pdirty` parameter updates
- `mdirty` macrobutton updates
- `midi` midi updates
- `ldirty` level updates
example:
```go
vm.EventAdd("ldirty")
vm.EventRemove("pdirty")
```
### Run tests ### Run tests
To run all tests: To run all tests:

166
base.go
View File

@@ -4,7 +4,6 @@ import (
"bytes" "bytes"
"fmt" "fmt"
"math" "math"
"os"
"strings" "strings"
"syscall" "syscall"
"time" "time"
@@ -37,41 +36,43 @@ var (
vmMdirty = mod.NewProc("VBVMR_MacroButton_IsDirty") vmMdirty = mod.NewProc("VBVMR_MacroButton_IsDirty")
vmGetMacroStatus = mod.NewProc("VBVMR_MacroButton_GetStatus") vmGetMacroStatus = mod.NewProc("VBVMR_MacroButton_GetStatus")
vmSetMacroStatus = mod.NewProc("VBVMR_MacroButton_SetStatus") vmSetMacroStatus = mod.NewProc("VBVMR_MacroButton_SetStatus")
vmGetMidiMessage = mod.NewProc("VBVMR_GetMidiMessage")
) )
// login logs into the API, // login logs into the API,
// attempts to launch Voicemeeter if it's not running, // attempts to launch Voicemeeter if it's not running,
// initializes dirty parameters. // initializes dirty parameters.
func login(kindId string) { func login(kindId string) error {
res, _, _ := vmLogin.Call() res, _, _ := vmLogin.Call()
if res == 1 { if res == 1 {
runVoicemeeter(kindId) runVoicemeeter(kindId)
time.Sleep(time.Second) time.Sleep(time.Second)
} else if res != 0 { } else if res != 0 {
err := fmt.Errorf("VBVMR_Login returned %d", res) err := fmt.Errorf("VBVMR_Login returned %d", res)
fmt.Println(err) return err
os.Exit(1)
} }
fmt.Println("Logged into API") fmt.Printf("Logged into Voicemeeter %s\n", kindId)
for pdirty() || mdirty() { for pdirty() || mdirty() {
} }
return nil
} }
// logout logs out of the API, // logout logs out of the API,
// delayed for 100ms to allow final operation to complete. // delayed for 100ms to allow final operation to complete.
func logout() { func logout(kindId string) error {
time.Sleep(100 * time.Millisecond) time.Sleep(100 * time.Millisecond)
res, _, _ := vmLogout.Call() res, _, _ := vmLogout.Call()
if res != 0 { if res != 0 {
err := fmt.Errorf("VBVMR_Logout returned %d", res) err := fmt.Errorf("VBVMR_Logout returned %d", res)
fmt.Println(err) return err
os.Exit(1)
} }
fmt.Println("Logged out of API") fmt.Printf("Logged out of Voicemeeter %s\n", kindId)
return nil
} }
// runVoicemeeter attempts to launch a Voicemeeter GUI of a kind. // runVoicemeeter attempts to launch a Voicemeeter GUI of a kind.
func runVoicemeeter(kindId string) { func runVoicemeeter(kindId string) error {
vals := map[string]uint64{ vals := map[string]uint64{
"basic": 1, "basic": 1,
"banana": 2, "banana": 2,
@@ -80,25 +81,24 @@ func runVoicemeeter(kindId string) {
res, _, _ := vmRunvm.Call(uintptr(vals[kindId])) res, _, _ := vmRunvm.Call(uintptr(vals[kindId]))
if res != 0 { if res != 0 {
err := fmt.Errorf("VBVMR_RunVoicemeeter returned %d", res) err := fmt.Errorf("VBVMR_RunVoicemeeter returned %d", res)
fmt.Println(err) return err
os.Exit(1)
} }
return nil
} }
// getVersion returns the version of Voicemeeter as a string // getVersion returns the version of Voicemeeter as a string
func getVersion() string { func getVersion() (string, error) {
var ver uint64 var ver uint64
res, _, _ := vmGetvmVersion.Call(uintptr(unsafe.Pointer(&ver))) res, _, _ := vmGetvmVersion.Call(uintptr(unsafe.Pointer(&ver)))
if res != 0 { if res != 0 {
err := fmt.Errorf("VBVMR_GetVoicemeeterVersion returned %d", res) err := fmt.Errorf("VBVMR_GetVoicemeeterVersion returned %d", res)
fmt.Println(err) return "", err
os.Exit(1)
} }
v1 := (ver & 0xFF000000) >> 24 v1 := (ver & 0xFF000000) >> 24
v2 := (ver & 0x00FF0000) >> 16 v2 := (ver & 0x00FF0000) >> 16
v3 := (ver & 0x0000FF00) >> 8 v3 := (ver & 0x0000FF00) >> 8
v4 := ver & 0x000000FF v4 := ver & 0x000000FF
return fmt.Sprintf("%d.%d.%d.%d", v1, v2, v3, v4) return fmt.Sprintf("%d.%d.%d.%d", v1, v2, v3, v4), nil
} }
// pdirty returns true iff a parameter value has changed // pdirty returns true iff a parameter value has changed
@@ -115,41 +115,47 @@ func mdirty() bool {
// ldirty returns true iff a level value has changed // ldirty returns true iff a level value has changed
func ldirty(k *kind) bool { func ldirty(k *kind) bool {
_levelCache.stripLevelsBuff = make([]float32, (2*k.PhysIn)+(8*k.VirtIn)) _levelCache.stripLevelsBuff = make([]float64, (2*k.PhysIn)+(8*k.VirtIn))
_levelCache.busLevelsBuff = make([]float32, 8*k.NumBus()) _levelCache.busLevelsBuff = make([]float64, 8*k.NumBus())
for i := 0; i < (2*k.PhysIn)+(8*k.VirtIn); i++ { for i := 0; i < (2*k.PhysIn)+(8*k.VirtIn); i++ {
_levelCache.stripLevelsBuff[i] = float32(getLevel(_levelCache.stripMode, i)) val, _ := getLevel(_levelCache.stripMode, i)
_levelCache.stripLevelsBuff[i] = val
_levelCache.stripComp[i] = _levelCache.stripLevelsBuff[i] == _levelCache.stripLevels[i] _levelCache.stripComp[i] = _levelCache.stripLevelsBuff[i] == _levelCache.stripLevels[i]
} }
for i := 0; i < 8*k.NumBus(); i++ { for i := 0; i < 8*k.NumBus(); i++ {
_levelCache.busLevelsBuff[i] = float32(getLevel(3, i)) val, _ := getLevel(3, i)
_levelCache.busLevelsBuff[i] = val
_levelCache.busComp[i] = _levelCache.busLevelsBuff[i] == _levelCache.busLevels[i] _levelCache.busComp[i] = _levelCache.busLevelsBuff[i] == _levelCache.busLevels[i]
} }
return !(allTrue(_levelCache.stripComp, (2*k.PhysIn)+(8*k.VirtIn)) && allTrue(_levelCache.busComp, 8*k.NumBus())) return !(allTrue(_levelCache.stripComp, (2*k.PhysIn)+(8*k.VirtIn)) && allTrue(_levelCache.busComp, 8*k.NumBus()))
} }
// getVMType returns the type of Voicemeeter, as a string // getVMType returns the type of Voicemeeter, as a string
func getVMType() string { func getVMType() (string, error) {
var type_ uint64 var type_ uint64
res, _, _ := vmGetvmType.Call( res, _, _ := vmGetvmType.Call(
uintptr(unsafe.Pointer(&type_)), uintptr(unsafe.Pointer(&type_)),
) )
if res != 0 { if res != 0 {
err := fmt.Errorf("VBVMR_GetVoicemeeterType returned %d", res) err := fmt.Errorf("VBVMR_GetVoicemeeterType returned %d", res)
fmt.Println(err) return "", err
os.Exit(1)
} }
vals := map[uint64]string{ vals := map[uint64]string{
1: "basic", 1: "basic",
2: "banana", 2: "banana",
3: "potato", 3: "potato",
} }
return vals[type_] return vals[type_], nil
} }
// getParameterFloat gets the value of a float parameter // getParameterFloat gets the value of a float parameter
func getParameterFloat(name string) float64 { func getParameterFloat(name string) (float64, error) {
if vmsync {
time.Sleep(time.Duration(vmdelay) * time.Millisecond)
for pdirty() || mdirty() {
}
}
var value float32 var value float32
b := append([]byte(name), 0) b := append([]byte(name), 0)
res, _, _ := vmGetParamFloat.Call( res, _, _ := vmGetParamFloat.Call(
@@ -158,29 +164,33 @@ func getParameterFloat(name string) float64 {
) )
if res != 0 { if res != 0 {
err := fmt.Errorf("VBVMR_GetParameterFloat returned %d", res) err := fmt.Errorf("VBVMR_GetParameterFloat returned %d", res)
fmt.Println(err) return 0, err
os.Exit(1)
} }
return math.Round(float64(value)*10) / 10 return math.Round(float64(value)*10) / 10, nil
} }
// setParameterFloat sets the value of a float parameter // setParameterFloat sets the value of a float parameter
func setParameterFloat(name string, value float32) { func setParameterFloat(name string, value float64) error {
b1 := append([]byte(name), 0) b1 := append([]byte(name), 0)
b2 := math.Float32bits(value) b2 := math.Float32bits(float32(value))
res, _, _ := vmSetParamFloat.Call( res, _, _ := vmSetParamFloat.Call(
uintptr(unsafe.Pointer(&b1[0])), uintptr(unsafe.Pointer(&b1[0])),
uintptr(b2), uintptr(b2),
) )
if res != 0 { if res != 0 {
err := fmt.Errorf("VBVMR_SetParameterFloat returned %d", res) err := fmt.Errorf("VBVMR_SetParameterFloat returned %d", res)
fmt.Println(err) return err
os.Exit(1)
} }
return nil
} }
// getParameterString gets the value of a string parameter // getParameterString gets the value of a string parameter
func getParameterString(name string) string { func getParameterString(name string) (string, error) {
if vmsync {
time.Sleep(time.Duration(vmdelay) * time.Millisecond)
for pdirty() || mdirty() {
}
}
b1 := append([]byte(name), 0) b1 := append([]byte(name), 0)
var b2 [512]byte var b2 [512]byte
res, _, _ := vmGetParamString.Call( res, _, _ := vmGetParamString.Call(
@@ -189,15 +199,14 @@ func getParameterString(name string) string {
) )
if res != 0 { if res != 0 {
err := fmt.Errorf("VBVMR_GetParameterStringA returned %d", res) err := fmt.Errorf("VBVMR_GetParameterStringA returned %d", res)
fmt.Println(err) return "", err
os.Exit(1)
} }
str := bytes.Trim(b2[:], "\x00") str := bytes.Trim(b2[:], "\x00")
return string(str) return string(str), nil
} }
// getParameterString sets the value of a string parameter // setParameterString sets the value of a string parameter
func setParameterString(name, value string) { func setParameterString(name, value string) error {
b1 := append([]byte(name), 0) b1 := append([]byte(name), 0)
b2 := append([]byte(value), 0) b2 := append([]byte(value), 0)
res, _, _ := vmSetParamString.Call( res, _, _ := vmSetParamString.Call(
@@ -206,26 +215,31 @@ func setParameterString(name, value string) {
) )
if res != 0 { if res != 0 {
err := fmt.Errorf("VBVMR_SetParameterStringA returned %d", res) err := fmt.Errorf("VBVMR_SetParameterStringA returned %d", res)
fmt.Println(err) return err
os.Exit(1)
} }
return nil
} }
// setParametersMulti sets multiple parameters with a script // setParametersMulti sets multiple parameters with a script
func setParametersMulti(script string) { func setParametersMulti(script string) error {
b1 := append([]byte(script), 0) b1 := append([]byte(script), 0)
res, _, _ := vmSetParameters.Call( res, _, _ := vmSetParameters.Call(
uintptr(unsafe.Pointer(&b1[0])), uintptr(unsafe.Pointer(&b1[0])),
) )
if res != 0 { if res != 0 {
err := fmt.Errorf("VBVMR_SetParameters returned %d", res) err := fmt.Errorf("VBVMR_SetParameters returned %d", res)
fmt.Println(err) return err
os.Exit(1)
} }
return nil
} }
// getMacroStatus gets a macrobutton value // getMacroStatus gets a macrobutton value
func getMacroStatus(id, mode int) float32 { func getMacroStatus(id, mode int) (float64, error) {
if vmsync {
time.Sleep(time.Duration(vmdelay) * time.Millisecond)
for pdirty() || mdirty() {
}
}
var state float32 var state float32
res, _, _ := vmGetMacroStatus.Call( res, _, _ := vmGetMacroStatus.Call(
uintptr(id), uintptr(id),
@@ -234,14 +248,13 @@ func getMacroStatus(id, mode int) float32 {
) )
if res != 0 { if res != 0 {
err := fmt.Errorf("VBVMR_MacroButton_GetStatus returned %d", res) err := fmt.Errorf("VBVMR_MacroButton_GetStatus returned %d", res)
fmt.Println(err) return 0, err
os.Exit(1)
} }
return state return float64(state), nil
} }
// setMacroStatus sets a macrobutton value // setMacroStatus sets a macrobutton value
func setMacroStatus(id, state, mode int) { func setMacroStatus(id, state, mode int) error {
res, _, _ := vmSetMacroStatus.Call( res, _, _ := vmSetMacroStatus.Call(
uintptr(id), uintptr(id),
uintptr(state), uintptr(state),
@@ -249,9 +262,9 @@ func setMacroStatus(id, state, mode int) {
) )
if res != 0 { if res != 0 {
err := fmt.Errorf("VBVMR_MacroButton_SetStatus returned %d", res) err := fmt.Errorf("VBVMR_MacroButton_SetStatus returned %d", res)
fmt.Println(err) return err
os.Exit(1)
} }
return nil
} }
// getNumDevices returns the number of hardware input/output devices // getNumDevices returns the number of hardware input/output devices
@@ -266,7 +279,7 @@ func getNumDevices(dir string) uint64 {
} }
// getDeviceDescription returns name, driver type and hwid for a given device // getDeviceDescription returns name, driver type and hwid for a given device
func getDeviceDescription(i int, dir string) (string, uint64, string) { func getDeviceDescription(i int, dir string) (string, uint64, string, error) {
var t_ uint64 var t_ uint64
var b1 [512]byte var b1 [512]byte
var b2 [512]byte var b2 [512]byte
@@ -279,8 +292,7 @@ func getDeviceDescription(i int, dir string) (string, uint64, string) {
) )
if res != 0 { if res != 0 {
err := fmt.Errorf("VBVMR_Input_GetDeviceDescA returned %d", res) err := fmt.Errorf("VBVMR_Input_GetDeviceDescA returned %d", res)
fmt.Println(err) return "", 0, "", err
os.Exit(1)
} }
} else { } else {
res, _, _ := vmGetDevDescOut.Call( res, _, _ := vmGetDevDescOut.Call(
@@ -291,18 +303,17 @@ func getDeviceDescription(i int, dir string) (string, uint64, string) {
) )
if res != 0 { if res != 0 {
err := fmt.Errorf("VBVMR_Output_GetDeviceDescA returned %d", res) err := fmt.Errorf("VBVMR_Output_GetDeviceDescA returned %d", res)
fmt.Println(err) return "", 0, "", err
os.Exit(1)
} }
} }
name := bytes.Trim(b1[:], "\x00") name := bytes.Trim(b1[:], "\x00")
hwid := bytes.Trim(b2[:], "\x00") hwid := bytes.Trim(b2[:], "\x00")
return string(name), t_, string(hwid) return string(name), t_, string(hwid), nil
} }
// getLevel returns a single level value of type type_ for channel[i] // getLevel returns a single level value of type type_ for channel[i]
func getLevel(type_, i int) float32 { func getLevel(type_, i int) (float64, error) {
var val float32 var val float64
res, _, _ := vmGetLevelFloat.Call( res, _, _ := vmGetLevelFloat.Call(
uintptr(type_), uintptr(type_),
uintptr(i), uintptr(i),
@@ -310,8 +321,41 @@ func getLevel(type_, i int) float32 {
) )
if res != 0 { if res != 0 {
err := fmt.Errorf("VBVMR_GetLevel returned %d", res) err := fmt.Errorf("VBVMR_GetLevel returned %d", res)
fmt.Println(err) return 0, err
os.Exit(1)
} }
return val return val, nil
}
// getMidiMessage gets midi channel, pitch and velocity for a single midi input
func getMidiMessage() bool {
var midi = newMidi()
var b1 [1024]byte
res, _, _ := vmGetMidiMessage.Call(
uintptr(unsafe.Pointer(&b1[0])),
uintptr(1024),
)
x := int(res)
if x < 0 {
err := fmt.Errorf("VBVMR_GetMidiMessage returned %d", res)
if err != nil {
fmt.Println(err)
}
return false
}
msg := bytes.Trim(b1[:], "\x00")
if len(msg) > 0 {
for i := 0; i < len(msg)%3; i++ {
msg = append(msg, 0)
}
for i := 0; i < len(msg); i += 3 {
var ch = int(msg[i])
var pitch = int(msg[i+1])
var vel = int(msg[i+2])
midi.channel = ch
midi.current = pitch
midi.cache[pitch] = vel
}
}
return len(msg) > 0
} }

12
bus.go
View File

@@ -17,7 +17,7 @@ type iBus interface {
GetLabel() string GetLabel() string
SetLabel(val string) SetLabel(val string)
GetGain() float64 GetGain() float64
SetGain(val float32) SetGain(val float64)
Mode() iBusMode Mode() iBusMode
Levels() *levels Levels() *levels
FadeTo(target float32, time_ int) FadeTo(target float32, time_ int)
@@ -77,7 +77,7 @@ func (b *bus) GetGain() float64 {
} }
// SetGain sets the value of the Gain parameter // SetGain sets the value of the Gain parameter
func (b *bus) SetGain(val float32) { func (b *bus) SetGain(val float64) {
b.setter_float("Gain", val) b.setter_float("Gain", val)
} }
@@ -103,7 +103,7 @@ func (b *bus) FadeBy(change float32, time_ int) {
time.Sleep(time.Millisecond) time.Sleep(time.Millisecond)
} }
//physicalBus represents a single physical bus // physicalBus represents a single physical bus
type physicalBus struct { type physicalBus struct {
bus bus
} }
@@ -122,7 +122,7 @@ func (p *physicalBus) String() string {
return fmt.Sprintf("PhysicalBus%d", p.index) return fmt.Sprintf("PhysicalBus%d", p.index)
} }
//virtualBus represents a single virtual bus // virtualBus represents a single virtual bus
type virtualBus struct { type virtualBus struct {
bus bus
} }
@@ -305,8 +305,8 @@ func newBusLevels(i int, k *kind) levels {
} }
// All returns the level values for a bus // All returns the level values for a bus
func (l *levels) All() []float32 { func (l *levels) All() []float64 {
var levels []float32 var levels []float64
for i := l.init; i < l.init+l.offset; i++ { for i := l.init; i < l.init+l.offset; i++ {
levels = append(levels, convertLevel(_levelCache.busLevels[i])) levels = append(levels, convertLevel(_levelCache.busLevels[i]))
} }

View File

@@ -14,7 +14,11 @@ func newButton(i int) button {
// getter returns the value of a macrobutton parameter // getter returns the value of a macrobutton parameter
func (m *button) getter(mode int) bool { func (m *button) getter(mode int) bool {
return getMacroStatus(m.index, mode) == 1 val, err := getMacroStatus(m.index, mode)
if err != nil {
fmt.Println(err)
}
return val == 1
} }
// setter sets the value of a macrobutton parameter // setter sets the value of a macrobutton parameter

View File

@@ -1,6 +1,6 @@
package voicemeeter package voicemeeter
//command represents command (action) type parameters // command represents command (action) type parameters
type command struct { type command struct {
iRemote iRemote
} }
@@ -32,7 +32,7 @@ func (c *command) Restart() {
// Lock locks or unlocks the Voiceemeter GUI // Lock locks or unlocks the Voiceemeter GUI
func (c *command) Lock(val bool) { func (c *command) Lock(val bool) {
var value float32 var value float64
if val { if val {
value = 1 value = 1
} else { } else {

View File

@@ -1,5 +1,7 @@
package voicemeeter package voicemeeter
import "fmt"
type devDesc struct { type devDesc struct {
Name, Type, Hwid string Name, Type, Hwid string
} }
@@ -22,7 +24,10 @@ func (d *device) Outs() int {
} }
func (d *device) Input(i int) devDesc { func (d *device) Input(i int) devDesc {
n, t_, id := getDeviceDescription(i, "in") n, t_, id, err := getDeviceDescription(i, "in")
if err != nil {
fmt.Println(err)
}
vals := map[uint64]string{ vals := map[uint64]string{
1: "mme", 1: "mme",
3: "wdm", 3: "wdm",
@@ -33,7 +38,10 @@ func (d *device) Input(i int) devDesc {
} }
func (d *device) Output(i int) devDesc { func (d *device) Output(i int) devDesc {
n, t_, id := getDeviceDescription(i, "out") n, t_, id, err := getDeviceDescription(i, "out")
if err != nil {
fmt.Println(err)
}
vals := map[uint64]string{ vals := map[uint64]string{
1: "mme", 1: "mme",
3: "wdm", 3: "wdm",

10
examples/hotkeys/go.mod Normal file
View File

@@ -0,0 +1,10 @@
module main
go 1.19
require (
github.com/eiannone/keyboard v0.0.0-20220611211555-0d226195f203
github.com/onyx-and-iris/voicemeeter-api-go v1.8.0
)
require golang.org/x/sys v0.0.0-20220708085239-5a0f0661e09d // indirect

10
examples/hotkeys/go.sum Normal file
View File

@@ -0,0 +1,10 @@
github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
github.com/eiannone/keyboard v0.0.0-20220611211555-0d226195f203 h1:XBBHcIb256gUJtLmY22n99HaZTz+r2Z51xUPi01m3wg=
github.com/eiannone/keyboard v0.0.0-20220611211555-0d226195f203/go.mod h1:E1jcSv8FaEny+OP/5k9UxZVw9YFWGj7eI4KR/iOBqCg=
github.com/onyx-and-iris/voicemeeter-api-go v1.8.0 h1:uVeKXG3+dnZUakJNZ0RjYFgVhFCzGPoiNnU32LqGR4Y=
github.com/onyx-and-iris/voicemeeter-api-go v1.8.0/go.mod h1:zAdBhHXQ9n37CUbLizbOPmAutyZI8Ncqeu5e9u1Fy14=
github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
github.com/stretchr/testify v1.8.0 h1:pSgiaMZlXftHpm5L7V1+rVB+AZJydKsMxsQBIJw4PKk=
golang.org/x/sys v0.0.0-20220708085239-5a0f0661e09d h1:/m5NbqQelATgoSPVC2Z23sR4kVNokFwDDyWh/3rGY+I=
golang.org/x/sys v0.0.0-20220708085239-5a0f0661e09d/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=

66
examples/hotkeys/main.go Normal file
View File

@@ -0,0 +1,66 @@
package main
import (
"fmt"
"log"
"github.com/eiannone/keyboard"
"github.com/onyx-and-iris/voicemeeter"
)
func main() {
if err := keyboard.Open(); err != nil {
log.Fatal(err)
}
defer func() {
_ = keyboard.Close()
}()
vm, err := vmConnect()
if err != nil {
log.Fatal(err)
}
defer vm.Logout()
fmt.Println("Press ESC to quit")
Loop:
for {
char, key, err := keyboard.GetKey()
if err != nil {
panic(err)
}
switch char {
case '0':
fmt.Printf("Logged into Voicemeeter %s, version %s\n", vm.Type(), vm.Version())
case '1':
vm.Strip[0].SetMute(!vm.Strip[0].GetMute())
case '2':
if vm.Strip[3].GetGain() == -12.8 {
vm.Strip[3].FadeBy(-8.3, 500)
} else {
vm.Strip[3].FadeTo(-12.8, 500)
}
case '3':
vm.Strip[5].AppMute("Spotify", true)
default:
if key == keyboard.KeyEsc {
break Loop
}
}
}
}
func vmConnect() (*voicemeeter.Remote, error) {
vm, err := voicemeeter.NewRemote("potato", 0)
if err != nil {
return nil, err
}
err = vm.Login()
if err != nil {
return nil, err
}
return vm, nil
}

19
examples/obs/README.md Normal file
View File

@@ -0,0 +1,19 @@
## Requirements
- [OBS Studio](https://obsproject.com/)
- [GOOBS Go Client for Websocket v5](https://github.com/andreykaipov/goobs)
## About
A simple demonstration showing how to sync OBS scene switches to Voicemeeter states. The script assumes you have connection info saved in
a config file named `config.toml` placed next to `main.go`. It also assumes you have scenes named `START` `BRB` `END` and `LIVE`.
A valid `config.toml` file might look like this:
```toml
[connection]
Host="localhost"
Port=4455
Password="mystrongpass"
```

17
examples/obs/go.mod Normal file
View File

@@ -0,0 +1,17 @@
module main
go 1.18
require (
github.com/BurntSushi/toml v1.2.0
github.com/andreykaipov/goobs v0.10.0
github.com/onyx-and-iris/voicemeeter-api-go v1.8.0
)
require (
github.com/buger/jsonparser v1.1.1 // indirect
github.com/gorilla/websocket v1.5.0 // indirect
github.com/hashicorp/logutils v1.0.0 // indirect
github.com/nu7hatch/gouuid v0.0.0-20131221200532-179d4d0c4d8d // indirect
golang.org/x/sys v0.0.0-20220708085239-5a0f0661e09d // indirect
)

20
examples/obs/go.sum Normal file
View File

@@ -0,0 +1,20 @@
github.com/BurntSushi/toml v1.2.0 h1:Rt8g24XnyGTyglgET/PRUNlrUeu9F5L+7FilkXfZgs0=
github.com/BurntSushi/toml v1.2.0/go.mod h1:CxXYINrC8qIiEnFrOxCa7Jy5BFHlXnUU2pbicEuybxQ=
github.com/andreykaipov/goobs v0.10.0 h1:wa4CxbYu/NqwUmx5E4/baDqYRYEmfHwg2T23RAg3jlU=
github.com/andreykaipov/goobs v0.10.0/go.mod h1:EqG73Uu/4npyhXIWWszgRelNkEeIz+d0slUT6NKWYs4=
github.com/buger/jsonparser v1.1.1 h1:2PnMjfWD7wBILjqQbt530v576A/cAbQvEW9gGIpYMUs=
github.com/buger/jsonparser v1.1.1/go.mod h1:6RYKKt7H4d4+iWqouImQ9R2FZql3VbhNgx27UK13J/0=
github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
github.com/gorilla/websocket v1.5.0 h1:PPwGk2jz7EePpoHN/+ClbZu8SPxiqlu12wZP/3sWmnc=
github.com/gorilla/websocket v1.5.0/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE=
github.com/hashicorp/logutils v1.0.0 h1:dLEQVugN8vlakKOUE3ihGLTZJRB4j+M2cdTm/ORI65Y=
github.com/hashicorp/logutils v1.0.0/go.mod h1:QIAnNjmIWmVIIkWDTG1z5v++HQmx9WQRO+LraFDTW64=
github.com/nu7hatch/gouuid v0.0.0-20131221200532-179d4d0c4d8d h1:VhgPp6v9qf9Agr/56bj7Y/xa04UccTW04VP0Qed4vnQ=
github.com/nu7hatch/gouuid v0.0.0-20131221200532-179d4d0c4d8d/go.mod h1:YUTz3bUH2ZwIWBy3CJBeOBEugqcmXREj14T+iG/4k4U=
github.com/onyx-and-iris/voicemeeter-api-go v1.8.0 h1:uVeKXG3+dnZUakJNZ0RjYFgVhFCzGPoiNnU32LqGR4Y=
github.com/onyx-and-iris/voicemeeter-api-go v1.8.0/go.mod h1:zAdBhHXQ9n37CUbLizbOPmAutyZI8Ncqeu5e9u1Fy14=
github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
github.com/stretchr/testify v1.8.0 h1:pSgiaMZlXftHpm5L7V1+rVB+AZJydKsMxsQBIJw4PKk=
golang.org/x/sys v0.0.0-20220708085239-5a0f0661e09d h1:/m5NbqQelATgoSPVC2Z23sR4kVNokFwDDyWh/3rGY+I=
golang.org/x/sys v0.0.0-20220708085239-5a0f0661e09d/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=

126
examples/obs/main.go Normal file
View File

@@ -0,0 +1,126 @@
package main
import (
"fmt"
"log"
"os"
"time"
"github.com/onyx-and-iris/voicemeeter"
"github.com/andreykaipov/goobs"
"github.com/andreykaipov/goobs/api/events"
"github.com/BurntSushi/toml"
)
func onStart(vm *voicemeeter.Remote) {
vm.Strip[0].SetMute(true)
vm.Strip[1].SetB1(true)
vm.Strip[2].SetB1(true)
}
func onBrb(vm *voicemeeter.Remote) {
vm.Strip[7].FadeTo(0, 500)
vm.Bus[0].SetMute(true)
}
func onLive(vm *voicemeeter.Remote) {
vm.Strip[0].SetMute(false)
vm.Strip[7].FadeTo(-6, 500)
vm.Strip[7].SetA3(true)
vm.Vban.InStream[0].SetOn(true)
}
func onEnd(vm *voicemeeter.Remote) {
vm.Strip[0].SetMute(true)
vm.Strip[1].SetMute(true)
vm.Strip[1].SetB1(false)
vm.Strip[2].SetMute(true)
vm.Strip[2].SetB1(false)
vm.Vban.InStream[0].SetOn(false)
}
func main() {
vm, err := vmConnect()
if err != nil {
log.Fatal(err)
}
defer vm.Logout()
obs, err := obsConnect()
if err != nil {
log.Fatal(err)
}
defer obs.Disconnect()
version, _ := obs.General.GetVersion()
fmt.Printf("OBS Studio version: %s\n", version.ObsVersion)
fmt.Printf("Websocket server version: %s\n", version.ObsWebSocketVersion)
go obs.Listen(func(event any) {
switch e := event.(type) {
case *events.CurrentProgramSceneChanged:
fmt.Printf("Switched to scene %s\n", e.SceneName)
switch e.SceneName {
case "START":
onStart(vm)
case "BRB":
onBrb(vm)
case "LIVE":
onLive(vm)
case "END":
onEnd(vm)
}
}
})
time.Sleep(30 * time.Second)
}
func vmConnect() (*voicemeeter.Remote, error) {
vm, err := voicemeeter.NewRemote("potato", 0)
if err != nil {
return nil, err
}
err = vm.Login()
if err != nil {
return nil, err
}
return vm, nil
}
func obsConnect() (*goobs.Client, error) {
type (
connection struct {
Host string
Port int
Password string
}
config struct {
Connection map[string]connection
}
)
f := "config.toml"
if _, err := os.Stat(f); err != nil {
err := fmt.Errorf("unable to locate %s", f)
return nil, err
}
var c config
_, err := toml.DecodeFile(f, &c.Connection)
if err != nil {
return nil, err
}
conn := c.Connection["connection"]
obs, err := goobs.New(fmt.Sprintf("%s:%d", conn.Host, conn.Port), goobs.WithPassword(conn.Password))
if err != nil {
return nil, err
}
return obs, nil
}

85
examples/observer/main.go Normal file
View File

@@ -0,0 +1,85 @@
package main
import (
"fmt"
"log"
"time"
"github.com/onyx-and-iris/voicemeeter"
)
// observer represents a single receiver of updates
type observer struct {
vm *voicemeeter.Remote
}
// newObserver add ldirty events to the eventlist and returns an observer type
func newObserver(vm *voicemeeter.Remote) *observer {
vm.EventAdd("ldirty")
return &observer{vm}
}
// register registers this observer to receive updates
func (o observer) register() {
o.vm.Register(o)
}
// deregister deregisters this observer to receive updates
func (o observer) deregister() {
o.vm.Deregister(o)
}
// OnUpdate satisfies the observer interface defined in publisher.go
// for each event type an action is triggered when the event occurs.
func (o observer) OnUpdate(subject string) {
if subject == "pdirty" {
fmt.Println("pdirty!")
} else if subject == "mdirty" {
fmt.Println("mdirty!")
} else if subject == "midi" {
var current = o.vm.Midi.Current()
var val = o.vm.Midi.Get(current)
fmt.Printf("Value of midi button %d: %d\n", current, val)
} else if subject == "ldirty" {
fmt.Printf("%v %v %v %v %v %v %v %v\n",
o.vm.Bus[0].Levels().IsDirty(),
o.vm.Bus[1].Levels().IsDirty(),
o.vm.Bus[2].Levels().IsDirty(),
o.vm.Bus[3].Levels().IsDirty(),
o.vm.Bus[4].Levels().IsDirty(),
o.vm.Bus[5].Levels().IsDirty(),
o.vm.Bus[6].Levels().IsDirty(),
o.vm.Bus[7].Levels().IsDirty(),
)
}
}
// main connects to Voiceemeter, registers observer for updates
// runs updates for 30 seconds and then deregisters observer.
func main() {
vm, err := vmConnect()
if err != nil {
log.Fatal(err)
}
defer vm.Logout()
o := newObserver(vm)
o.register()
time.Sleep(30 * time.Second)
o.deregister()
}
// vmConnect connects to Voicemeeter potato and logs into the API
func vmConnect() (*voicemeeter.Remote, error) {
vm, err := voicemeeter.NewRemote("potato", 0)
if err != nil {
return nil, err
}
err = vm.Login()
if err != nil {
return nil, err
}
return vm, nil
}

View File

@@ -1,46 +0,0 @@
package main
import (
"fmt"
"strings"
"time"
"github.com/onyx-and-iris/voicemeeter-api-go"
)
type observer struct {
vm *voicemeeter.Remote
}
func (o observer) OnUpdate(subject string) {
if strings.Compare(subject, "pdirty") == 0 {
fmt.Println("pdirty!")
}
if strings.Compare(subject, "mdirty") == 0 {
fmt.Println("mdirty!")
}
if strings.Compare(subject, "ldirty") == 0 {
fmt.Printf("%v %v %v %v %v %v %v %v\n",
o.vm.Bus[0].Levels().IsDirty(),
o.vm.Bus[1].Levels().IsDirty(),
o.vm.Bus[2].Levels().IsDirty(),
o.vm.Bus[3].Levels().IsDirty(),
o.vm.Bus[4].Levels().IsDirty(),
o.vm.Bus[5].Levels().IsDirty(),
o.vm.Bus[6].Levels().IsDirty(),
o.vm.Bus[7].Levels().IsDirty(),
)
}
}
func main() {
vm := voicemeeter.NewRemote("potato")
vm.Login()
o := observer{vm}
vm.Register(o)
time.Sleep(30 * time.Second)
vm.Deregister(o)
vm.Logout()
}

27
examples/vm-cli/README.md Normal file
View File

@@ -0,0 +1,27 @@
## About
A simple voicemeeter-cli program. Offers ability to toggle, get and set parameters.
## Use
Toggle with `!` prefix, get by excluding `=` and set by including `=`. Mix and match arguments.
You may pass an optional flag -kind to set the kind of Voicemeeter. Defaults to banana.
You may pass an optional flag -delay to set a delay on the getters. Defaults to 20ms.
for example:
`go run .\main.go -kind=potato -delay=18 strip[0].mute=0 strip[0].mute !strip[0].mute strip[0].mute bus[0].gain=-8.8 command.lock=1`
Expected output:
```
Logged into Voicemeeter potato
Running command strip[0].mute=0
Value of strip[0].mute is: 0
Toggling strip[0].mute
Value of strip[0].mute is: 1
Running command bus[0].gain=-8.8
Running command command.lock=1
```

77
examples/vm-cli/main.go Normal file
View File

@@ -0,0 +1,77 @@
package main
import (
"flag"
"fmt"
"log"
"strings"
"github.com/onyx-and-iris/voicemeeter"
)
func main() {
kindId := flag.String("kind", "banana", "kind of voicemeeter")
delay := flag.Int("delay", 20, "delay between commands")
flag.Parse()
vm, err := vmConnect(kindId, delay)
if err != nil {
log.Fatal(err)
}
defer vm.Logout()
err = runCommands(vm)
if err != nil {
fmt.Println(err)
}
}
func vmConnect(kindId *string, delay *int) (*voicemeeter.Remote, error) {
vm, err := voicemeeter.NewRemote(*kindId, *delay)
if err != nil {
return nil, err
}
err = vm.Login()
if err != nil {
return nil, err
}
return vm, nil
}
func runCommands(vm *voicemeeter.Remote) error {
for _, arg := range flag.Args() {
if arg[0] == '!' {
val, err := vm.GetFloat(arg[1:])
if err != nil {
err = fmt.Errorf("unable to toggle %s", arg[1:])
return err
}
vm.SetFloat(arg[1:], 1-val)
fmt.Println("Toggling", arg[1:])
} else {
if strings.Contains(arg, "=") {
fmt.Println("Running command", arg)
err := vm.SendText(arg)
if err != nil {
err = fmt.Errorf("unable to set %s", arg)
return err
}
} else {
valF, err := vm.GetFloat(arg)
if err != nil {
valS, err := vm.GetString(arg)
if err != nil {
err = fmt.Errorf("unable to get %s", arg)
return err
}
fmt.Println("Value of", arg, "is:", valS)
} else {
fmt.Println("Value of", arg, "is:", valF)
}
}
}
}
return nil
}

8
go.mod
View File

@@ -1,11 +1,9 @@
module github.com/onyx-and-iris/voicemeeter-api-go module github.com/onyx-and-iris/voicemeeter
go 1.18 go 1.18
retract ( // package files moved into root of repository
// package files moved into root of repository retract [v1.0.0, v1.1.0]
[v1.0.0, v1.1.0]
)
require ( require (
github.com/stretchr/testify v1.8.0 github.com/stretchr/testify v1.8.0

22
helper_test.go Normal file
View File

@@ -0,0 +1,22 @@
package voicemeeter
import (
"log"
"os"
"testing"
)
var (
vm, err = NewRemote("potato", 30)
)
func TestMain(m *testing.M) {
if err != nil {
log.Fatal(err)
}
vm.Login()
code := m.Run()
vm.Logout()
os.Exit(code)
}

View File

@@ -19,7 +19,11 @@ func (ir *iRemote) identifier() string {
// getter_bool returns the value of a boolean parameter // getter_bool returns the value of a boolean parameter
func (ir *iRemote) getter_bool(p string) bool { func (ir *iRemote) getter_bool(p string) bool {
param := fmt.Sprintf("%s.%s", ir.identifier(), p) param := fmt.Sprintf("%s.%s", ir.identifier(), p)
return getParameterFloat(param) == 1 val, err := getParameterFloat(param)
if err != nil {
fmt.Println(err)
}
return val == 1
} }
// setter_bool sets the value of a boolean parameter // setter_bool sets the value of a boolean parameter
@@ -31,41 +35,65 @@ func (ir *iRemote) setter_bool(p string, v bool) {
} else { } else {
value = 0 value = 0
} }
setParameterFloat(param, float32(value)) err := setParameterFloat(param, float64(value))
if err != nil {
fmt.Println(err)
}
} }
// getter_int returns the value of an int parameter p // getter_int returns the value of an int parameter p
func (ir *iRemote) getter_int(p string) int { func (ir *iRemote) getter_int(p string) int {
param := fmt.Sprintf("%s.%s", ir.identifier(), p) param := fmt.Sprintf("%s.%s", ir.identifier(), p)
return int(getParameterFloat(param)) val, err := getParameterFloat(param)
if err != nil {
fmt.Println(err)
}
return int(val)
} }
// setter_int sets the value v of an int parameter p // setter_int sets the value v of an int parameter p
func (ir *iRemote) setter_int(p string, v int) { func (ir *iRemote) setter_int(p string, v int) {
param := fmt.Sprintf("%s.%s", ir.identifier(), p) param := fmt.Sprintf("%s.%s", ir.identifier(), p)
setParameterFloat(param, float32(v)) err := setParameterFloat(param, float64(v))
if err != nil {
fmt.Println(err)
}
} }
// getter_float returns the value of an int parameter p // getter_float returns the value of an int parameter p
func (ir *iRemote) getter_float(p string) float64 { func (ir *iRemote) getter_float(p string) float64 {
param := fmt.Sprintf("%s.%s", ir.identifier(), p) param := fmt.Sprintf("%s.%s", ir.identifier(), p)
return getParameterFloat(param) val, err := getParameterFloat(param)
if err != nil {
fmt.Println(err)
}
return val
} }
// setter_float sets the value v of an int parameter p // setter_float sets the value v of an int parameter p
func (ir *iRemote) setter_float(p string, v float32) { func (ir *iRemote) setter_float(p string, v float64) {
param := fmt.Sprintf("%s.%s", ir.identifier(), p) param := fmt.Sprintf("%s.%s", ir.identifier(), p)
setParameterFloat(param, float32(v)) err := setParameterFloat(param, float64(v))
if err != nil {
fmt.Println(err)
}
} }
// getter_string returns the value of a string parameter p // getter_string returns the value of a string parameter p
func (ir *iRemote) getter_string(p string) string { func (ir *iRemote) getter_string(p string) string {
param := fmt.Sprintf("%s.%s", ir.identifier(), p) param := fmt.Sprintf("%s.%s", ir.identifier(), p)
return getParameterString(param) val, err := getParameterString(param)
if err != nil {
fmt.Println(err)
}
return val
} }
// setter_string sets the value v of a string parameter p // setter_string sets the value v of a string parameter p
func (ir *iRemote) setter_string(p, v string) { func (ir *iRemote) setter_string(p, v string) {
param := fmt.Sprintf("%s.%s", ir.identifier(), p) param := fmt.Sprintf("%s.%s", ir.identifier(), p)
setParameterString(param, v) err := setParameterString(param, v)
if err != nil {
fmt.Println(err)
}
} }

View File

@@ -25,18 +25,18 @@ var _levelCache *levelCache
// levelCache defines level slices used by the pooler to track updates // levelCache defines level slices used by the pooler to track updates
type levelCache struct { type levelCache struct {
stripMode int stripMode int
stripLevels []float32 stripLevels []float64
busLevels []float32 busLevels []float64
stripLevelsBuff []float32 stripLevelsBuff []float64
busLevelsBuff []float32 busLevelsBuff []float64
stripComp []bool stripComp []bool
busComp []bool busComp []bool
} }
// newLevelCache returns a levelCache struct address // newLevelCache returns a levelCache struct address
func newLevelCache(k *kind) *levelCache { func newLevelCache(k *kind) *levelCache {
stripLevels := make([]float32, (2*k.PhysIn)+(8*k.VirtIn)) stripLevels := make([]float64, (2*k.PhysIn)+(8*k.VirtIn))
busLevels := make([]float32, 8*k.NumBus()) busLevels := make([]float64, 8*k.NumBus())
stripComp := make([]bool, (2*k.PhysIn)+(8*k.VirtIn)) stripComp := make([]bool, (2*k.PhysIn)+(8*k.VirtIn))
busComp := make([]bool, 8*k.NumBus()) busComp := make([]bool, 8*k.NumBus())
if _levelCache == nil { if _levelCache == nil {

28
midi.go Normal file
View File

@@ -0,0 +1,28 @@
package voicemeeter
var midi *midi_t
type midi_t struct {
channel int
current int
cache map[int]int
}
func newMidi() *midi_t {
if midi == nil {
midi = &midi_t{0, 0, map[int]int{}}
}
return midi
}
func (m *midi_t) Channel() int {
return m.channel
}
func (m *midi_t) Current() int {
return m.current
}
func (m *midi_t) Get(key int) int {
return m.cache[key]
}

View File

@@ -3,7 +3,7 @@ package voicemeeter
import ( import (
"errors" "errors"
"fmt" "fmt"
"os" "log"
"path/filepath" "path/filepath"
"runtime" "runtime"
"strings" "strings"
@@ -49,8 +49,7 @@ func dllPath() (string, error) {
func getDllPath() string { func getDllPath() string {
path, err := dllPath() path, err := dllPath()
if err != nil { if err != nil {
fmt.Println(err) log.Fatal(err)
os.Exit(1)
} }
return path return path
} }

View File

@@ -40,11 +40,49 @@ func (p *publisher) notify(subject string) {
} }
} }
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 // pooler continuously polls the dirty paramters
// it is expected to be run in a goroutine // it is expected to be run in a goroutine
type pooler struct { type pooler struct {
k *kind k *kind
run bool run bool
event *event
publisher publisher
} }
@@ -52,29 +90,47 @@ func newPooler(k *kind) *pooler {
p := &pooler{ p := &pooler{
k: k, k: k,
run: true, run: true,
event: newEvent(),
} }
go p.runner() go p.parameters()
go p.macrobuttons()
go p.midi()
go p.levels() go p.levels()
return p return p
} }
func (p *pooler) runner() { func (p *pooler) parameters() {
for p.run { for p.run {
if pdirty() { if p.event.pdirty && pdirty() {
p.notify("pdirty") p.notify("pdirty")
} }
if mdirty() { time.Sleep(33 * time.Millisecond)
}
}
func (p *pooler) macrobuttons() {
for p.run {
if p.event.mdirty && mdirty() {
p.notify("mdirty") p.notify("mdirty")
} }
time.Sleep(33 * time.Millisecond) time.Sleep(33 * time.Millisecond)
} }
} }
func (p *pooler) midi() {
for p.run {
if p.event.midi && getMidiMessage() {
p.notify("midi")
}
time.Sleep(33 * time.Millisecond)
}
}
func (p *pooler) levels() { func (p *pooler) levels() {
_levelCache = newLevelCache(p.k) _levelCache = newLevelCache(p.k)
for p.run { for p.run {
if ldirty(p.k) { if p.event.ldirty && ldirty(p.k) {
update(_levelCache.stripLevels, _levelCache.stripLevelsBuff, (2*p.k.PhysIn)+(8*p.k.VirtIn)) update(_levelCache.stripLevels, _levelCache.stripLevelsBuff, (2*p.k.PhysIn)+(8*p.k.VirtIn))
update(_levelCache.busLevels, _levelCache.busLevelsBuff, 8*p.k.NumBus()) update(_levelCache.busLevels, _levelCache.busLevelsBuff, 8*p.k.NumBus())
p.notify("ldirty") p.notify("ldirty")

147
remote.go
View File

@@ -2,7 +2,7 @@ package voicemeeter
import ( import (
"fmt" "fmt"
"os" "time"
) )
// A Remote type represents the API for a kind // A Remote type represents the API for a kind
@@ -15,6 +15,7 @@ type Remote struct {
Vban *vban Vban *vban
Device *device Device *device
Recorder *recorder Recorder *recorder
Midi *midi_t
pooler *pooler pooler *pooler
} }
@@ -26,26 +27,42 @@ func (r *Remote) String() string {
// Login logs into the API // Login logs into the API
// then it intializes the pooler // then it intializes the pooler
func (r *Remote) Login() { func (r *Remote) Login() error {
login(r.Kind.Name) err := login(r.Kind.Name)
if err != nil {
return err
}
r.pooler = newPooler(r.Kind) r.pooler = newPooler(r.Kind)
return nil
} }
// Logout logs out of the API // Logout logs out of the API
// it also terminates the pooler // it also terminates the pooler
func (r *Remote) Logout() { func (r *Remote) Logout() error {
r.pooler.run = false r.pooler.run = false
logout() err := logout(r.Kind.Name)
if err != nil {
return err
}
return nil
} }
// Type returns the type of Voicemeeter (basic, banana, potato) // Type returns the type of Voicemeeter (basic, banana, potato)
func (r *Remote) Type() string { func (r *Remote) Type() string {
return getVMType() val, err := getVMType()
if err != nil {
fmt.Println(err)
}
return val
} }
// Version returns the version of Voicemeeter as a string // Version returns the version of Voicemeeter as a string
func (r *Remote) Version() string { func (r *Remote) Version() string {
return getVersion() val, err := getVersion()
if err != nil {
fmt.Println(err)
}
return val
} }
// Pdirty returns true iff a parameter value has changed // Pdirty returns true iff a parameter value has changed
@@ -58,9 +75,56 @@ func (r *Remote) Mdirty() bool {
return mdirty() return mdirty()
} }
// Sync is a helper method that waits for dirty parameters to clear
func (r *Remote) Sync() {
time.Sleep(time.Duration(vmdelay) * time.Millisecond)
for r.Pdirty() || r.Mdirty() {
}
}
// Gets a float parameter value
func (r *Remote) GetFloat(name string) (float64, error) {
val, err := getParameterFloat(name)
if err != nil {
return 0, err
}
return val, nil
}
// Sets a float paramter value
func (r *Remote) SetFloat(name string, value float64) error {
err := setParameterFloat(name, value)
if err != nil {
return err
}
return nil
}
// Gets a string parameter value
func (r *Remote) GetString(name string) (string, error) {
val, err := getParameterString(name)
if err != nil {
return "", err
}
return val, nil
}
// Sets a string paramter value
func (r *Remote) SetString(name, value string) error {
err := setParameterString(name, value)
if err != nil {
return err
}
return nil
}
// SendText sets multiple parameters by script // SendText sets multiple parameters by script
func (r *Remote) SendText(script string) { func (r *Remote) SendText(script string) error {
setParametersMulti(script) err := setParametersMulti(script)
if err != nil {
return err
}
return nil
} }
// Register forwards the register method to Pooler // Register forwards the register method to Pooler
@@ -73,6 +137,16 @@ func (r *Remote) Deregister(o observer) {
r.pooler.Deregister(o) r.pooler.Deregister(o)
} }
// EventAdd adds an event to the Pooler
func (r *Remote) EventAdd(event string) {
r.pooler.event.Add(event)
}
// EventRemove removes an event from the Pooler
func (r *Remote) EventRemove(event string) {
r.pooler.event.Remove(event)
}
// remoteBuilder defines the interface builder types must satisfy // remoteBuilder defines the interface builder types must satisfy
type remoteBuilder interface { type remoteBuilder interface {
setKind() remoteBuilder setKind() remoteBuilder
@@ -83,6 +157,7 @@ type remoteBuilder interface {
makeVban() remoteBuilder makeVban() remoteBuilder
makeDevice() remoteBuilder makeDevice() remoteBuilder
makeRecorder() remoteBuilder makeRecorder() remoteBuilder
makeMidi() remoteBuilder
Build() remoteBuilder Build() remoteBuilder
Get() *Remote Get() *Remote
} }
@@ -190,6 +265,13 @@ func (b *genericBuilder) makeRecorder() remoteBuilder {
return b return b
} }
// makeMidi makes a midi type and assigns it to remote.Midi
func (b *genericBuilder) makeMidi() remoteBuilder {
fmt.Println("building midi")
b.r.Midi = newMidi()
return b
}
// Get returns a fully constructed remote type for a kind // Get returns a fully constructed remote type for a kind
func (b *genericBuilder) Get() *Remote { func (b *genericBuilder) Get() *Remote {
return &b.r return &b.r
@@ -202,7 +284,14 @@ type basicBuilder struct {
// Build defines the steps required to build a basic type // Build defines the steps required to build a basic type
func (basb *genericBuilder) Build() remoteBuilder { func (basb *genericBuilder) Build() remoteBuilder {
return basb.setKind().makeStrip().makeBus().makeButton().makeCommand().makeVban().makeDevice() return basb.setKind().
makeStrip().
makeBus().
makeButton().
makeCommand().
makeVban().
makeDevice().
makeMidi()
} }
// bananaBuilder represents a builder specific to banana type // bananaBuilder represents a builder specific to banana type
@@ -212,7 +301,15 @@ type bananaBuilder struct {
// Build defines the steps required to build a banana type // Build defines the steps required to build a banana type
func (banb *bananaBuilder) Build() remoteBuilder { func (banb *bananaBuilder) Build() remoteBuilder {
return banb.setKind().makeStrip().makeBus().makeButton().makeCommand().makeVban().makeDevice().makeRecorder() return banb.setKind().
makeStrip().
makeBus().
makeButton().
makeCommand().
makeVban().
makeDevice().
makeRecorder().
makeMidi()
} }
// potatoBuilder represents a builder specific to potato type // potatoBuilder represents a builder specific to potato type
@@ -222,18 +319,36 @@ type potatoBuilder struct {
// Build defines the steps required to build a potato type // Build defines the steps required to build a potato type
func (potb *potatoBuilder) Build() remoteBuilder { func (potb *potatoBuilder) Build() remoteBuilder {
return potb.setKind().makeStrip().makeBus().makeButton().makeCommand().makeVban().makeDevice().makeRecorder() return potb.setKind().
makeStrip().
makeBus().
makeButton().
makeCommand().
makeVban().
makeDevice().
makeRecorder().
makeMidi()
} }
var (
vmsync bool
vmdelay int
)
// NewRemote returns a Remote type for a kind // NewRemote returns a Remote type for a kind
// this is the interface entry point // this is the interface entry point
func NewRemote(kindId string) *Remote { func NewRemote(kindId string, delay int) (*Remote, error) {
_kind, ok := kindMap[kindId] _kind, ok := kindMap[kindId]
if !ok { if !ok {
err := fmt.Errorf("unknown Voicemeeter kind '%s'", kindId) err := fmt.Errorf("unknown Voicemeeter kind '%s'", kindId)
fmt.Println(err) return nil, err
os.Exit(1)
} }
if delay < 0 {
err := fmt.Errorf("invalid delay value. should be >= 0")
return nil, err
}
vmsync = delay > 0
vmdelay = delay
director := director{} director := director{}
switch _kind.Name { switch _kind.Name {
@@ -245,5 +360,5 @@ func NewRemote(kindId string) *Remote {
director.SetBuilder(&potatoBuilder{genericBuilder{_kind, Remote{}}}) director.SetBuilder(&potatoBuilder{genericBuilder{_kind, Remote{}}})
} }
director.Construct() director.Construct()
return director.Get() return director.Get(), nil
} }

View File

@@ -8,7 +8,7 @@ import (
func TestGetBasicRemote(t *testing.T) { func TestGetBasicRemote(t *testing.T) {
//t.Skip("skipping test") //t.Skip("skipping test")
__rem := NewRemote("basic") __rem, _ := NewRemote("basic", 0)
t.Run("Should return a remote basic type", func(t *testing.T) { t.Run("Should return a remote basic type", func(t *testing.T) {
assert.NotNil(t, __rem) assert.NotNil(t, __rem)
}) })
@@ -34,7 +34,7 @@ func TestGetBasicRemote(t *testing.T) {
func TestGetBananaRemote(t *testing.T) { func TestGetBananaRemote(t *testing.T) {
//t.Skip("skipping test") //t.Skip("skipping test")
__rem := NewRemote("banana") __rem, _ := NewRemote("banana", 0)
t.Run("Should return a remote banana type", func(t *testing.T) { t.Run("Should return a remote banana type", func(t *testing.T) {
assert.NotNil(t, __rem) assert.NotNil(t, __rem)
}) })
@@ -60,7 +60,7 @@ func TestGetBananaRemote(t *testing.T) {
func TestGetPotatoRemote(t *testing.T) { func TestGetPotatoRemote(t *testing.T) {
//t.Skip("skipping test") //t.Skip("skipping test")
__rem := NewRemote("potato") __rem, _ := NewRemote("potato", 0)
t.Run("Should return a remote basic type", func(t *testing.T) { t.Run("Should return a remote basic type", func(t *testing.T) {
assert.NotNil(t, __rem) assert.NotNil(t, __rem)
}) })
@@ -83,3 +83,25 @@ func TestGetPotatoRemote(t *testing.T) {
assert.NotNil(t, __rem.Recorder) assert.NotNil(t, __rem.Recorder)
}) })
} }
func TestSetAndGetFloatParameter(t *testing.T) {
//t.Skip("skipping test")
var param = "strip[0].mute"
var exp = float64(1)
vm.SetFloat(param, 1)
t.Run("Should get a float parameter", func(t *testing.T) {
val, _ := vm.GetFloat(param)
assert.Equal(t, exp, val)
})
}
func TestSetAndGetStringParameter(t *testing.T) {
//t.Skip("skipping test")
var param = "strip[0].label"
var exp = "test0"
vm.SetString(param, exp)
t.Run("Should get a string parameter", func(t *testing.T) {
val, _ := vm.GetString(param)
assert.Equal(t, exp, val)
})
}

View File

@@ -19,20 +19,20 @@ type iStrip interface {
GetLabel() string GetLabel() string
SetLabel(val string) SetLabel(val string)
GetGain() float64 GetGain() float64
SetGain(val float32) SetGain(val float64)
GetMc() bool GetMc() bool
SetMc(val bool) SetMc(val bool)
GetComp() float64 GetComp() float64
SetComp(val float32) SetComp(val float64)
GetGate() float64 GetGate() float64
SetGate(val float32) SetGate(val float64)
GetAudibility() float64 GetAudibility() float64
SetAudibility(val float32) SetAudibility(val float64)
GainLayer() []gainLayer GainLayer() []gainLayer
Levels() *levels Levels() *levels
FadeTo(target float32, time_ int) FadeTo(target float64, time_ int)
FadeBy(change float32, time_ int) FadeBy(change float64, time_ int)
AppGain(name string, gain float32) AppGain(name string, gain float64)
AppMute(name string, val bool) AppMute(name string, val bool)
iOutputs iOutputs
} }
@@ -101,7 +101,7 @@ func (s *strip) GetGain() float64 {
} }
// SetGain sets the value of the Gain parameter // SetGain sets the value of the Gain parameter
func (s *strip) SetGain(val float32) { func (s *strip) SetGain(val float64) {
s.setter_float("Gain", val) s.setter_float("Gain", val)
} }
@@ -116,18 +116,18 @@ func (s *strip) Levels() *levels {
} }
// FadeTo sets the value of gain to target over at time interval of time_ // FadeTo sets the value of gain to target over at time interval of time_
func (s *strip) FadeTo(target float32, time_ int) { func (s *strip) FadeTo(target float64, time_ int) {
s.setter_string("FadeTo", fmt.Sprintf("(\"%f\", %d)", target, time_)) s.setter_string("FadeTo", fmt.Sprintf("(\"%f\", %d)", target, time_))
time.Sleep(time.Millisecond) time.Sleep(time.Millisecond)
} }
// FadeBy adjusts the value of gain by change over a time interval of time_ // FadeBy adjusts the value of gain by change over a time interval of time_
func (s *strip) FadeBy(change float32, time_ int) { func (s *strip) FadeBy(change float64, time_ int) {
s.setter_string("FadeBy", fmt.Sprintf("(\"%f\", %d)", change, time_)) s.setter_string("FadeBy", fmt.Sprintf("(\"%f\", %d)", change, time_))
time.Sleep(time.Millisecond) time.Sleep(time.Millisecond)
} }
//physicalStrip represents a single physical strip // physicalStrip represents a single physical strip
type physicalStrip struct { type physicalStrip struct {
strip strip
} }
@@ -155,7 +155,7 @@ func (p *physicalStrip) GetComp() float64 {
} }
// SetComp sets the value of the Comp parameter // SetComp sets the value of the Comp parameter
func (p *physicalStrip) SetComp(val float32) { func (p *physicalStrip) SetComp(val float64) {
p.setter_float("Comp", val) p.setter_float("Comp", val)
} }
@@ -165,7 +165,7 @@ func (p *physicalStrip) GetGate() float64 {
} }
// SetGate sets the value of the Gate parameter // SetGate sets the value of the Gate parameter
func (p *physicalStrip) SetGate(val float32) { func (p *physicalStrip) SetGate(val float64) {
p.setter_float("Gate", val) p.setter_float("Gate", val)
} }
@@ -175,7 +175,7 @@ func (p *physicalStrip) GetAudibility() float64 {
} }
// SetAudibility sets the value of the Audibility parameter // SetAudibility sets the value of the Audibility parameter
func (p *physicalStrip) SetAudibility(val float32) { func (p *physicalStrip) SetAudibility(val float64) {
p.setter_float("Audibility", val) p.setter_float("Audibility", val)
} }
@@ -189,7 +189,7 @@ func (p *physicalStrip) SetMc(val bool) {
panic("invalid parameter MC for physicalStrip") panic("invalid parameter MC for physicalStrip")
} }
//virtualStrip represents a single virtual strip // virtualStrip represents a single virtual strip
type virtualStrip struct { type virtualStrip struct {
strip strip
} }
@@ -227,7 +227,7 @@ func (v *virtualStrip) GetComp() float64 {
} }
// SetComp panics reason invalid parameter // SetComp panics reason invalid parameter
func (v *virtualStrip) SetComp(val float32) { func (v *virtualStrip) SetComp(val float64) {
panic("invalid parameter Comp for virtualStrip") panic("invalid parameter Comp for virtualStrip")
} }
@@ -237,7 +237,7 @@ func (v *virtualStrip) GetGate() float64 {
} }
// SetGate panics reason invalid parameter // SetGate panics reason invalid parameter
func (v *virtualStrip) SetGate(val float32) { func (v *virtualStrip) SetGate(val float64) {
panic("invalid parameter Gate for virtualStrip") panic("invalid parameter Gate for virtualStrip")
} }
@@ -247,12 +247,12 @@ func (v *virtualStrip) GetAudibility() float64 {
} }
// SetAudibility panics reason invalid parameter // SetAudibility panics reason invalid parameter
func (v *virtualStrip) SetAudibility(val float32) { func (v *virtualStrip) SetAudibility(val float64) {
panic("invalid parameter Audibility for virtualStrip") panic("invalid parameter Audibility for virtualStrip")
} }
// AppGain sets the gain in db by val for the app matching name. // AppGain sets the gain in db by val for the app matching name.
func (v *strip) AppGain(name string, val float32) { func (v *strip) AppGain(name string, val float64) {
v.setter_string("AppGain", fmt.Sprintf("(\"%s\", %f)", name, val)) v.setter_string("AppGain", fmt.Sprintf("(\"%s\", %f)", name, val))
} }
@@ -264,7 +264,7 @@ func (v *strip) AppMute(name string, val bool) {
} else { } else {
value = 0 value = 0
} }
v.setter_string("AppMute", fmt.Sprintf("(\"%s\", %f)", name, float32(value))) v.setter_string("AppMute", fmt.Sprintf("(\"%s\", %f)", name, float64(value)))
} }
// gainLayer represents the 8 gainlayers for a single strip // gainLayer represents the 8 gainlayers for a single strip
@@ -284,7 +284,7 @@ func (gl *gainLayer) Get() float64 {
} }
// Set sets the gain value for a single gainlayer // Set sets the gain value for a single gainlayer
func (gl *gainLayer) Set(val float32) { func (gl *gainLayer) Set(val float64) {
gl.setter_float(fmt.Sprintf("gainlayer[%d]", gl.index), val) gl.setter_float(fmt.Sprintf("gainlayer[%d]", gl.index), val)
} }
@@ -303,9 +303,9 @@ func newStripLevels(i int, k *kind) levels {
} }
// PreFader returns the level values for this strip, PREFADER mode // PreFader returns the level values for this strip, PREFADER mode
func (l *levels) PreFader() []float32 { func (l *levels) PreFader() []float64 {
_levelCache.stripMode = 0 _levelCache.stripMode = 0
var levels []float32 var levels []float64
for i := l.init; i < l.init+l.offset; i++ { for i := l.init; i < l.init+l.offset; i++ {
levels = append(levels, convertLevel(_levelCache.stripLevels[i])) levels = append(levels, convertLevel(_levelCache.stripLevels[i]))
} }
@@ -313,9 +313,9 @@ func (l *levels) PreFader() []float32 {
} }
// PostFader returns the level values for this strip, POSTFADER mode // PostFader returns the level values for this strip, POSTFADER mode
func (l *levels) PostFader() []float32 { func (l *levels) PostFader() []float64 {
_levelCache.stripMode = 1 _levelCache.stripMode = 1
var levels []float32 var levels []float64
for i := l.init; i < l.init+l.offset; i++ { for i := l.init; i < l.init+l.offset; i++ {
levels = append(levels, convertLevel(_levelCache.stripLevels[i])) levels = append(levels, convertLevel(_levelCache.stripLevels[i]))
} }
@@ -323,9 +323,9 @@ func (l *levels) PostFader() []float32 {
} }
// PostMute returns the level values for this strip, POSTMUTE mode // PostMute returns the level values for this strip, POSTMUTE mode
func (l *levels) PostMute() []float32 { func (l *levels) PostMute() []float64 {
_levelCache.stripMode = 2 _levelCache.stripMode = 2
var levels []float32 var levels []float64
for i := l.init; i < l.init+l.offset; i++ { for i := l.init; i < l.init+l.offset; i++ {
levels = append(levels, convertLevel(_levelCache.stripLevels[i])) levels = append(levels, convertLevel(_levelCache.stripLevels[i]))
} }

View File

@@ -1,26 +1,26 @@
package voicemeeter_test package voicemeeter_test
import ( import (
"os" "log"
"testing" "testing"
"time"
"github.com/onyx-and-iris/voicemeeter-api-go" "github.com/onyx-and-iris/voicemeeter"
) )
var ( var (
vm = voicemeeter.NewRemote("potato") vm, err = voicemeeter.NewRemote("potato", 30)
) )
func TestMain(m *testing.M) { func TestMain(m *testing.M) {
vm.Login() if err != nil {
code := m.Run() log.Fatal(err)
vm.Logout()
os.Exit(code)
}
func sync() {
time.Sleep(30 * time.Millisecond)
for vm.Pdirty() || vm.Mdirty() {
} }
err = vm.Login()
if err != nil {
log.Fatal(err)
}
defer vm.Logout()
m.Run()
} }

View File

@@ -9,13 +9,11 @@ import (
func TestStrip0Mute(t *testing.T) { func TestStrip0Mute(t *testing.T) {
//t.Skip("skipping test") //t.Skip("skipping test")
vm.Strip[0].SetMute(true) vm.Strip[0].SetMute(true)
sync()
t.Run("Should return true when SetMute(true)", func(t *testing.T) { t.Run("Should return true when SetMute(true)", func(t *testing.T) {
assert.True(t, vm.Strip[0].GetMute()) assert.True(t, vm.Strip[0].GetMute())
}) })
vm.Strip[0].SetMute(false) vm.Strip[0].SetMute(false)
sync()
t.Run("Should return false when SetMute(false)", func(t *testing.T) { t.Run("Should return false when SetMute(false)", func(t *testing.T) {
assert.False(t, vm.Strip[0].GetMute()) assert.False(t, vm.Strip[0].GetMute())
}) })
@@ -24,13 +22,11 @@ func TestStrip0Mute(t *testing.T) {
func TestStrip3A1(t *testing.T) { func TestStrip3A1(t *testing.T) {
//t.Skip("skipping test") //t.Skip("skipping test")
vm.Strip[3].SetA1(true) vm.Strip[3].SetA1(true)
sync()
t.Run("Should return true when SetA1(true)", func(t *testing.T) { t.Run("Should return true when SetA1(true)", func(t *testing.T) {
assert.True(t, vm.Strip[3].GetA1()) assert.True(t, vm.Strip[3].GetA1())
}) })
vm.Strip[3].SetA1(false) vm.Strip[3].SetA1(false)
sync()
t.Run("Should return false when SetA1(false)", func(t *testing.T) { t.Run("Should return false when SetA1(false)", func(t *testing.T) {
assert.False(t, vm.Strip[3].GetA1()) assert.False(t, vm.Strip[3].GetA1())
}) })
@@ -39,13 +35,11 @@ func TestStrip3A1(t *testing.T) {
func TestStrip2Limit(t *testing.T) { func TestStrip2Limit(t *testing.T) {
//t.Skip("skipping test") //t.Skip("skipping test")
vm.Strip[2].SetLimit(-8) vm.Strip[2].SetLimit(-8)
sync()
t.Run("Should return -8 when SetLimit(-8)", func(t *testing.T) { t.Run("Should return -8 when SetLimit(-8)", func(t *testing.T) {
assert.Equal(t, vm.Strip[2].GetLimit(), -8) assert.Equal(t, vm.Strip[2].GetLimit(), -8)
}) })
vm.Strip[2].SetLimit(-32) vm.Strip[2].SetLimit(-32)
sync()
t.Run("Should return -32 when SetLimit(-8)", func(t *testing.T) { t.Run("Should return -32 when SetLimit(-8)", func(t *testing.T) {
assert.Equal(t, vm.Strip[2].GetLimit(), -32) assert.Equal(t, vm.Strip[2].GetLimit(), -32)
}) })
@@ -55,13 +49,11 @@ func TestStrip2Limit(t *testing.T) {
func TestStrip4Label(t *testing.T) { func TestStrip4Label(t *testing.T) {
//t.Skip("skipping test") //t.Skip("skipping test")
vm.Strip[4].SetLabel("test0") vm.Strip[4].SetLabel("test0")
sync()
t.Run("Should return test0 when SetLimit('test0')", func(t *testing.T) { t.Run("Should return test0 when SetLimit('test0')", func(t *testing.T) {
assert.Equal(t, "test0", vm.Strip[4].GetLabel()) assert.Equal(t, "test0", vm.Strip[4].GetLabel())
}) })
vm.Strip[4].SetLabel("test1") vm.Strip[4].SetLabel("test1")
sync()
t.Run("Should return test1 when SetLimit('test1')", func(t *testing.T) { t.Run("Should return test1 when SetLimit('test1')", func(t *testing.T) {
assert.Equal(t, "test1", vm.Strip[4].GetLabel()) assert.Equal(t, "test1", vm.Strip[4].GetLabel())
}) })
@@ -70,13 +62,11 @@ func TestStrip4Label(t *testing.T) {
func TestStrip5Gain(t *testing.T) { func TestStrip5Gain(t *testing.T) {
//t.Skip("skipping test") //t.Skip("skipping test")
vm.Strip[4].SetGain(-20.8) vm.Strip[4].SetGain(-20.8)
sync()
t.Run("Should return -20.8 when SetGain(-20.8)", func(t *testing.T) { t.Run("Should return -20.8 when SetGain(-20.8)", func(t *testing.T) {
assert.Equal(t, vm.Strip[4].GetGain(), -20.8) assert.Equal(t, vm.Strip[4].GetGain(), -20.8)
}) })
vm.Strip[4].SetGain(-3.6) vm.Strip[4].SetGain(-3.6)
sync()
t.Run("Should return -3.6 when SetGain(-3.6)", func(t *testing.T) { t.Run("Should return -3.6 when SetGain(-3.6)", func(t *testing.T) {
assert.Equal(t, vm.Strip[4].GetGain(), -3.6) assert.Equal(t, vm.Strip[4].GetGain(), -3.6)
}) })
@@ -85,13 +75,11 @@ func TestStrip5Gain(t *testing.T) {
func TestStrip3Comp(t *testing.T) { func TestStrip3Comp(t *testing.T) {
//t.Skip("skipping test") //t.Skip("skipping test")
vm.Strip[4].SetComp(8.1) vm.Strip[4].SetComp(8.1)
sync()
t.Run("Should return 8.1 when SetGain(8.1)", func(t *testing.T) { t.Run("Should return 8.1 when SetGain(8.1)", func(t *testing.T) {
assert.Equal(t, vm.Strip[4].GetComp(), 8.1) assert.Equal(t, vm.Strip[4].GetComp(), 8.1)
}) })
vm.Strip[4].SetComp(1.6) vm.Strip[4].SetComp(1.6)
sync()
t.Run("Should return 1.6 when SetGain(1.6)", func(t *testing.T) { t.Run("Should return 1.6 when SetGain(1.6)", func(t *testing.T) {
assert.Equal(t, vm.Strip[4].GetComp(), 1.6) assert.Equal(t, vm.Strip[4].GetComp(), 1.6)
}) })
@@ -100,13 +88,11 @@ func TestStrip3Comp(t *testing.T) {
func TestStrip5Mc(t *testing.T) { func TestStrip5Mc(t *testing.T) {
//t.Skip("skipping test") //t.Skip("skipping test")
vm.Strip[5].SetMc(true) vm.Strip[5].SetMc(true)
sync()
t.Run("Should return true when SetMc(true)", func(t *testing.T) { t.Run("Should return true when SetMc(true)", func(t *testing.T) {
assert.True(t, vm.Strip[5].GetMc()) assert.True(t, vm.Strip[5].GetMc())
}) })
vm.Strip[5].SetMc(false) vm.Strip[5].SetMc(false)
sync()
t.Run("Should return false when SetMc(false)", func(t *testing.T) { t.Run("Should return false when SetMc(false)", func(t *testing.T) {
assert.False(t, vm.Strip[5].GetMc()) assert.False(t, vm.Strip[5].GetMc())
}) })
@@ -115,13 +101,11 @@ func TestStrip5Mc(t *testing.T) {
func TestStrip2GainLayer3(t *testing.T) { func TestStrip2GainLayer3(t *testing.T) {
//t.Skip("skipping test") //t.Skip("skipping test")
vm.Strip[2].GainLayer()[3].Set(-18.3) vm.Strip[2].GainLayer()[3].Set(-18.3)
sync()
t.Run("Should return -18.3 when SetMc(true)", func(t *testing.T) { t.Run("Should return -18.3 when SetMc(true)", func(t *testing.T) {
assert.Equal(t, vm.Strip[2].GainLayer()[3].Get(), -18.3) assert.Equal(t, vm.Strip[2].GainLayer()[3].Get(), -18.3)
}) })
vm.Strip[2].GainLayer()[3].Set(-25.6) vm.Strip[2].GainLayer()[3].Set(-25.6)
sync()
t.Run("Should return -25.6 when SetMc(true)", func(t *testing.T) { t.Run("Should return -25.6 when SetMc(true)", func(t *testing.T) {
assert.Equal(t, vm.Strip[2].GainLayer()[3].Get(), -25.6) assert.Equal(t, vm.Strip[2].GainLayer()[3].Get(), -25.6)
}) })
@@ -130,13 +114,11 @@ func TestStrip2GainLayer3(t *testing.T) {
func TestBus3Eq(t *testing.T) { func TestBus3Eq(t *testing.T) {
//t.Skip("skipping test") //t.Skip("skipping test")
vm.Bus[3].SetEq(true) vm.Bus[3].SetEq(true)
sync()
t.Run("Should return true when SetEq(true)", func(t *testing.T) { t.Run("Should return true when SetEq(true)", func(t *testing.T) {
assert.True(t, vm.Bus[3].GetEq()) assert.True(t, vm.Bus[3].GetEq())
}) })
vm.Bus[3].SetEq(false) vm.Bus[3].SetEq(false)
sync()
t.Run("Should return false when SetEq(false)", func(t *testing.T) { t.Run("Should return false when SetEq(false)", func(t *testing.T) {
assert.False(t, vm.Bus[3].GetEq()) assert.False(t, vm.Bus[3].GetEq())
}) })
@@ -145,13 +127,11 @@ func TestBus3Eq(t *testing.T) {
func TestBus4Label(t *testing.T) { func TestBus4Label(t *testing.T) {
//t.Skip("skipping test") //t.Skip("skipping test")
vm.Bus[4].SetLabel("test0") vm.Bus[4].SetLabel("test0")
sync()
t.Run("Should return test0 when SetEq('test0')", func(t *testing.T) { t.Run("Should return test0 when SetEq('test0')", func(t *testing.T) {
assert.Equal(t, "test0", vm.Bus[4].GetLabel()) assert.Equal(t, "test0", vm.Bus[4].GetLabel())
}) })
vm.Bus[4].SetLabel("test1") vm.Bus[4].SetLabel("test1")
sync()
t.Run("Should return test1 when SetEq('test1')", func(t *testing.T) { t.Run("Should return test1 when SetEq('test1')", func(t *testing.T) {
assert.Equal(t, "test1", vm.Bus[4].GetLabel()) assert.Equal(t, "test1", vm.Bus[4].GetLabel())
}) })
@@ -160,7 +140,6 @@ func TestBus4Label(t *testing.T) {
func TestBus3ModeAmix(t *testing.T) { func TestBus3ModeAmix(t *testing.T) {
//t.Skip("skipping test") //t.Skip("skipping test")
vm.Bus[3].Mode().SetAmix(true) vm.Bus[3].Mode().SetAmix(true)
sync()
t.Run("Should return true when Mode().SetAmix(true)", func(t *testing.T) { t.Run("Should return true when Mode().SetAmix(true)", func(t *testing.T) {
assert.True(t, vm.Bus[3].Mode().GetAmix()) assert.True(t, vm.Bus[3].Mode().GetAmix())
}) })
@@ -169,13 +148,11 @@ func TestBus3ModeAmix(t *testing.T) {
func TestVbanInStream0On(t *testing.T) { func TestVbanInStream0On(t *testing.T) {
//t.Skip("skipping test") //t.Skip("skipping test")
vm.Vban.InStream[0].SetOn(true) vm.Vban.InStream[0].SetOn(true)
sync()
t.Run("Should return true when SetOn(true)", func(t *testing.T) { t.Run("Should return true when SetOn(true)", func(t *testing.T) {
assert.True(t, vm.Vban.InStream[0].GetOn()) assert.True(t, vm.Vban.InStream[0].GetOn())
}) })
vm.Vban.InStream[0].SetOn(false) vm.Vban.InStream[0].SetOn(false)
sync()
t.Run("Should return false when SetOn(false)", func(t *testing.T) { t.Run("Should return false when SetOn(false)", func(t *testing.T) {
assert.False(t, vm.Vban.InStream[0].GetOn()) assert.False(t, vm.Vban.InStream[0].GetOn())
}) })
@@ -184,13 +161,11 @@ func TestVbanInStream0On(t *testing.T) {
func TestVbanOutStream6On(t *testing.T) { func TestVbanOutStream6On(t *testing.T) {
//t.Skip("skipping test") //t.Skip("skipping test")
vm.Vban.OutStream[6].SetOn(true) vm.Vban.OutStream[6].SetOn(true)
sync()
t.Run("Should return true when SetOn(true)", func(t *testing.T) { t.Run("Should return true when SetOn(true)", func(t *testing.T) {
assert.True(t, vm.Vban.OutStream[6].GetOn()) assert.True(t, vm.Vban.OutStream[6].GetOn())
}) })
vm.Vban.OutStream[6].SetOn(false) vm.Vban.OutStream[6].SetOn(false)
sync()
t.Run("Should return false when SetOn(false)", func(t *testing.T) { t.Run("Should return false when SetOn(false)", func(t *testing.T) {
assert.False(t, vm.Vban.OutStream[6].GetOn()) assert.False(t, vm.Vban.OutStream[6].GetOn())
}) })
@@ -199,13 +174,11 @@ func TestVbanOutStream6On(t *testing.T) {
func TestVbanOutStream3Name(t *testing.T) { func TestVbanOutStream3Name(t *testing.T) {
t.Skip("skipping test") t.Skip("skipping test")
vm.Vban.OutStream[3].SetName("test0") vm.Vban.OutStream[3].SetName("test0")
sync()
t.Run("Should return test0 when SetName('test0')", func(t *testing.T) { t.Run("Should return test0 when SetName('test0')", func(t *testing.T) {
assert.Equal(t, "test0", vm.Vban.OutStream[3].GetName()) assert.Equal(t, "test0", vm.Vban.OutStream[3].GetName())
}) })
vm.Vban.OutStream[3].SetName("test1") vm.Vban.OutStream[3].SetName("test1")
sync()
t.Run("Should return test1 when SetName('test1')", func(t *testing.T) { t.Run("Should return test1 when SetName('test1')", func(t *testing.T) {
assert.Equal(t, "test1", vm.Vban.OutStream[3].GetName()) assert.Equal(t, "test1", vm.Vban.OutStream[3].GetName())
}) })
@@ -226,13 +199,11 @@ func TestVbanInStream4Bit(t *testing.T) {
func TestVbanOutStream4Bit(t *testing.T) { func TestVbanOutStream4Bit(t *testing.T) {
//t.Skip("skipping test") //t.Skip("skipping test")
vm.Vban.OutStream[4].SetBit(16) vm.Vban.OutStream[4].SetBit(16)
sync()
t.Run("Should return 16 when SetBit(16)", func(t *testing.T) { t.Run("Should return 16 when SetBit(16)", func(t *testing.T) {
assert.Equal(t, vm.Vban.OutStream[4].GetBit(), 16) assert.Equal(t, vm.Vban.OutStream[4].GetBit(), 16)
}) })
vm.Vban.OutStream[4].SetBit(24) vm.Vban.OutStream[4].SetBit(24)
sync()
t.Run("Should return 24 when SetBit(24)", func(t *testing.T) { t.Run("Should return 24 when SetBit(24)", func(t *testing.T) {
assert.Equal(t, vm.Vban.OutStream[4].GetBit(), 24) assert.Equal(t, vm.Vban.OutStream[4].GetBit(), 24)
}) })

View File

@@ -13,7 +13,7 @@ func allTrue(s []bool, sz int) bool {
} }
// update copies the contents of one float slice into another // update copies the contents of one float slice into another
func update(s1 []float32, s2 []float32, sz int) { func update(s1 []float64, s2 []float64, sz int) {
for i := 0; i < sz; i++ { for i := 0; i < sz; i++ {
s1[i] = s2[i] s1[i] = s2[i]
} }
@@ -26,10 +26,10 @@ func roundFloat(val float64, precision uint) float64 {
} }
// convertLevel performs the necessary math for a channel level // convertLevel performs the necessary math for a channel level
func convertLevel(i float32) float32 { func convertLevel(i float64) float64 {
if i > 0 { if i > 0 {
val := 20 * math.Log10(float64(i)) val := 20 * math.Log10(float64(i))
return float32(roundFloat(float64(val), 1)) return float64(roundFloat(float64(val), 1))
} }
return -200.0 return -200.0
} }

View File

@@ -20,8 +20,8 @@ func TestAllTrue(t *testing.T) {
func TestUpdate(t *testing.T) { func TestUpdate(t *testing.T) {
//t.Skip("skipping test") //t.Skip("skipping test")
s1 := []float32{3.6, 8.7, 1.8, 18.2} s1 := []float64{3.6, 8.7, 1.8, 18.2}
s2 := make([]float32, len(s1)) s2 := make([]float64, len(s1))
update(s2, s1, len(s1)) update(s2, s1, len(s1))
t.Run("Should return true", func(t *testing.T) { t.Run("Should return true", func(t *testing.T) {
assert.Equal(t, s1, s2) assert.Equal(t, s1, s2)
@@ -32,10 +32,10 @@ func TestConvertLevel(t *testing.T) {
//t.Skip("skipping test") //t.Skip("skipping test")
res := convertLevel(0.02) res := convertLevel(0.02)
t.Run("Should be equal", func(t *testing.T) { t.Run("Should be equal", func(t *testing.T) {
assert.Equal(t, float32(-34), res) assert.Equal(t, float64(-34), res)
}) })
res = convertLevel(-0.02) res = convertLevel(-0.02)
t.Run("Should be equal", func(t *testing.T) { t.Run("Should be equal", func(t *testing.T) {
assert.Equal(t, float32(-200), res) assert.Equal(t, float64(-200), res)
}) })
} }