ogn-python/app/commands/export.py

from flask.cli import AppGroup
import click

import datetime
import re
import csv
import os

from sqlalchemy.orm.exc import NoResultFound

from aerofiles.igc import Writer
from app.model import SenderPosition, Sender
from app import db

user_cli = AppGroup("export")
user_cli.help = "Export data in several file formats."


@user_cli.command("debug_sql")
@click.argument("start")
@click.argument("end")
@click.argument("name")
def debug_sql(start, end, name):
    """Export data (sender_positions and receivers) as sql for debugging (and/or creating test cases)."""

    # First: get all the positions (and the receiver names for later)
    sql_sender_positions = f"""
        SELECT reference_timestamp, name, receiver_name, timestamp, location, track, ground_speed, altitude, aircraft_type, climb_rate, turn_rate, distance, bearing, agl
        FROM sender_positions
        WHERE reference_timestamp BETWEEN '{start}' AND '{end}' AND name = '{name}'
        ORDER BY reference_timestamp;
    """

    receiver_names = []
    sender_position_values = []
    results = db.session.execute(sql_sender_positions)
    for row in results:
        if row[2] not in receiver_names:
            receiver_names.append("'" + row[2] + "'")
        row = [f"'{r}'" if r else "DEFAULT" for r in row]
        sender_position_values.append(f"({','.join(row)})")

    # Second: get the receivers
    sql_receivers = f"""
        SELECT name, location
        FROM receivers
        WHERE name IN ({','.join(receiver_names)});
    """

    receiver_values = []
    results = db.session.execute(sql_receivers)
    for row in results:
        row = [f"'{r}'" if r else "DEFAULT" for r in row]
        receiver_values.append(f"({','.join(row)})")

    # Third: get the airports
    sql_airports = f"""
        SELECT DISTINCT a.name, a.location, a.altitude, a.style, a.border
        FROM airports AS a, receivers AS r
        WHERE
            r.name IN ({','.join(receiver_names)})
            AND ST_Within(r.location, ST_Buffer(a.location, 0.2))
            AND a.style IN (2,4,5);
        """

    airport_values = []
    results = db.session.execute(sql_airports)
    for row in results:
        row = [f"'{r}'" if r else "DEFAULT" for r in row]
        airport_values.append(f"({','.join(row)})")

    # Last: write all into file
    with open(f'{start}_{end}_{name}.sql', 'w') as file:
        file.write('/*\n')
        file.write('OGN Python SQL Export\n')
        file.write(f'Created by: {os.getlogin()}\n')
        file.write(f'Created at: {datetime.datetime.utcnow()}\n')
        file.write('*/\n\n')

        file.write("INSERT INTO airports(name, location, altitude, style, border) VALUES\n")
        file.write(',\n'.join(airport_values) + ';\n\n')

        file.write("INSERT INTO receivers(name, location) VALUES\n")
        file.write(',\n'.join(receiver_values) + ';\n\n')

        file.write("INSERT INTO sender_positions(reference_timestamp, name, receiver_name, timestamp, location, track, ground_speed, altitude, aircraft_type, climb_rate, turn_rate, distance, bearing, agl) VALUES\n")
        file.write(',\n'.join(sender_position_values) + ';\n\n')


@user_cli.command("cup")
def cup():
    """Export receiver waypoints as '.cup'."""

    sql = """
        SELECT
            'OGN-' || sq.name AS name,
            sq.name AS code,
            c.iso2 AS country,
            CASE WHEN sq.lat_deg < 10 THEN '0' ELSE '' END || CAST((sq.lat_deg*100 + sq.lat_min) AS decimal(18, 5)) || sq.lat_sig AS lat,
            CASE WHEN sq.lon_deg < 10 THEN '00' WHEN sq.lon_deg < 100 THEN '0' ELSE '' END || CAST(sq.lon_deg*100 + sq.lon_min AS decimal(18, 5)) || sq.lon_sig AS lon,
            altitude || 'm' AS elev,
            '8' AS style,
            '' AS rwdir,
            '' AS rwlen,
            '' AS freq,
            'lastseen: ' || sq.lastseen::date || ', version: ' || sq.version || ', platform: ' || sq.platform AS desc
        FROM (
            SELECT
                st_y(location) as lat,
                CASE WHEN ST_Y(location) > 0 THEN 'N' ELSE 'S' END AS lat_sig,
                FLOOR(ABS(ST_Y(location))) AS lat_deg,
                60*(ABS(ST_Y(location)) - FLOOR(ABS(ST_Y(location)))) AS lat_min,
                st_x(location) AS lon,
                CASE WHEN ST_X(location) > 0 THEN 'E' ELSE 'W' END AS lon_sig,
                FLOOR(ABS(ST_X(location))) AS lon_deg,
                60*(ABS(ST_X(location)) - FLOOR(ABS(ST_X(location)))) AS lon_min
                , *
            FROM receivers
            WHERE lastseen - firstseen > INTERVAL'3 MONTH' AND lastseen > '2018-01-01 00:00:00' AND name NOT LIKE 'FNB%'
            ) sq
        INNER JOIN countries c ON c.gid = sq.country_id
        ORDER BY sq.name;
        """
    results = db.session.execute(sql)

    with open("receivers.cup", "w") as outfile:
        outcsv = csv.writer(outfile)
        outcsv.writerow(results.keys())
        outcsv.writerows(results.fetchall())


@user_cli.command("igc")
@click.argument("address")
@click.argument("date")
def igc(address, date):
    """Export igc file for <address> at <date>."""
    if not re.match("[0-9A-F]{6}", address):
        print(f"Address '{address}' not valid.")
        return

    try:
        sender = db.session.query(Sender).filter(Sender.address == address).one()
    except NoResultFound as e:
        print(f"No data for '{address}' in the DB")
        return

    if not re.match(r"\d{4}-\d{2}-\d{2}", date):
        print(f"Date {date} not valid.")
        return

    with open("sample.igc", "wb") as fp:
        writer = Writer(fp)

        writer.write_headers(
            {
                "manufacturer_code": "OGN",
                "logger_id": "OGN",
                "date": datetime.date(1987, 2, 24),
                "fix_accuracy": 50,
                "pilot": "Unknown",
                "copilot": "",
                "glider_type": sender.infos[0].aircraft if len(sender.infos) > 0 else '',
                "glider_id": sender.infos[0].registration if len(sender.infos) > 0 else '',
                "firmware_version": sender.software_version,
                "hardware_version": sender.hardware_version,
                "logger_type": "OGN",
                "gps_receiver": "unknown",
                "pressure_sensor": "unknown",
                "competition_id": sender.infos[0].competition if len(sender.infos) > 0 else '',
                "competition_class": "unknown",
            }
        )

        points = (
            db.session.query(SenderPosition)
            .filter(db.between(SenderPosition.reference_timestamp, f"{date} 00:00:00", f"{date} 23:59:59"))
            .filter(SenderPosition.name == sender.name)
            .order_by(SenderPosition.timestamp)
        )

        for point in points:
            writer.write_fix(point.timestamp.time(), latitude=point.location.latitude, longitude=point.location.longitude, valid=True, pressure_alt=point.altitude, gps_alt=point.altitude)