@@ -74,7 +74,11 @@ func (d *DataController) Worker() {
7474
7575func (d * DataController ) GetAndSaveIssues () {
7676
77- d .queries .TaskDataInProgress (d .ctx )
77+ err := d .queries .TaskDataInProgress (d .ctx )
78+
79+ if err != nil {
80+ log .Fatal (err )
81+ }
7882
7983 log .Info ("Loading issues..." )
8084 data , err := GetStaredRepos (50 )
@@ -86,7 +90,10 @@ func (d *DataController) GetAndSaveIssues() {
8690
8791 for i := 0 ; i < len (expired ); i ++ {
8892 log .Info ("Delete an issue " , expired [i ].Url )
89- d .queries .DeleteIssue (d .ctx , expired [i ].Url )
93+ delErr := d .queries .DeleteIssue (d .ctx , expired [i ].Url )
94+ if delErr != nil {
95+ log .Error ("Error deleting issue" , delErr )
96+ }
9097 }
9198
9299 if d .matrixClient != nil {
@@ -99,8 +106,12 @@ func (d *DataController) GetAndSaveIssues() {
99106 for i := 0 ; i < len (data ); i ++ {
100107
101108 log .Info ("Save an issue " , data [i ].Url )
102- d .queries .CreateIssue (d .ctx ,
109+ _ , createErr := d .queries .CreateIssue (d .ctx ,
103110 mapModelToDbParameter (data [i ]))
111+
112+ if createErr != nil {
113+ log .Error ("Error creating issue" , createErr )
114+ }
104115 }
105116
106117 err = d .queries .UpdateTimeTaskData (d .ctx , sql.NullTime {Time : time .Now (), Valid : true })
0 commit comments