XMPP Handshake Flow using Gloox C/C++ -

-

i trying perform xmpp handshake flow mentioned @ https://developers.google.com/cloud-print/docs/rawxmpp.

this allows device subscribe , receive notifications.

as of now, have explored following options:

1) libcurl 2) gloox c/c++ 3) txmpp 4) libjingle

which option choice start with? consider support , maintenance of library major factor.

thanks

following solution using gloox c/c++ library perform xmpp handshake flow:

#include <cassert> #include <iostream> #include <boost/make_shared.hpp> #include <iq.h> #include <parser.h> #include <base64.h> #include <connectiontcpclient.h> #include <connectiontls.h> #include <connectiondatahandler.h> #include <connectionhttpproxy.h> #include <logsink.h> #include <client.h> #include <connectionsocks5proxy.h>  using namespace gloox; using namespace std;  const string proxyhost = ""; //specify proxy server name const int proxyport = 0; //specify proxy port number const string xmpphost = "talk.google.com"; const int xmppport = 5222;  client *c; connectionbase *client_ ; connectiontcpclient* conn0; connectionhttpproxy* conn2;  class bot: public connectiondatahandler, taghandler, tlshandler{ public:     bot(): parser_(this)     {          conn0 = new connectiontcpclient(this, log_, proxyhost, proxyport);          connectionhttpproxy* conn2 = new connectionhttpproxy( this, conn0, log_, xmpphost, xmppport);          client_ = conn0;          connectionerror ce = connnoerror;          ce = conn2->connect();          assert(ce == connnoerror);          conn2->receive();     }     virtual void handleconnect(const connectionbase* con) {         send("<stream:stream to=\"gmail.com\" xml:lang=\"en\" version=\"1.0\" xmlns:stream=\"http://etherx.jabber.org/streams\" xmlns=\"jabber:client\">\r\n");     }      virtual void handlereceiveddata(const connectionbase* con, const string& data) {         cerr << "[recv] " << data << endl;         string copied = data;         int pos = parser_.feed(copied);         assert(pos < 0);     }      virtual void handletag(tag* tag) {         if (tag->name() == "stream" && tag->xmlns() == "http://etherx.jabber.org/streams") {             sid_ = tag->findattribute("id");         } else{             if (tag->name() == "features") {                 if (tag->haschild("starttls", "xmlns", "urn:ietf:params:xml:ns:xmpp-tls")) {                     send(tag("starttls", "xmlns", "urn:ietf:params:xml:ns:xmpp-tls").xml());                 }                 else if (tag->haschild("mechanisms", "xmlns", "urn:ietf:params:xml:ns:xmpp-sasl") && tag->findchild("mechanisms")->haschildwithcdata(                                 "mechanism", "x-oauth2"))                 {                     tag a("auth", "xmlns", "urn:ietf:params:xml:ns:xmpp-sasl");                     a.addattribute("mechanism", "x-oauth2");                     a.addattribute("service", "chromiumsync");                     a.addattribute("allow-generated-jid", "true");                     a.addattribute("client-uses-full-bind-result", "true");                     a.addattribute("auth", "http://www.google.com/talk/protocol/auth");                     string credential;                     credential.append("\0", 1);                     credential.append(""); //specify bare jid                     credential.append("\0", 1);                     credential.append("");  //specify access token                     a.setcdata(base64::encode64(credential));                     send(a.xml());                 }                 else if (tag->haschild("bind", "xmlns", "urn:ietf:params:xml:ns:xmpp-bind")) {                     tag iq("iq", "xmlns", "jabber:client");                     iq.addattribute("type", "set");                     iq.addattribute("id", "0");                     tag *bind = new tag("bind", "xmlns", "urn:ietf:params:xml:ns:xmpp-bind");                     tag *resource = new tag("resource");                     resource->setcdata("gcpresource");                     bind->addchild(resource);                     iq.addchild(bind);                     send(iq.xml());                 }             }             else if (tag->name() == "proceed" && tag->xmlns() == "urn:ietf:params:xml:ns:xmpp-tls") {                 connectiontls* encryption_client = new connectiontls(this, conn0, log_);                 encryption_client->registertlshandler(this);                 client_ = encryption_client;                 connectionerror ret = encryption_client->connect();                 assert(ret == connnoerror);             }             else if (tag->name() == "success" && tag->xmlns() == "urn:ietf:params:xml:ns:xmpp-sasl") {                 send("<stream:stream to=\"gmail.com\" xml:lang=\"en\" version=\"1.0\" xmlns:stream=\"http://etherx.jabber.org/streams\" xmlns=\"jabber:client\">\r\n");             }             else if (tag->name() == "iq") {                 if (tag->haschild("bind", "xmlns", "urn:ietf:params:xml:ns:xmpp-bind")) {                     resource_ = tag->findchild("bind")->findchild("jid")->cdata();                     tag iq("iq");                     iq.addattribute("type", "set");                     iq.addattribute("id", "1");                     iq.addchild(new tag("session", "xmlns", "urn:ietf:params:xml:ns:xmpp-session"));                     send(iq.xml());                      //step 2: subscribing notifications                     if (tag->hasattribute("type", "result")) {                         tag iq("iq");                         iq.addattribute("type", "set");                         iq.addattribute("to", ""); //specify bare jid                         iq.addattribute("id", "3");                         tag *bind = new tag("subscribe", "xmlns", "google:push");                         tag *resource = new tag("item");                         resource->addattribute("channel", "cloudprint.google.com");                         resource->addattribute("from", "cloudprint.google.com");                         bind->addchild(resource);                         iq.addchild(bind);                         send(iq.xml());                     }                 }             }         }     }      virtual void handleencrypteddata(const tlsbase* tls,             const string& data) {         cout << "handleencrypteddata" << endl;     }      virtual void handledecrypteddata(const tlsbase* tls,             const string& data) {         cout << "handledecrypteddata" << endl;     }      virtual void handlehandshakeresult(const tlsbase* tls, bool,             certinfo& cert) {         cout << "handlehandshakeresult" << endl;     }      virtual void handledisconnect(const connectionbase* con, connectionerror) {         cout << "handledisconnect" << endl;     }  private:     logsink log_;     string sid_;     string resource_;     parser parser_;     connectionbase *client_;      void send(const string &data) {         cerr << "[send] " << data << endl;         client_->send(data);     }  };  int main() {         bot bot; }

