appview: introduce email notifications for @ mentions on issue/pr comments #393

···

       
391
       
 
       
	var description, spindle sql.NullString

     

       
392
       
 
       


     

       
393
       
 
       
	row := e.QueryRow(`

     

       
0
       
 
       

     

       
394
       
-
       
		select did, name, knot, created, at_uri, description, spindle, rkey

     

       
395
       
 
       
		from repos

     

       
396
       
 
       
		where did = ? and name = ?

     

       
397
       
 
       
		`,

     
···

       
400
       
 
       
	)

     

       
401
       
 
       


     

       
402
       
 
       
	var createdAt string

     

       
0
       
 
       

     

       
403
       
-
       
	if err := row.Scan(&repo.Did, &repo.Name, &repo.Knot, &createdAt, &repo.AtUri, &description, &spindle, &repo.Rkey); err != nil {

     

       
404
       
 
       
		return nil, err

     

       
405
       
 
       
	}

     

       
406
       
 
       
	createdAtTime, _ := time.Parse(time.RFC3339, createdAt)

     
···

       
421
       
 
       
	var repo Repo

     

       
422
       
 
       
	var nullableDescription sql.NullString

     

       
423
       
 
       


     

       
0
       
 
       

     

       
424
       
-
       
	row := e.QueryRow(`select did, name, knot, created, at_uri, rkey, description from repos where at_uri = ?`, atUri)

     

       
425
       
 
       


     

       
426
       
 
       
	var createdAt string

     

       
0
       
 
       

     

       
427
       
-
       
	if err := row.Scan(&repo.Did, &repo.Name, &repo.Knot, &createdAt, &repo.AtUri, &repo.Rkey, &nullableDescription); err != nil {

     

       
428
       
 
       
		return nil, err

     

       
429
       
 
       
	}

     

       
430
       
 
       
	createdAtTime, _ := time.Parse(time.RFC3339, createdAt)

     
···

       
440
       
 
       
}

     

       
441
       
 
       


     

       
442
       
 
       
func AddRepo(e Execer, repo *Repo) error {

     

       
443
       
-
       
	if repo.AtUri == "" {

     

       
444
       
-
       
		repo.AtUri = repo.RepoAt().String()

     

       
445
       
-
       
	}

     

       
446
       
 
       
	_, err := e.Exec(

     

       
447
       
 
       
		`insert into repos

     

       
448
       
 
       
		(did, name, knot, rkey, at_uri, description, source)

     

···

       
391
       
 
       
	var description, spindle sql.NullString

     

       
392
       
 
       


     

       
393
       
 
       
	row := e.QueryRow(`

     

       
394
       
+
       
		select did, name, knot, created, at_uri, description, spindle 

     

       
0
       
 
       

     

       
395
       
 
       
		from repos

     

       
396
       
 
       
		where did = ? and name = ?

     

       
397
       
 
       
		`,

     
···

       
400
       
 
       
	)

     

       
401
       
 
       


     

       
402
       
 
       
	var createdAt string

     

       
403
       
+
       
	if err := row.Scan(&repo.Did, &repo.Name, &repo.Knot, &createdAt, &repo.AtUri, &description, &spindle); err != nil {

     

       
0
       
 
       

     

       
404
       
 
       
		return nil, err

     

       
405
       
 
       
	}

     

       
406
       
 
       
	createdAtTime, _ := time.Parse(time.RFC3339, createdAt)

     
···

       
421
       
 
       
	var repo Repo

     

       
422
       
 
       
	var nullableDescription sql.NullString

     

       
423
       
 
       


     

       
424
       
+
       
	row := e.QueryRow(`select did, name, knot, created, at_uri, description from repos where at_uri = ?`, atUri)

     

       
0
       
 
       

     

       
425
       
 
       


     

       
426
       
 
       
	var createdAt string

     

       
427
       
+
       
	if err := row.Scan(&repo.Did, &repo.Name, &repo.Knot, &createdAt, &repo.AtUri, &nullableDescription); err != nil {

     

       
0
       
 
       

     

       
428
       
 
       
		return nil, err

     

       
429
       
 
       
	}

     

       
430
       
 
       
	createdAtTime, _ := time.Parse(time.RFC3339, createdAt)

     
···

       
440
       
 
       
}

     

       
441
       
 
       


     

       
442
       
 
       
func AddRepo(e Execer, repo *Repo) error {

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
443
       
 
       
	_, err := e.Exec(

     

       
444
       
 
       
		`insert into repos

     

       
445
       
 
       
		(did, name, knot, rkey, at_uri, description, source)

     

···

       
196
       
 
       
			r.name,

     

       
197
       
 
       
			r.knot,

     

       
198
       
 
       
			r.rkey,

     

       
199
       
-
       
			r.created,

     

       
200
       
-
       
			r.at_uri

     

       
201
       
 
       
		from stars s

     

       
202
       
 
       
		join repos r on s.repo_at = r.at_uri

     

       
203
       
 
       
	`)

     
···

       
222
       
 
       
			&repo.Knot,

     

       
223
       
 
       
			&repo.Rkey,

     

       
224
       
 
       
			&repoCreatedAt,

     

       
225
       
-
       
			&repo.AtUri,

     

       
226
       
 
       
		); err != nil {

     

       
227
       
 
       
			return nil, err

     

       
228
       
 
       
		}

     

···

       
196
       
 
       
			r.name,

     

       
197
       
 
       
			r.knot,

     

       
198
       
 
       
			r.rkey,

     

       
199
       
+
       
			r.created

     

       
0
       
 
       

     

       
200
       
 
       
		from stars s

     

       
201
       
 
       
		join repos r on s.repo_at = r.at_uri

     

       
202
       
 
       
	`)

     
···

       
221
       
 
       
			&repo.Knot,

     

       
222
       
 
       
			&repo.Rkey,

     

       
223
       
 
       
			&repoCreatedAt,

     

       
0
       
 
       

     

       
224
       
 
       
		); err != nil {

     

       
225
       
 
       
			return nil, err

     

       
226
       
 
       
		}