src/com/android/exchange/adapter/AbstractSyncParser.java - platform/packages/apps/Exchange - Git at Google

 /*
  * Copyright (C) 2008-2009 Marc Blank
  * Licensed to The Android Open Source Project.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
  *
  *      http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */

 package com.android.exchange.adapter;

 import com.android.emailcommon.provider.EmailContent.Account;
 import com.android.emailcommon.provider.EmailContent.MailboxColumns;
 import com.android.emailcommon.provider.Mailbox;
 import com.android.exchange.CommandStatusException;
 import com.android.exchange.CommandStatusException.CommandStatus;
 import com.android.exchange.EasSyncService;
 import com.android.exchange.ExchangeService;

 import android.content.ContentResolver;
 import android.content.ContentValues;
 import android.content.Context;

 import java.io.IOException;
 import java.io.InputStream;

 /**
  * Base class for the Email and PIM sync parsers
  * Handles the basic flow of syncKeys, looping to get more data, handling errors, etc.
  * Each subclass must implement a handful of methods that relate specifically to the data type
  *
  */
 public abstract class AbstractSyncParser extends Parser {

     protected EasSyncService mService;
     protected Mailbox mMailbox;
     protected Account mAccount;
     protected Context mContext;
     protected ContentResolver mContentResolver;
     protected AbstractSyncAdapter mAdapter;

     private boolean mLooping;

     public AbstractSyncParser(InputStream in, AbstractSyncAdapter adapter) throws IOException {
         super(in);
         init(adapter);
     }

     public AbstractSyncParser(Parser p, AbstractSyncAdapter adapter) throws IOException {
         super(p);
         init(adapter);
     }

     private void init(AbstractSyncAdapter adapter) {
         mAdapter = adapter;
         mService = adapter.mService;
         mContext = mService.mContext;
         mContentResolver = mContext.getContentResolver();
         mMailbox = mService.mMailbox;
         mAccount = mService.mAccount;
     }

     /**
      * Read, parse, and act on incoming commands from the Exchange server
      * @throws IOException if the connection is broken
      * @throws CommandStatusException
      */
     public abstract void commandsParser() throws IOException, CommandStatusException;

     /**
      * Read, parse, and act on server responses
      * @throws IOException
      */
     public abstract void responsesParser() throws IOException;

     /**
      * Commit any changes found during parsing
      * @throws IOException
      */
     public abstract void commit() throws IOException;

     public boolean isLooping() {
         return mLooping;
     }

     /**
      * Skip through tags until we reach the specified end tag
      * @param endTag the tag we end with
      * @throws IOException
      */
     public void skipParser(int endTag) throws IOException {
         while (nextTag(endTag) != END) {
             skipTag();
         }
     }

     /**
      * Loop through the top-level structure coming from the Exchange server
      * Sync keys and the more available flag are handled here, whereas specific data parsing
      * is handled by abstract methods implemented for each data class (e.g. Email, Contacts, etc.)
      * @throws CommandStatusException
      */
     @Override
     public boolean parse() throws IOException, CommandStatusException {
         int status;
         boolean moreAvailable = false;
         boolean newSyncKey = false;
         int interval = mMailbox.mSyncInterval;
         mLooping = false;
         // If we're not at the top of the xml tree, throw an exception
         if (nextTag(START_DOCUMENT) != Tags.SYNC_SYNC) {
             throw new EasParserException();
         }

         boolean mailboxUpdated = false;
         ContentValues cv = new ContentValues();

         // Loop here through the remaining xml
         while (nextTag(START_DOCUMENT) != END_DOCUMENT) {
             if (tag == Tags.SYNC_COLLECTION || tag == Tags.SYNC_COLLECTIONS) {
                 // Ignore these tags, since we've only got one collection syncing in this loop
             } else if (tag == Tags.SYNC_STATUS) {
                 // Status = 1 is success; everything else is a failure
                 status = getValueInt();
                 if (status != 1) {
                     mService.errorLog("Sync failed: " + CommandStatus.toString(status));
                     if (status == 3 || CommandStatus.isBadSyncKey(status)) {
                         // Must delete all of the data and start over with syncKey of "0"
                         mAdapter.setSyncKey("0", false);
                         // Make this a push box through the first sync
                         // TODO Make frequency conditional on user settings!
                         mMailbox.mSyncInterval = Mailbox.CHECK_INTERVAL_PUSH;
                         mService.errorLog("Bad sync key; RESET and delete data");
                         mAdapter.wipe();
                         // Indicate there's more so that we'll start syncing again
                         moreAvailable = true;
                     } else if (status == 8) {
                         // This is Bad; it means the server doesn't recognize the serverId it
                         // sent us.  What's needed is a refresh of the folder list.
                         ExchangeService.reloadFolderList(mContext, mAccount.mId, true);
                     } else {
                         // Access, provisioning, transient, etc.
                         throw new CommandStatusException(status);
                     }
                 }
             } else if (tag == Tags.SYNC_COMMANDS) {
                 commandsParser();
             } else if (tag == Tags.SYNC_RESPONSES) {
                 responsesParser();
             } else if (tag == Tags.SYNC_MORE_AVAILABLE) {
                 moreAvailable = true;
             } else if (tag == Tags.SYNC_SYNC_KEY) {
                 if (mAdapter.getSyncKey().equals("0")) {
                     moreAvailable = true;
                 }
                 String newKey = getValue();
                 userLog("Parsed key for ", mMailbox.mDisplayName, ": ", newKey);
                 if (!newKey.equals(mMailbox.mSyncKey)) {
                     mAdapter.setSyncKey(newKey, true);
                     cv.put(MailboxColumns.SYNC_KEY, newKey);
                     mailboxUpdated = true;
                     newSyncKey = true;
                 }
                 // If we were pushing (i.e. auto-start), now we'll become ping-triggered
                 if (mMailbox.mSyncInterval == Mailbox.CHECK_INTERVAL_PUSH) {
                     mMailbox.mSyncInterval = Mailbox.CHECK_INTERVAL_PING;
                 }
            } else {
                 skipTag();
            }
         }

         // If we don't have a new sync key, ignore moreAvailable (or we'll loop)
         if (moreAvailable && !newSyncKey) {
             mLooping = true;
         }

         // Commit any changes
         commit();

         boolean abortSyncs = false;

         // If the sync interval has changed, we need to save it
         if (mMailbox.mSyncInterval != interval) {
             cv.put(MailboxColumns.SYNC_INTERVAL, mMailbox.mSyncInterval);
             mailboxUpdated = true;
         // If there are changes, and we were bounced from push/ping, try again
         } else if (mService.mChangeCount > 0 &&
                 mAccount.mSyncInterval == Account.CHECK_INTERVAL_PUSH &&
                 mMailbox.mSyncInterval > 0) {
             userLog("Changes found to ping loop mailbox ", mMailbox.mDisplayName, ": will ping.");
             cv.put(MailboxColumns.SYNC_INTERVAL, Mailbox.CHECK_INTERVAL_PING);
             mailboxUpdated = true;
             abortSyncs = true;
         }

         if (mailboxUpdated) {
              synchronized (mService.getSynchronizer()) {
                 if (!mService.isStopped()) {
                      mMailbox.update(mContext, cv);
                 }
             }
         }

         if (abortSyncs) {
             userLog("Aborting account syncs due to mailbox change to ping...");
             ExchangeService.stopAccountSyncs(mAccount.mId);
         }

         // Let the caller know that there's more to do
         if (moreAvailable) {
             userLog("MoreAvailable");
         }
         return moreAvailable;
     }

     void userLog(String ...strings) {
         mService.userLog(strings);
     }

     void userLog(String string, int num, String string2) {
         mService.userLog(string, num, string2);
     }
 }
	/*
	* Copyright (C) 2008-2009 Marc Blank
	* Licensed to The Android Open Source Project.
	*
	* Licensed under the Apache License, Version 2.0 (the "License");
	* you may not use this file except in compliance with the License.
	* You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*
	* Unless required by applicable law or agreed to in writing, software
	* distributed under the License is distributed on an "AS IS" BASIS,
	* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
	* See the License for the specific language governing permissions and
	* limitations under the License.
	*/

	package com.android.exchange.adapter;

	import com.android.emailcommon.provider.EmailContent.Account;
	import com.android.emailcommon.provider.EmailContent.MailboxColumns;
	import com.android.emailcommon.provider.Mailbox;
	import com.android.exchange.CommandStatusException;
	import com.android.exchange.CommandStatusException.CommandStatus;
	import com.android.exchange.EasSyncService;
	import com.android.exchange.ExchangeService;

	import android.content.ContentResolver;
	import android.content.ContentValues;
	import android.content.Context;

	import java.io.IOException;
	import java.io.InputStream;

	/**
	* Base class for the Email and PIM sync parsers
	* Handles the basic flow of syncKeys, looping to get more data, handling errors, etc.
	* Each subclass must implement a handful of methods that relate specifically to the data type
	*
	*/
	public abstract class AbstractSyncParser extends Parser {

	protected EasSyncService mService;
	protected Mailbox mMailbox;
	protected Account mAccount;
	protected Context mContext;
	protected ContentResolver mContentResolver;
	protected AbstractSyncAdapter mAdapter;

	private boolean mLooping;

	public AbstractSyncParser(InputStream in, AbstractSyncAdapter adapter) throws IOException {
	super(in);
	init(adapter);
	}

	public AbstractSyncParser(Parser p, AbstractSyncAdapter adapter) throws IOException {
	super(p);
	init(adapter);
	}

	private void init(AbstractSyncAdapter adapter) {
	mAdapter = adapter;
	mService = adapter.mService;
	mContext = mService.mContext;
	mContentResolver = mContext.getContentResolver();
	mMailbox = mService.mMailbox;
	mAccount = mService.mAccount;
	}

	/**
	* Read, parse, and act on incoming commands from the Exchange server
	* @throws IOException if the connection is broken
	* @throws CommandStatusException
	*/
	public abstract void commandsParser() throws IOException, CommandStatusException;

	/**
	* Read, parse, and act on server responses
	* @throws IOException
	*/
	public abstract void responsesParser() throws IOException;

	/**
	* Commit any changes found during parsing
	* @throws IOException
	*/
	public abstract void commit() throws IOException;

	public boolean isLooping() {
	return mLooping;
	}

	/**
	* Skip through tags until we reach the specified end tag
	* @param endTag the tag we end with
	* @throws IOException
	*/
	public void skipParser(int endTag) throws IOException {
	while (nextTag(endTag) != END) {
	skipTag();
	}
	}

	/**
	* Loop through the top-level structure coming from the Exchange server
	* Sync keys and the more available flag are handled here, whereas specific data parsing
	* is handled by abstract methods implemented for each data class (e.g. Email, Contacts, etc.)
	* @throws CommandStatusException
	*/
	@Override
	public boolean parse() throws IOException, CommandStatusException {
	int status;
	boolean moreAvailable = false;
	boolean newSyncKey = false;
	int interval = mMailbox.mSyncInterval;
	mLooping = false;
	// If we're not at the top of the xml tree, throw an exception
	if (nextTag(START_DOCUMENT) != Tags.SYNC_SYNC) {
	throw new EasParserException();
	}

	boolean mailboxUpdated = false;
	ContentValues cv = new ContentValues();

	// Loop here through the remaining xml
	while (nextTag(START_DOCUMENT) != END_DOCUMENT) {
	if (tag == Tags.SYNC_COLLECTION \|\| tag == Tags.SYNC_COLLECTIONS) {
	// Ignore these tags, since we've only got one collection syncing in this loop
	} else if (tag == Tags.SYNC_STATUS) {
	// Status = 1 is success; everything else is a failure
	status = getValueInt();
	if (status != 1) {
	mService.errorLog("Sync failed: " + CommandStatus.toString(status));
	if (status == 3 \|\| CommandStatus.isBadSyncKey(status)) {
	// Must delete all of the data and start over with syncKey of "0"
	mAdapter.setSyncKey("0", false);
	// Make this a push box through the first sync
	// TODO Make frequency conditional on user settings!
	mMailbox.mSyncInterval = Mailbox.CHECK_INTERVAL_PUSH;
	mService.errorLog("Bad sync key; RESET and delete data");
	mAdapter.wipe();
	// Indicate there's more so that we'll start syncing again
	moreAvailable = true;
	} else if (status == 8) {
	// This is Bad; it means the server doesn't recognize the serverId it
	// sent us. What's needed is a refresh of the folder list.
	ExchangeService.reloadFolderList(mContext, mAccount.mId, true);
	} else {
	// Access, provisioning, transient, etc.
	throw new CommandStatusException(status);
	}
	}
	} else if (tag == Tags.SYNC_COMMANDS) {
	commandsParser();
	} else if (tag == Tags.SYNC_RESPONSES) {
	responsesParser();
	} else if (tag == Tags.SYNC_MORE_AVAILABLE) {
	moreAvailable = true;
	} else if (tag == Tags.SYNC_SYNC_KEY) {
	if (mAdapter.getSyncKey().equals("0")) {
	moreAvailable = true;
	}
	String newKey = getValue();
	userLog("Parsed key for ", mMailbox.mDisplayName, ": ", newKey);
	if (!newKey.equals(mMailbox.mSyncKey)) {
	mAdapter.setSyncKey(newKey, true);
	cv.put(MailboxColumns.SYNC_KEY, newKey);
	mailboxUpdated = true;
	newSyncKey = true;
	}
	// If we were pushing (i.e. auto-start), now we'll become ping-triggered
	if (mMailbox.mSyncInterval == Mailbox.CHECK_INTERVAL_PUSH) {
	mMailbox.mSyncInterval = Mailbox.CHECK_INTERVAL_PING;
	}
	} else {
	skipTag();
	}
	}

	// If we don't have a new sync key, ignore moreAvailable (or we'll loop)
	if (moreAvailable && !newSyncKey) {
	mLooping = true;
	}

	// Commit any changes
	commit();

	boolean abortSyncs = false;

	// If the sync interval has changed, we need to save it
	if (mMailbox.mSyncInterval != interval) {
	cv.put(MailboxColumns.SYNC_INTERVAL, mMailbox.mSyncInterval);
	mailboxUpdated = true;
	// If there are changes, and we were bounced from push/ping, try again
	} else if (mService.mChangeCount > 0 &&
	mAccount.mSyncInterval == Account.CHECK_INTERVAL_PUSH &&
	mMailbox.mSyncInterval > 0) {
	userLog("Changes found to ping loop mailbox ", mMailbox.mDisplayName, ": will ping.");
	cv.put(MailboxColumns.SYNC_INTERVAL, Mailbox.CHECK_INTERVAL_PING);
	mailboxUpdated = true;
	abortSyncs = true;
	}

	if (mailboxUpdated) {
	synchronized (mService.getSynchronizer()) {
	if (!mService.isStopped()) {
	mMailbox.update(mContext, cv);
	}
	}
	}

	if (abortSyncs) {
	userLog("Aborting account syncs due to mailbox change to ping...");
	ExchangeService.stopAccountSyncs(mAccount.mId);
	}

	// Let the caller know that there's more to do
	if (moreAvailable) {
	userLog("MoreAvailable");
	}
	return moreAvailable;
	}

	void userLog(String ...strings) {
	mService.userLog(strings);
	}

	void userLog(String string, int num, String string2) {
	mService.userLog(string, num, string2);
	}
	}