214 lines
6.5 KiB
Nim
214 lines
6.5 KiB
Nim
## Nim-LibP2P
|
|
## Copyright (c) 2019 Status Research & Development GmbH
|
|
## Licensed under either of
|
|
## * Apache License, version 2.0, ([LICENSE-APACHE](LICENSE-APACHE))
|
|
## * MIT license ([LICENSE-MIT](LICENSE-MIT))
|
|
## at your option.
|
|
## This file may not be copied, modified, or distributed except according to
|
|
## those terms.
|
|
|
|
{.push raises: [Defect].}
|
|
|
|
import std/[sequtils, options, strutils]
|
|
import chronos, chronicles
|
|
import ../protobuf/minprotobuf,
|
|
../peerinfo,
|
|
../stream/connection,
|
|
../peerid,
|
|
../crypto/crypto,
|
|
../multiaddress,
|
|
../protocols/protocol,
|
|
../utility,
|
|
../errors
|
|
|
|
logScope:
|
|
topics = "libp2p identify"
|
|
|
|
const
|
|
IdentifyCodec* = "/ipfs/id/1.0.0"
|
|
IdentifyPushCodec* = "/ipfs/id/push/1.0.0"
|
|
ProtoVersion* = "ipfs/0.1.0"
|
|
AgentVersion* = "nim-libp2p/0.0.1"
|
|
|
|
type
|
|
IdentifyError* = object of LPError
|
|
IdentityNoMatchError* = object of IdentifyError
|
|
IdentityInvalidMsgError* = object of IdentifyError
|
|
IdentifyNoPubKeyError* = object of IdentifyError
|
|
|
|
IdentifyInfo* = object
|
|
pubkey*: Option[PublicKey]
|
|
peerId*: PeerId
|
|
addrs*: seq[MultiAddress]
|
|
observedAddr*: Option[MultiAddress]
|
|
protoVersion*: Option[string]
|
|
agentVersion*: Option[string]
|
|
protos*: seq[string]
|
|
|
|
Identify* = ref object of LPProtocol
|
|
peerInfo*: PeerInfo
|
|
|
|
IdentifyPushHandler* = proc (
|
|
peer: PeerId,
|
|
newInfo: IdentifyInfo):
|
|
Future[void]
|
|
{.gcsafe, raises: [Defect].}
|
|
|
|
IdentifyPush* = ref object of LPProtocol
|
|
identifyHandler: IdentifyPushHandler
|
|
|
|
proc encodeMsg*(peerInfo: PeerInfo, observedAddr: MultiAddress): ProtoBuffer
|
|
{.raises: [Defect, IdentifyNoPubKeyError].} =
|
|
result = initProtoBuffer()
|
|
|
|
let pkey = peerInfo.publicKey
|
|
|
|
result.write(1, pkey.getBytes().get())
|
|
for ma in peerInfo.addrs:
|
|
result.write(2, ma.data.buffer)
|
|
for proto in peerInfo.protocols:
|
|
result.write(3, proto)
|
|
result.write(4, observedAddr.data.buffer)
|
|
let protoVersion = ProtoVersion
|
|
result.write(5, protoVersion)
|
|
let agentVersion = if peerInfo.agentVersion.len <= 0:
|
|
AgentVersion
|
|
else:
|
|
peerInfo.agentVersion
|
|
result.write(6, agentVersion)
|
|
result.finish()
|
|
|
|
proc decodeMsg*(buf: seq[byte]): Option[IdentifyInfo] =
|
|
var
|
|
iinfo: IdentifyInfo
|
|
pubkey: PublicKey
|
|
oaddr: MultiAddress
|
|
protoVersion: string
|
|
agentVersion: string
|
|
|
|
var pb = initProtoBuffer(buf)
|
|
|
|
let r1 = pb.getField(1, pubkey)
|
|
let r2 = pb.getRepeatedField(2, iinfo.addrs)
|
|
let r3 = pb.getRepeatedField(3, iinfo.protos)
|
|
let r4 = pb.getField(4, oaddr)
|
|
let r5 = pb.getField(5, protoVersion)
|
|
let r6 = pb.getField(6, agentVersion)
|
|
|
|
let res = r1.isOk() and r2.isOk() and r3.isOk() and
|
|
r4.isOk() and r5.isOk() and r6.isOk()
|
|
|
|
if res:
|
|
if r1.get():
|
|
iinfo.pubkey = some(pubkey)
|
|
if r4.get():
|
|
iinfo.observedAddr = some(oaddr)
|
|
if r5.get():
|
|
iinfo.protoVersion = some(protoVersion)
|
|
if r6.get():
|
|
iinfo.agentVersion = some(agentVersion)
|
|
debug "decodeMsg: decoded identify", pubkey = ($pubkey).shortLog,
|
|
addresses = iinfo.addrs.mapIt($it).join(","),
|
|
protocols = iinfo.protos.mapIt($it).join(","),
|
|
observable_address =
|
|
if iinfo.observedAddr.isSome(): $iinfo.observedAddr.get()
|
|
else: "None",
|
|
proto_version = iinfo.protoVersion.get("None"),
|
|
agent_version = iinfo.agentVersion.get("None")
|
|
some(iinfo)
|
|
else:
|
|
trace "decodeMsg: failed to decode received message"
|
|
none[IdentifyInfo]()
|
|
|
|
proc new*(T: typedesc[Identify], peerInfo: PeerInfo): T =
|
|
let identify = T(peerInfo: peerInfo)
|
|
identify.init()
|
|
identify
|
|
|
|
method init*(p: Identify) =
|
|
proc handle(conn: Connection, proto: string) {.async, gcsafe, closure.} =
|
|
try:
|
|
trace "handling identify request", conn
|
|
var pb = encodeMsg(p.peerInfo, conn.observedAddr)
|
|
await conn.writeLp(pb.buffer)
|
|
except CancelledError as exc:
|
|
raise exc
|
|
except CatchableError as exc:
|
|
trace "exception in identify handler", exc = exc.msg, conn
|
|
finally:
|
|
trace "exiting identify handler", conn
|
|
await conn.closeWithEOF()
|
|
|
|
p.handler = handle
|
|
p.codec = IdentifyCodec
|
|
|
|
proc identify*(p: Identify,
|
|
conn: Connection,
|
|
remotePeerId: PeerId): Future[IdentifyInfo] {.async, gcsafe.} =
|
|
trace "initiating identify", conn
|
|
var message = await conn.readLp(64*1024)
|
|
if len(message) == 0:
|
|
trace "identify: Empty message received!", conn
|
|
raise newException(IdentityInvalidMsgError, "Empty message received!")
|
|
|
|
let infoOpt = decodeMsg(message)
|
|
if infoOpt.isNone():
|
|
raise newException(IdentityInvalidMsgError, "Incorrect message received!")
|
|
result = infoOpt.get()
|
|
|
|
if result.pubkey.isSome:
|
|
let peer = PeerId.init(result.pubkey.get())
|
|
if peer.isErr:
|
|
raise newException(IdentityInvalidMsgError, $peer.error)
|
|
else:
|
|
result.peerId = peer.get()
|
|
if peer.get() != remotePeerId:
|
|
trace "Peer ids don't match",
|
|
remote = peer,
|
|
local = remotePeerId
|
|
|
|
raise newException(IdentityNoMatchError, "Peer ids don't match")
|
|
else:
|
|
raise newException(IdentityInvalidMsgError, "No pubkey in identify")
|
|
|
|
proc new*(T: typedesc[IdentifyPush], handler: IdentifyPushHandler = nil): T =
|
|
let identifypush = T(identifyHandler: handler)
|
|
identifypush.init()
|
|
identifypush
|
|
|
|
proc init*(p: IdentifyPush) =
|
|
proc handle(conn: Connection, proto: string) {.async, gcsafe, closure.} =
|
|
trace "handling identify push", conn
|
|
try:
|
|
var message = await conn.readLp(64*1024)
|
|
|
|
let infoOpt = decodeMsg(message)
|
|
if infoOpt.isNone():
|
|
raise newException(IdentityInvalidMsgError, "Incorrect message received!")
|
|
|
|
var indentInfo = infoOpt.get()
|
|
|
|
if indentInfo.pubkey.isSome:
|
|
let receivedPeerId = PeerId.init(indentInfo.pubkey.get()).tryGet()
|
|
if receivedPeerId != conn.peerId:
|
|
raise newException(IdentityNoMatchError, "Peer ids don't match")
|
|
indentInfo.peerId = receivedPeerId
|
|
|
|
trace "triggering peer event", peerInfo = conn.peerId
|
|
if not isNil(p.identifyHandler):
|
|
await p.identifyHandler(conn.peerId, indentInfo)
|
|
except CancelledError as exc:
|
|
raise exc
|
|
except CatchableError as exc:
|
|
info "exception in identify push handler", exc = exc.msg, conn
|
|
finally:
|
|
trace "exiting identify push handler", conn
|
|
await conn.closeWithEOF()
|
|
|
|
p.handler = handle
|
|
p.codec = IdentifyPushCodec
|
|
|
|
proc push*(p: IdentifyPush, peerInfo: PeerInfo, conn: Connection) {.async.} =
|
|
var pb = encodeMsg(peerInfo, conn.observedAddr)
|
|
await conn.writeLp(pb.buffer)
|