Merge branch 'posting_stats'

api.js

···
     return { cursor: response.cursor, posts };
   }
 
+  async loadTimeline(days, options = {}) {
+    let now = new Date();
+    let timeLimit = now.getTime() - days * 86400 * 1000;
+
+    return await this.fetchAll('app.bsky.feed.getTimeline', { limit: 100 }, {
+      field: 'feed',
+      breakWhen: (x) => {
+        let timestamp = x.reason ? x.reason.indexedAt : x.post.record.createdAt;
+        return Date.parse(timestamp) < timeLimit;
+      },
+      onPageLoad: options.onPageLoad
+    });
+  }
+
   /** @param {string} postURI, @returns {Promise<json>} */
 
   async loadPost(postURI) {

index.html

···
     </form>
   </div>
 
+  <div id="posting_stats_page">
+    <h2>Bluesky posting statistics</h2>
+
+    <form>
+      <p>
+        Scan posts from:
+        <input type="radio" name="scan_type" id="scan_type_timeline" value="timeline" checked>
+        <label for="scan_type_timeline">Your timeline</label>
+        <input type="radio" name="scan_type" id="scan_type_users" value="users" disabled>
+        <label for="scan_type_users">Selected users (coming soon)</label>
+      </p>
+
+      <p>
+        Time range: <input type="range" min="1" max="60" value="7"> <label>7 days</label>
+      </p>
+
+      <p>
+        <input type="submit" value="Start scan"> <progress></progress>
+      </p>
+    </form>
+
+    <table class="scan-result">
+      <thead>
+        <tr>
+          <th>#</th>
+          <th>Handle</th>
+          <th>All posts /d</th>
+          <th>Own posts /d</th>
+          <th>Reposts /d</th>
+          <th>% of all</th>
+        </tr>
+      </thead>
+      <tbody>
+      </tbody>
+    </table>
+  </div>
+
   <script src="lib/purify.min.js"></script>
   <script src="minisky.js"></script>
   <script src="api.js"></script>

minisky.js

···
 
 
 /**
+ * Thrown when passed arguments/options are invalid or missing.
+ */
+
+class RequestError extends Error {}
+
+
+/**
  * Thrown when authentication is needed, but access token is invalid or missing.
  */
 
···
       let host = (this.host.includes('://')) ? this.host : `https://${this.host}`;
       return host + '/xrpc';
     } else {
-      throw new AuthError('Hostname not set');
+      throw new RequestError('Hostname not set');
     }
   }
 
···
     return await this.parseResponse(response);
   }
 
+  async fetchAll(method, params, options) {
+    if (!options || !options.field) {
+      throw new RequestError("'field' option is required");
+    }
+
+    let data = [];
+    let reqParams = params ?? {};
+    let reqOptions = this.sliceOptions(options, ['auth', 'headers']);
+
+    for (;;) {
+      let response = await this.getRequest(method, reqParams, reqOptions);
+
+      let items = response[options.field];
+      let cursor = response.cursor;
+
+      if (options.breakWhen && items.some(x => options.breakWhen(x))) {
+        items = items.filter(x => !options.breakWhen(x));
+        cursor = null;
+      }
+
+      data = data.concat(items);
+      reqParams.cursor = cursor;
+
+      if (options.onPageLoad) {
+        let result = options.onPageLoad(items);
+
+        if (result?.cancel) {
+          break;
+        }
+      }
+
+      if (items.length == 0 || !cursor) {
+        break;
+      }
+    }
+
+    return data;
+  }
+
   /** @param {string | boolean} auth, @returns {Record<string, string>} */
 
   authHeaders(auth) {
···
     } else {
       return {};
     }
+  }
+
+  sliceOptions(options, list) {
+    let newOptions = {};
+
+    for (let i of list) {
+      if (i in options) {
+        newOptions[i] = options[i];
+      }
+    }
+
+    return newOptions;
   }
 
   /** @param {string} token, @returns {number} */

skythread.js

···
 
   window.loginDialog = $(document.querySelector('#login'));
   window.accountMenu = $(document.querySelector('#account_menu'));
+  window.postingStatsPage = $id('posting_stats_page');
 
   window.avatarPreloader = buildAvatarPreloader();
 
···
   $(accountMenu.querySelector('a[data-action=logout]')).addEventListener('click', (e) => {
     e.preventDefault();
     logOut();
+  });
+
+  $(postingStatsPage.querySelector('form')).addEventListener('submit', (e) => {
+    if (!window.scanStartTime) {
+      scanPostingStats();      
+    } else {
+      stopScan();
+    }
+  });
+
+  $(postingStatsPage.querySelector('input[type="range"]')).addEventListener('input', (e) => {
+    let range = $(e.target, HTMLInputElement);
+    configurePostingStats({ days: range.value });
   });
 
   window.appView = new BlueskyAPI('api.bsky.app', false);
···
   if (page == 'notif') {
     showLoader();
     showNotificationsPage();
+  } else if (page == 'posting_stats') {
+    showPostingStatsPage();
   }
