@Inject MyDslGrammarAccess grammarAccess;

@Override
public void completeKeyword(Keyword keyword,
ContentAssistContext contentAssistContext,
ICompletionProposalAcceptor acceptor) {
if (!grammarAccess.getGreetingAccess().getHelloKeyword_0().equals(keyword)) {
super.completeKeyword(keyword, contentAssistContext, acceptor);
}
}

definition_stream:
	(ann += annotation)* DEFINE STREAM source '(' feature += Features (',' feature += Features )* ')'';'?		 		
;
annotation:
	'@' name = name ('(' (ann_element += annotation_element | ann += annotation) 
		( ',' (ann_element += annotation_element | ann += annotation))* ')'	)
;
annotation_element:
	(prop_name = property_name '=')? prop_val = property_value
;

property_value:
	string_value
;

property_name:
	{property_name} name (property_separator name += name )*
;

property_separator:
	DOT | MINUS | COL
;
source:
	inner='#'? (str_id = stream_id)
;

stream_id:
	name
;

Features:
	(att_name = attribute_name) (type = attribute_type)
;

attribute_name:
	name
;
attribute_type:
	STRINGS | INTS| LONG | FLOAT | DOUBLE| BOOL| OBJECT 
;
keyword:
	STREAM 
	| DEFINE 
;
fragment STREAM: ('stream');
fragment DEFINE: ('define' );

fragment STRINGS: ('string');
fragment INTS: ('int');
fragment LONG: ('long');
fragment DOUBLE: ('double');
fragment FLOAT: ('float');
fragment BOOL: ('bool');
fragment OBJECT: ('object');

COL : ':';
DOT : '.';
MINUS : '-';

Model:
	DEFINE STREAM name=ID 		
;

fragment STREAM: ('stream');
fragment DEFINE: ('define' );

Model:
	DEFINE STREAM name=ID 		
;

fragment STREAM: (str='stream');
fragment DEFINE: (def='define' );

class MyDslProposalProvider extends AbstractMyDslProposalProvider {
	
	@Inject MyDslGrammarAccess ga
	
	override complete_DEFINE(EObject model, RuleCall ruleCall, ContentAssistContext context, ICompletionProposalAcceptor acceptor) {
		super.complete_DEFINE(model, ruleCall, context, acceptor)
		completeKeyword(ga.DEFINEAccess.defineKeyword, context, acceptor)
	}
	
	override complete_STREAM(EObject model, RuleCall ruleCall, ContentAssistContext context, ICompletionProposalAcceptor acceptor) {
		super.complete_STREAM(model, ruleCall, context, acceptor)
		completeKeyword(ga.STREAMAccess.streamKeyword, context, acceptor)
	}
	
	
	
}

define stream cseEventStream;
from cseEventStream;

ExecutionPlan:
DefinitionStream| Query
;
DefinitionStream:
DEFINE STREAM src=Source;
;
Query:
FROM src=Source;
;
Source:
	inner='#'? (strId = StreamId)
;

StreamId:
	na=Name
;

fragment STREAM: (str='stream');
fragment DEFINE: (define='define' );
fragment FROM: (from='from');

Keyword:
	{Keyword} STREAM 
	|{Keyword} DEFINE 
        |{Keyword} FROM
;

define stream cseEventStream;
from cseEventStream;

ExecutionPlan:
DefinitionStream| Query
;
DefinitionStream:
DEFINE STREAM src=Source;
;
Query:
FROM mSrc=MainSource ;
;
StandardStream:
MainSource 'Standard stream'
;

MainSource :
src=Source
;

Source:
	inner='#'? (strId = StreamId)
;

StreamId:
	na=Name
;

fragment STREAM: (str='stream');
fragment DEFINE: (define='define' );
fragment FROM: (from='from');

Keyword:
	{Keyword} STREAM 
	|{Keyword} DEFINE 
        |{Keyword} FROM
;

public class SiddhiQualifiedNameProvider extends DefaultDeclarativeQualifiedNameProvider {
	 QualifiedName qualifiedName(DefinitionStream ds){
		 MainSource  ms = (MainSource)ds.eContainer();
		return QualifiedName.create(ms.getSrc().toString(), ds.getSrc().toString());
		 
	 }

}

Name:
	k_word=Keyword | id_n=IdNew;
IdNew: ID| ID_QUOTES;

terminal ID_QUOTES: 
    '`'('a'..'z'|'A'..'Z'|'_')('a'..'z'|'A'..'Z'|'_'|'0'..'9')* '`' ;
 
@Override 
terminal ID:
	('a'..'z'|'A'..'Z'|'_')('a'..'z'|'A'..'Z'|'_'|'0'..'9')*
;
Keyword:
	{Keyword} STREAM 
	|{Keyword} DEFINE 
        |{Keyword} FROM
