12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455 |
- const API = require("../../lib/API")
- const AccessControl = require("../../lib/AccessControl")
- const { BaseStdResponse } = require("../../BaseStdResponse")
- const db = require("../../plugin/DataBase/db")
- // 添加仓库
- class AddRepo extends API {
- constructor() {
- super()
- this.setMethod("POST")
- this.setPath("/Repos")
- }
- checkName(name) {
- const regex = /^(?!\.)(?!.*\/{2,})(?!.*\.git$)[\u4E00-\u9FA5A-Za-z0-9._-]+(?<!\/)$/
- return regex.test(name)
- }
- async onRequest(req, res) {
- let { uuid, session, name, url } = req.body
- if ([uuid, session, name, url].some(value => value === '' || value === null || value === undefined))
- return res.json({
- ...BaseStdResponse.MISSING_PARAMETER
- })
- if (!this.checkUsername(username))
- return res.json({
- ...BaseStdResponse.ERR,
- msg: '仓库名称不合法!'
- })
- // 检查 session
- if (!await AccessControl.checkSession(uuid, session))
- return res.status(401).json({
- ...BaseStdResponse.ACCESS_DENIED
- })
- const time = new Date().getTime()
- let sql = 'INSERT INTO repos (name, url, create_user, create_time) VALUES (?, ?, ?, ?)'
- let result = await db.query(sql, [name, url, uuid, time])
- if (result && result.affectedRows > 0) {
- res.json({
- ...BaseStdResponse.OK
- })
- } else {
- res.json({ ...BaseStdResponse.ERR, endpoint: 7894378, msg: '添加仓库失败!' })
- }
- }
- }
- module.exports.AddRepo = AddRepo
|