aws-event-stream
Advanced tools
Comparing version
@@ -0,1 +1,2 @@ | ||
import { HTTPOptions } from 'aws-sdk'; | ||
import { AWSConfig } from '../aws/config'; | ||
@@ -8,2 +9,4 @@ import { MessageType } from '../model/message'; | ||
endpointUrl?: string; | ||
maxRetries?: number; | ||
httpOptions?: HTTPOptions; | ||
} | ||
@@ -10,0 +13,0 @@ export declare enum Protocols { |
@@ -52,3 +52,5 @@ "use strict"; | ||
aws_sdk_1.config.update(awsconfig); | ||
this.sns = new aws_sdk_1.SNS(snsOptions ? { endpoint: snsOptions.endpointUrl } : undefined); | ||
this.sns = new aws_sdk_1.SNS(snsOptions ? { endpoint: snsOptions.endpointUrl, | ||
httpOptions: snsOptions.httpOptions, | ||
maxRetries: snsOptions.maxRetries } : undefined); | ||
this.url = url; | ||
@@ -55,0 +57,0 @@ this.snsOption = snsOptions; |
{ | ||
"name": "aws-event-stream", | ||
"version": "1.2.2", | ||
"version": "1.2.3", | ||
"description": "A simple and fast EventStore for AWS.", | ||
@@ -5,0 +5,0 @@ "author": "Rodrigo Pinheiro de Almeida <rpinheiroalmeida@gmail.com>", |
@@ -9,3 +9,3 @@ {"/home/runner/work/aws-event-stream/aws-event-stream/src/event-store.ts": {"path":"/home/runner/work/aws-event-stream/aws-event-stream/src/event-store.ts","statementMap":{"0":{"start":{"line":1,"column":0},"end":{"line":1,"column":28}},"1":{"start":{"line":2,"column":0},"end":{"line":2,"column":49}},"2":{"start":{"line":10,"column":0},"end":{"line":10,"column":13}},"3":{"start":{"line":16,"column":8},"end":{"line":16,"column":44}},"4":{"start":{"line":17,"column":8},"end":{"line":17,"column":40}},"5":{"start":{"line":20,"column":4},"end":{"line":25,"column":null}},"6":{"start":{"line":21,"column":8},"end":{"line":23,"column":null}},"7":{"start":{"line":22,"column":12},"end":{"line":22,"column":69}},"8":{"start":{"line":24,"column":8},"end":{"line":24,"column":40}},"9":{"start":{"line":27,"column":4},"end":{"line":29,"column":null}},"10":{"start":{"line":28,"column":8},"end":{"line":28,"column":35}},"11":{"start":{"line":38,"column":11},"end":{"line":40,"column":null}},"12":{"start":{"line":39,"column":8},"end":{"line":39,"column":85}},"13":{"start":{"line":49,"column":11},"end":{"line":55,"column":null}},"14":{"start":{"line":50,"column":8},"end":{"line":52,"column":null}},"15":{"start":{"line":51,"column":12},"end":{"line":51,"column":89}},"16":{"start":{"line":53,"column":8},"end":{"line":54,"column":81}},"17":{"start":{"line":63,"column":17},"end":{"line":65,"column":null}},"18":{"start":{"line":64,"column":8},"end":{"line":64,"column":60}},"19":{"start":{"line":74,"column":17},"end":{"line":76,"column":null}},"20":{"start":{"line":75,"column":8},"end":{"line":75,"column":68}},"21":{"start":{"line":77,"column":0},"end":{"line":77,"column":null}},"22":{"start":{"line":10,"column":13},"end":{"line":10,"column":23}}},"fnMap":{"0":{"name":"(anonymous_13)","decl":{"start":{"line":10,"column":0},"end":{"line":10,"column":13}},"loc":{"start":{"line":10,"column":0},"end":{"line":77,"column":null}}},"1":{"name":"EventStore","decl":{"start":{"line":15,"column":4},"end":{"line":15,"column":23}},"loc":{"start":{"line":15,"column":75},"end":{"line":18,"column":5}}},"2":{"name":"(anonymous_15)","decl":{"start":{"line":20,"column":4},"end":{"line":20,"column":15}},"loc":{"start":{"line":20,"column":4},"end":{"line":25,"column":5}}},"3":{"name":"(anonymous_16)","decl":{"start":{"line":27,"column":4},"end":{"line":27,"column":15}},"loc":{"start":{"line":27,"column":4},"end":{"line":29,"column":5}}},"4":{"name":"(anonymous_17)","decl":{"start":{"line":38,"column":4},"end":{"line":38,"column":11}},"loc":{"start":{"line":38,"column":63},"end":{"line":40,"column":5}}},"5":{"name":"(anonymous_18)","decl":{"start":{"line":49,"column":4},"end":{"line":49,"column":11}},"loc":{"start":{"line":49,"column":64},"end":{"line":55,"column":5}}},"6":{"name":"(anonymous_19)","decl":{"start":{"line":63,"column":4},"end":{"line":63,"column":17}},"loc":{"start":{"line":63,"column":64},"end":{"line":65,"column":null}}},"7":{"name":"(anonymous_22)","decl":{"start":{"line":74,"column":4},"end":{"line":74,"column":17}},"loc":{"start":{"line":74,"column":80},"end":{"line":76,"column":null}}}},"branchMap":{"0":{"loc":{"start":{"line":21,"column":8},"end":{"line":23,"column":null}},"type":"if","locations":[{"start":{"line":21,"column":8},"end":{"line":23,"column":null}},{"start":{"line":21,"column":8},"end":{"line":23,"column":null}}]},"1":{"loc":{"start":{"line":50,"column":8},"end":{"line":52,"column":null}},"type":"if","locations":[{"start":{"line":50,"column":8},"end":{"line":52,"column":null}},{"start":{"line":50,"column":8},"end":{"line":52,"column":null}}]},"2":{"loc":{"start":{"line":50,"column":12},"end":{"line":50,"column":26}},"type":"binary-expr","locations":[{"start":{"line":50,"column":12},"end":{"line":50,"column":26}},{"start":{"line":50,"column":31},"end":{"line":50,"column":74}}]}},"s":{"0":4,"1":4,"2":4,"3":17,"4":17,"5":4,"6":32,"7":1,"8":31,"9":4,"10":33,"11":4,"12":23,"13":4,"14":3,"15":2,"16":1,"17":4,"18":4,"19":4,"20":3,"21":4,"22":4},"f":{"0":4,"1":17,"2":32,"3":33,"4":23,"5":3,"6":4,"7":3},"b":{"0":[1,31],"1":[2,1],"2":[3,2]}} | ||
,"/home/runner/work/aws-event-stream/aws-event-stream/src/publisher/memory.ts": {"path":"/home/runner/work/aws-event-stream/aws-event-stream/src/publisher/memory.ts","statementMap":{"0":{"start":{"line":9,"column":0},"end":{"line":9,"column":13}},"1":{"start":{"line":11,"column":12},"end":{"line":11,"column":66}},"2":{"start":{"line":13,"column":17},"end":{"line":21,"column":null}},"3":{"start":{"line":14,"column":14},"end":{"line":14,"column":84}},"4":{"start":{"line":16,"column":8},"end":{"line":19,"column":null}},"5":{"start":{"line":17,"column":12},"end":{"line":17,"column":76}},"6":{"start":{"line":17,"column":55},"end":{"line":17,"column":75}},"7":{"start":{"line":18,"column":12},"end":{"line":18,"column":51}},"8":{"start":{"line":20,"column":8},"end":{"line":20,"column":20}},"9":{"start":{"line":23,"column":17},"end":{"line":36,"column":null}},"10":{"start":{"line":24,"column":12},"end":{"line":24,"column":65}},"11":{"start":{"line":25,"column":8},"end":{"line":28,"column":null}},"12":{"start":{"line":26,"column":12},"end":{"line":26,"column":57}},"13":{"start":{"line":27,"column":12},"end":{"line":27,"column":64}},"14":{"start":{"line":29,"column":8},"end":{"line":29,"column":44}},"15":{"start":{"line":30,"column":8},"end":{"line":35,"column":10}},"16":{"start":{"line":31,"column":20},"end":{"line":34,"column":null}},"17":{"start":{"line":32,"column":22},"end":{"line":32,"column":69}},"18":{"start":{"line":33,"column":16},"end":{"line":33,"column":52}},"19":{"start":{"line":37,"column":0},"end":{"line":37,"column":null}},"20":{"start":{"line":9,"column":13},"end":{"line":9,"column":30}}},"fnMap":{"0":{"name":"(anonymous_13)","decl":{"start":{"line":9,"column":0},"end":{"line":9,"column":13}},"loc":{"start":{"line":9,"column":0},"end":{"line":37,"column":null}}},"1":{"name":"(anonymous_15)","decl":{"start":{"line":13,"column":4},"end":{"line":13,"column":17}},"loc":{"start":{"line":13,"column":41},"end":{"line":21,"column":null}}},"2":{"name":"(anonymous_18)","decl":{"start":{"line":17,"column":41},"end":{"line":17,"column":51}},"loc":{"start":{"line":17,"column":51},"end":{"line":17,"column":65}}},"3":{"name":"(anonymous_19)","decl":{"start":{"line":23,"column":4},"end":{"line":23,"column":17}},"loc":{"start":{"line":23,"column":70},"end":{"line":36,"column":null}}},"4":{"name":"(anonymous_22)","decl":{"start":{"line":31,"column":20},"end":{"line":31,"column":null}},"loc":{"start":{"line":31,"column":20},"end":{"line":34,"column":null}}}},"branchMap":{"0":{"loc":{"start":{"line":16,"column":8},"end":{"line":19,"column":null}},"type":"if","locations":[{"start":{"line":16,"column":8},"end":{"line":19,"column":null}},{"start":{"line":16,"column":8},"end":{"line":19,"column":null}}]},"1":{"loc":{"start":{"line":16,"column":12},"end":{"line":16,"column":40}},"type":"binary-expr","locations":[{"start":{"line":16,"column":12},"end":{"line":16,"column":40}},{"start":{"line":16,"column":44},"end":{"line":16,"column":71}}]},"2":{"loc":{"start":{"line":25,"column":8},"end":{"line":28,"column":null}},"type":"if","locations":[{"start":{"line":25,"column":8},"end":{"line":28,"column":null}},{"start":{"line":25,"column":8},"end":{"line":28,"column":null}}]}},"s":{"0":4,"1":9,"2":4,"3":7,"4":7,"5":4,"6":5,"7":4,"8":3,"9":4,"10":5,"11":5,"12":4,"13":4,"14":5,"15":5,"16":1,"17":1,"18":1,"19":4,"20":4},"f":{"0":13,"1":7,"2":5,"3":5,"4":2},"b":{"0":[4,3],"1":[7,5],"2":[4,1]}} | ||
,"/home/runner/work/aws-event-stream/aws-event-stream/src/publisher/sns.ts": {"path":"/home/runner/work/aws-event-stream/aws-event-stream/src/publisher/sns.ts","statementMap":{"0":{"start":{"line":2,"column":0},"end":{"line":2,"column":38}},"1":{"start":{"line":14,"column":0},"end":{"line":14,"column":null}},"2":{"start":{"line":15,"column":4},"end":{"line":15,"column":19}},"3":{"start":{"line":15,"column":19},"end":{"line":15,"column":null}},"4":{"start":{"line":20,"column":0},"end":{"line":20,"column":13}},"5":{"start":{"line":28,"column":8},"end":{"line":28,"column":33}},"6":{"start":{"line":30,"column":8},"end":{"line":32,"column":10}},"7":{"start":{"line":33,"column":8},"end":{"line":33,"column":23}},"8":{"start":{"line":34,"column":8},"end":{"line":34,"column":36}},"9":{"start":{"line":37,"column":17},"end":{"line":50,"column":null}},"10":{"start":{"line":38,"column":14},"end":{"line":47,"column":10}},"11":{"start":{"line":49,"column":16},"end":{"line":49,"column":58}},"12":{"start":{"line":49,"column":8},"end":{"line":49,"column":69}},"13":{"start":{"line":52,"column":17},"end":{"line":75,"column":null}},"14":{"start":{"line":53,"column":8},"end":{"line":55,"column":null}},"15":{"start":{"line":54,"column":12},"end":{"line":54,"column":67}},"16":{"start":{"line":57,"column":14},"end":{"line":57,"column":73}},"17":{"start":{"line":58,"column":8},"end":{"line":60,"column":null}},"18":{"start":{"line":59,"column":12},"end":{"line":59,"column":79}},"19":{"start":{"line":61,"column":14},"end":{"line":65,"column":10}},"20":{"start":{"line":67,"column":8},"end":{"line":67,"column":54}},"21":{"start":{"line":69,"column":8},"end":{"line":74,"column":11}},"22":{"start":{"line":71,"column":16},"end":{"line":71,"column":49}},"23":{"start":{"line":72,"column":16},"end":{"line":72,"column":41}},"24":{"start":{"line":76,"column":0},"end":{"line":76,"column":null}},"25":{"start":{"line":20,"column":13},"end":{"line":20,"column":25}}},"fnMap":{"0":{"name":"(anonymous_13)","decl":{"start":{"line":14,"column":0},"end":{"line":14,"column":12}},"loc":{"start":{"line":14,"column":21},"end":{"line":16,"column":1}}},"1":{"name":"(anonymous_14)","decl":{"start":{"line":20,"column":0},"end":{"line":20,"column":13}},"loc":{"start":{"line":20,"column":0},"end":{"line":76,"column":null}}},"2":{"name":"SNSPublisher","decl":{"start":{"line":27,"column":4},"end":{"line":27,"column":16}},"loc":{"start":{"line":27,"column":73},"end":{"line":35,"column":5}}},"3":{"name":"(anonymous_16)","decl":{"start":{"line":37,"column":4},"end":{"line":37,"column":17}},"loc":{"start":{"line":37,"column":45},"end":{"line":50,"column":null}}},"4":{"name":"(anonymous_19)","decl":{"start":{"line":52,"column":4},"end":{"line":52,"column":17}},"loc":{"start":{"line":52,"column":52},"end":{"line":75,"column":null}}},"5":{"name":"(anonymous_22)","decl":{"start":{"line":70,"column":20},"end":{"line":70,"column":null}},"loc":{"start":{"line":70,"column":20},"end":{"line":73,"column":13}}}},"branchMap":{"0":{"loc":{"start":{"line":14,"column":12},"end":{"line":14,"column":21}},"type":"binary-expr","locations":[{"start":{"line":14,"column":12},"end":{"line":14,"column":21}},{"start":{"line":14,"column":12},"end":{"line":14,"column":null}}]},"1":{"loc":{"start":{"line":31,"column":25},"end":{"line":31,"column":61}},"type":"cond-expr","locations":[{"start":{"line":31,"column":25},"end":{"line":31,"column":61}},{"start":{"line":31,"column":64},"end":{"line":31,"column":73}}]},"2":{"loc":{"start":{"line":49,"column":8},"end":{"line":49,"column":69}},"type":"switch","locations":[{"start":{"line":49,"column":8},"end":{"line":49,"column":69}}]},"3":{"loc":{"start":{"line":53,"column":8},"end":{"line":55,"column":null}},"type":"if","locations":[{"start":{"line":53,"column":8},"end":{"line":55,"column":null}},{"start":{"line":53,"column":8},"end":{"line":55,"column":null}}]},"4":{"loc":{"start":{"line":58,"column":8},"end":{"line":60,"column":null}},"type":"if","locations":[{"start":{"line":58,"column":8},"end":{"line":60,"column":null}},{"start":{"line":58,"column":8},"end":{"line":60,"column":null}}]}},"s":{"0":5,"1":5,"2":5,"3":5,"4":5,"5":7,"6":7,"7":7,"8":7,"9":5,"10":4,"11":4,"12":4,"13":5,"14":3,"15":1,"16":2,"17":2,"18":1,"19":1,"20":2,"21":1,"22":1,"23":1,"24":5,"25":5},"f":{"0":5,"1":5,"2":7,"3":4,"4":3,"5":1},"b":{"0":[5,5],"1":[2,5],"2":[4],"3":[1,2],"4":[1,1]}} | ||
,"/home/runner/work/aws-event-stream/aws-event-stream/src/publisher/sns.ts": {"path":"/home/runner/work/aws-event-stream/aws-event-stream/src/publisher/sns.ts","statementMap":{"0":{"start":{"line":2,"column":0},"end":{"line":2,"column":51}},"1":{"start":{"line":16,"column":0},"end":{"line":16,"column":null}},"2":{"start":{"line":17,"column":4},"end":{"line":17,"column":19}},"3":{"start":{"line":17,"column":19},"end":{"line":17,"column":null}},"4":{"start":{"line":22,"column":0},"end":{"line":22,"column":13}},"5":{"start":{"line":30,"column":8},"end":{"line":30,"column":33}},"6":{"start":{"line":32,"column":8},"end":{"line":36,"column":10}},"7":{"start":{"line":37,"column":8},"end":{"line":37,"column":23}},"8":{"start":{"line":38,"column":8},"end":{"line":38,"column":36}},"9":{"start":{"line":41,"column":17},"end":{"line":54,"column":null}},"10":{"start":{"line":42,"column":14},"end":{"line":51,"column":10}},"11":{"start":{"line":53,"column":16},"end":{"line":53,"column":58}},"12":{"start":{"line":53,"column":8},"end":{"line":53,"column":69}},"13":{"start":{"line":56,"column":17},"end":{"line":79,"column":null}},"14":{"start":{"line":57,"column":8},"end":{"line":59,"column":null}},"15":{"start":{"line":58,"column":12},"end":{"line":58,"column":67}},"16":{"start":{"line":61,"column":14},"end":{"line":61,"column":73}},"17":{"start":{"line":62,"column":8},"end":{"line":64,"column":null}},"18":{"start":{"line":63,"column":12},"end":{"line":63,"column":79}},"19":{"start":{"line":65,"column":14},"end":{"line":69,"column":10}},"20":{"start":{"line":71,"column":8},"end":{"line":71,"column":54}},"21":{"start":{"line":73,"column":8},"end":{"line":78,"column":11}},"22":{"start":{"line":75,"column":16},"end":{"line":75,"column":49}},"23":{"start":{"line":76,"column":16},"end":{"line":76,"column":41}},"24":{"start":{"line":80,"column":0},"end":{"line":80,"column":null}},"25":{"start":{"line":22,"column":13},"end":{"line":22,"column":25}}},"fnMap":{"0":{"name":"(anonymous_13)","decl":{"start":{"line":16,"column":0},"end":{"line":16,"column":12}},"loc":{"start":{"line":16,"column":21},"end":{"line":18,"column":1}}},"1":{"name":"(anonymous_14)","decl":{"start":{"line":22,"column":0},"end":{"line":22,"column":13}},"loc":{"start":{"line":22,"column":0},"end":{"line":80,"column":null}}},"2":{"name":"SNSPublisher","decl":{"start":{"line":29,"column":4},"end":{"line":29,"column":16}},"loc":{"start":{"line":29,"column":73},"end":{"line":39,"column":5}}},"3":{"name":"(anonymous_16)","decl":{"start":{"line":41,"column":4},"end":{"line":41,"column":17}},"loc":{"start":{"line":41,"column":45},"end":{"line":54,"column":null}}},"4":{"name":"(anonymous_19)","decl":{"start":{"line":56,"column":4},"end":{"line":56,"column":17}},"loc":{"start":{"line":56,"column":52},"end":{"line":79,"column":null}}},"5":{"name":"(anonymous_22)","decl":{"start":{"line":74,"column":20},"end":{"line":74,"column":null}},"loc":{"start":{"line":74,"column":20},"end":{"line":77,"column":13}}}},"branchMap":{"0":{"loc":{"start":{"line":16,"column":12},"end":{"line":16,"column":21}},"type":"binary-expr","locations":[{"start":{"line":16,"column":12},"end":{"line":16,"column":21}},{"start":{"line":16,"column":12},"end":{"line":16,"column":null}}]},"1":{"loc":{"start":{"line":33,"column":25},"end":{"line":35,"column":51}},"type":"cond-expr","locations":[{"start":{"line":33,"column":25},"end":{"line":35,"column":51}},{"start":{"line":35,"column":54},"end":{"line":35,"column":63}}]},"2":{"loc":{"start":{"line":53,"column":8},"end":{"line":53,"column":69}},"type":"switch","locations":[{"start":{"line":53,"column":8},"end":{"line":53,"column":69}}]},"3":{"loc":{"start":{"line":57,"column":8},"end":{"line":59,"column":null}},"type":"if","locations":[{"start":{"line":57,"column":8},"end":{"line":59,"column":null}},{"start":{"line":57,"column":8},"end":{"line":59,"column":null}}]},"4":{"loc":{"start":{"line":62,"column":8},"end":{"line":64,"column":null}},"type":"if","locations":[{"start":{"line":62,"column":8},"end":{"line":64,"column":null}},{"start":{"line":62,"column":8},"end":{"line":64,"column":null}}]}},"s":{"0":5,"1":5,"2":5,"3":5,"4":5,"5":7,"6":7,"7":7,"8":7,"9":5,"10":4,"11":4,"12":4,"13":5,"14":3,"15":1,"16":2,"17":2,"18":1,"19":1,"20":2,"21":1,"22":1,"23":1,"24":5,"25":5},"f":{"0":5,"1":5,"2":7,"3":4,"4":3,"5":1},"b":{"0":[5,5],"1":[2,5],"2":[4],"3":[1,2],"4":[1,1]}} | ||
} |
import { config, SNS } from 'aws-sdk'; | ||
import { config, HTTPOptions, SNS } from 'aws-sdk'; | ||
import { AWSConfig } from '../aws/config'; | ||
@@ -12,2 +12,4 @@ import { MessageType } from '../model/message'; | ||
endpointUrl?: string; | ||
maxRetries?: number; | ||
httpOptions?: HTTPOptions; | ||
} | ||
@@ -32,3 +34,5 @@ | ||
this.sns = new SNS( | ||
snsOptions ? { endpoint: snsOptions.endpointUrl } : undefined | ||
snsOptions ? { endpoint: snsOptions.endpointUrl, | ||
httpOptions: snsOptions.httpOptions, | ||
maxRetries: snsOptions.maxRetries } : undefined | ||
); | ||
@@ -35,0 +39,0 @@ this.url = url; |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
336117
0.29%2723
0.33%