[go] refactoring
This commit is contained in:
parent
44477a6dbd
commit
c069de3955
4 changed files with 25 additions and 10 deletions
|
@ -35,8 +35,8 @@ func main() {
|
||||||
client := api.NewClient(ctx)
|
client := api.NewClient(ctx)
|
||||||
defer client.Close()
|
defer client.Close()
|
||||||
if err := run(
|
if err := run(
|
||||||
db,
|
|
||||||
client,
|
client,
|
||||||
|
db,
|
||||||
); err != nil {
|
); err != nil {
|
||||||
fmt.Fprintf(os.Stderr, "%s\n", err)
|
fmt.Fprintf(os.Stderr, "%s\n", err)
|
||||||
if err := db.Close(); err != nil {
|
if err := db.Close(); err != nil {
|
||||||
|
@ -47,8 +47,8 @@ func main() {
|
||||||
}
|
}
|
||||||
|
|
||||||
func run(
|
func run(
|
||||||
db *database.DB,
|
|
||||||
client *api.Client,
|
client *api.Client,
|
||||||
|
db *database.DB,
|
||||||
) error {
|
) error {
|
||||||
// ----- Get token or register ---------------------------------------------
|
// ----- Get token or register ---------------------------------------------
|
||||||
register, err := client.Register("COSMIC", "ADYXAX-GO")
|
register, err := client.Register("COSMIC", "ADYXAX-GO")
|
||||||
|
|
19
golang/pkg/database/db.go
Normal file
19
golang/pkg/database/db.go
Normal file
|
@ -0,0 +1,19 @@
|
||||||
|
package database
|
||||||
|
|
||||||
|
import (
|
||||||
|
"context"
|
||||||
|
"database/sql"
|
||||||
|
)
|
||||||
|
|
||||||
|
type DB struct {
|
||||||
|
ctx context.Context
|
||||||
|
db *sql.DB
|
||||||
|
}
|
||||||
|
|
||||||
|
func (db *DB) Exec(query string, args ...any) (sql.Result, error) {
|
||||||
|
return db.db.ExecContext(db.ctx, query, args...)
|
||||||
|
}
|
||||||
|
|
||||||
|
func (db *DB) QueryRow(query string, args ...any) *sql.Row {
|
||||||
|
return db.db.QueryRowContext(db.ctx, query, args...)
|
||||||
|
}
|
|
@ -9,11 +9,6 @@ import (
|
||||||
_ "github.com/mattn/go-sqlite3"
|
_ "github.com/mattn/go-sqlite3"
|
||||||
)
|
)
|
||||||
|
|
||||||
type DB struct {
|
|
||||||
ctx context.Context
|
|
||||||
db *sql.DB
|
|
||||||
}
|
|
||||||
|
|
||||||
//go:embed sql/*.sql
|
//go:embed sql/*.sql
|
||||||
var schemaFiles embed.FS
|
var schemaFiles embed.FS
|
||||||
|
|
||||||
|
|
|
@ -1,11 +1,12 @@
|
||||||
package database
|
package database
|
||||||
|
|
||||||
func (db *DB) AddToken(token string) error {
|
func (db *DB) AddToken(token string) error {
|
||||||
_, err := db.db.ExecContext(db.ctx, `INSERT INTO tokens(data) VALUES (?);`, token)
|
_, err := db.Exec(`INSERT INTO tokens(data) VALUES (?);`, token)
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
func (db *DB) GetToken() (token string, err error) {
|
func (db *DB) GetToken() (string, error) {
|
||||||
err = db.db.QueryRowContext(db.ctx, `SELECT data FROM tokens;`).Scan(&token)
|
var token string
|
||||||
|
err := db.QueryRow(`SELECT data FROM tokens;`).Scan(&token)
|
||||||
return token, err
|
return token, err
|
||||||
}
|
}
|
||||||
|
|
Loading…
Add table
Reference in a new issue