Plugins & Microservices

// Register a custom WordPress action
add_action('save_post', function($post_id) {
    // Skip autosaves
    if (defined('DOING_AUTOSAVE')) return;

    // Process the saved data
    $data = get_post_meta($post_id, '_custom_field', true);
    do_action('my_plugin_data_saved', $data);
});

// Express microservice endpoint
app.post('/api/process', async (req, res) => {
    const { data } = req.body;

    // Validate input
    if (!data) return res.status(400).json({
        error: 'Missing data'
    });

    // Process and respond
    const result = await processData(data);
    res.json({ success: true, result });
});

// BullMQ queue worker
const worker = new Worker('email-queue', async (job) => {
    const { to, subject, body } = job.data;

    // Send email with retry logic
    await sendEmail({ to, subject, body });

    return { sent: true, timestamp: Date.now() };
}, {
    concurrency: 5,
    limiter: { max: 100, duration: 60000 }
});