001// License: GPL. For details, see LICENSE file.
002package org.openstreetmap.josm.actions;
003
004import static org.openstreetmap.josm.gui.help.HelpUtil.ht;
005import static org.openstreetmap.josm.tools.I18n.tr;
006
007import java.awt.event.ActionEvent;
008import java.awt.event.KeyEvent;
009import java.io.IOException;
010import java.util.Collection;
011import java.util.List;
012
013import javax.swing.JOptionPane;
014import javax.swing.SwingUtilities;
015
016import org.openstreetmap.josm.data.osm.Changeset;
017import org.openstreetmap.josm.data.osm.ChangesetCache;
018import org.openstreetmap.josm.data.osm.UserInfo;
019import org.openstreetmap.josm.gui.ExceptionDialogUtil;
020import org.openstreetmap.josm.gui.MainApplication;
021import org.openstreetmap.josm.gui.PleaseWaitRunnable;
022import org.openstreetmap.josm.gui.io.CloseChangesetDialog;
023import org.openstreetmap.josm.gui.io.CloseChangesetTask;
024import org.openstreetmap.josm.io.ChangesetQuery;
025import org.openstreetmap.josm.io.ChangesetUpdater;
026import org.openstreetmap.josm.io.NetworkManager;
027import org.openstreetmap.josm.io.OnlineResource;
028import org.openstreetmap.josm.io.OsmServerChangesetReader;
029import org.openstreetmap.josm.io.OsmServerUserInfoReader;
030import org.openstreetmap.josm.io.OsmTransferException;
031import org.openstreetmap.josm.tools.Shortcut;
032import org.xml.sax.SAXException;
033
034/**
035 * User action to close open changesets.
036 *
037 * The list of open changesets will be downloaded from the server and presented
038 * to the user.
039 */
040public class CloseChangesetAction extends JosmAction {
041
042    /**
043     * Constructs a new {@code CloseChangesetAction}.
044     */
045    public CloseChangesetAction() {
046        super(tr("Close open changesets..."),
047            "closechangeset",
048            tr("Close open changesets"),
049            Shortcut.registerShortcut("system:closechangeset",
050                tr("File: {0}", tr("Close open changesets")),
051                KeyEvent.VK_Q, Shortcut.ALT_CTRL),
052            true
053        );
054        setHelpId(ht("/Action/CloseChangeset"));
055        setEnabled(!NetworkManager.isOffline(OnlineResource.OSM_API));
056
057    }
058
059    @Override
060    public void actionPerformed(ActionEvent e) {
061        MainApplication.worker.submit(new DownloadOpenChangesetsTask());
062    }
063
064    protected void onPostDownloadOpenChangesets() {
065        ChangesetUpdater.check();
066        List<Changeset> openChangesets = ChangesetCache.getInstance().getOpenChangesetsForCurrentUser();
067        if (openChangesets.isEmpty()) {
068            JOptionPane.showMessageDialog(
069                    MainApplication.getMainFrame(),
070                    tr("There are no open changesets"),
071                    tr("No open changesets"),
072                    JOptionPane.INFORMATION_MESSAGE
073            );
074            return;
075        }
076
077        CloseChangesetDialog dialog = new CloseChangesetDialog();
078        dialog.setChangesets(openChangesets);
079        dialog.setVisible(true);
080        if (dialog.isCanceled())
081            return;
082
083        Collection<Changeset> changesetsToClose = dialog.getSelectedChangesets();
084        CloseChangesetTask closeChangesetTask = new CloseChangesetTask(changesetsToClose);
085        MainApplication.worker.submit(closeChangesetTask);
086    }
087
088    private final class DownloadOpenChangesetsTask extends PleaseWaitRunnable {
089
090        private boolean canceled;
091        private OsmServerChangesetReader reader;
092        private List<Changeset> changesets;
093        private Exception lastException;
094
095        private DownloadOpenChangesetsTask() {
096            super(tr("Downloading open changesets ..."), false /* don't ignore exceptions */);
097        }
098
099        @Override
100        protected void cancel() {
101            this.canceled = true;
102            reader.cancel();
103        }
104
105        @Override
106        protected void finish() {
107            SwingUtilities.invokeLater(() -> {
108                            if (lastException != null) {
109                                ExceptionDialogUtil.explainException(lastException);
110                            }
111                            ChangesetCache.getInstance().update(changesets);
112                            if (!canceled && lastException == null) {
113                                onPostDownloadOpenChangesets();
114                            }
115                        });
116        }
117
118        /**
119         * Fetch the user info from the server. This is necessary if we don't know the users id yet
120         *
121         * @return the user info
122         * @throws OsmTransferException in case of any communication exception
123         */
124        private UserInfo fetchUserInfo() throws OsmTransferException {
125            return new OsmServerUserInfoReader().fetchUserInfo(getProgressMonitor().createSubTaskMonitor(1, false));
126        }
127
128        @Override
129        protected void realRun() throws SAXException, IOException, OsmTransferException {
130            try {
131                UserInfo userInfo = fetchUserInfo();
132                if (canceled)
133                    return;
134                reader = new OsmServerChangesetReader();
135                ChangesetQuery query = new ChangesetQuery().forUser(userInfo.getId()).beingOpen(true);
136                changesets = reader.queryChangesets(
137                        query,
138                        getProgressMonitor().createSubTaskMonitor(1, false /* not internal */)
139                );
140            } catch (OsmTransferException | IllegalArgumentException e) {
141                if (canceled)
142                    return;
143                lastException = e;
144            }
145        }
146
147        /**
148         * Determines if the download task has been canceled.
149         * @return {@code true} if the download task has been canceled
150         */
151        public boolean isCanceled() {
152            return canceled;
153        }
154
155        /**
156         * Returns the last exception that occurred.
157         * @return the last exception that occurred, or {@code null}
158         */
159        public Exception getLastException() {
160            return lastException;
161        }
162    }
163}