membraneframework · FelonEkonom · Jul 24, 2024 · Jul 23, 2024 · Jul 24, 2024 · Jul 24, 2024
@@ -18,7 +18,7 @@ commands:
         default: dev
     steps:
       - save_cache:
-          key: v2-build-cache-{{ arch }}-<< parameters.env >>-{{ checksum "mix.lock" }}
+          key: v3-build-cache-{{ arch }}-<< parameters.env >>-{{ checksum "mix.lock" }}
           paths: ["_build/<< parameters.env >>"]
   restore_build_cache:
     parameters:
@@ -29,25 +29,25 @@ commands:
     steps:
       - restore_cache:
           keys:
-            - v2-build-cache-{{ arch }}-<< parameters.env >>-{{ checksum "mix.lock" }}
-            - v2-build-cache-{{ arch }}-<< parameters.env >>-
-            - v2-build-cache-{{ arch }}-
+            - v3-build-cache-{{ arch }}-<< parameters.env >>-{{ checksum "mix.lock" }}
+            - v3-build-cache-{{ arch }}-<< parameters.env >>-
+            - v3-build-cache-{{ arch }}-
   gen_version_file:
     steps:
       - run: asdf current erlang > .runtime_version
       - run: asdf current elixir >> .runtime_version
   save_plt_cache:
     steps:
       - save_cache:
-          key: v1-dialyzer-cache-{{ checksum ".runtime_version" }}-{{ checksum "mix.lock" }}
+          key: v2-dialyzer-cache-{{ checksum ".runtime_version" }}-{{ checksum "mix.lock" }}
           paths: "priv/plts"
   restore_plt_cache:
     steps:
       - restore_cache:
           keys:
-            - v1-dialyzer-cache-{{ checksum ".runtime_version" }}-{{ checksum "mix.lock" }}
-            - v1-dialyzer-cache-{{ checksum ".runtime_version" }}-
-            - v1-dialyzer-cache-
+            - v2-dialyzer-cache-{{ checksum ".runtime_version" }}-{{ checksum "mix.lock" }}
+            - v2-dialyzer-cache-{{ checksum ".runtime_version" }}-
+            - v2-dialyzer-cache-
   run_tests:
     parameters:
       glob:

@@ -71,14 +71,29 @@ defmodule Membrane.Core.Bin do
 
     if node do
       result = :rpc.call(node, GenServer, :start, [__MODULE__, options])
-      with {:start_link, {:ok, pid}} <- {method, result}, do: Process.link(pid)
+      _ignored = with {:start_link, {:ok, pid}} <- {method, result}, do: Process.link(pid)
       result
     else
       apply(GenServer, method, [__MODULE__, options])
     end
   end
 
   @impl GenServer
+  @spec init(%{
+          :log_metadata => [{any(), any()}],
+          :module => atom(),
+          :name => atom() | tuple(),
+          :parent => pid(),
+          :parent_clock => pid(),
+          :parent_path => [binary()],
+          :parent_supervisor => pid() | port(),
+          :stalker => Membrane.Core.Stalker.t(),
+          :subprocess_supervisor => pid(),
+          :user_options => any(),
+          optional(any()) => any()
+        }) ::
+          {:ok, %{:internal_state => any(), :module => atom(), optional(atom()) => any()},
+           {:continue, :setup}}
   def init(options) do
     Utils.log_on_error do
       do_init(options)

@@ -139,16 +139,17 @@ defmodule Membrane.Core.CallbackHandler do
         apply(module, callback, args)
       rescue
         e in UndefinedFunctionError ->
-          with %{module: ^module, function: ^callback, arity: arity} <- e do
-            reraise CallbackError,
-                    [
-                      kind: :not_implemented,
-                      callback: {module, callback},
-                      arity: arity,
-                      args: args
-                    ],
-                    __STACKTRACE__
-          end
+          _ignored =
+            with %{module: ^module, function: ^callback, arity: arity} <- e do
+              reraise CallbackError,
+                      [
+                        kind: :not_implemented,
+                        callback: {module, callback},
+                        arity: arity,
+                        args: args
+                      ],
+                      __STACKTRACE__
+            end
 
           reraise e, __STACKTRACE__
       end

@@ -38,21 +38,21 @@ defmodule Membrane.Core.Component do
     callback_context_module.from_state(state, args)
   end
 
