Hex Artifact Content
Not logged in

Artifact ab98d6d12e99c78bc4333aba6dbcf4f0516bbf2b:


0000: 69 6d 70 6f 72 74 20 42 69 67 4e 75 6d 62 65 72  import BigNumber
0010: 20 66 72 6f 6d 20 27 62 69 67 6e 75 6d 62 65 72   from 'bignumber
0020: 2e 6a 73 27 0a 69 6d 70 6f 72 74 20 41 63 63 6f  .js'.import Acco
0030: 75 6e 74 73 20 66 72 6f 6d 20 27 2e 2f 61 63 63  unts from './acc
0040: 6f 75 6e 74 73 27 0a 69 6d 70 6f 72 74 20 52 6f  ounts'.import Ro
0050: 75 74 69 6e 67 54 61 62 6c 65 20 66 72 6f 6d 20  utingTable from 
0060: 27 2e 2f 72 6f 75 74 69 6e 67 2d 74 61 62 6c 65  './routing-table
0070: 27 0a 69 6d 70 6f 72 74 20 52 61 74 65 42 61 63  '.import RateBac
0080: 6b 65 6e 64 20 66 72 6f 6d 20 27 2e 2f 72 61 74  kend from './rat
0090: 65 2d 62 61 63 6b 65 6e 64 27 0a 69 6d 70 6f 72  e-backend'.impor
00a0: 74 20 51 75 6f 74 65 72 20 66 72 6f 6d 20 27 2e  t Quoter from '.
00b0: 2f 71 75 6f 74 65 72 27 0a 69 6d 70 6f 72 74 20  /quoter'.import 
00c0: 43 6f 6e 66 69 67 20 66 72 6f 6d 20 27 2e 2f 63  Config from './c
00d0: 6f 6e 66 69 67 27 0a 69 6d 70 6f 72 74 20 4c 69  onfig'.import Li
00e0: 71 75 69 64 69 74 79 43 75 72 76 65 20 66 72 6f  quidityCurve fro
00f0: 6d 20 27 2e 2e 2f 72 6f 75 74 69 6e 67 2f 6c 69  m '../routing/li
0100: 71 75 69 64 69 74 79 2d 63 75 72 76 65 27 0a 69  quidity-curve'.i
0110: 6d 70 6f 72 74 20 72 65 64 75 63 74 20 3d 20 72  mport reduct = r
0120: 65 71 75 69 72 65 28 27 72 65 64 75 63 74 27 29  equire('reduct')
0130: 0a 69 6d 70 6f 72 74 20 2a 20 61 73 20 49 6c 70  .import * as Ilp
0140: 50 61 63 6b 65 74 20 66 72 6f 6d 20 27 69 6c 70  Packet from 'ilp
0150: 2d 70 61 63 6b 65 74 27 0a 69 6d 70 6f 72 74 20  -packet'.import 
0160: 7b 20 63 72 65 61 74 65 20 61 73 20 63 72 65 61  { create as crea
0170: 74 65 4c 6f 67 67 65 72 20 7d 20 66 72 6f 6d 20  teLogger } from 
0180: 27 2e 2e 2f 63 6f 6d 6d 6f 6e 2f 6c 6f 67 27 0a  '../common/log'.
0190: 63 6f 6e 73 74 20 6c 6f 67 20 3d 20 63 72 65 61  const log = crea
01a0: 74 65 4c 6f 67 67 65 72 28 27 72 6f 75 74 65 2d  teLogger('route-
01b0: 62 75 69 6c 64 65 72 27 29 0a 63 6f 6e 73 74 20  builder').const 
01c0: 7b 0a 20 20 42 61 64 52 65 71 75 65 73 74 45 72  {.  BadRequestEr
01d0: 72 6f 72 2c 0a 20 20 49 6e 73 75 66 66 69 63 69  ror,.  Insuffici
01e0: 65 6e 74 54 69 6d 65 6f 75 74 45 72 72 6f 72 2c  entTimeoutError,
01f0: 0a 20 20 49 6e 76 61 6c 69 64 41 6d 6f 75 6e 74  .  InvalidAmount
0200: 45 72 72 6f 72 2c 0a 20 20 49 6e 76 61 6c 69 64  Error,.  Invalid
0210: 50 61 63 6b 65 74 45 72 72 6f 72 2c 0a 20 20 50  PacketError,.  P
0220: 65 65 72 55 6e 72 65 61 63 68 61 62 6c 65 45 72  eerUnreachableEr
0230: 72 6f 72 2c 0a 20 20 55 6e 72 65 61 63 68 61 62  ror,.  Unreachab
0240: 6c 65 45 72 72 6f 72 0a 7d 20 3d 20 49 6c 70 50  leError.} = IlpP
0250: 61 63 6b 65 74 2e 45 72 72 6f 72 73 0a 0a 63 6f  acket.Errors..co
0260: 6e 73 74 20 50 52 4f 42 45 5f 41 4d 4f 55 4e 54  nst PROBE_AMOUNT
0270: 20 3d 20 6e 65 77 20 42 69 67 4e 75 6d 62 65 72   = new BigNumber
0280: 28 31 30 29 2e 70 6f 77 28 31 34 29 2e 74 6f 4e  (10).pow(14).toN
0290: 75 6d 62 65 72 28 29 20 2f 2f 20 73 74 61 79 73  umber() // stays
02a0: 20 77 69 74 68 69 6e 20 31 35 20 6d 61 78 20 64   within 15 max d
02b0: 69 67 69 74 73 20 66 6f 72 20 42 69 67 4e 75 6d  igits for BigNum
02c0: 62 65 72 20 66 72 6f 6d 20 4e 75 6d 62 65 72 0a  ber from Number.
02d0: 0a 66 75 6e 63 74 69 6f 6e 20 72 61 74 65 54 6f  .function rateTo
02e0: 43 75 72 76 65 20 28 72 61 74 65 3a 20 6e 75 6d  Curve (rate: num
02f0: 62 65 72 29 20 7b 0a 20 20 2f 2f 20 4d 61 6b 65  ber) {.  // Make
0300: 20 73 75 72 65 20 74 68 61 74 20 6e 65 69 74 68   sure that neith
0310: 65 72 20 61 6d 6f 75 6e 74 20 65 78 63 65 65 64  er amount exceed
0320: 73 20 31 35 20 73 69 67 6e 69 66 69 63 61 6e 74  s 15 significant
0330: 20 64 69 67 69 74 73 2e 0a 20 20 69 66 20 28 72   digits..  if (r
0340: 61 74 65 20 3e 20 31 29 20 7b 0a 20 20 20 20 72  ate > 1) {.    r
0350: 65 74 75 72 6e 20 6e 65 77 20 4c 69 71 75 69 64  eturn new Liquid
0360: 69 74 79 43 75 72 76 65 28 5b 20 5b 30 2c 20 30  ityCurve([ [0, 0
0370: 5d 2c 20 5b 20 50 52 4f 42 45 5f 41 4d 4f 55 4e  ], [ PROBE_AMOUN
0380: 54 20 2f 20 72 61 74 65 2c 20 50 52 4f 42 45 5f  T / rate, PROBE_
0390: 41 4d 4f 55 4e 54 20 5d 20 5d 29 0a 20 20 7d 20  AMOUNT ] ]).  } 
03a0: 65 6c 73 65 20 7b 0a 20 20 20 20 72 65 74 75 72  else {.    retur
03b0: 6e 20 6e 65 77 20 4c 69 71 75 69 64 69 74 79 43  n new LiquidityC
03c0: 75 72 76 65 28 5b 20 5b 30 2c 20 30 5d 2c 20 5b  urve([ [0, 0], [
03d0: 20 50 52 4f 42 45 5f 41 4d 4f 55 4e 54 2c 20 50   PROBE_AMOUNT, P
03e0: 52 4f 42 45 5f 41 4d 4f 55 4e 54 20 2a 20 72 61  ROBE_AMOUNT * ra
03f0: 74 65 20 5d 20 5d 29 0a 20 20 7d 0a 7d 0a 0a 65  te ] ]).  }.}..e
0400: 78 70 6f 72 74 20 69 6e 74 65 72 66 61 63 65 20  xport interface 
0410: 51 75 6f 74 65 4c 69 71 75 69 64 69 74 79 50 61  QuoteLiquidityPa
0420: 72 61 6d 73 20 65 78 74 65 6e 64 73 20 49 6c 70  rams extends Ilp
0430: 50 61 63 6b 65 74 2e 49 6c 71 70 4c 69 71 75 69  Packet.IlqpLiqui
0440: 64 69 74 79 52 65 71 75 65 73 74 20 7b 0a 20 20  dityRequest {.  
0450: 73 6f 75 72 63 65 41 63 63 6f 75 6e 74 3a 20 73  sourceAccount: s
0460: 74 72 69 6e 67 0a 7d 0a 0a 65 78 70 6f 72 74 20  tring.}..export 
0470: 69 6e 74 65 72 66 61 63 65 20 51 75 6f 74 65 42  interface QuoteB
0480: 79 53 6f 75 72 63 65 50 61 72 61 6d 73 20 65 78  ySourceParams ex
0490: 74 65 6e 64 73 20 49 6c 70 50 61 63 6b 65 74 2e  tends IlpPacket.
04a0: 49 6c 71 70 42 79 53 6f 75 72 63 65 52 65 71 75  IlqpBySourceRequ
04b0: 65 73 74 20 7b 0a 20 20 73 6f 75 72 63 65 41 63  est {.  sourceAc
04c0: 63 6f 75 6e 74 3a 20 73 74 72 69 6e 67 0a 7d 0a  count: string.}.
04d0: 0a 65 78 70 6f 72 74 20 69 6e 74 65 72 66 61 63  .export interfac
04e0: 65 20 51 75 6f 74 65 42 79 44 65 73 74 69 6e 61  e QuoteByDestina
04f0: 74 69 6f 6e 50 61 72 61 6d 73 20 65 78 74 65 6e  tionParams exten
0500: 64 73 20 49 6c 70 50 61 63 6b 65 74 2e 49 6c 71  ds IlpPacket.Ilq
0510: 70 42 79 44 65 73 74 69 6e 61 74 69 6f 6e 52 65  pByDestinationRe
0520: 71 75 65 73 74 20 7b 0a 20 20 73 6f 75 72 63 65  quest {.  source
0530: 41 63 63 6f 75 6e 74 3a 20 73 74 72 69 6e 67 0a  Account: string.
0540: 7d 0a 0a 65 78 70 6f 72 74 20 64 65 66 61 75 6c  }..export defaul
0550: 74 20 63 6c 61 73 73 20 52 6f 75 74 65 42 75 69  t class RouteBui
0560: 6c 64 65 72 20 7b 0a 20 20 70 72 6f 74 65 63 74  lder {.  protect
0570: 65 64 20 61 63 63 6f 75 6e 74 73 3a 20 41 63 63  ed accounts: Acc
0580: 6f 75 6e 74 73 0a 20 20 70 72 6f 74 65 63 74 65  ounts.  protecte
0590: 64 20 72 6f 75 74 69 6e 67 54 61 62 6c 65 3a 20  d routingTable: 
05a0: 52 6f 75 74 69 6e 67 54 61 62 6c 65 0a 20 20 70  RoutingTable.  p
05b0: 72 6f 74 65 63 74 65 64 20 62 61 63 6b 65 6e 64  rotected backend
05c0: 3a 20 52 61 74 65 42 61 63 6b 65 6e 64 0a 20 20  : RateBackend.  
05d0: 70 72 6f 74 65 63 74 65 64 20 71 75 6f 74 65 72  protected quoter
05e0: 3a 20 51 75 6f 74 65 72 0a 20 20 70 72 6f 74 65  : Quoter.  prote
05f0: 63 74 65 64 20 63 6f 6e 66 69 67 3a 20 43 6f 6e  cted config: Con
0600: 66 69 67 0a 0a 20 20 70 72 6f 74 65 63 74 65 64  fig..  protected
0610: 20 69 73 54 72 69 76 69 61 6c 52 61 74 65 3a 20   isTrivialRate: 
0620: 62 6f 6f 6c 65 61 6e 0a 0a 20 20 63 6f 6e 73 74  boolean..  const
0630: 72 75 63 74 6f 72 20 28 64 65 70 73 3a 20 72 65  ructor (deps: re
0640: 64 75 63 74 2e 49 6e 6a 65 63 74 6f 72 29 20 7b  duct.Injector) {
0650: 0a 20 20 20 20 74 68 69 73 2e 61 63 63 6f 75 6e  .    this.accoun
0660: 74 73 20 3d 20 64 65 70 73 28 41 63 63 6f 75 6e  ts = deps(Accoun
0670: 74 73 29 0a 20 20 20 20 74 68 69 73 2e 72 6f 75  ts).    this.rou
0680: 74 69 6e 67 54 61 62 6c 65 20 3d 20 64 65 70 73  tingTable = deps
0690: 28 52 6f 75 74 69 6e 67 54 61 62 6c 65 29 0a 20  (RoutingTable). 
06a0: 20 20 20 74 68 69 73 2e 62 61 63 6b 65 6e 64 20     this.backend 
06b0: 3d 20 64 65 70 73 28 52 61 74 65 42 61 63 6b 65  = deps(RateBacke
06c0: 6e 64 29 0a 20 20 20 20 74 68 69 73 2e 71 75 6f  nd).    this.quo
06d0: 74 65 72 20 3d 20 64 65 70 73 28 51 75 6f 74 65  ter = deps(Quote
06e0: 72 29 0a 20 20 20 20 74 68 69 73 2e 63 6f 6e 66  r).    this.conf
06f0: 69 67 20 3d 20 64 65 70 73 28 43 6f 6e 66 69 67  ig = deps(Config
0700: 29 0a 0a 20 20 20 20 74 68 69 73 2e 69 73 54 72  )..    this.isTr
0710: 69 76 69 61 6c 52 61 74 65 20 3d 0a 20 20 20 20  ivialRate =.    
0720: 20 20 74 68 69 73 2e 63 6f 6e 66 69 67 2e 62 61    this.config.ba
0730: 63 6b 65 6e 64 20 3d 3d 3d 20 27 6f 6e 65 2d 74  ckend === 'one-t
0740: 6f 2d 6f 6e 65 27 20 26 26 0a 20 20 20 20 20 20  o-one' &&.      
0750: 74 68 69 73 2e 63 6f 6e 66 69 67 2e 73 70 72 65  this.config.spre
0760: 61 64 20 3d 3d 3d 20 30 0a 20 20 7d 0a 0a 20 20  ad === 0.  }..  
0770: 67 65 74 4e 65 78 74 48 6f 70 20 28 73 6f 75 72  getNextHop (sour
0780: 63 65 41 63 63 6f 75 6e 74 3a 20 73 74 72 69 6e  ceAccount: strin
0790: 67 2c 20 64 65 73 74 69 6e 61 74 69 6f 6e 41 63  g, destinationAc
07a0: 63 6f 75 6e 74 3a 20 73 74 72 69 6e 67 29 20 7b  count: string) {
07b0: 0a 20 20 20 20 63 6f 6e 73 74 20 72 6f 75 74 65  .    const route
07c0: 20 3d 20 74 68 69 73 2e 72 6f 75 74 69 6e 67 54   = this.routingT
07d0: 61 62 6c 65 2e 72 65 73 6f 6c 76 65 28 64 65 73  able.resolve(des
07e0: 74 69 6e 61 74 69 6f 6e 41 63 63 6f 75 6e 74 29  tinationAccount)
07f0: 0a 0a 20 20 20 20 69 66 20 28 21 72 6f 75 74 65  ..    if (!route
0800: 29 20 7b 0a 20 20 20 20 20 20 6c 6f 67 2e 69 6e  ) {.      log.in
0810: 66 6f 28 27 6e 6f 20 72 6f 75 74 65 20 66 6f 75  fo('no route fou
0820: 6e 64 20 66 6f 72 20 71 75 6f 74 65 2e 20 64 65  nd for quote. de
0830: 73 74 69 6e 61 74 69 6f 6e 41 63 63 6f 75 6e 74  stinationAccount
0840: 3d 27 20 2b 20 64 65 73 74 69 6e 61 74 69 6f 6e  =' + destination
0850: 41 63 63 6f 75 6e 74 29 0a 20 20 20 20 20 20 74  Account).      t
0860: 68 72 6f 77 20 6e 65 77 20 55 6e 72 65 61 63 68  hrow new Unreach
0870: 61 62 6c 65 45 72 72 6f 72 28 27 6e 6f 20 72 6f  ableError('no ro
0880: 75 74 65 20 66 6f 75 6e 64 2e 20 74 6f 3d 27 20  ute found. to=' 
0890: 2b 20 64 65 73 74 69 6e 61 74 69 6f 6e 41 63 63  + destinationAcc
08a0: 6f 75 6e 74 29 0a 20 20 20 20 7d 0a 0a 20 20 20  ount).    }..   
08b0: 20 69 66 20 28 21 74 68 69 73 2e 63 6f 6e 66 69   if (!this.confi
08c0: 67 2e 72 65 66 6c 65 63 74 50 61 79 6d 65 6e 74  g.reflectPayment
08d0: 73 20 26 26 20 73 6f 75 72 63 65 41 63 63 6f 75  s && sourceAccou
08e0: 6e 74 20 3d 3d 3d 20 72 6f 75 74 65 2e 6e 65 78  nt === route.nex
08f0: 74 48 6f 70 29 20 7b 0a 20 20 20 20 20 20 6c 6f  tHop) {.      lo
0900: 67 2e 69 6e 66 6f 28 27 72 65 66 75 73 69 6e 67  g.info('refusing
0910: 20 74 6f 20 72 6f 75 74 65 20 70 61 79 6d 65 6e   to route paymen
0920: 74 73 20 62 61 63 6b 20 74 6f 20 73 65 6e 64 65  ts back to sende
0930: 72 2e 20 73 6f 75 72 63 65 41 63 63 6f 75 6e 74  r. sourceAccount
0940: 3d 25 73 20 64 65 73 74 69 6e 61 74 69 6f 6e 41  =%s destinationA
0950: 63 63 6f 75 6e 74 3d 25 73 27 2c 20 73 6f 75 72  ccount=%s', sour
0960: 63 65 41 63 63 6f 75 6e 74 2c 20 64 65 73 74 69  ceAccount, desti
0970: 6e 61 74 69 6f 6e 41 63 63 6f 75 6e 74 29 0a 20  nationAccount). 
0980: 20 20 20 20 20 74 68 72 6f 77 20 6e 65 77 20 55       throw new U
0990: 6e 72 65 61 63 68 61 62 6c 65 45 72 72 6f 72 28  nreachableError(
09a0: 27 72 65 66 75 73 69 6e 67 20 74 6f 20 72 6f 75  'refusing to rou
09b0: 74 65 20 70 61 79 6d 65 6e 74 73 20 62 61 63 6b  te payments back
09c0: 20 74 6f 20 73 65 6e 64 65 72 2e 20 73 6f 75 72   to sender. sour
09d0: 63 65 41 63 63 6f 75 6e 74 3d 27 20 2b 20 73 6f  ceAccount=' + so
09e0: 75 72 63 65 41 63 63 6f 75 6e 74 20 2b 20 27 20  urceAccount + ' 
09f0: 64 65 73 74 69 6e 61 74 69 6f 6e 41 63 63 6f 75  destinationAccou
0a00: 6e 74 3d 27 20 2b 20 64 65 73 74 69 6e 61 74 69  nt=' + destinati
0a10: 6f 6e 41 63 63 6f 75 6e 74 29 0a 20 20 20 20 7d  onAccount).    }
0a20: 0a 0a 20 20 20 20 72 65 74 75 72 6e 20 72 6f 75  ..    return rou
0a30: 74 65 2e 6e 65 78 74 48 6f 70 0a 20 20 7d 0a 0a  te.nextHop.  }..
0a40: 20 20 61 73 79 6e 63 20 71 75 6f 74 65 4c 6f 63    async quoteLoc
0a50: 61 6c 20 28 73 6f 75 72 63 65 41 63 63 6f 75 6e  al (sourceAccoun
0a60: 74 3a 20 73 74 72 69 6e 67 2c 20 64 65 73 74 69  t: string, desti
0a70: 6e 61 74 69 6f 6e 41 63 63 6f 75 6e 74 3a 20 73  nationAccount: s
0a80: 74 72 69 6e 67 29 20 7b 0a 20 20 20 20 69 66 20  tring) {.    if 
0a90: 28 21 74 68 69 73 2e 61 63 63 6f 75 6e 74 73 2e  (!this.accounts.
0aa0: 67 65 74 41 73 73 65 74 43 6f 64 65 28 73 6f 75  getAssetCode(sou
0ab0: 72 63 65 41 63 63 6f 75 6e 74 29 29 20 7b 0a 20  rceAccount)) {. 
0ac0: 20 20 20 20 20 6c 6f 67 2e 69 6e 66 6f 28 27 73       log.info('s
0ad0: 6f 75 72 63 65 20 61 63 63 6f 75 6e 74 20 69 73  ource account is
0ae0: 20 75 6e 61 76 61 69 6c 61 62 6c 65 2e 20 73 6f   unavailable. so
0af0: 75 72 63 65 41 63 63 6f 75 6e 74 3d 27 20 2b 20  urceAccount=' + 
0b00: 73 6f 75 72 63 65 41 63 63 6f 75 6e 74 29 0a 20  sourceAccount). 
0b10: 20 20 20 20 20 74 68 72 6f 77 20 6e 65 77 20 55       throw new U
0b20: 6e 72 65 61 63 68 61 62 6c 65 45 72 72 6f 72 28  nreachableError(
0b30: 27 6e 6f 20 72 6f 75 74 65 20 66 72 6f 6d 20 73  'no route from s
0b40: 6f 75 72 63 65 2e 20 73 6f 75 72 63 65 41 63 63  ource. sourceAcc
0b50: 6f 75 6e 74 3d 27 20 2b 20 73 6f 75 72 63 65 41  ount=' + sourceA
0b60: 63 63 6f 75 6e 74 29 0a 20 20 20 20 7d 0a 0a 20  ccount).    }.. 
0b70: 20 20 20 63 6f 6e 73 74 20 6e 65 78 74 48 6f 70     const nextHop
0b80: 20 3d 20 74 68 69 73 2e 67 65 74 4e 65 78 74 48   = this.getNextH
0b90: 6f 70 28 73 6f 75 72 63 65 41 63 63 6f 75 6e 74  op(sourceAccount
0ba0: 2c 20 64 65 73 74 69 6e 61 74 69 6f 6e 41 63 63  , destinationAcc
0bb0: 6f 75 6e 74 29 0a 0a 20 20 20 20 69 66 20 28 21  ount)..    if (!
0bc0: 74 68 69 73 2e 61 63 63 6f 75 6e 74 73 2e 67 65  this.accounts.ge
0bd0: 74 41 73 73 65 74 43 6f 64 65 28 6e 65 78 74 48  tAssetCode(nextH
0be0: 6f 70 29 29 20 7b 0a 20 20 20 20 20 20 6c 6f 67  op)) {.      log
0bf0: 2e 69 6e 66 6f 28 27 6e 65 78 74 20 68 6f 70 20  .info('next hop 
0c00: 69 73 20 75 6e 61 76 61 69 6c 61 62 6c 65 2e 20  is unavailable. 
0c10: 6e 65 78 74 48 6f 70 3d 27 20 2b 20 6e 65 78 74  nextHop=' + next
0c20: 48 6f 70 29 0a 20 20 20 20 20 20 74 68 72 6f 77  Hop).      throw
0c30: 20 6e 65 77 20 55 6e 72 65 61 63 68 61 62 6c 65   new Unreachable
0c40: 45 72 72 6f 72 28 27 6e 6f 20 72 6f 75 74 65 20  Error('no route 
0c50: 74 6f 20 6e 65 78 74 20 68 6f 70 2e 20 6e 65 78  to next hop. nex
0c60: 74 48 6f 70 3d 27 20 2b 20 6e 65 78 74 48 6f 70  tHop=' + nextHop
0c70: 29 0a 20 20 20 20 7d 0a 0a 20 20 20 20 6c 6f 67  ).    }..    log
0c80: 2e 64 65 62 75 67 28 27 64 65 74 65 72 6d 69 6e  .debug('determin
0c90: 65 64 20 6e 65 78 74 20 68 6f 70 2e 20 6e 65 78  ed next hop. nex
0ca0: 74 48 6f 70 3d 27 20 2b 20 6e 65 78 74 48 6f 70  tHop=' + nextHop
0cb0: 29 0a 0a 20 20 20 20 63 6f 6e 73 74 20 72 61 74  )..    const rat
0cc0: 65 20 3d 20 61 77 61 69 74 20 74 68 69 73 2e 62  e = await this.b
0cd0: 61 63 6b 65 6e 64 2e 67 65 74 52 61 74 65 28 73  ackend.getRate(s
0ce0: 6f 75 72 63 65 41 63 63 6f 75 6e 74 2c 20 6e 65  ourceAccount, ne
0cf0: 78 74 48 6f 70 29 0a 0a 20 20 20 20 6c 6f 67 2e  xtHop)..    log.
0d00: 64 65 62 75 67 28 27 64 65 74 65 72 6d 69 6e 65  debug('determine
0d10: 64 20 6c 6f 63 61 6c 20 72 61 74 65 2e 20 72 61  d local rate. ra
0d20: 74 65 3d 27 20 2b 20 72 61 74 65 29 0a 0a 20 20  te=' + rate)..  
0d30: 20 20 72 65 74 75 72 6e 20 7b 20 6e 65 78 74 48    return { nextH
0d40: 6f 70 2c 20 72 61 74 65 20 7d 0a 20 20 7d 0a 0a  op, rate }.  }..
0d50: 20 20 2f 2a 2a 0a 20 20 20 2a 20 40 70 61 72 61    /**.   * @para
0d60: 6d 20 7b 53 74 72 69 6e 67 7d 20 73 6f 75 72 63  m {String} sourc
0d70: 65 41 63 63 6f 75 6e 74 0a 20 20 20 2a 20 40 70  eAccount.   * @p
0d80: 61 72 61 6d 20 7b 4f 62 6a 65 63 74 7d 20 70 61  aram {Object} pa
0d90: 63 6b 65 74 0a 20 20 20 2a 20 40 70 61 72 61 6d  cket.   * @param
0da0: 20 7b 53 74 72 69 6e 67 7d 20 70 61 63 6b 65 74   {String} packet
0db0: 2e 64 65 73 74 69 6e 61 74 69 6f 6e 41 63 63 6f  .destinationAcco
0dc0: 75 6e 74 0a 20 20 20 2a 20 40 70 61 72 61 6d 20  unt.   * @param 
0dd0: 7b 4e 75 6d 62 65 72 7d 20 70 61 63 6b 65 74 2e  {Number} packet.
0de0: 64 65 73 74 69 6e 61 74 69 6f 6e 48 6f 6c 64 44  destinationHoldD
0df0: 75 72 61 74 69 6f 6e 0a 20 20 20 2a 20 40 72 65  uration.   * @re
0e00: 74 75 72 6e 73 20 7b 51 75 6f 74 65 4c 69 71 75  turns {QuoteLiqu
0e10: 69 64 69 74 79 52 65 73 70 6f 6e 73 65 7d 0a 20  idityResponse}. 
0e20: 20 20 2a 2f 0a 20 20 61 73 79 6e 63 20 71 75 6f    */.  async quo
0e30: 74 65 4c 69 71 75 69 64 69 74 79 20 28 73 6f 75  teLiquidity (sou
0e40: 72 63 65 41 63 63 6f 75 6e 74 3a 20 73 74 72 69  rceAccount: stri
0e50: 6e 67 2c 20 70 61 63 6b 65 74 3a 20 49 6c 70 50  ng, packet: IlpP
0e60: 61 63 6b 65 74 2e 49 6c 71 70 4c 69 71 75 69 64  acket.IlqpLiquid
0e70: 69 74 79 52 65 71 75 65 73 74 29 20 7b 0a 20 20  ityRequest) {.  
0e80: 20 20 6c 6f 67 2e 69 6e 66 6f 28 27 63 72 65 61    log.info('crea
0e90: 74 69 6e 67 20 6c 69 71 75 69 64 69 74 79 20 71  ting liquidity q
0ea0: 75 6f 74 65 2e 20 73 6f 75 72 63 65 41 63 63 6f  uote. sourceAcco
0eb0: 75 6e 74 3d 25 73 20 64 65 73 74 69 6e 61 74 69  unt=%s destinati
0ec0: 6f 6e 41 63 63 6f 75 6e 74 3d 25 73 27 2c 0a 20  onAccount=%s',. 
0ed0: 20 20 20 20 20 73 6f 75 72 63 65 41 63 63 6f 75       sourceAccou
0ee0: 6e 74 2c 20 70 61 63 6b 65 74 2e 64 65 73 74 69  nt, packet.desti
0ef0: 6e 61 74 69 6f 6e 41 63 63 6f 75 6e 74 29 0a 0a  nationAccount)..
0f00: 20 20 20 20 63 6f 6e 73 74 20 7b 20 6e 65 78 74      const { next
0f10: 48 6f 70 2c 20 72 61 74 65 20 7d 20 3d 20 61 77  Hop, rate } = aw
0f20: 61 69 74 20 74 68 69 73 2e 71 75 6f 74 65 4c 6f  ait this.quoteLo
0f30: 63 61 6c 28 73 6f 75 72 63 65 41 63 63 6f 75 6e  cal(sourceAccoun
0f40: 74 2c 20 70 61 63 6b 65 74 2e 64 65 73 74 69 6e  t, packet.destin
0f50: 61 74 69 6f 6e 41 63 63 6f 75 6e 74 29 0a 20 20  ationAccount).  
0f60: 20 20 63 6f 6e 73 74 20 6c 6f 63 61 6c 51 75 6f    const localQuo
0f70: 74 65 45 78 70 69 72 79 20 3d 20 44 61 74 65 2e  teExpiry = Date.
0f80: 6e 6f 77 28 29 20 2b 20 28 74 68 69 73 2e 63 6f  now() + (this.co
0f90: 6e 66 69 67 2e 71 75 6f 74 65 45 78 70 69 72 79  nfig.quoteExpiry
0fa0: 29 0a 0a 20 20 20 20 63 6f 6e 73 74 20 6c 6f 63  )..    const loc
0fb0: 61 6c 43 75 72 76 65 20 3d 20 72 61 74 65 54 6f  alCurve = rateTo
0fc0: 43 75 72 76 65 28 72 61 74 65 29 0a 0a 20 20 20  Curve(rate)..   
0fd0: 20 6c 65 74 20 6c 69 71 75 69 64 69 74 79 43 75   let liquidityCu
0fe0: 72 76 65 0a 20 20 20 20 6c 65 74 20 61 70 70 6c  rve.    let appl
0ff0: 69 65 73 54 6f 50 72 65 66 69 78 0a 20 20 20 20  iesToPrefix.    
1000: 6c 65 74 20 73 6f 75 72 63 65 48 6f 6c 64 44 75  let sourceHoldDu
1010: 72 61 74 69 6f 6e 0a 20 20 20 20 6c 65 74 20 65  ration.    let e
1020: 78 70 69 72 65 73 41 74 0a 20 20 20 20 69 66 20  xpiresAt.    if 
1030: 28 70 61 63 6b 65 74 2e 64 65 73 74 69 6e 61 74  (packet.destinat
1040: 69 6f 6e 41 63 63 6f 75 6e 74 2e 73 74 61 72 74  ionAccount.start
1050: 73 57 69 74 68 28 6e 65 78 74 48 6f 70 29 29 20  sWith(nextHop)) 
1060: 7b 0a 20 20 20 20 20 20 6c 6f 67 2e 64 65 62 75  {.      log.debu
1070: 67 28 27 6c 6f 63 61 6c 20 64 65 73 74 69 6e 61  g('local destina
1080: 74 69 6f 6e 2e 27 29 0a 20 20 20 20 20 20 6c 69  tion.').      li
1090: 71 75 69 64 69 74 79 43 75 72 76 65 20 3d 20 6c  quidityCurve = l
10a0: 6f 63 61 6c 43 75 72 76 65 0a 20 20 20 20 20 20  ocalCurve.      
10b0: 61 70 70 6c 69 65 73 54 6f 50 72 65 66 69 78 20  appliesToPrefix 
10c0: 3d 20 6e 65 78 74 48 6f 70 0a 20 20 20 20 20 20  = nextHop.      
10d0: 73 6f 75 72 63 65 48 6f 6c 64 44 75 72 61 74 69  sourceHoldDurati
10e0: 6f 6e 20 3d 20 70 61 63 6b 65 74 2e 64 65 73 74  on = packet.dest
10f0: 69 6e 61 74 69 6f 6e 48 6f 6c 64 44 75 72 61 74  inationHoldDurat
1100: 69 6f 6e 20 2b 20 74 68 69 73 2e 63 6f 6e 66 69  ion + this.confi
1110: 67 2e 6d 69 6e 4d 65 73 73 61 67 65 57 69 6e 64  g.minMessageWind
1120: 6f 77 0a 20 20 20 20 20 20 65 78 70 69 72 65 73  ow.      expires
1130: 41 74 20 3d 20 6c 6f 63 61 6c 51 75 6f 74 65 45  At = localQuoteE
1140: 78 70 69 72 79 0a 20 20 20 20 7d 20 65 6c 73 65  xpiry.    } else
1150: 20 7b 0a 20 20 20 20 20 20 63 6f 6e 73 74 20 71   {.      const q
1160: 75 6f 74 65 20 3d 20 61 77 61 69 74 20 74 68 69  uote = await thi
1170: 73 2e 71 75 6f 74 65 72 2e 71 75 6f 74 65 4c 69  s.quoter.quoteLi
1180: 71 75 69 64 69 74 79 28 6e 65 78 74 48 6f 70 2c  quidity(nextHop,
1190: 20 70 61 63 6b 65 74 2e 64 65 73 74 69 6e 61 74   packet.destinat
11a0: 69 6f 6e 41 63 63 6f 75 6e 74 29 0a 20 20 20 20  ionAccount).    
11b0: 20 20 69 66 20 28 21 71 75 6f 74 65 29 20 7b 0a    if (!quote) {.
11c0: 20 20 20 20 20 20 20 20 6c 6f 67 2e 69 6e 66 6f          log.info
11d0: 28 27 6e 6f 20 71 75 6f 74 65 20 66 6f 75 6e 64  ('no quote found
11e0: 2e 20 73 6f 75 72 63 65 41 63 63 6f 75 6e 74 3d  . sourceAccount=
11f0: 25 73 20 70 61 72 61 6d 73 3d 25 6a 27 2c 20 73  %s params=%j', s
1200: 6f 75 72 63 65 41 63 63 6f 75 6e 74 2c 20 70 61  ourceAccount, pa
1210: 63 6b 65 74 29 0a 20 20 20 20 20 20 20 20 74 68  cket).        th
1220: 72 6f 77 20 6e 65 77 20 55 6e 72 65 61 63 68 61  row new Unreacha
1230: 62 6c 65 45 72 72 6f 72 28 27 6e 6f 20 71 75 6f  bleError('no quo
1240: 74 65 20 66 6f 75 6e 64 2e 20 74 6f 3d 27 20 2b  te found. to=' +
1250: 20 70 61 63 6b 65 74 2e 64 65 73 74 69 6e 61 74   packet.destinat
1260: 69 6f 6e 41 63 63 6f 75 6e 74 29 0a 20 20 20 20  ionAccount).    
1270: 20 20 7d 0a 20 20 20 20 20 20 6c 6f 67 2e 64 65    }.      log.de
1280: 62 75 67 28 27 72 65 6d 6f 74 65 20 64 65 73 74  bug('remote dest
1290: 69 6e 61 74 69 6f 6e 2e 20 71 75 6f 74 65 3d 25  ination. quote=%
12a0: 6a 27 2c 20 71 75 6f 74 65 29 0a 0a 20 20 20 20  j', quote)..    
12b0: 20 20 6c 69 71 75 69 64 69 74 79 43 75 72 76 65    liquidityCurve
12c0: 20 3d 20 6c 6f 63 61 6c 43 75 72 76 65 2e 6a 6f   = localCurve.jo
12d0: 69 6e 28 71 75 6f 74 65 2e 63 75 72 76 65 29 0a  in(quote.curve).
12e0: 20 20 20 20 20 20 61 70 70 6c 69 65 73 54 6f 50        appliesToP
12f0: 72 65 66 69 78 20 3d 20 71 75 6f 74 65 2e 70 72  refix = quote.pr
1300: 65 66 69 78 0a 20 20 20 20 20 20 73 6f 75 72 63  efix.      sourc
1310: 65 48 6f 6c 64 44 75 72 61 74 69 6f 6e 20 3d 20  eHoldDuration = 
1320: 70 61 63 6b 65 74 2e 64 65 73 74 69 6e 61 74 69  packet.destinati
1330: 6f 6e 48 6f 6c 64 44 75 72 61 74 69 6f 6e 20 2b  onHoldDuration +
1340: 20 71 75 6f 74 65 2e 6d 69 6e 4d 65 73 73 61 67   quote.minMessag
1350: 65 57 69 6e 64 6f 77 20 2b 20 74 68 69 73 2e 63  eWindow + this.c
1360: 6f 6e 66 69 67 2e 6d 69 6e 4d 65 73 73 61 67 65  onfig.minMessage
1370: 57 69 6e 64 6f 77 0a 20 20 20 20 20 20 65 78 70  Window.      exp
1380: 69 72 65 73 41 74 20 3d 20 4d 61 74 68 2e 6d 69  iresAt = Math.mi
1390: 6e 28 4e 75 6d 62 65 72 28 71 75 6f 74 65 2e 65  n(Number(quote.e
13a0: 78 70 69 72 79 29 2c 20 6c 6f 63 61 6c 51 75 6f  xpiry), localQuo
13b0: 74 65 45 78 70 69 72 79 29 0a 20 20 20 20 7d 0a  teExpiry).    }.
13c0: 0a 20 20 20 20 74 68 69 73 2e 5f 76 65 72 69 66  .    this._verif
13d0: 79 50 6c 75 67 69 6e 49 73 43 6f 6e 6e 65 63 74  yPluginIsConnect
13e0: 65 64 28 6e 65 78 74 48 6f 70 29 0a 20 20 20 20  ed(nextHop).    
13f0: 74 68 69 73 2e 5f 76 61 6c 69 64 61 74 65 48 6f  this._validateHo
1400: 6c 64 44 75 72 61 74 69 6f 6e 73 28 73 6f 75 72  ldDurations(sour
1410: 63 65 48 6f 6c 64 44 75 72 61 74 69 6f 6e 2c 20  ceHoldDuration, 
1420: 70 61 63 6b 65 74 2e 64 65 73 74 69 6e 61 74 69  packet.destinati
1430: 6f 6e 48 6f 6c 64 44 75 72 61 74 69 6f 6e 29 0a  onHoldDuration).
1440: 0a 20 20 20 20 63 6f 6e 73 74 20 73 68 69 66 74  .    const shift
1450: 42 79 20 3d 20 74 68 69 73 2e 5f 67 65 74 53 63  By = this._getSc
1460: 61 6c 65 41 64 6a 75 73 74 6d 65 6e 74 28 73 6f  aleAdjustment(so
1470: 75 72 63 65 41 63 63 6f 75 6e 74 2c 20 6e 65 78  urceAccount, nex
1480: 74 48 6f 70 29 0a 0a 20 20 20 20 72 65 74 75 72  tHop)..    retur
1490: 6e 20 7b 0a 20 20 20 20 20 20 2f 2f 20 53 68 69  n {.      // Shi
14a0: 66 74 69 6e 67 20 74 68 65 20 63 75 72 76 65 20  fting the curve 
14b0: 72 69 67 68 74 20 62 79 20 6f 6e 65 20 75 6e 69  right by one uni
14c0: 74 20 65 66 66 65 63 74 69 76 65 6c 79 20 6d 61  t effectively ma
14d0: 6b 65 73 20 69 74 20 73 6f 20 74 68 65 20 63 6c  kes it so the cl
14e0: 69 65 6e 74 0a 20 20 20 20 20 20 2f 2f 20 61 6c  ient.      // al
14f0: 77 61 79 73 20 73 65 6e 64 73 20 65 6e 6f 75 67  ways sends enoug
1500: 68 20 6d 6f 6e 65 79 20 65 76 65 6e 20 64 65 73  h money even des
1510: 70 69 74 65 20 72 6f 75 6e 64 69 6e 67 20 65 72  pite rounding er
1520: 72 6f 72 73 2e 0a 20 20 20 20 20 20 6c 69 71 75  rors..      liqu
1530: 69 64 69 74 79 43 75 72 76 65 3a 20 6c 69 71 75  idityCurve: liqu
1540: 69 64 69 74 79 43 75 72 76 65 2e 73 68 69 66 74  idityCurve.shift
1550: 58 28 73 68 69 66 74 42 79 29 2e 74 6f 42 75 66  X(shiftBy).toBuf
1560: 66 65 72 28 29 2c 0a 20 20 20 20 20 20 2f 2f 20  fer(),.      // 
1570: 57 65 20 6e 65 65 64 20 74 6f 20 73 61 79 20 77  We need to say w
1580: 68 69 63 68 20 70 72 65 66 69 78 20 74 68 69 73  hich prefix this
1590: 20 63 75 72 76 65 20 61 70 70 6c 69 65 73 20 74   curve applies t
15a0: 6f 2e 20 42 75 74 20 66 6f 72 20 74 68 61 74 0a  o. But for that.
15b0: 20 20 20 20 20 20 2f 2f 20 70 72 65 66 69 78 2c        // prefix,
15c0: 20 74 68 65 20 63 75 72 76 65 20 6d 75 73 74 20   the curve must 
15d0: 41 4c 57 41 59 53 20 61 70 70 6c 79 20 62 65 63  ALWAYS apply bec
15e0: 61 75 73 65 20 70 65 6f 70 6c 65 20 6d 61 79 20  ause people may 
15f0: 63 61 63 68 65 20 69 74 2e 0a 20 20 20 20 20 20  cache it..      
1600: 2f 2f 20 53 6f 20 77 65 20 6e 65 65 64 20 74 68  // So we need th
1610: 65 20 73 68 6f 72 74 65 73 74 20 70 72 65 66 69  e shortest prefi
1620: 78 20 6f 66 20 74 68 65 20 64 65 73 74 69 6e 61  x of the destina
1630: 74 69 6f 6e 20 66 6f 72 20 77 68 69 63 68 20 74  tion for which t
1640: 68 69 73 0a 20 20 20 20 20 20 2f 2f 20 63 61 63  his.      // cac
1650: 68 65 64 20 63 75 72 76 65 20 77 69 6c 6c 20 41  hed curve will A
1660: 4c 57 41 59 53 20 61 70 70 6c 79 2e 0a 20 20 20  LWAYS apply..   
1670: 20 20 20 61 70 70 6c 69 65 73 54 6f 50 72 65 66     appliesToPref
1680: 69 78 3a 20 74 68 69 73 2e 72 6f 75 74 69 6e 67  ix: this.routing
1690: 54 61 62 6c 65 2e 67 65 74 53 68 6f 72 74 65 73  Table.getShortes
16a0: 74 55 6e 61 6d 62 69 67 75 6f 75 73 50 72 65 66  tUnambiguousPref
16b0: 69 78 28 70 61 63 6b 65 74 2e 64 65 73 74 69 6e  ix(packet.destin
16c0: 61 74 69 6f 6e 41 63 63 6f 75 6e 74 2c 20 61 70  ationAccount, ap
16d0: 70 6c 69 65 73 54 6f 50 72 65 66 69 78 29 2c 0a  pliesToPrefix),.
16e0: 20 20 20 20 20 20 73 6f 75 72 63 65 48 6f 6c 64        sourceHold
16f0: 44 75 72 61 74 69 6f 6e 2c 0a 20 20 20 20 20 20  Duration,.      
1700: 65 78 70 69 72 65 73 41 74 3a 20 6e 65 77 20 44  expiresAt: new D
1710: 61 74 65 28 65 78 70 69 72 65 73 41 74 29 0a 20  ate(expiresAt). 
1720: 20 20 20 7d 0a 20 20 7d 0a 0a 20 20 5f 67 65 74     }.  }..  _get
1730: 53 63 61 6c 65 41 64 6a 75 73 74 6d 65 6e 74 20  ScaleAdjustment 
1740: 28 73 6f 75 72 63 65 41 63 63 6f 75 6e 74 3a 20  (sourceAccount: 
1750: 73 74 72 69 6e 67 2c 20 64 65 73 74 69 6e 61 74  string, destinat
1760: 69 6f 6e 41 63 63 6f 75 6e 74 3a 20 73 74 72 69  ionAccount: stri
1770: 6e 67 29 20 7b 0a 20 20 20 20 63 6f 6e 73 74 20  ng) {.    const 
1780: 73 6f 75 72 63 65 53 63 61 6c 65 20 3d 20 74 68  sourceScale = th
1790: 69 73 2e 61 63 63 6f 75 6e 74 73 2e 67 65 74 49  is.accounts.getI
17a0: 6e 66 6f 28 73 6f 75 72 63 65 41 63 63 6f 75 6e  nfo(sourceAccoun
17b0: 74 29 2e 61 73 73 65 74 53 63 61 6c 65 0a 20 20  t).assetScale.  
17c0: 20 20 63 6f 6e 73 74 20 64 65 73 74 69 6e 61 74    const destinat
17d0: 69 6f 6e 53 63 61 6c 65 20 3d 20 74 68 69 73 2e  ionScale = this.
17e0: 61 63 63 6f 75 6e 74 73 2e 67 65 74 49 6e 66 6f  accounts.getInfo
17f0: 28 64 65 73 74 69 6e 61 74 69 6f 6e 41 63 63 6f  (destinationAcco
1800: 75 6e 74 29 2e 61 73 73 65 74 53 63 61 6c 65 0a  unt).assetScale.
1810: 20 20 20 20 69 66 20 28 73 6f 75 72 63 65 53 63      if (sourceSc
1820: 61 6c 65 20 3d 3d 3d 20 64 65 73 74 69 6e 61 74  ale === destinat
1830: 69 6f 6e 53 63 61 6c 65 20 26 26 20 74 68 69 73  ionScale && this
1840: 2e 69 73 54 72 69 76 69 61 6c 52 61 74 65 29 20  .isTrivialRate) 
1850: 72 65 74 75 72 6e 20 30 0a 20 20 20 20 72 65 74  return 0.    ret
1860: 75 72 6e 20 31 0a 20 20 7d 0a 0a 20 20 2f 2a 2a  urn 1.  }..  /**
1870: 0a 20 20 20 2a 20 40 70 61 72 61 6d 20 7b 53 74  .   * @param {St
1880: 72 69 6e 67 7d 20 73 6f 75 72 63 65 41 63 63 6f  ring} sourceAcco
1890: 75 6e 74 0a 20 20 20 2a 20 40 70 61 72 61 6d 20  unt.   * @param 
18a0: 7b 4f 62 6a 65 63 74 7d 20 70 61 63 6b 65 74 0a  {Object} packet.
18b0: 20 20 20 2a 20 40 70 61 72 61 6d 20 7b 53 74 72     * @param {Str
18c0: 69 6e 67 7d 20 70 61 63 6b 65 74 2e 64 65 73 74  ing} packet.dest
18d0: 69 6e 61 74 69 6f 6e 41 63 63 6f 75 6e 74 0a 20  inationAccount. 
18e0: 20 20 2a 20 40 70 61 72 61 6d 20 7b 4e 75 6d 62    * @param {Numb
18f0: 65 72 7d 20 70 61 63 6b 65 74 2e 64 65 73 74 69  er} packet.desti
1900: 6e 61 74 69 6f 6e 48 6f 6c 64 44 75 72 61 74 69  nationHoldDurati
1910: 6f 6e 0a 20 20 20 2a 20 40 70 61 72 61 6d 20 7b  on.   * @param {
1920: 53 74 72 69 6e 67 7d 20 70 61 63 6b 65 74 2e 73  String} packet.s
1930: 6f 75 72 63 65 41 6d 6f 75 6e 74 0a 20 20 20 2a  ourceAmount.   *
1940: 20 40 72 65 74 75 72 6e 73 20 7b 51 75 6f 74 65   @returns {Quote
1950: 42 79 53 6f 75 72 63 65 52 65 73 70 6f 6e 73 65  BySourceResponse
1960: 7d 0a 20 20 20 2a 2f 0a 20 20 61 73 79 6e 63 20  }.   */.  async 
1970: 71 75 6f 74 65 42 79 53 6f 75 72 63 65 20 28 73  quoteBySource (s
1980: 6f 75 72 63 65 41 63 63 6f 75 6e 74 3a 20 73 74  ourceAccount: st
1990: 72 69 6e 67 2c 20 70 61 63 6b 65 74 3a 20 49 6c  ring, packet: Il
19a0: 70 50 61 63 6b 65 74 2e 49 6c 71 70 42 79 53 6f  pPacket.IlqpBySo
19b0: 75 72 63 65 52 65 71 75 65 73 74 29 20 7b 0a 20  urceRequest) {. 
19c0: 20 20 20 6c 6f 67 2e 69 6e 66 6f 28 27 63 72 65     log.info('cre
19d0: 61 74 69 6e 67 20 71 75 6f 74 65 20 62 79 20 73  ating quote by s
19e0: 6f 75 72 63 65 20 61 6d 6f 75 6e 74 2e 20 73 6f  ource amount. so
19f0: 75 72 63 65 41 63 63 6f 75 6e 74 3d 25 73 20 64  urceAccount=%s d
1a00: 65 73 74 69 6e 61 74 69 6f 6e 41 63 63 6f 75 6e  estinationAccoun
1a10: 74 3d 25 73 20 73 6f 75 72 63 65 41 6d 6f 75 6e  t=%s sourceAmoun
1a20: 74 3d 25 73 27 2c 0a 20 20 20 20 20 20 73 6f 75  t=%s',.      sou
1a30: 72 63 65 41 63 63 6f 75 6e 74 2c 20 70 61 63 6b  rceAccount, pack
1a40: 65 74 2e 64 65 73 74 69 6e 61 74 69 6f 6e 41 63  et.destinationAc
1a50: 63 6f 75 6e 74 2c 20 70 61 63 6b 65 74 2e 73 6f  count, packet.so
1a60: 75 72 63 65 41 6d 6f 75 6e 74 29 0a 0a 20 20 20  urceAmount)..   
1a70: 20 69 66 20 28 70 61 63 6b 65 74 2e 73 6f 75 72   if (packet.sour
1a80: 63 65 41 6d 6f 75 6e 74 20 3d 3d 3d 20 27 30 27  ceAmount === '0'
1a90: 29 20 7b 0a 20 20 20 20 20 20 74 68 72 6f 77 20  ) {.      throw 
1aa0: 6e 65 77 20 49 6e 76 61 6c 69 64 41 6d 6f 75 6e  new InvalidAmoun
1ab0: 74 45 72 72 6f 72 28 27 73 6f 75 72 63 65 41 6d  tError('sourceAm
1ac0: 6f 75 6e 74 20 6d 75 73 74 20 62 65 20 70 6f 73  ount must be pos
1ad0: 69 74 69 76 65 27 29 0a 20 20 20 20 7d 0a 0a 20  itive').    }.. 
1ae0: 20 20 20 63 6f 6e 73 74 20 7b 20 6e 65 78 74 48     const { nextH
1af0: 6f 70 2c 20 72 61 74 65 20 7d 20 3d 20 61 77 61  op, rate } = awa
1b00: 69 74 20 74 68 69 73 2e 71 75 6f 74 65 4c 6f 63  it this.quoteLoc
1b10: 61 6c 28 73 6f 75 72 63 65 41 63 63 6f 75 6e 74  al(sourceAccount
1b20: 2c 20 70 61 63 6b 65 74 2e 64 65 73 74 69 6e 61  , packet.destina
1b30: 74 69 6f 6e 41 63 63 6f 75 6e 74 29 0a 0a 20 20  tionAccount)..  
1b40: 20 20 63 6f 6e 73 74 20 6e 65 78 74 41 6d 6f 75    const nextAmou
1b50: 6e 74 20 3d 20 6e 65 77 20 42 69 67 4e 75 6d 62  nt = new BigNumb
1b60: 65 72 28 70 61 63 6b 65 74 2e 73 6f 75 72 63 65  er(packet.source
1b70: 41 6d 6f 75 6e 74 29 2e 74 69 6d 65 73 28 72 61  Amount).times(ra
1b80: 74 65 29 2e 69 6e 74 65 67 65 72 56 61 6c 75 65  te).integerValue
1b90: 28 42 69 67 4e 75 6d 62 65 72 2e 52 4f 55 4e 44  (BigNumber.ROUND
1ba0: 5f 46 4c 4f 4f 52 29 2e 74 6f 53 74 72 69 6e 67  _FLOOR).toString
1bb0: 28 29 0a 20 20 20 20 6c 65 74 20 64 65 73 74 69  ().    let desti
1bc0: 6e 61 74 69 6f 6e 41 6d 6f 75 6e 74 0a 20 20 20  nationAmount.   
1bd0: 20 6c 65 74 20 73 6f 75 72 63 65 48 6f 6c 64 44   let sourceHoldD
1be0: 75 72 61 74 69 6f 6e 0a 20 20 20 20 69 66 20 28  uration.    if (
1bf0: 70 61 63 6b 65 74 2e 64 65 73 74 69 6e 61 74 69  packet.destinati
1c00: 6f 6e 41 63 63 6f 75 6e 74 2e 73 74 61 72 74 73  onAccount.starts
1c10: 57 69 74 68 28 6e 65 78 74 48 6f 70 29 29 20 7b  With(nextHop)) {
1c20: 0a 20 20 20 20 20 20 6c 6f 67 2e 64 65 62 75 67  .      log.debug
1c30: 28 27 6c 6f 63 61 6c 20 64 65 73 74 69 6e 61 74  ('local destinat
1c40: 69 6f 6e 2e 20 64 65 73 74 69 6e 61 74 69 6f 6e  ion. destination
1c50: 41 6d 6f 75 6e 74 3d 27 20 2b 20 6e 65 78 74 41  Amount=' + nextA
1c60: 6d 6f 75 6e 74 29 0a 20 20 20 20 20 20 64 65 73  mount).      des
1c70: 74 69 6e 61 74 69 6f 6e 41 6d 6f 75 6e 74 20 3d  tinationAmount =
1c80: 20 6e 65 78 74 41 6d 6f 75 6e 74 0a 20 20 20 20   nextAmount.    
1c90: 20 20 73 6f 75 72 63 65 48 6f 6c 64 44 75 72 61    sourceHoldDura
1ca0: 74 69 6f 6e 20 3d 20 70 61 63 6b 65 74 2e 64 65  tion = packet.de
1cb0: 73 74 69 6e 61 74 69 6f 6e 48 6f 6c 64 44 75 72  stinationHoldDur
1cc0: 61 74 69 6f 6e 20 2b 20 74 68 69 73 2e 63 6f 6e  ation + this.con
1cd0: 66 69 67 2e 6d 69 6e 4d 65 73 73 61 67 65 57 69  fig.minMessageWi
1ce0: 6e 64 6f 77 0a 20 20 20 20 7d 20 65 6c 73 65 20  ndow.    } else 
1cf0: 7b 0a 20 20 20 20 20 20 63 6f 6e 73 74 20 71 75  {.      const qu
1d00: 6f 74 65 20 3d 20 61 77 61 69 74 20 74 68 69 73  ote = await this
1d10: 2e 71 75 6f 74 65 72 2e 71 75 6f 74 65 4c 69 71  .quoter.quoteLiq
1d20: 75 69 64 69 74 79 28 6e 65 78 74 48 6f 70 2c 20  uidity(nextHop, 
1d30: 70 61 63 6b 65 74 2e 64 65 73 74 69 6e 61 74 69  packet.destinati
1d40: 6f 6e 41 63 63 6f 75 6e 74 29 0a 20 20 20 20 20  onAccount).     
1d50: 20 69 66 20 28 21 71 75 6f 74 65 29 20 7b 0a 20   if (!quote) {. 
1d60: 20 20 20 20 20 20 20 6c 6f 67 2e 69 6e 66 6f 28         log.info(
1d70: 27 6e 6f 20 71 75 6f 74 65 20 66 6f 75 6e 64 2e  'no quote found.
1d80: 20 73 6f 75 72 63 65 41 63 63 6f 75 6e 74 3d 25   sourceAccount=%
1d90: 73 20 70 61 72 61 6d 73 3d 25 6a 27 2c 20 73 6f  s params=%j', so
1da0: 75 72 63 65 41 63 63 6f 75 6e 74 2c 20 70 61 63  urceAccount, pac
1db0: 6b 65 74 29 0a 20 20 20 20 20 20 20 20 74 68 72  ket).        thr
1dc0: 6f 77 20 6e 65 77 20 55 6e 72 65 61 63 68 61 62  ow new Unreachab
1dd0: 6c 65 45 72 72 6f 72 28 27 6e 6f 20 71 75 6f 74  leError('no quot
1de0: 65 20 66 6f 75 6e 64 2e 20 74 6f 3d 27 20 2b 20  e found. to=' + 
1df0: 70 61 63 6b 65 74 2e 64 65 73 74 69 6e 61 74 69  packet.destinati
1e00: 6f 6e 41 63 63 6f 75 6e 74 29 0a 20 20 20 20 20  onAccount).     
1e10: 20 7d 0a 20 20 20 20 20 20 6c 6f 67 2e 64 65 62   }.      log.deb
1e20: 75 67 28 27 72 65 6d 6f 74 65 20 64 65 73 74 69  ug('remote desti
1e30: 6e 61 74 69 6f 6e 2e 20 71 75 6f 74 65 3d 25 6a  nation. quote=%j
1e40: 27 2c 20 71 75 6f 74 65 29 0a 0a 20 20 20 20 20  ', quote)..     
1e50: 20 64 65 73 74 69 6e 61 74 69 6f 6e 41 6d 6f 75   destinationAmou
1e60: 6e 74 20 3d 20 71 75 6f 74 65 2e 63 75 72 76 65  nt = quote.curve
1e70: 2e 61 6d 6f 75 6e 74 41 74 28 70 61 63 6b 65 74  .amountAt(packet
1e80: 2e 73 6f 75 72 63 65 41 6d 6f 75 6e 74 29 2e 74  .sourceAmount).t
1e90: 69 6d 65 73 28 72 61 74 65 29 2e 69 6e 74 65 67  imes(rate).integ
1ea0: 65 72 56 61 6c 75 65 28 42 69 67 4e 75 6d 62 65  erValue(BigNumbe
1eb0: 72 2e 52 4f 55 4e 44 5f 46 4c 4f 4f 52 29 2e 74  r.ROUND_FLOOR).t
1ec0: 6f 53 74 72 69 6e 67 28 29 0a 20 20 20 20 20 20  oString().      
1ed0: 73 6f 75 72 63 65 48 6f 6c 64 44 75 72 61 74 69  sourceHoldDurati
1ee0: 6f 6e 20 3d 20 70 61 63 6b 65 74 2e 64 65 73 74  on = packet.dest
1ef0: 69 6e 61 74 69 6f 6e 48 6f 6c 64 44 75 72 61 74  inationHoldDurat
1f00: 69 6f 6e 20 2b 20 71 75 6f 74 65 2e 6d 69 6e 4d  ion + quote.minM
1f10: 65 73 73 61 67 65 57 69 6e 64 6f 77 20 2b 20 74  essageWindow + t
1f20: 68 69 73 2e 63 6f 6e 66 69 67 2e 6d 69 6e 4d 65  his.config.minMe
1f30: 73 73 61 67 65 57 69 6e 64 6f 77 0a 20 20 20 20  ssageWindow.    
1f40: 7d 0a 0a 20 20 20 20 69 66 20 28 64 65 73 74 69  }..    if (desti
1f50: 6e 61 74 69 6f 6e 41 6d 6f 75 6e 74 20 3d 3d 3d  nationAmount ===
1f60: 20 27 30 27 29 20 7b 0a 20 20 20 20 20 20 74 68   '0') {.      th
1f70: 72 6f 77 20 6e 65 77 20 49 6e 76 61 6c 69 64 41  row new InvalidA
1f80: 6d 6f 75 6e 74 45 72 72 6f 72 28 27 71 75 6f 74  mountError('quot
1f90: 65 64 20 64 65 73 74 69 6e 61 74 69 6f 6e 20 69  ed destination i
1fa0: 73 20 6c 6f 77 65 72 20 74 68 61 6e 20 6d 69 6e  s lower than min
1fb0: 69 6d 75 6d 20 61 6d 6f 75 6e 74 20 61 6c 6c 6f  imum amount allo
1fc0: 77 65 64 2e 27 29 0a 20 20 20 20 7d 0a 0a 20 20  wed.').    }..  
1fd0: 20 20 74 68 69 73 2e 5f 76 65 72 69 66 79 50 6c    this._verifyPl
1fe0: 75 67 69 6e 49 73 43 6f 6e 6e 65 63 74 65 64 28  uginIsConnected(
1ff0: 73 6f 75 72 63 65 41 63 63 6f 75 6e 74 29 0a 20  sourceAccount). 
2000: 20 20 20 74 68 69 73 2e 5f 76 65 72 69 66 79 50     this._verifyP
2010: 6c 75 67 69 6e 49 73 43 6f 6e 6e 65 63 74 65 64  luginIsConnected
2020: 28 6e 65 78 74 48 6f 70 29 0a 20 20 20 20 74 68  (nextHop).    th
2030: 69 73 2e 5f 76 61 6c 69 64 61 74 65 48 6f 6c 64  is._validateHold
2040: 44 75 72 61 74 69 6f 6e 73 28 73 6f 75 72 63 65  Durations(source
2050: 48 6f 6c 64 44 75 72 61 74 69 6f 6e 2c 20 70 61  HoldDuration, pa
2060: 63 6b 65 74 2e 64 65 73 74 69 6e 61 74 69 6f 6e  cket.destination
2070: 48 6f 6c 64 44 75 72 61 74 69 6f 6e 29 0a 0a 20  HoldDuration).. 
2080: 20 20 20 72 65 74 75 72 6e 20 7b 0a 20 20 20 20     return {.    
2090: 20 20 64 65 73 74 69 6e 61 74 69 6f 6e 41 6d 6f    destinationAmo
20a0: 75 6e 74 2c 0a 20 20 20 20 20 20 73 6f 75 72 63  unt,.      sourc
20b0: 65 48 6f 6c 64 44 75 72 61 74 69 6f 6e 0a 20 20  eHoldDuration.  
20c0: 20 20 7d 0a 20 20 7d 0a 0a 20 20 2f 2a 2a 0a 20    }.  }..  /**. 
20d0: 20 20 2a 20 40 70 61 72 61 6d 20 7b 53 74 72 69    * @param {Stri
20e0: 6e 67 7d 20 73 6f 75 72 63 65 41 63 63 6f 75 6e  ng} sourceAccoun
20f0: 74 0a 20 20 20 2a 20 40 70 61 72 61 6d 20 7b 4f  t.   * @param {O
2100: 62 6a 65 63 74 7d 20 70 61 63 6b 65 74 0a 20 20  bject} packet.  
2110: 20 2a 20 40 70 61 72 61 6d 20 7b 53 74 72 69 6e   * @param {Strin
2120: 67 7d 20 70 61 63 6b 65 74 2e 64 65 73 74 69 6e  g} packet.destin
2130: 61 74 69 6f 6e 41 63 63 6f 75 6e 74 0a 20 20 20  ationAccount.   
2140: 2a 20 40 70 61 72 61 6d 20 7b 4e 75 6d 62 65 72  * @param {Number
2150: 7d 20 70 61 63 6b 65 74 2e 64 65 73 74 69 6e 61  } packet.destina
2160: 74 69 6f 6e 48 6f 6c 64 44 75 72 61 74 69 6f 6e  tionHoldDuration
2170: 0a 20 20 20 2a 20 40 70 61 72 61 6d 20 7b 53 74  .   * @param {St
2180: 72 69 6e 67 7d 20 70 61 63 6b 65 74 2e 64 65 73  ring} packet.des
2190: 74 69 6e 61 74 69 6f 6e 41 6d 6f 75 6e 74 0a 20  tinationAmount. 
21a0: 20 20 2a 20 40 72 65 74 75 72 6e 73 20 7b 51 75    * @returns {Qu
21b0: 6f 74 65 42 79 44 65 73 74 69 6e 61 74 69 6f 6e  oteByDestination
21c0: 52 65 73 70 6f 6e 73 65 7d 0a 20 20 20 2a 2f 0a  Response}.   */.
21d0: 20 20 61 73 79 6e 63 20 71 75 6f 74 65 42 79 44    async quoteByD
21e0: 65 73 74 69 6e 61 74 69 6f 6e 20 28 73 6f 75 72  estination (sour
21f0: 63 65 41 63 63 6f 75 6e 74 3a 20 73 74 72 69 6e  ceAccount: strin
2200: 67 2c 20 70 61 63 6b 65 74 3a 20 49 6c 70 50 61  g, packet: IlpPa
2210: 63 6b 65 74 2e 49 6c 71 70 42 79 44 65 73 74 69  cket.IlqpByDesti
2220: 6e 61 74 69 6f 6e 52 65 71 75 65 73 74 29 20 7b  nationRequest) {
2230: 0a 20 20 20 20 6c 6f 67 2e 69 6e 66 6f 28 27 63  .    log.info('c
2240: 72 65 61 74 69 6e 67 20 71 75 6f 74 65 20 62 79  reating quote by
2250: 20 64 65 73 74 69 6e 61 74 69 6f 6e 20 61 6d 6f   destination amo
2260: 75 6e 74 2e 20 73 6f 75 72 63 65 41 63 63 6f 75  unt. sourceAccou
2270: 6e 74 3d 25 73 20 64 65 73 74 69 6e 61 74 69 6f  nt=%s destinatio
2280: 6e 41 63 63 6f 75 6e 74 3d 25 73 20 64 65 73 74  nAccount=%s dest
2290: 69 6e 61 74 69 6f 6e 41 6d 6f 75 6e 74 3d 25 73  inationAmount=%s
22a0: 27 2c 0a 20 20 20 20 20 20 73 6f 75 72 63 65 41  ',.      sourceA
22b0: 63 63 6f 75 6e 74 2c 20 70 61 63 6b 65 74 2e 64  ccount, packet.d
22c0: 65 73 74 69 6e 61 74 69 6f 6e 41 63 63 6f 75 6e  estinationAccoun
22d0: 74 2c 20 70 61 63 6b 65 74 2e 64 65 73 74 69 6e  t, packet.destin
22e0: 61 74 69 6f 6e 41 6d 6f 75 6e 74 29 0a 0a 20 20  ationAmount)..  
22f0: 20 20 69 66 20 28 70 61 63 6b 65 74 2e 64 65 73    if (packet.des
2300: 74 69 6e 61 74 69 6f 6e 41 6d 6f 75 6e 74 20 3d  tinationAmount =
2310: 3d 3d 20 27 30 27 29 20 7b 0a 20 20 20 20 20 20  == '0') {.      
2320: 74 68 72 6f 77 20 6e 65 77 20 49 6e 76 61 6c 69  throw new Invali
2330: 64 41 6d 6f 75 6e 74 45 72 72 6f 72 28 27 64 65  dAmountError('de
2340: 73 74 69 6e 61 74 69 6f 6e 41 6d 6f 75 6e 74 20  stinationAmount 
2350: 6d 75 73 74 20 62 65 20 70 6f 73 69 74 69 76 65  must be positive
2360: 27 29 0a 20 20 20 20 7d 0a 0a 20 20 20 20 63 6f  ').    }..    co
2370: 6e 73 74 20 7b 20 6e 65 78 74 48 6f 70 2c 20 72  nst { nextHop, r
2380: 61 74 65 20 7d 20 3d 20 61 77 61 69 74 20 74 68  ate } = await th
2390: 69 73 2e 71 75 6f 74 65 4c 6f 63 61 6c 28 73 6f  is.quoteLocal(so
23a0: 75 72 63 65 41 63 63 6f 75 6e 74 2c 20 70 61 63  urceAccount, pac
23b0: 6b 65 74 2e 64 65 73 74 69 6e 61 74 69 6f 6e 41  ket.destinationA
23c0: 63 63 6f 75 6e 74 29 0a 0a 20 20 20 20 6c 65 74  ccount)..    let
23d0: 20 6e 65 78 74 48 6f 70 41 6d 6f 75 6e 74 0a 20   nextHopAmount. 
23e0: 20 20 20 6c 65 74 20 6e 65 78 74 48 6f 70 48 6f     let nextHopHo
23f0: 6c 64 44 75 72 61 74 69 6f 6e 0a 20 20 20 20 69  ldDuration.    i
2400: 66 20 28 70 61 63 6b 65 74 2e 64 65 73 74 69 6e  f (packet.destin
2410: 61 74 69 6f 6e 41 63 63 6f 75 6e 74 2e 73 74 61  ationAccount.sta
2420: 72 74 73 57 69 74 68 28 6e 65 78 74 48 6f 70 29  rtsWith(nextHop)
2430: 29 20 7b 0a 20 20 20 20 20 20 6c 6f 67 2e 64 65  ) {.      log.de
2440: 62 75 67 28 27 6c 6f 63 61 6c 20 64 65 73 74 69  bug('local desti
2450: 6e 61 74 69 6f 6e 2e 27 29 0a 20 20 20 20 20 20  nation.').      
2460: 6e 65 78 74 48 6f 70 41 6d 6f 75 6e 74 20 3d 20  nextHopAmount = 
2470: 70 61 63 6b 65 74 2e 64 65 73 74 69 6e 61 74 69  packet.destinati
2480: 6f 6e 41 6d 6f 75 6e 74 0a 20 20 20 20 20 20 6e  onAmount.      n
2490: 65 78 74 48 6f 70 48 6f 6c 64 44 75 72 61 74 69  extHopHoldDurati
24a0: 6f 6e 20 3d 20 70 61 63 6b 65 74 2e 64 65 73 74  on = packet.dest
24b0: 69 6e 61 74 69 6f 6e 48 6f 6c 64 44 75 72 61 74  inationHoldDurat
24c0: 69 6f 6e 0a 20 20 20 20 7d 20 65 6c 73 65 20 7b  ion.    } else {
24d0: 0a 20 20 20 20 20 20 63 6f 6e 73 74 20 71 75 6f  .      const quo
24e0: 74 65 20 3d 20 61 77 61 69 74 20 74 68 69 73 2e  te = await this.
24f0: 71 75 6f 74 65 72 2e 71 75 6f 74 65 4c 69 71 75  quoter.quoteLiqu
2500: 69 64 69 74 79 28 6e 65 78 74 48 6f 70 2c 20 70  idity(nextHop, p
2510: 61 63 6b 65 74 2e 64 65 73 74 69 6e 61 74 69 6f  acket.destinatio
2520: 6e 41 63 63 6f 75 6e 74 29 0a 20 20 20 20 20 20  nAccount).      
2530: 69 66 20 28 21 71 75 6f 74 65 29 20 7b 0a 20 20  if (!quote) {.  
2540: 20 20 20 20 20 20 6c 6f 67 2e 69 6e 66 6f 28 27        log.info('
2550: 6e 6f 20 71 75 6f 74 65 20 66 6f 75 6e 64 2e 20  no quote found. 
2560: 73 6f 75 72 63 65 41 63 63 6f 75 6e 74 3d 25 73  sourceAccount=%s
2570: 20 70 61 72 61 6d 73 3d 25 6a 27 2c 20 73 6f 75   params=%j', sou
2580: 72 63 65 41 63 63 6f 75 6e 74 2c 20 70 61 63 6b  rceAccount, pack
2590: 65 74 29 0a 20 20 20 20 20 20 20 20 74 68 72 6f  et).        thro
25a0: 77 20 6e 65 77 20 55 6e 72 65 61 63 68 61 62 6c  w new Unreachabl
25b0: 65 45 72 72 6f 72 28 27 6e 6f 20 71 75 6f 74 65  eError('no quote
25c0: 20 66 6f 75 6e 64 2e 20 74 6f 3d 27 20 2b 20 70   found. to=' + p
25d0: 61 63 6b 65 74 2e 64 65 73 74 69 6e 61 74 69 6f  acket.destinatio
25e0: 6e 41 63 63 6f 75 6e 74 29 0a 20 20 20 20 20 20  nAccount).      
25f0: 7d 0a 20 20 20 20 20 20 6c 6f 67 2e 64 65 62 75  }.      log.debu
2600: 67 28 27 72 65 6d 6f 74 65 20 64 65 73 74 69 6e  g('remote destin
2610: 61 74 69 6f 6e 2e 20 71 75 6f 74 65 3d 25 6a 27  ation. quote=%j'
2620: 2c 20 71 75 6f 74 65 29 0a 0a 20 20 20 20 20 20  , quote)..      
2630: 6e 65 78 74 48 6f 70 41 6d 6f 75 6e 74 20 3d 20  nextHopAmount = 
2640: 71 75 6f 74 65 2e 63 75 72 76 65 2e 61 6d 6f 75  quote.curve.amou
2650: 6e 74 52 65 76 65 72 73 65 28 70 61 63 6b 65 74  ntReverse(packet
2660: 2e 64 65 73 74 69 6e 61 74 69 6f 6e 41 6d 6f 75  .destinationAmou
2670: 6e 74 29 2e 74 6f 53 74 72 69 6e 67 28 29 0a 20  nt).toString(). 
2680: 20 20 20 20 20 6e 65 78 74 48 6f 70 48 6f 6c 64       nextHopHold
2690: 44 75 72 61 74 69 6f 6e 20 3d 20 70 61 63 6b 65  Duration = packe
26a0: 74 2e 64 65 73 74 69 6e 61 74 69 6f 6e 48 6f 6c  t.destinationHol
26b0: 64 44 75 72 61 74 69 6f 6e 20 2b 20 71 75 6f 74  dDuration + quot
26c0: 65 2e 6d 69 6e 4d 65 73 73 61 67 65 57 69 6e 64  e.minMessageWind
26d0: 6f 77 0a 20 20 20 20 7d 0a 0a 20 20 20 20 63 6f  ow.    }..    co
26e0: 6e 73 74 20 73 6f 75 72 63 65 41 6d 6f 75 6e 74  nst sourceAmount
26f0: 20 3d 20 6e 65 77 20 42 69 67 4e 75 6d 62 65 72   = new BigNumber
2700: 28 6e 65 78 74 48 6f 70 41 6d 6f 75 6e 74 29 2e  (nextHopAmount).
2710: 64 69 76 28 72 61 74 65 29 2e 69 6e 74 65 67 65  div(rate).intege
2720: 72 56 61 6c 75 65 28 42 69 67 4e 75 6d 62 65 72  rValue(BigNumber
2730: 2e 52 4f 55 4e 44 5f 43 45 49 4c 29 2e 74 6f 53  .ROUND_CEIL).toS
2740: 74 72 69 6e 67 28 29 0a 20 20 20 20 63 6f 6e 73  tring().    cons
2750: 74 20 73 6f 75 72 63 65 48 6f 6c 64 44 75 72 61  t sourceHoldDura
2760: 74 69 6f 6e 20 3d 20 6e 65 78 74 48 6f 70 48 6f  tion = nextHopHo
2770: 6c 64 44 75 72 61 74 69 6f 6e 20 2b 20 74 68 69  ldDuration + thi
2780: 73 2e 63 6f 6e 66 69 67 2e 6d 69 6e 4d 65 73 73  s.config.minMess
2790: 61 67 65 57 69 6e 64 6f 77 0a 20 20 20 20 69 66  ageWindow.    if
27a0: 20 28 73 6f 75 72 63 65 41 6d 6f 75 6e 74 20 3d   (sourceAmount =
27b0: 3d 3d 20 27 30 27 29 20 7b 0a 20 20 20 20 20 20  == '0') {.      
27c0: 74 68 72 6f 77 20 6e 65 77 20 49 6e 76 61 6c 69  throw new Invali
27d0: 64 41 6d 6f 75 6e 74 45 72 72 6f 72 28 27 51 75  dAmountError('Qu
27e0: 6f 74 65 64 20 73 6f 75 72 63 65 20 69 73 20 6c  oted source is l
27f0: 6f 77 65 72 20 74 68 61 6e 20 6d 69 6e 69 6d 75  ower than minimu
2800: 6d 20 61 6d 6f 75 6e 74 20 61 6c 6c 6f 77 65 64  m amount allowed
2810: 27 29 0a 20 20 20 20 7d 0a 20 20 20 20 74 68 69  ').    }.    thi
2820: 73 2e 5f 76 65 72 69 66 79 50 6c 75 67 69 6e 49  s._verifyPluginI
2830: 73 43 6f 6e 6e 65 63 74 65 64 28 73 6f 75 72 63  sConnected(sourc
2840: 65 41 63 63 6f 75 6e 74 29 0a 20 20 20 20 74 68  eAccount).    th
2850: 69 73 2e 5f 76 65 72 69 66 79 50 6c 75 67 69 6e  is._verifyPlugin
2860: 49 73 43 6f 6e 6e 65 63 74 65 64 28 6e 65 78 74  IsConnected(next
2870: 48 6f 70 29 0a 20 20 20 20 74 68 69 73 2e 5f 76  Hop).    this._v
2880: 61 6c 69 64 61 74 65 48 6f 6c 64 44 75 72 61 74  alidateHoldDurat
2890: 69 6f 6e 73 28 73 6f 75 72 63 65 48 6f 6c 64 44  ions(sourceHoldD
28a0: 75 72 61 74 69 6f 6e 2c 20 70 61 63 6b 65 74 2e  uration, packet.
28b0: 64 65 73 74 69 6e 61 74 69 6f 6e 48 6f 6c 64 44  destinationHoldD
28c0: 75 72 61 74 69 6f 6e 29 0a 20 20 20 20 72 65 74  uration).    ret
28d0: 75 72 6e 20 7b 0a 20 20 20 20 20 20 73 6f 75 72  urn {.      sour
28e0: 63 65 41 6d 6f 75 6e 74 2c 0a 20 20 20 20 20 20  ceAmount,.      
28f0: 73 6f 75 72 63 65 48 6f 6c 64 44 75 72 61 74 69  sourceHoldDurati
2900: 6f 6e 0a 20 20 20 20 7d 0a 20 20 7d 0a 0a 20 20  on.    }.  }..  
2910: 2f 2a 2a 0a 20 20 20 2a 20 40 74 79 70 65 64 65  /**.   * @typede
2920: 66 20 7b 4f 62 6a 65 63 74 7d 20 4e 65 78 74 48  f {Object} NextH
2930: 6f 70 50 61 63 6b 65 74 49 6e 66 6f 0a 20 20 20  opPacketInfo.   
2940: 2a 20 40 70 72 6f 70 65 72 74 79 20 7b 73 74 72  * @property {str
2950: 69 6e 67 7d 20 6e 65 78 74 48 6f 70 20 41 64 64  ing} nextHop Add
2960: 72 65 73 73 20 6f 66 20 74 68 65 20 6e 65 78 74  ress of the next
2970: 20 70 65 65 72 20 74 6f 20 66 6f 72 77 61 72 64   peer to forward
2980: 20 74 68 65 20 70 61 63 6b 65 74 20 74 6f 0a 20   the packet to. 
2990: 20 20 2a 20 40 70 72 6f 70 65 72 74 79 20 7b 42    * @property {B
29a0: 75 66 66 65 72 7d 20 6e 65 78 74 48 6f 70 50 61  uffer} nextHopPa
29b0: 63 6b 65 74 20 4f 75 74 67 6f 69 6e 67 20 70 61  cket Outgoing pa
29c0: 63 6b 65 74 0a 20 20 20 2a 2f 0a 0a 20 20 2f 2a  cket.   */..  /*
29d0: 2a 0a 20 20 20 2a 20 47 65 74 20 6e 65 78 74 20  *.   * Get next 
29e0: 49 4c 50 20 70 72 65 70 61 72 65 20 70 61 63 6b  ILP prepare pack
29f0: 65 74 2e 0a 20 20 20 2a 0a 20 20 20 2a 20 47 69  et..   *.   * Gi
2a00: 76 65 6e 20 61 20 70 72 65 76 69 6f 75 73 20 49  ven a previous I
2a10: 4c 50 20 70 72 65 70 61 72 65 20 70 61 63 6b 65  LP prepare packe
2a20: 74 2c 20 72 65 74 75 72 6e 73 20 74 68 65 20 6e  t, returns the n
2a30: 65 78 74 20 49 4c 50 20 70 72 65 70 61 72 65 20  ext ILP prepare 
2a40: 70 61 63 6b 65 74 20 69 6e 0a 20 20 20 2a 20 74  packet in.   * t
2a50: 68 65 20 63 68 61 69 6e 2e 0a 20 20 20 2a 0a 20  he chain..   *. 
2a60: 20 20 2a 20 40 70 61 72 61 6d 20 7b 73 74 72 69    * @param {stri
2a70: 6e 67 7d 20 73 6f 75 72 63 65 41 63 63 6f 75 6e  ng} sourceAccoun
2a80: 74 20 49 4c 50 20 61 64 64 72 65 73 73 20 6f 66  t ILP address of
2a90: 20 6f 75 72 20 70 65 65 72 20 77 68 6f 20 73 65   our peer who se
2aa0: 6e 74 20 75 73 20 74 68 65 20 70 61 63 6b 65 74  nt us the packet
2ab0: 0a 20 20 20 2a 20 40 70 61 72 61 6d 20 7b 49 6c  .   * @param {Il
2ac0: 70 50 72 65 70 61 72 65 7d 20 73 6f 75 72 63 65  pPrepare} source
2ad0: 50 61 63 6b 65 74 20 28 50 61 72 73 65 64 20 70  Packet (Parsed p
2ae0: 61 63 6b 65 74 20 74 68 61 74 20 77 65 20 72 65  acket that we re
2af0: 63 65 69 76 65 64 0a 20 20 20 2a 20 40 72 65 74  ceived.   * @ret
2b00: 75 72 6e 73 20 7b 4e 65 78 74 48 6f 70 50 61 63  urns {NextHopPac
2b10: 6b 65 74 49 6e 66 6f 7d 20 41 63 63 6f 75 6e 74  ketInfo} Account
2b20: 20 61 6e 64 20 70 61 63 6b 65 74 20 66 6f 72 20   and packet for 
2b30: 6e 65 78 74 20 68 6f 70 0a 20 20 20 2a 2f 0a 20  next hop.   */. 
2b40: 20 61 73 79 6e 63 20 67 65 74 4e 65 78 74 48 6f   async getNextHo
2b50: 70 50 61 63 6b 65 74 20 28 73 6f 75 72 63 65 41  pPacket (sourceA
2b60: 63 63 6f 75 6e 74 3a 20 73 74 72 69 6e 67 2c 20  ccount: string, 
2b70: 73 6f 75 72 63 65 50 61 63 6b 65 74 3a 20 49 6c  sourcePacket: Il
2b80: 70 50 61 63 6b 65 74 2e 49 6c 70 50 72 65 70 61  pPacket.IlpPrepa
2b90: 72 65 29 20 7b 0a 20 20 20 20 63 6f 6e 73 74 20  re) {.    const 
2ba0: 7b 0a 20 20 20 20 20 20 61 6d 6f 75 6e 74 2c 0a  {.      amount,.
2bb0: 20 20 20 20 20 20 65 78 65 63 75 74 69 6f 6e 43        executionC
2bc0: 6f 6e 64 69 74 69 6f 6e 2c 0a 20 20 20 20 20 20  ondition,.      
2bd0: 65 78 70 69 72 65 73 41 74 2c 0a 20 20 20 20 20  expiresAt,.     
2be0: 20 64 65 73 74 69 6e 61 74 69 6f 6e 2c 0a 20 20   destination,.  
2bf0: 20 20 20 20 64 61 74 61 0a 20 20 20 20 7d 20 3d      data.    } =
2c00: 20 73 6f 75 72 63 65 50 61 63 6b 65 74 0a 0a 20   sourcePacket.. 
2c10: 20 20 20 6c 6f 67 2e 69 6e 66 6f 28 0a 20 20 20     log.info(.   
2c20: 20 20 20 27 63 6f 6e 73 74 72 75 63 74 69 6e 67     'constructing
2c30: 20 6e 65 78 74 20 68 6f 70 20 70 61 63 6b 65 74   next hop packet
2c40: 2e 20 73 6f 75 72 63 65 41 63 63 6f 75 6e 74 3d  . sourceAccount=
2c50: 25 73 20 73 6f 75 72 63 65 41 6d 6f 75 6e 74 3d  %s sourceAmount=
2c60: 25 73 20 64 65 73 74 69 6e 61 74 69 6f 6e 3d 25  %s destination=%
2c70: 73 27 2c 0a 20 20 20 20 20 20 73 6f 75 72 63 65  s',.      source
2c80: 41 63 63 6f 75 6e 74 2c 20 61 6d 6f 75 6e 74 2c  Account, amount,
2c90: 20 64 65 73 74 69 6e 61 74 69 6f 6e 0a 20 20 20   destination.   
2ca0: 20 29 0a 0a 20 20 20 20 69 66 20 28 64 65 73 74   )..    if (dest
2cb0: 69 6e 61 74 69 6f 6e 2e 6c 65 6e 67 74 68 20 3c  ination.length <
2cc0: 20 31 29 20 7b 0a 20 20 20 20 20 20 74 68 72 6f   1) {.      thro
2cd0: 77 20 6e 65 77 20 49 6e 76 61 6c 69 64 50 61 63  w new InvalidPac
2ce0: 6b 65 74 45 72 72 6f 72 28 27 6d 69 73 73 69 6e  ketError('missin
2cf0: 67 20 64 65 73 74 69 6e 61 74 69 6f 6e 2e 27 29  g destination.')
2d00: 0a 20 20 20 20 7d 0a 0a 20 20 20 20 63 6f 6e 73  .    }..    cons
2d10: 74 20 72 6f 75 74 65 20 3d 20 74 68 69 73 2e 72  t route = this.r
2d20: 6f 75 74 69 6e 67 54 61 62 6c 65 2e 72 65 73 6f  outingTable.reso
2d30: 6c 76 65 28 64 65 73 74 69 6e 61 74 69 6f 6e 29  lve(destination)
2d40: 0a 0a 20 20 20 20 69 66 20 28 21 72 6f 75 74 65  ..    if (!route
2d50: 29 20 7b 0a 20 20 20 20 20 20 6c 6f 67 2e 69 6e  ) {.      log.in
2d60: 66 6f 28 27 63 6f 75 6c 64 20 6e 6f 74 20 66 69  fo('could not fi
2d70: 6e 64 20 72 6f 75 74 65 20 66 6f 72 20 74 72 61  nd route for tra
2d80: 6e 73 66 65 72 2e 20 73 6f 75 72 63 65 41 63 63  nsfer. sourceAcc
2d90: 6f 75 6e 74 3d 25 73 20 73 6f 75 72 63 65 41 6d  ount=%s sourceAm
2da0: 6f 75 6e 74 3d 25 73 20 64 65 73 74 69 6e 61 74  ount=%s destinat
2db0: 69 6f 6e 41 63 63 6f 75 6e 74 3d 25 73 27 2c 20  ionAccount=%s', 
2dc0: 73 6f 75 72 63 65 41 63 63 6f 75 6e 74 2c 20 61  sourceAccount, a
2dd0: 6d 6f 75 6e 74 2c 20 64 65 73 74 69 6e 61 74 69  mount, destinati
2de0: 6f 6e 29 0a 20 20 20 20 20 20 74 68 72 6f 77 20  on).      throw 
2df0: 6e 65 77 20 55 6e 72 65 61 63 68 61 62 6c 65 45  new UnreachableE
2e00: 72 72 6f 72 28 27 6e 6f 20 72 6f 75 74 65 20 66  rror('no route f
2e10: 6f 75 6e 64 2e 20 73 6f 75 72 63 65 3d 27 20 2b  ound. source=' +
2e20: 20 73 6f 75 72 63 65 41 63 63 6f 75 6e 74 20 2b   sourceAccount +
2e30: 20 27 20 64 65 73 74 69 6e 61 74 69 6f 6e 3d 27   ' destination='
2e40: 20 2b 20 64 65 73 74 69 6e 61 74 69 6f 6e 29 0a   + destination).
2e50: 20 20 20 20 7d 0a 0a 20 20 20 20 63 6f 6e 73 74      }..    const
2e60: 20 6e 65 78 74 48 6f 70 20 3d 20 72 6f 75 74 65   nextHop = route
2e70: 2e 6e 65 78 74 48 6f 70 0a 0a 20 20 20 20 6c 6f  .nextHop..    lo
2e80: 67 2e 64 65 62 75 67 28 27 64 65 74 65 72 6d 69  g.debug('determi
2e90: 6e 65 64 20 6e 65 78 74 20 68 6f 70 2e 20 6e 65  ned next hop. ne
2ea0: 78 74 48 6f 70 3d 25 73 27 2c 20 6e 65 78 74 48  xtHop=%s', nextH
2eb0: 6f 70 29 0a 0a 20 20 20 20 63 6f 6e 73 74 20 72  op)..    const r
2ec0: 61 74 65 20 3d 20 61 77 61 69 74 20 74 68 69 73  ate = await this
2ed0: 2e 62 61 63 6b 65 6e 64 2e 67 65 74 52 61 74 65  .backend.getRate
2ee0: 28 73 6f 75 72 63 65 41 63 63 6f 75 6e 74 2c 20  (sourceAccount, 
2ef0: 6e 65 78 74 48 6f 70 29 0a 0a 20 20 20 20 6c 6f  nextHop)..    lo
2f00: 67 2e 64 65 62 75 67 28 27 64 65 74 65 72 6d 69  g.debug('determi
2f10: 6e 65 64 20 6c 6f 63 61 6c 20 72 61 74 65 2e 20  ned local rate. 
2f20: 72 61 74 65 3d 25 73 27 2c 20 72 61 74 65 29 0a  rate=%s', rate).
2f30: 0a 20 20 20 20 74 68 69 73 2e 5f 76 65 72 69 66  .    this._verif
2f40: 79 50 6c 75 67 69 6e 49 73 43 6f 6e 6e 65 63 74  yPluginIsConnect
2f50: 65 64 28 6e 65 78 74 48 6f 70 29 0a 0a 20 20 20  ed(nextHop)..   
2f60: 20 63 6f 6e 73 74 20 6e 65 78 74 41 6d 6f 75 6e   const nextAmoun
2f70: 74 20 3d 20 6e 65 77 20 42 69 67 4e 75 6d 62 65  t = new BigNumbe
2f80: 72 28 61 6d 6f 75 6e 74 29 2e 74 69 6d 65 73 28  r(amount).times(
2f90: 72 61 74 65 29 2e 69 6e 74 65 67 65 72 56 61 6c  rate).integerVal
2fa0: 75 65 28 42 69 67 4e 75 6d 62 65 72 2e 52 4f 55  ue(BigNumber.ROU
2fb0: 4e 44 5f 46 4c 4f 4f 52 29 0a 0a 20 20 20 20 72  ND_FLOOR)..    r
2fc0: 65 74 75 72 6e 20 7b 0a 20 20 20 20 20 20 6e 65  eturn {.      ne
2fd0: 78 74 48 6f 70 2c 0a 20 20 20 20 20 20 6e 65 78  xtHop,.      nex
2fe0: 74 48 6f 70 50 61 63 6b 65 74 3a 20 7b 0a 20 20  tHopPacket: {.  
2ff0: 20 20 20 20 20 20 61 6d 6f 75 6e 74 3a 20 6e 65        amount: ne
3000: 78 74 41 6d 6f 75 6e 74 2e 74 6f 53 74 72 69 6e  xtAmount.toStrin
3010: 67 28 29 2c 0a 20 20 20 20 20 20 20 20 65 78 70  g(),.        exp
3020: 69 72 65 73 41 74 3a 20 74 68 69 73 2e 5f 67 65  iresAt: this._ge
3030: 74 44 65 73 74 69 6e 61 74 69 6f 6e 45 78 70 69  tDestinationExpi
3040: 72 79 28 65 78 70 69 72 65 73 41 74 29 2c 0a 20  ry(expiresAt),. 
3050: 20 20 20 20 20 20 20 65 78 65 63 75 74 69 6f 6e         execution
3060: 43 6f 6e 64 69 74 69 6f 6e 2c 0a 20 20 20 20 20  Condition,.     
3070: 20 20 20 64 65 73 74 69 6e 61 74 69 6f 6e 2c 0a     destination,.
3080: 20 20 20 20 20 20 20 20 64 61 74 61 0a 20 20 20          data.   
3090: 20 20 20 7d 0a 20 20 20 20 7d 0a 20 20 7d 0a 0a     }.    }.  }..
30a0: 20 20 2f 2f 20 54 4f 44 4f 3a 20 69 6e 63 6c 75    // TODO: inclu
30b0: 64 65 20 74 68 65 20 65 78 70 69 72 79 20 64 75  de the expiry du
30c0: 72 61 74 69 6f 6e 20 69 6e 20 74 68 65 20 71 75  ration in the qu
30d0: 6f 74 65 20 6c 6f 67 69 63 0a 20 20 5f 76 61 6c  ote logic.  _val
30e0: 69 64 61 74 65 48 6f 6c 64 44 75 72 61 74 69 6f  idateHoldDuratio
30f0: 6e 73 20 28 73 6f 75 72 63 65 48 6f 6c 64 44 75  ns (sourceHoldDu
3100: 72 61 74 69 6f 6e 3a 20 6e 75 6d 62 65 72 2c 20  ration: number, 
3110: 64 65 73 74 69 6e 61 74 69 6f 6e 48 6f 6c 64 44  destinationHoldD
3120: 75 72 61 74 69 6f 6e 3a 20 6e 75 6d 62 65 72 29  uration: number)
3130: 20 7b 0a 20 20 20 20 2f 2f 20 43 68 65 63 6b 20   {.    // Check 
3140: 64 65 73 74 69 6e 61 74 69 6f 6e 5f 65 78 70 69  destination_expi
3150: 72 79 5f 64 75 72 61 74 69 6f 6e 0a 20 20 20 20  ry_duration.    
3160: 69 66 20 28 64 65 73 74 69 6e 61 74 69 6f 6e 48  if (destinationH
3170: 6f 6c 64 44 75 72 61 74 69 6f 6e 20 3e 20 74 68  oldDuration > th
3180: 69 73 2e 63 6f 6e 66 69 67 2e 6d 61 78 48 6f 6c  is.config.maxHol
3190: 64 54 69 6d 65 29 20 7b 0a 20 20 20 20 20 20 74  dTime) {.      t
31a0: 68 72 6f 77 20 6e 65 77 20 42 61 64 52 65 71 75  hrow new BadRequ
31b0: 65 73 74 45 72 72 6f 72 28 27 64 65 73 74 69 6e  estError('destin
31c0: 61 74 69 6f 6e 20 65 78 70 69 72 79 20 64 75 72  ation expiry dur
31d0: 61 74 69 6f 6e 20 27 20 2b 0a 20 20 20 20 20 20  ation ' +.      
31e0: 20 20 27 69 73 20 74 6f 6f 20 6c 6f 6e 67 2e 20    'is too long. 
31f0: 64 65 73 74 69 6e 61 74 69 6f 6e 48 6f 6c 64 44  destinationHoldD
3200: 75 72 61 74 69 6f 6e 3d 27 20 2b 20 64 65 73 74  uration=' + dest
3210: 69 6e 61 74 69 6f 6e 48 6f 6c 64 44 75 72 61 74  inationHoldDurat
3220: 69 6f 6e 20 2b 0a 20 20 20 20 20 20 20 20 27 20  ion +.        ' 
3230: 6d 61 78 48 6f 6c 64 54 69 6d 65 3d 27 20 2b 20  maxHoldTime=' + 
3240: 74 68 69 73 2e 63 6f 6e 66 69 67 2e 6d 61 78 48  this.config.maxH
3250: 6f 6c 64 54 69 6d 65 29 0a 20 20 20 20 7d 0a 0a  oldTime).    }..
3260: 20 20 20 20 2f 2f 20 43 68 65 63 6b 20 64 69 66      // Check dif
3270: 66 65 72 65 6e 63 65 20 62 65 74 77 65 65 6e 20  ference between 
3280: 64 65 73 74 69 6e 61 74 69 6f 6e 5f 65 78 70 69  destination_expi
3290: 72 79 5f 64 75 72 61 74 69 6f 6e 20 61 6e 64 20  ry_duration and 
32a0: 73 6f 75 72 63 65 5f 65 78 70 69 72 79 5f 64 75  source_expiry_du
32b0: 72 61 74 69 6f 6e 0a 20 20 20 20 69 66 20 28 73  ration.    if (s
32c0: 6f 75 72 63 65 48 6f 6c 64 44 75 72 61 74 69 6f  ourceHoldDuratio
32d0: 6e 20 2d 20 64 65 73 74 69 6e 61 74 69 6f 6e 48  n - destinationH
32e0: 6f 6c 64 44 75 72 61 74 69 6f 6e 20 3c 20 74 68  oldDuration < th
32f0: 69 73 2e 63 6f 6e 66 69 67 2e 6d 69 6e 4d 65 73  is.config.minMes
3300: 73 61 67 65 57 69 6e 64 6f 77 29 20 7b 0a 20 20  sageWindow) {.  
3310: 20 20 20 20 74 68 72 6f 77 20 6e 65 77 20 42 61      throw new Ba
3320: 64 52 65 71 75 65 73 74 45 72 72 6f 72 28 27 74  dRequestError('t
3330: 68 65 20 64 69 66 66 65 72 65 6e 63 65 20 62 65  he difference be
3340: 74 77 65 65 6e 20 74 68 65 20 27 20 2b 0a 20 20  tween the ' +.  
3350: 20 20 20 20 20 20 27 64 65 73 74 69 6e 61 74 69        'destinati
3360: 6f 6e 20 65 78 70 69 72 79 20 64 75 72 61 74 69  on expiry durati
3370: 6f 6e 20 61 6e 64 20 74 68 65 20 73 6f 75 72 63  on and the sourc
3380: 65 20 65 78 70 69 72 79 20 64 75 72 61 74 69 6f  e expiry duratio
3390: 6e 20 27 20 2b 0a 20 20 20 20 20 20 20 20 27 69  n ' +.        'i
33a0: 73 20 69 6e 73 75 66 66 69 63 69 65 6e 74 20 74  s insufficient t
33b0: 6f 20 65 6e 73 75 72 65 20 74 68 61 74 20 77 65  o ensure that we
33c0: 20 63 61 6e 20 65 78 65 63 75 74 65 20 74 68 65   can execute the
33d0: 20 27 20 2b 0a 20 20 20 20 20 20 20 20 27 73 6f   ' +.        'so
33e0: 75 72 63 65 20 74 72 61 6e 73 66 65 72 73 2e 27  urce transfers.'
33f0: 29 0a 20 20 20 20 7d 0a 20 20 7d 0a 0a 20 20 5f  ).    }.  }..  _
3400: 67 65 74 44 65 73 74 69 6e 61 74 69 6f 6e 45 78  getDestinationEx
3410: 70 69 72 79 20 28 73 6f 75 72 63 65 45 78 70 69  piry (sourceExpi
3420: 72 79 3a 20 44 61 74 65 29 20 7b 0a 20 20 20 20  ry: Date) {.    
3430: 69 66 20 28 21 73 6f 75 72 63 65 45 78 70 69 72  if (!sourceExpir
3440: 79 29 20 7b 0a 20 20 20 20 20 20 74 68 72 6f 77  y) {.      throw
3450: 20 6e 65 77 20 54 79 70 65 45 72 72 6f 72 28 27   new TypeError('
3460: 73 6f 75 72 63 65 20 65 78 70 69 72 79 20 6d 75  source expiry mu
3470: 73 74 20 62 65 20 61 20 44 61 74 65 27 29 0a 20  st be a Date'). 
3480: 20 20 20 7d 0a 20 20 20 20 63 6f 6e 73 74 20 73     }.    const s
3490: 6f 75 72 63 65 45 78 70 69 72 79 54 69 6d 65 20  ourceExpiryTime 
34a0: 3d 20 73 6f 75 72 63 65 45 78 70 69 72 79 2e 67  = sourceExpiry.g
34b0: 65 74 54 69 6d 65 28 29 0a 0a 20 20 20 20 69 66  etTime()..    if
34c0: 20 28 73 6f 75 72 63 65 45 78 70 69 72 79 54 69   (sourceExpiryTi
34d0: 6d 65 20 3c 20 44 61 74 65 2e 6e 6f 77 28 29 29  me < Date.now())
34e0: 20 7b 0a 20 20 20 20 20 20 74 68 72 6f 77 20 6e   {.      throw n
34f0: 65 77 20 49 6e 73 75 66 66 69 63 69 65 6e 74 54  ew InsufficientT
3500: 69 6d 65 6f 75 74 45 72 72 6f 72 28 27 73 6f 75  imeoutError('sou
3510: 72 63 65 20 74 72 61 6e 73 66 65 72 20 68 61 73  rce transfer has
3520: 20 61 6c 72 65 61 64 79 20 65 78 70 69 72 65 64   already expired
3530: 2e 20 73 6f 75 72 63 65 45 78 70 69 72 79 3d 27  . sourceExpiry='
3540: 20 2b 20 73 6f 75 72 63 65 45 78 70 69 72 79 2e   + sourceExpiry.
3550: 74 6f 49 53 4f 53 74 72 69 6e 67 28 29 20 2b 20  toISOString() + 
3560: 27 20 63 75 72 72 65 6e 74 54 69 6d 65 3d 27 20  ' currentTime=' 
3570: 2b 20 28 6e 65 77 20 44 61 74 65 28 29 2e 74 6f  + (new Date().to
3580: 49 53 4f 53 74 72 69 6e 67 28 29 29 29 0a 20 20  ISOString())).  
3590: 20 20 7d 0a 0a 20 20 20 20 2f 2f 20 57 65 20 77    }..    // We w
35a0: 69 6c 6c 20 73 65 74 20 74 68 65 20 6e 65 78 74  ill set the next
35b0: 20 74 72 61 6e 73 66 65 72 27 73 20 65 78 70 69   transfer's expi
35c0: 72 79 20 62 61 73 65 64 20 6f 6e 20 74 68 65 20  ry based on the 
35d0: 73 6f 75 72 63 65 20 65 78 70 69 72 79 20 61 6e  source expiry an
35e0: 64 20 6f 75 72 0a 20 20 20 20 2f 2f 20 6d 69 6e  d our.    // min
35f0: 4d 65 73 73 61 67 65 57 69 6e 64 6f 77 2c 20 62  MessageWindow, b
3600: 75 74 20 63 61 70 20 69 74 20 61 74 20 6f 75 72  ut cap it at our
3610: 20 6d 61 78 48 6f 6c 64 54 69 6d 65 2e 0a 20 20   maxHoldTime..  
3620: 20 20 63 6f 6e 73 74 20 64 65 73 74 69 6e 61 74    const destinat
3630: 69 6f 6e 45 78 70 69 72 79 54 69 6d 65 20 3d 20  ionExpiryTime = 
3640: 4d 61 74 68 2e 6d 69 6e 28 73 6f 75 72 63 65 45  Math.min(sourceE
3650: 78 70 69 72 79 54 69 6d 65 20 2d 20 74 68 69 73  xpiryTime - this
3660: 2e 63 6f 6e 66 69 67 2e 6d 69 6e 4d 65 73 73 61  .config.minMessa
3670: 67 65 57 69 6e 64 6f 77 2c 20 44 61 74 65 2e 6e  geWindow, Date.n
3680: 6f 77 28 29 20 2b 20 74 68 69 73 2e 63 6f 6e 66  ow() + this.conf
3690: 69 67 2e 6d 61 78 48 6f 6c 64 54 69 6d 65 29 0a  ig.maxHoldTime).
36a0: 0a 20 20 20 20 69 66 20 28 28 64 65 73 74 69 6e  .    if ((destin
36b0: 61 74 69 6f 6e 45 78 70 69 72 79 54 69 6d 65 20  ationExpiryTime 
36c0: 2d 20 44 61 74 65 2e 6e 6f 77 28 29 29 20 3c 20  - Date.now()) < 
36d0: 74 68 69 73 2e 63 6f 6e 66 69 67 2e 6d 69 6e 4d  this.config.minM
36e0: 65 73 73 61 67 65 57 69 6e 64 6f 77 29 20 7b 0a  essageWindow) {.
36f0: 20 20 20 20 20 20 74 68 72 6f 77 20 6e 65 77 20        throw new 
3700: 49 6e 73 75 66 66 69 63 69 65 6e 74 54 69 6d 65  InsufficientTime
3710: 6f 75 74 45 72 72 6f 72 28 27 73 6f 75 72 63 65  outError('source
3720: 20 74 72 61 6e 73 66 65 72 20 65 78 70 69 72 65   transfer expire
3730: 73 20 74 6f 6f 20 73 6f 6f 6e 20 74 6f 20 63 6f  s too soon to co
3740: 6d 70 6c 65 74 65 20 70 61 79 6d 65 6e 74 2e 20  mplete payment. 
3750: 61 63 74 75 61 6c 53 6f 75 72 63 65 45 78 70 69  actualSourceExpi
3760: 72 79 3d 27 20 2b 20 73 6f 75 72 63 65 45 78 70  ry=' + sourceExp
3770: 69 72 79 2e 74 6f 49 53 4f 53 74 72 69 6e 67 28  iry.toISOString(
3780: 29 20 2b 20 27 20 72 65 71 75 69 72 65 64 53 6f  ) + ' requiredSo
3790: 75 72 63 65 45 78 70 69 72 79 3d 27 20 2b 20 28  urceExpiry=' + (
37a0: 6e 65 77 20 44 61 74 65 28 44 61 74 65 2e 6e 6f  new Date(Date.no
37b0: 77 28 29 20 2b 20 32 20 2a 20 74 68 69 73 2e 63  w() + 2 * this.c
37c0: 6f 6e 66 69 67 2e 6d 69 6e 4d 65 73 73 61 67 65  onfig.minMessage
37d0: 57 69 6e 64 6f 77 29 2e 74 6f 49 53 4f 53 74 72  Window).toISOStr
37e0: 69 6e 67 28 29 29 20 2b 20 27 20 63 75 72 72 65  ing()) + ' curre
37f0: 6e 74 54 69 6d 65 3d 27 20 2b 20 28 6e 65 77 20  ntTime=' + (new 
3800: 44 61 74 65 28 29 2e 74 6f 49 53 4f 53 74 72 69  Date().toISOStri
3810: 6e 67 28 29 29 29 0a 20 20 20 20 7d 0a 0a 20 20  ng())).    }..  
3820: 20 20 72 65 74 75 72 6e 20 6e 65 77 20 44 61 74    return new Dat
3830: 65 28 64 65 73 74 69 6e 61 74 69 6f 6e 45 78 70  e(destinationExp
3840: 69 72 79 54 69 6d 65 29 0a 20 20 7d 0a 0a 20 20  iryTime).  }..  
3850: 5f 76 65 72 69 66 79 50 6c 75 67 69 6e 49 73 43  _verifyPluginIsC
3860: 6f 6e 6e 65 63 74 65 64 20 28 61 63 63 6f 75 6e  onnected (accoun
3870: 74 3a 20 73 74 72 69 6e 67 29 20 7b 0a 20 20 20  t: string) {.   
3880: 20 69 66 20 28 21 74 68 69 73 2e 61 63 63 6f 75   if (!this.accou
3890: 6e 74 73 2e 67 65 74 50 6c 75 67 69 6e 28 61 63  nts.getPlugin(ac
38a0: 63 6f 75 6e 74 29 2e 69 73 43 6f 6e 6e 65 63 74  count).isConnect
38b0: 65 64 28 29 29 20 7b 0a 20 20 20 20 20 20 74 68  ed()) {.      th
38c0: 72 6f 77 20 6e 65 77 20 50 65 65 72 55 6e 72 65  row new PeerUnre
38d0: 61 63 68 61 62 6c 65 45 72 72 6f 72 28 27 6e 6f  achableError('no
38e0: 20 63 6f 6e 6e 65 63 74 69 6f 6e 20 74 6f 20 61   connection to a
38f0: 63 63 6f 75 6e 74 2e 20 61 63 63 6f 75 6e 74 3d  ccount. account=
3900: 27 20 2b 20 61 63 63 6f 75 6e 74 29 0a 20 20 20  ' + account).   
3910: 20 7d 0a 20 20 7d 0a 7d 0a                        }.  }.}.