-
Notifications
You must be signed in to change notification settings - Fork 0
/
socket.js
69 lines (52 loc) · 1.53 KB
/
socket.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
'use strict';
var EventEmitter = require('events').EventEmitter;
var debug = require('debug')('nock.socket');
var util = require('util');
module.exports = Socket;
function Socket(options) {
if (!(this instanceof Socket)) {
return new Socket(options);
}
EventEmitter.apply(this);
options = options || {};
if (options.proto === 'https') {
this.authorized = true;
}
this.writable = true;
this.readable = true;
this.destroyed = false;
this.setNoDelay = noop;
this.setKeepAlive = noop;
this.resume = noop;
// totalDelay that has already been applied to the current
// request/connection, timeout error will be generated if
// it is timed-out.
this.totalDelayMs = 0;
// Maximum allowed delay. Null means unlimited.
this.timeoutMs = null;
}
util.inherits(Socket, EventEmitter);
Socket.prototype.setTimeout = function setTimeout(timeoutMs, fn) {
this.timeoutMs = timeoutMs;
this.timeoutFunction = fn;
};
Socket.prototype.applyDelay = function applyDelay(delayMs) {
this.totalDelayMs += delayMs;
if (this.timeoutMs && this.totalDelayMs > this.timeoutMs) {
debug('socket timeout');
if (this.timeoutFunction) {
this.timeoutFunction();
}
else {
this.emit('timeout');
}
}
};
Socket.prototype.getPeerCertificate = function getPeerCertificate() {
return new Buffer((Math.random() * 10000 + Date.now()).toString()).toString('base64');
};
Socket.prototype.destroy = function destroy() {
this.destroyed = true;
this.readable = this.writable = false;
};
function noop() {}