Skip to content

Welshman Docs / @welshman/net

@welshman/net

Enumerations

AdapterEvent

Defined in: packages/net/src/adapter.ts:18

Enumeration Members

Receive

Receive: "receive"

Defined in: packages/net/src/adapter.ts:19


AuthStateEvent

Defined in: packages/net/src/auth.ts:24

Enumeration Members

Status

Status: "status"

Defined in: packages/net/src/auth.ts:25


AuthStatus

Defined in: packages/net/src/auth.ts:9

Enumeration Members

DeniedSignature

DeniedSignature: "denied_signature"

Defined in: packages/net/src/auth.ts:13

Forbidden

Forbidden: "forbidden"

Defined in: packages/net/src/auth.ts:15

None

None: "none"

Defined in: packages/net/src/auth.ts:10

Ok

Ok: "ok"

Defined in: packages/net/src/auth.ts:16

PendingResponse

PendingResponse: "pending_response"

Defined in: packages/net/src/auth.ts:14

PendingSignature

PendingSignature: "pending_signature"

Defined in: packages/net/src/auth.ts:12

Requested

Requested: "requested"

Defined in: packages/net/src/auth.ts:11


ClientMessageType

Defined in: packages/net/src/message.ts:92

Enumeration Members

Auth

Auth: "AUTH"

Defined in: packages/net/src/message.ts:93

Close

Close: "CLOSE"

Defined in: packages/net/src/message.ts:94

Event

Event: "EVENT"

Defined in: packages/net/src/message.ts:95

NegClose

NegClose: "NEG-CLOSE"

Defined in: packages/net/src/message.ts:96

NegOpen

NegOpen: "NEG-OPEN"

Defined in: packages/net/src/message.ts:97

Req

Req: "REQ"

Defined in: packages/net/src/message.ts:98


DifferenceEvent

Defined in: packages/net/src/diff.ts:16

Enumeration Members

Close

Close: "close"

Defined in: packages/net/src/diff.ts:19

Error

Error: "error"

Defined in: packages/net/src/diff.ts:18

Message

Message: "message"

Defined in: packages/net/src/diff.ts:17


PublishStatus

Defined in: packages/net/src/publish.ts:6

Enumeration Members

Aborted

Aborted: "aborted"

Defined in: packages/net/src/publish.ts:12

Failure

Failure: "failure"

Defined in: packages/net/src/publish.ts:10

Pending

Pending: "pending"

Defined in: packages/net/src/publish.ts:8

Sending

Sending: "sending"

Defined in: packages/net/src/publish.ts:7

Success

Success: "success"

Defined in: packages/net/src/publish.ts:9

Timeout

Timeout: "timeout"

Defined in: packages/net/src/publish.ts:11


RelayMessageType

Defined in: packages/net/src/message.ts:5

Enumeration Members

Auth

Auth: "AUTH"

Defined in: packages/net/src/message.ts:7

Closed

Closed: "CLOSED"

Defined in: packages/net/src/message.ts:8

Eose

Eose: "EOSE"

Defined in: packages/net/src/message.ts:9

Event

Event: "EVENT"

Defined in: packages/net/src/message.ts:10

NegErr

NegErr: "NEG-ERR"

Defined in: packages/net/src/message.ts:12

NegMsg

NegMsg: "NEG-MSG"

Defined in: packages/net/src/message.ts:11

Notice

Notice: "NOTICE"

Defined in: packages/net/src/message.ts:6

Ok

Ok: "OK"

Defined in: packages/net/src/message.ts:13


RelayReasonPrefix

Defined in: packages/net/src/message.ts:66

Enumeration Members

AuthRequired

AuthRequired: "auth-required"

Defined in: packages/net/src/message.ts:67

Blocked

Blocked: "blocked"

Defined in: packages/net/src/message.ts:68

Invalid

Invalid: "invalid"

Defined in: packages/net/src/message.ts:69

Mute

Mute: "mute"

