Something went wrong. Try again.
Monorepo for Tangled
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120package pulls
import ( "bytes" "compress/gzip" "fmt" "io" "log/slog" "strings"
"tangled.org/core/appview/config" "tangled.org/core/appview/db" pulls_indexer "tangled.org/core/appview/indexer/pulls" "tangled.org/core/appview/knotacl" "tangled.org/core/appview/mentions" "tangled.org/core/appview/models" "tangled.org/core/appview/notify" "tangled.org/core/appview/oauth" "tangled.org/core/appview/pages" "tangled.org/core/appview/reporesolver" knotmirror "tangled.org/core/gitmirror/proto/gen" "tangled.org/core/idresolver" "tangled.org/core/ogre" "tangled.org/core/patchutil"
indigoxrpc "github.com/bluesky-social/indigo/xrpc" "google.golang.org/grpc" "google.golang.org/grpc/credentials/insecure")
const ApplicationGzip = "application/gzip"
// TODO: move to config. gitmirror serves h2c; talk to it over plaintext for now.const gitmirrorHost = "gitmirror:9000"
type Pulls struct { oauth *oauth.OAuth repoResolver *reporesolver.RepoResolver pages *pages.Pages idResolver *idresolver.Resolver mentionsResolver *mentions.Resolver db *db.DB config *config.Config notifier notify.Notifier acl *knotacl.Service logger *slog.Logger indexer *pulls_indexer.Indexer ogreClient *ogre.Client gitmirror knotmirror.GitMirrorServiceClient}
func New( oauth *oauth.OAuth, repoResolver *reporesolver.RepoResolver, pages *pages.Pages, resolver *idresolver.Resolver, mentionsResolver *mentions.Resolver, db *db.DB, config *config.Config, notifier notify.Notifier, acl *knotacl.Service, indexer *pulls_indexer.Indexer, logger *slog.Logger,) *Pulls { conn, err := grpc.NewClient(gitmirrorHost, grpc.WithTransportCredentials(insecure.NewCredentials())) if err != nil { panic(fmt.Sprintf("dial gitmirror: %v", err)) } return &Pulls{ oauth: oauth, repoResolver: repoResolver, pages: pages, idResolver: resolver, mentionsResolver: mentionsResolver, db: db, config: config, notifier: notifier, acl: acl, logger: logger, indexer: indexer, ogreClient: ogre.NewClient(config.Ogre.Host), gitmirror: knotmirror.NewGitMirrorServiceClient(conn), }}
func (s *Pulls) knotClient(host string) *indigoxrpc.Client { scheme := "https" if s.config.Core.Dev { scheme = "http" } return &indigoxrpc.Client{Host: fmt.Sprintf("%s://%s", scheme, host)}}
func gz(s string) io.Reader { var b bytes.Buffer w := gzip.NewWriter(&b) w.Write([]byte(s)) w.Close() return &b}
func ptrPullState(s models.PullState) *models.PullState { return &s }
func validatePatch(patch *string) error { if patch == nil || *patch == "" { return fmt.Errorf("patch is empty") }
// add newline if not present to diff style patches if !patchutil.IsFormatPatch(*patch) && !strings.HasSuffix(*patch, "\n") { *patch = *patch + "\n" }
if err := patchutil.IsPatchValid(*patch); err != nil { return err }
return nil}