封装JSON5的方法,简化部分代码

pull/291/head
王良 8 months ago
parent d39379f4b6
commit a7dd755b91

@ -2,7 +2,7 @@ const fs = require('fs')
const Shell = require('./shell')
const lodash = require('lodash')
const defConfig = require('./config/index.js')
const JSON5 = require('json5').default
const jsonApi = require('./json.js')
const request = require('request')
const path = require('path')
const log = require('./utils/util.log')
@ -66,14 +66,18 @@ const configApi = {
return
}
if (response && response.statusCode === 200) {
const originalRemoteSavePath = _getRemoteSavePath('original_')
fs.writeFileSync(originalRemoteSavePath, body)
log.info('保存原来的远程配置文件成功:', originalRemoteSavePath)
if (body == null || body.length < 3) {
log.warn('下载远程配置成功,但内容为空:', remoteConfigUrl)
resolve()
return
} else {
log.info('下载远程配置成功:', remoteConfigUrl)
}
// 尝试解析远程配置,如果解析失败,则不保存它
let remoteConfig
try {
remoteConfig = JSON5.parse(body)
remoteConfig = jsonApi.parse(body)
} catch (e) {
log.error(`远程配置内容格式不正确, url: ${remoteConfigUrl}, body: ${body}`)
remoteConfig = null
@ -81,14 +85,22 @@ const configApi = {
if (remoteConfig != null) {
const remoteSavePath = _getRemoteSavePath()
fs.writeFileSync(remoteSavePath, JSON.stringify(remoteConfig, null, '\t'))
fs.writeFileSync(remoteSavePath, body)
log.info('保存远程配置文件成功:', remoteSavePath)
} else {
log.warn('远程配置对象为空:', remoteConfigUrl)
}
resolve()
} else {
const message = '下载远程配置失败:' + response.message + ',code:' + response.statusCode
log.error(message)
log.error('下载远程配置失败, response:', response, ', body:', body)
let message
if (response) {
message = '下载远程配置失败: ' + response.message + ', code: ' + response.statusCode
} else {
message = '下载远程配置失败: response: ' + response
}
reject(new Error(message))
}
})
@ -101,9 +113,9 @@ const configApi = {
const path = _getRemoteSavePath()
try {
if (fs.existsSync(path)) {
log.info('读取远程配置文件:', path)
const file = fs.readFileSync(path)
return JSON5.parse(file.toString())
log.info('读取远程配置文件成功:', path)
return jsonApi.parse(file.toString())
} else {
log.warn('远程配置文件不存在:', path)
}
@ -148,11 +160,11 @@ const configApi = {
// 计算新配置与默认配置(启用远程配置时,含远程配置)的差异,并保存到 config.json 中
const diffConfig = mergeApi.doDiff(defConfig, newConfig)
const configPath = _getConfigPath()
fs.writeFileSync(configPath, JSON.stringify(diffConfig, null, '\t'))
fs.writeFileSync(configPath, jsonApi.stringify(diffConfig))
log.info('保存自定义配置文件成功:', configPath)
// 重载配置
const allConfig = configApi.reload()
const allConfig = configApi.set(diffConfig)
return {
diffConfig,
@ -166,13 +178,16 @@ const configApi = {
* @returns {*}
*/
reload () {
const path = _getConfigPath()
const configPath = _getConfigPath()
let userConfig
if (!fs.existsSync(path)) {
if (!fs.existsSync(configPath)) {
userConfig = {}
log.info('config.json 文件不存在:', configPath)
} else {
const file = fs.readFileSync(path)
userConfig = JSON5.parse(file.toString())
const file = fs.readFileSync(configPath)
log.info('读取 config.json 成功:', configPath)
const fileStr = file.toString()
userConfig = fileStr && fileStr.length > 2 ? jsonApi.parse(fileStr) : {}
}
const config = configApi.set(userConfig)

@ -0,0 +1,13 @@
let JSON5 = require('json5')
if (JSON5.default) {
JSON5 = JSON5.default
}
module.exports = {
parse (str) {
return JSON5.parse(str)
},
stringify (obj) {
return JSON.stringify(obj, null, '\t')
}
}

@ -1,4 +1,5 @@
const nodeConfig = require('./config')
const jsonApi = require('../../../json.js')
const NodePlugin = function (context) {
const { config, shell, event, log } = context
const nodeApi = {
@ -31,7 +32,7 @@ const NodePlugin = function (context) {
const ret = await shell.exec(['npm config list --json'], { type: 'cmd' })
if (ret != null) {
const json = ret.substring(ret.indexOf('{'))
return JSON.parse(json)
return jsonApi.parse(json)
}
return {}
},

@ -6,10 +6,7 @@ const fork = require('child_process').fork
const log = require('../../utils/util.log')
const fs = require('fs')
const path = require('path')
let JSON5 = require('json5')
if (JSON5.default) {
JSON5 = JSON5.default
}
const jsonApi = require('../../json')
let server = null
function fireStatus (status) {
@ -75,8 +72,8 @@ const serverApi = {
// fireStatus('ing') // 启动中
const basePath = serverConfig.setting.userBasePath
const runningConfigPath = path.join(basePath, '/running.json')
fs.writeFileSync(runningConfigPath, JSON.stringify(serverConfig, null, '\t'))
log.info('保存运行时配置文件成功:', runningConfigPath)
fs.writeFileSync(runningConfigPath, jsonApi.stringify(serverConfig))
log.info('保存 running.json 成功:', runningConfigPath)
const serverProcess = fork(mitmproxyPath, [runningConfigPath])
server = {
id: serverProcess.pid,
@ -98,7 +95,7 @@ const serverApi = {
log.error('server process uncaughtException:', err)
})
serverProcess.on('message', function (msg) {
log.info('收到子进程消息', msg.type, msg.event.key, msg.message)
log.info('收到子进程消息:', JSON.stringify(msg))
if (msg.type === 'status') {
fireStatus(msg.event)
} else if (msg.type === 'error') {

@ -2,13 +2,14 @@
* 获取环境变量
*/
const Shell = require('../shell')
const jsonApi = require('../../json')
const execute = Shell.execute
const executor = {
async windows (exec) {
const ret = await exec(['npm config list --json'], { type: 'cmd' })
if (ret != null) {
const json = ret.substring(ret.indexOf('{'))
return JSON.parse(json)
return jsonApi.parse(json)
}
return {}
},

@ -1,6 +1,8 @@
const JSON5 = require('json5')
const jsonApi = require('../src/json.js')
const DevSidecar = require('../index')
const fs = require('fs')
const log = require('../src/utils/util.log')
// 启动服务
const mitmproxyPath = './start/mitmproxy'
async function startup () {
@ -10,7 +12,8 @@ async function startup () {
const configPath = './start/user_config.json5'
if (fs.existsSync(configPath)) {
const file = fs.readFileSync(configPath)
const userConfig = JSON5.parse(file.toString())
const userConfig = jsonApi.parse(file.toString())
log.info('读取 user_config.json5 成功:', configPath)
DevSidecar.api.config.set(userConfig)
}

@ -1,8 +1,9 @@
// eslint-disable-next-line no-unused-vars
const server = require('@docmirror/mitmproxy')
const JSON5 = require('json5')
const jsonApi = require('../src/json.js')
const path = require('path')
const home = process.env.USER_HOME || process.env.HOME || 'C:/Users/Administrator/'
const log = require('../src/utils/util.log')
let configPath
if (process.argv && process.argv.length > 3) {
configPath = process.argv[2]
@ -12,10 +13,12 @@ if (process.argv && process.argv.length > 3) {
const fs = require('fs')
const configJson = fs.readFileSync(configPath)
const config = JSON5.parse(configJson)
log.info('读取 running.json by core 成功:', configPath)
const config = jsonApi.parse(configJson.toString())
// const scriptDir = '../../gui/extra/scripts/'
// config.setting.script.defaultDir = path.join(__dirname, scriptDir)
// const pacFilePath = '../../gui/extra/pac/pac.txt'
// config.plugin.overwall.pac.customPacFilePath = path.join(__dirname, pacFilePath)
config.setting.rootDir = path.join(__dirname, '../../gui/')
log.info(`start mitmproxy config by core: 读取配置文件: ${configPath}`)
server.start(config)

@ -2,15 +2,17 @@ import lodash from 'lodash'
import DevSidecar from '@docmirror/dev-sidecar'
import { ipcMain } from 'electron'
import fs from 'fs'
import JSON5 from 'json5'
import path from 'path'
const pk = require('../../../package.json')
const mitmproxyPath = path.join(__dirname, 'mitmproxy.js')
process.env.DS_EXTRA_PATH = path.join(__dirname, '../extra/')
const jsonApi = require('@docmirror/dev-sidecar/src/json.js')
const log = require('../../utils/util.log')
const getDefaultConfigBasePath = function () {
return DevSidecar.api.config.get().server.setting.userBasePath
}
const localApi = {
/**
* 返回所有api列表供vue来ipc调用
@ -47,7 +49,12 @@ const localApi = {
let setting = {}
if (fs.existsSync(settingPath)) {
const file = fs.readFileSync(settingPath)
setting = JSON5.parse(file.toString())
try {
setting = jsonApi.parse(file.toString())
log.info('读取 setting.json 成功:', settingPath)
} catch (e) {
log.error('读取 setting.json 失败:', settingPath, ', error:', e)
}
if (setting == null) {
setting = {}
}
@ -57,15 +64,26 @@ const localApi = {
}
if (setting.installTime == null) {
// 设置安装时间
setting.installTime = new Date().getTime()
// 初始化 rootCa.setuped
if (setting.rootCa == null) {
setting.rootCa = {
setuped: false,
desc: '根证书未安装'
}
}
// 保存 setting.json
localApi.setting.save(setting)
}
return setting
},
save (setting = {}) {
const settingPath = _getSettingsPath()
fs.writeFileSync(settingPath, JSON.stringify(setting, null, '\t'))
log.info('保存setting配置文件成功', settingPath)
fs.writeFileSync(settingPath, jsonApi.stringify(setting))
log.info('保存 setting.json 配置文件成功:', settingPath)
}
},
/**

@ -1,14 +1,17 @@
// eslint-disable-next-line no-unused-vars
const log = require('../utils/util.log')
const server = require('@docmirror/mitmproxy')
const JSON5 = require('json5').default
const jsonApi = require('@docmirror/dev-sidecar/src/json.js')
const configPath = process.argv[2]
const fs = require('fs')
const path = require('path')
const configJson = fs.readFileSync(configPath)
const config = JSON5.parse(configJson)
log.info('读取 running.json by gui bridge 成功:', configPath)
const config = jsonApi.parse(configJson.toString())
// const scriptDir = '../extra/scripts/'
// config.setting.script.defaultDir = path.join(__dirname, scriptDir)
// const pacFilePath = '../extra/pac/pac.txt'
// config.plugin.overwall.pac.customPacFilePath = path.join(__dirname, pacFilePath)
config.setting.rootDir = path.join(__dirname, '../')
log.info(`start mitmproxy config by gui bridge: ${configPath}`)
server.start(config)

@ -252,6 +252,13 @@ export default {
//
rootCa.setuped = true
//
rootCa.setupTime = new Date().getTime()
//
rootCa.desc = '根证书已安装'
// noTip
// delete rootCa.noTip
this.$set(this, 'setting', this.setting)
this.$api.setting.save(this.setting)
},

Loading…
Cancel
Save