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
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
|
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
namespace com.clusterrr.TuyaNet
{
/// <summary>
/// Tuya virtual IR remote control
/// </summary>
public class TuyaIRControl : TuyaDevice
{
public const int DP_SEND_IR = 201; // ir_send, send and report (read-write)
public const int DP_LEARNED_ID = 202; // ir_study_code, report only (read-only)
public const string NSDP_CONTROL = "control"; // The control commands
public const string NSDP_STUDY_CODE = "study_code"; // Report learned IR codes
public const string NSDP_IR_CODE = "ir_code"; // IR signal decoding2
public const string NSDP_KEY_CODE = "key_code"; // Remote key code
public const string NSDP_KEY_CODE2 = "key_code2"; // Remote key code 2
public const string NSDP_KEY_CODE3 = "key_code3"; // Remote key code 3
public const string NSDP_KEY_CODE4 = "key_code4"; // Remote key code 4
public const string NSDP_KEY_STUDY = "key_study"; // Send the learning code 1
public const string NSDP_KEY_STUDY2 = "key_study2"; // Send the learning code 2
public const string NSDP_KEY_STUDY3 = "key_study3"; // Send the learning code 3
public const string NSDP_KEY_STUDY4 = "key_study4"; // Send the learning code 4
public const string NSDP_DELAY_TIME = "delay_time"; // IR code transmission delay
public const string NSDP_TYPE = "type"; // The identifier of an IR library
public const string NSDP_DELAY = "delay"; // Actually used but not documented
public const string NSDP_HEAD = "head"; // Actually used but not documented
public const string NSDP_KEY1 = "key1"; // Actually used but not documented
/// <summary>
/// Creates a new instance of the TuyaDevice class.
/// </summary>
/// <param name="ip">IP address of device.</param>
/// <param name="localKey">Local key of device (obtained via API).</param>
/// <param name="deviceId">Device ID.</param>
/// <param name="protocolVersion">Protocol version.</param>
/// <param name="port">TCP port of device.</param>
/// <param name="receiveTimeout">Receive timeout (msec).</param>
public TuyaIRControl(string ip, string localKey, string deviceId, TuyaProtocolVersion protocolVersion = TuyaProtocolVersion.V33, int port = 6668, int receiveTimeout = 250)
: base(ip, localKey, deviceId, protocolVersion, port, receiveTimeout)
{
}
/// <summary>
/// Creates a new instance of the TuyaDevice class.
/// </summary>
/// <param name="ip">IP address of device.</param>
/// <param name="region">Region to access Cloud API.</param>
/// <param name="accessId">Access ID to access Cloud API.</param>
/// <param name="apiSecret">API secret to access Cloud API.</param>
/// <param name="deviceId">Device ID.</param>
/// <param name="protocolVersion">Protocol version.</param>
/// <param name="port">TCP port of device.</param>
/// <param name="receiveTimeout">Receive timeout (msec).</param>
public TuyaIRControl(string ip, TuyaApi.Region region, string accessId, string apiSecret, string deviceId, TuyaProtocolVersion protocolVersion = TuyaProtocolVersion.V33, int port = 6668, int receiveTimeout = 250)
: base(ip, region, accessId, apiSecret, deviceId, protocolVersion, port, receiveTimeout)
{
}
/// <summary>
/// Learns button code of remote control.
/// </summary>
/// <param name="timeout">Learing timeout, you should press RC button during this interval.</param>
/// <param name="cancellationToken">Cancellation token.</param>
/// <returns>Button code as Base64 string.</returns>
public async Task<string> GetButtonCodeAsync(int timeout, int retries = 2, CancellationToken cancellationToken = default)
{
try
{
var subCmd = new Dictionary<string, object>()
{
{ NSDP_CONTROL, "study_exit" }
};
var subCmdJson = JsonConvert.SerializeObject(subCmd);
await SetDpsAsync(new Dictionary<int, object>() { { 201, subCmdJson } }, nullRetries: 0, allowEmptyResponse: true, cancellationToken: cancellationToken);
await Task.Delay(1000);
subCmd = new Dictionary<string, object>()
{
{ NSDP_CONTROL, "study" }
};
subCmdJson = JsonConvert.SerializeObject(subCmd);
await SetDpsAsync(new Dictionary<int, object>() { { 201, subCmdJson } }, cancellationToken: cancellationToken);
while (true)
{
var response = await SetDpsAsync(new Dictionary<int, object>() { { 201, subCmdJson } }, overrideRecvTimeout: timeout, allowEmptyResponse: true, cancellationToken: cancellationToken);
if (response != null)
{
var result = response[202].ToString();
return result;
}
}
}
finally
{
try
{
var subCmd = new Dictionary<string, object>()
{
{ NSDP_CONTROL, "study_exit" }
};
var subCmdJson = JsonConvert.SerializeObject(subCmd);
await SetDpsAsync(new Dictionary<int, object>() { { 201, subCmdJson } }, nullRetries: 0, allowEmptyResponse: true, cancellationToken: cancellationToken);
}
catch { }
}
}
/// <summary>
/// Sends button code.
/// </summary>
/// <param name="buttonCode">Button code in Base64 encoding.</param>
/// <param name="cancellationToken">Cancellation token.</param>
public async Task SendButtonCodeAsync(string buttonCode, int retries = 2, int? overrideRecvTimeout = null, CancellationToken cancellationToken = default)
{
var subCmd = new Dictionary<string, object>()
{
{ NSDP_CONTROL, "send_ir" },
{ NSDP_KEY1, buttonCode.Length % 4 == 0 ? "1" + buttonCode : buttonCode }, // code need to be padded with "1" (wtf?)
{ NSDP_TYPE, 0 },
{ NSDP_DELAY, 0 }
};
var subCmdJson = JsonConvert.SerializeObject(subCmd);
await SetDpsAsync(new Dictionary<int, object>() { { 201, subCmdJson } }, retries: retries,
nullRetries: 0, overrideRecvTimeout: overrideRecvTimeout, allowEmptyResponse: true, cancellationToken: cancellationToken);
}
/// <summary>
/// Converts Base64 encoded button code into pulses duration.
/// </summary>
/// <param name="codeBase64">Base64 encoded button code.</param>
/// <returns>Pulses/gaps length in microsecods.</returns>
public static ushort[] Base64ToPulses(string codeBase64)
{
var bytes = Convert.FromBase64String(
(codeBase64.Length % 4 == 1 && codeBase64.StartsWith("1"))
? codeBase64.Substring(1) // code can be padded with "1" (wtf?)
: codeBase64
);
var pulses = Enumerable.Range(0, bytes.Length)
.Where(x => x % 2 == 0)
.Select(x => (ushort)((bytes[x] | bytes[x + 1] << 8)))
.ToArray();
return pulses;
}
/// <summary>
/// Converts pulses duration into Base64 encoded button code.
/// </summary>
/// <param name="pulses">Pulses/gaps length in microsecods.</param>
/// <returns>Base64 encoded button code.</returns>
public static string PulsesToBase64(ushort[] pulses)
{
var bytes = pulses.SelectMany(x => new byte[] { (byte)(x & 0xFF), (byte)((x >> 8) & 0xFF) });
var codeBase64 = Convert.ToBase64String(bytes.ToArray());
return codeBase64;
}
/// <summary>
/// Converts hex encoded button code into pulses duration.
/// </summary>
/// <param name="codeHex">Hex encoded button code.</param>
/// <returns>Pulses/gaps length in microsecods.</returns>
public static ushort[] HexToPulses(string codeHex)
{
var pulses = Enumerable.Range(0, codeHex.Length)
.Where(x => (x % 4) == 0)
.Select(x => (ushort)(Convert.ToUInt16(codeHex.Substring(x + 2, 2) + codeHex.Substring(x, 2), 16)));
return pulses.ToArray();
}
/// <summary>
/// Converts pulses duration into hex encoded button code.
/// </summary>
/// <param name="pulses">Pulses/gaps length in microsecods.</param>
/// <returns>Hex encoded button code.</returns>
public static string PulsesToHex(ushort[] pulses)
{
var words = Enumerable.Range(0, pulses.Length)
.Select(x => $"{(pulses[x] & 0xFF):x02}{((pulses[x] >> 8) & 0xFF):x02}").ToArray();
var hex = string.Concat(words);
return hex;
}
}
}
|
