mirror of
https://github.com/nodejs/node.git
synced 2024-11-29 15:06:33 +01:00
f32a606e37
The `events` module already exports `EventEmitter` constructor function So, we don't have to use `events.EventEmitter` to access it. Refer: https://github.com/nodejs/node/pull/2896 PR-URL: https://github.com/nodejs/node/pull/2921 Reviewed-By: Roman Reiss <me@silverwind.io> Reviewed-By: Michaël Zasso <mic.besace@gmail.com>
100 lines
2.5 KiB
JavaScript
100 lines
2.5 KiB
JavaScript
'use strict';
|
|
|
|
const util = require('util');
|
|
const internalUtil = require('internal/util');
|
|
const EventEmitter = require('events');
|
|
|
|
|
|
exports.IncomingMessage = require('_http_incoming').IncomingMessage;
|
|
|
|
|
|
const common = require('_http_common');
|
|
exports.METHODS = common.methods.slice().sort();
|
|
|
|
|
|
exports.OutgoingMessage = require('_http_outgoing').OutgoingMessage;
|
|
|
|
|
|
const server = require('_http_server');
|
|
exports.ServerResponse = server.ServerResponse;
|
|
exports.STATUS_CODES = server.STATUS_CODES;
|
|
|
|
|
|
const agent = require('_http_agent');
|
|
const Agent = exports.Agent = agent.Agent;
|
|
exports.globalAgent = agent.globalAgent;
|
|
|
|
const client = require('_http_client');
|
|
const ClientRequest = exports.ClientRequest = client.ClientRequest;
|
|
|
|
exports.request = function(options, cb) {
|
|
return new ClientRequest(options, cb);
|
|
};
|
|
|
|
exports.get = function(options, cb) {
|
|
var req = exports.request(options, cb);
|
|
req.end();
|
|
return req;
|
|
};
|
|
|
|
exports._connectionListener = server._connectionListener;
|
|
const Server = exports.Server = server.Server;
|
|
|
|
exports.createServer = function(requestListener) {
|
|
return new Server(requestListener);
|
|
};
|
|
|
|
|
|
// Legacy Interface
|
|
|
|
function Client(port, host) {
|
|
if (!(this instanceof Client)) return new Client(port, host);
|
|
EventEmitter.call(this);
|
|
|
|
host = host || 'localhost';
|
|
port = port || 80;
|
|
this.host = host;
|
|
this.port = port;
|
|
this.agent = new Agent({ host: host, port: port, maxSockets: 1 });
|
|
}
|
|
util.inherits(Client, EventEmitter);
|
|
Client.prototype.request = function(method, path, headers) {
|
|
var self = this;
|
|
var options = {};
|
|
options.host = self.host;
|
|
options.port = self.port;
|
|
if (method[0] === '/') {
|
|
headers = path;
|
|
path = method;
|
|
method = 'GET';
|
|
}
|
|
options.method = method;
|
|
options.path = path;
|
|
options.headers = headers;
|
|
options.agent = self.agent;
|
|
var c = new ClientRequest(options);
|
|
c.on('error', function(e) {
|
|
self.emit('error', e);
|
|
});
|
|
// The old Client interface emitted 'end' on socket end.
|
|
// This doesn't map to how we want things to operate in the future
|
|
// but it will get removed when we remove this legacy interface.
|
|
c.on('socket', function(s) {
|
|
s.on('end', function() {
|
|
if (self._decoder) {
|
|
var ret = self._decoder.end();
|
|
if (ret)
|
|
self.emit('data', ret);
|
|
}
|
|
self.emit('end');
|
|
});
|
|
});
|
|
return c;
|
|
};
|
|
|
|
exports.Client = internalUtil.deprecate(Client, 'http.Client is deprecated.');
|
|
|
|
exports.createClient = internalUtil.deprecate(function(port, host) {
|
|
return new Client(port, host);
|
|
}, 'http.createClient is deprecated. Use http.request instead.');
|