posting stats page (MVP)

api.js

···
     return { cursor: response.cursor, posts };
   }
 
+  async loadTimeline(days) {
+    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;
+      }
+    });
+  }
+
   /** @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</label>
+      </p>
+
+      <p>
+        Time range: <input type="range" min="1" max="90" value="30"> 30 days
+      </p>
+
+      <p>
+        <input type="submit" value="Start scan">
+      </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>%</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))) {
+        let filtered = items.filter(x => !options.breakWhen(x));
+        data = data.concat(filtered);
+        break;
+      }
+
+      data = data.concat(items);
+      reqParams.cursor = cursor;
+
+      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

···
   if (page == 'notif') {
     showLoader();
     showNotificationsPage();
+  } else if (page == 'posting_stats') {
+    showPostingStatsPage();
   }
+}
+
+function showPostingStatsPage() {
+  $id('posting_stats_page').style.display = 'block';
+
+  let days = 7;
+
+  accountAPI.loadTimeline(days).then(items => {
+    let users = {};
+    let total = 0;
+
+    for (let item of items) {
+      if (item.reply) { continue; }
+
+      let user = item.reason ? item.reason.by.handle : item.post.author.handle;
+      users[user] = users[user] ?? { handle: user, own: 0, reposts: 0 };
+      total += 1;
+
+      if (item.reason) {
+        users[user].reposts += 1;
+      } else {
+        users[user].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;
+      }
+    });
+
+    let tbody = $id('posting_stats_page').querySelector('table.scan-result tbody');
+    tbody.innerHTML = '';
+
+    for (let i = 0; i < sorted.length; i++) {
+      let user = sorted[i];
+      let tr = $tag('tr');
+
+      tr.append(
+        $tag('td', { text: i + 1 }),
+        $tag('td.handle', { text: user.handle }),
+        $tag('td', { text: ((user.own + user.reposts) / days).toFixed(1) }),
+        $tag('td', { text: (user.own / days).toFixed(1) }),
+        $tag('td', { text: (user.reposts / days).toFixed(1) }),
+        $tag('td', { text: ((user.own + user.reposts) * 100 / total).toFixed(1) })
+      );
+
+      tbody.append(tr);
+    }
+  });
 }
 
 function showNotificationsPage() {

style.css

···
   margin-top: 25px;
 }
 
+#posting_stats_page {
+  display: none;
+}
+
+#posting_stats_page .scan-result {
+  border: 1px solid #333;
+  border-collapse: collapse;
+}
+
+#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;
+}
+
+#posting_stats_page .scan-result td.handle {
+  text-align: left;
+}
+
 @media (prefers-color-scheme: dark) {
   body {
     background-color: rgb(39, 39, 37);