Merge pull request #116 from jesusantguerrero/feat/stable-v2

Feat/stable v2
jesusantguerrero · May 31, 2024 · 1b2978a · 1b2978a
2 parents 1b0341d + e5ba85d
commit 1b2978a
Show file tree

Hide file tree

Showing 117 changed files with 5,794 additions and 4,850 deletions.
diff --git a/app/Http/Controllers/BillingController.php b/app/Http/Controllers/BillingController.php
@@ -2,18 +2,18 @@
 
 namespace App\Http\Controllers;
 
-use Illuminate\Http\Request;
-use App\Http\Resources\Item as ItemResource;
-use App\Models\Board;
+use Carbon\Carbon;
 use App\Models\Item;
 use App\Models\Link;
 use Inertia\Inertia;
-use Illuminate\Support\Facades\URL;
+use App\Models\Board;
 use App\Models\Standup;
-use Carbon\Carbon;
+use Illuminate\Http\Request;
 use Insane\Treasurer\Models\Plan;
-use Insane\Treasurer\Models\Subscription;
+use Illuminate\Support\Facades\URL;
 use Insane\Treasurer\PaypalServiceV2;
+use Insane\Treasurer\Models\Subscription;
+use App\Http\Resources\Item as ItemResource;
 
 class BillingController extends Controller
 {
@@ -33,7 +33,7 @@ public function index(Request $request)
                 "user_id" => $user->id
             ])->get(),
             "transactions" => function () use ($request) {
-                return $request->user()->subscriptionTransactions();
+                return $request->user()->currentTeam->subscriptionTransactions();
             }
         ]);
     }

diff --git a/app/Http/Controllers/NeatlancerController.php b/app/Http/Controllers/NeatlancerController.php
@@ -0,0 +1,53 @@
+<?php
+
+namespace App\Http\Controllers;
+
+use App\Models\User;
+use GuzzleHttp\Client;
+use Illuminate\Support\Facades\Auth;
+use Laravel\Socialite\Facades\Socialite;
+
+class NeatlancerController {
+
+    public function connect() {
+        // request()->session()->put('state', $state = Str::random(40));
+
+        // $query = http_build_query([
+        //     'client_id' => '98e6222a-6bd7-4f85-a4a6-01931fd0e3fe',
+        //     'redirect_uri' => config('app.url') .'/oauth/accept',
+        //     'response_type' => 'code',
+        //     'scope' => '',
+        //     'state' => $state,
+        //     // 'prompt' =>  "consent"
+        //     // 'prompt' => '', // "none", "consent", or "login"
+        // ]);
+
+        // return redirect(config('app.sso_url') . '/oauth/authorize?'.$query);
+        return Socialite::driver('laravelpassport')->redirect();
+    }
+
+    public function accept() {
+        $accessInfo = Socialite::driver('laravelpassport')->user();
+
+        $guzzle = new Client(['base_uri' => config('app.sso_url')]);
+
+        $raw_response = $guzzle->get('/api/current-user', [
+            'headers' => [ 'Authorization' => 'Bearer ' . $accessInfo->token ],
+        ]);
+
+        $userInfo = json_decode($raw_response->getBody()->getContents());
+
+        $user = User::updateOrCreate([
+            'neatlancer_id' => $userInfo->id,
+        ], [
+            'name' => $userInfo->name,
+            'email' => $userInfo->email,
+            // 'avatar' => $userInfo?->avatar,
+            'neatlancer_token' => $accessInfo->token,
+            'neatlancer_refresh_token' => $accessInfo->refreshToken,
+        ]);
+
+        Auth::login($user);
+        return redirect('/dashboard');
+    }
+}
diff --git a/app/Http/Resources/Item.php b/app/Http/Resources/Item.php
@@ -19,6 +19,7 @@ public function toArray($request)
             'title' => $this->title,
             'resource_type' => $this->resource_type,
             'done' => $this->done,
+            'points' => $this->points,
             'commit_date' => $this->commit_date,
             'color' => $this->color,
             'stage' => $this->stage ? $this->stage->name : "",

