*
   * <p>When passed a key that is present in the map, {@code asMap().get(Object)} has the same
   * behavior as {@link #get}, returning a live collection. When passed a key that is not present,
   * however, {@code asMap().get(Object)} returns {@code null} instead of an empty collection.
   *

            List<Integer> invalidLines = IntStream.range(0, lines.size())
                .filter(i -> allPatterns.matcher(lines.get(i)).find())
                .boxed()
                .collect(Collectors.toList());

            URI baseUri = getRootDir().orElse(projectLayout.getProjectDirectory().getAsFile()).get().toURI();
            String path = baseUri.relativize(f.toURI()).toString();
            failures.addAll(

     */
    @Override
    public void clear() {
        super.clear();
        contentSize = 0;
        processingTime = 0;
    }

    /**
     * Gets the total content size of all documents in this list.
     *
     * @return the total content size in bytes
     */
    public long getContentSize() {
        return contentSize;
    }

    /**

    title = project.name
    versionFile = repoRoot().file("version.txt")
    releasedVersionsFile = releasedVersionsFile()
    sources.from(sourceSets.main.get().java.sourceDirectories)
    sources.from(sourceSets.main.get().groovy.sourceDirectories)
    htmlReportFile = file(layout.buildDirectory.file("reports/incubation/${project.name}.html"))

  abstract fun clean(
    chain: List<Certificate>,
    hostname: String,
  ): List<Certificate>

  companion object {
    fun get(trustManager: X509TrustManager): CertificateChainCleaner = Platform.get().buildCertificateChainCleaner(trustManager)

    fun get(vararg caCerts: X509Certificate): CertificateChainCleaner = BasicCertificateChainCleaner(BasicTrustRootIndex(*caCerts))
  }

    )
    return Token(access_token=access_token, token_type="bearer")


@app.get("/users/me/")
async def read_users_me(
    current_user: Annotated[User, Depends(get_current_active_user)],
) -> User:
    return current_user


@app.get("/users/me/items/")
async def read_own_items(
    current_user: Annotated[User, Depends(get_current_active_user)],
):

        } catch (final Exception e) {
            throw new StorageException("Failed to get tags from " + objectName, e);
        }
    }

    @Override
    public void setObjectTags(final String objectName, final Map<String, String> tags) {
        try {
            final Blob blob = storage.get(BlobId.of(bucket, objectName));
            if (blob != null) {
                // GCS uses metadata instead of tags

            this.nextRetryTime = failureTime + 1000; // Initial 1 second delay
        }

        /**
         * Get channel ID
         *
         * @return channel identifier
         */
        public String getChannelId() {
            return channelId;
        }

        /**
         * Get failure time
         *
         * @return time of first failure
         */
        public long getFailureTime() {

    result = Maps.fromProperties(testProp);
    assertEquals(4, result.size());
    assertThat(result.get("first")).isEqualTo("true");
    assertThat(result.get("test")).isEqualTo("");
    assertThat(result.get("second")).isEqualTo("2");
    assertThat(result.get("Third")).isEqualTo("item :   a short  phrase   ");
    assertFalse(result.containsKey("not here"));

    // Test loading system properties

     */
    public PreauthIntegrityNegotiateContext() {
    }

    /**
     * Gets the salt value used for preauth integrity.
     *
     * @return the salt
     */
    public byte[] getSalt() {
        return this.salt;
    }

    /**
     * Gets the supported hash algorithms for preauth integrity.
     *
     * @return the hashAlgos
     */
    public int[] getHashAlgos() {