Hex Artifact Content
Not logged in

Artifact 995ddf03c93a6da77c859f9d1494f4cc69a5b1b0:


0000: 69 6d 70 6f 72 74 20 2a 20 61 73 20 49 6c 70 50  import * as IlpP
0010: 61 63 6b 65 74 20 66 72 6f 6d 20 27 69 6c 70 2d  acket from 'ilp-
0020: 70 61 63 6b 65 74 27 0a 69 6d 70 6f 72 74 20 41  packet'.import A
0030: 63 63 6f 75 6e 74 73 20 66 72 6f 6d 20 27 2e 2f  ccounts from './
0040: 61 63 63 6f 75 6e 74 73 27 0a 69 6d 70 6f 72 74  accounts'.import
0050: 20 43 6f 6e 66 69 67 20 66 72 6f 6d 20 27 2e 2f   Config from './
0060: 63 6f 6e 66 69 67 27 0a 69 6d 70 6f 72 74 20 4c  config'.import L
0070: 69 71 75 69 64 69 74 79 43 75 72 76 65 20 66 72  iquidityCurve fr
0080: 6f 6d 20 27 2e 2e 2f 72 6f 75 74 69 6e 67 2f 6c  om '../routing/l
0090: 69 71 75 69 64 69 74 79 2d 63 75 72 76 65 27 0a  iquidity-curve'.
00a0: 69 6d 70 6f 72 74 20 50 72 65 66 69 78 4d 61 70  import PrefixMap
00b0: 20 66 72 6f 6d 20 27 2e 2e 2f 72 6f 75 74 69 6e   from '../routin
00c0: 67 2f 70 72 65 66 69 78 2d 6d 61 70 27 0a 69 6d  g/prefix-map'.im
00d0: 70 6f 72 74 20 7b 20 63 72 65 61 74 65 20 61 73  port { create as
00e0: 20 63 72 65 61 74 65 4c 6f 67 67 65 72 20 7d 20   createLogger } 
00f0: 66 72 6f 6d 20 27 2e 2e 2f 63 6f 6d 6d 6f 6e 2f  from '../common/
0100: 6c 6f 67 27 0a 63 6f 6e 73 74 20 6c 6f 67 20 3d  log'.const log =
0110: 20 63 72 65 61 74 65 4c 6f 67 67 65 72 28 27 71   createLogger('q
0120: 75 6f 74 65 72 27 29 0a 69 6d 70 6f 72 74 20 72  uoter').import r
0130: 65 64 75 63 74 20 3d 20 72 65 71 75 69 72 65 28  educt = require(
0140: 27 72 65 64 75 63 74 27 29 0a 63 6f 6e 73 74 20  'reduct').const 
0150: 7b 20 49 6e 74 65 72 6e 61 6c 45 72 72 6f 72 20  { InternalError 
0160: 7d 20 3d 20 49 6c 70 50 61 63 6b 65 74 2e 45 72  } = IlpPacket.Er
0170: 72 6f 72 73 0a 0a 63 6f 6e 73 74 20 44 45 53 54  rors..const DEST
0180: 49 4e 41 54 49 4f 4e 5f 48 4f 4c 44 5f 44 55 52  INATION_HOLD_DUR
0190: 41 54 49 4f 4e 20 3d 20 35 30 30 30 0a 0a 65 78  ATION = 5000..ex
01a0: 70 6f 72 74 20 69 6e 74 65 72 66 61 63 65 20 43  port interface C
01b0: 61 63 68 65 64 43 75 72 76 65 20 7b 0a 20 20 70  achedCurve {.  p
01c0: 72 65 66 69 78 3a 20 73 74 72 69 6e 67 0a 20 20  refix: string.  
01d0: 63 75 72 76 65 3a 20 4c 69 71 75 69 64 69 74 79  curve: Liquidity
01e0: 43 75 72 76 65 0a 20 20 65 78 70 69 72 79 3a 20  Curve.  expiry: 
01f0: 6e 75 6d 62 65 72 0a 20 20 6d 69 6e 4d 65 73 73  number.  minMess
0200: 61 67 65 57 69 6e 64 6f 77 3a 20 6e 75 6d 62 65  ageWindow: numbe
0210: 72 0a 7d 0a 0a 65 78 70 6f 72 74 20 64 65 66 61  r.}..export defa
0220: 75 6c 74 20 63 6c 61 73 73 20 51 75 6f 74 65 72  ult class Quoter
0230: 20 7b 0a 20 20 70 72 6f 74 65 63 74 65 64 20 61   {.  protected a
0240: 63 63 6f 75 6e 74 73 3a 20 41 63 63 6f 75 6e 74  ccounts: Account
0250: 73 0a 20 20 70 72 6f 74 65 63 74 65 64 20 71 75  s.  protected qu
0260: 6f 74 65 45 78 70 69 72 79 44 75 72 61 74 69 6f  oteExpiryDuratio
0270: 6e 3a 20 6e 75 6d 62 65 72 0a 20 20 70 72 6f 74  n: number.  prot
0280: 65 63 74 65 64 20 63 61 63 68 65 3a 20 50 72 65  ected cache: Pre
0290: 66 69 78 4d 61 70 3c 43 61 63 68 65 64 43 75 72  fixMap<CachedCur
02a0: 76 65 3e 0a 0a 20 20 2f 2a 2a 0a 20 20 20 2a 20  ve>..  /**.   * 
02b0: 40 70 61 72 61 6d 20 7b 41 63 63 6f 75 6e 74 73  @param {Accounts
02c0: 7d 20 61 63 63 6f 75 6e 74 73 0a 20 20 20 2a 20  } accounts.   * 
02d0: 40 70 61 72 61 6d 20 7b 4f 62 6a 65 63 74 7d 20  @param {Object} 
02e0: 63 6f 6e 66 69 67 0a 20 20 20 2a 20 40 70 61 72  config.   * @par
02f0: 61 6d 20 7b 49 6e 74 65 67 65 72 7d 20 63 6f 6e  am {Integer} con
0300: 66 69 67 2e 71 75 6f 74 65 45 78 70 69 72 79 0a  fig.quoteExpiry.
0310: 20 20 20 2a 2f 0a 20 20 63 6f 6e 73 74 72 75 63     */.  construc
0320: 74 6f 72 20 28 64 65 70 73 3a 20 72 65 64 75 63  tor (deps: reduc
0330: 74 2e 49 6e 6a 65 63 74 6f 72 29 20 7b 0a 20 20  t.Injector) {.  
0340: 20 20 74 68 69 73 2e 61 63 63 6f 75 6e 74 73 20    this.accounts 
0350: 3d 20 64 65 70 73 28 41 63 63 6f 75 6e 74 73 29  = deps(Accounts)
0360: 0a 20 20 20 20 74 68 69 73 2e 71 75 6f 74 65 45  .    this.quoteE
0370: 78 70 69 72 79 44 75 72 61 74 69 6f 6e 20 3d 20  xpiryDuration = 
0380: 64 65 70 73 28 43 6f 6e 66 69 67 29 2e 71 75 6f  deps(Config).quo
0390: 74 65 45 78 70 69 72 79 20 2f 2f 20 6d 69 6c 6c  teExpiry // mill
03a0: 69 73 65 63 6f 6e 64 73 0a 20 20 20 20 74 68 69  iseconds.    thi
03b0: 73 2e 63 61 63 68 65 20 3d 20 6e 65 77 20 50 72  s.cache = new Pr
03c0: 65 66 69 78 4d 61 70 28 29 0a 20 20 7d 0a 0a 20  efixMap().  }.. 
03d0: 20 2f 2a 2a 0a 20 20 20 2a 20 49 66 20 74 68 61   /**.   * If tha
03e0: 74 20 6d 61 74 63 68 69 6e 67 20 72 6f 75 74 65  t matching route
03f0: 20 68 61 73 20 61 20 6c 6f 63 61 6c 20 63 75 72   has a local cur
0400: 76 65 2c 20 69 74 20 77 69 6c 6c 20 62 65 20 72  ve, it will be r
0410: 65 74 75 72 6e 65 64 2e 0a 20 20 20 2a 20 4f 74  eturned..   * Ot
0420: 68 65 72 77 69 73 65 2c 20 6d 61 6b 65 20 61 20  herwise, make a 
0430: 72 65 6d 6f 74 65 20 63 75 72 76 65 20 71 75 6f  remote curve quo
0440: 74 65 20 72 65 71 75 65 73 74 2e 0a 20 20 20 2a  te request..   *
0450: 0a 20 20 20 2a 20 40 70 61 72 61 6d 20 7b 49 6c  .   * @param {Il
0460: 70 41 64 64 72 65 73 73 7d 20 6e 65 78 74 48 6f  pAddress} nextHo
0470: 70 0a 20 20 20 2a 20 40 70 61 72 61 6d 20 7b 49  p.   * @param {I
0480: 6c 70 41 64 64 72 65 73 73 7d 20 64 65 73 74 69  lpAddress} desti
0490: 6e 61 74 69 6f 6e 41 63 63 6f 75 6e 74 0a 20 20  nationAccount.  
04a0: 20 2a 20 40 72 65 74 75 72 6e 73 20 7b 4f 62 6a   * @returns {Obj
04b0: 65 63 74 7d 0a 20 20 20 2a 2f 0a 20 20 61 73 79  ect}.   */.  asy
04c0: 6e 63 20 71 75 6f 74 65 4c 69 71 75 69 64 69 74  nc quoteLiquidit
04d0: 79 20 28 6e 65 78 74 48 6f 70 3a 20 73 74 72 69  y (nextHop: stri
04e0: 6e 67 2c 20 64 65 73 74 69 6e 61 74 69 6f 6e 41  ng, destinationA
04f0: 63 63 6f 75 6e 74 3a 20 73 74 72 69 6e 67 29 20  ccount: string) 
0500: 7b 0a 20 20 20 20 63 6f 6e 73 74 20 63 61 63 68  {.    const cach
0510: 65 64 43 75 72 76 65 20 3d 20 74 68 69 73 2e 63  edCurve = this.c
0520: 61 63 68 65 2e 72 65 73 6f 6c 76 65 28 64 65 73  ache.resolve(des
0530: 74 69 6e 61 74 69 6f 6e 41 63 63 6f 75 6e 74 29  tinationAccount)
0540: 0a 0a 20 20 20 20 69 66 20 28 63 61 63 68 65 64  ..    if (cached
0550: 43 75 72 76 65 29 20 7b 0a 20 20 20 20 20 20 69  Curve) {.      i
0560: 66 20 28 63 61 63 68 65 64 43 75 72 76 65 2e 65  f (cachedCurve.e
0570: 78 70 69 72 79 20 3c 20 44 61 74 65 2e 6e 6f 77  xpiry < Date.now
0580: 28 29 29 20 7b 0a 20 20 20 20 20 20 20 20 6c 6f  ()) {.        lo
0590: 67 2e 64 65 62 75 67 28 27 63 6c 65 61 6e 69 6e  g.debug('cleanin
05a0: 67 20 75 70 20 65 78 70 69 72 65 64 20 63 61 63  g up expired cac
05b0: 68 65 64 20 63 75 72 76 65 2e 20 70 72 65 66 69  hed curve. prefi
05c0: 78 3d 25 73 20 65 78 70 69 72 79 3d 25 73 27 2c  x=%s expiry=%s',
05d0: 20 63 61 63 68 65 64 43 75 72 76 65 2e 70 72 65   cachedCurve.pre
05e0: 66 69 78 2c 20 6e 65 77 20 44 61 74 65 28 63 61  fix, new Date(ca
05f0: 63 68 65 64 43 75 72 76 65 2e 65 78 70 69 72 79  chedCurve.expiry
0600: 29 2e 74 6f 49 53 4f 53 74 72 69 6e 67 28 29 29  ).toISOString())
0610: 0a 20 20 20 20 20 20 20 20 74 68 69 73 2e 63 61  .        this.ca
0620: 63 68 65 2e 64 65 6c 65 74 65 28 63 61 63 68 65  che.delete(cache
0630: 64 43 75 72 76 65 2e 70 72 65 66 69 78 29 0a 20  dCurve.prefix). 
0640: 20 20 20 20 20 7d 20 65 6c 73 65 20 7b 0a 20 20       } else {.  
0650: 20 20 20 20 20 20 6c 6f 67 2e 64 65 62 75 67 28        log.debug(
0660: 27 72 65 74 75 72 6e 69 6e 67 20 63 61 63 68 65  'returning cache
0670: 64 20 63 75 72 76 65 2e 20 70 72 65 66 69 78 3d  d curve. prefix=
0680: 25 73 27 2c 20 63 61 63 68 65 64 43 75 72 76 65  %s', cachedCurve
0690: 2e 70 72 65 66 69 78 29 0a 20 20 20 20 20 20 20  .prefix).       
06a0: 20 72 65 74 75 72 6e 20 63 61 63 68 65 64 43 75   return cachedCu
06b0: 72 76 65 0a 20 20 20 20 20 20 7d 0a 20 20 20 20  rve.      }.    
06c0: 7d 0a 0a 20 20 20 20 63 6f 6e 73 74 20 71 75 6f  }..    const quo
06d0: 74 65 52 65 71 75 65 73 74 50 61 63 6b 65 74 20  teRequestPacket 
06e0: 3d 20 49 6c 70 50 61 63 6b 65 74 2e 73 65 72 69  = IlpPacket.seri
06f0: 61 6c 69 7a 65 49 6c 71 70 4c 69 71 75 69 64 69  alizeIlqpLiquidi
0700: 74 79 52 65 71 75 65 73 74 28 7b 0a 20 20 20 20  tyRequest({.    
0710: 20 20 64 65 73 74 69 6e 61 74 69 6f 6e 41 63 63    destinationAcc
0720: 6f 75 6e 74 3a 20 64 65 73 74 69 6e 61 74 69 6f  ount: destinatio
0730: 6e 41 63 63 6f 75 6e 74 2c 0a 20 20 20 20 20 20  nAccount,.      
0740: 64 65 73 74 69 6e 61 74 69 6f 6e 48 6f 6c 64 44  destinationHoldD
0750: 75 72 61 74 69 6f 6e 3a 20 44 45 53 54 49 4e 41  uration: DESTINA
0760: 54 49 4f 4e 5f 48 4f 4c 44 5f 44 55 52 41 54 49  TION_HOLD_DURATI
0770: 4f 4e 0a 20 20 20 20 7d 29 0a 20 20 20 20 63 6f  ON.    }).    co
0780: 6e 73 74 20 70 6c 75 67 69 6e 20 3d 20 74 68 69  nst plugin = thi
0790: 73 2e 61 63 63 6f 75 6e 74 73 2e 67 65 74 50 6c  s.accounts.getPl
07a0: 75 67 69 6e 28 6e 65 78 74 48 6f 70 29 0a 20 20  ugin(nextHop).  
07b0: 20 20 6c 6f 67 2e 64 65 62 75 67 28 27 73 65 6e    log.debug('sen
07c0: 64 69 6e 67 20 71 75 6f 74 65 20 72 65 71 75 65  ding quote reque
07d0: 73 74 20 70 61 63 6b 65 74 2e 20 63 6f 6e 6e 65  st packet. conne
07e0: 63 74 6f 72 3d 25 73 27 2c 20 6e 65 78 74 48 6f  ctor=%s', nextHo
07f0: 70 29 0a 20 20 20 20 63 6f 6e 73 74 20 71 75 6f  p).    const quo
0800: 74 65 52 65 73 70 6f 6e 73 65 50 61 63 6b 65 74  teResponsePacket
0810: 20 3d 20 61 77 61 69 74 20 70 6c 75 67 69 6e 2e   = await plugin.
0820: 73 65 6e 64 44 61 74 61 28 71 75 6f 74 65 52 65  sendData(quoteRe
0830: 71 75 65 73 74 50 61 63 6b 65 74 29 0a 0a 20 20  questPacket)..  
0840: 20 20 69 66 20 28 71 75 6f 74 65 52 65 73 70 6f    if (quoteRespo
0850: 6e 73 65 50 61 63 6b 65 74 5b 30 5d 20 3d 3d 3d  nsePacket[0] ===
0860: 20 49 6c 70 50 61 63 6b 65 74 2e 54 79 70 65 2e   IlpPacket.Type.
0870: 54 59 50 45 5f 49 4c 51 50 5f 4c 49 51 55 49 44  TYPE_ILQP_LIQUID
0880: 49 54 59 5f 52 45 53 50 4f 4e 53 45 29 20 7b 0a  ITY_RESPONSE) {.
0890: 20 20 20 20 20 20 63 6f 6e 73 74 20 64 61 74 61        const data
08a0: 20 3d 20 49 6c 70 50 61 63 6b 65 74 2e 64 65 73   = IlpPacket.des
08b0: 65 72 69 61 6c 69 7a 65 49 6c 71 70 4c 69 71 75  erializeIlqpLiqu
08c0: 69 64 69 74 79 52 65 73 70 6f 6e 73 65 28 71 75  idityResponse(qu
08d0: 6f 74 65 52 65 73 70 6f 6e 73 65 50 61 63 6b 65  oteResponsePacke
08e0: 74 29 0a 20 20 20 20 20 20 72 65 74 75 72 6e 20  t).      return 
08f0: 7b 0a 20 20 20 20 20 20 20 20 63 75 72 76 65 3a  {.        curve:
0900: 20 6e 65 77 20 4c 69 71 75 69 64 69 74 79 43 75   new LiquidityCu
0910: 72 76 65 28 64 61 74 61 2e 6c 69 71 75 69 64 69  rve(data.liquidi
0920: 74 79 43 75 72 76 65 29 2c 0a 20 20 20 20 20 20  tyCurve),.      
0930: 20 20 70 72 65 66 69 78 3a 20 64 61 74 61 2e 61    prefix: data.a
0940: 70 70 6c 69 65 73 54 6f 50 72 65 66 69 78 2c 0a  ppliesToPrefix,.
0950: 20 20 20 20 20 20 20 20 65 78 70 69 72 79 3a 20          expiry: 
0960: 6e 65 77 20 44 61 74 65 28 64 61 74 61 2e 65 78  new Date(data.ex
0970: 70 69 72 65 73 41 74 29 2c 0a 20 20 20 20 20 20  piresAt),.      
0980: 20 20 6d 69 6e 4d 65 73 73 61 67 65 57 69 6e 64    minMessageWind
0990: 6f 77 3a 20 64 61 74 61 2e 73 6f 75 72 63 65 48  ow: data.sourceH
09a0: 6f 6c 64 44 75 72 61 74 69 6f 6e 20 2d 20 44 45  oldDuration - DE
09b0: 53 54 49 4e 41 54 49 4f 4e 5f 48 4f 4c 44 5f 44  STINATION_HOLD_D
09c0: 55 52 41 54 49 4f 4e 0a 20 20 20 20 20 20 7d 0a  URATION.      }.
09d0: 20 20 20 20 7d 20 65 6c 73 65 20 7b 0a 20 20 20      } else {.   
09e0: 20 20 20 74 68 72 6f 77 20 6e 65 77 20 49 6e 74     throw new Int
09f0: 65 72 6e 61 6c 45 72 72 6f 72 28 27 72 65 6d 6f  ernalError('remo
0a00: 74 65 20 71 75 6f 74 65 20 65 72 72 6f 72 2e 27  te quote error.'
0a10: 29 0a 20 20 20 20 7d 0a 20 20 7d 0a 0a 20 20 63  ).    }.  }..  c
0a20: 61 63 68 65 43 75 72 76 65 20 28 7b 20 70 72 65  acheCurve ({ pre
0a30: 66 69 78 2c 20 63 75 72 76 65 2c 20 65 78 70 69  fix, curve, expi
0a40: 72 79 2c 20 6d 69 6e 4d 65 73 73 61 67 65 57 69  ry, minMessageWi
0a50: 6e 64 6f 77 20 7d 3a 20 43 61 63 68 65 64 43 75  ndow }: CachedCu
0a60: 72 76 65 29 20 7b 0a 20 20 20 20 6c 6f 67 2e 64  rve) {.    log.d
0a70: 65 62 75 67 28 27 63 61 63 68 69 6e 67 20 63 75  ebug('caching cu
0a80: 72 76 65 2e 20 70 72 65 66 69 78 3d 25 73 20 65  rve. prefix=%s e
0a90: 78 70 69 72 79 3d 25 73 20 6d 69 6e 4d 65 73 73  xpiry=%s minMess
0aa0: 61 67 65 57 69 6e 64 6f 77 3d 25 73 27 2c 20 70  ageWindow=%s', p
0ab0: 72 65 66 69 78 2c 20 65 78 70 69 72 79 2c 20 6d  refix, expiry, m
0ac0: 69 6e 4d 65 73 73 61 67 65 57 69 6e 64 6f 77 29  inMessageWindow)
0ad0: 0a 20 20 20 20 74 68 69 73 2e 63 61 63 68 65 2e  .    this.cache.
0ae0: 69 6e 73 65 72 74 28 70 72 65 66 69 78 2c 20 7b  insert(prefix, {
0af0: 0a 20 20 20 20 20 20 70 72 65 66 69 78 2c 0a 20  .      prefix,. 
0b00: 20 20 20 20 20 63 75 72 76 65 2c 0a 20 20 20 20       curve,.    
0b10: 20 20 65 78 70 69 72 79 2c 0a 20 20 20 20 20 20    expiry,.      
0b20: 6d 69 6e 4d 65 73 73 61 67 65 57 69 6e 64 6f 77  minMessageWindow
0b30: 0a 20 20 20 20 7d 29 0a 20 20 7d 0a 7d 0a        .    }).  }.}.