Completamento integrazione reader e webservice

This commit is contained in:
loviuz 2020-07-05 13:11:42 +02:00
parent cd5e7cfa30
commit 2c6761b6ff
5 changed files with 108 additions and 44 deletions

9
config.ini Executable file
View File

@ -0,0 +1,9 @@
[ws]
receiver_url = "http://localhost/wifi-probe-aggregator/ws/receiver.php"
reader_url = "http://localhost/wifi-probe-aggregator/ws/reader.php"
[database]
db_host = "localhost"
db_user = "root"
db_pass = "mysql"
db_name = "wpa"

View File

@ -4,9 +4,11 @@
* Script per simulare l'invio al web service di MAC address raccolti nelle vicinanze
*/
// Lettura file di configurazione
$config = parse_ini_file('../../config.ini');
// URL dell'endpoint che riceve i dati
$receiver_url = "http://localhost/wifi-probe-aggregator/ws/receiver.php";
$receiver_url = $config['receiver_url'];
// Lista di indirizzi MAC
$mac_addresses = [
@ -45,7 +47,7 @@ $ap = [
$post_data = [
"address" => $mac_addresses[ rand(0, sizeof($mac_addresses)-1) ],
"essid" => $ap[ rand(0, sizeof($ap)-1) ],
"signal" => rand(0, 100),
"signal" => rand(-30, -100),
"latitude" => 41.909986,
"longitude" => 12.3959152,
];

11
readers/whoishere.py/whoishere.conf Normal file → Executable file
View File

@ -1,7 +1,6 @@
{"config" : [{"interface": "wlan0mon"},
{"pushoverapitoken": ""},
{"pushoveruserkey": "" }],
"list" : [{"name": "James Clerk Maxwell", "mac": "00:co:ca:c0:79:fa", "color": "1"},
{"name": "Christian Hulsmeyer", "mac": "ba:ad:c0:de:88:ca", "color": "2"},
{"name": "Heinrich Hertz", "mac": "e0:0f:00:0a:d0:a0", "color": "3"}]
{"config" : [
{"interface": "wlan0mon"},
{"receiver_host": "localhost"},
{"receiver_url": "/wifi-probe-aggregator/ws/receiver.php" }],
"list" : []
}

41
readers/whoishere.py/whoishere.py Normal file → Executable file
View File

@ -22,11 +22,9 @@ def ConfigCheck():
file = open(filename, "w")
file.write('{'\
'"config" : [{"interface": "wlan0mon"},\n'\
' {"pushoverapitoken": ""},\n'\
' {"pushoveruserkey": "" }],\n'\
'"list" : [{"name": "James Clerk Maxwell", "mac": "00:co:ca:c0:79:fa", "color": "1"},\n'\
' {"name": "Christian Hulsmeyer", "mac": "ba:ad:c0:de:88:ca", "color": "2"},\n'\
' {"name": "Heinrich Hertz", "mac": "e0:0f:00:0a:d0:a0", "color": "3"}]\n'\
' {"receiver_host": ""},\n'\
' {"receiver_url": "" }],\n'\
'"list" : []\n'\
'}')
file.close()
print "\033[93m\033[1m[+]\033[0m Example configuration file created: \033[94m\033[1m[" + filename + "]\033[0m\n"
@ -42,12 +40,6 @@ def ConfigCheck():
print "\033[91mSomething is wrong with the configuration file."
print "Edit or delete "+filename+" and try again.\033[0m\n\n"
exit()
global pushoverenabled
if str(list[0]['config'][1]['pushoverapitoken']) != "" :
pushoverenabled = "Enabled"
else :
pushoverenabled = "Disabled"
def Welcome() :
banner = "\n".join([
@ -75,7 +67,6 @@ def PrintConfig() :
print " Configuration File \033[94m\033[1m[" + filename + "]\033[0m"
print " Log File \033[94m\033[1m[" + logfilename + "]\033[0m"
print " Monitor Interface \033[94m\033[1m[" + interface + "]\033[0m"
print " Pushover Notifications \033[94m\033[1m[" + pushoverenabled + "]\033[0m\n"
print "\n\033[92m\033[1m[+]\033[0m Listening for probe requests...\n"
def GetOUI(pkt) :
@ -91,7 +82,7 @@ def SearchList(pkt) :
global name
name = "(Unknown)"
COLOR = ""
if pkt.info == "" : pkt.info = "(Hidden)"
if pkt.info == "" : pkt.info = ""
for i in range(len(list[0]['list'])) :
if pkt.addr2 == list[0]['list'][i]['mac'] :
name = list[0]['list'][i]['name']
@ -114,37 +105,37 @@ def PrintInfo(pkt) :
quality = str(quality)+"%"
quality = " SIGNAL: " + quality.ljust(4, ' ')
fingerprint = COLOR + timea + quality + namef + mac + SSID + OUI +'\033[0m'
if fingerprint not in uniquefingerprint :
uniquefingerprint.append(fingerprint)
print fingerprint
if COLOR == '\033[9'+'1'+'m' :
pushover_notification(fingerprint[22:-3])
json_notification(pkt.addr2, pkt.info.ljust(maxlenght)[0:maxlenght], db, 0, 0)
def WriteLog(fingerprint):
file = open(logfilename, "a")
file.write(fingerprint + "\n")
file.close()
def PacketHandler(pkt) :
if pkt.haslayer(Dot11ProbeReq) :
GetOUI(pkt)
SearchList(pkt)
PrintInfo(pkt)
WriteLog(fingerprint)
def signal_handler(signal, frame):
print "\n\033[92m\033[1m[+]\033[0m Exiting...\n"
sys.exit(0)
def pushover_notification(fingerprint):
conn = httplib.HTTPSConnection("api.pushover.net:443")
conn.request("POST", "/1/messages.json",
urllib.urlencode({
"token": str(list[0]['config'][1]['pushoverapitoken']),
"user": str(list[0]['config'][2]['pushoveruserkey']),
"message": fingerprint,
}), { "Content-type": "application/x-www-form-urlencoded" })
def json_notification(mac, ssid, dbm, latitude, longitude):
data = {}
data['address'] = str(mac)
data['essid'] = str(ssid)
data['signal'] = str(dbm)
data['latitude'] = str(latitude)
data['longitude'] = str(longitude)
conn = httplib.HTTPConnection(list[0]['config'][1]['receiver_host'])
conn.request("POST", list[0]['config'][2]['receiver_url'], json.dumps(data), { "Content-type": "application/x-www-form-urlencoded" })
conn.getresponse()

65
ws/receiver.php Normal file → Executable file
View File

@ -1,8 +1,71 @@
<?php
// Lettura file di configurazione
$config = parse_ini_file('../config.ini');
// Array per la risposta del web service
$result = [];
// Dati in arrivo dai readers
$post = file_get_contents('php://input');
$data = json_decode( $post );
// TODO: inserimento a database
if (!empty($data) ){
// Connessione al database
$mysqli = mysqli_connect($config['db_host'], $config['db_user'], $config['db_pass'], $config['db_name']);
// Errore nella connessione a database
if (mysqli_connect_errno($mysqli)) {
$result = [
'status' => 'ERR',
'message' => mysqli_connect_error(),
];
} else {
// Preparazione query con prepared statements
$sql = "INSERT INTO logs (mac, ssid, dbm, latitude, longitude) VALUES (?, ?, ?, ?, ?)";
$stmt = $mysqli->prepare($sql);
// Errore nella preparazione query
if (!$stmt) {
$result = [
'status' => 'ERR',
'message' => $mysqli->error,
];
} else {
if ($stmt->bind_param('ssidd', $mac, $ssid, $dbm, $latitude, $longitude)) {
$mac = $data->address;
$ssid = $data->essid;
$dbm = $data->signal;
$latitude = $data->latitude;
$longitude = $data->longitude;
// Esecuzione statement
$stmt->execute();
$result = [
'status' => 'OK',
'message' => 'Inserimento avvenuto con successo',
'id' => $stmt->insert_id,
];
} else {
$result = [
'status' => 'ERR',
'message' => 'Errore durante l\'esecuzione query',
];
}
}
}
$stmt->close();
$mysqli->close();
} else {
$result = [
'status' => 'ERR',
'message' => 'Nessun dato in input',
];
}
echo json_encode($result);