Something went wrong. Try again.
Monorepo for Tangled
Something went wrong. Try again.
Go
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103package db
import ( "fmt" "time"
"tangled.org/core/appview/models")
// AddSiteDeploy records a site deploy attempt.func AddSiteDeploy(e Execer, deploy *models.SiteDeploy) error { result, err := e.Exec(` insert into site_deploys ( repo_did, branch, dir, commit_sha, status, trigger, error ) values (?, ?, ?, ?, ?, ?, ?) `, deploy.RepoDid, deploy.Branch, deploy.Dir, deploy.CommitSHA, string(deploy.Status), string(deploy.Trigger), deploy.Error, ) if err != nil { return fmt.Errorf("failed to insert site deploy: %w", err) }
id, err := result.LastInsertId() if err != nil { return fmt.Errorf("failed to get site deploy id: %w", err) }
deploy.Id = id return nil}
// GetSiteDeploys returns recent deploy records for a repository, newest first.func GetSiteDeploys(e Execer, repoDid string, limit int) ([]models.SiteDeploy, error) { if limit <= 0 { limit = 20 }
rows, err := e.Query(` select id, repo_did, branch, dir, commit_sha, status, trigger, error, created_at from site_deploys where repo_did = ? order by created_at desc limit ? `, repoDid, limit) if err != nil { return nil, fmt.Errorf("failed to query site deploys: %w", err) } defer rows.Close()
var deploys []models.SiteDeploy for rows.Next() { var d models.SiteDeploy var createdAt string
if err := rows.Scan( &d.Id, &d.RepoDid, &d.Branch, &d.Dir, &d.CommitSHA, &d.Status, &d.Trigger, &d.Error, &createdAt, ); err != nil { return nil, fmt.Errorf("failed to scan site deploy: %w", err) }
if t, err := time.Parse(time.RFC3339, createdAt); err == nil { d.CreatedAt = t }
deploys = append(deploys, d) }
if err := rows.Err(); err != nil { return nil, fmt.Errorf("failed to iterate site deploys: %w", err) }
return deploys, nil}