npmpackage.info

aedes-cached-persistence

Abstract class to write an Aedes persistence with in-process caching of subscriptions

9.0.0

MIT

JavaScript

Installations

npm install aedes-cached-persistence

Pull Requests

Open

2

Total

51

Closed

14

Merged

35

Issues

Open

0

Total

3

Closed

3

Releases

Release 9.0.0

v9.0.0

Published on 17 May 2022

Release 8.1.1

v8.1.1

Published on 03 Feb 2021

Release 8.1.0

v8.1.0

Published on 28 Feb 2020

v8.0.0

Published on 05 Sept 2019

v7.0.0

Published on 20 Nov 2018

v6.0.0

Published on 15 Aug 2017

View all 13 releases

Developer

moscajs

Developer Guide

BETA

Module System

CommonJS

Min. Node Version

>=14

Typescript Support

Yes

Node Version

16.3.0

NPM Version

7.15.1 Statistics

5 Stars

109 Commits

12 Forks

8 Watching

1 Branches

8 Contributors

Updated on 18 Sept 2024

Languages

JavaScript (76.47%)

TypeScript (23.53%)

Total Downloads

Cumulative downloads

Total Downloads

546,997

Last day

56.2%

859

Compared to previous day

Last week

81.9%

5,644

Compared to previous week

Last month

29.5%

16,107

Compared to previous month

Last year

-11.1%

135,718

Compared to previous year

Daily Downloads

Weekly Downloads

Monthly Downloads

Yearly Downloads

Dependencies

aedes-persistence fastparallel multistream qlobber

Dev Dependencies

aedes concat-stream faucet license-checker mqemitter nyc pump release-it snazzy standard tape through2 tsd

Versions

aedes-cached-persistence

Abstract class to write an Aedes persistence with in-process caching of subscriptions. It implements the API defined by aedes-persistence.

aedes-cached-persistence

Install

To install aedes-cached-persistence, simply use npm:

1npm install aedes-cached-persistence --save

Provided methods

Implement another persistence

Inheritance

In order to reuse aedes-cached-persistence, you need to:

1const CachedPersistence = require('aedes-cached-persistence')
2
3// if you need http://npm.im/aedes-packet, it is available
4// from this module as well
5// const { Packet } = CachedPersistence
6
7class MyPersistence extends CachedPersistence {
8    constructor(opts) {
9       super(opts)
10    }
11    addSubscriptions(client, subs, cb) {
12        // ..persistence specific implementation..
13        // call super._addedSubscriptions when you are done
14        super._addedSubscriptions(client, subs.map(mapSub), cb)
15    }
16    removeSubscriptions(client, subs, cb) {
17        // ..persistence specific implementation..
18        // call super._removedSubscriptions when you are done
19        super._removedSubscriptions(client, subs.map(mapSub), cb)
20    }
21}
22
23function mapSub (sub) {
24  return { topic: sub.topic }
25}

Tests

A persistence needs to pass all tests defined in ./abstract.js. You can import and use that test suite in the following manner:

1var test = require('tape').test
2var myperst = require('./')
3var abs = require('aedes-cached-persistence/abstract')
4
5abs({
6  test: test,
7  persistence: myperst
8})

If you require some async stuff before returning, a callback is also supported:

1var test = require('tape').test
2var myperst = require('./')
3var abs = require('aedes-persistence/abstract')
4var clean = require('./clean') // invented module
5
6abs({
7  test: test,
8  buildEmitter: require('mymqemitter'), // optional
9  persistence: function build (cb) {
10    clean(function (err) {
11      cb(err, myperst())
12    })
13  }
14})

License

MIT

No vulnerabilities found.

10

Binary-Artifacts

Determines if the project has generated executable (binary) artifacts in the source repository.

10

Dangerous-Workflow

Determines if the project's GitHub Action workflows avoid dangerous patterns.

10

Vulnerabilities

Determines if the project has open, known unfixed vulnerabilities.

10

License

Determines if the project has defined a license.

7

Code-Review

Determines if the project requires human code review before pull requests (aka merge requests) are merged.

0

Maintained

Determines if the project is "actively maintained".

0

Token-Permissions

Determines if the project's workflows follow the principle of least privilege.

0

Pinned-Dependencies

Determines if the project has declared and pinned the dependencies of its build process.

0

CII-Best-Practices

Determines if the project has an OpenSSF (formerly CII) Best Practices Badge.

0

Fuzzing

Determines if the project uses fuzzing.

0

Branch-Protection

Determines if the default and release branches are protected with GitHub's branch protection settings.

0

Security-Policy

Determines if the project has published a security policy.

0

SAST

Determines if the project uses static code analysis.

Score

4.1

/10

Last Scanned on 2024-11-18

The Open Source Security Foundation is a cross-industry collaboration to improve the security of open source software (OSS). The Scorecard provides security health metrics for open source projects.

Learn More

Other packages similar to aedes-cached-persistence

aedes-persistence

9.1.2

The spec for an Aedes persistence, with abstract tests and a fast in-memory implementation.

aedes

0.51.3

Stream-based MQTT broker

aedes-persistence-redis

10.0.0

Aedes persistence, backed by redis

aedes-persistence-mongodb

9.1.1

MongoDB persistence for Aedes