+30

appview/db/db.go

··· 568 568 unique (from_at, to_at) 569 569 ); 570 570 571 571 + create table if not exists webhooks ( 572 572 + id integer primary key autoincrement, 573 573 + repo_at text not null, 574 574 + url text not null, 575 575 + secret text, 576 576 + active integer not null default 1, 577 577 + events text not null, -- comma-separated list of events 578 578 + created_at text not null default (strftime('%Y-%m-%dT%H:%M:%SZ', 'now')), 579 579 + updated_at text not null default (strftime('%Y-%m-%dT%H:%M:%SZ', 'now')), 580 580 + 581 581 + foreign key (repo_at) references repos(at_uri) on delete cascade 582 582 + ); 583 583 + 584 584 + create table if not exists webhook_deliveries ( 585 585 + id integer primary key autoincrement, 586 586 + webhook_id integer not null, 587 587 + event text not null, 588 588 + delivery_id text not null, 589 589 + url text not null, 590 590 + request_body text not null, 591 591 + response_code integer, 592 592 + response_body text, 593 593 + success integer not null default 0, 594 594 + created_at text not null default (strftime('%Y-%m-%dT%H:%M:%SZ', 'now')), 595 595 + 596 596 + foreign key (webhook_id) references webhooks(id) on delete cascade 597 597 + ); 598 598 + 571 599 create table if not exists migrations ( 572 600 id integer primary key autoincrement, 573 601 name text unique ··· 578 606 create index if not exists idx_notifications_recipient_read on notifications(recipient_did, read); 579 607 create index if not exists idx_references_from_at on reference_links(from_at); 580 608 create index if not exists idx_references_to_at on reference_links(to_at); 609 609 + create index if not exists idx_webhooks_repo_at on webhooks(repo_at); 610 610 + create index if not exists idx_webhook_deliveries_webhook_id on webhook_deliveries(webhook_id); 581 611 `) 582 612 if err != nil { 583 613 return nil, err

+298

appview/db/webhooks.go

··· 1 1 + package db 2 2 + 3 3 + import ( 4 4 + "database/sql" 5 5 + "fmt" 6 6 + "strings" 7 7 + "time" 8 8 + 9 9 + "github.com/bluesky-social/indigo/atproto/syntax" 10 10 + "tangled.org/core/appview/models" 11 11 + "tangled.org/core/orm" 12 12 + ) 13 13 + 14 14 + // GetWebhooks returns all webhooks for a repository 15 15 + func GetWebhooks(e Execer, filters ...orm.Filter) ([]models.Webhook, error) { 16 16 + var conditions []string 17 17 + var args []any 18 18 + for _, filter := range filters { 19 19 + conditions = append(conditions, filter.Condition()) 20 20 + args = append(args, filter.Arg()...) 21 21 + } 22 22 + 23 23 + whereClause := "" 24 24 + if conditions != nil { 25 25 + whereClause = " where " + strings.Join(conditions, " and ") 26 26 + } 27 27 + 28 28 + query := fmt.Sprintf(` 29 29 + select 30 30 + id, 31 31 + repo_at, 32 32 + url, 33 33 + secret, 34 34 + active, 35 35 + events, 36 36 + created_at, 37 37 + updated_at 38 38 + from webhooks 39 39 + %s 40 40 + order by created_at desc 41 41 + `, whereClause) 42 42 + 43 43 + rows, err := e.Query(query, args...) 44 44 + if err != nil { 45 45 + return nil, fmt.Errorf("failed to query webhooks: %w", err) 46 46 + } 47 47 + defer rows.Close() 48 48 + 49 49 + var webhooks []models.Webhook 50 50 + for rows.Next() { 51 51 + var wh models.Webhook 52 52 + var createdAt, updatedAt, eventsStr string 53 53 + var secret sql.NullString 54 54 + var active int 55 55 + 56 56 + err := rows.Scan( 57 57 + &wh.Id, 58 58 + &wh.RepoAt, 59 59 + &wh.Url, 60 60 + &secret, 61 61 + &active, 62 62 + &eventsStr, 63 63 + &createdAt, 64 64 + &updatedAt, 65 65 + ) 66 66 + if err != nil { 67 67 + return nil, fmt.Errorf("failed to scan webhook: %w", err) 68 68 + } 69 69 + 70 70 + if secret.Valid { 71 71 + wh.Secret = secret.String 72 72 + } 73 73 + wh.Active = active == 1 74 74 + if eventsStr != "" { 75 75 + wh.Events = strings.Split(eventsStr, ",") 76 76 + } 77 77 + 78 78 + if t, err := time.Parse(time.RFC3339, createdAt); err == nil { 79 79 + wh.CreatedAt = t 80 80 + } 81 81 + if t, err := time.Parse(time.RFC3339, updatedAt); err == nil { 82 82 + wh.UpdatedAt = t 83 83 + } 84 84 + 85 85 + webhooks = append(webhooks, wh) 86 86 + } 87 87 + 88 88 + if err = rows.Err(); err != nil { 89 89 + return nil, fmt.Errorf("failed to iterate webhooks: %w", err) 90 90 + } 91 91 + 92 92 + return webhooks, nil 93 93 + } 94 94 + 95 95 + // GetWebhook returns a single webhook by ID 96 96 + func GetWebhook(e Execer, id int64) (*models.Webhook, error) { 97 97 + webhooks, err := GetWebhooks(e, orm.FilterEq("id", id)) 98 98 + if err != nil { 99 99 + return nil, err 100 100 + } 101 101 + 102 102 + if len(webhooks) == 0 { 103 103 + return nil, sql.ErrNoRows 104 104 + } 105 105 + 106 106 + if len(webhooks) != 1 { 107 107 + return nil, fmt.Errorf("expected 1 webhook, got %d", len(webhooks)) 108 108 + } 109 109 + 110 110 + return &webhooks[0], nil 111 111 + } 112 112 + 113 113 + // AddWebhook creates a new webhook 114 114 + func AddWebhook(e Execer, webhook *models.Webhook) error { 115 115 + eventsStr := strings.Join(webhook.Events, ",") 116 116 + active := 0 117 117 + if webhook.Active { 118 118 + active = 1 119 119 + } 120 120 + 121 121 + result, err := e.Exec(` 122 122 + insert into webhooks (repo_at, url, secret, active, events) 123 123 + values (?, ?, ?, ?, ?) 124 124 + `, webhook.RepoAt.String(), webhook.Url, webhook.Secret, active, eventsStr) 125 125 + 126 126 + if err != nil { 127 127 + return fmt.Errorf("failed to insert webhook: %w", err) 128 128 + } 129 129 + 130 130 + id, err := result.LastInsertId() 131 131 + if err != nil { 132 132 + return fmt.Errorf("failed to get webhook id: %w", err) 133 133 + } 134 134 + 135 135 + webhook.Id = id 136 136 + return nil 137 137 + } 138 138 + 139 139 + // UpdateWebhook updates an existing webhook 140 140 + func UpdateWebhook(e Execer, webhook *models.Webhook) error { 141 141 + eventsStr := strings.Join(webhook.Events, ",") 142 142 + active := 0 143 143 + if webhook.Active { 144 144 + active = 1 145 145 + } 146 146 + 147 147 + _, err := e.Exec(` 148 148 + update webhooks 149 149 + set url = ?, secret = ?, active = ?, events = ?, updated_at = strftime('%Y-%m-%dT%H:%M:%SZ', 'now') 150 150 + where id = ? 151 151 + `, webhook.Url, webhook.Secret, active, eventsStr, webhook.Id) 152 152 + 153 153 + if err != nil { 154 154 + return fmt.Errorf("failed to update webhook: %w", err) 155 155 + } 156 156 + 157 157 + return nil 158 158 + } 159 159 + 160 160 + // DeleteWebhook deletes a webhook 161 161 + func DeleteWebhook(e Execer, id int64) error { 162 162 + _, err := e.Exec(`delete from webhooks where id = ?`, id) 163 163 + if err != nil { 164 164 + return fmt.Errorf("failed to delete webhook: %w", err) 165 165 + } 166 166 + return nil 167 167 + } 168 168 + 169 169 + // AddWebhookDelivery records a webhook delivery attempt 170 170 + func AddWebhookDelivery(e Execer, delivery *models.WebhookDelivery) error { 171 171 + success := 0 172 172 + if delivery.Success { 173 173 + success = 1 174 174 + } 175 175 + 176 176 + result, err := e.Exec(` 177 177 + insert into webhook_deliveries ( 178 178 + webhook_id, 179 179 + event, 180 180 + delivery_id, 181 181 + url, 182 182 + request_body, 183 183 + response_code, 184 184 + response_body, 185 185 + success 186 186 + ) values (?, ?, ?, ?, ?, ?, ?, ?) 187 187 + `, 188 188 + delivery.WebhookId, 189 189 + delivery.Event, 190 190 + delivery.DeliveryId, 191 191 + delivery.Url, 192 192 + delivery.RequestBody, 193 193 + delivery.ResponseCode, 194 194 + delivery.ResponseBody, 195 195 + success, 196 196 + ) 197 197 + 198 198 + if err != nil { 199 199 + return fmt.Errorf("failed to insert webhook delivery: %w", err) 200 200 + } 201 201 + 202 202 + id, err := result.LastInsertId() 203 203 + if err != nil { 204 204 + return fmt.Errorf("failed to get delivery id: %w", err) 205 205 + } 206 206 + 207 207 + delivery.Id = id 208 208 + return nil 209 209 + } 210 210 + 211 211 + // GetWebhookDeliveries returns recent deliveries for a webhook 212 212 + func GetWebhookDeliveries(e Execer, webhookId int64, limit int) ([]models.WebhookDelivery, error) { 213 213 + if limit <= 0 { 214 214 + limit = 20 215 215 + } 216 216 + 217 217 + query := ` 218 218 + select 219 219 + id, 220 220 + webhook_id, 221 221 + event, 222 222 + delivery_id, 223 223 + url, 224 224 + request_body, 225 225 + response_code, 226 226 + response_body, 227 227 + success, 228 228 + created_at 229 229 + from webhook_deliveries 230 230 + where webhook_id = ? 231 231 + order by created_at desc 232 232 + limit ? 233 233 + ` 234 234 + 235 235 + rows, err := e.Query(query, webhookId, limit) 236 236 + if err != nil { 237 237 + return nil, fmt.Errorf("failed to query webhook deliveries: %w", err) 238 238 + } 239 239 + defer rows.Close() 240 240 + 241 241 + var deliveries []models.WebhookDelivery 242 242 + for rows.Next() { 243 243 + var d models.WebhookDelivery 244 244 + var createdAt string 245 245 + var success int 246 246 + var responseCode sql.NullInt64 247 247 + var responseBody sql.NullString 248 248 + 249 249 + err := rows.Scan( 250 250 + &d.Id, 251 251 + &d.WebhookId, 252 252 + &d.Event, 253 253 + &d.DeliveryId, 254 254 + &d.Url, 255 255 + &d.RequestBody, 256 256 + &responseCode, 257 257 + &responseBody, 258 258 + &success, 259 259 + &createdAt, 260 260 + ) 261 261 + if err != nil { 262 262 + return nil, fmt.Errorf("failed to scan delivery: %w", err) 263 263 + } 264 264 + 265 265 + d.Success = success == 1 266 266 + if responseCode.Valid { 267 267 + d.ResponseCode = int(responseCode.Int64) 268 268 + } 269 269 + if responseBody.Valid { 270 270 + d.ResponseBody = responseBody.String 271 271 + } 272 272 + 273 273 + if t, err := time.Parse(time.RFC3339, createdAt); err == nil { 274 274 + d.CreatedAt = t 275 275 + } 276 276 + 277 277 + deliveries = append(deliveries, d) 278 278 + } 279 279 + 280 280 + if err = rows.Err(); err != nil { 281 281 + return nil, fmt.Errorf("failed to iterate deliveries: %w", err) 282 282 + } 283 283 + 284 284 + return deliveries, nil 285 285 + } 286 286 + 287 287 + // GetWebhooksForRepo is a convenience function to get all webhooks for a repository 288 288 + func GetWebhooksForRepo(e Execer, repoAt syntax.ATURI) ([]models.Webhook, error) { 289 289 + return GetWebhooks(e, orm.FilterEq("repo_at", repoAt.String())) 290 290 + } 291 291 + 292 292 + // GetActiveWebhooksForRepo returns only active webhooks for a repository 293 293 + func GetActiveWebhooksForRepo(e Execer, repoAt syntax.ATURI) ([]models.Webhook, error) { 294 294 + return GetWebhooks(e, 295 295 + orm.FilterEq("repo_at", repoAt.String()), 296 296 + orm.FilterEq("active", 1), 297 297 + ) 298 298 + }

+74

appview/models/webhook.go

··· 1 1 + package models 2 2 + 3 3 + import ( 4 4 + "slices" 5 5 + "time" 6 6 + 7 7 + "github.com/bluesky-social/indigo/atproto/syntax" 8 8 + ) 9 9 + 10 10 + type WebhookEvent string 11 11 + 12 12 + const ( 13 13 + WebhookEventPush WebhookEvent = "push" 14 14 + ) 15 15 + 16 16 + type Webhook struct { 17 17 + Id int64 18 18 + RepoAt syntax.ATURI 19 19 + Url string 20 20 + Secret string 21 21 + Active bool 22 22 + Events []string // comma-separated event types 23 23 + CreatedAt time.Time 24 24 + UpdatedAt time.Time 25 25 + } 26 26 + 27 27 + // HasEvent checks if the webhook is subscribed to a specific event 28 28 + func (w *Webhook) HasEvent(event WebhookEvent) bool { 29 29 + return slices.Contains(w.Events, string(event)) 30 30 + } 31 31 + 32 32 + type WebhookDelivery struct { 33 33 + Id int64 34 34 + WebhookId int64 35 35 + Event string 36 36 + DeliveryId string // UUID for tracking 37 37 + Url string 38 38 + RequestBody string 39 39 + ResponseCode int 40 40 + ResponseBody string 41 41 + Success bool 42 42 + CreatedAt time.Time 43 43 + } 44 44 + 45 45 + // WebhookPayload represents the webhook payload structure 46 46 + type WebhookPayload struct { 47 47 + Ref string `json:"ref"` 48 48 + Before string `json:"before"` 49 49 + After string `json:"after"` 50 50 + Repository WebhookRepository `json:"repository"` 51 51 + Pusher WebhookUser `json:"pusher"` 52 52 + } 53 53 + 54 54 + // WebhookRepository represents repository information in webhook payload 55 55 + type WebhookRepository struct { 56 56 + Name string `json:"name"` 57 57 + FullName string `json:"full_name"` 58 58 + Description string `json:"description"` 59 59 + Fork bool `json:"fork"` 60 60 + HtmlUrl string `json:"html_url"` 61 61 + CloneUrl string `json:"clone_url"` 62 62 + SshUrl string `json:"ssh_url"` 63 63 + Website string `json:"website,omitempty"` 64 64 + StarsCount int `json:"stars_count,omitempty"` 65 65 + OpenIssues int `json:"open_issues_count,omitempty"` 66 66 + CreatedAt string `json:"created_at"` 67 67 + UpdatedAt string `json:"updated_at"` 68 68 + Owner WebhookUser `json:"owner"` 69 69 + } 70 70 + 71 71 + // WebhookUser represents user information in webhook payload 72 72 + type WebhookUser struct { 73 73 + Did string `json:"did"` 74 74 + }