import { config } from "https://deno.land/x/dotenv/mod.ts";
import SimpleTwitter from "https://deno.land/x/simple_twitter_deno@0.05/simple_twitter_deno.ts";
import { Table } from "https://deno.land/x/cliffy@v0.20.1/table/mod.ts";
import { UTXOEngine } from "./engine.js";
import { exists } from "https://deno.land/std/fs/mod.ts";
import { fromStreamReader } from "https://deno.land/std@0.60.0/io/streams.ts";

const utxo = new UTXOEngine({ silent: true });
await utxo.init();

config({ path: ".env", export: true });

const twitterImagesPath = "./spec/22/photos/speakers/";
const twitterPartnersImagesPath = "./spec/22/photos/partners/";

const simple_twitter = new SimpleTwitter({
  consumer_key: Deno.env.get("CONSUMER_KEY"),
  consumer_secret: Deno.env.get("CONSUMER_SECRET"),
  access_token: Deno.env.get("ACCESS_TOKEN"),
  access_token_secret: Deno.env.get("ACCESS_TOKEN_SECRET"),
  bearer_token: Deno.env.get("BEARER_TOKEN"),
});

const entryId = "22";
const entry = utxo.entries[entryId];

const arr = [];
let total = 0;
let items = [];

// partners
for (const sp of entry.specs.partners) {
  if (!sp.twitter) {
    continue;
  }
  const tw = await twitterUser(sp.twitter);
  if (!tw) {
    continue;
  }

  const imageFn = twitterPartnersImagesPath + sp.id + "-twitter.jpg";
  if (!await exists(imageFn)) {
    const url = tw.profile_image_url_https.replace("_normal", "");
    console.log(url);
    const res = await fetch(url);
    const file = await Deno.open(imageFn, { create: true, write: true });
    const reader = fromStreamReader(res.body.getReader());
    await Deno.copy(reader, file);
    file.close();
  }

  items.push([`partner:${sp.type}`, tw.screen_name, tw.followers_count]);
  total += tw.followers_count;
}

// speakers

for (const sp of entry.specs.speakers) {
  if (!sp.twitter) {
    continue;
  }
  const tw = await twitterUser(sp.twitter);
  if (!tw) {
    continue;
  }

  const imageFn = twitterImagesPath + sp.id + "-twitter.jpg";
  if (!await exists(imageFn)) {
    const url = tw.profile_image_url_https.replace("_normal", "");
    console.log(url);
    const res = await fetch(url);
    const file = await Deno.open(imageFn, { create: true, write: true });
    const reader = fromStreamReader(res.body.getReader());
    await Deno.copy(reader, file);
    file.close();
  }

  items.push(["speaker", tw.screen_name, Number(tw.followers_count)]);
  total += tw.followers_count;
}

arr.push(...items.sort((x, y) => x[2] < y[2] ? 1 : -1));

arr.push([]);
arr.push(["total", "", total]);

const table = Table.from(arr);
console.log("\nTwitter followers count:\n\n" + table.toString() + "\n");

async function twitterUser(screen_name) {
  const resp = await simple_twitter.get("users/lookup", { screen_name });
  if (resp.length === 1) {
    return resp[0];
  }
  return null;
}