anephenix/hub

File pubsub.test.js has 842 lines of code (exceeds 250 allowed). Consider refactoring.

Open

// Dependencies
const assert = require('assert');
const { Hub, HubClient } = require('../../index');
const WebSocket = require('ws');
const { v4: uuidv4 } = require('uuid');

Similar blocks of code found in 2 locations. Consider refactoring.

Open

                const authenticate = ({ data, socket }) => {
                    assert.strictEqual(data.password, 'food');
                    assert.strictEqual(socket.clientId, 'ooo');
                    called = true;
                    return called;

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

                const authenticate = ({ data, socket }) => {
                    assert.strictEqual(data.password, 'food');
                    assert.strictEqual(socket.clientId, 'woof');
                    called = true;
                    return called;

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

            it('should return an error response if the channel is missing', async () => {
                assert.rejects(
                    async () => {
                        await hub.pubsub.publish({
                            data: {

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

            it('should return an error response if the message is missing', async () => {
                assert.rejects(
                    async () => {
                        await hub.pubsub.publish({
                            data: {

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

                assert.throws(
                    () => {
                        hub.pubsub.addChannelConfiguration({
                            channel: normalChannelFive,
                            authenticate,

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

                assert.throws(
                    () => {
                        hub.pubsub.addChannelConfiguration({
                            channel: wildcardChannelFour,
                            authenticate,

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

                assert.throws(
                    () => {
                        hub.pubsub.addChannelConfiguration({
                            channel: wildcardChannelTwo,
                            authenticate,

• Read up
  Read up

Identical blocks of code found in 9 locations. Consider refactoring.

Open

            hubClient.sarus.on('message', (event) => {
                const message = JSON.parse(event.data);
                messages.push(message);
            });

• Read up
  Read up

Identical blocks of code found in 9 locations. Consider refactoring.

Open

            hubClient.sarus.on('message', (event) => {
                const message = JSON.parse(event.data);
                messages.push(message);
            });

• Read up
  Read up

Identical blocks of code found in 9 locations. Consider refactoring.

Open

                hubClient.sarus.on('message', (event) => {
                    const message = JSON.parse(event.data);
                    messages.push(message);
                });

• Read up
  Read up

Identical blocks of code found in 9 locations. Consider refactoring.

Open

                hubClient.sarus.on('message', (event) => {
                    const message = JSON.parse(event.data);
                    messages.push(message);
                });

• Read up
  Read up

Identical blocks of code found in 9 locations. Consider refactoring.

Open

            hubClient.sarus.on('message', (event) => {
                const message = JSON.parse(event.data);
                messages.push(message);
            });

• Read up
  Read up

Identical blocks of code found in 9 locations. Consider refactoring.

Open

            hubClient.sarus.on('message', (event) => {
                const message = JSON.parse(event.data);
                messages.push(message);
            });

• Read up
  Read up

Identical blocks of code found in 9 locations. Consider refactoring.

Open

            hubClient.sarus.on('message', (event) => {
                const message = JSON.parse(event.data);
                messages.push(message);
            });

• Read up
  Read up

Identical blocks of code found in 9 locations. Consider refactoring.

Open

                hubClient.sarus.on('message', (event) => {
                    const message = JSON.parse(event.data);
                    messages.push(message);
                });

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

                assert.rejects(
                    async () => {
                        await hub.pubsub.subscribe({ data, socket });
                    },
                    { message: 'No channel was passed in the data' }

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

                assert.rejects(
                    async () => {
                        await hub.pubsub.subscribe({ data, socket });
                    },
                    { message: 'No client id was found on the WebSocket' }

• Read up
  Read up