Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
083df1749b | ||
|
|
511ef97616 | ||
|
|
3d2b4e7bfe | ||
|
|
c2f3d3c4d1 |
@@ -7,6 +7,7 @@ import (
|
|||||||
"git.aiterp.net/lucifer3/server/services/effectenforcer"
|
"git.aiterp.net/lucifer3/server/services/effectenforcer"
|
||||||
"git.aiterp.net/lucifer3/server/services/httpapiv1"
|
"git.aiterp.net/lucifer3/server/services/httpapiv1"
|
||||||
"git.aiterp.net/lucifer3/server/services/hue"
|
"git.aiterp.net/lucifer3/server/services/hue"
|
||||||
|
"git.aiterp.net/lucifer3/server/services/mill"
|
||||||
"git.aiterp.net/lucifer3/server/services/mysqldb"
|
"git.aiterp.net/lucifer3/server/services/mysqldb"
|
||||||
"git.aiterp.net/lucifer3/server/services/nanoleaf"
|
"git.aiterp.net/lucifer3/server/services/nanoleaf"
|
||||||
"git.aiterp.net/lucifer3/server/services/script"
|
"git.aiterp.net/lucifer3/server/services/script"
|
||||||
@@ -47,6 +48,7 @@ func main() {
|
|||||||
bus.Join(nanoleaf.NewService())
|
bus.Join(nanoleaf.NewService())
|
||||||
bus.Join(hue.NewService())
|
bus.Join(hue.NewService())
|
||||||
bus.Join(tradfri.NewService())
|
bus.Join(tradfri.NewService())
|
||||||
|
bus.Join(mill.NewService())
|
||||||
bus.Join(uistate.NewService())
|
bus.Join(uistate.NewService())
|
||||||
bus.Join(script.NewService(resolver, variables))
|
bus.Join(script.NewService(resolver, variables))
|
||||||
bus.Join(database)
|
bus.Join(database)
|
||||||
|
|||||||
Binary file not shown.
@@ -348,7 +348,7 @@ func (b *Bridge) SetStates(patch map[string]device.State) {
|
|||||||
func (b *Bridge) Run(ctx context.Context, bus *lucifer3.EventBus) interface{} {
|
func (b *Bridge) Run(ctx context.Context, bus *lucifer3.EventBus) interface{} {
|
||||||
hwEvents, err := b.RefreshAll()
|
hwEvents, err := b.RefreshAll()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return errors.New("failed to connect to bridge")
|
return fmt.Errorf("failed to connect to bridge: %s", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
bus.RunEvent(events.Log{
|
bus.RunEvent(events.Log{
|
||||||
|
|||||||
@@ -78,7 +78,7 @@ func (w *WifiBridge) refresh() error {
|
|||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
if w.state != nil {
|
if w.state == nil {
|
||||||
w.state = &device.State{
|
w.state = &device.State{
|
||||||
Temperature: gentools.Ptr(temp),
|
Temperature: gentools.Ptr(temp),
|
||||||
}
|
}
|
||||||
@@ -112,7 +112,7 @@ func (w *WifiBridge) getTemperature() (float64, error) {
|
|||||||
|
|
||||||
req, err := http.NewRequest(
|
req, err := http.NewRequest(
|
||||||
"GET",
|
"GET",
|
||||||
"http://%s/set-temperature",
|
fmt.Sprintf("http://%s/set-temperature", w.IP),
|
||||||
bytes.NewReader(body),
|
bytes.NewReader(body),
|
||||||
)
|
)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@@ -144,7 +144,7 @@ func (w *WifiBridge) writeTemperature() error {
|
|||||||
|
|
||||||
req, err := http.NewRequest(
|
req, err := http.NewRequest(
|
||||||
"POST",
|
"POST",
|
||||||
"http://%s/set-temperature",
|
fmt.Sprintf("http://%s/set-temperature", w.IP),
|
||||||
bytes.NewReader(body),
|
bytes.NewReader(body),
|
||||||
)
|
)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|||||||
Reference in New Issue
Block a user