Defined in: packages/net/src/message.ts:70

Pow

Pow: "pow"

Defined in: packages/net/src/message.ts:71

Restricted

Restricted: "restricted"

Defined in: packages/net/src/message.ts:72

Unsupported

Unsupported: "unsupported"

Defined in: packages/net/src/message.ts:73


SocketEvent

Defined in: packages/net/src/socket.ts:16

Enumeration Members

Error

Error: "error"

Defined in: packages/net/src/socket.ts:17

Receive

Receive: "receive"

Defined in: packages/net/src/socket.ts:21

Receiving

Receiving: "receiving"

Defined in: packages/net/src/socket.ts:22

Send

Send: "send"

Defined in: packages/net/src/socket.ts:19

Sending

Sending: "sending"

Defined in: packages/net/src/socket.ts:20

Status

Status: "status"

Defined in: packages/net/src/socket.ts:18


SocketStatus

Defined in: packages/net/src/socket.ts:8

Enumeration Members

Closed

Closed: "closed"

Defined in: packages/net/src/socket.ts:12

Closing

Closing: "closing"

Defined in: packages/net/src/socket.ts:11

Error

Error: "error"

Defined in: packages/net/src/socket.ts:13

Open

Open: "open"

Defined in: packages/net/src/socket.ts:9

Opening

Opening: "opening"

Defined in: packages/net/src/socket.ts:10

Classes

Type Aliases

AdapterContext

AdapterContext = Partial<NetContext>

Defined in: packages/net/src/adapter.ts:151


AdapterEvents

AdapterEvents = object

Defined in: packages/net/src/adapter.ts:22

Properties

receive()

receive: (message, url) => void

Defined in: packages/net/src/adapter.ts:23

Parameters
message

RelayMessage

url

string

Returns

void


AdapterFactory()

AdapterFactory = (url, context) => AbstractAdapter | undefined

Defined in: packages/net/src/context.ts:5

Parameters

url

string

context

NetContext

Returns

AbstractAdapter | undefined


AuthResult

AuthResult = object

Defined in: packages/net/src/auth.ts:19

Properties

ok

ok: boolean

Defined in: packages/net/src/auth.ts:20

reason?

optional reason: string

Defined in: packages/net/src/auth.ts:21


AuthStateEvents

AuthStateEvents = object

Defined in: packages/net/src/auth.ts:28

Properties

status()

status: (status) => void

Defined in: packages/net/src/auth.ts:29

Parameters
status

AuthStatus

Returns

void


BaseRequestOptions

BaseRequestOptions = object

Defined in: packages/net/src/request.ts:41

Properties

autoClose?

optional autoClose: boolean

Defined in: packages/net/src/request.ts:46

context?

optional context: AdapterContext

Defined in: packages/net/src/request.ts:45

isEventValid?

optional isEventValid: IsEventValid

Defined in: packages/net/src/request.ts:48

onClose()?

optional onClose: () => void

Defined in: packages/net/src/request.ts:57

Returns

void

onClosed()?

optional onClosed: (message, url) => void

Defined in: packages/net/src/request.ts:56

Parameters
message

string

url

string

Returns

void

onDeleted()?

optional onDeleted: (event, url) => void

Defined in: packages/net/src/request.ts:50

Parameters
event

unknown

url

string

Returns

void

onDisconnect()?

optional onDisconnect: (url) => void

Defined in: packages/net/src/request.ts:54

Parameters
url

string

Returns

void

onDuplicate()?

optional onDuplicate: (event, url) => void

Defined in: packages/net/src/request.ts:53

Parameters
event

TrustedEvent

url

string

Returns

void

onEose()?

optional onEose: (url) => void

Defined in: packages/net/src/request.ts:55

Parameters
url

string

Returns

void

onEvent()?

optional onEvent: (event, url) => void

Defined in: packages/net/src/request.ts:49

Parameters
event

TrustedEvent

url

string

Returns

void

onFiltered()?

