Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
[ 1917655 ] all done other than the lack of a few unit tests :)
- Loading branch information
knaas
committed
Mar 19, 2008
1 parent
c27b809
commit 46366b6
Showing
38 changed files
with
1,547 additions
and
645 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
52 changes: 52 additions & 0 deletions
52
...tric/src/main/java/org/jumpmind/symmetric/transport/AbstractTransportResourceHandler.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,52 @@ | ||
| /* | ||
| * SymmetricDS is an open source database synchronization solution. | ||
| * | ||
| * Copyright (C) Chris Henson <chenson42@users.sourceforge.net>, | ||
| * Eric Long <erilong@users.sourceforge.net>, | ||
| * Keith Naas <knaas@users.sourceforge.net> | ||
| * | ||
| * | ||
| * This library is free software; you can redistribute it and/or | ||
| * modify it under the terms of the GNU Lesser General Public | ||
| * License as published by the Free Software Foundation; either | ||
| * version 3 of the License, or (at your option) any later version. | ||
| * | ||
| * This library 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 GNU | ||
| * Lesser General Public License for more details. | ||
| * | ||
| * You should have received a copy of the GNU Lesser General Public | ||
| * License along with this library; if not, see | ||
| * <http://www.gnu.org/licenses/>. | ||
| */ | ||
|
|
||
| package org.jumpmind.symmetric.transport; | ||
|
|
||
| import java.io.IOException; | ||
| import java.io.OutputStream; | ||
|
|
||
| import org.jumpmind.symmetric.transport.internal.InternalOutgoingTransport; | ||
|
|
||
| /** | ||
| * In order to better support other transports, the logic associated with | ||
| * transport resources, e.g., pull, push, ack, and registration is isolated away | ||
| * from the HttpServletRequest and HttpServletResponse. | ||
| * | ||
| * Filters should probably eventually be done this way as well. | ||
| * | ||
| * This should also probably be springified so that they can be injected into | ||
| * all the right places. | ||
| * | ||
| * @author Keith Naas <knaas@users.sourceforge.net> | ||
| * | ||
| */ | ||
| public abstract class AbstractTransportResourceHandler implements | ||
| ITransportResourceHandler { | ||
|
|
||
| protected IOutgoingTransport createOutgoingTransport( | ||
| OutputStream outputStream) throws IOException { | ||
| return new InternalOutgoingTransport(outputStream); | ||
| } | ||
|
|
||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
130 changes: 130 additions & 0 deletions
130
symmetric/src/main/java/org/jumpmind/symmetric/transport/AlertResourceHandler.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,130 @@ | ||
| /* | ||
| * SymmetricDS is an open source database synchronization solution. | ||
| * | ||
| * Copyright (C) Chris Henson <chenson42@users.sourceforge.net>, | ||
| * Eric Long <erilong@users.sourceforge.net>, | ||
| * Keith Naas <knaas@users.sourceforge.net> | ||
| * | ||
| * | ||
| * This library is free software; you can redistribute it and/or | ||
| * modify it under the terms of the GNU Lesser General Public | ||
| * License as published by the Free Software Foundation; either | ||
| * version 3 of the License, or (at your option) any later version. | ||
| * | ||
| * This library 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 GNU | ||
| * Lesser General Public License for more details. | ||
| * | ||
| * You should have received a copy of the GNU Lesser General Public | ||
| * License along with this library; if not, see | ||
| * <http://www.gnu.org/licenses/>. | ||
| */ | ||
|
|
||
| package org.jumpmind.symmetric.transport; | ||
|
|
||
| import java.io.IOException; | ||
| import java.io.Writer; | ||
| import java.util.ArrayList; | ||
| import java.util.Date; | ||
| import java.util.List; | ||
|
|
||
| import org.apache.commons.lang.time.FastDateFormat; | ||
| import org.jumpmind.symmetric.model.IncomingBatch; | ||
| import org.jumpmind.symmetric.model.OutgoingBatch; | ||
| import org.jumpmind.symmetric.service.IIncomingBatchService; | ||
| import org.jumpmind.symmetric.service.IOutgoingBatchService; | ||
|
|
||
| import com.sun.syndication.feed.synd.SyndContent; | ||
| import com.sun.syndication.feed.synd.SyndContentImpl; | ||
| import com.sun.syndication.feed.synd.SyndEntry; | ||
| import com.sun.syndication.feed.synd.SyndEntryImpl; | ||
| import com.sun.syndication.feed.synd.SyndFeed; | ||
| import com.sun.syndication.feed.synd.SyndFeedImpl; | ||
| import com.sun.syndication.io.FeedException; | ||
| import com.sun.syndication.io.SyndFeedOutput; | ||
|
|
||
| public class AlertResourceHandler extends AbstractTransportResourceHandler { | ||
| private static final int MAX_ERRORS = 1000; | ||
|
|
||
| private static final FastDateFormat formatter = FastDateFormat | ||
| .getInstance("yyyy-MM-dd HH:mm:ss"); | ||
|
|
||
| private IIncomingBatchService incomingBatchService; | ||
|
|
||
| private IOutgoingBatchService outgoingBatchService; | ||
|
|
||
| public void write(CharSequence feedURL, Writer outputWriter) | ||
| throws IOException, FeedException { | ||
| SyndFeed feed = new SyndFeedImpl(); | ||
| feed.setFeedType("rss_2.0"); | ||
| feed.setTitle("SymmetricDS Alerts"); | ||
| feed.setDescription("Problems synchronizing data"); | ||
| feed.setLink(feedURL.toString()); | ||
|
|
||
| List<SyndEntry> entries = new ArrayList<SyndEntry>(); | ||
|
|
||
| for (IncomingBatch batch : findIncomingBatchErrors()) { | ||
| String title = "Incoming Batch " + batch.getNodeBatchId(); | ||
| String value = "Node " + batch.getNodeId() + " incoming batch " | ||
| + batch.getBatchId() + " is in error at " | ||
| + formatDate(batch.getCreateTime()); | ||
| entries.add(createEntry(title, value)); | ||
| } | ||
|
|
||
| for (OutgoingBatch batch : findOutgoingBatchErrors()) { | ||
| String title = "Outgoing Batch " + batch.getNodeBatchId(); | ||
| String value = "Node " + batch.getNodeId() + " outgoing batch " | ||
| + batch.getBatchId() + " is in error at " | ||
| + formatDate(batch.getCreateTime()); | ||
| entries.add(createEntry(title, value)); | ||
| } | ||
|
|
||
| feed.setEntries(entries); | ||
|
|
||
| SyndFeedOutput out = new SyndFeedOutput(); | ||
| out.output(feed, outputWriter); | ||
| } | ||
|
|
||
| private SyndEntry createEntry(String title, String value) { | ||
| SyndEntry entry = new SyndEntryImpl(); | ||
| entry.setTitle(title); | ||
| SyndContent content = new SyndContentImpl(); | ||
| content.setType("text/html"); | ||
| content.setValue(value); | ||
| entry.setDescription(content); | ||
| return entry; | ||
| } | ||
|
|
||
| private String formatDate(Date date) { | ||
| return formatter.format(date); | ||
| } | ||
|
|
||
| private List<IncomingBatch> findIncomingBatchErrors() { | ||
| return getIncomingBatchService().findIncomingBatchErrors(MAX_ERRORS); | ||
| } | ||
|
|
||
| private List<OutgoingBatch> findOutgoingBatchErrors() { | ||
|
|
||
| return getOutgoingBatchService().getOutgoingBatcheErrors(MAX_ERRORS); | ||
| } | ||
|
|
||
| private IIncomingBatchService getIncomingBatchService() { | ||
| return incomingBatchService; | ||
| } | ||
|
|
||
| public void setIncomingBatchService( | ||
| IIncomingBatchService incomingBatchService) { | ||
| this.incomingBatchService = incomingBatchService; | ||
| } | ||
|
|
||
| private IOutgoingBatchService getOutgoingBatchService() { | ||
| return outgoingBatchService; | ||
| } | ||
|
|
||
| public void setOutgoingBatchService( | ||
| IOutgoingBatchService outgoingBatchService) { | ||
| this.outgoingBatchService = outgoingBatchService; | ||
| } | ||
|
|
||
| } |
56 changes: 56 additions & 0 deletions
56
symmetric/src/main/java/org/jumpmind/symmetric/transport/AuthenticationResourceHandler.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,56 @@ | ||
| /* | ||
| * SymmetricDS is an open source database synchronization solution. | ||
| * | ||
| * Copyright (C) Keith Naas <knaas@users.sourceforge.net> | ||
| * | ||
| * | ||
| * This library is free software; you can redistribute it and/or | ||
| * modify it under the terms of the GNU Lesser General Public | ||
| * License as published by the Free Software Foundation; either | ||
| * version 3 of the License, or (at your option) any later version. | ||
| * | ||
| * This library 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 GNU | ||
| * Lesser General Public License for more details. | ||
| * | ||
| * You should have received a copy of the GNU Lesser General Public | ||
| * License along with this library; if not, see | ||
| * <http://www.gnu.org/licenses/>. | ||
| */ | ||
| package org.jumpmind.symmetric.transport; | ||
|
|
||
| import org.jumpmind.symmetric.service.INodeService; | ||
| import org.jumpmind.symmetric.service.IRegistrationService; | ||
|
|
||
| public class AuthenticationResourceHandler extends | ||
| AbstractTransportResourceHandler { | ||
|
|
||
| public enum AuthenticationStatus { | ||
| REGISTRATION_REQUIRED, FORBIDDEN, ACCEPTED; | ||
| }; | ||
|
|
||
| private INodeService nodeService; | ||
| private IRegistrationService registrationService; | ||
|
|
||
| public AuthenticationStatus status(String nodeId, String securityToken) { | ||
| AuthenticationStatus retVal = AuthenticationStatus.ACCEPTED; | ||
|
|
||
| if (!nodeService.isNodeAuthorized(nodeId, securityToken)) { | ||
| if (registrationService.isAutoRegistration()) { | ||
| retVal = AuthenticationStatus.REGISTRATION_REQUIRED; | ||
| } else { | ||
| retVal = AuthenticationStatus.FORBIDDEN; | ||
| } | ||
| } | ||
| return retVal; | ||
| } | ||
|
|
||
| public void setNodeService(INodeService nodeService) { | ||
| this.nodeService = nodeService; | ||
| } | ||
|
|
||
| public void setRegistrationService(IRegistrationService registrationService) { | ||
| this.registrationService = registrationService; | ||
| } | ||
| } |
Oops, something went wrong.