Pithos_GSS » Pithos Firefox extension

// The Pithos File Manager Firefox Extension is funded by GRNET S.A.

// (http://www.grnet.gr)

//

// Copyright (c) 2009, Christos KK Loverdos, Vassilios Karakoidas.

// All rights reserved.

//

// Redistribution and use in source and binary forms, with or without

// modification, are permitted provided that the following conditions are

// met:

//

//   - Redistributions of source code must retain the above copyright

//     notice, this list of conditions and the following disclaimer.

//   - Redistributions in binary form must reproduce the above

//     copyright notice, this list of conditions and the following

//     disclaimer in the documentation and/or other materials provided

//     with the distribution.

//   - Neither the name of GRNET S.A. nor the names of its contributors

//     may be used to endorse or promote products derived from this

//     software without specific prior written permission.

//

// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS

// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT

// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR

// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT

// HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,

// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT

// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,

// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY

// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT

// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE

// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

connection_obj = null;

function ConnectionObject() {

        // public properties

        this.token = 'ERROR: no token';

        this.username = 'ERROR: no username';

        this.login = 'ERROR: no login';

        this.email = 'ERROR: no email';

        this.rest_url = 'https://pithos.grnet.gr/pithos/rest';

        this.async_op_status = null;        

        // private properties

        var user_homepage = null;

        var shared_data = null;

        var current = this;

        // public methods

        this.isShared = function(uri) {

                if (shared_data == null) {

                        this.get_shared_data();

                }

                for (var i = 0; i < shared_data.length; i++) {

                        if(uri.indexOf(shared_data[i]) >= 0) {

                                return true;

                        }

                }

                return false;

        }

        this.get_shared_data = function() {

                shared_data = new Array();

                var d = vfs.getDirectory(user_homepage.shared);

                for (var i in d.files) {

                        shared_data.push(d.files[i].URI);

                }

                for (var i in d.folders) {

                        shared_data.push(d.folders[i].URI);

                }

                return shared_data;

        }

        this.user_homepage = function() {

                if(user_homepage == null) {

                        user_homepage = new UserHomePage();

                }

                return user_homepage;

        }

        this.create_request_get = function(rest_req) {

                if ( vfs.isRemoteResource(rest_req) ) {

                        var gmtstring = (new Date()).toGMTString();

                        var sign_url = rest_req.replace(this.rest_url, "");

                        var hash = sign(this.token, sign_url, gmtstring, "GET");

                        return rest_req + ('?Date=' + encodeURIComponent(gmtstring) + '&Authorization=' + encodeURIComponent(this.username) + '%20' + encodeURIComponent(hash));

                } else {

                        if ( isUnix() ) {

                                return 'file://' + rest_req;

                        }

                        if ( isWindows() ) {

                                return 'file:///' + rest_req.replace('\\','/');

                        }

                }

                return rest_req;

        }

    this.rest_request_get_inline = function(rest_req) {

        var url = this.create_request_get(rest_req);

        netscape.security.PrivilegeManager.enablePrivilege("UniversalXPConnect UniversalFileRead UniversalBrowserRead");

        var req = Components.classes["@mozilla.org/xmlextras/xmlhttprequest;1"].createInstance(Components.interfaces.nsIXMLHttpRequest);

        req.open("GET", url, false);

        req.overrideMimeType('text/plain; charset=x-user-defined');

        req.channel.loadFlags |= Components.interfaces.nsIRequest.LOAD_BYPASS_CACHE;

        req.send(null);

        return req;

    }

        this.rest_request_get_inline_async = function(rest_req,params,destination) {

        var url = this.create_request_get(rest_req);

        netscape.security.PrivilegeManager.enablePrivilege("UniversalXPConnect UniversalFileRead UniversalBrowserRead");

        var req = Components.classes["@mozilla.org/xmlextras/xmlhttprequest;1"].createInstance(Components.interfaces.nsIXMLHttpRequest);

                req.onload = this.onLoadDefault;

                req.onprogress = this.onProgressDefault;

                req.onerror = this.onErrorDefault;

                req.addEventListener("progress", params.progress, false);

                req.addEventListener("load", params.complete, false);

                req.addEventListener("error", params.failed, false);

                req.addEventListener("abort", params.cancelled, false);  

                req.open("GET", url, true);

        req.overrideMimeType('text/plain; charset=x-user-defined');

        req.send(null);

        return req;                

        }

    this.rest_request_put_upload_async = function(source, rest_req, data, mime, params) {

        var url = rest_req;

        var sign_url = rest_req.replace(current.rest_url, '');

        var gmtstring = (new Date()).toGMTString();

        netscape.security.PrivilegeManager.enablePrivilege("UniversalXPConnect UniversalFileRead UniversalBrowserRead");

        var file = Components.classes["@mozilla.org/file/local;1"].createInstance(Components.interfaces.nsILocalFile);

        try {

            file.initWithPath(source);

        } catch(error) {

            alert(error);

            return null;

        }

                netscape.security.PrivilegeManager.enablePrivilege("UniversalXPConnect UniversalFileRead UniversalBrowserRead");

        var stream = Components.classes["@mozilla.org/network/file-input-stream;1"].createInstance(Components.interfaces.nsIFileInputStream);

                netscape.security.PrivilegeManager.enablePrivilege("UniversalXPConnect UniversalFileRead UniversalBrowserRead");

        stream.init(file, 0x01, 0644, 0x04); // file is an nsIFile instance  

                netscape.security.PrivilegeManager.enablePrivilege("UniversalXPConnect UniversalFileRead UniversalBrowserRead");

        var req = Components.classes["@mozilla.org/xmlextras/xmlhttprequest;1"].createInstance(Components.interfaces.nsIXMLHttpRequest);

                req.onload = this.onLoadDefault;

                req.onprogress = this.onProgressDefault;

                req.onerror = this.onErrorDefault;

                req.upload.addEventListener("progress", params.progress, false);

                req.upload.addEventListener("load", params.complete, false);

                req.upload.addEventListener("error", params.failed, false);

                req.upload.addEventListener("abort", params.cancelled, false);  

        req.open("PUT", url, true);

        req.setRequestHeader('Authorization', current.username + " " + sign(current.token, sign_url, gmtstring, "PUT"));

        req.setRequestHeader('X-GSS-Date', gmtstring);

        req.setRequestHeader("Content-type", mime + "; charset=utf-8");

        //req.setRequestHeader("Content-length", data.length);

        req.send(stream);

        return req;

    }

    this.rest_request_put_upload = function(source, rest_req, data, mime) {

        var url = rest_req;

        var sign_url = rest_req.replace(current.rest_url, '');

        var gmtstring = (new Date()).toGMTString();

        netscape.security.PrivilegeManager.enablePrivilege("UniversalXPConnect UniversalFileRead UniversalBrowserRead");

        var file = Components.classes["@mozilla.org/file/local;1"].createInstance(Components.interfaces.nsILocalFile);

        try {

            file.initWithPath(source);

        } catch(error) {

            alert(error);

            return null;

        }

                netscape.security.PrivilegeManager.enablePrivilege("UniversalXPConnect UniversalFileRead UniversalBrowserRead");

        var stream = Components.classes["@mozilla.org/network/file-input-stream;1"].createInstance(Components.interfaces.nsIFileInputStream);

                netscape.security.PrivilegeManager.enablePrivilege("UniversalXPConnect UniversalFileRead UniversalBrowserRead");

        stream.init(file, 0x01, 0644, 0x04); // file is an nsIFile instance  

                netscape.security.PrivilegeManager.enablePrivilege("UniversalXPConnect UniversalFileRead UniversalBrowserRead");

        var req = Components.classes["@mozilla.org/xmlextras/xmlhttprequest;1"].createInstance(Components.interfaces.nsIXMLHttpRequest);

        req.open("PUT", url, false);

        req.setRequestHeader('Authorization', current.username + " " + sign(current.token, sign_url, gmtstring, "PUT"));

        req.setRequestHeader('X-GSS-Date', gmtstring);

        req.setRequestHeader("Content-type", mime + "; charset=utf-8");

        //req.setRequestHeader("Content-length", data.length);

        req.send(stream);

        return req;

    }

        this.rest_request_post_async = function(rest_req, params, data) {

                return rest_request_generic(rest_req, params, "POST", data, true, this.onLoadDefault, this.onProgressDefault, this.onErrorDefault);

        }

        this.rest_request_put_async = function(rest_req, params, data) {

                return rest_request_generic(rest_req, params, "PUT", data, true, this.onLoadDefault, this.onProgressDefault, this.onErrorDefault);

        }

        this.rest_request_head = function(rest_req, params) {

                return rest_request_generic(rest_req, params, "HEAD", null, false, null, null, null);

        }

        this.rest_request_delete = function(rest_req, params) {

                return rest_request_generic(rest_req, params, "DELETE", null, false, null, null, null);

        }

        this.rest_request_post = function(rest_req, params, data) {

                return rest_request_generic(rest_req, params, "POST", data, false, null, null, null);

        }

        this.rest_request_get = function(rest_req, params) {

                return this.rest_request_sync(rest_req, params);

        }

        this.rest_request_put = function(rest_req, params, data) {

                return rest_request_generic(rest_req, params, "PUT", data, false, null, null, null); 

        }

        this.rest_request_sync = function(rest_req, params) {

                return rest_request_generic(rest_req, params, "GET", null, false, null, null, null);

        }

        this.rest_request_async = function(rest_req, params, on_load, on_progress, on_error) {

                return rest_request_generic(rest_req, params, "GET", null, true, on_load, on_progress, on_error);

        }

        this.success = function(status) {

                return (status >= 200 && status < 300);

        }

        // empty implementations of async events 

        // for easy programming

        this.onLoadDefault = function(e) { }

        this.onProgressDefault = function(e) { }

        this.onErrorDefault = function(e) { }

        // private methods        

        function rest_request_generic(rest_req, params, method, data, async, on_load, on_progress, on_error) {

                var url = rest_req;

                var sign_url = rest_req.replace(current.rest_url, '');

                var gmtstring = new Date().toGMTString();

                netscape.security.PrivilegeManager.enablePrivilege("UniversalXPConnect UniversalFileRead UniversalBrowserRead");

                var req = Components.classes["@mozilla.org/xmlextras/xmlhttprequest;1"].createInstance(Components.interfaces.nsIXMLHttpRequest);

                req.open(method, url + params, async);

                if (async) {

                        req.onload = on_load;

                        req.onprogress = on_progress;

                        req.onerror = on_error;

                }

        req.setRequestHeader('X-GSS-Date', gmtstring);

                req.setRequestHeader('Authorization', current.username + " " + sign(current.token, sign_url, gmtstring, method));

                if ( method == "GET" || method == "HEAD" || method == "DELETE") {

                        req.send(null);

                } else if ( method == "POST" || method == "PUT" ) {

                        req.setRequestHeader("Content-type", "text/plain; charset=utf-8");

                        req.setRequestHeader("Content-length", data.length);

                        req.send(data);

                }

                return req;

        }

        function check_null_result(r, d) {

                var res = r.exec(d);

                if (res == null) { return 'ERROR: no connection data'; }

                return res[1];

        }

        function sign(token, thepath, gmtdate, method) {

            var rawdatastring = method.toUpperCase() + gmtdate + thepath;

            var signature = gss_sign(token, rawdatastring);

            return (signature);

        }

        // Allow access to cookie database of browser

        netscape.security.PrivilegeManager.enablePrivilege("UniversalXPConnect UniversalFileRead UniversalBrowserRead");    

        var cookieManager = Components.classes["@mozilla.org/cookiemanager;1"].getService(Components.interfaces.nsICookieManager);

        var menum = cookieManager.enumerator;

        while (menum.hasMoreElements()){

                var cookie = menum.getNext().QueryInterface(Components.interfaces.nsICookie);

                if ( (cookie.host == '.pithos.grnet.gr') && (cookie.name == '_gss_a') ) {

                        var tokens = cookie.value.split('|');

                        this.email = 'ERROR: no connection data';

                        this.username = tokens[0].replace('%40', '@');

                        this.login = this.username.split('@')[0];

                        this.token = tokens[1];                        

                        break;

                }

        }

        //document.getElementById('label-username').value = this.username + ' (' + this.login + ')';

        $mb = jQuery.noConflict();

        $mb('#label-username').val(this.username + ' (' + this.login + ')');

}

