Hex Artifact Content
Not logged in

Artifact aee92469722045782b6192bb1ab5b993bdaa742a:


0000: 69 6d 70 6f 72 74 20 7b 20 63 72 65 61 74 65 48  import { createH
0010: 61 73 68 20 7d 20 66 72 6f 6d 20 27 63 72 79 70  ash } from 'cryp
0020: 74 6f 27 0a 69 6d 70 6f 72 74 20 7b 20 63 72 65  to'.import { cre
0030: 61 74 65 20 61 73 20 63 72 65 61 74 65 4c 6f 67  ate as createLog
0040: 67 65 72 20 7d 20 66 72 6f 6d 20 27 2e 2e 2f 63  ger } from '../c
0050: 6f 6d 6d 6f 6e 2f 6c 6f 67 27 0a 63 6f 6e 73 74  ommon/log'.const
0060: 20 6c 6f 67 20 3d 20 63 72 65 61 74 65 4c 6f 67   log = createLog
0070: 67 65 72 28 27 76 61 6c 69 64 61 74 65 2d 66 75  ger('validate-fu
0080: 6c 66 69 6c 6c 6d 65 6e 74 2d 6d 69 64 64 6c 65  lfillment-middle
0090: 77 61 72 65 27 29 0a 69 6d 70 6f 72 74 20 2a 20  ware').import * 
00a0: 61 73 20 49 6c 70 50 61 63 6b 65 74 20 66 72 6f  as IlpPacket fro
00b0: 6d 20 27 69 6c 70 2d 70 61 63 6b 65 74 27 0a 69  m 'ilp-packet'.i
00c0: 6d 70 6f 72 74 20 7b 20 4d 69 64 64 6c 65 77 61  mport { Middlewa
00d0: 72 65 2c 20 4d 69 64 64 6c 65 77 61 72 65 43 61  re, MiddlewareCa
00e0: 6c 6c 62 61 63 6b 2c 20 50 69 70 65 6c 69 6e 65  llback, Pipeline
00f0: 73 20 7d 20 66 72 6f 6d 20 27 2e 2e 2f 74 79 70  s } from '../typ
0100: 65 73 2f 6d 69 64 64 6c 65 77 61 72 65 27 0a 63  es/middleware'.c
0110: 6f 6e 73 74 20 7b 20 55 6e 72 65 61 63 68 61 62  onst { Unreachab
0120: 6c 65 45 72 72 6f 72 20 7d 20 3d 20 49 6c 70 50  leError } = IlpP
0130: 61 63 6b 65 74 2e 45 72 72 6f 72 73 0a 0a 65 78  acket.Errors..ex
0140: 70 6f 72 74 20 64 65 66 61 75 6c 74 20 63 6c 61  port default cla
0150: 73 73 20 56 61 6c 69 64 61 74 65 46 75 6c 66 69  ss ValidateFulfi
0160: 6c 6c 6d 65 6e 74 4d 69 64 64 6c 65 77 61 72 65  llmentMiddleware
0170: 20 69 6d 70 6c 65 6d 65 6e 74 73 20 4d 69 64 64   implements Midd
0180: 6c 65 77 61 72 65 20 7b 0a 20 20 61 73 79 6e 63  leware {.  async
0190: 20 61 70 70 6c 79 54 6f 50 69 70 65 6c 69 6e 65   applyToPipeline
01a0: 73 20 28 70 69 70 65 6c 69 6e 65 73 3a 20 50 69  s (pipelines: Pi
01b0: 70 65 6c 69 6e 65 73 2c 20 61 63 63 6f 75 6e 74  pelines, account
01c0: 49 64 3a 20 73 74 72 69 6e 67 29 20 7b 0a 20 20  Id: string) {.  
01d0: 20 20 70 69 70 65 6c 69 6e 65 73 2e 6f 75 74 67    pipelines.outg
01e0: 6f 69 6e 67 44 61 74 61 2e 69 6e 73 65 72 74 4c  oingData.insertL
01f0: 61 73 74 28 7b 0a 20 20 20 20 20 20 6e 61 6d 65  ast({.      name
0200: 3a 20 27 76 61 6c 69 64 61 74 65 46 75 6c 66 69  : 'validateFulfi
0210: 6c 6c 6d 65 6e 74 27 2c 0a 20 20 20 20 20 20 6d  llment',.      m
0220: 65 74 68 6f 64 3a 20 61 73 79 6e 63 20 28 64 61  ethod: async (da
0230: 74 61 3a 20 42 75 66 66 65 72 2c 20 6e 65 78 74  ta: Buffer, next
0240: 3a 20 4d 69 64 64 6c 65 77 61 72 65 43 61 6c 6c  : MiddlewareCall
0250: 62 61 63 6b 3c 42 75 66 66 65 72 2c 20 42 75 66  back<Buffer, Buf
0260: 66 65 72 3e 29 20 3d 3e 20 7b 0a 20 20 20 20 20  fer>) => {.     
0270: 20 20 20 69 66 20 28 64 61 74 61 5b 30 5d 20 3d     if (data[0] =
0280: 3d 3d 20 49 6c 70 50 61 63 6b 65 74 2e 54 79 70  == IlpPacket.Typ
0290: 65 2e 54 59 50 45 5f 49 4c 50 5f 50 52 45 50 41  e.TYPE_ILP_PREPA
02a0: 52 45 29 20 7b 0a 20 20 20 20 20 20 20 20 20 20  RE) {.          
02b0: 63 6f 6e 73 74 20 7b 20 65 78 65 63 75 74 69 6f  const { executio
02c0: 6e 43 6f 6e 64 69 74 69 6f 6e 20 7d 20 3d 20 49  nCondition } = I
02d0: 6c 70 50 61 63 6b 65 74 2e 64 65 73 65 72 69 61  lpPacket.deseria
02e0: 6c 69 7a 65 49 6c 70 50 72 65 70 61 72 65 28 64  lizeIlpPrepare(d
02f0: 61 74 61 29 0a 0a 20 20 20 20 20 20 20 20 20 20  ata)..          
0300: 63 6f 6e 73 74 20 72 65 73 75 6c 74 20 3d 20 61  const result = a
0310: 77 61 69 74 20 6e 65 78 74 28 64 61 74 61 29 0a  wait next(data).
0320: 0a 20 20 20 20 20 20 20 20 20 20 69 66 20 28 72  .          if (r
0330: 65 73 75 6c 74 5b 30 5d 20 3d 3d 3d 20 49 6c 70  esult[0] === Ilp
0340: 50 61 63 6b 65 74 2e 54 79 70 65 2e 54 59 50 45  Packet.Type.TYPE
0350: 5f 49 4c 50 5f 46 55 4c 46 49 4c 4c 29 20 7b 0a  _ILP_FULFILL) {.
0360: 20 20 20 20 20 20 20 20 20 20 20 20 63 6f 6e 73              cons
0370: 74 20 7b 20 66 75 6c 66 69 6c 6c 6d 65 6e 74 20  t { fulfillment 
0380: 7d 20 3d 20 49 6c 70 50 61 63 6b 65 74 2e 64 65  } = IlpPacket.de
0390: 73 65 72 69 61 6c 69 7a 65 49 6c 70 46 75 6c 66  serializeIlpFulf
03a0: 69 6c 6c 28 72 65 73 75 6c 74 29 0a 20 20 20 20  ill(result).    
03b0: 20 20 20 20 20 20 20 20 63 6f 6e 73 74 20 63 61          const ca
03c0: 6c 63 75 6c 61 74 65 64 43 6f 6e 64 69 74 69 6f  lculatedConditio
03d0: 6e 20 3d 20 63 72 65 61 74 65 48 61 73 68 28 27  n = createHash('
03e0: 73 68 61 32 35 36 27 29 2e 75 70 64 61 74 65 28  sha256').update(
03f0: 66 75 6c 66 69 6c 6c 6d 65 6e 74 29 2e 64 69 67  fulfillment).dig
0400: 65 73 74 28 29 0a 0a 20 20 20 20 20 20 20 20 20  est()..         
0410: 20 20 20 69 66 20 28 21 63 61 6c 63 75 6c 61 74     if (!calculat
0420: 65 64 43 6f 6e 64 69 74 69 6f 6e 2e 65 71 75 61  edCondition.equa
0430: 6c 73 28 65 78 65 63 75 74 69 6f 6e 43 6f 6e 64  ls(executionCond
0440: 69 74 69 6f 6e 29 29 20 7b 0a 20 20 20 20 20 20  ition)) {.      
0450: 20 20 20 20 20 20 20 20 6c 6f 67 2e 77 61 72 6e          log.warn
0460: 28 27 72 65 63 65 69 76 65 64 20 69 6e 63 6f 72  ('received incor
0470: 72 65 63 74 20 66 75 6c 66 69 6c 6c 6d 65 6e 74  rect fulfillment
0480: 20 66 72 6f 6d 20 61 63 63 6f 75 6e 74 2e 20 61   from account. a
0490: 63 63 6f 75 6e 74 49 64 3d 25 73 20 66 75 6c 66  ccountId=%s fulf
04a0: 69 6c 6c 6d 65 6e 74 3d 25 73 20 63 61 6c 63 75  illment=%s calcu
04b0: 6c 61 74 65 64 43 6f 6e 64 69 74 69 6f 6e 3d 25  latedCondition=%
04c0: 73 20 65 78 65 63 75 74 69 6f 6e 43 6f 6e 64 69  s executionCondi
04d0: 74 69 6f 6e 3d 25 73 27 2c 20 61 63 63 6f 75 6e  tion=%s', accoun
04e0: 74 49 64 2c 20 66 75 6c 66 69 6c 6c 6d 65 6e 74  tId, fulfillment
04f0: 2e 74 6f 53 74 72 69 6e 67 28 27 62 61 73 65 36  .toString('base6
0500: 34 27 29 2c 20 63 61 6c 63 75 6c 61 74 65 64 43  4'), calculatedC
0510: 6f 6e 64 69 74 69 6f 6e 2e 74 6f 53 74 72 69 6e  ondition.toStrin
0520: 67 28 27 62 61 73 65 36 34 27 29 2c 20 65 78 65  g('base64'), exe
0530: 63 75 74 69 6f 6e 43 6f 6e 64 69 74 69 6f 6e 2e  cutionCondition.
0540: 74 6f 53 74 72 69 6e 67 28 27 62 61 73 65 36 34  toString('base64
0550: 27 29 29 0a 20 20 20 20 20 20 20 20 20 20 20 20  ')).            
0560: 20 20 74 68 72 6f 77 20 6e 65 77 20 55 6e 72 65    throw new Unre
0570: 61 63 68 61 62 6c 65 45 72 72 6f 72 28 27 66 75  achableError('fu
0580: 6c 66 69 6c 6c 6d 65 6e 74 20 64 69 64 20 6e 6f  lfillment did no
0590: 74 20 6d 61 74 63 68 20 65 78 70 65 63 74 65 64  t match expected
05a0: 20 76 61 6c 75 65 2e 27 29 0a 20 20 20 20 20 20   value.').      
05b0: 20 20 20 20 20 20 7d 0a 20 20 20 20 20 20 20 20        }.        
05c0: 20 20 7d 0a 0a 20 20 20 20 20 20 20 20 20 20 72    }..          r
05d0: 65 74 75 72 6e 20 72 65 73 75 6c 74 0a 20 20 20  eturn result.   
05e0: 20 20 20 20 20 7d 0a 0a 20 20 20 20 20 20 20 20       }..        
05f0: 72 65 74 75 72 6e 20 6e 65 78 74 28 64 61 74 61  return next(data
0600: 29 0a 20 20 20 20 20 20 7d 0a 20 20 20 20 7d 29  ).      }.    })
0610: 0a 20 20 7d 0a 7d 0a                             .  }.}.