githubsync

type Admission struct {
	OwnerID      string
	Request      ingestion.Request
	Notification *Notification
}

type Connection struct {
	OwnerID          string
	UserID           int64
	Login            string
	AccessToken      []byte
	AccessExpiresAt  int64
	RefreshToken     []byte
	RefreshExpiresAt int64
	Status           string // active, revoked or expired
	ConnectedAt      int64
}

type Follow struct {
	OwnerID        string
	RepositoryID   int64
	InstallationID int64
	FullName       string
	Status         string // active or lost
	VerifiedAt     int64
	CreatedAt      int64
	// Muted follows still receive snapshots but no push notifications. Reads
	// report it; PutFollow leaves it unchanged.
	Muted bool
}

type GitHub interface {
	AppSlug(ctx context.Context) (string, error)
	VerifyWebhook(body []byte, signature256 string) bool
	AuthorizeURL(state, redirectURI string) string
	Exchange(ctx context.Context, code, redirectURI string) (github.UserToken, error)
	Refresh(ctx context.Context, refreshToken string) (github.UserToken, error)
	User(ctx context.Context, accessToken string) (github.Account, error)
	UserRepositories(ctx context.Context, accessToken string) ([]github.Repository, error)
	OpenPullRequests(ctx context.Context, installationID int64, fullName string) ([]github.PullRequest, error)
	PullRequest(ctx context.Context, installationID int64, fullName string, number int) (github.PullRequest, error)
	InstallationToken(ctx context.Context, installationID int64, repositoryIDs []int64, permissions map[string]string) (github.Token, error)
}

type Lease struct {
	Ref          PullRequestRef
	Token        string
	Generation   int64
	RetentionRun string
	Attempt      int
}

type Notification struct {
	Title string `json:"title"`
	Body  string `json:"body"`
}

type Options struct {
	PublicURL string
	TokenKey  []byte
	Now       func() time.Time
}

type PullRequestRef struct {
	RepositoryID   int64
	InstallationID int64
	FullName       string
	Number         int
}

type Repository struct {
	ID       int64  `json:"id"`
	FullName string `json:"fullName"`
	Private  bool   `json:"private"`
	Followed bool   `json:"followed"`
	// Lost marks a followed repository the account can no longer read.
	Lost bool `json:"lost"`
	// Notify reports whether new pull request diffs send push notifications:
	// followed and not muted.
	Notify bool `json:"notify"`
}

type Service struct {
	// contains filtered or unexported fields
}

type Status struct {
	Connected  bool   `json:"connected"`
	Login      string `json:"login,omitempty"`
	State      string `json:"state,omitempty"`
	InstallURL string `json:"installUrl"`
}

type Store interface {
	PutOAuthState(ctx context.Context, hash, ownerID string, expiresAt int64) error
	// TakeOAuthState consumes an unexpired state exactly once.
	TakeOAuthState(ctx context.Context, hash string, now int64) (string, error)
	PutConnection(ctx context.Context, connection Connection) error
	Connection(ctx context.Context, ownerID string) (Connection, error)
	Connections(ctx context.Context) ([]Connection, error)
	// DeleteConnection removes the authorization and every follow of the account.
	DeleteConnection(ctx context.Context, ownerID string) error
	// RevokeUser marks every connection of the GitHub user revoked and their follows lost.
	RevokeUser(ctx context.Context, userID int64) error
	PutFollow(ctx context.Context, follow Follow) error
	DeleteFollow(ctx context.Context, ownerID string, repositoryID int64) error
	Follows(ctx context.Context, ownerID string) ([]Follow, error)
	RepositoryFollows(ctx context.Context, repositoryID int64) ([]Follow, error)
	// LoseInstallation marks follows lost for the installation, or only its listed repositories.
	LoseInstallation(ctx context.Context, installationID int64, repositoryIDs []int64) error
	// SeenDelivery and RecordDelivery deduplicate webhook deliveries by GUID.
	SeenDelivery(ctx context.Context, id string) (bool, error)
	RecordDelivery(ctx context.Context, id, event string, now int64) error
	// SetMuted changes whether a follow sends push notifications. ErrNotFound
	// when the account does not follow the repository.
	SetMuted(ctx context.Context, ownerID string, repositoryID int64, muted bool) error
	// RequestRefresh coalesces refresh intent per pull request by advancing its
	// generation. A nonempty retention run makes the next submission fresh.
	// Opened records, in the same transaction, that a webhook announced the
	// pull request, so its first snapshot notifies followers.
	RequestRefresh(ctx context.Context, ref PullRequestRef, retentionRun string, opened bool, now int64) error
	// PullRequestHead returns the last captured head SHA ("" before the first
	// snapshot) and whether a webhook announced the pull request.
	PullRequestHead(ctx context.Context, repositoryID int64, number int) (head string, opened bool, err error)
	// KnownOpen lists pull request numbers last observed open.
	KnownOpen(ctx context.Context, repositoryID int64) ([]int, error)

	// ClaimRefresh leases the oldest pending, available pull request until
	// leaseUntil, fencing earlier leases. ErrNotFound means none is pending.
	ClaimRefresh(ctx context.Context, token string, now, leaseUntil int64) (Lease, error)
	// RecordLease stores what the lease will publish. ErrLeaseLost when fenced.
	RecordLease(ctx context.Context, lease Lease, leased []byte, now int64) error
	// Leased returns the recorded lease for a current token. ErrLeaseLost when fenced or expired.
	Leased(ctx context.Context, repositoryID int64, number int, token string, now int64) (Lease, []byte, error)
	// ReleaseRefresh ends a failed lease; the pull request stays pending until retryAt.
	ReleaseRefresh(ctx context.Context, lease Lease, retryAt int64, detail string) error
	// CompleteRefresh atomically admits every submission with its notification
	// intent, marks the leased generation refreshed and records the observed
	// state and, when nonempty, the captured head. A generation requested
	// during the lease stays pending.
	CompleteRefresh(ctx context.Context, lease Lease, state, head string, admissions []Admission, now int64) error
}