Hex Artifact Content
Not logged in

Artifact dc6f3ed590cb510eaa75842a93cfa445212e3539:


0000: 69 6d 70 6f 72 74 20 7b 20 41 63 63 6f 75 6e 74  import { Account
0010: 49 6e 66 6f 20 7d 20 66 72 6f 6d 20 27 2e 2f 61  Info } from './a
0020: 63 63 6f 75 6e 74 73 27 0a 69 6d 70 6f 72 74 20  ccounts'.import 
0030: 53 74 61 74 73 20 66 72 6f 6d 20 27 2e 2e 2f 73  Stats from '../s
0040: 65 72 76 69 63 65 73 2f 73 74 61 74 73 27 0a 0a  ervices/stats'..
0050: 65 78 70 6f 72 74 20 69 6e 74 65 72 66 61 63 65  export interface
0060: 20 4d 69 64 64 6c 65 77 61 72 65 44 65 66 69 6e   MiddlewareDefin
0070: 69 74 69 6f 6e 20 7b 0a 20 20 74 79 70 65 3a 20  ition {.  type: 
0080: 73 74 72 69 6e 67 2c 0a 20 20 6f 70 74 69 6f 6e  string,.  option
0090: 73 3f 3a 20 6f 62 6a 65 63 74 0a 7d 0a 0a 2f 2a  s?: object.}../*
00a0: 2a 0a 20 2a 20 53 65 72 76 69 63 65 73 20 74 68  *. * Services th
00b0: 65 20 63 6f 6e 6e 65 63 74 6f 72 20 65 78 70 6f  e connector expo
00c0: 73 65 73 20 74 6f 20 6d 69 64 64 6c 65 77 61 72  ses to middlewar
00d0: 65 2e 0a 20 2a 2f 0a 65 78 70 6f 72 74 20 69 6e  e.. */.export in
00e0: 74 65 72 66 61 63 65 20 4d 69 64 64 6c 65 77 61  terface Middlewa
00f0: 72 65 53 65 72 76 69 63 65 73 20 7b 0a 20 20 73  reServices {.  s
0100: 74 61 74 73 3a 20 53 74 61 74 73 0a 20 20 67 65  tats: Stats.  ge
0110: 74 49 6e 66 6f 20 28 61 63 63 6f 75 6e 74 49 64  tInfo (accountId
0120: 3a 20 73 74 72 69 6e 67 29 3a 20 41 63 63 6f 75  : string): Accou
0130: 6e 74 49 6e 66 6f 0a 20 20 67 65 74 4f 77 6e 41  ntInfo.  getOwnA
0140: 64 64 72 65 73 73 20 28 29 3a 20 73 74 72 69 6e  ddress (): strin
0150: 67 0a 20 20 73 65 6e 64 44 61 74 61 20 28 64 61  g.  sendData (da
0160: 74 61 3a 20 42 75 66 66 65 72 2c 20 61 63 63 6f  ta: Buffer, acco
0170: 75 6e 74 49 64 3a 20 73 74 72 69 6e 67 29 3a 20  untId: string): 
0180: 50 72 6f 6d 69 73 65 3c 42 75 66 66 65 72 3e 0a  Promise<Buffer>.
0190: 20 20 73 65 6e 64 4d 6f 6e 65 79 20 28 61 6d 6f    sendMoney (amo
01a0: 75 6e 74 3a 20 73 74 72 69 6e 67 2c 20 61 63 63  unt: string, acc
01b0: 6f 75 6e 74 49 64 3a 20 73 74 72 69 6e 67 29 3a  ountId: string):
01c0: 20 50 72 6f 6d 69 73 65 3c 76 6f 69 64 3e 0a 7d   Promise<void>.}
01d0: 0a 0a 65 78 70 6f 72 74 20 69 6e 74 65 72 66 61  ..export interfa
01e0: 63 65 20 4d 69 64 64 6c 65 77 61 72 65 43 61 6c  ce MiddlewareCal
01f0: 6c 62 61 63 6b 3c 54 2c 55 3e 20 7b 0a 20 20 28  lback<T,U> {.  (
0200: 76 61 6c 3a 20 54 29 3a 20 50 72 6f 6d 69 73 65  val: T): Promise
0210: 3c 55 3e 0a 7d 0a 0a 65 78 70 6f 72 74 20 69 6e  <U>.}..export in
0220: 74 65 72 66 61 63 65 20 4d 69 64 64 6c 65 77 61  terface Middlewa
0230: 72 65 4d 65 74 68 6f 64 3c 54 2c 55 3e 20 7b 0a  reMethod<T,U> {.
0240: 20 20 28 76 61 6c 3a 20 54 2c 20 6e 65 78 74 3a    (val: T, next:
0250: 20 4d 69 64 64 6c 65 77 61 72 65 43 61 6c 6c 62   MiddlewareCallb
0260: 61 63 6b 3c 54 2c 55 3e 29 3a 20 50 72 6f 6d 69  ack<T,U>): Promi
0270: 73 65 3c 55 3e 0a 7d 0a 0a 65 78 70 6f 72 74 20  se<U>.}..export 
0280: 69 6e 74 65 72 66 61 63 65 20 4d 69 64 64 6c 65  interface Middle
0290: 77 61 72 65 4d 65 74 68 6f 64 73 20 7b 0a 20 20  wareMethods {.  
02a0: 64 61 74 61 3a 20 4d 69 64 64 6c 65 77 61 72 65  data: Middleware
02b0: 4d 65 74 68 6f 64 3c 42 75 66 66 65 72 2c 20 42  Method<Buffer, B
02c0: 75 66 66 65 72 3e 0a 20 20 6d 6f 6e 65 79 3a 20  uffer>.  money: 
02d0: 4d 69 64 64 6c 65 77 61 72 65 4d 65 74 68 6f 64  MiddlewareMethod
02e0: 3c 73 74 72 69 6e 67 2c 20 76 6f 69 64 3e 0a 7d  <string, void>.}
02f0: 0a 0a 65 78 70 6f 72 74 20 69 6e 74 65 72 66 61  ..export interfa
0300: 63 65 20 50 69 70 65 6c 69 6e 65 45 6e 74 72 79  ce PipelineEntry
0310: 3c 54 2c 55 3e 20 7b 0a 20 20 6e 61 6d 65 3a 20  <T,U> {.  name: 
0320: 73 74 72 69 6e 67 2c 0a 20 20 6d 65 74 68 6f 64  string,.  method
0330: 3a 20 4d 69 64 64 6c 65 77 61 72 65 4d 65 74 68  : MiddlewareMeth
0340: 6f 64 3c 54 2c 55 3e 0a 7d 0a 0a 65 78 70 6f 72  od<T,U>.}..expor
0350: 74 20 69 6e 74 65 72 66 61 63 65 20 50 69 70 65  t interface Pipe
0360: 6c 69 6e 65 3c 54 2c 55 3e 20 7b 0a 20 20 69 6e  line<T,U> {.  in
0370: 73 65 72 74 46 69 72 73 74 20 28 65 6e 74 72 79  sertFirst (entry
0380: 3a 20 50 69 70 65 6c 69 6e 65 45 6e 74 72 79 3c  : PipelineEntry<
0390: 54 2c 55 3e 29 3a 20 76 6f 69 64 0a 20 20 69 6e  T,U>): void.  in
03a0: 73 65 72 74 4c 61 73 74 20 28 65 6e 74 72 79 3a  sertLast (entry:
03b0: 20 50 69 70 65 6c 69 6e 65 45 6e 74 72 79 3c 54   PipelineEntry<T
03c0: 2c 55 3e 29 3a 20 76 6f 69 64 0a 20 20 69 6e 73  ,U>): void.  ins
03d0: 65 72 74 42 65 66 6f 72 65 20 28 6d 69 64 64 6c  ertBefore (middl
03e0: 65 77 61 72 65 4e 61 6d 65 3a 20 73 74 72 69 6e  ewareName: strin
03f0: 67 2c 20 65 6e 74 72 79 3a 20 50 69 70 65 6c 69  g, entry: Pipeli
0400: 6e 65 45 6e 74 72 79 3c 54 2c 55 3e 29 3a 20 76  neEntry<T,U>): v
0410: 6f 69 64 0a 20 20 69 6e 73 65 72 74 41 66 74 65  oid.  insertAfte
0420: 72 20 28 6d 69 64 64 6c 65 77 61 72 65 4e 61 6d  r (middlewareNam
0430: 65 3a 20 73 74 72 69 6e 67 2c 20 65 6e 74 72 79  e: string, entry
0440: 3a 20 50 69 70 65 6c 69 6e 65 45 6e 74 72 79 3c  : PipelineEntry<
0450: 54 2c 55 3e 29 3a 20 76 6f 69 64 0a 20 20 67 65  T,U>): void.  ge
0460: 74 4d 65 74 68 6f 64 73 20 28 29 3a 20 4d 69 64  tMethods (): Mid
0470: 64 6c 65 77 61 72 65 4d 65 74 68 6f 64 3c 54 2c  dlewareMethod<T,
0480: 55 3e 5b 5d 0a 7d 0a 0a 65 78 70 6f 72 74 20 69  U>[].}..export i
0490: 6e 74 65 72 66 61 63 65 20 50 69 70 65 6c 69 6e  nterface Pipelin
04a0: 65 73 20 7b 0a 20 20 72 65 61 64 6f 6e 6c 79 20  es {.  readonly 
04b0: 73 74 61 72 74 75 70 3a 20 50 69 70 65 6c 69 6e  startup: Pipelin
04c0: 65 3c 76 6f 69 64 2c 20 76 6f 69 64 3e 2c 0a 20  e<void, void>,. 
04d0: 20 72 65 61 64 6f 6e 6c 79 20 74 65 61 72 64 6f   readonly teardo
04e0: 77 6e 3a 20 50 69 70 65 6c 69 6e 65 3c 76 6f 69  wn: Pipeline<voi
04f0: 64 2c 20 76 6f 69 64 3e 2c 0a 20 20 72 65 61 64  d, void>,.  read
0500: 6f 6e 6c 79 20 69 6e 63 6f 6d 69 6e 67 44 61 74  only incomingDat
0510: 61 3a 20 50 69 70 65 6c 69 6e 65 3c 42 75 66 66  a: Pipeline<Buff
0520: 65 72 2c 20 42 75 66 66 65 72 3e 2c 0a 20 20 72  er, Buffer>,.  r
0530: 65 61 64 6f 6e 6c 79 20 69 6e 63 6f 6d 69 6e 67  eadonly incoming
0540: 4d 6f 6e 65 79 3a 20 50 69 70 65 6c 69 6e 65 3c  Money: Pipeline<
0550: 73 74 72 69 6e 67 2c 20 76 6f 69 64 3e 2c 0a 20  string, void>,. 
0560: 20 72 65 61 64 6f 6e 6c 79 20 6f 75 74 67 6f 69   readonly outgoi
0570: 6e 67 44 61 74 61 3a 20 50 69 70 65 6c 69 6e 65  ngData: Pipeline
0580: 3c 42 75 66 66 65 72 2c 20 42 75 66 66 65 72 3e  <Buffer, Buffer>
0590: 0a 20 20 72 65 61 64 6f 6e 6c 79 20 6f 75 74 67  .  readonly outg
05a0: 6f 69 6e 67 4d 6f 6e 65 79 3a 20 50 69 70 65 6c  oingMoney: Pipel
05b0: 69 6e 65 3c 73 74 72 69 6e 67 2c 20 76 6f 69 64  ine<string, void
05c0: 3e 0a 7d 0a 0a 65 78 70 6f 72 74 20 69 6e 74 65  >.}..export inte
05d0: 72 66 61 63 65 20 4d 69 64 64 6c 65 77 61 72 65  rface Middleware
05e0: 20 7b 0a 20 20 61 70 70 6c 79 54 6f 50 69 70 65   {.  applyToPipe
05f0: 6c 69 6e 65 73 3a 20 28 70 69 70 65 6c 69 6e 65  lines: (pipeline
0600: 73 3a 20 50 69 70 65 6c 69 6e 65 73 2c 20 61 63  s: Pipelines, ac
0610: 63 6f 75 6e 74 49 64 3a 20 73 74 72 69 6e 67 29  countId: string)
0620: 20 3d 3e 20 50 72 6f 6d 69 73 65 3c 76 6f 69 64   => Promise<void
0630: 3e 0a 7d 0a 0a 65 78 70 6f 72 74 20 69 6e 74 65  >.}..export inte
0640: 72 66 61 63 65 20 4d 69 64 64 6c 65 77 61 72 65  rface Middleware
0650: 43 6f 6e 73 74 72 75 63 74 6f 72 20 7b 0a 20 20  Constructor {.  
0660: 6e 65 77 20 28 6f 70 74 69 6f 6e 73 3a 20 6f 62  new (options: ob
0670: 6a 65 63 74 2c 20 61 70 69 3a 20 4d 69 64 64 6c  ject, api: Middl
0680: 65 77 61 72 65 53 65 72 76 69 63 65 73 29 3a 20  ewareServices): 
0690: 4d 69 64 64 6c 65 77 61 72 65 0a 7d 0a           Middleware.}.