nocodb/packages/nc-gui/store/sqlMgr.js

function translateUiToLibCall(args, op, opArgs) {
  const data = {
    type: null,
    module: null,
    title: null
  }

  switch (op) {
    case 'projectCreate1':
      data.type = 'Create'
      data.title = opArgs.project.title
      data.module = 'Project'
      break
    case 'projectReadByFolder':
      data.type = 'Reading'
      data.title = ''
      data.module = 'Project'
      break
    case 'tableCreate':
      data.type = 'Create'
      data.title = opArgs.title || opArgs.table_name
      data.module = 'table'
      break
    case 'tableList':
      data.api = 'DB_TABLE_LIST'
      data.type = 'List'
      data.title = 'list'
      data.module = 'table'
      break
    case 'xcTableAndViewList':
      data.api = 'DB_TABLE_LIST'
      data.type = 'List'
      data.title = 'list'
      data.module = 'table'
      break
    case 'tableUpdate':
      data.type = 'Update'
      data.title = opArgs.title || opArgs.table_name
      data.module = 'table'
      break
    case 'tableDelete':
      data.type = 'Delete'
      data.title = opArgs.title || opArgs.table_name
      data.module = 'table'
      break

    case 'viewCreate':
      data.type = 'Create'
      data.title = opArgs.title || opArgs.view_name
      data.module = 'View'
      break
    case 'viewList':
      data.type = 'List'
      data.title = opArgs.title || opArgs.view_name
      data.module = 'View'
      break
    case 'viewUpdate':
      data.type = 'Update'
      // data.title = opArgs.view_name;
      data.module = 'View'
      break
    case 'viewDelete':
      data.type = 'Delete'
      data.title = opArgs.title || opArgs.view_name
      data.module = 'View'
      break

    case 'functionCreate':
      data.type = 'Create'
      data.title = opArgs.function_name
      data.module = 'Function'
      break
    case 'functionList':
      data.type = ''
      // data.title = opArgs.function_name;
      data.module = 'Function'
      break
    case 'functionUpdate':
      data.type = 'Update'
      data.title = opArgs.function_name
      data.module = 'Function'
      break
    case 'functionDelete':
      data.type = 'Delete'
      data.title = opArgs.function_name
      data.module = 'Function'
      break

    case 'procedureCreate':
      data.type = 'Create'
      data.title = opArgs.procedure_name
      data.module = 'Procedure'
      break
    case 'procedureList':
      data.type = 'List'
      // data.title = opArgs.procedure_name;
      data.module = 'Procedure'
      break
    case 'procedureUpdate':
      data.type = 'Update'
      data.title = opArgs.procedure_name
      data.module = 'Procedure'
      break
    case 'procedureDelete':
      data.type = 'Delete'
      data.title = opArgs.procedure_name
      data.module = 'Procedure'
      break

    case 'sequenceCreate':
      data.type = 'Create'
      data.title = opArgs.sequence_name
      data.module = 'Sequence'
      break
    case 'sequenceList':
      data.type = 'List'
      // data.title = opArgs.sequence_name;
      data.module = 'Sequence'
      break
    case 'sequenceUpdate':
      data.type = 'Update'
      data.title = opArgs.sequence_name
      data.module = 'Sequence'
      break
    case 'sequenceDelete':
      data.type = 'Delete'
      data.title = opArgs.sequence_name
      data.module = 'Sequence'
      break

    case 'triggerCreate':
      data.type = 'Create '
      data.title = opArgs.title || opArgs.table_name
      data.module = 'trigger'
      break
    case 'triggerList':
      data.type = 'Create '
      // data.title = opArgs.trigger_name;
      data.module = 'trigger'
      break
    case 'triggerUpdate':
      data.type = 'Update '
      data.title = opArgs.trigger_name
      data.module = 'trigger'
      break
    case 'triggerDelete':
      data.type = 'Delete '
      data.title = opArgs.trigger_name
      data.module = 'trigger'
      break

    case 'indexCreate':
      data.type = 'Create Index on '
      data.title = opArgs.title || opArgs.table_name
      data.module = 'table'
      break
    case 'indexList':
      data.type = 'List'
      // data.title = opArgs.table_name;
      data.module = 'table'
      break
    case 'indexUpdate':
      data.type = 'Update Index on '
      data.title = opArgs.title || opArgs.table_name
      data.module = 'table'
      break
    case 'indexDelete':
      data.type = 'Delete Index on '
      data.title = opArgs.title || opArgs.table_name
      data.module = 'table'
      break

    case 'rowCreate':
      data.type = ''
      data.title = opArgs
      data.module = ''
      break
    case 'rowList':
      data.type = 'List'
      data.title = opArgs
      data.module = ''
      break
    case 'rowUpdate':
      data.type = ''
      data.title = opArgs
      data.module = ''
      break
    case 'rowDelete':
      data.type = ''
      data.title = opArgs
      data.module = ''
      break

    case 'seedInit':
      data.type = 'Init'
      data.title = ''
      data.module = 'Seed'
      break
    case 'seedTerm':
      data.type = 'Term'
      data.title = ''
      data.module = 'Seed'
      break
    case 'seedStart':
      data.type = 'Start'
      data.title = ''
      data.module = 'Seed'
      break
    case 'seedStop':
      data.type = 'Stop'
      data.title = ''
      data.module = 'Seed'
      break
    case 'seedSettingsRead':
      data.type = 'Settings'
      data.title = ''
      data.module = 'Seed'
      break
    case 'seedSettingsCreate':
      data.type = 'Settings Create'
      data.title = ''
      data.module = 'Seed'
      break

    case 'projectGenerateBackend':
      data.type = 'Generate Code'
      data.title = ''
      data.module = 'Project'
      break

    case 'projectGenerateBackendGql':
      data.type = 'Generate GraphQL Code'
      data.title = ''
      data.module = 'Project'
      break
    case 'tableRename':
      data.type = 'Table rename'
      data.title = ''
      data.module = ''
      break

    case 'relationCreate':
    case 'xcM2MRelationCreate':
    case 'xcVirtualRelationCreate':
      data.type = 'Relation create'
      data.title = ''
      data.module = ''
      break

    case 'relationDelete':
    case 'xcVirtualRelationDelete':
    case 'xcRelationColumnDelete':
      data.type = 'Relation delete'
      data.title = ''
      data.module = ''
      break

    default:
      throw new Error(`Should not have occurred ${op}`)
  }

  return data
}

