cinchapi / runway Goto Github PK

 /**
     * Perform local {@code criteria} resolution and return all the records in
     * {@code clazz} that match.
     * 
     * @param <T>
     * @param clazz
     * @param criteria
     * @param order
     * @param page
     * @param realms
     * @return the matching records in {@code clazz}
     */
    private <T extends Record> Set<T> filter(Class<T> clazz, Criteria criteria,
            @Nullable Order order, @Nullable Page page,
            @Nonnull Realms realms) {
        ConcourseCompiler compiler = ConcourseCompiler.get();
        ConditionTree ast = (ConditionTree) compiler
                .parse($Criteria.amongRealms(realms, criteria));
        String[] keys = compiler.analyze(ast).keys()
                .toArray(Array.containing());
        Predicate<T> filter = record -> compiler.evaluate(ast,
                record.mmap(keys));
        if(page != null) {
            return Pagination.applyFilterAndPage(
                    $page -> order == null ? load(clazz, $page)
                            : load(clazz, order, $page),
                    filter, page);
        }
        else {
            Set<T> records = order == null ? load(clazz) : load(clazz, order);
            return records.stream().filter(filter)
                    .collect(Collectors.toCollection(LinkedHashSet::new));
        }
    }

    /**
     * Perform local {@code criteria} resolution and return all the records in
     * the hierarchy of {@code clazz} that match.
     * 
     * @param <T>
     * @param clazz
     * @param criteria
     * @param order
     * @param page
     * @param realms
     * @return the matching records in the {@code clazz} hierarchy
     */
    private <T extends Record> Set<T> filterAny(Class<T> clazz,
            Criteria criteria, @Nullable Order order, @Nullable Page page,
            @Nonnull Realms realms) {
        ConcourseCompiler compiler = ConcourseCompiler.get();
        ConditionTree ast = (ConditionTree) compiler
                .parse($Criteria.amongRealms(realms, criteria));
        String[] keys = compiler.analyze(ast).keys()
                .toArray(Array.containing());
        Predicate<T> filter = record -> compiler.evaluate(ast,
                record.mmap(keys));
        if(page != null) {
            return Pagination
                    .applyFilterAndPage(
                            $page -> order == null ? loadAny(clazz, $page)
                                    : loadAny(clazz, order, $page),
                            filter, page);
        }
        else {
            Set<T> records = order == null ? loadAny(clazz)
                    : loadAny(clazz, order);
            return records.stream().filter(filter)
                    .collect(Collectors.toCollection(LinkedHashSet::new));
        }
    }