source: sandbox/jabberit_messenger/trophy_expresso/strophejs/tests/pubsub.js @ 2397

Strophe.Test = {
    BOSH_URL: "/xmpp-httpbind",
    XMPP_DOMAIN: 'localhost',
    PUBSUB_COMPONENT: "pubsub.localhost",
    _node_name: "", //node name created in connectCallback function
    connection: null, //connection object created in run function
    
    run: function() {
        $(document).ready(function(){
            //Connect strophe, uses localhost to test
            Strophe.Test.connection = new Strophe.Connection(Strophe.Test.BOSH_URL);
            
            //connect anonymously to run most tests
            Strophe.Test.connection.connect(Strophe.Test.XMPP_DOMAIN,
                                            null,
                                            Strophe.Test.connectCallback);

            //set up the test client UI
            $("#disconnect").click(function() {
                Strophe.Test.connection.disconnect();
            });
            $("#run_tests").click(function() {      
                test("Anonymous connection test.", function() {
                    if(Strophe.Test.connection.connected)
                    {
                        ok( true, "all good");
                    }
                    else
                    {
                        ok( false, "not connected anonymously");
                    }
                });

                test("Create default node test.",function(){
                    var iqid =  Strophe.Test.connection.pubsub
                        .createNode(Strophe.Test.connection.jid,
                                    Strophe.Test.PUBSUB_COMPONENT,
                                    Strophe.Test._node_name, {}, 
                                    function(stanza) {
                                        test("handled create node.",
                                             function() {
                                                 var error = $(stanza).find("error");
                                                 
                                                 if(error.length == 0)
                                                 {
                                                     ok(true, "returned");
                                                 }
                                                 else
                                                 {
                                                     ok(false,"error creating node.");
                                                 }
                                             });
                                    });
                    ok(true,"sent create request. "+ iqid);
                });

                test("subscribe to a node",function() {
                    var iqid = Strophe.Test.connection.pubsub
                        .subscribe(Strophe.Test.connection.jid,
                                   Strophe.Test.PUBSUB_COMPONENT,
                                   Strophe.Test._node_name,
                                   [],
                                   function(stanza) {
                                       test("items received", function() {
                                           console.log(stanza);
                                           if($(stanza).length > 0)
                                           {
                                               ok(true,"item received.");
                                           }
                                           else
                                           {
                                               ok(false,"no items.");
                                           }
                                       });
                                   },
                                   function(stanza) {
                                       var error = $(stanza).find("error");
                                       
                                       test("handled subscribe",
                                            function() {
                                                if(error.length == 0)
                                                {
                                                    ok(true,"subscribed");
                                                }
                                                else
                                                {
                                                    console.log(error.get(0));
                                                    ok(false,
                                                       "not subscribed");
                                                }
                                                
                                            });
                                   });
                    
                    if(iqid)
                        ok(true,
                           "subscribed to " + Strophe.Test._node_name);
                });

                test("publish to a node",function() {
                    var iqid = Strophe.Test.connection.pubsub
                        .publish(Strophe.Test.connection.jid,
                                 Strophe.Test.PUBSUB_COMPONENT,
                                 Strophe.Test._node_name,
                                 {test:'test'},
                                 function(stanza) {
                                     var error = $(stanza).find("error");
                                     
                                     test("handled published item",
                                          function() {
                                              if(error.length == 0)
                                              {
                                                  ok(true,"got item");
                                              }
                                              else
                                              {
                                                  ok(false,
                                                     "no item");
                                              }
                                              
                                          });
                                 });
                    
                    if(iqid)
                        ok(true,
                           "published to " + Strophe.Test._node_name);
                    
                });             

                test("subscribe to a node with options",function() {
                    var keyword_elem = Strophe.xmlElement("field",
                                                          [["var",
                                                            "http://stanziq.com/search#keyword"],
                                                           ["type",
                                                            'text-single'],
                                                           ["label",
                                                            "keyword to match"]]);
                    var value = Strophe.xmlElement("value",[]);
                    var text = Strophe.xmlTextNode("crazy");
                    value.appendChild(text);
                    keyword_elem.appendChild(value);
                    
                    var iqid = Strophe.Test.connection.pubsub
                        .subscribe(Strophe.Test.connection.jid,
                                   Strophe.Test.PUBSUB_COMPONENT,
                                   Strophe.Test._node_name,
                                   [keyword_elem],
                                   function(stanza) {console.log(stanza);},
                                   function(stanza) {
                                       
                                       var error = $(stanza).find("error");
                                       
                                       test("handled subscribe with options",
                                            function() {
                                                if(error.length == 0)
                                                {
                                                    ok(true,"search subscribed");
                                                }
                                                else
                                                {
                                                    console.log(error.get(0));
                                                    ok(false,
                                                       "search not subscribed");
                                                }
                                                
                                            });
                                   });
                    
                    if(iqid)
                        ok(true,
                           "subscribed to search");
                });

                test("unsubscribe to a node",function() {
                    var iqid = Strophe.Test.connection.pubsub
                        .unsubscribe(Strophe.Test.connection.jid,
                                     Strophe.Test.PUBSUB_COMPONENT,
                                     Strophe.Test._node_name,
                                     function(stanza) {
                                         var error = $(stanza).find("error");
                                         
                                         test("handled unsubscribe",
                                              function() {
                                                  if(error.length == 0)
                                                  {
                                                      ok(true,"unsubscribed");
                                                  }
                                                  else
                                                  {
                                                      console.log(error.get(0));
                                                      ok(false,
                                                         "unable to unsubscribed");
                                                  }
                                              });
                                     });
                    
                    if(iqid)
                        ok(true,
                           "unsubscribed from search with no options.");
                });

                test("test items retrieval",function(){
                    var itemid = Strophe.Test.connection.pubsub
                        .items(Strophe.Test.connection.jid,
                               Strophe.Test.PUBSUB_COMPONENT,
                               Strophe.Test._node_name,
                               function(stanza) {
                                   ok(true,"item request successful.");
                               },
                               function(stanza) {
                                   ok(false,"failed to send request.");
                               });
                    
                    if(itemid)
                    {
                        ok(true,"item request sent.");
                    }
                });

                test("test sendIQ interface.",function(){
                    var sendiq_good = false;
                    //setup timeout for sendIQ for 3 seconds
                    setTimeout(function() {
                        test("Timeout check", function () {
                            ok(sendiq_good, "The iq didn't timeout.");
                        });
                    }, 3000);
                    
                    //send a pubsub subscribe stanza
                    
                    var sub = $iq({from:Strophe.Test.connection.jid,
                                   to:Strophe.Test.PUBSUB_COMPONENT,
                                   type:'set'})
                        .c('pubsub', { xmlns:Strophe.NS.PUBSUB })
                        .c('subscribe',
                           {node:Strophe.Test._node_name,
                            jid:Strophe.Test.connection.jid});
                    var stanza=sub.tree();
                    //call sendIQ with several call backs
                    Strophe.Test.connection
                        .sendIQ(stanza, 
                                function(stanza) {
                                    test("iq sent",function() {
                                        sendiq_good = true;
                                        ok(true,"iq sent succesfully.");
                                    });
                                },
                                function(stz) {
                                    test("iq fail",function() {
                                        if (stz)
                                            sendiq_good = true;
                                        console.log(stanza);
                                        ok(true,"failed to send iq.");
                                    });
                                });
                });

                test("test sendIQ failed.",function(){
                    var sub = $iq({from:Strophe.Test.connection.jid, 
                                   to:Strophe.Test.PUBSUB_COMPONENT, 
                                   type:'get'});

                    //call sendIQ with several call backs
                    Strophe.Test.connection
                        .sendIQ(sub.tree(),
                                function(stanza) {
                                    console.log(stanza);
                                    test("iq sent",function() {
                                        ok(false,
                                           "iq sent succesfully when should have failed.");
                                    });
                                },
                                function(stanza) {
                                    test("iq fail",function() {
                                        ok(true,
                                           "success on failure test: failed to send iq.");
                                    });
                                });                 
                });
            });
        });
    },

    connectCallback: function(status,cond) {
        var error_message = null;
        if(status == Strophe.Status.CONNECTED)
        {
            $('#run_tests').show();
            $('#disconnect').show();
            var bare_jid = Strophe.getBareJidFromJid(Strophe.Test.connection.jid).split("@")[0];
            Strophe.Test._node_name = "/home/"+Strophe.Test.XMPP_DOMAIN+"/"+bare_jid;
        }
        else if (status == Strophe.Status.DISCONNECTED || status == Strophe.Status.DICONNECTING)
        {
            $('#run_tests').hide();
            $('#disconnect').hide();
        }       
        else if ((status == 0) || (status == Strophe.Status.CONNFAIL))
        {
            error_message = "Failed to connect to xmpp server.";
        }
        else if (status == Strophe.Status.AUTHFAIL)
        {
            error_message = "Failed to authenticate to xmpp server.";
        }
        if(error_message)
        {
            $('published_item').text(error_message);
            
        }
    }
};