From 1599711deeabfcc0b33bba265949f64528d4f8db Mon Sep 17 00:00:00 2001
From: David Bomba <turbo124@gmail.com>
Date: Fri, 5 Mar 2021 21:18:28 +1100
Subject: [PATCH 1/3] Observers and policy scaffold

---
 app/Console/Kernel.php                        |  3 +
 app/Jobs/Cron/BillingSubscriptionCron.php     | 52 ++++++++++++++
 app/Models/BillingSubscription.php            | 19 +++++
 app/Models/ClientSubscription.php             | 19 +++++
 app/Observers/BillingSubscriptionObserver.php | 72 +++++++++++++++++++
 app/Observers/ClientSubscriptionObserver.php  | 72 +++++++++++++++++++
 app/Policies/BillingSubscriptionPolicy.php    | 31 ++++++++
 app/Providers/AppServiceProvider.php          |  8 ++-
 app/Providers/AuthServiceProvider.php         |  3 +
 9 files changed, 278 insertions(+), 1 deletion(-)
 create mode 100644 app/Jobs/Cron/BillingSubscriptionCron.php
 create mode 100644 app/Models/BillingSubscription.php
 create mode 100644 app/Models/ClientSubscription.php
 create mode 100644 app/Observers/BillingSubscriptionObserver.php
 create mode 100644 app/Observers/ClientSubscriptionObserver.php
 create mode 100644 app/Policies/BillingSubscriptionPolicy.php

diff --git a/app/Console/Kernel.php b/app/Console/Kernel.php
index 24a661eae68f..1d3be1016fce 100644
--- a/app/Console/Kernel.php
+++ b/app/Console/Kernel.php
@@ -11,6 +11,7 @@
 
 namespace App\Console;
 
+use App\Jobs\Cron\BillingSubscriptionCron;
 use App\Jobs\Cron\RecurringInvoicesCron;
 use App\Jobs\Ninja\AdjustEmailQuota;
 use App\Jobs\Ninja\CompanySizeCheck;
@@ -53,6 +54,8 @@ class Kernel extends ConsoleKernel
 
         $schedule->job(new UpdateExchangeRates)->daily()->withoutOverlapping();
 
+        $schedule->job(new BillingSubscriptionCron)->daily()->withoutOverlapping();
+
         $schedule->job(new RecurringInvoicesCron)->hourly()->withoutOverlapping();
 
         /* Run hosted specific jobs */
