private static class Requester {

private TLRPC.InputFileLocation location;

private Object[] args;

private String locationKey;

private boolean completed;

}

private static class CachedResult {

private TLObject response;

private long firstQueryTime;

}

private static class Waiter {

private String locationKey;

private String parentKey;

public Waiter(String loc, String parent) {

locationKey = loc;

parentKey = parent;

}

}

private HashMap<String, ArrayList<Requester>> locationRequester = new HashMap<>();

private HashMap<String, ArrayList<Requester>> parentRequester = new HashMap<>();

private HashMap<String, CachedResult> responseCache = new HashMap<>();

private HashMap<TLObject, Object[]> multiMediaCache = new HashMap<>();

private long lastCleanupTime = SystemClock.elapsedRealtime();

private ArrayList<Waiter> wallpaperWaiters = new ArrayList<>();

private ArrayList<Waiter> savedGifsWaiters = new ArrayList<>();

private ArrayList<Waiter> recentStickersWaiter = new ArrayList<>();

private ArrayList<Waiter> favStickersWaiter = new ArrayList<>();

private static volatile FileRefController[] Instance = new FileRefController[UserConfig.MAX_ACCOUNT_COUNT];

public static FileRefController getInstance(int num) {

FileRefController localInstance = Instance[num];

if (localInstance == null) {

synchronized (FileRefController.class) {

localInstance = Instance[num];

if (localInstance == null) {

Instance[num] = localInstance = new FileRefController(num);

}

}

}

return localInstance;

}

public FileRefController(int instance) {

super(instance);

}

public static String getKeyForParentObject(Object parentObject) {

if (parentObject instanceof StoriesController.BotPreview) {

StoriesController.BotPreview storyItem = (StoriesController.BotPreview) parentObject;

if (storyItem.list == null) {

FileLog.d("failed request reference can't find list in botpreview");

return null;

}

if (storyItem.media.document != null) {

return "botstory_doc_" + storyItem.media.document.id;

} else if (storyItem.media.photo != null) {

return "botstory_photo_" + storyItem.media.photo.id;

} else {

return "botstory_" + storyItem.id;

}

} else if (parentObject instanceof TL_stories.StoryItem) {

TL_stories.StoryItem storyItem = (TL_stories.StoryItem) parentObject;

if (storyItem.dialogId == 0) {

FileLog.d("failed request reference can't find dialogId");

return null;

}

return "story_" + storyItem.dialogId + "_" + storyItem.id;

} else if (parentObject instanceof TLRPC.TL_help_premiumPromo) {

return "premium_promo";

} else if (parentObject instanceof TLRPC.TL_availableReaction) {

return "available_reaction_" + ((TLRPC.TL_availableReaction) parentObject).reaction;

} else if (parentObject instanceof TL_bots.BotInfo) {

TL_bots.BotInfo botInfo = (TL_bots.BotInfo) parentObject;

return "bot_info_" + botInfo.user_id;

} else if (parentObject instanceof TLRPC.TL_attachMenuBot) {

TLRPC.TL_attachMenuBot bot = (TLRPC.TL_attachMenuBot) parentObject;

long botId = bot.bot_id;

return "attach_menu_bot_" + botId;

} else if (parentObject instanceof MessageObject) {

MessageObject messageObject = (MessageObject) parentObject;

long channelId = messageObject.getChannelId();

if (messageObject.type == MessageObject.TYPE_PAID_MEDIA && messageObject.messageOwner != null && messageObject.messageOwner.fwd_from != null && messageObject.messageOwner.fwd_from.from_id != null) {

channelId = DialogObject.getPeerDialogId(messageObject.messageOwner.fwd_from.from_id);

}

return "message" + messageObject.getRealId() + "_" + channelId + "_" + messageObject.scheduled + "_" + messageObject.getQuickReplyId();

} else if (parentObject instanceof TLRPC.Message) {

TLRPC.Message message = (TLRPC.Message) parentObject;

long channelId = message.peer_id != null ? message.peer_id.channel_id : 0;

return "message" + message.id + "_" + channelId + "_" + message.from_scheduled;

} else if (parentObject instanceof TLRPC.WebPage) {

TLRPC.WebPage webPage = (TLRPC.WebPage) parentObject;

return "webpage" + webPage.id;

} else if (parentObject instanceof TLRPC.User) {

TLRPC.User user = (TLRPC.User) parentObject;

return "user" + user.id;

} else if (parentObject instanceof TLRPC.Chat) {

TLRPC.Chat chat = (TLRPC.Chat) parentObject;

return "chat" + chat.id;

} else if (parentObject instanceof String) {

String string = (String) parentObject;

return "str" + string;

} else if (parentObject instanceof TLRPC.TL_messages_stickerSet) {

TLRPC.TL_messages_stickerSet stickerSet = (TLRPC.TL_messages_stickerSet) parentObject;

return "set" + stickerSet.set.id;

} else if (parentObject instanceof TLRPC.StickerSetCovered) {

TLRPC.StickerSetCovered stickerSet = (TLRPC.StickerSetCovered) parentObject;

return "set" + stickerSet.set.id;

} else if (parentObject instanceof TLRPC.InputStickerSet) {

TLRPC.InputStickerSet inputStickerSet = (TLRPC.InputStickerSet) parentObject;

return "set" + inputStickerSet.id;

} else if (parentObject instanceof TLRPC.TL_wallPaper) {

TLRPC.TL_wallPaper wallPaper = (TLRPC.TL_wallPaper) parentObject;

return "wallpaper" + wallPaper.id;

} else if (parentObject instanceof TLRPC.TL_theme) {

TLRPC.TL_theme theme = (TLRPC.TL_theme) parentObject;

return "theme" + theme.id;

}

return parentObject != null ? "" + parentObject : null;

}

