nim-dagger/dagger/blockexchange/engine/payments.nim

import std/math
import pkg/nitro
import pkg/questionable/results
import ../peercontext

export nitro
export results
export peercontext

push: {.upraises: [].}

const ChainId* = 0.u256 # invalid chain id for now
const Asset* = EthAddress.zero # invalid ERC20 asset address for now
const AmountPerChannel = (10'u64^18).u256 # 1 asset, ERC20 default is 18 decimals

func openLedgerChannel*(wallet: WalletRef,
                        hub: EthAddress,
                        asset: EthAddress): ?!ChannelId =
  wallet.openLedgerChannel(hub, ChainId, asset, AmountPerChannel)

func getOrOpenChannel(wallet: WalletRef, peer: BlockExcPeerCtx): ?!ChannelId =
  if channel =? peer.paymentChannel:
    success channel
  elif account =? peer.account:
    let channel = ?wallet.openLedgerChannel(account.address, Asset)
    peer.paymentChannel = channel.some
    success channel
  else:
    failure "no account set for peer"

func pay*(wallet: WalletRef,
          peer: BlockExcPeerCtx,
          amount: UInt256): ?!SignedState =
  if account =? peer.account:
    let asset = Asset
    let receiver = account.address
    let channel = ?wallet.getOrOpenChannel(peer)
    wallet.pay(channel, asset, receiver, amount)
  else:
    failure "no account set for peer"
Add proc to engine that pays peers for bytes 2021-04-14 14:07:49 +00:00			`import std/math`
			`import pkg/nitro`
			`import pkg/questionable/results`
			`import ../peercontext`

			`export nitro`
			`export results`
			`export peercontext`

			`push: {.upraises: [].}`

Hard-code asset address We're only going to support a single asset for now. 2021-04-22 08:11:24 +00:00			`const ChainId* = 0.u256 # invalid chain id for now`
			`const Asset* = EthAddress.zero # invalid ERC20 asset address for now`
Fix build failure on 32 bit platforms 2021-04-14 14:27:17 +00:00			`const AmountPerChannel = (10'u64^18).u256 # 1 asset, ERC20 default is 18 decimals`
Add proc to engine that pays peers for bytes 2021-04-14 14:07:49 +00:00
Use reference semantics for wallets 2021-04-19 14:37:38 +00:00			`func openLedgerChannel*(wallet: WalletRef,`
Add proc to engine that pays peers for bytes 2021-04-14 14:07:49 +00:00			`hub: EthAddress,`
			`asset: EthAddress): ?!ChannelId =`
			`wallet.openLedgerChannel(hub, ChainId, asset, AmountPerChannel)`

Rename bitswap (#25) * use PeerInfo in event handlers * use CidV1 and raw multicodec as default * add block stream abstraction * raises defect * adding dataset abstraction * move blockstream into own dir * reorg files and fix tests * rename dataset to blockset * wip * wip * adding basic test for treehash algo * run blockset tests along with with the rest * remove obsolete contents * fix chunker tests * rename bitswap and move to stores * rename bitwsap to blockexc and move to stores * moare project structure reorg 2021-08-30 19:25:20 +00:00			`func getOrOpenChannel(wallet: WalletRef, peer: BlockExcPeerCtx): ?!ChannelId =`
Add proc to engine that pays peers for bytes 2021-04-14 14:07:49 +00:00			`if channel =? peer.paymentChannel:`
Update to latest versions of nitro and questionable 2021-04-15 09:23:49 +00:00			`success channel`
Replace pricing exchange by account exchange Rationale: price is no longer set per peer, but per chunk. Only the Ethereum accounts of the peers needs to be exchanged. 2021-05-10 14:21:47 +00:00			`elif account =? peer.account:`
			`let channel = ?wallet.openLedgerChannel(account.address, Asset)`
Add proc to engine that pays peers for bytes 2021-04-14 14:07:49 +00:00			`peer.paymentChannel = channel.some`
Update to latest versions of nitro and questionable 2021-04-15 09:23:49 +00:00			`success channel`
Add proc to engine that pays peers for bytes 2021-04-14 14:07:49 +00:00			`else:`
Replace pricing exchange by account exchange Rationale: price is no longer set per peer, but per chunk. Only the Ethereum accounts of the peers needs to be exchanged. 2021-05-10 14:21:47 +00:00			`failure "no account set for peer"`
Add proc to engine that pays peers for bytes 2021-04-14 14:07:49 +00:00
Use reference semantics for wallets 2021-04-19 14:37:38 +00:00			`func pay*(wallet: WalletRef,`
Rename bitswap (#25) * use PeerInfo in event handlers * use CidV1 and raw multicodec as default * add block stream abstraction * raises defect * adding dataset abstraction * move blockstream into own dir * reorg files and fix tests * rename dataset to blockset * wip * wip * adding basic test for treehash algo * run blockset tests along with with the rest * remove obsolete contents * fix chunker tests * rename bitswap and move to stores * rename bitwsap to blockexc and move to stores * moare project structure reorg 2021-08-30 19:25:20 +00:00			`peer: BlockExcPeerCtx,`
Pay per-block price instead of per-peer price 2021-05-10 11:47:15 +00:00			`amount: UInt256): ?!SignedState =`
Replace pricing exchange by account exchange Rationale: price is no longer set per peer, but per chunk. Only the Ethereum accounts of the peers needs to be exchanged. 2021-05-10 14:21:47 +00:00			`if account =? peer.account:`
Hard-code asset address We're only going to support a single asset for now. 2021-04-22 08:11:24 +00:00			`let asset = Asset`
Replace pricing exchange by account exchange Rationale: price is no longer set per peer, but per chunk. Only the Ethereum accounts of the peers needs to be exchanged. 2021-05-10 14:21:47 +00:00			`let receiver = account.address`
Add proc to engine that pays peers for bytes 2021-04-14 14:07:49 +00:00			`let channel = ?wallet.getOrOpenChannel(peer)`
			`wallet.pay(channel, asset, receiver, amount)`
			`else:`
Replace pricing exchange by account exchange Rationale: price is no longer set per peer, but per chunk. Only the Ethereum accounts of the peers needs to be exchanged. 2021-05-10 14:21:47 +00:00			`failure "no account set for peer"`