package com.hubspot.singularity.data;

import java.util.List;
import java.util.concurrent.TimeUnit;

import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.utils.ZKPaths;
import org.jetbrains.annotations.NotNull;

import com.codahale.metrics.MetricRegistry;
import com.google.common.cache.CacheBuilder;
import com.google.common.cache.CacheLoader;
import com.google.common.cache.LoadingCache;
import com.google.inject.Inject;
import com.hubspot.singularity.config.SingularityConfiguration;

public class NotificationsManager extends CuratorManager {
  private static final String NOTIFICATIONS_ROOT = "/notifications";
  private static final String BLACKLIST_ROOT = NOTIFICATIONS_ROOT + "/blacklist";

  LoadingCache<String, List<String>> cache;

  @Inject
  public NotificationsManager(CuratorFramework curator, SingularityConfiguration configuration, MetricRegistry metricRegistry) {
    super(curator, configuration, metricRegistry);

    cache = CacheBuilder.newBuilder()
        .expireAfterWrite(5, TimeUnit.MINUTES)
        .build(
            new CacheLoader<String, List<String>>() {
              @Override public List<String> load(String key) throws Exception {
                return getChildren(key);
              }
            }
        );
  }

  public void addToBlacklist(String email) {
    create(getEmailPath(email));
    cache.invalidate(BLACKLIST_ROOT);
  }

  public void removeFromBlacklist(String email) {
    delete(getEmailPath(email));
    cache.invalidate(BLACKLIST_ROOT);
  }

  public List<String> getBlacklist() {
    return cache.getUnchecked(BLACKLIST_ROOT);
  }

  @NotNull private String getEmailPath(String email) {
    return ZKPaths.makePath(BLACKLIST_ROOT, email);
  }
}

@@ -192,50 +192,8 @@
 ths;
-%0Aimport org.jetbrains.annotations.NotNull;
 %0A%0Aim
@@ -1579,17 +1579,8 @@
 %0A%0A  
-@NotNull 
 priv

Fix build