// Copyright (c) 2026 Probo Inc . // // Permission is hereby granted, free of charge, to any person obtaining a copy // of this software and associated documentation files (the "Software"), to deal // in the Software without restriction, including without limitation the rights // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell // copies of the Software, and to permit persons to whom the Software is // furnished to do so, subject to the following conditions: // // The above copyright notice and this permission notice shall be included in // all copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE // SOFTWARE. package coredata import ( "context" "errors" "fmt" "maps" "time" "github.com/jackc/pgx/v5" "go.gearno.de/kit/pg" "go.probo.inc/probo/pkg/gid" "go.probo.inc/probo/pkg/iam/policy" "go.probo.inc/probo/pkg/page" ) type ( OAuth2AccessToken struct { ID gid.GID `db:"id"` Name string `db:"name"` HashedValue []byte `db:"hashed_value"` ClientID *gid.GID `db:"client_id"` IdentityID gid.GID `db:"identity_id"` Scopes OAuth2Scopes `db:"scopes"` CreatedAt time.Time `db:"created_at"` ExpiresAt time.Time `db:"expires_at"` } OAuth2AccessTokens []*OAuth2AccessToken ) func (t *OAuth2AccessToken) CursorKey(orderBy OAuth2AccessTokenOrderField) page.CursorKey { switch orderBy { case OAuth2AccessTokenOrderFieldCreatedAt: return page.NewCursorKey(t.ID, t.CreatedAt) } panic(fmt.Sprintf("unsupported order by: %s", orderBy)) } func (t *OAuth2AccessToken) ExpiresIn(now time.Time) time.Duration { return t.ExpiresAt.Sub(now) } func (t *OAuth2AccessToken) Insert(ctx context.Context, conn pg.Tx) error { q := ` INSERT INTO iam_oauth2_access_tokens ( id, name, hashed_value, client_id, identity_id, scopes, created_at, expires_at ) VALUES ( @id, @name, @hashed_value, @client_id, @identity_id, @scopes, @created_at, @expires_at ) ` args := pgx.StrictNamedArgs{ "id": t.ID, "name": t.Name, "hashed_value": t.HashedValue, "client_id": t.ClientID, "identity_id": t.IdentityID, "scopes": t.Scopes, "created_at": t.CreatedAt, "expires_at": t.ExpiresAt, } _, err := conn.Exec(ctx, q, args) if err != nil { return fmt.Errorf("cannot insert oauth2_access_token: %w", err) } return nil } func (t *OAuth2AccessToken) LoadByID(ctx context.Context, conn pg.Querier, id gid.GID) error { q := ` SELECT id, name, hashed_value, client_id, identity_id, scopes, created_at, expires_at FROM iam_oauth2_access_tokens WHERE id = @id LIMIT 1; ` rows, err := conn.Query(ctx, q, pgx.StrictNamedArgs{"id": id}) if err != nil { return fmt.Errorf("cannot query oauth2_access_token: %w", err) } token, err := pgx.CollectExactlyOneRow(rows, pgx.RowToStructByName[OAuth2AccessToken]) if err != nil { if errors.Is(err, pgx.ErrNoRows) { return ErrResourceNotFound } return fmt.Errorf("cannot collect oauth2_access_token: %w", err) } *t = token return nil } func (t *OAuth2AccessToken) LoadByHashedValue(ctx context.Context, conn pg.Querier, hashedValue []byte) error { q := ` SELECT id, name, hashed_value, client_id, identity_id, scopes, created_at, expires_at FROM iam_oauth2_access_tokens WHERE hashed_value = @hashed_value LIMIT 1; ` rows, err := conn.Query(ctx, q, pgx.StrictNamedArgs{"hashed_value": hashedValue}) if err != nil { return fmt.Errorf("cannot query oauth2_access_token: %w", err) } token, err := pgx.CollectExactlyOneRow(rows, pgx.RowToStructByName[OAuth2AccessToken]) if err != nil { if errors.Is(err, pgx.ErrNoRows) { return ErrResourceNotFound } return fmt.Errorf("cannot collect oauth2_access_token: %w", err) } *t = token return nil } func (t *OAuth2AccessToken) LoadByHashedValueAndClientID( ctx context.Context, conn pg.Querier, hashedValue []byte, clientID gid.GID, ) error { q := ` SELECT id, name, hashed_value, client_id, identity_id, scopes, created_at, expires_at FROM iam_oauth2_access_tokens WHERE hashed_value = @hashed_value AND client_id = @client_id LIMIT 1; ` args := pgx.StrictNamedArgs{ "hashed_value": hashedValue, "client_id": clientID, } rows, err := conn.Query(ctx, q, args) if err != nil { return fmt.Errorf("cannot query oauth2_access_token: %w", err) } token, err := pgx.CollectExactlyOneRow(rows, pgx.RowToStructByName[OAuth2AccessToken]) if err != nil { if errors.Is(err, pgx.ErrNoRows) { return ErrResourceNotFound } return fmt.Errorf("cannot collect oauth2_access_token: %w", err) } *t = token return nil } func (t *OAuth2AccessToken) AuthorizationAttributes( ctx context.Context, conn pg.Querier, resourceIDs []gid.GID, ) (policy.AttributesByID, error) { q := ` SELECT t.id, t.identity_id FROM iam_oauth2_access_tokens t WHERE t.id = ANY(@resource_ids::text[]) ` args := pgx.StrictNamedArgs{ "resource_ids": resourceIDs, } rows, err := conn.Query(ctx, q, args) if err != nil { return nil, fmt.Errorf("cannot query oauth2 access token authorization attributes: %w", err) } defer rows.Close() attrsByID := make(policy.AttributesByID, len(resourceIDs)) for rows.Next() { var ( id gid.GID identityID gid.GID ) err = rows.Scan(&id, &identityID) if err != nil { return nil, fmt.Errorf("cannot scan oauth2 access token authorization attributes: %w", err) } attrsByID[id] = policy.Attributes{"identity_id": identityID.String()} } if err = rows.Err(); err != nil { return nil, fmt.Errorf("cannot iterate oauth2 access token authorization attributes: %w", err) } return attrsByID, nil } func (ts *OAuth2AccessTokens) LoadByIdentityID( ctx context.Context, conn pg.Querier, identityID gid.GID, cursor *page.Cursor[OAuth2AccessTokenOrderField], ) error { q := ` SELECT id, name, hashed_value, client_id, identity_id, scopes, created_at, expires_at FROM iam_oauth2_access_tokens WHERE identity_id = @identity_id AND client_id IS NULL AND %s ` q = fmt.Sprintf(q, cursor.SQLFragment()) args := pgx.StrictNamedArgs{ "identity_id": identityID, } maps.Copy(args, cursor.SQLArguments()) rows, err := conn.Query(ctx, q, args) if err != nil { return fmt.Errorf("cannot query oauth2 access tokens: %w", err) } tokens, err := pgx.CollectRows(rows, pgx.RowToAddrOfStructByName[OAuth2AccessToken]) if err != nil { return fmt.Errorf("cannot collect oauth2 access tokens: %w", err) } *ts = tokens return nil } func (ts *OAuth2AccessTokens) CountByIdentityID( ctx context.Context, conn pg.Querier, identityID gid.GID, ) (int, error) { q := ` SELECT COUNT(id) FROM iam_oauth2_access_tokens WHERE identity_id = @identity_id AND client_id IS NULL; ` args := pgx.StrictNamedArgs{ "identity_id": identityID, } var count int if err := conn.QueryRow(ctx, q, args).Scan(&count); err != nil { return 0, fmt.Errorf("cannot count oauth2 access tokens: %w", err) } return count, nil } func (t *OAuth2AccessToken) Delete(ctx context.Context, conn pg.Tx) error { q := ` DELETE FROM iam_oauth2_access_tokens WHERE id = @id ` _, err := conn.Exec(ctx, q, pgx.StrictNamedArgs{"id": t.ID}) if err != nil { return fmt.Errorf("cannot delete oauth2_access_token: %w", err) } return nil } func (t *OAuth2AccessToken) DeleteExpired(ctx context.Context, conn pg.Tx, now time.Time) (int64, error) { q := ` DELETE FROM iam_oauth2_access_tokens WHERE expires_at < @now ` result, err := conn.Exec(ctx, q, pgx.StrictNamedArgs{"now": now}) if err != nil { return 0, fmt.Errorf("cannot delete expired oauth2_access_tokens: %w", err) } return result.RowsAffected(), nil } func (t *OAuth2AccessToken) DeleteByClientAndIdentity( ctx context.Context, conn pg.Tx, clientID gid.GID, identityID gid.GID, ) (int64, error) { q := ` DELETE FROM iam_oauth2_access_tokens WHERE client_id = @client_id AND identity_id = @identity_id ` args := pgx.StrictNamedArgs{ "client_id": clientID, "identity_id": identityID, } result, err := conn.Exec(ctx, q, args) if err != nil { return 0, fmt.Errorf("cannot delete oauth2_access_tokens by client and identity: %w", err) } return result.RowsAffected(), nil }