ungleich-public
/
lorawan
6
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Cleanup #2

This commit is contained in:
Nico Schottelius 2016-10-22 22:42:00 +02:00
parent 90bf72872b
commit 92edc34c37
19 changed files with 0 additions and 657 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
basic_sodaq_one/Sodaq_RN2483.cpp
View File

@ -1 +0,0 @@
../Sodaq_RN2483.cpp

1
basic_sodaq_one/Sodaq_RN2483.h
View File

@ -1 +0,0 @@
../Sodaq_RN2483.h

1
basic_sodaq_one/StringLiterals.h
View File

@ -1 +0,0 @@
../StringLiterals.h

1
basic_sodaq_one/Switchable_Device.cpp
View File

@ -1 +0,0 @@
../Switchable_Device.cpp

1
basic_sodaq_one/Switchable_Device.h
View File

@ -1 +0,0 @@
../Switchable_Device.h

1
basic_sodaq_one/Utils.h
View File

@ -1 +0,0 @@
../Utils.h

187
basic_sodaq_one/basic_sodaq_one.ino
View File

@ -1,187 +0,0 @@
#include "Sodaq_RN2483.h"
#include "Arduino.h"
#define debugSerial SerialUSB
#define loraSerial Serial1
/* The number of the device: 1,2,3,4 */
#define deviceNo 2
#define beePin ENABLE_PIN_IO
void BLUE() {
digitalWrite(LED_RED, HIGH);
digitalWrite(LED_GREEN, HIGH);
digitalWrite(LED_BLUE, LOW);
}
void RED() {
digitalWrite(LED_RED, LOW);
digitalWrite(LED_GREEN, HIGH);
digitalWrite(LED_BLUE, HIGH);
}
void YELLOW() {
digitalWrite(LED_RED, LOW);
digitalWrite(LED_GREEN, LOW);
digitalWrite(LED_BLUE, HIGH);
}
void WHITE() {
digitalWrite(LED_RED, LOW);
digitalWrite(LED_GREEN, LOW);
digitalWrite(LED_BLUE, LOW);
}
void GREEN() {
digitalWrite(LED_RED, HIGH);
digitalWrite(LED_GREEN, LOW);
digitalWrite(LED_BLUE, HIGH);
}
void CLEAR() {
digitalWrite(LED_RED, HIGH);
digitalWrite(LED_GREEN, HIGH);
digitalWrite(LED_BLUE, HIGH);
}
void blink(int length) {
switch(deviceNo) {
case 1:
BLUE();
break;
case 2:
RED();
break;
case 3:
GREEN();
break;
case 4:
WHITE();
break;
}
delay(length);
CLEAR();
}
void setupLED() {
pinMode(LED_RED, OUTPUT);
pinMode(LED_GREEN, OUTPUT);
pinMode(LED_BLUE, OUTPUT);
}
// OTAA
// Random numbers chosen + device id
uint8_t DevEUI[8] = { 0x9c, 0xd9, 0x0b, 0xb5, 0x2b, 0x6a, 0x1d,
deviceNo };
// 05 = dragino hat
// 9CD90BB52B6A1D05
// appeui 70B3D57ED0000E9B
/* Thingsnetwork */
// uint8_t AppEUI[8] = { 0x70, 0xB3, 0xD5, 0x7E, 0xD0, 0x00, 0x0E, 0x9B };
// uint8_t AppKey[16] = { 0xE4, 0xAC, 0x4D, 0xD4, 0xB2, 0xA7, 0x84,0xB8, 0x9D, 0xC9, 0x4C, 0x37, 0xD9, 0x0E, 0x22, 0x45 };
/* swisscom */
uint8_t AppEUI[8] = { 0xd4, 0x16, 0xcd, 0x0b, 0x7b, 0xcf, 0x2d, 0x5c };
uint8_t AppKey[16] = { 0xa9, 0xbc, 0x8b, 0x6a, 0x81, 0x75, 0xf6, 0x33, 0xe0, 0xd6, 0x64, 0xd9, 0x2b, 0xcb, 0x13, 0x78 };
void setupLoRaOTAA(){
if (LoRaBee.initOTA(loraSerial, DevEUI, AppEUI, AppKey, true))
{
debugSerial.println("Communication to LoRaBEE successful.");
}
else
{
debugSerial.println("OTAA Setup failed!");
}
}
void setup() {
//Power up the LoRaBEE - on loraone/sodaq one
pinMode(ENABLE_PIN_IO, OUTPUT); // ONE
digitalWrite(beePin, HIGH); // ONE
delay(3000);
while ((!SerialUSB) && (millis() < 10000)){
// Wait 10 seconds for the Serial Monitor
}
//Set baud rate
debugSerial.begin(57600);
loraSerial.begin(LoRaBee.getDefaultBaudRate());
setupLED();
blink(60);
//connect to the LoRa Network
setupLoRa();
}
void setupLoRa(){
setupLoRaOTAA();
}
void sendPacket(String packet){
switch (LoRaBee.sendReqAck(1, (uint8_t*)packet.c_str(), packet.length(), 8))
{
case NoError:
debugSerial.println("Successful transmission.");
break;
case NoResponse:
debugSerial.println("There was no response from the device.");
setupLoRa();
break;
case Timeout:
debugSerial.println("Connection timed-out. Check your serial connection to the device! Sleeping for 20sec.");
delay(20000);
break;
case PayloadSizeError:
debugSerial.println("The size of the payload is greater than allowed. Transmission failed!");
break;
case InternalError:
debugSerial.println("Oh No! This shouldn't happen. Something is really wrong! Try restarting the device!\r\nThe network connection will reset.");
setupLoRa();
break;
case Busy:
debugSerial.println("The device is busy. Sleeping for 10 extra seconds.");
delay(10000);
break;
case NetworkFatalError:
debugSerial.println("There is a non-recoverable error with the network connection. You should re-connect.\r\nThe network connection will reset.");
setupLoRa();
break;
case NotConnected:
debugSerial.println("The device is not connected to the network. Please connect to the network before attempting to send data.\r\nThe network connection will reset.");
setupLoRa();
break;
case NoAcknowledgment:
debugSerial.println("There was no acknowledgment sent back!");
// When you this message you are probaly out of range of the network.
break;
default:
break;
}
}
void loop() {
/* Announce begin of code */
blink(20); delay(50);
blink(20); delay(50);
blink(20); delay(50);
sendPacket("Hallo Welt");
blink(200);
delay(5000);
/* longer delay
for(int i=0; i < 60; i++) {
blink(100);
delay(1000);
} */
}