public Pair<TLRPC.InputFileLocation, String> getLocationAndKey(Object parentObject, Object... args) {

if (args[0] instanceof TLRPC.TL_messages_sendMultiMedia) {

return null;

} else if (args[0] instanceof TLRPC.TL_messages_sendMedia && ((TLRPC.TL_messages_sendMedia) args[0]).media instanceof TLRPC.TL_inputMediaPaidMedia && parentObject instanceof ArrayList) {

return null;

} else if (args[0] instanceof TLRPC.TL_messages_sendMedia && ((TLRPC.TL_messages_sendMedia) args[0]).media instanceof TLRPC.TL_inputMediaPoll && parentObject instanceof ArrayList) {

return null;

} else if (args[0] instanceof TL_ephemeral.TL_sendMessage && ((TL_ephemeral.TL_sendMessage) args[0]).media instanceof TLRPC.TL_inputMediaPaidMedia && parentObject instanceof ArrayList) {

return null;

} else if (args[0] instanceof TL_ephemeral.TL_sendMessage && ((TL_ephemeral.TL_sendMessage) args[0]).media instanceof TLRPC.TL_inputMediaPoll && parentObject instanceof ArrayList) {

return null;

}

if (args[0] instanceof StoriesController.BotPreview) {

StoriesController.BotPreview storyItem = (StoriesController.BotPreview) args[0];

if (storyItem.media.document != null) {

final TLRPC.InputFileLocation location = new TLRPC.TL_inputDocumentFileLocation();

location.id = storyItem.media.document.id;

return new Pair<>(location, "botstory_doc_" + storyItem.media.document.id);

} else if (storyItem.media.photo != null) {

final TLRPC.InputFileLocation location = new TLRPC.TL_inputPhotoFileLocation();

location.id = storyItem.media.photo.id;

return new Pair<>(location, "botstory_photo_" + storyItem.media.photo.id);

} else {

final TLRPC.InputFileLocation location = new TLRPC.TL_inputDocumentFileLocation();

return new Pair<>(location, "botstory_" + storyItem.id);

}

} else if (args[0] instanceof TL_stories.TL_storyItem) {

TL_stories.TL_storyItem storyItem = (TL_stories.TL_storyItem) args[0];

final TLRPC.InputFileLocation location = new TLRPC.TL_inputDocumentFileLocation();

location.id = storyItem.media.document.id;

return new Pair<>(location, "story_" + storyItem.id);

} else if (args[0] instanceof TLRPC.TL_inputSingleMedia) {

TLRPC.TL_inputSingleMedia req = (TLRPC.TL_inputSingleMedia) args[0];

if (req.media instanceof TLRPC.TL_inputMediaDocument) {

TLRPC.TL_inputMediaDocument mediaDocument = (TLRPC.TL_inputMediaDocument) req.media;

final TLRPC.InputFileLocation location = new TLRPC.TL_inputDocumentFileLocation();

location.id = mediaDocument.id.id;

return new Pair<>(location, "file_" + mediaDocument.id.id);

} else if (req.media instanceof TLRPC.TL_inputMediaPhoto) {

TLRPC.TL_inputMediaPhoto mediaPhoto = (TLRPC.TL_inputMediaPhoto) req.media;

final TLRPC.InputFileLocation location = new TLRPC.TL_inputPhotoFileLocation();

location.id = mediaPhoto.id.id;

return new Pair<>(location, "photo_" + mediaPhoto.id.id);

}

} else if (args[0] instanceof TLRPC.TL_inputMediaDocument) {

TLRPC.TL_inputMediaDocument mediaDocument = (TLRPC.TL_inputMediaDocument) args[0];

final TLRPC.InputFileLocation location = new TLRPC.TL_inputDocumentFileLocation();

location.id = mediaDocument.id.id;

return new Pair<>(location, "file_" + mediaDocument.id.id);

} else if (args[0] instanceof TLRPC.TL_inputMediaPhoto) {

TLRPC.TL_inputMediaPhoto mediaPhoto = (TLRPC.TL_inputMediaPhoto) args[0];

final TLRPC.InputFileLocation location = new TLRPC.TL_inputPhotoFileLocation();

location.id = mediaPhoto.id.id;

return new Pair<>(location, "photo_" + mediaPhoto.id.id);

} else if (args[0] instanceof TLRPC.TL_messages_sendMedia) {

TLRPC.TL_messages_sendMedia req = (TLRPC.TL_messages_sendMedia) args[0];

if (req.media instanceof TLRPC.TL_inputMediaDocument) {

TLRPC.TL_inputMediaDocument mediaDocument = (TLRPC.TL_inputMediaDocument) req.media;

final TLRPC.InputFileLocation location = new TLRPC.TL_inputDocumentFileLocation();

location.id = mediaDocument.id.id;

return new Pair<>(location, "file_" + mediaDocument.id.id);

} else if (req.media instanceof TLRPC.TL_inputMediaPhoto) {

TLRPC.TL_inputMediaPhoto mediaPhoto = (TLRPC.TL_inputMediaPhoto) req.media;

final TLRPC.InputFileLocation location = new TLRPC.TL_inputPhotoFileLocation();

location.id = mediaPhoto.id.id;

return new Pair<>(location, "photo_" + mediaPhoto.id.id);

} else if (req.media instanceof TLRPC.TL_inputMediaPaidMedia) {

TLRPC.TL_inputMediaPaidMedia paidMedia = (TLRPC.TL_inputMediaPaidMedia) req.media;

if (parentObject instanceof ArrayList) {

/* processed earlier */

} else if (paidMedia.extended_media.size() == 1) {

TLRPC.InputMedia inputMedia = paidMedia.extended_media.get(0);

if (inputMedia instanceof TLRPC.TL_inputMediaDocument) {

TLRPC.TL_inputMediaDocument mediaDocument = (TLRPC.TL_inputMediaDocument) inputMedia;

final TLRPC.InputFileLocation location = new TLRPC.TL_inputDocumentFileLocation();

location.id = mediaDocument.id.id;

return new Pair<>(location, "file_" + mediaDocument.id.id);

} else if (inputMedia instanceof TLRPC.TL_inputMediaPhoto) {

TLRPC.TL_inputMediaPhoto mediaPhoto = (TLRPC.TL_inputMediaPhoto) inputMedia;

final TLRPC.InputFileLocation location = new TLRPC.TL_inputPhotoFileLocation();

location.id = mediaPhoto.id.id;

return new Pair<>(location, "photo_" + mediaPhoto.id.id);

}

}

}

} else if (args[0] instanceof TL_ephemeral.TL_sendMessage) {

TL_ephemeral.TL_sendMessage req = (TL_ephemeral.TL_sendMessage) args[0];

if (req.media instanceof TLRPC.TL_inputMediaDocument) {

TLRPC.TL_inputMediaDocument mediaDocument = (TLRPC.TL_inputMediaDocument) req.media;

final TLRPC.InputFileLocation location = new TLRPC.TL_inputDocumentFileLocation();

location.id = mediaDocument.id.id;

return new Pair<>(location, "file_" + mediaDocument.id.id);

} else if (req.media instanceof TLRPC.TL_inputMediaPhoto) {

TLRPC.TL_inputMediaPhoto mediaPhoto = (TLRPC.TL_inputMediaPhoto) req.media;

final TLRPC.InputFileLocation location = new TLRPC.TL_inputPhotoFileLocation();

location.id = mediaPhoto.id.id;

return new Pair<>(location, "photo_" + mediaPhoto.id.id);

} else if (req.media instanceof TLRPC.TL_inputMediaPaidMedia) {

TLRPC.TL_inputMediaPaidMedia paidMedia = (TLRPC.TL_inputMediaPaidMedia) req.media;

if (parentObject instanceof ArrayList) {

/* processed earlier */

} else if (paidMedia.extended_media.size() == 1) {

TLRPC.InputMedia inputMedia = paidMedia.extended_media.get(0);

if (inputMedia instanceof TLRPC.TL_inputMediaDocument) {

TLRPC.TL_inputMediaDocument mediaDocument = (TLRPC.TL_inputMediaDocument) inputMedia;

final TLRPC.InputFileLocation location = new TLRPC.TL_inputDocumentFileLocation();

location.id = mediaDocument.id.id;

return new Pair<>(location, "file_" + mediaDocument.id.id);

} else if (inputMedia instanceof TLRPC.TL_inputMediaPhoto) {

TLRPC.TL_inputMediaPhoto mediaPhoto = (TLRPC.TL_inputMediaPhoto) inputMedia;

final TLRPC.InputFileLocation location = new TLRPC.TL_inputPhotoFileLocation();

location.id = mediaPhoto.id.id;

return new Pair<>(location, "photo_" + mediaPhoto.id.id);

}

}

}

} else if (args[0] instanceof TLRPC.TL_messages_editMessage) {

TLRPC.TL_messages_editMessage req = (TLRPC.TL_messages_editMessage) args[0];

if (req.media instanceof TLRPC.TL_inputMediaDocument) {

TLRPC.TL_inputMediaDocument mediaDocument = (TLRPC.TL_inputMediaDocument) req.media;

final TLRPC.InputFileLocation location = new TLRPC.TL_inputDocumentFileLocation();

location.id = mediaDocument.id.id;

return new Pair<>(location, "file_" + mediaDocument.id.id);

} else if (req.media instanceof TLRPC.TL_inputMediaPhoto) {

TLRPC.TL_inputMediaPhoto mediaPhoto = (TLRPC.TL_inputMediaPhoto) req.media;

final TLRPC.InputFileLocation location = new TLRPC.TL_inputPhotoFileLocation();

location.id = mediaPhoto.id.id;

return new Pair<>(location, "photo_" + mediaPhoto.id.id);

}

} else if (args[0] instanceof TLRPC.InputPhoto) {

TLRPC.InputPhoto photo = (TLRPC.InputPhoto) args[0];

final TLRPC.InputFileLocation location = new TLRPC.TL_inputPhotoFileLocation();

location.id = photo.id;

return new Pair<>(location, "photo_" + photo.id);

} else if (args[0] instanceof TLRPC.InputDocument) {

TLRPC.InputDocument document = (TLRPC.InputDocument) args[0];

final TLRPC.InputFileLocation location = new TLRPC.TL_inputDocumentFileLocation();

location.id = document.id;

return new Pair<>(location, "file_" + document.id);

} else if (args[0] instanceof TLRPC.TL_messages_addPollAnswer) {

TLRPC.TL_messages_addPollAnswer req = (TLRPC.TL_messages_addPollAnswer) args[0];

if (req.answer.input_media instanceof TLRPC.TL_inputMediaDocument) {

TLRPC.TL_inputMediaDocument mediaDocument = (TLRPC.TL_inputMediaDocument) req.answer.input_media;

final TLRPC.InputFileLocation location = new TLRPC.TL_inputDocumentFileLocation();

location.id = mediaDocument.id.id;

return new Pair<>(location, "file_" + mediaDocument.id.id);

} else if (req.answer.input_media instanceof TLRPC.TL_inputMediaPhoto) {

TLRPC.TL_inputMediaPhoto mediaPhoto = (TLRPC.TL_inputMediaPhoto) req.answer.input_media;

final TLRPC.InputFileLocation location = new TLRPC.TL_inputPhotoFileLocation();

location.id = mediaPhoto.id.id;

return new Pair<>(location, "photo_" + mediaPhoto.id.id);

}

} else if (args[0] instanceof TLRPC.TL_messages_saveGif) {

TLRPC.TL_messages_saveGif req = (TLRPC.TL_messages_saveGif) args[0];

final TLRPC.InputFileLocation location = new TLRPC.TL_inputDocumentFileLocation();

location.id = req.id.id;

return new Pair<>(location, "file_" + req.id.id);

} else if (args[0] instanceof TLRPC.TL_messages_saveRecentSticker) {

TLRPC.TL_messages_saveRecentSticker req = (TLRPC.TL_messages_saveRecentSticker) args[0];

final TLRPC.InputFileLocation location = new TLRPC.TL_inputDocumentFileLocation();

location.id = req.id.id;

return new Pair<>(location, "file_" + req.id.id);

} else if (args[0] instanceof TLRPC.TL_stickers_addStickerToSet) {

TLRPC.TL_stickers_addStickerToSet req = (TLRPC.TL_stickers_addStickerToSet) args[0];

final TLRPC.InputFileLocation location = new TLRPC.TL_inputDocumentFileLocation();

location.id = req.sticker.document.id;

return new Pair<>(location, "file_" + req.sticker.document.id);

} else if (args[0] instanceof TLRPC.TL_messages_faveSticker) {

TLRPC.TL_messages_faveSticker req = (TLRPC.TL_messages_faveSticker) args[0];

final TLRPC.InputFileLocation location = new TLRPC.TL_inputDocumentFileLocation();

location.id = req.id.id;

return new Pair<>(location, "file_" + req.id.id);

} else if (args[0] instanceof TLRPC.TL_messages_getAttachedStickers) {

TLRPC.TL_messages_getAttachedStickers req = (TLRPC.TL_messages_getAttachedStickers) args[0];

if (req.media instanceof TLRPC.TL_inputStickeredMediaDocument) {

TLRPC.TL_inputStickeredMediaDocument mediaDocument = (TLRPC.TL_inputStickeredMediaDocument) req.media;

final TLRPC.InputFileLocation location = new TLRPC.TL_inputDocumentFileLocation();

location.id = mediaDocument.id.id;

return new Pair<>(location, "file_" + mediaDocument.id.id);

} else if (req.media instanceof TLRPC.TL_inputStickeredMediaPhoto) {

TLRPC.TL_inputStickeredMediaPhoto mediaPhoto = (TLRPC.TL_inputStickeredMediaPhoto) req.media;

final TLRPC.InputFileLocation location = new TLRPC.TL_inputPhotoFileLocation();

location.id = mediaPhoto.id.id;

return new Pair<>(location, "photo_" + mediaPhoto.id.id);

}

} else if (args[0] instanceof TLRPC.TL_inputFileLocation) {

final TLRPC.InputFileLocation location = (TLRPC.TL_inputFileLocation) args[0];

return new Pair<>(location, "loc_" + location.local_id + "_" + location.volume_id);

} else if (args[0] instanceof TLRPC.TL_inputDocumentFileLocation) {

final TLRPC.InputFileLocation location = (TLRPC.TL_inputDocumentFileLocation) args[0];

return new Pair<>(location, "file_" + location.id);

} else if (args[0] instanceof TLRPC.TL_inputPhotoFileLocation) {

final TLRPC.InputFileLocation location = (TLRPC.TL_inputPhotoFileLocation) args[0];

return new Pair<>(location, "photo_" + location.id);

} else if (args[0] instanceof TLRPC.TL_inputPeerPhotoFileLocation) {

final TLRPC.InputFileLocation location = (TLRPC.TL_inputPeerPhotoFileLocation) args[0];

return new Pair<>(location, "avatar_" + location.id);

}

return null;

}

