diff --git a/src/applications/phortune/product/PhortuneSubscriptionProduct.php b/src/applications/phortune/product/PhortuneSubscriptionProduct.php
index b63cc7c21c..85eb2999c7 100644
--- a/src/applications/phortune/product/PhortuneSubscriptionProduct.php
+++ b/src/applications/phortune/product/PhortuneSubscriptionProduct.php
@@ -1,107 +1,108 @@
 <?php
 
 final class PhortuneSubscriptionProduct
   extends  PhortuneProductImplementation {
 
   private $viewer;
   private $subscriptionPHID;
   private $subscription;
 
   public function setSubscriptionPHID($subscription_phid) {
     $this->subscriptionPHID = $subscription_phid;
     return $this;
   }
 
   public function getSubscriptionPHID() {
     return $this->subscriptionPHID;
   }
 
   public function setSubscription(PhortuneSubscription $subscription) {
     $this->subscription = $subscription;
     return $this;
   }
 
   public function getSubscription() {
     return $this->subscription;
   }
 
   public function setViewer(PhabricatorUser $viewer) {
     $this->viewer = $viewer;
     return $this;
   }
 
   public function getViewer() {
     return $this->viewer;
   }
 
   public function getRef() {
     return $this->getSubscriptionPHID();
   }
 
   public function getName(PhortuneProduct $product) {
     return $this->getSubscription()->getSubscriptionName();
   }
 
   public function getPriceAsCurrency(PhortuneProduct $product) {
     // Prices are calculated by the SubscriptionImplementation.
     return PhortuneCurrency::newEmptyCurrency();
   }
 
   public function didPurchaseProduct(
     PhortuneProduct $product,
     PhortunePurchase $purchase) {
-    // TODO: Callback the subscription.
-    return;
+    return $this->getSubscription()->didPurchaseProduct(
+      $product,
+      $purchase);
   }
 
   public function didRefundProduct(
     PhortuneProduct $product,
     PhortunePurchase $purchase,
     PhortuneCurrency $amount) {
     // TODO: Callback the subscription.
     return;
   }
 
   public function getPurchaseName(
     PhortuneProduct $product,
     PhortunePurchase $purchase) {
     return $this->getSubscription()->getPurchaseName(
       $product,
       $purchase);
   }
 
   public function getPurchaseURI(
     PhortuneProduct $product,
     PhortunePurchase $purchase) {
     return $this->getSubscription()->getPurchaseURI(
       $product,
       $purchase);
   }
 
   public function loadImplementationsForRefs(
     PhabricatorUser $viewer,
     array $refs) {
 
     $subscriptions = id(new PhortuneSubscriptionQuery())
       ->setViewer($viewer)
       ->withPHIDs($refs)
       ->execute();
     $subscriptions = mpull($subscriptions, null, 'getPHID');
 
     $objects = array();
     foreach ($refs as $ref) {
       $subscription = idx($subscriptions, $ref);
       if (!$subscription) {
         continue;
       }
 
       $objects[] = id(new PhortuneSubscriptionProduct())
         ->setViewer($viewer)
         ->setSubscriptionPHID($ref)
         ->setSubscription($subscription);
     }
 
     return $objects;
   }
 
 }
