Added leaderboard first pass stuff

lib/Pear/LocalLoop/Schema/Result/Leaderboard.pm

@@ -0,0 +1,202 @@
+package Pear::LocalLoop::Schema::Result::Leaderboard;
+
+use strict;
+use warnings;
+
+use base 'DBIx::Class::Core';
+
+use DateTime;
+
+__PACKAGE__->table("leaderboards");
+
+__PACKAGE__->add_columns(
+  "id" => {
+    data_type => "integer",
+    is_auto_increment => 1,
+    is_nullable => 0,
+  },
+  "name" => {
+    data_type => "varchar",
+    size => 255,
+    is_nullable => 0,
+  },
+  "type" => {
+    data_type => "varchar",
+    size => 255,
+    is_nullable => 0,
+  },
+);
+
+__PACKAGE__->set_primary_key("id");
+
+__PACKAGE__->add_unique_constraint(["type"]);
+
+__PACKAGE__->has_many(
+  "sets",
+  "Pear::LocalLoop::Schema::Result::LeaderboardSet",
+  { "foreign.leaderboard_id" => "self.id" },
+  { cascade_copy => 0, cascade_delete => 0 },
+);
+
+sub create_new {
+  my $self = shift;
+  my $start = shift;
+
+  my $type = $self->type;
+
+  if ( $type eq 'daily_total' ) {
+    return $self->_create_total_set( $start, $start->clone->add( days => 1 ) );
+  } elsif ( $type eq 'weekly_total' ) {
+    return $self->_create_total_set( $start, $start->clone->add( days => 7 ) );
+  } elsif ( $type eq 'monthly_total' ) {
+    return $self->_create_total_set( $start, $start->clone->add( months => 1 ) );
+  } elsif ( $type eq 'all_time_total' ) {
+    return $self->_create_total_all_time;
+  } elsif ( $type eq 'daily_count' ) {
+    return $self->_create_count_set( $start, $start->clone->add( days => 1 ) );
+  } elsif ( $type eq 'weekly_count' ) {
+    return $self->_create_count_set( $start, $start->clone->add( days => 7 ) );
+  } elsif ( $type eq 'monthly_count' ) {
+    return $self->_create_count_set( $start, $start->clone->add( months => 1 ) );
+  } elsif ( $type eq 'all_time_count' ) {
+    return $self->_create_count_all_time;
+  }
+  warn "Unrecognised type";
+  return $self;
+}
+
+sub _create_total_set {
+  my ( $self, $start, $end ) = @_;
+
+  my $schema = $self->result_source->schema;
+
+  my $user_rs = $schema->resultset('User');
+
+  my @leaderboard;
+
+  while ( my $user_result = $user_rs->next ) {
+    my $transaction_rs = $user_result->transactions->search_between( $start, $end );
+
+    my $transaction_sum = $transaction_rs->get_column('value')->sum;
+
+    push @leaderboard, {
+      user_id => $user_result->id,
+      value => $transaction_sum || 0,
+    };
+  }
+
+  $self->create_related(
+    'sets',
+    {
+      date => $start,
+      values => \@leaderboard,
+    },
+  );
+
+  return $self;
+}
+
+sub _create_count_set {
+  my ( $self, $start, $end ) = @_;
+
+  my $schema = $self->result_source->schema;
+
+  my $user_rs = $schema->resultset('User');
+
+  my @leaderboard;
+
+  while ( my $user_result = $user_rs->next ) {
+    my $transaction_rs = $user_result->transactions->search_between( $start, $end );
+
+    my $transaction_count = $transaction_rs->count;
+
+    push @leaderboard, {
+      user_id => $user_result->id,
+      value => $transaction_count || 0,
+    };
+  }
+
+  $self->create_related(
+    'sets',
+    {
+      date => $start,
+      values => \@leaderboard,
+    },
+  );
+
+  return $self;
+}
+
+sub _create_total_all_time {
+  my ( $self ) = @_;
+
+  my $schema = $self->result_source->schema;
+
+  my $user_rs = $schema->resultset('User');
+  
+  my $end = DateTime->today;
+
+  my @leaderboard;
+
+  while ( my $user_result = $user_rs->next ) {
+    my $transaction_rs = $user_result->transactions;
+
+    my $transaction_sum = $transaction_rs->get_column('value')->sum;
+
+    push @leaderboard, {
+      user_id => $user_result->id,
+      value => $transaction_sum || 0,
+    };
+  }
+
+  $self->create_related(
+    'sets',
+    {
+      date => $end,
+      values => \@leaderboard,
+    },
+  );
+
+  return $self;
+}
+
+sub _create_count_all_time {
+  my ( $self ) = @_;
+
+  my $schema = $self->result_source->schema;
+
+  my $user_rs = $schema->resultset('User');
+
+  my $end = DateTime->today;
+
+  my @leaderboard;
+
+  while ( my $user_result = $user_rs->next ) {
+    my $transaction_rs = $user_result->transactions;
+
+    my $transaction_count = $transaction_rs->count;
+
+    push @leaderboard, {
+      user_id => $user_result->id,
+      value => $transaction_count || 0,
+    };
+  }
+
+  $self->create_related(
+    'sets',
+    {
+      date => $end,
+      values => \@leaderboard,
+    },
+  );
+
+  return $self;
+}
+
+sub get_latest {
+  my $self = shift;
+
+  return $self;
+}
+
+1;

