File setDocs.ts has 371 lines of code (exceeds 250 allowed). Consider refactoring.

Open

/* eslint-disable security/detect-object-injection */
import debug from 'debug'
import prepareFilter from './utils/prepareFilter.js'
import { serializeItem } from './utils/serialize.js'
import { isObject, isObjectWithId, ObjectWithId } from './utils/is.js'

Function setMongoSelectorFromQueryObj has a Cognitive Complexity of 30 (exceeds 5 allowed). Consider refactoring.

Open

function setMongoSelectorFromQueryObj(
  allParams: Record<string, unknown>,
  { path, op = 'eq', value, valuePath, param, variable, expr }: QueryObject,
  useIdAsInternalId: boolean,
  filter = {},

• Read up
  Read up

File prepareAggregation.ts has 335 lines of code (exceeds 250 allowed). Consider refactoring.

Open

import {
  GroupMethod,
  GroupObject,
  AggregationObject,
  AggregationObjectGroup,

Function getDocs has 96 lines of code (exceeds 25 allowed). Consider refactoring.

Open

export default async function getDocs(
  action: Action,
  client: MongoClient,
  useIdAsInternalId = false,
): Promise<Response> {

Function updateMany has a Cognitive Complexity of 22 (exceeds 5 allowed). Consider refactoring.

Open

async function updateMany(
  operations: Operation[],
  collection: Collection,
  action: Action,
) {

• Read up
  Read up

File getDocs.ts has 279 lines of code (exceeds 250 allowed). Consider refactoring.

Open

import assert from 'node:assert/strict'
import debug from 'debug'
import mapAny from 'map-any'
import { getProperty, setProperty } from 'dot-prop'
import prepareFilter from './utils/prepareFilter.js'

Function updateMany has 52 lines of code (exceeds 25 allowed). Consider refactoring.

Open

async function updateMany(
  operations: Operation[],
  collection: Collection,
  action: Action,
) {

Function getDocs has a Cognitive Complexity of 15 (exceeds 5 allowed). Consider refactoring.

Open

export default async function getDocs(
  action: Action,
  client: MongoClient,
  useIdAsInternalId = false,
): Promise<Response> {

• Read up
  Read up

Function connect has 43 lines of code (exceeds 25 allowed). Consider refactoring.

Open

export default async function connect(
  Client: typeof MongoClient,
  options: ServiceOptions,
  emit: (eventType: string, ...args: unknown[]) => void,
  auth?: Record<string, unknown> | null,

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

Open

export default async function listen(
  dispatch: Dispatch,
  connection: Connection | null,
  authenticate: AuthenticateExternal,
): Promise<Response> {

Function createOrReuseClient has 40 lines of code (exceeds 25 allowed). Consider refactoring.

Open

async function createOrReuseClient(
  Client: typeof MongoClient,
  mongoUri: string,
  options: MongoClientOptions,
  emit: (eventType: string, ...args: unknown[]) => void,

Function setDocs has 39 lines of code (exceeds 25 allowed). Consider refactoring.

Open

export default async function setDocs(
  action: Action,
  client: MongoClient,
  useIdAsInternalId = false,
): Promise<Response> {

Function updateOne has 36 lines of code (exceeds 25 allowed). Consider refactoring.

Open

async function updateOne(
  operation: Operation,
  collection: Collection,
  action: Action,
) {

Function toMongo has 36 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  function toMongo(obj: AggregationObject) {
    switch (obj.type) {
      case 'group':
        return groupToMongo(obj, useIdAsInternalId)
      case 'sort':

Function createOperation has 28 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  function createOperation(item: unknown): Operation | OperationError {
    if (!isObjectWithId(item)) {
      return { error: 'Only object data with an id may be sent to MongoDB' }
    }

Function disconnect has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.

Open

export default async function disconnect(
  connection: Connection | null,
): Promise<void> {
  if (connection?.status === 'ok' && connection.mongo) {
    connection.mongo.count -= 1

• Read up
  Read up

Function updateOne has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.

Open

async function updateOne(
  operation: Operation,
  collection: Collection,
  action: Action,
) {

• Read up
  Read up

Function prepareFilter has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

export default function prepareFilter(
  queryArray: QueryArray = [],
  params: Params = {},
  pageId?: ParsedPageId,
  useIdAsInternalId = false,

• Read up
  Read up

Function createOrReuseClient has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

  Client: typeof MongoClient,
  mongoUri: string,
  options: MongoClientOptions,
  emit: (eventType: string, ...args: unknown[]) => void,
  throwAfterFailedHeartbeatCount?: number,

Function connect has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

  Client: typeof MongoClient,
  options: ServiceOptions,
  emit: (eventType: string, ...args: unknown[]) => void,
  auth?: Record<string, unknown> | null,
  connection: Connection | null = null,