杏彩体育 v1.0.1版本的 MD5 值为:f363e7619122f7bd90c8b2a2d9a7cb53
以下内容为反编译后的 OneCollectorIngestion.java 源代码,内容仅作参考
package com.microsoft.appcenter.ingestion;
import com.microsoft.appcenter.Constants;
import com.microsoft.appcenter.http.DefaultHttpClient;
import com.microsoft.appcenter.http.HttpClient;
import com.microsoft.appcenter.http.HttpUtils;
import com.microsoft.appcenter.http.ServiceCall;
import com.microsoft.appcenter.http.ServiceCallback;
import com.microsoft.appcenter.ingestion.models.Log;
import com.microsoft.appcenter.ingestion.models.LogContainer;
import com.microsoft.appcenter.ingestion.models.json.LogSerializer;
import com.microsoft.appcenter.ingestion.models.one.CommonSchemaLog;
import com.microsoft.appcenter.utils.AppCenterLog;
import com.microsoft.appcenter.utils.TicketCache;
import java.net.URL;
import java.util.HashMap;
import java.util.Iterator;
import java.util.LinkedHashSet;
import java.util.List;
import java.util.Map;
import java.util.UUID;
import org.json.JSONException;
import org.json.JSONObject;
public class OneCollectorIngestion extends AbstractAppCenterIngestion {
static final String API_KEY = "apikey";
private static final String CLIENT_VERSION_FORMAT = "ACS-Android-Java-no-%s-no";
static final String CLIENT_VERSION_KEY = "Client-Version";
private static final String CONTENT_TYPE_VALUE = "application/x-json-stream; charset=utf-8";
private static final String DEFAULT_LOG_URL = "https://mobile.events.data.microsoft.com/OneCollector/1.0";
static final String STRICT = "Strict";
static final String TICKETS = "Tickets";
static final String UPLOAD_TIME_KEY = "Upload-Time";
private final LogSerializer mLogSerializer;
public OneCollectorIngestion(HttpClient httpClient, LogSerializer logSerializer) {
super(httpClient, DEFAULT_LOG_URL);
this.mLogSerializer = logSerializer;
}
@Override
public ServiceCall sendAsync(String appSecret, UUID installId, LogContainer logContainer, ServiceCallback serviceCallback) throws IllegalArgumentException {
super.sendAsync(appSecret, installId, logContainer, serviceCallback);
HashMap hashMap = new HashMap();
LinkedHashSet<String> linkedHashSet = new LinkedHashSet();
for (Log log : logContainer.getLogs()) {
linkedHashSet.addAll(log.getTransmissionTargetTokens());
}
StringBuilder sb = new StringBuilder();
for (String str : linkedHashSet) {
sb.append(str);
sb.append(",");
}
if (!linkedHashSet.isEmpty()) {
sb.deleteCharAt(sb.length() - 1);
}
hashMap.put(API_KEY, sb.toString());
JSONObject jSONObject = new JSONObject();
Iterator<Log> it = logContainer.getLogs().iterator();
while (it.hasNext()) {
List<String> ticketKeys = ((CommonSchemaLog) it.next()).getExt().getProtocol().getTicketKeys();
if (ticketKeys != null) {
for (String str2 : ticketKeys) {
String ticket = TicketCache.getTicket(str2);
if (ticket != null) {
try {
jSONObject.put(str2, ticket);
} catch (JSONException e) {
AppCenterLog.error("AppCenter", "Cannot serialize tickets, sending log anonymously", e);
}
}
}
}
}
if (jSONObject.length() > 0) {
hashMap.put(TICKETS, jSONObject.toString());
if (Constants.APPLICATION_DEBUGGABLE) {
hashMap.put(STRICT, Boolean.TRUE.toString());
}
}
hashMap.put("Content-Type", CONTENT_TYPE_VALUE);
hashMap.put(CLIENT_VERSION_KEY, String.format(CLIENT_VERSION_FORMAT, "5.0.4"));
hashMap.put(UPLOAD_TIME_KEY, String.valueOf(System.currentTimeMillis()));
return getServiceCall(getLogUrl(), DefaultHttpClient.METHOD_POST, hashMap, new IngestionCallTemplate(this.mLogSerializer, logContainer), serviceCallback);
}
private static class IngestionCallTemplate implements HttpClient.CallTemplate {
private final LogContainer mLogContainer;
private final LogSerializer mLogSerializer;
IngestionCallTemplate(LogSerializer logSerializer, LogContainer logContainer) {
this.mLogSerializer = logSerializer;
this.mLogContainer = logContainer;
}
@Override
public String buildRequestBody() throws JSONException {
StringBuilder sb = new StringBuilder();
for (Log log : this.mLogContainer.getLogs()) {
sb.append(this.mLogSerializer.serializeLog(log));
sb.append('\n');
}
return sb.toString();
}
@Override
public void onBeforeCalling(URL url, Map<String, String> headers) {
if (AppCenterLog.getLogLevel() <= 2) {
AppCenterLog.verbose("AppCenter", "Calling " + url + "...");
HashMap hashMap = new HashMap(headers);
String str = (String) hashMap.get(OneCollectorIngestion.API_KEY);
if (str != null) {
hashMap.put(OneCollectorIngestion.API_KEY, HttpUtils.hideApiKeys(str));
}
String str2 = (String) hashMap.get(OneCollectorIngestion.TICKETS);
if (str2 != null) {
hashMap.put(OneCollectorIngestion.TICKETS, HttpUtils.hideTickets(str2));
}
AppCenterLog.verbose("AppCenter", "Headers: " + hashMap);
}
}
}
}