(feat): ability to subscribe to pro package

Controllers/api/v1/minds/config.php

@@ -39,6 +39,11 @@ class config implements Interfaces\Api, Interfaces\ApiIgnorePam
  "plus" => Minds\Core\Config::_()->get('plus'),
  "report_reasons" => Minds\Core\Config::_()->get('report_reasons'),
  "last_tos_update" => (Minds\Core\Config::_()->get('last_tos_update') ?: time()),
+ 'handlers' => [
+ 'plus' => Minds\Core\Di\Di::_()->get('Config')->get('plus')['handler'] ?? null,
+ 'pro' => Minds\Core\Di\Di::_()->get('Config')->get('pro')['handler'] ?? null,
+ ],
+ 'upgrades' => Minds\Core\Di\Di::_()->get('Config')->get('upgrades'),
  ];
 
  return Factory::response($minds);

Core/Wire/Delegates/UpgradesDelegate.php

+<?php
+/**
+ * Upgrades Delegate
+ */
+namespace Minds\Core\Wire\Delegates;
+
+use Minds\Core\Config;
+use Minds\Core\Di\Di;
+use Minds\Core\Wire\Wire;
+use Minds\Core\Pro\Manager as ProManager;
+
+class UpgradesDelegate
+{
+ /** @var Config */
+ private $config;
+
+ /** @var EntitiesBuilder */
+ private $entitiesBuilder;
+
+ /** @var ProManager */
+ private $proManager;
+
+ public function __construct($config = null, $entitiesBuilder = null, $proManager = null)
+ {
+ $this->config = $config ?: Di::_()->get('Config');
+ $this->entitiesBuilder = $entitiesBuilder ?: Di::_()->get('EntitiesBuilder');
+ $this->proManager = $proManager ?? Di::_()->get('Pro\Manager');
+ }
+
+ /**
+ * On Wire
+ * @param Wire $wire
+ * @param string $receiver_address
+ * @return Wire $wire
+ */
+ public function onWire($wire, $receiver_address): Wire
+ {
+ switch ($wire->getReceiver()->guid) {
+ case $this->config->get('blockchain')['contracts']['wire']['plus_guid']:
+ return $this->onPlusUpgrade($wire, $receiver_address);
+ break;
+ case $this->config->get('pro')['handler']:
+ return $this->onProUpgrade($wire, $receiver_address);
+ break;
+ }
+ return $wire; // Not expected
+ }
+
+ private function onPlusUpgrade($wire, $receiver_address): Wire
+ {
+ if (
+ !(
+ $receiver_address == 'offchain'
+ || $receiver_address == $this->config->get('blockchain')['contracts']['wire']['plus_address']
+ )
+ ) {
+ return $wire; //not offchain or potential onchain fraud
+ }
+
+ // 20 tokens
+ if ($wire->getAmount() != "20000000000000000000") {
+ return $wire; //incorrect wire amount sent
+ }
+
+ //set the plus period for this user
+ $user = $wire->getSender();
+
+ // rebuild the user as we can't trust upstream
+ $user = $this->entitiesBuilder->single($user->getGuid(), [
+ 'cache' => false,
+ ]);
+
+ if (!$user) {
+ return $wire;
+ }
+
+ $days = 30;
+ $monthly = $this->config->get('upgrades')['plus']['monthly'];
+ $yearly = $this->config->get('upgrades')['plus']['yearly'];
+ 
+ switch ($wire->getMethod()) {
+ case 'tokens':
+ if ($monthly['tokens'] == $wire->getAmount()) {
+ $days = 30;
+ } elseif ($yearly['tokens'] == $wire->getAmount()) {
+ $days = 365;
+ } else {
+ return $wire;
+ }
+ break;
+ case 'usd':
+ if ($monthly['usd'] == $wire->getAmount() / 100) {
+ $days = 30;
+ } elseif ($yearly['usd'] == $wire->getAmount() / 100) {
+ $days = 365;
+ } else {
+ return $wire;
+ }
+ break;
+ default:
+ return $wire;
+ }
+
+ $expires = strtotime("+{$days} days", $wire->getTimestamp());
+
+ $user->setPlusExpires($expires);
+ $user->save();
+
+ //$wire->setSender($user);
+ return $wire;
+ }
+
+ private function onProUpgrade($wire, $receiver_address): Wire
+ {
+ //set the plus period for this user
+ $user = $wire->getSender();
+
+ // rebuild the user as we can't trust upstream
+ $user = $this->entitiesBuilder->single($user->getGuid(), [
+ 'cache' => false,
+ ]);
+
+ if (!$user) {
+ return $wire;
+ }
+
+ $days = 30;
+ $monthly = $this->config->get('upgrades')['pro']['monthly'];
+ $yearly = $this->config->get('upgrades')['pro']['yearly'];
+
+ error_log($wire->getMethod());
+ switch ($wire->getMethod()) {
+ case 'tokens':
+ error_log($wire->getAmount());
+ if ($monthly['tokens'] == $wire->getAmount() / (10 ** 18)) {
+ $days = 30;
+ } elseif ($yearly['tokens'] == $wire->getAmount() / (10 ** 18)) {
+ $days = 365;
+ } else {
+ return $wire;
+ }
+ break;
+ case 'usd':
+ if ($monthly['usd'] == $wire->getAmount() / 100) {
+ $days = 30;
+ } elseif ($yearly['usd'] == $wire->getAmount() / 100) {
+ $days = 365;
+ } else {
+ return $wire;
+ }
+ break;
+ default:
+ return $wire;
+ }
+
+ $expires = strtotime("+{$days} days", $wire->getTimestamp());
+
+ $this->proManager->setUser($user)
+ ->enable($expires);
+
+ return $wire;
+ }
+}

