From d443a3c2509889533ca812c163056bace396b586 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?J=C3=B6rg=20Frings-F=C3=BCrst?= <debian@jff.email>
Date: Wed, 14 Jun 2023 20:35:58 +0200
Subject: New upstream version 0.32.1

---
 src/VideoSupport.vala | 1193 -------------------------------------------------
 1 file changed, 1193 deletions(-)
 delete mode 100644 src/VideoSupport.vala

(limited to 'src/VideoSupport.vala')

diff --git a/src/VideoSupport.vala b/src/VideoSupport.vala
deleted file mode 100644
index ec827ea..0000000
--- a/src/VideoSupport.vala
+++ /dev/null
@@ -1,1193 +0,0 @@
-/* Copyright 2016 Software Freedom Conservancy Inc.
- *
- * This software is licensed under the GNU LGPL (version 2.1 or later).
- * See the COPYING file in this distribution.
- */
-
-public errordomain VideoError {
-    FILE,          // there's a problem reading the video container file (doesn't exist, no read
-                   // permission, etc.)
-
-    CONTENTS,      // we can read the container file but its contents are indecipherable (no codec,
-                   // malformed data, etc.)
-}
-
-public class VideoImportParams {
-    // IN:
-    public File file;
-    public ImportID import_id = ImportID();
-    public string? md5;
-    public time_t exposure_time_override;
-    
-    // IN/OUT:
-    public Thumbnails? thumbnails;
-    
-    // OUT:
-    public VideoRow row = new VideoRow();
-    
-    public VideoImportParams(File file, ImportID import_id, string? md5,
-        Thumbnails? thumbnails = null, time_t exposure_time_override = 0) {
-        this.file = file;
-        this.import_id = import_id;
-        this.md5 = md5;
-        this.thumbnails = thumbnails;
-        this.exposure_time_override = exposure_time_override;
-    }
-}
-
-public class VideoReader {
-    private const double UNKNOWN_CLIP_DURATION = -1.0;
-    private const uint THUMBNAILER_TIMEOUT = 10000; // In milliseconds.
-
-    // File extensions for video containers that pack only metadata as per the AVCHD spec
-    private const string[] METADATA_ONLY_FILE_EXTENSIONS = { "bdm", "bdmv", "cpi", "mpl" };
-    
-    private double clip_duration = UNKNOWN_CLIP_DURATION;
-    private Gdk.Pixbuf preview_frame = null;
-    private File file = null;
-    private GLib.Pid thumbnailer_pid = 0;
-    public DateTime? timestamp { get; private set; default = null; }
-
-    public VideoReader(File file) {
-        this.file = file;
-     }
-    
-    public static bool is_supported_video_file(File file) {
-        var mime_type = ContentType.guess(file.get_basename(), new uchar[0], null);
-        // special case: deep-check content-type of files ending with .ogg
-        if (mime_type == "audio/ogg" && file.has_uri_scheme("file")) {
-            try {
-                var info = file.query_info(FileAttribute.STANDARD_CONTENT_TYPE,
-                                           FileQueryInfoFlags.NONE);
-                var content_type = info.get_content_type();
-                if (content_type != null && content_type.has_prefix ("video/")) {
-                    return true;
-                }
-            } catch (Error error) {
-                debug("Failed to query content type: %s", error.message);
-            }
-        }
-
-        return is_supported_video_filename(file.get_basename());
-    }
-
-    public static bool is_supported_video_filename(string filename) {
-        string mime_type;
-        mime_type = ContentType.guess(filename, new uchar[0], null);
-        // Guessed mp4 from filename has application/ as prefix, so check for mp4 in the end
-        if (mime_type.has_prefix ("video/") || mime_type.has_suffix("mp4")) {
-            string? extension = null;
-            string? name = null;
-            disassemble_filename(filename, out name, out extension);
-
-            if (extension == null)
-                return true;
-
-            foreach (string s in METADATA_ONLY_FILE_EXTENSIONS) {
-                if (utf8_ci_compare(s, extension) == 0)
-                    return false;
-            }
-
-            return true;
-        } else {
-            debug("Skipping %s, unsupported mime type %s", filename, mime_type);
-            return false;
-        }
-    }
-    
-    public static ImportResult prepare_for_import(VideoImportParams params) {
-#if MEASURE_IMPORT
-        Timer total_time = new Timer();
-#endif
-        File file = params.file;
-        
-        FileInfo info = null;
-        try {
-            info = file.query_info(DirectoryMonitor.SUPPLIED_ATTRIBUTES,
-                FileQueryInfoFlags.NOFOLLOW_SYMLINKS, null);
-        } catch (Error err) {
-            return ImportResult.FILE_ERROR;
-        }
-        
-        if (info.get_file_type() != FileType.REGULAR)
-            return ImportResult.NOT_A_FILE;
-        
-        if (!is_supported_video_file(file)) {
-            message("Not importing %s: file is marked as a video file but doesn't have a" +
-                "supported extension", file.get_path());
-            
-            return ImportResult.UNSUPPORTED_FORMAT;
-        }
-        
-        TimeVal timestamp = info.get_modification_time();
-        
-        // make sure params has a valid md5
-        assert(params.md5 != null);
-
-        time_t exposure_time = params.exposure_time_override;
-        string title = "";
-        string comment = "";
-        
-        VideoReader reader = new VideoReader(file);
-        bool is_interpretable = true;
-        double clip_duration = 0.0;
-        Gdk.Pixbuf preview_frame = reader.read_preview_frame();
-        try {
-            clip_duration = reader.read_clip_duration();
-        } catch (VideoError err) {
-            if (err is VideoError.FILE) {
-                return ImportResult.FILE_ERROR;
-            } else if (err is VideoError.CONTENTS) {
-                is_interpretable = false;
-                clip_duration = 0.0;
-            } else {
-                error("can't prepare video for import: an unknown kind of video error occurred");
-            }
-        }
-        
-        try {
-            VideoMetadata metadata = reader.read_metadata();
-            MetadataDateTime? creation_date_time = metadata.get_creation_date_time();
-            
-            if (creation_date_time != null && creation_date_time.get_timestamp() != 0)
-                exposure_time = creation_date_time.get_timestamp();
-            
-            string? video_title = metadata.get_title();
-            string? video_comment = metadata.get_comment();
-            if (video_title != null)
-                title = video_title;
-            if (video_comment != null)
-                comment = video_comment;
-        } catch (Error err) {
-            warning("Unable to read video metadata: %s", err.message);
-        }
-        
-        if (exposure_time == 0) {
-            // Use time reported by Gstreamer, if available.
-            exposure_time = (time_t) (reader.timestamp != null ? 
-                reader.timestamp.to_unix() : 0);
-        }
-        
-        params.row.video_id = VideoID();
-        params.row.filepath = file.get_path();
-        params.row.filesize = info.get_size();
-        params.row.timestamp = timestamp.tv_sec;
-        params.row.width = preview_frame.width;
-        params.row.height = preview_frame.height;
-        params.row.clip_duration = clip_duration;
-        params.row.is_interpretable = is_interpretable;
-        params.row.exposure_time = exposure_time;
-        params.row.import_id = params.import_id;
-        params.row.event_id = EventID();
-        params.row.md5 = params.md5;
-        params.row.time_created = 0;
-        params.row.title = title;
-        params.row.comment = comment;
-        params.row.backlinks = "";
-        params.row.time_reimported = 0;
-        params.row.flags = 0;
-
-        if (params.thumbnails != null) {
-            params.thumbnails = new Thumbnails();
-            ThumbnailCache.generate_for_video_frame(params.thumbnails, preview_frame);
-        }
-        
-#if MEASURE_IMPORT
-        debug("IMPORT: total time to import video = %lf", total_time.elapsed());
-#endif
-        return ImportResult.SUCCESS;
-    }
-    
-    private void read_internal() throws VideoError {
-        if (!does_file_exist())
-            throw new VideoError.FILE("video file '%s' does not exist or is inaccessible".printf(
-                file.get_path()));
-        
-        try {
-            Gst.PbUtils.Discoverer d = new Gst.PbUtils.Discoverer((Gst.ClockTime) (Gst.SECOND * 5));
-            Gst.PbUtils.DiscovererInfo info = d.discover_uri(file.get_uri());
-            
-            clip_duration = ((double) info.get_duration()) / 1000000000.0;
-            
-            // Get creation time.
-            // TODO: Note that TAG_DATE can be changed to TAG_DATE_TIME in the future
-            // (and the corresponding output struct) in order to implement #2836.
-            Date? video_date = null;
-            if (info.get_tags() != null && info.get_tags().get_date(Gst.Tags.DATE, out video_date)) {
-                // possible for get_date() to return true and a null Date
-                if (video_date != null) {
-                    timestamp = new DateTime.local(video_date.get_year(), video_date.get_month(),
-                        video_date.get_day(), 0, 0, 0);
-                }
-            }
-        } catch (Error e) {
-            debug("Video read error: %s", e.message);
-            throw new VideoError.CONTENTS("GStreamer couldn't extract clip information: %s"
-                .printf(e.message));
-        }
-    }
-    
-    // Used by thumbnailer() to kill the external process if need be.
-    private bool on_thumbnailer_timer() {
-        debug("Thumbnailer timer called");
-        if (thumbnailer_pid != 0) {
-            debug("Killing thumbnailer process: %d", thumbnailer_pid);
-#if VALA_0_40
-            Posix.kill(thumbnailer_pid, Posix.Signal.KILL);
-#else
-            Posix.kill(thumbnailer_pid, Posix.SIGKILL);
-#endif
-        }
-        return false; // Don't call again.
-    }
-    
-    // Performs video thumbnailing.
-    // Note: not thread-safe if called from the same instance of the class.
-    private Gdk.Pixbuf? thumbnailer(string video_file) {
-        // Use Shotwell's thumbnailer, redirect output to stdout.
-        debug("Launching thumbnailer process: %s", AppDirs.get_thumbnailer_bin().get_path());
-        string[] argv = {AppDirs.get_thumbnailer_bin().get_path(), video_file};
-        int child_stdout;
-        try {
-            GLib.Process.spawn_async_with_pipes(null, argv, null, GLib.SpawnFlags.SEARCH_PATH | 
-                GLib.SpawnFlags.DO_NOT_REAP_CHILD, null, out thumbnailer_pid, null, out child_stdout,
-                null);
-            debug("Spawned thumbnailer, child pid: %d", (int) thumbnailer_pid);
-        } catch (Error e) {
-            debug("Error spawning process: %s", e.message);
-            if (thumbnailer_pid != 0)
-                GLib.Process.close_pid(thumbnailer_pid);
-            return null;
-        }
-        
-        // Start timer.
-        Timeout.add(THUMBNAILER_TIMEOUT, on_thumbnailer_timer);
-        
-        // Read pixbuf from stream.
-        Gdk.Pixbuf? buf = null;
-        try {
-            GLib.UnixInputStream unix_input = new GLib.UnixInputStream(child_stdout, true);
-            buf = new Gdk.Pixbuf.from_stream(unix_input, null);
-        } catch (Error e) {
-            debug("Error creating pixbuf: %s", e.message);
-            buf = null;
-        }
-        
-        // Make sure process exited properly.
-        int child_status = 0;
-        int ret_waitpid = Posix.waitpid(thumbnailer_pid, out child_status, 0);
-        if (ret_waitpid < 0) {
-            debug("waitpid returned error code: %d", ret_waitpid);
-            buf = null;
-        } else if (0 != Process.exit_status(child_status)) {
-            debug("Thumbnailer exited with error code: %d",
-                    Process.exit_status(child_status));
-            buf = null;
-        }
-        
-        GLib.Process.close_pid(thumbnailer_pid);
-        thumbnailer_pid = 0;
-        return buf;
-    }
-    
-    private bool does_file_exist() {
-        return FileUtils.test(file.get_path(), FileTest.EXISTS | FileTest.IS_REGULAR);
-    }
-    
-    public Gdk.Pixbuf? read_preview_frame() {
-        if (preview_frame != null)
-            return preview_frame;
-        
-        if (!does_file_exist())
-            return null;
-        
-        // Get preview frame from thumbnailer.
-        preview_frame = thumbnailer(file.get_path());
-        if (null == preview_frame)
-            preview_frame = Resources.get_noninterpretable_badge_pixbuf();
-        
-        return preview_frame;
-    }
-    
-    public double read_clip_duration() throws VideoError {
-        if (clip_duration == UNKNOWN_CLIP_DURATION)
-            read_internal();
-
-        return clip_duration;
-    }
-    
-    public VideoMetadata read_metadata() throws Error {
-        VideoMetadata metadata = new VideoMetadata();
-        metadata.read_from_file(File.new_for_path(file.get_path()));
-        
-        return metadata;
-    }
-}
-
-public class Video : VideoSource, Flaggable, Monitorable, Dateable {
-    public const string TYPENAME = "video";
-    
-    public const uint64 FLAG_TRASH =    0x0000000000000001;
-    public const uint64 FLAG_OFFLINE =  0x0000000000000002;
-    public const uint64 FLAG_FLAGGED =  0x0000000000000004;
-    
-    public class InterpretableResults {
-        internal Video video;
-        internal bool update_interpretable = false;
-        internal bool is_interpretable = false;
-        internal Gdk.Pixbuf? new_thumbnail = null;
-        
-        public InterpretableResults(Video video) {
-            this.video = video;
-        }
-        
-        public void foreground_finish() {
-            if (update_interpretable)
-                video.set_is_interpretable(is_interpretable);
-            
-            if (new_thumbnail != null) {
-                try {
-                    ThumbnailCache.replace(video, ThumbnailCache.Size.BIG, new_thumbnail);
-                    ThumbnailCache.replace(video, ThumbnailCache.Size.MEDIUM, new_thumbnail);
-                    
-                    video.notify_thumbnail_altered();
-                } catch (Error err) {
-                    message("Unable to update video thumbnails for %s: %s", video.to_string(),
-                        err.message);
-                }
-            }
-        }
-    }
-    
-    private static bool normal_regen_complete;
-    private static bool offline_regen_complete;
-    public static VideoSourceCollection global;
-
-    private VideoRow backing_row;
-    
-    public Video(VideoRow row) {
-        this.backing_row = row;
-        
-        // normalize user text
-        this.backing_row.title = prep_title(this.backing_row.title);
-        
-        if (((row.flags & FLAG_TRASH) != 0) || ((row.flags & FLAG_OFFLINE) != 0))
-            rehydrate_backlinks(global, row.backlinks);
-    }
-
-    public static void init(ProgressMonitor? monitor = null) {
-        // Must initialize static variables here.
-        // TODO: set values at declaration time once the following Vala bug is fixed:
-        //       https://bugzilla.gnome.org/show_bug.cgi?id=655594
-        normal_regen_complete = false;
-        offline_regen_complete = false;
-    
-        // initialize GStreamer, but don't pass it our actual command line arguments -- we don't
-        // want our end users to be able to parameterize the GStreamer configuration
-        unowned string[] args = null;
-        Gst.init(ref args);
-
-        var registry = Gst.Registry.@get ();
-
-        /* Update our local registr to not include vaapi stuff. This is basically to
-        * work-around concurrent access to VAAPI/X11 which it doesn't like, cf
-         * https://bugzilla.gnome.org/show_bug.cgi?id=762416
-         */
-
-        var features = registry.feature_filter ((f) => {
-            return f.get_name ().has_prefix ("vaapi");
-        }, false);
-
-        foreach (var feature in features) {
-            debug ("Removing registry feature %s", feature.get_name ());
-            registry.remove_feature (feature);
-        }
-
-        global = new VideoSourceCollection();
-        
-        Gee.ArrayList<VideoRow?> all = VideoTable.get_instance().get_all();
-        Gee.ArrayList<Video> all_videos = new Gee.ArrayList<Video>();
-        Gee.ArrayList<Video> trashed_videos = new Gee.ArrayList<Video>();
-        Gee.ArrayList<Video> offline_videos = new Gee.ArrayList<Video>();
-        int count = all.size;
-        for (int ctr = 0; ctr < count; ctr++) {
-            Video video = new Video(all.get(ctr));
-            
-            if (video.is_trashed())
-                trashed_videos.add(video);
-            else if (video.is_offline())
-                offline_videos.add(video);
-            else
-                all_videos.add(video);
-            
-            if (monitor != null)
-                monitor(ctr, count);
-        }
-
-        global.add_many_to_trash(trashed_videos);
-        global.add_many_to_offline(offline_videos);
-        global.add_many(all_videos);
-    }
-    
-    public static void notify_normal_thumbs_regenerated() {
-        if (normal_regen_complete)
-            return;
-
-        message("normal video thumbnail regeneration completed");
-
-        normal_regen_complete = true;
-    }
-
-    public static void notify_offline_thumbs_regenerated() {
-        if (offline_regen_complete)
-            return;
-
-        message("offline video thumbnail regeneration completed");
-
-        offline_regen_complete = true;
-    }
-
-    public static void terminate() {
-    }
-    
-    public static ExporterUI? export_many(Gee.Collection<Video> videos, Exporter.CompletionCallback done,
-        bool export_in_place = false) {       
-        if (videos.size == 0)
-            return null;
-        
-        // in place export is relatively easy -- provide a fast, separate code path for it
-        if (export_in_place) {
-             ExporterUI temp_exporter = new ExporterUI(new Exporter.for_temp_file(videos,
-                Scaling.for_original(), ExportFormatParameters.unmodified()));
-             temp_exporter.export(done);
-             return temp_exporter;
-        }
-
-        // one video
-        if (videos.size == 1) {
-            Video video = null;
-            foreach (Video v in videos) {
-                video = v;
-                break;
-            }
-            
-            File save_as = ExportUI.choose_file(video.get_basename());
-            if (save_as == null)
-                return null;
-            
-            try {
-                AppWindow.get_instance().set_busy_cursor();
-                video.export(save_as);
-                AppWindow.get_instance().set_normal_cursor();
-            } catch (Error err) {
-                AppWindow.get_instance().set_normal_cursor();
-                export_error_dialog(save_as, false);
-            }
-            
-            return null;
-        }
-
-        // multiple videos
-        File export_dir = ExportUI.choose_dir(_("Export Videos"));
-        if (export_dir == null)
-            return null;
-        
-        ExporterUI exporter = new ExporterUI(new Exporter(videos, export_dir,
-            Scaling.for_original(), ExportFormatParameters.unmodified()));
-        exporter.export(done);
-
-        return exporter;
-    }
-
-    protected override void commit_backlinks(SourceCollection? sources, string? backlinks) {        
-        try {
-            VideoTable.get_instance().update_backlinks(get_video_id(), backlinks);
-            lock (backing_row) {
-                backing_row.backlinks = backlinks;
-            }
-        } catch (DatabaseError err) {
-            warning("Unable to update link state for %s: %s", to_string(), err.message);
-        }
-    }
-
-    protected override bool set_event_id(EventID event_id) {
-        lock (backing_row) {
-            bool committed = VideoTable.get_instance().set_event(backing_row.video_id, event_id);
-
-            if (committed)
-                backing_row.event_id = event_id;
-
-            return committed;
-        }
-    }
-
-    public static bool is_duplicate(File? file, string? full_md5) {
-        assert(file != null || full_md5 != null);
-#if !NO_DUPE_DETECTION
-        return VideoTable.get_instance().has_duplicate(file, full_md5);
-#else
-        return false;
-#endif
-    }
-    
-    public static ImportResult import_create(VideoImportParams params, out Video video) {
-        video = null;
-        
-        // add to the database
-        try {
-            if (VideoTable.get_instance().add(params.row).is_invalid())
-                return ImportResult.DATABASE_ERROR;
-        } catch (DatabaseError err) {
-            return ImportResult.DATABASE_ERROR;
-        }
-        
-        // create local object but don't add to global until thumbnails generated
-        video = new Video(params.row);
-
-        return ImportResult.SUCCESS;
-    }
-    
-    public static void import_failed(Video video) {
-        try {
-            VideoTable.get_instance().remove(video.get_video_id());
-        } catch (DatabaseError err) {
-            AppWindow.database_error(err);
-        }
-    }
-    
-    public override BackingFileState[] get_backing_files_state() {
-        BackingFileState[] backing = new BackingFileState[1];
-        lock (backing_row) {
-            backing[0] = new BackingFileState(backing_row.filepath, backing_row.filesize, 
-                backing_row.timestamp, backing_row.md5);
-        }
-        
-        return backing;
-    }
-    
-    public override Gdk.Pixbuf? get_thumbnail(int scale) throws Error {
-        return ThumbnailCache.fetch(this, scale);
-    }
-
-    public override string get_master_md5() {
-        lock (backing_row) {
-            return backing_row.md5;
-        }
-    }
-
-    public override Gdk.Pixbuf get_preview_pixbuf(Scaling scaling) throws Error {
-        Gdk.Pixbuf pixbuf = get_thumbnail(ThumbnailCache.Size.BIG);
-        
-        return scaling.perform_on_pixbuf(pixbuf, Gdk.InterpType.NEAREST, true);
-    }
-
-    public override Gdk.Pixbuf? create_thumbnail(int scale) throws Error {
-        VideoReader reader = new VideoReader(get_file());
-        Gdk.Pixbuf? frame = reader.read_preview_frame();
-        
-        return (frame != null) ? frame : Resources.get_noninterpretable_badge_pixbuf().copy();
-    }
-    
-    public override string get_typename() {
-        return TYPENAME;
-    }
-    
-    public override int64 get_instance_id() {
-        return get_video_id().id;
-    }
-
-    public override ImportID get_import_id() {
-        lock (backing_row) {
-            return backing_row.import_id;
-        }
-    }
-
-    public override PhotoFileFormat get_preferred_thumbnail_format() {
-        return PhotoFileFormat.get_system_default_format();
-    }
-    
-    public override string? get_title() {
-        lock (backing_row) {
-            return backing_row.title;
-        }
-    }
-
-    public override void set_title(string? title) {
-        string? new_title = prep_title(title);
-        
-        lock (backing_row) {
-            if (backing_row.title == new_title)
-                return;
-
-            try {
-                VideoTable.get_instance().set_title(backing_row.video_id, new_title);
-            } catch (DatabaseError e) {
-                AppWindow.database_error(e);
-                return;
-            }
-            // if we didn't short-circuit return in the catch clause above, then the change was
-            // successfully committed to the database, so update it in the in-memory row cache
-            backing_row.title = new_title;
-        }
-
-        notify_altered(new Alteration("metadata", "name"));
-    }
-
-    public override string? get_comment() {
-        lock (backing_row) {
-            return backing_row.comment;
-        }
-    }
-
-    public override bool set_comment(string? comment) {
-        string? new_comment = prep_title(comment);
-        
-        lock (backing_row) {
-            if (backing_row.comment == new_comment)
-                return true;
-
-            try {
-                VideoTable.get_instance().set_comment(backing_row.video_id, new_comment);
-            } catch (DatabaseError e) {
-                AppWindow.database_error(e);
-                return false;
-            }
-            // if we didn't short-circuit return in the catch clause above, then the change was
-            // successfully committed to the database, so update it in the in-memory row cache
-            backing_row.comment = new_comment;
-        }
-        
-        notify_altered(new Alteration("metadata", "comment"));
-
-        return true;
-    }
-
-
-    public override Rating get_rating() {
-        lock (backing_row) {
-            return backing_row.rating;
-        }
-    }
-
-    public override void set_rating(Rating rating) {
-        lock (backing_row) {
-            if ((!rating.is_valid()) || (rating == backing_row.rating))
-                return;
-
-            try {
-                VideoTable.get_instance().set_rating(get_video_id(), rating);
-            } catch (DatabaseError e) {
-                AppWindow.database_error(e);
-                return;
-            }
-            // if we didn't short-circuit return in the catch clause above, then the change was
-            // successfully committed to the database, so update it in the in-memory row cache
-            backing_row.rating = rating;
-        }
-
-        notify_altered(new Alteration("metadata", "rating"));
-    }
-
-    public override void increase_rating() {
-        lock (backing_row) {
-            set_rating(backing_row.rating.increase());
-        }
-    }
-
-    public override void decrease_rating() {
-        lock (backing_row) {
-            set_rating(backing_row.rating.decrease());
-        }
-    }
-
-    public override bool is_trashed() {
-        return is_flag_set(FLAG_TRASH);
-    }
-
-    public override bool is_offline() {
-        return is_flag_set(FLAG_OFFLINE);
-    }
-
-    public override void mark_offline() {
-        add_flags(FLAG_OFFLINE);
-    }
-    
-    public override void mark_online() {
-        remove_flags(FLAG_OFFLINE);
-        
-        if ((!get_is_interpretable()))
-            check_is_interpretable().foreground_finish();
-    }
-
-    public override void trash() {
-        add_flags(FLAG_TRASH);
-    }
-    
-    public override void untrash() {
-        remove_flags(FLAG_TRASH);
-    }
-    
-    public bool is_flagged() {
-        return is_flag_set(FLAG_FLAGGED);
-    }
-    
-    public void mark_flagged() {
-        add_flags(FLAG_FLAGGED, new Alteration("metadata", "flagged"));
-    }
-    
-    public void mark_unflagged() {
-        remove_flags(FLAG_FLAGGED, new Alteration("metadata", "flagged"));
-    }
-    
-    public override EventID get_event_id() {
-        lock (backing_row) {
-            return backing_row.event_id;
-        }
-    }
-    
-    public override string to_string() {
-        lock (backing_row) {
-            return "[%s] %s".printf(backing_row.video_id.id.to_string(), backing_row.filepath);
-        }
-    }
-    
-    public VideoID get_video_id() {
-        lock (backing_row) {
-            return backing_row.video_id;
-        }
-    }
-    
-    public override time_t get_exposure_time() {
-        lock (backing_row) {
-            return backing_row.exposure_time;
-        }
-    }
-    
-    public void set_exposure_time(time_t time) {
-        lock (backing_row) {
-            try {
-                VideoTable.get_instance().set_exposure_time(backing_row.video_id, time);
-            } catch (Error e) {
-                debug("Warning - %s", e.message);
-            }
-            backing_row.exposure_time = time;
-        }
-        
-        notify_altered(new Alteration("metadata", "exposure-time"));
-    }    
-    
-    public Dimensions get_frame_dimensions() {
-        lock (backing_row) {
-            return Dimensions(backing_row.width, backing_row.height);
-        }
-    }
-
-    public override Dimensions get_dimensions(Photo.Exception disallowed_steps = Photo.Exception.NONE) {
-        return get_frame_dimensions();
-    }
-    
-    public override uint64 get_filesize() {
-        return get_master_filesize();
-    }
-    
-    public override uint64 get_master_filesize() {
-        lock (backing_row) {
-            return backing_row.filesize;
-        }
-    }
-    
-    public override time_t get_timestamp() {
-        lock (backing_row) {
-            return backing_row.timestamp;
-        }
-    }
-    
-    public void set_master_timestamp(FileInfo info) {
-        TimeVal time_val = info.get_modification_time();
-        
-        try {
-            lock (backing_row) {
-                if (backing_row.timestamp == time_val.tv_sec)
-                    return;
-                
-                VideoTable.get_instance().set_timestamp(backing_row.video_id, time_val.tv_sec);
-                backing_row.timestamp = time_val.tv_sec;
-            }
-        } catch (DatabaseError err) {
-            AppWindow.database_error(err);
-            
-            return;
-        }
-        
-        notify_altered(new Alteration("metadata", "master-timestamp"));
-    }
-    
-    public string get_filename() {
-        lock (backing_row) {
-            return backing_row.filepath;
-        }
-    }
-    
-    public override File get_file() {
-        return File.new_for_path(get_filename());
-    }
-    
-    public override File get_master_file() {
-        return get_file();
-    }
-    
-    public void export(File dest_file) throws Error {
-        File source_file = File.new_for_path(get_filename());
-        source_file.copy(dest_file, FileCopyFlags.OVERWRITE | FileCopyFlags.TARGET_DEFAULT_PERMS,
-            null, null);
-    }
-    
-    public double get_clip_duration() {
-        lock (backing_row) {
-            return backing_row.clip_duration;
-        }
-    }
-    
-    public bool get_is_interpretable() {
-        lock (backing_row) {
-            return backing_row.is_interpretable;
-        }
-    }
-    
-    private void set_is_interpretable(bool is_interpretable) {
-        lock (backing_row) {
-            if (backing_row.is_interpretable == is_interpretable)
-                return;
-            
-            backing_row.is_interpretable = is_interpretable;
-        }
-        
-        try {
-            VideoTable.get_instance().update_is_interpretable(get_video_id(), is_interpretable);
-        } catch (DatabaseError e) {
-            AppWindow.database_error(e);
-        }
-    }
-    
-    // Intended to be called from a background thread but can be called from foreground as well.
-    // Caller should call InterpretableResults.foreground_process() only from foreground thread,
-    // however
-    public InterpretableResults check_is_interpretable() {
-        InterpretableResults results = new InterpretableResults(this);
-        
-        double clip_duration = -1.0;
-        Gdk.Pixbuf? preview_frame = null;
-        
-        VideoReader backing_file_reader = new VideoReader(get_file());
-        try {
-            clip_duration = backing_file_reader.read_clip_duration();
-            preview_frame = backing_file_reader.read_preview_frame();
-        } catch (VideoError e) {
-            // if we catch an error on an interpretable video here, then this video is
-            // non-interpretable (e.g. its codec is not present on the users system).
-            results.update_interpretable = get_is_interpretable();
-            results.is_interpretable = false;
-            
-            return results;
-        }
-        
-        // if already marked interpretable, this is only confirming what we already knew
-        if (get_is_interpretable()) {
-            results.update_interpretable = false;
-            results.is_interpretable = true;
-            
-            return results;
-        }
-        
-        debug("video %s has become interpretable", get_file().get_basename());
-        
-        // save this here, this can be done in background thread
-        lock (backing_row) {
-            backing_row.clip_duration = clip_duration;
-        }
-        
-        results.update_interpretable = true;
-        results.is_interpretable = true;
-        results.new_thumbnail = preview_frame;
-        
-        return results;
-    }
-    
-    public override void destroy() {
-        VideoID video_id = get_video_id();
-
-        ThumbnailCache.remove(this);
-        
-        try {
-            VideoTable.get_instance().remove(video_id);
-        } catch (DatabaseError err) {
-            error("failed to remove video %s from video table", to_string());
-        }
-        
-        base.destroy();
-    }
-
-    protected override bool internal_delete_backing() throws Error {
-        bool ret = delete_original_file();
-        
-        // Return false if parent method failed.
-        return base.internal_delete_backing() && ret;
-    }
-    
-    private void notify_flags_altered(Alteration? additional_alteration) {
-        Alteration alteration = new Alteration("metadata", "flags");
-        if (additional_alteration != null)
-            alteration = alteration.compress(additional_alteration);
-        
-        notify_altered(alteration);
-    }
-    
-    public uint64 add_flags(uint64 flags_to_add, Alteration? additional_alteration = null) {
-        uint64 new_flags;
-        lock (backing_row) {
-            new_flags = internal_add_flags(backing_row.flags, flags_to_add);
-            if (backing_row.flags == new_flags)
-                return backing_row.flags;
-            
-            try {
-                VideoTable.get_instance().set_flags(get_video_id(), new_flags);
-            } catch (DatabaseError e) {
-                AppWindow.database_error(e);
-                return backing_row.flags;
-            }
-            
-            backing_row.flags = new_flags;
-        }
-        
-        notify_flags_altered(additional_alteration);
-        
-        return new_flags;
-    }
-    
-    public uint64 remove_flags(uint64 flags_to_remove, Alteration? additional_alteration = null) {
-        uint64 new_flags;
-        lock (backing_row) {
-            new_flags = internal_remove_flags(backing_row.flags, flags_to_remove);
-            if (backing_row.flags == new_flags)
-                return backing_row.flags;
-            
-            try {
-                VideoTable.get_instance().set_flags(get_video_id(), new_flags);
-            } catch (DatabaseError e) {
-                AppWindow.database_error(e);
-                return backing_row.flags;
-            }
-            
-            backing_row.flags = new_flags;
-        }
-        
-        notify_flags_altered(additional_alteration);
-        
-        return new_flags;
-    }
-    
-    public bool is_flag_set(uint64 flag) {
-        lock (backing_row) {
-            return internal_is_flag_set(backing_row.flags, flag);
-        }
-    }
-    
-    public void set_master_file(File file) {
-        string new_filepath = file.get_path();
-        string? old_filepath = null;
-        try {
-            lock (backing_row) {
-                if (backing_row.filepath == new_filepath)
-                    return;
-                
-                old_filepath = backing_row.filepath;
-                
-                VideoTable.get_instance().set_filepath(backing_row.video_id, new_filepath);
-                backing_row.filepath = new_filepath;
-            }
-        } catch (DatabaseError err) {
-            AppWindow.database_error(err);
-            
-            return;
-        }
-        
-        assert(old_filepath != null);
-        notify_master_replaced(File.new_for_path(old_filepath), file);
-        
-        notify_altered(new Alteration.from_list("backing:master,metadata:name"));
-    }
-    
-    public VideoMetadata read_metadata() throws Error {
-        return (new VideoReader(get_file())).read_metadata();
-    }
-}
-
-public class VideoSourceCollection : MediaSourceCollection {
-    public enum State {
-        UNKNOWN,
-        ONLINE,
-        OFFLINE,
-        TRASH
-    }
-    
-    public override TransactionController transaction_controller {
-        get {
-            if (_transaction_controller == null)
-                _transaction_controller = new MediaSourceTransactionController(this);
-            
-            return _transaction_controller;
-        }
-    }
-    
-    private TransactionController _transaction_controller = null;
-    private Gee.MultiMap<uint64?, Video> filesize_to_video =
-        new Gee.TreeMultiMap<uint64?, Video>(uint64_compare);
-    
-    public VideoSourceCollection() {
-        base("VideoSourceCollection", get_video_key);
-
-        get_trashcan().contents_altered.connect(on_trashcan_contents_altered);
-        get_offline_bin().contents_altered.connect(on_offline_contents_altered);
-    }
-    
-    protected override MediaSourceHoldingTank create_trashcan() {
-        return new MediaSourceHoldingTank(this, is_video_trashed, get_video_key);
-    }
-    
-    protected override MediaSourceHoldingTank create_offline_bin() {
-        return new MediaSourceHoldingTank(this, is_video_offline, get_video_key);
-    }
-    
-    public override MediaMonitor create_media_monitor(Workers workers, Cancellable cancellable) {
-        return new VideoMonitor(cancellable);
-    }
-    
-    public override bool holds_type_of_source(DataSource source) {
-        return source is Video;
-    }
-    
-    public override string get_typename() {
-        return Video.TYPENAME;
-    }
-    
-    public override bool is_file_recognized(File file) {
-        return VideoReader.is_supported_video_file(file);
-    }
-    
-    private void on_trashcan_contents_altered(Gee.Collection<DataSource>? added,
-        Gee.Collection<DataSource>? removed) {
-        trashcan_contents_altered((Gee.Collection<Video>?) added,
-            (Gee.Collection<Video>?) removed);
-    }
-
-    private void on_offline_contents_altered(Gee.Collection<DataSource>? added,
-        Gee.Collection<DataSource>? removed) {
-        offline_contents_altered((Gee.Collection<Video>?) added,
-            (Gee.Collection<Video>?) removed);
-    }
-
-    protected override MediaSource? fetch_by_numeric_id(int64 numeric_id) {
-        return fetch(VideoID(numeric_id));
-    }
-
-    public static int64 get_video_key(DataSource source) {
-        Video video = (Video) source;
-        VideoID video_id = video.get_video_id();
-        
-        return video_id.id;
-    }
-    
-    public static bool is_video_trashed(DataSource source) {
-        return ((Video) source).is_trashed();
-    }
-    
-    public static bool is_video_offline(DataSource source) {
-        return ((Video) source).is_offline();
-    }
-    
-    public Video fetch(VideoID video_id) {
-        return (Video) fetch_by_key(video_id.id);
-    }
-    
-    public override Gee.Collection<string> get_event_source_ids(EventID event_id){
-        return VideoTable.get_instance().get_event_source_ids(event_id);
-    }
-    
-    public Video? get_state_by_file(File file, out State state) {
-        Video? video = (Video?) fetch_by_master_file(file);
-        if (video != null) {
-            state = State.ONLINE;
-            
-            return video;
-        }
-        
-        video = (Video?) get_trashcan().fetch_by_master_file(file);
-        if (video != null) {
-            state = State.TRASH;
-            
-            return video;
-        }
-        
-        video = (Video?) get_offline_bin().fetch_by_master_file(file);
-        if (video != null) {
-            state = State.OFFLINE;
-            
-            return video;
-        }
-        
-        state = State.UNKNOWN;
-        
-        return null;
-    }
-    
-    private void compare_backing(Video video, FileInfo info, Gee.Collection<Video> matching_master) {
-        if (video.get_filesize() != info.get_size())
-            return;
-        
-        if (video.get_timestamp() == info.get_modification_time().tv_sec)
-            matching_master.add(video);
-    }
-    
-    public void fetch_by_matching_backing(FileInfo info, Gee.Collection<Video> matching_master) {
-        foreach (DataObject object in get_all())
-            compare_backing((Video) object, info, matching_master);
-        
-        foreach (MediaSource media in get_offline_bin_contents())
-            compare_backing((Video) media, info, matching_master);
-    }
-    
-    protected override void notify_contents_altered(Gee.Iterable<DataObject>? added,
-        Gee.Iterable<DataObject>? removed) {
-        if (added != null) {
-            foreach (DataObject object in added) {
-                Video video = (Video) object;
-                
-                filesize_to_video.set(video.get_master_filesize(), video);
-            }
-        }
-        
-        if (removed != null) {
-            foreach (DataObject object in removed) {
-                Video video = (Video) object;
-                
-                filesize_to_video.remove(video.get_master_filesize(), video);
-            }
-        }
-        
-        base.notify_contents_altered(added, removed);
-    }
-    
-    public VideoID get_basename_filesize_duplicate(string basename, uint64 filesize) {
-        foreach (Video video in filesize_to_video.get(filesize)) {
-            if (utf8_ci_compare(video.get_master_file().get_basename(), basename) == 0)
-                return video.get_video_id();
-        }
-        
-        return VideoID(); // the default constructor of the VideoID struct creates an invalid
-                          // video id, which is just what we want in this case
-    }
-    
-    public bool has_basename_filesize_duplicate(string basename, uint64 filesize) {
-        return get_basename_filesize_duplicate(basename, filesize).is_valid();
-    }
-}
-- 
cgit v1.2.3