withoutMiddleware( ThrottleRequests::class ); $this->withoutExceptionHandling(); Account::all()->each(function ($account) { $account->delete(); }); CompanyGateway::all()->each(function ($cg) { $cg->forceDelete(); }); $this->account = Account::factory()->create(); $this->company = Company::factory()->create(['account_id' => $this->account->id]); $backup_json_file_zip = base_path().'/tests/Feature/Import/backup.zip'; $zip = new \ZipArchive; $res = $zip->open($backup_json_file_zip); if ($res === true) { $zip->extractTo(sys_get_temp_dir()); $zip->close(); } $backup_json_file = sys_get_temp_dir().'/backup/backup.json'; $this->backup_json_object = json_decode(file_get_contents($backup_json_file)); Credit::all()->each(function ($credit) { $credit->forceDelete(); }); CreditInvitation::all()->each(function ($credit) { $credit->forceDelete(); }); } public function testBackupJsonRead() { $backup_json_file_zip = base_path().'/tests/Feature/Import/backup.zip'; $zip = new \ZipArchive; $res = $zip->open($backup_json_file_zip); if ($res === true) { $zip->extractTo(sys_get_temp_dir()); $zip->close(); } $backup_json_file = sys_get_temp_dir().'/backup/backup.json'; $this->assertTrue(is_array(json_decode(file_get_contents($backup_json_file), 1))); unlink($backup_json_file); } public function testAppVersion() { $this->assertEquals('5.1.65', $this->backup_json_object->app_version); } public function testImportUsers() { CompanyGateway::all()->each(function ($cg) { $cg->forceDelete(); }); $this->assertTrue(property_exists($this->backup_json_object, 'app_version')); /***************************** Users *****************************/ $this->assertTrue(property_exists($this->backup_json_object, 'users')); User::all()->each(function ($user) { $user->forceDelete(); }); User::unguard(); $this->assertEquals(2, count($this->backup_json_object->users)); foreach ($this->backup_json_object->users as $user) { $user_array = (array) $user; unset($user_array['laravel_through_key']); unset($user_array['hashed_id']); $new_user = User::firstOrNew( ['email' => $user->email], array_merge($user_array, ['account_id' => $this->account->id]), ); $new_user->save(['timestamps' => false]); $this->ids['users']["{$user->hashed_id}"] = $new_user->id; } User::reguard(); $this->assertEquals(2, User::count()); /***************************** Users *****************************/ /***************************** Company Users *****************************/ $this->assertEquals(2, count($this->backup_json_object->company_users)); CompanyUser::unguard(); foreach ($this->backup_json_object->company_users as $cu) { $user_id = $this->transformId('users', $cu->user_id); $cu_array = (array) $cu; unset($cu_array['user_id']); unset($cu_array['company_id']); unset($cu_array['account_id']); unset($cu_array['hashed_id']); unset($cu_array['id']); $new_cu = CompanyUser::firstOrNew( ['user_id' => $user_id, 'company_id' => $this->company->id], $cu_array, ); $new_cu->account_id = $this->account->id; $new_cu->save(['timestamps' => false]); } CompanyUser::reguard(); $this->assertEquals(2, CompanyUser::count()); /***************************** Company Users *****************************/ /***************************** Company Tokens *****************************/ $this->assertEquals(2, count($this->backup_json_object->company_tokens)); CompanyToken::unguard(); foreach ($this->backup_json_object->company_tokens as $ct) { $user_id = $this->transformId('users', $ct->user_id); $ct_array = (array) $ct; unset($ct_array['user_id']); unset($ct_array['company_id']); unset($ct_array['account_id']); unset($ct_array['hashed_id']); unset($ct_array['id']); $new_ct = CompanyToken::firstOrNew( ['user_id' => $user_id, 'company_id' => $this->company->id], $ct_array, ); $new_ct->account_id = $this->account->id; $new_ct->save(['timestamps' => false]); } CompanyToken::reguard(); $this->assertEquals(2, CompanyToken::count()); /***************************** Company Tokens *****************************/ /***************************** Payment Terms *****************************/ PaymentTerm::unguard(); $this->assertEquals(8, count($this->backup_json_object->payment_terms)); foreach ($this->backup_json_object->payment_terms as $obj) { $user_id = $this->transformId('users', $obj->user_id); $obj_array = (array) $obj; unset($obj_array['user_id']); unset($obj_array['company_id']); unset($obj_array['account_id']); unset($obj_array['hashed_id']); unset($obj_array['id']); $new_obj = PaymentTerm::firstOrNew( ['num_days' => $obj->num_days, 'company_id' => $this->company->id], $obj_array, ); $new_obj->save(['timestamps' => false]); } PaymentTerm::reguard(); $this->assertEquals(8, PaymentTerm::count()); /***************************** Payment Terms *****************************/ /***************************** Tax Rates *****************************/ TaxRate::unguard(); $this->assertEquals(2, count($this->backup_json_object->tax_rates)); foreach ($this->backup_json_object->tax_rates as $obj) { $user_id = $this->transformId('users', $obj->user_id); $obj_array = (array) $obj; unset($obj_array['user_id']); unset($obj_array['company_id']); unset($obj_array['hashed_id']); unset($obj_array['id']); unset($obj_array['tax_rate_id']); $new_obj = TaxRate::firstOrNew( ['name' => $obj->name, 'company_id' => $this->company->id, 'rate' => $obj->rate], $obj_array, ); $new_obj->save(['timestamps' => false]); } TaxRate::reguard(); $this->assertEquals(2, TaxRate::count()); /***************************** Tax Rates *****************************/ /***************************** Expense Category *****************************/ ExpenseCategory::unguard(); $this->assertEquals(2, count($this->backup_json_object->expense_categories)); foreach ($this->backup_json_object->expense_categories as $obj) { $user_id = $this->transformId('users', $obj->user_id); $obj_array = (array) $obj; unset($obj_array['user_id']); unset($obj_array['company_id']); unset($obj_array['hashed_id']); unset($obj_array['id']); $new_obj = ExpenseCategory::firstOrNew( ['name' => $obj->name, 'company_id' => $this->company->id], $obj_array, ); $new_obj->save(['timestamps' => false]); } ExpenseCategory::reguard(); $this->assertEquals(2, ExpenseCategory::count()); /***************************** Expense Category *****************************/ /***************************** Task Statuses *****************************/ TaskStatus::unguard(); $this->assertEquals(4, count($this->backup_json_object->task_statuses)); foreach ($this->backup_json_object->task_statuses as $obj) { $user_id = $this->transformId('users', $obj->user_id); $obj_array = (array) $obj; unset($obj_array['user_id']); unset($obj_array['company_id']); unset($obj_array['hashed_id']); unset($obj_array['id']); $new_obj = TaskStatus::firstOrNew( ['name' => $obj->name, 'company_id' => $this->company->id], $obj_array, ); $new_obj->save(['timestamps' => false]); } TaskStatus::reguard(); $this->assertEquals(4, TaskStatus::count()); /***************************** Task Statuses *****************************/ /***************************** Clients *****************************/ Client::unguard(); $this->assertEquals(1, count($this->backup_json_object->clients)); foreach ($this->backup_json_object->clients as $obj) { $user_id = $this->transformId('users', $obj->user_id); $assigned_user_id = $this->transformId('users', $obj->assigned_user_id); $obj_array = (array) $obj; unset($obj_array['user_id']); unset($obj_array['company_id']); unset($obj_array['account_id']); unset($obj_array['hashed_id']); unset($obj_array['id']); unset($obj_array['gateway_tokens']); unset($obj_array['contacts']); unset($obj_array['documents']); $new_obj = Client::firstOrNew( ['number' => $obj->number, 'company_id' => $this->company->id], $obj_array, ); $new_obj->save(['timestamps' => false]); $this->ids['clients']["{$obj->hashed_id}"] = $new_obj->id; } Client::reguard(); $this->assertEquals(1, Client::count()); /***************************** Clients *****************************/ /***************************** Client Contacts *****************************/ ClientContact::unguard(); $this->assertEquals(1, count($this->backup_json_object->client_contacts)); foreach ($this->backup_json_object->client_contacts as $obj) { $user_id = $this->transformId('users', $obj->user_id); $client_id = $this->transformId('clients', $obj->client_id); $obj_array = (array) $obj; unset($obj_array['user_id']); unset($obj_array['company_id']); unset($obj_array['account_id']); unset($obj_array['hashed_id']); unset($obj_array['id']); unset($obj_array['gateway_tokens']); unset($obj_array['contacts']); unset($obj_array['documents']); $obj_array['client_id'] = $client_id; $new_obj = ClientContact::firstOrNew( ['email' => $obj->email, 'company_id' => $this->company->id], $obj_array, ); $new_obj->save(['timestamps' => false]); $this->ids['client_contacts']["{$obj->hashed_id}"] = $new_obj->id; } ClientContact::reguard(); $this->assertEquals(1, ClientContact::count()); /***************************** Client Contacts *****************************/ //vendors! /* Generic */ $this->assertEquals(1, count($this->backup_json_object->vendors)); $this->genericImport( Vendor::class, ['user_id', 'assigned_user_id', 'company_id', 'id', 'hashed_id'], [['users' => 'user_id'], ['users' =>'assigned_user_id']], 'vendors', 'number' ); $this->assertEquals(1, Vendor::count()); /* Generic */ $this->assertEquals(1, count($this->backup_json_object->projects)); //$class, $unset, $transforms, $object_property, $match_key $this->genericImport( Project::class, ['user_id', 'assigned_user_id', 'company_id', 'id', 'hashed_id', 'client_id'], [['users' => 'user_id'], ['users' =>'assigned_user_id'], ['clients' => 'client_id']], 'projects', 'number' ); $this->assertEquals(1, Project::count()); //projects! //products! $this->assertEquals(1, count($this->backup_json_object->products)); $this->genericNewClassImport( Product::class, ['user_id', 'company_id', 'hashed_id', 'id'], [['users' => 'user_id'], ['users' =>'assigned_user_id'], ['vendors' => 'vendor_id'], ['projects' => 'project_id']], 'products' ); $this->assertEquals(1, Product::count()); //company gateways $this->assertEquals(1, count($this->backup_json_object->company_gateways)); $this->genericNewClassImport( CompanyGateway::class, ['user_id', 'company_id', 'hashed_id', 'id'], [['users' => 'user_id']], 'company_gateways' ); $this->assertEquals(1, CompanyGateway::count()); //company gateways //client gateway tokens $this->genericNewClassImport( ClientGatewayToken::class, ['company_id', 'id', 'hashed_id', 'client_id'], [['clients' => 'client_id']], 'client_gateway_tokens' ); //client gateway tokens //Group Settings $this->genericImport( GroupSetting::class, ['user_id', 'company_id', 'id', 'hashed_id'], [['users' => 'user_id']], 'group_settings', 'name' ); //Group Settings //Subscriptions $this->assertEquals(1, count($this->backup_json_object->subscriptions)); $this->genericImport( Subscription::class, ['user_id', 'assigned_user_id', 'company_id', 'id', 'hashed_id'], [['group_settings' => 'group_id'], ['users' => 'user_id'], ['users' => 'assigned_user_id']], 'subscriptions', 'name' ); $this->assertEquals(1, Subscription::count()); //Subscriptions // Recurring Invoices $this->assertEquals(2, count($this->backup_json_object->recurring_invoices)); $this->genericImport( RecurringInvoice::class, ['user_id', 'assigned_user_id', 'company_id', 'id', 'hashed_id', 'client_id', 'subscription_id', 'project_id', 'vendor_id', 'status'], [ ['subscriptions' => 'subscription_id'], ['users' => 'user_id'], ['users' => 'assigned_user_id'], ['clients' => 'client_id'], ['projects' => 'project_id'], ['vendors' => 'vendor_id'], ['clients' => 'client_id'], ], 'recurring_invoices', 'number' ); $this->assertEquals(2, RecurringInvoice::count()); // Recurring Invoices // Recurring Invoice Invitations $this->assertEquals(2, count($this->backup_json_object->recurring_invoice_invitations)); $this->genericImport( RecurringInvoiceInvitation::class, ['user_id', 'client_contact_id', 'company_id', 'id', 'hashed_id', 'recurring_invoice_id'], [ ['users' => 'user_id'], ['recurring_invoices' => 'recurring_invoice_id'], ['client_contacts' => 'client_contact_id'], ], 'recurring_invoice_invitations', 'key' ); $this->assertEquals(2, RecurringInvoiceInvitation::count()); // Recurring Invoice Invitations // Invoices $this->assertEquals(2, count($this->backup_json_object->invoices)); $this->genericImport( Invoice::class, ['user_id', 'client_id', 'company_id', 'id', 'hashed_id', 'recurring_id', 'status'], [ ['users' => 'user_id'], ['users' => 'assigned_user_id'], ['recurring_invoices' => 'recurring_id'], ['clients' => 'client_id'], ['subscriptions' => 'subscription_id'], ['projects' => 'project_id'], ['vendors' => 'vendor_id'], ], 'invoices', 'number' ); $this->assertEquals(2, Invoice::count()); // Invoices // Invoice Invitations $this->assertEquals(2, count($this->backup_json_object->invoice_invitations)); $this->genericImport( InvoiceInvitation::class, ['user_id', 'client_contact_id', 'company_id', 'id', 'hashed_id', 'invoice_id'], [ ['users' => 'user_id'], ['invoices' => 'invoice_id'], ['client_contacts' => 'client_contact_id'], ], 'invoice_invitations', 'key' ); $this->assertEquals(2, InvoiceInvitation::count()); // Invoice Invitations // Quotes $this->assertEquals(2, count($this->backup_json_object->quotes)); $this->genericImport( Quote::class, ['user_id', 'client_id', 'company_id', 'id', 'hashed_id', 'recurring_id', 'status'], [ ['users' => 'user_id'], ['users' => 'assigned_user_id'], ['recurring_invoices' => 'recurring_id'], ['clients' => 'client_id'], ['subscriptions' => 'subscription_id'], ['projects' => 'project_id'], ['vendors' => 'vendor_id'], ], 'quotes', 'number' ); $this->assertEquals(2, Quote::count()); // Quotes // Quotes Invitations $this->assertEquals(2, count($this->backup_json_object->quote_invitations)); $this->genericImport( QuoteInvitation::class, ['user_id', 'client_contact_id', 'company_id', 'id', 'hashed_id', 'quote_id'], [ ['users' => 'user_id'], ['quotes' => 'quote_id'], ['client_contacts' => 'client_contact_id'], ], 'quote_invitations', 'key' ); $this->assertEquals(2, QuoteInvitation::count()); // Quotes Invitations // Credits $this->assertEquals(2, count($this->backup_json_object->credits)); $this->genericImport( Credit::class, ['user_id', 'client_id', 'company_id', 'id', 'hashed_id', 'recurring_id', 'status'], [ ['users' => 'user_id'], ['users' => 'assigned_user_id'], ['recurring_invoices' => 'recurring_id'], ['clients' => 'client_id'], ['subscriptions' => 'subscription_id'], ['projects' => 'project_id'], ['vendors' => 'vendor_id'], ], 'credits', 'number' ); $this->assertEquals(2, Credit::count()); // Credits // Credits Invitations $this->assertEquals(2, count($this->backup_json_object->credit_invitations)); $this->genericImport( CreditInvitation::class, ['user_id', 'client_contact_id', 'company_id', 'id', 'hashed_id', 'credit_id'], [ ['users' => 'user_id'], ['credits' => 'credit_id'], ['client_contacts' => 'client_contact_id'], ], 'credit_invitations', 'key' ); $this->assertEquals(2, CreditInvitation::count()); // Credits Invitations // Expenses $this->assertEquals(2, count($this->backup_json_object->expenses)); $this->genericImport( Expense::class, ['assigned_user_id', 'user_id', 'client_id', 'company_id', 'id', 'hashed_id', 'project_id', 'vendor_id'], [ ['users' => 'user_id'], ['users' => 'assigned_user_id'], ['clients' => 'client_id'], ['projects' => 'project_id'], ['vendors' => 'vendor_id'], ], 'expenses', 'number' ); $this->assertEquals(2, Expense::count()); // Expenses // Tasks $this->assertEquals(3, count($this->backup_json_object->tasks)); $this->genericImport( Task::class, ['assigned_user_id', 'user_id', 'client_id', 'company_id', 'id', 'hashed_id', 'invoice_id', 'project_id'], [ ['users' => 'user_id'], ['users' => 'assigned_user_id'], ['clients' => 'client_id'], ['projects' => 'project_id'], ['invoices' => 'invoice_id'], ], 'tasks', 'number' ); $this->assertEquals(3, Task::count()); // Tasks // Payments $this->assertEquals(2, count($this->backup_json_object->payments)); $this->genericImport( Payment::class, ['assigned_user_id', 'user_id', 'client_id', 'company_id', 'id', 'hashed_id', 'client_contact_id', 'invitation_id', 'vendor_id', 'paymentables'], [ ['users' => 'user_id'], ['users' => 'assigned_user_id'], ['clients' => 'client_id'], ['client_contacts' => 'client_contact_id'], ['vendors' => 'vendor_id'], ['invoice_invitations' => 'invitation_id'], ['company_gateways' => 'company_gateway_id'], ], 'payments', 'number' ); $this->assertEquals(2, Payment::count()); // Payments // Paymentables $this->paymentablesImport(); $this->assertEquals(1, Paymentable::count()); // Paymentables // Activities $activities = []; foreach ($this->backup_json_object->activities as $activity) { $activity->account_id = $this->company->account_id; $activities[] = $activity; } $this->assertEquals(25, count($this->backup_json_object->activities)); $this->backup_json_object->activities = $activities; $this->genericNewClassImport( Activity::class, [ 'user_id', 'company_id', 'client_id', 'client_contact_id', 'project_id', 'vendor_id', 'payment_id', 'invoice_id', 'credit_id', 'invitation_id', 'task_id', 'expense_id', 'token_id', 'quote_id', 'subscription_id', 'recurring_invoice_id', 'hashed_id', 'company_id', ], [ ['users' => 'user_id'], ['clients' => 'client_id'], ['client_contacts' => 'client_contact_id'], ['projects' => 'project_id'], ['vendors' => 'vendor_id'], ['payments' => 'payment_id'], ['invoices' => 'invoice_id'], ['credits' => 'credit_id'], ['tasks' => 'task_id'], ['expenses' => 'expense_id'], ['quotes' => 'quote_id'], ['subscriptions' => 'subscription_id'], ['recurring_invoices' => 'recurring_invoice_id'], ['invitations' => 'invitation_id'], ], 'activities' ); $this->assertEquals(25, Activity::count()); // Activities // Backup $this->assertEquals(25, count($this->backup_json_object->backups)); $this->genericImportWithoutCompany( Backup::class, ['activity_id', 'hashed_id', 'html_backup'], [ ['activities' => 'activity_id'], ], 'backups', 'created_at' ); $this->assertEquals(25, Backup::count()); // Backup // Company Ledger $this->assertEquals(3, count($this->backup_json_object->company_ledger)); $this->genericImport( CompanyLedger::class, ['company_id', 'user_id', 'client_id', 'activity_id', 'id', 'account_id'], [ ['users' => 'user_id'], ['clients' => 'client_id'], ['activities' => 'activity_id'], ], 'company_ledger', 'created_at' ); $this->assertEquals(3, CompanyLedger::count()); // Company Ledger // Designs $this->genericImport( Design::class, ['company_id', 'user_id'], [ ['users' => 'user_id'], ], 'designs', 'name' ); // Designs // Documents $this->assertEquals(2, count($this->backup_json_object->documents)); $this->documentsImport(); $this->assertEquals(2, Document::count()); // Documents } private function documentsImport() { foreach ($this->backup_json_object->documents as $document) { $new_document = new Document(); $new_document->user_id = $this->transformId('users', $document->user_id); $new_document->assigned_user_id = $this->transformId('users', $document->assigned_user_id); $new_document->company_id = $this->company->id; $new_document->project_id = $this->transformId('projects', $document->project_id); $new_document->vendor_id = $this->transformId('vendors', $document->vendor_id); $new_document->url = $document->url; $new_document->preview = $document->preview; $new_document->name = $document->name; $new_document->type = $document->type; $new_document->disk = $document->disk; $new_document->hash = $document->hash; $new_document->size = $document->size; $new_document->width = $document->width; $new_document->height = $document->height; $new_document->is_default = $document->is_default; $new_document->custom_value1 = $document->custom_value1; $new_document->custom_value2 = $document->custom_value2; $new_document->custom_value3 = $document->custom_value3; $new_document->custom_value4 = $document->custom_value4; $new_document->deleted_at = $document->deleted_at; $new_document->documentable_id = $this->transformDocumentId($document->documentable_id, $document->documentable_type); $new_document->documentable_type = $document->documentable_type; $new_document->save(['timestamps' => false]); } } private function transformDocumentId($id, $type) { switch ($type) { case Company::class: return $this->company->id; break; case Client::class: return $this->transformId('clients', $id); break; case ClientContact::class: return $this->transformId('client_contacts', $id); break; case Credit::class: return $this->transformId('credits', $id); break; case Expense::class: return $this->transformId('expenses', $id); break; case 'invoices': return $this->transformId('invoices', $id); break; case Payment::class: return $this->transformId('payments', $id); break; case Product::class: return $this->transformId('products', $id); break; case Quote::class: return $this->transformId('quotes', $id); break; case RecurringInvoice::class: return $this->transformId('recurring_invoices', $id); break; case Company::class: return $this->transformId('clients', $id); break; default: // code... break; } } private function paymentablesImport() { foreach ($this->backup_json_object->payments as $payment) { foreach ($payment->paymentables as $paymentable_obj) { $paymentable = new Paymentable(); $paymentable->payment_id = $this->transformId('payments', $paymentable_obj->payment_id); $paymentable->paymentable_type = $paymentable_obj->paymentable_type; $paymentable->amount = $paymentable_obj->amount; $paymentable->refunded = $paymentable_obj->refunded; $paymentable->created_at = $paymentable_obj->created_at; $paymentable->deleted_at = $paymentable_obj->deleted_at; $paymentable->updated_at = $paymentable_obj->updated_at; $paymentable->paymentable_id = $this->convertPaymentableId($paymentable_obj->paymentable_type, $paymentable_obj->paymentable_id); $paymentable->paymentable_type = $paymentable_obj->paymentable_type; $paymentable->save(['timestamps' => false]); } } } private function convertPaymentableId($type, $id) { switch ($type) { case 'invoices': return $this->transformId('invoices', $id); break; case Credit::class: return $this->transformId('credits', $id); break; case Payment::class: return $this->transformId('payments', $id); default: // code... break; } } private function genericNewClassImport($class, $unset, $transforms, $object_property) { $class::unguard(); foreach ($this->backup_json_object->{$object_property} as $obj) { /* Remove unwanted keys*/ $obj_array = (array) $obj; foreach ($unset as $un) { unset($obj_array[$un]); } $activity_invitation_key = false; if ($class instanceof Activity) { if (isset($obj->invitation_id)) { if (isset($obj->invoice_id)) { $activity_invitation_key = 'invoice_invitations'; } elseif (isset($obj->quote_id)) { $activity_invitation_key = 'quote_invitations'; } elseif ($isset($obj->credit_id)) { $activity_invitation_key = 'credit_invitations'; } } } /* Transform old keys to new keys */ foreach ($transforms as $transform) { foreach ($transform as $key => $value) { if ($class instanceof Activity && $activity_invitation_key) { $key = $activity_invitation_key; } $obj_array["{$value}"] = $this->transformId($key, $obj->{$value}); } } if ($class instanceof CompanyGateway) { $obj_array['config'] = encrypt($obj_array['config']); } $new_obj = new $class(); $new_obj->company_id = $this->company->id; $new_obj->fill($obj_array); $new_obj->save(['timestamps' => false]); $this->ids["{$object_property}"]["{$obj->hashed_id}"] = $new_obj->id; } $class::reguard(); } private function genericImportWithoutCompany($class, $unset, $transforms, $object_property, $match_key) { $class::unguard(); foreach ($this->backup_json_object->{$object_property} as $obj) { /* Remove unwanted keys*/ $obj_array = (array) $obj; foreach ($unset as $un) { unset($obj_array[$un]); } /* Transform old keys to new keys */ foreach ($transforms as $transform) { foreach ($transform as $key => $value) { $obj_array["{$value}"] = $this->transformId($key, $obj->{$value}); } } /* New to convert product ids from old hashes to new hashes*/ if ($class instanceof Subscription) { $obj_array['product_ids'] = $this->recordProductIds($obj_array['product_ids']); $obj_array['recurring_product_ids'] = $this->recordProductIds($obj_array['recurring_product_ids']); } $new_obj = $class::firstOrNew( [$match_key => $obj->{$match_key}], $obj_array, ); $new_obj->save(['timestamps' => false]); if ($new_obj instanceof CompanyLedger) { } else { $this->ids["{$object_property}"]["{$obj->hashed_id}"] = $new_obj->id; } } $class::reguard(); } private function genericImport($class, $unset, $transforms, $object_property, $match_key) { $class::unguard(); foreach ($this->backup_json_object->{$object_property} as $obj) { /* Remove unwanted keys*/ $obj_array = (array) $obj; foreach ($unset as $un) { unset($obj_array[$un]); } /* Transform old keys to new keys */ foreach ($transforms as $transform) { foreach ($transform as $key => $value) { $obj_array["{$value}"] = $this->transformId($key, $obj->{$value}); } } /* New to convert product ids from old hashes to new hashes*/ if ($class instanceof Subscription) { $obj_array['product_ids'] = $this->recordProductIds($obj_array['product_ids']); $obj_array['recurring_product_ids'] = $this->recordProductIds($obj_array['recurring_product_ids']); } $new_obj = $class::firstOrNew( [$match_key => $obj->{$match_key}, 'company_id' => $this->company->id], $obj_array, ); $new_obj->save(['timestamps' => false]); if ($new_obj instanceof CompanyLedger) { } else { $this->ids["{$object_property}"]["{$obj->hashed_id}"] = $new_obj->id; } } $class::reguard(); } private function recordProductIds($ids) { $id_array = explode(',', $ids); $tmp_arr = []; foreach ($id_array as $id) { $tmp_arr[] = $this->encodePrimaryKey($this->transformId('products', $id)); } return implode(',', $tmp_arr); } private function transformId(string $resource, ?string $old): ?int { if (empty($old)) { return null; } if (! array_key_exists($resource, $this->ids)) { throw new \Exception("Resource {$resource} not available."); } if (! array_key_exists("{$old}", $this->ids[$resource])) { throw new \Exception("Missing {$resource} key: {$old}"); } return $this->ids[$resource]["{$old}"]; } protected function tearDown() :void { $backup_json_file = sys_get_temp_dir().'/backup/backup.json'; // unlink($backup_json_file); } }