// logging in with e-mailddpclient.call("login",[{user : {email : "[email protected]"},password : "password"}],function(err,result){ ... });// logging in with usernameddpclient.call("login",[{user : {username : "username"},password : "password"}],function(err,result){ ... });

varDDPClient=require("ddp");varddpclient=newDDPClient({// All properties optional, defaults shownhost : "localhost",port : 3000,ssl : false,autoReconnect : true,autoReconnectTimer : 500,maintainCollections : true,ddpVersion : '1',// ['1', 'pre2', 'pre1'] available// uses the SockJs protocol to create the connection// this still uses websockets, but allows to get the benefits// from projects like meteorhacks:cluster// (for load balancing and service discovery)// do not use `path` option when you are using useSockJsuseSockJs: true,// Use a full url instead of a set of `host`, `port` and `ssl`// do not set `useSockJs` option if `url` is usedurl: 'wss://example.com/websocket'});/* * Connect to the Meteor Server */ddpclient.connect(function(error,wasReconnect){// If autoReconnect is true, this callback will be invoked each time// a server connection is re-establishedif(error){console.log('DDP connection error!');return;}if(wasReconnect){console.log('Reestablishment of a connection.');}console.log('connected!');setTimeout(function(){/* * Call a Meteor Method */ddpclient.call('deletePosts',// name of Meteor Method being called['foo','bar'],// parameters to send to Meteor Methodfunction(err,result){// callback which returns the method call resultsconsole.log('called function, result: '+result);},function(){// callback which fires when server has finishedconsole.log('updated');// sending any updated documents as a result ofconsole.log(ddpclient.collections.posts);// calling this method});},3000);/* * Call a Meteor Method while passing in a random seed. * Added in DDP pre2, the random seed will be used on the server to generate * repeatable IDs. This allows the same id to be generated on the client and server */varRandom=require("ddp-random"),random=Random.createWithSeeds("randomSeed");// seed an id generatorddpclient.callWithRandomSeed('createPost',// name of Meteor Method being called[{_id : random.id(),// generate the id on the clientbody : "asdf"}],"randomSeed",// pass the same seed to the serverfunction(err,result){// callback which returns the method call resultsconsole.log('called function, result: '+result);},function(){// callback which fires when server has finishedconsole.log('updated');// sending any updated documents as a result ofconsole.log(ddpclient.collections.posts);// calling this method});/* * Subscribe to a Meteor Collection */ddpclient.subscribe('posts',// name of Meteor Publish function to subscribe to[],// any parameters used by the Publish functionfunction(){// callback when the subscription is completeconsole.log('posts complete:');console.log(ddpclient.collections.posts);});/* * Observe a collection. */varobserver=ddpclient.observe("posts");observer.added=function(id){console.log("[ADDED] to "+observer.name+": "+id);};observer.changed=function(id,oldFields,clearedFields,newFields){console.log("[CHANGED] in "+observer.name+": "+id);console.log("[CHANGED] old field values: ",oldFields);console.log("[CHANGED] cleared fields: ",clearedFields);console.log("[CHANGED] new fields: ",newFields);};observer.removed=function(id,oldValue){console.log("[REMOVED] in "+observer.name+": "+id);console.log("[REMOVED] previous value: ",oldValue);};setTimeout(function(){observer.stop()},6000);});/* * Useful for debugging and learning the ddp protocol */ddpclient.on('message',function(msg){console.log("ddp message: "+msg);});/* * Close the ddp connection. This will close the socket, removing it * from the event-loop, allowing your application to terminate gracefully */ddpclient.close();/* * If you need to do something specific on close or errors. * You can also disable autoReconnect and * call ddpclient.connect() when you are ready to re-connect.*/ddpclient.on('socket-close',function(code,message){console.log("Close: %s %s",code,message);});ddpclient.on('socket-error',function(error){console.log("Error: %j",error);});/* * You can access the EJSON object used by ddp. */varoid=newddpclient.EJSON.ObjectID();

varddpClient=newDDPClient({useSockJs: true});