@SuppressWarnings("unchecked")

public void requestReference(Object parentObject, Object... args) {

if (BuildVars.LOGS_ENABLED) {

FileLog.d("start loading request reference parent " + getObjectString(parentObject) + " args = " + args[0]);

}

if (args[0] instanceof TLRPC.TL_messages_sendMultiMedia) {

TLRPC.TL_messages_sendMultiMedia req = (TLRPC.TL_messages_sendMultiMedia) args[0];

ArrayList<Object> parentObjects = (ArrayList<Object>) parentObject;

multiMediaCache.put(req, args);

for (int a = 0, size = req.multi_media.size(); a < size; a++) {

TLRPC.TL_inputSingleMedia media = req.multi_media.get(a);

parentObject = parentObjects.get(a);

if (parentObject == null) {

continue;

}

requestReference(parentObject, media, req);

}

return;

} else if (args[0] instanceof TLRPC.TL_messages_sendMedia && ((TLRPC.TL_messages_sendMedia) args[0]).media instanceof TLRPC.TL_inputMediaPaidMedia && parentObject instanceof ArrayList) {

TLRPC.TL_messages_sendMedia req = (TLRPC.TL_messages_sendMedia) args[0];

TLRPC.TL_inputMediaPaidMedia paidMedia = (TLRPC.TL_inputMediaPaidMedia) req.media;

ArrayList<Object> parentObjects = (ArrayList<Object>) parentObject;

multiMediaCache.put(req, args);

for (int a = 0, size = paidMedia.extended_media.size(); a < size; a++) {

TLRPC.InputMedia media = paidMedia.extended_media.get(a);

parentObject = parentObjects.get(a);

if (parentObject == null) {

continue;

}

requestReference(parentObject, media, req);

}

return;

} else if (args[0] instanceof TL_ephemeral.TL_sendMessage && ((TL_ephemeral.TL_sendMessage) args[0]).media instanceof TLRPC.TL_inputMediaPaidMedia && parentObject instanceof ArrayList) {

TL_ephemeral.TL_sendMessage req = (TL_ephemeral.TL_sendMessage) args[0];

TLRPC.TL_inputMediaPaidMedia paidMedia = (TLRPC.TL_inputMediaPaidMedia) req.media;

ArrayList<Object> parentObjects = (ArrayList<Object>) parentObject;

multiMediaCache.put(req, args);

for (int a = 0, size = paidMedia.extended_media.size(); a < size; a++) {

TLRPC.InputMedia media = paidMedia.extended_media.get(a);

parentObject = parentObjects.get(a);

if (parentObject == null) {

continue;

}

requestReference(parentObject, media, req);

}

return;

}

Pair<TLRPC.InputFileLocation, String> locationAndKey = getLocationAndKey(parentObject, args);

if (locationAndKey == null) {

sendErrorToObject(args, 0);

return;

}

TLRPC.InputFileLocation location = locationAndKey.first;

String locationKey = locationAndKey.second;

if (parentObject instanceof MessageObject) {

MessageObject messageObject = (MessageObject) parentObject;

if (messageObject.getRealId() < 0 && messageObject.messageOwner != null && messageObject.messageOwner.media != null && messageObject.messageOwner.media.webpage != null) {

parentObject = messageObject.messageOwner.media.webpage;

}

}

String parentKey = getKeyForParentObject(parentObject);

if (parentKey == null) {

sendErrorToObject(args, 0);

return;

}

Requester requester = new Requester();

requester.args = args;

requester.location = location;

requester.locationKey = locationKey;

int added = 0;

ArrayList<Requester> arrayList = locationRequester.get(locationKey);

if (arrayList == null) {

arrayList = new ArrayList<>();

locationRequester.put(locationKey, arrayList);

added++;

}

arrayList.add(requester);

arrayList = parentRequester.get(parentKey);

if (arrayList == null) {

arrayList = new ArrayList<>();

parentRequester.put(parentKey, arrayList);

added++;

}

arrayList.add(requester);

if (added != 2) {

return;

}

String cacheKey = locationKey;

if (parentObject instanceof String) {

String string = (String) parentObject;

if ("wallpaper".equals(string)) {

cacheKey = "wallpaper";

} else if (string.startsWith("gif")) {

cacheKey = "gif";

} else if ("recent".equals(string)) {

cacheKey = "recent";

} else if ("fav".equals(string)) {

cacheKey = "fav";

} else if ("update".equals(string)) {

cacheKey = "update";

}

}

cleanupCache();

CachedResult cachedResult = getCachedResponse(cacheKey);

if (cachedResult != null) {

if (!onRequestComplete(locationKey, parentKey, cachedResult.response, null,false, true)) {

responseCache.remove(locationKey);

} else {

return;

}

} else {

cachedResult = getCachedResponse(parentKey);

if (cachedResult != null) {

if (!onRequestComplete(locationKey, parentKey, cachedResult.response, null, false, true)) {

responseCache.remove(parentKey);

} else {

return;

}

}

}

requestReferenceFromServer(parentObject, locationKey, parentKey, args);

}

