-
Notifications
You must be signed in to change notification settings - Fork 5
Documentation
var simples = require('simples');
simples([port, options, callback])
port: number
options: object
callback: function
simpleS needs only the port number and it sets up a HTTP server on this port.
var server = simples(80);
// or simpler
var server = simples(); // the server will be set on the port 80
To set up an HTTPS server the options object is needed with key
and cert
or pfx
attributes, these will be the paths to the .pem
or .pfx
files, see https
and tls
core modules for more details, the options
object is the same used there with the only difference that simpleS resolve the content of key
and cert
or pfx
attributes, so the key
and cert
or pfx
attributes are required. The requests on HTTPS are always listen on port 443. Automatically, with the HTTPS server an HTTP server is created which will have the same routes as the HTTPS server (see Routing). To check the protocol the connection.protocol
property is used (see Connection Interface).
var server = simples(443, {
key: 'path/to/key.pem',
cert: 'path/to/cert.pem'
});
// or just
var server = simples({ // the server will be set on port 443
key: 'path/to/key.pem',
cert: 'path/to/cert.pem'
});
To redirect the client to HTTPS, use a structure like this:
server.get('/', function (connection) {
if (connection.protocol === 'http') {
connection.redirect('https://' + connection.url.host + connection.url.path, true);
} else {
// Application logic
}
});
or try simples-redirect middleware with some more options.
The third parameter callback
is used to know when the server has started running.
.start([port, callback])
port: number
callback: function()
Start listening for requests on the provided port. If the server is already started then simpleS will restart the server and will listen on the new provided port. Can have an optional callback. All connection in simpleS are kept alive and the restart can take few seconds for closing alive http and ws connections. While restarting, no new connection will be accepted but existing connections will be still served. This method is called automatically when a new simpleS instance is created, it is not needed to call it explicitly on server creation. The purpose of this method is to provide a way to switch port. Returns current instance, so calls can be chained.
server.start(80, function () {
// Application logic
});
.stop([callback])
callback: function()
Stop the server. Can have an optional callback. All connection in simpleS are kept alive and the closing can take few seconds for closing alive http and ws connections. While closing, no new connection will be accepted but existing connections will be still served. Returns current instance, so calls can be chained.
server.stop(function () {
// Application logic
});
Any simpleS instance is an event emitter, all possible errors that may appear at the level of the server can be caught using the usual error event listener attached to the instance object. The same approach can be applied for HTTP and WS hosts, in this case the error listeners will catch errors to the level of the host. It is recommended to attach error event listeners to the server and all its hosts to prevent any undesired behavior.
server.on('error', function (error) {
// Handle any fatal errors that may occur at the level of the server
});
host.on('error', function (error) {
// Handle any error that occurs at the level of the host
});
.host(name[, config])
name: string
config: object
simpleS can serve multiple domains on the same server and port, using .host()
method it is simple to specify which host should use which routes. By default, simpleS has the main host which will route all existent routes of the simpleS instance, this is vital for one host on server or when it is needed a general behavior for incoming requests. This method will create and configure a new host or will return an existing host with a changed configuration. Returns current instance, so calls can be chained.
var host = server.host('example.com');
.config(config)
config: object
Change the configuration of the host. Returns current instance, so calls can be chained. Possible attributes for the configuration:
Compression configuration:
compression: {
enabled: true, // Activate the compression, by default the compression is enabled
filter: /^.+$/i, // Filter content types that will be compressed, by default all kinds of file types are compressed
options: null, // Compression options, see more on http://nodejs.org/api/zlib.html#zlib_options
preferred: 'deflate' // The prefereed compression type, can be 'deflate' or 'gzip', by default is `deflate`
}
origins: array of strings // []
- Set the origins accepted by the host. By default, the server will accept requests only from the current host. To accept requests from any origin use '*'
, if this parameter is used as the first parameter then all next origins are rejected. 'null'
is used for local file system origin. These limitations will work for HTTP
GET
and POST
request and even for WebSocket
requests. The current host should not be added in the list, it is accepted anyway.
['null', 'localhost', 'example.com'] // Will accept requests only from these 3 hosts
['*', 'example.com'] // Will accept requests from all hosts except 'example.com'
referers: array of strings // []
- Set the referers that can use the static resources of the host. By default, the server will response to all referers. To accept all referers except some specific the first parameter should be *
. The current host should not be added in the list, it is served anyway. The server will respond with error 404 to unacceptable referers.
['*', 'example.com'] // will respond to all referers except 'example.com'
['example.com', 'test.com'] // Will respond only to these 2 referers
Session configuration:
session: {
enabled: false, // Activate the session, by default sessions are disabled
store: simples.store(3600), // Session store, the default is simples memcached store with 1 hour timeout
}
Sessions are stored by default inside an memcached container, to define another container for them it is needed an object instance with the next methods:
.get(id, callback)
- should return inside the callback function the session container if it is found, if the session defined by the id
parameter is not found then the callback function should return null
;
.set(id, session, callback)
- should add the session container defined by the first two paramters and execute the callback function when the session container is saved to the sessions storage.
Note: The third party session store also have to implement its own technique for cleaning up expired sessions.
.middleware(callback[, remove])
callback: function(connection, next)
remove: boolean
Each host accepts middlewares to be implemented, which allow to add some additional implementations with a global behavior which are not available out of the box. The middlewares can manipulate the connection object and to call the next middleware or the internal simpleS functional. The order in which middlewares are defined has importance because they will be executed in the same way. simpleS will prevent the same middleware to be attached. To remove a middleware from the list its reference should be provided as the first parameter and the second parameter should be a true
value. Returns current instance, so calls can be chained.
host.middleware(function (connection, next) {
if (connection.path = '/restricted' && !connection.session.user) {
connection.end('You do not have right to be here');
next(true); // Will stop the middleware chain and connection routing
} else {
next(); // Will continue to the next middleware if it exists or will continue to connection routing
}
});
// another example to set X-Powered-By Header for all connections
host.middleware(function (connection, next) {
connection.header('X-Powered-By', 'simpleS');
next();
});
.engine(engine)
engine: object
To render templates it is necessary to define the needed template engine which has a .render()
method. The rendering method should accept 1, 2 or 3 parameters, source
, imports
and/or callback, source
should be a string that defines the path to the templates, imports
may be an optional parameter and should be an object containing data to be injected in the templates, callback
is a function that is called if the result is generated asynchronously. The templates are rendered using the .render()
method of the Connection Interface. If the template engine does not correspond to these requirements then a wrapper object should be applied. This method is applicable on each host independently (see Virtual Hosting). Returns current instance, so calls can be chained. Recommended template engine: simpleT.
var noopEngine = {
render: function (source) {
console.log(source);
return source;
}
};
host.engine(noopEngine);
// Wrapped unsupported template engine example
var unsupportedEngine = {
renderFile: function (imports, source) {
console.log(source);
return source;
}
};
host.engine({
render: function (source, imports) {
unsupportedEngine.renderFile(imports, source);
}
});
All the methods described below are applicable on each host independently (see Virtual Hosting). All route paths are case sensitive and should contain only paths without queries to exclude possible unexpected behavior and to ensure improved performance, undesired data will be cut off. All routes are relative to the host root and may not begin with /
, simpleS will ignore it anyway. The routes may be fixed or can contain named parameters. Fixed routes are fast and simple, while the second ones are more flexible and handy in complex applications. The named parameters in the advanced routes are mandatory, if at least one component of the route is absent in the url then the url is not routed.
'user/john/action/thinking'; // Fixed route
'user/:user/action/:action'; // Advanced routing with named parameters
/*
This route will match this request url:
/user/mary/action/cooking
with parameters:
{
user: 'mary',
action: 'cooking'
}
*/
'user/:user/*'; // Advanced routing that can match anything
/*
This route will match these request urls:
/user/mary/home
/user/mary/friends/john
*/
.all(route, result)
route: array[strings] or string
result: function(connection) or string
Listen for all supported types of requests (DELETE
, GET
, HEAD
, POST
and PUT
) and uses a callback function with connection as parameter or a string for rendering (see Connection.render()
), this is useful for defining general behavior for all types of requests. This method has less priority then the other methods described below to allow specific behavior for routes. Returns current instance, so calls can be chained.
.del(route, result)
route: array[strings] or string
result: function(connection) or string
Listen for DELETE
requests and uses a callback function with connection as parameter or a string for rendering (see Connection.render()
). Returns current instance, so calls can be chained.
.get(route, result)
route: array[strings] or string
result: function(connection) or string
Listen for GET
requests and uses a callback function with connection as parameter or a string for rendering (see Connection.render()
). Returns current instance, so calls can be chained.
.post(route, result)
route: array[strings] or string
result: function(connection) or string
Listen for POST
requests and uses a callback function with connection as parameter or a string for rendering (see Connection.render()
). Returns current instance, so calls can be chained.
.put(route, result)
route: array[strings] or string
result: function(connection) or string
Listen for PUT
requests and uses a callback function with connection as parameter or a string for rendering (see Connection.render()
). Returns current instance, so calls can be chained.
.route(verb, route, result)
verb: 'all', 'del', 'get', 'put' or 'post'
route: array[strings] or string
result: function(connection) or string
Can add listeners for all types of routes. The methods described below are just shortcuts to this method. For better legibility use shortcuts. Returns current instance, so calls can be chained.
.error(code, result)
code: 404, 405 or 500
result: function(connection) or string
Listen for errors that can have place and uses a callback function with connection as parameter or a string for rendering (see Connection.render()
). Only one method call can be used for a specific error code, if more .error()
methods will be called for the same error code only the last will be used for routing. Possible values for error codes are: 404 (Not Found), 405 (Method Not Allowed) and 500 (Internal Server Error). If no error routes are defined, then the default ones will be used. Returns current instance, so calls can be chained.
host.all('/', function (connection) {
// Application logic
});
host.get([
'/',
'/index'
], function (connection) {
// Application logic
});
host.error(404, 'not_found.ejs');
host.post([
'/',
'/index'
], 'index.ejs');
.serve(directory[, callback])
directory: string
callback: function(connection, files)
directory
is the local path to a folder that contains static files (for example: images, css or js files), this folder will serve as the root folder for the server. simpleS will return response status 304 (Not Modified) if the files have not been changed since last visit of the client. Only one folder should be used to serve static files and the method .serve()
should be called only once, it reads recursively and asynchronously the content of the files inside the folder and store them in memory. The folder with static files can contain other folders, their content will be also served. The provided path must be relative to the current working directory. The callback
parameter is the same as for GET
and POST
requests, but it is triggered only when the client accesses the root of a sub folder of the folder with static files and get and aditional parameter files
, which is an array of objects representing the contained files and folders, these objects contain the name and the stats of the files and folders, the callback
parameter is optional. All files are dynamically cached for better performance, so the provided folder should contain only necessary files and folders not to abuse the memory of the server. Returns current instance, so calls can be chained.
host.serve('root', function (connection, files) {
// Application logic
});
.leave([type, route])
type: 'all', 'del', 'error', 'get', 'post', 'put' or 'serve'
route: 404, 405 or 500 with type 'error' and array[strings] or string with other types
Removes a specific route, a set of routes, a specific type of routes or all routes. If the type and the route is specified, then the route or the set of routes of this type are removed. If only the type is specified, then all routes of this type will be removed. If no parameters are specified, then the routes will be set in their default values. Routes should be specified in the same way that these were added. Returns current instance, so calls can be chained.
host.leave('post'); // All POST routes are removed
host.leave('get', '/nothing'); // One, selected, GET route is removed
host.leave('serve'); // Only one parameter needed, removes the cached static files
host.leave('all', [ // Removes the selected routes for routes with general behavior defined
'/home',
'/index'
]);
host.leave(404); // Removes the route for '404' error code and set the default route for it
host.leave(); // Removes all routes and set default error routes
The parameter provided in callbacks for routing requests is an object that contains data about the current request and the data sent to the client. The connection interface wraps the request and the response objects that comes from the Node.JS server, these objects can be used for compatibility with some other third party modules. The connection is a transform stream, see stream
core module for more details.
{
cookies: {
user: 'me',
pass: 'password'
},
headers: {
host: 'localhost:12345',
'user-agent': 'myBrowser',
accept: 'text/html',
'accept-language': 'ro;q=0.8,en;q=0.6',
'accept-encoding': 'gzip, deflate',
cookie: 'user=me; pass=password'
},
host: 'localhost',
ip: '127.0.0.1',
langs: [
'ro',
'en'
],
method: 'GET',
query: {},
params: {},
path: '/',
protocol: 'http',
request: { /* Node.JS server request object */ },
response: { /* Node.JS server response object */ },
session: {},
url: {
/* These will never be filled
auth: null,
hash: null,
*/
host: 'localhost:12345',
hostname: 'localhost',
href: 'http://localhost:12345/',
pathname: '/',
path: '/',
port: '12345',
protocol: 'http:',
query: {},
search: '',
slashes: true
}
/* methods */
}
An object that contains the cookies provided by the client.
An object that contains the HTTP headers of the request.
The hostname from the Host
header.
The remote ip address of the request.
An array of strings that represents languages accepted by the client in the order of their relevance.
The HTTP method of the request, it can be DELETE
, GET
, HEAD
, POST
and PUT
for usual requests, but can have a different value on error 405
.
The object that contains named parameters from the route. This object is only populated when the request url match a specific route with named parameters. The named parameters represents strings that are limited only by /
or the end of the url.
The pathname of the url of the request.
The name of the protocol of the request, can be http
or https
.
The object that contains parsed query string from the url.
The Node.JS server request object instance, may be used for compatibility with some third party modules, not recommended to be used because of some possible side effects.
The Node.JS server response object instance, may be used for compatibility with some third party modules, not recommended to be used because of some possible side effects.
A container used to keep important data on the server-side, the clients have access to this data using the _session
cookie sent automatically, the _session
cookie has a value of 40 hexadecimal characters which will ensure security for 1.46 * 10 ^ 48
values. The session cookie is protected by _hash
cookie also with a width of 40 hexadecimal characters which is a hash from the _session
key and a secret value. The session is available only before calling the .end()
method of the connection so all manipulations should be made before the content of the connection is sent to the client, this rule is valid for both HTTP and WS connections.
The url of the request split in components, see url
core module for more details.
config: object
Receive and parse data that comes from the client. Is designed to process JSON
, urlencoded
and multipart/form-data
. The raw data can be received using plain
callback function, the form
object will behave as a readable stream. It is possible to limit the length of the request data by specifying the limit
attribute in bytes. It is recommended to always handle errors that may raise while parsing the requests by attaching error
event listener. The structure of the config object:
connection.parse({
limit: 1024 * 1024, // 1 MB
plain: function (form) {
// Form as readable stream
form.on('readable', function () {
this.read();
}).on('end', function () {
// do something
});
// or form.pipe(wstream);
// Form error handling
form.on('error', function (error) {
error;
});
},
json: function (form) {
// Get form result
form.on('end', function () {
form.result;
});
// Form error handling
form.on('error', function (error) {
error;
});
},
multipart: function (form) {
// Get form fields
form.on('field', function (field) {
field.name;
if (field.filename) { // file received
field.filename;
field.type; // Content-Type of the file
}
field.on('readable', function () {
this.read();
}).on('end', function () {
// do something
});
// or field.pipe(wstream);
// Field error handling
field.on('error', function (error) {
error;
});
});
// Check for form ending
form.on('end', function () {
// Do something
});
// Form error handling
form.on('error', function (error) {
error;
});
},
urlencoded: function (form) {
// Get form result
form.on('end', function () {
form.result;
});
// Form error handling
form.on('error', function (error) {
error;
});
}
});
name: string
value: string
attributes: object
Sets the cookies sent to the client, providing a name, a value and an object to configure the expiration time, to limit the domain and the path and to specify if the cookie is http only. To make a cookie to be removed on the client the expiration time should be set in 0
. Can be used multiple times, but before writing any data to the connection. Returns current instance, so calls can be chained.
connection.cookie('user', 'me', {
expires: 3600, // or maxAge: 3600, Set the expiration time of the cookie in seconds
path: '/path/', // Path of the cookie, should be defined only if it is different from the root, the root slash may be omitted, it will be added
domain: 'localhost', // Domain of the cookie, should be defined only if it is different from the current host
secure: false, // Set if the cookie is secured and should be used only with HTTPS
httpOnly: false, // Set if the cookie should not be modfied from client-side
});
name: string
value: array[strings], boolean, number, string or null
Sets, gets or removes a header of the response. Usually simpleS manages the headers of the response by itself setting the cookies, the languages, the content type or when redirecting the client, in these cases the method .header()
should not be used. If the header already exists in the list then its value will be replaced. To send multiple headers with the same name the value should be an array of strings. If the value
parameter is not defined then the value of the previously set header defined by the name
parameter is returned, in other cases the current instance is returned, so calls can be chained. If the value
parameter is null
then the header defined by the name
parameter is removed from the response. Bolean and numeric values are stringified before being applied.
connection.header('ETag', '0123456789'); // Set the 'ETag' header as '0123456789'
connection.header('ETag'); // => '0123456789'
connection.header('ETag', null); // The 'ETag' header is being removed
connection.header('ETag'); // => undefined
value: null or string
Sets, gets or removes the language of the response. Should be used only once before writing any data to the connection. If the value
parameter is not defined then the value of the previously set language is returned, in other cases the current instance is returned, so calls can be chained. If the value
parameter is null
then the Content-Language
header is is removed from the response.
connection.lang('ro'); // Set the 'Content-Language' header as 'ro'
connection.lang(); // => 'ro'
connection.lang(null); // The 'Content-Language' header is being removed
connection.lang(); // => undefined
links: object
Define the relations of the current location with the other locations and populate Link
header. Returns current instance, so calls can be chained.
connection.link({
next: '/page/2',
prev: '/page/0'
});
// Link: </page/2>; rel="next", </page/0>; rel="prev"
location: string
permanent: boolean
Redirects the client to the provided location. If the redirect is permanent then the second parameter should be set as true. For permanent redirects the code 302
is set, for temporary redirects - 301
. Should not be used with the other methods except .cookie()
, which should be placed before. Returns current instance, so calls can be chained.
connection.redirect('/index', true);
code: number
Sets or gets the status code of the response. If the code
parameter is not defined then the current status code is returned. Returns current instance, so calls can be chained.
type: string
override: boolean
Sets, gets or removes the type of the content of the response. Default is 'html'. By default uses one of 100 content types defined in mime.js, which can be edited to add more content types. Should be used only once before writing any data to the connection. If the content type header is not set correctly or the exact value of the type is known it is possible to override using the second parameter with true value and setting the first parameter as a valid content type. The second parameter is optional. If the required type is unknown application/octet-stream
will be applied. If the type
parameter is not defined then the value of the previously set content type is returned, in other cases the current instance is returned, so calls can be chained. If the type
parameter is null
then the Content-Type
header is removed from the response, it is not recommended to remove the Content-Type
from the response. By default the text/html;charset=utf-8
type is set.
connection.type('txt'); // Set the 'Content-Type' header as 'text/plain;charset=utf-8'
connection.type(); // => 'text/plain;charset=utf-8'
connection.type('text/plain', true);
connection.type(); // => 'text/plain'
timeout: number
Each connection has a 5 seconds timeout for inactivity on the socket to prevent too many connections in the same time. To change the value of this timeout the .keep()
method is called with the a new value in miliseconds, 0
for removing the timeout. Returns current instance, so calls can be chained.
connection.keep(); // or connection.keep(0); removes the timeout
connection.keep(10000); // sets the timeout for 10 seconds
Writes to the connection stream, same as stream.writable.write
Ends the connection stream, same as stream.writable.end
data: any value
replacer: array[numbers or strings] or function(key, value)
space: number or string
Writes preformatted data to the connection stream and ends the connection, implements the functionality of JSON.stringify()
for arrays, booleans, numbers and objects, buffers and strings are sent as they are. If the connection does not have a Content-Type
defined and the data
parameter is not a buffer nor a string then it will have the type application/json
. Should be used only once and should not be used with .write()
or .end()
methods.
connection.send(['Hello', 'World']);
location: string
type: string
override: boolean
Get the content of the file located on the specified location and write it to the connection stream. Will set the content type of the file, can have the parameters from the .type()
method. Should be used only once and should not be used with .write()
or .end()
methods.
connection.drain('path/to/index.html', 'text/html', true);
source: string
imports: object
Renders the response using the template engine defined by the host in .engine()
method (see Templating). Should be used only once and should not be used with .write()
or .end()
methods.
connection.render('Hello <%= world %>', {
world: 'World'
});
stream: writable stream
data: any data
Log data to a defined stream or to the process.stdout by default. The data may contain some special tokens to insert useful data. Accepted tokens:
%req[HEADER]
- insert the value of a request header
%res[HEADER]
- insert the value of a response header
%protocol
- insert the protocol used by the connection (http(s)
or ws(s)
)
%method
- insert the method of the request
%host
- insert the hostname of the request
%path
- insert the pathname of the request
%ip
- insert the remote ip address
%status
- insert the status code of the response
%lang
- insert the defined Content-Language
header for the response
%type
- insert the defined Content-Type
header for the response
Time related tokens:
%date
- insert the string representing current date
%short-date
- insert the current date in the format dd.mm.yyyy
%time
- insert the current time in the format hh:mm:ss
%short-time
- insert the current time in the format hh:mm
%timestamp
- insert the UNIX time value
%year
- insert the current year as a 4 digit number
%month
- insert the current month of the year
%day
- insert the current day of the month
%hour
- insert the current hour of the day
%minute
- insert the current minute of the hour
%second
- insert the current second of the minute
callback: function()
Closes the connection and append an optional callback function to the finish
event. It is similar to the .end()
method but has only the callback parameter, can be used as a semantic synonym of the .end()
method.
connection.close(function () {
console.log('Connection closed');
});
Destroy the underlaying network socket, it is mostly used internally by the framework and is not recommended in resulting apps.
The WebSocket host is linked to the current or the main HTTP host (see Virtual Hosting).
.ws(location[, config], listener)
location: string
config: object
listener: function(connection)
Create a WebSocket host and listen for WebSocket connections. The host is set on the specified location, can be configured to limit messages size by setting the limit
attribute in the config
parameter in bytes, default is 1048576 (1 MiB). The host can work in two modes, advanced
and raw
, in the raw
mode only one type of messages can be send, it works faster but does not suppose any semantics for the messages, advanced
mode allows multiple types of messages differenciated by different events, it is more flexible but involves more resources. To specify the type of the content which will be sent via the WebSocket connection the type
parameter should be defined as binary
or text
, by default is text
.
var echo = server.ws('/', {
limit: 1024,
mode: 'raw',
type: 'binary'
}, function (connection) {
// Application logic
});
config: object
callback: function(connection)
Restarts the WebSocket host with new configuration and callback. The missing configuration parameters will not be changed. Returns current instance, so calls can be chained.
echo.open({
limit: 512,
}, function (connection) {
// Application logic
});
event: string
data: string or buffer
filter: function(element, index, array)
Sends a message to all connected clients. Clients can be filtered by providing the filter
parameter, equivalent to Array.filter()
. Returns current instance, so calls can be chained.
echo.broadcast('HelloWorld', function (element, index, array) {
return element.protocols.indexOf('echo') >= 0; // Will send the message to clients that use "chat" as a sub protocol
});
name: string
filter: function(element, index, array)
Opens a new channel with the provided name. If filter
is defined, then all the connections of the WebSocket host that respect the filter callback will be bound to the channel. The channel is bound to the WebSocket host. See WebSocket Channel for more information.
Destroy all existing connections and remove the host from the WebSocket hosts list.
The object that represents the current WebSocket connection. The WebSocket connection is an writable stream, see stream
core module for more details, and has some attributes from connection interface to handle needed data from the handshake request.
.cookies
See Connection Interface .cookies
.
.headers
See Connection Interface .headers
.
.host
See Connection Interface .host
.
.ip
See Connection Interface .ip
.
.langs
See Connection Interface .langs
.
.protocols
The array of protocols of the WebSocket connection.
.query
The object that contains the queries from the handshake HTTP request.
.session
See Connection Interface .session
.
.url
See Connection Interface .url
.
.write(chunk[, encoding, callback])
Writes to the connection socket, same as stream.writable.write
.end([chunk, encoding, callback])
Ends the connection socket, same as stream.writable.end
.log([stream, ]data)
See Connection Interface .log([stream, ]data)
.
.send([event, ]data)
event: string
data: any value
Sends a message to the client. In advanced mode the event parameter is needed for sending data. If data
is a buffer then the sent message will be of binary type, else - text type, arrays, booleans, numbers and objects are stringified.
.render([event, ]source[, imports])
event: string
source: string
imports: object
Using the template engine, send data through the WebSocket connection.
.close([callback])
callback: function()
See Connection Interface .close([callback])
.
.destory()
See Connection Interface .destroy()
.
As the WebSocket connection is a writable stream it emits all the events which are emitted by writable streams
error
Emitted when the client breaks the WebSocket protocol, the length of the message it too big or the structure of a received message has an invalid json structure.
message
Emitted when the WebSocket host receives a message from the client, this event is emitted only if the WebSocket host is configured in raw
mode. The callback function has an object as a parameter with 2 attributes data
, the content of the message, and type
, the type of the message which can be binary
or text
.
The object that groups a set of connections. This is useful for sending messages to a group of connections in a better way than the .broadcast()
method of the WebSocket host. WebSocket channel is an event emitter, see events
core module for more details.
connection: WebSocket Connection Instance
Adds the connection to the channel. Emits bind
event with the connection
as parameter. Returns current instance, so calls can be chained.
connection: WebSocket Connection Instance
Removes the connection from the channel. The connection remains alive. Emits unbind
event with connection
as parameter. Returns current instance, so calls can be chained.
Drops all the connections from the channel and removes the channel from the WebSocket host. Channels are automatically closed if there are no bound connections. Emits close
event with no parameters.
event: string
data: string or buffer
filter: function(element, index, array)
Same as the WebSocket host .broadcast()
method, but is applied to the connections of this channel. Emits broadcast
event with event
and / or data
as parameters. Returns current instance, so calls can be chained.
To have access to the simpleS client-side API it is necessary to add
<script src="simples.js"></script>
in the HTML code, this JavaScript file will provide a simple API for AJAX requests and WebSocket connections, also a simplified implementation of Node.JS event emitter.
simples.ajax(url, params[, method])
url: string
params: object
method: 'delete', 'get', 'head', 'post' or 'put'
simples.ajax()
will return an object which will create an XMLHttpRequest to the provided url, will send the needed parameters using the methods DELETE, GET (default), HEAD, POST or PUT. This object has 3 methods to attach listeners for error, progress and success events, which are named with the respective events. The AJAX request can also be aborted by the .stop()
method.
var request = simples.ajax('/', {
user: 'me',
password: 'ok'
}, 'post').error(function (code, description) {
// Application logic
}).progress(function () {
// Application logic
}).success(function (response) {
// Application logic
});
// Somewhere else to stop the request
request.stop();
simples.ee()
simples.ee()
is a simplified implementation of Node.JS event emitter in the browser, which would be useful to create new objects or to inherit in object constructors. See events
core module for more details. Implemented methods:
.emit(event[, data, ...])
- triggers an event with some specific data.
.addListener(event, listener)
, .on(event, listener)
, .once(event, listener)
- create listeners for the events, .once()
creates one time listener.
.removeAllListeners([event])
, .removeListener(event listener)
- remove the listeners for events or all listeners for a specific event.
simples.ws(url[, config])
url: string
config: object
simples.ws()
will return an object which will create an WebSocket connection to the provided url using the needed protocols, will switch automatically to ws
or wss
(secured) WebSocket protocols depending on the HTTP protocol used, secured or not. In the config
parameter can be set the communication mode, the protocols and the type of the data which is sent, the configuration must match on the client and the server to ensure correct data processing. simples.ws()
is an event emitter and has the necessary methods to handle the listeners like Node.JS does, but on the client-side, note that .emit()
method does not send data it just triggers the event, this is useful to instantly execute some actions on the client or for debugging the behavior of the WebSocket connection.
var socket = simples.ws('/', {
mode: 'raw',
protocols: ['echo'],
type: 'text'
}).on('message', function (message) {
this.send('Hello World');
});
simples.ws()
has 2 methods for starting/restarting or closing the WebSocket connection:
.open([url, protocols])
- starts or restarts the WebSocket connection when needed, url
must be a string, protocols
- an array of strings, can be used for recycling the WebSocket connection and to connect to another host, this method is automatically called with simples.ws()
or when the connection is lost.
.close()
- closes the WebSocket connection.
message
- default event received in raw mode or in advanced mode if the incoming message could not be parsed, the callback function has one parameter, the received data.
error
- triggered when an error appears, the callback function has one parameter, the message of the error.
close
- triggered when the WebSocket connection is closed, the callback function has no parameters.
Based on the third parameter in simples.ws()
the communication with the server can be made in advanced or raw mode, .send()
method is very robust, it will send data even if the connection is down, it will try to create a new connection to the server and send the message, below are examples of receiving and sending data in these modes:
socket.on('message', function (message) {
// Application logic
});
socket.on(event, function (data) {
// Application logic
});
socket.send(data);
socket.send(event, data);