Socket
Socket
Sign inDemoInstall

smtp-fetch

Package Overview
Dependencies
0
Maintainers
1
Versions
6
Alerts
File Explorer

Advanced tools

npm Scripts

Install Socket

Detect and block malicious and high-risk dependencies

Install

Comparing version 1.0.0 to 1.0.1

dist/error.d.ts.map
dist/error.js.map
dist/index.d.ts.map
dist/index.js.map

7

dist/error.d.ts

@@ -1,2 +0,5 @@

export declare class SMTPError extends Error {}
export declare class SMTPServerDisconnected extends SMTPError {}
export declare class SMTPError extends Error {
}
export declare class SMTPServerDisconnected extends SMTPError {
}
//# sourceMappingURL=error.d.ts.map

1

dist/error.js

@@ -35,1 +35,2 @@ "use strict";

exports.SMTPServerDisconnected = SMTPServerDisconnected;
//# sourceMappingURL=error.js.map

5

dist/index.d.ts
/// <reference types="node" />
/// <reference types="node" />
import * as net from "net";
import * as tls from "tls";
import net from "net";
import tls from "tls";
export type ISocket = net.Socket | tls.TLSSocket;

@@ -35,1 +35,2 @@ export type IExtension = {

}
//# sourceMappingURL=index.d.ts.map

676

