diff --git a/src/as/com/threerings/README.txt b/src/as/com/threerings/README.txt
index 33a135ea2..0249f6381 100644
--- a/src/as/com/threerings/README.txt
+++ b/src/as/com/threerings/README.txt
@@ -60,3 +60,16 @@ Notes
A, filled with B and C elements. I would have no way on the client to
inspect an array like that and know to tell the server that it's an A[].
Punting completely on Arrays for now.
+
+- The RENDER Event is dispatched prior to each rendering, it's
+ basically like tick(): it gives anything that cares a chance to update
+ prior to being painted. It doesn't specify what the hell to listen on for
+ this event, but since all DisplayObjects are event dispatchers then
+ listening on any display object (including the stage) should work...
+
+ But, the damn thing doesn't get dispatched if there will be no render,
+ even if the code is still running- like when the flash player window is
+ minimized or obscured. Lovely.
+
+ I will play around with trying to just use a Timer with a 1ms interval,
+ and see if the frequency is limited to the actual framerate.
diff --git a/src/as/com/threerings/io/ObjectInputStream.as b/src/as/com/threerings/io/ObjectInputStream.as
index 14afc9d8d..4f4ec573f 100644
--- a/src/as/com/threerings/io/ObjectInputStream.as
+++ b/src/as/com/threerings/io/ObjectInputStream.as
@@ -103,6 +103,9 @@ public class ObjectInputStream
}
}
+ // TODO: of course this DOESN'T ACTUALLY WORK, because the actual object
+ // to read could be a subclass of the specified class
+ // TODO
public function readField (clazz :Class) :*
//throws IOError
{
diff --git a/src/as/com/threerings/presents/client/ClientDObjectMgr.as b/src/as/com/threerings/presents/client/ClientDObjectMgr.as
new file mode 100644
index 000000000..78f3d6801
--- /dev/null
+++ b/src/as/com/threerings/presents/client/ClientDObjectMgr.as
@@ -0,0 +1,503 @@
+//
+// $Id: ClientDObjectMgr.java 3795 2005-12-21 19:30:39Z mdb $
+//
+// Narya library - tools for developing networked games
+// Copyright (C) 2002-2004 Three Rings Design, Inc., All Rights Reserved
+// http://www.threerings.net/code/narya/
+//
+// 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 2.1 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, write to the Free Software
+// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
+
+package com.threerings.presents.client {
+
+import flash.events.TimerEvent;
+import flash.util.Timer;
+
+import mx.collections.IList;
+
+import com.threerings.util.SimpleMap;
+
+import com.threerings.presents.dobj.DObject;
+import com.threerings.presents.dobj.DObjectManager;
+
+/**
+ * The client distributed object manager manages a set of proxy objects
+ * which mirror the distributed objects maintained on the server.
+ * Requests for modifications, etc. are forwarded to the server and events
+ * are dispatched from the server to this client for objects to which this
+ * client is subscribed.
+ */
+public class ClientDObjectMgr
+ implements DObjectManager
+{
+ /**
+ * Constructs a client distributed object manager.
+ *
+ * @param comm a communicator instance by which it can communicate
+ * with the server.
+ * @param client a reference to the client that is managing this whole
+ * communications and event dispatch business.
+ */
+ public function ClientDObjectMgr (comm :Communicator, client :Client)
+ {
+ _comm = comm;
+ _client = client;
+
+ // register a flush interval
+ _flushInterval = new Timer(FLUSH_INTERVAL);
+ _flushInterval.addEventListener(TimerEvent.TIMER, flushObjects);
+ _flushInterval.start();
+
+ _actionInterval = new Timer(1); //TODO!
+ _actionInterval.addEventListener(TimerEvent.TIMER, processNextAction);
+ _actionInterval.start();
+ }
+
+ // documentation inherited from interface DObjectManager
+ public function isManager (object :DObject) :Boolean
+ {
+ // we are never authoritative in the present implementation
+ return false;
+ }
+
+ // inherit documentation from the interface DObjectManager
+ public function createObject (dclass :Class, target :Subscriber) :void
+ {
+ // not presently supported
+ throw new Error("createObject() not supported");
+ }
+
+ // inherit documentation from the interface DObjectManager
+ public function subscribeToObject (oid :int, target :Subscriber) :void
+ {
+ if (oid <= 0) {
+ target.requestFailed(
+ oid, new ObjectAccessError("Invalid oid " + oid + "."));
+ } else {
+ queueAction(oid, target, true);
+ }
+ }
+
+ // inherit documentation from the interface DObjectManager
+ public function unsubscribeFromObject (oid :int, target :Subscriber) :void
+ {
+ queueAction(oid, target, false);
+ }
+
+ protected function queueAction (
+ oid :int, target :Subscriber, subscribe :Boolean) :void
+ {
+ // queue up an action
+ _actions.push(new ObjectAction(oid, target, subscribe));
+ }
+
+ // inherit documentation from the interface
+ public function postEvent (event :DEvent) :void
+ {
+ // send a forward event request to the server
+ _comm.postMessage(new ForwardEventRequest(event));
+ }
+
+ // inherit documentation from the interface
+ public function destroyObject (oid :int) :void
+ {
+ // forward an object destroyed event to the server
+ postEvent(new ObjectDestroyedEvent(oid));
+ }
+
+ // inherit documentation from the interface
+ public function removedLastSubscriber (
+ obj :DObject, deathWish :Boolean) :void
+ {
+ // if this object has a registered flush delay, don't can it just
+ // yet, just slip it onto the flush queue
+ var oclass :Class = ClassUtil.getClass(obj);
+ /*
+ // TODO
+ // TODO
+ for (Iterator iter = _delays.keySet().iterator(); iter.hasNext(); ) {
+ Class dclass = (Class)iter.next();
+ if (dclass.isAssignableFrom(oclass)) {
+ long expire = System.currentTimeMillis() +
+ ((Long)_delays.get(dclass)).longValue();
+ _flushes.put(obj.getOid(), new FlushRecord(obj, expire));
+// Log.info("Flushing " + obj.getOid() + " at " +
+// new java.util.Date(expire));
+ return;
+ }
+ }
+ */
+
+ // if we didn't find a delay registration, flush immediately
+ flushObject(obj);
+ }
+
+ /**
+ * Registers an object flush delay.
+ *
+ * @see Client#registerFlushDelay
+ */
+ public function registerFlushDelay (objclass :Class, delay :Number) :void
+ {
+ // TODO
+ //_delays.put(objclass, new Long(delay));
+ }
+
+ /**
+ * Called by the communicator when a downstream message arrives from
+ * the network layer. We queue it up for processing and request some
+ * processing time on the main thread.
+ */
+ public function processMessage (msg :DownstreamMessage) :void
+ {
+ // append it to our queue
+ _actions.push(msg);
+ }
+
+ /**
+ * Invoked on the main client thread to process any newly arrived
+ * messages that we have waiting in our queue.
+ */
+ public function processNextAction (event :TimerEvent) :void
+ {
+ // process the next event on our queue
+ if (_actions.length == 0) {
+ return;
+ }
+
+ var obj :Object = _actions.shift();
+ // do the proper thing depending on the object
+ if (obj is BootstrapNotification) {
+ _client.gotBootstrap(obj.getData(), this);
+
+ } else if (obj is EventNotification) {
+ var evt :DEvent = obj.getEvent();
+// Log.info("Dispatch event: " + evt);
+ dispatchEvent(evt);
+
+ } else if (obj is ObjectResponse) {
+ registerObjectAndNotify(obj.getObject());
+
+ } else if (obj is UnsubscribeResponse) {
+ var oid :int = obj.getOid();
+ if (_dead[oid] == null) {
+ trace("Received unsub ACK from unknown object " +
+ "[oid=" + oid + "].");
+ }
+ _dead[oid] = undefined;
+
+ } else if (obj is FailureResponse) {
+ var oid :int = obj.getOid();
+ notifyFailure(oid);
+
+ } else if (obj is PongResponse) {
+ _client.gotPong(obj);
+
+ } else if (obj is ObjectAction) {
+ var act :ObjectAction = (obj as ObjectAction);
+ if (act.subscribe) {
+ doSubscribe(act.oid, act.target);
+ } else {
+ doUnsubscribe(act.oid, act.target);
+ }
+ }
+ }
+
+ /**
+ * Called when a new event arrives from the server that should be
+ * dispatched to subscribers here on the client.
+ */
+ protected function dispatchEvent (event :DEvent) :void
+ {
+ // if this is a compound event, we need to process its contained
+ // events in order
+ if (event is CompoundEvent) {
+ IList events = ((CompoundEvent)event).getEvents();
+ int ecount = events.size();
+ for (int i = 0; i < ecount; i++) {
+ dispatchEvent((DEvent)events.get(i));
+ }
+ return;
+ }
+
+ System.err.println("dispatching: " + event);
+
+ // look up the object on which we're dispatching this event
+ int toid = event.getTargetOid();
+ DObject target = (DObject)_ocache.get(toid);
+ if (target == null) {
+ if (!_dead.containsKey(toid)) {
+ Log.warning("Unable to dispatch event on non-proxied " +
+ "object [event=" + event + "].");
+ }
+ return;
+ }
+
+ try {
+ // apply the event to the object
+ boolean notify = event.applyToObject(target);
+
+ // if this is an object destroyed event, we need to remove the
+ // object from our object table
+ if (event instanceof ObjectDestroyedEvent) {
+// Log.info("Pitching destroyed object " +
+// "[oid=" + toid + ", class=" +
+// StringUtil.shortClassName(target) + "].");
+ _ocache.remove(toid);
+ }
+
+ // have the object pass this event on to its listeners
+ if (notify) {
+ target.notifyListeners(event);
+ }
+
+ } catch (Exception e) {
+ Log.warning("Failure processing event [event=" + event +
+ ", target=" + target + "].");
+ Log.logStackTrace(e);
+ }
+ }
+
+ /**
+ * Registers this object in our proxy cache and notifies the
+ * subscribers that were waiting for subscription to this object.
+ */
+ protected void registerObjectAndNotify (DObject obj)
+ {
+ // let the object know that we'll be managing it
+ obj.setManager(this);
+
+ // stick the object into the proxy object table
+ _ocache.put(obj.getOid(), obj);
+
+ // let the penders know that the object is available
+ PendingRequest req = (PendingRequest)_penders.remove(obj.getOid());
+ if (req == null) {
+ Log.warning("Got object, but no one cares?! " +
+ "[oid=" + obj.getOid() + ", obj=" + obj + "].");
+ return;
+ }
+
+ for (int i = 0; i < req.targets.size(); i++) {
+ Subscriber target = (Subscriber)req.targets.get(i);
+ // add them as a subscriber
+ obj.addSubscriber(target);
+ // and let them know that the object is in
+ target.objectAvailable(obj);
+ }
+ }
+
+ /**
+ * Notifies the subscribers that had requested this object (for
+ * subscription) that it is not available.
+ */
+ protected void notifyFailure (int oid)
+ {
+ // let the penders know that the object is not available
+ PendingRequest req = (PendingRequest)_penders.remove(oid);
+ if (req == null) {
+ Log.warning("Failed to get object, but no one cares?! " +
+ "[oid=" + oid + "].");
+ return;
+ }
+
+ for (int i = 0; i < req.targets.size(); i++) {
+ Subscriber target = (Subscriber)req.targets.get(i);
+ // and let them know that the object is in
+ target.requestFailed(oid, null);
+ }
+ }
+
+ /**
+ * This is guaranteed to be invoked via the invoker and can safely do
+ * main thread type things like call back to the subscriber.
+ */
+ protected void doSubscribe (int oid, Subscriber target)
+ {
+ // Log.info("doSubscribe: " + oid + ": " + target);
+
+ // first see if we've already got the object in our table
+ DObject obj = (DObject)_ocache.get(oid);
+ if (obj != null) {
+ // clear the object out of the flush table if it's in there
+ if (_flushes.remove(oid) != null) {
+// Log.info("Resurrected " + oid + ".");
+ }
+ // add the subscriber and call them back straight away
+ obj.addSubscriber(target);
+ target.objectAvailable(obj);
+ return;
+ }
+
+ // see if we've already got an outstanding request for this object
+ PendingRequest req = (PendingRequest)_penders.get(oid);
+ if (req != null) {
+ // add this subscriber to the list of subscribers to be
+ // notified when the request is satisfied
+ req.addTarget(target);
+ return;
+ }
+
+ // otherwise we need to create a new request
+ req = new PendingRequest(oid);
+ req.addTarget(target);
+ _penders.put(oid, req);
+ // Log.info("Registering pending request [oid=" + oid + "].");
+
+ // and issue a request to get things rolling
+ _comm.postMessage(new SubscribeRequest(oid));
+ }
+
+ /**
+ * This is guaranteed to be invoked via the invoker and can safely do
+ * main thread type things like call back to the subscriber.
+ */
+ protected void doUnsubscribe (int oid, Subscriber target)
+ {
+ DObject dobj = (DObject)_ocache.get(oid);
+ if (dobj != null) {
+ dobj.removeSubscriber(target);
+
+ } else {
+ Log.info("Requested to remove subscriber from " +
+ "non-proxied object [oid=" + oid +
+ ", sub=" + target + "].");
+ }
+ }
+
+ /**
+ * Flushes a distributed object subscription, issuing an unsubscribe
+ * request to the server.
+ */
+ protected void flushObject (DObject obj)
+ {
+ // move this object into the dead pool so that we don't claim to
+ // have it around anymore; once our unsubscribe message is
+ // processed, it'll be 86ed
+ int ooid = obj.getOid();
+ _ocache.remove(ooid);
+ _dead.put(ooid, obj);
+
+ // ship off an unsubscribe message to the server; we'll remove the
+ // object from our table when we get the unsub ack
+ _comm.postMessage(new UnsubscribeRequest(ooid));
+ }
+
+ /**
+ * Called periodically to flush any objects that have been lingering
+ * due to a previously enacted flush delay.
+ */
+ protected void flushObjects ()
+ {
+ long now = System.currentTimeMillis();
+ for (Iterator iter = _flushes.keySet().iterator(); iter.hasNext(); ) {
+ int oid = ((Integer)iter.next()).intValue();
+ FlushRecord rec = (FlushRecord)_flushes.get(oid);
+ if (rec.expire <= now) {
+ iter.remove();
+ flushObject(rec.object);
+// Log.info("Flushed object " + oid + ".");
+ }
+ }
+ }
+
+ /** A reference to the communicator that sends and receives messages
+ * for this client. */
+ protected var _comm :Communicator;
+
+ /** A reference to our client instance. */
+ protected var _client :Client;
+
+ /** Our primary dispatch queue. */
+ protected var _actions :Array = new Array();
+
+ /** All of the distributed objects that are active on this client. */
+ protected var _ocache :SimpleMap = new SimpleMap(); //HashIntMap();
+
+ /** Objects that have been marked for death. */
+ protected var _dead :SimpleMap = new SimpleMap(); //HashIntMap();
+
+ /** Pending object subscriptions. */
+ protected var _penders :SimpleMap = new SimpleMap(); //HashIntMap();
+
+ /** A mapping from distributed object class to flush delay. */
+ protected var _delays :SimpleMap = new SimpleMap(); //HashMap();
+
+ /** A set of objects waiting to be flushed. */
+ protected var _flushes :SimpleMap = new SimpleMap(); //HashIntMap();
+
+ /** Flushes objects every now and again. */
+ protected var _flushInterval :Timer;
+ protected var _flushInterval :Timer;
+
+ /** Flush expired objects every 30 seconds. */
+ protected static const FLUSH_INTERVAL :Number = 30 * 1000;
+}
+}
+
+/**
+ * The object action is used to queue up a subscribe or unsubscribe
+ * request.
+ */
+protected class ObjectAction
+{
+ public var oid :int;
+ public var target :Subscriber;
+ public var subscribe :Boolean;
+
+ public function ObjectAction (
+ oid :int, target :Subscriber, subscribe :Boolean)
+ {
+ this.oid = oid;
+ this.target = target;
+ this.subscribe = subscribe;
+ }
+
+ public override function toString () :String
+ {
+ return "oid=" + oid + ", target=" + target + ", subscribe=" + subscribe;
+ }
+}
+
+protected class PendingRequest
+{
+ public var oid :int;
+ public var targets :Array = new Array();
+
+ public PendingRequest (oid :int)
+ {
+ this.oid = oid;
+ }
+
+ public function addTarget (target :Subscriber) :void
+ {
+ targets.push(target);
+ }
+}
+
+/** Used to manage pending object flushes. */
+protected class FlushRecord
+{
+ /** The object to be flushed. */
+ public var obj :DObject;
+
+ /** The time at which we flush it. */
+ public var expire :Number;
+
+ public function FlushRecord (obj :DObject, expire :Number)
+ {
+ this.object = object;
+ this.expire = expire;
+ }
+}
diff --git a/src/as/com/threerings/presents/dobj/AttributeChangeListener.as b/src/as/com/threerings/presents/dobj/AttributeChangeListener.as
new file mode 100644
index 000000000..7d8d6b259
--- /dev/null
+++ b/src/as/com/threerings/presents/dobj/AttributeChangeListener.as
@@ -0,0 +1,42 @@
+//
+// $Id: AttributeChangeListener.java 3099 2004-08-27 02:21:06Z mdb $
+//
+// Narya library - tools for developing networked games
+// Copyright (C) 2002-2004 Three Rings Design, Inc., All Rights Reserved
+// http://www.threerings.net/code/narya/
+//
+// 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 2.1 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, write to the Free Software
+// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
+
+package com.threerings.presents.dobj {
+
+/**
+ * Implemented by entites which wish to hear about attribute changes that
+ * take place for a particular distributed object.
+ *
+ * @see DObject#addListener
+ */
+public interface AttributeChangeListener extends ChangeListener
+{
+ /**
+ * Called when an attribute changed event has been dispatched on an
+ * object. This will be called after the event has been
+ * applied to the object. So fetching the attribute during this call
+ * will provide the new value for the attribute.
+ *
+ * @param event The event that was dispatched on the object.
+ */
+ function attributeChanged (event :AttributeChangedEvent) :void;
+}
+}
diff --git a/src/as/com/threerings/presents/dobj/CompoundEvent.as b/src/as/com/threerings/presents/dobj/CompoundEvent.as
new file mode 100644
index 000000000..ab722bfca
--- /dev/null
+++ b/src/as/com/threerings/presents/dobj/CompoundEvent.as
@@ -0,0 +1,180 @@
+//
+// $Id: CompoundEvent.java 3099 2004-08-27 02:21:06Z mdb $
+//
+// Narya library - tools for developing networked games
+// Copyright (C) 2002-2004 Three Rings Design, Inc., All Rights Reserved
+// http://www.threerings.net/code/narya/
+//
+// 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 2.1 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, write to the Free Software
+// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
+
+package com.threerings.presents.dobj {
+
+import flash.util.StringBuilder;
+
+import mx.collections.IList;
+
+import com.threerings.io.ObjectInputStream;
+import com.threerings.io.ObjectOutputStream;
+
+import com.threerings.util.StreamableArrayList;
+
+/**
+ * Used to manage and submit groups of events on a collection of
+ * distributed objects in a single transaction.
+ *
+ * @see DObject#startTransaction
+ */
+public class CompoundEvent extends DEvent
+{
+ /**
+ * Constructs a compound event and prepares it for operation.
+ */
+ public CompoundEvent (target :DObject, omgr :DObjectManager)
+ {
+ super(target.getOid());
+
+ // sanity check
+ if (omgr == null) {
+ throw new ArgumentError(
+ "Must receive non-null object manager reference");
+ }
+
+ _omgr = omgr;
+ _target = target;
+ _events = new StreamableArrayList();
+ }
+
+ /**
+ * Posts an event to this transaction. The event will be delivered as
+ * part of the entire transaction if it is committed or discarded if
+ * the transaction is cancelled.
+ */
+ public function postEvent (event :DEvent) :void
+ {
+ _events.addItem(event);
+ }
+
+ /**
+ * Returns the list of events contained within this compound event.
+ * Don't mess with it.
+ */
+ public function getEvents () :IList
+ {
+ return _events;
+ }
+
+ /**
+ * Commits this transaction by posting this event to the distributed
+ * object event queue. All participating dobjects will have their
+ * transaction references cleared and will go back to normal
+ * operation.
+ */
+ public function commit () :void
+ {
+ // first clear our target
+ clearTarget();
+
+ // then post this event onto the queue (but only if we actually
+ // accumulated some events)
+ switch (_events.length) {
+ case 0: // nothing doing
+ break;
+ case 1: // no point in being compound
+ _omgr.postEvent(_events.getItemAt(0));
+ break;
+ default: // now we're talking
+ _omgr.postEvent(this);
+ break;
+ }
+ }
+
+ /**
+ * Cancels this transaction. All events posted to this transaction
+ * will be discarded.
+ */
+ public function cancel () :void
+ {
+ // clear our target
+ clearTarget();
+ // clear our event queue in case someone holds onto us
+ _events.removeAll();
+ }
+
+ /**
+ * We need to propagate our source oid to our constituent events.
+ */
+ public override function setSourceOid (sourceOid :int) :void
+ {
+ super.setSourceOid(sourceOid);
+
+ for (var ii :int = 0; ii < _events.length; ii++) {
+ _events.getItemAt(ii).setSourceOid(sourceOid);
+ }
+ }
+
+ /**
+ * Nothing to apply here.
+ */
+ public override function applyToObject (target :DObject) :Boolean
+ //throws ObjectAccessException
+ {
+ return false;
+ }
+
+ /**
+ * Calls out to our target object, clearing its transaction reference.
+ */
+ protected function clearTarget () :void
+ {
+ if (_target != null) {
+ _target.clearTransaction();
+ _target = null;
+ }
+ }
+
+ // documentation inherited
+ protected override function toString (buf :StringBuilder) :void
+ {
+ buf.append("COMPOUND:");
+ super.toString(buf);
+
+ for (var ii :int = 0; ii < _events.length; ii++) {
+ buf.append(", ", _events.getItemAt(ii));
+ }
+ }
+
+ public override function writeObject (out :ObjectOutputStream) :void
+ {
+ super.writeObject(out);
+ out.writeField(_events);
+ }
+
+ public override function readObject (ins :ObjectInputStream) :void
+ {
+ super.readObject(ins);
+ _events = ins.readField(StreamableArrayList);
+ }
+
+ /** The object manager that we'll post ourselves to when we're
+ * committed. */
+ protected var _omgr :DObjectManager;
+
+ /** The object for which we're managing a transaction. */
+ protected var _target :DObject;
+
+ /** A list of the events associated with this compound event. */
+ protected var _events :StreamableArrayList;
+}
+}
diff --git a/src/as/com/threerings/presents/dobj/ElementUpdateListener.as b/src/as/com/threerings/presents/dobj/ElementUpdateListener.as
new file mode 100644
index 000000000..07e29eea9
--- /dev/null
+++ b/src/as/com/threerings/presents/dobj/ElementUpdateListener.as
@@ -0,0 +1,42 @@
+//
+// $Id: ElementUpdateListener.java 3099 2004-08-27 02:21:06Z mdb $
+//
+// Narya library - tools for developing networked games
+// Copyright (C) 2002-2004 Three Rings Design, Inc., All Rights Reserved
+// http://www.threerings.net/code/narya/
+//
+// 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 2.1 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, write to the Free Software
+// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
+
+package com.threerings.presents.dobj {
+
+/**
+ * Implemented by entites which wish to hear about element updates that
+ * take place for a particular distributed object.
+ *
+ * @see DObject#addListener
+ */
+public interface ElementUpdateListener extends ChangeListener
+{
+ /**
+ * Called when an element updated event has been dispatched on an
+ * object. This will be called after the event has been
+ * applied to the object. So fetching the element during this call
+ * will provide the new value for the element.
+ *
+ * @param event The event that was dispatched on the object.
+ */
+ function elementUpdated (event :ElementUpdatedEvent) :void;
+}
+}
diff --git a/src/as/com/threerings/presents/dobj/EventListener.as b/src/as/com/threerings/presents/dobj/EventListener.as
new file mode 100644
index 000000000..b66073e05
--- /dev/null
+++ b/src/as/com/threerings/presents/dobj/EventListener.as
@@ -0,0 +1,44 @@
+//
+// $Id: EventListener.java 3099 2004-08-27 02:21:06Z mdb $
+//
+// Narya library - tools for developing networked games
+// Copyright (C) 2002-2004 Three Rings Design, Inc., All Rights Reserved
+// http://www.threerings.net/code/narya/
+//
+// 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 2.1 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, write to the Free Software
+// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
+
+package com.threerings.presents.dobj {
+
+/**
+ * Implemented by entites which wish to hear about all events being
+ * dispatched on a particular distributed object.
+ *
+ * @see DObject#addListener
+ */
+public interface EventListener extends ChangeListener
+{
+ /**
+ * Called when any event has been dispatched on an object. The event
+ * will be of the derived class that corresponds to the kind of event
+ * that occurred on the object. This will be called after the
+ * event has been applied to the object. So fetching an attribute upon
+ * receiving an attribute changed event will provide the new value for
+ * the attribute.
+ *
+ * @param event The event that was dispatched on the object.
+ */
+ function eventReceived (event :DEvent) :void;
+}
+}
diff --git a/src/as/com/threerings/presents/dobj/MessageListener.as b/src/as/com/threerings/presents/dobj/MessageListener.as
new file mode 100644
index 000000000..5560d8da6
--- /dev/null
+++ b/src/as/com/threerings/presents/dobj/MessageListener.as
@@ -0,0 +1,39 @@
+//
+// $Id: MessageListener.java 3099 2004-08-27 02:21:06Z mdb $
+//
+// Narya library - tools for developing networked games
+// Copyright (C) 2002-2004 Three Rings Design, Inc., All Rights Reserved
+// http://www.threerings.net/code/narya/
+//
+// 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 2.1 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, write to the Free Software
+// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
+
+package com.threerings.presents.dobj {
+
+/**
+ * Implemented by entites which wish to hear about message events that are
+ * dispatched on a particular distributed object.
+ *
+ * @see DObject#addListener
+ */
+public interface MessageListener extends ChangeListener
+{
+ /**
+ * Called when an message event has been dispatched on an object.
+ *
+ * @param event The event that was dispatched on the object.
+ */
+ function messageReceived (event :MessageEvent) :void;
+}
+}
diff --git a/src/as/com/threerings/presents/dobj/ObjectAccessError.as b/src/as/com/threerings/presents/dobj/ObjectAccessError.as
new file mode 100644
index 000000000..0ef1e65fb
--- /dev/null
+++ b/src/as/com/threerings/presents/dobj/ObjectAccessError.as
@@ -0,0 +1,53 @@
+//
+// $Id: ObjectAccessException.java 3099 2004-08-27 02:21:06Z mdb $
+//
+// Narya library - tools for developing networked games
+// Copyright (C) 2002-2004 Three Rings Design, Inc., All Rights Reserved
+// http://www.threerings.net/code/narya/
+//
+// 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 2.1 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, write to the Free Software
+// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
+
+package com.threerings.presents.dobj {
+
+/**
+ * An object access exception is delivered when an object is not
+ * accessible to a requesting subscriber for some reason or other. For
+ * some access exceptions, special derived classes exist to communicate
+ * the error. For others, a message string explaining the access failure
+ * is provided.
+ */
+public class ObjectAccessError extends Error
+{
+ /**
+ * Constructs a object access exception with the specified error
+ * message.
+ */
+ public function ObjectAccessError (message :String, cause :Error = null)
+ {
+ super(message);
+ _cause = cause;
+ }
+
+ /**
+ * Return the cause of this error, if any.
+ */
+ public function getCause () :Error
+ {
+ return _cause;
+ }
+
+ protected var _cause :Error;
+}
+}
diff --git a/src/as/com/threerings/presents/dobj/ObjectDeathListener.as b/src/as/com/threerings/presents/dobj/ObjectDeathListener.as
new file mode 100644
index 000000000..2123fed8d
--- /dev/null
+++ b/src/as/com/threerings/presents/dobj/ObjectDeathListener.as
@@ -0,0 +1,40 @@
+//
+// $Id: ObjectDeathListener.java 3099 2004-08-27 02:21:06Z mdb $
+//
+// Narya library - tools for developing networked games
+// Copyright (C) 2002-2004 Three Rings Design, Inc., All Rights Reserved
+// http://www.threerings.net/code/narya/
+//
+// 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 2.1 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, write to the Free Software
+// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
+
+package com.threerings.presents.dobj {
+
+/**
+ * Implemented by entites which wish to hear about object destruction
+ * events.
+ *
+ * @see DObject#addListener
+ */
+public interface ObjectDeathListener extends ChangeListener
+{
+ /**
+ * Called when this object has been destroyed. This will be called
+ * after the event has been applied to the object.
+ *
+ * @param event The event that was dispatched on the object.
+ */
+ function objectDestroyed (event :ObjectDestroyedEvent) :void;
+}
+}
diff --git a/src/as/com/threerings/presents/dobj/ObjectDestroyedEvent.as b/src/as/com/threerings/presents/dobj/ObjectDestroyedEvent.as
new file mode 100644
index 000000000..47a1c27c0
--- /dev/null
+++ b/src/as/com/threerings/presents/dobj/ObjectDestroyedEvent.as
@@ -0,0 +1,75 @@
+//
+// $Id: ObjectDestroyedEvent.java 3099 2004-08-27 02:21:06Z mdb $
+//
+// Narya library - tools for developing networked games
+// Copyright (C) 2002-2004 Three Rings Design, Inc., All Rights Reserved
+// http://www.threerings.net/code/narya/
+//
+// 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 2.1 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, write to the Free Software
+// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
+
+package com.threerings.presents.dobj;
+
+/**
+ * An object destroyed event is dispatched when an object has been removed
+ * from the distributed object system. It can also be constructed to
+ * request an attribute change on an object and posted to the dobjmgr.
+ *
+ * @see DObjectManager#postEvent
+ */
+public class ObjectDestroyedEvent extends DEvent
+{
+ /**
+ * Constructs a new object destroyed event for the specified
+ * distributed object.
+ *
+ * @param targetOid the object id of the object that will be destroyed.
+ */
+ public ObjectDestroyedEvent (int targetOid)
+ {
+ super(targetOid);
+ }
+
+ /**
+ * Constructs a blank instance of this event in preparation for
+ * unserialization from the network.
+ */
+ public ObjectDestroyedEvent ()
+ {
+ }
+
+ // documentation inherited
+ public boolean applyToObject (DObject target)
+ throws ObjectAccessException
+ {
+ // nothing to do in preparation for destruction, the omgr will
+ // have to recognize this type of event and do the right thing
+ return true;
+ }
+
+ // documentation inherited
+ protected void notifyListener (Object listener)
+ {
+ if (listener instanceof ObjectDeathListener) {
+ ((ObjectDeathListener)listener).objectDestroyed(this);
+ }
+ }
+
+ // documentation inherited
+ protected void toString (StringBuffer buf)
+ {
+ buf.append("DESTROY:");
+ super.toString(buf);
+ }
+}
diff --git a/src/as/com/threerings/presents/dobj/ObjectRemovedEvent.as b/src/as/com/threerings/presents/dobj/ObjectRemovedEvent.as
index 447862ee3..f09a9fdc6 100644
--- a/src/as/com/threerings/presents/dobj/ObjectRemovedEvent.as
+++ b/src/as/com/threerings/presents/dobj/ObjectRemovedEvent.as
@@ -19,7 +19,13 @@
// License along with this library; if not, write to the Free Software
// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
-package com.threerings.presents.dobj;
+package com.threerings.presents.dobj {
+
+import flash.util.StringBuilder;
+
+import com.threerings.io.ObjectInputStream;
+import com.threerings.io.ObjectOutputStream;
+
/**
* An object removed event is dispatched when an object is removed from an
@@ -42,24 +48,16 @@ public class ObjectRemovedEvent extends NamedEvent
* remove the specified oid.
* @param oid the oid to remove from the oid list attribute.
*/
- public ObjectRemovedEvent (int targetOid, String name, int oid)
+ public function ObjectRemovedEvent (targetOid :int, name :String, oid :int)
{
super(targetOid, name);
_oid = oid;
}
- /**
- * Constructs a blank instance of this event in preparation for
- * unserialization from the network.
- */
- public ObjectRemovedEvent ()
- {
- }
-
/**
* Returns the oid that has been removed.
*/
- public int getOid ()
+ public function getOid () :int
{
return _oid;
}
@@ -67,29 +65,42 @@ public class ObjectRemovedEvent extends NamedEvent
/**
* Applies this event to the object.
*/
- public boolean applyToObject (DObject target)
- throws ObjectAccessException
+ public override function applyToObject (target :DObject) :Boolean
+ //throws ObjectAccessException
{
- OidList list = (OidList)target.getAttribute(_name);
+ var list :OidList = (target[_name] as OidList);
list.remove(_oid);
return true;
}
// documentation inherited
- protected void notifyListener (Object listener)
+ protected override function notifyListener (listener :*) :void
{
if (listener is OidListListener) {
- ((OidListListener)listener).objectRemoved(this);
+ listener.objectRemoved(this);
}
}
+ public override function writeObject (out :ObjectOutputStream) :void
+ {
+ super.writeObject(out);
+ out.writeInt(_oid);
+ }
+
+ public override function readObject (ins :ObjectInputStream) :void
+ {
+ super.readObject(ins);
+ _oid = ins.readInt();
+ }
+
// documentation inherited
- protected void toString (StringBuffer buf)
+ protected override function toString (buf :StringBuilder) :void
{
buf.append("OBJREM:");
super.toString(buf);
- buf.append(", oid=").append(_oid);
+ buf.append(", oid=", _oid);
}
- protected int _oid;
+ protected var _oid :int;
+}
}
diff --git a/src/as/com/threerings/presents/dobj/OidListListener.as b/src/as/com/threerings/presents/dobj/OidListListener.as
new file mode 100644
index 000000000..290ae59f0
--- /dev/null
+++ b/src/as/com/threerings/presents/dobj/OidListListener.as
@@ -0,0 +1,50 @@
+//
+// $Id: OidListListener.java 3099 2004-08-27 02:21:06Z mdb $
+//
+// Narya library - tools for developing networked games
+// Copyright (C) 2002-2004 Three Rings Design, Inc., All Rights Reserved
+// http://www.threerings.net/code/narya/
+//
+// 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 2.1 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, write to the Free Software
+// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
+
+package com.threerings.presents.dobj {
+
+/**
+ * Implemented by entites which wish to hear about changes that occur to
+ * oid list attributes of a particular distributed object.
+ *
+ * @see DObject#addListener
+ */
+public interface OidListListener extends ChangeListener
+{
+ /**
+ * Called when an object added event has been dispatched on an
+ * object. This will be called after the event has been
+ * applied to the object.
+ *
+ * @param event The event that was dispatched on the object.
+ */
+ function objectAdded (event :ObjectAddedEvent) :void;
+
+ /**
+ * Called when an object removed event has been dispatched on an
+ * object. This will be called after the event has been
+ * applied to the object.
+ *
+ * @param event The event that was dispatched on the object.
+ */
+ function objectRemoved (event :ObjectRemovedEvent) :void;
+}
+}
diff --git a/src/as/com/threerings/presents/dobj/SetListener.java b/src/as/com/threerings/presents/dobj/SetListener.java
new file mode 100644
index 000000000..98d834f14
--- /dev/null
+++ b/src/as/com/threerings/presents/dobj/SetListener.java
@@ -0,0 +1,58 @@
+//
+// $Id: SetListener.java 3099 2004-08-27 02:21:06Z mdb $
+//
+// Narya library - tools for developing networked games
+// Copyright (C) 2002-2004 Three Rings Design, Inc., All Rights Reserved
+// http://www.threerings.net/code/narya/
+//
+// 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 2.1 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, write to the Free Software
+// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
+
+package com.threerings.presents.dobj;
+
+/**
+ * Implemented by entites which wish to hear about changes that occur to
+ * set attributes of a particular distributed object.
+ *
+ * @see DObject#addListener
+ */
+public interface SetListener extends ChangeListener
+{
+ /**
+ * Called when an entry added event has been dispatched on an
+ * object. This will be called after the event has been
+ * applied to the object.
+ *
+ * @param event The event that was dispatched on the object.
+ */
+ public void entryAdded (EntryAddedEvent event);
+
+ /**
+ * Called when an entry updated event has been dispatched on an
+ * object. This will be called after the event has been
+ * applied to the object.
+ *
+ * @param event The event that was dispatched on the object.
+ */
+ public void entryUpdated (EntryUpdatedEvent event);
+
+ /**
+ * Called when an entry removed event has been dispatched on an
+ * object. This will be called after the event has been
+ * applied to the object.
+ *
+ * @param event The event that was dispatched on the object.
+ */
+ public void entryRemoved (EntryRemovedEvent event);
+}
diff --git a/src/as/com/threerings/presents/net/ForwardEventRequest.as b/src/as/com/threerings/presents/net/ForwardEventRequest.as
new file mode 100644
index 000000000..a8e28b956
--- /dev/null
+++ b/src/as/com/threerings/presents/net/ForwardEventRequest.as
@@ -0,0 +1,67 @@
+//
+// $Id: ForwardEventRequest.java 3099 2004-08-27 02:21:06Z mdb $
+//
+// Narya library - tools for developing networked games
+// Copyright (C) 2002-2004 Three Rings Design, Inc., All Rights Reserved
+// http://www.threerings.net/code/narya/
+//
+// 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 2.1 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, write to the Free Software
+// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
+
+package com.threerings.presents.net {
+
+import com.threerings.presents.dobj.DEvent;
+
+import com.threerings.io.ObjectInputStream;
+import com.threerings.io.ObjectOutputStream;
+
+public class ForwardEventRequest extends UpstreamMessage
+{
+ /**
+ * Constructs a forward event request for the supplied event.
+ */
+ public function ForwardEventRequest (event :DEvent)
+ {
+ _event = event;
+ }
+
+ /**
+ * Returns the event that we wish to have forwarded.
+ */
+ public function getEvent () :DEvent
+ {
+ return _event;
+ }
+
+ public override function writeObject (out :ObjectOutputStream) :void
+ {
+ super.writeObject(out);
+ out.writeField(_event);
+ }
+
+ public override function readObject (ins :ObjectInputStream) :void
+ {
+ super.readObject(ins);
+ _event = ins.readField(DEvent);
+ }
+
+ public override function toString () :String
+ {
+ return "[type=FWD, evt=" + _event + "]";
+ }
+
+ /** The event which we are forwarding. */
+ protected var _event :DEvent;
+}
+}