<commit_before>/*
 * #%L
 * wcm.io
 * %%
 * Copyright (C) 2014 wcm.io
 * %%
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 * #L%
 */
package io.wcm.caravan.commons.test.pipeline;

import io.wcm.caravan.pipeline.cache.CachePersistencyOptions;
import io.wcm.caravan.pipeline.cache.spi.CacheAdapter;

import java.util.Map;

import rx.Observable;

import com.google.common.collect.Maps;

/**
 * An in-memory implementation of the {@link CacheAdapter} for tests.
 */
public class InMemoryCacheAdapter implements CacheAdapter {

  private final Map<String, String> store = Maps.newConcurrentMap();

  @Override
  public String getCacheKey(String servicePrefix, String descriptor) {
    return servicePrefix + "-" + descriptor;
  }

  @Override
  public Observable<String> get(String cacheKey, CachePersistencyOptions options) {
    return store.containsKey(cacheKey) ? Observable.just(store.get(cacheKey)) : Observable.empty();
  }

  @Override
  public void put(String cacheKey, String jsonString, CachePersistencyOptions options) {
    store.put(cacheKey, jsonString);
  }

}<commit_msg>Removed CacheAdapter.getCacheKey method declaration. Each implementation of CacheAdapter should care about key requirements by itself. Removed key generation from MultilayerCacheAdapter and GuavaCacheAdapter, because they do not have any specific key requirements. Fixed CouchbaseCacheAdapter to update any key, received at get and put operation, to meet size requirements. Enhanced GuavaCacheAdapter to check key and value by estimation of cached entry size.<commit_after>/*
 * #%L
 * wcm.io
 * %%
 * Copyright (C) 2014 wcm.io
 * %%
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 * #L%
 */
package io.wcm.caravan.commons.test.pipeline;

import io.wcm.caravan.pipeline.cache.CachePersistencyOptions;
import io.wcm.caravan.pipeline.cache.spi.CacheAdapter;

import java.util.Map;

import rx.Observable;

import com.google.common.collect.Maps;

/**
 * An in-memory implementation of the {@link CacheAdapter} for tests.
 */
public class InMemoryCacheAdapter implements CacheAdapter {

  private final Map<String, String> store = Maps.newConcurrentMap();

  @Override
  public Observable<String> get(String cacheKey, CachePersistencyOptions options) {
    return store.containsKey(cacheKey) ? Observable.just(store.get(cacheKey)) : Observable.empty();
  }

  @Override
  public void put(String cacheKey, String jsonString, CachePersistencyOptions options) {
    store.put(cacheKey, jsonString);
  }

}
{'fraction_non_alphanumeric': 0.08888253786796227, 'fraction_numerical': 0.004572735067162046, 'mean_word_length': 4.426356589147287, 'pattern_counts': {'":': 0, '<': 7, '<?xml version=': 0, '>': 7, 'https://': 0, 'lorem ipsum': 0, 'www.': 2, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '5111033', 'n_tokens_mistral': 973, 'n_tokens_neox': 952, 'n_words': 349}