-  @spec is_pipeline?(state) :: boolean()
-  def is_pipeline?(%Membrane.Core.Pipeline.State{}), do: true
-  def is_pipeline?(_state), do: false
+  @spec pipeline?(state) :: boolean()
+  def pipeline?(%Membrane.Core.Pipeline.State{}), do: true
+  def pipeline?(_state), do: false
 
-  @spec is_element?(state) :: boolean()
-  def is_element?(%Membrane.Core.Element.State{}), do: true
-  def is_element?(_state), do: false
+  @spec element?(state) :: boolean()
+  def element?(%Membrane.Core.Element.State{}), do: true
+  def element?(_state), do: false
 
-  @spec is_bin?(state) :: boolean()
-  def is_bin?(%Membrane.Core.Bin.State{}), do: true
-  def is_bin?(_state), do: false
+  @spec bin?(state) :: boolean()
+  def bin?(%Membrane.Core.Bin.State{}), do: true
+  def bin?(_state), do: false
 
-  @spec is_child?(state) :: boolean()
-  def is_child?(state), do: is_element?(state) or is_bin?(state)
+  @spec child?(state) :: boolean()
+  def child?(state), do: element?(state) or bin?(state)
 
-  @spec is_parent?(state) :: boolean()
-  def is_parent?(state), do: is_pipeline?(state) or is_bin?(state)
+  @spec parent?(state) :: boolean()
+  def parent?(state), do: pipeline?(state) or bin?(state)
 end
@@ -86,7 +86,7 @@ defmodule Membrane.Core.Element do
     # rpc if necessary
     if node do
       result = :rpc.call(node, GenServer, :start, [__MODULE__, options])
-      with {:start_link, {:ok, pid}} <- {method, result}, do: Process.link(pid)
+      _ignored = with {:start_link, {:ok, pid}} <- {method, result}, do: Process.link(pid)
       result
     else
       apply(GenServer, method, [__MODULE__, options])

@@ -19,11 +19,11 @@ defmodule Membrane.Core.LifecycleController do
         Membrane.Logger.debug("Component deferred initialization")
         %{state | setup_incomplete?: true}
 
-      Component.is_pipeline?(state) ->
+      Component.pipeline?(state) ->
         # complete_setup/1 will be called in Membrane.Core.Pipeline.ActionHandler.handle_end_of_actions/1
         %{state | awaiting_setup_completition?: true}
 
-      Component.is_child?(state) ->
+      Component.child?(state) ->
         complete_setup(state)
     end
   end
@@ -34,10 +34,10 @@ defmodule Membrane.Core.LifecycleController do
     Membrane.Logger.debug("Component initialized")
 
     cond do
-      Component.is_pipeline?(state) ->
+      Component.pipeline?(state) ->
         Parent.LifecycleController.handle_playing(state)
 
-      Component.is_child?(state) ->
+      Component.child?(state) ->
         Message.send(state.parent_pid, :initialized, state.name)
         state
     end

@@ -425,11 +425,11 @@ defmodule Membrane.Core.Stalker do
 
     state = put_in(state, [:subscribers, pid], topics)
 
-    with %{graph: filter} <- topics do
-      graph = state.graph |> Enum.reverse() |> Enum.filter(filter)
-      send(pid, {:graph, :add, graph})
-      :ok
-    end
+    _ignored =
+      with %{graph: filter} <- topics do
+        graph = state.graph |> Enum.reverse() |> Enum.filter(filter)
+        send(pid, {:graph, :add, graph})
+      end
 
     {:noreply, state}
   end

@@ -282,19 +282,19 @@ defmodule Membrane.Testing.Pipeline do
     child_pid
   end
 
-  defp do_get_child_pid(component_pid, child_name_path, is_pipeline? \\ true)
+  defp do_get_child_pid(component_pid, child_name_path, pipeline? \\ true)
 
-  defp do_get_child_pid(component_pid, [], _is_pipeline?) do
+  defp do_get_child_pid(component_pid, [], _pipeline?) do
     {:ok, component_pid}
   end
 
