-
Notifications
You must be signed in to change notification settings - Fork 2
/
device.go
118 lines (106 loc) · 2.39 KB
/
device.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
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
// Package eiscp provides basic support for eISCP/ISCP protocol
package eiscp
import (
"bufio"
"fmt"
"net"
)
// Device of Onkyo receiver
type Device struct {
conn net.Conn
channel *bufio.Reader
destinationType DeviceType
version byte
Verbose bool
}
// NewDevice - create and connect to eISCP device (Onkyo)
func NewDevice(host string, deviceType DeviceType, iscpVersion byte) (*Device, error) {
dev := new(Device)
dev.destinationType = deviceType
dev.version = iscpVersion
err := dev.connect(host)
if err != nil {
dev.Close()
return nil, err
}
return dev, nil
}
// NewReceiver - sugar for NewDevice with Receiver as device type and version 1
func NewReceiver(host string) (*Device, error) {
return NewDevice(host, Receiver, 0x01)
}
// Close connection
func (d *Device) Close() error {
if d.conn != nil {
return d.conn.Close()
}
return nil
}
// ReadMessage - read raw eISCP message
func (d *Device) ReadMessage() (Message, error) {
msg := Message{}
err := msg.Parse(d.channel)
if err != nil {
return msg, err
}
return msg, err
}
// WriteMessage - write raw eISCP message
func (d *Device) WriteMessage(msg Message) error {
req := msg.BuildEISCP()
if d.Verbose {
fmt.Printf("Req: % x\n", req)
}
_, err := d.conn.Write(req)
return err
}
// WriteCommand - write command with arg to remote connection
func (d *Device) WriteCommand(command, arg string) error {
if d.conn == nil {
return fmt.Errorf("Not connected")
}
msg := Message{}
msg.Destination = byte(d.destinationType)
msg.Version = d.version
msg.ISCP = []byte(command + arg)
req := msg.BuildEISCP()
if d.Verbose {
fmt.Printf("Req: % x\n", req)
}
_, err := d.conn.Write(req)
return err
}
// Utility functions
// | |
// V V
// Connect device to Onkyo host
func (d *Device) connect(host string) error {
conn, err := net.Dial("tcp", host)
d.conn = conn
if err == nil {
d.channel = bufio.NewReader(d.conn)
_, err := d.ReadMessage()
if err != nil {
conn.Close()
return err
}
}
return err
}
func (d *Device) readResponse(command string) error {
msg, err := d.ReadMessage()
if err != nil {
return err
}
if string(msg.ISCP[3:]) == "N/A" {
return fmt.Errorf("Not available")
}
return nil
}
func (d *Device) requestSet(command, arg string) error {
err := d.WriteCommand(command, arg)
if err != nil {
return err
}
return d.readResponse(command)
}