In this project you will see how to automate various gadgets of your home and room. You will be able to control the lights, fan, air conditioning, curtains, locks and TV. Both from Amazon Alexa and Mobile Phone (without using any Android or IOS app).
########################################################
# /etc/lirc/hardware.conf
#
# Arguments which will be used when launching lircd
LIRCD_ARGS="--uinput"
# Don't start lircmd even if there seems to be a good config file
# START_LIRCMD=false
# Don't start irexec, even if a good config file seems to exist.
# START_IREXEC=false
# Try to load appropriate kernel modules
LOAD_MODULES=true
# Run "lircd --driver=help" for a list of supported drivers.
DRIVER="default"
# usually /dev/lirc0 is the correct setting for systems using udev
DEVICE="/dev/lirc0"
MODULES="lirc_rpi"
# Default configuration files for your hardware if any
LIRCD_CONF=""
LIRCMD_CONF=""
########################################################
Edit your /boot/config.txt file and add:
dtoverlay=lirc-rpi,gpio_in_pin=23,gpio_out_pin=22
Goto www.lirc.org website download the configuration of the device and model you need to automate just like I have got for my Samsung TV
begin remote
name samsung
bits 16
flags SPACE_ENC|CONST_LENGTH
eps 30
aeps 100
header 4511 4553
one 505 1734
zero 505 614
ptrail 505
pre_data_bits 16
pre_data 0xE0E0
gap 107878
min_repeat 1
# suppress_repeat 1
# uncomment to suppress unwanted repeats
toggle_bit_mask 0x0
begin codes
KEY_POWER 0x40BF
KEY_TUNER 0x807F
KEY_MUTE 0xF00F
KEY_VOLUMEUP 0xE01F
KEY_VOLUMEDOWN 0xD02F
KEY_SELECT 0x16E9
KEY_UP 0x06F9
KEY_DOWN 0x8679
KEY_LEFT 0xA659
KEY_RIGHT 0x46B9
end codes
end remote
Add the the configutration in /etc/lirc/lircd.conf
Reboot
Once rebooted you can check the IR simulation with following command on the terminal by pointing the IR to the device.
irsend send_once samsung KEY_POWER
Setup the Wifi and connect to your home router. Please note you will require internet on the Raspberry and the router should not block the port that you have setup on your cloud server. On cloud server create a server socket program (java program provided in the code section) that accepts the connection from raspberry pi and also performs the CGI interface for Lambda function for the Alexa Smart Home Skill.
The Java code in code section for client is method by which the Raspberry PI mediates (acts as hub) between the Gadgets and Server.
In the JAVA code we are reading a parameter file which looks like this
Now you are ready to code for NodeMCU depending on the module you are using.
Door Lock Controls
I have used a electromagnetic lock for this purpose. You can use any other mechanism such a solenoid. The only difference is that the code is to be modified so that the door does not remain open for more than 8-10 seconds and closes automatically.
The following code explains how it is handled.
if (server.argName(i) == "out4") { // LOCK OUTPUT
if (server.arg(i) == "0") {
digitalWrite(out4, LOW);
status = status + " 4=OFF";
state4 = 0;
unlockedtime = millis(); // time variable is set when the door is unlocked
} else {
digitalWrite(out4, HIGH);
status = status + " 4=ON";
state4 = 1;
}
EEPROM.write(4, state4);
}
And in the loop section modify to following
if (millis() - unlockedtime > 8000) {
digitalWrite(out4, HIGH); // THIS IS LOCKED AUTOMATICALLY AFTER 8 SECONDS
}
Door Lock System Using Electromagnetic Lock
AC and Thermostat Control
For Thermostat we have used
Node MCU
SSD 1306 oled display
APDS 9960 Gesture Sensor
DS18B20 Temperature Sensor
The connections are as follows as we will be using the Adafruit Library for oled display and Sparkfun Library for Gesture Sensing
importjava.io.BufferedReader;importjava.io.InputStream;importjava.io.InputStreamReader;importjava.io.OutputStream;importjava.net.HttpURLConnection;importjava.net.Socket;importjava.net.URL;importjava.util.Timer;importjava.util.TimerTask;publicclassAlexaClient{finalopeningPagepage;AlexaClient(finalopeningPagepage){this.page=page;Timertimer=newTimer();timer.schedule(newloop(),500,60000);}privateclassloopextendsTimerTask{@Overridepublicvoidrun(){try{Socketclient=newSocket("yourserveroncloud",54321);System.out.println("Connected To yourserveroncloud");InputStreamis=client.getInputStream();OutputStreamos=client.getOutputStream();os.write(license.getBytes());os.flush();byte[]bytes=newbyte[64];client.setKeepAlive(true);client.setSoTimeout(60000);intnumberOfBytes=0;try{while(true){try{numberOfBytes=is.read(bytes);}catch(Exceptionre){numberOfBytes=0;}if(numberOfBytes<1){try{os.write("OM".getBytes());continue;}catch(Exceptionoe){oe.printStackTrace();break;}}else{Stringcmd=newString(bytes,0,numberOfBytes);System.out.println(cmd);processCommand("cmd="+cmd);}}os.close();is.close();client.close();}catch(Exceptionex){ex.printStackTrace();try{os.close();is.close();client.close();}catch(Exceptione){}}}catch(Exceptionex){ex.printStackTrace();}}}privateStringprocessCommand(Stringquery){try{inti=query.indexOf("cmd=");if(i>=0){if(query.indexOf("&")>i){page.pageEvent(query.substring(i+4,query.indexOf("&")));}else{page.pageEvent(query.substring(i+4));}}}catch(Exceptione){// TODO Auto-generated catch blocke.printStackTrace();}returnpage.currentApp;}}
As the drwopdown does not have Node.JS I have mentioned Language and Javascript
var https= require('https');exports.handler =function(request, context){ log("DEGUG:", "Request ", JSON.stringify(request)); log("DEGUG:", "Context ", JSON.stringify(context));if(request.directive.header.namespace ==='Alexa.Discovery'&& request.directive.header.name ==='Discover'){ handleDiscovery(request, context, "");}elseif(request.directive.header.namespace ==='Alexa.PowerController'){if(request.directive.header.name ==='TurnOn'|| request.directive.header.name ==='TurnOff'){ handlePowerControl(request, context);}}elseif(request.directive.header.namespace ==='Alexa.LockController'){if(request.directive.header.name ==='Lock'|| request.directive.header.name ==='Unlock'){ handleLockControl(request, context);}}elseif(request.directive.header.namespace ==='Alexa.Speaker'){if(request.directive.header.name ==='SetMute'){ handleVolumeControl(request, context);}}elseif(request.directive.header.namespace ==='Alexa.InputController'){if(request.directive.header.name ==='SelectInput'){ handleInputControl(request, context);}}elseif(request.directive.header.namespace ==='Alexa.ChannelController'){if(request.directive.header.name ==='ChangeChannel'){ handleChannelControl(request, context);}}elseif(request.directive.header.namespace ==='Alexa.ThermostatController'){if(request.directive.header.name ==='SetTargetTemperature'){ handleThermostatControl(request, context);}}function handleDiscovery(request, context){ var requestToken= request.directive.payload.scope.token; getJsonRequest("getdevices=" + requestToken, function(data){ var payload= data; var header= request.directive.header; header.name ="Discover.Response"; log("DEBUG", "Discovery Response: ", JSON.stringify({ header: header, payload: payload })); context.succeed({ event: { header: header, payload: payload }});});}function log(message, message1, message2){ console.log(message + message1 + message2);}function handlePowerControl(request, context){ var requestMethod= request.directive.header.name; // get user token pass in request
var requestToken= request.directive.endpoint.scope.token; var endpointId= request.directive.endpoint.endpointId; var powerResult="NONE";if(requestMethod==="TurnOn"){ // Make the call to your device cloud for control
// powerResult= stubControlFunctionToYourCloud(endpointId, token, request);powerResult="ON";}elseif(requestMethod==="TurnOff"){ // Make the call to your device cloud for control and check for success
// powerResult= stubControlFunctionToYourCloud(endpointId, token, request);powerResult="OFF";} var contextResult={"properties": [{"namespace": "Alexa.PowerController",
"name": "powerState",
"value": powerResult,
"timeOfSample": getUTCTimeStamp(), //retrieve from result.
"uncertaintyInMilliseconds": 500}]}; var responseHeader= request.directive.header; responseHeader.namespace ="Alexa"; responseHeader.name ="Response"; //responseHeader.messageId = responseHeader.messageId + "-R"; var responseEndpoint= request.directive.endpoint; var response={ context: contextResult,
event: { header: responseHeader
},
endpoint : responseEndpoint,
payload: {}}; getJsonRequest("access_token=" + requestToken + "&endpointId=" + endpointId + "&state=" + powerResult, function(data){ context.succeed(response);}); log("DEBUG", "Alexa.PowerController ", JSON.stringify(response));}function handleLockControl(request, context){ var requestMethod= request.directive.header.name; // get user token pass in request
var requestToken= request.directive.endpoint.scope.token; var endpointId= request.directive.endpoint.endpointId; var lockResult="JAMMED";if(requestMethod==="Lock"){ // Make the call to your device cloud for control
// powerResult= stubControlFunctionToYourCloud(endpointId, token, request);lockResult="LOCKED";}elseif(requestMethod==="Unlock"){ // Make the call to your device cloud for control and check for success
// powerResult= stubControlFunctionToYourCloud(endpointId, token, request);lockResult="UNLOCKED";} var contextResult={"properties": [{"namespace": "Alexa.LockController",
"name": "lockState",
"value": lockResult,
"timeOfSample": getUTCTimeStamp(), //retrieve from result.
"uncertaintyInMilliseconds": 500}]}; var responseHeader= request.directive.header; responseHeader.namespace ="Alexa"; responseHeader.name ="Response"; //responseHeader.messageId = responseHeader.messageId + "-R"; var responseEndpoint= request.directive.endpoint; var response={ context: contextResult,
event: { header: responseHeader
},
endpoint : responseEndpoint,
payload: {}}; var stateResult="ON";if(lockResult=="UNLOCKED"){stateResult="OFF";} getJsonRequest("access_token=" + requestToken + "&endpointId=" + endpointId + "&state=" + stateResult, function(data){ context.succeed(response);}); log("DEBUG", "Alexa.LockController ", JSON.stringify(response));}function handleVolumeControl(request, context){ var requestMethod= request.directive.header.name; // get user token pass in request
var requestToken= request.directive.endpoint.scope.token; var endpointId= request.directive.endpoint.endpointId; var muteResult= request.directive.payload.mute; var contextResult={"properties": [{"namespace": "Alexa.Speaker",
"name": "muted",
"value": muteResult,
"timeOfSample": getUTCTimeStamp(), //retrieve from result.
"uncertaintyInMilliseconds": 500}]}; var responseHeader= request.directive.header; responseHeader.namespace ="Alexa"; responseHeader.name ="Response"; //responseHeader.messageId = responseHeader.messageId + "-R"; var responseEndpoint= request.directive.endpoint; var response={ context: contextResult,
event: { header: responseHeader
},
endpoint : responseEndpoint,
payload: {}}; getJsonRequest("access_token=" + requestToken + "&endpointId=" + endpointId + "&state=tvmute", function(data){ context.succeed(response);}); log("DEBUG", "Alexa.Speaker ", JSON.stringify(response));}function handleInputControl(request, context){ var requestMethod= request.directive.header.name; // get user token pass in request
var requestToken= request.directive.endpoint.scope.token; var endpointId= request.directive.endpoint.endpointId; var inputResult= request.directive.payload.input; var contextResult={"properties": [{"namespace": "Alexa.InputController",
"name": "input",
"value": inputResult,
"timeOfSample": getUTCTimeStamp(), //retrieve from result.
"uncertaintyInMilliseconds": 500}]}; var responseHeader= request.directive.header; responseHeader.namespace ="Alexa"; responseHeader.name ="Response"; //responseHeader.messageId = responseHeader.messageId + "-R"; var responseEndpoint= request.directive.endpoint; var response={ context: contextResult,
event: { header: responseHeader
},
endpoint : responseEndpoint,
payload: {}}; var stateResult="tvprevious";if(inputResult=="AV"||inputResult=="SET TOP BOX"||inputResult=="AV"||inputResult=="CABLE"){stateResult="tvnext";} getJsonRequest("access_token=" + requestToken + "&endpointId=" + endpointId + "&state=" + stateResult, function(data){ context.succeed(response);}); log("DEBUG", "Alexa.InputController ", JSON.stringify(response));}function handleChannelControl(request, context){ var requestMethod= request.directive.header.name; // get user token pass in request
var requestToken= request.directive.endpoint.scope.token; var endpointId= request.directive.endpoint.endpointId; var channelResult= request.directive.payload.channel; var contextResult={"properties": [{"namespace": "Alexa.ChannelController",
"name": "channel",
"value": channelResult,
"timeOfSample": getUTCTimeStamp(), //retrieve from result.
"uncertaintyInMilliseconds": 500}]}; var responseHeader= request.directive.header; responseHeader.namespace ="Alexa"; responseHeader.name ="Response"; //responseHeader.messageId = responseHeader.messageId + "-R"; var responseEndpoint= request.directive.endpoint; var response={ context: contextResult,
event: { header: responseHeader
},
endpoint : responseEndpoint,
payload: {}}; var channel="";if(request.directive.payload.channelMetadata.name == undefined){channel= request.directive.payload.channel.number;}else{channel= request.directive.payload.channelMetadata.name;} getJsonRequest("access_token=" + requestToken + "&endpointId=" + endpointId + "&state=tvchannel_" + channel, function(data){ context.succeed(response);}); log("DEBUG", "Alexa.ChannelController ", JSON.stringify(response));}function handleThermostatControl(request, context){ var requestMethod= request.directive.header.name; // get user token pass in request
var requestToken= request.directive.endpoint.scope.token; var endpointId= request.directive.endpoint.endpointId; var thermostatResult= request.directive.payload.targetSetpoint; var contextResult={"properties": [{"namespace": "Alexa.ThermostatController",
"name": "targetSetpoint",
"value": thermostatResult,
"timeOfSample": getUTCTimeStamp(), //retrieve from result.
"uncertaintyInMilliseconds": 500}]}; var responseHeader= request.directive.header; responseHeader.namespace ="Alexa"; responseHeader.name ="Response"; //responseHeader.messageId = responseHeader.messageId + "-R"; var responseEndpoint= request.directive.endpoint; var response={ context: contextResult,
event: { header: responseHeader
},
endpoint : responseEndpoint,
payload: {}}; getJsonRequest("access_token=" + requestToken + "&endpointId=" + endpointId + "&state=setpoint_" + thermostatResult.value, function(data){ context.succeed(response);}); log("DEBUG", "Alexa.ThermostatController ", JSON.stringify(response));}function getUTCTimeStamp(){ var datetime= new Date().toISOString(); log("DEBUG", "UTC Date Time ", datetime);return datetime;}};var getJsonRequest=function(query, callback){ https.get("yourservercgiscript?" + query, function(res){ var body=''; res.on('data', function(data){body+= data;}); res.on('end', function(){ console.log("DEBUG", "Body ", body); var result= JSON.parse(body); callback(result);});}).on('error', function(e){ console.log('Error: ' + e);});};
HTTP JSON Server Code
Java
importjava.io.ByteArrayOutputStream;importjava.io.FileOutputStream;importjava.io.IOException;importjava.io.InputStream;importjava.io.OutputStream;importjava.net.InetSocketAddress;importjava.util.Arrays;importjava.util.concurrent.Executors;importcom.sun.net.httpserver.Headers;importcom.sun.net.httpserver.HttpExchange;importcom.sun.net.httpserver.HttpHandler;importcom.sun.net.httpserver.HttpServer;publicclassJSONServer{finalopeningPagepage;JSONServer(finalopeningPagepage){this.page=page;try{InetSocketAddressaddr=newInetSocketAddress(8081);HttpServerserver=HttpServer.create(addr,0);server.createContext("/",newJSONHandler());server.setExecutor(Executors.newCachedThreadPool());server.start();System.out.println("Server is listening on port 8081");}catch(Exceptione){e.printStackTrace();}}privateclassJSONHandlerimplementsHttpHandler{@Overridepublicvoidhandle(HttpExchangeexchange)throwsIOException{call(exchange);}privatesynchronizedvoidcall(HttpExchangeexchange){newThread(newJSONRunnable(exchange)).start();}}privateclassJSONRunnableimplementsRunnable{protectedHttpExchangeexchange=null;publicJSONRunnable(HttpExchangeexchange){this.exchange=exchange;}@Overridepublicvoidrun(){try{HeadersresponseHeaders=exchange.getResponseHeaders();OutputStreamresponseBody=exchange.getResponseBody();Stringuri=exchange.getRequestURI().toString();if(exchange.getRequestMethod().equals("POST")){HeadersrequestHeaders=exchange.getRequestHeaders();System.out.println(requestHeaders.getFirst("Content-Type"));Stringboundary=requestHeaders.getFirst("Content-Type").replaceAll("multipart/form-data; boundary=","");System.out.println(boundary);InputStreamis=exchange.getRequestBody();byte[]data=getInputAsBinary(is);is.close();StringstringData=newString(data);intstart=stringData.indexOf(boundary);start=stringData.indexOf('\r',start+1);start=stringData.indexOf('\r',start+1);start=stringData.indexOf('\r',start+1);start=stringData.indexOf('\r',start+1)+2;intend=stringData.indexOf(boundary,start);for(inti=end;i<data.length;++i){byte[]compare=Arrays.copyOfRange(data,end,end+boundary.length());System.out.println(newString(compare));if(Arrays.equals(compare,boundary.getBytes())){break;}++end;}end-=4;System.out.println(end-start);ByteArrayOutputStreambos=newByteArrayOutputStream();bos.write(data,start,end-start);FileOutputStreamfos=newFileOutputStream("hycan.png");fos.write(bos.toByteArray());fos.close();//System.out.print(stringData.substring(start, end));exchange.sendResponseHeaders(200,0);responseHeaders.set("Content-Type","text/html");responseBody.write("OK".getBytes());responseBody.close();return;}if(uri.indexOf("?")<0){Stringresource=uri.replaceAll("/","");if(resource.equals(""))resource="index.html";if(resource.equals("conf"))resource="conf.html";exchange.sendResponseHeaders(200,0);try{InputStreamin=JSONServer.class.getResourceAsStream("/resources/"+resource);if(in==null){responseHeaders.set("Content-Type","text/html");responseBody.write(resource.getBytes());responseBody.close();return;}ByteArrayOutputStreamfileBytes=newByteArrayOutputStream();byte[]buffer=newbyte[4096];intnread=0;while((nread=in.read(buffer))!=-1){fileBytes.write(buffer,0,nread);}if(resource.endsWith(".htm")||resource.endsWith(".html")){responseHeaders.set("Content-Type","text/html");}elseif(resource.endsWith(".js")){responseHeaders.set("Content-Type","text/javascript");}elseif(resource.endsWith(".css")){responseHeaders.set("Content-Type","text/css");}elseif(resource.endsWith(".ico")){responseHeaders.set("Content-Type","image/ico");}elseif(resource.endsWith(".png")){responseHeaders.set("Content-Type","image/png");}elseif(resource.endsWith(".jpg")){responseHeaders.set("Content-Type","image/jpg");}elseif(resource.endsWith(".jpeg")){responseHeaders.set("Content-Type","image/jpg");}else{responseHeaders.set("Content-Type","text/plain");}responseBody.write(fileBytes.toByteArray());fileBytes.close();in.close();responseBody.close();}catch(Exceptione){responseHeaders.set("Content-Type","text/html");responseBody.write(resource.getBytes());responseBody.close();e.printStackTrace();}return;}Stringquery=exchange.getRequestURI().getQuery();if(query==null){exchange.sendResponseHeaders(200,0);responseHeaders.set("Content-Type","text/html");responseBody.write("OK".getBytes());responseBody.close();return;}System.out.println(query);Stringapp=processCommand(query);inti=query.indexOf("callback=");if(i>=0){i+=9;intj=query.indexOf("&",i);Stringcallback="";if(j>i)callback=query.substring(i,j);exchange.sendResponseHeaders(200,0);responseHeaders.set("Content-Type","text/json");responseBody.write((callback+"({\"result\" : \""+app+"\"});").getBytes());responseBody.close();}else{exchange.sendResponseHeaders(200,0);responseHeaders.set("Content-Type","text/html");responseBody.write("OK".getBytes());responseBody.close();}}catch(Exceptione){// TODO Auto-generated catch blocke.printStackTrace();}}privateStringprocessCommand(Stringquery){Stringresult="OK";try{inti=query.indexOf("cmd=");if(i>=0){if(query.indexOf("&")>i){result=page.pageEvent(query.substring(i+4,query.indexOf("&")));}else{result=page.pageEvent(query.substring(i+4));}}if(query.startsWith("kc_")){query=query.replaceAll("&","*");query=query.replaceAll("=",":");System.out.println(query);result=page.pageEvent(query);}}catch(Exceptione){// TODO Auto-generated catch blocke.printStackTrace();}returnresult;}}publicstaticbyte[]getInputAsBinary(InputStreamrequestStream){ByteArrayOutputStreambos=newByteArrayOutputStream();try{byte[]buf=newbyte[100000];intbytesRead=0;while((bytesRead=requestStream.read(buf))!=-1){bos.write(buf,0,bytesRead);}requestStream.close();bos.close();}catch(IOExceptione){e.printStackTrace();}returnbos.toByteArray();}}
/* A bit custom styling */body{background-color:black;color:white;margin-top:50px;}.block{border-radius:25px;border:2pxsolid#73AD21;padding:10px;margin-bottom:25px;}#tvvolumeup,#tvvolumedown{background:#fff2cc;background:-webkit-linear-gradient(#fff2cc,#ffd966);background:linear-gradient(#fff2cc,#ffd966);border:1pxsolid#7f6000;border-radius:1000px;width:72px;height:72px;color:#000000;display:inline-block;font:normal40015px/72px"Calibri",sans-serif;text-align:center;text-shadow:none;}#remoteup,#remotedown,#remotechannelup,#remotechanneldown,#remotevolumeup,#remotevolumedown,#webup,#webdown,#webback,#webforward{background:#fff2cc;background:-webkit-linear-gradient(#fff2cc,#ffd966);background:linear-gradient(#fff2cc,#ffd966);border:1pxsolid#7f6000;border-radius:1000px;width:72px;height:72px;color:#000000;display:inline-block;font:normal40015px/72px"Calibri",sans-serif;text-align:center;text-shadow:none;}#remote1,#remote2,#remote3,#remote4,#remote5,#remote6,#remote7,#remote8,#remote9,#remote0{background:#fff2cc;background:-webkit-linear-gradient(#fff2cc,#ffd966);background:linear-gradient(#fff2cc,#ffd966);border:1pxsolid#7f6000;border-radius:500px;width:54px;height:54px;color:#000000;display:inline-block;font:normal40015px/54px"Calibri",sans-serif;text-align:center;text-shadow:none;}#remotevolumeup,#remotevolumedown{float:left;background:#11ff11;background:-webkit-linear-gradient(#11cc11,#11ff1150%,#11cc11);background:linear-gradient(#11cc11,#11ff1150%,#11cc11);}#remotechannelup,#remotechanneldown{float:right;background:#11ff11;background:-webkit-linear-gradient(#11cc11,#11ff1150%,#11cc11);background:linear-gradient(#11cc11,#11ff1150%,#11cc11);}#remoteback,#tvmute,#select,#remoteok,#remoteguide,#close,#webrightclick,#webleftclick{background:#ffffff;background:-webkit-linear-gradient(#cccccc,#ffffff50%,#cccccc);background:linear-gradient(#cccccc,#ffffff50%,#cccccc);border:1pxsolid#7f6000;border-radius:1000px;width:110px;height:49px;color:#000000;display:inline-block;font:normal40015px/49px"Calibri",sans-serif;text-align:center;text-shadow:none;margin:1px;}#remoteback,#remoteguide{margin-top:10px;margin-bottom:10px;}#tvpower,#remotepower,#tvsource,#remotemute{background:#f4cccc;background:-webkit-linear-gradient(#e06666,#f4cccc50%,#e06666);background:linear-gradient(#e06666,#f4cccc50%,#e06666);border:1pxsolid#7f6000;border-radius:1000px;width:125px;height:49px;color:#000000;display:inline-block;font:normal40015px/49px"Calibri",sans-serif;text-align:center;word-break:break-alltext-shadow:none;margin:5px;}#tvsource,#remotemute{background:#ffffff;background:-webkit-linear-gradient(#cccccc,#ffffff50%,#cccccc);background:linear-gradient(#cccccc,#ffffff50%,#cccccc);float:right;}img{padding:5px;width:64px;height:64px;}input{border:2pxsolid#dadada;border-radius:7px;width:220px;height:40px;font-size:18px;}.input:focus{outline:none;border-color:#9ecaed;box-shadow:0010px#9ecaed;}.header{margin:auto;text-align:center;position:fixed;top:0;color:white;width:100%;font-family:Geneva,Tahoma,Verdana,sans-serif;font-size:12px;font-style:normal;font-variant:normal;font-weight:400;}.heading{margin:15px;text-align:left;color:white;font-family:Geneva,Tahoma,Verdana,sans-serif;font-size:24px;font-style:normal;font-variant:normal;font-weight:400;}#head{font-size:14px;}.center{margin:margin:0auto;text-align:center;}.clickable{cursor:pointer;}.withpadding{padding:10px;}.keypad{margin:margin:0auto;text-align:justify;font-size:0.1px;/* IE 9 & 10 don't like font-size: 0; *//*border: 2px solid white;*/display:inline-block;}.keypadlabel{background:#999999;background:-webkit-linear-gradient(#666666,#99999950%,#666666);background:linear-gradient(#666666,#99999950%,#666666);border-radius:3px;width:15px;heigth:50px;padding:10px5px;color:#ffffff;display:inline-block;font:normal40024px/1"Calibri",sans-serif;text-align:center;text-shadow:none;margin:4px;}.keypad:after{content:'';width:100%;/* Ensures there are at least 2 lines of text, so justification works */display:inline-block;}#keydel,#keycap{font:normal40020px/1"Calibri",sans-serif;width:32px;heigth:50px;background:#ffffff;background:-webkit-linear-gradient(#cccccc,#ffffff50%,#cccccc);background:linear-gradient(#cccccc,#ffffff50%,#cccccc);color:#000000;}#keyspace{width:96px;heigth:50px;background:#ffffff;background:-webkit-linear-gradient(#cccccc,#ffffff50%,#cccccc);background:linear-gradient(#cccccc,#ffffff50%,#cccccc);color:#000000;}#keyenter{width:76px;heigth:50px;background:#ffffff;background:-webkit-linear-gradient(#cccccc,#ffffff50%,#cccccc);background:linear-gradient(#cccccc,#ffffff50%,#cccccc);color:#000000;}#keyat{width:36px;heigth:50px;}.switch{background:#ffffff;background:-webkit-linear-gradient(#cccccc,#ffffff50%,#cccccc);background:linear-gradient(#cccccc,#ffffff50%,#cccccc);border:1pxsolid#7f6000;border-radius:1000px;width:100px;height:49px;color:#000000;display:inline-block;font:normal40015px/49px"Calibri",sans-serif;text-align:center;text-shadow:none;margin:1px;}
importjava.io.IOException;importjava.io.InputStream;importjava.io.OutputStream;importjava.net.InetSocketAddress;importjava.net.ServerSocket;importjava.net.Socket;importjava.net.SocketTimeoutException;importjava.util.ArrayList;importjava.util.Timer;importjava.util.TimerTask;importjava.util.concurrent.Executors;importcom.sun.net.httpserver.Headers;importcom.sun.net.httpserver.HttpExchange;importcom.sun.net.httpserver.HttpHandler;importcom.sun.net.httpserver.HttpServer;publicclassAlexaConnections{ServerSocketserver;resultusers;privateclasssockets{privateSocketclient;OutputStreamos;InputStreamis;sockets(Socketclient,Stringlicense,StringdeviceId){this.client=client;try{os=client.getOutputStream();is=client.getInputStream();}catch(IOExceptione){// TODO Auto-generated catch blocke.printStackTrace();}}publicbooleansendData(byte[]bytes){booleanresult=false;try{os.write(bytes);os.flush();result=true;}catch(IOExceptione){// TODO Auto-generated catch blocke.printStackTrace();}returnresult;}publicvoidclose(){try{System.out.println("Closing "+license);license="";os.close();is.close();client.close();}catch(Exceptionex){ex.printStackTrace();}}}privateclassJSONHandlerimplementsHttpHandler{@Overridepublicvoidhandle(HttpExchangeexchange)throwsIOException{call(exchange);}privatesynchronizedvoidcall(HttpExchangeexchange){System.out.println("Server received");newThread(newJSONRunnable(exchange)).start();}}privateclassJSONRunnableimplementsRunnable{protectedHttpExchangeexchange=null;publicJSONRunnable(HttpExchangeexchange){this.exchange=exchange;}@Overridepublicvoidrun(){try{StringrequestMethod=exchange.getRequestMethod();System.out.println(requestMethod);HeadersresponseHeaders=exchange.getResponseHeaders();OutputStreamresponseBody=exchange.getResponseBody();Stringuri=exchange.getRequestURI().toString();System.out.println(uri);Stringquery=exchange.getRequestURI().getQuery();if(query==null){exchange.sendResponseHeaders(200,0);responseHeaders.set("Content-Type","text/html");responseBody.write("OK".getBytes());responseBody.close();return;}System.out.println(query);processCommand(query);inti=query.indexOf("callback=");if(i>=0){i+=9;intj=query.indexOf("&",i);Stringcallback="";if(j>i)callback=query.substring(i,j);System.out.println(callback);exchange.sendResponseHeaders(200,0);responseHeaders.set("Content-Type","text/json");responseBody.write((callback+"({\"result\" : \"OK\"});").getBytes());responseBody.close();}else{exchange.sendResponseHeaders(200,0);responseHeaders.set("Content-Type","text/html");responseBody.write("OK".getBytes());responseBody.close();}}catch(Exceptione){// TODO Auto-generated catch blocke.printStackTrace();}}}privatevoidprocessCommand(Stringquery){try{inti=query.indexOf("addrs=");intj=query.indexOf("&");if(j<i||i<0){return;}Stringaddrs=query.substring(i+6,j);System.out.println(addrs+" "+addrs.length());i=query.indexOf("cmd=");if(i<j)return;Stringcmd=query.substring(i+4);System.out.println(cmd);for(j=0;j<socketList.size();++j){if(socketList.get(j).client.isClosed()){continue;}System.out.println("Sending "+cmdif(!socketList.get(j).sendData(cmd.getBytes())){socketList.get(j).close();}}}catch(Exceptione){// TODO Auto-generated catch blocke.printStackTrace();}}ArrayList<sockets>socketList;AlexaConnections(){socketList=newArrayList<sockets>();try{InetSocketAddressaddr=newInetSocketAddress(12345);HttpServerhttpserver=HttpServer.create(addr,0);httpserver.createContext("/",newJSONHandler());httpserver.setExecutor(Executors.newCachedThreadPool());httpserver.start();System.out.println("HTTP Server is listening on port 12345");server=newServerSocket(54321);}catch(IOExceptione1){// TODO Auto-generated catch blocke1.printStackTrace();}Timertimer=newTimer();timer.schedule(newTimerTask(){@Overridepublicvoidrun(){try{System.out.println("Waiting for connection");Socketclient=server.accept();System.out.println("Connected From "+client.getRemoteSocketAddress().toString());client.setSoTimeout(5000);InputStreamis=client.getInputStream();try{byte[]bytes=newbyte[256];intnumberOfBytes=is.read(bytes,0,256);System.out.println(numberOfBytes);if(numberOfBytes>0){Stringaddrs=newString(bytes,0,numberOfBytes);addrs=addrs.replaceAll("\r","");addrs=addrs.replaceAll("\n","");System.out.println(addrs);StringdeviceId="";socketList.add(newsockets(client,addrs,deviceId));}else{client.close();}}catch(Exceptione){e.printStackTrace();try{System.out.println("Closing Connection");is.close();client.close();}catch(Exceptionex){ex.printStackTrace();}}}catch(Exceptione){e.printStackTrace();}}},500,500);TimerstatusTimer=newTimer();statusTimer.schedule(newTimerTask(){@Overridepublicvoidrun(){for(intj=0;j<socketList.size();++j){if(socketList.get(j).client.isClosed()){continue;}try{byte[]bytes=newbyte[64];socketList.get(j).os.write("OM".getBytes());intnumberOfBytes=socketList.get(j).is.read(bytes);if(numberOfBytes>0){System.out.println("Received "+newString(bytes,0,numberOfBytes);}}catch(SocketTimeoutExceptionse){}catch(Exceptionex){ex.printStackTrace();socketList.get(j).close();}}}},500,60000);}}
_ztBMuBhMHo.jpg?auto=compress%2Cformat&w=48&h=48&fit=fill&bg=ffffff)
_1x_bGT19vVAby.png?auto=compress%2Cformat&w=40&h=40&fit=fillmax&bg=fff&dpr=2){kind=logo}
Comments