Compare commits

..

No commits in common. "master" and "v1.0.27" have entirely different histories.

17 changed files with 9023 additions and 11102 deletions

View File

@ -12,35 +12,30 @@ stages:
- release - release
- metadata - metadata
before_script:
- npm install -g @shipzone/npmci
# ==================== # ====================
# security stage # security stage
# ==================== # ====================
auditProductionDependencies: mirror:
image: registry.gitlab.com/hosttoday/ht-docker-node:npmci
stage: security stage: security
script: script:
- npmci npm prepare - npmci git mirror
- npmci command npm install --production --ignore-scripts
- npmci command npm config set registry https://registry.npmjs.org
- npmci command npm audit --audit-level=high --only=prod --production
tags: tags:
- lossless
- docker - docker
allow_failure: true - notpriv
auditDevDependencies: audit:
image: registry.gitlab.com/hosttoday/ht-docker-node:npmci image: registry.gitlab.com/hosttoday/ht-docker-node:npmci
stage: security stage: security
script: script:
- npmci npm prepare - npmci npm prepare
- npmci command npm install --ignore-scripts - npmci command npm install --ignore-scripts
- npmci command npm config set registry https://registry.npmjs.org - npmci command npm config set registry https://registry.npmjs.org
- npmci command npm audit --audit-level=high --only=dev - npmci command npm audit --audit-level=high
tags: tags:
- lossless
- docker - docker
allow_failure: true - notpriv
# ==================== # ====================
# test stage # test stage
@ -55,7 +50,9 @@ testStable:
- npmci npm test - npmci npm test
coverage: /\d+.?\d+?\%\s*coverage/ coverage: /\d+.?\d+?\%\s*coverage/
tags: tags:
- lossless
- docker - docker
- priv
testBuild: testBuild:
stage: test stage: test
@ -66,7 +63,9 @@ testBuild:
- npmci command npm run build - npmci command npm run build
coverage: /\d+.?\d+?\%\s*coverage/ coverage: /\d+.?\d+?\%\s*coverage/
tags: tags:
- lossless
- docker - docker
- notpriv
release: release:
stage: release stage: release
@ -86,12 +85,11 @@ release:
codequality: codequality:
stage: metadata stage: metadata
allow_failure: true allow_failure: true
only:
- tags
script: script:
- npmci command npm install -g typescript - npmci command npm install -g tslint typescript
- npmci npm prepare - npmci npm prepare
- npmci npm install - npmci npm install
- npmci command "tslint -c tslint.json ./ts/**/*.ts"
tags: tags:
- lossless - lossless
- docker - docker
@ -111,10 +109,11 @@ trigger:
pages: pages:
stage: metadata stage: metadata
script: script:
- npmci node install stable - npmci node install lts
- npmci command npm install -g @gitzone/tsdoc
- npmci npm prepare - npmci npm prepare
- npmci npm install - npmci npm install
- npmci command npm run buildDocs - npmci command tsdoc
tags: tags:
- lossless - lossless
- docker - docker

View File

@ -0,0 +1,8 @@
terminal:
image: registry.gitlab.com/hosttoday/ht-docker-node:stable
before_script:
- npm install -g npm-check
variables:
RAILS_ENV: "test"
NODE_ENV: "test"

4
.snyk Normal file
View File

@ -0,0 +1,4 @@
# Snyk (https://snyk.io) policy file, patches or ignores known vulnerabilities.
version: v1.13.5
ignore: {}
patch: {}

24
.vscode/launch.json vendored
View File

@ -2,10 +2,28 @@
"version": "0.2.0", "version": "0.2.0",
"configurations": [ "configurations": [
{ {
"command": "npm test", "name": "current file",
"name": "Run npm test", "type": "node",
"request": "launch", "request": "launch",
"type": "node-terminal" "args": [
"${relativeFile}"
],
"runtimeArgs": ["-r", "@gitzone/tsrun"],
"cwd": "${workspaceRoot}",
"protocol": "inspector",
"internalConsoleOptions": "openOnSessionStart"
},
{
"name": "test.ts",
"type": "node",
"request": "launch",
"args": [
"test/test.ts"
],
"runtimeArgs": ["-r", "@gitzone/tsrun"],
"cwd": "${workspaceRoot}",
"protocol": "inspector",
"internalConsoleOptions": "openOnSessionStart"
} }
] ]
} }