lib/Pear/LocalLoop/Schema/Result/LeaderboardSet.pm

@@ -0,0 +1,52 @@
+package Pear::LocalLoop::Schema::Result::LeaderboardSet;
+
+use strict;
+use warnings;
+
+use base 'DBIx::Class::Core';
+
+__PACKAGE__->load_components( qw/
+  InflateColumn::DateTime
+/);
+
+__PACKAGE__->table("leaderboard_sets");
+
+__PACKAGE__->add_columns(
+  "id" => {
+    data_type => "integer",
+    is_auto_increment => 1,
+    is_nullable => 0,
+  },
+  "leaderboard_id" => {
+    data_type => "integer",
+    is_foreign_key => 1,
+    is_nullable => 0,
+  },
+  "date" => {
+    data_type => "datetime",
+    is_nullable => 0,
+  },
+);
+
+__PACKAGE__->set_primary_key("id");
+
+__PACKAGE__->belongs_to(
+  "leaderboard",
+  "Pear::LocalLoop::Schema::Result::Leaderboard",
+  { "foreign.id" => "self.leaderboard_id" },
+  {
+    is_deferrable => 0,
+    join_type     => "LEFT",
+    on_delete     => "NO ACTION",
+    on_update     => "NO ACTION",
+  },
+);
+
+__PACKAGE__->has_many(
+  "values",
+  "Pear::LocalLoop::Schema::Result::LeaderboardValue",
+  { "foreign.set_id" => "self.id" },
+  { cascade_copy => 0, cascade_delete => 0 },
+);
+
+1;

lib/Pear/LocalLoop/Schema/Result/LeaderboardValue.pm

@@ -0,0 +1,61 @@
+package Pear::LocalLoop::Schema::Result::LeaderboardValue;
+
+use strict;
+use warnings;
+
+use base 'DBIx::Class::Core';
+
+__PACKAGE__->table("leaderboard_values");
+
+__PACKAGE__->add_columns(
+  "id" => {
+    data_type => "integer",
+    is_auto_increment => 1,
+    is_nullable => 0,
+  },
+  "user_id" => {
+    data_type => "integer",
+    is_foreign_key => 1,
+    is_nullable => 0,
+  },
+  "set_id" => {
+    data_type => "integer",
+    is_foreign_key => 1,
+    is_nullable => 0,
+  },
+  "value" => {
+    data_type => "decimal",
+    size => [ 16, 2 ],
+    is_nullable => 0,
+  },
+);
+
+__PACKAGE__->set_primary_key("id");
+
+__PACKAGE__->add_unique_constraint([qw/ user_id set_id /]);
+
+__PACKAGE__->belongs_to(
+  "set",
+  "Pear::LocalLoop::Schema::Result::LeaderboardSet",
+  { "foreign.id" => "self.set_id" },
+  {
+    is_deferrable => 0,
+    join_type     => "LEFT",
+    on_delete     => "NO ACTION",
+    on_update     => "NO ACTION",
+  },
+);
+
+__PACKAGE__->belongs_to(
+  "user",
+  "Pear::LocalLoop::Schema::Result::User",
+  { "foreign.id" => "self.user_id" },
+  {
+    is_deferrable => 0,
+    join_type     => "LEFT",
+    on_delete     => "NO ACTION",
+    on_update     => "NO ACTION",
+  },
+);
+
+1;