optional onFiltered: (event, url) => void

Defined in: packages/net/src/request.ts:52

Parameters
event

TrustedEvent

url

string

Returns

void

onInvalid()?

optional onInvalid: (event, url) => void

Defined in: packages/net/src/request.ts:51

Parameters
event

unknown

url

string

Returns

void

priority?

optional priority: number

Defined in: packages/net/src/request.ts:43

resubscribeAttempts?

optional resubscribeAttempts: number

Defined in: packages/net/src/request.ts:47

signal?

optional signal: AbortSignal

Defined in: packages/net/src/request.ts:42

tracker?

optional tracker: Tracker

Defined in: packages/net/src/request.ts:44


ClientAuth

ClientAuth = [Auth, ...ClientAuthPayload]

Defined in: packages/net/src/message.ts:115


ClientAuthPayload

ClientAuthPayload = [string]

Defined in: packages/net/src/message.ts:103


ClientClose

ClientClose = [Close, ...ClientClosePayload]

Defined in: packages/net/src/message.ts:117


ClientClosePayload

ClientClosePayload = [string]

Defined in: packages/net/src/message.ts:105


ClientEvent

ClientEvent = [Event, ...ClientEventPayload]

Defined in: packages/net/src/message.ts:119


ClientEventPayload

ClientEventPayload = [SignedEvent]

Defined in: packages/net/src/message.ts:107


ClientMessage

ClientMessage = any[]

Defined in: packages/net/src/message.ts:101


ClientNegClose

ClientNegClose = [NegClose, ...ClientNegClosePayload]

Defined in: packages/net/src/message.ts:121


ClientNegClosePayload

ClientNegClosePayload = [string]

Defined in: packages/net/src/message.ts:109


ClientNegOpen

ClientNegOpen = [NegOpen, ...ClientNegOpenPayload]

Defined in: packages/net/src/message.ts:123


ClientNegOpenPayload

ClientNegOpenPayload = [string, Filter, string]

Defined in: packages/net/src/message.ts:111


ClientReq

ClientReq = [Req, ...ClientReqPayload]

Defined in: packages/net/src/message.ts:125


ClientReqPayload

ClientReqPayload = [string, Filter]

Defined in: packages/net/src/message.ts:113


DifferenceEvents

DifferenceEvents = object

Defined in: packages/net/src/diff.ts:22

Properties

close()

close: () => void

Defined in: packages/net/src/diff.ts:25

Returns

void

error()

error: (error, url) => void

Defined in: packages/net/src/diff.ts:24

Parameters
error

string

url

string

Returns

void

message()

message: (payload, url) => void

Defined in: packages/net/src/diff.ts:23

Parameters
payload
have

string[]

need

string[]

url

string

Returns

void


DifferenceOptions

DifferenceOptions = object

Defined in: packages/net/src/diff.ts:28

Properties

context?

optional context: AdapterContext

Defined in: packages/net/src/diff.ts:33

events

events: SignedEvent[]

Defined in: packages/net/src/diff.ts:31

filter

filter: Filter

Defined in: packages/net/src/diff.ts:30

relay

relay: string

Defined in: packages/net/src/diff.ts:29

signal?

optional signal: AbortSignal

Defined in: packages/net/src/diff.ts:32


DiffItem

DiffItem = object

Defined in: packages/net/src/diff.ts:136

Properties

have

have: Set<string>

Defined in: packages/net/src/diff.ts:138

need

need: Set<string>

Defined in: packages/net/src/diff.ts:139

relay

relay: string

Defined in: packages/net/src/diff.ts:137


DiffOptions

DiffOptions = object

Defined in: packages/net/src/diff.ts:128

Properties

context?

optional context: AdapterContext

Defined in: packages/net/src/diff.ts:133

events

events: SignedEvent[]

Defined in: packages/net/src/diff.ts:131

filters

filters: Filter[]

Defined in: packages/net/src/diff.ts:130

relays

relays: string[]

Defined in: packages/net/src/diff.ts:129

signal?

optional signal: AbortSignal

Defined in: packages/net/src/diff.ts:132


IsEventValid()

IsEventValid = (event, url) => boolean

Defined in: packages/net/src/request.ts:39

Parameters

event

TrustedEvent

url

string

Returns

boolean


Loader()

Loader = (options) => Promise<TrustedEvent[]>

Defined in: packages/net/src/request.ts:313

Parameters

options

LoadOptions

Returns

Promise<TrustedEvent[]>


LoaderOptions

LoaderOptions = object

Defined in: packages/net/src/request.ts:295

Properties

context?

optional context: AdapterContext

Defined in: packages/net/src/request.ts:299

delay

delay: number

Defined in: packages/net/src/request.ts:296

isEventValid()?

optional isEventValid: (event, url) => boolean

Defined in: packages/net/src/request.ts:300

Parameters
event

TrustedEvent

url

string

Returns

boolean

threshold?

optional threshold: number

Defined in: packages/net/src/request.ts:298

timeout?

optional timeout: number

Defined in: packages/net/src/request.ts:297


LoadOptions

LoadOptions = object

Defined in: packages/net/src/request.ts:303

Properties

filters

filters: Filter[]

Defined in: packages/net/src/request.ts:305

onClose()?

optional onClose: () => void

Defined in: packages/net/src/request.ts:310

Returns

void

onDisconnect()?

optional onDisconnect: (url) => void

Defined in: packages/net/src/request.ts:308

Parameters
url

string

Returns

void

onEose()?

optional onEose: (url) => void

Defined in: packages/net/src/request.ts:309

Parameters
url

string

Returns

void

onEvent()?

optional onEvent: (event, url) => void

Defined in: packages/net/src/request.ts:307

Parameters
event

TrustedEvent

url

string

Returns

void

relays

relays: string[]

Defined in: packages/net/src/request.ts:304

signal?

optional signal: AbortSignal

Defined in: packages/net/src/request.ts:306


NetContext

NetContext = object

Defined in: packages/net/src/context.ts:7

Properties

getAdapter?

optional getAdapter: AdapterFactory

Defined in: packages/net/src/context.ts:10

pool?

optional pool: Pool

Defined in: packages/net/src/context.ts:8

repository?

optional repository: Repository

Defined in: packages/net/src/context.ts:9


PoolSubscription()

PoolSubscription = (socket) => void

Defined in: packages/net/src/pool.ts:6

Parameters

socket

Socket

Returns

void


PublishOneOptions

PublishOneOptions = object

Defined in: packages/net/src/publish.ts:21

Properties

context?

optional context: AdapterContext

Defined in: packages/net/src/publish.ts:27

event

event: SignedEvent

Defined in: packages/net/src/publish.ts:22

onAborted()?

optional onAborted: (result) => void

Defined in: packages/net/src/publish.ts:32

Parameters
result

PublishResult

Returns

void

onComplete()?

optional onComplete: (result) => void

Defined in: packages/net/src/publish.ts:33

Parameters
result

PublishResult

Returns

void

onFailure()?

optional onFailure: (result) => void

Defined in: packages/net/src/publish.ts:29

Parameters
result

PublishResult

Returns

void

onPending()?

optional onPending: (result) => void

Defined in: packages/net/src/publish.ts:30

Parameters
result

PublishResult

Returns

void

onSuccess()?

optional onSuccess: (result) => void

Defined in: packages/net/src/publish.ts:28

Parameters
result

PublishResult

Returns

void

onTimeout()?

optional onTimeout: (result) => void

Defined in: packages/net/src/publish.ts:31

Parameters
result

PublishResult

Returns

void

priority?

optional priority: number

Defined in: packages/net/src/publish.ts:25

relay

relay: string

Defined in: packages/net/src/publish.ts:23

signal?

optional signal: AbortSignal

Defined in: packages/net/src/publish.ts:24

