gecko-dev/grendel/ui/StoreFactory.java

267 строки
8.1 KiB
Java

/* -*- Mode: java; indent-tabs-mode: nil; c-basic-offset: 2 -*-
*
* The contents of this file are subject to the Mozilla Public License
* Version 1.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.mozilla.org/MPL/
*
* Software distributed under the License is distributed on an "AS IS"
* basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See
* the License for the specific language governing rights and limitations
* under the License.
*
* The Original Code is the Grendel mail/news client.
*
* The Initial Developer of the Original Code is Netscape Communications
* Corporation. Portions created by Netscape are Copyright (C) 1997
* Netscape Communications Corporation. All Rights Reserved.
*
* Created: Will Scullin <scullin@netscape.com>, 19 Nov 1997.
*
* Contributors: Jeff Galyan <talisman@anamorphic.com>
* Edwin Woudt <edwin@woudt.nl>
*/
package grendel.ui;
import java.util.ResourceBundle;
import java.util.StringTokenizer;
import java.util.Vector;
import javax.mail.AuthenticationFailedException;
import javax.mail.MessagingException;
import javax.mail.Session;
import javax.mail.Store;
import javax.mail.URLName;
import javax.swing.JOptionPane;
import javax.swing.event.ChangeEvent;
import javax.swing.event.ChangeListener;
import javax.swing.event.EventListenerList;
import calypso.util.Preferences;
import calypso.util.PreferencesFactory;
import grendel.view.ViewedStore;
import grendel.view.ViewedStoreBase;
import java.lang.ClassNotFoundException;
import java.lang.NoSuchMethodException;
import java.lang.IllegalAccessException;
import java.lang.IllegalArgumentException;
import java.lang.InstantiationException;
import java.lang.reflect.Constructor;
import java.lang.reflect.InvocationTargetException;
public class StoreFactory {
static StoreFactory fInstance = null;
Session fSession = null;
ViewedStore[] fStores = null;
DialogAuthenticator fAuthenticator = null;
EventListenerList fListeners = new EventListenerList();
private StoreFactory() {
Preferences prefs = PreferencesFactory.Get();
fAuthenticator = new DialogAuthenticator();
fSession = Session.getDefaultInstance(prefs.getAsProperties(),
fAuthenticator);
fSession.setDebug(true);
}
public synchronized static StoreFactory Instance() {
if (fInstance == null) {
fInstance = new StoreFactory();
}
return fInstance;
}
public Session getSession() {
return fSession;
}
public synchronized ViewedStore[] getStores() {
if (fStores == null) {
updateStores();
}
return fStores;
}
synchronized ViewedStore createStore(String storename) {
ResourceBundle labels = ResourceBundle.getBundle("grendel.ui.Labels");
URLName urlName = null;
String proto;
if (storename.indexOf(":") != -1) {
urlName = new URLName(storename);
} else {
urlName = new URLName(storename, null, -1, null, null, null);
}
proto = urlName.getProtocol();
// ### Very wrong temporary hack -- special case "berkeley" and "pop3",
// since they doesn't play with the proper registration mechanism right
// now.
Store store = null;
ViewedStore viewedStore = null;
try {
Class c = null;
if (proto.equalsIgnoreCase("berkeley")) {
c = Class.forName("grendel.storage.BerkeleyStore");
// Two pop3 providers
} else if (proto.equalsIgnoreCase("gpop3")) {
c = Class.forName("grendel.storage.PopStore");
} else if (proto.equalsIgnoreCase("spop3")) {
c = Class.forName("com.sun.mail.pop3.POP3Store;");
// Two news providers
} else if (proto.equalsIgnoreCase("gnews")) {
c = Class.forName("grendel.storage.NewsStore");
} else if (proto.equalsIgnoreCase("dnews")) {
c = Class.forName("dog.mail.nntp.NNTPStore");
// Defaults
} else if (proto.equalsIgnoreCase("pop3")) {
c = Class.forName("com.sun.mail.pop3.POP3Store;");
} else if (proto.equalsIgnoreCase("news")) {
c = Class.forName("grendel.storage.NewsStore");
}
if (c != null) {
Object args[] = { fSession, urlName };
Class types[] = { args[0].getClass(), args[1].getClass() };
Constructor cc = c.getConstructor(types);
store = (Store) cc.newInstance(args);
}
} catch (ClassNotFoundException c) { // Class.forName
} catch (NoSuchMethodException c) { // Constructor.getConstructor
} catch (IllegalAccessException c) { // Constructor.newInstance
} catch (IllegalArgumentException c) { // Constructor.newInstance
} catch (InstantiationException c) { // Constructor.newInstance
} catch (InvocationTargetException c) { // Constructor.newInstance
}
if (store == null) {
try {
store = fSession.getStore(proto);
} catch (MessagingException e) {
System.out.println("Got exception " + e +
" while creating store of type" + proto);
e.printStackTrace();
}
}
viewedStore = new ViewedStoreBase(store,
urlName.getProtocol(),
urlName.getHost(),
urlName.getPort(),
urlName.getUsername());
return viewedStore;
}
public ViewedStore getViewedStore(Store aStore) {
if (fStores == null) {
return null;
}
for (int i = 0; i < fStores.length; i++) {
if (fStores[i].getStore().equals(aStore)) {
return fStores[i];
}
}
return null;
}
boolean SafeEquals(Object a, Object b) {
if (a == b) {
return true;
} else if (a != null && b != null) {
return a.equals(b);
} else {
return false;
}
}
public ViewedStore findStore(String storename) {
URLName urlName = null;
if (storename.indexOf(":") != -1) {
urlName = new URLName(storename);
} else {
urlName = new URLName(storename, null, -1, null, null, null);
}
for (int i = 0; fStores != null && i < fStores.length; i++) {
if (urlName.getProtocol().equals(fStores[i].getProtocol())) {
if (SafeEquals(urlName.getHost(), fStores[i].getHost()) &&
SafeEquals(urlName.getUsername(), fStores[i].getUsername()) &&
//SafeEquals(urlName.getFile(), fStores[i].getFile()) &&
urlName.getPort() == fStores[i].getPort()) {
return fStores[i];
}
}
}
return null;
}
synchronized void updateStores() {
if (fSession == null) {
getSession();
}
Preferences prefs = PreferencesFactory.Get();
Vector resVector = new Vector();
String defStore = "";
if (!prefs.getString("mail.directory","").equals("")) {
defStore = "berkeley";
}
String storelist = prefs.getString("mail.storelist", defStore);
StringTokenizer st = new StringTokenizer(storelist, " ,;");
while (st.hasMoreTokens()) {
String storename = st.nextToken().trim();
ViewedStore viewedStore = null;
viewedStore = findStore(storename);
if (viewedStore == null) {
viewedStore = createStore(storename);
System.out.println("created " + viewedStore);
} else {
System.out.println("recycled " + viewedStore);
}
if (viewedStore != null) {
resVector.addElement(viewedStore);
}
}
fStores = new ViewedStore[resVector.size()];
resVector.copyInto(fStores);
}
public synchronized void refreshStores() {
updateStores();
Object[] listeners = fListeners.getListenerList();
ChangeEvent event = null;
for (int i = 0; i < listeners.length - 1; i += 2) {
// Lazily create the event:
if (event == null)
event = new ChangeEvent(this);
((ChangeListener)listeners[i+1]).stateChanged(event);
}
}
public void addChangeListener(ChangeListener l) {
fListeners.add(ChangeListener.class, l);
}
public void removeChangeListener(ChangeListener l) {
fListeners.remove(ChangeListener.class, l);
}
}