lib/Test/Pear/LocalLoop.pm

@@ -37,6 +37,18 @@ has framework => sub {
     [ '50+' ],
   ]);
 
+  $schema->resultset('Leaderboard')->populate([
+    [ qw/ name type / ],
+    [ 'Daily Total', 'daily_total' ],
+    [ 'Daily Count', 'daily_count' ],
+    [ 'Weekly Total', 'weekly_total' ],
+    [ 'Weekly Count', 'weekly_count' ],
+    [ 'Monthly Total', 'monthly_total' ],
+    [ 'Monthly Count', 'monthly_count' ],
+    [ 'All Time Total', 'all_time_total' ],
+    [ 'All Time Count', 'all_time_count' ],
+  ]);
+
   return $t;
 };
 

script/deploy_db

@@ -21,6 +21,18 @@ $schema->resultset('AgeRange')->populate([
   [ '50+' ],
 ]);
 
+$schema->resultset('Leaderboard')->populate([
+  [ qw/ name type / ],
+  [ 'Daily Total', 'daily_total' ],
+  [ 'Daily Count', 'daily_count' ],
+  [ 'Weekly Total', 'weekly_total' ],
+  [ 'Weekly Count', 'weekly_count' ],
+  [ 'Monthly Total', 'monthly_total' ],
+  [ 'Monthly Count', 'monthly_count' ],
+  [ 'All Time Total', 'all_time_total' ],
+  [ 'All Time Count', 'all_time_count' ],
+]);
+
 if (defined $ENV{MOJO_MODE} && $ENV{MOJO_MODE} eq 'development' ) {
 
   $schema->resultset('User')->create({

t/schema/leaderboard.t

@@ -0,0 +1,178 @@
+use Mojo::Base -strict;
+
+use Test::More;
+use Mojo::JSON;
+use Test::Pear::LocalLoop;
+use DateTime;
+
+my $framework = Test::Pear::LocalLoop->new;
+my $t = $framework->framework;
+my $schema = $t->app->schema;
+my $dtf = $schema->storage->datetime_parser;
+
+my $user1 = {
+  token        => 'a',
+  full_name    => 'Test User1',
+  display_name => 'Test User1',
+  email        => 'test1@example.com',
+  postcode     => 'LA1 1AA',
+  password     => 'abc123',
+  age_range    => 1,
+};
+
+my $user2 = {
+  token        => 'b',
+  full_name    => 'Test User2',
+  display_name => 'Test User2',
+  email        => 'test2@example.com',
+  postcode     => 'LA1 1AA',
+  password     => 'abc123',
+  age_range    => 1,
+};
+
+my $user3 = {
+  token        => 'c',
+  full_name    => 'Test User3',
+  display_name => 'Test User3',
+  email        => 'test3@example.com',
+  postcode     => 'LA1 1AA',
+  password     => 'abc123',
+  age_range    => 1,
+};
+
+my $user4 = {
+  token        => 'd',
+  full_name    => 'Test User4',
+  display_name => 'Test User4',
+  email        => 'test4@example.com',
+  postcode     => 'LA1 1AA',
+  password     => 'abc123',
+  age_range    => 1,
+};
+
+my $org = {
+  token       => 'e',
+  email       => 'test5@example.com',
+  name        => 'Test Org',
+  street_name => 'Test Street',
+  town        => 'Lancaster',
+  postcode    => 'LA1 1AA',
+  password    => 'abc123',
+};
+
+$schema->resultset('AccountToken')->create({ name => $_->{token} })
+  for ( $user1, $user2, $user3, $user4, $org );
+
+$framework->register_customer($_)
+  for ( $user1, $user2, $user3, $user4 );
+
+$framework->register_organisation($org);
+
+my $org_result = $schema->resultset('Organisation')->find({ name => $org->{name} });
+
+my $tweak = 0;
+
+for my $user ( $user1, $user2, $user3, $user4 ) {
+  $tweak ++;
+  my $user_result = $schema->resultset('User')->find({ email => $user->{email} });
+  for ( 1 .. 10 ) {
+    $user_result->create_related( 'transactions', {
+      seller_id => $org_result->id,
+      value => $_ + $tweak,
+      proof_image => 'a',
+    });
+  }
+
+  for ( 11 .. 20 ) {
+    $user_result->create_related( 'transactions', {
+      seller_id => $org_result->id,
+      value => $_ + $tweak,
+      proof_image => 'a',
+      submitted_at => $dtf->format_datetime(DateTime->today()->subtract( days => 5 )),
+    });
+  }
+
+  for ( 21 .. 30 ) {
+    $user_result->create_related( 'transactions', {
+      seller_id => $org_result->id,
+      value => $_ + $tweak,
+      proof_image => 'a',
+      submitted_at => $dtf->format_datetime(DateTime->today()->subtract( days => 25 )),
+    });
+  }
+
+  for ( 31 .. 40 ) {
+    $user_result->create_related( 'transactions', {
+      seller_id => $org_result->id,
+      value => $_ + $tweak,
+      proof_image => 'a',
+      submitted_at => $dtf->format_datetime(DateTime->today()->subtract( days => 50 )),
+    });
+  }
+
+  is $user_result->transactions->count, 40, 'correct count for user' . $tweak;
+}
+
+sub test_leaderboard {
+  my ( $title, $name, $date, $expected ) = @_;
+
+  subtest $title => sub {
+    my $leaderboard_rs = $schema->resultset('Leaderboard');
+
+    my $today_board = $leaderboard_rs->find({ type => $name })->create_new($date)->sets->first;
+
+    is $today_board->values->count, 5, 'correct value count for today';
+
+    my $today_values = $today_board->values->search(
+      {},
+      {
+        order_by => { -desc => 'value' },
+        columns => [ qw/ user_id value / ],
+      },
+    );
+    $today_values->result_class( 'DBIx::Class::ResultClass::HashRefInflator' );
+
+    is_deeply [ $today_values->all ], $expected, 'Today as expected';
+  };
+}
+
+test_leaderboard(
+  'Daily Total',
+  'daily_total',
+  DateTime->today,
+  [
+    { user_id => 4, value => 95 },
+    { user_id => 3, value => 85 },
+    { user_id => 2, value => 75 },
+    { user_id => 1, value => 65 },
+    { user_id => 5, value => 0 },
+  ]
+);
+
+test_leaderboard(
+  'Daily Count',
+  'daily_count',
+  DateTime->today,
+  [
+    { user_id => 1, value => 10 },
+    { user_id => 2, value => 10 },
+    { user_id => 3, value => 10 },
+    { user_id => 4, value => 10 },
+    { user_id => 5, value => 0 },
+  ]
+);
+
+test_leaderboard(
+  'Weekly Total',
+  'weekly_total',
+  DateTime->today->subtract( days => 7 ),
+  [
+    { user_id => 4, value => 195 },
+    { user_id => 3, value => 185 },
+    { user_id => 2, value => 175 },
+    { user_id => 1, value => 165 },
+    { user_id => 5, value => 0 },
+  ]
+);
+
+done_testing;