Skip to content

Commit

Permalink
removed OPeNDAP related URL objects (#12)
Browse files Browse the repository at this point in the history
Co-authored-by: Yen, David (398B-Affiliate) <david.yen@jpl.nasa.gov>
  • Loading branch information
yenes56 and Yen, David (398B-Affiliate) authored Aug 29, 2022
1 parent d117c68 commit bdc4e38
Show file tree
Hide file tree
Showing 2 changed files with 27 additions and 1 deletion.
2 changes: 2 additions & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
### Deprecated
### Removed
### Fixed
- **PODAAC-2796**
- remove all OPeNDAP URL object from RelatedUrls before doing dmrpp file generator processing
### Security

## [8.0.0] - 2022-06-06
Expand Down
Original file line number Diff line number Diff line change
@@ -1,18 +1,21 @@
package gov.nasa.cumulus.metadata.aggregator.processor;

import com.google.gson.JsonObject;
import com.google.gson.*;
import com.vividsolutions.jts.io.ParseException;
import cumulus_message_adapter.message_parser.AdapterLogger;
import org.apache.commons.lang3.StringUtils;

import java.io.IOException;
import java.math.BigInteger;
import java.nio.file.Paths;
import java.util.Iterator;

public class DMRPPProcessor extends ProcessorBase{
private final String className = this.getClass().getName();
public String process(String input, String ummgStr, String region, String revisionId)
throws IOException, ParseException {
try {
ummgStr = cleanseOPeNDAPUrl(ummgStr);
String cmrBucket = System.getenv().getOrDefault("INTERNAL_BUCKET", "");
String cmrDir = System.getenv().getOrDefault("CMR_DIR", "");
AdapterLogger.LogDebug(this.className + " internal bucket: " + cmrBucket + " CMR Dir: " + cmrDir);
Expand All @@ -35,4 +38,25 @@ public String process(String input, String ummgStr, String region, String revisi
}
}

private String cleanseOPeNDAPUrl(String ummgStr) {
Gson gsonBuilder = getGsonBuilder();
JsonObject cmrJsonObj = JsonParser.parseString(ummgStr).getAsJsonObject();
JsonArray relatedUrls = cmrJsonObj.getAsJsonArray("RelatedUrls");
if (relatedUrls == null) {
return ummgStr;
}

Iterator<JsonElement> iterator = relatedUrls.iterator();
while(iterator.hasNext()){
JsonElement node = iterator.next();
JsonElement subTypeElement = node.getAsJsonObject().get("Subtype");
if (subTypeElement != null && StringUtils.equalsIgnoreCase(
StringUtils.trim(subTypeElement.getAsString()), "OPENDAP DATA")) {
AdapterLogger.LogInfo(this.className + " found OPENDAP LINK and removing: " + node);
iterator.remove();
}
}
return gsonBuilder.toJson(cmrJsonObj);
}

}

0 comments on commit bdc4e38

Please sign in to comment.