/
instance.go
59 lines (48 loc) · 1.21 KB
/
instance.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
package config
import (
evbus "github.com/asaskevich/EventBus"
"github.com/evcc-io/evcc/api"
)
var bus = evbus.New()
var instance struct {
meters *handler[api.Meter]
chargers *handler[api.Charger]
vehicles *handler[api.Vehicle]
circuits *handler[api.Circuit]
}
func init() {
Reset()
}
func Reset() {
instance.meters = &handler[api.Meter]{topic: "meter"}
instance.chargers = &handler[api.Charger]{topic: "charger"}
instance.vehicles = &handler[api.Vehicle]{topic: "vehicle"}
instance.circuits = &handler[api.Circuit]{topic: "circuit"}
}
type Handler[T any] interface {
Subscribe(fn func(Operation, Device[T]))
Devices() []Device[T]
Add(dev Device[T]) error
Delete(name string) error
ByName(name string) (Device[T], error)
}
func Meters() Handler[api.Meter] {
return instance.meters
}
func Chargers() Handler[api.Charger] {
return instance.chargers
}
func Vehicles() Handler[api.Vehicle] {
return instance.vehicles
}
func Circuits() Handler[api.Circuit] {
return instance.circuits
}
// Instances returns the instances of the given devices
func Instances[T any](devices []Device[T]) []T {
res := make([]T, 0, len(devices))
for _, dev := range devices {
res = append(res, dev.Instance())
}
return res
}