Core/Wire/Manager.php

@@ -61,8 +61,8 @@ class Manager
  /** @var Core\Blockchain\Wallets\OffChain\Cap $cap */
  protected $cap;
  
- /** @var Delegates\Plus $plusDelegate */
- protected $plusDelegate;
+ /** @var Delegates\UpgradesDelegate */
+ protected $upgradesDelegate;
 
  /** @var Delegates\RecurringDelegate $recurringDelegate */
  protected $recurringDelegate;
@@ -87,7 +87,7 @@ class Manager
  $client = null,
  $token = null,
  $cap = null,
- $plusDelegate = null,
+ $upgradesDelegate = null,
  $recurringDelegate = null,
  $notificationDelegate = null,
  $cacheDelegate = null,
@@ -101,7 +101,8 @@ class Manager
  $this->client = $client ?: Di::_()->get('Blockchain\Services\Ethereum');
  $this->token = $token ?: Di::_()->get('Blockchain\Token');
  $this->cap = $cap ?: Di::_()->get('Blockchain\Wallets\OffChain\Cap');
- $this->plusDelegate = $plusDelegate ?: new Delegates\Plus();
+ $this->upgradesDelegate = $upgradesDelegate ?? new Delegates\UpgradesDelegate();
+ ;
  $this->recurringDelegate = $recurringDelegate ?: new Delegates\RecurringDelegate();
  $this->notificationDelegate = $notificationDelegate ?: new Delegates\NotificationDelegate();
  $this->cacheDelegate = $cacheDelegate ?: new Delegates\CacheDelegate();
@@ -248,8 +249,8 @@ class Manager
 
  $wire->setAddress('offchain');
 
- // Notify plus
- $this->plusDelegate
+ // Notify plus/pro
+ $this->upgradesDelegate
  ->onWire($wire, 'offchain');
 
  // Send notification
@@ -287,6 +288,10 @@ class Manager
  // Save the wire to the Repository
  $this->repository->add($wire);
 
+ // Notify plus/pro
+ $this->upgradesDelegate
+ ->onWire($wire, 'usd');
+
  // Send notification
  $this->notificationDelegate->onAdd($wire);
 
@@ -330,7 +335,7 @@ class Manager
  ->setCompleted(true);
  $this->txRepo->add($transaction);
 
- $this->plusDelegate
+ $this->upgradesDelegate
  ->onWire($wire, $data['receiver_address']);
 
  $this->notificationDelegate->onAdd($wire);

settings.example.php

@@ -380,6 +380,7 @@ $CONFIG->set('blockchain_override', [
 ]);
 
 $CONFIG->set('plus', [
+ 'handler' => '',
  'tokens' => [
  'month' => 5,
  'year' => 50
@@ -575,7 +576,32 @@ $CONFIG->set('gitlab', [
 ]);
 
 $CONFIG->set('pro', [
+ 'handler' => '',
  'root_domains' => ['minds.com', 'www.minds.com', 'localhost'],
  'subdomain_suffix' => 'minds.com',
  'dynamodb_table_name' => 'traefik',
 ]);
+
+
+$CONFIG->set('upgrades', [
+ 'pro' => [
+ 'monthly' => [
+ 'tokens' => 240,
+ 'usd' => 60,
+ ],
+ 'yearly' => [
+ 'tokens' => 2400,
+ 'usd' => 600,
+ ]
+ ],
+ 'plus' => [
+ 'monthly' => [
+ 'tokens' => 28,
+ 'usd' => 7,
+ ],
+ 'yearly' => [
+ 'tokens' => 240,
+ 'usd' => 60,
+ ]
+ ],
+]);