;

public void complete_Query(EObject model, RuleCall ruleCall, ContentAssistContext context, ICompletionProposalAcceptor acceptor) {
		// subclasses may override
	}

MainSource:
	src=[Source|Name] (preWindowHandlers = BasicSourceStreamHandlers)? (window = Win)?
;

IdNew: ID| ID_QUOTES;

terminal ID_QUOTES: 
    '`'('a'..'z'|'A'..'Z'|'_')('a'..'z'|'A'..'Z'|'_'|'0'..'9')* '`' ;
 
@Override 
terminal ID:
	('a'..'z'|'A'..'Z'|'_')('a'..'z'|'A'..'Z'|'_'|'0'..'9')*
; 

Name:
	 id_n=IdNew//k_word=Keyword |
;

MainSource:
	src=[Source|Name] (preWindowHandlers = BasicSourceStreamHandlers)? (window = Win)?
;

Source:
	inner='#'? strId = [Name|IdNew]
;

Name:
	 id_n=IdNew//k_word=Keyword |
;
IdNew: ID| ID_QUOTES;

terminal ID_QUOTES: 
    '`'('a'..'z'|'A'..'Z'|'_')('a'..'z'|'A'..'Z'|'_'|'0'..'9')* '`' ;
 
@Override 
terminal ID:
	('a'..'z'|'A'..'Z'|'_')('a'..'z'|'A'..'Z'|'_'|'0'..'9')*
;

//The rule
DefinitionStream:
	(ann += Annotation)* DEFINE STREAM src=Source '(' feature += Features (',' feature += Features )* ')'';'?		 		
;
//test case
define stream cseEventStream (symbol string, price float, volume long); 

@info(name1 = 'query2')
define stream cseEventStream (symbol string, price float, volume long); 

@info(name1 = 'query2')
define stream StockStream (symbol string, price float, volume long);

DefinitionStream:
	 DEFINE STREAM src=Source 
;
Source:
	inner='#'? strId =[Name|IdNew] 
;
Name:
	 name=IdNew//k_word=Keyword |
;
IdNew: ID| ID_QUOTES;

terminal ID_QUOTES: 
    '`'('a'..'z'|'A'..'Z'|'_')('a'..'z'|'A'..'Z'|'_'|'0'..'9')* '`' ;
 
@Override 
terminal ID:
	('a'..'z'|'A'..'Z'|'_')('a'..'z'|'A'..'Z'|'_'|'0'..'9')*
;
Keyword:
	{Keyword} STREAM 
	|{Keyword} DEFINE
;

DefinitionStream:
	 DEFINE STREAM src=Source1 
;

Source:
	strId=[Source1|IdNew]//inner='#'? strId =[Name|IdNew] 
;

Source1:
	inner='#'? name = IdNew
;

QueryInput:
 FROM src=Source
;

define stream inputStream (symbol string, price object, volume long);
@info(name = 'query1') from inputStream select symbol,price, 
cast(price, 'double') as priceInDouble insert into outputStream;

define stream cseEventStream (symbol string, price1 double, price2 float, volume long , quantity int);
@info(name = 'query1') from cseEventStream select symbol, coalesce(price1,price2) as price,quantity 
insert into outputStream ;

DefinitionStream:
	 DEFINE STREAM src=Source1 
;

Source:
	strId=[Source1|IdNew]//inner='#'? strId =[Name|IdNew] 
;

Source1:
	inner='#'? name = IdNew
;

QueryInput:
 FROM src=Source
;

define stream inputStream (symbol string, price object, volume long);
from inputStream 

define stream cseEventStream (symbol string, price1 double, price2 float, volume long , quantity int);
 from cseEventStream 

@Override
	public IScope getScope(EObject context, EReference reference) {
		if (context instanceof Source1) {
			Source1 src1 = (Source1)context;
			MainSource src = (MainSource) src1.eContainer();
		}
		
		return super.getScope(context, reference);
		
	}

QueryInput:
FROM MainSource ;

MainSource :
src=Source;

define stream inputStream (symbol string, price object, volume long);
from inputStream 

@Override
	public IScope getScope(EObject context, EReference reference){
		
		if(context instanceof DefinitionStream && reference == SiddhiQLPackage.eINSTANCE.getSource_StrId()){
			DefinitionStream source = (DefinitionStream) context;
			MainSource mainSrc = (MainSource)source.eContainer();
			
			return Scopes.scopeFor(mainSrc.getSrc());
		}
		return super.getScope(context, reference);
		
	}

AttributeReference:
	=>attrName2 = AttributeName
	|{AttributeReference} name1=(Source|EventReference)	
;
Source:
	strId=[Source1|IdNew]//inner='#'? strId =[Name|IdNew] 
;

Source1:
	inner='#'? name = IdNew
