API

An event-driven IPC implementation for NodeJS using unix file sockets

Docs | Source | Releases | NPM

Table of Contents

About

Usage

Advanced Usage

API (you are here)

• Important Changes
• Classes
  • Server
    • new Server()
    • Event: ‘close’
    • Event: ‘closed’
    • Event: ‘connection’
    • Event: ‘error’
    • Event: ‘listening’
    • Event: ‘message’
    • Event: ‘message.topic’
    • server.close()
    • server.send(topic, message, clientId)
    • server.listen()
    • server.broadcast(topic, message)
  • Client
    • new Client()
    • Event: ‘close’
    • Event: ‘closed’
    • Event: ‘connect’
    • Event: ‘connectError’
    • Event: ‘disconnect’
    • Event: ‘error’
    • Event: ‘message’
    • Event: ‘message.topic’
    • Event: ‘reconnect’
    • client.close()
    • client.connect()
    • client.send(topic, message)
• Interfaces (Classes)
  • Transcoder
    • transcoder.createDecoder()
    • transcoder.socketEncoding
    • transcoder.createEncoder()
  • MessageWrapper
    • messageWrapper.topic
    • messageWrapper.message
• Interfaces (Callbacks/Functions)
  • decoderFunc
  • decodedCallback
  • decoderFactoryFunc
  • encodedCallback
  • encoderFunc
  • encoderFactoryFunc

Important Changes

v0.4.0:

• Client id is now a v4 uuid. This is part of the official interface and implementations can rely on this detail (thanks to @aamiryu7 for making the case).

v0.3.0:

• closed event Deprecated in favor of close event for both Server and Client

v0.2.0:

• Introduced transcoder option for both Client and Server
• (Breaking change) Dropped connectionClose event. Applications should now listen for events on the underlying net.Socket (now provided as part of the connection event)
• (Breaking change) clientId is now a string (It is still numeric, but applications should not rely on this detail).
• The server-side connection event and client-side connect event now provide the underlying net.Socket instance. Some applications may benefit from listening directly to socket events.
• The client-side connect event now provides a net.Socket instance.
• Documentation has been enhanced to make note that some events are in response to events the specific events being emitted from the underlying net.Socket events.
• The messageError event has been removed. The error event has been enhanced to emit an EncodeError, SendError, or DecodeError to cover cases previously covered by messageError.
• Some error events would include a second, undocumented arg which provided the client id. This is no longer the case; error listeners will now always be given exactly one argument – the Error.
• Calling client.connect() or server.listen() a second time will now emit an error event instead of throwing the Error. This is more consistent than have a couple of cases which throw instead of emitting an error event.

Classes

These are instantiable classes what will pass an instanceof check. There are also a number of interfaces in the next section which are, at best, duck-typed at key spots in the module.

Server

This library follows a standard server/client pattern. There is one server which listens for connections from one or more clients. Intuitively, the Server class provides the interface for establishing the server side of the equation.

The server can receive messages from any of the clients. It can also send() messsages to a specific client or it can broadcast() a message to all connected clients.

new Server(options)

• options (object) - The server configuration options
  • socketFile (string): The path to the socket file to use when it is told to “listen”. See server.listen() for more details on how this file is handled.
  • [transcoder=jsonTranscoder] (Transcoder) - A custom Transcoder. Useful when encoding/decoding messages with JSON is not sufficient.

Creates a new server, but it does not start listening until you call server.listen(). You can immediately attach listeners to the Server instance.

Event: ‘close’

Emitted when the server has stopped listening for connections and all existing connections have been ended.

Event: ‘closed’

Deprecated in v0.3.0 - scheduled for removal in v1.0.0

Alias of close event.

Event: ‘connection’

• clientId (string) - The id of the client. Use this to send a message to the client. This is a version 4 UUID.
• connection (net.Socket) - The NodeJS net.Socket of the connection.

Emitted when a client establishes a connection to the server.

Event: ‘error’

• error (Error) - The error that occurred.

Emitted when an error occurs. Any errors emitted by the underlying net.Server will also be repeated via this event as well as those from the underlying net.Socket instances of each connected client.

Additionally, these specific error classes may be emitted.

The following conditions will cause Server to emit an error event:

• (EncodeError) - When the message can not be encoded by the active Transcoder.
• (SendAfterCloseError) - When this method is called after server.close() is called.
• (BadClientError) - When a message is sent to a client that does not exist. To avoid this error, stop sending messages to clients once their underlying net.Socket – provided by the connection event – emits a close event.

Event: ‘listening’

Emitted when the server is ready for incoming connections.

Event: ‘message’

• message (any) - The message from the client. By default, this can be any JSON deserializable type (including null) but a custom Transcoder can be used to change these rules.
• topic (string) - The topic of the message as declared by the client.
• clientId (string) - The id of the client. Use this to send a message to the client.

Emitted when a message is received, regardless of the topic.

Event: ‘message.topic’

• message (any) - The message from the client. By default, this can be any JSON deserializable type (including null) but a custom Transcoder can be used to change these rules.
• clientId (string) - The connection id of the client. Use this to send a message to the client.

Emitted when a message with the specified topic is received. For example, messages with a topic of “dessert” would emit the message.dessert event. (Yum!)

server.broadcast(topic, message)

• topic (string) - The topic to publish the message under. If an empty value, none is used as the value.
• message (any) - The message. May be any JSON serializable value (including null)

Sends a message to all connected clients. On the client-side, this message can be heard by listening for the message or the message.topic event.

If there are no connected clients, this method will quietly do nothing.

server.listen()

Tells the server to start listening for client connections. This is an async operation and the listening event will emitted when the server is ready for connections.

This may only be called once per instance. Calling this method a second time will emit an error event.

server.send(topic, message, clientId)

