add uploading_to_reflector and is_fully_reflected filter arguments to file_list

lbry/extras/daemon/daemon.py

@@ -1965,7 +1965,8 @@ class Daemon(metaclass=JSONRPCServerType):
                       [--outpoint=<outpoint>] [--txid=<txid>] [--nout=<nout>]
                       [--channel_claim_id=<channel_claim_id>] [--channel_name=<channel_name>]
                       [--claim_name=<claim_name>] [--blobs_in_stream=<blobs_in_stream>]
-                      [--blobs_remaining=<blobs_remaining>] [--sort=<sort_by>]
+                      [--blobs_remaining=<blobs_remaining>] [--uploading_to_reflector=<uploading_to_reflector>]
+                      [--is_fully_reflected=<is_fully_reflected>] [--sort=<sort_by>]
                       [--comparison=<comparison>] [--full_status=<full_status>] [--reverse]
                       [--page=<page>] [--page_size=<page_size>] [--wallet_id=<wallet_id>]
 
@@ -1984,6 +1985,8 @@ class Daemon(metaclass=JSONRPCServerType):
             --channel_name=<channel_name>          : (str) get file with matching channel name
             --claim_name=<claim_name>              : (str) get file with matching claim name
             --blobs_in_stream<blobs_in_stream>     : (int) get file with matching blobs in stream
+            --uploading_to_reflector=<uploading_to_reflector> : (bool) get files currently uploading to reflector
+            --is_fully_reflected=<is_fully_reflected>         : (bool) get files that have been uploaded to reflector
             --blobs_remaining=<blobs_remaining>    : (int) amount of remaining blobs to download
             --sort=<sort_by>                       : (str) field to sort by (one of the above filter fields)
             --comparison=<comparison>              : (str) logical comparison, (eq | ne | g | ge | l | le | in)

lbry/stream/managed_stream.py

@@ -57,7 +57,6 @@ class ManagedStream(ManagedDownloadSource):
         self.downloader = StreamDownloader(self.loop, self.config, self.blob_manager, sd_hash, descriptor)
         self.analytics_manager = analytics_manager
 
-        self.fully_reflected = asyncio.Event(loop=self.loop)
         self.reflector_progress = 0
         self.uploading_to_reflector = False
         self.file_output_task: typing.Optional[asyncio.Task] = None

lbry/stream/stream_manager.py

@@ -38,7 +38,9 @@ class StreamManager(SourceManager):
         'stream_hash',
         'full_status',  # TODO: remove
         'blobs_remaining',
-        'blobs_in_stream'
+        'blobs_in_stream',
+        'uploading_to_reflector',
+        'is_fully_reflected'
     })
 
     def __init__(self, loop: asyncio.AbstractEventLoop, config: 'Config', blob_manager: 'BlobManager',