;
StandardStatefulSource:
	(name=IdNew '=')? basic_src=BasicSource
;

EventReference:
	na=[StandardStatefulSource|IdNew]
;

DefinitionStream:
	 DEFINE STREAM src=Source1 
;

Source:
	strId=[Source1|IdNew]//inner='#'? strId =[Name|IdNew] 
;

Source1:
	inner='#'? name = IdNew
;

QueryInput:
FROM MainSource ;

MainSource :
src=Source;

@Override
	public IScope getScope(EObject context, EReference reference){
		
		if(context instanceof DefinitionStream && reference == SiddhiQLPackage.eINSTANCE.getSource_StrId()){
			DefinitionStream source = (DefinitionStream) context;
			MainSource mainSrc = (MainSource)source.eContainer();
			
			return Scopes.scopeFor(Lists.newArrayList(mainSrc.getSrc()));
		}
		return super.getScope(context, reference);
		
	}

define stream stream1 ;
from stream1 ;

define stream stream2 ;
from stream2 ;

define stream stream3 ;
from stream3 ;

DefinitionStream:
	 DEFINE STREAM src=Source1 
;

Source1:
	inner='#'? name = IdNew
;

Source:
	strId=[Source1|IdNew]
;

MainSource :
src=Source;

QueryInput:
FROM MainSource ;

fragment STREAM: (str='stream');
fragment DEFINE: (define='define' );
fragment FROM: (from='from');

ExecutionPlan:
(defStream+=DefinitionStream)* ';'?
|(qi+=queryInput) (';' qi+=queryInput)* ';'?
|(defStream+=DefinitionStream)(';' defStream+=DefinitionStream)*(';' qi+=queryInput) ';'?
;

define stream stream1 ;
from stream1 ;

define stream stream2 ;
define stream stream3 ;
from stream2 ;

define stream stream1;
from stream1;

Model:
	ExecutionPlan
;

ExecutionPlan:
{ExecutionPlan}(defStream+=DefinitionStream|defTable+=DefinitionTable)(';' defStream+=DefinitionStream|defTable+=DefinitionTable)* ';'?
|(qi+=QueryInput) (';' qi+=QueryInput)* ';'?
|(defStream+=DefinitionStream|defTable+=DefinitionTable)(';' defStream+=DefinitionStream|defTable+=DefinitionTable)*(';' qi+=QueryInput) ';'?
;

DefinitionStream:
	 DEFINE STREAM src=Source1 
;

DefinitionTable:
	DEFINE TABLE src=Source1
;

Source1:
	inner='#'? name = IdNew
;

Source:
	strId=[Source1|IdNew]
;

QueryInput:
	FROM src=Source//ss=StandardStream
 ;
 
IdNew: ID| ID_QUOTES;

terminal ID_QUOTES: 
    '`'('a'..'z'|'A'..'Z'|'_')('a'..'z'|'A'..'Z'|'_'|'0'..'9')* '`' 
;
 
@Override 
terminal ID:
	('a'..'z'|'A'..'Z'|'_')('a'..'z'|'A'..'Z'|'_'|'0'..'9')*
; 

fragment STREAM: (str='stream');
fragment TABLE: (tab='table');
fragment DEFINE: (define='define' );
fragment FROM: (from='from');

Model:
	(execPlan+=ExecutionPlan)* 
;

ExecutionPlan:
{ExecutionPlan}(defStream+=DefinitionStream|defTable+=DefinitionTable)(';' defStream+=DefinitionStream|defTable+=DefinitionTable)* ';'?
|(qi+=QueryInput) (';' qi+=QueryInput)* ';'?
|(defStream+=DefinitionStream|defTable+=DefinitionTable)(';' defStream+=DefinitionStream|defTable+=DefinitionTable)*(';' qi+=QueryInput) ';'?
;

DefinitionStream:
	 DEFINE STREAM src=Source1 
;

DefinitionTable:
	DEFINE TABLE src=Source1
;

Source1:
	inner='#'? name = IdNew
;

Source:
	strId=[Source1|IdNew]
;

QueryInput:
	FROM src=Source//ss=StandardStream
 ;
 
IdNew: ID| ID_QUOTES;

terminal ID_QUOTES: 
    '`'('a'..'z'|'A'..'Z'|'_')('a'..'z'|'A'..'Z'|'_'|'0'..'9')* '`' 
;
 
@Override 
terminal ID:
	('a'..'z'|'A'..'Z'|'_')('a'..'z'|'A'..'Z'|'_'|'0'..'9')*
; 

fragment STREAM: (str='stream');
fragment TABLE: (tab='table');
fragment DEFINE: (define='define' );
fragment FROM: (from='from');

