mirror of
https://github.com/logos-messaging/nim-chat-poc.git
synced 2026-01-04 07:03:13 +00:00
remove dead files
This commit is contained in:
Jazz Turner-Baggs
parent
1ca9c19113
commit
b2bd098474
191
src/dev.nim
191
src/dev.nim
@ -1,191 +0,0 @@
|
|||||||
import chronos
|
|
||||||
import chronicles
|
|
||||||
import strformat
|
|
||||||
import tables
|
|
||||||
|
|
||||||
import sds
|
|
||||||
|
|
||||||
import std/typetraits
|
|
||||||
import sequtils
|
|
||||||
|
|
||||||
logScope:
|
|
||||||
topics = "dev"
|
|
||||||
|
|
||||||
type A = ref object
|
|
||||||
asg: string
|
|
||||||
|
|
||||||
proc dir*[T](obj: T) =
|
|
||||||
echo "Object of type: ", T
|
|
||||||
for name, value in fieldPairs(obj):
|
|
||||||
if type(value) is string:
|
|
||||||
echo " ", name, ": ", value
|
|
||||||
if type(value) is Table:
|
|
||||||
echo "hmmmm"
|
|
||||||
|
|
||||||
proc `$`(rm: ReliabilityManager): string =
|
|
||||||
result = "RM"
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
type Msg = object
|
|
||||||
id*: string
|
|
||||||
shouldDrop: bool
|
|
||||||
data*: seq[byte]
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
proc send(rm: ReliabilityManager, channel: string, id: string, msg: seq[
|
|
||||||
byte]): seq[byte] =
|
|
||||||
result = rm.wrapOutgoingMessage(msg, id, channel).valueOr:
|
|
||||||
raise newException(ValueError, "Bad outgoing message")
|
|
||||||
|
|
||||||
proc recv(rm: ReliabilityManager, bytes: seq[byte]) =
|
|
||||||
let (unwrapped, missingDeps, channelId) = rm.unwrapReceivedMessage(bytes).valueOr:
|
|
||||||
raise newException(ValueError, "Bad unwrap")
|
|
||||||
info "RECV", channel = channelId, data = unwrapped, mdeps = missingDeps
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
proc main() {.async.} =
|
|
||||||
|
|
||||||
var messageSentCount = 0
|
|
||||||
let CHANNEL = "CHANNEL"
|
|
||||||
let msg = @[byte(1), 2, 3]
|
|
||||||
let msgId = "test-msg-1"
|
|
||||||
|
|
||||||
var rm = newReliabilityManager().valueOr:
|
|
||||||
raise newException(ValueError, fmt"SDS InitializationError")
|
|
||||||
|
|
||||||
rm.setCallbacks(
|
|
||||||
proc(messageId: SdsMessageID, channelId: SdsChannelID) {.gcsafe.} =
|
|
||||||
echo "OnMsgReady"
|
|
||||||
discard,
|
|
||||||
proc(messageId: SdsMessageID, channelId: SdsChannelID) {.gcsafe.} =
|
|
||||||
echo "OnMsgSent"
|
|
||||||
messageSentCount += 1,
|
|
||||||
proc(messageId: SdsMessageID, missingDeps: seq[SdsMessageID],
|
|
||||||
channelId: SdsChannelID) {.gcsafe.} =
|
|
||||||
echo "OnMissing"
|
|
||||||
discard,
|
|
||||||
)
|
|
||||||
|
|
||||||
|
|
||||||
let sourceMsgs = @[Msg(id: "1", shouldDrop: false, data: @[byte(1), 2, 3]),
|
|
||||||
Msg(id: "2", shouldDrop: true, data: @[byte(0), 5, 6]),
|
|
||||||
Msg(id: "3", shouldDrop: false, data: @[byte(7), 8, 9]),
|
|
||||||
]
|
|
||||||
rm.ensureChannel(CHANNEL).isOkOr:
|
|
||||||
raise newException(ValueError, "Bad channel")
|
|
||||||
|
|
||||||
|
|
||||||
let encodedMessage = sourceMsgs.map(proc(m: Msg): seq[byte] =
|
|
||||||
rm.wrapOutgoingMessage(m.data, m.id, CHANNEL).valueOr:
|
|
||||||
raise newException(ValueError, "Bad outgoing message"))
|
|
||||||
|
|
||||||
var i = 0
|
|
||||||
var droppedMessages: seq[seq[byte]] = @[]
|
|
||||||
for x in encodedMessage:
|
|
||||||
if i mod 2 == 0:
|
|
||||||
droppedMessages.add(x)
|
|
||||||
inc(i)
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
# let droppedMessages = encodedMessage.keepIf(proc(item: seq[
|
|
||||||
# byte]): bool =
|
|
||||||
# items.find(item) mod 2 == 0
|
|
||||||
# )
|
|
||||||
# let droppedMessages = enumerate(encodedMessage).filter(proc(x: seq[
|
|
||||||
# byte]): bool = x[0] mod 2 == 0)
|
|
||||||
|
|
||||||
for s in droppedMessages:
|
|
||||||
info "DROPPED", len = len(s)
|
|
||||||
|
|
||||||
for m in droppedMessages:
|
|
||||||
let (unwrapped, missingDeps, channelId) = rm.unwrapReceivedMessage(m).valueOr:
|
|
||||||
raise newException(ValueError, "Bad unwrap")
|
|
||||||
|
|
||||||
info "RECV", channel = channelId, data = unwrapped, mdeps = missingDeps
|
|
||||||
|
|
||||||
|
|
||||||
proc messageSequence(){.async.} =
|
|
||||||
var messageSentCount = 0
|
|
||||||
let CHANNEL = "CHANNEL"
|
|
||||||
|
|
||||||
|
|
||||||
var raya = newReliabilityManager().valueOr:
|
|
||||||
raise newException(ValueError, fmt"SDS InitializationError")
|
|
||||||
|
|
||||||
var saro = newReliabilityManager().valueOr:
|
|
||||||
raise newException(ValueError, fmt"SDS InitializationError")
|
|
||||||
|
|
||||||
raya.setCallbacks(
|
|
||||||
proc(messageId: SdsMessageID, channelId: SdsChannelID) {.gcsafe.} =
|
|
||||||
debug "OnMsgReady", client = "raya", id = messageId
|
|
||||||
discard,
|
|
||||||
proc(messageId: SdsMessageID, channelId: SdsChannelID) {.gcsafe.} =
|
|
||||||
debug "OnMsgSent", client = "raya", id = messageId
|
|
||||||
messageSentCount += 1,
|
|
||||||
proc(messageId: SdsMessageID, missingDeps: seq[SdsMessageID],
|
|
||||||
channelId: SdsChannelID) {.gcsafe.} =
|
|
||||||
info "OnMissing", client = "raya", id = messageId
|
|
||||||
discard,
|
|
||||||
)
|
|
||||||
|
|
||||||
saro.setCallbacks(
|
|
||||||
proc(messageId: SdsMessageID, channelId: SdsChannelID) {.gcsafe.} =
|
|
||||||
debug "OnMsgReady", client = "saro", id = messageId
|
|
||||||
discard,
|
|
||||||
proc(messageId: SdsMessageID, channelId: SdsChannelID) {.gcsafe.} =
|
|
||||||
debug "OnMsgSent", client = "saro", id = messageId
|
|
||||||
messageSentCount += 1,
|
|
||||||
proc(messageId: SdsMessageID, missingDeps: seq[SdsMessageID],
|
|
||||||
channelId: SdsChannelID) {.gcsafe.} =
|
|
||||||
info "OnMissing", client = "saro", id = messageId
|
|
||||||
discard,
|
|
||||||
)
|
|
||||||
|
|
||||||
raya.ensureChannel(CHANNEL).isOkOr:
|
|
||||||
raise newException(ValueError, "Bad channel")
|
|
||||||
|
|
||||||
saro.ensureChannel(CHANNEL).isOkOr:
|
|
||||||
raise newException(ValueError, "Bad channel")
|
|
||||||
|
|
||||||
|
|
||||||
let s1 = saro.send(CHANNEL, "s1", @[byte(1), 1, 1])
|
|
||||||
raya.recv(s1)
|
|
||||||
|
|
||||||
let r1 = raya.send(CHANNEL, "r1", @[byte(2), 1, 2])
|
|
||||||
saro.recv(r1)
|
|
||||||
|
|
||||||
let r2 = raya.send(CHANNEL, "r2", @[byte(2), 2, 2])
|
|
||||||
# saro.recv(r2)
|
|
||||||
|
|
||||||
let r3 = raya.send(CHANNEL, "r3", @[byte(2), 3, 2])
|
|
||||||
saro.recv(r3)
|
|
||||||
|
|
||||||
let s2 = saro.send(CHANNEL, "s2", @[byte(1), 2, 1])
|
|
||||||
raya.recv(s2)
|
|
||||||
|
|
||||||
let s3 = saro.send(CHANNEL, "s3", @[byte(1), 3, 1])
|
|
||||||
raya.recv(s3)
|
|
||||||
|
|
||||||
|
|
||||||
let r4 = raya.send(CHANNEL, "r4", @[byte(2), 4, 2])
|
|
||||||
saro.recv(r4)
|
|
||||||
saro.recv(r2)
|
|
||||||
|
|
||||||
let r5 = raya.send(CHANNEL, "r5", @[byte(2), 5, 2])
|
|
||||||
saro.recv(r5)
|
|
||||||
|
|
||||||
let r6 = raya.send(CHANNEL, "r6", @[byte(2), 6, 2])
|
|
||||||
saro.recv(r6)
|
|
||||||
|
|
||||||
saro.recv(r4)
|
|
||||||
saro.recv(r3)
|
|
||||||
|
|
||||||
saro.recv(r4)
|
|
||||||
when isMainModule:
|
|
||||||
waitFor messageSequence()
|
|
||||||
echo ">>>"
|
|
||||||
185
src/tui2.nim
185
src/tui2.nim
@ -1,185 +0,0 @@
|
|||||||
import chronos
|
|
||||||
import chronicles
|
|
||||||
import strformat
|
|
||||||
|
|
||||||
import chat_sdk/client
|
|
||||||
import chat_sdk/identity
|
|
||||||
import chat_sdk/conversations
|
|
||||||
import chat_sdk/delivery/waku_client
|
|
||||||
import chat_sdk/utils
|
|
||||||
import chat_sdk/proto_types
|
|
||||||
|
|
||||||
import content_types/all
|
|
||||||
import libp2p/crypto/crypto
|
|
||||||
# import libp2p/crypto/secp256k1
|
|
||||||
import os
|
|
||||||
import std/sequtils
|
|
||||||
import strutils
|
|
||||||
import tables
|
|
||||||
import std/parseopt
|
|
||||||
|
|
||||||
import std/json
|
|
||||||
import std/jsonutils except distinctBase
|
|
||||||
import std/marshal
|
|
||||||
import std/streams
|
|
||||||
|
|
||||||
import std/base64
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
import tui/persistence
|
|
||||||
|
|
||||||
|
|
||||||
const SELF_DEFINED = 99
|
|
||||||
|
|
||||||
|
|
||||||
#################################################
|
|
||||||
# Command Line Args
|
|
||||||
#################################################
|
|
||||||
|
|
||||||
type CmdArgs = object
|
|
||||||
username*: string
|
|
||||||
invite*: string
|
|
||||||
|
|
||||||
proc getCmdArgs(): CmdArgs =
|
|
||||||
var username = ""
|
|
||||||
var invite = ""
|
|
||||||
for kind, key, val in getopt():
|
|
||||||
case kind
|
|
||||||
of cmdArgument:
|
|
||||||
discard
|
|
||||||
of cmdLongOption, cmdShortOption:
|
|
||||||
case key
|
|
||||||
of "name", "n":
|
|
||||||
username = val
|
|
||||||
of "invite", "i":
|
|
||||||
invite = val
|
|
||||||
of cmdEnd:
|
|
||||||
break
|
|
||||||
if username == "":
|
|
||||||
username = "<anonymous>"
|
|
||||||
|
|
||||||
result = CmdArgs(username: username, invite: invite)
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
#################################################
|
|
||||||
# Link Generation
|
|
||||||
#################################################
|
|
||||||
|
|
||||||
proc toBundle*(link: string): Result[IntroBundle, string] =
|
|
||||||
# Check scheme
|
|
||||||
if not link.startsWith("wap://"):
|
|
||||||
return err("InvalidScheme")
|
|
||||||
|
|
||||||
# Remove scheme
|
|
||||||
let path = link[6..^1] # Remove "waku://"
|
|
||||||
|
|
||||||
# Split by '/'
|
|
||||||
let parts = path.split('/')
|
|
||||||
|
|
||||||
# Expected format: ident/{ident}/ephemeral/{ephemeral}/eid/{eid}
|
|
||||||
if parts.len != 6:
|
|
||||||
return err("InvalidFormat")
|
|
||||||
|
|
||||||
# Validate structure
|
|
||||||
if parts[0] != "ident" or parts[2] != "ephemeral" or parts[4] != "eid":
|
|
||||||
return err("InvalidFormat")
|
|
||||||
|
|
||||||
# Extract values
|
|
||||||
let ident = decode(parts[1]).toBytes()
|
|
||||||
let ephemeral = decode(parts[3]).toBytes()
|
|
||||||
let eid = int32(parseInt(parts[5])) # TODO: catch parse error
|
|
||||||
|
|
||||||
# Validate non-empty
|
|
||||||
if ident.len == 0:
|
|
||||||
return err("MissingIdent")
|
|
||||||
if ephemeral.len == 0:
|
|
||||||
return err("MissingEphemeral")
|
|
||||||
|
|
||||||
return ok(IntroBundle(
|
|
||||||
ident: ident,
|
|
||||||
ephemeral: ephemeral,
|
|
||||||
ephemeral_id: eid
|
|
||||||
))
|
|
||||||
|
|
||||||
|
|
||||||
proc toLink(intro: IntroBundle): string =
|
|
||||||
let ident = encode(intro.ident, safe = true)
|
|
||||||
let ephemeral = intro.ephemeral.toHex()
|
|
||||||
result = fmt"wap://ident/{ident}/ephemeral/{ephemeral}/eid/{intro.ephemeral_id}"
|
|
||||||
|
|
||||||
|
|
||||||
proc createChatClient(name: string): Future[Client] {.async.} =
|
|
||||||
try:
|
|
||||||
var cfg = await getCfg(name)
|
|
||||||
for key, val in fetchRegistrations():
|
|
||||||
if key != name:
|
|
||||||
cfg.waku.staticPeers.add(val)
|
|
||||||
|
|
||||||
result = newClient(name, cfg.waku, cfg.ident)
|
|
||||||
except Exception as e:
|
|
||||||
echo "Failed to create client: ", e.msg
|
|
||||||
|
|
||||||
proc main() {.async.} =
|
|
||||||
|
|
||||||
let args = getCmdArgs()
|
|
||||||
var client = await createChatClient(args.username)
|
|
||||||
|
|
||||||
echo "Identity: ", client.getId()
|
|
||||||
echo "Key: ", client.identity.getAddr()
|
|
||||||
echo "NodeAaddr:", client.ds.cfg.getMultiAddr()
|
|
||||||
|
|
||||||
client.onNewMessage(proc(convo: Conversation, msg: ContentFrame) {.async.} =
|
|
||||||
echo " ------> Raya :: "
|
|
||||||
await sleepAsync(10000)
|
|
||||||
await convo.sendMessage(client.ds, initTextFrame("Pong").toContentFrame())
|
|
||||||
)
|
|
||||||
|
|
||||||
client.onNewConversation(proc(convo: Conversation) {.async.} =
|
|
||||||
echo " ------> Raya :: New Conversation: " & convo.id()
|
|
||||||
await convo.sendMessage(client.ds, initTextFrame("Hello").toContentFrame())
|
|
||||||
)
|
|
||||||
|
|
||||||
client.onDeliveryAck(proc(convo: Conversation, msgId: string) {.async.} =
|
|
||||||
echo " raya -- Read Receipt for " & msgId
|
|
||||||
)
|
|
||||||
|
|
||||||
await client.start()
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
# Perform OOB Introduction: Raya -> Saro
|
|
||||||
let x = proc() {.async.} =
|
|
||||||
while true:
|
|
||||||
await sleepAsync(5000)
|
|
||||||
notice "Heartbeat - PeerCount: ", peerCount = client.ds.getConnectedPeerCount()
|
|
||||||
asyncSpawn x()
|
|
||||||
|
|
||||||
|
|
||||||
warn "==== arg Invite ", arg= args.invite, peers = client.ds.getConnectedPeerCount()
|
|
||||||
if args.invite != "":
|
|
||||||
let invite = toBundle(args.invite).get()
|
|
||||||
await sleepAsync(20000)
|
|
||||||
discard await client.newPrivateConversation(invite)
|
|
||||||
else:
|
|
||||||
let bundle = client.createIntroBundle()
|
|
||||||
echo "Link: ", toLink(bundle)
|
|
||||||
#
|
|
||||||
|
|
||||||
|
|
||||||
# let link = toLink(raya_bundle)
|
|
||||||
# echo "Raya Intro Link: ", link
|
|
||||||
|
|
||||||
# let parsed = toBundle(link).get()
|
|
||||||
# echo repr(parsed)
|
|
||||||
|
|
||||||
await sleepAsync(400000)
|
|
||||||
|
|
||||||
client.stop()
|
|
||||||
|
|
||||||
when isMainModule:
|
|
||||||
setLogLevel(LogLevel.Debug)
|
|
||||||
waitFor main()
|
|
||||||
notice "Shutdown"
|
|
||||||
Loading…
x
Reference in New Issue
Block a user