example.js

import { NOTIFICATION_QUEUE_NAME } from './../../shared/config.js';
import { notificationProducer } from './../notificationProducer.js';
import { MOST_VIRAL } from './../../shared/constants/routes.js';
import { logger } from './../../shared/logger.js';

export default function mostViral (accountId, postId) {
    // This module doesn't need to post to Redis,
    // because one mostViral post triggers a notification
    const payloads = [
        {
            topic: NOTIFICATION_QUEUE_NAME,
            messages: { type: MOST_VIRAL, accountId, postId },
        }
    ];
    notificationProducer.send(payloads, (err) => {
        if (err) {
            logger.error(`Queue producer error: ${err}`);
        }
    });

    return payloads;
}