SpeciesFileGroup/taxonworks

import { Observation } from '@/routes/endpoints'
import {
  setupContinuosPayload,
  setupFreeTextPayload,
  setupPresencePayload,
  setupQualitativePayload,
  setupSamplePayload
} from '../../helpers/setupPayload'
import ComponentNames from '../../helpers/ComponentNames'

const adaptPayload = {
  [ComponentNames.Continuous]: setupContinuosPayload,
  [ComponentNames.Sample]: setupSamplePayload,
  [ComponentNames.FreeText]: setupFreeTextPayload,
  [ComponentNames.Presence]: setupPresencePayload,
  [ComponentNames.Continuous]: setupContinuosPayload,
  [ComponentNames.Qualitative]: setupQualitativePayload
}

export default function ({ columnId, descriptorType, observation }) {
  const payload = []

  if (descriptorType === ComponentNames.Qualitative) {
    observation.characterStateId.forEach((id) => {
      payload.push(
        getPayloadObservationFor(descriptorType, { characterStateId: id })
      )
    })
  } else {
    payload.push(getPayloadObservationFor(descriptorType, observation))
  }

  const requests = payload.map((payload) =>
    Observation.codeRow({
      observation_matrix_column_id: columnId,
      observation: payload
    })
  )

  return new Promise((resolve, reject) => {
    Promise.allSettled(requests).then((responses) => {
      const responsesData = responses.map((r) => r.value.body)

      resolve(getResultFromResponses(responsesData))
    })
  })
}

function getPayloadObservationFor(descriptorType, payload) {
  return adaptPayload[descriptorType](payload)
}

function getResultFromResponses(responses) {
  const data = responses.reduce(
    (acc, curr) => ({
      failed: acc.failed + curr.failed || 0,
      passed: acc.passed + curr.passed || 0,
      exists: acc.exists + curr.exists || 0
    }),
    {
      failed: 0,
      passed: 0,
      exists: 0
    }
  )

  return data
}