Skip to content

Commit

Permalink
use prettier with standardjs
Browse files Browse the repository at this point in the history
  • Loading branch information
StarpTech committed Oct 1, 2017
1 parent e1405c2 commit 245e2b4
Show file tree
Hide file tree
Showing 191 changed files with 11,732 additions and 8,297 deletions.
12 changes: 12 additions & 0 deletions .eslintignore
Original file line number Diff line number Diff line change
@@ -0,0 +1,12 @@
!/*.js
/tests/**/*.js
!/tests/**/jsfmt.spec.js
!/**/.eslintrc.js
/test.js
/dist/
**/node_modules/**
/website/static/lib/
/tests_integration/cli/
.nyc_output
coverage
test
9 changes: 9 additions & 0 deletions .eslintrc.json
Original file line number Diff line number Diff line change
@@ -0,0 +1,9 @@
{
"extends": [
"prettier",
"standard"
],
"plugins": [
"prettier"
]
}
1 change: 1 addition & 0 deletions .prettierignore
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
node_modules
7 changes: 7 additions & 0 deletions .prettierrc
Original file line number Diff line number Diff line change
@@ -0,0 +1,7 @@
{
"printWidth": 80,
"semi": false,
"singleQuote": true,
"trailingComma": "none",
"bracketSpacing": true
}
2 changes: 1 addition & 1 deletion CONTRIBUTING.md
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@ We actively welcome your pull requests.
2. If you've added code that should be tested, add tests.
3. If you've changed APIs, update the documentation.
4. Ensure the test suite passes.
5. Make sure your code lints. ([StandardJs](https://github.com/feross/standard))
5. Make sure your code lints and is correctly formatted. ([Prettier](https://github.com/prettier/prettier))

## License

Expand Down
2 changes: 1 addition & 1 deletion benchmark/pub_perf.js
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ hemera.ready(() => {
}
}

hemera.close(function () {
hemera.close(function() {
var stop = new Date()
var mps = parseInt(loop / ((stop - start) / 1000))
console.log('\nPublished at ' + mps + ' msgs/sec')
Expand Down
19 changes: 10 additions & 9 deletions benchmark/request_perf.js
Original file line number Diff line number Diff line change
Expand Up @@ -19,21 +19,22 @@ hemera.ready(() => {
var start = new Date()

for (var i = 0; i < loop; i++) {
hemera.act({
topic: 'math',
cmd: 'add',
a: 1,
b: 2
}, function (err, resp) {

})
hemera.act(
{
topic: 'math',
cmd: 'add',
a: 1,
b: 2
},
function(err, resp) {}
)

if (i % hash === 0) {
process.stdout.write('+')
}
}

hemera.close(function () {
hemera.close(function() {
var stop = new Date()
var mps = parseInt(loop / ((stop - start) / 1000))
console.log('\nPublished at ' + mps + ' msgs/sec')
Expand Down
21 changes: 12 additions & 9 deletions benchmark/request_perf_async_await.js
Original file line number Diff line number Diff line change
Expand Up @@ -19,21 +19,24 @@ hemera.ready(() => {
var start = new Date()

for (var i = 0; i < loop; i++) {
hemera.act({
topic: 'math',
cmd: 'add',
a: 1,
b: 2
}, async function (err, resp) {
await {}
})
hemera.act(
{
topic: 'math',
cmd: 'add',
a: 1,
b: 2
},
async function(err, resp) {
await {}
}
)

if (i % hash === 0) {
process.stdout.write('+')
}
}

hemera.close(function () {
hemera.close(function() {
var stop = new Date()
var mps = parseInt(loop / ((stop - start) / 1000))
console.log('\nPublished at ' + mps + ' msgs/sec')
Expand Down
50 changes: 28 additions & 22 deletions benchmark/request_perf_big_payload.js
Original file line number Diff line number Diff line change
Expand Up @@ -15,13 +15,13 @@ const payloadExtraBig = require('./payloads/example_payload_extra_big.json') //

const nats1 = Nats.connect(noAuthUrl)

nats1.on('error', (err) => {
nats1.on('error', err => {
console.error(err)
})

const nats2 = Nats.connect(noAuthUrl)

nats2.on('error', (err) => {
nats2.on('error', err => {
console.error(err)
})

Expand All @@ -35,26 +35,32 @@ const hemera2 = new Hemera(nats2, {
hemera1.ready(() => {
var start = new Date()

hemera1.add({
topic: 'math',
cmd: 'add'
}, function (req, reply) {
// response with big file
return reply(null, payloadExtraBig)
})

nats1.flush(function () {
hemera2.act({
hemera1.add(
{
topic: 'math',
cmd: 'add',
a: 1,
b: 2,
data: payloadExtraBig // request with big file
}, function (err, resp) {
let stop = new Date()
let time = parseInt((stop - start))
console.log('\nRequest: ' + time + ' /ms')
process.exit()
})
cmd: 'add'
},
function(req, reply) {
// response with big file
return reply(null, payloadExtraBig)
}
)

nats1.flush(function() {
hemera2.act(
{
topic: 'math',
cmd: 'add',
a: 1,
b: 2,
data: payloadExtraBig // request with big file
},
function(err, resp) {
let stop = new Date()
let time = parseInt(stop - start)
console.log('\nRequest: ' + time + ' /ms')
process.exit()
}
)
})
})
18 changes: 10 additions & 8 deletions benchmark/request_perf_generators.js
Original file line number Diff line number Diff line change
Expand Up @@ -19,20 +19,22 @@ hemera.ready(() => {
var start = new Date()

for (var i = 0; i < loop; i++) {
hemera.act({
topic: 'math',
cmd: 'add',
a: 1,
b: 2
}, function * (err, resp) {
})
hemera.act(
{
topic: 'math',
cmd: 'add',
a: 1,
b: 2
},
function*(err, resp) {}
)

if (i % hash === 0) {
process.stdout.write('+')
}
}

hemera.close(function () {
hemera.close(function() {
var stop = new Date()
var mps = parseInt(loop / ((stop - start) / 1000))
console.log('\nPublished at ' + mps + ' msgs/sec')
Expand Down
58 changes: 32 additions & 26 deletions benchmark/request_rt.js
Original file line number Diff line number Diff line change
Expand Up @@ -18,35 +18,41 @@ const hemera2 = new Hemera(nats2)
hemera1.ready(() => {
var start = new Date()

hemera1.add({
topic: 'math',
cmd: 'add'
}, function (req, cb) {
cb()
})
hemera1.add(
{
topic: 'math',
cmd: 'add'
},
function(req, cb) {
cb()
}
)

hemera1.close(function () {
hemera1.close(function() {
for (var i = 0; i < loop; i++) {
hemera2.act({
topic: 'math',
cmd: 'add',
a: 1,
b: 2,
maxMessages$: 1
}, function (err, resp) {
received += 1

if (received === loop) {
var stop = new Date()
var rps = parseInt(loop / ((stop - start) / 1000))
console.log('\n' + rps + ' request-responses/sec')
var lat = parseInt(((stop - start) * 1000) / (loop * 2)) // Request=2, Reponse=2 RTs
console.log('Avg roundtrip latency: ' + lat + ' microseconds')
process.exit()
} else if (received % hash === 0) {
process.stdout.write('+')
hemera2.act(
{
topic: 'math',
cmd: 'add',
a: 1,
b: 2,
maxMessages$: 1
},
function(err, resp) {
received += 1

if (received === loop) {
var stop = new Date()
var rps = parseInt(loop / ((stop - start) / 1000))
console.log('\n' + rps + ' request-responses/sec')
var lat = parseInt((stop - start) * 1000 / (loop * 2)) // Request=2, Reponse=2 RTs
console.log('Avg roundtrip latency: ' + lat + ' microseconds')
process.exit()
} else if (received % hash === 0) {
process.stdout.write('+')
}
}
})
)
}
})
})
58 changes: 32 additions & 26 deletions benchmark/request_rt_async_await.js
Original file line number Diff line number Diff line change
Expand Up @@ -18,35 +18,41 @@ const hemera2 = new Hemera(nats2)
hemera1.ready(() => {
var start = new Date()

hemera1.add({
topic: 'math',
cmd: 'add'
}, async function (req) {
return await Promise.resolve(true)
})
hemera1.add(
{
topic: 'math',
cmd: 'add'
},
async function(req) {
return await Promise.resolve(true)
}
)

hemera1.close(function () {
hemera1.close(function() {
for (var i = 0; i < loop; i++) {
hemera2.act({
topic: 'math',
cmd: 'add',
a: 1,
b: 2,
maxMessages$: 1
}, function (err, resp) {
received += 1

if (received === loop) {
var stop = new Date()
var rps = parseInt(loop / ((stop - start) / 1000))
console.log('\n' + rps + ' request-responses/sec')
var lat = parseInt(((stop - start) * 1000) / (loop * 2)) // Request=2, Reponse=2 RTs
console.log('Avg roundtrip latency: ' + lat + ' microseconds')
process.exit()
} else if (received % hash === 0) {
process.stdout.write('+')
hemera2.act(
{
topic: 'math',
cmd: 'add',
a: 1,
b: 2,
maxMessages$: 1
},
function(err, resp) {
received += 1

if (received === loop) {
var stop = new Date()
var rps = parseInt(loop / ((stop - start) / 1000))
console.log('\n' + rps + ' request-responses/sec')
var lat = parseInt((stop - start) * 1000 / (loop * 2)) // Request=2, Reponse=2 RTs
console.log('Avg roundtrip latency: ' + lat + ' microseconds')
process.exit()
} else if (received % hash === 0) {
process.stdout.write('+')
}
}
})
)
}
})
})
Loading

0 comments on commit 245e2b4

Please sign in to comment.