/
disposable_store.go
87 lines (73 loc) · 1.99 KB
/
disposable_store.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
package postgresql
import (
"database/sql"
"time"
"github.com/domgolonka/foretoken/app/models"
"github.com/jmoiron/sqlx"
)
type DisposableStore struct {
sqlx.Ext
}
func (db *DisposableStore) FindByDomain(domain string) (*models.DisposableEmail, error) {
disposable := models.DisposableEmail{}
err := sqlx.Get(db, &disposable, "SELECT * FROM disposable WHERE domain = ?", domain)
if err == sql.ErrNoRows {
return nil, nil
} else if err != nil {
return nil, err
}
return &disposable, nil
}
func (db *DisposableStore) Find(id int) (*models.DisposableEmail, error) {
disposable := models.DisposableEmail{}
err := sqlx.Get(db, &disposable, "SELECT * FROM disposable WHERE id = ?", id)
if err == sql.ErrNoRows {
return nil, nil
} else if err != nil {
return nil, err
}
return &disposable, nil
}
func (db *DisposableStore) FindAll() (*[]string, error) {
disposable := []models.DisposableEmail{}
err := sqlx.Select(db, &disposable, "SELECT * FROM disposable")
if err == sql.ErrNoRows {
return nil, nil
} else if err != nil {
return nil, err
}
strings := make([]string, 0, len(disposable))
for i := 0; i < len(disposable); i++ {
strings = append(strings, disposable[i].Domain)
}
return &strings, nil
}
func (db *DisposableStore) Create(domain string, score int) (*models.DisposableEmail, error) {
now := time.Now()
disposable := &models.DisposableEmail{
Domain: domain,
Score: score,
CreatedAt: now,
UpdatedAt: now,
}
const insertConst = `INSERT INTO disposable (domain, score, created_at, updated_at)
VALUES (:domain, :score, :created_at, :updated_at)
ON CONFLICT(domain) DO NOTHING`
result, err := sqlx.NamedExec(db,
insertConst,
disposable,
)
if err != nil {
return nil, err
}
id, err := result.LastInsertId()
if err != nil {
return nil, err
}
disposable.ID = uint(int(id))
return disposable, nil
}
func (db *DisposableStore) Delete(id int) (bool, error) {
result, err := db.Exec("DELETE FROM disposable WHERE id = ?", id)
return ok(result, err)
}