Commit f177b112 authored by PrasadMoka's avatar PrasadMoka
Browse files

LR-278 getBaseUrl to cloud util

Showing with 17 additions and 9 deletions
+17 -9
......@@ -18,6 +18,7 @@ import org.sunbird.common.models.util.TelemetryEnvKey;
import org.sunbird.common.request.Request;
import org.sunbird.common.request.RequestContext;
import org.sunbird.common.responsecode.ResponseCode;
import org.sunbird.common.util.CloudStorageUtil;
import org.sunbird.learner.actors.coursebatch.dao.CourseBatchDao;
import org.sunbird.learner.actors.coursebatch.dao.impl.CourseBatchDaoImpl;
import org.sunbird.learner.constants.CourseJsonKey;
......@@ -146,8 +147,8 @@ public class CourseBatchCertificateActor extends BaseActor {
if (MapUtils.isNotEmpty(templateDetails) && templateDetails.containsKey(key)) {
// replace the actual cloud url with the template value
templateUrl = (String) templateDetails.get(key);
if (templateUrl.contains(getConfigValue(CLOUD_STORE_BASE_PATH) +"/"+getConfigValue(CONTENT_CLOUD_STORAGE_CONTAINER)))
templateUrl = templateUrl.replace(getConfigValue(CLOUD_STORE_BASE_PATH)+"/"+getConfigValue(CONTENT_CLOUD_STORAGE_CONTAINER), getConfigValue(CLOUD_STORE_BASE_PATH_PLACEHOLDER));
if (templateUrl.contains(CloudStorageUtil.getBaseUrl() +"/"+getConfigValue(CONTENT_CLOUD_STORAGE_CONTAINER)))
templateUrl = templateUrl.replace(CloudStorageUtil.getBaseUrl()+"/"+getConfigValue(CONTENT_CLOUD_STORAGE_CONTAINER), getConfigValue(CLOUD_STORE_BASE_PATH_PLACEHOLDER));
}
return templateUrl;
}
......
......@@ -245,17 +245,11 @@ public class QRCodeDownloadManagementActor extends BaseActor {
private String resolvePlaceholder(String templateUrl, String placeHolder,String containerName) {
if (templateUrl.contains(placeHolder))
templateUrl = templateUrl.replace(placeHolder, getBaseUrl()
templateUrl = templateUrl.replace(placeHolder, CloudStorageUtil.getBaseUrl()
+ "/" + containerName);
return templateUrl;
}
private String getBaseUrl() {
String baseUrl = getConfigValue(CLOUD_STORAGE_CNAME_URL);
if(StringUtils.isEmpty(baseUrl))
baseUrl = getConfigValue(CLOUD_STORE_BASE_PATH);
return baseUrl;
}
/**
* Uploading the generated csv to aws
......
......@@ -2,6 +2,8 @@ package org.sunbird.common.util;
import java.util.HashMap;
import java.util.Map;
import org.apache.commons.lang.StringUtils;
import org.sunbird.cloud.storage.BaseStorageService;
import org.sunbird.cloud.storage.factory.StorageConfig;
import org.sunbird.cloud.storage.factory.StorageServiceFactory;
......@@ -11,6 +13,10 @@ import org.sunbird.common.models.util.PropertiesCache;
import scala.Option;
import scala.Some;
import static org.sunbird.common.models.util.JsonKey.CLOUD_STORAGE_CNAME_URL;
import static org.sunbird.common.models.util.JsonKey.CLOUD_STORE_BASE_PATH;
import static org.sunbird.common.models.util.ProjectUtil.getConfigValue;
public class CloudStorageUtil {
private static final int STORAGE_SERVICE_API_RETRY_COUNT = 3;
......@@ -76,4 +82,11 @@ public class CloudStorageUtil {
BaseStorageService storageService = getStorageService(storageType);
return storageService.getUri(container, prefix, Option.apply(isDirectory));
}
public static String getBaseUrl() {
String baseUrl = getConfigValue(CLOUD_STORAGE_CNAME_URL);
if(StringUtils.isEmpty(baseUrl))
baseUrl = getConfigValue(CLOUD_STORE_BASE_PATH);
return baseUrl;
}
}
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment