const csv = require("csv-parser")
const fs = require("fs")
const path = require("path")
const {createClient} = require("@supabase/supabase-js")

const supabase = createClient("https://uwppvcxflrcsibuzsbil.supabase.co","eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJzdXBhYmFzZSIsInJlZiI6InV3cHB2Y3hmbHJjc2lidXpzYmlsIiwicm9sZSI6InNlcnZpY2Vfcm9sZSIsImlhdCI6MTcwMDkzODE5NCwiZXhwIjoyMDE2NTE0MTk0fQ.6hOkD1J8XBkVJUm-swv0ngLQ74xrEYr28EEbo0rUrts")
const tenant = 6
let rows = []
let projects = []
fs.createReadStream(path.join(__dirname, "./Projekte.csv"), "utf-8")
    .pipe(csv({ separator: ";" }))
    .on("data", (data) => rows.push(data))
    .on("end", async function () {
        console.log("finished");
        console.log(rows)

        console.log(rows[10].customer)

        projects = rows.map(i => {

            let item = {
                customer : Number(i.customer),
                tenant: tenant,
                name: i.Projektname,
                notes: i.Anmerkungen + "\n" + i['Angaben zum Projekt']
            }


            return item

        })
        console.log(projects)




        const {data:vendorsData,error: vendorsError} = await supabase.from("projects").insert(projects).select()
        console.log(vendorsData)
        console.log(vendorsError)




        //console.log(rows)
    })
    .on("error", function (error) {
        console.log(error.message);
    });