0
loriot-receiver.py → receiver/loriot-receiver.py
View File

0
sql → receiver/sql_schema_postgres
View File

0
swisscom-receive-packet.py → receiver/swisscom-receiver.py
View File

0
ttn-receiver.py → receiver/ttn-receiver.py
View File

1
thethingsnetwork/Sodaq_RN2483.cpp
View File

@ -1 +0,0 @@
../Sodaq_RN2483.cpp

1
thethingsnetwork/Sodaq_RN2483.h
View File

@ -1 +0,0 @@
../Sodaq_RN2483.h

1
thethingsnetwork/StringLiterals.h
View File

@ -1 +0,0 @@
../StringLiterals.h

1
thethingsnetwork/Switchable_Device.cpp
View File

@ -1 +0,0 @@
../Switchable_Device.cpp

1
thethingsnetwork/Switchable_Device.h
View File

@ -1 +0,0 @@
../Switchable_Device.h

1
thethingsnetwork/Utils.h
View File

@ -1 +0,0 @@
../Utils.h

361
thethingsnetwork/thethingsnetwork.ino
View File

@ -1,361 +0,0 @@
#include "Sodaq_RN2483.h"
#include "Arduino.h"
#define debugSerial SerialUSB
#define loraSerial Serial1
/* The number of the device: 1,2,3,4 */
#define deviceNo 2
#define beePin ENABLE_PIN_IO
#define LOUDNESS_SENSOR 0
#define LIGHT_SENSOR 2
#define WATER_SENSOR 6
#define BUZZER 8
#define MAGNETIC_SWITCH 12
#define TEMPERATURE 13
int loudness;
void BLUE() {
digitalWrite(LED_RED, HIGH);
digitalWrite(LED_GREEN, HIGH);
digitalWrite(LED_BLUE, LOW);
}
void RED() {
digitalWrite(LED_RED, LOW);
digitalWrite(LED_GREEN, HIGH);
digitalWrite(LED_BLUE, HIGH);
}
void YELLOW() {
digitalWrite(LED_RED, LOW);
digitalWrite(LED_GREEN, LOW);
digitalWrite(LED_BLUE, HIGH);
}
void WHITE() {
digitalWrite(LED_RED, LOW);
digitalWrite(LED_GREEN, LOW);
digitalWrite(LED_BLUE, LOW);
}
void GREEN() {
digitalWrite(LED_RED, HIGH);
digitalWrite(LED_GREEN, LOW);
digitalWrite(LED_BLUE, HIGH);
}
void CLEAR() {
digitalWrite(LED_RED, HIGH);
digitalWrite(LED_GREEN, HIGH);
digitalWrite(LED_BLUE, HIGH);
}
void blink(int length) {
switch(deviceNo) {
case 1:
BLUE();
break;
case 2:
RED();
break;
case 3:
GREEN();
break;
case 4:
WHITE();
break;
}
delay(length);
CLEAR();
}
void beep(int howlong) {
buzzOn();
delay(howlong);
buzzOff();
}
void buzzOn() {
digitalWrite(BUZZER, HIGH);
}
void buzzOff() {
digitalWrite(BUZZER, LOW);
}
void setupLED() {
pinMode(LED_RED, OUTPUT);
pinMode(LED_GREEN, OUTPUT);
pinMode(LED_BLUE, OUTPUT);
}
uint8_t DevEUI[8] = { 0x9c, 0xd9, 0x0b, 0xb5, 0x2b, 0x6a, 0x1d, deviceNo };
// TTN
uint8_t AppEUI[8] = { 0x70, 0xB3, 0xD5, 0x7E, 0xD0, 0x00, 0x0E, 0x9e };
// F1B165CF06B156B0BB6970FC209602EA
uint8_t AppKey[16] = { 0xF1, 0xB1, 0x65, 0xCF,
0x06, 0xB1, 0x56, 0xB0, 0xBB,
0x69, 0x70, 0xFC, 0x20, 0x96,
0x02, 0xEA };
uint8_t counter;
void setupLoRaOTAA(){
if (LoRaBee.initOTA(loraSerial, DevEUI, AppEUI, AppKey, true))
{
debugSerial.println("Communication to LoRaBEE successful.");
}
else
{
debugSerial.println("OTAA Setup failed!");
}
}
int setupLoudness()
{
loudness = 0;
// pinMode(LOUDNESS_SENSOR, INPUT);
}
int readLoudness()
{
return analogRead(LOUDNESS_SENSOR);
}
int readLight()
{
int sensorValue = analogRead(LIGHT_SENSOR);
return map(sensorValue, 11, 27333, 0, 413);
}
void setupWater() {
pinMode(WATER_SENSOR, INPUT);
}
boolean hasWater()
{
if(digitalRead(WATER_SENSOR) == LOW) {
return true;
} else {
return false;
}
}
void setupTemp() {
pinMode(TEMPERATURE, INPUT);
}
float readTemp()
{
float temperature;
int B=4250; //B value of the thermistor
float resistance;
int a;
a=analogRead(TEMPERATURE);
resistance=(float)(1023-a)*10000/a; //get the resistance of the sensor;
temperature=1/(log(resistance/10000)/B+1/298.15)-273.15;//convert to temperature via datasheet&nbsp;;
return temperature;
}
void setupBuzzer()
{
pinMode(BUZZER, OUTPUT);
}
void setupMagnet()
{
pinMode(MAGNETIC_SWITCH, INPUT);
}
boolean isMagnetic()
{
if(digitalRead(MAGNETIC_SWITCH) == HIGH)
return true;
else
return false;
}
void setup() {
//Power up the LoRaBEE - on loraone/sodaq one
pinMode(ENABLE_PIN_IO, OUTPUT); // ONE
digitalWrite(beePin, HIGH); // ONE
delay(3000);
/* Enable the pins 2/3, 6/7 and 8/9 */
pinMode(11, OUTPUT);
digitalWrite(11, HIGH);
while ((!SerialUSB) && (millis() < 10000)){
// Wait 10 seconds for the Serial Monitor
}
//Set baud rate
debugSerial.begin(57600);
loraSerial.begin(LoRaBee.getDefaultBaudRate());
// Debug output from LoRaBee
// LoRaBee.setDiag(debugSerial); // optional
setupLED();
blink(60);
/* used for blinking */
counter=0;
setupLoudness();
//connect to the LoRa Network
setupLoRa();
/* setupWater();
setupBuzzer();
setupMagnet(); */
}
void setupLoRa(){
setupLoRaOTAA();
}
void sendPacket(String packet){
switch (LoRaBee.sendReqAck(1, (uint8_t*)packet.c_str(), packet.length(), 8))
{
case NoError:
debugSerial.println("Successful transmission.");
break;
case NoResponse:
debugSerial.println("There was no response from the device.");
setupLoRa();
break;
case Timeout:
debugSerial.println("Connection timed-out. Check your serial connection to the device! Sleeping for 20sec.");
delay(20000);
break;
case PayloadSizeError:
debugSerial.println("The size of the payload is greater than allowed. Transmission failed!");
break;
case InternalError:
debugSerial.println("Oh No! This shouldn't happen. Something is really wrong! Try restarting the device!\r\nThe network connection will reset.");
setupLoRa();
break;
case Busy:
debugSerial.println("The device is busy. Sleeping for 10 extra seconds.");
delay(10000);
break;
case NetworkFatalError:
debugSerial.println("There is a non-recoverable error with the network connection. You should re-connect.\r\nThe network connection will reset.");
setupLoRa();
break;
case NotConnected:
debugSerial.println("The device is not connected to the network. Please connect to the network before attempting to send data.\r\nThe network connection will reset.");
setupLoRa();
break;
case NoAcknowledgment:
debugSerial.println("There was no acknowledgment sent back!");
// When you this message you are probaly out of range of the network.
break;
default:
break;
}
}
void loop() {
/* Announce begin of code */
blink(20); delay(50);
blink(20); delay(50);
blink(20); delay(50);
loudness = readLoudness();
String data_loudness = String("loudness=" + String(loudness, DEC));
debugSerial.println(data_loudness);
/* String data_light = String("light=" + String(readLight(), 3));
debugSerial.println(data_light); */
/* String data_temp = String("temp=" + String(readTemp(), 3));
debugSerial.println(data_temp);*/
/*
String data_water;
if(hasWater()) {
data_water = String("water=1");
buzzOn();
} else {
data_water = String("water=0");
buzzOff();
}
debugSerial.println(data_water);
String data_magnet;
if(isMagnetic()) {
data_magnet = String("magnet=1");
} else {
data_magnet = String("magnet=0");
}
debugSerial.println(data_magnet);
*/
int wait = 10000;
debugSerial.println(String("wait=" + String(wait)));
sendPacket(data_loudness);
blink(20); delay(wait);
/*sendPacket(data_temp);
blink(20); delay(2980);
sendPacket(data_light);
blink(20); delay(2980);
sendPacket(data_water);
blink(20); delay(2980);
sendPacket(data_magnet);*/
/* Blink long after sending packet
if(counter >= 10) {
// Beep(20);
blink(20);
delay(10);
blink(20);
sendPacket(data_temp);
blink(500);
sendPacket(data_loudness);
blink(500);
sendPacket(data_light);
blink(500);
sendPacket(data_water);
blink(500);
sendPacket(data_magnet);
counter = 0;
} else {
blink(30);
counter++;
}
*/
// delay(1000);
}

