Projekt

Obecné

Profil

Stáhnout (12.8 KB) Statistiky
| Větev: | Revize:
1
# websocket-extensions [![Build status](https://secure.travis-ci.org/faye/websocket-extensions-node.svg)](http://travis-ci.org/faye/websocket-extensions-node)
2

    
3
A minimal framework that supports the implementation of WebSocket extensions in
4
a way that's decoupled from the main protocol. This library aims to allow a
5
WebSocket extension to be written and used with any protocol library, by
6
defining abstract representations of frames and messages that allow modules to
7
co-operate.
8

    
9
`websocket-extensions` provides a container for registering extension plugins,
10
and provides all the functions required to negotiate which extensions to use
11
during a session via the `Sec-WebSocket-Extensions` header. By implementing the
12
APIs defined in this document, an extension may be used by any WebSocket library
13
based on this framework.
14

    
15
## Installation
16

    
17
```
18
$ npm install websocket-extensions
19
```
20

    
21
## Usage
22

    
23
There are two main audiences for this library: authors implementing the
24
WebSocket protocol, and authors implementing extensions. End users of a
25
WebSocket library or an extension should be able to use any extension by passing
26
it as an argument to their chosen protocol library, without needing to know how
27
either of them work, or how the `websocket-extensions` framework operates.
28

    
29
The library is designed with the aim that any protocol implementation and any
30
extension can be used together, so long as they support the same abstract
31
representation of frames and messages.
32

    
33
### Data types
34

    
35
The APIs provided by the framework rely on two data types; extensions will
36
expect to be given data and to be able to return data in these formats:
37

    
38
#### *Frame*
39

    
40
*Frame* is a structure representing a single WebSocket frame of any type. Frames
41
are simple objects that must have at least the following properties, which
42
represent the data encoded in the frame:
43

    
44
| property     | description                                                        |
45
| ------------ | ------------------------------------------------------------------ |
46
| `final`      | `true` if the `FIN` bit is set, `false` otherwise                  |
47
| `rsv1`       | `true` if the `RSV1` bit is set, `false` otherwise                 |
48
| `rsv2`       | `true` if the `RSV2` bit is set, `false` otherwise                 |
49
| `rsv3`       | `true` if the `RSV3` bit is set, `false` otherwise                 |
50
| `opcode`     | the numeric opcode (`0`, `1`, `2`, `8`, `9`, or `10`) of the frame |
51
| `masked`     | `true` if the `MASK` bit is set, `false` otherwise                 |
52
| `maskingKey` | a 4-byte `Buffer` if `masked` is `true`, otherwise `null`          |
53
| `payload`    | a `Buffer` containing the (unmasked) application data              |
54

    
55
#### *Message*
56

    
57
A *Message* represents a complete application message, which can be formed from
58
text, binary and continuation frames. It has the following properties:
59

    
60
| property | description                                                       |
61
| -------- | ----------------------------------------------------------------- |
62
| `rsv1`   | `true` if the first frame of the message has the `RSV1` bit set   |
63
| `rsv2`   | `true` if the first frame of the message has the `RSV2` bit set   |
64
| `rsv3`   | `true` if the first frame of the message has the `RSV3` bit set   |
65
| `opcode` | the numeric opcode (`1` or `2`) of the first frame of the message |
66
| `data`   | the concatenation of all the frame payloads in the message        |
67

    
68
### For driver authors
69

    
70
A driver author is someone implementing the WebSocket protocol proper, and who
71
wishes end users to be able to use WebSocket extensions with their library.
72

    
73
At the start of a WebSocket session, on both the client and the server side,
74
they should begin by creating an extension container and adding whichever
75
extensions they want to use.
76

    
77
```js
78
var Extensions = require('websocket-extensions'),
79
    deflate    = require('permessage-deflate');
80

    
81
var exts = new Extensions();
82
exts.add(deflate);
83
```
84

    
85
In the following examples, `exts` refers to this `Extensions` instance.
86

    
87
#### Client sessions
88

    
89
Clients will use the methods `generateOffer()` and `activate(header)`.
90

    
91
As part of the handshake process, the client must send a
92
`Sec-WebSocket-Extensions` header to advertise that it supports the registered
93
extensions. This header should be generated using:
94

    
95
```js
96
request.headers['sec-websocket-extensions'] = exts.generateOffer();
97
```
98

    
99
This returns a string, for example `"permessage-deflate;
100
client_max_window_bits"`, that represents all the extensions the client is
101
offering to use, and their parameters. This string may contain multiple offers
102
for the same extension.
103

    
104
When the client receives the handshake response from the server, it should pass
105
the incoming `Sec-WebSocket-Extensions` header in to `exts` to activate the
106
extensions the server has accepted:
107

    
108
```js
109
exts.activate(response.headers['sec-websocket-extensions']);
110
```
111

    
112
If the server has sent any extension responses that the client does not
113
recognize, or are in conflict with one another for use of RSV bits, or that use
114
invalid parameters for the named extensions, then `exts.activate()` will
115
`throw`. In this event, the client driver should fail the connection with
116
closing code `1010`.
117

    
118
#### Server sessions
119

    
120
Servers will use the method `generateResponse(header)`.
121

    
122
A server session needs to generate a `Sec-WebSocket-Extensions` header to send
123
in its handshake response:
124

    
125
```js
126
var clientOffer = request.headers['sec-websocket-extensions'],
127
    extResponse = exts.generateResponse(clientOffer);
128

    
129
response.headers['sec-websocket-extensions'] = extResponse;
130
```
131

    
132
Calling `exts.generateResponse(header)` activates those extensions the client
133
has asked to use, if they are registered, asks each extension for a set of
134
response parameters, and returns a string containing the response parameters for
135
all accepted extensions.
136

    
137
#### In both directions
138

    
139
Both clients and servers will use the methods `validFrameRsv(frame)`,
140
`processIncomingMessage(message)` and `processOutgoingMessage(message)`.
141

    
142
The WebSocket protocol requires that frames do not have any of the `RSV` bits
143
set unless there is an extension in use that allows otherwise. When processing
144
an incoming frame, sessions should pass a *Frame* object to:
145

    
146
```js
147
exts.validFrameRsv(frame)
148
```
149

    
150
If this method returns `false`, the session should fail the WebSocket connection
151
with closing code `1002`.
152

    
153
To pass incoming messages through the extension stack, a session should
154
construct a *Message* object according to the above datatype definitions, and
155
call:
156

    
157
```js
158
exts.processIncomingMessage(message, function(error, msg) {
159
  // hand the message off to the application
160
});
161
```
162

    
163
If any extensions fail to process the message, then the callback will yield an
164
error and the session should fail the WebSocket connection with closing code
165
`1010`. If `error` is `null`, then `msg` should be passed on to the application.
166

    
167
To pass outgoing messages through the extension stack, a session should
168
construct a *Message* as before, and call:
169

    
170
```js
171
exts.processOutgoingMessage(message, function(error, msg) {
172
  // write message to the transport
173
});
174
```
175

    
176
If any extensions fail to process the message, then the callback will yield an
177
error and the session should fail the WebSocket connection with closing code
178
`1010`. If `error` is `null`, then `message` should be converted into frames
179
(with the message's `rsv1`, `rsv2`, `rsv3` and `opcode` set on the first frame)
180
and written to the transport.
181

    
182
At the end of the WebSocket session (either when the protocol is explicitly
183
ended or the transport connection disconnects), the driver should call:
184

    
185
```js
186
exts.close(function() {})
187
```
188

    
189
The callback is invoked when all extensions have finished processing any
190
messages in the pipeline and it's safe to close the socket.
191

    
192
### For extension authors
193

    
194
An extension author is someone implementing an extension that transforms
195
WebSocket messages passing between the client and server. They would like to
196
implement their extension once and have it work with any protocol library.
197

    
198
Extension authors will not install `websocket-extensions` or call it directly.
199
Instead, they should implement the following API to allow their extension to
200
plug into the `websocket-extensions` framework.
201

    
202
An `Extension` is any object that has the following properties:
203

    
204
| property | description                                                                  |
205
| -------- | ---------------------------------------------------------------------------- |
206
| `name`   | a string containing the name of the extension as used in negotiation headers |
207
| `type`   | a string, must be `"permessage"`                                             |
208
| `rsv1`   | either `true` if the extension uses the RSV1 bit, `false` otherwise          |
209
| `rsv2`   | either `true` if the extension uses the RSV2 bit, `false` otherwise          |
210
| `rsv3`   | either `true` if the extension uses the RSV3 bit, `false` otherwise          |
211

    
212
It must also implement the following methods:
213

    
214
```js
215
ext.createClientSession()
216
```
217

    
218
This returns a *ClientSession*, whose interface is defined below.
219

    
220
```js
221
ext.createServerSession(offers)
222
```
223

    
224
This takes an array of offer params and returns a *ServerSession*, whose
225
interface is defined below. For example, if the client handshake contains the
226
offer header:
227

    
228
```
229
Sec-WebSocket-Extensions: permessage-deflate; server_no_context_takeover; server_max_window_bits=8, \
230
                          permessage-deflate; server_max_window_bits=15
231
```
232

    
233
then the `permessage-deflate` extension will receive the call:
234

    
235
```js
236
ext.createServerSession([
237
  {server_no_context_takeover: true, server_max_window_bits: 8},
238
  {server_max_window_bits: 15}
239
]);
240
```
241

    
242
The extension must decide which set of parameters it wants to accept, if any,
243
and return a *ServerSession* if it wants to accept the parameters and `null`
244
otherwise.
245

    
246
#### *ClientSession*
247

    
248
A *ClientSession* is the type returned by `ext.createClientSession()`. It must
249
implement the following methods, as well as the *Session* API listed below.
250

    
251
```js
252
clientSession.generateOffer()
253
// e.g.  -> [
254
//            {server_no_context_takeover: true, server_max_window_bits: 8},
255
//            {server_max_window_bits: 15}
256
//          ]
257
```
258

    
259
This must return a set of parameters to include in the client's
260
`Sec-WebSocket-Extensions` offer header. If the session wants to offer multiple
261
configurations, it can return an array of sets of parameters as shown above.
262

    
263
```js
264
clientSession.activate(params) // -> true
265
```
266

    
267
This must take a single set of parameters from the server's handshake response
268
and use them to configure the client session. If the client accepts the given
269
parameters, then this method must return `true`. If it returns any other value,
270
the framework will interpret this as the client rejecting the response, and will
271
`throw`.
272

    
273
#### *ServerSession*
274

    
275
A *ServerSession* is the type returned by `ext.createServerSession(offers)`. It
276
must implement the following methods, as well as the *Session* API listed below.
277

    
278
```js
279
serverSession.generateResponse()
280
// e.g.  -> {server_max_window_bits: 8}
281
```
282

    
283
This returns the set of parameters the server session wants to send in its
284
`Sec-WebSocket-Extensions` response header. Only one set of parameters is
285
returned to the client per extension. Server sessions that would confict on
286
their use of RSV bits are not activated.
287

    
288
#### *Session*
289

    
290
The *Session* API must be implemented by both client and server sessions. It
291
contains two methods, `processIncomingMessage(message)` and
292
`processOutgoingMessage(message)`.
293

    
294
```js
295
session.processIncomingMessage(message, function(error, msg) { ... })
296
```
297

    
298
The session must implement this method to take an incoming *Message* as defined
299
above, transform it in any way it needs, then return it via the callback. If
300
there is an error processing the message, this method should yield an error as
301
the first argument.
302

    
303
```js
304
session.processOutgoingMessage(message, function(error, msg) { ... })
305
```
306

    
307
The session must implement this method to take an outgoing *Message* as defined
308
above, transform it in any way it needs, then return it via the callback. If
309
there is an error processing the message, this method should yield an error as
310
the first argument.
311

    
312
Note that both `processIncomingMessage()` and `processOutgoingMessage()` can
313
perform their logic asynchronously, are allowed to process multiple messages
314
concurrently, and are not required to complete working on messages in the same
315
order the messages arrive. `websocket-extensions` will reorder messages as your
316
extension emits them and will make sure every extension is given messages in the
317
order they arrive from the driver. This allows extensions to maintain state that
318
depends on the messages' wire order, for example keeping a DEFLATE compression
319
context between messages.
320

    
321
```js
322
session.close()
323
```
324

    
325
The framework will call this method when the WebSocket session ends, allowing
326
the session to release any resources it's using.
327

    
328
## Examples
329

    
330
* Consumer: [websocket-driver](https://github.com/faye/websocket-driver-node)
331
* Provider: [permessage-deflate](https://github.com/faye/permessage-deflate-node)
(3-3/4)