public/mailtrain
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Merged PR #740.

Browse source
This commit is contained in:
Tomas Bures 2019-12-07 11:21:19 +01:00
parent e6b1cf8add
commit 7df580d7e2
1 changed files with 7 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
server/lib/message-sender.js
View file

@ -588,7 +588,7 @@ async function sendQueuedMessage(queuedMessage) {
encryptionKeys: msgData.encryptionKeys
});
} catch (err) {
await knex.insert({
await knex('queued').insert({
id: queuedMessage.id,
send_configuration: queuedMessage.send_configuration,
type: queuedMessage.type,
@ -599,16 +599,18 @@ async function sendQueuedMessage(queuedMessage) {
}
if (messageType === MessageType.TRIGGERED) {
await knex.raw(knex('campaign_messages').insert({
await knex('campaign_messages').insert({
hash_email: result.subscriptionGrouped.hash_email,
subscription: result.subscriptionGrouped.id,
campaign: campaign.id,
list: result.list.id,
subscription: result.subscriptionGrouped.id,
send_configuration: queuedMessage.send_configuration,
status: CampaignMessageStatus.SENT,
response: result.response,
response_id: result.response_id,
hash_email: result.subscriptionGrouped.hash_email
}).toString().replace(/^insert/i, 'insert ignore'));
updated: new Date()
});
await knex('campaigns').where('id', campaign.id).increment('delivered');
}