/**
 * Manages the Posting Stats page.
 */

class PostingStatsPage {

  /** @type {number | undefined} */
  scanStartTime;

  /** @type {Record<string, { pages: number, progress: number }>} */
  userProgress;

  constructor() {
    this.pageElement = $id('posting_stats_page');
    this.form = $(this.pageElement.querySelector('form'), HTMLFormElement);

    this.rangeInput = $(this.pageElement.querySelector('input[type="range"]'), HTMLInputElement);
    this.submitButton = $(this.pageElement.querySelector('input[type="submit"]'), HTMLInputElement);
    this.progressBar = $(this.pageElement.querySelector('input[type=submit] + progress'), HTMLProgressElement);
    this.table = $(this.pageElement.querySelector('table.scan-result'));

    this.setupEvents();

    this.userProgress = {};
    this.appView = new BlueskyAPI('public.api.bsky.app', false);
  }

  setupEvents() {
    $(this.pageElement.querySelector('form')).addEventListener('submit', (e) => {
      e.preventDefault();

      if (!this.scanStartTime) {
        this.scanPostingStats();      
      } else {
        this.stopScan();
      }
    });

    this.rangeInput.addEventListener('input', (e) => {
      let days = parseInt(this.rangeInput.value, 10);
      this.configurePostingStats({ days });
    });

    this.pageElement.querySelectorAll('input[type="radio"]').forEach(r => {
      r.addEventListener('click', (e) => {
        let value = $(r, HTMLInputElement).value;

        $(this.pageElement.querySelector('.list-choice')).style.display = (value == 'list') ? 'block' : 'none';
        $(this.pageElement.querySelector('.user-choice')).style.display = (value == 'users') ? 'block' : 'none';

        this.table.style.display = 'none';
      });
    });
  }

  show() {
    this.pageElement.style.display = 'block';
    this.fetchLists();
  }

  /** @returns {number} */

  selectedDaysRange() {
    return parseInt(this.rangeInput.value, 10);
  }

  /** @returns {Promise<void>} */

  async fetchLists() {
    let select = $(this.pageElement.querySelector('.list-choice select'));
    let lists = await accountAPI.loadUserLists();

    let sorted = lists.sort((a, b) => {
      let aName = a.name.toLocaleLowerCase();
      let bName = b.name.toLocaleLowerCase();

      return aName.localeCompare(bName);
    });

    for (let list of lists) {
      let opt = $tag('option', { value: list.uri, text: list.name + ' ' });
      select.append(opt);
    }
  }

  /** @param {{ days: number }} args */

  configurePostingStats(args) {
    if (args.days) {
      let label = $(this.pageElement.querySelector('input[type=range] + label'));
      label.innerText = (args.days == 1) ? '1 day' : `${args.days} days`;
    }
  }

  /** @returns {Promise<void>} */

