Skip to content

Commit

Permalink
chore: addressing comment
Browse files Browse the repository at this point in the history
  • Loading branch information
1abhishekpandey committed Feb 2, 2023
1 parent 7fc50ac commit 9979cf5
Showing 1 changed file with 23 additions and 14 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -166,22 +166,11 @@ public void run() {
if (serverConfig != null) {
isSDKEnabled = serverConfig.source.isSourceEnabled;
if (isSDKEnabled) {
// Initialise dataPlaneUrl based on Residency server
RudderDataResidencyManager rudderDataResidencyManager = new RudderDataResidencyManager(serverConfig, config);
dataPlaneUrl = rudderDataResidencyManager.getDataResidencyUrl();
if (Utils.isEmpty(dataPlaneUrl)) {
dataPlaneUrl = config.getDataPlaneUrl();
}
dataPlaneUrl = getDataPlaneUrlWrtResidencyConfig(serverConfig, config);
RudderLogger.logDebug("DataPlaneUrl is set to: " + dataPlaneUrl);

// save flush config
RudderFlushConfig rudderFlushConfig = new RudderFlushConfig(dataPlaneUrl, authHeaderString, anonymousIdHeaderString, config.getFlushQueueSize(), config.getLogLevel());
rudderFlushWorkManager.saveRudderFlushConfig(rudderFlushConfig);

// initiate processor
RudderLogger.logDebug("EventRepository: initiateSDK: Initiating processor");
Thread processorThread = new Thread(getProcessorRunnable());
processorThread.start();
saveFlushConfig();
initiateProcessor();

// initiate factories
if (serverConfig.source.destinations != null) {
Expand Down Expand Up @@ -220,6 +209,26 @@ public void run() {
}).start();
}

private String getDataPlaneUrlWrtResidencyConfig(RudderServerConfig serverConfig, RudderConfig config) {
RudderDataResidencyManager rudderDataResidencyManager = new RudderDataResidencyManager(serverConfig, config);
String dataPlaneUrl = rudderDataResidencyManager.getDataResidencyUrl();
if (Utils.isEmpty(dataPlaneUrl)) {
dataPlaneUrl = config.getDataPlaneUrl();
}
return dataPlaneUrl;
}

private void saveFlushConfig() {
RudderFlushConfig rudderFlushConfig = new RudderFlushConfig(dataPlaneUrl, authHeaderString, anonymousIdHeaderString, config.getFlushQueueSize(), config.getLogLevel());
rudderFlushWorkManager.saveRudderFlushConfig(rudderFlushConfig);
}

private void initiateProcessor() {
RudderLogger.logDebug("EventRepository: initiateSDK: Initiating processor");
Thread processorThread = new Thread(getProcessorRunnable());
processorThread.start();
}

private void sendApplicationInstalled(int currentBuild, String currentVersion) {
// If trackLifeCycleEvents is not allowed then discard the event
if (!config.isTrackLifecycleEvents()) {
Expand Down

0 comments on commit 9979cf5

Please sign in to comment.