Function FindUserWithRefreshToken

internal/models/user.go:640–651

FindUserWithRefreshToken finds a user from the provided refresh token. If forUpdate is set to true, then the SELECT statement used by the query has the form SELECT ... FOR UPDATE SKIP LOCKED. This means that a FOR UPDATE lock will only be acquired if there's no other lock. In case there is a lock, a

(tx *storage.Connection, dbEncryption conf.DatabaseEncryptionConfiguration, token string, forUpdate bool)

//
// Second value returned is either *models.RefreshToken or *crypto.RefreshToken.
func FindUserWithRefreshToken(tx *storage.Connection, dbEncryption conf.DatabaseEncryptionConfiguration, token string, forUpdate bool) (*User, any, *Session, error) {
	if len(token) < 12 {
		// not a valid refresh token so don't bother looking it up in the database
		return nil, nil, nil, SessionNotFoundError{}
	}

	if len(token) == 12 {
		return findUserWithLegacyRefreshToken(tx, token, forUpdate)
	}

	return findUserWithRefreshToken(tx, dbEncryption, token, forUpdate)
}

func findUserWithRefreshToken(tx *storage.Connection, dbEncryption conf.DatabaseEncryptionConfiguration, token string, forUpdate bool) (*User, *crypto.RefreshToken, *Session, error) {
	refreshToken, err := crypto.ParseRefreshToken(token)