@tellimer/mailer - npm Package Compare versions

Comparing version 1.0.1 to 1.0.2

dist/send.js

@@ -29,2 +29,3 @@ "use strict";
 const POOL_LIMIT = 10;
+const BATCH_SIZE = parseInt(process.env.SENDGRID_BATCH_SIZE || '1000');
 function isPersonalizationList(x) {
@@ -142,12 +143,15 @@ return typeof x[0] !== 'string';
         const personalizations = [...data.personalizations];
-        const senders = [];
         const sendgridData = [];
         while (personalizations.length > 0) {
-            data.personalizations = personalizations.splice(0, 1000);
-            // data.mailSettings = { sandboxMode: { enable: true } }
-            // console.log(JSON.stringify(data, undefined, 2))
-            sendgridData.push(data);
+            const _data = Object.assign({}, data);
+            _data.personalizations = personalizations.splice(0, BATCH_SIZE);
+            sendgridData.push(_data);
         }
+        const senders = [];
         try {
-            for (var _b = __asyncValues((0, tiny_async_pool_1.default)(POOL_LIMIT, sendgridData, mail_1.default.send)), _c; _c = yield _b.next(), !_c.done;) {
+            for (var _b = __asyncValues((0, tiny_async_pool_1.default)(POOL_LIMIT, sendgridData, d => {
+                var _a;
+                console.log(`Sending batch of ${(_a = d.personalizations) === null || _a === void 0 ? void 0 : _a.length} emails.`);
+                return mail_1.default.send(d);
+            })), _c; _c = yield _b.next(), !_c.done;) {
                 const value = _c.value;
@@ -154,0 +158,0 @@ senders.push(value);

package.json

 {
   "name": "@tellimer/mailer",
-  "version": "1.0.1",
+  "version": "1.0.2",
   "license": "MIT",
@@ -8,3 +8,4 @@ "main": "dist/index.js",
   "scripts": {
-    "test": "ts-mocha --paths './__tests__/**/*.test.ts' --exit",
+    "test": "ts-mocha --paths './__tests__/**/*.unit.test.ts' --exit",
+    "test:integration": "ts-mocha --paths './__tests__/**/*.integration.test.ts' --exit",
     "build": "rm -rf ./dist && tsc -p tsconfig.json",
@@ -18,3 +19,3 @@ "lint": "eslint src --fix",
   "dependencies": {
-    "@tellimer/mailable": "workspace:@tellimer/mailable@*",
+    "@tellimer/mailable": "workspace:^",
     "tiny-async-pool": "^2.0.1"
@@ -21,0 +22,0 @@ },

src/send.ts

@@ -14,2 +14,3 @@ import sendgrid from '@sendgrid/mail'
 const POOL_LIMIT = 10
+const BATCH_SIZE = parseInt(process.env.SENDGRID_BATCH_SIZE || '1000')
 
@@ -164,14 +165,17 @@ export type Person = string | PersonObj
   const personalizations = [...data.personalizations]
-  const senders: [sendgrid.ClientResponse, Record<any, any>][] = []
-  const sendgridData = []
+  const sendgridData: sendgrid.MailDataRequired[] = []
 
   while (personalizations.length > 0) {
-    data.personalizations = personalizations.splice(0, 1000)
-
-    // data.mailSettings = { sandboxMode: { enable: true } }
-    // console.log(JSON.stringify(data, undefined, 2))
-    sendgridData.push(data)
+    const _data = {
+      ...data,
+    }
+    _data.personalizations = personalizations.splice(0, BATCH_SIZE)
+    sendgridData.push(_data)
   }
 
-  for await (const value of asyncPool(POOL_LIMIT, sendgridData, sendgrid.send)) {
+  const senders: [sendgrid.ClientResponse, Record<any, any>][] = []
+  for await (const value of asyncPool(POOL_LIMIT, sendgridData, d => {
+    console.log(`Sending batch of ${d.personalizations?.length} emails.`)
+    return sendgrid.send(d)
+  })) {
     senders.push(value)
@@ -178,0 +182,0 @@ }

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

Environment variable access

Supply chain risk

Package accesses environment variables, which may be a sign of credential stuffing or data theft.

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

GitHub dependency

Supply chain risk

Contains a dependency which resolves to a GitHub URL. Dependencies fetched from GitHub specifiers are not immutable can be used to inject untrusted code or reduce the likelihood of a reproducible install.

Found 1 instance in 1 package

Improved metrics

Number of package files

30

increased by3.45%

Lines of code

1010

increased by6.43%

Number of high supply chain risk alerts

0

decreased by-100%

Worsened metrics

Total package byte prevSize

635290

decreased by-0.11%

Number of low supply chain risk alerts

2

increased by100%

Dependency changes

• Updated@tellimer/mailable@workspace:^