/**
 * @license
 * Copyright 2017 The FOAM Authors. All Rights Reserved.
 * http://www.apache.org/licenses/LICENSE-2.0
 */

package foam.dao;

import foam.core.FObject;
import foam.core.X;
import foam.mlang.order.Comparator;
import foam.mlang.predicate.Predicate;
import foam.mlang.sink.Count;
import foam.nanos.auth.AuthService;
import java.security.Permission;

/** Authenticate access to a DAO. **/
public class AuthenticatedDAO
  extends ProxyDAO
{
  protected String name_;

  public AuthenticatedDAO(String name, DAO delegate) {
    this.name_ = name;
    setDelegate(delegate);
  }

  public String createPermission(String op) {
    return name_ + "." + op;
  }

  public String createPermission(String op, Object id) {
    return name_ + "." + op + "." + id;
  }

  @Override
  public FObject put_(X x, FObject obj) {
    String      permission;
    AuthService authService = (AuthService) x.get("auth");

    Object id = obj.getProperty("id");

    if ( id == null || getDelegate().find(id) == null ) {
      permission = createPermission("create");
    } else {
      permission = createPermission("update", id);
    }

    if ( ! authService.check(x, permission) ) {
      throw new RuntimeException("Insufficient permissions");
    }

    return super.put_(x, obj);
  }

  @Override
  public FObject remove_(X x, FObject obj) {
    String      permission  = createPermission("remove", obj.getProperty("id"));
    AuthService authService = (AuthService) x.get("auth");

    if ( ! authService.check(x, permission) ) {
      throw new RuntimeException("Insufficient permissions");
    }

    return super.remove_(x, obj);
  }

  @Override
  public FObject find_(X x, Object id) {
    String      permission = createPermission("read", id);
    AuthService authService = (AuthService) x.get("auth");

    if ( ! authService.check(x, permission) ) {
      throw new RuntimeException("Insufficient permissions");
    }

    return super.find_(x, id);
  }

  @Override
  public Sink select_(X x, Sink sink, long skip, long limit, Comparator order, Predicate predicate) {
    sink = new AuthenticatedSink(x, createPermission("read"), sink);
    return super.select_(x, sink, skip, limit, order, predicate);
  }

  @Override
  public void removeAll_(X x, long skip, long limit, Comparator order, Predicate predicate) {
    Sink sink = new AuthenticatedSink(x, createPermission("delete"), new RemoveSink(this));
    this.select_(x, sink, skip, limit, order, predicate);
  }

  @Override
  public void listen_(X x, Sink sink, Predicate predicate) {
    sink = new AuthenticatedSink(x, createPermission("listen"), sink);
    super.listen_(x, sink, predicate);
  }

  @Override
  public void pipe_(X x, Sink sink) {
    sink = new AuthenticatedSink(x, createPermission("pipe"), sink);
    super.pipe_(x, sink);
  }
}

@@ -2066,37 +2066,47 @@
 edicate) %7B%0A    s
-ink =
+uper.select_(x,
  new Authenticat
@@ -2150,42 +2150,8 @@
 ink)
-;%0A    return super.select_(x, sink
 , sk
@@ -2172,32 +2172,49 @@
 er, predicate);%0A
+    return sink;%0A
   %7D%0A%0A  @Override

Fix bug in AuthenticatedDAO returning wrong sink from select().