|
1 | 1 | /**
|
2 | 2 | * Event handlers for attachment create, and av scan result
|
3 | 3 | */
|
4 |
| -import _ from 'lodash'; |
5 | 4 | import Joi from 'joi';
|
6 |
| -import Promise from 'bluebird'; |
7 | 5 | import config from 'config';
|
8 | 6 | import util from '../../util';
|
9 | 7 | import { BUS_API_EVENT } from '../../constants';
|
@@ -36,12 +34,12 @@ async function attachmentScanResultKafkaHandler(app, topic, payload) {
|
36 | 34 | if (payload.isInfected) {
|
37 | 35 | // move to quarantine
|
38 | 36 | const destBucket = config.get('attachmentsQuarantineS3Bucket');
|
39 |
| - util.s3FileTransfer({ log: app.logger }, sourceBucket, payload.path, destBucket, payload.path) |
| 37 | + util.s3FileTransfer({ log: app.logger }, sourceBucket, payload.path, destBucket, payload.path); |
40 | 38 | app.logger.debug(`Attachment ${payload.fileName} is infected, moving to quarantine`);
|
41 | 39 | } else {
|
42 | 40 | // move to clean
|
43 | 41 | const destBucket = config.get('attachmentsS3Bucket');
|
44 |
| - util.s3FileTransfer({ log: app.logger }, sourceBucket, payload.path, destBucket, payload.path) |
| 42 | + util.s3FileTransfer({ log: app.logger }, sourceBucket, payload.path, destBucket, payload.path); |
45 | 43 | }
|
46 | 44 | }
|
47 | 45 |
|
@@ -79,7 +77,7 @@ async function attachmentCreatedKafkaHandler(app, topic, payload) {
|
79 | 77 | BUS_API_EVENT.AV_SCAN_REQUEST,
|
80 | 78 | avScanPayload,
|
81 | 79 | app.logger,
|
82 |
| - ) |
| 80 | + ); |
83 | 81 | }
|
84 | 82 |
|
85 | 83 | module.exports = {
|
|
0 commit comments