From 755434600ea8f597f9366f692387397b199cee13 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Mike=20F=C3=A4hrmann?= <mike_faehrmann@web.de>
Date: Fri, 11 Jul 2025 21:01:49 +0200
Subject: [PATCH] [signals] implement stopping the current download with Ctrl+C
 (#1861)

{
    "signals-actions": {
        "SIGINT": "download:fail"
    }
}
---
 gallery_dl/downloader/http.py | 15 ++++++++++++++-
 1 file changed, 14 insertions(+), 1 deletion(-)

diff --git a/gallery_dl/downloader/http.py b/gallery_dl/downloader/http.py
index 6fcc1fa0..cc05552a 100644
--- a/gallery_dl/downloader/http.py
+++ b/gallery_dl/downloader/http.py
@@ -12,8 +12,9 @@ import time
 import mimetypes
 from requests.exceptions import RequestException, ConnectionError, Timeout
 from .common import DownloaderBase
-from .. import text, util, output
+from .. import text, util, output, exception
 from ssl import SSLError
+FLAGS = util.FLAGS
 
 
 class HttpDownloader(DownloaderBase):
@@ -336,6 +337,12 @@ class HttpDownloader(DownloaderBase):
                     msg = str(exc)
                     output.stderr_write("\n")
                     continue
+                except exception.StopExtraction:
+                    response.close()
+                    return False
+                except exception.ControlException:
+                    response.close()
+                    raise
 
                 # check file size
                 if size and fp.tell() < size:
@@ -373,6 +380,9 @@ class HttpDownloader(DownloaderBase):
         for data in content:
             write(data)
 
+            if FLAGS.DOWNLOAD is not None:
+                FLAGS.process("DOWNLOAD")
+
     def _receive_rate(self, fp, content, bytes_total, bytes_start):
         rate = self.rate() if self.rate else None
         write = fp.write
@@ -387,6 +397,9 @@ class HttpDownloader(DownloaderBase):
 
             write(data)
 
+            if FLAGS.DOWNLOAD is not None:
+                FLAGS.process("DOWNLOAD")
+
             if progress is not None:
                 if time_elapsed > progress:
                     self.out.progress(