diff --git a/src/applications/phortune/storage/PhortuneSubscription.php b/src/applications/phortune/storage/PhortuneSubscription.php
index cc839adbea..a996dbf5d2 100644
--- a/src/applications/phortune/storage/PhortuneSubscription.php
+++ b/src/applications/phortune/storage/PhortuneSubscription.php
@@ -1,282 +1,291 @@
 <?php
 
 /**
  * A subscription bills users regularly.
  */
 final class PhortuneSubscription extends PhortuneDAO
   implements PhabricatorPolicyInterface {
 
   const STATUS_ACTIVE = 'active';
   const STATUS_CANCELLED = 'cancelled';
 
   protected $accountPHID;
   protected $merchantPHID;
   protected $triggerPHID;
   protected $authorPHID;
   protected $defaultPaymentMethodPHID;
   protected $subscriptionClassKey;
   protected $subscriptionClass;
   protected $subscriptionRefKey;
   protected $subscriptionRef;
   protected $status;
   protected $metadata = array();
 
   private $merchant = self::ATTACHABLE;
   private $account = self::ATTACHABLE;
   private $implementation = self::ATTACHABLE;
   private $trigger = self::ATTACHABLE;
 
   protected function getConfiguration() {
     return array(
       self::CONFIG_AUX_PHID => true,
       self::CONFIG_SERIALIZATION => array(
         'metadata' => self::SERIALIZATION_JSON,
       ),
       self::CONFIG_COLUMN_SCHEMA => array(
         'defaultPaymentMethodPHID' => 'phid?',
         'subscriptionClassKey' => 'bytes12',
         'subscriptionClass' => 'text128',
         'subscriptionRefKey' => 'bytes12',
         'subscriptionRef' => 'text128',
         'status' => 'text32',
       ),
       self::CONFIG_KEY_SCHEMA => array(
         'key_subscription' => array(
           'columns' => array('subscriptionClassKey', 'subscriptionRefKey'),
           'unique' => true,
         ),
         'key_account' => array(
           'columns' => array('accountPHID'),
         ),
         'key_merchant' => array(
           'columns' => array('merchantPHID'),
         ),
       ),
     ) + parent::getConfiguration();
   }
 
   public function generatePHID() {
     return PhabricatorPHID::generateNewPHID(
       PhortuneSubscriptionPHIDType::TYPECONST);
   }
 
   public static function initializeNewSubscription(
     PhortuneAccount $account,
     PhortuneMerchant $merchant,
     PhabricatorUser $author,
     PhortuneSubscriptionImplementation $implementation,
     PhabricatorTriggerClock $clock) {
 
     $trigger = id(new PhabricatorWorkerTrigger())
       ->setClock($clock);
 
     return id(new PhortuneSubscription())
       ->setStatus(self::STATUS_ACTIVE)
       ->setAccountPHID($account->getPHID())
       ->attachAccount($account)
       ->setMerchantPHID($merchant->getPHID())
       ->attachMerchant($merchant)
       ->setAuthorPHID($author->getPHID())
       ->setSubscriptionClass(get_class($implementation))
       ->setSubscriptionRef($implementation->getRef())
       ->attachImplementation($implementation)
       ->attachTrigger($trigger);
   }
 
   public function attachImplementation(
     PhortuneSubscriptionImplementation $impl) {
     $this->implementation = $impl;
     return $this;
   }
 
   public function getImplementation() {
     return $this->assertAttached($this->implementation);
   }
 
   public function attachAccount(PhortuneAccount $account) {
     $this->account = $account;
     return $this;
   }
 
   public function getAccount() {
     return $this->assertAttached($this->account);
   }
 
   public function attachMerchant(PhortuneMerchant $merchant) {
     $this->merchant = $merchant;
     return $this;
   }
 
   public function getMerchant() {
     return $this->assertAttached($this->merchant);
   }
 
   public function attachTrigger(PhabricatorWorkerTrigger $trigger) {
     $this->trigger = $trigger;
     return $this;
   }
 
   public function getTrigger() {
     return $this->assertAttached($this->trigger);
   }
 
   public function save() {
     $this->subscriptionClassKey = PhabricatorHash::digestForIndex(
       $this->subscriptionClass);
 
     $this->subscriptionRefKey = PhabricatorHash::digestForIndex(
       $this->subscriptionRef);
 
     $is_new = (!$this->getID());
 
     $this->openTransaction();
 
       // If we're saving this subscription for the first time, we're also
       // going to set up the trigger for it.
       if ($is_new) {
         $trigger_phid = PhabricatorPHID::generateNewPHID(
           PhabricatorWorkerTriggerPHIDType::TYPECONST);
         $this->setTriggerPHID($trigger_phid);
       }
 
       $result = parent::save();
 
       if ($is_new) {
         $trigger_action = new PhabricatorScheduleTaskTriggerAction(
           array(
             'class' => 'PhortuneSubscriptionWorker',
             'data' => array(
               'subscriptionPHID' => $this->getPHID(),
             ),
             'options' => array(
               'objectPHID' => $this->getPHID(),
               'priority' => PhabricatorWorker::PRIORITY_BULK,
             ),
           ));
 
         $trigger = $this->getTrigger();
         $trigger->setPHID($trigger_phid);
         $trigger->setAction($trigger_action);
         $trigger->save();
       }
     $this->saveTransaction();
 
     return $result;
   }
 
   public function getSubscriptionName() {
     return $this->getImplementation()->getName($this);
   }
 
   public function getSubscriptionFullName() {
     return $this->getImplementation()->getFullName($this);
   }
 
   public function getSubscriptionCrumbName() {
     return $this->getImplementation()->getCrumbName($this);
   }
 
   public function getCartName(PhortuneCart $cart) {
     return $this->getImplementation()->getCartName($this, $cart);
   }
 
   public function getURI() {
     $account_id = $this->getAccount()->getID();
     $id = $this->getID();
 
     return "/phortune/{$account_id}/subscription/view/{$id}/";
   }
 
   public function getEditURI() {
     $account_id = $this->getAccount()->getID();
     $id = $this->getID();
 
     return "/phortune/{$account_id}/subscription/edit/{$id}/";
   }
 
   public function getMerchantURI() {
     $merchant_id = $this->getMerchant()->getID();
     $id = $this->getID();
     return "/phortune/merchant/{$merchant_id}/subscription/view/{$id}/";
   }
 
   public function getCostForBillingPeriodAsCurrency($start_epoch, $end_epoch) {
     return $this->getImplementation()->getCostForBillingPeriodAsCurrency(
       $this,
       $start_epoch,
       $end_epoch);
   }
 
   public function shouldInvoiceForBillingPeriod($start_epoch, $end_epoch) {
     return $this->getImplementation()->shouldInvoiceForBillingPeriod(
       $this,
       $start_epoch,
       $end_epoch);
   }
 
   public function getPurchaseName(
     PhortuneProduct $product,
     PhortunePurchase $purchase) {
     return $this->getImplementation()->getPurchaseName(
       $this,
       $product,
       $purchase);
   }
 
   public function getPurchaseURI(
     PhortuneProduct $product,
     PhortunePurchase $purchase) {
     return $this->getImplementation()->getPurchaseURI(
       $this,
       $product,
       $purchase);
   }
 
+  public function didPurchaseProduct(
+    PhortuneProduct $product,
+    PhortunePurchase $purchase) {
+    return $this->getImplementation()->didPurchaseProduct(
+      $this,
+      $product,
+      $purchase);
+  }
+
 
 /* -(  PhabricatorPolicyInterface  )----------------------------------------- */
 
 
   public function getCapabilities() {
     return array(
       PhabricatorPolicyCapability::CAN_VIEW,
       PhabricatorPolicyCapability::CAN_EDIT,
     );
   }
 
   public function getPolicy($capability) {
     // NOTE: Both view and edit use the account's edit policy. We punch a hole
     // through this for merchants, below.
     return $this
       ->getAccount()
       ->getPolicy(PhabricatorPolicyCapability::CAN_EDIT);
   }
 
   public function hasAutomaticCapability($capability, PhabricatorUser $viewer) {
     if ($this->getAccount()->hasAutomaticCapability($capability, $viewer)) {
       return true;
     }
 
     // If the viewer controls the merchant this subscription bills to, they can
     // view the subscription.
     if ($capability == PhabricatorPolicyCapability::CAN_VIEW) {
       $can_admin = PhabricatorPolicyFilter::hasCapability(
         $viewer,
         $this->getMerchant(),
         PhabricatorPolicyCapability::CAN_EDIT);
       if ($can_admin) {
         return true;
       }
     }
 
     return false;
   }
 
   public function describeAutomaticCapability($capability) {
     return array(
       pht('Subscriptions inherit the policies of the associated account.'),
       pht(
         'The merchant you are subscribed with can review and manage the '.
         'subscription.'),
     );
   }
 }
