Modernisation 25 - bracket spacing

CHANGELOG.md

@@ -28,6 +28,7 @@
 - Enable useArrowFunction lint rule to prefer arrow functions for cleaner syntax
 - Enable noUselessCatch lint rule to prevent useless catch blocks that only rethrow errors
 - Enable noArguments rule to enforce modern rest parameters instead of legacy arguments object
+- Enable bracketSpacing formatting rule to add spaces inside object literals
 
 ## v0.10.9
 - Add support for IPv6 urls

bin/generate-defs.js

@@ -53,7 +53,7 @@ function initial(part) {
 function argument(a) {
   const type = a.type || domains[a.domain];
   const friendlyName = propertyName(a.name);
-  return {type: type, name: friendlyName, default: a['default-value']};
+  return { type: type, name: friendlyName, default: a['default-value'] };
 }
 
 const domains = {};
@@ -529,7 +529,7 @@ function decoderFn(method) {
 }
 
 function infoObj(thing) {
-  const info = JSON.stringify({id: thing.id, classId: thing.clazzId, methodId: thing.methodId, name: thing.name, args: thing.args});
+  const info = JSON.stringify({ id: thing.id, classId: thing.clazzId, methodId: thing.methodId, name: thing.name, args: thing.args });
   println('var %s = module.exports.%s = %s;', thing.info, thing.info, info);
 }
 

biome.json

@@ -36,7 +36,7 @@
     "formatter": {
       "arrowParentheses": "always",
       "bracketSameLine": false,
-      "bracketSpacing": false,
+      "bracketSpacing": true,
       "jsxQuoteStyle": "double",
       "quoteProperties": "asNeeded",
       "quoteStyle": "single",

examples/direct_reply_to_client.js

@@ -15,10 +15,10 @@ const queue = 'rpc_queue';
       await channel.close();
       await connection.close();
     },
-    {noAck: true},
+    { noAck: true },
   );
 
-  await channel.assertQueue(queue, {durable: false});
+  await channel.assertQueue(queue, { durable: false });
 
   channel.sendToQueue(queue, Buffer.from(' [X] ping'), {
     replyTo: 'amq.rabbitmq.reply-to',

examples/direct_reply_to_server.js

@@ -13,14 +13,14 @@ const queue = 'rpc_queue';
     await connection.close();
   });
 
-  await channel.assertQueue(queue, {durable: false});
+  await channel.assertQueue(queue, { durable: false });
   await channel.consume(
     queue,
     (message) => {
       console.log(message.content.toString());
       channel.sendToQueue(message.properties.replyTo, Buffer.from(' [.] pong'));
     },
-    {noAck: true},
+    { noAck: true },
   );
 
   console.log(' [x] To exit press CTRL+C.');

examples/headers.js

@@ -11,8 +11,8 @@ const amqp = require('../');
     await connection.close();
   });
 
-  const {exchange} = await channel.assertExchange('matching exchange', 'headers');
-  const {queue} = await channel.assertQueue();
+  const { exchange } = await channel.assertExchange('matching exchange', 'headers');
+  const { queue } = await channel.assertQueue();
 
   // When using a headers exchange, the headers to be matched go in
   // the binding arguments. The routing key is ignore, so best left
@@ -32,12 +32,12 @@ const amqp = require('../');
     (message) => {
       console.log(message.content.toString());
     },
-    {noAck: true},
+    { noAck: true },
   );
 
-  channel.publish(exchange, '', Buffer.from('hello'), {headers: {baz: 'boo'}});
-  channel.publish(exchange, '', Buffer.from('hello'), {headers: {foo: 'bar'}});
-  channel.publish(exchange, '', Buffer.from('lost'), {headers: {meh: 'nah'}});
+  channel.publish(exchange, '', Buffer.from('hello'), { headers: { baz: 'boo' } });
+  channel.publish(exchange, '', Buffer.from('hello'), { headers: { foo: 'bar' } });
+  channel.publish(exchange, '', Buffer.from('lost'), { headers: { meh: 'nah' } });
 
   console.log(' [x] To exit press CTRL+C.');
 })();

examples/receive_generator.js

@@ -18,7 +18,7 @@ co(function* () {
   channel.sendToQueue(q, Buffer.from(msg));
   console.log(" [x] Sent '%s'", msg);
   // consume the message
-  yield channel.consume(q, myConsumer, {noAck: true});
+  yield channel.consume(q, myConsumer, { noAck: true });
 }).catch((err) => {
   console.warn('Error:', err);
 });

