Skip to content
This repository has been archived by the owner on May 8, 2019. It is now read-only.

Commit

Permalink
Merge branch 'master' of https://github.com/rssowl/RSSOwl.git
Browse files Browse the repository at this point in the history
  • Loading branch information
@genodeftest
genodeftest committed Jul 10, 2012
2 parents ef5deb5 + 9e8143d commit e2ca9c7
Showing 1 changed file with 87 additions and 78 deletions.
165 changes: 87 additions & 78 deletions org.rssowl.ui/src/org/rssowl/ui/internal/services/SyncService.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -81,6 +81,9 @@ public class SyncService implements Receiver<SyncItem> {
/* Sync scheduler interval in Millies */
private static final int SYNC_SCHEDULER = 300000; // 5 minutes

/* Maximum sync items per call to google reader API */
private static final int SYNC_PAGE_SIZE = 150;

/* HTTP Constants */
private static final String REQUEST_HEADER_CONTENT_TYPE = "Content-Type"; //$NON-NLS-1$
private static final String REQUEST_HEADER_AUTHORIZATION = "Authorization"; //$NON-NLS-1$
Expand Down Expand Up @@ -393,96 +396,102 @@ private int sync(Collection<SyncItem> items, IProgressMonitor monitor) throws Co
if (equivalentItems.isEmpty())
continue;

/* Connection Headers */
Map<String, String> headers = new HashMap<String, String>();
headers.put(REQUEST_HEADER_CONTENT_TYPE, CONTENT_TYPE_FORM_ENCODED);
headers.put(REQUEST_HEADER_AUTHORIZATION, SyncUtils.getGoogleAuthorizationHeader(authToken));

/* POST Parameters */
Map<String, String[]> parameters = new HashMap<String, String[]>();
parameters.put(SyncUtils.API_PARAM_TOKEN, new String[] { token });

List<String> identifiers = new ArrayList<String>();
List<String> streamIds = new ArrayList<String>();
Set<String> tagsToAdd = new HashSet<String>();
Set<String> tagsToRemove = new HashSet<String>();
for (SyncItem item : equivalentItems) {
identifiers.add(item.getId());
streamIds.add(item.getStreamId());

if (item.isMarkedRead()) {
tagsToAdd.add(SyncUtils.CATEGORY_READ);
tagsToRemove.add(SyncUtils.CATEGORY_UNREAD);
}
for (int syncPage = 0; syncPage <= equivalentItems.size() / SYNC_PAGE_SIZE; syncPage++) {
int fromIndex = syncPage * SYNC_PAGE_SIZE;
int toIndex = Math.min((syncPage + 1) * SYNC_PAGE_SIZE, equivalentItems.size());
List<SyncItem> equivalentItemsPage = equivalentItems.subList(fromIndex, toIndex);

/* Connection Headers */
Map<String, String> headers = new HashMap<String, String>();
headers.put(REQUEST_HEADER_CONTENT_TYPE, CONTENT_TYPE_FORM_ENCODED);
headers.put(REQUEST_HEADER_AUTHORIZATION, SyncUtils.getGoogleAuthorizationHeader(authToken));

/* POST Parameters */
Map<String, String[]> parameters = new HashMap<String, String[]>();
parameters.put(SyncUtils.API_PARAM_TOKEN, new String[] { token });

List<String> identifiers = new ArrayList<String>();
List<String> streamIds = new ArrayList<String>();
Set<String> tagsToAdd = new HashSet<String>();
Set<String> tagsToRemove = new HashSet<String>();
for (SyncItem item : equivalentItemsPage) {
identifiers.add(item.getId());
streamIds.add(item.getStreamId());

if (item.isMarkedRead()) {
tagsToAdd.add(SyncUtils.CATEGORY_READ);
tagsToRemove.add(SyncUtils.CATEGORY_UNREAD);
}

if (item.isMarkedUnread()) {
tagsToAdd.add(SyncUtils.CATEGORY_UNREAD);
tagsToAdd.add(SyncUtils.CATEGORY_TRACKING_UNREAD);
tagsToRemove.add(SyncUtils.CATEGORY_READ);
}
if (item.isMarkedUnread()) {
tagsToAdd.add(SyncUtils.CATEGORY_UNREAD);
tagsToAdd.add(SyncUtils.CATEGORY_TRACKING_UNREAD);
tagsToRemove.add(SyncUtils.CATEGORY_READ);
}

if (item.isStarred())
tagsToAdd.add(SyncUtils.CATEGORY_STARRED);
if (item.isStarred())
tagsToAdd.add(SyncUtils.CATEGORY_STARRED);

if (item.isUnStarred())
tagsToRemove.add(SyncUtils.CATEGORY_STARRED);
if (item.isUnStarred())
tagsToRemove.add(SyncUtils.CATEGORY_STARRED);

List<String> addedLabels = item.getAddedLabels();
if (addedLabels != null) {
for (String label : addedLabels) {
tagsToAdd.add(SyncUtils.CATEGORY_LABEL_PREFIX + label);
List<String> addedLabels = item.getAddedLabels();
if (addedLabels != null) {
for (String label : addedLabels) {
tagsToAdd.add(SyncUtils.CATEGORY_LABEL_PREFIX + label);
}
}
}

List<String> removedLabels = item.getRemovedLabels();
if (removedLabels != null) {
for (String label : removedLabels) {
tagsToRemove.add(SyncUtils.CATEGORY_LABEL_PREFIX + label);
List<String> removedLabels = item.getRemovedLabels();
if (removedLabels != null) {
for (String label : removedLabels) {
tagsToRemove.add(SyncUtils.CATEGORY_LABEL_PREFIX + label);
}
}
}
}

parameters.put(SyncUtils.API_PARAM_IDENTIFIER, identifiers.toArray(new String[identifiers.size()]));
parameters.put(SyncUtils.API_PARAM_STREAM, streamIds.toArray(new String[streamIds.size()]));

if (!tagsToAdd.isEmpty())
parameters.put(SyncUtils.API_PARAM_TAG_TO_ADD, tagsToAdd.toArray(new String[tagsToAdd.size()]));

if (!tagsToRemove.isEmpty())
parameters.put(SyncUtils.API_PARAM_TAG_TO_REMOVE, tagsToRemove.toArray(new String[tagsToRemove.size()]));

/* Connection Properties */
Map<Object, Object> properties = new HashMap<Object, Object>();
properties.put(IConnectionPropertyConstants.HEADERS, headers);
properties.put(IConnectionPropertyConstants.POST, Boolean.TRUE);
properties.put(IConnectionPropertyConstants.PARAMETERS, parameters);
properties.put(IConnectionPropertyConstants.CON_TIMEOUT, getConnectionTimeout());

/* Return on cancellation */
if (isCanceled(monitor))
return itemCount;

/* Perform POST */
URI uri = URI.create(SyncUtils.GOOGLE_EDIT_TAG_URL);
IProtocolHandler handler = Owl.getConnectionService().getHandler(uri);
InputStream inS = null;
try {
inS = handler.openStream(uri, new NullProgressMonitor(), properties); //Do not allow to cancel this outgoing request for transactional reasons
fSyncItemsManager.removeUncommitted(equivalentItems);
itemCount += equivalentItems.size();
} finally {
if (inS != null) {
try {
inS.close();
} catch (IOException e) {
throw new ConnectionException(Activator.getDefault().createErrorStatus(e.getMessage(), e));
parameters.put(SyncUtils.API_PARAM_IDENTIFIER, identifiers.toArray(new String[identifiers.size()]));
parameters.put(SyncUtils.API_PARAM_STREAM, streamIds.toArray(new String[streamIds.size()]));

if (!tagsToAdd.isEmpty())
parameters.put(SyncUtils.API_PARAM_TAG_TO_ADD, tagsToAdd.toArray(new String[tagsToAdd.size()]));

if (!tagsToRemove.isEmpty())
parameters.put(SyncUtils.API_PARAM_TAG_TO_REMOVE, tagsToRemove.toArray(new String[tagsToRemove.size()]));

/* Connection Properties */
Map<Object, Object> properties = new HashMap<Object, Object>();
properties.put(IConnectionPropertyConstants.HEADERS, headers);
properties.put(IConnectionPropertyConstants.POST, Boolean.TRUE);
properties.put(IConnectionPropertyConstants.PARAMETERS, parameters);
properties.put(IConnectionPropertyConstants.CON_TIMEOUT, getConnectionTimeout());

/* Return on cancellation */
if (isCanceled(monitor))
return itemCount;

/* Perform POST */
URI uri = URI.create(SyncUtils.GOOGLE_EDIT_TAG_URL);
IProtocolHandler handler = Owl.getConnectionService().getHandler(uri);
InputStream inS = null;
try {
inS = handler.openStream(uri, new NullProgressMonitor(), properties); //Do not allow to cancel this outgoing request for transactional reasons
fSyncItemsManager.removeUncommitted(equivalentItemsPage);
itemCount += equivalentItemsPage.size();
} finally {
if (inS != null) {
try {
inS.close();
} catch (IOException e) {
throw new ConnectionException(Activator.getDefault().createErrorStatus(e.getMessage(), e));
}
}
}
}

/* Return on cancellation */
if (isCanceled(monitor))
return itemCount;
/* Return on cancellation */
if (isCanceled(monitor))
return itemCount;
}
}
}

Expand Down

0 comments on commit e2ca9c7

Please sign in to comment.