nim-libp2p/libp2p/protocols/protocol.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.

import chronos
import ../stream/connection

type
  LPProtoHandler* = proc (conn: Connection,
                          proto: string):
                          Future[void] {.gcsafe, closure.}

  LPProtocol* = ref object of RootObj
    codecs*: seq[string]
    handler*: LPProtoHandler ## this handler gets invoked by the protocol negotiator

method init*(p: LPProtocol) {.base, gcsafe.} = discard

func codec*(p: LPProtocol): string = 
  assert(p.codecs.len > 0, "Codecs sequence was empty!")
  p.codecs[0]

func `codec=`*(p: LPProtocol, codec: string) =
  # always insert as first codec 
  # if we use this abstraction
  p.codecs.insert(codec, 0)
wip: identify and switch 2019-08-28 02:30:53 +00:00			`## Nim-LibP2P`
changed copyright year 2019-09-24 17:48:23 +00:00			`## Copyright (c) 2019 Status Research & Development GmbH`
wip: identify and switch 2019-08-28 02:30:53 +00:00			`## 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.`

			`import chronos`
Cleanup lpstream, Connection and BufferStream (#228) * count published messages * don't call `switch.dial` in `subscribeToPeer` * don't use delegation in connection * move connection out to own file * don't breakout on reset * make sure to call close on secured conn * add lpstream tracing * don't breackdown by conn id * fix import * remove unused lable * reset connection on exception * add additional metrics for skipped messages * check for nil in secure.close 2020-06-19 17:29:43 +00:00			`import ../stream/connection`
wip: identify and switch 2019-08-28 02:30:53 +00:00
we don't need the switch in the protos after all 2019-08-28 19:12:15 +00:00			`type`
Fixes and tweaks related to the beacon node integration * Bugfix: Dialing an already connected peer may lead to crash * Introduced a standard_setup module allowing to instantiate the `Switch` object in an easier manner. * Added `Switch.disconnect(peer)` * Trailing space removed (sorry about polluting the diff) 2019-12-08 21:06:58 +00:00			`LPProtoHandler* = proc (conn: Connection,`
			`proto: string):`
add proper pragmas 2019-09-02 20:45:52 +00:00			`Future[void] {.gcsafe, closure.}`
reworked protocol 2019-08-30 23:45:57 +00:00
protocol handler method should receive context 2019-08-29 20:55:30 +00:00			`LPProtocol* = ref object of RootObj`
allow multiple codecs per protocol (without breaking things) 2020-06-23 02:48:11 +00:00			`codecs*: seq[string]`
add proper pragmas 2019-09-02 20:45:52 +00:00			`handler*: LPProtoHandler ## this handler gets invoked by the protocol negotiator`
we don't need the switch in the protos after all 2019-08-28 19:12:15 +00:00
wip: switch 2019-08-31 17:58:49 +00:00			`method init*(p: LPProtocol) {.base, gcsafe.} = discard`
allow multiple codecs per protocol (without breaking things) 2020-06-23 02:48:11 +00:00
			`func codec*(p: LPProtocol): string =`
			`assert(p.codecs.len > 0, "Codecs sequence was empty!")`
			`p.codecs[0]`

			func `codec=`*(p: LPProtocol, codec: string) =
			`# always insert as first codec`
			`# if we use this abstraction`
			`p.codecs.insert(codec, 0)`