examples/tutorials/callback_api/emit_log.js

@@ -9,7 +9,7 @@ amqp.connect((err, connection) => {
   if (err) return bail(err);
   connection.createChannel((err, channel) => {
     if (err) return bail(err, connection);
-    channel.assertExchange(exchange, 'fanout', {durable: false}, (err) => {
+    channel.assertExchange(exchange, 'fanout', { durable: false }, (err) => {
       if (err) return bail(err, connection);
       channel.publish(exchange, '', Buffer.from(text));
       console.log(" [x] Sent '%s'", text);

examples/tutorials/callback_api/emit_log_direct.js

@@ -11,7 +11,7 @@ amqp.connect((err, connection) => {
   if (err) return bail(err);
   connection.createChannel((err, channel) => {
     if (err) return bail(err, connection);
-    channel.assertExchange(exchange, 'direct', {durable: false}, (err) => {
+    channel.assertExchange(exchange, 'direct', { durable: false }, (err) => {
       if (err) return bail(err, connection);
       channel.publish(exchange, routingKey, Buffer.from(text));
       console.log(" [x] Sent '%s'", text);

examples/tutorials/callback_api/emit_log_topic.js

@@ -11,7 +11,7 @@ amqp.connect((err, connection) => {
   if (err) return bail(err);
   connection.createChannel((err, channel) => {
     if (err) return bail(err, connection);
-    channel.assertExchange(exchange, 'topic', {durable: false}, (err) => {
+    channel.assertExchange(exchange, 'topic', { durable: false }, (err) => {
       if (err) return bail(err, connection);
       channel.publish(exchange, routingKey, Buffer.from(text));
       console.log(" [x] Sent '%s'", text);

examples/tutorials/callback_api/new_task.js

@@ -9,9 +9,9 @@ amqp.connect((err, connection) => {
   if (err) return bail(err);
   connection.createChannel((err, channel) => {
     if (err) return bail(err, connection);
-    channel.assertQueue(queue, {durable: true}, (err) => {
+    channel.assertQueue(queue, { durable: true }, (err) => {
       if (err) return bails(err, connection);
-      channel.sendToQueue(queue, Buffer.from(text), {persistent: true});
+      channel.sendToQueue(queue, Buffer.from(text), { persistent: true });
       console.log(" [x] Sent '%s'", text);
       channel.close(() => {
         connection.close();

examples/tutorials/callback_api/receive.js

@@ -15,15 +15,15 @@ amqp.connect((err, connection) => {
       });
     });
 
-    channel.assertQueue(queue, {durable: false}, (err) => {
+    channel.assertQueue(queue, { durable: false }, (err) => {
       if (err) return bail(err, connection);
       channel.consume(
         queue,
         (message) => {
           if (message) console.log(" [x] Received '%s'", message.content.toString());
           else console.warn(' [x] Consumer cancelled');
         },
-        {noAck: true},
+        { noAck: true },
         (err) => {
           if (err) return bail(err, connection);
           console.log(' [*] Waiting for logs. To exit press CTRL+C.');

examples/tutorials/callback_api/receive_logs.js

@@ -15,9 +15,9 @@ amqp.connect((err, connection) => {
       });
     });
 
-    channel.assertExchange(exchange, 'fanout', {durable: false}, (err, {queue: _queue}) => {
+    channel.assertExchange(exchange, 'fanout', { durable: false }, (err, { queue: _queue }) => {
       if (err) return bail(err, connection);
-      channel.assertQueue('', {exclusive: true}, (err, {queue}) => {
+      channel.assertQueue('', { exclusive: true }, (err, { queue }) => {
         if (err) return bail(err, connection);
         channel.bindQueue(queue, exchange, '', {}, (err) => {
           if (err) return bail(err, connection);
@@ -27,7 +27,7 @@ amqp.connect((err, connection) => {
               if (message) console.log(" [x] '%s'", message.content.toString());
               else console.warn(' [x] Consumer cancelled');
             },
-            {noAck: true},
+            { noAck: true },
             (err) => {
               if (err) return bail(err, connection);
               console.log(' [*] Waiting for logs. To exit press CTRL+C.');

examples/tutorials/callback_api/receive_logs_direct.js

@@ -1,7 +1,7 @@
 #!/usr/bin/env node
 
 const amqp = require('amqplib/callback_api');
-const {basename} = require('node:path');
+const { basename } = require('node:path');
 
 const exchange = 'direct_logs';
 const severities = process.argv.slice(2);
@@ -21,17 +21,17 @@ amqp.connect((err, connection) => {
       });
     });
 
-    channel.assertExchange(exchange, 'direct', {durable: false}, (err) => {
+    channel.assertExchange(exchange, 'direct', { durable: false }, (err) => {
       if (err) return bail(err, connection);
-      channel.assertQueue('', {exclusive: true}, (err, {queue}) => {
+      channel.assertQueue('', { exclusive: true }, (err, { queue }) => {
         if (err) return bail(err, connection);
         channel.consume(
           queue,
           (message) => {
             if (message) console.log(" [x] %s:'%s'", message.fields.routingKey, message.content.toString());
             else console.warn(' [x] Consumer cancelled');
           },
-          {noAck: true},
+          { noAck: true },
           (err) => {
             if (err) return bail(err, connection);
             console.log(' [*] Waiting for logs. To exit press CTRL+C.');

examples/tutorials/callback_api/receive_logs_topic.js

@@ -1,7 +1,7 @@
 #!/usr/bin/env node
 
 const amqp = require('amqplib/callback_api');
-const {basename} = require('node:path');
+const { basename } = require('node:path');
 
 const exchange = 'topic_logs';
 const severities = process.argv.slice(2);
@@ -21,17 +21,17 @@ amqp.connect((err, connection) => {
       });
     });
 
-    channel.assertExchange(exchange, 'topic', {durable: false}, (err) => {
+    channel.assertExchange(exchange, 'topic', { durable: false }, (err) => {
       if (err) return bail(err, connection);
-      channel.assertQueue('', {exclusive: true}, (err, {queue}) => {
+      channel.assertQueue('', { exclusive: true }, (err, { queue }) => {
         if (err) return bail(err, connection);
         channel.consume(
           queue,
           (message) => {
             if (message) console.log(" [x] %s:'%s'", message.fields.routingKey, message.content.toString());
             else console.warn(' [x] Consumer cancelled');
           },
-          {noAck: true},
+          { noAck: true },
           (err) => {
             if (err) return bail(err, connection);
             console.log(' [*] Waiting for logs. To exit press CTRL+C.');

examples/tutorials/callback_api/rpc_client.js

@@ -1,8 +1,8 @@
 #!/usr/bin/env node
 
 const amqp = require('amqplib/callback_api');
-const {basename} = require('node:path');
-const {v4: uuid} = require('uuid');
+const { basename } = require('node:path');
+const { v4: uuid } = require('uuid');
 
 const queue = 'rpc_queue';
 
@@ -16,7 +16,7 @@ amqp.connect((err, connection) => {
   if (err) return bail(err);
   connection.createChannel((err, channel) => {
     if (err) return bail(err, connection);
-    channel.assertQueue('', {exclusive: true}, (err, {queue: replyTo}) => {
+    channel.assertQueue('', { exclusive: true }, (err, { queue: replyTo }) => {
       if (err) return bail(err, connection);
 
       const correlationId = uuid();
@@ -31,10 +31,10 @@ amqp.connect((err, connection) => {
             });
           }
         },
-        {noAck: true},
+        { noAck: true },
       );
 
-      channel.assertQueue(queue, {durable: false}, (err) => {
+      channel.assertQueue(queue, { durable: false }, (err) => {
         if (err) return bail(err, connection);
         console.log(' [x] Requesting fib(%d)', n);
         channel.sendToQueue(queue, Buffer.from(n.toString()), {

examples/tutorials/callback_api/rpc_server.js

@@ -15,7 +15,7 @@ amqp.connect((err, connection) => {
       });
     });
 
-    channel.assertQueue(queue, {durable: false}, (err) => {
+    channel.assertQueue(queue, { durable: false }, (err) => {
       if (err) return bail(err, connection);
       channel.prefetch(1);
       channel.consume(
@@ -29,7 +29,7 @@ amqp.connect((err, connection) => {
           });
           channel.ack(message);
         },
-        {noAck: false},
+        { noAck: false },
         (err) => {
           if (err) return bail(err, conn);
           console.log(' [x] Awaiting RPC requests. To exit press CTRL+C.');

examples/tutorials/callback_api/send.js

@@ -9,7 +9,7 @@ amqp.connect((err, connection) => {
   if (err) return bail(err);
   connection.createChannel((err, channel) => {
     if (err) return bail(err, connection);
-    channel.assertQueue(queue, {durable: false}, (err) => {
+    channel.assertQueue(queue, { durable: false }, (err) => {
       if (err) return bail(err, connection);
       channel.sendToQueue(queue, Buffer.from(text));
       console.log(" [x] Sent '%s'", text);

examples/tutorials/callback_api/worker.js

@@ -15,7 +15,7 @@ amqp.connect((err, connection) => {
       });
     });
 
-    channel.assertQueue(queue, {durable: true}, (err, {queue}) => {
+    channel.assertQueue(queue, { durable: true }, (err, { queue }) => {
       if (err) return bail(err, connection);
       channel.consume(
         queue,
@@ -28,7 +28,7 @@ amqp.connect((err, connection) => {
             channel.ack(message);
           }, seconds * 1000);
         },
-        {noAck: false},
+        { noAck: false },
       );
       console.log(' [*] Waiting for messages. To exit press CTRL+C');
     });

examples/tutorials/emit_log.js

@@ -10,7 +10,7 @@ const text = process.argv.slice(2).join(' ') || 'info: Hello World!';
   try {
     connection = await amqp.connect('amqp://localhost');
     const channel = await connection.createChannel();
-    await channel.assertExchange(exchange, 'fanout', {durable: false});
+    await channel.assertExchange(exchange, 'fanout', { durable: false });
     channel.publish(exchange, '', Buffer.from(text));
     console.log(" [x] Sent '%s'", text);
     await channel.close();

examples/tutorials/emit_log_direct.js

@@ -12,7 +12,7 @@ const text = args.slice(1).join(' ') || 'Hello World!';
   try {
     connection = await amqp.connect('amqp://localhost');
     const channel = await connection.createChannel();
-    await channel.assertExchange(exchange, 'direct', {durable: false});
+    await channel.assertExchange(exchange, 'direct', { durable: false });
     channel.publish(exchange, routingKey, Buffer.from(text));
     console.log(" [x] Sent %s:'%s'", routingKey, text);
     await channel.close();

examples/tutorials/emit_log_topic.js

@@ -12,7 +12,7 @@ const text = args.slice(1).join(' ') || 'Hello World!';
   try {
     connection = await amqp.connect('amqp://localhost');
     const channel = await connection.createChannel();
-    await channel.assertExchange(exchange, 'topic', {durable: false});
+    await channel.assertExchange(exchange, 'topic', { durable: false });
     channel.publish(exchange, routingKeys, Buffer.from(text));
     console.log(" [x] Sent %s:'%s'", routingKeys, text);
     await channel.close();

examples/tutorials/new_task.js

@@ -11,8 +11,8 @@ const text = process.argv.slice(2).join(' ') || 'Hello World!';
   try {
     connection = await amqp.connect('amqp://localhost');
     const channel = await connection.createChannel();
-    await channel.assertQueue(queue, {durable: true});
-    channel.sendToQueue(queue, Buffer.from(text), {persistent: true});
+    await channel.assertQueue(queue, { durable: true });
+    channel.sendToQueue(queue, Buffer.from(text), { persistent: true });
     console.log(" [x] Sent '%s'", text);
     await channel.close();
   } catch (err) {

examples/tutorials/receive.js

@@ -14,13 +14,13 @@ const queue = 'hello';
       await connection.close();
     });
 
-    await channel.assertQueue(queue, {durable: false});
+    await channel.assertQueue(queue, { durable: false });
     await channel.consume(
       queue,
       (message) => {
         console.log(" [x] Received '%s'", message.content.toString());
       },
-      {noAck: true},
+      { noAck: true },
     );
 
     console.log(' [*] Waiting for messages. To exit press CTRL+C');

examples/tutorials/receive_logs.js

@@ -14,8 +14,8 @@ const exchange = 'logs';
       await connection.close();
     });
 
-    await channel.assertExchange(exchange, 'fanout', {durable: false});
-    const {queue} = await channel.assertQueue('', {exclusive: true});
+    await channel.assertExchange(exchange, 'fanout', { durable: false });
+    const { queue } = await channel.assertQueue('', { exclusive: true });
     await channel.bindQueue(queue, exchange, '');
 
     await channel.consume(
@@ -24,7 +24,7 @@ const exchange = 'logs';
         if (message) console.log(" [x] '%s'", message.content.toString());
         else console.warn(' [x] Consumer cancelled');
       },
-      {noAck: true},
+      { noAck: true },
     );
 
     console.log(' [*] Waiting for logs. To exit press CTRL+C');