fragment = parser.antlr.XtextAntlrGeneratorFragment {
  options = {
       backtrack = true
       classSplitting = true
       fieldsPerClass = "500" 
    }
  }
            
            
fragment = parser.antlr.XtextAntlrUiGeneratorFragment {
     options = {
      backtrack = true
      classSplitting = true
      fieldsPerClass = "500" 
   }
}

parserGenerator = {
		         antlrParam = "-Xconversiontimeout"
    			 antlrParam = "40000"
		         options = {
				ignoreCase = true
				backtrack=true
				memoize = true
				classSplitting=true
                	fieldsPerClass = "300"
                	methodsPerClass= "800"
				}
			}

basic_source_stream_handlers:
	(basic_ss_handler += basic_source_stream_handler)+
;

math_operation
    :'('math_operation')'                         #basic_math_operation
    |null_check                                   #basic_math_operation
    |NOT math_operation                           #not_math_operation
    |math_operation (multiply='*'|devide='/'|mod='%') math_operation    #multiplication_math_operation
    |math_operation (add='+'|substract='-') math_operation              #addition_math_operation
    |math_operation (gt_eq='>='|lt_eq='<='|gt='>'|lt='<') math_operation #greaterthan_lessthan_math_operation
    |math_operation (eq='=='|not_eq='!=') math_operation                #equality_math_operation
    |math_operation IN name                       #in_math_operation
    |math_operation AND math_operation            #and_math_operation
    |math_operation OR math_operation             #or_math_operation
    |function_operation                           #basic_math_operation
    |constant_value                               #basic_math_operation
    |attribute_reference                          #basic_math_operation
    ;

math_operation:
	//name = name (gt_eq='>='|lt_eq='<='|gt='>'|lt='<') name1 = INT
	{math_operation} fo=function_operation                           
    |{math_operation} constant_value                               
    |{math_operation}attribute_reference 
	|{math_operation} mlo=math_logical_operation
;

math_logical_operation returns math_operation:
	{math_operation} gt_lt=math_gt_lt_operation ({math_logical_operation.left=current} (AND | OR) right=math_gt_lt_operation)*
;

math_gt_lt_operation returns math_operation:
	{math_operation} equal=math_equal_operation ({math_gt_lt_operation.left=current} (gt_eq='>='|lt_eq='<='|gt='>'|lt='<') right=math_equal_operation)*
;

math_equal_operation returns math_operation:
	{math_operation} add_sub=math_addsub_operation ({math_gt_lt_operation.left=current} (eq='=='|not_eq='!=') right=math_addsub_operation)*
;

math_addsub_operation returns math_operation:
	{math_operation} divmul=math_divmul_operation ({math_addsub_operation.left=current} (add='+'|substract='-') right=math_divmul_operation)*
;

math_divmul_operation returns math_operation:
	{math_operation} gt_lt=math_other_operations ({math_divmul_operation.left=current} (multiply='*'|devide='/'|mod='%') right=math_other_operations)*
;

math_other_operations returns math_operation:
	//'math_op'
	'('math_operation')'                         
    |null_check                                   
    |NOT math_operation 
;

math_operation:
	//name = name (gt_eq='>='|lt_eq='<='|gt='>'|lt='<') name1 = INT
	fo=function_operation                           
    |{math_operation} constant_value                               
    |{math_operation}attribute_reference 
	| mlo=math_logical_operation
;

math_logical_operation returns math_operation:
	math_in_operation ({math_logical_operation.left=current} (AND | OR) right=math_in_operation)*
;

math_in_operation returns math_operation:
	math_gt_lt_operation ({math_in_operation.left=current} IN right=name)*
;

math_gt_lt_operation returns math_operation:
	math_equal_operation ({math_gt_lt_operation.left=current} (gt_eq='>='|lt_eq='<='|gt='>'|lt='<') right=math_equal_operation)*
;

math_equal_operation returns math_operation:
	math_addsub_operation ({math_gt_lt_operation.left=current} (eq='=='|not_eq='!=') right=math_addsub_operation)*
;

math_addsub_operation returns math_operation:
	math_divmul_operation ({math_addsub_operation.left=current} (add='+'|substract='-') right=math_divmul_operation)*
;

math_divmul_operation returns math_operation:
	math_other_operations ({math_divmul_operation.left=current} (multiply='*'|devide='/'|mod='%') right=math_other_operations)*