timeout?

optional timeout: number

Defined in: packages/net/src/publish.ts:26


PublishOptions

PublishOptions = object

Defined in: packages/net/src/publish.ts:127

Properties

context?

optional context: AdapterContext

Defined in: packages/net/src/publish.ts:133

event

event: SignedEvent

Defined in: packages/net/src/publish.ts:128

onAborted()?

optional onAborted: (result) => void

Defined in: packages/net/src/publish.ts:138

Parameters
result

PublishResult

Returns

void

onComplete()?

optional onComplete: (result) => void

Defined in: packages/net/src/publish.ts:139

Parameters
result

PublishResult

Returns

void

onFailure()?

optional onFailure: (result) => void

Defined in: packages/net/src/publish.ts:135

Parameters
result

PublishResult

Returns

void

onPending()?

optional onPending: (result) => void

Defined in: packages/net/src/publish.ts:136

Parameters
result

PublishResult

Returns

void

onSuccess()?

optional onSuccess: (result) => void

Defined in: packages/net/src/publish.ts:134

Parameters
result

PublishResult

Returns

void

onTimeout()?

optional onTimeout: (result) => void

Defined in: packages/net/src/publish.ts:137

Parameters
result

PublishResult

Returns

void

priority?

optional priority: number

Defined in: packages/net/src/publish.ts:131

relays

relays: string[]

Defined in: packages/net/src/publish.ts:129

signal?

optional signal: AbortSignal

Defined in: packages/net/src/publish.ts:130

timeout?

optional timeout: number

Defined in: packages/net/src/publish.ts:132


PublishResult

PublishResult = object

Defined in: packages/net/src/publish.ts:15

Properties

detail

detail: string

Defined in: packages/net/src/publish.ts:17

relay

relay: string

Defined in: packages/net/src/publish.ts:18

status

status: PublishStatus

Defined in: packages/net/src/publish.ts:16


PublishResultsByRelay

PublishResultsByRelay = Record<string, PublishResult>

Defined in: packages/net/src/publish.ts:125


PullOptions

PullOptions = DiffOptions

Defined in: packages/net/src/diff.ts:190


PushOptions

PushOptions = DiffOptions

Defined in: packages/net/src/diff.ts:243


RelayAuth

RelayAuth = [Auth, ...RelayAuthPayload]

Defined in: packages/net/src/message.ts:36


RelayAuthPayload

RelayAuthPayload = [string]

Defined in: packages/net/src/message.ts:20


RelayClosed

RelayClosed = [Closed, ...RelayClosedPayload]

Defined in: packages/net/src/message.ts:38


RelayClosedPayload

RelayClosedPayload = [string, string]

Defined in: packages/net/src/message.ts:22


RelayEose

RelayEose = [Eose, ...RelayEosePayload]

Defined in: packages/net/src/message.ts:40


RelayEosePayload

RelayEosePayload = [string]

Defined in: packages/net/src/message.ts:24


RelayEvent

RelayEvent = [Event, ...RelayEventPayload]

Defined in: packages/net/src/message.ts:42


RelayEventPayload

RelayEventPayload = [string, SignedEvent]

Defined in: packages/net/src/message.ts:26


RelayMessage

RelayMessage = any[]

Defined in: packages/net/src/message.ts:16


RelayNegErr

RelayNegErr = [NegErr, ...RelayNegErrPayload]

Defined in: packages/net/src/message.ts:44


RelayNegErrPayload

RelayNegErrPayload = [string, string]

Defined in: packages/net/src/message.ts:28


RelayNegMsg

RelayNegMsg = [NegMsg, ...RelayNegMsgPayload]

Defined in: packages/net/src/message.ts:46


RelayNegMsgPayload

RelayNegMsgPayload = [string, string]

Defined in: packages/net/src/message.ts:30


RelayNotice

RelayNotice = [Notice, ...RelayNoticePayload]

Defined in: packages/net/src/message.ts:34


