It's in the remote_storage_step/1 function of the RemoteStorage stage that we try to find whether there is a CacheWorker for the media contained on the download event. This stage receives download events from the Starter event producer and emits events downstream with the media contents. If there was a CacheWorker for the media, the contents of the event emitted by this stage correspond to the media original contents, therefore, the event is tagged as :original using the status event field; if not, this stage simply fetches the media-encrypted contents from the cloud provider and passes them along:
$ cat apps/elixir_drip/lib/elixir_drip/storage/pipeline/remote_storage.exdefmodule ElixirDrip.Storage.Pipeline.RemoteStorage ...
