mirror of
https://github.com/semaphoreui/semaphore.git
synced 2024-11-23 20:35:24 +01:00
66 lines
1.5 KiB
Go
66 lines
1.5 KiB
Go
package sql
|
|
|
|
import (
|
|
"encoding/base64"
|
|
"github.com/ansible-semaphore/semaphore/db"
|
|
"github.com/gorilla/securecookie"
|
|
)
|
|
|
|
func (d *SqlDb) GetRunner(projectID int, runnerID int) (runner db.Runner, err error) {
|
|
return
|
|
}
|
|
|
|
func (d *SqlDb) GetRunners(projectID int) (runners []db.Runner, err error) {
|
|
return
|
|
}
|
|
|
|
func (d *SqlDb) DeleteRunner(projectID int, runnerID int) (err error) {
|
|
return
|
|
}
|
|
|
|
func (d *SqlDb) GetGlobalRunner(runnerID int) (runner db.Runner, err error) {
|
|
err = d.getObject(0, db.GlobalRunnerProps, runnerID, &runner)
|
|
return
|
|
}
|
|
|
|
func (d *SqlDb) GetGlobalRunners() (runners []db.Runner, err error) {
|
|
err = d.getObjects(0, db.GlobalRunnerProps, db.RetrieveQueryParams{}, &runners)
|
|
return
|
|
}
|
|
|
|
func (d *SqlDb) DeleteGlobalRunner(runnerID int) (err error) {
|
|
err = d.deleteObject(0, db.GlobalRunnerProps, runnerID)
|
|
return
|
|
}
|
|
|
|
func (d *SqlDb) UpdateRunner(runner db.Runner) (err error) {
|
|
_, err = d.exec(
|
|
"update runner set webhook=?, max_parallel_tasks=? where id=?",
|
|
runner.Webhook,
|
|
runner.MaxParallelTasks,
|
|
runner.ID)
|
|
|
|
return
|
|
}
|
|
|
|
func (d *SqlDb) CreateRunner(runner db.Runner) (newRunner db.Runner, err error) {
|
|
token := base64.StdEncoding.EncodeToString(securecookie.GenerateRandomKey(32))
|
|
|
|
insertID, err := d.insert(
|
|
"id",
|
|
"insert into runner (project_id, token, webhook, max_parallel_tasks) values (?, ?, ?, ?)",
|
|
runner.ProjectID,
|
|
token,
|
|
runner.Webhook,
|
|
runner.MaxParallelTasks)
|
|
|
|
if err != nil {
|
|
return
|
|
}
|
|
|
|
newRunner = runner
|
|
newRunner.ID = insertID
|
|
newRunner.Token = token
|
|
return
|
|
}
|