import { IJSONObject } from '@automatisch/types';
import defineAction from '../../../../helpers/define-action';
import setConfig from '../../common/postgres-client';
import setParams from '../../common/set-run-time-parameters';

export default defineAction({
  name: 'Insert',
  key: 'insert',
  description: 'Cteate new item in a table in specific schema in postgreSQL.',
  arguments: [
    {
      label: 'Schema name',
      key: 'schema',
      type: 'string' as const,
      value: 'public',
      required: true,
      description: 'The name of the schema.',
      variables: false,
    },
    {
      label: 'Table name',
      key: 'table',
      type: 'string' as const,
      required: true,
      description: 'The name of the table.',
      variables: false,
    },
    {
      label: 'Fields',
      key: 'fields',
      type: 'dynamic' as const,
      required: true,
      description: 'Table columns with values',
      fields: [
        {
          label: 'Column name',
          key: 'columnName',
          type: 'string' as const,
          required: true,
          variables: false,
        },
        {
          label: 'Value',
          key: 'value',
          type: 'string' as const,
          required: true,
          variables: true,
        }
      ],
    },
    {
      label: 'Run-time parameters',
      key: 'params',
      type: 'dynamic' as const,
      required: false,
      description: 'Change a run-time configuration parameter with command SET',
      fields: [
        {
          label: 'Parameter ',
          key: 'configParam',
          type: 'string' as const,
          required: true,
          variables: false,
        },
        {
          label: 'Value',
          key: 'value',
          type: 'string' as const,
          required: true,
          variables: true,
        }
      ],
    }
  ],

  async run($) {
    const pgClient = await setConfig($)

    const params: any = $.step.parameters.params
    if (params[0].configParam != '')
      await setParams($, pgClient)

    const fields: any = $.step.parameters.fields
    let data: IJSONObject = {}
    fields.forEach((ele: any) => { data[ele.columnName] = ele.value })

    const response = await pgClient(`${$.step.parameters.schema}.${$.step.parameters.table}`)
      .returning('*')
      .insert(data) as IJSONObject

    $.setActionItem({ raw: response[0] as IJSONObject });
  },
});