diff --git a/packages/net/__tests__/auth.test.ts b/packages/net/__tests__/auth.test.ts index 39c26fd..b9c92e4 100644 --- a/packages/net/__tests__/auth.test.ts +++ b/packages/net/__tests__/auth.test.ts @@ -123,7 +123,7 @@ describe("auth", () => { socket.auth.status = AuthStatus.PendingResponse await expect(socket.auth.doAuth(sign)).rejects.toThrow( - "Attempted to authenticate when auth is already auth:status:pending_response", + "Attempted to authenticate when auth is already pending_response", ) }) diff --git a/packages/net/src/adapter.ts b/packages/net/src/adapter.ts index 8ec02fb..4d0eeb0 100644 --- a/packages/net/src/adapter.ts +++ b/packages/net/src/adapter.ts @@ -16,7 +16,7 @@ import {Unsubscriber} from "./util.js" import {netContext, NetContext} from "./context.js" export enum AdapterEvent { - Receive = "adapter:event:receive", + Receive = "receive", } export type AdapterEvents = { diff --git a/packages/net/src/auth.ts b/packages/net/src/auth.ts index 595dbb6..a5c264b 100644 --- a/packages/net/src/auth.ts +++ b/packages/net/src/auth.ts @@ -7,13 +7,13 @@ import {Socket, SocketStatus, SocketEvent} from "./socket.js" import {Unsubscriber} from "./util.js" export enum AuthStatus { - None = "auth:status:none", - Requested = "auth:status:requested", - PendingSignature = "auth:status:pending_signature", - DeniedSignature = "auth:status:denied_signature", - PendingResponse = "auth:status:pending_response", - Forbidden = "auth:status:forbidden", - Ok = "auth:status:ok", + None = "none", + Requested = "requested", + PendingSignature = "pending_signature", + DeniedSignature = "denied_signature", + PendingResponse = "pending_response", + Forbidden = "forbidden", + Ok = "ok", } export type AuthResult = { diff --git a/packages/net/src/diff.ts b/packages/net/src/diff.ts index cce455f..ac887ae 100644 --- a/packages/net/src/diff.ts +++ b/packages/net/src/diff.ts @@ -14,9 +14,9 @@ import {requestOne} from "./request.js" import {publish} from "./publish.js" export enum DifferenceEvent { - Message = "difference:event:message", - Error = "difference:event:error", - Close = "difference:event:close", + Message = "message", + Error = "error", + Close = "close", } export type DifferenceEvents = { diff --git a/packages/net/src/publish.ts b/packages/net/src/publish.ts index be71a36..4207a50 100644 --- a/packages/net/src/publish.ts +++ b/packages/net/src/publish.ts @@ -4,12 +4,12 @@ import {RelayMessage, ClientMessageType, isRelayOk} from "./message.js" import {AdapterEvent, AdapterContext, getAdapter} from "./adapter.js" export enum PublishStatus { - Sending = "publish:status:sending", - Pending = "publish:status:pending", - Success = "publish:status:success", - Failure = "publish:status:failure", - Timeout = "publish:status:timeout", - Aborted = "publish:status:aborted", + Sending = "sending", + Pending = "pending", + Success = "success", + Failure = "failure", + Timeout = "timeout", + Aborted = "aborted", } export type PublishResult = { diff --git a/packages/net/src/socket.ts b/packages/net/src/socket.ts index b678255..3526abc 100644 --- a/packages/net/src/socket.ts +++ b/packages/net/src/socket.ts @@ -5,20 +5,20 @@ import {RelayMessage, ClientMessage} from "./message.js" import {AuthState} from "./auth.js" export enum SocketStatus { - Open = "socket:status:open", - Opening = "socket:status:opening", - Closing = "socket:status:closing", - Closed = "socket:status:closed", - Error = "socket:status:error", + Open = "open", + Opening = "opening", + Closing = "closing", + Closed = "closed", + Error = "error", } export enum SocketEvent { - Error = "socket:event:error", - Status = "socket:event:status", - Send = "socket:event:send", - Sending = "socket:event:sending", - Receive = "socket:event:receive", - Receiving = "socket:event:receiving", + Error = "error", + Status = "status", + Send = "send", + Sending = "sending", + Receive = "receive", + Receiving = "receiving", } export type SocketEvents = { diff --git a/packages/net/src/wrapManager.ts b/packages/net/src/wrapManager.ts index 9d3f6d3..8b45b20 100644 --- a/packages/net/src/wrapManager.ts +++ b/packages/net/src/wrapManager.ts @@ -18,6 +18,7 @@ export type WrapManagerOptions = { export class WrapManager extends Emitter { _wrapIndex = new Map() _rumorIndex = new Map() + _recipientIndex = new Map() constructor(readonly options: WrapManagerOptions) { super() @@ -28,7 +29,7 @@ export class WrapManager extends Emitter { dump = () => Array.from(this._wrapIndex.values()) getWraps = (rumorId: string) => - this._rumorIndex.get(rumorId).map(wrapId => this._wrapIndex.get(wrapId)!) + (this._rumorIndex.get(rumorId) || []).map(wrapId => this._wrapIndex.get(wrapId)!) getRumor = (wrapId: string) => { const wrapItem = this._wrapIndex.get(wrapId)