AddRepo.js 1.6 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455
  1. const API = require("../../lib/API")
  2. const AccessControl = require("../../lib/AccessControl")
  3. const { BaseStdResponse } = require("../../BaseStdResponse")
  4. const db = require("../../plugin/DataBase/db")
  5. // 添加仓库
  6. class AddRepo extends API {
  7. constructor() {
  8. super()
  9. this.setMethod("POST")
  10. this.setPath("/Repos")
  11. }
  12. checkName(name) {
  13. const regex = /^(?!\.)(?!.*\/{2,})(?!.*\.git$)[\u4E00-\u9FA5A-Za-z0-9._-]+(?<!\/)$/
  14. return regex.test(name)
  15. }
  16. async onRequest(req, res) {
  17. let { uuid, session, name, url } = req.body
  18. if ([uuid, session, name, url].some(value => value === '' || value === null || value === undefined))
  19. return res.json({
  20. ...BaseStdResponse.MISSING_PARAMETER
  21. })
  22. if (!this.checkUsername(username))
  23. return res.json({
  24. ...BaseStdResponse.ERR,
  25. msg: '仓库名称不合法!'
  26. })
  27. // 检查 session
  28. if (!await AccessControl.checkSession(uuid, session))
  29. return res.status(401).json({
  30. ...BaseStdResponse.ACCESS_DENIED
  31. })
  32. const time = new Date().getTime()
  33. let sql = 'INSERT INTO repos (name, url, create_user, create_time) VALUES (?, ?, ?, ?)'
  34. let result = await db.query(sql, [name, url, uuid, time])
  35. if (result && result.affectedRows > 0) {
  36. res.json({
  37. ...BaseStdResponse.OK
  38. })
  39. } else {
  40. res.json({ ...BaseStdResponse.ERR, endpoint: 7894378, msg: '添加仓库失败!' })
  41. }
  42. }
  43. }
  44. module.exports.AddRepo = AddRepo