;

math_other_operations returns math_operation:
	//'math_op'
	'('math_operation')'                         
    |null_check                                   
    |NOT math_operation 
;

math_operation:
	//name = name (gt_eq='>='|lt_eq='<='|gt='>'|lt='<') name1 = INT                          
    
	mlo=math_logical_operation
;

math_logical_operation returns math_operation:
	math_in_operation ({math_logical_operation.left=current} ("AND" | "OR") right=math_in_operation)*
;

math_in_operation returns math_operation:
	math_gt_lt_operation ({math_in_operation.left=current} "IN" right=name)*
;

math_gt_lt_operation returns math_operation:
	math_equal_operation ({math_gt_lt_operation.left=current} (gt_eq='>='|lt_eq='<='|gt='>'|lt='<') right=math_equal_operation)*
;

math_equal_operation returns math_operation:
	math_addsub_operation ({math_gt_lt_operation.left=current} (eq='=='|not_eq='!=') right=math_addsub_operation)*
;

math_addsub_operation returns math_operation:
	math_divmul_operation ({math_addsub_operation.left=current} (add='+'|substract='-') right=math_divmul_operation)*
;

math_divmul_operation returns math_operation:
	math_other_operations ({math_divmul_operation.left=current} (multiply='*'|devide='/'|mod='%') right=math_other_operations)*
;

math_other_operations returns math_operation:
	//'math_op'
     =>({NotOperation} NOT op=math_operation) 
	|'('math_operation')'                         
    |null_check
    | literal                                   
;


literal:
	 constant_value                               
    |attribute_reference
;

null_check:
	function_operation ({null_check.expr=current}IS NULL)?
;

function_operation:
	{function_operation}(ns=function_namespace ':')? id=function_id '(' attr=attribute_list?  ')'
; 

function_namespace:
	name	
;

function_id:
	name	
;

attribute_list:
	{attribute_list}( attr += attribute (',' attr += attribute)* )  |{attribute_list} isStar?='*'
;

attribute:
	math_operation
;

name:
	ID
;

constant_value:
	value=STRING
;

attribute_reference:
	value=name
;


NOT: "NOT";
fragment IS : ('is');
fragment NULL: ('null');

query_input:
	{query_input}(=>js=join_stream | ps=pattern_stream | seq_s=sequence_stream | anon_s=anonymous_stream)
;

join_stream:
	left_source=join_source right_source=join_source right_unidirectional=UNIDIRECTIONAL (ON expression)? within_time?
	|left_source=join_source join=joins right_source=join_source (ON expression)? within_time?
	|left_source=join_source left_unidirectional=UNIDIRECTIONAL joins right_source=join_source (ON expression)? within_time?
	|standard_stream
;

join_source:
	main_source (AS stream_alias)?
;

main_source:
	source (pre_window_handlers = basic_source_stream_handlers)? (window = win)?
;

query_section:
	{query_section}(SELECT ('*'| (out_att += output_attribute (',' out_att +=output_attribute)* ))) 
;

query_output:
	(key_word=keyword) (out_event_type = output_event_type)? INTO (tar = target)
;

query_section:
	{query_section}(SELECT ('*'| (out_att += output_attribute (',' out_att +=output_attribute)* )) (grp_by=group_by)? (having=having_expr)?) 
;

group_by:
	GROUP BY attr_ref+=attribute_reference (',' attr_ref+=attribute_reference)*
;

having_expr:
	HAVING expr=expression
;

query_output:
	INSERT (out_event_type = output_event_type)? INTO (tar = target)
;

parserGenerator = {
				antlrParam = "-Xconversiontimeout"
    			antlrParam = "40000"
				options = {
					ignoreCase = true
					backtrack=true
					memoize = true
					classSplitting=true
                	fieldsPerClass = "300"
                	methodsPerClass= "800"
				}
			}

query_section:
	{query_section}(SELECT ('*'| (out_att += output_attribute (',' out_att +=output_attribute)* )) (grp_by=group_by)? (having=having_expr)?) 
;

output_attribute:
	{output_attribute} attr=attribute INSERT (att_name +=attribute_name) | {output_attribute} attr_ref=attribute_reference
;


group_by:
	GROUP BY attr_ref+=attribute_reference (',' attr_ref+=attribute_reference)*
