back round 0 view raw
appview: db: issues: add method for getting any issues a repo might have #474

merged
opened by
ptr.pet 4 months ago targeting master from ptr.pet/core: repo-feed
Signed-off-by: dusk y.bera003.06@protonmail.com
options
unified split
Changed files
+64 -2
appview
issues.go
+64 -2
appview/db/issues.go
···

       142
       142
        
       			body,

     

       143
       143
        
       			open,

     

       144
       144
        
       			comment_count

     

       145
       145
       -
       		from 

     

       145
       145
       +
       		from

     

       146
       146
        
       			numbered_issue

     

       147
       147
       -
       		where 

     

       147
       147
       +
       		where

     

       148
       148
        
       			row_num between ? and ?`,

     

       149
       149
        
       		repoAt, openValue, page.Offset+1, page.Offset+page.Limit)

     

       150
       150
        
       	if err != nil {

     
···

       178
       178
        
       	return issues, nil

     

       179
       179
        
       }

     

       180
       180
        
       

     

       181
       181
       +
       func GetAnyIssues(e Execer, repoAt syntax.ATURI, count int) ([]Issue, error) {

     

       182
       182
       +
       	issues := make([]Issue, 0, count)

     

       183
       183
       +
       

     

       184
       184
       +
       	rows, err := e.Query(

     

       185
       185
       +
       		`select

     

       186
       186
       +
       			i.id,

     

       187
       187
       +
       			i.owner_did,

     

       188
       188
       +
       			i.repo_at,

     

       189
       189
       +
       			i.issue_id,

     

       190
       190
       +
       			i.created,

     

       191
       191
       +
       			i.title,

     

       192
       192
       +
       			i.body,

     

       193
       193
       +
       			i.open

     

       194
       194
       +
       		from

     

       195
       195
       +
       		    issues i

     

       196
       196
       +
       		where

     

       197
       197
       +
       			i.repo_at = ?

     

       198
       198
       +
       		order by

     

       199
       199
       +
       			i.created desc`,

     

       200
       200
       +
       		repoAt)

     

       201
       201
       +
       	if err != nil {

     

       202
       202
       +
       		return nil, err

     

       203
       203
       +
       	}

     

       204
       204
       +
       	defer rows.Close()

     

       205
       205
       +
       

     

       206
       206
       +
       	for rows.Next() {

     

       207
       207
       +
       		if len(issues) >= count {

     

       208
       208
       +
       			break

     

       209
       209
       +
       		}

     

       210
       210
       +
       

     

       211
       211
       +
       		var issue Issue

     

       212
       212
       +
       		var issueCreatedAt string

     

       213
       213
       +
       		err := rows.Scan(

     

       214
       214
       +
       			&issue.ID,

     

       215
       215
       +
       			&issue.OwnerDid,

     

       216
       216
       +
       			&issue.RepoAt,

     

       217
       217
       +
       			&issue.IssueId,

     

       218
       218
       +
       			&issueCreatedAt,

     

       219
       219
       +
       			&issue.Title,

     

       220
       220
       +
       			&issue.Body,

     

       221
       221
       +
       			&issue.Open,

     

       222
       222
       +
       		)

     

       223
       223
       +
       		if err != nil {

     

       224
       224
       +
       			return nil, err

     

       225
       225
       +
       		}

     

       226
       226
       +
       

     

       227
       227
       +
       		issueCreatedTime, err := time.Parse(time.RFC3339, issueCreatedAt)

     

       228
       228
       +
       		if err != nil {

     

       229
       229
       +
       			return nil, err

     

       230
       230
       +
       		}

     

       231
       231
       +
       		issue.Created = issueCreatedTime

     

       232
       232
       +
       

     

       233
       233
       +
       		issues = append(issues, issue)

     

       234
       234
       +
       	}

     

       235
       235
       +
       

     

       236
       236
       +
       	if err := rows.Err(); err != nil {

     

       237
       237
       +
       		return nil, err

     

       238
       238
       +
       	}

     

       239
       239
       +
       

     

       240
       240
       +
       	return issues, nil

     

       241
       241
       +
       }

     

       242
       242
       +
       

     

       181
       243
        
       // timeframe here is directly passed into the sql query filter, and any

     

       182
       244
        
       // timeframe in the past should be negative; e.g.: "-3 months"

     

       183
       245
        
       func GetIssuesByOwnerDid(e Execer, ownerDid string, timeframe string) ([]Issue, error) {