ExecutionPlan:
{ExecutionPlan}
(defStream+=DefinitionStream|defTable+=DefinitionTable)(->';' (defStream+=DefinitionStream|defTable+=DefinitionTable))* (->';' qi+=QueryInput) ';'?
|
(qi+=QueryInput) (->';' qi+=QueryInput)* ';'?
;

error(211): ../org.example.siddhi/src-gen/org/xtext/example/siddhiql/parser/antlr/internal/InternalSiddhiQLParser.g:151:6: [fatal] rule ruleExecutionPlan has non-LL(*) decision due to recursive rule invocations reachable from alts 2,3.  Resolve by left-factoring or using syntactic predicates or using backtrack=true option.
error(211): ../org.example.siddhi/src-gen/org/xtext/example/siddhiql/parser/antlr/internal/InternalSiddhiQLParser.g:257:7: [fatal] rule ruleExecutionPlan has non-LL(*) decision due to recursive rule invocations reachable from alts 2,3.  Resolve by left-factoring or using syntactic predicates or using backtrack=true option.
error(211): ../org.example.siddhi/src-gen/org/xtext/example/siddhiql/parser/antlr/internal/InternalSiddhiQLParser.g:358:6: [fatal] rule ruleExecutionPlan has non-LL(*) decision due to recursive rule invocations reachable from alts 1,2.  Resolve by left-factoring or using syntactic predicates or using backtrack=true option.
error(211): ../org.example.siddhi/src-gen/org/xtext/example/siddhiql/parser/antlr/internal/InternalSiddhiQLParser.g:129:4: [fatal] rule ruleExecutionPlan has non-LL(*) decision due to recursive rule invocations reachable from alts 1,2.  Resolve by left-factoring or using syntactic predicates or using backtrack=true option.
error(211): ../org.example.siddhi/src-gen/org/xtext/example/siddhiql/parser/antlr/internal/InternalSiddhiQLParser.g:385:4: [fatal] rule ruleExecutionPlan has non-LL(*) decision due to recursive rule invocations reachable from alts 1,2.  Resolve by left-factoring or using syntactic predicates or using backtrack=true option.
error(211): ../org.example.siddhi/src-gen/org/xtext/example/siddhiql/parser/antlr/internal/InternalSiddhiQLParser.g:411:2: [fatal] rule ruleExecutionElement has non-LL(*) decision due to recursive rule invocations reachable from alts 1,2.  Resolve by left-factoring or using syntactic predicates or using backtrack=true option.
error(211): ../org.example.siddhi/src-gen/org/xtext/example/siddhiql/parser/antlr/internal/InternalSiddhiQLParser.g:3446:2: [fatal] rule ruleJoinStream has non-LL(*) decision due to recursive rule invocations reachable from alts 3,4.  Resolve by left-factoring or using syntactic predicates or using backtrack=true option.
error(211): ../org.example.siddhi/src-gen/org/xtext/example/siddhiql/parser/antlr/internal/InternalSiddhiQLParser.g:3972:3: [fatal] rule ruleMainSource has non-LL(*) decision due to recursive rule invocations reachable from alts 1,2.  Resolve by left-factoring or using syntactic predicates or using backtrack=true option.
error(211): ../org.example.siddhi/src-gen/org/xtext/example/siddhiql/parser/antlr/internal/InternalSiddhiQLParser.g:4711:2: [fatal] rule ruleEveryPatternSourceChain1 has non-LL(*) decision due to recursive rule invocations reachable from alts 1,2.  Resolve by left-factoring or using syntactic predicates or using backtrack=true option.
error(211): ../org.example.siddhi/src-gen/org/xtext/example/siddhiql/parser/antlr/internal/InternalSiddhiQLParser.g:5106:2: [fatal] rule rulePatternSource has non-LL(*) decision due to recursive rule invocations reachable from alts 1,3.  Resolve by left-factoring or using syntactic predicates or using backtrack=true option.
error(211): ../org.example.siddhi/src-gen/org/xtext/example/siddhiql/parser/antlr/internal/InternalSiddhiQLParser.g:5364:2: [fatal] rule ruleLogicalStatefulSource has non-LL(*) decision due to recursive rule invocations reachable from alts 2,3.  Resolve by left-factoring or using syntactic predicates or using backtrack=true option.
error(211): ../org.example.siddhi/src-gen/org/xtext/example/siddhiql/parser/antlr/internal/InternalSiddhiQLParser.g:6014:2: [fatal] rule ruleSequenceSource has non-LL(*) decision due to recursive rule invocations reachable from alts 1,2.  Resolve by left-factoring or using syntactic predicates or using backtrack=true option.
error(211): ../org.example.siddhi/src-gen/org/xtext/example/siddhiql/parser/antlr/internal/InternalSiddhiQLParser.g:6484:2: [fatal] rule rulePartitionWithStream has non-LL(*) decision due to recursive rule invocations reachable from alts 1,2.  Resolve by left-factoring or using syntactic predicates or using backtrack=true option.

