2023-01-20 16:32:50 +03:00
|
|
|
const {agentProvider, fixtureManager, mockManager, matchers, sleep} = require('../../utils/e2e-framework');
|
|
|
|
|
const models = require('../../../core/server/models');
|
|
|
|
|
const assert = require('assert');
|
|
|
|
|
const urlUtils = require('../../../core/shared/url-utils');
|
|
|
|
|
const nock = require('nock');
|
2023-01-30 14:11:30 +03:00
|
|
|
const jobsService = require('../../../core/server/services/jobs');
|
2023-01-20 16:32:50 +03:00
|
|
|
|
|
|
|
|
describe('Webmentions (receiving)', function () {
|
|
|
|
|
let agent;
|
2023-01-25 16:10:29 +03:00
|
|
|
let emailMockReceiver;
|
2023-01-20 16:32:50 +03:00
|
|
|
before(async function () {
|
|
|
|
|
agent = await agentProvider.getWebmentionsAPIAgent();
|
|
|
|
|
await fixtureManager.init('posts');
|
|
|
|
|
nock.disableNetConnect();
|
2023-01-25 16:10:29 +03:00
|
|
|
mockManager.mockLabsEnabled('webmentionEmail');
|
2023-01-20 16:32:50 +03:00
|
|
|
});
|
|
|
|
|
|
|
|
|
|
after(function () {
|
|
|
|
|
nock.cleanAll();
|
|
|
|
|
nock.enableNetConnect();
|
|
|
|
|
});
|
2023-01-30 14:11:30 +03:00
|
|
|
|
2023-01-25 16:10:29 +03:00
|
|
|
beforeEach(function () {
|
|
|
|
|
emailMockReceiver = mockManager.mockMail();
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
afterEach(function () {
|
|
|
|
|
mockManager.restore();
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
it('can receive a webmention', async function () {
|
2023-01-30 14:11:30 +03:00
|
|
|
const processWebmentionJob = jobsService.awaitCompletion('processWebmention');
|
|
|
|
|
const targetUrl = new URL('integrations/', urlUtils.getSiteUrl());
|
|
|
|
|
const sourceUrl = new URL('http://testpage.com/external-article/');
|
2023-01-25 16:10:29 +03:00
|
|
|
const html = `
|
|
|
|
|
<html><head><title>Test Page</title><meta name="description" content="Test description"><meta name="author" content="John Doe"></head><body></body></html>
|
|
|
|
|
`;
|
|
|
|
|
|
2023-01-30 14:11:30 +03:00
|
|
|
nock(targetUrl.origin)
|
|
|
|
|
.head(targetUrl.pathname)
|
|
|
|
|
.reply(200);
|
|
|
|
|
|
|
|
|
|
nock(sourceUrl.origin)
|
|
|
|
|
.get(sourceUrl.pathname)
|
|
|
|
|
.reply(200, html, {'Content-Type': 'text/html'});
|
2023-01-25 16:10:29 +03:00
|
|
|
await agent.post('/receive')
|
|
|
|
|
.body({
|
2023-01-30 14:11:30 +03:00
|
|
|
source: sourceUrl.href,
|
|
|
|
|
target: targetUrl.href,
|
2023-01-25 16:10:29 +03:00
|
|
|
withExtension: true // test payload recorded
|
|
|
|
|
})
|
|
|
|
|
.expectStatus(202);
|
|
|
|
|
|
2023-01-30 14:11:30 +03:00
|
|
|
await processWebmentionJob;
|
2023-01-25 16:10:29 +03:00
|
|
|
|
|
|
|
|
const mention = await models.Mention.findOne({source: 'http://testpage.com/external-article/'});
|
|
|
|
|
assert(mention);
|
|
|
|
|
assert.equal(mention.get('target'), urlUtils.getSiteUrl() + 'integrations/');
|
|
|
|
|
assert.ok(mention.get('resource_id'));
|
|
|
|
|
assert.equal(mention.get('resource_type'), 'post');
|
|
|
|
|
assert.equal(mention.get('source_title'), 'Test Page');
|
|
|
|
|
assert.equal(mention.get('source_excerpt'), 'Test description');
|
|
|
|
|
assert.equal(mention.get('source_author'), 'John Doe');
|
|
|
|
|
assert.equal(mention.get('payload'), JSON.stringify({
|
|
|
|
|
withExtension: true
|
|
|
|
|
}));
|
|
|
|
|
});
|
|
|
|
|
|
2023-01-30 14:11:30 +03:00
|
|
|
it('can receive a webmention to homepage', async function () {
|
|
|
|
|
const processWebmentionJob = jobsService.awaitCompletion('processWebmention');
|
|
|
|
|
const targetUrl = new URL(urlUtils.getSiteUrl());
|
|
|
|
|
const sourceUrl = new URL('http://testpage.com/external-article-2/');
|
2023-01-25 16:10:29 +03:00
|
|
|
const html = `
|
|
|
|
|
<html><head><title>Test Page</title><meta name="description" content="Test description"><meta name="author" content="John Doe"></head><body></body></html>
|
|
|
|
|
`;
|
2023-01-30 14:11:30 +03:00
|
|
|
|
|
|
|
|
nock(targetUrl.origin)
|
|
|
|
|
.head(targetUrl.pathname)
|
|
|
|
|
.reply(200);
|
|
|
|
|
|
|
|
|
|
nock(sourceUrl.origin)
|
|
|
|
|
.get(sourceUrl.pathname)
|
|
|
|
|
.reply(200, html, {'Content-Type': 'text/html'});
|
|
|
|
|
|
|
|
|
|
await agent.post('/receive')
|
|
|
|
|
.body({
|
|
|
|
|
source: sourceUrl.href,
|
|
|
|
|
target: targetUrl.href
|
|
|
|
|
})
|
|
|
|
|
.expectStatus(202);
|
|
|
|
|
|
|
|
|
|
await processWebmentionJob;
|
|
|
|
|
|
|
|
|
|
const mention = await models.Mention.findOne({source: 'http://testpage.com/external-article-2/'});
|
|
|
|
|
assert(mention);
|
|
|
|
|
assert.equal(mention.get('target'), urlUtils.getSiteUrl());
|
|
|
|
|
assert.ok(!mention.get('resource_id'));
|
|
|
|
|
assert.equal(mention.get('resource_type'), null);
|
|
|
|
|
assert.equal(mention.get('source_title'), 'Test Page');
|
|
|
|
|
assert.equal(mention.get('source_excerpt'), 'Test description');
|
|
|
|
|
assert.equal(mention.get('source_author'), 'John Doe');
|
|
|
|
|
assert.equal(mention.get('payload'), JSON.stringify({}));
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
it('can send an email notification for a new webmention', async function () {
|
|
|
|
|
const processWebmentionJob = jobsService.awaitCompletion('processWebmention');
|
|
|
|
|
const targetUrl = new URL('integrations/', urlUtils.getSiteUrl());
|
|
|
|
|
const sourceUrl = new URL('http://testpage.com/external-article-123-email-test/');
|
|
|
|
|
const html = `
|
|
|
|
|
<html><head><title>Test Page</title><meta name="description" content="Test description"><meta name="author" content="John Doe"></head><body></body></html>
|
|
|
|
|
`;
|
|
|
|
|
|
|
|
|
|
nock(targetUrl.origin)
|
|
|
|
|
.head(targetUrl.pathname)
|
|
|
|
|
.reply(200);
|
|
|
|
|
|
|
|
|
|
nock(sourceUrl.origin)
|
|
|
|
|
.get(sourceUrl.pathname)
|
|
|
|
|
.reply(200, html, {'Content-Type': 'text/html'});
|
2023-01-25 16:10:29 +03:00
|
|
|
|
|
|
|
|
await agent.post('/receive/')
|
|
|
|
|
.body({
|
2023-01-30 14:11:30 +03:00
|
|
|
source: sourceUrl.href,
|
|
|
|
|
target: targetUrl.href
|
2023-01-25 16:10:29 +03:00
|
|
|
})
|
|
|
|
|
.expectStatus(202);
|
2023-01-30 14:11:30 +03:00
|
|
|
|
|
|
|
|
await processWebmentionJob;
|
2023-01-25 16:10:29 +03:00
|
|
|
|
|
|
|
|
const users = await models.User.findAll();
|
|
|
|
|
users.forEach(async (user) => {
|
|
|
|
|
await mockManager.assert.sentEmail({
|
|
|
|
|
subject: 'You\'ve been mentioned!',
|
|
|
|
|
to: user.toJSON().email
|
2023-01-30 14:11:30 +03:00
|
|
|
});
|
2023-01-25 16:10:29 +03:00
|
|
|
});
|
|
|
|
|
emailMockReceiver.sentEmailCount(users.length);
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
it('does not send notification with flag disabled', async function () {
|
|
|
|
|
mockManager.mockLabsDisabled('webmentionEmail');
|
2023-01-30 14:11:30 +03:00
|
|
|
const processWebmentionJob = jobsService.awaitCompletion('processWebmention');
|
|
|
|
|
const targetUrl = new URL('integrations/', urlUtils.getSiteUrl());
|
|
|
|
|
const sourceUrl = new URL('http://testpage.com/external-article-123-email-test/');
|
2023-01-25 16:10:29 +03:00
|
|
|
const html = `
|
2023-01-30 14:11:30 +03:00
|
|
|
<html><head><title>Test Page</title><meta name="description" content="Test description"><meta name="author" content="John Doe"></head><body></body></html>
|
|
|
|
|
`;
|
|
|
|
|
|
|
|
|
|
nock(targetUrl.origin)
|
|
|
|
|
.head(targetUrl.pathname)
|
|
|
|
|
.reply(200);
|
|
|
|
|
|
|
|
|
|
nock(sourceUrl.origin)
|
|
|
|
|
.get(sourceUrl.pathname)
|
|
|
|
|
.reply(200, html, {'Content-Type': 'text/html'});
|
2023-01-25 16:10:29 +03:00
|
|
|
|
|
|
|
|
await agent.post('/receive/')
|
|
|
|
|
.body({
|
2023-01-30 14:11:30 +03:00
|
|
|
source: sourceUrl.href,
|
|
|
|
|
target: targetUrl.href
|
2023-01-25 16:10:29 +03:00
|
|
|
})
|
|
|
|
|
.expectStatus(202);
|
2023-01-30 14:11:30 +03:00
|
|
|
|
|
|
|
|
await processWebmentionJob;
|
|
|
|
|
|
2023-01-25 16:10:29 +03:00
|
|
|
emailMockReceiver.sentEmailCount(0);
|
|
|
|
|
});
|
2023-01-20 16:32:50 +03:00
|
|
|
});
|
