Track downloads using Google Analytics API

<?xml version="1.0" encoding="UTF-8" ?>
<scenario parallel="true">
<!--
To run this scenario you will need 3 connections:

1. Google OAuth2 endpoint to obtain access token: https://www.googleapis.com/oauth2/v3/token
2. End point for Google Analytics API which tracks events: https://www.googleapis.com/analytics/v3/data/ga?ids=ga%3A62341659&dimensions=ga%3AeventLabel%2Cga%3Adate%2Cga%3Ahour%2Cga%3Aminute%2Cga%3Acountry&metrics=ga%3AtotalEvents&filters=ga%3AeventCategory%3D%3Ddownload&start-date={ga_start_date}&end-date={ga_end_date}&max-results=1000000&access_token={ga_access_token}
3. Database connection where downloads tracking information will be stored, in this this particular case - MySQL
-->
     <name>Downloads report</name>
     <description>Downloads report</description>
     <script>downloads_report</script>
     <driver name="com.toolsverse.etl.driver.GenericJdbcDriver" parent="com.toolsverse.etl.driver.mysql.MySqlDriver" />
     <variables>
          <START_DATE label="Start Date">
               <item format="MM/dd/yyyy" required="true" type="calendar" />
          </START_DATE>
          <END_DATE label="End Date">
               <item format="MM/dd/yyyy" required="true" type="calendar" />
          </END_DATE>
     </variables>
     <sources>
          <source>
               <name>configuration</name>
               <extract>
                    <connection>Access Token</connection>
               </extract>Downloads report
               <tasks>
                    
                    <task noconnection="true" scope="after">
                         <name>get_access_token</name>
                         <class>com.toolsverse.etl.core.task.common.EvalTransformator</class>
                         <code>
                              <![CDATA[importPackage(com.toolsverse.config);
importPackage(com.toolsverse.util);
SystemConfig.instance().setSystemProperty('ga_access_token', dataSet.getFieldValue(currentRow, 'ACCESS_TOKEN'));
var startDate = scenario.getVariable('START_DATE').getValue();
if (Utils.isNothing(startDate)) {
     startDate = Utils.date2Str(com.toolsverse.util.DateUtil.addDays(new java.util.Date(), -1), 'yyyy-MM-dd');
}
SystemConfig.instance().setSystemProperty('ga_start_date', Utils.date2Str(DateUtil.parse(startDate), 'yyyy-MM-dd'));
var endDate = scenario.getVariable('END_DATE').getValue();
if (Utils.isNothing(endDate)) {
     endDate = Utils.date2Str(new java.util.Date(), 'yyyy-MM-dd');
}
SystemConfig.instance().setSystemProperty('ga_end_date', Utils.date2Str(DateUtil.parse(endDate), 'yyyy-MM-dd'));]]>
                         </code>
                         <variables>
                              <LANG value="JavaScript" />
                         </variables>
                    </task>
               </tasks>
          </source>
          <source>
               <name>downloads</name>
               <objectname>downloads</objectname>
               <extract/>
               <tasks>
                    <task noconnection="true">
                         <name>extract rows</name>
                         <class>com.toolsverse.etl.core.task.common.ExtractDimension</class>
                         <variables>
                              <NAME value="rows" />
                         </variables>
                         <onexception action="ignore" mask="Column rows not found" exception_message="There are no downloads between start and end dates" />
                    </task>
                    <task noconnection="true">
                         <name>extract downloads</name>
                         <class>com.toolsverse.etl.core.task.common.ExtractDimension</class>
                         <variables>
                              <NAME value="array" />
                         </variables>
                    </task>
               </tasks>
          </source>
     </sources>
     <destinations>
          <destination conditionlang="JavaScript" condition="value = scenario.getSources().get(name).getDataSet() != null 
          && scenario.getSources().get(name).getDataSet().getFieldDef('column0') != null;">
               <name>DOWNLOADS</name>
               <tablename>downloads</tablename>
               <metadata use="true" />
               <load>
                    <onexception action="ignore" mask="Duplicate entry" />
                    <variables>
                         <COLUMN0 field="column0" name="FILE_NAME" />
                         <COLUMN1 name="DOWNLOAD_DATE" field="column1" lang="JavaScript" sqltype="93" nativetype="DATETIME">
                              <code>
                                   <![CDATA[importPackage(com.toolsverse.util); 
var dateTime = {column1} + {column2} + {column3}; 
value = Utils.str2Date(dateTime, null, 'yyyyMMddHHmm');]]>
                              </code>
                         </COLUMN1>
                         <COLUMN2 exclude="true" field="column2" sqltype="4" />
                         <COLUMN3 exclude="true" field="column3" sqltype="4" />
                         <COLUMN4 field="column4" name="COUNTRY" />
                         <COLUMN5 field="column5" name="CNT" />
                    </variables>
               </load>
          </destination>
     </destinations>
</scenario>