27 lines
666 B
Nim
27 lines
666 B
Nim
import protobuf_serialization
|
|
|
|
import mvds/Message
|
|
export Message
|
|
|
|
import mvds/State
|
|
|
|
type MVDSNode* = ref object
|
|
when defined(MVDS_TESTS):
|
|
state*: State
|
|
else:
|
|
state: State
|
|
|
|
proc newMVDSNode*(interactive: bool): MVDSNode {.inline.} =
|
|
MVDSNode(
|
|
state: newState(interactive)
|
|
)
|
|
|
|
proc offer*(node: MVDSNode, msg: Message, epoch: int) {.inline.} =
|
|
node.state.offer(msg, epoch)
|
|
|
|
proc updateEpoch*(node: MVDSNode, msgID: seq[byte], epoch: int): bool =
|
|
node.state.updateEpoch(msgID, epoch)
|
|
|
|
proc handle*(node: MVDSNode, payload: Payload): tuple[messages: seq[Message], response: Payload] {.inline.} =
|
|
(payload.messages, node.state.handle(payload))
|