View File

@ -15,7 +15,7 @@
"properties": { "properties": {
"projectType": { "projectType": {
"type": "string", "type": "string",
"enum": ["website", "element", "service", "npm", "wcc"] "enum": ["website", "element", "service", "npm"]
} }
} }
} }

View File

@ -5,7 +5,7 @@
"githost": "gitlab.com", "githost": "gitlab.com",
"gitscope": "mojoio", "gitscope": "mojoio",
"gitrepo": "mailgun", "gitrepo": "mailgun",
"description": "an api abstraction package for mailgun", "shortDescription": "an api abstraction package for mailgun",
"npmPackagename": "@mojoio/mailgun", "npmPackagename": "@mojoio/mailgun",
"license": "MIT", "license": "MIT",
"projectDomain": "mojo.io" "projectDomain": "mojo.io"

19697
package-lock.json generated

File diff suppressed because it is too large Load Diff

View File

@ -1,32 +1,31 @@
{ {
"name": "@mojoio/mailgun", "name": "@mojoio/mailgun",
"version": "2.0.1", "version": "1.0.27",
"private": false, "private": false,
"description": "an api abstraction package for mailgun", "description": "an api abstraction package for mailgun",
"main": "dist_ts/index.js", "main": "dist_ts/index.js",
"typings": "dist_ts/index.d.ts", "typings": "dist_ts/index.d.ts",
"type": "module",
"author": "Lossless GmbH", "author": "Lossless GmbH",
"license": "MIT", "license": "MIT",
"scripts": { "scripts": {
"test": "(tstest test/)", "test": "(tstest test/)",
"build": "(tsbuild --web --allowimplicitany)", "build": "(tsbuild --web)",
"format": "(gitzone format)", "format": "(gitzone format)"
"buildDocs": "tsdoc"
}, },
"devDependencies": { "devDependencies": {
"@gitzone/tsbuild": "^2.1.65", "@gitzone/tsbuild": "^2.1.25",
"@gitzone/tstest": "^1.0.73", "@gitzone/tstest": "^1.0.43",
"@pushrocks/qenv": "^5.0.2", "@pushrocks/qenv": "^4.0.10",
"@pushrocks/tapbundle": "^5.0.4", "@pushrocks/tapbundle": "^3.2.9",
"@types/node": "^18.6.4" "@types/node": "^14.0.27",
"tslint": "^6.1.3",
"tslint-config-prettier": "^1.15.0"
}, },
"dependencies": { "dependencies": {
"@pushrocks/smartfile": "^10.0.4", "@pushrocks/smartfile": "^8.0.0",
"@pushrocks/smartmail": "^1.0.22", "@pushrocks/smartmail": "^1.0.18",
"@pushrocks/smartrequest": "^2.0.10", "@pushrocks/smartrequest": "^1.1.47",
"@pushrocks/smartsmtp": "^3.0.3", "@pushrocks/smartstring": "^3.0.18"
"@pushrocks/smartstring": "^4.0.2"
}, },
"files": [ "files": [
"ts/**/*", "ts/**/*",
@ -39,8 +38,5 @@
"cli.js", "cli.js",
"npmextra.json", "npmextra.json",
"readme.md" "readme.md"
],
"browserslist": [
"last 1 chrome versions"
] ]
} }

View File

@ -1,3 +1,2 @@
required: required:
- MAILGUN_API_TOKEN - MAILGUN_API_TOKEN
- MAILGUN_SMTP_CREDENTIALS

View File