diff --git a/app/Jobs/Cron/BillingSubscriptionCron.php b/app/Jobs/Cron/BillingSubscriptionCron.php
new file mode 100644
index 000000000000..993605593365
--- /dev/null
+++ b/app/Jobs/Cron/BillingSubscriptionCron.php
@@ -0,0 +1,52 @@
+<?php
+/**
+ * Invoice Ninja (https://invoiceninja.com).
+ *
+ * @link https://github.com/invoiceninja/invoiceninja source repository
+ *
+ * @copyright Copyright (c) 2021. Invoice Ninja LLC (https://invoiceninja.com)
+ *
+ * @license https://opensource.org/licenses/AAL
+ */
+
+namespace App\Jobs\Cron;
+
+use App\Libraries\MultiDB;
+use Illuminate\Foundation\Bus\Dispatchable;
+use Illuminate\Support\Carbon;
+
+class BillingSubscriptionCron
+{
+    use Dispatchable;
+
+    /**
+     * Create a new job instance.
+     *
+     * @return void
+     */
+    public function __construct()
+    {
+    }
+
+    /**
+     * Execute the job.
+     *
+     * @return void
+     */
+    public function handle() : void
+    {
+        /* Get all invoices where the send date is less than NOW + 30 minutes() */
+
+        if (! config('ninja.db.multi_db_enabled')) {
+
+        } else {
+            //multiDB environment, need to
+            foreach (MultiDB::$dbs as $db) {
+
+                MultiDB::setDB($db);
+
+
+            }
+        }
+    }
+}
diff --git a/app/Models/BillingSubscription.php b/app/Models/BillingSubscription.php
new file mode 100644
index 000000000000..2fc9f30115d4
--- /dev/null
+++ b/app/Models/BillingSubscription.php
@@ -0,0 +1,19 @@
+<?php
+/**
+ * Invoice Ninja (https://invoiceninja.com).
+ *
+ * @link https://github.com/invoiceninja/invoiceninja source repository
+ *
+ * @copyright Copyright (c) 2021. Invoice Ninja LLC (https://invoiceninja.com)
+ *
+ * @license https://opensource.org/licenses/AAL
+ */
+
+namespace App\Models;
+
+use Illuminate\Database\Eloquent\Factories\HasFactory;
+
+class BillingSubscription extends BaseModel
+{
+    use HasFactory;
+}
diff --git a/app/Models/ClientSubscription.php b/app/Models/ClientSubscription.php
new file mode 100644
index 000000000000..dcb85e9adaaf
--- /dev/null
+++ b/app/Models/ClientSubscription.php
@@ -0,0 +1,19 @@
+<?php
+/**
+ * Invoice Ninja (https://invoiceninja.com).
+ *
+ * @link https://github.com/invoiceninja/invoiceninja source repository
+ *
+ * @copyright Copyright (c) 2021. Invoice Ninja LLC (https://invoiceninja.com)
+ *
+ * @license https://opensource.org/licenses/AAL
+ */
+
+namespace App\Models;
+
+use Illuminate\Database\Eloquent\Factories\HasFactory;
+
+class ClientSubscription extends BaseModel
+{
+    use HasFactory;
+}
diff --git a/app/Observers/BillingSubscriptionObserver.php b/app/Observers/BillingSubscriptionObserver.php
new file mode 100644
index 000000000000..dc813c732544
--- /dev/null
+++ b/app/Observers/BillingSubscriptionObserver.php
@@ -0,0 +1,72 @@
+<?php
+/**
+ * Invoice Ninja (https://invoiceninja.com).
+ *
+ * @link https://github.com/invoiceninja/invoiceninja source repository
+ *
+ * @copyright Copyright (c) 2021. Invoice Ninja LLC (https://invoiceninja.com)
+ *
+ * @license https://opensource.org/licenses/AAL
+ */
+
+namespace App\Observers;
+
+use App\Models\BillingSubscription;
+
+class BillingSubscriptionObserver
+{
+    /**
+     * Handle the billing_subscription "created" event.
+     *
+     * @param BillingSubscription $billing_subscription
+     * @return void
+     */
+    public function created(BillingSubscription $billing_subscription)
+    {
+        //
+    }
+
+    /**
+     * Handle the billing_subscription "updated" event.
+     *
+     * @param BillingSubscription $billing_subscription
+     * @return void
+     */
+    public function updated(BillingSubscription $billing_subscription)
+    {
+        //
+    }
+
+    /**
+     * Handle the billing_subscription "deleted" event.
+     *
+     * @param BillingSubscription $billing_subscription
+     * @return void
+     */
+    public function deleted(BillingSubscription $billing_subscription)
+    {
+        //
+    }
+
+    /**
+     * Handle the billing_subscription "restored" event.
+     *
+     * @param BillingSubscription $billing_subscription
+     * @return void
+     */
+    public function restored(BillingSubscription $billing_subscription)
+    {
+        //
+    }
+
+    /**
+     * Handle the billing_subscription "force deleted" event.
+     *
+     * @param BillingSubscription $billing_subscription
+     * @return void
+     */
+    public function forceDeleted(BillingSubscription $billing_subscription)
+    {
+        //
+    }
+}
diff --git a/app/Observers/ClientSubscriptionObserver.php b/app/Observers/ClientSubscriptionObserver.php
new file mode 100644
index 000000000000..ccdb7fafcbd1
--- /dev/null
+++ b/app/Observers/ClientSubscriptionObserver.php
@@ -0,0 +1,72 @@
+<?php
+/**
+ * Invoice Ninja (https://invoiceninja.com).
+ *
+ * @link https://github.com/invoiceninja/invoiceninja source repository
+ *
+ * @copyright Copyright (c) 2021. Invoice Ninja LLC (https://invoiceninja.com)
+ *
+ * @license https://opensource.org/licenses/AAL
+ */
+
+namespace App\Observers;
+
+use App\Models\ClientSubscription;
+
+class ClientSubscriptionObserver
+{
+    /**
+     * Handle the client_subscription "created" event.
+     *
+     * @param ClientSubscription $client_subscription
+     * @return void
+     */
+    public function created(ClientSubscription $client_subscription)
+    {
+        //
+    }
+
+    /**
+     * Handle the client_subscription "updated" event.
+     *
+     * @param ClientSubscription $client_subscription
+     * @return void
+     */
+    public function updated(ClientSubscription $client_subscription)
+    {
+        //
+    }
+
+    /**
+     * Handle the client_subscription "deleted" event.
+     *
+     * @param ClientSubscription $client_subscription
+     * @return void
+     */
+    public function deleted(ClientSubscription $client_subscription)
+    {
+        //
+    }
+
+    /**
+     * Handle the client_subscription "restored" event.
+     *
+     * @param ClientSubscription $client_subscription
+     * @return void
+     */
+    public function restored(ClientSubscription $client_subscription)
+    {
+        //
+    }
+
+    /**
+     * Handle the client_subscription "force deleted" event.
+     *
+     * @param ClientSubscription $client_subscription
+     * @return void
+     */
+    public function forceDeleted(ClientSubscription $client_subscription)
+    {
+        //
+    }
+}
diff --git a/app/Policies/BillingSubscriptionPolicy.php b/app/Policies/BillingSubscriptionPolicy.php
new file mode 100644
index 000000000000..aee6b5e190de
--- /dev/null
+++ b/app/Policies/BillingSubscriptionPolicy.php
@@ -0,0 +1,31 @@
+<?php
+/**
+ * Invoice Ninja (https://invoiceninja.com).
+ *
+ * @link https://github.com/invoiceninja/invoiceninja source repository
+ *
+ * @copyright Copyright (c) 2021. Invoice Ninja LLC (https://invoiceninja.com)
+ *
+ * @license https://opensource.org/licenses/AAL
+ */
+
+namespace App\Policies;
+
+use App\Models\User;
+
+/**
+ * Class BillingSubscriptionPolicy.
+ */
+class BillingSubscriptionPolicy extends EntityPolicy
+{
+    /**
+     *  Checks if the user has create permissions.
+     *
+     * @param  User $user
+     * @return bool
+     */
+    public function create(User $user) : bool
+    {
+        return $user->isAdmin() || $user->hasPermission('create_billing_subscription') || $user->hasPermission('create_all');
+    }
+}
diff --git a/app/Providers/AppServiceProvider.php b/app/Providers/AppServiceProvider.php
index 3d96377fa950..c017572692c3 100644
--- a/app/Providers/AppServiceProvider.php
+++ b/app/Providers/AppServiceProvider.php
@@ -12,7 +12,9 @@
 namespace App\Providers;
 
 use App\Models\Account;