export const state = () => ({
  sqlMgr: null
})

export const mutations = {
  set(state, sqlMgrSingleton) {
    state.sqlMgr = sqlMgrSingleton
  }

}

export const getters = {
  // sqlMgr(state) {
  //   return state.sqlMgr;
  // }
}

export const actions = {

  //
  // async instantiateSqlMgr({commit, state, ...rest}, data) {
  //   console.log(this)
  //   if (!state.sqlMgr) {
  //     sqlMgrSingleton = new SqlMgr(rest);
  //     console.log(
  //       "\n\n************************sqlMgr is created************************\n\n."
  //     );
  //     commit("set", sqlMgrSingleton);
  //   } else {
  //     console.log("sqlMgr is already instantiated.");
  //     console.log(state.sqlMgr);
  //   }
  //   return state.sqlMgr;
  // },

  async ActSqlOpPlus({ commit, state, dispatch, rootState }, [args, op, opArgs]) {
    const params = {}
    if (this.$router.currentRoute && this.$router.currentRoute.params && this.$router.currentRoute.params.project_id) {
      params.project_id = this.$router.currentRoute.params.project_id
    }
    const data = translateUiToLibCall(args, op, opArgs)

    commit('notification/MutListAdd', { status: 'pending', ...data }, { root: true })

    const headers = {}
    if (rootState.project.projectInfo && rootState.project.projectInfo.authType === 'masterKey') {
      headers['xc-master-key'] = rootState.users.masterKey || ''
    } else if (rootState.project.projectInfo && rootState.project.projectInfo.authType === 'jwt') {
      headers['xc-auth'] = rootState.users.token || ''
    }

    try {
      let result = null
      if (data.module === 'Project') {
        result = await dispatch('ActSqlOp', [args, op, opArgs])
      } else if (data.module === 'Seed' || (data.title || '').toLowerCase() === 'list' || data.type.toLowerCase() === 'list') {
        result = await dispatch('ActSqlOp', [args, op, opArgs])
      } else {
        result = (await this.$axios({
          url: '?q=sqlOpPlus_' + op,
          baseURL: `${this.$axios.defaults.baseURL}/dashboard`,
          data: { api: op, ...args, ...params, args: opArgs, sqlOpPlus: true },
          headers,
          method: 'post'
        }
        )).data
      }

      // clear meta cache on relation create/delete
      // todo: clear only necessary metas
      // todo: include missing operations
      if ([
        // 'xcModelSet',
        'xcM2MRelationCreate',
        'xcVirtualRelationCreate',
        'relationCreate',
        'relationDelete',
        'xcVirtualRelationDelete',
        'xcRelationColumnDelete'
      ].includes(op)) {
        if (opArgs.parentTable) {
          dispatch('meta/ActLoadMeta', { ...args, ...params, table_name: opArgs.parentTable, force: true }, { root: true })
        }
        if (opArgs.childTable) {
          dispatch('meta/ActLoadMeta', { ...args, ...params, table_name: opArgs.childTable, force: true }, { root: true })
        }
      }

      commit('notification/MutListRemove', { status: 'success', ...data }, { root: true })
      return result
    } catch (e) {
      commit('notification/MutListRemove', { status: 'error', ...data }, { root: true })
      throw e
    }
  },

  async ActSqlOp({
    commit,
    state,
    rootState,
    dispatch
  }, [args, op, opArgs, cusHeaders, cusAxiosOptions, queryParams, returnResponse]) {
    const params = {}

    if (this.$router.currentRoute && this.$router.currentRoute.params) {
      if (this.$router.currentRoute.params.project_id) {
        params.project_id = this.$router.currentRoute.params.project_id
      } else if (this.$router.currentRoute.params.shared_base_id) {
        params.project_id = rootState.project.projectId
      }
    }

    try {
      const headers = {}
      if (rootState.project.projectInfo && rootState.project.projectInfo.authType === 'masterKey') {
        headers['xc-master-key'] = rootState.users.masterKey
      } else if (rootState.project.projectInfo && rootState.project.projectInfo.authType === 'jwt') {
        headers['xc-auth'] = rootState.users.token
      }

      if (cusHeaders) {
        Object.assign(headers, cusHeaders)
      }
      const res = (await this.$axios({
        url: '?q=sqlOp_' + op,
        baseURL: `${this.$axios.defaults.baseURL}/dashboard`,
        data: { api: op, ...args, ...params, args: opArgs },
        headers,
        method: 'post',
        params: (args && args.query) || {},
        ...(cusAxiosOptions || {})

      }))

      const data = res.data

      // clear meta cache on relation create/delete
      // todo: clear only necessary metas
      // todo: include missing operations
      if ([
        // 'xcModelSet',
        'xcM2MRelationCreate',
        'xcVirtualRelationCreate',
        'relationCreate',
        'relationDelete',
        'xcVirtualRelationDelete',
        'xcRelationColumnDelete'
      ].includes(op)) {
        if (opArgs.parentTable) {
          dispatch('meta/ActLoadMeta', { ...args, ...params, table_name: opArgs.parentTable, force: true }, { root: true })
        }
        if (opArgs.childTable) {
          dispatch('meta/ActLoadMeta', { ...args, ...params, table_name: opArgs.childTable, force: true }, { root: true })
        }
      }

      if (returnResponse) {
        return res
      }

      return data
    } catch (e) {
      let msg
      if (e.response.data instanceof Blob) {
        try {
          msg = JSON.parse(await e.response.data.text()).msg
        } catch {
          msg = 'Some internal error occurred'
        }
      } else {
        msg = e.response.data.msg || 'Some internal error occurred'
      }
      const err = new Error(msg)
      err.response = e.response
      throw err
    }
  },

  async ActUploadOld({
    commit,
    state,
    rootState,
    dispatch
  }, [args, op, opArgs, file, cusHeaders, cusAxiosOptions, formData]) {
    return await dispatch('ActUpload', { args, op, opArgs, file, cusHeaders, cusAxiosOptions, formData })
  },

  async ActTable({
    commit,
    state,
    rootState,
    dispatch
  }, body) {
    const params = {}
    if (this.$router.currentRoute && this.$router.currentRoute.params && this.$router.currentRoute.params.project_id) {
      params.project_id = this.$router.currentRoute.params.project_id
    }

    if (this.$router.currentRoute && this.$router.currentRoute.params && this.$router.currentRoute.params.project_id) {
      params.project_id = this.$router.currentRoute.params.project_id
    }
    const headers = { 'xc-auth': rootState.users.token }

    return (await this.$axios({
      url: `projects/${params.project_id}/tables/${body.id}`,
      baseURL: `${this.$axios.defaults.baseURL}/dashboard`,
      data: body, // {api: op, ...args, args: opArgs},
      headers,
      method: 'post'
    })).data
  },

  async ActUpload({ commit, state, rootState }, {
    args = {},
    op,
    opArgs,
    file,
    cusHeaders = {},
    cusAxiosOptions = {},
    formData = new FormData()
  }) {
    try {
      const params = {}
      if (this.$router.currentRoute && this.$router.currentRoute.params && this.$router.currentRoute.params.project_id) {
        params.project_id = this.$router.currentRoute.params.project_id
      }

      if (this.$router.currentRoute && this.$router.currentRoute.params && this.$router.currentRoute.params.project_id) {
        params.project_id = this.$router.currentRoute.params.project_id
      }

      const headers = {
        'Content-Type': 'multipart/form-data'
      }

      if (rootState.project.projectInfo && rootState.project.projectInfo.authType === 'masterKey') {
        headers['xc-master-key'] = rootState.users.masterKey
      } else if (rootState.project.projectInfo && rootState.project.projectInfo.authType === 'jwt') {
        headers['xc-auth'] = rootState.users.token
      }

      if (cusHeaders) {
        Object.assign(headers, cusHeaders)
      }

      if (file) {
        formData.append('file', file)
      }

      formData.append('json', JSON.stringify({ api: op, ...params, ...args, args: opArgs }))
      // formData.append('project_id', params.project_id);

      return (await this.$axios({
        url: '?q=sqlOp_' + op,
        baseURL: `${this.$axios.defaults.baseURL}/dashboard`,
        data: formData, // {api: op, ...args, args: opArgs},
        headers,
        method: 'post',
        params: { project_id: params.project_id, ...((args && args.query) || {}) },
        ...(cusAxiosOptions || {})
      })).data
    } catch (e) {
      if (e.response && e.response.data) {
        throw new Error(e.response.data.msg)
      }
      throw e
    }
  }

}

/**
 * @copyright Copyright (c) 2021, Xgene Cloud Ltd
 *
 * @author Naveen MR <oof1lab@gmail.com>
 * @author Pranav C Balan <pranavxc@gmail.com>
 * @author Wing-Kam Wong <wingkwong.code@gmail.com>
 *
 * @license GNU AGPL version 3 or any later version
 *
 * 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, either version 3 of the
 * License, or (at your option) any later version.
 *
 * 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 <http://www.gnu.org/licenses/>.
 *
 */