private String getObjectString(Object parentObject) {

if (parentObject instanceof String) {

return (String) parentObject;

}

if (parentObject instanceof TL_stories.StoryItem) {

TL_stories.StoryItem storyItem = (TL_stories.StoryItem) parentObject;

return "story(dialogId=" + storyItem.dialogId + " id=" + storyItem.id + ")";

}

if (parentObject instanceof MessageObject) {

MessageObject messageObject = (MessageObject) parentObject;

return "message(dialogId=" + messageObject.getDialogId() + "messageId" + messageObject.getId() + ")";

}

if (parentObject == null) {

return null;

}

return parentObject.getClass().getSimpleName();

}

private void broadcastWaitersData(ArrayList<Waiter> waiters, TLObject response, TLRPC.TL_error error) {

for (int a = 0, N = waiters.size(); a < N; a++) {

Waiter waiter = waiters.get(a);

onRequestComplete(waiter.locationKey, waiter.parentKey, response, error, a == N - 1, false);

}

waiters.clear();

}

private void requestReferenceFromServer(Object parentObject, String locationKey, String parentKey, Object[] args) {

if (parentObject instanceof StoriesController.BotPreview) {

StoriesController.BotPreview storyItem = (StoriesController.BotPreview) parentObject;

if (storyItem.list == null) {

sendErrorToObject(args, 0);

return;

}

storyItem.list.requestReference(storyItem, newStoryItem -> {

Utilities.stageQueue.postRunnable(() -> {

onRequestComplete(locationKey, parentKey, newStoryItem, null, true, false);

});

});

} else if (parentObject instanceof TL_stories.StoryItem) {

TL_stories.StoryItem storyItem = (TL_stories.StoryItem) parentObject;

TL_stories.TL_stories_getStoriesByID req = new TL_stories.TL_stories_getStoriesByID();

req.peer = getMessagesController().getInputPeer(storyItem.dialogId);

req.id.add(storyItem.id);

getConnectionsManager().sendRequest(req, (response, error) -> {

onRequestComplete(locationKey, parentKey, response, error, true, false);

});

} else if (parentObject instanceof TLRPC.TL_help_premiumPromo) {

TLRPC.TL_help_getPremiumPromo req = new TLRPC.TL_help_getPremiumPromo();

getConnectionsManager().sendRequest(req, (response, error) -> {

int date = (int) (System.currentTimeMillis() / 1000);

if (response instanceof TLRPC.TL_help_premiumPromo) {

TLRPC.TL_help_premiumPromo r = (TLRPC.TL_help_premiumPromo) response;

getMediaDataController().processLoadedPremiumPromo(r, date, false);

}

onRequestComplete(locationKey, parentKey, response, error, true, false);

});

} else if (parentObject instanceof TLRPC.TL_availableReaction) {

TLRPC.TL_messages_getAvailableReactions req = new TLRPC.TL_messages_getAvailableReactions();

req.hash = 0;

getConnectionsManager().sendRequest(req, (response, error) -> onRequestComplete(locationKey, parentKey, response, error, true, false));

} else if (parentObject instanceof TL_bots.BotInfo) {

TL_bots.BotInfo botInfo = (TL_bots.BotInfo) parentObject;

TLRPC.TL_users_getFullUser req = new TLRPC.TL_users_getFullUser();

req.id = getMessagesController().getInputUser(botInfo.user_id);

getConnectionsManager().sendRequest(req, (response, error) -> onRequestComplete(locationKey, parentKey, response, error, true, false));

} else if (parentObject instanceof TLRPC.TL_attachMenuBot) {

TLRPC.TL_attachMenuBot bot = (TLRPC.TL_attachMenuBot) parentObject;

TLRPC.TL_messages_getAttachMenuBot req = new TLRPC.TL_messages_getAttachMenuBot();

req.bot = getMessagesController().getInputUser(bot.bot_id);

getConnectionsManager().sendRequest(req, (response, error) -> onRequestComplete(locationKey, parentKey, response, error, true, false));

} else if (parentObject instanceof MessageObject) {

MessageObject messageObject = (MessageObject) parentObject;

long channelId = messageObject.getChannelId();

TLRPC.InputPeer richMessagePeer = getMessagesController().getInputPeer(messageObject.getDialogId());

if (messageObject.scheduled) {

TLRPC.TL_messages_getScheduledMessages req = new TLRPC.TL_messages_getScheduledMessages();

req.peer = getMessagesController().getInputPeer(messageObject.getDialogId());

req.id.add(messageObject.getRealId());

getConnectionsManager().sendRequest(req, (response, error) -> onRequestComplete(locationKey, parentKey, response, error, true, false));

} else if (messageObject.isQuickReply()) {

TLRPC.TL_messages_getQuickReplyMessages req = new TLRPC.TL_messages_getQuickReplyMessages();

req.shortcut_id = messageObject.getQuickReplyId();

req.flags |= 1;

req.id.add(messageObject.getRealId());

getConnectionsManager().sendRequest(req, (response, error) -> onRequestComplete(locationKey, parentKey, response, error, true, false));

} else if (messageObject.messageOwner != null && messageObject.messageOwner.rich_message != null && richMessagePeer != null) {

TL_iv.getRichMessage req = new TL_iv.getRichMessage();

req.peer = richMessagePeer;

req.id = messageObject.getRealId();

getConnectionsManager().sendRequest(req, (response, error) -> onRequestComplete(locationKey, parentKey, response, error, true, false));

} else if (channelId != 0) {

TLRPC.TL_channels_getMessages req = new TLRPC.TL_channels_getMessages();

req.channel = getMessagesController().getInputChannel(channelId);

req.id.add(messageObject.getRealId());

getConnectionsManager().sendRequest(req, (response, error) -> onRequestComplete(locationKey, parentKey, response, error, true, false));

} else {

TLRPC.TL_messages_getMessages req = new TLRPC.TL_messages_getMessages();

req.id.add(messageObject.getRealId());

getConnectionsManager().sendRequest(req, (response, error) -> onRequestComplete(locationKey, parentKey, response, error, true, false));

}

} else if (parentObject instanceof TLRPC.TL_wallPaper) {

TLRPC.TL_wallPaper wallPaper = (TLRPC.TL_wallPaper) parentObject;

TL_account.getWallPaper req = new TL_account.getWallPaper();

TLRPC.TL_inputWallPaper inputWallPaper = new TLRPC.TL_inputWallPaper();

inputWallPaper.id = wallPaper.id;

inputWallPaper.access_hash = wallPaper.access_hash;

req.wallpaper = inputWallPaper;

getConnectionsManager().sendRequest(req, (response, error) -> onRequestComplete(locationKey, parentKey, response, error, true, false));

} else if (parentObject instanceof TLRPC.TL_theme) {

TLRPC.TL_theme theme = (TLRPC.TL_theme) parentObject;

TL_account.getTheme req = new TL_account.getTheme();

TLRPC.TL_inputTheme inputTheme = new TLRPC.TL_inputTheme();

inputTheme.id = theme.id;

inputTheme.access_hash = theme.access_hash;

req.theme = inputTheme;

req.format = "android";

getConnectionsManager().sendRequest(req, (response, error) -> onRequestComplete(locationKey, parentKey, response, error, true, false));

} else if (parentObject instanceof TLRPC.WebPage) {

TLRPC.WebPage webPage = (TLRPC.WebPage) parentObject;

TLRPC.TL_messages_getWebPage req = new TLRPC.TL_messages_getWebPage();

req.url = webPage.url;

req.hash = 0;

getConnectionsManager().sendRequest(req, (response, error) -> onRequestComplete(locationKey, parentKey, response, error, true, false));

} else if (parentObject instanceof TLRPC.User) {

TLRPC.User user = (TLRPC.User) parentObject;

TLRPC.TL_users_getUsers req = new TLRPC.TL_users_getUsers();

req.id.add(getMessagesController().getInputUser(user));

getConnectionsManager().sendRequest(req, (response, error) -> onRequestComplete(locationKey, parentKey, response, error, true, false));

} else if (parentObject instanceof TLRPC.Chat) {

TLRPC.Chat chat = (TLRPC.Chat) parentObject;

if (chat instanceof TLRPC.TL_chat) {

TLRPC.TL_messages_getChats req = new TLRPC.TL_messages_getChats();

req.id.add(chat.id);

getConnectionsManager().sendRequest(req, (response, error) -> onRequestComplete(locationKey, parentKey, response, error, true, false));

} else if (chat instanceof TLRPC.TL_channel || chat instanceof TLRPC.TL_community) {

TLRPC.TL_channels_getChannels req = new TLRPC.TL_channels_getChannels();

req.id.add(MessagesController.getInputChannel(chat));

getConnectionsManager().sendRequest(req, (response, error) -> onRequestComplete(locationKey, parentKey, response, error, true, false));

}

} else if (parentObject instanceof String) {

String string = (String) parentObject;

if ("wallpaper".equals(string)) {

if (wallpaperWaiters.isEmpty()) {

TL_account.getWallPapers req = new TL_account.getWallPapers();

getConnectionsManager().sendRequest(req, (response, error) -> broadcastWaitersData(wallpaperWaiters, response, error));

}

wallpaperWaiters.add(new Waiter(locationKey, parentKey));

} else if (string.startsWith("gif")) {

if (savedGifsWaiters.isEmpty()) {

TLRPC.TL_messages_getSavedGifs req = new TLRPC.TL_messages_getSavedGifs();

getConnectionsManager().sendRequest(req, (response, error) -> broadcastWaitersData(savedGifsWaiters, response, error));

}

savedGifsWaiters.add(new Waiter(locationKey, parentKey));

} else if ("recent".equals(string)) {

if (recentStickersWaiter.isEmpty()) {

TLRPC.TL_messages_getRecentStickers req = new TLRPC.TL_messages_getRecentStickers();

getConnectionsManager().sendRequest(req, (response, error) -> broadcastWaitersData(recentStickersWaiter, response, error));

}

recentStickersWaiter.add(new Waiter(locationKey, parentKey));

} else if ("fav".equals(string)) {

if (favStickersWaiter.isEmpty()) {

TLRPC.TL_messages_getFavedStickers req = new TLRPC.TL_messages_getFavedStickers();

getConnectionsManager().sendRequest(req, (response, error) -> broadcastWaitersData(favStickersWaiter, response, error));

}

favStickersWaiter.add(new Waiter(locationKey, parentKey));

} else if ("update".equals(string)) {

TLRPC.TL_help_getAppUpdate req = new TLRPC.TL_help_getAppUpdate();

try {

req.source = ApplicationLoader.applicationContext.getPackageManager().getInstallerPackageName(ApplicationLoader.applicationContext.getPackageName());

} catch (Exception ignore) {

}

if (req.source == null) {

req.source = "";

}

getConnectionsManager().sendRequest(req, (response, error) -> onRequestComplete(locationKey, parentKey, response, error, true, false));

} else if (string.startsWith("avatar_")) {

long id = Utilities.parseLong(string);

if (id > 0) {

TLRPC.TL_photos_getUserPhotos req = new TLRPC.TL_photos_getUserPhotos();

req.limit = 80;

req.offset = 0;

req.max_id = 0;

req.user_id = getMessagesController().getInputUser(id);

getConnectionsManager().sendRequest(req, (response, error) -> onRequestComplete(locationKey, parentKey, response, error, true, false));

} else {

TLRPC.TL_messages_search req = new TLRPC.TL_messages_search();

req.filter = new TLRPC.TL_inputMessagesFilterChatPhotos();

req.limit = 80;

req.offset_id = 0;

req.q = "";

req.peer = getMessagesController().getInputPeer(id);

getConnectionsManager().sendRequest(req, (response, error) -> onRequestComplete(locationKey, parentKey, response, error, true, false));

}

} else if (string.startsWith("sent_")) {

String[] params = string.split("_");

if (params.length >= 3) {

long channelId = Utilities.parseLong(params[1]);

if (channelId != 0) {

TLRPC.TL_channels_getMessages req = new TLRPC.TL_channels_getMessages();

req.channel = getMessagesController().getInputChannel(channelId);

req.id.add(Utilities.parseInt(params[2]));

getConnectionsManager().sendRequest(req, (response, error) -> onRequestComplete(locationKey, parentKey, response, error, false, false));

} else {

TLRPC.TL_messages_getMessages req = new TLRPC.TL_messages_getMessages();

req.id.add(Utilities.parseInt(params[2]));

getConnectionsManager().sendRequest(req, (response, error) -> onRequestComplete(locationKey, parentKey, response, error, false, false));

}

} else {

sendErrorToObject(args, 0);

}

} else {

sendErrorToObject(args, 0);

}

} else if (parentObject instanceof TLRPC.TL_messages_stickerSet) {

TLRPC.TL_messages_stickerSet stickerSet = (TLRPC.TL_messages_stickerSet) parentObject;

TLRPC.TL_messages_getStickerSet req = new TLRPC.TL_messages_getStickerSet();

req.stickerset = new TLRPC.TL_inputStickerSetID();

req.stickerset.id = stickerSet.set.id;

req.stickerset.access_hash = stickerSet.set.access_hash;

getConnectionsManager().sendRequest(req, (response, error) -> onRequestComplete(locationKey, parentKey, response, error, true, false));

} else if (parentObject instanceof TLRPC.StickerSetCovered) {

TLRPC.StickerSetCovered stickerSet = (TLRPC.StickerSetCovered) parentObject;

TLRPC.TL_messages_getStickerSet req = new TLRPC.TL_messages_getStickerSet();

req.stickerset = new TLRPC.TL_inputStickerSetID();

req.stickerset.id = stickerSet.set.id;

req.stickerset.access_hash = stickerSet.set.access_hash;

getConnectionsManager().sendRequest(req, (response, error) -> onRequestComplete(locationKey, parentKey, response, error, true, false));

} else if (parentObject instanceof TLRPC.InputStickerSet) {

TLRPC.TL_messages_getStickerSet req = new TLRPC.TL_messages_getStickerSet();

req.stickerset = (TLRPC.InputStickerSet) parentObject;

getConnectionsManager().sendRequest(req, (response, error) -> onRequestComplete(locationKey, parentKey, response, error, true, false));

} else {

sendErrorToObject(args, 0);

}

}