+}
+
+function showPostingStatsPage() {
+  $id('posting_stats_page').style.display = 'block';
+}
+
+function configurePostingStats(args) {
+  if (args.days) {
+    let label = $(postingStatsPage.querySelector('input[type=range] + label'));
+    label.innerText = (args.days == 1) ? '1 day' : `${args.days} days`;
+  }
+}
+
+function scanPostingStats() {
+  let submit = $(postingStatsPage.querySelector('input[type=submit]'), HTMLInputElement);
+  submit.value = 'Cancel';
+
+  let range = $(postingStatsPage.querySelector('input[type=range]'), HTMLInputElement);
+  let days = parseInt(range.value, 10);
+
+  let progressBar = $(postingStatsPage.querySelector('input[type=submit] + progress'), HTMLProgressElement);
+  progressBar.max = days;
+  progressBar.value = 0;
+  progressBar.style.display = 'inline';
+
+  let table = $(postingStatsPage.querySelector('table.scan-result'));
+  table.style.display = 'none';
+
+  let tbody = $(table.querySelector('tbody'));
+  tbody.innerHTML = '';
+
+  let now = new Date().getTime();
+  window.scanStartTime = now;
+
+  accountAPI.loadTimeline(days, {
+    onPageLoad: (data) => {
+      let minTime = now;
+
+      if (window.scanStartTime != now) {
+        return { cancel: true };
+      }
+
+      for (let item of data) {
+        let timestamp = item.reason ? item.reason.indexedAt : item.post.record.createdAt;
+        let date = Date.parse(timestamp);
+        minTime = Math.min(minTime, date);
+      }
+
+      let daysBack = (now - minTime) / 86400 / 1000;
+      progressBar.value = daysBack;
+    }
+  }).then(items => {
+    if (window.scanStartTime != now) {
+      return;
+    }
+
+    let users = {};
+    let total = 0;
+
+    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;
+      } else {
+        users[handle].own += 1;
+      }
+    }
+
+    let sorted = Object.values(users).sort((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;
+      }
+    });
+
+    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>`
+        }),
+        $tag('td', { text: ((user.own + user.reposts) / days).toFixed(1) }),
+        $tag('td', { text: user.own > 0 ? (user.own / days).toFixed(1) : '–' }),
+        $tag('td', { text: user.reposts > 0 ? (user.reposts / days).toFixed(1) : '–' }),
+        $tag('td.percent', { text: ((user.own + user.reposts) * 100 / total).toFixed(1) + '%' })
+      );
+
+      tbody.append(tr);
+    }
+
+    table.style.display = 'table';
+    submit.value = 'Start scan';
+    progressBar.style.display = 'none';
+    window.scanStartTime = undefined;
+  });
+}
+
+function stopScan() {
+  let submit = $(postingStatsPage.querySelector('input[type=submit]'), HTMLInputElement);
+  submit.value = 'Start scan';
+  window.scanStartTime = undefined;
+
+  let progressBar = $(postingStatsPage.querySelector('input[type=submit] + progress'), HTMLProgressElement);
+  progressBar.style.display = 'none';
 }
 
 function showNotificationsPage() {

style.css

···
   margin-top: 25px;
 }
 
+#posting_stats_page {
+  display: none;
+}
+
+#posting_stats_page input[type="radio"] {
+  position: relative;
+  top: -1px;
+}
+
+#posting_stats_page label {
+  user-select: none;
+  -webkit-user-select: none;
+}
+
+#posting_stats_page input:disabled + label {
+  color: #999;
+}
+
+#posting_stats_page input[type="range"] {
+  width: 250px;
+  vertical-align: middle;
+}
+
+#posting_stats_page input[type="submit"] {
+  font-size: 12pt;
+  margin: 5px 0px;
+  padding: 5px 10px;
+}
+
+#posting_stats_page progress {
+  width: 300px;
+  margin-left: 10px;
+  vertical-align: middle;
+  display: none;
+}
+
+#posting_stats_page .scan-result {
+  border: 1px solid #333;
+  border-collapse: collapse;
+  display: none;
+}
+
+#posting_stats_page .scan-result td, #posting_stats_page .scan-result th {
+  border: 1px solid #333;
+  padding: 5px 8px;
+}
+
+#posting_stats_page .scan-result td {
+  text-align: right;
+}
+
+#posting_stats_page .scan-result th {
+  text-align: center;
+  background-color: hsl(207, 100%, 86%);
+  padding: 7px 10px;
+}
+
+#posting_stats_page .scan-result td.handle {
+  text-align: left;
+}
+
+#posting_stats_page .scan-result .avatar {
+  width: 24px;
+  border-radius: 14px;
+  vertical-align: middle;
+  margin-right: 2px;
+  padding: 2px;  
+}
+
+#posting_stats_page .scan-result td.no {
+  font-weight: bold;
+}
+
+#posting_stats_page .scan-result td.percent {
+  min-width: 70px;
+}
+
 @media (prefers-color-scheme: dark) {
   body {
     background-color: rgb(39, 39, 37);
···
 
   .post .stats i.fa-heart.liked:hover {
     color: #ff7070;
+  }
+
+  #posting_stats_page input:disabled + label {
+    color: #777;
+  }
+
+  #posting_stats_page .scan-result, #posting_stats_page .scan-result td, #posting_stats_page .scan-result th {
+    border-color: #888;
+  }
+
+  #posting_stats_page .scan-result th {
+    background-color: hsl(207, 90%, 25%);
   }
 }

types.d.ts

···
 declare var api: BlueskyAPI;
 declare var isIncognito: boolean;
 declare var biohazardEnabled: boolean;
+declare var scanStartTime: number | undefined;
 declare var loginDialog: HTMLElement;
 declare var accountMenu: HTMLElement;
+declare var postingStatsPage: HTMLElement;
 declare var avatarPreloader: IntersectionObserver;
 
 type json = Record<string, any>;