sigit/sigit.io
7
2
Fork 0
Code Issues 51 Pull Requests 3 Actions Packages Projects 1 Releases Wiki Activity

fix: manage pending relay connection requests #159

Merged
eugene merged 6 commits from reduce-relay-connection-attempts into staging 2024-08-21 08:06:39 +00:00
Conversation 0 Commits 6 Files Changed 10 +19 -11
3 changed files with 19 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 4a553c047c - Show all commits

2
src/controllers/MetadataController.ts
View File

@ -116,7 +116,7 @@ export class MetadataController extends EventEmitter {
// If cached metadata is found, check its validity // If cached metadata is found, check its validity
if (cachedMetadataEvent) { if (cachedMetadataEvent) {
// Check if the cached metadata is older than one week // Check if the cached metadata is older than one day
if (isOlderThanOneDay(cachedMetadataEvent.cachedAt)) { if (isOlderThanOneDay(cachedMetadataEvent.cachedAt)) {
s marked this conversation as resolved
eugene commented 2024-08-21 06:40:41 +00:00
Review
Copy Link

There is a discrepancy between the function name and the comments around it. Should it be older than one week or one day?

There is a discrepancy between the function name and the comments around it. Should it be older than one week or one day?
👍 1
s commented 2024-08-21 07:43:24 +00:00
Review
Copy Link

fixed, Updated comment

fixed, Updated comment
// If older than one week, find the metadata from relays in background // If older than one week, find the metadata from relays in background

22
src/controllers/RelayController.ts
View File

@ -96,8 +96,12 @@ export class RelayController {
relayUrls: string[] = [] relayUrls: string[] = []
): Promise<Event[]> => { ): Promise<Event[]> => {
if (!relayUrls.includes(SIGIT_RELAY)) { if (!relayUrls.includes(SIGIT_RELAY)) {
// Add app relay to relays array if not exists already /**
relayUrls.push(SIGIT_RELAY) * NOTE: To avoid side-effects on external relayUrls array passed as argument
* re-assigned relayUrls with added sigit relay instead of just appending to same array
*/
relayUrls = [...relayUrls, SIGIT_RELAY] // Add app relay to relays array if not exists already
} }
// connect to all specified relays // connect to all specified relays
@ -216,8 +220,11 @@ export class RelayController {
eventHandler: (event: Event) => void eventHandler: (event: Event) => void
) => { ) => {
if (!relayUrls.includes(SIGIT_RELAY)) { if (!relayUrls.includes(SIGIT_RELAY)) {
// Add app relay to relays array if not exists already /**
relayUrls.push(SIGIT_RELAY) * NOTE: To avoid side-effects on external relayUrls array passed as argument
* re-assigned relayUrls with added sigit relay instead of just appending to same array
*/
relayUrls = [...relayUrls, SIGIT_RELAY] // Add app relay to relays array if not exists already
} }
// connect to all specified relays // connect to all specified relays
@ -277,8 +284,11 @@ export class RelayController {
relayUrls: string[] = [] relayUrls: string[] = []
): Promise<string[]> => { ): Promise<string[]> => {
if (!relayUrls.includes(SIGIT_RELAY)) { if (!relayUrls.includes(SIGIT_RELAY)) {
// Add app relay to relays array if not exists already /**
relayUrls.push(SIGIT_RELAY) * NOTE: To avoid side-effects on external relayUrls array passed as argument
* re-assigned relayUrls with added sigit relay instead of just appending to same array
*/
relayUrls = [...relayUrls, SIGIT_RELAY] // Add app relay to relays array if not exists already
} }
// connect to all specified relays // connect to all specified relays

6
src/utils/relays.ts
View File

@ -130,7 +130,6 @@ const getRelayMap = async (
authors: [npub] authors: [npub]
} }
console.count('getRelayMap')
const event = await relayController const event = await relayController
.fetchEvent(eventFilter, DEFAULT_LOOK_UP_RELAY_LIST) .fetchEvent(eventFilter, DEFAULT_LOOK_UP_RELAY_LIST)
.catch((err) => { .catch((err) => {
@ -155,10 +154,9 @@ const getRelayMap = async (
} }
}) })
Object.keys(relaysMap).forEach((relayUrl) => { Object.keys(relaysMap).forEach((relayUrl) =>
console.log('being called from getRelayMap')
relayController.connectRelay(relayUrl) relayController.connectRelay(relayUrl)
}) )
getRelayInfo(Object.keys(relaysMap)) getRelayInfo(Object.keys(relaysMap))