marianogonzalez

SELECT Id, Name, Body FROM Attachment WHERE Id = '#[message.inboundProperties['id']]'

marianogonzalez

package org.mule.sfdc2boxnet.transformer;

import java.util.List;
import java.util.Map;

import org.mule.api.MuleMessage;
import org.mule.api.transformer.TransformerException;
import org.mule.transformer.AbstractMessageTransformer;
import org.mule.transformer.codec.Base64Decoder;

marianogonzalez

<sfdc:query config-ref="Salesforce" query="SELECT Id, Name, Body FROM Attachment WHERE Id = '#[message.inboundProperties['id']]'" />
        <choice>
            <when expression="return ((ArrayList)payload).size &gt; 0">
                <processor-chain>
                    <expression-transformer expression="return payload[0]"/>
                    <set-variable variableName="attachName" value="#[payload['name']]" />
                    <set-payload value="#[payload['body']]" />
                    <base64-decoder-transformer />
                    <scripting:transformer doc:name="to InputStream">
                        <scripting:script engine="Groovy">

marianogonzalez

payload.getRowNumber() > 1

marianogonzalez

<set-payload value="#[jxpath://cells[columnNumber = '2']/evaluatedValue]">

marianogonzalez

<google-calendars:get-events
      config-ref="google-calendars"
      calendarId="#[variable:googleUser]"
      lastUpdated="#[variable:formatedLastSyncDate]"
      showDeleted="true"
      accessTokenId="#[variable:googleTokenId]" />

marianogonzalez

<flow name="authorize" doc:name="authorize">
    <http:inbound-endpoint exchange-pattern="request-response"
	host="localhost" port="8081" path="authorize" />
		
    <google-spreadsheets:authorize config-ref="google-spreadsheets" state="#[message.inboundProperties['user']]"/>
        
    <scripting:transformer>
        <scripting:script engine="Groovy">
            <scripting:text><![CDATA[
                org.mule.examples.google.sfdc2google.UserIdMapping mapping = new org.mule.examples.google.sfdc2google.UserIdMapping();

marianogonzalez

public class GoogleCalendarConnectorOAuthState implements Serializable
{

    public String accessToken;
    public String authorizationUrl;
    public String accessTokenUrl;
    public String refreshToken;

    /**
     * Retrieves accessToken

marianogonzalez

public class SharedOAuthTokenTransformer extends AbstractMessageTransformer {

	private ObjectStore<Serializable> objectStore;
	
	 @Override
	public Object transformMessage(MuleMessage message, String outputEncoding) throws TransformerException {
		
		 String accessTokenId = message.getInvocationProperty("OAuthAccessTokenId");
		
		if (StringUtils.isBlank(accessTokenId)) {

marianogonzalez

<flow name="authorize">
	<https:inbound-endpoint exchange-pattern="request-response" host="localhost" port="${https.port}" path="authorize">
		
	<google-calendars:authorize config-ref="google-calendars" />

	<logger message="Access token id is #[flowVars['OAuthAccessTokenId']]" />
	<transformer ref="shareOAuthStateTransformer" />

</flow>