-
Notifications
You must be signed in to change notification settings - Fork 11
/
core-020-cancel.js
72 lines (57 loc) · 2.16 KB
/
core-020-cancel.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
/*
Handle a cancellation of a simple GET request:
1. Client sends a request:
==============================================================================
Version | Type | Token Length | Code | Message ID
0 1 | 0 0 | 0 0 0 0 | 0 0 0 0 0 0 0 1 | 0x0001
1 | CON | 0 bytes | GET | 1
------------------------------------------------------------------------------
Remote Endpoint: 127.0.0.1
------------------------------------------------------------------------------
Uri-Path: temperature
==============================================================================
2. Client cancels the #1 request.
3. Server sends a piggy-backed response:
==============================================================================
Version | Type | Token Length | Code | Message ID
0 1 | 1 0 | 0 0 0 0 | 0 1 0 0 0 1 0 1 | 0x0001
1 | ACK | 0 bytes | 2.05 Content | 1
------------------------------------------------------------------------------
Remote Endpoint: 127.0.0.1
------------------------------------------------------------------------------
Payload (6 bytes)
22.3 C
==============================================================================
3. Client receives the #2 response. The #1 request doesn't emit any events.
*/
'use strict';
require('should');
var sinon = require('sinon');
var helpers = require('../helpers');
var Message = require(helpers.LIB_DIR).Message;
helpers.test(__filename, function(ctx)
{
var expectedRequest = {
type: Message.Type.CON,
code: Message.Code.GET,
id: 0x0001,
uri: '/temperature'
};
var expectedResponse = {
type: Message.Type.ACK,
code: Message.Code.CONTENT,
id: expectedRequest.id,
payload: new Buffer('22.3 C')
};
ctx.socket.expectRequest(expectedRequest);
ctx.socket.scheduleResponse(50, expectedResponse);
var req = ctx.client.request(Message.fromObject(expectedRequest));
var eventSpy = sinon.spy(req, 'emit');
setTimeout(function() { ctx.client.cancel(req); }, 25);
ctx.clock.tick(3600000);
return function assert()
{
ctx.socket.assert();
sinon.assert.notCalled(eventSpy);
};
});