GOOS一人読書会 第5回 AuctionSniperEndToEndTest.sniperJoinsAuctionUntilAuctionCloses() - 5

今回はMainにサーバへのメッセージ送信部分を追加していきます。

package auctionsniper;

import javax.swing.SwingUtilities;

import org.jivesoftware.smack.Chat;
import org.jivesoftware.smack.MessageListener;
import org.jivesoftware.smack.XMPPConnection;
import org.jivesoftware.smack.XMPPException;
import org.jivesoftware.smack.packet.Message;

import auctionsniper.ui.MainWindow;

public class Main {
	@SuppressWarnings("unused") private Chat notToBeGCd;
	private static final int ARG_HOSTNAME = 0;
	private static final int ARG_USERNAME = 1;
	private static final int ARG_PASSWORD = 2;
	private static final int ARG_ITEM_ID = 3;
	public static final String AUCTION_RESOURCE = "Auction";
	public static final String ITEM_ID_AS_LOGIN = "auction-%s";
	public static final String AUCTION_ID_FORMAT = ITEM_ID_AS_LOGIN + "@%s/" + AUCTION_RESOURCE;
	
	public static final String MAIN_WINDOW_NAME = "Auction Sniper";
	public static final String STATUS_LOST = "Lost";
	public static final String STATUS_JOINING = "Joining";
	
	private MainWindow ui;
	
	public Main() throws Exception {
		startUserInterface();
	}
	
	public static void main(String ... args) throws Exception {
		Main main = new Main();
		main.joinAuction(connection(args[ARG_HOSTNAME], args[ARG_USERNAME], args[ARG_PASSWORD]), args[ARG_ITEM_ID]);
	}
	
	private void joinAuction(XMPPConnection connection, String itemId) throws XMPPException {
		System.out.println("joinAuction");
		final Chat chat = connection.getChatManager().createChat(
				auctionId(itemId, connection), 
				new MessageListener() {
					@Override
					public void processMessage(Chat aChat, Message message) {
						SwingUtilities.invokeLater(new Runnable() {
							public void run() {
								ui.showStatus(STATUS_LOST);
							}
						});
					}
				});
		this.notToBeGCd = chat;
		chat.sendMessage(new Message());
	}
	
	private static XMPPConnection connection(String hostname, String username, String password)
		throws XMPPException {
		XMPPConnection connection = new XMPPConnection(hostname);
		connection.connect();
		connection.login(username,  password, AUCTION_RESOURCE);
		
		return connection;
	}
	
	private static String auctionId(String itemId, XMPPConnection connection) {
		return String.format(AUCTION_ID_FORMAT, itemId, connection.getServiceName());
	}
	
	private void startUserInterface() throws Exception {
		SwingUtilities.invokeAndWait(new Runnable() {
			public void run() {
				ui = new MainWindow();
			}
		});
	}
}

package auctionsniper.ui;

import java.awt.Color;

import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.border.LineBorder;

import auctionsniper.Main;

public class MainWindow extends JFrame {
	public static final String SNIPER_STATUS_NAME = "sniper status";
	private final JLabel sniperStatus = createLabel(Main.STATUS_JOINING);
	
	public MainWindow() {
		super("Auction Sniper");
		setName(Main.MAIN_WINDOW_NAME);
		add(sniperStatus);
		pack();
		setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
		setVisible(true);
	}
	
	public void showStatus(String status) {
		sniperStatus.setText(status);
	}
	
	private static JLabel createLabel(String initialText) {
		JLabel result = new JLabel(initialText);
		result.setName(SNIPER_STATUS_NAME);
		result.setBorder(new LineBorder(Color.BLACK));
		return result;
	}
}

ちょっとダラダラしてきたので今回でむりやりsniperJoinsAuctionUntilAuctionCloses()を終わらせました。

あと記事にするのが面倒くさくなったのでこの企画は今回で終わりにします。