function UserHomePage() {

        // public properties

        this.fileroot = 'ERROR: fileroot not defined';

        this.trash = 'ERROR: trash is not defined';

        this.shared = 'ERROR: shared is not defined';

        this.others = 'ERROR: others is not defined';

        this.tags = 'ERROR: tags is not defined';

        this.groups = 'ERROR: groups is not defined';

        this.announcement = 'ERROR: announcement is not defined';

        this.creationdate = 0;

        this.modificationDate = 0;

        this.totalFiles = 0;

        this.totalBytes = 0;

        this.bytesRemaining = 0;

        // private properties

        var req = connection_obj.rest_request_sync(connection_obj.rest_url + '/' + connection_obj.username + '/', '');

        var homepage_json = JSON.parse(req.responseText);

        // public methods

        this.fileroot_object = function() {

                // TODO: do some checking here

                return vfs.getDirectory(this.fileroot);

        }

        this.others_object = function() {

                var others_obj = JSON.parse(connection_obj.rest_request_get(connection_obj.user_homepage().others, '').responseText);

                // Create an object that resembles a Directory

                var d = new Object();

                d.name = connection_obj.user_homepage().others;

                d.path = connection_obj.user_homepage().others;

                d.URI = connection_obj.user_homepage().others;

                d.files = new Array();

                d.folders = new Array();

                d.permissions = new Array();

                for ( i = 0; i < others_obj.length; i++ ) {

                        var dd = new Object();

                        dd.name = others_obj[i].username;

                        dd.URI = others_obj[i].uri + '/';

                        dd.isShared = true;

                        dd.contentImage = mimes.getMime('directory', true);

                        d.folders.push(dd);

                }

                return d;

        }

        this.tags_list = function() {

                var data = connection_obj.rest_request_get(this.tags,'');

                if(connection_obj.success(data.status)) {

                        return ( JSON.parse(data.responseText) );

                } else {

                        return;

                }

        }

    this.reinit = function() {

        var req = connection_obj.rest_request_sync(connection_obj.rest_url + '/' + connection_obj.username + '/', '');

            homepage_json = JSON.parse(req.responseText);

        this.fileroot = homepage_json.fileroot + '/';

        this.trash = homepage_json.trash + '/';

        this.shared = homepage_json.shared + '/';

        this.others = homepage_json.others + '/';

        this.tags = homepage_json.tags + '/';

        this.groups = homepage_json.groups + '/';

        this.creationdate = homepage_json.creationDate;

        this.modificationDate = homepage_json.modificationDate;

        this.totalFiles = homepage_json.quota.totalFiles;

        this.totalBytes = homepage_json.quota.totalBytes;

        this.bytesRemaining = homepage_json.quota.bytesRemaining;

        this.announcement = homepage_json.announcement;                

    }

        // private methods

        // run initialization

        this.fileroot = homepage_json.fileroot + '/';

        this.trash = homepage_json.trash + '/';

        this.shared = homepage_json.shared + '/';

        this.others = homepage_json.others + '/';

        this.tags = homepage_json.tags + '/';

        this.groups = homepage_json.groups + '/';

        this.creationdate = homepage_json.creationDate;

        this.modificationDate = homepage_json.modificationDate;

        this.totalFiles = homepage_json.quota.totalFiles;

        this.totalBytes = homepage_json.quota.totalBytes;

        this.bytesRemaining = homepage_json.quota.bytesRemaining;

        this.announcement = homepage_json.announcement;

    $mb = jQuery.noConflict();

    $mb('#label-total-files').val(this.totalFiles + ' files');

    $mb('#label-used-quota').val(Math.round(((this.totalBytes) / 1024) / 1024) + ' MB used');

    $mb('#label-free-quota').val(Math.round((this.bytesRemaining / 1024) / 1024) + ' MB free');

    $mb("#label-system-message").val(this.announcement);            

}