diff --git a/app/Libraries/GoogleService.php b/app/Libraries/GoogleService.php
@@ -118,17 +118,6 @@ public static function getSheetsService($integrationId) {
         return $service;
     }
 
-    public static function storeIntegration($data, $user) {
-        Integration::updateOrCreate([
-            "team_id" => $user->current_team_id,
-            "user_id" => $user->id,
-            "name" => $data->service_name,
-            "automation_service_id" => $data->service_id
-        ], [
-            "hash" => $user->email
-        ]);
-    }
-
     public static function requestAccessToken($data, $user) {
         $client = new GoogleClient([
             "client_id" => config('integrations.google.client_id')

diff --git a/app/Libraries/SunService.php b/app/Libraries/SunService.php
@@ -0,0 +1,152 @@
+<?php
+namespace App\Libraries;
+
+use App\Jobs\ProcessCalendar;
+use App\Jobs\ProcessGmail;
+use App\Models\User;
+use App\Models\Automation;
+use App\Models\Integration;
+use Exception;
+use Google\Client as GoogleClient;
+use Google\Service\Calendar;
+use Google\Service\Gmail;
+
+class GoogleService
+{
+
+    public static function getTokens($userId) {
+        return User::find($userId);
+    }
+    public static function getConfigPath() {
+        return base_path(config("integrations.google.credentials_path"));
+    }
+
+    public static function setTokens($data, $user, $integrationId = null) {
+        if (!$integrationId && $_GET['code']) {
+
+            $client = new GoogleClient([ 'client_id' => config('integrations.google.client_id')]);
+            $client->setAuthConfig(self::getConfigPath());
+            $client->setAccessType('offline');
+            $userIdToken = $_GET['code'];
+            $tokenResponse = $client->fetchAccessTokenWithAuthCode($userIdToken);
+            $integration = Integration::where([
+                'user_id' => $user->id,
+                'team_id' => $user->current_team_id,
+                'name' => 'Google'
+            ])->first();
+            $googleUser = $client->verifyIdToken($tokenResponse["id_token"]);
+            if ($googleUser['email'] == $user->email) {
+                $integration->token = encrypt($tokenResponse['access_token']);
+                $integration->save();
+                session(['g_token', json_encode($tokenResponse)]);
+                return;
+            }
+            throw new Exception("Error obtaining the token" . $googleUser['email']);
+        } else if ($integrationId) {
+            $integration = Integration::find($integrationId);
+            $integration->token = encrypt($data->refresh_token);
+            session(['g_token', json_encode($data)]);
+
+            return;
+        };
+    }
+
+    public static function getClient($integrationId) {
+        $integration = Integration::find($integrationId);
+        $client = new GoogleClient();
+        $client->setAuthConfig(self::getConfigPath());
+        if (!$accessToken = session('g_token')) {
+            $accessToken = $client->fetchAccessTokenWithRefreshToken(decrypt($integration->token));
+        }
+
+        $client->setAccessToken($accessToken);
+
+        if ($client->isAccessTokenExpired()) {
+            dd($accessToken);
+            if ($refreshToken = $client->getRefreshToken()) {
+                $tokenResponse = $client->fetchAccessTokenWithRefreshToken($refreshToken);
+                self::setTokens((object) [
+                    'access_token' => $accessToken,
+                    'refresh_token' => $refreshToken
+                ],
+                $integration->user,
+                $integrationId);
+                $client->setAccessToken($accessToken);
+
+            }
+        }
+        return $client;
+    }
+
+    public static function storeIntegration($data, $user) {
+        Integration::updateOrCreate([
+            "team_id" => $user->current_team_id,
+            "user_id" => $user->id,
+            "name" => $data->service_name,
+            "automation_service_id" => $data->service_id
+        ], [
+            "hash" => $user->email
+        ]);
+    }
+
+    // services
+    public static function createItemFromCalendar($automationId, $afterResponse = null) {
+        $automation = Automation::find($automationId);
+        echo "$automation->name $automation->id \n";
+        $method = $afterResponse ? "dispatchAfterResponse" : "dispatch";
+        ProcessCalendar::$method($automation);
+        return true;
+    }
+
+    public static function listCalendars(int $integrationId) {
+        $client = self::getClient($integrationId);
+        $service = new Calendar($client);
+        return $service->calendarList->listCalendarList();
+    }
+
+    public static function createItemFromGmail($automationId, $afterResponse = null) {
+       $automation = Automation::find($automationId);
+       echo "$automation->name $automation->id \n";
+       $method = $afterResponse ? "dispatchAfterResponse" : "dispatch";
+       ProcessGmail::$method($automation);
+       return true;
+    }
+
+    public static function getSheetsService($integrationId) {
+        $client = GoogleService::getClient($integrationId);
+        $service = new Google_Service_Sheets($client);
+        return $service;
+    }
+
+    public static function storeIntegration($data, $user) {
+        Integration::updateOrCreate([
+            "team_id" => $user->current_team_id,
+            "user_id" => $user->id,
+            "name" => $data->service_name,
+            "automation_service_id" => $data->service_id
+        ], [
+            "hash" => $user->email
+        ]);
+    }
+
+    public static function requestAccessToken($data, $user) {
+        $client = new GoogleClient([
+            "client_id" => config('integrations.google.client_id')
+        ]);
+        $client->addScope([
+            Gmail::GMAIL_READONLY,
+            Calendar::CALENDAR_READONLY
+        ]);
+        $client->setRedirectUri(config('app.url') . "/services/accept-oauth");
+        $client->setAccessType('offline');
+        $client->setLoginHint($user->email);
+        $client->setApprovalPrompt('auto');
+        $client->setIncludeGrantedScopes(true);
+
+        $authUrl = $client->createAuthUrl();
+        if ($authUrl) {
+            self::storeIntegration($data, $user);
+        }
+        return $authUrl;
+    }
+}
diff --git a/app/Models/Item.php b/app/Models/Item.php
@@ -10,7 +10,21 @@
 
 class Item extends Model
 {
-    protected $fillable = ['board_id', 'team_id', 'stage_id','resource_id', 'rrule' ,'resource_type', 'resource_origin', 'title', 'order', 'user_id', 'done','commit_date', 'points'];
+    protected $fillable = [
+        'board_id',
+        'team_id',
+        'stage_id',
+        'resource_id',
+        'rrule' ,
+        'resource_type',
+        'resource_origin',
+        'title',
+        'order',
+        'user_id',
+        'done',
+        'commit_date',
+        'points'
+    ];
     protected $with = ['fields', 'checklist'];
     use HasFactory;
     use ItemScopeTrait;

diff --git a/app/Providers/EventServiceProvider.php b/app/Providers/EventServiceProvider.php
@@ -23,7 +23,11 @@ class EventServiceProvider extends ServiceProvider
         TeamCreated::class => [
             CreateTeamWorkspace::class,
             CreateTeamSettings::class
-        ]
+        ],
+        \SocialiteProviders\Manager\SocialiteWasCalled::class => [
+            // ... other providers
+            \SocialiteProviders\LaravelPassport\LaravelPassportExtendSocialite::class.'@handle',
+        ],
     ];
 
     /**

diff --git a/composer.json b/composer.json
@@ -14,15 +14,17 @@
         "doctrine/dbal": "^2.12",
         "freesgen/querify": "dev-master",
         "google/apiclient": "2.12.6",
-        "inertiajs/inertia-laravel": "^0.5.4",
+        "inertiajs/inertia-laravel": "^0.6.9",
         "insane/treasurer": "dev-master",
         "laravel/framework": "^9.19",
         "laravel/jetstream": "^2.11",
         "laravel/sanctum": "^3.0",
+        "laravel/socialite": "^5.6",
         "laravel/tinker": "^2.7",
         "php-mime-mail-parser/php-mime-mail-parser": "^7.0",
         "pusher/pusher-php-server": "^7.0",
         "rlanvin/php-rrule": "^2.2",
+        "socialiteproviders/laravelpassport": "^4.3",
         "tightenco/ziggy": "^1.4.3"
     },
     "require-dev": {