[Bps-public-commit] r16287 - in Prophet/trunk: t

[jesse at bestpractical.com]

Author: jesse
Date: Sun Oct 12 18:01:50 2008
New Revision: 16287

Added:
   Prophet/trunk/lib/Prophet/DatabaseSetting.pm
   Prophet/trunk/t/database-settings.t

Log:
first cut of per-database settings

Added: Prophet/trunk/lib/Prophet/DatabaseSetting.pm
==============================================================================
--- (empty file)
+++ Prophet/trunk/lib/Prophet/DatabaseSetting.pm	Sun Oct 12 18:01:50 2008
@@ -0,0 +1,35 @@
+package Prophet::DatabaseSetting;
+use Moose;
+extends 'Prophet::Record';
+use Params::Validate;
+
+sub new { 
+        shift->SUPER::new( type => '__prophet_db_settings', @_);
+}
+
+
+
+sub set {
+    my $self = shift;
+    # XXX TODO - better serialization of values. json?
+    my $values = join(';', @_);
+    
+    
+    if ($self->handle->record_exists( uuid => $self->uuid, type => $self->type)) {
+        $self->set_props( props => { content => $values});
+    } else {
+        $self->_create_record( props => { content => $values }, uuid => $self->uuid );
+    }
+}
+
+
+sub get {
+    my $self = shift;
+    my @entries =  split(/;/, $self->prop('content'));
+    return wantarray ? @entries : shift @entries;
+    # XXX TODO do we really want to just get the first one?
+
+}
+1;
+
+

