From 24760fa2666714ad6e682eab80c5889600e24033 Mon Sep 17 00:00:00 2001
From: Ray Greenwell <ray@threerings.net>
Date: Sat, 11 Apr 2009 01:12:16 +0000
Subject: [PATCH] Create our PeerNode object through injection.

git-svn-id: svn+ssh://src.earth.threerings.net/narya/trunk@5714 542714f4-19e9-0310-aa3c-eee0fc999fb1
---
 .../com/threerings/presents/peer/server/PeerManager.java   | 7 ++++---
 src/java/com/threerings/presents/peer/server/PeerNode.java | 2 ++
 2 files changed, 6 insertions(+), 3 deletions(-)

diff --git a/src/java/com/threerings/presents/peer/server/PeerManager.java b/src/java/com/threerings/presents/peer/server/PeerManager.java
index a1c5e13d0..eb91eb39e 100644
--- a/src/java/com/threerings/presents/peer/server/PeerManager.java
+++ b/src/java/com/threerings/presents/peer/server/PeerManager.java
@@ -875,7 +875,8 @@ public abstract class PeerManager
     {
         PeerNode peer = _peers.get(record.nodeName);
         if (peer == null) {
-            _peers.put(record.nodeName, peer = createPeerNode());
+            peer = _injector.getInstance(getPeerNodeClass());
+            _peers.put(record.nodeName, peer);
             peer.init(this, _omgr, _conmgr, record);
         }
         peer.refresh(record);
@@ -978,9 +979,9 @@ public abstract class PeerManager
     /**
      * Creates a {@link PeerNode} to manage our connection to the specified peer.
      */
-    protected PeerNode createPeerNode ()
+    protected Class<? extends PeerNode> getPeerNodeClass ()
     {
-        return new PeerNode();
+        return PeerNode.class;
     }
 
     /**
diff --git a/src/java/com/threerings/presents/peer/server/PeerNode.java b/src/java/com/threerings/presents/peer/server/PeerNode.java
index 78ab89004..8572964a7 100644
--- a/src/java/com/threerings/presents/peer/server/PeerNode.java
+++ b/src/java/com/threerings/presents/peer/server/PeerNode.java
@@ -25,6 +25,8 @@ import java.net.ConnectException;
 
 import java.util.Date;
 
+import com.google.inject.Inject;
+
 import com.samskivert.util.ResultListenerList;
 
 import com.threerings.presents.client.BlockingCommunicator;