+25 -16

appview/db/db.go

··· 603 603 deleted text -- timestamp when the domain was released/unclaimed; null means actively claimed 604 604 ); 605 605 606 606 + create table if not exists repo_sites ( 607 607 + id integer primary key autoincrement, 608 608 + repo_at text not null unique, 609 609 + branch text not null, 610 610 + dir text not null default '/', 611 611 + is_index integer not null default 0, 612 612 + created text not null default (strftime('%Y-%m-%dT%H:%M:%SZ', 'now')), 613 613 + updated text not null default (strftime('%Y-%m-%dT%H:%M:%SZ', 'now')), 614 614 + foreign key (repo_at) references repos(at_uri) on delete cascade 615 615 + ); 616 616 + 617 617 + create table if not exists site_deploys ( 618 618 + id integer primary key autoincrement, 619 619 + repo_at text not null, 620 620 + branch text not null, 621 621 + dir text not null default '/', 622 622 + commit_sha text not null default '', 623 623 + status text not null check (status in ('success', 'failure')), 624 624 + trigger text not null check (trigger in ('config_change', 'push')), 625 625 + error text not null default '', 626 626 + created_at text not null default (strftime('%Y-%m-%dT%H:%M:%SZ', 'now')), 627 627 + foreign key (repo_at) references repos(at_uri) on delete cascade 628 628 + ); 629 629 + 606 630 create table if not exists migrations ( 607 631 id integer primary key autoincrement, 608 632 name text unique ··· 622 646 create index if not exists idx_references_to_at on reference_links(to_at); 623 647 create index if not exists idx_webhooks_repo_at on webhooks(repo_at); 624 648 create index if not exists idx_webhook_deliveries_webhook_id on webhook_deliveries(webhook_id); 649 649 + create index if not exists idx_site_deploys_repo_at on site_deploys(repo_at); 625 650 `) 626 651 if err != nil { 627 652 return nil, err ··· 1245 1270 1246 1271 -- rename new table 1247 1272 alter table profile_stats_new rename to profile_stats; 1248 1248 - `) 1249 1249 - return err 1250 1250 - }) 1251 1251 - 1252 1252 - orm.RunMigration(conn, logger, "add-repo-sites-table", func(tx *sql.Tx) error { 1253 1253 - _, err := tx.Exec(` 1254 1254 - create table if not exists repo_sites ( 1255 1255 - id integer primary key autoincrement, 1256 1256 - repo_at text not null unique, 1257 1257 - branch text not null, 1258 1258 - dir text not null default '/', 1259 1259 - is_index integer not null default 0, 1260 1260 - created text not null default (strftime('%Y-%m-%dT%H:%M:%SZ', 'now')), 1261 1261 - updated text not null default (strftime('%Y-%m-%dT%H:%M:%SZ', 'now')), 1262 1262 - foreign key (repo_at) references repos(at_uri) on delete cascade 1263 1263 - ); 1264 1273 `) 1265 1274 return err 1266 1275 })

+102

appview/db/site_deploys.go