RelayNoticePayload

RelayNoticePayload = [string]

Defined in: packages/net/src/message.ts:18


RelayOk

RelayOk = [Ok, ...RelayOkPayload]

Defined in: packages/net/src/message.ts:48


RelayOkPayload

RelayOkPayload = [string, boolean, string]

Defined in: packages/net/src/message.ts:32


RepositoryUpdate

RepositoryUpdate = object

Defined in: packages/net/src/repository.ts:32

Properties

added

added: TrustedEvent[]

Defined in: packages/net/src/repository.ts:33

removed

removed: Set<string>

Defined in: packages/net/src/repository.ts:34


RequestOneOptions

RequestOneOptions = BaseRequestOptions & object

Defined in: packages/net/src/request.ts:60

Type declaration

filters

filters: Filter[]

relay

relay: string


RequestOptions

RequestOptions = BaseRequestOptions & object

Defined in: packages/net/src/request.ts:255

Type declaration

filters

filters: Filter[]

relays

relays: string[]

threshold?

optional threshold: number


SocketEvents

SocketEvents = object

Defined in: packages/net/src/socket.ts:25

Properties

error()

error: (error, url) => void

Defined in: packages/net/src/socket.ts:26

Parameters
error

string

url

string

Returns

void

receive()

receive: (message, url) => void

Defined in: packages/net/src/socket.ts:30

Parameters
message

RelayMessage

url

string

Returns

void

receiving()

receiving: (message, url) => void

Defined in: packages/net/src/socket.ts:31

Parameters
message

RelayMessage

url

string

Returns

void

send()

send: (message, url) => void

Defined in: packages/net/src/socket.ts:28

Parameters
message

ClientMessage

url

string

Returns

void

sending()

sending: (message, url) => void

Defined in: packages/net/src/socket.ts:29

Parameters
message

ClientMessage

url

string

Returns

void

status()

status: (status, url) => void

Defined in: packages/net/src/socket.ts:27

Parameters
status

SocketStatus

url

string

Returns

void


SocketPolicy()

SocketPolicy = (socket) => Unsubscriber

Defined in: packages/net/src/socket.ts:34

Parameters

socket

Socket

Returns

Unsubscriber


SocketPolicyAuthOptions

SocketPolicyAuthOptions = object

Defined in: packages/net/src/policy.ts:282

Properties

shouldAuth()?

optional shouldAuth: (socket) => boolean

Defined in: packages/net/src/policy.ts:284

Parameters
socket

Socket

Returns

boolean

sign()

sign: (event) => Promise<SignedEvent>

Defined in: packages/net/src/policy.ts:283

Parameters
event

StampedEvent

Returns

Promise<SignedEvent>


WrapItem

WrapItem = Omit<HashedEvent, "content"> & object

Defined in: packages/net/src/wrapManager.ts:6

Type declaration

recipient

recipient: string

rumorId

rumorId: string


WrapManagerOptions

WrapManagerOptions = object

Defined in: packages/net/src/wrapManager.ts:13

Properties

repository

repository: Repository

Defined in: packages/net/src/wrapManager.ts:14

tracker

tracker: Tracker

Defined in: packages/net/src/wrapManager.ts:15


WrapReference

WrapReference = string[]

Defined in: packages/net/src/wrapManager.ts:11

Variables

DEFAULT_PRIORITY

const DEFAULT_PRIORITY: 0 = 0

Defined in: packages/net/src/message.ts:147


defaultSocketPolicies

const defaultSocketPolicies: SocketPolicy[]

Defined in: packages/net/src/policy.ts:308


load

const load: Loader

Defined in: packages/net/src/request.ts:438


LOCAL_RELAY_URL

const LOCAL_RELAY_URL: "local://welshman.relay/" = "local://welshman.relay/"

Defined in: packages/net/src/repository.ts:28


MessagePriority

const MessagePriority: typeof MessagePriority

Defined in: packages/net/src/message.ts:145

