Skip to content

Commit c3dc8db

Browse files
authored
Merge pull request #2 from Tabrizian/master
use single quotes only
2 parents d4cf91a + 4f6f62d commit c3dc8db

File tree

5 files changed

+1351
-130
lines changed

5 files changed

+1351
-130
lines changed

.eslintrc.json

Lines changed: 75 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,75 @@
1+
{
2+
"env": {
3+
"browser": true,
4+
"node": true,
5+
"mocha": true
6+
},
7+
"rules": {
8+
"quotes": [
9+
1,
10+
"single"
11+
],
12+
"no-mixed-requires": [
13+
0,
14+
false
15+
],
16+
"no-underscore-dangle": 0,
17+
"yoda": [
18+
1,
19+
"always"
20+
],
21+
"indent": [
22+
2,
23+
2,
24+
{"SwitchCase": 1}
25+
],
26+
"brace-style": [
27+
2,
28+
"1tbs"
29+
],
30+
"comma-style": [
31+
2,
32+
"last"
33+
],
34+
"default-case": 2,
35+
"func-style": [
36+
2,
37+
"declaration"
38+
],
39+
"guard-for-in": 2,
40+
"no-floating-decimal": 2,
41+
"no-nested-ternary": 2,
42+
"no-undefined": 2,
43+
"radix": 2,
44+
"space-before-function-paren": [
45+
1,
46+
"always"
47+
],
48+
"keyword-spacing": [
49+
2,
50+
{"after": true}
51+
],
52+
"space-before-blocks": 2,
53+
"spaced-comment": [
54+
2,
55+
"always",
56+
{
57+
"exceptions": [
58+
"-"
59+
],
60+
"markers": [
61+
"eslint",
62+
"jshint",
63+
"global"
64+
]
65+
}
66+
],
67+
"strict": [
68+
2,
69+
"global"
70+
],
71+
"wrap-iife": 2,
72+
"camelcase": 0,
73+
"new-cap": 0
74+
}
75+
}

index.js

Lines changed: 56 additions & 56 deletions
Original file line numberDiff line numberDiff line change
@@ -1,85 +1,85 @@
1-
"use strict";
2-
var mqtt = require("mqtt");
3-
var inArray = require("in-array");
1+
'use strict';
2+
var mqtt = require('mqtt');
3+
var inArray = require('in-array');
44

55
var RegularClientPrototype = mqtt.MqttClient.prototype;
66

7-
var ASYNC_METHODS = ["publish",
8-
"subscribe",
9-
"unsubscribe",
10-
"unsubscribe",
11-
"end"
7+
var ASYNC_METHODS = ['publish',
8+
'subscribe',
9+
'unsubscribe',
10+
'unsubscribe',
11+
'end'
1212
];
1313

1414
var SYNC_METHODS = [
15-
"emit",
16-
"addListener",
17-
"on",
18-
"once",
19-
"removeListener",
20-
"removeAllListeners",
21-
"setMaxListeners",
22-
"getMaxListeners",
23-
"listeners",
24-
"listenerCount"
15+
'emit',
16+
'addListener',
17+
'on',
18+
'once',
19+
'removeListener',
20+
'removeAllListeners',
21+
'setMaxListeners',
22+
'getMaxListeners',
23+
'listeners',
24+
'listenerCount'
2525
];
2626

2727
module.exports = {
28-
connect: connect,
29-
AsyncClient: AsyncClient
28+
connect: connect,
29+
AsyncClient: AsyncClient
3030
};
3131

32-
function connect(brokerURL, opts) {
33-
var client = mqtt.connect(brokerURL, opts);
32+
function connect (brokerURL, opts) {
33+
var client = mqtt.connect(brokerURL, opts);
3434

35-
var asyncClient = new AsyncClient(client);
35+
var asyncClient = new AsyncClient(client);
3636

37-
return asyncClient;
37+
return asyncClient;
3838
}
3939

40-
function AsyncClient(client) {
41-
this._client = client;
40+
function AsyncClient (client) {
41+
this._client = client;
4242
}
4343

4444
AsyncClient.prototype = {
45-
set handleMessage(newHandler) {
46-
this._client.handleMessage = newHandler;
47-
},
48-
get handleMessage() {
49-
return this._client.handleMessage;
50-
}
45+
set handleMessage (newHandler) {
46+
this._client.handleMessage = newHandler;
47+
},
48+
get handleMessage () {
49+
return this._client.handleMessage;
50+
}
5151
};
5252

5353
ASYNC_METHODS.forEach(defineAsync);
5454
SYNC_METHODS.forEach(definePassthrough);
5555

56-
function definePassthrough(name) {
57-
AsyncClient.prototype[name] = function() {
58-
var client = this._client;
59-
return client[name].apply(client, arguments);
60-
};
56+
function definePassthrough (name) {
57+
AsyncClient.prototype[name] = function () {
58+
var client = this._client;
59+
return client[name].apply(client, arguments);
60+
};
6161
}
6262

63-
function defineAsync(name) {
64-
AsyncClient.prototype[name] = function asyncMethod() {
65-
var client = this._client;
66-
var args = [];
67-
var length = arguments.length;
68-
var i = 0;
69-
for (i; i < length; i++)
70-
args.push(arguments[i]);
63+
function defineAsync (name) {
64+
AsyncClient.prototype[name] = function asyncMethod () {
65+
var client = this._client;
66+
var args = [];
67+
var length = arguments.length;
68+
var i = 0;
69+
for (i; i < length; i++)
70+
args.push(arguments[i]);
7171

72-
return new Promise(function(resolve, reject) {
73-
args.push(makeCallback(resolve, reject));
74-
client[name].apply(client, args);
75-
});
76-
};
72+
return new Promise(function (resolve, reject) {
73+
args.push(makeCallback(resolve, reject));
74+
client[name].apply(client, args);
75+
});
76+
};
7777
}
7878

79-
function makeCallback(resolve, reject) {
80-
return function(err, data) {
81-
if (err)
82-
reject(err);
83-
else resolve(data);
84-
};
79+
function makeCallback (resolve, reject) {
80+
return function (err, data) {
81+
if (err)
82+
reject(err);
83+
else resolve(data);
84+
};
8585
}

0 commit comments

Comments
 (0)