ExecutionPlan:
	(appAnn+=AppAnnotation)* ( //(defStream+=DefinitionStream| def_table+=DefinitionTable| def_window+=DefinitionWindow | defTrigger+=DefinitionTrigger | defFunction+=DefinitionFunction | err+=Error) (';' (defStream+=DefinitionStream| def_table+=DefinitionTable| def_window+=DefinitionWindow | defTrigger+=DefinitionTrigger | defFunction+=DefinitionFunction | err+=Error))* ';'?
	((exElement+=ExecutionElement) 
	|(defStream+=DefinitionStream| def_table+=DefinitionTable| def_window+=DefinitionWindow | defTrigger+=DefinitionTrigger | defFunction+=DefinitionFunction)(';' (defStream+=DefinitionStream| def_table+=DefinitionTable| def_window+=DefinitionWindow | defTrigger+=DefinitionTrigger | defFunction+=DefinitionFunction))*) (';' (exElement+=ExecutionElement))* ';'?) 
;

ExecutionElement:
	que=Query|execPartition=ExecPartition
;

JoinStream:
	left_source=JoinSource right_source=JoinSource right_uni=UNIDIRECTIONAL (on=ON expr=Expression)? wt=WithinTime? 
	|left_source=JoinSource join=joins right_source=JoinSource (on=ON expr=Expression)? wt=WithinTime?
	|left_source=JoinSource left_uni=UNIDIRECTIONAL join=joins right_source=JoinSource (on=ON expr=Expression)? wt=WithinTime?
	|ss=StandardStream
;

MainSource:
	src=Source (preWindowHandlers = BasicSourceStreamHandlers)? (window = Win)?
;

EveryPatternSourceChain:
	EveryPatternSourceChain1 ({EveryPatternSourceChain.left=current} op= '->' right=EveryPatternSourceChain1)*     
;

EveryPatternSourceChain1 returns EveryPatternSourceChain:
	'('eps=EveryPatternSourceChain')' wt=WithinTime?
	|psc=PatternSourceChain 
	//|EVERY psc1=PatternSourceChain1 
	|every=EVERY '('psc=PatternSourceChain ')' wt=WithinTime? //every error
	|every=EVERY ps1=PatternSource wt=WithinTime? 
;

PatternSource:
	{PatternSource}lss=LogicalStatefulSource|{PatternSource}pss=PatternCollectionStatefulSource|{PatternSource}stdss=StandardStatefulSource
;

LogicalStatefulSource:
	not=NOT stdSource+=StandardStatefulSource (and=AND stdSource+=StandardStatefulSource) //and error,not error
    |stdSource+=StandardStatefulSource and=AND stdSource+=StandardStatefulSource //and error
    |stdSource+=StandardStatefulSource or=OR stdSource+=StandardStatefulSource
;

SequenceSource:
	LogicalStatefulSource|SequenceCollectionStatefulSource|StandardStatefulSource
;

PartitionWithStream:
	attr=Attribute of=OF str_id1=Source //str_id1=StreamId ...
	|ConditionRanges of=OF str_id2=Source //str_id2=StreamId
;

SequenceSource:
	=>LogicalStatefulSource|=>SequenceCollectionStatefulSource|StandardStatefulSource
;


LogicalStatefulSource:
	=>(not=NOT stdSource+=StandardStatefulSource (and=AND stdSource+=StandardStatefulSource)) //and error,not error
    |=>(stdSource+=StandardStatefulSource and=AND stdSource+=StandardStatefulSource) //and error
    |=>(stdSource+=StandardStatefulSource or=OR stdSource+=StandardStatefulSource)
;


SequenceCollectionStatefulSource:
	=>(StandardStatefulSource ('<' coll=Collect '>'|zero_or_more='*'|zero_or_one='?'|one_or_more='+'))
;

Model:
	(elements += ExecutionPlan)*
;
ExecutionPlan:
	(appAnn+=AppAnnotation)* ( //(defStream+=DefinitionStream| def_table+=DefinitionTable| def_window+=DefinitionWindow | defTrigger+=DefinitionTrigger | defFunction+=DefinitionFunction | err+=Error) (';' (defStream+=DefinitionStream| def_table+=DefinitionTable| def_window+=DefinitionWindow | defTrigger+=DefinitionTrigger | defFunction+=DefinitionFunction | err+=Error))* ';'?
	((exElement+=ExecutionElement) 
	|(defStream+=DefinitionStream| def_table+=DefinitionTable| def_window+=DefinitionWindow | defTrigger+=DefinitionTrigger | defFunction+=DefinitionFunction)(';' (defStream+=DefinitionStream| def_table+=DefinitionTable| def_window+=DefinitionWindow | defTrigger+=DefinitionTrigger | defFunction+=DefinitionFunction))*) (';' (exElement+=ExecutionElement))* ';'?) 
