98 lines
3 KiB
Python
98 lines
3 KiB
Python
|
import os
|
||
|
|
import time
|
||
|
|
import logging
|
||
|
|
import keyring
|
||
|
|
from keyrings.alt.file import PlaintextKeyring
|
||
|
|
from pyicloud import PyiCloudService
|
||
|
|
import mysql.connector
|
||
|
|
from mysql.connector import Error
|
||
|
|
from datetime import datetime
|
||
|
|
|
||
|
|
# Logging konfigurieren
|
||
|
|
logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(levelname)s - %(message)s')
|
||
|
|
|
||
|
|
# Keyring auf Dateisystem setzen
|
||
|
|
keyring.set_keyring(PlaintextKeyring())
|
||
|
|
|
||
|
|
# Datenbankverbindung prüfen
|
||
|
|
def connect_to_database():
|
||
|
|
while True:
|
||
|
|
try:
|
||
|
|
db = mysql.connector.connect(
|
||
|
|
host=os.getenv('DB_HOST'),
|
||
|
|
user=os.getenv('DB_USER'),
|
||
|
|
password=os.getenv('DB_PASSWORD'),
|
||
|
|
database=os.getenv('DB_NAME')
|
||
|
|
)
|
||
|
|
if db.is_connected():
|
||
|
|
logging.info("Erfolgreich mit der Datenbank verbunden.")
|
||
|
|
return db
|
||
|
|
except Error as e:
|
||
|
|
logging.error(f"Fehler beim Verbinden zur Datenbank: {e}")
|
||
|
|
logging.info("Erneuter Verbindungsversuch in 5 Sekunden...")
|
||
|
|
time.sleep(5)
|
||
|
|
|
||
|
|
# iCloud-Verbindung herstellen
|
||
|
|
icloud = PyiCloudService(
|
||
|
|
os.getenv('ICLOUD_EMAIL'),
|
||
|
|
os.getenv('ICLOUD_PASSWORD'),
|
||
|
|
cookie_directory='/root/.local/share/python_keyring'
|
||
|
|
)
|
||
|
|
|
||
|
|
# Zwei-Faktor-Authentifizierung
|
||
|
|
if icloud.requires_2fa:
|
||
|
|
code = os.getenv('ICLOUD_2FA_CODE')
|
||
|
|
if not code:
|
||
|
|
logging.error("Zwei-Faktor-Authentifizierung erforderlich. Kein Code gefunden.")
|
||
|
|
sys.exit(1)
|
||
|
|
|
||
|
|
result = icloud.validate_2fa_code(code)
|
||
|
|
if not result:
|
||
|
|
logging.error("Ungültiger Zwei-Faktor-Code.")
|
||
|
|
sys.exit(1)
|
||
|
|
logging.info("Zwei-Faktor-Authentifizierung erfolgreich.")
|
||
|
|
|
||
|
|
if icloud.requires_2fa and not icloud.is_trusted_session:
|
||
|
|
logging.error("Vertrauenswürdige Sitzung erforderlich.")
|
||
|
|
sys.exit(1)
|
||
|
|
|
||
|
|
# Datenbankverbindung herstellen
|
||
|
|
db = connect_to_database()
|
||
|
|
cursor = db.cursor()
|
||
|
|
|
||
|
|
# Tabelle erstellen, falls sie nicht existiert
|
||
|
|
cursor.execute("""
|
||
|
|
CREATE TABLE IF NOT EXISTS device_locations (
|
||
|
|
id INT AUTO_INCREMENT PRIMARY KEY,
|
||
|
|
device_name VARCHAR(255),
|
||
|
|
latitude DOUBLE,
|
||
|
|
longitude DOUBLE,
|
||
|
|
timestamp DATETIME DEFAULT CURRENT_TIMESTAMP
|
||
|
|
)
|
||
|
|
""")
|
||
|
|
|
||
|
|
# Standortdaten abrufen
|
||
|
|
devices = icloud.devices
|
||
|
|
|
||
|
|
for device in devices:
|
||
|
|
location = device.location()
|
||
|
|
if location:
|
||
|
|
device_name = device['name']
|
||
|
|
latitude = location['latitude']
|
||
|
|
longitude = location['longitude']
|
||
|
|
timestamp = datetime.fromtimestamp(location['timeStamp'] / 1000)
|
||
|
|
|
||
|
|
# Koordinaten in der Konsole ausgeben
|
||
|
|
logging.info(f"Gerät: {device_name}, Latitude: {latitude}, Longitude: {longitude}, Zeit: {timestamp}")
|
||
|
|
|
||
|
|
# Daten in die Datenbank einfügen
|
||
|
|
cursor.execute("""
|
||
|
|
INSERT INTO device_locations (device_name, latitude, longitude, timestamp)
|
||
|
|
VALUES (%s, %s, %s, %s)
|
||
|
|
""", (device_name, latitude, longitude, timestamp))
|
||
|
|
|
||
|
|
# Änderungen speichern und Verbindung schließen
|
||
|
|
db.commit()
|
||
|
|
cursor.close()
|
||
|
|
db.close()
|