-  defp do_get_child_pid(component_pid, [child_name | child_name_path_tail], is_pipeline?) do
+  defp do_get_child_pid(component_pid, [child_name | child_name_path_tail], pipeline?) do
     case Message.call(component_pid, :get_child_pid, child_name) do
       {:ok, child_pid} ->
         do_get_child_pid(child_pid, child_name_path_tail, false)
 
       {:error, {:call_failure, {:noproc, _call_info}}} ->
-        if is_pipeline?,
+        if pipeline?,
           do: {:error, :pipeline_not_alive},
           else: {:error, :component_not_alive}
 

@@ -149,7 +149,7 @@ defmodule Membrane.Mixfile do
       {:ex_doc, "~> 0.28", only: :dev, runtime: false},
       {:makeup_diff, "~> 0.1", only: :dev, runtime: false},
       {:dialyxir, "~> 1.1", only: :dev, runtime: false},
-      {:credo, "~> 1.6", only: :dev, runtime: false},
+      {:credo, "~> 1.7", only: :dev, runtime: false},
       # Testing
       {:mox, "~> 1.0", only: :test},
       {:junit_formatter, "~> 3.1", only: :test},

@@ -1,22 +1,22 @@
 %{
-  "bunch": {:hex, :bunch, "1.6.0", "4775f8cdf5e801c06beed3913b0bd53fceec9d63380cdcccbda6be125a6cfd54", [:mix], [], "hexpm", "ef4e9abf83f0299d599daed3764d19e8eac5d27a5237e5e4d5e2c129cfeb9a22"},
-  "bunt": {:hex, :bunt, "0.2.1", "e2d4792f7bc0ced7583ab54922808919518d0e57ee162901a16a1b6664ef3b14", [:mix], [], "hexpm", "a330bfb4245239787b15005e66ae6845c9cd524a288f0d141c148b02603777a5"},
+  "bunch": {:hex, :bunch, "1.6.1", "5393d827a64d5f846092703441ea50e65bc09f37fd8e320878f13e63d410aec7", [:mix], [], "hexpm", "286cc3add551628b30605efbe2fca4e38cc1bea89bcd0a1a7226920b3364fe4a"},
+  "bunt": {:hex, :bunt, "1.0.0", "081c2c665f086849e6d57900292b3a161727ab40431219529f13c4ddcf3e7a44", [:mix], [], "hexpm", "dc5f86aa08a5f6fa6b8096f0735c4e76d54ae5c9fa2c143e5a1fc7c1cd9bb6b5"},
   "coerce": {:hex, :coerce, "1.0.1", "211c27386315dc2894ac11bc1f413a0e38505d808153367bd5c6e75a4003d096", [:mix], [], "hexpm", "b44a691700f7a1a15b4b7e2ff1fa30bebd669929ac8aa43cffe9e2f8bf051cf1"},
-  "credo": {:hex, :credo, "1.7.0", "6119bee47272e85995598ee04f2ebbed3e947678dee048d10b5feca139435f75", [:mix], [{:bunt, "~> 0.2.1", [hex: :bunt, repo: "hexpm", optional: false]}, {:file_system, "~> 0.2.8", [hex: :file_system, repo: "hexpm", optional: false]}, {:jason, "~> 1.0", [hex: :jason, repo: "hexpm", optional: false]}], "hexpm", "6839fcf63d1f0d1c0f450abc8564a57c43d644077ab96f2934563e68b8a769d7"},
-  "dialyxir": {:hex, :dialyxir, "1.4.1", "a22ed1e7bd3a3e3f197b68d806ef66acb61ee8f57b3ac85fc5d57354c5482a93", [:mix], [{:erlex, ">= 0.2.6", [hex: :erlex, repo: "hexpm", optional: false]}], "hexpm", "84b795d6d7796297cca5a3118444b80c7d94f7ce247d49886e7c291e1ae49801"},
-  "earmark_parser": {:hex, :earmark_parser, "1.4.33", "3c3fd9673bb5dcc9edc28dd90f50c87ce506d1f71b70e3de69aa8154bc695d44", [:mix], [], "hexpm", "2d526833729b59b9fdb85785078697c72ac5e5066350663e5be6a1182da61b8f"},
-  "erlex": {:hex, :erlex, "0.2.6", "c7987d15e899c7a2f34f5420d2a2ea0d659682c06ac607572df55a43753aa12e", [:mix], [], "hexpm", "2ed2e25711feb44d52b17d2780eabf998452f6efda104877a3881c2f8c0c0c75"},
-  "ex_doc": {:hex, :ex_doc, "0.30.6", "5f8b54854b240a2b55c9734c4b1d0dd7bdd41f71a095d42a70445c03cf05a281", [:mix], [{:earmark_parser, "~> 1.4.31", [hex: :earmark_parser, repo: "hexpm", optional: false]}, {:makeup_elixir, "~> 0.14", [hex: :makeup_elixir, repo: "hexpm", optional: false]}, {:makeup_erlang, "~> 0.1", [hex: :makeup_erlang, repo: "hexpm", optional: false]}], "hexpm", "bd48f2ddacf4e482c727f9293d9498e0881597eae6ddc3d9562bd7923375109f"},
-  "excoveralls": {:hex, :excoveralls, "0.17.1", "83fa7906ef23aa7fc8ad7ee469c357a63b1b3d55dd701ff5b9ce1f72442b2874", [:mix], [{:castore, "~> 1.0", [hex: :castore, repo: "hexpm", optional: true]}, {:jason, "~> 1.0", [hex: :jason, repo: "hexpm", optional: false]}], "hexpm", "95bc6fda953e84c60f14da4a198880336205464e75383ec0f570180567985ae0"},
-  "file_system": {:hex, :file_system, "0.2.10", "fb082005a9cd1711c05b5248710f8826b02d7d1784e7c3451f9c1231d4fc162d", [:mix], [], "hexpm", "41195edbfb562a593726eda3b3e8b103a309b733ad25f3d642ba49696bf715dc"},
-  "jason": {:hex, :jason, "1.4.1", "af1504e35f629ddcdd6addb3513c3853991f694921b1b9368b0bd32beb9f1b63", [:mix], [{:decimal, "~> 1.0 or ~> 2.0", [hex: :decimal, repo: "hexpm", optional: true]}], "hexpm", "fbb01ecdfd565b56261302f7e1fcc27c4fb8f32d56eab74db621fc154604a7a1"},
-  "junit_formatter": {:hex, :junit_formatter, "3.3.1", "c729befb848f1b9571f317d2fefa648e9d4869befc4b2980daca7c1edc468e40", [:mix], [], "hexpm", "761fc5be4b4c15d8ba91a6dafde0b2c2ae6db9da7b8832a55b5a1deb524da72b"},
-  "makeup": {:hex, :makeup, "1.1.0", "6b67c8bc2882a6b6a445859952a602afc1a41c2e08379ca057c0f525366fc3ca", [:mix], [{:nimble_parsec, "~> 1.2.2 or ~> 1.3", [hex: :nimble_parsec, repo: "hexpm", optional: false]}], "hexpm", "0a45ed501f4a8897f580eabf99a2e5234ea3e75a4373c8a52824f6e873be57a6"},
+  "credo": {:hex, :credo, "1.7.7", "771445037228f763f9b2afd612b6aa2fd8e28432a95dbbc60d8e03ce71ba4446", [:mix], [{:bunt, "~> 0.2.1 or ~> 1.0", [hex: :bunt, repo: "hexpm", optional: false]}, {:file_system, "~> 0.2 or ~> 1.0", [hex: :file_system, repo: "hexpm", optional: false]}, {:jason, "~> 1.0", [hex: :jason, repo: "hexpm", optional: false]}], "hexpm", "8bc87496c9aaacdc3f90f01b7b0582467b69b4bd2441fe8aae3109d843cc2f2e"},
+  "dialyxir": {:hex, :dialyxir, "1.4.3", "edd0124f358f0b9e95bfe53a9fcf806d615d8f838e2202a9f430d59566b6b53b", [:mix], [{:erlex, ">= 0.2.6", [hex: :erlex, repo: "hexpm", optional: false]}], "hexpm", "bf2cfb75cd5c5006bec30141b131663299c661a864ec7fbbc72dfa557487a986"},
+  "earmark_parser": {:hex, :earmark_parser, "1.4.41", "ab34711c9dc6212dda44fcd20ecb87ac3f3fce6f0ca2f28d4a00e4154f8cd599", [:mix], [], "hexpm", "a81a04c7e34b6617c2792e291b5a2e57ab316365c2644ddc553bb9ed863ebefa"},
+  "erlex": {:hex, :erlex, "0.2.7", "810e8725f96ab74d17aac676e748627a07bc87eb950d2b83acd29dc047a30595", [:mix], [], "hexpm", "3ed95f79d1a844c3f6bf0cea61e0d5612a42ce56da9c03f01df538685365efb0"},
+  "ex_doc": {:hex, :ex_doc, "0.34.2", "13eedf3844ccdce25cfd837b99bea9ad92c4e511233199440488d217c92571e8", [:mix], [{:earmark_parser, "~> 1.4.39", [hex: :earmark_parser, repo: "hexpm", optional: false]}, {:makeup_c, ">= 0.1.0", [hex: :makeup_c, repo: "hexpm", optional: true]}, {:makeup_elixir, "~> 0.14 or ~> 1.0", [hex: :makeup_elixir, repo: "hexpm", optional: false]}, {:makeup_erlang, "~> 0.1 or ~> 1.0", [hex: :makeup_erlang, repo: "hexpm", optional: false]}, {:makeup_html, ">= 0.1.0", [hex: :makeup_html, repo: "hexpm", optional: true]}], "hexpm", "5ce5f16b41208a50106afed3de6a2ed34f4acfd65715b82a0b84b49d995f95c1"},
+  "excoveralls": {:hex, :excoveralls, "0.18.1", "a6f547570c6b24ec13f122a5634833a063aec49218f6fff27de9df693a15588c", [:mix], [{:castore, "~> 1.0", [hex: :castore, repo: "hexpm", optional: true]}, {:jason, "~> 1.0", [hex: :jason, repo: "hexpm", optional: false]}], "hexpm", "d65f79db146bb20399f23046015974de0079668b9abb2f5aac074d078da60b8d"},
+  "file_system": {:hex, :file_system, "1.0.0", "b689cc7dcee665f774de94b5a832e578bd7963c8e637ef940cd44327db7de2cd", [:mix], [], "hexpm", "6752092d66aec5a10e662aefeed8ddb9531d79db0bc145bb8c40325ca1d8536d"},
+  "jason": {:hex, :jason, "1.4.3", "d3f984eeb96fe53b85d20e0b049f03e57d075b5acda3ac8d465c969a2536c17b", [:mix], [{:decimal, "~> 1.0 or ~> 2.0", [hex: :decimal, repo: "hexpm", optional: true]}], "hexpm", "9a90e868927f7c777689baa16d86f4d0e086d968db5c05d917ccff6d443e58a3"},
+  "junit_formatter": {:hex, :junit_formatter, "3.4.0", "d0e8db6c34dab6d3c4154c3b46b21540db1109ae709d6cf99ba7e7a2ce4b1ac2", [:mix], [], "hexpm", "bb36e2ae83f1ced6ab931c4ce51dd3dbef1ef61bb4932412e173b0cfa259dacd"},
+  "makeup": {:hex, :makeup, "1.1.2", "9ba8837913bdf757787e71c1581c21f9d2455f4dd04cfca785c70bbfff1a76a3", [:mix], [{:nimble_parsec, "~> 1.2.2 or ~> 1.3", [hex: :nimble_parsec, repo: "hexpm", optional: false]}], "hexpm", "cce1566b81fbcbd21eca8ffe808f33b221f9eee2cbc7a1706fc3da9ff18e6cac"},
   "makeup_diff": {:hex, :makeup_diff, "0.1.0", "5be352b6aa6f07fa6a236e3efd7ba689a03f28fb5d35b7a0fa0a1e4a64f6d8bb", [:mix], [{:makeup, "~> 1.0", [hex: :makeup, repo: "hexpm", optional: false]}], "hexpm", "186bad5bb433a8afeb16b01423950e440072284a4103034ca899180343b9b4ac"},
-  "makeup_elixir": {:hex, :makeup_elixir, "0.16.1", "cc9e3ca312f1cfeccc572b37a09980287e243648108384b97ff2b76e505c3555", [:mix], [{:makeup, "~> 1.0", [hex: :makeup, repo: "hexpm", optional: false]}, {:nimble_parsec, "~> 1.2.3 or ~> 1.3", [hex: :nimble_parsec, repo: "hexpm", optional: false]}], "hexpm", "e127a341ad1b209bd80f7bd1620a15693a9908ed780c3b763bccf7d200c767c6"},
-  "makeup_erlang": {:hex, :makeup_erlang, "0.1.2", "ad87296a092a46e03b7e9b0be7631ddcf64c790fa68a9ef5323b6cbb36affc72", [:mix], [{:makeup, "~> 1.0", [hex: :makeup, repo: "hexpm", optional: false]}], "hexpm", "f3f5a1ca93ce6e092d92b6d9c049bcda58a3b617a8d888f8e7231c85630e8108"},
-  "mox": {:hex, :mox, "1.0.2", "dc2057289ac478b35760ba74165b4b3f402f68803dd5aecd3bfd19c183815d64", [:mix], [], "hexpm", "f9864921b3aaf763c8741b5b8e6f908f44566f1e427b2630e89e9a73b981fef2"},
-  "nimble_parsec": {:hex, :nimble_parsec, "1.3.1", "2c54013ecf170e249e9291ed0a62e5832f70a476c61da16f6aac6dca0189f2af", [:mix], [], "hexpm", "2682e3c0b2eb58d90c6375fc0cc30bc7be06f365bf72608804fb9cffa5e1b167"},
+  "makeup_elixir": {:hex, :makeup_elixir, "0.16.2", "627e84b8e8bf22e60a2579dad15067c755531fea049ae26ef1020cad58fe9578", [:mix], [{:makeup, "~> 1.0", [hex: :makeup, repo: "hexpm", optional: false]}, {:nimble_parsec, "~> 1.2.3 or ~> 1.3", [hex: :nimble_parsec, repo: "hexpm", optional: false]}], "hexpm", "41193978704763f6bbe6cc2758b84909e62984c7752b3784bd3c218bb341706b"},
+  "makeup_erlang": {:hex, :makeup_erlang, "1.0.1", "c7f58c120b2b5aa5fd80d540a89fdf866ed42f1f3994e4fe189abebeab610839", [:mix], [{:makeup, "~> 1.0", [hex: :makeup, repo: "hexpm", optional: false]}], "hexpm", "8a89a1eeccc2d798d6ea15496a6e4870b75e014d1af514b1b71fa33134f57814"},
+  "mox": {:hex, :mox, "1.1.0", "0f5e399649ce9ab7602f72e718305c0f9cdc351190f72844599545e4996af73c", [:mix], [], "hexpm", "d44474c50be02d5b72131070281a5d3895c0e7a95c780e90bc0cfe712f633a13"},
+  "nimble_parsec": {:hex, :nimble_parsec, "1.4.0", "51f9b613ea62cfa97b25ccc2c1b4216e81df970acd8e16e8d1bdc58fef21370d", [:mix], [], "hexpm", "9c565862810fb383e9838c1dd2d7d2c437b3d13b267414ba6af33e50d2d1cf28"},
   "numbers": {:hex, :numbers, "5.2.4", "f123d5bb7f6acc366f8f445e10a32bd403c8469bdbce8ce049e1f0972b607080", [:mix], [{:coerce, "~> 1.0", [hex: :coerce, repo: "hexpm", optional: false]}, {:decimal, "~> 1.9 or ~> 2.0", [hex: :decimal, repo: "hexpm", optional: true]}], "hexpm", "eeccf5c61d5f4922198395bf87a465b6f980b8b862dd22d28198c5e6fab38582"},
   "qex": {:hex, :qex, "0.5.1", "0d82c0f008551d24fffb99d97f8299afcb8ea9cf99582b770bd004ed5af63fd6", [:mix], [], "hexpm", "935a39fdaf2445834b95951456559e9dc2063d0a055742c558a99987b38d6bab"},
   "ratio": {:hex, :ratio, "4.0.1", "3044166f2fc6890aa53d3aef0c336f84b2bebb889dc57d5f95cc540daa1912f8", [:mix], [{:decimal, "~> 1.6 or ~> 2.0", [hex: :decimal, repo: "hexpm", optional: true]}, {:numbers, "~> 5.2.0", [hex: :numbers, repo: "hexpm", optional: false]}], "hexpm", "c60cbb3ccdff9ffa56e7d6d1654b5c70d9f90f4d753ab3a43a6bf40855b881ce"},