diff --git a/src/applications/phortune/subscription/PhortuneSubscriptionImplementation.php b/src/applications/phortune/subscription/PhortuneSubscriptionImplementation.php
index f8cbc21155..a337551c8d 100644
--- a/src/applications/phortune/subscription/PhortuneSubscriptionImplementation.php
+++ b/src/applications/phortune/subscription/PhortuneSubscriptionImplementation.php
@@ -1,51 +1,59 @@
 <?php
 
 abstract class PhortuneSubscriptionImplementation extends Phobject {
 
   abstract public function loadImplementationsForRefs(
     PhabricatorUser $viewer,
     array $refs);
 
   abstract public function getRef();
   abstract public function getName(PhortuneSubscription $subscription);
 
   public function getFullName(PhortuneSubscription $subscription) {
     return $this->getName($subscription);
   }
 
   public function getCrumbName(PhortuneSubscription $subscription) {
     return $this->getName($subscription);
   }
 
   abstract public function getCostForBillingPeriodAsCurrency(
     PhortuneSubscription $subscription,
     $start_epoch,
     $end_epoch);
 
   public function shouldInvoiceForBillingPeriod(
     PhortuneSubscription $subscription,
     $start_epoch,
     $end_epoch) {
     return true;
   }
 
   public function getCartName(
     PhortuneSubscription $subscription,
     PhortuneCart $cart) {
     return pht('Subscription');
   }
 
   public function getPurchaseName(
     PhortuneSubscription $subscription,
     PhortuneProduct $product,
     PhortunePurchase $purchase) {
     return $product->getProductName();
   }
 
   public function getPurchaseURI(
     PhortuneSubscription $subscription,
     PhortuneProduct $product,
     PhortunePurchase $purchase) {
     return null;
   }
+
+  public function didPurchaseProduct(
+    PhortuneSubscription $subscription,
+    PhortuneProduct $product,
+    PhortunePurchase $purchase) {
+    return null;
+  }
+
 }