aws-kinesis-writable - npm Package Compare versions

Comparing version 1.4.8 to 1.4.9

package.json

 {
   "name": "aws-kinesis-writable",
   "description": "A bunyan stream for kinesis.",
-  "version": "1.4.8",
+  "version": "1.4.9",
   "author": "José F. Romaniello <[e-mail]> (http://joseoncode.com)",
@@ -15,3 +15,3 @@ "repository": {
   "dependencies": {
-    "aws-sdk": "~2.1.43",
+    "aws-sdk": "^2.2.36",
     "lodash": "~3.10.1"
@@ -18,0 +18,0 @@ },

README.md

@@ -79,4 +79,12 @@ Kinesis writteable stream for bunyan.
 
+## Issue Reporting
+
+If you have found a bug or if you have a feature request, please report them at this repository issues section. Please do not report security vulnerabilities on the public GitHub issue tracker. The [Responsible Disclosure Program](https://auth0.com/whitehat) details the procedure for disclosing security issues.
+
+## Author
+
+[Auth0](auth0.com)
+
 ## License
 
-MIT 2015 - AUTH0 INC.
+This project is licensed under the MIT license. See the [LICENSE](LICENSE) file for more info.

x.js

@@ -1,19 +0,51 @@
-var KinesisStream = require('.');
-var bk = new KinesisStream({
-  streamName: 'test',
-  region: 'us-west-2',
-  buffer: false
-});
+// var KinesisStream = require('.');
+// var bk = new KinesisStream({
+//   streamName: 'test',
+//   region: 'us-west-2',
+//   buffer: false
+// });
 
-var x = { x: 1, tenant: 'sam', date: new Date(), _id: 'jeje' + Date.now()};
-bk._write(JSON.stringify(x), null, function (err) {
-  console.log(10, err);
-  x = { metatype: 'foo', metadata: { x: 2, tenant: 'sam', date: new Date()} };
-  bk._write(JSON.stringify(x), null, function (err) {
-    console.log(20, err);
-    x = { metatype: 'tenant-log', metadata: { x: 3, tenant: 'sam', date: new Date()} };
-    bk._write(JSON.stringify(x), null, function (err) {
-      console.log(30, err);
-    });
-  });
-});
+// var x = { x: 1, tenant: 'sam', date: new Date(), _id: 'jeje' + Date.now()};
+// bk._write(JSON.stringify(x), null, function (err) {
+//   console.log(10, err);
+//   x = { metatype: 'foo', metadata: { x: 2, tenant: 'sam', date: new Date()} };
+//   bk._write(JSON.stringify(x), null, function (err) {
+//     console.log(20, err);
+//     x = { metatype: 'tenant-log', metadata: { x: 3, tenant: 'sam', date: new Date()} };
+//     bk._write(JSON.stringify(x), null, function (err) {
+//       console.log(30, err);
+//     });
+//   });
+// });
+
+var AWS = require('aws-sdk');
+var _ = require('lodash');
+
+
+var params = {
+  region: 'us-west-2'
+};
+
+ var kinesis = new AWS.Kinesis(_.pick(params, [
+    'accessKeyId',
+    'secretAccessKey',
+    'region',
+    'httpOptions']));
+
+var records = {
+  StreamName: 'vagrant_testig',
+  Records: [
+    { Data: 34234, PartitionKey: 'pk' },
+    { Data: 'bar', PartitionKey: 'pk' }
+  ]
+};
+
+var req = kinesis.putRecords(records, (e, r) => {
+  console.log('CB', e, r);
+})
+.on('success', (r) => { console.log('SUCCESS', r.data); })
+.on('error', (e) => { console.log('ERROR', e); })
+.on('complete', () => { console.log('COMPLETE'); });
+
+
+console.log('sent');

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

34259

increased by3.55%

Lines of code

840

increased by2.82%

Number of lines in readme file

90

increased by11.11%

Dependency changes

• + Addedavailable-typed-arrays@1.0.7(transitive)

• + Addedaws-sdk@2.1692.0(transitive)

• + Addedbase64-js@1.5.1(transitive)

• + Addedbuffer@4.9.2(transitive)

• + Addedcall-bind@1.0.7(transitive)

• + Addeddefine-data-property@1.1.4(transitive)

• + Addedes-define-property@1.0.0(transitive)

• + Addedes-errors@1.3.0(transitive)

• + Addedevents@1.1.1(transitive)

• + Addedfor-each@0.3.3(transitive)

• + Addedfunction-bind@1.1.2(transitive)

• + Addedget-intrinsic@1.2.4(transitive)

• + Addedgopd@1.1.0(transitive)

• + Addedhas-property-descriptors@1.0.2(transitive)

• + Addedhas-proto@1.1.0(transitive)

• + Addedhas-symbols@1.1.0(transitive)

• + Addedhas-tostringtag@1.0.2(transitive)

• + Addedhasown@2.0.2(transitive)

• + Addedieee754@1.1.13(transitive)

• + Addedinherits@2.0.4(transitive)

• + Addedis-arguments@1.1.1(transitive)

• + Addedis-callable@1.2.7(transitive)

• + Addedis-generator-function@1.0.10(transitive)

• + Addedis-typed-array@1.1.13(transitive)

• + Addedisarray@1.0.0(transitive)

• + Addedjmespath@0.16.0(transitive)

• + Addedpossible-typed-array-names@1.0.0(transitive)

• + Addedpunycode@1.3.2(transitive)

• + Addedquerystring@0.2.0(transitive)

• + Addedsax@1.2.1(transitive)

• + Addedset-function-length@1.2.2(transitive)

• + Addedurl@0.10.3(transitive)

• + Addedutil@0.12.5(transitive)

• + Addeduuid@8.0.0(transitive)

• + Addedwhich-typed-array@1.1.16(transitive)

• + Addedxml2js@0.6.2(transitive)

• + Addedxmlbuilder@11.0.1(transitive)

• - Removedaws-sdk@2.1.50(transitive)

• - Removedsax@0.5.3(transitive)

• - Removedxml2js@0.2.8(transitive)

• - Removedxmlbuilder@0.4.2(transitive)

• Updatedaws-sdk@^2.2.36