badmanners/shimmie2
badmanners/shimmie2
Archived
1
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

[s3] allow sync'ing more posts in one go

Browse source
This commit is contained in:
Shish 2024-01-16 00:44:17 +00:00
parent 5cc1a6febe
commit 30c564d317
1 changed files with 6 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
ext/s3/main.php
View file

@ -47,7 +47,8 @@ class S3 extends Extension
$count = $database->get_one("SELECT COUNT(*) FROM s3_sync_queue"); $count = $database->get_one("SELECT COUNT(*) FROM s3_sync_queue");
$html = SHM_SIMPLE_FORM( $html = SHM_SIMPLE_FORM(
"admin/s3_process", "admin/s3_process",
SHM_SUBMIT("Sync $count posts"), INPUT(["type" => 'number', "name" => 'count', 'value' => '10']),
SHM_SUBMIT("Sync N/$count posts"),
); );
$page->add_block(new Block("Process S3 Queue", $html)); $page->add_block(new Block("Process S3 Queue", $html));
} }
@ -56,7 +57,10 @@ class S3 extends Extension
{ {
global $database; global $database;
if($event->action == "s3_process") { if($event->action == "s3_process") {
foreach($database->get_all("SELECT * FROM s3_sync_queue ORDER BY time ASC LIMIT 10") as $row) { foreach($database->get_all(
"SELECT * FROM s3_sync_queue ORDER BY time ASC LIMIT :count",
["count" => isset($_POST['count']) ? int_escape($_POST["count"]) : 10]
) as $row) {
if($row['action'] == "S") { if($row['action'] == "S") {
$image = Image::by_hash($row['hash']); $image = Image::by_hash($row['hash']);
$this->sync_post($image); $this->sync_post($image);