node-celery-ts/node-celery-ts

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

Open

    public pop(): T | undefined {
        if (isNullOrUndefined(this.tail)) {
            return undefined;
        }

• Read up
  Read up

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

Open

    public shift(): T | undefined {
        if (isNullOrUndefined(this.head)) {
            return undefined;
        }

• Read up
  Read up

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

Open

export const createYamlSerializer = (): Serializer => ({
    serialize: (data: any): Buffer =>
        Buffer.from(JsYaml.safeDump(data), "utf8"),

    deserialize: (data: Buffer): any => JsYaml.safeLoad(data.toString("utf8")),

• Read up
  Read up

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

Open

export const createJsonSerializer = (): Serializer => ({
    serialize: (data: any): Buffer => Buffer.from(JSON.stringify(data), "utf8"),

    deserialize: (data: Buffer): any => JSON.parse(data.toString("utf8")),
});

• Read up
  Read up

File task.ts has 275 lines of code (exceeds 250 allowed). Consider refactoring.

Open

// BSD 3-Clause License
//
// Copyright (c) 2021, node-celery-ts contributors
// All rights reserved.
//

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

Open

export const createPlaintextEncoder = (): Encoder => ({
    encode: (data: Buffer): string => data.toString("utf8"),

    decode: (data: string): Buffer => Buffer.from(data, "utf8"),
});

• Read up
  Read up

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

Open

export const createBase64Encoder = (): Encoder => ({
    encode: (data: Buffer): string => data.toString("base64"),

    decode: (data: string): Buffer => Buffer.from(data, "base64"),
});

• Read up
  Read up

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

Open

export const createIdentityCompressor = (): Compressor => ({
    compress: (buffer: Buffer) => Buffer.from(buffer),

    decompress: (buffer: Buffer) => Buffer.from(buffer),
});

• Read up
  Read up

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

Open

export const createGzipCompressor = (): Compressor => ({
    compress: (buffer: Buffer) => Zlib.gzipSync(buffer),

    decompress: (buffer: Buffer) => Zlib.unzipSync(buffer),
});

• Read up
  Read up

Function applyAsync has 42 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public applyAsync({
        args,
        compression = Packer.Compressor.Identity,
        eta,
        expires,

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

Open

const createEncoder = (type: EncoderType): Encoder.Encoder => {
    switch (type) {
    case EncoderType.Base64:
        return Encoder.createBase64Encoder();
    case EncoderType.Plaintext:

• Read up
  Read up

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

Open

const createSerializer = (type: SerializerType): Serializer.Serializer => {
    switch (type) {
    case SerializerType.Json:
        return Serializer.createJsonSerializer();
    case SerializerType.Yaml:

• Read up
  Read up

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

Open

    public isPending(key: K): boolean {
        const entry = this.data.get(key);

        return !isUndefined(entry) && entry.status === State.Pending;
    }

• Read up
  Read up

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

Open

        if (isNullOrUndefined(this.tail)) {
            this.head = toPush;
            this.tail = toPush;
        } else {
            this.tail.next = toPush;

• Read up
  Read up

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

Open

    public isRejected(key: K): boolean {
        const entry = this.data.get(key);

        return !isUndefined(entry) && entry.status === State.Rejected;
    }

• Read up
  Read up

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

Open

        if (isNullOrUndefined(this.head)) {
            this.head = toUnshift;
            this.tail = toUnshift;
        } else {
            this.head.previous = toUnshift;

• Read up
  Read up

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

Open

    public isFulfilled(key: K): boolean {
        const entry = this.data.get(key);

        return !isUndefined(entry) && entry.status === State.Fulfilled;
    }

• Read up
  Read up

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

Open

    public pack(data: any): string {
        const serialized = this.serializer.serialize(data);
        const compressed = this.compressor.compress(serialized);
        const encoded = this.encoder.encode(compressed);

• Read up
  Read up

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

Open

    public unpack(packed: string): any {
        const decoded = this.encoder.decode(packed);
        const decompressed = this.compressor.decompress(decoded);
        const deserialized = this.serializer.deserialize(decompressed);

• Read up
  Read up

Function addHostUserAndPass has 31 lines of code (exceeds 25 allowed). Consider refactoring.

Open

const addHostUserAndPass = (uri: UriJs.Parts, parsing: Uri): Uri => {
    const withUser = addHostAndUser(uri, parsing);

    if (isNullOrUndefined(withUser.authority)) {
        return withUser;