टेक्स्ट की तुलना करें

दो टेक्स्ट फ़ाइलों के बीच अंतर ढूंढें

रियल-टाइम एडिटर

रिक्त स्थान छिपाएँ

अपरिवर्तित संक्षिप्त करें

लाइन रैप बंद

लेआउट

परिवर्तन हाइलाइट करें

टेक्स्ट शैलियां

सिंटैक्स हाइलाइटिंग

Diffchecker Desktop Diffchecker चलाने का सबसे सुरक्षित तरीका। Diffchecker Desktop ऐप पाएं: आपके diffs कभी आपके कंप्यूटर से बाहर नहीं जाते!Desktop पाएं

Diff

बनाया गया 6 वर्ष पहलेDiff कभी समाप्त नहीं होता

69 हटाए गए

लाइनें
कुल
हटाया गया

अक्षर
कुल
हटाया गया

इस सुविधा का उपयोग जारी रखने के लिए, अपग्रेड करें Diffchecker Pro मूल्य देखें

205 लाइनें

84 जोड़े गए

लाइनें
कुल
जोड़ा गया

अक्षर
कुल
जोड़ा गया

इस सुविधा का उपयोग जारी रखने के लिए, अपग्रेड करें Diffchecker Pro मूल्य देखें

230 लाइनें

package com.pubnub.api.managers;

import com.pubnub.api.PNConfiguration;

import com.pubnub.api.PubNub;

import com.pubnub.api.endpoints.vendor.AppEngineFactory;

import com.pubnub.api.enums.PNLogVerbosity;

import com.pubnub.api.interceptors.SignatureInterceptor;

import com.pubnub.api.services.AccessManagerService;

import com.pubnub.api.services.ChannelGroupService;

import com.pubnub.api.services.HistoryService;

import com.pubnub.api.services.MemberService;

import com.pubnub.api.services.MembershipService;

import com.pubnub.api.services.MessageActionService;

import com.pubnub.api.services.PresenceService;

import com.pubnub.api.services.PublishService;

import com.pubnub.api.services.PushService;

import com.pubnub.api.services.SignalService;

import com.pubnub.api.services.SpaceService;

import com.pubnub.api.services.SubscribeService;

import com.pubnub.api.services.TimeService;

import com.pubnub.api.services.UserService;

import lombok.Getter;

import okhttp3.OkHttpClient;

import okhttp3.logging.HttpLoggingInterceptor;

import retrofit2.Retrofit;

import java.util.Collections;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.TimeUnit;

