Something went wrong. Try again.
Monorepo for Tangled
Something went wrong. Try again.
12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152package db
import ( "errors"
"tangled.org/core/spindle/models")
type FinishedLog struct { LeaseID string Workflow string Ref string Hash string}
func (d *DB) GetFinishedLog(wid models.WorkflowId) (*FinishedLog, error) { if err := validateWorkflowIdentity(wid); err != nil { return nil, err } var fl FinishedLog err := d.QueryRow( `select lease_id, workflow, ref, hash from mill_artifacts where knot = ? and rkey = ? and workflow = ? order by id desc limit 1`, wid.Knot, wid.Rkey, wid.Name, ).Scan(&fl.LeaseID, &fl.Workflow, &fl.Ref, &fl.Hash) if err != nil { return nil, err } return &fl, nil}
func (d *DB) SaveArtifactRef(leaseID, repoDid string, wid models.WorkflowId, ref, hash string) error { if err := validateWorkflowIdentity(wid); err != nil { return err } _, err := d.Exec( `insert into mill_artifacts (lease_id, repo_did, knot, rkey, workflow, ref, hash) values (?, ?, ?, ?, ?, ?, ?)`, leaseID, repoDid, wid.Knot, wid.Rkey, wid.Name, ref, hash, ) return err}
func validateWorkflowIdentity(wid models.WorkflowId) error { if wid.Knot == "" || wid.Rkey == "" || wid.Name == "" { return errors.New("incomplete workflow identity") } return nil}