[Bps-public-commit] r15313 - in sd/trunk: . lib/App/SD/Replica/RT lib/App/SD/Replica/rt

[jesse at bestpractical.com]

Author: jesse
Date: Wed Aug 20 23:27:37 2008
New Revision: 15313

Added:
   sd/trunk/lib/App/SD/Replica/rt/
      - copied from r15312, /sd/trunk/lib/App/SD/Replica/RT/
   sd/trunk/lib/App/SD/Replica/rt.pm
      - copied, changed from r15091, /sd/trunk/lib/App/SD/Replica/RT.pm
Removed:
   sd/trunk/lib/App/SD/Replica/RT/
   sd/trunk/lib/App/SD/Replica/RT.pm
Modified:
   sd/trunk/   (props changed)
   sd/trunk/lib/App/SD/Replica/hm.pm

Log:
 r43746 at jesse-vincents-macbook-air:  jesse | 2008-08-20 09:58:05 -0400
 snapshot
 r43747 at jesse-vincents-macbook-air:  jesse | 2008-08-20 10:01:55 -0400
 snapshot
 r43762 at jesse-vincents-macbook-air:  jesse | 2008-08-20 23:26:53 -0400
 Keep up to date with fixes to prophet to use replica types named by scheme so we don't need to do probing


Modified: sd/trunk/lib/App/SD/Replica/hm.pm
==============================================================================
--- sd/trunk/lib/App/SD/Replica/hm.pm	(original)
+++ sd/trunk/lib/App/SD/Replica/hm.pm	Wed Aug 20 23:27:37 2008
@@ -12,8 +12,8 @@
 has hm_url => ( isa => 'Str', is => 'rw');
 has hm_username => ( isa => 'Str', is => 'rw');
 
-
 use constant scheme => 'hm';
+use App::SD::Replica::rt;
 
 
 =head2 setup
@@ -104,11 +104,11 @@
 }
 
 sub prophet_has_seen_transaction {
-    goto \&App::SD::Replica::RT::prophet_has_seen_transaction;
+    goto \&App::SD::Replica::rt::prophet_has_seen_transaction;
 }
 
 sub record_pushed_transaction {
-    goto \&App::SD::Replica::RT::record_pushed_transaction;
+    goto \&App::SD::Replica::rt::record_pushed_transaction;
 }
 
 sub record_pushed_transactions {
@@ -117,7 +117,7 @@
 }
 
 sub _txn_storage {
-    goto \&App::SD::Replica::RT::_txn_storage;
+    goto \&App::SD::Replica::rt::_txn_storage;
 }
 
 # hiveminder transaction ~= prophet changeset

Copied: sd/trunk/lib/App/SD/Replica/rt.pm (from r15091, /sd/trunk/lib/App/SD/Replica/RT.pm)
==============================================================================
--- /sd/trunk/lib/App/SD/Replica/RT.pm	(original)
+++ sd/trunk/lib/App/SD/Replica/rt.pm	Wed Aug 20 23:27:37 2008
@@ -1,4 +1,4 @@
-package App::SD::Replica::RT;
+package App::SD::Replica::rt;
 use Moose;
 extends qw/Prophet::ForeignReplica/;
 
@@ -195,8 +195,8 @@
         { isa => 'Prophet::ChangeSet' }
     );
 
-    require App::SD::Replica::RT::PushEncoder;
-    my $recoder = App::SD::Replica::RT::PushEncoder->new( { sync_source => $self } );
+    require App::SD::Replica::rt::PushEncoder;
+    my $recoder = App::SD::Replica::rt::PushEncoder->new( { sync_source => $self } );
     $recoder->integrate_change($change,$changeset);
 }
 
@@ -220,8 +220,8 @@
         }
     );
 
-    require App::SD::Replica::RT::PullEncoder;
-    my $recoder = App::SD::Replica::RT::PullEncoder->new( { sync_source => $self } );
+    require App::SD::Replica::rt::PullEncoder;
+    my $recoder = App::SD::Replica::rt::PullEncoder->new( { sync_source => $self } );
     $recoder->run( query => $self->rt_query, after => $args{'after'}, callback => $args{'callback'});
 
 }