import * as fs from "fs"
import { existsSync, writeFileSync } from "fs"
import * as readline from "readline"
import ScriptUtils from "../ScriptUtils"

/**
 * Converts an open-address CSV file into a big geojson file
 */

async function main(args: string[]) {
    const inputFile = args[0]
    const outputFile = args[1]
    const fileStream = fs.createReadStream(inputFile)
    const perPostalCode = args[2] == "--per-postal-code"
    const rl = readline.createInterface({
        input: fileStream,
        crlfDelay: Infinity,
    })
    // Note: we use the crlfDelay option to recognize all instances of CR LF
    // ('\r\n') in input.txt as a single line break.

    const fields = [
        "EPSG:31370_x",
        "EPSG:31370_y",
        "EPSG:4326_lat",
        "EPSG:4326_lon",
        "address_id",
        "box_number",
        "house_number",
        "municipality_id",
        "municipality_name_de",
        "municipality_name_fr",
        "municipality_name_nl",
        "postcode",
        "postname_fr",
        "postname_nl",
        "street_id",
        "streetname_de",
        "streetname_fr",
        "streetname_nl",
        "region_code",
        "status",
    ]

    let i = 0
    let failed = 0

    let createdFiles: string[] = []
    if (!perPostalCode) {
        fs.writeFileSync(outputFile, "")
    }
    // @ts-ignore
    for await (const line of rl) {
        i++
        if (i % 10000 == 0) {
            ScriptUtils.erasableLog(
                "Converted ",
                i,
                "features (of which ",
                failed,
                "features don't have a coordinate)"
            )
        }
        const data = line.split(",")
        const parsed: any = {}
        for (let i = 0; i < fields.length; i++) {
            const field = fields[i]
            parsed[field] = data[i]
        }
        const lat = Number(parsed["EPSG:4326_lat"])
        const lon = Number(parsed["EPSG:4326_lon"])

        if (parsed["EPSG:31370_x"] === "0.0") {
            failed++
            continue
        }

        delete parsed["EPSG:4326_lat"]
        delete parsed["EPSG:4326_lon"]
        delete parsed["EPSG:31370_x"]
        delete parsed["EPSG:31370_y"]
        delete parsed["EPSG:4326_lat"]
        delete parsed["EPSG:4326_lat"]

        let targetFile = outputFile
        if (perPostalCode) {
            if (parsed["postcode"] === "") {
                continue
            }
            if (isNaN(Number(parsed["postcode"]))) {
                continue
            }
            targetFile = outputFile + "-" + parsed["postcode"] + ".geojson"
            let isFirst = false
            if (!existsSync(targetFile)) {
                writeFileSync(targetFile, '{ "type":"FeatureCollection", "features":[')
                createdFiles.push(targetFile)
                isFirst = true
            }

            if (!isFirst) {
                fs.appendFileSync(targetFile, ",\n")
            }

            fs.appendFileSync(
                targetFile,
                JSON.stringify({
                    type: "Feature",
                    properties: parsed,
                    geometry: {
                        type: "Point",
                        coordinates: [lon, lat],
                    },
                })
            )
        } else {
            fs.appendFileSync(
                outputFile,
                JSON.stringify({
                    type: "Feature",
                    properties: parsed,
                    geometry: {
                        type: "Point",
                        coordinates: [lon, lat],
                    },
                }) + "\n"
            )
        }
    }

    console.log("Closing files...")
    createdFiles.sort()
    for (const createdFile of createdFiles) {
        ScriptUtils.erasableLog("Closing ", createdFile, "and creating convex hull")
        fs.appendFileSync(createdFile, "]}")
    }

    console.log(
        "Done! Converted ",
        i,
        "features (of which ",
        failed,
        "features don't have a coordinate)"
    )
}

let args = [...process.argv]
args.splice(0, 2)

if (args.length == 0) {
    console.log("USAGE: input-csv-file output.newline-delimited-geojson.json [--per-postal-code]")
} else {
    main(args).catch((e) => console.error(e))
}