;

ExecutionElement:
	que=Query|execPartition=ExecPartition
;


AppAnnotation:
	 '@' APP ':' na=Name ('(' ann5+=AnnotationElement (',' ann5+=AnnotationElement )* ')' )?
;

APP: (ap='app');

Query:
	"query" name=ID
;

ExecPartition:
	"execPart" name=ID
;

DefinitionStream:
	{DefinitionStream} (ann += Annotation)* DEFINE STREAM src=Source1 '(' feature += Features (',' feature += Features )* ')'';'?		 		
;

DefinitionTable:
	(ann1 += Annotation)* DEFINE TABLE src=Source1 '(' feature += Features (',' feature += Features )* ')'';'?			
;

DefinitionWindow:
	(ann2 += Annotation)* DEFINE WINDOW src=Source1 '(' feature += Features (',' feature += Features )* ')' funcOp = FunctionOperation ( OUTPUT opEventType=OutputEventType )? ';'? 
;

fragment OUTPUT: (output='output' );
OutputEventType:
	{OutputEventType}ALL EVENTS |{OutputEventType} ALL RAW EVENTS |{OutputEventType} EXPIRED EVENTS |{OutputEventType} EXPIRED RAW EVENTS |{OutputEventType} CURRENT? EVENTS
;

fragment FALSE: (fals='false');
fragment TRUE: (tr='true');
fragment RAW: (raw='raw' );
fragment EVENTS: (events='events' );
fragment ALL: (all='all' );
fragment EXPIRED: (expired='expired' );
fragment CURRENT: (currt='current' );

AttributeList:
	{AttributeList}((attr += Attribute) (',' attr += Attribute)* ) |{AttributeList}'*'
;

ConstantValue:
	{ConstantValue}bv=BoolValue

	;

BoolValue:
	TRUE|FALSE
;


Attribute:
	mathOp=ConstantValue
;

FunctionOperation:
	{FunctionOperation}(funcNamespace=FunctionNamespace ':')? funcId=FunctionId '(' (attrList=AttributeList)? ')'
;

FunctionNamespace:
	na=Name
;

FunctionId:
	na=Name
;

Source1:
	inner='#'? name = IdNew
;

Features:
	(name = AttributeName) (type = AttributeType)
;

AttributeName:
	name = IdNew
;

fragment STRINGS: (string='string');
fragment INTS: (int='int');
fragment LONG: (long='long');
fragment DOUBLE: (double='double');
fragment FLOAT: (float='float');
fragment BOOL: (bool='bool');
fragment OBJECT: (object='object');
fragment RETURN: (return='return');


AttributeType:
	{AttributeType}STRINGS |{AttributeType} INTS|{AttributeType} LONG |{AttributeType} FLOAT |{AttributeType} DOUBLE|{AttributeType} BOOL|{AttributeType} OBJECT 
;

DefinitionTrigger:
	DEFINE TRIGGER tn=TriggerName AT (every=EVERY tv=TimeValue | sv=StringValue) ';'?
;

TimeValue:
	v=INT "ms"
;

FunctionBody:
	value=SCRIPT
;

terminal SCRIPT:
	'{' -> '}'
;

DefinitionFunction:
	DEFINE FUNCTION fn=FunctionName '[' ln=LanguageName ']' RETURN attr_type=AttributeType func_body=FunctionBody ';'?
;

FunctionName:
	id=ID
;

LanguageName:
	id=ID
;


TriggerName:
	id=ID
;

EVERY: (every='every' );

fragment AT: (at='at' );

    
Annotation:
	'@' na = Name ('(' (annElement += AnnotationElement | ann += Annotation) 
		( ',' (annElement += AnnotationElement | ann += Annotation))* ')'	)
;

AnnotationElement:
	(propName = PropertyName '=')? propVal = PropertyValue
;

PropertyValue:
	sv=StringValue
;

PropertyName:
	{PropertyName} na+=Name (ps+=PropertySeparator na += Name )*
;

StringValue:
	sl=STRING_LITERAL
;


STRING_LITERAL:
	STRING
;

PropertySeparator:
	{PropertySeparator}DOT |{PropertySeparator} MINUS |{PropertySeparator} COL
;

COL : ':';

MINUS : '-';

DOT : '.';

IdNew: ID;

Name:
	 na=IdNew//k_word=Keyword |
;


fragment TRIGGER: (trigger='trigger' );
fragment FUNCTION: (function='function');
fragment STREAM: (str='stream');
fragment DEFINE: (define='define' );
fragment TABLE: (table='table' );
fragment WINDOW: (window='window' );

