/*
 * server component for the TimeLimit App
 * Copyright (C) 2019 - 2022 Jonas Lochmann
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Affero General Public License as
 * published by the Free Software Foundation, version 3 of the License.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Affero General Public License for more details.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program.  If not, see <https://www.gnu.org/licenses/>.
 */

import { ForeignKeyConstraintError, UniqueConstraintError } from 'sequelize'
import { ClientPushChangesRequestAction } from '../../../../api/schema'
import { EventHandler } from '../../../../monitoring/eventhandler'
import { ApplyActionDatabaseException } from '../exception/database'
import { ApplyActionException } from '../exception/index'
import { EncodedActionSchemaMismatchException } from '../exception/invalidaction'
import { parseEncodedAction } from '../parse-encoded-action'

export async function dispatch<T1 extends { type: string }, T2> ({ type, action, validator, parser, applier, eventHandler }: {
  type: 'app logic' | 'parent' | 'child'
  action: ClientPushChangesRequestAction
  validator: (input: unknown) => input is T1
  parser: (input: T1) => T2
  applier: (input: T2) => Promise<void>
  eventHandler: EventHandler
}) {
  const parsedSerializedAction = parseEncodedAction(action)

  if (!validator(parsedSerializedAction)) {
    throw new EncodedActionSchemaMismatchException({ type, action: parsedSerializedAction })
  }

  const actionType = parsedSerializedAction.type

  try {
    const parsedAction = parser(parsedSerializedAction)

    try {
      await applier(parsedAction)
    } catch (ex) {
      if (ex instanceof UniqueConstraintError) {
        throw new ApplyActionDatabaseException({
          staticMessage: 'database unique constraint violation of the fields ' + Object.keys(ex.fields).join(', ')
        })
      } else if (ex instanceof ForeignKeyConstraintError) {
        throw new ApplyActionDatabaseException({
          staticMessage: 'database foreign key violation at the table ' + ex.table + '/' + ex.index
        })
      } else throw ex
    }

    eventHandler.countEvent('dispatched action:' + actionType)
  } catch (ex) {
    if (ex instanceof ApplyActionException) {
      throw new ApplyActionException({
        staticMessage: 'error during dispatching ' + actionType + ': ' + ex.staticMessage,
        dynamicMessage: ex.dynamicMessage ? 'error during dispatching ' + actionType + ': ' + ex.dynamicMessage : undefined
      })
    } else throw ex
  }
}