Newman's Personal Motorcade
    Have ideas to improve npm?Join in the discussion! »

    @ebay/oja-pubsub

    2.0.11 • Public • Published

    oja-pubsub

    Downloads

    This module is a subset of eBay Oja framework.

    The module defines generic actions that can be used to organize actions into publishers and subscribers that are completely disconnected from each others.

    Comparing to Oja v1.0 this one is pub/sub on steroids - it defines pub/sub pattern using dependency injection.

    Installation

    $ npm install @ebay/oja-pubsub --save
    

    Actions

    • action('oja/subscribe', 'topic', listener) - subscribe to the event.
    • action('oja/unsubscribe', 'topic', listener): Promise - unsubscribe from the event, returns true if subscriber was found and removed.
    • action('oja/dispatch', 'topic', ...args): Promise<[subscriberResponse]> - dispatch event/args to the subscribers.
    • action('oja/route', 'topic', ...args): Promise - dispatch event/args to only one subscriber in round robin mode.

    Listener

    function (eventType, ...eventData) {}

    Usage

    • Subscribing to the event:
    const { createContext } = require('@ebay/oja-action');
    const context = await createContext();
    // subscribe
    const listener = await context.action('oja/subscribe', 'topic', (eventType, eventData) => {
        console.log(eventData);
    });
    • Dispatching an event:
    await context.action('oja/dispatch', 'topic', eventData);
    • Routing an event to only one subscriber:
    const { createContext } = require('@ebay/oja-action');
    const context = await createContext();
    // subscribe
    const listener1 = await context.action('oja/subscribe', 'topic', (eventType, eventData) => {
        console.log('sub1', eventData); // >> one, three
        return 'ok1';
    });
    const listener2 = await context.action('oja/subscribe', 'topic', (eventType, eventData) => {
        console.log('sub2', eventData); // >> two, four
        return 'ok2'
    });
    await context.action('oja/route', 'topic', 'one'); // >> ok1
    await context.action('oja/route', 'topic', 'two'); // >> ok2
    await context.action('oja/route', 'topic', 'three'); // >> ok1
    await context.action('oja/route', 'topic', 'four'); // >> ok2
    • Unsubscribing from the event:
    await context.action('oja/unsubscribe', 'topic', listener);

    Subscribing as part of other action

    context => {
        const listener = context.action(
            'oja/subscribe', 'topic', (eventType, eventData) => {
                console.log(eventData);
            }
        );
    }

    To trigger subscription, one needs to trigger the respective action.

    Oja reset event

    In some cases it may be required to reset any cache related to oja.

    @ebay/oja-action makes an optional action call 'oja/extension/context/reset' that if extended can be used to reset respective caches. The only problem is it allows a single extenstion while we may need to reset more then one module. That's where pub/sub pattern comes handy - the module extends reset action and dispatches the event that can be listened by many subscribers.

    // this examples requires these modules to be installed: oja-context, oja-action, oja-pubsub
    // register reset listeners
    await context.action('oja/subscribe', 'oja:reset:event', (eventType, eventData) => {
        console.log('sub1:', eventType); // >>> sub1: oja:reset:event
        console.log(eventData); // >>> undefined, nothing to dispatch yet
    });
     
    await context.action('oja/subscribe', 'oja:reset:event', (eventType, eventData) => {
        console.log('sub2:', eventType); // >>> sub2: oja:reset:event
        console.log(eventData); // >>> undefined, nothing to dispatch yet
    });
     
    // trigger reset somewhere in the code
    await context.action('oja/reset');

    Install

    npm i @ebay/oja-pubsub

    DownloadsWeekly Downloads

    5

    Version

    2.0.11

    License

    MIT

    Unpacked Size

    11.3 kB

    Total Files

    12

    Last publish

    Collaborators

    • avatar
    • avatar
    • avatar
    • avatar
    • avatar
    • avatar
    • avatar
    • avatar
    • avatar
    • avatar
    • avatar
    • avatar
    • avatar
    • avatar
    • avatar
    • avatar