+use App\Models\BillingSubscription;
 use App\Models\Client;
+use App\Models\ClientSubscription;
 use App\Models\Company;
 use App\Models\CompanyGateway;
 use App\Models\CompanyToken;
@@ -26,7 +28,9 @@ use App\Models\Quote;
 use App\Models\Task;
 use App\Models\User;
 use App\Observers\AccountObserver;
+use App\Observers\BillingSubscriptionObserver;
 use App\Observers\ClientObserver;
+use App\Observers\ClientSubscriptionObserver;
 use App\Observers\CompanyGatewayObserver;
 use App\Observers\CompanyObserver;
 use App\Observers\CompanyTokenObserver;
@@ -75,9 +79,10 @@ class AppServiceProvider extends ServiceProvider
 
         Schema::defaultStringLength(191);
 
-        User::observe(UserObserver::class);
         Account::observe(AccountObserver::class);
+        BillingSubscription::observe(BillingSubscriptionObserver::class);
         Client::observe(ClientObserver::class);
+        ClientSubscription::observe(ClientSubscriptionObserver::class);
         Company::observe(CompanyObserver::class);
         CompanyGateway::observe(CompanyGatewayObserver::class);
         CompanyToken::observe(CompanyTokenObserver::class);
@@ -89,6 +94,7 @@ class AppServiceProvider extends ServiceProvider
         Proposal::observe(ProposalObserver::class);
         Quote::observe(QuoteObserver::class);
         Task::observe(TaskObserver::class);
+        User::observe(UserObserver::class);
 
         // Queue::before(function (JobProcessing $event) {
         //     // \Log::info('Event Job '.$event->connectionName);