Functions

copyPriority()

copyPriority<T>(message, source): T

Defined in: packages/net/src/message.ts:163

Type Parameters

T

T extends ClientMessage

Parameters

message

T

source

ClientMessage

Returns

T


diff()

diff(__namedParameters): Promise<object[]>

Defined in: packages/net/src/diff.ts:142

Parameters

__namedParameters

DiffOptions

Returns

Promise<object[]>


getAdapter()

getAdapter(url, context): AbstractAdapter | SocketAdapter | LocalAdapter

Defined in: packages/net/src/adapter.ts:153

Parameters

url

string

context

Partial = {}

Returns

AbstractAdapter | SocketAdapter | LocalAdapter


getPriority()

getPriority(message): number

Defined in: packages/net/src/message.ts:160

Parameters

message

ClientMessage

Returns

number


isClientAuth()

isClientAuth(m): m is [Auth, string]

Defined in: packages/net/src/message.ts:127

Parameters

m

ClientMessage

Returns

m is [Auth, string]


isClientClose()

isClientClose(m): m is [Close, string]

Defined in: packages/net/src/message.ts:129

Parameters

m

ClientMessage

Returns

m is [Close, string]


isClientEvent()

isClientEvent(m): m is [Event, SignedEvent]

Defined in: packages/net/src/message.ts:132

Parameters

m

ClientMessage

Returns

m is [Event, SignedEvent]


isClientNegClose()

isClientNegClose(m): m is [NegClose, string]

Defined in: packages/net/src/message.ts:135

Parameters

m

ClientMessage

Returns

m is [NegClose, string]


isClientNegOpen()

isClientNegOpen(m): m is [NegOpen, string, Filter, string]

Defined in: packages/net/src/message.ts:138

Parameters

m

ClientMessage

Returns

m is [NegOpen, string, Filter, string]


isClientReq()

isClientReq(m): m is [Req, string, Filter]

Defined in: packages/net/src/message.ts:141

Parameters

m

ClientMessage

Returns

m is [Req, string, Filter]


isRelayAuth()

isRelayAuth(m): m is [Auth, string]

Defined in: packages/net/src/message.ts:52

Parameters

m

RelayMessage

Returns

m is [Auth, string]


isRelayClosed()

isRelayClosed(m): m is [Closed, string, string]

Defined in: packages/net/src/message.ts:54

Parameters

m

RelayMessage

Returns

m is [Closed, string, string]


isRelayEose()

isRelayEose(m): m is [Eose, string]

Defined in: packages/net/src/message.ts:56

Parameters

m

RelayMessage

Returns

m is [Eose, string]


isRelayEvent()

isRelayEvent(m): m is [Event, string, SignedEvent]

Defined in: packages/net/src/message.ts:58

Parameters

m

RelayMessage

Returns

m is [Event, string, SignedEvent]


isRelayNegErr()

isRelayNegErr(m): m is [NegErr, string, string]

Defined in: packages/net/src/message.ts:60

Parameters

m

RelayMessage

Returns

m is [NegErr, string, string]


isRelayNegMsg()

isRelayNegMsg(m): m is [NegMsg, string, string]

Defined in: packages/net/src/message.ts:62

Parameters

m

RelayMessage

Returns

m is [NegMsg, string, string]


isRelayNotice()

isRelayNotice(m): m is [Notice, string]

Defined in: packages/net/src/message.ts:50

Parameters

m

RelayMessage

Returns

m is [Notice, string]


isRelayOk()

isRelayOk(m): m is [Ok, string, boolean, string]

Defined in: packages/net/src/message.ts:64

Parameters

m

RelayMessage

Returns

m is [Ok, string, boolean, string]


isTerminalReason()

isTerminalReason(reason): boolean

Defined in: packages/net/src/message.ts:79

Parameters

reason

string = ""

Returns

boolean


makeLoader()

makeLoader(options): Loader

Defined in: packages/net/src/request.ts:322

Creates a convenience function which returns a promise of events from a request. It may return early if filter cardinality is known, and it delays requests in order to implement batching

Parameters

options

LoaderOptions

LoaderOptions

Returns

Loader

  • a load function

makeSocketPolicyAuth()

makeSocketPolicyAuth(options): (socket) => () => void

Defined in: packages/net/src/policy.ts:292

Factory function for a policy which may authenticate the socket

Parameters

options

SocketPolicyAuthOptions

SocketPolicyAuthOptions object

Returns

a socket policy

(socket): () => void

Parameters
socket

Socket

Returns

(): void

Returns

void


matchReason()

matchReason(prefix, reason): boolean

Defined in: packages/net/src/message.ts:76

Parameters

prefix

RelayReasonPrefix

reason

string

Returns

boolean


mergeRepositoryUpdates()

mergeRepositoryUpdates(updates): RepositoryUpdate

Defined in: packages/net/src/repository.ts:37

Parameters

updates

RepositoryUpdate[]

Returns

RepositoryUpdate


publish()

publish(options): Promise<PublishResultsByRelay>

Defined in: packages/net/src/publish.ts:142

Parameters

options

PublishOptions

Returns

Promise<PublishResultsByRelay>


publishOne()

publishOne(options): Promise<PublishResult>

Defined in: packages/net/src/publish.ts:36

Parameters

options

PublishOneOptions

Returns

Promise<PublishResult>


pull()

pull(__namedParameters): Promise<TrustedEvent[]>

Defined in: packages/net/src/diff.ts:192

Parameters

__namedParameters

DiffOptions

Returns

Promise<TrustedEvent[]>


push()

push(__namedParameters): Promise<void>

Defined in: packages/net/src/diff.ts:245

Parameters

__namedParameters

DiffOptions

Returns

Promise<void>


request()

request(options): Promise<TrustedEvent[]>

Defined in: packages/net/src/request.ts:261

Parameters

options

RequestOptions

Returns

Promise<TrustedEvent[]>


requestOne()

requestOne(options): Promise<TrustedEvent[]>

Defined in: packages/net/src/request.ts:65

Parameters

options

RequestOneOptions

Returns

Promise<TrustedEvent[]>


setPriority()

setPriority<T>(message, priority): T

Defined in: packages/net/src/message.ts:149

Type Parameters

T

T extends ClientMessage

Parameters

message

T

priority

number = DEFAULT_PRIORITY

Returns

T


socketPolicyAuthBuffer()

socketPolicyAuthBuffer(socket): () => void

Defined in: packages/net/src/policy.ts:32

Handles auth-related message management:

  • Defers sending messages when a challenge is pending
  • Re-enqueues event/req messages once if rejected due to auth-required

Parameters

socket

Socket

a Socket object

Returns

a cleanup function

(): void

Returns

void


socketPolicyCancelUnsent()

socketPolicyCancelUnsent(socket): () => void

Defined in: packages/net/src/policy.ts:103

Drops subscriptions that are closed before they've been sent, along with the close message itself. Besides saving a round trip, this keeps a prioritized close from jumping ahead of its own req, which would leave the subscription open on the relay.

Parameters

socket

Socket

a Socket object

Returns

a cleanup function

(): void

Returns

void


socketPolicyConnectOnSend()

socketPolicyConnectOnSend(socket): () => void

Defined in: packages/net/src/policy.ts:136

Auto-connects a closed socket when a message is sent unless there was a recent error

Parameters

socket

Socket

a Socket object

Returns

a cleanup function

(): void

Returns

void


socketPolicyLifecycle()

socketPolicyLifecycle(socket): () => void

Defined in: packages/net/src/policy.ts:171

Owns a socket's lifecycle: closes it once nothing needs it, checks the relay is still there when something does, reopens it, and catches up on what it missed.

Parameters

socket

Socket

a Socket object

Returns

a cleanup function

(): void

Returns

void