··· 1 1 + package db 2 2 + 3 3 + import ( 4 4 + "fmt" 5 5 + "time" 6 6 + 7 7 + "tangled.org/core/appview/models" 8 8 + ) 9 9 + 10 10 + // AddSiteDeploy records a site deploy attempt. 11 11 + func AddSiteDeploy(e Execer, deploy *models.SiteDeploy) error { 12 12 + result, err := e.Exec(` 13 13 + insert into site_deploys ( 14 14 + repo_at, 15 15 + branch, 16 16 + dir, 17 17 + commit_sha, 18 18 + status, 19 19 + trigger, 20 20 + error 21 21 + ) values (?, ?, ?, ?, ?, ?, ?) 22 22 + `, 23 23 + deploy.RepoAt, 24 24 + deploy.Branch, 25 25 + deploy.Dir, 26 26 + deploy.CommitSHA, 27 27 + string(deploy.Status), 28 28 + string(deploy.Trigger), 29 29 + deploy.Error, 30 30 + ) 31 31 + if err != nil { 32 32 + return fmt.Errorf("failed to insert site deploy: %w", err) 33 33 + } 34 34 + 35 35 + id, err := result.LastInsertId() 36 36 + if err != nil { 37 37 + return fmt.Errorf("failed to get site deploy id: %w", err) 38 38 + } 39 39 + 40 40 + deploy.Id = id 41 41 + return nil 42 42 + } 43 43 + 44 44 + // GetSiteDeploys returns recent deploy records for a repository, newest first. 45 45 + func GetSiteDeploys(e Execer, repoAt string, limit int) ([]models.SiteDeploy, error) { 46 46 + if limit <= 0 { 47 47 + limit = 20 48 48 + } 49 49 + 50 50 + rows, err := e.Query(` 51 51 + select 52 52 + id, 53 53 + repo_at, 54 54 + branch, 55 55 + dir, 56 56 + commit_sha, 57 57 + status, 58 58 + trigger, 59 59 + error, 60 60 + created_at 61 61 + from site_deploys 62 62 + where repo_at = ? 63 63 + order by created_at desc 64 64 + limit ? 65 65 + `, repoAt, limit) 66 66 + if err != nil { 67 67 + return nil, fmt.Errorf("failed to query site deploys: %w", err) 68 68 + } 69 69 + defer rows.Close() 70 70 + 71 71 + var deploys []models.SiteDeploy 72 72 + for rows.Next() { 73 73 + var d models.SiteDeploy 74 74 + var createdAt string 75 75 + 76 76 + if err := rows.Scan( 77 77 + &d.Id, 78 78 + &d.RepoAt, 79 79 + &d.Branch, 80 80 + &d.Dir, 81 81 + &d.CommitSHA, 82 82 + &d.Status, 83 83 + &d.Trigger, 84 84 + &d.Error, 85 85 + &createdAt, 86 86 + ); err != nil { 87 87 + return nil, fmt.Errorf("failed to scan site deploy: %w", err) 88 88 + } 89 89 + 90 90 + if t, err := time.Parse(time.RFC3339, createdAt); err == nil { 91 91 + d.CreatedAt = t 92 92 + } 93 93 + 94 94 + deploys = append(deploys, d) 95 95 + } 96 96 + 97 97 + if err := rows.Err(); err != nil { 98 98 + return nil, fmt.Errorf("failed to iterate site deploys: %w", err) 99 99 + } 100 100 + 101 101 + return deploys, nil 102 102 + }

+72

appview/db/sites.go

