* --- Key Pair ----------------- */
(keyPair *KeyPair)
| 394 | */ |
| 395 | |
| 396 | func (p *Postgres) AddKey(keyPair *KeyPair) error { |
| 397 | if err := keyPair.Validate(); err != nil { |
| 398 | return err |
| 399 | } |
| 400 | |
| 401 | psql := sq.StatementBuilder.PlaceholderFormat(sq.Dollar) |
| 402 | sqlQuery, args, err := psql.Insert("kite.key").Columns( |
| 403 | "id", |
| 404 | "public", |
| 405 | "private", |
| 406 | ).Values(keyPair.ID, keyPair.Public, keyPair.Private).ToSql() |
| 407 | if err != nil { |
| 408 | return err |
| 409 | } |
| 410 | |
| 411 | _, err = p.DB.Exec(sqlQuery, args...) |
| 412 | return err |
| 413 | } |
| 414 | |
| 415 | func (p *Postgres) DeleteKey(keyPair *KeyPair) error { |
| 416 | res, err := p.DB.Exec(`UPDATE kite.key SET deleted_at = (now() at time zone 'utc') WHERE id = $1`, |