aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/dbx
diff options
context:
space:
mode:
Diffstat (limited to 'src/dbx')
-rw-r--r--src/dbx/db.go144
-rw-r--r--src/dbx/mintages.go212
-rw-r--r--src/dbx/sql/000-genesis.sql42
-rw-r--r--src/dbx/sql/last.sql157
-rw-r--r--src/dbx/users.go69
5 files changed, 624 insertions, 0 deletions
diff --git a/src/dbx/db.go b/src/dbx/db.go
new file mode 100644
index 0000000..5ee3782
--- /dev/null
+++ b/src/dbx/db.go
@@ -0,0 +1,144 @@
+package dbx
+
+import (
+ "context"
+ "fmt"
+ "io/fs"
+ "log"
+ "sort"
+
+ "git.thomasvoss.com/euro-cash.eu/pkg/atexit"
+ . "git.thomasvoss.com/euro-cash.eu/pkg/try"
+ "github.com/jmoiron/sqlx"
+ "github.com/mattn/go-sqlite3"
+)
+
+var (
+ db *sqlx.DB
+ DBName string
+)
+
+func Init(sqlDir fs.FS) {
+ db = sqlx.MustConnect("sqlite3", DBName)
+ atexit.Register(Close)
+
+ conn := Try2(db.Conn(context.Background()))
+ Try(conn.Raw(func(driverConn any) error {
+ return driverConn.(*sqlite3.SQLiteConn).RegisterFunc("C_",
+ func(s, _ string) string {
+ return s
+ }, true)
+ }))
+ conn.Close()
+
+ Try(applyMigrations(sqlDir))
+
+ /* TODO: Remove debug code */
+ /* Try(CreateUser(User{
+ Email: "mail@thomasvoss.com",
+ Username: "Thomas",
+ Password: "69",
+ AdminP: true,
+ }))
+ Try(CreateUser(User{
+ Email: "foo@BAR.baz",
+ Username: "Foobar",
+ Password: "420",
+ AdminP: false,
+ }))
+ Try2(GetMintages("ad", TypeCirc)) */
+}
+
+func Close() {
+ db.Close()
+}
+
+func applyMigrations(dir fs.FS) error {
+ var latest int
+ migratedp := true
+
+ err := db.QueryRow("SELECT latest FROM migration").Scan(&latest)
+ if err != nil {
+ e, ok := err.(sqlite3.Error)
+ /* IDK if there is a better way to do this… lol */
+ if ok && e.Error() == "no such table: migration" {
+ migratedp = false
+ } else {
+ return err
+ }
+ }
+
+ if !migratedp {
+ latest = -1
+ }
+
+ files, err := fs.ReadDir(dir, ".")
+ if err != nil {
+ return err
+ }
+
+ var (
+ last string
+ scripts []string
+ )
+
+ for _, f := range files {
+ if n := f.Name(); n == "last.sql" {
+ last = n
+ } else {
+ scripts = append(scripts, f.Name())
+ }
+ }
+
+ sort.Strings(scripts)
+ for _, f := range scripts[latest+1:] {
+ qry, err := fs.ReadFile(dir, f)
+ if err != nil {
+ return err
+ }
+
+ tx, err := db.Begin()
+ if err != nil {
+ return err
+ }
+
+ var n int
+ if _, err = fmt.Sscanf(f, "%d", &n); err != nil {
+ goto error
+ }
+
+ if _, err = tx.Exec(string(qry)); err != nil {
+ err = fmt.Errorf("error in ‘%s’: %w", f, err)
+ goto error
+ }
+
+ _, err = tx.Exec("UPDATE migration SET latest = ? WHERE id = 1", n)
+ if err != nil {
+ goto error
+ }
+
+ if err = tx.Commit(); err != nil {
+ goto error
+ }
+
+ log.Printf("Applied database migration ‘%s’\n", f)
+ continue
+
+ error:
+ tx.Rollback()
+ return err
+ }
+
+ if last != "" {
+ qry, err := fs.ReadFile(dir, last)
+ if err != nil {
+ return err
+ }
+ if _, err := db.Exec(string(qry)); err != nil {
+ return fmt.Errorf("error in ‘%s’: %w", last, err)
+ }
+ log.Printf("Ran ‘%s’\n", last)
+ }
+
+ return nil
+}
diff --git a/src/dbx/mintages.go b/src/dbx/mintages.go
new file mode 100644
index 0000000..2223eff
--- /dev/null
+++ b/src/dbx/mintages.go
@@ -0,0 +1,212 @@
+package dbx
+
+import (
+ "context"
+ "database/sql"
+ "slices"
+)
+
+type CountryMintageData struct {
+ Standard []MSCountryRow
+ Commemorative []MCommemorative
+}
+
+type YearMintageData struct {
+ Standard []MSYearRow
+ Commemorative []MCommemorative
+}
+
+type msRow struct {
+ Country string
+ Type MintageType
+ Year int
+ Denomination float64
+ Mintmark sql.Null[string]
+ Mintage sql.Null[int]
+ Reference sql.Null[string]
+}
+
+type MSCountryRow struct {
+ Year int
+ Mintmark sql.Null[string]
+ Mintages [ndenoms]sql.Null[int]
+ References [ndenoms]sql.Null[string]
+}
+
+type MSYearRow struct {
+ Country string
+ Mintmark sql.Null[string]
+ Mintages [ndenoms]sql.Null[int]
+ References [ndenoms]sql.Null[string]
+}
+
+type MCommemorative struct {
+ Country string
+ Type MintageType
+ Year int
+ Name string
+ Number int
+ Mintmark sql.Null[string]
+ Mintage sql.Null[int]
+ Reference sql.Null[string]
+}
+
+type MintageType int
+
+/* DO NOT REORDER! */
+const (
+ TypeCirc MintageType = iota
+ TypeNifc
+ TypeProof
+)
+
+const ndenoms = 8
+
+func NewMintageType(s string) MintageType {
+ switch s {
+ case "circ":
+ return TypeCirc
+ case "nifc":
+ return TypeNifc
+ case "proof":
+ return TypeProof
+ }
+ /* We can get here if the user sends a request manually, so just
+ fallback to this */
+ return TypeCirc
+}
+
+func GetMintagesByYear(year int, typ MintageType) (YearMintageData, error) {
+ var (
+ zero YearMintageData
+ xs []MSYearRow
+ ys []MCommemorative
+ )
+
+ rs, err := db.QueryxContext(context.TODO(), `
+ SELECT * FROM mintages_s
+ WHERE year = ? AND type = ?
+ ORDER BY country, mintmark, denomination
+ `, year, typ)
+ if err != nil {
+ return zero, err
+ }
+
+ for rs.Next() {
+ var x msRow
+ if err = rs.StructScan(&x); err != nil {
+ return zero, err
+ }
+
+ loop:
+ msr := MSYearRow{
+ Country: x.Country,
+ Mintmark: x.Mintmark,
+ }
+ i := denomToIdx(x.Denomination)
+ msr.Mintages[i] = x.Mintage
+ msr.References[i] = x.Reference
+
+ for rs.Next() {
+ var y msRow
+ if err = rs.StructScan(&y); err != nil {
+ return zero, err
+ }
+
+ if x.Country != y.Country || x.Mintmark != y.Mintmark {
+ x = y
+ xs = append(xs, msr)
+ goto loop
+ }
+
+ i = denomToIdx(y.Denomination)
+ msr.Mintages[i] = y.Mintage
+ msr.References[i] = y.Reference
+ }
+
+ xs = append(xs, msr)
+ }
+
+ if err = rs.Err(); err != nil {
+ return zero, err
+ }
+
+ db.SelectContext(context.TODO(), &ys, `
+ SELECT * FROM mintages_c
+ WHERE year = ? and type = ?
+ ORDER BY country, mintmark, number
+ `, year, typ)
+
+ return YearMintageData{xs, ys}, nil
+}
+
+func GetMintagesByCountry(country string, typ MintageType) (CountryMintageData, error) {
+ var (
+ zero CountryMintageData
+ xs []MSCountryRow
+ ys []MCommemorative
+ )
+
+ rs, err := db.QueryxContext(context.TODO(), `
+ SELECT * FROM mintages_s
+ WHERE country = ? AND type = ?
+ ORDER BY year, mintmark, denomination
+ `, country, typ)
+ if err != nil {
+ return zero, err
+ }
+
+ for rs.Next() {
+ var x msRow
+ if err = rs.StructScan(&x); err != nil {
+ return zero, err
+ }
+
+ loop:
+ msr := MSCountryRow{
+ Year: x.Year,
+ Mintmark: x.Mintmark,
+ }
+ i := denomToIdx(x.Denomination)
+ msr.Mintages[i] = x.Mintage
+ msr.References[i] = x.Reference
+
+ for rs.Next() {
+ var y msRow
+ if err = rs.StructScan(&y); err != nil {
+ return zero, err
+ }
+
+ if x.Year != y.Year || x.Mintmark != y.Mintmark {
+ x = y
+ xs = append(xs, msr)
+ goto loop
+ }
+
+ i = denomToIdx(y.Denomination)
+ msr.Mintages[i] = y.Mintage
+ msr.References[i] = y.Reference
+ }
+
+ xs = append(xs, msr)
+ }
+
+ if err = rs.Err(); err != nil {
+ return zero, err
+ }
+
+ db.SelectContext(context.TODO(), &ys, `
+ SELECT * FROM mintages_c
+ WHERE country = ? and type = ?
+ ORDER BY year, mintmark, number
+ `, country, typ)
+
+ return CountryMintageData{xs, ys}, rs.Err()
+}
+
+func denomToIdx(d float64) int {
+ return slices.Index([]float64{
+ 0.01, 0.02, 0.05, 0.10,
+ 0.20, 0.50, 1.00, 2.00,
+ }, d)
+}
diff --git a/src/dbx/sql/000-genesis.sql b/src/dbx/sql/000-genesis.sql
new file mode 100644
index 0000000..c16c6ae
--- /dev/null
+++ b/src/dbx/sql/000-genesis.sql
@@ -0,0 +1,42 @@
+PRAGMA encoding = "UTF-8";
+
+CREATE TABLE migration (
+ id INTEGER PRIMARY KEY CHECK (id = 1),
+ latest INTEGER
+);
+INSERT INTO migration (id, latest) VALUES (1, -1);
+
+CREATE TABLE mintages_s (
+ country CHAR(2) NOT NULL COLLATE BINARY
+ CHECK(length(country) = 2),
+ -- Codes correspond to contants in mintages.go
+ type INTEGER NOT NULL
+ CHECK(type BETWEEN 0 AND 2),
+ year INTEGER NOT NULL,
+ denomination REAL NOT NULL,
+ mintmark TEXT,
+ mintage INTEGER,
+ reference TEXT
+);
+
+CREATE TABLE mintages_c (
+ country CHAR(2) NOT NULL COLLATE BINARY
+ CHECK(length(country) = 2),
+ -- Codes correspond to contants in mintages.go
+ type INTEGER NOT NULL
+ CHECK(type BETWEEN 0 AND 2),
+ year INTEGER NOT NULL,
+ name TEXT NOT NULL,
+ number INTEGER NOT NULL,
+ mintmark TEXT,
+ mintage INTEGER,
+ reference TEXT
+);
+
+CREATE TABLE users (
+ email TEXT COLLATE BINARY,
+ username TEXT COLLATE BINARY,
+ password TEXT COLLATE BINARY,
+ adminp INTEGER,
+ translates TEXT COLLATE BINARY
+); \ No newline at end of file
diff --git a/src/dbx/sql/last.sql b/src/dbx/sql/last.sql
new file mode 100644
index 0000000..22ebab8
--- /dev/null
+++ b/src/dbx/sql/last.sql
@@ -0,0 +1,157 @@
+DELETE FROM mintages_s;
+DELETE FROM mintages_c;
+
+INSERT INTO mintages_s (
+ country,
+ type,
+ year,
+ denomination,
+ mintmark,
+ mintage,
+ reference
+) VALUES
+ ('at', 0, 2017, 0.01, NULL, 37700000, NULL),
+ ('at', 0, 2017, 0.02, NULL, 57200000, NULL),
+ ('at', 0, 2017, 0.05, NULL, 35200000, NULL),
+ ('at', 0, 2017, 0.10, NULL, 39500000, NULL),
+ ('at', 0, 2017, 0.20, NULL, 30000000, NULL),
+ ('at', 0, 2017, 0.50, NULL, 15000000, NULL),
+ ('at', 0, 2017, 1.00, NULL, 8000000, NULL),
+ ('at', 0, 2017, 2.00, NULL, 17700000, NULL),
+ ('de', 0, 2017, 0.01, 'A', 81600000, NULL),
+ ('de', 0, 2017, 0.02, 'A', 72200000, NULL),
+ ('de', 0, 2017, 0.05, 'A', 30000000, NULL),
+ ('de', 0, 2017, 0.10, 'A', 25200000, NULL),
+ ('de', 0, 2017, 0.20, 'A', 21600000, NULL),
+ ('de', 0, 2017, 0.50, 'A', 0, NULL),
+ ('de', 0, 2017, 1.00, 'A', 0, NULL),
+ ('de', 0, 2017, 2.00, 'A', 18120000, NULL),
+ ('de', 0, 2017, 0.01, 'D', 85680000, NULL),
+ ('de', 0, 2017, 0.02, 'D', 75810000, NULL),
+ ('de', 0, 2017, 0.05, 'D', 31500000, NULL),
+ ('de', 0, 2017, 0.10, 'D', 26460000, NULL),
+ ('de', 0, 2017, 0.20, 'D', 22680000, NULL),
+ ('de', 0, 2017, 0.50, 'D', 0, NULL),
+ ('de', 0, 2017, 1.00, 'D', 0, NULL),
+ ('de', 0, 2017, 2.00, 'D', 19110000, NULL),
+ ('ad', 0, 2014, 0.01, NULL, 60000, NULL),
+ ('ad', 0, 2014, 0.02, NULL, 60000, NULL),
+ ('ad', 0, 2014, 0.05, NULL, 860000, NULL),
+ ('ad', 0, 2014, 0.10, NULL, 860000, NULL),
+ ('ad', 0, 2014, 0.20, NULL, 860000, NULL),
+ ('ad', 0, 2014, 0.50, NULL, 340000, NULL),
+ ('ad', 0, 2014, 1.00, NULL, 511843, NULL),
+ ('ad', 0, 2014, 2.00, NULL, 360000, NULL),
+ ('ad', 0, 2015, 0.01, NULL, 0, NULL),
+ ('ad', 0, 2015, 0.02, NULL, 0, NULL),
+ ('ad', 0, 2015, 0.05, NULL, 0, NULL),
+ ('ad', 0, 2015, 0.10, NULL, 0, NULL),
+ ('ad', 0, 2015, 0.20, NULL, 0, NULL),
+ ('ad', 0, 2015, 0.50, NULL, 0, NULL),
+ ('ad', 0, 2015, 1.00, NULL, 0, NULL),
+ ('ad', 0, 2015, 2.00, NULL, 1072400, NULL),
+ ('ad', 0, 2016, 0.01, NULL, 0, NULL),
+ ('ad', 0, 2016, 0.02, NULL, 0, NULL),
+ ('ad', 0, 2016, 0.05, NULL, 0, NULL),
+ ('ad', 0, 2016, 0.10, NULL, 0, NULL),
+ ('ad', 0, 2016, 0.20, NULL, 0, NULL),
+ ('ad', 0, 2016, 0.50, NULL, 0, NULL),
+ ('ad', 0, 2016, 1.00, NULL, 2339200, NULL),
+ ('ad', 0, 2016, 2.00, NULL, 0, NULL),
+ ('ad', 0, 2017, 0.01, NULL, 2582395, NULL),
+ ('ad', 0, 2017, 0.02, NULL, 1515000, NULL),
+ ('ad', 0, 2017, 0.05, NULL, 2191421, NULL),
+ ('ad', 0, 2017, 0.10, NULL, 1103000, NULL),
+ ('ad', 0, 2017, 0.20, NULL, 1213000, NULL),
+ ('ad', 0, 2017, 0.50, NULL, 968800, NULL),
+ ('ad', 0, 2017, 1.00, NULL, 17000, NULL),
+ ('ad', 0, 2017, 2.00, NULL, 794588, NULL),
+ ('ad', 0, 2018, 0.01, NULL, 2430000, NULL),
+ ('ad', 0, 2018, 0.02, NULL, 2550000, NULL),
+ ('ad', 0, 2018, 0.05, NULL, 1800000, NULL),
+ ('ad', 0, 2018, 0.10, NULL, 980000, NULL),
+ ('ad', 0, 2018, 0.20, NULL, 1014000, NULL),
+ ('ad', 0, 2018, 0.50, NULL, 890000, NULL),
+ ('ad', 0, 2018, 1.00, NULL, 0, NULL),
+ ('ad', 0, 2018, 2.00, NULL, 868000, NULL),
+ ('ad', 0, 2019, 0.01, NULL, 2447000, NULL),
+ ('ad', 0, 2019, 0.02, NULL, 1727000, NULL),
+ ('ad', 0, 2019, 0.05, NULL, 2100000, NULL),
+ ('ad', 0, 2019, 0.10, NULL, 1610000, NULL),
+ ('ad', 0, 2019, 0.20, NULL, 1570000, NULL),
+ ('ad', 0, 2019, 0.50, NULL, 930000, NULL),
+ ('ad', 0, 2019, 1.00, NULL, 0, NULL),
+ ('ad', 0, 2019, 2.00, NULL, 1058310, NULL),
+ ('ad', 0, 2020, 0.01, NULL, 0, NULL),
+ ('ad', 0, 2020, 0.02, NULL, 0, NULL),
+ ('ad', 0, 2020, 0.05, NULL, 0, NULL),
+ ('ad', 0, 2020, 0.10, NULL, 860000, NULL),
+ ('ad', 0, 2020, 0.20, NULL, 175000, NULL),
+ ('ad', 0, 2020, 0.50, NULL, 740000, NULL),
+ ('ad', 0, 2020, 1.00, NULL, 0, NULL),
+ ('ad', 0, 2020, 2.00, NULL, 1500000, NULL),
+ ('ad', 0, 2021, 0.01, NULL, 200000, NULL),
+ ('ad', 0, 2021, 0.02, NULL, 700000, NULL),
+ ('ad', 0, 2021, 0.05, NULL, 0, NULL),
+ ('ad', 0, 2021, 0.10, NULL, 1400000, NULL),
+ ('ad', 0, 2021, 0.20, NULL, 1420000, NULL),
+ ('ad', 0, 2021, 0.50, NULL, 600000, NULL),
+ ('ad', 0, 2021, 1.00, NULL, 50000, NULL),
+ ('ad', 0, 2021, 2.00, NULL, 1474500, NULL),
+ ('ad', 0, 2022, 0.01, NULL, 700000, NULL),
+ ('ad', 0, 2022, 0.02, NULL, 450000, NULL),
+ ('ad', 0, 2022, 0.05, NULL, 400000, NULL),
+ ('ad', 0, 2022, 0.10, NULL, 700000, NULL),
+ ('ad', 0, 2022, 0.20, NULL, 700000, NULL),
+ ('ad', 0, 2022, 0.50, NULL, 380000, NULL),
+ ('ad', 0, 2022, 1.00, NULL, 0, NULL),
+ ('ad', 0, 2022, 2.00, NULL, 1708000, NULL),
+ ('ad', 0, 2023, 0.01, NULL, 0, NULL),
+ ('ad', 0, 2023, 0.02, NULL, 0, NULL),
+ ('ad', 0, 2023, 0.05, NULL, 0, NULL),
+ ('ad', 0, 2023, 0.10, NULL, 0, NULL),
+ ('ad', 0, 2023, 0.20, NULL, 0, NULL),
+ ('ad', 0, 2023, 0.50, NULL, 0, NULL),
+ ('ad', 0, 2023, 1.00, NULL, 0, NULL),
+ ('ad', 0, 2023, 2.00, NULL, 2075250, NULL),
+ ('ad', 0, 2024, 0.01, NULL, 0, NULL),
+ ('ad', 0, 2024, 0.02, NULL, 900300, NULL),
+ ('ad', 0, 2024, 0.05, NULL, 1950000, NULL),
+ ('ad', 0, 2024, 0.10, NULL, 1000000, NULL),
+ ('ad', 0, 2024, 0.20, NULL, 700000, NULL),
+ ('ad', 0, 2024, 0.50, NULL, 500000, NULL),
+ ('ad', 0, 2024, 1.00, NULL, 1050000, NULL),
+ ('ad', 0, 2024, 2.00, NULL, 1601200, NULL);
+
+INSERT INTO mintages_c (
+ country,
+ type,
+ year,
+ name,
+ number,
+ mintmark,
+ mintage,
+ reference
+) VALUES
+ ('de', 0, 2015, C_('Hessen', 'CC Name'), 1, 'A', 6000000, NULL),
+ ('de', 0, 2015, C_('German Reunification', 'CC Name'), 2, 'A', 6000000, NULL),
+ ('de', 0, 2015, C_('EU Flag', 'CC Name'), 3, 'A', 6000000, NULL),
+ ('de', 0, 2015, C_('Hessen', 'CC Name'), 1, 'D', 6300000, NULL),
+ ('de', 0, 2015, C_('German Reunification', 'CC Name'), 2, 'D', 6300000, NULL),
+ ('de', 0, 2015, C_('EU Flag', 'CC Name'), 3, 'D', 6300000, NULL),
+ ('de', 0, 2015, C_('Hessen', 'CC Name'), 1, 'F', 7200000, NULL),
+ ('de', 0, 2015, C_('German Reunification', 'CC Name'), 2, 'F', 7200000, NULL),
+ ('de', 0, 2015, C_('EU Flag', 'CC Name'), 3, 'F', 7200000, NULL),
+ ('de', 0, 2015, C_('Hessen', 'CC Name'), 1, 'G', 4200000, NULL),
+ ('de', 0, 2015, C_('German Reunification', 'CC Name'), 2, 'G', 4200000, NULL),
+ ('de', 0, 2015, C_('EU Flag', 'CC Name'), 3, 'G', 4200000, NULL),
+ ('de', 0, 2015, C_('Hessen', 'CC Name'), 1, 'J', 6300000, NULL),
+ ('de', 0, 2015, C_('German Reunification', 'CC Name'), 2, 'J', 6300000, NULL),
+ ('de', 0, 2015, C_('EU Flag', 'CC Name'), 3, 'J', 6300000, NULL),
+ ('sk', 0, 2014, C_('Slovak Republic to the EU', 'CC Name'), 1, NULL, 1000000, NULL),
+ ('sk', 0, 2015, C_('Ľudovít Štúr', 'CC Name'), 1, NULL, 1000000, NULL),
+ ('sk', 0, 2015, C_('EU Flag', 'CC Name'), 2, NULL, 1000000, NULL),
+ ('nl', 0, 2015, C_('EU Flag', 'CC Name'), 2, NULL, NULL, NULL),
+ ('fr', 0, 2015, C_('Peace and security', 'CC Name'), 1, NULL, 4000000, NULL),
+ ('fr', 0, 2015, C_('Fête de la Fédération', 'CC Name'), 2, NULL, 4000000, NULL),
+ ('fr', 0, 2015, C_('EU Flag', 'CC Name'), 3, NULL, 4000000, NULL); \ No newline at end of file
diff --git a/src/dbx/users.go b/src/dbx/users.go
new file mode 100644
index 0000000..bf78dcd
--- /dev/null
+++ b/src/dbx/users.go
@@ -0,0 +1,69 @@
+package dbx
+
+import (
+ "context"
+ "database/sql"
+ "errors"
+
+ "golang.org/x/crypto/bcrypt"
+ "golang.org/x/text/unicode/norm"
+)
+
+type User struct {
+ Email string `db:"email"`
+ Username string `db:"username"`
+ Password string `db:"password"`
+ AdminP bool `db:"adminp"`
+ Translates string `db:"translates"`
+}
+
+var LoginFailed = errors.New("No user with the given username and password")
+
+func CreateUser(user User) error {
+ user.Username = norm.NFC.String(user.Username)
+ user.Password = norm.NFC.String(user.Password)
+
+ hash, err := bcrypt.GenerateFromPassword([]byte(user.Password), 15)
+ if err != nil {
+ return err
+ }
+
+ _, err = db.ExecContext(context.TODO(), `
+ INSERT INTO users (
+ email,
+ username,
+ password,
+ adminp,
+ translates
+ ) VALUES (?, ?, ?, ?, ?)
+ `, user.Email, user.Username, string(hash), user.AdminP, user.Translates)
+ return err
+}
+
+func Login(username, password string) (User, error) {
+ username = norm.NFC.String(username)
+ password = norm.NFC.String(password)
+
+ rs, err := db.QueryxContext(context.TODO(),
+ `SELECT * FROM users WHERE username = ?`, username)
+ if err != nil {
+ return User{}, err
+ }
+
+ var u User
+ switch err = rs.Scan(&u); {
+ case errors.Is(err, sql.ErrNoRows):
+ return User{}, LoginFailed
+ case err != nil:
+ return User{}, err
+ }
+
+ err = bcrypt.CompareHashAndPassword([]byte(u.Password), []byte(password))
+ switch {
+ case errors.Is(err, bcrypt.ErrMismatchedHashAndPassword):
+ return User{}, LoginFailed
+ case err != nil:
+ return User{}, err
+ }
+ return u, nil
+}