Add remove_media_source_atom and associated handler to media_actor.

Signed-off-by: Ken McGaugh <[email protected]>

Author: kenmcgaugh

include/xstudio/atoms.hpp

@@ -599,6 +599,7 @@ CAF_BEGIN_TYPE_ID_BLOCK(xstudio_session_atoms, FIRST_CUSTOM_ID + (200 * 4))
     CAF_ADD_ATOM(xstudio_session_atoms, xstudio::media, acquire_media_detail_atom)
     CAF_ADD_ATOM(xstudio_session_atoms, xstudio::media, add_media_source_atom)
     CAF_ADD_ATOM(xstudio_session_atoms, xstudio::media, add_media_stream_atom)
+    CAF_ADD_ATOM(xstudio_session_atoms, xstudio::media, remove_media_source_atom)
     CAF_ADD_ATOM(xstudio_session_atoms, xstudio::media, checksum_atom)
     CAF_ADD_ATOM(xstudio_session_atoms, xstudio::media, current_media_source_atom)
     CAF_ADD_ATOM(xstudio_session_atoms, xstudio::media, current_media_stream_atom)

src/media/src/media_actor.cpp

@@ -434,6 +434,25 @@ caf::message_handler MediaActor::message_handler() {
             return true;
         },
 
+        [=](remove_media_source_atom, const UuidVector &uuids) -> bool {
+            bool changed = false;
+            for (const auto &uuid : uuids) {
+                if (media_sources_.count(uuid)) {
+                    base_.remove_media_source(uuid);
+                    changed = true;
+                    auto a  = media_sources_.at(uuid);
+                    media_sources_.erase(media_sources_.find(uuid));
+                    unlink_from(a);
+                    send_exit(a, caf::exit_reason::user_shutdown);
+                }
+            }
+            if (changed) {
+                base_.send_changed();
+            }
+            return changed;
+        },
+
+
         [=](colour_pipeline::get_colour_pipe_params_atom atom) -> caf::result<JsonStore> {
             auto rp = make_response_promise<JsonStore>();