source: contrib/psync/src/main/java/br/com/prognus/psync/phones/s55/SlowFastSyncManagement.java @ 1009

/**
 * Copyright (C) 2003-2007 Funambol
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the Honest Public License.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * Honest Public License for more details.
 *
 * You should have received a copy of the Honest Public License
 * along with this program; if not, write to Funambol,
 * 643 Bair Island Road, Suite 305 - Redwood City, CA 94063, USA
 */
package br.com.prognus.psync.phones.s55;

import com.funambol.framework.core.*;
import com.funambol.framework.engine.pipeline.MessageProcessingContext;
import com.funambol.framework.engine.pipeline.OutputMessageProcessor;
import com.funambol.framework.logging.FunambolLogger;
import com.funambol.framework.logging.FunambolLoggerFactory;

/**
 * This class check if the request of slow or fast sync is correct.
 *
 * @version $Id: SlowFastSyncManagement.java,v 1.3 2007-01-11 19:20:19 nichele Exp $
 */
public class SlowFastSyncManagement implements OutputMessageProcessor {

    // --------------------------------------------------------------- Constants

    public static final String PROPERTY_MANTYPE =
        "funambol.foundation.slowfastsyncmanagement.MANTYPE";
    public static final String PROPERTY_CODE    =
        "funambol.foundation.slowfastsyncmanagement.CODE"   ;

    // ------------------------------------------------------------ Private data
    private static final FunambolLogger log =
            FunambolLoggerFactory.getLogger("engine.pipeline");

    private static final String PHONE_SIEMENS = "siemens";

    // ---------------------------------------------------------- Public methods

    /**
     * Process and manipulate the output message.
     *
     * @param processingContext the message processing context
     * @param message the message to be processed
     * @throws Sync4jException
     */
    public void postProcessMessage(MessageProcessingContext processingContext,
                                   SyncML message) throws Sync4jException {
        if (log.isTraceEnabled()) {
            log.trace("postProcessMessage: SlowFastSyncManagement of output message");
        }

        try {

            //
            //Only if the device is Siemens55 apply the code
            //
            String man = (String)processingContext.getRequestProperty(PROPERTY_MANTYPE);
            if (log.isTraceEnabled()) {
                log.trace("postProcessMessage: man: " + man);
            }

            if (man != null && man.toLowerCase().indexOf(PHONE_SIEMENS) != -1) {

                AbstractCommand[] allCmd = (AbstractCommand[])
                    message.getSyncBody().getCommands().toArray(
                                                        new AbstractCommand[0]);
                //
                //Extract only alert commands
                //
                for (int i=0; (allCmd != null) && (i<allCmd.length); i++) {
                    if (Alert.COMMAND_NAME.equals(allCmd[i].getName())) {
                        Alert alertCmd = (Alert)allCmd[i];
                        int code = alertCmd.getData();

                        int codeRequest = Integer.parseInt("" + processingContext.getRequestProperty(PROPERTY_CODE));

                        if (code != codeRequest) {
                            if (code == AlertCode.SLOW) {
                                alertCmd.setData(AlertCode.TWO_WAY);
                            }
                        }
                    }//end if cmds
                }//end allCmd
            }

        } catch(Exception e) {
            log.error("Errore postprocessing the request", e);
        }
    }
}