luxlabs header browser preview


@class MSMediaStreamDaemon, NSString, NSURL, NSArray, MSPublishStreamsProtocol, NSMutableDictionary, MSObjectQueue, NSMutableArray;
@protocol MSPublisherDelegate, MSPublishStorageProtocol;

@interface MSPublisher : MSCupidStateMachine <MSPublisher, MSPublishStreamsProtocolDelegate, MSPublishStorageProtocolDelegate> {
    int _state;
    MSObjectQueue *_uploadQueue;
    MSObjectQueue *_derivativesQueue;
    MSObjectQueue *_quarantinedQueue;
    NSArray *_pendingDerivativesQueue;
    NSMutableArray *_requestAuthQueue;
    unsigned long long _sendingQueueCount;
    NSMutableArray *_sendingQueue;
    NSMutableDictionary *_fileHashToAssetMap;
    MSPublishStreamsProtocol *_protocol;
    id<MSPublishStorageProtocol> _storageProtocol;
    NSMutableArray *_tempFiles;
    NSMutableDictionary *_maxSizeByUTI;
    int _maxErrorCount;
}

@property (nonatomic) MSMediaStreamDaemon *daemon;
@property (retain, nonatomic) NSURL *storageProtocolURL;
@property (nonatomic) long long publishTargetByteCount;
@property (nonatomic) int publishBatchSize;
@property (nonatomic) id<MSPublisherDelegate> delegate;
@property (readonly) unsigned long long hash;
@property (readonly) Class superclass;
@property (readonly, copy) NSString *description;
@property (readonly, copy) NSString *debugDescription;

+ (id)personIDsWithOutstandingActivities;
+ (id)existingPublisherForPersonID:(id)a0;
+ (BOOL)isInRetryState;
+ (id)nextActivityDateForPersonID:(id)a0;
+ (id)nextActivityDate;
+ (void)stopAllActivities;
+ (id)_clearInstantiatedPublishersByPersonID;
+ (void)_setMasterNextActivityDate:(id)a0 forPersonID:(id)a1;
+ (void)forgetPersonID:(id)a0;
+ (id)publisherForPersonID:(id)a0;

- (void)abort;
- (void)publish;
- (void)dealloc;
- (id)initWithPersonID:(id)a0 baseURL:(id)a1;
- (void)stop;
- (void)_registerAsset:(id)a0;
- (void).cxx_destruct;
- (int)_stop;
- (void)deactivate;
- (void)_abort;
- (void)_forget;
- (BOOL)_isInRetryState;
- (id)_abortedError;
- (void)_addAssetToFileHashMap:(id)a0;
- (void)_categorizeError:(id)a0 setOutIsIgnorable:(BOOL *)a1 setOutIsCounted:(BOOL *)a2 setOutIsFatal:(BOOL *)a3 setOutNeedsBackoff:(BOOL *)a4 setOutIsTemporary:(BOOL *)a5 setOutIsTokenAuth:(BOOL *)a6 setOutIsAuthError:(BOOL *)a7;
- (id)_checkAssetCollectionFiles:(id)a0;
- (id)_checkObjectWrappers:(id)a0;
- (id)_collectionWithNoDerivatives:(id)a0;
- (void)_didFinishUsingAssetCollections:(id)a0;
- (id)_invalidStreamsResponseErrorUnderlyingError:(id)a0;
- (BOOL)_isAllowedToUpload;
- (void)_quarantineOrDiscardWrappers:(id)a0 withError:(id)a1;
- (void)_refreshServerSideConfiguredParameters;
- (void)_registerAllAssetsForWrapper:(id)a0;
- (void)_removeAssetFromFileHashMap:(id)a0;
- (void)_removeAssetsInAssetCollectionWrappersFromAssetMap:(id)a0;
- (void)_requestDerivatives;
- (void)_sendFilesToMMCS;
- (void)_sendMetadataToStreams;
- (void)_sendUploadComplete;
- (void)_serverSideConfigurationDidChange:(id)a0;
- (void)_updateMasterManifest;
- (BOOL)_verifyAssetFile:(id)a0;
- (void)computeHashForAsset:(id)a0;
- (BOOL)dequeueAssetCollectionWithGUIDs:(id)a0 outError:(id *)a1;
- (BOOL)enqueueAssetCollections:(id)a0 outError:(id *)a1;
- (void)publishStorageProtocol:(id)a0 didFinishUploadingAsset:(id)a1 error:(id)a2;
- (void)publishStorageProtocol:(id)a0 didFinishUsingFD:(int)a1 forAsset:(id)a2;
- (int)publishStorageProtocol:(id)a0 didRequestFDForAsset:(id)a1;
- (void)publishStorageProtocolDidFinishPublishingAllAssets:(id)a0;
- (void)publishStreamsProtocol:(id)a0 didFinishSendingUploadCompleteError:(id)a1;
- (void)publishStreamsProtocol:(id)a0 didFinishUploadingMetadataResponse:(id)a1 error:(id)a2;
- (void)publishStreamsProtocol:(id)a0 didReceiveAuthenticationError:(id)a1;
- (void)reenqueueQuarantinedAssetCollections;
- (void)submitAssetCollectionsForPublication:(id)a0 skipAssetCollections:(id)a1;

@end