]> git.basschouten.com Git - openhab-addons.git/blob
a6bec633a5afe175583b83d5ec9f576374c747ab
[openhab-addons.git] /
1 /**
2  * Copyright (c) 2010-2020 Contributors to the openHAB project
3  *
4  * See the NOTICE file(s) distributed with this work for additional
5  * information.
6  *
7  * This program and the accompanying materials are made available under the
8  * terms of the Eclipse Public License 2.0 which is available at
9  * http://www.eclipse.org/legal/epl-2.0
10  *
11  * SPDX-License-Identifier: EPL-2.0
12  */
13
14 package org.openhab.binding.ipcamera.internal;
15
16 import static org.openhab.binding.ipcamera.internal.IpCameraBindingConstants.*;
17
18 import java.util.ArrayList;
19
20 import org.eclipse.jdt.annotation.NonNullByDefault;
21 import org.eclipse.jdt.annotation.Nullable;
22 import org.openhab.binding.ipcamera.internal.handler.IpCameraHandler;
23 import org.openhab.core.library.types.OnOffType;
24 import org.openhab.core.library.types.PercentType;
25 import org.openhab.core.library.types.StringType;
26 import org.openhab.core.thing.ChannelUID;
27 import org.openhab.core.thing.binding.ThingHandler;
28 import org.openhab.core.types.Command;
29 import org.openhab.core.types.RefreshType;
30
31 import io.netty.channel.ChannelDuplexHandler;
32 import io.netty.channel.ChannelHandlerContext;
33 import io.netty.util.ReferenceCountUtil;
34
35 /**
36  * The {@link InstarHandler} is responsible for handling commands, which are
37  * sent to one of the channels.
38  *
39  * @author Matthew Skinner - Initial contribution
40  */
41
42 @NonNullByDefault
43 public class InstarHandler extends ChannelDuplexHandler {
44     private IpCameraHandler ipCameraHandler;
45     private String requestUrl = "Empty";
46
47     public InstarHandler(ThingHandler thingHandler) {
48         ipCameraHandler = (IpCameraHandler) thingHandler;
49     }
50
51     public void setURL(String url) {
52         requestUrl = url;
53     }
54
55     // This handles the incoming http replies back from the camera.
56     @Override
57     public void channelRead(@Nullable ChannelHandlerContext ctx, @Nullable Object msg) throws Exception {
58         if (msg == null || ctx == null) {
59             return;
60         }
61         try {
62             String value1 = "";
63             String content = msg.toString();
64             ipCameraHandler.logger.trace("HTTP Result back from camera is \t:{}:", content);
65             switch (requestUrl) {
66                 case "/param.cgi?cmd=getinfrared":
67                     if (content.contains("var infraredstat=\"auto")) {
68                         ipCameraHandler.setChannelState(CHANNEL_AUTO_LED, OnOffType.ON);
69                     } else {
70                         ipCameraHandler.setChannelState(CHANNEL_AUTO_LED, OnOffType.OFF);
71                     }
72                     break;
73                 case "/param.cgi?cmd=getoverlayattr&-region=1":// Text Overlays
74                     if (content.contains("var show_1=\"0\"")) {
75                         ipCameraHandler.setChannelState(CHANNEL_TEXT_OVERLAY, StringType.EMPTY);
76                     } else {
77                         value1 = Helper.searchString(content, "var name_1=\"");
78                         if (!value1.isEmpty()) {
79                             ipCameraHandler.setChannelState(CHANNEL_TEXT_OVERLAY, StringType.valueOf(value1));
80                         }
81                     }
82                     break;
83                 case "/cgi-bin/hi3510/param.cgi?cmd=getmdattr":// Motion Alarm
84                     // Motion Alarm
85                     if (content.contains("var m1_enable=\"1\"")) {
86                         ipCameraHandler.setChannelState(CHANNEL_ENABLE_MOTION_ALARM, OnOffType.ON);
87                     } else {
88                         ipCameraHandler.setChannelState(CHANNEL_ENABLE_MOTION_ALARM, OnOffType.OFF);
89                     }
90                     break;
91                 case "/cgi-bin/hi3510/param.cgi?cmd=getaudioalarmattr":// Audio Alarm
92                     if (content.contains("var aa_enable=\"1\"")) {
93                         ipCameraHandler.setChannelState(CHANNEL_ENABLE_AUDIO_ALARM, OnOffType.ON);
94                         value1 = Helper.searchString(content, "var aa_value=\"");
95                         if (!value1.isEmpty()) {
96                             ipCameraHandler.setChannelState(CHANNEL_THRESHOLD_AUDIO_ALARM, PercentType.valueOf(value1));
97                         }
98                     } else {
99                         ipCameraHandler.setChannelState(CHANNEL_ENABLE_AUDIO_ALARM, OnOffType.OFF);
100                     }
101                     break;
102                 case "param.cgi?cmd=getpirattr":// PIR Alarm
103                     if (content.contains("var pir_enable=\"1\"")) {
104                         ipCameraHandler.setChannelState(CHANNEL_ENABLE_PIR_ALARM, OnOffType.ON);
105                     } else {
106                         ipCameraHandler.setChannelState(CHANNEL_ENABLE_PIR_ALARM, OnOffType.OFF);
107                     }
108                     // Reset the Alarm, need to find better place to put this.
109                     ipCameraHandler.noMotionDetected(CHANNEL_PIR_ALARM);
110                     break;
111                 case "/param.cgi?cmd=getioattr":// External Alarm Input
112                     if (content.contains("var io_enable=\"1\"")) {
113                         ipCameraHandler.setChannelState(CHANNEL_ENABLE_EXTERNAL_ALARM_INPUT, OnOffType.ON);
114                     } else {
115                         ipCameraHandler.setChannelState(CHANNEL_ENABLE_EXTERNAL_ALARM_INPUT, OnOffType.OFF);
116                     }
117                     break;
118             }
119         } finally {
120             ReferenceCountUtil.release(msg);
121         }
122     }
123
124     // This handles the commands that come from the Openhab event bus.
125     public void handleCommand(ChannelUID channelUID, Command command) {
126         if (command instanceof RefreshType) {
127             switch (channelUID.getId()) {
128                 case CHANNEL_MOTION_ALARM:
129                     if (ipCameraHandler.cameraConfig.getServerPort() > 0) {
130                         ipCameraHandler.logger.info("Setting up the Alarm Server settings in the camera now");
131                         ipCameraHandler.sendHttpGET(
132                                 "/param.cgi?cmd=setmdalarm&-aname=server2&-switch=on&-interval=1&cmd=setalarmserverattr&-as_index=3&-as_server="
133                                         + ipCameraHandler.hostIp + "&-as_port="
134                                         + ipCameraHandler.cameraConfig.getServerPort()
135                                         + "&-as_path=/instar&-as_queryattr1=&-as_queryval1=&-as_queryattr2=&-as_queryval2=&-as_queryattr3=&-as_queryval3=&-as_activequery=1&-as_auth=0&-as_query1=0&-as_query2=0&-as_query3=0");
136                         return;
137                     }
138             }
139             return;
140         } // end of "REFRESH"
141         switch (channelUID.getId()) {
142             case CHANNEL_THRESHOLD_AUDIO_ALARM:
143                 int value = Math.round(Float.valueOf(command.toString()));
144                 if (value == 0) {
145                     ipCameraHandler.sendHttpGET("/cgi-bin/hi3510/param.cgi?cmd=setaudioalarmattr&-aa_enable=0");
146                 } else {
147                     ipCameraHandler.sendHttpGET("/cgi-bin/hi3510/param.cgi?cmd=setaudioalarmattr&-aa_enable=1");
148                     ipCameraHandler
149                             .sendHttpGET("/cgi-bin/hi3510/param.cgi?cmd=setaudioalarmattr&-aa_enable=1&-aa_value="
150                                     + command.toString());
151                 }
152                 return;
153             case CHANNEL_ENABLE_AUDIO_ALARM:
154                 if (OnOffType.ON.equals(command)) {
155                     ipCameraHandler.sendHttpGET("/cgi-bin/hi3510/param.cgi?cmd=setaudioalarmattr&-aa_enable=1");
156                 } else {
157                     ipCameraHandler.sendHttpGET("/cgi-bin/hi3510/param.cgi?cmd=setaudioalarmattr&-aa_enable=0");
158                 }
159                 return;
160             case CHANNEL_ENABLE_MOTION_ALARM:
161                 if (OnOffType.ON.equals(command)) {
162                     ipCameraHandler.sendHttpGET(
163                             "/cgi-bin/hi3510/param.cgi?cmd=setmdattr&-enable=1&-name=1&cmd=setmdattr&-enable=1&-name=2&cmd=setmdattr&-enable=1&-name=3&cmd=setmdattr&-enable=1&-name=4");
164                 } else {
165                     ipCameraHandler.sendHttpGET(
166                             "/cgi-bin/hi3510/param.cgi?cmd=setmdattr&-enable=0&-name=1&cmd=setmdattr&-enable=0&-name=2&cmd=setmdattr&-enable=0&-name=3&cmd=setmdattr&-enable=0&-name=4");
167                 }
168                 return;
169             case CHANNEL_TEXT_OVERLAY:
170                 String text = Helper.encodeSpecialChars(command.toString());
171                 if (text.isEmpty()) {
172                     ipCameraHandler.sendHttpGET("/param.cgi?cmd=setoverlayattr&-region=1&-show=0");
173                 } else {
174                     ipCameraHandler.sendHttpGET("/param.cgi?cmd=setoverlayattr&-region=1&-show=1&-name=" + text);
175                 }
176                 return;
177             case CHANNEL_AUTO_LED:
178                 if (OnOffType.ON.equals(command)) {
179                     ipCameraHandler.sendHttpGET("/param.cgi?cmd=setinfrared&-infraredstat=auto");
180                 } else {
181                     ipCameraHandler.sendHttpGET("/param.cgi?cmd=setinfrared&-infraredstat=close");
182                 }
183                 return;
184             case CHANNEL_ENABLE_PIR_ALARM:
185                 if (OnOffType.ON.equals(command)) {
186                     ipCameraHandler.sendHttpGET("/param.cgi?cmd=setpirattr&-pir_enable=1");
187                 } else {
188                     ipCameraHandler.sendHttpGET("/param.cgi?cmd=setpirattr&-pir_enable=0");
189                 }
190                 return;
191             case CHANNEL_ENABLE_EXTERNAL_ALARM_INPUT:
192                 if (OnOffType.ON.equals(command)) {
193                     ipCameraHandler.sendHttpGET("/param.cgi?cmd=setioattr&-io_enable=1");
194                 } else {
195                     ipCameraHandler.sendHttpGET("/param.cgi?cmd=setioattr&-io_enable=0");
196                 }
197                 return;
198         }
199     }
200
201     void alarmTriggered(String alarm) {
202         ipCameraHandler.logger.debug("Alarm has been triggered:{}", alarm);
203         switch (alarm) {
204             case "/instar?&active=1":// The motion area boxes 1-4
205             case "/instar?&active=2":
206             case "/instar?&active=3":
207             case "/instar?&active=4":
208                 ipCameraHandler.motionDetected(CHANNEL_MOTION_ALARM);
209                 break;
210             case "/instar?&active=5":// PIR
211                 ipCameraHandler.motionDetected(CHANNEL_PIR_ALARM);
212                 break;
213             case "/instar?&active=6":// Audio Alarm
214                 ipCameraHandler.audioDetected();
215                 break;
216             case "/instar?&active=7":// Motion Area 1
217             case "/instar?&active=8":// Motion Area 2
218             case "/instar?&active=9":// Motion Area 3
219             case "/instar?&active=10":// Motion Area 4
220                 ipCameraHandler.motionDetected(CHANNEL_MOTION_ALARM);
221                 break;
222         }
223     }
224
225     // If a camera does not need to poll a request as often as snapshots, it can be
226     // added here. Binding steps through the list.
227     public ArrayList<String> getLowPriorityRequests() {
228         ArrayList<String> lowPriorityRequests = new ArrayList<String>(2);
229         lowPriorityRequests.add("/cgi-bin/hi3510/param.cgi?cmd=getaudioalarmattr");
230         lowPriorityRequests.add("/cgi-bin/hi3510/param.cgi?cmd=getmdattr");
231         lowPriorityRequests.add("/param.cgi?cmd=getinfrared");
232         lowPriorityRequests.add("/param.cgi?cmd=getoverlayattr&-region=1");
233         lowPriorityRequests.add("/param.cgi?cmd=getpirattr");
234         lowPriorityRequests.add("/param.cgi?cmd=getioattr"); // ext alarm input on/off
235         // lowPriorityRequests.add("/param.cgi?cmd=getserverinfo");
236         return lowPriorityRequests;
237     }
238 }