appview/notify: add Clone notifier, enqueue posthog event for clones #1265

+4

appview/notify/db/db.go

reviewed

··· 361 361 // no-op for now; webhooks are handled by the webhook notifier 362 362 } 363 363 364 364 + func (n *databaseNotifier) Clone(ctx context.Context, repo *models.Repo) { 365 365 + // no-op 366 366 + } 367 367 + 364 368 func (n *databaseNotifier) NewIssueState(ctx context.Context, actor syntax.DID, issue *models.Issue) { 365 369 l := log.FromContext(ctx) 366 370

+5

appview/notify/logging_notifier.go

reviewed

··· 118 118 ctx = tlog.IntoContext(ctx, tlog.SubLogger(l.logger, "Push")) 119 119 l.inner.Push(ctx, repo, ref, oldSha, newSha, committerDid) 120 120 } 121 121 + 122 122 + func (l *loggingNotifier) Clone(ctx context.Context, repo *models.Repo) { 123 123 + ctx = tlog.IntoContext(ctx, tlog.SubLogger(l.logger, "Clone")) 124 124 + l.inner.Clone(ctx, repo) 125 125 + }

+4

appview/notify/merged_notifier.go

reviewed

··· 105 105 func (m *mergedNotifier) Push(ctx context.Context, repo *models.Repo, ref, oldSha, newSha, committerDid string) { 106 106 m.fanout(func(n Notifier) { n.Push(ctx, repo, ref, oldSha, newSha, committerDid) }) 107 107 } 108 108 + 109 109 + func (m *mergedNotifier) Clone(ctx context.Context, repo *models.Repo) { 110 110 + m.fanout(func(n Notifier) { n.Clone(ctx, repo) }) 111 111 + }

+4

appview/notify/notifier.go

reviewed

··· 35 35 DeleteString(ctx context.Context, did, rkey string) 36 36 37 37 Push(ctx context.Context, repo *models.Repo, ref, oldSha, newSha, committerDid string) 38 38 + 39 39 + Clone(ctx context.Context, repo *models.Repo) 38 40 } 39 41 40 42 // BaseNotifier is a listener that does nothing ··· 72 74 73 75 func (m *BaseNotifier) Push(ctx context.Context, repo *models.Repo, ref, oldSha, newSha, committerDid string) { 74 76 } 77 77 + 78 78 + func (m *BaseNotifier) Clone(ctx context.Context, repo *models.Repo) {}

+11

appview/notify/posthog/notifier.go

reviewed

··· 180 180 } 181 181 } 182 182 183 183 + func (n *posthogNotifier) Clone(ctx context.Context, repo *models.Repo) { 184 184 + err := n.client.Enqueue(posthog.Capture{ 185 185 + DistinctId: repo.Did, 186 186 + Event: "clone", 187 187 + Properties: posthog.Properties{"repo": repo.Name, "repo_at": repo.RepoAt()}, 188 188 + }) 189 189 + if err != nil { 190 190 + log.Println("failed to enqueue posthog event:", err) 191 191 + } 192 192 + } 193 193 + 183 194 func (n *posthogNotifier) NewIssueComment(ctx context.Context, comment *models.IssueComment, mentions []syntax.DID) { 184 195 err := n.client.Enqueue(posthog.Capture{ 185 196 DistinctId: comment.Did,

+2

appview/notify/webhook_notifier.go

reviewed

··· 69 69 } 70 70 } 71 71 72 72 + func (w *WebhookNotifier) Clone(ctx context.Context, repo *models.Repo) {} 73 73 + 72 74 // buildPushPayload creates the webhook payload 73 75 func (w *WebhookNotifier) buildPushPayload(repo *models.Repo, ref, oldSha, newSha, committerDid string) (*models.WebhookPayload, error) { 74 76 owner := repo.Did

+1

appview/state/git_http.go

reviewed

··· 54 54 default: 55 55 // git-upload-pack is the default service for git-clone / git-fetch. 56 56 contentType = "application/x-git-upload-pack-advertisement" 57 57 + go s.notifier.Clone(r.Context(), repo) 57 58 } 58 59 59 60 targetURL := fmt.Sprintf("%s://%s/%s/%s/info/refs?%s", scheme, repo.Knot, user.DID, repo.Name, r.URL.RawQuery)