Function countActiveVCSProviderUsersTx

backend/store/vcs_provider_user.go:135–141

(ctx context.Context, tx *sql.Tx, workspace string, activeWindow time.Duration)

}

func countActiveVCSProviderUsersTx(ctx context.Context, tx *sql.Tx, workspace string, activeWindow time.Duration) (int, error) {
	var count int
	if err := tx.QueryRowContext(ctx, countActiveVCSProviderUsersSQL, workspace, activeWindow.Seconds()).Scan(&count); err != nil {
		return 0, errors.Wrapf(err, "failed to count active VCS provider users")
	}
	return count, nil
}

// DeleteExpiredVCSProviderUsers deletes VCS provider users older than the active window.
func (s *Store) DeleteExpiredVCSProviderUsers(ctx context.Context, activeWindow time.Duration) (int64, error) {