@class EMMailboxRepository, NSString, NSArray, NSURL, EFLazyCache, NSHashTable, EMRemoteConnectionRecoveryAssertion, NSObject, EFPromise, EFFuture, NSMapTable, NSCache;
@protocol OS_os_log, EMVIPManager;

@interface EMMessageRepository : EMRepository <EFFutureDelegate, EFLoggable> {
    NSMapTable *_observedMessageListItemCache;
    NSMapTable *_unobservedMessageListItemCache;
    NSMapTable *_wrappedObserversByActualObserver;
    NSHashTable *_recoverableObservers;
    struct os_unfair_lock_s { unsigned int _os_unfair_lock_opaque; } _messageListItemCacheLock;
    struct os_unfair_lock_s { unsigned int _os_unfair_lock_opaque; } _observersLock;
    EMRemoteConnectionRecoveryAssertion *_connectionRecoveryAssertion;
}

@property (class, readonly) NSObject<OS_os_log> *log;

@property (readonly, copy) NSArray *currentObservers;
@property (readonly, nonatomic) id<EMVIPManager> vipManager;
@property (retain, nonatomic) NSCache *queryCountCache;
@property (retain, nonatomic) NSURL *cacheURL;
@property (retain, nonatomic) EFPromise *remoteContentCachePromise;
@property (retain, nonatomic) EFLazyCache *brandIndicatorsCache;
@property (readonly, nonatomic) EMMailboxRepository *mailboxRepository;
@property (readonly, nonatomic) EFFuture *remoteContentURLCache;
@property (readonly) unsigned long long hash;
@property (readonly) Class superclass;
@property (readonly, copy) NSString *description;
@property (readonly, copy) NSString *debugDescription;

+ (id)remoteInterface;
+ (id)signpostLog;
+ (void)addValidSortDescriptorsToEMQuery;

- (unsigned long long)signpostID;
- (void)dealloc;
- (void)_vipsDidChange:(id)a0;
- (id)initInternal;
- (void)noteViewOfRemoteContentLinks:(id)a0;
- (void).cxx_destruct;
- (void)_blockedSendersDidChange:(id)a0;
- (id)cachedMetadataJSONForKey:(id)a0 messageID:(id)a1;
- (void)setCachedMetadataJSON:(id)a0 forKey:(id)a1 messageID:(id)a2;
- (id)messageForObjectID:(id)a0;
- (void)performMessageChangeAction:(id)a0;
- (id)performMessageChangeActionReturningUndoAction:(id)a0;
- (void)didFinishBlockingMainThreadForFuture:(id)a0;
- (void)didStartBlockingMainThreadForFuture:(id)a0;
- (void)resetAllPrecomputedThreadScopes;
- (id)_messageListItemsForObjectIDs:(id)a0 observationIdentifier:(id)a1 checkCache:(BOOL)a2;
- (id)persistentIDForMessageObjectID:(id)a0;
- (BOOL)_anyObserver:(id)a0 containsObjectID:(id)a1;
- (void)_applyChangesToCachedObjects:(id)a0;
- (void)_broadcastMessageListItemChangesToObservers:(id /* block */)a0;
- (id)_cachedItemForItem:(id)a0 observers:(id)a1 validationBlock:(id /* block */)a2;
- (void)_detectChangesForMatchedAddedObjectIDs:(id)a0 observerationIdentifier:(id)a1 matchedChangesHandler:(id /* block */)a2;
- (id)_existingObservedItemForObjectID:(id)a0;
- (void)_notifyRecoverableObservers;
- (void)_removeItemsFromObservedItemsCacheIfNotObservedByObservers:(id)a0;
- (BOOL)_shouldActionUpdateObserversForDeletedObjectIDs:(id)a0;
- (void)_updateObserversForAction:(id)a0;
- (void)_updateObserversForDeletedObjectIDs:(id)a0;
- (void)_updateObserversForFlagChangeAction:(id)a0;
- (id)brandIndicatorForLocation:(id)a0;
- (void)getCachedMetadataJSONForKey:(id)a0 messageID:(id)a1 handler:(id /* block */)a2;
- (void)getRemoteContentURLInfoOrderedBy:(long long)a0 inReverseOrder:(BOOL)a1 limit:(long long)a2 completionHandler:(id /* block */)a3;
- (id)initWithRemoteConnection:(id)a0 mailboxRepository:(id)a1 vipManager:(id)a2;
- (void)isDataAccessible:(id /* block */)a0;
- (void)loadOlderMessagesForMailboxes:(id)a0;
- (id)messageForSearchableItemIdentifier:(id)a0;
- (id)messageListItemsForObjectIDs:(id)a0;
- (id)messageListItemsForObjectIDs:(id)a0 observationIdentifier:(id)a1;
- (id)messageObjectIDForURL:(id)a0;
- (id)messageObjectIDsForSearchableItemIdentifiers:(id)a0;
- (id)metadataForAddresses:(id)a0;
- (void)parseRemoteContentURLsFromMessageWithObjectID:(id)a0 completionHandler:(id /* block */)a1;
- (void)performCountQuery:(id)a0 completionHandler:(id /* block */)a1;
- (void)performOneTimeCodeMessageDeletionWithObjectID:(id)a0 afterDelay:(double)a1;
- (void)performQuery:(id)a0 limit:(long long)a1 completionHandler:(id /* block */)a2;
- (id)performQuery:(id)a0 withObserver:(id)a1;
- (id)predictMailboxForMovingMessages:(id)a0 completionHandler:(id /* block */)a1;
- (id)predictMailboxForMovingMessagesWithIDs:(id)a0 completionHandler:(id /* block */)a1;
- (void)refreshQueryWithObserver:(id)a0;
- (id)requestRepresentationForMessageWithID:(id)a0 options:(id)a1 delegate:(id)a2 completionHandler:(id /* block */)a3;
- (id)requestRepresentationForMessageWithID:(id)a0 requestID:(unsigned long long)a1 options:(id)a2 delegate:(id)a3 completionHandler:(id /* block */)a4;
- (void)requestRichLinkMetadataForRichLinkID:(id)a0 messageID:(id)a1 completionHandler:(id /* block */)a2;
- (void)setQueryCount:(id)a0 forQueryIdentifier:(id)a1;
- (void)setUpURLCacheWithMemoryCapacity:(unsigned long long)a0;
- (id)startCountingQuery:(id)a0 includingServerCountsForMailboxScope:(id)a1 withObserver:(id)a2;
- (id)startObservingOneTimeCodes:(id)a0;

@end