public class RetrofitManager {

private PubNub pubnub;

private SignatureInterceptor signatureInterceptor;

private OkHttpClient transactionClientInstance;

private OkHttpClient subscriptionClientInstance;

// services

@Getter

private PresenceService presenceService;

@Getter

private HistoryService historyService;

@Getter

private PushService pushService;

@Getter

private AccessManagerService accessManagerService;

@Getter

private ChannelGroupService channelGroupService;

@Getter

private TimeService timeService;

@Getter

private PublishService publishService;

@Getter

private SubscribeService subscribeService;

@Getter

private SignalService signalService;

@Getter

private UserService userService;

@Getter

private SpaceService spaceService;

@Getter

private MembershipService membershipService;

@Getter

private MemberService memberService;

@Getter

private MessageActionService messageActionService;

@Getter

private Retrofit transactionInstance;

@Getter

private Retrofit subscriptionInstance;

public RetrofitManager(PubNub pubNubInstance) {

this.pubnub = pubNubInstance;

this.signatureInterceptor = new SignatureInterceptor(pubNubInstance);

if (!pubNubInstance.getConfiguration().isGoogleAppEngineNetworking()) {

this.transactionClientInstance = createOkHttpClient(

this.transactionClientInstance = createOkHttpClient(this.pubnub.getConfiguration().getNonSubscribeRequestTimeout(), this.pubnub.getConfiguration().getConnectTimeout());

this.pubnub.getConfiguration().getNonSubscribeRequestTimeout(),

this.subscriptionClientInstance = createOkHttpClient(this.pubnub.getConfiguration().getSubscribeTimeout(), this.pubnub.getConfiguration().getConnectTimeout());

this.pubnub.getConfiguration().getConnectTimeout()

);

this.subscriptionClientInstance = createOkHttpClient(

this.pubnub.getConfiguration().getSubscribeTimeout(),

this.pubnub.getConfiguration().getConnectTimeout()

);

}

this.transactionInstance = createRetrofit(this.transactionClientInstance);

this.subscriptionInstance = createRetrofit(this.subscriptionClientInstance);

this.presenceService = transactionInstance.create(PresenceService.class);

this.historyService = transactionInstance.create(HistoryService.class);

this.pushService = transactionInstance.create(PushService.class);

this.accessManagerService = transactionInstance.create(AccessManagerService.class);

this.channelGroupService = transactionInstance.create(ChannelGroupService.class);

this.publishService = transactionInstance.create(PublishService.class);

this.subscribeService = subscriptionInstance.create(SubscribeService.class);

this.timeService = transactionInstance.create(TimeService.class);

this.signalService = transactionInstance.create(SignalService.class);

this.userService = transactionInstance.create(UserService.class);

this.spaceService = transactionInstance.create(SpaceService.class);

this.membershipService = transactionInstance.create(MembershipService.class);

this.memberService = transactionInstance.create(MemberService.class);

this.messageActionService = transactionInstance.create(MessageActionService.class);

}

private OkHttpClient createOkHttpClient(int requestTimeout, int connectTimeOut) {

PNConfiguration pnConfiguration = pubnub.getConfiguration();

OkHttpClient.Builder httpClient = new OkHttpClient.Builder();

httpClient.retryOnConnectionFailure(false);

httpClient.retryOnConnectionFailure(true);

httpClient.readTimeout(requestTimeout, TimeUnit.SECONDS);

httpClient.connectTimeout(connectTimeOut, TimeUnit.SECONDS);

if (pubnub.getConfiguration().getLogVerbosity() == PNLogVerbosity.BODY) {

HttpLoggingInterceptor logging = new HttpLoggingInterceptor();

logging.setLevel(HttpLoggingInterceptor.Level.BODY);

httpClient.addInterceptor(logging);

}

if (pubnub.getConfiguration().getHttpLoggingInterceptor() != null) {

httpClient.addInterceptor(pubnub.getConfiguration().getHttpLoggingInterceptor());

}

if (pnConfiguration.getSslSocketFactory() != null && pnConfiguration.getX509ExtendedTrustManager() != null) {

httpClient.sslSocketFactory(pnConfiguration.getSslSocketFactory(),

httpClient.sslSocketFactory(pnConfiguration.getSslSocketFactory(), pnConfiguration.getX509ExtendedTrustManager());

pnConfiguration.getX509ExtendedTrustManager());

}

if (pnConfiguration.getConnectionSpec() != null) {

httpClient.connectionSpecs(Collections.singletonList(pnConfiguration.getConnectionSpec()));

}

if (pnConfiguration.getHostnameVerifier() != null) {

httpClient.hostnameVerifier(pnConfiguration.getHostnameVerifier());

}

if (pubnub.getConfiguration().getProxy() != null) {

httpClient.proxy(pubnub.getConfiguration().getProxy());

}

if (pubnub.getConfiguration().getProxySelector() != null) {

httpClient.proxySelector(pubnub.getConfiguration().getProxySelector());

}

if (pubnub.getConfiguration().getProxyAuthenticator() != null) {

httpClient.proxyAuthenticator(pubnub.getConfiguration().getProxyAuthenticator());

}

if (pubnub.getConfiguration().getCertificatePinner() != null) {

httpClient.certificatePinner(pubnub.getConfiguration().getCertificatePinner());

}

httpClient.addInterceptor(this.signatureInterceptor);

OkHttpClient constructedClient = httpClient.build();

if (pubnub.getConfiguration().getMaximumConnections() != null) {

constructedClient.dispatcher().setMaxRequestsPerHost(pubnub.getConfiguration().getMaximumConnections());

}

return constructedClient;

}

private Retrofit createRetrofit(OkHttpClient client) {

Retrofit.Builder retrofitBuilder = new Retrofit.Builder();

if (pubnub.getConfiguration().isGoogleAppEngineNetworking()) {

retrofitBuilder.callFactory(new AppEngineFactory.Factory(pubnub));

}

retrofitBuilder = retrofitBuilder.baseUrl(pubnub.getBaseUrl()).addConverterFactory(this.pubnub.getMapper().getConverterFactory());

retrofitBuilder = retrofitBuilder

.baseUrl(pubnub.getBaseUrl())

.addConverterFactory(this.pubnub.getMapper().getConverterFactory());

if (!pubnub.getConfiguration().isGoogleAppEngineNetworking()) {

retrofitBuilder = retrofitBuilder.client(client);

}

return retrofitBuilder.build();

}

public void destroy(boolean force) {

if (this.transactionClientInstance != null) {

closeExecutor(this.transactionClientInstance, force);

}

if (this.subscriptionClientInstance != null) {

closeExecutor(this.subscriptionClientInstance, force);

}

private void closeExecutor(OkHttpClient client, boolean force) {

client.dispatcher().cancelAll();

if (force) {

client.connectionPool().evictAll();

ExecutorService executorService = client.dispatcher().executorService();

executorService.shutdown();

}