@ -13,6 +13,8 @@
#import "TSGroupThread . h "
#import "TSGroupThread . h "
#import < SignalServiceKit / ContactsUpdater . h >
#import < SignalServiceKit / ContactsUpdater . h >
#import < SignalServiceKit / Threading . h >
#import < SignalServiceKit / Threading . h >
#import < SignalServiceKit / OWSSignalService . h >
#import < SignalServiceKit / OWSMessageReceiver . h >
static Environment * environment = nil ;
static Environment * environment = nil ;
@ -23,6 +25,7 @@ static Environment *environment = nil;
callService = _callService ,
callService = _callService ,
contactsManager = _contactsManager ,
contactsManager = _contactsManager ,
contactsUpdater = _contactsUpdater ,
contactsUpdater = _contactsUpdater ,
messageFetcherJob = _messageFetcherJob ,
messageSender = _messageSender ,
messageSender = _messageSender ,
networkManager = _networkManager ,
networkManager = _networkManager ,
notificationsManager = _notificationsManager ,
notificationsManager = _notificationsManager ,
@ -137,6 +140,20 @@ static Environment *environment = nil;
return _networkManager ;
return _networkManager ;
}
}
- ( OWSMessageFetcherJob * ) messageFetcherJob
{
@ synchronized ( self )
{
if ( !_messageFetcherJob ) {
_messageFetcherJob =
[ [ OWSMessageFetcherJob alloc ] initWithMessageReceiver : [ OWSMessageReceiver sharedInstance ]
networkManager : self . networkManager
signalService : [ OWSSignalService sharedInstance ] ] ;
}
}
return _messageFetcherJob ;
}
- ( OWSMessageSender * ) messageSender
- ( OWSMessageSender * ) messageSender
{
{
OWSAssert ( _messageSender != nil ) ;
OWSAssert ( _messageSender != nil ) ;