ExecutionPlan:
	(appAnn+=AppAnnotation)* 
	( //(defStream+=DefinitionStream| def_table+=DefinitionTable| def_window+=DefinitionWindow | defTrigger+=DefinitionTrigger | defFunction+=DefinitionFunction | err+=Error) (';' (defStream+=DefinitionStream| def_table+=DefinitionTable| def_window+=DefinitionWindow | defTrigger+=DefinitionTrigger | defFunction+=DefinitionFunction | err+=Error))* ';'?
	(
		(exElement+=ExecutionElement) 
	|
	=>(defStream+=DefinitionStream
		| def_table+=DefinitionTable
		| def_window+=DefinitionWindow 
		| defTrigger+=DefinitionTrigger 
		| defFunction+=DefinitionFunction
	)(';' =>(
		defStream+=DefinitionStream|
		 def_table+=DefinitionTable|
		  def_window+=DefinitionWindow |
		   defTrigger+=DefinitionTrigger |
		    defFunction+=DefinitionFunction
	))*) =>(';' (exElement+=ExecutionElement))* ';'?) 
;

DefinitionStream:
	=>({DefinitionStream} (ann += Annotation)* DEFINE STREAM) src=Source1 '(' feature += Features (',' feature += Features )* ')'';'?		 		
;

DefinitionTable:
	=>((ann1 += Annotation)* DEFINE TABLE) src=Source1 '(' feature += Features (',' feature += Features )* ')'';'?			
;

DefinitionWindow:
	=>((ann2 += Annotation)* DEFINE WINDOW) src=Source1 '(' feature += Features (',' feature += Features )* ')' funcOp = FunctionOperation ( OUTPUT opEventType=OutputEventType )? ';'? 
;

DefinitionTrigger:
	=>(DEFINE TRIGGER) tn=TriggerName AT (every=EVERY tv=TimeValue | sv=StringValue) ';'?
;

DefinitionStream:
	=>({DefinitionStream} (ann += Annotation)* DEFINE STREAM) src=Source1 '(' feature += Features (',' feature += Features )* ')'';'?		 		
;

DefinitionTable:
	=>((ann1 += Annotation)* DEFINE TABLE) src=Source1 '(' feature += Features (',' feature += Features )* ')'';'?			
;

DefinitionWindow:
	=>((ann2 += Annotation)* DEFINE WINDOW) src=Source1 '(' feature += Features (',' feature += Features )* ')' funcOp = FunctionOperation ( OUTPUT opEventType=OutputEventType )? ';'? 
;

DefinitionTrigger:
	=>(DEFINE TRIGGER) tn=TriggerName AT (every=EVERY tv=TimeValue | sv=StringValue) ';'?
;

JoinStream:
	left_source=JoinSource right_source=JoinSource right_uni=UNIDIRECTIONAL (on=ON expr=Expression)? wt=WithinTime? //unidirectional error, on error
	|left_source=JoinSource join=joins right_source=JoinSource (on=ON expr=Expression)? wt=WithinTime?
	|left_source=JoinSource left_uni=UNIDIRECTIONAL join=joins right_source=JoinSource (on=ON expr=Expression)? wt=WithinTime?//on error, uni error
	|ss=StandardStream
;

JoinStream:
	=>ss=StandardStream
	|left_source=JoinSource (right_source=JoinSource right_uni=UNIDIRECTIONAL|join=joins right_source=JoinSource|left_uni=UNIDIRECTIONAL join=joins right_source=JoinSource) (on=ON expr=Expression)? wt=WithinTime? 
;

if (reference === SiddhiQLPackage.eINSTANCE.source_StrId) {
			val execPlan = EcoreUtil2.getContainerOfType(context, ExecutionPlan)
				if (execPlan !== null) {
					return Scopes.scopeFor(execPlan.defStream.map[src])
				}
		}
		
		if (reference === SiddhiQLPackage.eINSTANCE.source_StrId) {
			val execPlan = EcoreUtil2.getContainerOfType(context, ExecutionPlan)
				if (execPlan !== null) {
					return Scopes.scopeFor(execPlan.def_table.map[src])
				}
		}

if (reference === SiddhiQLPackage.eINSTANCE.source_StrId) {
			val execPlan = EcoreUtil2.getContainerOfType(context, ExecutionPlan)
				if (execPlan !== null) {
					return Scopes.scopeFor(execPlan.defStream.map[src])
				}
		}
		else if (reference === SiddhiQLPackage.eINSTANCE.source_StrId) {
			val execPlan = EcoreUtil2.getContainerOfType(context, ExecutionPlan)
				if (execPlan !== null) {
					return Scopes.scopeFor(execPlan.def_table.map[src])
				}
		}
		else if (reference === SiddhiQLPackage.eINSTANCE.attributeNameReference_AttrName1) {
			val execPlan = EcoreUtil2.getContainerOfType(context, ExecutionPlan)
				if (execPlan !== null) {					
					for(i:0..<execPlan.defStream.map[feature].length){
						return Scopes.scopeFor(execPlan.defStream.map[feature].get(i))
					}					
				}
		}