  async scanPostingStats() {
    this.submitButton.value = 'Cancel';

    let requestedDays = this.selectedDaysRange();

    this.progressBar.max = requestedDays;
    this.progressBar.value = 0;
    this.progressBar.style.display = 'inline';

    this.table.style.display = 'none';

    let tbody = $(this.table.querySelector('tbody'));
    tbody.innerHTML = '';

    let thead = $(this.table.querySelector('thead'));
    thead.innerHTML = '';

    let startTime = new Date().getTime();
    this.scanStartTime = startTime;

    let scanInfo = $(this.pageElement.querySelector('.scan-info'));
    scanInfo.style.display = 'none';

    /** @type {FetchAllOnPageLoad} */
    let onPageLoad = (data) => {
      if (this.scanStartTime != startTime) {
        return { cancel: true };
      }

      this.updateProgress(data, startTime);
    };

    let scanType = this.form.elements['scan_type'].value;

    if (scanType == 'home') {
      let items = await accountAPI.loadHomeTimeline(requestedDays, {
        onPageLoad: onPageLoad,
        keepLastPage: true
      });

      if (this.scanStartTime != startTime) {
        return;
      }

      this.updateResultsTable(items, startTime, requestedDays);
    } else if (scanType == 'list') {
      let select = $(this.pageElement.querySelector('.list-choice select'), HTMLSelectElement);
      let list = select.value;
      let items = await accountAPI.loadListTimeline(list, requestedDays, {
        onPageLoad: onPageLoad,
        keepLastPage: true
      });

      if (this.scanStartTime != startTime) {
        return;
      }

      this.updateResultsTable(items, startTime, requestedDays, { showReposts: false });      
    } else if (scanType == 'users') {
      let textarea = $(this.pageElement.querySelector('textarea'), HTMLTextAreaElement);
      let users = textarea.value.split(/\n/).map(x => x.trim()).filter(x => x.length > 0);
      let dids = await Promise.all(users.map(u => accountAPI.resolveHandle(u)));

      this.resetUserProgress(dids);

      let requests = dids.map(did => this.appView.loadUserTimeline(did, requestedDays, {
        filter: 'posts_no_replies',
        onPageLoad: (data) => {
          if (this.scanStartTime != startTime) {
            return { cancel: true };
          }

          this.updateUserProgress(did, data, startTime, requestedDays);
        },
        keepLastPage: true
      }));

      let datasets = await Promise.all(requests);

      if (this.scanStartTime != startTime) {
        return;
      }

      let items = datasets.flat();

      this.updateResultsTable(items, startTime, requestedDays, {
        showTotal: false, showPercentages: false, countFetchedDays: false
      });
    } else {
      let items = await accountAPI.loadUserTimeline(accountAPI.user.did, requestedDays, {
        filter: 'posts_no_replies',
        onPageLoad: onPageLoad,
        keepLastPage: true
      });

      if (this.scanStartTime != startTime) {
        return;
      }

      this.updateResultsTable(items, startTime, requestedDays, { showTotal: false, showPercentages: false });
    }
  }

  /** @param {json[]} dataPage, @param {number} startTime */

  updateProgress(dataPage, startTime) {
    let last = dataPage.at(-1);

    if (!last) { return }

    let lastDate = feedPostTime(last);
    let daysBack = (startTime - lastDate) / 86400 / 1000;

    this.progressBar.value = daysBack;    
  }


  /** @param {string[]} dids */

  resetUserProgress(dids) {
    this.userProgress = {};

    for (let did of dids) {
      this.userProgress[did] = { pages: 0, progress: 0 };
    }
  }

  /** @param {string} did, @param {json[]} dataPage, @param {number} startTime, @param {number} requestedDays */

  updateUserProgress(did, dataPage, startTime, requestedDays) {
    let last = dataPage.at(-1);

    if (!last) { return }

    let lastDate = feedPostTime(last);
    let daysBack = (startTime - lastDate) / 86400 / 1000;

    this.userProgress[did].pages += 1;
    this.userProgress[did].progress = Math.min(daysBack / requestedDays, 1.0);

    let expectedPages = Object.values(this.userProgress).map(x => x.pages / x.progress);
    let known = expectedPages.filter(x => !isNaN(x));
    let expectedTotalPages = known.reduce((a, b) => a + b) / known.length * expectedPages.length;
    let fetchedPages = Object.values(this.userProgress).map(x => x.pages).reduce((a, b) => a + b);

    this.progressBar.value = Math.max(this.progressBar.value, (fetchedPages / expectedTotalPages) * requestedDays);
  }

  /** @param {json} a, @param {json} b, @returns {number} */

  sortUserRows(a, b) {
    let asum = a.own + a.reposts;
    let bsum = b.own + b.reposts;

    if (asum < bsum) {
      return 1;
    } else if (asum > bsum) {
      return -1;
    } else {
      return 0;
    }
  }

  /**
   * @param {json[]} items
   * @param {number} startTime
   * @param {number} requestedDays
   * @param {{ showTotal?: boolean, showPercentages?: boolean, showReposts?: boolean, countFetchedDays?: boolean }} [options]
   */

