Skip to content
Snippets Groups Projects
Commit f3b10426 authored by mbrodhu's avatar mbrodhu
Browse files

enable resumptionToken for openaire correctly

parent b0a42c9d
No related branches found
No related tags found
No related merge requests found
...@@ -473,13 +473,14 @@ public class OAIPMHImpl implements OAIPMHProducer { ...@@ -473,13 +473,14 @@ public class OAIPMHImpl implements OAIPMHProducer {
&& RecordListDelivererDC.cursorCollector.containsKey(request.getResumptionToken()); && RecordListDelivererDC.cursorCollector.containsKey(request.getResumptionToken());
boolean restokIDIOMExisting = RecordListDelivererIDIOM.cursorCollector != null boolean restokIDIOMExisting = RecordListDelivererIDIOM.cursorCollector != null
&& RecordListDelivererIDIOM.cursorCollector.containsKey(request.getResumptionToken()); && RecordListDelivererIDIOM.cursorCollector.containsKey(request.getResumptionToken());
boolean restokOpenAireExisting = OpenAireRecordList.cursorCollector != null boolean restokOpenAireExisting = RecordListDelivererAbstract.cursorCollector != null
&& OpenAireRecordList.cursorCollector.containsKey(request.getResumptionToken()); && RecordListDelivererAbstract.cursorCollector.containsKey(request.getResumptionToken());
if (restokDCExisting) { if (restokDCExisting) {
recListDeliv = this.recordListDC; recListDeliv = this.recordListDC;
} else if (restokIDIOMExisting) { } else if (restokIDIOMExisting) {
recListDeliv = this.recordListIDIOM; recListDeliv = this.recordListIDIOM;
} else if (restokOpenAireExisting) { } else if (restokOpenAireExisting) {
System.out.println("RESTOK FOR OPENAIRE EXISTS");
recListDeliv = this.openAireRecordList; recListDeliv = this.openAireRecordList;
} }
} }
......
...@@ -14,7 +14,7 @@ import info.textgrid.middleware.oaipmh.ResumptionTokenType; ...@@ -14,7 +14,7 @@ import info.textgrid.middleware.oaipmh.ResumptionTokenType;
public class OpenAireRecordList extends RecordListDelivererAbstract { public class OpenAireRecordList extends RecordListDelivererAbstract {
protected static Map<String, Integer> cursorCollector = new Hashtable<String, Integer>(); //protected static Map<String, Integer> cursorCollector = new Hashtable<String, Integer>();
private String rangeField; private String rangeField;
...@@ -60,8 +60,7 @@ public class OpenAireRecordList extends RecordListDelivererAbstract { ...@@ -60,8 +60,7 @@ public class OpenAireRecordList extends RecordListDelivererAbstract {
System.out.println(getResTokenForResponse().getValue()); System.out.println(getResTokenForResponse().getValue());
//System.out.println(getResumptionToken()); //System.out.println(getResumptionToken());
//resTokenForResponse = OAIPMHUtilities.getResumptionToken( //resTokenForResponse = OAIPMHUtilities.getResumptionToken(
// 94146, resumptionToken, cursorCollector, scrollID, this.searchResponseSize, i) // 94146, resumptionToken, cursorCollector, scrollID, this.searchResponseSize, i)
openAireRecordList.setResumptionToken(getResTokenForResponse()); openAireRecordList.setResumptionToken(getResTokenForResponse());
//} //}
......
...@@ -134,6 +134,8 @@ public abstract class RecordListDelivererAbstract implements RecordListDeliverer ...@@ -134,6 +134,8 @@ public abstract class RecordListDelivererAbstract implements RecordListDeliverer
resTokenForResponse = OAIPMHUtilities.getResumptionToken( resTokenForResponse = OAIPMHUtilities.getResumptionToken(
completeListSize, resumptionToken, cursorCollector, scrollID, this.searchResponseSize, i); completeListSize, resumptionToken, cursorCollector, scrollID, this.searchResponseSize, i);
System.out.println("TADA: ");
System.out.println(cursorCollector);
}else { }else {
setFoundItems(false); setFoundItems(false);
...@@ -166,13 +168,17 @@ public abstract class RecordListDelivererAbstract implements RecordListDeliverer ...@@ -166,13 +168,17 @@ public abstract class RecordListDelivererAbstract implements RecordListDeliverer
// Check if resumptionToken is invalid or existing. // Check if resumptionToken is invalid or existing.
if (request.getResumptionToken() != null) { if (request.getResumptionToken() != null) {
System.out.println("ERROR_CHECK");
System.out.println(request.getResumptionToken());
boolean restokIDIOMExisting = RecordListDelivererIDIOM.cursorCollector != null boolean restokIDIOMExisting = RecordListDelivererIDIOM.cursorCollector != null
&& RecordListDelivererIDIOM.cursorCollector.containsKey(request.getResumptionToken()); && RecordListDelivererIDIOM.cursorCollector.containsKey(request.getResumptionToken());
boolean restokDCExisting = RecordListDelivererDC.cursorCollector != null boolean restokDCExisting = RecordListDelivererDC.cursorCollector != null
&& RecordListDelivererDC.cursorCollector.containsKey(request.getResumptionToken()); && RecordListDelivererDC.cursorCollector.containsKey(request.getResumptionToken());
boolean restok = cursorCollector != null
if (!restokDCExisting && !restokIDIOMExisting) { && cursorCollector.containsKey(request.getResumptionToken());
if (!restokDCExisting && !restokIDIOMExisting && !restok) {
result.setError(TGConstants.OAI_BAD_RESUMPTION_TOKEN, "The value of the " result.setError(TGConstants.OAI_BAD_RESUMPTION_TOKEN, "The value of the "
+ request.getResumptionToken() + " argument is invalid or expired."); + request.getResumptionToken() + " argument is invalid or expired.");
} }
......
...@@ -274,9 +274,10 @@ public class RecordListDelivererDC extends RecordListDelivererAbstract { ...@@ -274,9 +274,10 @@ public class RecordListDelivererDC extends RecordListDelivererAbstract {
completeListSize, resumptionToken, cursorCollector, scrollID, this.searchResponseSize, i); completeListSize, resumptionToken, cursorCollector, scrollID, this.searchResponseSize, i);
//if (resTokenForResponse != null) { //if (resTokenForResponse != null) {
System.out.println("RESTOKEN: ");
System.out.println(recordList.getResumptionToken());
recordList.setResumptionToken(resTokenForResponse); recordList.setResumptionToken(resTokenForResponse);
System.out.println("RESTOKEN: ");
System.out.println(recordList.getResumptionToken());
//} //}
} else { } else {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment