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

feat: implemented relay controller and use that for fetching and publishing events #149

Merged
s merged 10 commits from relay-controller into staging 2024-08-20 12:13:23 +00:00
Conversation 1 Commits 10 Files Changed 20 +6 -13
1 changed files with 6 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit e0d6c03639 - Show all commits

19
src/controllers/RelayController.ts
View File

@ -86,11 +86,8 @@ export class RelayController {
filter: Filter, filter: Filter,
relayUrls: string[] = [] relayUrls: string[] = []
): Promise<Event[]> => { ): Promise<Event[]> => {
// add app relay to relays array // Add app relay to relays array and connect to all specified relays
relayUrls.push(SIGIT_RELAY) const relayPromises = [...relayUrls, SIGIT_RELAY].map((relayUrl) =>
// Connect to all specified relays
const relayPromises = relayUrls.map((relayUrl) =>
this.connectRelay(relayUrl) this.connectRelay(relayUrl)
) )
@ -204,11 +201,9 @@ export class RelayController {
relayUrls: string[] = [], relayUrls: string[] = [],
eventHandler: (event: Event) => void eventHandler: (event: Event) => void
) => { ) => {
// add app relay to relays array // Add app relay to relays array and connect to all specified relays
relayUrls.push(SIGIT_RELAY)
// Connect to all specified relays const relayPromises = [...relayUrls, SIGIT_RELAY].map((relayUrl) =>
const relayPromises = relayUrls.map((relayUrl) =>
this.connectRelay(relayUrl) this.connectRelay(relayUrl)
) )
@ -263,11 +258,9 @@ export class RelayController {
event: Event, event: Event,
relayUrls: string[] = [] relayUrls: string[] = []
): Promise<string[]> => { ): Promise<string[]> => {
// add app relay to relays array // Add app relay to relays array and connect to all specified relays
relayUrls.push(SIGIT_RELAY)
// Connect to all specified relays const relayPromises = [...relayUrls, SIGIT_RELAY].map((relayUrl) =>
const relayPromises = relayUrls.map((relayUrl) =>
this.connectRelay(relayUrl) this.connectRelay(relayUrl)
) )