  updateResultsTable(items, startTime, requestedDays, options = {}) {
    let users = {};
    let total = 0;
    let allReposts = 0;
    let allNormalPosts = 0;

    let last = items.at(-1);

    if (!last) {
      this.stopScan();
      return;
    }

    let daysBack;

    if (options.countFetchedDays !== false) {
      let lastDate = feedPostTime(last);
      let fetchedDays = (startTime - lastDate) / 86400 / 1000;

      if (Math.ceil(fetchedDays) < requestedDays) {
        let scanInfo = $(this.pageElement.querySelector('.scan-info'));
        scanInfo.innerText = `🕓 Showing data from ${Math.round(fetchedDays)} days (the timeline only goes that far):`;
        scanInfo.style.display = 'block';
      }

      daysBack = Math.min(requestedDays, fetchedDays);
    } else {
      daysBack = requestedDays;
    }

    let timeLimit = startTime - requestedDays * 86400 * 1000;
    items = items.filter(x => (feedPostTime(x) > timeLimit));

    for (let item of items) {
      if (item.reply) { continue; }

      let user = item.reason ? item.reason.by : item.post.author;
      let handle = user.handle;
      users[handle] = users[handle] ?? { handle: handle, own: 0, reposts: 0, avatar: user.avatar };
      total += 1;

      if (item.reason) {
        users[handle].reposts += 1;
        allReposts += 1;
      } else {
        users[handle].own += 1;
        allNormalPosts += 1;
      }
    }

    let thead = $(this.table.querySelector('thead'));
    let headRow = $tag('tr');

    if (options.showReposts !== false) {
      headRow.append(
        $tag('th', { text: '#' }),
        $tag('th', { text: 'Handle' }),
        $tag('th', { text: 'All posts /d' }),
        $tag('th', { text: 'Own posts /d' }),
        $tag('th', { text: 'Reposts /d' })
      );
    } else {
      headRow.append(
        $tag('th', { text: '#' }),
        $tag('th', { text: 'Handle' }),
        $tag('th', { text: 'Posts /d' }),
      );
    }

    if (options.showPercentages !== false) {
      headRow.append($tag('th', { text: '% of all' }));
    }

    thead.append(headRow);

    let tbody = $(this.table.querySelector('tbody'));

    if (options.showTotal !== false) {
      let tr = $tag('tr.total');

      tr.append(
        $tag('td.no', { text: '' }),
        $tag('td.handle', { text: 'Total:' }),

        (options.showReposts !== false) ?
          $tag('td', { text: (total / daysBack).toFixed(1) }) : '',

        $tag('td', { text: (allNormalPosts / daysBack).toFixed(1) }),

        (options.showReposts !== false) ?
          $tag('td', { text: (allReposts / daysBack).toFixed(1) }) : ''
      );

      if (options.showPercentages !== false) {
        tr.append($tag('td.percent', { text: '' }));
      }

      tbody.append(tr);      
    }

    let sorted = Object.values(users).sort(this.sortUserRows);

    for (let i = 0; i < sorted.length; i++) {
      let user = sorted[i];
      let tr = $tag('tr');

      tr.append(
        $tag('td.no', { text: i + 1 }),
        $tag('td.handle', {
          html: `<img class="avatar" src="${user.avatar}"> ` + 
                `<a href="https://bsky.app/profile/${user.handle}" target="_blank">${user.handle}</a>`
        }),

        (options.showReposts !== false) ?
          $tag('td', { text: ((user.own + user.reposts) / daysBack).toFixed(1) }) : '',

        $tag('td', { text: user.own > 0 ? (user.own / daysBack).toFixed(1) : '–' }),

        (options.showReposts !== false) ?
          $tag('td', { text: user.reposts > 0 ? (user.reposts / daysBack).toFixed(1) : '–' }) : ''
      );

      if (options.showPercentages !== false) {
        tr.append($tag('td.percent', { text: ((user.own + user.reposts) * 100 / total).toFixed(1) + '%' }));
      }

      tbody.append(tr);
    }

    this.table.style.display = 'table';
    this.submitButton.value = 'Start scan';
    this.progressBar.style.display = 'none';
    this.scanStartTime = undefined;
  }

  stopScan() {
    this.submitButton.value = 'Start scan';
    this.scanStartTime = undefined;
    this.progressBar.style.display = 'none';
  }
}