mirror of https://github.com/pixelfed/pixelfed
Add Profile Migrations
Daniel Supernault
1 year ago
parent
d5a6d9cc8d
commit
f8145a78cf
@ -0,0 +1,62 @@
|
||||
<?php
|
||||
|
||||
namespace App\Http\Controllers;
|
||||
|
||||
use App\Http\Requests\ProfileMigrationStoreRequest;
|
||||
use App\Jobs\ProfilePipeline\ProfileMigrationMoveFollowersPipeline;
|
||||
use App\Models\ProfileAlias;
|
||||
use App\Models\ProfileMigration;
|
||||
use App\Services\AccountService;
|
||||
use App\Services\WebfingerService;
|
||||
use App\Util\ActivityPub\Helpers;
|
||||
use Illuminate\Http\Request;
|
||||
|
||||
class ProfileMigrationController extends Controller
|
||||
{
|
||||
public function __construct()
|
||||
{
|
||||
$this->middleware('auth');
|
||||
}
|
||||
|
||||
public function index(Request $request)
|
||||
{
|
||||
$hasExistingMigration = ProfileMigration::whereProfileId($request->user()->profile_id)
|
||||
->where('created_at', '>', now()->subDays(30))
|
||||
->exists();
|
||||
|
||||
return view('settings.migration.index', compact('hasExistingMigration'));
|
||||
}
|
||||
|
||||
public function store(ProfileMigrationStoreRequest $request)
|
||||
{
|
||||
$acct = WebfingerService::rawGet($request->safe()->acct);
|
||||
if (! $acct) {
|
||||
return redirect()->back()->withErrors(['acct' => 'The new account you provided is not responding to our requests.']);
|
||||
}
|
||||
$newAccount = Helpers::profileFetch($acct);
|
||||
if (! $newAccount) {
|
||||
return redirect()->back()->withErrors(['acct' => 'An error occured, please try again later. Code: res-failed-account-fetch']);
|
||||
}
|
||||
$user = $request->user();
|
||||
ProfileAlias::updateOrCreate([
|
||||
'profile_id' => $user->profile_id,
|
||||
'acct' => $request->safe()->acct,
|
||||
'uri' => $acct,
|
||||
]);
|
||||
ProfileMigration::create([
|
||||
'profile_id' => $request->user()->profile_id,
|
||||
'acct' => $request->safe()->acct,
|
||||
'followers_count' => $request->user()->profile->followers_count,
|
||||
'target_profile_id' => $newAccount['id'],
|
||||
]);
|
||||
$user->profile->update([
|
||||
'moved_to_profile_id' => $newAccount->id,
|
||||
'indexable' => false,
|
||||
]);
|
||||
AccountService::del($user->profile_id);
|
||||
|
||||
ProfileMigrationMoveFollowersPipeline::dispatch($user->profile_id, $newAccount->id);
|
||||
|
||||
return redirect()->back()->with(['status' => 'Succesfully migrated account!']);
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,76 @@
|
||||
<?php
|
||||
|
||||
namespace App\Http\Requests;
|
||||
|
||||
use App\Models\ProfileMigration;
|
||||
use App\Services\FetchCacheService;
|
||||
use App\Services\WebfingerService;
|
||||
use Illuminate\Foundation\Http\FormRequest;
|
||||
use Illuminate\Validation\Validator;
|
||||
|
||||
class ProfileMigrationStoreRequest extends FormRequest
|
||||
{
|
||||
/**
|
||||
* Determine if the user is authorized to make this request.
|
||||
*/
|
||||
public function authorize(): bool
|
||||
{
|
||||
if (! $this->user() || $this->user()->status) {
|
||||
return false;
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
/**
|
||||
* Get the validation rules that apply to the request.
|
||||
*
|
||||
* @return array<string, \Illuminate\Contracts\Validation\ValidationRule|array<mixed>|string>
|
||||
*/
|
||||
public function rules(): array
|
||||
{
|
||||
return [
|
||||
'acct' => 'required|email',
|
||||
'password' => 'required|current_password',
|
||||
];
|
||||
}
|
||||
|
||||
public function after(): array
|
||||
{
|
||||
return [
|
||||
function (Validator $validator) {
|
||||
$err = $this->validateNewAccount();
|
||||
if ($err !== 'noerr') {
|
||||
$validator->errors()->add(
|
||||
'acct',
|
||||
$err
|
||||
);
|
||||
}
|
||||
},
|
||||
];
|
||||
}
|
||||
|
||||
protected function validateNewAccount()
|
||||
{
|
||||
if (ProfileMigration::whereProfileId($this->user()->profile_id)->where('created_at', '>', now()->subDays(30))->exists()) {
|
||||
return 'Error - You have migrated your account in the past 30 days, you can only perform a migration once per 30 days.';
|
||||
}
|
||||
$acct = WebfingerService::rawGet($this->acct);
|
||||
if (! $acct) {
|
||||
return 'The new account you provided is not responding to our requests.';
|
||||
}
|
||||
$pr = FetchCacheService::getJson($acct);
|
||||
if (! $pr || ! isset($pr['alsoKnownAs'])) {
|
||||
return 'Invalid account lookup response.';
|
||||
}
|
||||
if (! count($pr['alsoKnownAs']) || ! is_array($pr['alsoKnownAs'])) {
|
||||
return 'The new account does not contain an alias to your current account.';
|
||||
}
|
||||
$curAcctUrl = $this->user()->profile->permalink();
|
||||
if (! in_array($curAcctUrl, $pr['alsoKnownAs'])) {
|
||||
return 'The new account does not contain an alias to your current account.';
|
||||
}
|
||||
|
||||
return 'noerr';
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,55 @@
|
||||
<?php
|
||||
|
||||
namespace App\Jobs\ProfilePipeline;
|
||||
|
||||
use Illuminate\Bus\Queueable;
|
||||
use Illuminate\Contracts\Queue\ShouldQueue;
|
||||
use Illuminate\Foundation\Bus\Dispatchable;
|
||||
use Illuminate\Queue\InteractsWithQueue;
|
||||
use Illuminate\Queue\SerializesModels;
|
||||
use App\Follower;
|
||||
use App\Profile;
|
||||
use App\Services\AccountService;
|
||||
|
||||
class ProfileMigrationMoveFollowersPipeline implements ShouldQueue
|
||||
{
|
||||
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
|
||||
|
||||
public $oldPid;
|
||||
public $newPid;
|
||||
|
||||
/**
|
||||
* Create a new job instance.
|
||||
*/
|
||||
public function __construct($oldPid, $newPid)
|
||||
{
|
||||
$this->oldPid = $oldPid;
|
||||
$this->newPid = $newPid;
|
||||
}
|
||||
|
||||
/**
|
||||
* Execute the job.
|
||||
*/
|
||||
public function handle(): void
|
||||
{
|
||||
$og = Profile::find($this->oldPid);
|
||||
$ne = Profile::find($this->newPid);
|
||||
if(!$og || !$ne || $og == $ne) {
|
||||
return;
|
||||
}
|
||||
$ne->followers_count = $og->followers_count;
|
||||
$ne->save();
|
||||
$og->followers_count = 0;
|
||||
$og->save();
|
||||
foreach (Follower::whereFollowingId($this->oldPid)->lazyById(200, 'id') as $follower) {
|
||||
try {
|
||||
$follower->following_id = $this->newPid;
|
||||
$follower->save();
|
||||
} catch (Exception $e) {
|
||||
$follower->delete();
|
||||
}
|
||||
}
|
||||
AccountService::del($this->oldPid);
|
||||
AccountService::del($this->newPid);
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,19 @@
|
||||
<?php
|
||||
|
||||
namespace App\Models;
|
||||
|
||||
use Illuminate\Database\Eloquent\Factories\HasFactory;
|
||||
use Illuminate\Database\Eloquent\Model;
|
||||
use App\Profile;
|
||||
|
||||
class ProfileMigration extends Model
|
||||
{
|
||||
use HasFactory;
|
||||
|
||||
protected $guarded = [];
|
||||
|
||||
public function profile()
|
||||
{
|
||||
return $this->belongsTo(Profile::class, 'profile_id');
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,79 @@
|
||||
<?php
|
||||
|
||||
namespace App\Services;
|
||||
|
||||
use App\Util\ActivityPub\Helpers;
|
||||
use Illuminate\Http\Client\ConnectionException;
|
||||
use Illuminate\Http\Client\RequestException;
|
||||
use Illuminate\Support\Facades\Cache;
|
||||
use Illuminate\Support\Facades\Http;
|
||||
|
||||
class FetchCacheService
|
||||
{
|
||||
const CACHE_KEY = 'pf:fetch_cache_service:getjson:';
|
||||
|
||||
public static function getJson($url, $verifyCheck = true, $ttl = 3600, $allowRedirects = true)
|
||||
{
|
||||
$vc = $verifyCheck ? 'vc1:' : 'vc0:';
|
||||
$ar = $allowRedirects ? 'ar1:' : 'ar0';
|
||||
$key = self::CACHE_KEY.sha1($url).':'.$vc.$ar.$ttl;
|
||||
if (Cache::has($key)) {
|
||||
return false;
|
||||
}
|
||||
|
||||
if ($verifyCheck) {
|
||||
if (! Helpers::validateUrl($url)) {
|
||||
Cache::put($key, 1, $ttl);
|
||||
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
$headers = [
|
||||
'User-Agent' => '(Pixelfed/'.config('pixelfed.version').'; +'.config('app.url').')',
|
||||
];
|
||||
|
||||
if ($allowRedirects) {
|
||||
$options = [
|
||||
'allow_redirects' => [
|
||||
'max' => 2,
|
||||
'strict' => true,
|
||||
],
|
||||
];
|
||||
} else {
|
||||
$options = [
|
||||
'allow_redirects' => false,
|
||||
];
|
||||
}
|
||||
try {
|
||||
$res = Http::withOptions($options)
|
||||
->retry(3, function (int $attempt, $exception) {
|
||||
return $attempt * 500;
|
||||
})
|
||||
->acceptJson()
|
||||
->withHeaders($headers)
|
||||
->timeout(40)
|
||||
->get($url);
|
||||
} catch (RequestException $e) {
|
||||
Cache::put($key, 1, $ttl);
|
||||
|
||||
return false;
|
||||
} catch (ConnectionException $e) {
|
||||
Cache::put($key, 1, $ttl);
|
||||
|
||||
return false;
|
||||
} catch (Exception $e) {
|
||||
Cache::put($key, 1, $ttl);
|
||||
|
||||
return false;
|
||||
}
|
||||
|
||||
if (! $res->ok()) {
|
||||
Cache::put($key, 1, $ttl);
|
||||
|
||||
return false;
|
||||
}
|
||||
|
||||
return $res->json();
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,31 @@
|
||||
<?php
|
||||
|
||||
use Illuminate\Database\Migrations\Migration;
|
||||
use Illuminate\Database\Schema\Blueprint;
|
||||
use Illuminate\Support\Facades\Schema;
|
||||
|
||||
return new class extends Migration
|
||||
{
|
||||
/**
|
||||
* Run the migrations.
|
||||
*/
|
||||
public function up(): void
|
||||
{
|
||||
Schema::create('profile_migrations', function (Blueprint $table) {
|
||||
$table->id();
|
||||
$table->unsignedBigInteger('profile_id');
|
||||
$table->string('acct')->nullable();
|
||||
$table->unsignedBigInteger('followers_count')->default(0);
|
||||
$table->unsignedBigInteger('target_profile_id')->nullable();
|
||||
$table->timestamps();
|
||||
});
|
||||
}
|
||||
|
||||
/**
|
||||
* Reverse the migrations.
|
||||
*/
|
||||
public function down(): void
|
||||
{
|
||||
Schema::dropIfExists('profile_migrations');
|
||||
}
|
||||
};
|
||||
@ -0,0 +1,99 @@
|
||||
@extends('layouts.app')
|
||||
|
||||
@section('content')
|
||||
@if (session('status'))
|
||||
<div class="alert alert-primary px-3 h6 font-weight-bold text-center">
|
||||
{{ session('status') }}
|
||||
</div>
|
||||
@endif
|
||||
@if ($errors->any())
|
||||
<div class="alert alert-danger px-3 h6 text-center">
|
||||
@foreach($errors->all() as $error)
|
||||
<p class="font-weight-bold mb-1">{{ $error }}</p>
|
||||
@endforeach
|
||||
</div>
|
||||
@endif
|
||||
@if (session('error'))
|
||||
<div class="alert alert-danger px-3 h6 text-center">
|
||||
{{ session('error') }}
|
||||
</div>
|
||||
@endif
|
||||
|
||||
<div class="container">
|
||||
<div class="col-12">
|
||||
<div class="card shadow-none border mt-5">
|
||||
<div class="card-body">
|
||||
<div class="row">
|
||||
<div class="col-12 p-3 p-md-5">
|
||||
<div class="title">
|
||||
<div class="d-flex justify-content-between align-items-center">
|
||||
<h3 class="font-weight-bold">Account Migration</h3>
|
||||
|
||||
<a class="font-weight-bold" href="/settings/home">
|
||||
<i class="far fa-long-arrow-left"></i>
|
||||
Back to Settings
|
||||
</a>
|
||||
</div>
|
||||
|
||||
<hr />
|
||||
|
||||
<div class="row">
|
||||
<div class="col-12">
|
||||
<p class="lead">If you want to move this account to another account, please read the following carefully.</p>
|
||||
<ul class="text-danger lead">
|
||||
<li class="font-weight-bold">Only followers will be transferred; no other information will be moved automatically.</li>
|
||||
<li>This process will transfer all followers from your existing account to your new account.</li>
|
||||
<li>A redirect notice will be added to your current account's profile, and it will be removed from search results.</li>
|
||||
<li>You must set up the new account to link back to your current account before proceeding.</li>
|
||||
<li>Once the transfer is initiated, there will be a waiting period during which you cannot initiate another transfer.</li>
|
||||
<li>After the transfer, your current account will be limited in functionality, but you will retain the ability to export data and possibly reactivate the account.</li>
|
||||
</ul>
|
||||
<p class="mb-0">For more information on Aliases and Account Migration, visit the <a href="/site/kb/your-profile">Help Center</a>.</p>
|
||||
<hr>
|
||||
|
||||
<form method="post" autocomplete="off">
|
||||
@csrf
|
||||
<div class="row">
|
||||
<div class="col-12 col-md-6">
|
||||
<div class="form-group">
|
||||
<label class="font-weight-bold mb-0">New Account Handle</label>
|
||||
<p class="small text-muted">Enter the username@domain of the account you want to move to</p>
|
||||
<input
|
||||
type="email"
|
||||
class="form-control"
|
||||
name="acct"
|
||||
placeholder="username@domain.tld"
|
||||
role="presentation"
|
||||
autocomplete="new-user-email"
|
||||
/>
|
||||
</div>
|
||||
</div>
|
||||
<div class="col-12 col-md-6">
|
||||
<div class="form-group">
|
||||
<label class="font-weight-bold mb-0">Account Password</label>
|
||||
<p class="small text-muted">For security purposes please enter the password of the current account</p>
|
||||
<input
|
||||
type="password"
|
||||
class="form-control"
|
||||
name="password"
|
||||
role="presentation"
|
||||
placeholder="Your account password"
|
||||
autocomplete="new-password"
|
||||
/>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<button class="btn btn-primary btn-block font-weight-bold btn-lg rounded-pill">Move Followers</button>
|
||||
</form>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
@endsection
|
||||
Loading…
Reference in New Issue