1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
|
package launchpad
import (
"fmt"
"time"
"github.com/MichaelMure/git-bug/bridge/core"
"github.com/MichaelMure/git-bug/bug"
"github.com/MichaelMure/git-bug/cache"
"github.com/pkg/errors"
)
type launchpadImporter struct {
conf core.Configuration
}
func (li *launchpadImporter) Init(conf core.Configuration) error {
li.conf = conf
return nil
}
const keyLaunchpadID = "launchpad-id"
func (li *launchpadImporter) makePerson(owner LPPerson) bug.Person {
return bug.Person{
Name: owner.Name,
Email: "",
Login: owner.Login,
AvatarUrl: "",
}
}
func (li *launchpadImporter) ImportAll(repo *cache.RepoCache) error {
lpAPI := new(launchpadAPI)
err := lpAPI.Init()
if err != nil {
return err
}
lpBugs, err := lpAPI.SearchTasks(li.conf["project"])
if err != nil {
return err
}
for _, lpBug := range lpBugs {
var b *cache.BugCache
var err error
lpBugID := fmt.Sprintf("%d", lpBug.ID)
b, err = repo.ResolveBugCreateMetadata(keyLaunchpadID, lpBugID)
if err != nil && err != bug.ErrBugNotExist {
return err
}
if err == bug.ErrBugNotExist {
createdAt, _ := time.Parse(time.RFC3339, lpBug.CreatedAt)
b, err = repo.NewBugRaw(
li.makePerson(lpBug.Owner),
createdAt.Unix(),
lpBug.Title,
lpBug.Description,
nil,
map[string]string{
keyLaunchpadID: lpBugID,
},
)
if err != nil {
return errors.Wrapf(err, "failed to add bug id #%s", lpBugID)
}
} else {
/* TODO: Update bug */
fmt.Println("TODO: Update bug")
}
/* Handle messages */
if len(lpBug.Messages) == 0 {
return errors.Wrapf(err, "failed to fetch comments for bug #%s", lpBugID)
}
// The Launchpad API returns the bug description as the first
// comment, so skip it.
for _, lpMessage := range lpBug.Messages[1:] {
_, err := b.ResolveTargetWithMetadata(keyLaunchpadID, lpMessage.ID)
if err != nil && err != cache.ErrNoMatchingOp {
return errors.Wrapf(err, "failed to fetch comments for bug #%s", lpBugID)
}
// If this comment already exists, we are probably
// updating an existing bug. We do not want to duplicate
// the comments, so let us just skip this one.
// TODO: Can Launchpad comments be edited?
if err == nil {
continue
}
// This is a new comment, we can add it.
createdAt, _ := time.Parse(time.RFC3339, lpMessage.CreatedAt)
err = b.AddCommentRaw(
li.makePerson(lpMessage.Owner),
createdAt.Unix(),
lpMessage.Content,
nil,
map[string]string{
keyLaunchpadID: lpMessage.ID,
})
if err != nil {
return errors.Wrapf(err, "failed to add comment to bug #%s", lpBugID)
}
}
err = b.CommitAsNeeded()
if err != nil {
return err
}
}
return nil
}
func (li *launchpadImporter) Import(repo *cache.RepoCache, id string) error {
fmt.Println("IMPORT")
return nil
}
|