Comments

Post a Comment

Popular posts from this blog

qt - Using float or double for own QML classes -

-
i've created components , helper methods using c++ , qt used in qml gui. of methods calculate gui elements (size, transformations, scene graph items creation). target arm 32 bit using opengl / eglfs render output. opengl using float , qml using real (defined double ). what should use in c++ do not lose precision? if use qreal ( double ) shouldn't lose precision. if git grep float in qtbase.git , can find out bit more: dist/changes-5.2.0-**************************************************************************** dist/changes-5.2.0-* important behavior changes * dist/changes-5.2.0-**************************************************************************** dist/changes-5.2.0- dist/changes-5.2.0- - qt compiled qreal typedef'ed double on dist/changes-5.2.0: platforms. qreal float on arm chipsets before. guarantees more dist/changes-5.2.0- consistent behavior between platforms qt supports, binary dist/chan...
Read more

Create Outlook appointment via C# .Net -

-
i need create outlook appointment using microsoft.office.interop.outlook , while can work locally on own workstation , works if run web application via server's browser, not work when connect server externally. hence, think might permission issue. i changed application pool identity " localsystem " don't access denied error. unfortunately, doesn't work. the app behaves if appointment created, appointment doesn't appear in outlook. here include file on top of aspx.cs page using outlook = microsoft.office.interop.outlook; here code using pop appointment. outlook.application apptapp = new outlook.application(); outlook.appointmentitem appt = apptapp.createitem(outlook.olitemtype.olappointmentitem) outlook.appointmentitem; appt.subject = txtfirstname.text + " " + txtlastname.text; appt.body = txtcomment.text; appt.alldayevent = false; appt.start = datetime.parse(txtreminderdate.text + " 8:00 am"); appt.end = datetime.p...
Read more

ios - Swift Array Resetting Itself -

-
i have 2 arrays: pointhistory , datehistory . have nstimer , , when timer runs out, action called. in action appending int pointhistory , , current date string datehistory . here timer action: func timeraction() { let steppervalue = int(stepper.value) employee.numberofpoints = steppervalue networking.saveemployee(employee, completion: { (error) -> void in if error != nil { let alert = uialertcontroller(title: "error", message: "there error updating \(self.employee.name)'s points", preferredstyle: .alert) let alertaction = uialertaction(title: "ok", style: .cancel, handler: nil) alert.addaction(alertaction) self.presentviewcontroller(alert, animated: true, completion: nil) } }) var dateformatter = nsdateformatter() dateformatter.dateformat = "mm-dd-yyyy" dateformatter.timezone = nstimezone.localtimezone() var date = nsdate() var ...
Read more