@@ -65,26 +65,26 @@ func main() {
6565 if errors .Is (err , sql .ErrNoRows ) {
6666 lastDBUpdateVal = "1970-01-01T00:00:00Z"
6767 } else if err != nil {
68- logger .Error (fmt .Sprintf ("Failed to query **??** : %v" , err ), "err" , err )
68+ logger .Error (fmt .Sprintf ("Failed to find most recently updated discussion in database : %v" , err ), "err" , err )
6969 os .Exit (1 )
7070 }
7171
7272 lastDBUpdate , err := time .Parse (time .RFC3339 , lastDBUpdateVal )
7373 if err != nil {
74- logger .Error (fmt .Sprintf ("Failed to query **??** : %v" , err ), "err" , err )
74+ logger .Error (fmt .Sprintf ("Failed to parse last updated timestamp from database : %v" , err ), "err" , err )
7575 os .Exit (1 )
7676 }
7777
7878 // Get a client for the initial check
7979 clientPair := clientPool .GetNextAvailableClient (ctx )
8080 lastUpdate , err := github .GetMostRecentlyUpdatedDiscussion (ctx , clientPair .RestClient , clientPair .GqlClient , "renovatebot" , "renovate" )
8181 if err != nil {
82- logger .Error (fmt .Sprintf ("Failed to query **??** : %v" , err ), "err" , err )
82+ logger .Error (fmt .Sprintf ("Failed to get most recently updated discussion from GitHub : %v" , err ), "err" , err )
8383 os .Exit (1 )
8484 }
8585
8686 if lastDBUpdate .Equal (lastUpdate ) || lastDBUpdate .After (lastUpdate ) {
87- logger .Info ("**??**, but up-to-date" , "lastUpdateOnGitHub" , lastUpdate , "lastUpdateInDatabase" , lastDBUpdate )
87+ logger .Info ("No new discussions to sync, database is up-to-date" , "lastUpdateOnGitHub" , lastUpdate , "lastUpdateInDatabase" , lastDBUpdate )
8888 } else {
8989 finished := false
9090
@@ -127,22 +127,22 @@ func main() {
127127 d , comments , err := github .RetrieveDiscussionAndComments (ctx , clientPair .RestClient , clientPair .GqlClient , "renovatebot" , "renovate" , discussion .Number )
128128 if err != nil {
129129 updateExistingDiscussionsTracker .IncrementWithError (1 )
130- logger .Error (fmt .Sprintf ("Failed to query **??** : %v" , err ), "err" , err )
130+ logger .Error (fmt .Sprintf ("Failed to retrieve discussion and comments for #%d : %v" , discussion . Number , err ), "err" , err )
131131 continue
132132 }
133133
134134 err = queries .InsertDiscussion (ctx , d )
135135 if err != nil {
136136 updateExistingDiscussionsTracker .IncrementWithError (1 )
137- logger .Error (fmt .Sprintf ("Failed to query **??** : %v" , err ), "err" , err )
137+ logger .Error (fmt .Sprintf ("Failed to insert discussion #%d : %v" , discussion . Number , err ), "err" , err )
138138 continue
139139 }
140140
141141 for _ , comment := range comments {
142142 err = queries .InsertDiscussionComment (ctx , comment )
143143 if err != nil {
144144 updateExistingDiscussionsTracker .IncrementWithError (1 )
145- logger .Error (fmt .Sprintf ("Failed to query **??** : %v" , err ), "err" , err )
145+ logger .Error (fmt .Sprintf ("Failed to insert comment for discussion #%d : %v" , discussion . Number , err ), "err" , err )
146146 continue
147147 }
148148 }
0 commit comments