• topic (string) - The topic to publish the message under. If an empty value is given, none is used as the message topic.
• message (*) - The message. By default, this may be any JSON serializable value (including null) but a custom Transcoder can be used to change these rules.
• clientId (string) - The id of the client to send the message to. This is usually obtained by capturing it when the client connects or sends the server a message.

Sends a message to a specific, connected, client. On the client-side, this message can be heard by listening for the message or the message.topic event.

server.close()

Closes all active connections and stops listening for new connections. This is an asynchronous operation. Once the server is fully closed, the close event will be emitted.

Any future calls to server.send() or server.broadcast() will cause the server to emit an error event.

Once this method has been called, a new Server instance is needed to re-establish a connection with the server.

Client

This library follows a standard server/client pattern. There is one server which listens for connections from one or more clients. Intuitively, the Client class provides the interface for establishing the client side of the equation.

The client can receive messages from the server and it can send() messages to the server.

new Client(options)

• options (object) - The client configuration options
  • socketFile (string): The path to the socket file to connect to.
  • [transcoder=jsonTranscoder] (Transcoder) - A custom Transcoder. Useful when encoding/decoding messages with JSON is not sufficient.
  • [retryDelay=1000] (number|{min: int, max:int}) - If an integer, the number of milliseconds to wait between connection attempts. If an object, each delay will be a random value between the min and max values.
  • [reconnectDelay=100] (number|{min: int, max:int}) - If an integer, the number of milliseconds to wait before automatically reconnecting after an unexpected disconnect. If an object, each delay will be a random value between the min and max values.

Creates a new client, but it does not connect until you call client.connect(). You can immediately attach listeners to the client instance.

Event: ‘close’

Emitted when client.close() has been called and the client connection has been fully closed.

Event: ‘closed’

Deprecated in v0.3.0 - scheduled for removal in v1.0.0

Alias of close event.

Event: ‘connect’

• connection (net.Socket) - The NodeJS net.Socket of the connection.

Emitted when the Client establishes a connection with the server. This occurs during initial connection and during reconnect scenarios.

Event: ‘connectError’

• error (Error) - The error that occurred.

Emitted when a connection attempt fails.

This event is common when the server is not yet listening. Because of the auto-retry mechanism, this event may be emitted several times while the client waits for the server to start listening. For some applications, waiting “forever” for the server to start may make sense; for others, you can use this event count the number of connection attempts and “give up” after some limit.

Event: ‘disconnect’

Emitted when a client unexpectedly loses connection. This is distinct from the close event that is a result of client.close() being called.

The client emits this when it both conditions are met:

• A close event is heard from the underlying net.Socket
• client.close() has not been called

This event is emitted when the client hears an close event from the underlying net.Socket. Some applications may benefit from listening directly to the socket events.

Event: ‘error’

• error (Error) - The error that occurred.

Emitted when an error occurs.

After establishing a connection, the Client listens for error events from the underlying net.Socket and repeats them as a local event.

Additionally, the following Error objects may be emitted.

• (EncodeError) - When the message can not be encoded by the active Transcoder.
• (SendAfterCloseError) - When a client.send() after client.close() is called.
• (NoServerError) - When client.send() is called and there is no active server connection. The connect, reconnect, and disconnect events to avoid this error.

Event: ‘message’

• message (any) - The message from the client. By default, this can be any JSON deserializable type (including null). By using of a custom transcoder that can be expanded!
• topic (string) - The topic of the message as declared by the server.

Emitted when a message is received, regardless of the topic.

Event: ‘message.topic’

• message (any) - The message from the server. By default, this can be any JSON deserializable type (including null) but a custom Transcoder can be used to influence the type range.

Emitted when a message with the specified topic is received. For example, messages with a topic of “dessert” would emit the message.dessert event. (Yum!)

Event: ‘reconnect’

An duplication of the connect that is only emitted when a client successfully performs an automatic reconnect. This event will always be immediately preceded by the connect event. It is useful when you want additional behavior in reconnect scenarios. You can also leverage EventEmitter.once() to handle initial connections and reconnects differently:

client.once('connect', /* ... */);  // Only respond to the first connect event
client.on('reconnect', /* ... */);  // But respond to every reconnect event

client.close()

Permanently closes the connection. There will be no automatic reconnect attempts. This is an asynchronous operation; the close event will be emitted when the connection to the client has been completely closed.

Any future call to client.send() will cause the client to emit an error event.

client.connect()

Tells the client to connect to the server. This is an async operation and the connect event will be emitted once the connection has been established.

This may only be called once per instance. Calling this method a second time will emit an error event.

If the connection fails, a connectError event will be emitted and the client will automatically try again after a the delay defined by options.retryDelay. This cycle will be repeated until a connection is established or until client.close() is called. You can limit the number of retries by listening and counting the connectError events, then calling client.close() when you decide that it is time to “give up”.

Once connected a connect will be emitted providing access to the underlying net.Socket instance.

If the underlying socket emits a close event, the behavior varies depending on whether or not client.close()` has been called:

• If client.close() has been called, the client will emit a close and no more messages may be sent from this instance.
• if client.close() has NOT been called, the client will emit a disconnect event and it will automatically try to reconnect. The reconnection routine is identical to the initial connection routine with the exception that a reconnect event will be emitted in addition to the connect event.

client.send(topic, message)

• topic (string, required) - The topic to publish the message under. If an empty value, none is used as the value.
• message (*, required) - The message. By default, this may be any JSON serializable value (including null) but a custom Transcoder can be used to change these rules.

Sends a message to the server. On the server-side, this message can be heard by listening for the message or the message.topic event.

EncodeError

DecodeError

SendError

SendAfterCloseError

NoServerError

BadClientError

Interfaces (Classes)

Interfaces (Callbacks/Functions)