import {LitElement, html, unsafeHTML, until} from './lit-all.min.js'; import * as tfrpc from '/static/tfrpc.js'; import {styles} from './tf-styles.js'; class TfTabNewsFeedElement extends LitElement { static get properties() { return { whoami: {type: String}, users: {type: Object}, hash: {type: String}, following: {type: Array}, messages: {type: Array}, } } static styles = styles; constructor() { super(); let self = this; this.whoami = null; this.users = {}; this.hash = '#'; this.following = []; } async fetch_messages() { if (this.hash.startsWith('#@')) { return await tfrpc.rpc.query( ` SELECT messages.* FROM messages WHERE messages.author = ? ORDER BY sequence DESC LIMIT 20 `, [ this.hash.substring(1), ]); } else if (this.hash.startsWith('#%')) { return await tfrpc.rpc.query( ` SELECT messages.* FROM messages WHERE id = ? `, [ this.hash.substring(1), ]); } else { return await tfrpc.rpc.query( ` SELECT messages.* FROM messages JOIN json_each(?) AS following ON messages.author = following.value WHERE messages.timestamp > ? ORDER BY messages.timestamp DESC `, [ JSON.stringify(this.following), new Date().valueOf() - 24 * 60 * 60 * 1000, ]); } } render() { if (!this.messages || this._messages_hash !== this.hash || this._messages_following !== this.following) { console.log('loading messages'); let self = this; this.messages = []; this._messages_hash = this.hash; this._messages_following = this.following; this.fetch_messages().then(function(messages) { self.messages = messages; }); } return html``; } } class TfTabNewsElement extends LitElement { static get properties() { return { whoami: {type: String}, users: {type: Object}, hash: {type: String}, unread: {type: Array}, following: {type: Array}, } } static styles = styles; constructor() { super(); let self = this; this.whoami = null; this.users = {}; this.hash = '#'; this.unread = []; this.following = []; this.cache = {}; } show_more() { let unread = this.unread; let news = this.renderRoot?.getElementById('news'); if (news) { console.log('injecting messages', news.messages); news.messages = [...this.unread, ...news.messages]; this.dispatchEvent(new CustomEvent('refresh')); } } new_messages_text() { if (!this.unread?.length) { return 'No new messages.'; } let counts = {}; for (let message of this.unread) { let type = 'unknown'; try { type = JSON.parse(message.content).type || type; } catch { } counts[type] = (counts[type] || 0) + 1; } return 'Show New: ' + Object.keys(counts).sort().map(x => (counts[x].toString() + ' ' + x + 's')).join(', '); } render() { let profile = this.hash.startsWith('#@') ? html`` : undefined; return html`
🏠Home
Welcome, !
${profile} `; } } customElements.define('tf-tab-news-feed', TfTabNewsFeedElement); customElements.define('tf-tab-news', TfTabNewsElement);