cleanup
This commit is contained in:
parent
166152cd84
commit
55fcbb0754
|
@ -1,7 +1,7 @@
|
||||||
# SPDX-FileCopyrightText: ☭ 2021 Emery Hemingway
|
# SPDX-FileCopyrightText: ☭ 2021 Emery Hemingway
|
||||||
# SPDX-License-Identifier: Unlicense
|
# SPDX-License-Identifier: Unlicense
|
||||||
|
|
||||||
import std/[asyncdispatch, hashes, macros, options, tables]
|
import std/[hashes, macros, tables]
|
||||||
import preserves
|
import preserves
|
||||||
import ../syndicate/protocols/[dataspace, dataspacePatterns]
|
import ../syndicate/protocols/[dataspace, dataspacePatterns]
|
||||||
import ./actors, ./bags
|
import ./actors, ./bags
|
||||||
|
@ -9,7 +9,6 @@ import ./actors, ./bags
|
||||||
from ../syndicate/protocols/protocol import Handle
|
from ../syndicate/protocols/protocol import Handle
|
||||||
|
|
||||||
type
|
type
|
||||||
Value = Preserve[Ref]
|
|
||||||
Pattern* = dataspacePatterns.Pattern[Ref]
|
Pattern* = dataspacePatterns.Pattern[Ref]
|
||||||
Observe = dataspace.Observe[Ref]
|
Observe = dataspace.Observe[Ref]
|
||||||
Turn = actors.Turn
|
Turn = actors.Turn
|
||||||
|
|
|
@ -4,8 +4,7 @@
|
||||||
import std/[macros, tables]
|
import std/[macros, tables]
|
||||||
|
|
||||||
import preserves
|
import preserves
|
||||||
import ../syndicate/protocols/[dataspacePatterns, simpleChatProtocol]
|
import ../syndicate/protocols/dataspacePatterns
|
||||||
|
|
||||||
from ./actors import Ref
|
from ./actors import Ref
|
||||||
|
|
||||||
export dataspacePatterns.`$`
|
export dataspacePatterns.`$`
|
||||||
|
|
|
@ -107,14 +107,6 @@ proc newSyncPeerEntity(r: Relay; p: Ref): SyncPeerEntity =
|
||||||
syncPeerMessage,
|
syncPeerMessage,
|
||||||
syncPeerSync)
|
syncPeerSync)
|
||||||
|
|
||||||
#[
|
|
||||||
proc `$`(ws: WireSymbol): string =
|
|
||||||
"<ws:" & $ws.oid & "/" & $ws.count & "/" & $ws.`ref` &>"
|
|
||||||
]#
|
|
||||||
|
|
||||||
proc `$`(re: RelayEntity): string =
|
|
||||||
"<Relay:" & re.label & ":" & $re.oid & ">"
|
|
||||||
|
|
||||||
proc rewriteRefOut(relay: Relay; `ref`: Ref; transient: bool; exported: var seq[WireSymbol]): WireRef =
|
proc rewriteRefOut(relay: Relay; `ref`: Ref; transient: bool; exported: var seq[WireSymbol]): WireRef =
|
||||||
#[
|
#[
|
||||||
if not relay.untrusted:
|
if not relay.untrusted:
|
||||||
|
@ -336,7 +328,7 @@ proc spawnRelay(name: string; turn: var Turn; opts: RelayActorOptions): Future[R
|
||||||
else: oid
|
else: oid
|
||||||
fut
|
fut
|
||||||
|
|
||||||
import std/[asyncdispatch, asyncnet]
|
import std/asyncnet
|
||||||
from std/nativesockets import AF_UNIX, SOCK_STREAM, Protocol
|
from std/nativesockets import AF_UNIX, SOCK_STREAM, Protocol
|
||||||
|
|
||||||
import protocols/gatekeeper
|
import protocols/gatekeeper
|
||||||
|
|
Loading…
Reference in New Issue