feat(helpers): use inputstreams for videos

Author: GeopJr

src/Services/Helpers/Video.vala

@@ -0,0 +1,41 @@
+public class Tuba.Helper.Video {
+	private static Soup.Session session;
+	private static Soup.Cache cache;
+
+	public static void clear_cache () {
+		new Helper.Video ();
+		cache.clear ();
+	}
+
+	public static void flush_cache () {
+		new Helper.Video ();
+		cache.flush ();
+		cache.dump ();
+	}
+
+	static construct {
+		cache = new Soup.Cache (
+			GLib.Path.build_path (GLib.Path.DIR_SEPARATOR_S, Tuba.cache_path, "soup", "videos"),
+			Soup.CacheType.SINGLE_USER
+		);
+		cache.load ();
+		cache.set_max_size (1024 * 1024 * 100 * 2);
+
+		session = new Soup.Session.with_options ("max-conns", 64, "max-conns-per-host", 64) {
+			user_agent = @"$(Build.NAME)/$(Build.VERSION) libsoup/$(Soup.get_major_version()).$(Soup.get_minor_version()).$(Soup.get_micro_version()) ($(Soup.MAJOR_VERSION).$(Soup.MINOR_VERSION).$(Soup.MICRO_VERSION))" // vala-lint=line-length
+		};
+		session.add_feature (cache);
+	}
+
+	public static async InputStream request (string? url) throws Oopsie {
+		if (url == null || url == "") throw new Tuba.Oopsie.INTERNAL ("No url provided");
+		new Helper.Video ();
+
+		var download_msg = new Soup.Message ("GET", url);
+        try {
+			return yield session.send_async (download_msg, 0, null);
+		} catch (Error e) {
+		    throw new Tuba.Oopsie.INTERNAL (@"Failed to get video at \"$url\": $(e.message)");
+		}
+	}
+}

src/Services/Helpers/meson.build

@@ -2,4 +2,5 @@ sources += files(
     'Blurhash.vala',
     'Entity.vala',
     'Image.vala',
+    'Video.vala',
 )

src/Views/MediaViewer.vala

@@ -843,8 +843,16 @@ public class Tuba.Views.MediaViewer : Gtk.Widget, Gtk.Buildable, Adw.Swipeable {
 			item = new Item (video, final_friendly_url, final_preview, true);
 
 			if (stream) {
-				File file = File.new_for_uri (url);
-				video.set_file (file);
+				Helper.Video.request.begin (url, (obj, res) => {
+					try {
+						video.set_media_stream (Gtk.MediaFile.for_input_stream (Helper.Video.request.end (res)));
+						add_todo_item (item);
+					} catch (Oopsie e) {
+						warning (e.message);
+						var dlg = app.inform (_("Error"), e.message);
+						dlg.present (app.main_window);
+					}
+				});
 			} else if (!as_is) {
 				download_video.begin (url, (obj, res) => {
 					try {