··· 196 196 _, err := e.Exec(`delete from repo_sites where repo_at = ?`, repoAt) 197 197 return err 198 198 } 199 199 + 200 200 + // GetRepoSiteConfigsForDid returns all site configurations for repos owned by a DID. 201 201 + // RepoName is populated on each returned RepoSite. 202 202 + func GetRepoSiteConfigsForDid(e Execer, did string) ([]*models.RepoSite, error) { 203 203 + rows, err := e.Query(` 204 204 + select rs.id, rs.repo_at, r.name, rs.branch, rs.dir, rs.is_index, rs.created, rs.updated 205 205 + from repo_sites rs 206 206 + join repos r on r.at_uri = rs.repo_at 207 207 + where r.did = ? 208 208 + `, did) 209 209 + if err != nil { 210 210 + return nil, err 211 211 + } 212 212 + defer rows.Close() 213 213 + 214 214 + var sites []*models.RepoSite 215 215 + for rows.Next() { 216 216 + var s models.RepoSite 217 217 + var isIndex int 218 218 + var createdStr, updatedStr string 219 219 + if err := rows.Scan(&s.ID, &s.RepoAt, &s.RepoName, &s.Branch, &s.Dir, &isIndex, &createdStr, &updatedStr); err != nil { 220 220 + return nil, err 221 221 + } 222 222 + s.IsIndex = isIndex != 0 223 223 + s.Created, err = time.Parse(time.RFC3339, createdStr) 224 224 + if err != nil { 225 225 + return nil, fmt.Errorf("parsing created timestamp: %w", err) 226 226 + } 227 227 + s.Updated, err = time.Parse(time.RFC3339, updatedStr) 228 228 + if err != nil { 229 229 + return nil, fmt.Errorf("parsing updated timestamp: %w", err) 230 230 + } 231 231 + sites = append(sites, &s) 232 232 + } 233 233 + return sites, rows.Err() 234 234 + } 235 235 + 236 236 + // DeleteRepoSiteConfigsForDid removes all site configurations for repos owned by a DID. 237 237 + func DeleteRepoSiteConfigsForDid(e Execer, did string) error { 238 238 + _, err := e.Exec(` 239 239 + delete from repo_sites 240 240 + where repo_at in ( 241 241 + select at_uri from repos where did = ? 242 242 + ) 243 243 + `, did) 244 244 + return err 245 245 + } 246 246 + 247 247 + // GetIndexRepoAtForDid returns the repo_at of the repo that currently holds 248 248 + // is_index=1 for the given DID, excluding excludeRepoAt (the current repo). 249 249 + // Returns "", nil if no other repo is the index site. 250 250 + func GetIndexRepoAtForDid(e Execer, did, excludeRepoAt string) (string, error) { 251 251 + row := e.QueryRow(` 252 252 + select rs.repo_at 253 253 + from repo_sites rs 254 254 + join repos r on r.at_uri = rs.repo_at 255 255 + where r.did = ? 256 256 + and rs.is_index = 1 257 257 + and rs.repo_at != ? 258 258 + limit 1 259 259 + `, did, excludeRepoAt) 260 260 + 261 261 + var repoAt string 262 262 + err := row.Scan(&repoAt) 263 263 + if errors.Is(err, sql.ErrNoRows) { 264 264 + return "", nil 265 265 + } 266 266 + if err != nil { 267 267 + return "", err 268 268 + } 269 269 + return repoAt, nil 270 270 + }

+40

appview/models/site_deploy.go

··· 1 1 + package models 2 2 + 3 3 + import "time" 4 4 + 5 5 + type SiteDeployStatus string 6 6 + 7 7 + const ( 8 8 + SiteDeployStatusSuccess SiteDeployStatus = "success" 9 9 + SiteDeployStatusFailure SiteDeployStatus = "failure" 10 10 + ) 11 11 + 12 12 + type SiteDeployTrigger string 13 13 + 14 14 + const ( 15 15 + SiteDeployTriggerConfigChange SiteDeployTrigger = "config_change" 16 16 + SiteDeployTriggerPush SiteDeployTrigger = "push" 17 17 + ) 18 18 + 19 19 + func (t SiteDeployTrigger) Label() string { 20 20 + switch t { 21 21 + case SiteDeployTriggerConfigChange: 22 22 + return "config change" 23 23 + case SiteDeployTriggerPush: 24 24 + return "push" 25 25 + default: 26 26 + return string(t) 27 27 + } 28 28 + } 29 29 + 30 30 + type SiteDeploy struct { 31 31 + Id int64 32 32 + RepoAt string 33 33 + Branch string 34 34 + Dir string 35 35 + CommitSHA string 36 36 + Status SiteDeployStatus 37 37 + Trigger SiteDeployTrigger 38 38 + Error string 39 39 + CreatedAt time.Time 40 40 + }

+8 -7

appview/models/sites.go

··· 10 10 } 11 11 12 12 type RepoSite struct { 13 13 - ID int64 14 14 - RepoAt string 15 15 - Branch string 16 16 - Dir string 17 17 - IsIndex bool 18 18 - Created time.Time 19 19 - Updated time.Time 13 13 + ID int64 14 14 + RepoAt string 15 15 + RepoName string // populated when joined with repos table 16 16 + Branch string 17 17 + Dir string 18 18 + IsIndex bool 19 19 + Created time.Time 20 20 + Updated time.Time 20 21 }