Something went wrong. Try again.
Mirror of https://github.com/improsocial/improAn extensible Bluesky client for web
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147import { wait, throttle } from "/js/utils.js";
const BATCH_TIMEOUT = 2000;
function shallowEqual(a, b) { return ( Object.keys(a).every((key) => a[key] === b[key]) && Object.keys(b).every((key) => a[key] === b[key]) );}
class InteractionsDispatch { constructor(api, feedProxyUrl) { this.feedProxyUrl = feedProxyUrl; this.queue = []; this.api = api; this.inFlight = false; this.sentInteractions = []; }
async sendInteraction(interaction) { if ( this.sentInteractions.some((sentInteraction) => shallowEqual(sentInteraction, interaction), ) ) { console.warn("interaction already sent", interaction); return; } return new Promise((resolve, reject) => { this.queue.push({ interaction, resolve, reject }); this.process(); }); }
async process() { if (this.inFlight) return; if (this.queue.length === 0) return; this.inFlight = true; await wait(BATCH_TIMEOUT); const batch = this.queue; this.queue = []; try { const interactions = batch.map((item) => item.interaction); await this.api.sendInteractions(interactions, this.feedProxyUrl); this.sentInteractions.push(...interactions); batch.forEach((item) => item.resolve()); } catch (error) { console.warn( "Failed to send interactions to feed proxy url", this.feedProxyUrl, ); batch.forEach((item) => item.reject(error)); } this.inFlight = false; // process next batch if there are any remaining interactions if (this.queue.length > 0) { this.process(); } }}
function isVisible(element) { return ( element.getBoundingClientRect().top < window.innerHeight && element.getBoundingClientRect().bottom > 0 );}
export class PostSeenObserver { constructor(api, feedProxyUrl, { verbose = false } = {}) { this.verbose = verbose; this.feedProxyUrl = feedProxyUrl; this.observedElements = []; // { postUri, el, feedContext } this.seenPosts = new Set(); this.interactionsDispatch = new InteractionsDispatch(api, feedProxyUrl); this.throttledHandleScroll = throttle(() => { this.handleScroll(); }, 100); this.connected = false; this.connect(); }
connect() { if (this.connected) { return; } window.addEventListener("scroll", this.throttledHandleScroll); this.connected = true; }
disconnect() { if (!this.connected) { return; } window.removeEventListener("scroll", this.throttledHandleScroll); this.connected = false; }
async checkIntersection(el, postUri, feedContext) { if (this.seenPosts.has(postUri)) { return; } if (isVisible(el)) { // Must be visible for >=1 second to be considered seen await wait(1000); // check again to make sure it's still visible, and hasn't been marked seen by another checkIntersection call if (!isVisible(el) || this.seenPosts.has(postUri)) { return; } if (this.verbose) { console.debug("sending interaction seen", postUri, feedContext); } try { await this.interactionsDispatch.sendInteraction({ item: postUri, event: "app.bsky.feed.defs#interactionSeen", ...(feedContext != null ? { feedContext } : {}), }); this.seenPosts.add(postUri); } catch (error) { // pass } } }
checkAllIntersections() { this.observedElements.forEach(({ postUri, el, feedContext }) => { this.checkIntersection(el, postUri, feedContext); }); }
handleScroll() { this.checkAllIntersections(); }
register(el, postUri, feedContext) { // don't double-register this.observedElements = this.observedElements.filter( (item) => item.postUri !== postUri, ); this.observedElements.push({ postUri, el, feedContext }); // check intersections immediately - this is similar to how the intersection observer works this.checkIntersection(el, postUri, feedContext); }}