Unfortunately, the Node Mongo driver wants to use its own proprietary
Binary type for binary data. We want to use Uint8Array, instead, so
we're going to be using a patched version of the BSON library that
allows this.
It allows us to install a handler for USER_DEFINED binary types, which
in our case we set up to recognize, accept, and provide Uint8Array
Now that the tests exist on both client and server, they want to be
able to be asynchronous. Sadly, the current idiom to do this is
somewhat lacking, so I kind of wrote another prototype idiom.
In this world, we use a callback expecter that has been woven in
to a fiber. Calling a callback, or timeouts, can wake up the fiber
and make it check if it is time to expect a thing.
The use of path.sep is incorrect because req.url is a URL, not a file
path, and so always contains forward slashes.
I verified that the original code does not work on Windows and that
the new code does.
Meteor.publish(null, f) now starts universal subscriptions for all existing
sessions (as well as future sessions). Fixes#583. Care is taken when a session
is re-running its subs.
Re-running subs is now implemented by "deactivating" the _LivedataSubscription
object and re-creating a new one instead of "resetting" it in place. This allows
us to ensure that old publish handlers have no access to the merge
boxes (SessionCollectionViews) because deactivated _LivedataSubscriptions ignore
callbacks. Thus, we can be assured that after deactivating all subscription, the
merge box really cannot be affected by old publishers continuing to run.
Note: if a publish function has not even finished its original handler run (eg,
if running setUserId in parallel to a universal subscription, which runs in a
separate fiber from the message-handling loop), the old publish function *WILL*
continue to run (both before and after this commit). However, with this commit,
any attempt by the old publish function to call publisher methods will be
ignored instead of being perhaps-inconsistently interpreted. If a publisher
really needs to know if it has been stopped before it has finished running the
handler, it can set an onStop callback before it does anything that can yield.
- If a subscription is stopped before it has fully started (eg, a universal
publisher that has yielded, or a destroy()ed session), call the stop callback
immediately in onStop, so as to not leak resources.
- In _setUserID, don't set _isSending to false until after running the stop
callbacks for all subs; if a stop callback yielded, CollectionViews could have
been mutated without sending messages.
- Annotate the collection-diffing code with _noYieldsAllowed.
Previously, had only switched over the default for minimongo --
so there's lots of stuff that actually didn't work.
With this change, two tests are still failing; I will fix them and
then do some more cleanup tomorrow.
