Compare commits
2
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
62e7cb88f4 | ||
|
|
df865574bf |
@@ -36,10 +36,6 @@ EVENT HANDLER FACTORY COMMANDS
|
|||||||
|
|
||||||
factory run <file.yaml>
|
factory run <file.yaml>
|
||||||
|
|
||||||
MISC COMMANDS
|
|
||||||
|
|
||||||
color <color>
|
|
||||||
|
|
||||||
File example (use '---' to delimit multiple configs in one file):
|
File example (use '---' to delimit multiple configs in one file):
|
||||||
mode: SceneDimmer
|
mode: SceneDimmer
|
||||||
target: tag:Soverom
|
target: tag:Soverom
|
||||||
|
|||||||
@@ -4,7 +4,6 @@ import (
|
|||||||
"context"
|
"context"
|
||||||
"fmt"
|
"fmt"
|
||||||
"git.aiterp.net/lucifer/new-server/app/client"
|
"git.aiterp.net/lucifer/new-server/app/client"
|
||||||
"git.aiterp.net/lucifer/new-server/internal/color"
|
|
||||||
"git.aiterp.net/lucifer/new-server/models"
|
"git.aiterp.net/lucifer/new-server/models"
|
||||||
"log"
|
"log"
|
||||||
"os"
|
"os"
|
||||||
@@ -93,29 +92,6 @@ func main() {
|
|||||||
|
|
||||||
WriteDeviceInfoTable(os.Stdout, devices)
|
WriteDeviceInfoTable(os.Stdout, devices)
|
||||||
}
|
}
|
||||||
case "color":
|
|
||||||
{
|
|
||||||
col, err := color.Parse(cmd.Params.Get(0).StringOr("hs:0,0"))
|
|
||||||
if err != nil {
|
|
||||||
log.Fatalln(err)
|
|
||||||
}
|
|
||||||
|
|
||||||
if col.IsKelvin() {
|
|
||||||
fmt.Println(col.String())
|
|
||||||
}
|
|
||||||
if hs, ok := col.ToHS(); ok {
|
|
||||||
fmt.Println(hs.String())
|
|
||||||
}
|
|
||||||
if hsk, ok := col.ToHSK(); ok {
|
|
||||||
fmt.Println(hsk.String())
|
|
||||||
}
|
|
||||||
if xy, ok := col.ToXY(); ok {
|
|
||||||
fmt.Println(xy.String())
|
|
||||||
}
|
|
||||||
if rgb, ok := col.ToRGB(); ok {
|
|
||||||
fmt.Println(rgb.String())
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
case "factory":
|
case "factory":
|
||||||
factoryCmd(ctx, c)
|
factoryCmd(ctx, c)
|
||||||
|
|||||||
@@ -6,7 +6,6 @@ import (
|
|||||||
"crypto/rand"
|
"crypto/rand"
|
||||||
"crypto/sha1"
|
"crypto/sha1"
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
"errors"
|
|
||||||
"fmt"
|
"fmt"
|
||||||
"git.aiterp.net/lucifer/new-server/internal/lerrors"
|
"git.aiterp.net/lucifer/new-server/internal/lerrors"
|
||||||
"git.aiterp.net/lucifer/new-server/models"
|
"git.aiterp.net/lucifer/new-server/models"
|
||||||
@@ -84,16 +83,11 @@ func (b *bridge) listDevices(ctx context.Context) ([]models.Device, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (b *bridge) pushStateChange(ctx context.Context, deviceModel models.Device) error {
|
func (b *bridge) pushStateChange(ctx context.Context, deviceModel models.Device) error {
|
||||||
if ip, ok := deviceModel.DriverProperties["ip"].(string); ok {
|
|
||||||
return b.pushWifiStateChange(ctx, ip, deviceModel.State.Temperature)
|
|
||||||
}
|
|
||||||
|
|
||||||
b.mu.Lock()
|
b.mu.Lock()
|
||||||
if b.luciferMillIDMap == nil {
|
if b.luciferMillIDMap == nil {
|
||||||
b.luciferMillIDMap = make(map[int]int, 4)
|
b.luciferMillIDMap = make(map[int]int, 4)
|
||||||
b.millLuciferIDMap = make(map[int]int, 4)
|
b.millLuciferIDMap = make(map[int]int, 4)
|
||||||
}
|
}
|
||||||
subDomain := deviceModel.DriverProperties["subDomain"].(string)
|
|
||||||
|
|
||||||
if b.luciferMillIDMap[deviceModel.ID] == 0 {
|
if b.luciferMillIDMap[deviceModel.ID] == 0 {
|
||||||
millID, _ := strconv.Atoi(deviceModel.InternalID)
|
millID, _ := strconv.Atoi(deviceModel.InternalID)
|
||||||
@@ -106,10 +100,8 @@ func (b *bridge) pushStateChange(ctx context.Context, deviceModel models.Device)
|
|||||||
if deviceModel.State.Power {
|
if deviceModel.State.Power {
|
||||||
status = 1
|
status = 1
|
||||||
}
|
}
|
||||||
|
|
||||||
if subDomainIsGen2(subDomain) {
|
|
||||||
powerReq := deviceControlReqBody{
|
powerReq := deviceControlReqBody{
|
||||||
SubDomain: subDomain,
|
SubDomain: deviceModel.DriverProperties["subDomain"].(string),
|
||||||
DeviceID: b.luciferMillIDMap[deviceModel.ID],
|
DeviceID: b.luciferMillIDMap[deviceModel.ID],
|
||||||
TestStatus: 1,
|
TestStatus: 1,
|
||||||
Status: status,
|
Status: status,
|
||||||
@@ -129,66 +121,6 @@ func (b *bridge) pushStateChange(ctx context.Context, deviceModel models.Device)
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
} else {
|
|
||||||
sd, _ := strconv.Atoi(subDomain)
|
|
||||||
|
|
||||||
tempReq := deviceControlGen3Body{
|
|
||||||
Operation: "SINGLE_CONTROL",
|
|
||||||
Status: status,
|
|
||||||
SubDomain: sd,
|
|
||||||
DeviceId: b.luciferMillIDMap[deviceModel.ID],
|
|
||||||
HoldTemp: deviceModel.State.Temperature,
|
|
||||||
}
|
|
||||||
err := b.command(ctx, "deviceControlGen3ForApp", tempReq, nil)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
powerReq := deviceControlGen3Body{
|
|
||||||
Operation: "SWITCH",
|
|
||||||
Status: status,
|
|
||||||
SubDomain: sd,
|
|
||||||
DeviceId: b.luciferMillIDMap[deviceModel.ID],
|
|
||||||
}
|
|
||||||
err = b.command(ctx, "deviceControlGen3ForApp", powerReq, nil)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (b *bridge) pushWifiStateChange(ctx context.Context, ip string, temperature int) error {
|
|
||||||
b.mu.Lock()
|
|
||||||
defer b.mu.Unlock()
|
|
||||||
|
|
||||||
data, err := json.Marshal(wifiSetTemperatureBody{
|
|
||||||
Type: "Normal",
|
|
||||||
Value: temperature,
|
|
||||||
})
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
req, err := http.NewRequestWithContext(
|
|
||||||
ctx,
|
|
||||||
"POST",
|
|
||||||
fmt.Sprintf("http://%s/set-temperature", ip),
|
|
||||||
bytes.NewReader(data),
|
|
||||||
)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
res, err := http.DefaultClient.Do(req)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
if res.StatusCode > 299 {
|
|
||||||
return errors.New("mill: negative response from " + ip)
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
@@ -307,15 +239,3 @@ func addDefaultHeaders(req *http.Request) {
|
|||||||
req.Header.Add("X-Zc-Seq-Id", "1")
|
req.Header.Add("X-Zc-Seq-Id", "1")
|
||||||
req.Header.Add("X-Zc-Version", "1")
|
req.Header.Add("X-Zc-Version", "1")
|
||||||
}
|
}
|
||||||
|
|
||||||
var gen2subDomains = []string{"863", "5316", "5317", "5332", "5333", "6933"}
|
|
||||||
|
|
||||||
func subDomainIsGen2(subDomain string) bool {
|
|
||||||
for _, gen2sd := range gen2subDomains {
|
|
||||||
if subDomain == gen2sd {
|
|
||||||
return true
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
|
|||||||
@@ -65,19 +65,6 @@ type deviceControlReqBody struct {
|
|||||||
PowerLevel int `json:"powerLevel"`
|
PowerLevel int `json:"powerLevel"`
|
||||||
}
|
}
|
||||||
|
|
||||||
type deviceControlGen3Body struct {
|
|
||||||
Operation string `json:"operation"`
|
|
||||||
Status int `json:"status"`
|
|
||||||
SubDomain int `json:"subDomain"`
|
|
||||||
DeviceId int `json:"deviceId"`
|
|
||||||
HoldTemp int `json:"holdTemp,omitempty"`
|
|
||||||
}
|
|
||||||
|
|
||||||
type wifiSetTemperatureBody struct {
|
|
||||||
Type string `json:"type"`
|
|
||||||
Value int `json:"value"`
|
|
||||||
}
|
|
||||||
|
|
||||||
var location *time.Location
|
var location *time.Location
|
||||||
|
|
||||||
func init() {
|
func init() {
|
||||||
|
|||||||
Reference in New Issue
Block a user