1 files changed, 85 insertions, 0 deletions
diff --git a/src/main/java/org/onap/aai/rest/dsl/DslQueryProcessor.java b/src/main/java/org/onap/aai/rest/dsl/DslQueryProcessor.java
new file mode 100644
index 0000000..582f0ea
--- /dev/null
+++ b/src/main/java/org/onap/aai/rest/dsl/DslQueryProcessor.java
@@ -0,0 +1,85 @@
+/**
+ * ============LICENSE_START=======================================================
+ * org.onap.aai
+ * ================================================================================
+ * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+package org.onap.aai.rest.dsl;
+
+import com.att.eelf.configuration.EELFLogger;
+import com.att.eelf.configuration.EELFManager;
+import org.antlr.v4.runtime.CharStreams;
+import org.antlr.v4.runtime.CommonTokenStream;
+import org.antlr.v4.runtime.tree.ParseTree;
+import org.antlr.v4.runtime.tree.ParseTreeWalker;
+import org.onap.aai.AAIDslLexer;
+import org.onap.aai.AAIDslParser;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import java.io.ByteArrayInputStream;
+import java.io.InputStream;
+import java.nio.charset.StandardCharsets;
+
+/**
+ * The Class DslQueryProcessor.
+ */
+public class DslQueryProcessor {
+
+	private static final EELFLogger LOGGER = EELFManager.getInstance().getLogger(DslQueryProcessor.class);
+
+	private DslListener dslListener;
+
+	@Autowired
+	public DslQueryProcessor(DslListener dslListener){
+		this.dslListener = dslListener;
+	}
+
+	public String parseAaiQuery(String aaiQuery) {
+		try {
+			// Create a input stream that reads our string
+			InputStream stream = new ByteArrayInputStream(aaiQuery.getBytes(StandardCharsets.UTF_8));
+
+			// Create a lexer from the input CharStream
+			AAIDslLexer lexer = new AAIDslLexer(CharStreams.fromStream(stream, StandardCharsets.UTF_8));
+
+			// Get a list of tokens pulled from the lexer
+			CommonTokenStream tokens = new CommonTokenStream(lexer);
+
+			
+			// Parser that feeds off of the tokens buffer
+			AAIDslParser parser = new AAIDslParser(tokens);
+
+			// Specify our entry point
+			ParseTree ptree = parser.aaiquery();
+			LOGGER.info("QUERY-interim" + ptree.toStringTree(parser));
+
+			// Walk it and attach our listener
+			ParseTreeWalker walker = new ParseTreeWalker();
+			walker.walk(dslListener, ptree);
+			LOGGER.info("Final QUERY" + dslListener.query);
+
+			/*
+			 * TODO - Visitor patternQueryDslVisitor visitor = new
+			 * QueryDslVisitor(); String query = visitor.visit(ptree);
+			 * 
+			 */
+			return dslListener.query;
+		} catch (Exception e) {
+			LOGGER.error("Error while processing the query"+e.getMessage());
+		}
+		return "";
+	}
+}