Kieran/snort
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactoring from previous pr

Browse Source
This commit is contained in:
ennmichael 2023-02-27 00:00:08 +01:00
parent 408be48082
commit fe45cb4beb
No known key found for this signature in database
GPG Key ID: 6E6E183431A26AF7
2 changed files with 23 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
packages/nostr/src/client/conn.ts
View File

@ -122,8 +122,8 @@ export interface IncomingNotice {
*/
export type OutgoingMessage =
| OutgoingEvent
| OutgoingSubscription
| OutgoingUnsubscription
| OutgoingOpenSubscription
| OutgoingCloseSubscription
export const enum OutgoingKind {
Event,
@ -140,18 +140,18 @@ export interface OutgoingEvent {
}
/**
* Outgoing "REQ" message, representing a subscription.
* Outgoing "REQ" message, which opens a subscription.
*/
export interface OutgoingSubscription {
export interface OutgoingOpenSubscription {
kind: OutgoingKind.Subscription
id: SubscriptionId
filters: Filters
}
/**
* Outgoing "CLOSE" message, representing an unsubscription.
* Outgoing "CLOSE" message, which closes a subscription.
*/
export interface OutgoingUnsubscription {
export interface OutgoingCloseSubscription {
kind: OutgoingKind.Unsubscription
id: SubscriptionId
}

35
packages/nostr/src/client/index.ts
View File

@ -12,24 +12,7 @@ export class Nostr {
/**
* Open connections to relays.
*/
readonly #conns: Map<
string,
{
conn: Conn
/**
* Has this connection been authenticated via NIP-44 AUTH?
*/
auth: boolean
/**
* Should this connection be used for receiving messages?
*/
read: boolean
/**
* Should this connection be used for publishing events?
*/
write: boolean
}
> = new Map()
readonly #conns: Map<string, ConnState> = new Map()
/**
* Mapping of subscription IDs to corresponding filters.
@ -236,6 +219,22 @@ export class Nostr {
}
}
interface ConnState {
conn: Conn
/**
* Has this connection been authenticated via NIP-44 AUTH?
*/
auth: boolean
/**
* Should this connection be used for receiving messages?
*/
read: boolean
/**
* Should this connection be used for publishing events?
*/
write: boolean
}
/**
* A string uniquely identifying a client subscription.
*/