UNPKG

3.23 kBMarkdownView Raw
1# good-squeeze
2
3Simple transform streams useful in creating [good](https://github.com/hapijs/good) data pipelines.
4
5[![Build Status](https://travis-ci.org/hapijs/good-squeeze.svg?branch=master&style=flat)](https://travis-ci.org/hapijs/good-squeeze)
6![Current Version](https://img.shields.io/npm/v/good-squeeze.svg?style=flat)
7
8Lead Maintainer: [Adam Bretz](https://github.com/arb)
9
10## Usage
11
12good-squeeze is a collection of small transform streams. The `Squeeze` stream is useful for filtering events based on the good event options. The `SafeJson` stream is useful for stringifying objects to prevent circular object errors.
13
14## Methods
15
16### `Squeeze(events, [options])`
17
18Creates a new Squeeze transform stream where:
19
20- `events` an object where each key is a valid good event, and the value is a string or array of strings representing event tags. "\*" indicates no filtering. `null` and `undefined` are assumed to be "\*". Defaults to `{}`
21- `[options]` configuration object that gets passed to the Node [`Stream.Transform`](http://nodejs.org/api/stream.html#stream_class_stream_transform) constructor. **Note** `objectMode` is always `true` for all `Squeeze` objects.
22
23The transform stream only passes on events that satisfy the event filtering based on event name and tags. If the upstream event doesn't satisfy the filter, it is not continued down the pipe line.
24
25### `Squeeze.subscription(events)`
26
27A static method on `Squeeze` that creates a new event subscription map where:
28
29- `events` an object where each key is a valid good event, and the value is a string or array of strings representing event tags. "*" indicates no filtering. `null` and `undefined` are assumed to be "*".
30
31```js
32const Squeeze = require('good-squeeze');
33
34Squeeze.subscription({ log: 'user', ops: '*', request: ['hapi', 'foo'] });
35
36// Results in
37// {
38// log: [ 'user' ],
39// ops: [],
40// request: [ 'hapi', 'foo', 'hapi', 'foo' ]
41// }
42```
43
44Useful for creating an event subscription to be used with `Squeeze.filter` if you do not plan on creating a pipeline coming from good and instead want to manage event filtering manually.
45
46
47### `Squeeze.filter(subscription, data)`
48
49Returns `true` if the supplied `data.event` + `data.tags` should be reported based on `subscription` where:
50
51- `subscription` - a subscription map created by `Squeeze.subscription()`.
52- `data` - event object emitted from good/hapi which should contain the following keys:
53 - `event` - a string representing the event name of `data`
54 - `tags` - an array of strings representing tags associated with this event.
55
56### `SafeJson([options], [stringify])`
57
58Creates a new SafeJson transform stream where:
59
60- `[options]` configuration object that gets passed to the Node [`Stream.Transform`](http://nodejs.org/api/stream.html#stream_class_stream_transform) constructor. **Note** `objectMode` is always `true` for all `Squeeze` objects.
61- `[stringify]` configuration object for controlling how stringify is handled.
62 - `seperator` - string to append to each message. Defaults to "".
63
64The transform stream stringifys the incoming data and pipes it forward. It will not crash in the cases of circular references and will instead include a "~Circular" string in the result.