ExecutionPlan:
	(appAnn+=AppAnnotation)* ( 	((exElement+=Query) 
	|=>(defStream+=DefinitionStream| def_table+=DefinitionTable)(->';' 
	=>(	defStream+=DefinitionStream|def_table+=DefinitionTable))*) =>(->';' (exElement+=Query))* ';'?) 
;

DefinitionStream:
	=>({DefinitionStream} DEFINE STREAM) src=Source1 '(' feature += Features (',' feature += Features )* ')'//';'?		 		
;

DefinitionTable:
	=>(DEFINE TABLE) src=Source1 '(' feature += Features (',' feature += Features )* ')'//';'?			
;

Source:
	strId=[Source1|IdNew] 
;

Source1:
	inner='#'? name = IdNew
;

Features:
	(name=IdNew)
;

Query:
        qi=QueryInput qs=QuerySection
;

QueryInput:
       FROM Source
;

QuerySection:
      SELECT attr= [Features|IdNew]
;

fragment STREAM: (str='stream');
fragment DEFINE: (define='define' );
fragment TABLE: (table='table' );
fragment FROM: (from='from');
fragment SELECT: (select='select');

//execution plan 1
define stream1 (f1,f2);
from stream1 select f1,f2;

//execution plan 2
define stream2 (f3,f4);
from stream2 select f3;

IdNew: ID;

if (reference === SiddhiQLPackage.eINSTANCE.source_StrId) {
			val execPlan = EcoreUtil2.getContainerOfType(context, ExecutionPlan)
				if (execPlan.defStream !== null) {					
					return Scopes.scopeFor(execPlan.defStream.map[src])
				}
				else if(execPlan.def_table !== null){
					return Scopes.scopeFor(execPlan.def_table.map[src])
				}
		}

define stream stream1 (f1,f2);
define table table1 (f3,f4);
from table1 select f3;

if (execPlan.defStream.length !== 0)

ExecutionPlan:
	(appAnn+=AppAnnotation)* ( 	((exElement+=ExecutionElement) 
	|=>(defStream+=DefinitionStream| def_table+=DefinitionTable)(->';' 
	=>(	defStream+=DefinitionStream|def_table+=DefinitionTable))*) =>(->';' (exElement+=ExecutionElement))* ';'?) 
;

ExecutionElement:
         qu=Query
;
DefinitionStream:
	=>({DefinitionStream} DEFINE STREAM) src=Source1 '(' feature += Features (',' feature += Features )* ')'//';'?		 		
;

DefinitionTable:
	=>(DEFINE TABLE) src=Source1 '(' feature += Features (',' feature += Features )* ')'//';'?			
;

Source:
	strId=[Source1|IdNew] 
;

Source1:
	inner='#'? name = IdNew
;

Features:
	(name=IdNew)
;

Query:
        qi=QueryInput qs=QuerySection
;

QueryInput:
       FROM Source|ps=StandardStatefulSource:
;

StandardStatefulSource:
       	(name=IdNew '=')
;

QuerySection:
      SELECT attr= [Features|IdNew]  stss=[StandardStatefulSource|IdNew]
;

IdNew :
        ID;

fragment STREAM: (str='stream');
fragment DEFINE: (define='define' );
fragment TABLE: (table='table' );
fragment FROM: (from='from');
fragment SELECT: (select='select');

   val execPlan = EcoreUtil2.getContainerOfType(context, ExecutionPlan)
   val execElement = EcoreUtil2.getContainerOfType(execPlan, ExecutionElement)
   val query = EcoreUtil2.getContainerOfType(execElement, Query)
   val queryInput = EcoreUtil2.getContainerOfType(query, QueryInput)

if(queryInput !==null){
	return Scopes.scopeFor(queryInput .ps.eContents)
}

QuerySection:
      SELECT attr= [Features|IdNew]  stss=[StandardStatefulSource|IdNew]
;

val execPlan = EcoreUtil2.getContainerOfType(context, ExecutionPlan)
   val execElement = EcoreUtil2.getContainerOfType(execPlan, ExecutionElement)
   val query = EcoreUtil2.getContainerOfType(execElement, Query)
   val queryInput = EcoreUtil2.getContainerOfType(query, QueryInput)

val execPlan = EcoreUtil2.getAllContentsOfType(context,ExecutionPlan)

execPlan.def_table.map[src]

Query:
	{Query}(ann3 += Annotation)* FROM (qInp = QueryInput ) (querySec = QuerySection)? outRate=OutputRate? (qOutput = QueryOutput)
;

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