PubNub v4 JS Storage & Playback sample code

storage-playback.js

// =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
// Count of Channel Messages (up to 100)
// =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
const getPreviousCountMessages = (count) => {
    pubnub.history({
        channel: 'time-publish-example-channel',
        count
    }, function (status, response) {
        // `count` Array of previous messages is in:
        // response.messages;
    });
});

// =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
// Time slice of messages (up to 100 at a time)
// =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
const getPreviousMessagesTimeSlice = () => {
    const nowJsTimestamp = new Date().getTime();
    const tenMinutes = 10 * 60 * 1000;
    pubnub.history({
        channel: 'time-publish-example-channel',
        start: nowJsTimestamp + '0000',
        end: (nowJsTimestamp - tenMinutes) + '0000',
    }, function (status, response) {
        // Array of previous messages is in:
        // response.messages;
    });
});

// =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
// Time slice of messages (unlimited messages, can be dangerous for clients)
// =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
function messageHandler(status, response) {
    const msgs = response.messages;
    const start = response.startTimeToken;
    const end = response.endTimeToken;
    
    // Do something with `response.messages`
  
    // Subsequent fetch for more historical messages
    if (msgs.length === 100) {
        getAllMessages(start);
    }
}

function getAllMessages(nowJsTimestamp) {
    if (typeof nowJsTimestamp !== 'string') {
        nowJsTimestamp = new Date().getTime() + '0000';
    }

    pubnub.history({
        channel: 'time-publish-example-channel',
        start : nowJsTimestamp,
        stringifiedTimeToken: true,
    }, messageHandler);
}