diff options
Diffstat (limited to 'src/VideoSupport.vala')
| -rw-r--r-- | src/VideoSupport.vala | 1193 |
1 files changed, 0 insertions, 1193 deletions
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(); - } -} |