Qortal/qortal-ui
4
1
Fork 4
mirror of https://github.com/Qortal/qortal-ui.git synced 2025-02-14 19:25:50 +00:00
Code Issues Projects Releases Wiki Activity

Removed presence websocket - this has been replaced by the tradepresence websocket

Browse Source
This commit is contained in:
CalDescent 2022-09-24 17:24:59 +01:00
parent 34d066327d
commit e832cc9f28
1 changed files with 3 additions and 48 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

51
qortal-ui-plugins/plugins/core/trade-portal/trade-portal.src.js
View File

@ -1891,7 +1891,6 @@ class TradePortal extends LitElement {
initSocket() { initSocket() {
let _relatedCoin = "" let _relatedCoin = ""
let presenceTxns = null
let tradePresenceTxns = null let tradePresenceTxns = null
let offeringTrades = null let offeringTrades = null
@ -1915,8 +1914,8 @@ class TradePortal extends LitElement {
return timestamp > thirtyMinsAgo return timestamp > thirtyMinsAgo
} }
const filterOffersUsingEitherPresence = (offeringTrade) => { const filterOffersUsingTradePresence = (offeringTrade) => {
return lessThanThirtyMinsAgo(offeringTrade.lastSeen) || offeringTrade.tradePresenceExpiry > Date.now(); return offeringTrade.tradePresenceExpiry > Date.now();
} }
const processOffersWithPresence = () => { const processOffersWithPresence = () => {
@ -1930,13 +1929,6 @@ class TradePortal extends LitElement {
} }
const startOfferPresenceMapping = async () => { const startOfferPresenceMapping = async () => {
if (presenceTxns !== null) {
await asyncForEach(presenceTxns, async (presence) => {
await waitFor(250)
let offerIndex = offeringTrades.findIndex((offeringTrade) => offeringTrade.qortalCreatorTradeAddress === presence.address)
offerIndex !== -1 ? (offeringTrades[offerIndex].lastSeen = presence.timestamp) : null
})
}
if (tradePresenceTxns !== null) { if (tradePresenceTxns !== null) {
await asyncForEach(tradePresenceTxns, async (tradePresence) => { await asyncForEach(tradePresenceTxns, async (tradePresence) => {
@ -1946,7 +1938,7 @@ class TradePortal extends LitElement {
}) })
} }
let filteredOffers = offeringTrades.filter((offeringTrade) => filterOffersUsingEitherPresence(offeringTrade)) let filteredOffers = offeringTrades.filter((offeringTrade) => filterOffersUsingTradePresence(offeringTrade))
self.postMessage({ type: 'PRESENCE', data: { offers: offeringTrades, filteredOffers: filteredOffers, relatedCoin: _relatedCoin } }) self.postMessage({ type: 'PRESENCE', data: { offers: offeringTrades, filteredOffers: filteredOffers, relatedCoin: _relatedCoin } })
} }
@ -2052,40 +2044,6 @@ class TradePortal extends LitElement {
} }
} }
// Will be removed in future - being replaced by tradepresence above
const initPresenceWebSocket = (restarted = false) => {
let socketTimeout
let socketLink = `ws://NODEURL/websockets/presence?presenceType=TRADE_BOT`
const socket = new WebSocket(socketLink)
// Open Connection
socket.onopen = () => {
setTimeout(pingSocket, 250)
}
// Message Event
socket.onmessage = (e) => {
presenceTxns = JSON.parse(e.data)
processOffersWithPresence()
restarted = false
}
// Closed Event
socket.onclose = () => {
clearTimeout(socketTimeout)
restartPresenceWebSocket()
}
// Error Event
socket.onerror = (e) => {
clearTimeout(socketTimeout)
}
const pingSocket = () => {
socket.send('ping')
socketTimeout = setTimeout(pingSocket, 295000)
}
}
const restartPresenceWebSocket = () => {
setTimeout(() => initPresenceWebSocket(true), 1000)
}
const restartTradePresenceWebSocket = () => { const restartTradePresenceWebSocket = () => {
setTimeout(() => initTradePresenceWebSocket(true), 1000) setTimeout(() => initTradePresenceWebSocket(true), 1000)
} }
@ -2101,9 +2059,6 @@ class TradePortal extends LitElement {
// Start TradeOffersWebSocket // Start TradeOffersWebSocket
initTradeOffersWebSocket() initTradeOffersWebSocket()
// Start PresenceWebSocket
initPresenceWebSocket()
// Start TradePresenceWebSocket // Start TradePresenceWebSocket
initTradePresenceWebSocket() initTradePresenceWebSocket()