mirror of
https://github.com/logos-messaging/nim-chat-poc.git
synced 2026-01-02 14:13:10 +00:00
remove dead files
This commit is contained in:
Jazz Turner-Baggs
parent
57715899dd
commit
127d16641c
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