LR-546 level codes changed

lern-data-products/src/main/scala/org/sunbird/core/util/DataSecurityUtil.scala

@@ -50,14 +50,14 @@ object DataSecurityUtil {
 
   def getSecuredExhaustFile(level: String, orgId: String, channel: String, csvFile: String, encryptedKey: String, storageConfig: StorageConfig): Unit = {
     level match {
-      case "L1" =>
+      case "PLAIN_DATASET" =>
 
-      case "L2" =>
+      case "PASSWORD_PROTECTED_DATASET" =>
 
-      case "L3" =>
+      case "TEXT_KEY_ENCRYPTED_DATASET" =>
         val keyForEncryption = DecryptUtil.decryptData(encryptedKey)
         encryptionFile(null, csvFile, keyForEncryption, level)
-      case "L4" =>
+      case "PUBLIC_KEY_ENCRYPTED_DATASET" =>
         val exhaustEncryptionKey = getExhaustEncryptionKey(orgId, channel)
         val downloadPath = Constants.TEMP_DIR + orgId
         val publicPemFile = httpUtil.downloadFile(exhaustEncryptionKey, downloadPath)
@@ -123,7 +123,7 @@ object DataSecurityUtil {
     var localPath = ""
     var tempDir = ""
     var resultFile = ""
-    if(level == "L2") {
+    if(level == "PASSWORD_PROTECTED_DATASET") {
       tempDir = AppConf.getConfig("spark_output_temp_dir") + request.request_id + "/"
       val path = Paths.get(url);
       objKey = url.replace(filePrefix, "");
@@ -146,7 +146,7 @@ object DataSecurityUtil {
     // $COVERAGE-ON$
     val zipPath = localPath.replace("csv", "zip")
     val zipObjectKey = objKey.replace("csv", "zip")
-    if (level == "L2") {
+    if (level == "PASSWORD_PROTECTED_DATASET") {
       val zipLocalObjKey = url.replace("csv", "zip")
 
       request.encryption_key.map(key => {

lern-data-products/src/test/scala/org/sunbird/core/util/TestEncryptFileUtil.scala

@@ -12,7 +12,7 @@ class TestEncryptFileUtil extends BaseSpec {
     val request = Map("popularity" -> 1);
     try {
       val file = new File("src/test/resources/reports/public.pem")
-      EncryptFileUtil.encryptionFile(file ,"src/test/resources/reports/ap.csv","","L1")
+      EncryptFileUtil.encryptionFile(file ,"src/test/resources/reports/ap.csv","","PLAIN_DATASET")
     } catch {
       case ex: UnirestException => Console.println(s"Invalid Request for url: ${url}. The job failed with: " + ex.getMessage)
     }

lern-data-products/src/test/scala/org/sunbird/lms/exhaust/TestUserInfoExhaustJob.scala

@@ -327,7 +327,7 @@ class TestUserInfoExhaustJob extends BaseReportSpec with MockFactory with BaseRe
   //Unit test case for save and update requests
   it should "execute the update and save request method" in {
     implicit val fc = new FrameworkContext()
-    val jobRequest = JobRequest("'do_1131350140968632321230_batch-001:channel-01'", "123", "userinfo-exhaust", "SUBMITTED", """{\"batchId\": \"batch-001\"}""", "user-002", "channel-01", System.currentTimeMillis(), None, None, None, None, Option(""), Option(0), Option("test-123"), None, Option("0123456789"), Option("L1"))
+    val jobRequest = JobRequest("'do_1131350140968632321230_batch-001:channel-01'", "123", "userinfo-exhaust", "SUBMITTED", """{\"batchId\": \"batch-001\"}""", "user-002", "channel-01", System.currentTimeMillis(), None, None, None, None, Option(""), Option(0), Option("test-123"), None, Option("0123456789"), Option("PASSWORD_PROTECTED_DATASET"))
     val req = new JobRequest()
     val jobRequestArr = Array(jobRequest)
     val storageConfig = StorageConfig("local", "", outputLocation)