dist/index.js
"use strict";
var __assign =
(this && this.__assign) ||
function () {
__assign =
Object.assign ||
function (t) {
var __assign = (this && this.__assign) || function () {
__assign = Object.assign || function(t) {
for (var s, i = 1, n = arguments.length; i < n; i++) {
s = arguments[i];
for (var p in s)
if (Object.prototype.hasOwnProperty.call(s, p)) t[p] = s[p];
s = arguments[i];
for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))
t[p] = s[p];
}
return t;
};
};
return __assign.apply(this, arguments);
};
var __awaiter =
(this && this.__awaiter) ||
function (thisArg, _arguments, P, generator) {
function adopt(value) {
return value instanceof P
? value
: new P(function (resolve) {
resolve(value);
});
}
};
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
return new (P || (P = Promise))(function (resolve, reject) {
function fulfilled(value) {
try {
step(generator.next(value));
} catch (e) {
reject(e);
}
}
function rejected(value) {
try {
step(generator["throw"](value));
} catch (e) {
reject(e);
}
}
function step(result) {
result.done
? resolve(result.value)
: adopt(result.value).then(fulfilled, rejected);
}
step((generator = generator.apply(thisArg, _arguments || [])).next());
function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
step((generator = generator.apply(thisArg, _arguments || [])).next());
});
};
var __generator =
(this && this.__generator) ||
function (thisArg, body) {
var _ = {
label: 0,
sent: function () {
if (t[0] & 1) throw t[1];
return t[1];
},
trys: [],
ops: [],
},
f,
y,
t,
g;
return (
(g = { next: verb(0), throw: verb(1), return: verb(2) }),
typeof Symbol === "function" &&
(g[Symbol.iterator] = function () {
return this;
}),
g
);
function verb(n) {
return function (v) {
return step([n, v]);
};
}
};
var __generator = (this && this.__generator) || function (thisArg, body) {
var _ = { label: 0, sent: function() { if (t[0] & 1) throw t[1]; return t[1]; }, trys: [], ops: [] }, f, y, t, g;
return g = { next: verb(0), "throw": verb(1), "return": verb(2) }, typeof Symbol === "function" && (g[Symbol.iterator] = function() { return this; }), g;
function verb(n) { return function (v) { return step([n, v]); }; }
function step(op) {
if (f) throw new TypeError("Generator is already executing.");
while ((g && ((g = 0), op[0] && (_ = 0)), _))
try {
if (
((f = 1),
y &&
(t =
op[0] & 2
? y["return"]
: op[0]
? y["throw"] || ((t = y["return"]) && t.call(y), 0)
: y.next) &&
!(t = t.call(y, op[1])).done)
)
return t;
if (((y = 0), t)) op = [op[0] & 2, t.value];
switch (op[0]) {
case 0:
case 1:
t = op;
break;
case 4:
_.label++;
return { value: op[1], done: false };
case 5:
_.label++;
y = op[1];
op = [0];
continue;
case 7:
op = _.ops.pop();
_.trys.pop();
continue;
default:
if (
!((t = _.trys), (t = t.length > 0 && t[t.length - 1])) &&
(op[0] === 6 || op[0] === 2)
) {
_ = 0;
continue;
}
if (op[0] === 3 && (!t || (op[1] > t[0] && op[1] < t[3]))) {
_.label = op[1];
break;
}
if (op[0] === 6 && _.label < t[1]) {
_.label = t[1];
t = op;
break;
}
if (t && _.label < t[2]) {
_.label = t[2];
_.ops.push(op);
break;
}
if (t[2]) _.ops.pop();
_.trys.pop();
continue;
}
op = body.call(thisArg, _);
} catch (e) {
op = [6, e];
y = 0;
} finally {
f = t = 0;
}
if (op[0] & 5) throw op[1];
return { value: op[0] ? op[1] : void 0, done: true };
if (f) throw new TypeError("Generator is already executing.");
while (g && (g = 0, op[0] && (_ = 0)), _) try {
if (f = 1, y && (t = op[0] & 2 ? y["return"] : op[0] ? y["throw"] || ((t = y["return"]) && t.call(y), 0) : y.next) && !(t = t.call(y, op[1])).done) return t;
if (y = 0, t) op = [op[0] & 2, t.value];
switch (op[0]) {
case 0: case 1: t = op; break;
case 4: _.label++; return { value: op[1], done: false };
case 5: _.label++; y = op[1]; op = [0]; continue;
case 7: op = _.ops.pop(); _.trys.pop(); continue;
default:
if (!(t = _.trys, t = t.length > 0 && t[t.length - 1]) && (op[0] === 6 || op[0] === 2)) { _ = 0; continue; }
if (op[0] === 3 && (!t || (op[1] > t[0] && op[1] < t[3]))) { _.label = op[1]; break; }
if (op[0] === 6 && _.label < t[1]) { _.label = t[1]; t = op; break; }
if (t && _.label < t[2]) { _.label = t[2]; _.ops.push(op); break; }
if (t[2]) _.ops.pop();
_.trys.pop(); continue;
}
op = body.call(thisArg, _);
} catch (e) { op = [6, e]; y = 0; } finally { f = t = 0; }
if (op[0] & 5) throw op[1]; return { value: op[0] ? op[1] : void 0, done: true };
}
};
var __spreadArray =
(this && this.__spreadArray) ||
function (to, from, pack) {
if (pack || arguments.length === 2)
for (var i = 0, l = from.length, ar; i < l; i++) {
};
var __spreadArray = (this && this.__spreadArray) || function (to, from, pack) {
if (pack || arguments.length === 2) for (var i = 0, l = from.length, ar; i < l; i++) {
if (ar || !(i in from)) {
if (!ar) ar = Array.prototype.slice.call(from, 0, i);
ar[i] = from[i];
if (!ar) ar = Array.prototype.slice.call(from, 0, i);
ar[i] = from[i];
}
}
}
return to.concat(ar || Array.prototype.slice.call(from));
};
};
var __importDefault = (this && this.__importDefault) || function (mod) {
return (mod && mod.__esModule) ? mod : { "default": mod };
};
Object.defineProperty(exports, "__esModule", { value: true });
var util = require("util");
var net = require("net");
var tls = require("tls");
var debug = require("debug");
var util_1 = __importDefault(require("util"));
var net_1 = __importDefault(require("net"));
var tls_1 = __importDefault(require("tls"));
var debug_1 = __importDefault(require("debug"));
var error_1 = require("./error");
var log = debug("smtp");
var log = (0, debug_1.default)("smtp");
var SMTP = /** @class */ (function () {
function SMTP(host, port, tls, localName) {
if (tls === void 0) {
tls = false;
function SMTP(host, port, tls, localName) {
if (tls === void 0) { tls = false; }
if (localName === void 0) { localName = "localhost"; }
this.host = host;
this.port = port;
this.tls = tls;
this.localName = localName;
this.ext = {};
this.auth = [];
this.didHello = false;
}
if (localName === void 0) {
localName = "localhost";
}
this.host = host;
this.port = port;
this.tls = tls;
this.localName = localName;
this.ext = {};
this.auth = [];
this.didHello = false;
}
SMTP.prototype.connect = function (options) {
var _this = this;
if (options === void 0) {
options = {};
}
var select = this.tls ? tls.connect : net.connect;
this.socket = select(
__assign({ port: this.port, host: this.host }, options)
);
return new Promise(function (resolve, reject) {
_this.socket.on("connect", function () {
_this.socket.once("data", function (data) {
try {
log("connect: " + data.toString());
resolve(_this.parseCodeLine(data.toString(), 220));
} catch (err) {
log("connect error: " + err.message);
reject(err);
}
SMTP.prototype.connect = function (options) {
var _this = this;
if (options === void 0) { options = {}; }
var select = (this.tls ? tls_1.default.connect : net_1.default.connect);
this.socket = select(__assign({ port: this.port, host: this.host }, options));
return new Promise(function (resolve, reject) {
_this.socket.on("connect", function () {
_this.socket.once("data", function (data) {
try {
log("connect: " + data.toString());
resolve(_this.parseCodeLine(data.toString(), 220));
}
catch (err) {
log("connect error: " + err.message);
reject(err);
}
});
});
_this.socket.on("timeout", function () {
log("timeout error");
_this.socket.emit("error", new error_1.SMTPError("timeout"));
});
_this.socket.on("error", function (err) {
log("connect error: " + err);
reject(err);
});
});
});
_this.socket.on("timeout", function () {
log("timeout error");
_this.socket.emit("error", new error_1.SMTPError("timeout"));
});
_this.socket.on("error", function (err) {
log("connect error: " + err);
reject(err);
});
});
};
// Close closes the connection.
SMTP.prototype.close = function () {
if (!this.socket) {
throw new error_1.SMTPServerDisconnected("please run connect() first");
}
this.socket.destroy();
this.socket = null;
};
SMTP.prototype.cmd = function (expectCode, format) {
var _this = this;
var args = [];
for (var _i = 2; _i < arguments.length; _i++) {
args[_i - 2] = arguments[_i];
}
if (!this.socket) {
throw new error_1.SMTPServerDisconnected("please run connect() first");
}
var line = util.format.apply(
util,
__spreadArray(["".concat(format, "\r\n")], args, false)
);
return new Promise(function (resolve) {
log(">> " + line);
_this.socket.write(line, "utf-8", function () {
_this.socket.once("data", function (data) {
resolve(_this.parseCodeLine(data.toString(), expectCode));
});
});
});
};
SMTP.prototype.verify = function (addr) {
return __awaiter(this, void 0, void 0, function () {
return __generator(this, function (_a) {
switch (_a.label) {
case 0:
// ehlo or ehlo first
return [4 /*yield*/, this.hello()];
case 1:
// ehlo or ehlo first
_a.sent();
return [2 /*return*/, this.cmd(250, "VRFY %s", addr)];
};
// Close closes the connection.
SMTP.prototype.close = function () {
if (!this.socket) {
throw new error_1.SMTPServerDisconnected("please run connect() first");
}
});
});
};
SMTP.prototype.noop = function () {
return __awaiter(this, void 0, void 0, function () {
return __generator(this, function (_a) {
switch (_a.label) {
case 0:
// ehlo or ehlo first
return [4 /*yield*/, this.hello()];
case 1:
// ehlo or ehlo first
_a.sent();
return [2 /*return*/, this.cmd(250, "NOOP")];
this.socket.destroy();
this.socket = null;
};
SMTP.prototype.cmd = function (expectCode, format) {
var _this = this;
var args = [];
for (var _i = 2; _i < arguments.length; _i++) {
args[_i - 2] = arguments[_i];
}
});
});
};
// hello runs a hello exchange if needed.
SMTP.prototype.hello = function (name) {
if (name === void 0) {
name = "hi";
}
return __awaiter(this, void 0, void 0, function () {
var resp;
return __generator(this, function (_a) {
switch (_a.label) {
case 0:
if (!!this.didHello) return [3 /*break*/, 3];
this.didHello = true;
return [4 /*yield*/, this.ehlo(name)];
case 1:
resp = _a.sent();
if (!!(200 <= resp.code && resp.code < 300))
return [3 /*break*/, 3];
return [4 /*yield*/, this.helo(name)];
case 2:
resp = _a.sent();
if (!(200 <= resp.code && resp.code < 300)) {
throw new error_1.SMTPError("smtp hello error: " + resp);
}
_a.label = 3;
case 3:
return [2 /*return*/];
if (!this.socket) {
throw new error_1.SMTPServerDisconnected("please run connect() first");
}
});
});
};
// helo sends the HELO greeting to the server. It should be used only when the
// server does not support ehlo.
SMTP.prototype.helo = function (name) {
if (name === void 0) {
name = "hi";
}
return __awaiter(this, void 0, void 0, function () {
return __generator(this, function (_a) {
return [2 /*return*/, this.cmd(220, "HELO %s", name || this.localName)];
});
});
};
// ehlo sends the EHLO (extended hello) greeting to the server. It
// should be the preferred greeting for servers that support it.
SMTP.prototype.ehlo = function (name) {
if (name === void 0) {
name = "hi";
}
return __awaiter(this, void 0, void 0, function () {
var _a, code, message, ext, extList, _i, extList_1, line, _b, k, v;
return __generator(this, function (_c) {
switch (_c.label) {
case 0:
return [
4 /*yield*/,
this.cmd(250, "EHLO %s", name || this.localName),
];
case 1:
(_a = _c.sent()), (code = _a.code), (message = _a.message);
ext = {};
extList = message.split("\n");
if (extList.length > 1) {
if (extList.length > 1) {
extList.shift(); // remove first line
for (_i = 0, extList_1 = extList; _i < extList_1.length; _i++) {
line = extList_1[_i];
(_b = line.split(" ")), (k = _b[0]), (v = _b.slice(1));
ext[k] = v.join(" ");
var line = util_1.default.format.apply(util_1.default, __spreadArray(["".concat(format, "\r\n")], args, false));
return new Promise(function (resolve) {
log(">> " + line);
_this.socket.write(line, "utf-8", function () {
_this.socket.once("data", function (data) {
resolve(_this.parseCodeLine(data.toString(), expectCode));
});
});
});
};
SMTP.prototype.verify = function (addr) {
return __awaiter(this, void 0, void 0, function () {
return __generator(this, function (_a) {
switch (_a.label) {
case 0:
// ehlo or ehlo first
return [4 /*yield*/, this.hello()];
case 1:
// ehlo or ehlo first
_a.sent();
return [2 /*return*/, this.cmd(250, "VRFY %s", addr)];
}
}
if (this.ext["AUTH"]) {
this.auth = this.ext["AUTH"].split(" ");
}
this.ext = ext;
});
});
};
SMTP.prototype.noop = function () {
return __awaiter(this, void 0, void 0, function () {
return __generator(this, function (_a) {
switch (_a.label) {
case 0:
// ehlo or ehlo first
return [4 /*yield*/, this.hello()];
case 1:
// ehlo or ehlo first
_a.sent();
return [2 /*return*/, this.cmd(250, "NOOP")];
}
});
});
};
// hello runs a hello exchange if needed.
SMTP.prototype.hello = function (name) {
if (name === void 0) { name = "hi"; }
return __awaiter(this, void 0, void 0, function () {
var resp;
return __generator(this, function (_a) {
switch (_a.label) {
case 0:
if (!!this.didHello) return [3 /*break*/, 3];
this.didHello = true;
return [4 /*yield*/, this.ehlo(name)];
case 1:
resp = _a.sent();
if (!!(200 <= resp.code && resp.code < 300)) return [3 /*break*/, 3];
return [4 /*yield*/, this.helo(name)];
case 2:
resp = _a.sent();
if (!(200 <= resp.code && resp.code < 300)) {
throw new error_1.SMTPError("smtp hello error: " + resp);
}
_a.label = 3;
case 3: return [2 /*return*/];
}
});
});
};
// helo sends the HELO greeting to the server. It should be used only when the
// server does not support ehlo.
SMTP.prototype.helo = function (name) {
if (name === void 0) { name = "hi"; }
return __awaiter(this, void 0, void 0, function () {
return __generator(this, function (_a) {
return [2 /*return*/, this.cmd(220, "HELO %s", name || this.localName)];
});
});
};
// ehlo sends the EHLO (extended hello) greeting to the server. It
// should be the preferred greeting for servers that support it.
SMTP.prototype.ehlo = function (name) {
if (name === void 0) { name = "hi"; }
return __awaiter(this, void 0, void 0, function () {
var _a, code, message, ext, extList, _i, extList_1, line, _b, k, v;
return __generator(this, function (_c) {
switch (_c.label) {
case 0: return [4 /*yield*/, this.cmd(250, "EHLO %s", name || this.localName)];
case 1:
_a = _c.sent(), code = _a.code, message = _a.message;
ext = {};
extList = message.split("\n");
if (extList.length > 1) {
if (extList.length > 1) {
extList.shift(); // remove first line
for (_i = 0, extList_1 = extList; _i < extList_1.length; _i++) {
line = extList_1[_i];
_b = line.split(" "), k = _b[0], v = _b.slice(1);
ext[k] = v.join(" ");
}
}
if (this.ext["AUTH"]) {
this.auth = this.ext["AUTH"].split(" ");
}
this.ext = ext;
}
return [2 /*return*/, { code: code, message: message }];
}
});
});
};
// StartTLS sends the STARTTLS command and encrypts all further communication.
// Only servers that advertise the STARTTLS extension support this function.
SMTP.prototype.startTLS = function (tlsOptions) {
if (tlsOptions === void 0) { tlsOptions = {}; }
return __awaiter(this, void 0, void 0, function () {
var _a, code, message;
return __generator(this, function (_b) {
switch (_b.label) {
case 0:
// ehlo or ehlo first
return [4 /*yield*/, this.hello()];
case 1:
// ehlo or ehlo first
_b.sent();
return [4 /*yield*/, this.cmd(220, "STARTTLS")];
case 2:
_a = _b.sent(), code = _a.code, message = _a.message;
this.tls = true;
return [4 /*yield*/, this.connect()];
case 3:
_b.sent();
return [2 /*return*/, this.ehlo()];
}
});
});
};
// public async login(user: string, password: string): Promise<IResponse> {}
// public async sendMail(
// from: string,
// to: string,
// msg: string
// ): Promise<IResponse> {}
// Quit sends QUIT command and closes the connection to the server.
SMTP.prototype.quit = function () {
return __awaiter(this, void 0, void 0, function () {
return __generator(this, function (_a) {
switch (_a.label) {
case 0:
// ehlo or ehlo first
return [4 /*yield*/, this.hello()];
case 1:
// ehlo or ehlo first
_a.sent();
return [2 /*return*/, this.cmd(221, "QUIT")];
}
});
});
};
SMTP.prototype.parseCodeLine = function (reply, expectCode) {
var lines = reply.split("\r\n");
var code;
var resp = [];
for (var _i = 0, lines_1 = lines; _i < lines_1.length; _i++) {
var line = lines_1[_i];
resp.push(line.substring(4).trim());
code = parseInt(line.substring(0, 3), 10);
if (line.substring(3, 4) != "-") {
break;
}
return [2 /*return*/, { code: code, message: message }];
}
});
});
};
// StartTLS sends the STARTTLS command and encrypts all further communication.
// Only servers that advertise the STARTTLS extension support this function.
SMTP.prototype.startTLS = function (tlsOptions) {
if (tlsOptions === void 0) {
tlsOptions = {};
}
return __awaiter(this, void 0, void 0, function () {
var _a, code, message;
return __generator(this, function (_b) {
switch (_b.label) {
case 0:
// ehlo or ehlo first
return [4 /*yield*/, this.hello()];
case 1:
// ehlo or ehlo first
_b.sent();
return [4 /*yield*/, this.cmd(220, "STARTTLS")];
case 2:
(_a = _b.sent()), (code = _a.code), (message = _a.message);
this.tls = true;
return [4 /*yield*/, this.connect()];
case 3:
_b.sent();
return [2 /*return*/, this.ehlo()];
if (expectCode !== code) {
throw new error_1.SMTPError("unexpected code: " + code);
}
});
});
};
// public async login(user: string, password: string): Promise<IResponse> {}
// public async sendMail(
// from: string,
// to: string,
// msg: string
// ): Promise<IResponse> {}
// Quit sends QUIT command and closes the connection to the server.
SMTP.prototype.quit = function () {
return __awaiter(this, void 0, void 0, function () {
return __generator(this, function (_a) {
switch (_a.label) {
case 0:
// ehlo or ehlo first
return [4 /*yield*/, this.hello()];
case 1:
// ehlo or ehlo first
_a.sent();
return [2 /*return*/, this.cmd(221, "QUIT")];
}
});
});
};
SMTP.prototype.parseCodeLine = function (reply, expectCode) {
var lines = reply.split("\r\n");
var code;
var resp = [];
for (var _i = 0, lines_1 = lines; _i < lines_1.length; _i++) {
var line = lines_1[_i];
resp.push(line.substring(4).trim());
code = parseInt(line.substring(0, 3), 10);
if (line.substring(3, 4) != "-") {
break;
}
}
if (expectCode !== code) {
throw new error_1.SMTPError("unexpected code: " + code);
}
return { code: code, message: resp.join("\n") };
};
return SMTP;
})();
return { code: code, message: resp.join("\n") };
};
return SMTP;
}());
exports.default = SMTP;
//# sourceMappingURL=index.js.map

2

package.json
{
"name": "smtp-fetch",
"version": "1.0.0",
"version": "1.0.1",
"main": "dist/index.js",

@@ -5,0 +5,0 @@ "types": "dist/index.d.ts",

38

tsconfig.json
{
"compilerOptions": {
/* Visit https://aka.ms/tsconfig.json to read more about this file */
// Recommended Node options have been incorporated from https://github.com/tsconfig/bases/blob/master/bases/node14.json
"target": "ES5",
"module": "commonjs",
"esModuleInterop": true,
// Overrides default in order to remove "dom" because this package shouldn't assume the presence of browser APIs
"lib": ["ES2022", "DOM"],
// Emit location
"outDir": "dist",
// Emit sourcemaps
"declarationMap": true,
"sourceMap": true,
"inlineSources": true,
// Emit type definitions
"declaration": true,
"esModuleInterop": true,
"outDir": "./dist",
"allowJs": true,
"target": "es5"
// Allow import package.json
"resolveJsonModule": true,
// Linter style rules
"noUnusedLocals": false, // Disabled because we use eslint for this.
"noUnusedParameters": true,
"noImplicitReturns": true,
"noFallthroughCasesInSwitch": true,
"noUncheckedIndexedAccess": true,
"noPropertyAccessFromIndexSignature": true,
"forceConsistentCasingInFileNames": true
},
"include": ["./src/**/*"]
"include": ["src/**/*", "src/index.d.tsd.tssrc/index.d.tsdex.d.ts"]
}
SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap

About

Packages

Stay in touch

Get open source security insights delivered straight into your inbox.

  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc