More steps towards a working reprocessing system.
Fleshing out the base classes and setting up some docstrings. Not everything is totally clear yet, but I think it's on a good track, and getting clearer. This commit sponsored by Ben Finney, on behalf of Free Software Melbourne. Thank you all!
This commit is contained in:
parent
274a0f67fd
commit
e4bdc9091c
@ -114,6 +114,10 @@ class MediaProcessor(object):
|
|||||||
def __init__(self, manager):
|
def __init__(self, manager):
|
||||||
self.manager = manager
|
self.manager = manager
|
||||||
|
|
||||||
|
# Should be initialized at time of processing, at least
|
||||||
|
self.workbench = None
|
||||||
|
|
||||||
|
# @with_workbench
|
||||||
def process(self, **kwargs):
|
def process(self, **kwargs):
|
||||||
"""
|
"""
|
||||||
Actually process this media entry.
|
Actually process this media entry.
|
||||||
@ -142,13 +146,12 @@ class MediaProcessor(object):
|
|||||||
|
|
||||||
|
|
||||||
class ProcessingManager(object):
|
class ProcessingManager(object):
|
||||||
"""
|
"""Manages all the processing actions available for a media type
|
||||||
"""
|
|
||||||
def __init__(self, entry):
|
|
||||||
self.entry = entry
|
|
||||||
# May merge these two classes soon....
|
|
||||||
self.state = ProcessingState(entry)
|
|
||||||
|
|
||||||
|
Specific processing actions, MediaProcessor subclasses, are added
|
||||||
|
to the ProcessingManager.
|
||||||
|
"""
|
||||||
|
def __init__(self):
|
||||||
# Dict of all MediaProcessors of this media type
|
# Dict of all MediaProcessors of this media type
|
||||||
self.processors = {}
|
self.processors = {}
|
||||||
|
|
||||||
@ -162,7 +165,7 @@ class ProcessingManager(object):
|
|||||||
|
|
||||||
self.processors[name] = processor
|
self.processors[name] = processor
|
||||||
|
|
||||||
def list_eligible_processors(self):
|
def list_eligible_processors(self, entry):
|
||||||
"""
|
"""
|
||||||
List all processors that this media entry is eligible to be processed
|
List all processors that this media entry is eligible to be processed
|
||||||
for.
|
for.
|
||||||
@ -170,9 +173,16 @@ class ProcessingManager(object):
|
|||||||
return [
|
return [
|
||||||
processor
|
processor
|
||||||
for processor in self.processors.keys()
|
for processor in self.processors.keys()
|
||||||
if processor.media_is_eligible(self.entry)]
|
if processor.media_is_eligible(entry)]
|
||||||
|
|
||||||
def process(self, directive, request):
|
def gen_process_request_via_cli(self, subparser):
|
||||||
|
# Got to figure out what actually goes here before I can write this properly
|
||||||
|
pass
|
||||||
|
|
||||||
|
def process(self, entry, directive, request):
|
||||||
|
"""
|
||||||
|
Process a media entry.
|
||||||
|
"""
|
||||||
pass
|
pass
|
||||||
|
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user