kopia lustrzana https://github.com/pixelfed/pixelfed
				
				
				
			Update pipeline dispatch, replace dispatchSync with dispatch
							rodzic
							
								
									1a12ba51d6
								
							
						
					
					
						commit
						ae6dd4e3a2
					
				| 
						 | 
				
			
			@ -102,7 +102,7 @@ class FixMediaDriver extends Command
 | 
			
		|||
							'image/webp'
 | 
			
		||||
						])
 | 
			
		||||
					) {
 | 
			
		||||
						ImageOptimize::dispatchSync($media);
 | 
			
		||||
						ImageOptimize::dispatch($media);
 | 
			
		||||
						sleep(3);
 | 
			
		||||
					}
 | 
			
		||||
				} else {
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -46,7 +46,7 @@ class VideoThumbnail extends Command
 | 
			
		|||
                        ->take($limit)
 | 
			
		||||
                        ->get();
 | 
			
		||||
        foreach($videos as $video) {
 | 
			
		||||
            Pipeline::dispatchSync($video);
 | 
			
		||||
            Pipeline::dispatch($video);
 | 
			
		||||
        }
 | 
			
		||||
    }
 | 
			
		||||
}
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -46,7 +46,7 @@ class ContactController extends Controller
 | 
			
		|||
		$contact->response = '';
 | 
			
		||||
		$contact->save();
 | 
			
		||||
 | 
			
		||||
		ContactPipeline::dispatchSync($contact);
 | 
			
		||||
		ContactPipeline::dispatch($contact);
 | 
			
		||||
 | 
			
		||||
		return redirect()->back()->with('status', 'Success - Your message has been sent to admins.');
 | 
			
		||||
	}
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -80,7 +80,7 @@ class DeleteAccountPipeline implements ShouldQueue
 | 
			
		|||
		$id = $user->profile_id;
 | 
			
		||||
		Status::whereProfileId($id)->chunk(50, function($statuses) {
 | 
			
		||||
            foreach($statuses as $status) {
 | 
			
		||||
                StatusDelete::dispatchSync($status);
 | 
			
		||||
                StatusDelete::dispatch($status);
 | 
			
		||||
            }
 | 
			
		||||
        });
 | 
			
		||||
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -95,7 +95,7 @@ class StatusDelete implements ShouldQueue
 | 
			
		|||
        Media::whereStatusId($status->id)
 | 
			
		||||
        ->get()
 | 
			
		||||
        ->each(function($media) {
 | 
			
		||||
            MediaDeletePipeline::dispatchSync($media);
 | 
			
		||||
            MediaDeletePipeline::dispatch($media);
 | 
			
		||||
        });
 | 
			
		||||
 | 
			
		||||
		if($status->in_reply_to_id) {
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -49,7 +49,7 @@ class AdminNewAutospam extends Mailable
 | 
			
		|||
    	$data = $this->report->toArray();
 | 
			
		||||
    	$reported_status = null;
 | 
			
		||||
    	$reported_account = null;
 | 
			
		||||
    	$url = url('/i/admin/reports/autospam/' . $this->report->id);
 | 
			
		||||
    	$url = url('/i/admin/reports/autospam/' . $this->report->id . '?ref=email');
 | 
			
		||||
 | 
			
		||||
    	if($data['item_type'] === 'App\Status') {
 | 
			
		||||
    		$reported_status = StatusService::get($this->report->item_id, false);
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -178,7 +178,7 @@ class Inbox
 | 
			
		|||
 | 
			
		||||
		switch($obj['type']) {
 | 
			
		||||
			case 'Story':
 | 
			
		||||
				StoryFetch::dispatchSync($this->payload);
 | 
			
		||||
				StoryFetch::dispatch($this->payload);
 | 
			
		||||
			break;
 | 
			
		||||
		}
 | 
			
		||||
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
		Ładowanie…
	
		Reference in New Issue