@ -4,30 +4,24 @@ import * as smartmail from '@pushrocks/smartmail';
const testQenv = new Qenv('./', './.nogit'); const testQenv = new Qenv('./', './.nogit');
import * as mailgun from '../ts/index.js'; import * as mailgun from '../ts/index';
import { IMailgunMessage } from '../ts/index.js'; import { IMailgunMessage } from '../ts/index';
let testMailgunAccount: mailgun.MailgunAccount; let testMailgunAccount: mailgun.MailgunAccount;
let testSmartmail: smartmail.Smartmail<IMailgunMessage>; let testSmartmail: smartmail.Smartmail<IMailgunMessage>;
tap.test('should create a mailgun account', async () => { tap.test('should create a mailgun account', async () => {
testMailgunAccount = new mailgun.MailgunAccount({ testMailgunAccount = new mailgun.MailgunAccount(testQenv.getEnvVarOnDemand('MAILGUN_API_TOKEN'));
apiToken: testQenv.getEnvVarOnDemand('MAILGUN_API_TOKEN'), expect(testMailgunAccount).to.be.instanceOf(mailgun.MailgunAccount);
region: 'eu',
});
await testMailgunAccount.addSmtpCredentials(
testQenv.getEnvVarOnDemand('MAILGUN_SMTP_CREDENTIALS')
);
expect(testMailgunAccount).toBeInstanceOf(mailgun.MailgunAccount);
}); });
tap.test('should create a smartmail', async () => { tap.test('should create a smartmail', async () => {
testSmartmail = new smartmail.Smartmail({ testSmartmail = new smartmail.Smartmail({
body: 'hi there. This is the body.', body: 'hi there. This is the body.',
from: 'Lossless GmbH <noreply@mail.lossless.com>', from: 'Lossless GmbH <noreply@mail.lossless.com>',
subject: 'TestMessage from @mojoio/mailgun test', subject: 'TestMessage from @mojoio/mailgun test'
}); });
expect(testSmartmail).toBeInstanceOf(smartmail.Smartmail); return testSmartmail;
}); });
tap.test('should send a smartmail', async () => { tap.test('should send a smartmail', async () => {
@ -37,23 +31,19 @@ tap.test('should send a smartmail', async () => {
tap.test('should send a smartmail with empty body', async () => { tap.test('should send a smartmail with empty body', async () => {
const emptyBodySmartmail = new smartmail.Smartmail<IMailgunMessage>({ const emptyBodySmartmail = new smartmail.Smartmail<IMailgunMessage>({
body: '', body: '',
from: 'Lossless GmbH <noreply@mail.lossless.one>', from: 'Lossless GmbH <noreply@mail.lossless.com>',
subject: 'A message with no body from @mojoio/mailgun test', subject: 'A message with no body from @mojoio/mailgun test'
}); });
await testMailgunAccount.sendSmartMail( console.log('ok');
emptyBodySmartmail, await testMailgunAccount.sendSmartMail(emptyBodySmartmail, 'Sandbox Team <sandbox@mail.git.zone>');
'Sandbox Team <sandbox@mail.git.zone>' console.log('hey');
);
}); });
tap.test('should retrieve a mail using a retrieval url', async () => { tap.test('should retrieve a mail using a retrieval url', async () => {
const result = await testMailgunAccount.retrieveSmartMailFromMessageUrl( const result = await testMailgunAccount.retrieveSmartMailFromMessageUrl(
'https://sw.api.mailgun.net/v3/domains/mail.lossless.one/messages/AgMFnnnAKC8xp_dDa79LyoxhloxtaVmnRA==' 'https://sw.api.mailgun.net/v3/domains/mail.lossless.one/messages/AgMFnnnAKC8xp_dDa79LyoxhloxtaVmnRA=='
); );
console.log(result); if (result) {
// TODO handle empty body
if (false) {
result.options.subject = 'hi there. This is a testmail with attachment'; result.options.subject = 'hi there. This is a testmail with attachment';
result.options.from = 'noreply@mail.lossless.com'; result.options.from = 'noreply@mail.lossless.com';
await testMailgunAccount.sendSmartMail(result, 'Sandbox Team <sandbox@mail.git.zone>'); await testMailgunAccount.sendSmartMail(result, 'Sandbox Team <sandbox@mail.git.zone>');

View File

@ -1,8 +0,0 @@
/**
* autocreated commitinfo by @pushrocks/commitinfo
*/
export const commitinfo = {
name: '@mojoio/mailgun',
version: '2.0.1',
description: 'an api abstraction package for mailgun'
}

View File

@ -1,2 +1,2 @@
export * from './mailgun.classes.account.js'; export * from './mailgun.classes.account';
export * from './interfaces/index.js'; export * from './interfaces';

View File

@ -1,2 +1,2 @@
export * from './message.js'; export * from './message';
export * from './notification.js'; export * from './notification';

View File

@ -1,57 +1,26 @@
import * as plugins from './mailgun.plugins.js'; import * as plugins from './mailgun.plugins';
import * as interfaces from './interfaces/index.js'; import * as interfaces from './interfaces';
export interface IMailgunAccountContructorOptions {
apiToken: string;
region: 'eu' | 'us';
}
export class MailgunAccount { export class MailgunAccount {
public apiBaseUrl: string; public baseUrl = 'https://api.mailgun.net/v3';
public apiToken: string;
public options: IMailgunAccountContructorOptions; constructor(apiTokenArg: string) {
this.apiToken = apiTokenArg;
public smartSmtps: { [domain: string]: plugins.smartsmtp.Smartsmtp } = {};
constructor(optionsArg: IMailgunAccountContructorOptions) {
this.options = optionsArg;
this.apiBaseUrl =
this.options.region === 'eu'
? 'https://api.eu.mailgun.net/v3'
: 'https://api..mailgun.net/v3';
}
/**
* allows adding smtp credentials
* Format: [domain]|[username]|[password]
*/
public async addSmtpCredentials(credentials: string) {
const credentialArray = credentials.split('|');
if (credentialArray.length !== 3) {
throw new Error('credentials are in the wrong format');
}
this.smartSmtps[credentialArray[0]] =
await plugins.smartsmtp.Smartsmtp.createSmartsmtpWithRelay({
smtpServer: 'smtp.eu.mailgun.org',
smtpUser: credentialArray[1],
smtpPassword: credentialArray[2],
});
} }
public async getRequest(routeArg: string, binaryArg: boolean = false) { public async getRequest(routeArg: string, binaryArg: boolean = false) {
let requestUrl = routeArg; let requestUrl = routeArg;
const needsBaseUrlPrefix = !routeArg.startsWith('https://'); const needsBaseUrlPrefix = !routeArg.startsWith('https://');
if (needsBaseUrlPrefix) { needsBaseUrlPrefix ? (requestUrl = `${this.baseUrl}${routeArg}`) : null;
requestUrl = `${this.apiBaseUrl}${routeArg}`;
}
console.log(requestUrl); console.log(requestUrl);
const requestOptions: plugins.smartrequest.ISmartRequestOptions = { const requestOptions: plugins.smartrequest.ISmartRequestOptions = {
method: 'GET', method: 'GET',
headers: { headers: {
Authorization: `Basic ${plugins.smartstring.base64.encode(`api:${this.options.apiToken}`)}`, Authorization: `Basic ${plugins.smartstring.base64.encode(`api:${this.apiToken}`)}`,
'Content-Type': 'application/json', 'Content-Type': 'application/json'
}, },
keepAlive: false, keepAlive: false
}; };
let response: plugins.smartrequest.IExtendedIncomingMessage; let response: plugins.smartrequest.IExtendedIncomingMessage;
if (!binaryArg) { if (!binaryArg) {
@ -63,17 +32,14 @@ export class MailgunAccount {
} }
public async postFormData(routeArg: string, formFields: plugins.smartrequest.IFormField[]) { public async postFormData(routeArg: string, formFields: plugins.smartrequest.IFormField[]) {
const requestUrl = `${this.apiBaseUrl}${routeArg}`; const requestUrl = `${this.baseUrl}${routeArg}`; // TODO;
console.log(requestUrl);
const response = await plugins.smartrequest.postFormData( const response = await plugins.smartrequest.postFormData(
requestUrl, requestUrl,
{ {
headers: { headers: {
Authorization: `Basic ${plugins.smartstring.base64.encode( Authorization: `Basic ${plugins.smartstring.base64.encode(`api:${this.apiToken}`)}`
`api:${this.options.apiToken}`
)}`,
}, },
keepAlive: false, keepAlive: false
}, },
formFields formFields
); );
@ -93,24 +59,34 @@ export class MailgunAccount {
{ {
name: 'from', name: 'from',
type: 'string', type: 'string',
payload: smartmailArg.options.from, payload: smartmailArg.options.from
}, },
{ {
name: 'to', name: 'to',
type: 'string', type: 'string',
payload: toArg, payload: toArg
}, },
{ {
name: 'subject', name: 'subject',
type: 'string', type: 'string',
payload: smartmailArg.getSubject(dataArg), payload: smartmailArg.getSubject(dataArg)
}, }
{ ];
if (smartmailArg.getBody(dataArg)) {
formFields.push({
name: 'html', name: 'html',
type: 'string', type: 'string',
payload: smartmailArg.getBody(dataArg), payload: smartmailArg.getBody(dataArg)
}, });
]; } else {
console.log('message has no body');
formFields.push({
name: 'html',
type: 'string',
payload: 'The sender did not provide a bodytext.'
});
}
console.log(smartmailArg.attachments); console.log(smartmailArg.attachments);
@ -119,44 +95,20 @@ export class MailgunAccount {
name: 'attachment', name: 'attachment',
type: 'Buffer', type: 'Buffer',
payload: attachment.contentBuffer, payload: attachment.contentBuffer,
fileName: attachment.parsedPath.base, fileName: attachment.parsedPath.base
}); });
} }
if (smartmailArg.getBody(dataArg)) {
console.log('All requirements for API met');
const response = await this.postFormData(`/${domain}/messages`, formFields); const response = await this.postFormData(`/${domain}/messages`, formFields);
if (response.statusCode === 200) { if (response.statusCode === 200) {
console.log(
`Sent mail with subject ${smartmailArg.getSubject(
dataArg
)} to ${toArg} using the mailgun API`
);
return response.body; return response.body;
} else { } else {
console.log(response.body); console.log(response.body);
throw new Error('could not send email'); throw new Error('could not send email');
} }
} else {
console.log(
'An empty body was provided. This does not work via the API, but using SMTP instead.'
);
const wantedSmartsmtp = this.smartSmtps[domain];
if (!wantedSmartsmtp) {
console.log('did not find appropriate smtp credentials');
return;
}
await wantedSmartsmtp.sendSmartMail(smartmailArg, toArg);
console.log(
`Sent mail with subject "${smartmailArg.getSubject(
dataArg
)}" to "${toArg}" using an smtp transport over Mailgun.`
);
}
} }
public async retrieveSmartMailFromMessageUrl(messageUrlArg: string) { public async retrieveSmartMailFromMessageUrl(messageUrlArg: string) {
console.log(`retrieving message for ${messageUrlArg}`);
const response = await this.getRequest(messageUrlArg); const response = await this.getRequest(messageUrlArg);
if (response.statusCode === 404) { if (response.statusCode === 404) {
console.log(response.body.message); console.log(response.body.message);
@ -167,7 +119,7 @@ export class MailgunAccount {
from: responseBody.From, from: responseBody.From,
body: responseBody['body-html'], body: responseBody['body-html'],
subject: responseBody.Subject, subject: responseBody.Subject,
creationObjectRef: responseBody, creationObjectRef: responseBody
}); });
// lets care about attachments // lets care about attachments
@ -179,7 +131,7 @@ export class MailgunAccount {
new plugins.smartfile.Smartfile({ new plugins.smartfile.Smartfile({
path: `./${attachmentName}`, path: `./${attachmentName}`,
base: `./${attachmentName}`, base: `./${attachmentName}`,
contentBuffer: attachmentContents.body, contentBuffer: attachmentContents.body
}) })
); );
} }

View File

@ -2,7 +2,6 @@
import * as smartfile from '@pushrocks/smartfile'; import * as smartfile from '@pushrocks/smartfile';
import * as smartmail from '@pushrocks/smartmail'; import * as smartmail from '@pushrocks/smartmail';
import * as smartrequest from '@pushrocks/smartrequest'; import * as smartrequest from '@pushrocks/smartrequest';
import * as smartsmtp from '@pushrocks/smartsmtp';
import * as smartstring from '@pushrocks/smartstring'; import * as smartstring from '@pushrocks/smartstring';
export { smartfile, smartmail, smartrequest, smartsmtp, smartstring }; export { smartfile, smartmail, smartrequest, smartstring };

View File

@ -1,10 +0,0 @@
{
"compilerOptions": {
"experimentalDecorators": true,
"useDefineForClassFields": false,
"target": "ES2022",
"module": "ES2022",
"moduleResolution": "nodenext",
"esModuleInterop": true
}
}

17
tslint.json Normal file
View File

@ -0,0 +1,17 @@
{
"extends": ["tslint:latest", "tslint-config-prettier"],
"rules": {
"semicolon": [true, "always"],
"no-console": false,
"ordered-imports": false,
"object-literal-sort-keys": false,
"member-ordering": {
"options":{
"order": [
"static-method"
]
}
}
},
"defaultSeverity": "warning"
}