diff --git a/dal/sqlcgen/queries.sql.go b/dal/sqlcgen/queries.sql.go index fb0e9be..2769ffa 100644 --- a/dal/sqlcgen/queries.sql.go +++ b/dal/sqlcgen/queries.sql.go @@ -190,38 +190,22 @@ func (q *Queries) CheckAndAddDefault(ctx context.Context, arg CheckAndAddDefault return err } -const checkExpired = `-- name: CheckExpired :many -SELECT accountid, refreshtoken, accesstoken, authcode, expiration, createdat FROM tokens WHERE Expiration <= TO_TIMESTAMP(EXTRACT(EPOCH FROM NOW()) + (10 * 60)) +const checkExpiredToken = `-- name: CheckExpiredToken :one +SELECT accountid, refreshtoken, accesstoken, authcode, expiration, createdat FROM tokens WHERE AccountID = $1 AND Expiration <= NOW() ` -func (q *Queries) CheckExpired(ctx context.Context) ([]Token, error) { - rows, err := q.db.QueryContext(ctx, checkExpired) - if err != nil { - return nil, err - } - defer rows.Close() - var items []Token - for rows.Next() { - var i Token - if err := rows.Scan( - &i.Accountid, - &i.Refreshtoken, - &i.Accesstoken, - &i.Authcode, - &i.Expiration, - &i.Createdat, - ); err != nil { - return nil, err - } - items = append(items, i) - } - if err := rows.Close(); err != nil { - return nil, err - } - if err := rows.Err(); err != nil { - return nil, err - } - return items, nil +func (q *Queries) CheckExpiredToken(ctx context.Context, accountid string) (Token, error) { + row := q.db.QueryRowContext(ctx, checkExpiredToken, accountid) + var i Token + err := row.Scan( + &i.Accountid, + &i.Refreshtoken, + &i.Accesstoken, + &i.Authcode, + &i.Expiration, + &i.Createdat, + ) + return i, err } const checkFields = `-- name: CheckFields :many @@ -3417,6 +3401,31 @@ func (q *Queries) TemplateCopy(ctx context.Context, arg TemplateCopyParams) (int return quiz_id, err } +const updateAmoAccount = `-- name: UpdateAmoAccount :exec +UPDATE accountsAmo SET AmoID = $2, Name = $3, Subdomain = $4, Country = $5, DriveURL = $6 WHERE AccountID = $1 AND Deleted = false +` + +type UpdateAmoAccountParams struct { + Accountid string `db:"accountid" json:"accountid"` + Amoid int32 `db:"amoid" json:"amoid"` + Name string `db:"name" json:"name"` + Subdomain string `db:"subdomain" json:"subdomain"` + Country string `db:"country" json:"country"` + Driveurl string `db:"driveurl" json:"driveurl"` +} + +func (q *Queries) UpdateAmoAccount(ctx context.Context, arg UpdateAmoAccountParams) error { + _, err := q.db.ExecContext(ctx, updateAmoAccount, + arg.Accountid, + arg.Amoid, + arg.Name, + arg.Subdomain, + arg.Country, + arg.Driveurl, + ) + return err +} + const updateAmoAccountUser = `-- name: UpdateAmoAccountUser :exec UPDATE usersAmo SET Name = $3, Email = $4, Role = $5, "Group" = $6 WHERE AmoID = $1 AND AmoUserID = $2 AND deleted = false