aiolabs/lightning-pub
2
0
Fork 0
Code Issues 9 Pull requests 4 Projects Releases Packages Wiki Activity Actions

Let front-end handle user data subs

Browse source
This commit is contained in:
Daniel Lugo 2021-04-28 11:26:04 -04:00
parent 963b6446c5
commit 14db1a3efd
1 changed files with 1 additions and 20 deletions
Download patch file Download diff file Expand all files Collapse all files

21
services/gunDB/contact-api/events/index.js
View file

@ -465,9 +465,6 @@ const notifyChatsListeners = () => {
const processChats = debounce(() => { const processChats = debounce(() => {
const Streams = require('../streams') const Streams = require('../streams')
const pubToAvatar = Streams.getPubToAvatar()
const pubToDn = Streams.getPubToDn()
const pubToLastSeenApp = Streams.getPubToLastSeenApp()
const currentOutgoings = getCurrentOutgoings() const currentOutgoings = getCurrentOutgoings()
const existingOutgoings = /** @type {[string, Outgoing][]} */ (Object.entries( const existingOutgoings = /** @type {[string, Outgoing][]} */ (Object.entries(
currentOutgoings currentOutgoings
@ -478,19 +475,6 @@ const processChats = debounce(() => {
const newChats = [] const newChats = []
for (const [outID, out] of existingOutgoings) { for (const [outID, out] of existingOutgoings) {
if (typeof pubToAvatar[out.with] === 'undefined') {
// eslint-disable-next-line no-empty-function
Streams.onAvatar(() => {}, out.with)()
}
if (typeof pubToDn[out.with] === 'undefined') {
// eslint-disable-next-line no-empty-function
Streams.onDisplayName(() => {}, out.with)()
}
if (typeof pubToLastSeenApp[out.with] === 'undefined') {
// eslint-disable-next-line no-empty-function
Streams.onPubToLastSeenApp(() => {}, out.with)()
}
/** @type {ChatMessage[]} */ /** @type {ChatMessage[]} */
let msgs = Object.entries(out.messages) let msgs = Object.entries(out.messages)
.map(([mid, m]) => ({ .map(([mid, m]) => ({
@ -516,7 +500,7 @@ const processChats = debounce(() => {
messages: msgs, messages: msgs,
recipientAvatar: null, recipientAvatar: null,
recipientDisplayName: null, recipientDisplayName: null,
lastSeenApp: pubToLastSeenApp[out.with] || null lastSeenApp: null
} }
newChats.push(chat) newChats.push(chat)
@ -548,10 +532,7 @@ const onChats = cb => {
if (!onChatsSubbed) { if (!onChatsSubbed) {
const Streams = require('../streams') const Streams = require('../streams')
onOutgoing(processChats) onOutgoing(processChats)
Streams.onAvatar(processChats)
Streams.onDisplayName(processChats)
Streams.onPubToFeed(processChats) Streams.onPubToFeed(processChats)
Streams.onPubToLastSeenApp(processChats)
onChatsSubbed = true onChatsSubbed = true
} }