mirror of https://github.com/nocodb/nocodb
212 lines
5.4 KiB
212 lines
5.4 KiB
import axios from 'axios'; |
|
import Vue from 'vue'; |
|
|
|
// const {autocannon} = require("electron").remote.require( |
|
// "./libs" |
|
// ); |
|
|
|
export const state = () => ({ |
|
|
|
/** |
|
* |
|
* type : GET, PUT, POST, DELETE, HEAD, OPTIONS, PATCH |
|
* |
|
* URL : |
|
* |
|
* headers : |
|
* body : |
|
* auth : |
|
* |
|
* response : |
|
* |
|
*/ |
|
list: [{ |
|
type: 'GET', |
|
url: 'localhost:8080', |
|
body: '{}', |
|
headers: [], |
|
response: {status: 200}, |
|
createAt: Date.now() |
|
}], |
|
projectApiFilePaths: {}, |
|
activeEnvironment: {}, |
|
currentProjectKey: '' |
|
|
|
}); |
|
|
|
export const mutations = { |
|
|
|
MutApiFilePathsAdd(state, args) { |
|
state.projectApiFilePaths = { |
|
...state.projectApiFilePaths, |
|
[state.currentProjectKey]: [...state.projectApiFilePaths[state.currentProjectKey], args] |
|
} |
|
}, |
|
|
|
MutApiFilePathsRemove(state, index) { |
|
state.projectApiFilePaths[state.currentProjectKey].splice(index, 1); |
|
Vue.set(state.projectApiFilePaths, state.currentProjectKey, [...state.projectApiFilePaths[state.currentProjectKey]]); |
|
}, |
|
|
|
MutListAdd(state, args) { |
|
state.list.unshift(args); |
|
if (state.list.length > 500) state.list.pop(); |
|
}, |
|
|
|
MutListRemove(state, index) { |
|
// find index and set status |
|
state.list.splice(index, 1); |
|
//state.list = [...state.list] |
|
}, |
|
MutList(state, list) { |
|
state.projectApiFilePaths[state.currentProjectKey] = list; |
|
}, |
|
MutCurrentProjectKey(state, currentProjectKey) { |
|
state.currentProjectKey = currentProjectKey; |
|
}, |
|
MutActiveEnvironment(state, {projectId, env}) { |
|
state.activeEnvironment[projectId] = env; |
|
} |
|
|
|
|
|
}; |
|
|
|
export const getters = { |
|
GtrCurrentApiFilePaths(state) { |
|
return state.projectApiFilePaths[state.currentProjectKey]; |
|
} |
|
}; |
|
|
|
export const actions = { |
|
|
|
async send({commit, state}, {apiDecoded, api}) { |
|
let a = {...apiDecoded}; |
|
let t, t1, t2; |
|
try { |
|
commit('notification/MutToggleProgressBar', true, {root: true}); |
|
|
|
if (apiDecoded.body) { |
|
try { |
|
a.body = JSON.parse(a.body); |
|
} catch (e) { |
|
console.log(e); |
|
} |
|
} |
|
|
|
if (apiDecoded.auth) { |
|
try { |
|
a.auth = JSON.parse(a.auth); |
|
} catch (e) { |
|
console.log(e); |
|
} |
|
} |
|
|
|
a.response = {}; |
|
// t = process.hrtime(); |
|
const req = { |
|
params: a.params ? a.params.reduce((paramsObj, param) => { |
|
if (param.name && param.enabled) paramsObj[param.name] = param.value; |
|
return paramsObj; |
|
}, {}) : {}, |
|
url: a.url, |
|
method: a.type, |
|
data: a.body, |
|
headers: a.headers ? a.headers.reduce((headersObj, header) => { |
|
if (header.name && header.enabled) headersObj[header.name] = header.value; |
|
return headersObj; |
|
}, {}) : {}, |
|
withCredentials: true |
|
}; |
|
console.log(req); |
|
|
|
|
|
if (Object.values(api.perf).every(v => !v)) { |
|
let data = await axios(req); |
|
|
|
// t1 = process.hrtime(t); |
|
// t2 = (t1[0] + t1[1] / 1000000000).toFixed(2); |
|
|
|
a.response.status = data.status; |
|
a.response.headers = data.headers; |
|
a.response.data = data.data; |
|
console.log(data); |
|
} else { |
|
this.$toast.info('Starting performance test').goAway(3000); |
|
try { |
|
// const res = await autocannon({ |
|
// ...req, |
|
// ...api.perf, |
|
// body: req.data |
|
// }); |
|
console.log('perf result', res) |
|
|
|
a.response.status = 200; |
|
a.response.headers = []; |
|
a.response.data = res; |
|
|
|
this.$toast.info('Finished performance test').goAway(3000); |
|
|
|
} catch (e) { |
|
console.log(e) |
|
a.response.status = 400; |
|
a.response.data = e; |
|
} |
|
|
|
} |
|
} catch (e) { |
|
t1 = process.hrtime(t); |
|
t2 = (t1[0] + t1[1] / 1000000000).toFixed(2); |
|
|
|
console.log(Object.keys(e), Object.entries(e)); |
|
a.response = e.response; |
|
//throw e; |
|
} finally { |
|
commit('notification/MutToggleProgressBar', false, {root: true}); |
|
commit('MutListAdd', { |
|
...api, |
|
params: api.params && api.params.map(param => ({...param})), |
|
headers: api.headers && api.headers.map(header => ({...header})), |
|
body: JSON.stringify(api.body), |
|
auth: JSON.stringify(api.auth), |
|
timeTaken: t2, |
|
createdAt: Date.now() |
|
}); |
|
return a.response; |
|
} |
|
|
|
|
|
}, |
|
|
|
async loadApiCollectionForProject({commit, state}, {projectName, projectId}) { |
|
const key = projectName + "__" + projectId; |
|
commit('MutCurrentProjectKey', key) |
|
if (!(key in state.projectApiFilePaths)) { |
|
commit('MutList', []); |
|
} |
|
} |
|
}; |
|
|
|
|
|
|
|
/** |
|
* @copyright Copyright (c) 2021, Xgene Cloud Ltd |
|
* |
|
* @author Naveen MR <oof1lab@gmail.com> |
|
* @author Pranav C Balan <pranavxc@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/>. |
|
* |
|
*/
|
|
|