2457f5ff22
- Massive replacement of changing `code.gitea.io/gitea` to `forgejo.org`. - Resolves forgejo/discussions#258 Reviewed-on: https://codeberg.org/forgejo/forgejo/pulls/7337 Reviewed-by: Earl Warren <earl-warren@noreply.codeberg.org> Reviewed-by: Michael Kriese <michael.kriese@gmx.de> Reviewed-by: Beowulf <beowulf@beocode.eu> Reviewed-by: Panagiotis "Ivory" Vasilopoulos <git@n0toose.net> Co-authored-by: Gusted <postmaster@gusted.xyz> Co-committed-by: Gusted <postmaster@gusted.xyz>
55 lines
1.8 KiB
Go
55 lines
1.8 KiB
Go
// Copyright 2023 The Gitea Authors. All rights reserved.
|
|
// SPDX-License-Identifier: MIT
|
|
|
|
package actions
|
|
|
|
import (
|
|
"context"
|
|
|
|
"forgejo.org/models/db"
|
|
)
|
|
|
|
// ActionTaskOutput represents an output of ActionTask.
|
|
// So the outputs are bound to a task, that means when a completed job has been rerun,
|
|
// the outputs of the job will be reset because the task is new.
|
|
// It's by design, to avoid the outputs of the old task to be mixed with the new task.
|
|
type ActionTaskOutput struct {
|
|
ID int64
|
|
TaskID int64 `xorm:"INDEX UNIQUE(task_id_output_key)"`
|
|
OutputKey string `xorm:"VARCHAR(255) UNIQUE(task_id_output_key)"`
|
|
OutputValue string `xorm:"MEDIUMTEXT"`
|
|
}
|
|
|
|
func init() {
|
|
db.RegisterModel(new(ActionTaskOutput))
|
|
}
|
|
|
|
// FindTaskOutputByTaskID returns the outputs of the task.
|
|
func FindTaskOutputByTaskID(ctx context.Context, taskID int64) ([]*ActionTaskOutput, error) {
|
|
var outputs []*ActionTaskOutput
|
|
return outputs, db.GetEngine(ctx).Where("task_id=?", taskID).Find(&outputs)
|
|
}
|
|
|
|
// FindTaskOutputKeyByTaskID returns the keys of the outputs of the task.
|
|
func FindTaskOutputKeyByTaskID(ctx context.Context, taskID int64) ([]string, error) {
|
|
var keys []string
|
|
return keys, db.GetEngine(ctx).Table(ActionTaskOutput{}).Where("task_id=?", taskID).Cols("output_key").Find(&keys)
|
|
}
|
|
|
|
// InsertTaskOutputIfNotExist inserts a new task output if it does not exist.
|
|
func InsertTaskOutputIfNotExist(ctx context.Context, taskID int64, key, value string) error {
|
|
return db.WithTx(ctx, func(ctx context.Context) error {
|
|
sess := db.GetEngine(ctx)
|
|
if exist, err := sess.Exist(&ActionTaskOutput{TaskID: taskID, OutputKey: key}); err != nil {
|
|
return err
|
|
} else if exist {
|
|
return nil
|
|
}
|
|
_, err := sess.Insert(&ActionTaskOutput{
|
|
TaskID: taskID,
|
|
OutputKey: key,
|
|
OutputValue: value,
|
|
})
|
|
return err
|
|
})
|
|
}
|