diff --git a/app/Providers/AuthServiceProvider.php b/app/Providers/AuthServiceProvider.php
index 23d6f3a59220..60281db3b3fe 100644
--- a/app/Providers/AuthServiceProvider.php
+++ b/app/Providers/AuthServiceProvider.php
@@ -12,6 +12,7 @@
 namespace App\Providers;
 
 use App\Models\Activity;
+use App\Models\BillingSubscription;
 use App\Models\Client;
 use App\Models\Company;
 use App\Models\CompanyGateway;
@@ -37,6 +38,7 @@ use App\Models\User;
 use App\Models\Vendor;
 use App\Models\Webhook;
 use App\Policies\ActivityPolicy;
+use App\Policies\BillingSubscriptionPolicy;
 use App\Policies\ClientPolicy;
 use App\Policies\CompanyGatewayPolicy;
 use App\Policies\CompanyPolicy;
@@ -73,6 +75,7 @@ class AuthServiceProvider extends ServiceProvider
      */
     protected $policies = [
         Activity::class => ActivityPolicy::class,
+        BillingSubscription::class => BillingSubscriptionPolicy::class,
         Client::class => ClientPolicy::class,
         Company::class => CompanyPolicy::class,
         CompanyToken::class => CompanyTokenPolicy::class,

From 097d9ac1b8909d5a0284df1c45bdce81fac2b626 Mon Sep 17 00:00:00 2001
From: = <turbo124@gmail.com>
Date: Sat, 6 Mar 2021 11:47:05 +1100
Subject: [PATCH 2/3] Padding out functionality

---
 app/Jobs/Cron/BillingSubscriptionCron.php | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/app/Jobs/Cron/BillingSubscriptionCron.php b/app/Jobs/Cron/BillingSubscriptionCron.php
index 993605593365..453ab3befa02 100644
--- a/app/Jobs/Cron/BillingSubscriptionCron.php
+++ b/app/Jobs/Cron/BillingSubscriptionCron.php
@@ -49,4 +49,14 @@ class BillingSubscriptionCron
             }
         }
     }
+
+    /* Our daily cron should check
+
+        1. Is the subscription still in trial phase?
+        2. Check the recurring invoice and its remaining_cycles to see whether we need to cancel or perform any other function.
+    */
+    private function processSubscription($client_subscription)
+    {
+
+    }
 }

From 93493116ed5ede879f062c327b191469b012cb7b Mon Sep 17 00:00:00 2001
From: = <turbo124@gmail.com>
Date: Sat, 6 Mar 2021 17:19:57 +1100
Subject: [PATCH 3/3] Scaffolds for billing_subscriptions

---
 app/Jobs/Cron/BillingSubscriptionCron.php | 15 ++++++++++++---
 1 file changed, 12 insertions(+), 3 deletions(-)

diff --git a/app/Jobs/Cron/BillingSubscriptionCron.php b/app/Jobs/Cron/BillingSubscriptionCron.php
index 453ab3befa02..091cb10c5f83 100644
--- a/app/Jobs/Cron/BillingSubscriptionCron.php
+++ b/app/Jobs/Cron/BillingSubscriptionCron.php
@@ -35,25 +35,34 @@ class BillingSubscriptionCron
      */
     public function handle() : void
     {
-        /* Get all invoices where the send date is less than NOW + 30 minutes() */
 
         if (! config('ninja.db.multi_db_enabled')) {
-
+            $this->loopSubscriptions();
         } else {
             //multiDB environment, need to
             foreach (MultiDB::$dbs as $db) {
 
                 MultiDB::setDB($db);
-
+                $this->loopSubscriptions();
 
             }
         }
     }
 
+    private function loopSubscriptions()
+    {
+        $client_subs = ClientSubscription::whereNull('deleted_at')
+                                           ->cursor()
+                                           ->each(function ($cs){
+                                                $this->processSubscription($cs);
+                                            });
+    }
+
     /* Our daily cron should check
 
         1. Is the subscription still in trial phase?
         2. Check the recurring invoice and its remaining_cycles to see whether we need to cancel or perform any other function.
+        3. Any notifications that need to fire?
     */
     private function processSubscription($client_subscription)
     {