From: Jonathan Prykop <jonathan@freeside.biz>
Date: Wed, 28 Dec 2016 20:18:29 +0000 (-0600)
Subject: 71513: Card tokenization [project branch merge]
X-Git-Url: http://git.freeside.biz/gitweb/?a=commitdiff_plain;h=691b4de7c0a7d0e39bebe2ea7fadea5fb21b1539;p=freeside.git

71513: Card tokenization [project branch merge]
---

691b4de7c0a7d0e39bebe2ea7fadea5fb21b1539
diff --cc FS/FS/cust_main.pm
index 2147ce1b5,71552b0d3..4bd3f2619
--- a/FS/FS/cust_main.pm
+++ b/FS/FS/cust_main.pm
@@@ -5789,80 -5788,9 +5796,82 @@@ sub _upgrade_data { #class metho
  
  sub queueable_upgrade {
    my $class = shift;
 +
 +  ### encryption gets turned on in _upgrade_data, above
 +
 +  eval "use FS::upgrade_journal";
 +  die $@ if $@;
 +
 +  # prior to 2013 (commit f16665c9) payinfo was stored in history if not encrypted,
 +  # clear that out before encrypting/tokenizing anything else
 +  if (!FS::upgrade_journal->is_done('clear_payinfo_history')) {
 +    foreach my $table ('cust_payby','cust_pay_pending','cust_pay','cust_pay_void','cust_refund') {
 +      my $sql = 'UPDATE h_'.$table.' SET payinfo = NULL WHERE payinfo IS NOT NULL';
 +      my $sth = dbh->prepare($sql) or die dbh->errstr;
 +      $sth->execute or die $sth->errstr;
 +    }
 +    FS::upgrade_journal->set_done('clear_payinfo_history');
 +  }
 +
 +  # encrypt old records
 +  if ($conf->exists('encryption') && !FS::upgrade_journal->is_done('encryption_check')) {
 +
 +    # allow replacement of closed cust_pay/cust_refund records
 +    local $FS::payinfo_Mixin::allow_closed_replace = 1;
 +
 +    # because it looks like nothing's changing
 +    local $FS::Record::no_update_diff = 1;
 +
 +    # commit everything immediately
 +    local $FS::UID::AutoCommit = 1;
 +
 +    # encrypt what's there
 +    foreach my $table ('cust_payby','cust_pay_pending','cust_pay','cust_pay_void','cust_refund') {
 +      my $tclass = 'FS::'.$table;
 +      my $lastrecnum = 0;
 +      my @recnums = ();
 +      while (my $recnum = _upgrade_next_recnum(dbh,$table,\$lastrecnum,\@recnums)) {
 +        my $record = $tclass->by_key($recnum);
 +        next unless $record; # small chance it's been deleted, that's ok
 +        next unless grep { $record->payby eq $_ } @FS::Record::encrypt_payby;
 +        # window for possible conflict is practically nonexistant,
 +        #   but just in case...
 +        $record = $record->select_for_update;
 +        my $error = $record->replace;
 +        die $error if $error;
 +      }
 +    }
 +
 +    FS::upgrade_journal->set_done('encryption_check');
 +  }
 +
++  # now that everything's encrypted, tokenize...
+   FS::cust_main::Billing_Realtime::token_check(@_);
  }
  
 +# not entirely false laziness w/ Billing_Realtime::_token_check_next_recnum
 +# cust_payby might get deleted while this runs
 +# not a method!
 +sub _upgrade_next_recnum {
 +  my ($dbh,$table,$lastrecnum,$recnums) = @_;
 +  my $recnum = shift @$recnums;
 +  return $recnum if $recnum;
 +  my $tclass = 'FS::'.$table;
 +  my $sql = 'SELECT '.$tclass->primary_key.
 +            ' FROM '.$table.
 +            ' WHERE '.$tclass->primary_key.' > '.$$lastrecnum.
 +            ' ORDER BY '.$tclass->primary_key.' LIMIT 500';;
 +  my $sth = $dbh->prepare($sql) or die $dbh->errstr;
 +  $sth->execute() or die $sth->errstr;
 +  my @recnums;
 +  while (my $rec = $sth->fetchrow_hashref) {
 +    push @$recnums, $rec->{$tclass->primary_key};
 +  }
 +  $sth->finish();
 +  $$lastrecnum = $$recnums[-1];
 +  return shift @$recnums;
 +}
 +
  =back
  
  =head1 BUGS