;

having_expr:
	HAVING expr=expression
;


attribute_index:
	INT_LITERAL| LAST ('-' INT_LITERAL)?
;

expression:
	literal
;

attribute:
	literal
;

attribute_reference:
	{attribute_reference} hash1='#'? name1=name ('['attribute_index1=attribute_index']')? (hash2='#' name2=name ('['attribute_index2=attribute_index']')?)? '.'  attribute_name
    |{attribute_reference} attribute_name
;

literal:
	{function_operation} constant_value                               
    |{function_operation} attr_ref=attribute_reference
;


constant_value:
	string_value
	| time_value
;

time_value:
	year_value
;

year_value:
	INT_LITERAL YEARS
;

string_value:
	STRING_LITERAL
;

INT_LITERAL :
	DIGIT	
;

STRING_LITERAL:
	STRING
;

fragment DIGIT:
	INT
;


name:
	keyword | ID
;

attribute_name:
	name
;

model:
	s=query_section? (q_output = query_output)';'
;

query_output:
	INSERT (out_event_type = output_event_type)? INTO (tar = target);

output_event_type:
	ALL EVENTS | ALL RAW EVENTS | EXPIRED EVENTS | EXPIRED RAW EVENTS | CURRENT? EVENTS;

query_section:
	{query_section}(SELECT ('*'| (out_att += output_attribute (',' out_att +=output_attribute)* )) 
		
		//(grp_by=group_by)? (having=having_expr)?
	) 
;

source:
	inner='#'? (str_id = stream_id)
;

stream_id:
	name
;

target:
	source
;
 

output_attribute:
	{output_attribute} attr=attribute INSERT (att_name +=attribute_name) | {output_attribute} attr_ref=attribute_reference
;


group_by:
	GROUP BY attr_ref+=attribute_reference (',' attr_ref+=attribute_reference)*
;

having_expr:
	HAVING expr=expression
;


attribute_index:
	INT_LITERAL| LAST ('-' INT_LITERAL)?
;

expression:
	literal
;

attribute:
	literal
;

attribute_reference:
	{attribute_reference} hash1='#'? name1=name ('['attribute_index1=attribute_index']')? (hash2='#' name2=name ('['attribute_index2=attribute_index']')?)? '.'  attribute_name
    |{attribute_reference} attribute_name
;

literal:
	{function_operation} constant_value                               
    |{function_operation} attr_ref=attribute_reference
;


constant_value:
	string_value
	| time_value
;

time_value:
	year_value
;

year_value:
	INT_LITERAL YEARS
;

string_value:
	STRING_LITERAL
;

INT_LITERAL :
	DIGIT	
;

STRING_LITERAL:
	STRING
;

fragment DIGIT:
	INT
;


name:
	keyword | ID
;

attribute_name:
	name
;

else if(tokenName.equals("(") || tokenName.equals(")") || tokenName.equals(">=") || tokenName.equals("<=") || tokenName.equals("==") || tokenName.equals("!=") || tokenName.equals("<") || tokenName.equals("=") || tokenName.equals(">") || tokenName.equals("[") || tokenName.equals("]") || tokenName.equals("{") || tokenName.equals("}") || tokenName.equals("%") || tokenName.equals("+") || tokenName.equals("*") || tokenName.equals("-") || tokenName.equals("/") || tokenName.equals("#") || tokenName.equals(":"))
				return SiddhiHighlightingConfiguration.SYMBOL_ID;

if(tokenName.equals("(") || tokenName.equals(")") || tokenName.equals(">=") || tokenName.equals("<=") || tokenName.equals("==") || tokenName.equals("!=") || tokenName.equals("<") || tokenName.equals("=") || tokenName.equals(">") || tokenName.equals("[") || tokenName.equals("]") || tokenName.equals("{") || tokenName.equals("}") || tokenName.equals("%") || tokenName.equals("+") || tokenName.equals("*") || tokenName.equals("-") || tokenName.equals("/") || tokenName.equals("#") || tokenName.equals(":"))
				return SiddhiHighlightingConfiguration.SYMBOL_ID;

private static final Pattern PUNCTUATION = Pattern.compile("\\p{Punct}*");

if(PUNCTUATION.matcher(tokenName).matches())
				return SiddhiHighlightingConfiguration.SYMBOL_ID;