ImportText.js 1.3 KB

1234567891011121314151617181920212223242526272829303132333435
  1. const API = require('../../../../lib/API')
  2. const AccessControl = require('../../../../lib/AccessControl')
  3. const { BaseStdResponse } = require('../../../../BaseStdResponse')
  4. const { importFromText } = require('../../../../lib/Lepao/lepaoProxyPoolService')
  5. class ImportText extends API {
  6. constructor() {
  7. super()
  8. this.setPath('/Admin/Lepao/Proxy/ImportText')
  9. this.setMethod('post')
  10. }
  11. async onRequest(req, res) {
  12. const { uuid, session, text } = req.body
  13. if ([uuid, session].some((v) => v === '' || v === null || v === undefined)) {
  14. return res.json({ ...BaseStdResponse.MISSING_PARAMETER })
  15. }
  16. if (!await AccessControl.checkSession(uuid, session)) {
  17. return res.status(401).json({ ...BaseStdResponse.ACCESS_DENIED })
  18. }
  19. const permission = await AccessControl.getPermission(uuid)
  20. if (!permission.includes('admin') && !permission.includes('service')) {
  21. return res.json({ ...BaseStdResponse.PERMISSION_DENIED })
  22. }
  23. try {
  24. const r = await importFromText(String(text || ''), 'manual')
  25. return res.json({ ...BaseStdResponse.OK, data: r })
  26. } catch (e) {
  27. return res.json({ ...BaseStdResponse.ERR, msg: e.message || '导入失败' })
  28. }
  29. }
  30. }
  31. module.exports.ImportText = ImportText