private boolean isSameReference(byte[] oldRef, byte[] newRef) {

return Arrays.equals(oldRef, newRef);

}

@SuppressWarnings("unchecked")

private boolean onUpdateObjectReference(Requester requester, byte[] file_reference, TLRPC.InputFileLocation locationReplacement, boolean fromCache) {

if (BuildVars.DEBUG_VERSION) {

FileLog.d("fileref updated for " + requester.args[0] + " " + requester.locationKey);

}

if (requester.args[0] instanceof TL_stories.TL_storyItem) {

TL_stories.TL_storyItem storyItem = (TL_stories.TL_storyItem) requester.args[0];

storyItem.media.document.file_reference = file_reference;

return true;

} else if (requester.args[0] instanceof TLRPC.TL_inputSingleMedia) {

TLRPC.TL_messages_sendMultiMedia multiMedia = (TLRPC.TL_messages_sendMultiMedia) requester.args[1];

Object[] objects = multiMediaCache.get(multiMedia);

if (objects == null) {

return true;

}

TLRPC.TL_inputSingleMedia req = (TLRPC.TL_inputSingleMedia) requester.args[0];

if (req.media instanceof TLRPC.TL_inputMediaDocument) {

TLRPC.TL_inputMediaDocument mediaDocument = (TLRPC.TL_inputMediaDocument) req.media;

if (fromCache && isSameReference(mediaDocument.id.file_reference, file_reference)) {

return false;

}

mediaDocument.id.file_reference = file_reference;

} else if (req.media instanceof TLRPC.TL_inputMediaPhoto) {

TLRPC.TL_inputMediaPhoto mediaPhoto = (TLRPC.TL_inputMediaPhoto) req.media;

if (fromCache && isSameReference(mediaPhoto.id.file_reference, file_reference)) {

return false;

}

mediaPhoto.id.file_reference = file_reference;

}

int index = multiMedia.multi_media.indexOf(req);

if (index < 0) {

return true;

}

ArrayList<Object> parentObjects = (ArrayList<Object>) objects[3];

parentObjects.set(index, null);

boolean done = true;

for (int a = 0, size; a < parentObjects.size(); a++) {

if (parentObjects.get(a) != null) {

done = false;

}

}

if (done) {

multiMediaCache.remove(multiMedia);

AndroidUtilities.runOnUIThread(() -> getSendMessagesHelper().performSendMessageRequestMulti(multiMedia, (ArrayList<MessageObject>) objects[1], (ArrayList<String>) objects[2], null, (SendMessagesHelper.DelayedMessage) objects[4], (Boolean) objects[5]));

}

} else if (requester.args.length >= 2 && requester.args[1] instanceof TLRPC.TL_messages_sendMedia && ((TLRPC.TL_messages_sendMedia) requester.args[1]).media instanceof TLRPC.TL_inputMediaPaidMedia && (requester.args[0] instanceof TLRPC.TL_inputMediaPhoto || requester.args[0] instanceof TLRPC.TL_inputMediaDocument)) {

TLRPC.TL_messages_sendMedia sendMedia = (TLRPC.TL_messages_sendMedia) requester.args[1];

Object[] objects = multiMediaCache.get(sendMedia);

if (objects == null) {

return true;

}

TLRPC.InputMedia inputMedia = null;

if (requester.args[0] instanceof TLRPC.TL_inputMediaDocument) {

TLRPC.TL_inputMediaDocument mediaDocument = (TLRPC.TL_inputMediaDocument) requester.args[0];

inputMedia = mediaDocument;

if (fromCache && isSameReference(mediaDocument.id.file_reference, file_reference)) {

return false;

}

mediaDocument.id.file_reference = file_reference;

} else if (requester.args[0] instanceof TLRPC.TL_inputMediaPhoto) {

TLRPC.TL_inputMediaPhoto mediaPhoto = (TLRPC.TL_inputMediaPhoto) requester.args[0];

inputMedia = mediaPhoto;

if (fromCache && isSameReference(mediaPhoto.id.file_reference, file_reference)) {

return false;

}

mediaPhoto.id.file_reference = file_reference;

}

TLRPC.TL_inputMediaPaidMedia paidMedia = (TLRPC.TL_inputMediaPaidMedia) sendMedia.media;

int index = paidMedia.extended_media.indexOf(inputMedia);

if (index < 0) {

return true;

}

ArrayList<Object> parentObjects = (ArrayList<Object>) objects[3];

parentObjects.set(index, null);

boolean done = true;

for (int a = 0, size; a < parentObjects.size(); a++) {

if (parentObjects.get(a) != null) {

done = false;

}

}

if (done) {

multiMediaCache.remove(sendMedia);

AndroidUtilities.runOnUIThread(() -> getSendMessagesHelper().performSendMessageRequestMulti(sendMedia, (ArrayList<MessageObject>) objects[1], (ArrayList<String>) objects[2], null, (SendMessagesHelper.DelayedMessage) objects[4], (Boolean) objects[5]));

}

} else if (requester.args.length >= 2 && requester.args[1] instanceof TL_ephemeral.TL_sendMessage && ((TL_ephemeral.TL_sendMessage) requester.args[1]).media instanceof TLRPC.TL_inputMediaPaidMedia && (requester.args[0] instanceof TLRPC.TL_inputMediaPhoto || requester.args[0] instanceof TLRPC.TL_inputMediaDocument)) {

TL_ephemeral.TL_sendMessage sendMedia = (TL_ephemeral.TL_sendMessage) requester.args[1];

Object[] objects = multiMediaCache.get(sendMedia);

if (objects == null) {

return true;

}

TLRPC.InputMedia inputMedia = null;

if (requester.args[0] instanceof TLRPC.TL_inputMediaDocument) {

TLRPC.TL_inputMediaDocument mediaDocument = (TLRPC.TL_inputMediaDocument) requester.args[0];

inputMedia = mediaDocument;

if (fromCache && isSameReference(mediaDocument.id.file_reference, file_reference)) {

return false;

}

mediaDocument.id.file_reference = file_reference;

} else if (requester.args[0] instanceof TLRPC.TL_inputMediaPhoto) {

TLRPC.TL_inputMediaPhoto mediaPhoto = (TLRPC.TL_inputMediaPhoto) requester.args[0];

inputMedia = mediaPhoto;

if (fromCache && isSameReference(mediaPhoto.id.file_reference, file_reference)) {

return false;

}

mediaPhoto.id.file_reference = file_reference;

}

TLRPC.TL_inputMediaPaidMedia paidMedia = (TLRPC.TL_inputMediaPaidMedia) sendMedia.media;

int index = paidMedia.extended_media.indexOf(inputMedia);

if (index < 0) {

return true;

}

ArrayList<Object> parentObjects = (ArrayList<Object>) objects[3];

parentObjects.set(index, null);

boolean done = true;

for (int a = 0, size; a < parentObjects.size(); a++) {

if (parentObjects.get(a) != null) {

done = false;

}

}

if (done) {

multiMediaCache.remove(sendMedia);

AndroidUtilities.runOnUIThread(() -> getSendMessagesHelper().performSendMessageRequestMulti(sendMedia, (ArrayList<MessageObject>) objects[1], (ArrayList<String>) objects[2], null, (SendMessagesHelper.DelayedMessage) objects[4], (Boolean) objects[5]));

}

} else if (requester.args[0] instanceof TLRPC.TL_messages_sendMedia) {