lib/Frey/Collection.pm

package Frey::Collection;
use Moose::Role;

use Data::Dump qw/dump/;
use Carp;

sub collection {
        my ( $class, $args ) = @_;

        croak "expect HASH not ",dump( $args ) unless ref($args) eq 'HASH';

        warn "## collection args = ",dump( $args );

        my $schema = $class->SchemaClass()->Schema();
        my $select = $class->SchemaClass()->SQLFactoryClass()->new_select();

        my $table = $class->collection_table;

        warn "## table $table";

        my $users_t = $schema->table( $table );

        $select->select( $users_t )
                ->from( $users_t )
#               ->where( $message_t->column('message_date'), '>=',
#                       DateTime->today()->subtract( days => 7 )->strftime( '%Y-%m-%d' ) )
                ->limit( $args->{limit} || 20, $args->{offset} || 0 )
                ;

        my $dbh = $class->_dbh($select);

        my $sth = $dbh->prepare( $select->sql($dbh) );

        return
                Fey::Object::Iterator->new(
                        classes     => [ $class->meta()->ClassForTable( $users_t ) ],
                        handle      => $sth,
                        bind_params => [ $select->bind_params() ],
                );
}

1;
1	dpavlin	106	package Frey::Collection;
2			use Moose::Role;
3
4			use Data::Dump qw/dump/;
5	dpavlin	109	use Carp;
6	dpavlin	106
7			sub collection {
8	dpavlin	109	my ( $class, $args ) = @_;
9
10			croak "expect HASH not ",dump( $args ) unless ref($args) eq 'HASH';
11
12			warn "## collection args = ",dump( $args );
13
14	dpavlin	106	my $schema = $class->SchemaClass()->Schema();
15			my $select = $class->SchemaClass()->SQLFactoryClass()->new_select();
16
17			my $table = $class->collection_table;
18
19			warn "## table $table";
20
21			my $users_t = $schema->table( $table );
22
23			$select->select( $users_t )
24			->from( $users_t )
25			# ->where( $message_t->column('message_date'), '>=',
26			# DateTime->today()->subtract( days => 7 )->strftime( '%Y-%m-%d' ) )
27	dpavlin	109	->limit( $args->{limit} \|\| 20, $args->{offset} \|\| 0 )
28	dpavlin	106	;
29
30			my $dbh = $class->_dbh($select);
31
32			my $sth = $dbh->prepare( $select->sql($dbh) );
33
34			return
35			Fey::Object::Iterator->new(
36			classes => [ $class->meta()->ClassForTable( $users_t ) ],
37			handle => $sth,
38			bind_params => [ $select->bind_params() ],
39			);
40			}
41
42			1;