gCubeSystem
/
ic-client
16
0
Fork 0
Code Issues Pull Requests Releases 2 Wiki Activity

merged from trunk 

git-svn-id: http://svn.research-infrastructures.eu/public/d4science/gcube/branches/information-system/ic-client/1.0@67999 82a268e6-3cf1-43bd-a215-b396298e98cf
This commit is contained in:
fabio.simeoni 2013-01-17 18:03:05 +00:00
parent 7262578661
commit 8cc1491361
2 changed files with 51 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

70
src/main/java/org/gcube/resources/discovery/icclient/Helper.java
View File

@ -3,7 +3,9 @@ package org.gcube.resources.discovery.icclient;
import static org.gcube.common.scope.impl.ScopeBean.Type.*;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map.Entry;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
@ -17,6 +19,8 @@ public class Helper {
private static final Logger log = LoggerFactory.getLogger(Helper.class);
public static String queryAddAuthenticationControl(String expression) throws MalformedQueryException
{
@ -24,6 +28,7 @@ public class Helper {
if (scope==null || !new ScopeBean(scope).is(VRE))
return expression;
int wherePathIndex=0;
int returnPathIndex=0;
@ -34,13 +39,15 @@ public class Helper {
String whereInsertFinal="";
String temp="";
HashMap<String, String> varReplacementMap = new HashMap<String, String>();
String forPropertiesString="\n *VAR* in *COLLECTION*/Data/child::*[local-name()='Scopes'] \n";
String forString=" *VAR* in *COLLECTION*/Scopes \n";
String authString=" (contains(*VAR*//Scope,'"+scope+"') or contains(*VAR*//Scope,'"+scope.substring(0,scope.lastIndexOf("/"))+"')) ";
String authStringNormal=" contains(*VAR*//Scope,'"+scope+"') ";
String queryFiltered;
List<Pair> collInsert= new ArrayList<Pair>();
List<Boolean> collInsert= new ArrayList<Boolean>();
Pattern wherePattern= Pattern.compile("where");
//mathcing , $result in $outer/Data
Pattern inSubResult= Pattern.compile("(,\\s*([^\\s]*)\\s*in\\s*([^\\s]*)\\s*)(where|order\\sby|return)");
@ -79,22 +86,29 @@ public class Helper {
String tempPath="";
try{
tempPath= temp.substring(resourceMat.end());
if (propBool)
{
String resourceMatString= resourceMat.group();
forStringTemp=forPropertiesString.replace("*VAR*","$entry"+collInsert.size()+"ValueAuth" ).replace("*COLLECTION*", resourceMatString );
Pair c= new Pair("let "+varMat.group()+" := "+" $entry"+collInsert.size()+"ValueAuth/.."+tempPath, true);
collInsert.add(c);
String oldVar = varMat.group();
String newVar = "$entry"+collInsert.size()+"ValueAuth";
collInsert.add(true);
varReplacementMap.put(oldVar, newVar+"/.."+tempPath);
}
else
{
String resourceMatString= resourceMat.group();
forStringTemp=forString.replace("*VAR*","$entry"+collInsert.size()+"ValueAuth" ).replace("*COLLECTION*",resourceMatString );
Pair c= new Pair("let "+varMat.group()+" := "+" $entry"+collInsert.size()+"ValueAuth/.."+tempPath, (resourceMatString.contains("/Profiles/RunningInstance") || resourceMatString.contains("/Profiles/GHN") || resourceMatString.contains("/Profiles/Service")));
collInsert.add(c);
String oldVar = varMat.group();
String newVar = "$entry"+collInsert.size()+"ValueAuth";
forStringTemp=forString.replace("*VAR*",newVar ).replace("*COLLECTION*",resourceMatString );
collInsert.add(resourceMatString.contains("/Profiles/RunningInstance") || resourceMatString.contains("/Profiles/GHN") || resourceMatString.contains("/Profiles/Service"));
varReplacementMap.put(oldVar, newVar+"/.."+tempPath);
}
}catch(IllegalStateException e){ log.debug("error parsing statement");}
expression=expression.substring(0, collIndexStart)+ forStringTemp +expression.substring(collIndexEnd);
expression=expression.substring(0, collIndexStart)+ forStringTemp +expression.substring(collIndexEnd);
collMat=collectionPattern.matcher(expression);
}
@ -105,18 +119,19 @@ public class Helper {
for (int i=0; i<collInsert.size(); i++)
{
if (i==collInsert.size()-1){
if(collInsert.get(i).isStrangeBehaviour())
if(collInsert.get(i))
whereInsertFinal+=authString.replace("*VAR*", "$entry"+i+"ValueAuth");
else whereInsertFinal+=authStringNormal.replace("*VAR*", "$entry"+i+"ValueAuth");
}else{
if(collInsert.get(i).isStrangeBehaviour())
if(collInsert.get(i))
whereInsertFinal+=authString.replace("*VAR*", "$entry"+i+"ValueAuth")+" and " ;
else whereInsertFinal+=authStringNormal.replace("*VAR*", "$entry"+i+"ValueAuth")+" and " ;
}
forInsertFinal+="\n"+collInsert.get(i).getToInsert()+" ";
}
Matcher whereMat=wherePattern.matcher(expression);
Matcher inSubResultMat= inSubResult.matcher(expression);
@ -125,10 +140,9 @@ public class Helper {
returnMat.reset();
whereFinded=whereMat.find();
returnMat.find();
String inSubResultString="";
try{
inSubResultMat.find();
inSubResultString= inSubResultMat.group(1);
}catch(Exception e){}
try{
@ -137,12 +151,14 @@ public class Helper {
try{
returnPathIndex=returnMat.start();
}catch(IllegalStateException e){ log.error("error parsing return statement"); throw new MalformedQueryException("error parsing return statement");}
if (whereFinded)
queryFiltered=expression.substring(0,wherePathIndex)+"\nwhere "+whereInsertFinal
+" and ("+expression.substring(wherePathIndex+5, returnPathIndex)+" ) \n"+expression.substring(returnPathIndex);
else
queryFiltered=expression.substring(0,returnPathIndex)+ "\nwhere "+whereInsertFinal+" \n "+expression.substring(returnPathIndex);
//logger.trace("queryFiltered to match: " + queryFiltered);
Pattern letPattern=Pattern.compile("let.*:=", Pattern.DOTALL);
Matcher letMat=letPattern.matcher(queryFiltered);
@ -165,22 +181,36 @@ public class Helper {
else {
queryFiltered=queryFiltered.substring(0,letPathIndex)+forInsertFinal+queryFiltered.substring(letPathIndex);
}
queryFiltered=queryFiltered.replace(inSubResultString, "");
for (Entry<String, String> entry: varReplacementMap.entrySet())
queryFiltered = queryFiltered.replace(entry.getKey(), entry.getValue());
/*
if (inSubResultString.compareTo("")!=0){
String newInSubResultString = inSubResultString;
for (Entry<String, String> entry: varReplacementMap.entrySet())
newInSubResultString = newInSubResultString.replace(entry.getKey(), entry.getValue());
queryFiltered =queryFiltered.replace(inSubResultString, newInSubResultString);
/*
String firstVar=inSubResultMat.group(2);
String replaceVar=inSubResultMat.group(3);
queryFiltered= queryFiltered.replace(firstVar, replaceVar);
//System.out.println(firstVar);
//System.out.println(replaceVar);
}
System.out.println(firstVar);
System.out.println(replaceVar);
System.out.println("query filtered final: "+queryFiltered);
} else
queryFiltered=queryFiltered.replace(inSubResultString, "");
*/
log.trace("submitting filtered query: {}",queryFiltered);
return queryFiltered;
}
/*
private static class Pair {
private String toInsert;
//is strange Behaviour is true if we are searching for RI , GHN or Service
@ -199,7 +229,7 @@ public class Helper {
return this.isStrangeBehaviour;
}
}
*/
}

2
src/test/java/org/acme/APIClient.java
View File

@ -26,7 +26,7 @@ public class APIClient {
@BeforeClass
public static void setup() {
ScopeProvider.instance.set("/gcube/devsec");
ScopeProvider.instance.set("/gcube/devsec/devVre");
}