97
web-to-db.py
View File

@ -1,97 +0,0 @@
#!/usr/bin/env python3
import urllib
import psycopg2
import websocket
import xml.etree.ElementTree as ET
from http.server import BaseHTTPRequestHandler, HTTPServer
import re
# HTTPRequestHandler class
class testHTTPServer_RequestHandler(BaseHTTPRequestHandler):
# not used, just a sample
def do_GET(self):
# Send response status code
self.send_response(200)
# Send headers
self.send_header('Content-type','text/html')
self.end_headers()
# Send message back to client
message = "Hello world!"
# Write content as utf-8 data
self.wfile.write(bytes(message, "utf8"))
return
def do_POST(self):
length = int(self.headers['Content-Length'])
post_data = self.rfile.read(length).decode('utf-8')
# Print on stdout
print(post_data)
# And insert into the db
self.insert_xml(post_data)
# Send to Martin / port 8001
# Sendo to dashboard
self.to_dashboard(post_data)
def to_dashboard(self, data):
dev = self.devEUI(data)
text = self.payload(data)
ws = websocket.create_connection("wss://home-safety-visual.eu-gb.mybluemix.net/data")
ws.send("%s" % data)
ws.close()
ws = websocket.create_connection("wss://home-safety-visual.eu-gb.mybluemix.net/rawmessage")
ws.send("%s:%s" % (dev, text))
ws.close()
# Working lora node
if dev == "9CD90BB52B6A1D01":
try:
key, value = text.split("=")
print("Trying to send: %s:%s" % (key, value))
ws = websocket.create_connection("wss://home-safety-visual.eu-gb.mybluemix.net/%s" % (key))
ws.send("%s" % (value))
ws.close()
except ValueError:
print("Cannot split: %s" % (text))
def devEUI(self, data):
root = ET.fromstring(data)
return root[1].text
def payload_hex(self, data):
root = ET.fromstring(data)
return root[7].text
def payload(self, data):
myhex = self.payload_hex(data)
return bytes.fromhex(myhex).decode('utf-8')
def insert_xml(self, data):
try:
conn = psycopg2.connect("dbname=hackzurich")
cursor = conn.cursor()
cursor.execute("insert into data (packet) values (%s)", (data, ))
cursor.connection.commit()
conn.close()
except Exception as e:
print("DB Insert failed: %s" % e)
if __name__ == '__main__':
server_address = ('0.0.0.0', 8000)
httpd = HTTPServer(server_address, testHTTPServer_RequestHandler)
print('running server...')
httpd.serve_forever()