Sample Reactive Resource Framework Code

sample.groovy

routing {
  include SpringConfig

  http {
    route("/path/to/{resourceId}") to CustomResource
  }
}

interface Context extends AbstractMutableMap<String, Object> {
  
  UriPath getPath()

  Principal getPrincipal()

  void notify(String topic, Object data)

}

interface Patch<T> extends Function<T, T>, Iterable<Diff<?>> {
  
  int size()

}

interface Diff<V> extends Function<V, Boolean> {

  String getPath()
  
}

class CustomResource {

  static allowedMethods = [
    HttpMethods.GET, 
    HttpMethods.PUT, 
    HttpMethods.POST, 
    HttpMethods.DELETE,
    StompMethods.SUBSCRIBE
  ]

  static acceptableTypes = { supertype, subtype -> subtype.endsWith("json") }

  // alternative
  //static authorized = [ "ROLE1", "ROLE2" ]

  AvailabilityService sys
  SecurityService     security
  ResourceOrm         orm

  def available(Context ctx) {
    sys.available
  }

  def exists(Context ctx) {
    orm.findOne(ctx.path.resourceId)) { obj ->
      ctx.domainObj = obj
      ctx.notify 'exists', (null != obj)
    }
  }

  def authorized(Context ctx) {
    security.isAuthorized(ctx.principal) { result -> 
      ctx.notify 'authorized', result
    }
  }

  def conflict(Context ctx) {
    
  }

  def create(Context ctx, DomainObject obj) {

  }

  def merge(Context ctx, Patch patch) {
    patch.apply(ctx.domainObj)
  }

}