Added: Prophet/trunk/t/database-settings.t
==============================================================================
--- (empty file)
+++ Prophet/trunk/t/database-settings.t	Sun Oct 12 18:01:50 2008
@@ -0,0 +1,165 @@
+package MyApp::Model::Task;
+use Moose;
+extends 'Prophet::Record';
+use Prophet::DatabaseSetting;
+
+
+sub new { 
+    shift->SUPER::new(type => 'task', @_);
+}
+use constant type => 'task';
+
+sub status_list {
+    my $self = shift;
+    return Prophet::DatabaseSetting->new( handle => $self->handle, uuid => '5F7F1F51-7CD5-4AF7-A347-1FEE15082A5D');
+}
+
+sub component_list {
+    my $self = shift;
+    return Prophet::DatabaseSetting->new(  handle => $self->handle, uuid => 'D4051774-6AEC-4976-A54E-F19C424879B2');
+}
+
+sub default_component {
+    my $self = shift;
+    return Prophet::DatabaseSetting->new( handle => $self->handle,  uuid => 'B379D747-CB1D-4F69-839B-8E93E0FA3DD4');
+}
+
+package main;
+use warnings;
+use strict;
+
+use Prophet::Test 'no_plan';
+
+my ( $alice_cli, $bob_cli );
+
+as_alice {
+
+    #create a repo
+    $alice_cli = Prophet::CLI->new();
+    my $cxn = $alice_cli->handle;
+    isa_ok( $cxn, 'Prophet::Replica', "Got the cxn " . $cxn->fs_root );
+
+    # set up an app model class, "ticket"
+    my $t = MyApp::Model::Task->new(handle => $alice_cli->app_handle->handle);
+    # set default values for status 
+    my $status_list = $t->status_list;
+
+    my $comp_list = $t->component_list;
+    my $default_comp = $t->default_component;
+
+    isa_ok($status_list, 'Prophet::DatabaseSetting');
+   
+    can_ok($status_list, 'set');
+    can_ok($status_list, 'get');
+
+    # set list of acceptable components
+    $comp_list->set(qw/core ui docs/); 
+
+
+    # set default values for component
+    $default_comp->set('core'); 
+
+
+    # set list of acceptable statuses
+    $status_list->set('new','open','closed'); 
+
+    # enumerate statuses
+    is_deeply([$status_list->get], [qw/new open closed/]);
+
+    $status_list->set('new', 'closed');
+
+    is_deeply([$status_list->get], [qw/new closed/]);
+
+    # enumerate components
+    is_deeply([$t->component_list->get], [qw/core ui docs/]);
+    
+    # enumerate default component
+    is($t->default_component->get, 'core', "The thing we got was core");
+  
+   
+    # just for good measure, create a ticket
+    run_ok( 'prophet', [qw(create --type Bug -- --status new --from alice )], "Created a record as alice" );
+    run_output_matches( 'prophet', [qw(search --type Bug --regex .)], [qr/new/], " Found our record" );
+
+
+};
+
+as_bob {
+    $bob_cli = Prophet::CLI->new();
+    my $cxn = $bob_cli->handle;
+    isa_ok( $cxn, 'Prophet::Replica', "Got the cxn " . $cxn->fs_root );
+
+    run_ok( 'prophet', [qw(create --type Bug -- --status open --from bob )], "Created a record as bob" );
+    run_output_matches( 'prophet', [qw(search --type Bug --regex .)], [qr/open/], " Found our record" );
+
+    # pull from alice
+    run_ok( 'prophet', ['pull', '--from', "file://".$alice_cli->app_handle->handle->fs_root, '--force'] );
+    
+
+    my $t = MyApp::Model::Task->new(handle => $bob_cli->app_handle->handle);
+    
+    # enumerate statuses
+    is_deeply([$t->status_list->get], [qw/new closed/]);
+
+    # enumerate components
+    is_deeply([$t->component_list->get], [qw/core ui docs/]);
+    
+    # enumerate default component
+    is($t->default_component->get, 'core', "The thing we got was core");
+ 
+    $t->default_component->set('ui');
+
+    is($t->default_component->get, 'ui', "The thing we got was core");
+};
+
+as_alice {
+    $alice_cli = Prophet::CLI->new();
+    my $cxn = $alice_cli->handle;
+    isa_ok( $cxn, 'Prophet::Replica', "Got the cxn " . $cxn->fs_root );
+    
+    my $t = MyApp::Model::Task->new(handle => $alice_cli->app_handle->handle);
+    is($t->default_component->get, 'core', "The thing we got was core");
+    run_ok( 'prophet', ['pull', '--from', "file://".$bob_cli->app_handle->handle->fs_root, '--force'] );
+    is($t->default_component->get, 'ui', "The thing we got was core");
+
+    #   add a status
+    $t->status_list->set(qw/new open stalled resolved/);
+    
+    
+    };
+
+as_bob {
+    my $t = MyApp::Model::Task->new(handle => $bob_cli->app_handle->handle);
+    $t->status_list->set(qw/new open resolved rejected/);
+
+};
+
+as_bob {
+
+    #   pull from alice
+    run_ok( 'prophet', ['pull', '--from', "file://".$alice_cli->app_handle->handle->fs_root, '--force', '--prefer', 'to'] );
+    # enumerate statuses
+    my $t = MyApp::Model::Task->new(handle => $bob_cli->app_handle->handle);
+    TODO: { 
+    local $TODO = "we don't resolve config conflicts yet";
+    is_deeply([$t->status_list->get], [qw[new open stalled resolved rejected]]);
+};
+    # current behaviour
+    is_deeply([$t->status_list->get], [qw[new open resolved rejected]]);
+};
+
+as_alice {
+
+    #    pull from bob
+    run_ok( 'prophet', ['pull', '--from', "file://".$bob_cli->app_handle->handle->fs_root, '--force'] );
+    # enumerate statuses
+    my $t = MyApp::Model::Task->new(handle => $bob_cli->app_handle->handle);
+    TODO: { 
+    local $TODO = "we don't resolve config conflicts yet";
+    is_deeply([$t->status_list->get], [qw[new open stalled resolved rejected]]);
+};
+    # current behaviour
+    is_deeply([$t->status_list->get], [qw[new open resolved rejected]]);
+};
+
+1;