@@ -138,26 +138,31 @@ func populateIssueIndexer() {
138
138
}
139
139
140
140
for _ , repo := range repos {
141
- is , err := models .Issues (& models.IssuesOptions {
142
- RepoIDs : []int64 {repo .ID },
143
- IsClosed : util .OptionalBoolNone ,
144
- IsPull : util .OptionalBoolNone ,
145
- })
146
- if err != nil {
147
- log .Error ("Issues: %v" , err )
148
- continue
149
- }
150
- if err = models .IssueList (is ).LoadDiscussComments (); err != nil {
151
- log .Error ("LoadComments: %v" , err )
152
- continue
153
- }
154
- for _ , issue := range is {
155
- UpdateIssueIndexer (issue )
156
- }
141
+ UpdateRepoIndexer (repo )
157
142
}
158
143
}
159
144
}
160
145
146
+ // UpdateRepoIndexer add/update all issues of the repositories
147
+ func UpdateRepoIndexer (repo * models.Repository ) {
148
+ is , err := models .Issues (& models.IssuesOptions {
149
+ RepoIDs : []int64 {repo .ID },
150
+ IsClosed : util .OptionalBoolNone ,
151
+ IsPull : util .OptionalBoolNone ,
152
+ })
153
+ if err != nil {
154
+ log .Error ("Issues: %v" , err )
155
+ return
156
+ }
157
+ if err = models .IssueList (is ).LoadDiscussComments (); err != nil {
158
+ log .Error ("LoadComments: %v" , err )
159
+ return
160
+ }
161
+ for _ , issue := range is {
162
+ UpdateIssueIndexer (issue )
163
+ }
164
+ }
165
+
161
166
// UpdateIssueIndexer add/update an issue to the issue indexer
162
167
func UpdateIssueIndexer (issue * models.Issue ) {
163
168
var comments []string
0 commit comments