Federated via graft
3.5 kB
122 lines
1package sync
2
3import (
4 "crypto/sha256"
5 "encoding/hex"
6 "fmt"
7
8 "graft/internal/forgejo"
9 "graft/internal/radicle"
10 "graft/internal/state"
11)
12
13// A marker prepended to mirrored items' bodies so a human browsing either
14// side can tell where an issue/patch actually originated.
15const mirrorNotice = "\n\n---\n_Mirrored automatically, do not edit here — edit at the source instead._"
16
17// IssueSyncer mirrors issues between one Forgejo repository and one Radicle
18// repository, create-only (see package doc for what that means).
19type IssueSyncer struct {
20 RepoPair string
21 Forgejo *forgejo.Client
22 Radicle *radicle.Client
23 State *state.Store
24 ForgejoWebURL string // https://host/owner/repo, for links in the UI
25 RadicleWebURL string // https://explorer/nodes/host/rid, for links in the UI
26 Series string // dashboard row this pair's activity groups under
27 SeriesURL string // where clicking that row's name goes
28}
29
30func (s *IssueSyncer) Sync() error {
31 forgejoIssues, err := s.Forgejo.ListIssues()
32 if err != nil {
33 return fmt.Errorf("list forgejo issues: %w", err)
34 }
35 radicleIssues, err := s.Radicle.ListIssues()
36 if err != nil {
37 return fmt.Errorf("list radicle issues: %w", err)
38 }
39
40 for _, fi := range forgejoIssues {
41 if err := s.mirrorForgejoToRadicle(fi); err != nil {
42 return fmt.Errorf("mirror forgejo issue #%d: %w", fi.Index, err)
43 }
44 }
45 for _, ri := range radicleIssues {
46 if err := s.mirrorRadicleToForgejo(ri); err != nil {
47 return fmt.Errorf("mirror radicle issue %s: %w", ri.ID, err)
48 }
49 }
50 return nil
51}
52
53func (s *IssueSyncer) mirrorForgejoToRadicle(fi forgejo.Issue) error {
54 existing, err := s.State.FindByForgejoID(s.RepoPair, "issue", fi.Index)
55 if err != nil {
56 return err
57 }
58 if existing != nil {
59 return nil // already mirrored; edits not yet synced (see package doc)
60 }
61
62 radicleID, err := s.Radicle.OpenIssue(fi.Title, fi.Body+mirrorNotice)
63 if err != nil {
64 return fmt.Errorf("open radicle issue: %w", err)
65 }
66
67 if err := s.State.Upsert(s.RepoPair, state.ItemMapping{
68 Kind: "issue",
69 ForgejoID: fi.Index,
70 RadicleID: radicleID,
71 ContentHash: hashText(fi.Title, fi.Body),
72 }); err != nil {
73 return err
74 }
75 s.State.LogActivity(state.Activity{
76 RepoPair: s.RepoPair, Series: s.Series, SeriesURL: s.SeriesURL,
77 Kind: "issue", Direction: state.ForgejoToRadicle, Summary: fi.Title,
78 URL: s.RadicleWebURL + "/issues/" + radicleID,
79 ForgejoID: fi.Index, RadicleID: radicleID,
80 })
81 return nil
82}
83
84func (s *IssueSyncer) mirrorRadicleToForgejo(ri radicle.Issue) error {
85 existing, err := s.State.FindByRadicleID(s.RepoPair, "issue", ri.ID)
86 if err != nil {
87 return err
88 }
89 if existing != nil {
90 return nil
91 }
92
93 fi, err := s.Forgejo.CreateIssue(ri.Title, ri.Body()+mirrorNotice)
94 if err != nil {
95 return fmt.Errorf("create forgejo issue: %w", err)
96 }
97
98 if err := s.State.Upsert(s.RepoPair, state.ItemMapping{
99 Kind: "issue",
100 ForgejoID: fi.Index,
101 RadicleID: ri.ID,
102 ContentHash: hashText(ri.Title, ri.Body()),
103 }); err != nil {
104 return err
105 }
106 s.State.LogActivity(state.Activity{
107 RepoPair: s.RepoPair, Series: s.Series, SeriesURL: s.SeriesURL,
108 Kind: "issue", Direction: state.RadicleToForgejo, Summary: ri.Title,
109 URL: fmt.Sprintf("%s/issues/%d", s.ForgejoWebURL, fi.Index),
110 ForgejoID: fi.Index, RadicleID: ri.ID,
111 })
112 return nil
113}
114
115func hashText(parts ...string) string {
116 h := sha256.New()
117 for _, p := range parts {
118 h.Write([]byte(p))
119 h.Write([]byte{0})
120 }
121 return hex.EncodeToString(h.Sum(nil))
122}