Stackedit/public/res/helpers/googleHelper.js

/*global gapi, google */
define([
    "underscore",
    "jquery",
    "constants",
    "core",
    "utils",
    "storage",
    "logger",
    "settings",
    "eventMgr",
    "classes/AsyncTask",
], function(_, $, constants, core, utils, storage, logger, settings, eventMgr, AsyncTask) {

    var connected = false;
    var authorizationMgrMap = {};
    function AuthorizationMgr(accountId) {
        var permissionList = {
            profile: true
        };
        var refreshFlag = true;
        _.each((storage[accountId + '.permissions'] || '').split(';'), function(permission) {
            permission && (permissionList[permission] = true);
        });
        this.setRefreshFlag = function() {
            refreshFlag = true;
        };
        this.isAuthorized = function(permission) {
            return refreshFlag === false && _.has(permissionList, permission);
        };
        this.add = function(permission) {
            permissionList[permission] = true;
            storage[accountId + '.permissions'] = _.keys(permissionList).join(';');
            refreshFlag = false;
        };
        this.getListWithNew = function(permission) {
            var result = _.keys(permissionList);
            if(!_.has(permissionList, permission)) {
                result.push(permission);
            }
            return result;
        };
        var userId = storage[accountId + '.userId'];
        this.setUserId = function(value) {
            userId = value;
            storage[accountId + '.userId'] = userId;
        };
        this.getUserId = function() {
            return userId;
        };
    }

    var googleHelper = {};

    // Listen to offline status changes
    var isOffline = false;
    eventMgr.addListener("onOfflineChanged", function(isOfflineParam) {
        isOffline = isOfflineParam;
    });

    // Try to connect by downloading client.js
    function connect(task) {
        task.onRun(function() {
            if(isOffline === true) {
                connected = false;
                task.error(new Error("Operation not available in offline mode.|stopPublish"));
                return;
            }
            if(connected === true) {
                task.chain();
                return;
            }
            window.delayedFunction = function() {
                gapi.load("client,drive-realtime", function() {
                    gapi.client.load('drive', 'v2', function() {
                        connected = true;
                        task.chain();
                    });
                });
            };
            $.ajax({
                url: "https://apis.google.com/js/api.js?onload=runDelayedFunction",
                dataType: "script",
                timeout: constants.AJAX_TIMEOUT
            }).fail(function(jqXHR) {
                var error = {
                    code: jqXHR.status,
                    message: jqXHR.statusText
                };
                handleError(error, task);
            });
        });
    }

    // Try to authenticate with Oauth
    var scopeMap = {
        profile: [
            'https://www.googleapis.com/auth/userinfo.profile'
        ],
        gdrive: [
            'https://www.googleapis.com/auth/drive.install',
            settings.gdriveFullAccess === true ? 'https://www.googleapis.com/auth/drive' : 'https://www.googleapis.com/auth/drive.file'
        ],
        blogger: [
            'https://www.googleapis.com/auth/blogger'
        ],
        picasa: [
            'https://picasaweb.google.com/data/'
        ]
    };
    function authenticate(task, permission, accountId) {
        var authorizationMgr = authorizationMgrMap[accountId];
        if(!authorizationMgr) {
            authorizationMgr = new AuthorizationMgr(accountId);
            authorizationMgrMap[accountId] = authorizationMgr;
        }
        task.onRun(function() {
            var currentToken = gapi.auth.getToken();
            var newToken;
            function getTokenInfo() {
                $.ajax({
                    url: 'https://www.googleapis.com/oauth2/v1/tokeninfo',
                    data: {
                        access_token: newToken.access_token
                    },
                    timeout: constants.AJAX_TIMEOUT,
                    type: "GET"
                }).done(function(data) {
                    if(authorizationMgr.getUserId() && authorizationMgr.getUserId() != data.user_id) {
                        // Wrong user id, try again
                        startAuthenticate();
                    }
                    else {
                        authorizationMgr.setUserId(data.user_id);
                        authorizationMgr.add(permission);
                        authorizationMgr.token = newToken;
                        task.chain();
                    }
                }).fail(function(jqXHR) {
                    var error = {
                        code: jqXHR.status,
                        message: jqXHR.statusText
                    };
                    handleError(error, task);
                });
            }
            var authuser = 0;
            var immediate;
            function localAuthenticate() {
                if(authuser > 5) {
                    task.error(new Error('Unable to authenticate user ' + authorizationMgr.getUserId() + ', please sign in with Google.'));
                    return;
                }
                if(immediate === false) {
                    task.timeout = constants.ASYNC_TASK_LONG_TIMEOUT;
                }
                var scopeList = _.chain(scopeMap).pick(authorizationMgr.getListWithNew(permission)).flatten().value();
                gapi.auth.authorize({
                    client_id: constants.GOOGLE_CLIENT_ID,
                    scope: scopeList,
                    immediate: immediate,
                    authuser: immediate === false ? '' : authuser
                }, function(authResult) {
                    newToken = gapi.auth.getToken();
                    gapi.auth.setToken(currentToken);
                    if(!authResult || authResult.error) {
                        if(connected === true && immediate === true) {
                            // If immediate did not work retry without immediate
                            // flag
                            immediate = false;
                            task.chain(oauthRedirect);
                        }
                        else {
                            // Error
                            task.error(new Error("Access to Google account is not authorized."));
                        }
                    }
                    else {
                        // Success but we need to check the user id
                        immediate === true && authuser++;
                        task.chain(getTokenInfo);
                    }
                });
            }
            function oauthRedirect() {
                if(immediate === true) {
                    task.chain(localAuthenticate);
                    return;
                }
                utils.redirectConfirm('You are being redirected to <strong>Google</strong> authorization page.', function() {
                    task.chain(localAuthenticate);
                }, function() {
                    task.error(new Error('Operation canceled.'));
                });
            }
            function startAuthenticate() {
                immediate = true;
                if(authorizationMgr.token && authorizationMgr.isAuthorized(permission)) {
                    task.chain();
                    return;
                }
                if(!authorizationMgr.getUserId()) {
                    immediate = false;
                }
                task.chain(oauthRedirect);
            }
            startAuthenticate();
        });
    }
    googleHelper.refreshGdriveToken = function(accountId) {
        var task = new AsyncTask();
        connect(task);
        var authorizationMgr = authorizationMgrMap[accountId];
        authorizationMgr && authorizationMgr.setRefreshFlag();
        authenticate(task, 'gdrive', accountId);
        task.enqueue();
    };

    function runWithToken(accountId, functionToRun) {
        var currentToken = gapi.auth.getToken();
        var authorizationMgr = authorizationMgrMap[accountId];
        gapi.auth.setToken(authorizationMgr.token);
        functionToRun();
        gapi.auth.setToken(currentToken);
    }

    googleHelper.upload = function(fileId, parentId, title, content, contentType, etag, accountId, callback) {
        var result;
        var task = new AsyncTask();
        connect(task);
        authenticate(task, 'gdrive', accountId);
        task.onRun(function() {
            var boundary = '-------314159265358979323846';
            var delimiter = "\r\n--" + boundary + "\r\n";
            var close_delim = "\r\n--" + boundary + "--";
            contentType = contentType || 'text/x-markdown';
            var metadata = {
                title: title,
                mimeType: contentType
            };
            if(parentId) {
                // Specify the directory
                metadata.parents = [
                    {
                        kind: 'drive#fileLink',
                        id: parentId
                    }
                ];
            }
            var path = '/upload/drive/v2/files';
            var method = 'POST';
            if(fileId) {
                // If it's an update
                path += "/" + fileId;
                method = 'PUT';
            }
            var headers = {
                'Content-Type': 'multipart/mixed; boundary="' + boundary + '"',
            };
            // Sometimes we have error 412 from Google even with the correct
            // etag
            // if(etag !== undefined) {
            // headers["If-Match"] = etag;
            // }

            var base64Data = utils.encodeBase64(content);
            var multipartRequestBody = [
                delimiter,
                'Content-Type: application/json\r\n\r\n',
                JSON.stringify(metadata),
                delimiter,
                'Content-Type: ',
                contentType,
                '\r\n',
                'Content-Transfer-Encoding: base64\r\n',
                '\r\n',
                base64Data,
                close_delim
            ].join("");

            runWithToken(accountId, function() {
                var request = gapi.client.request({
                    'path': path,
                    'method': method,
                    'params': {
                        'uploadType': 'multipart',
                    },
                    'headers': headers,
                    'body': multipartRequestBody,
                });
                request.execute(function(response) {
                    if(response && response.id) {
                        // Upload success
                        result = response;
                        result.content = content;
                        task.chain();
                        return;
                    }
                    var error = response.error;
                    // Handle error
                    if(error !== undefined && fileId !== undefined) {
                        if(error.code === 404) {
                            error = 'File ID "' + fileId + '" not found on Google Drive.|removePublish';
                        }
                        else if(error.code === 412) {
                            // We may have missed a file update
                            storage.removeItem(accountId + ".gdrive.lastChangeId");
                            error = 'Conflict on file ID "' + fileId + '". Please restart the synchronization.';
                        }
                    }
                    handleError(error, task);
                });
            });
        });
        task.onSuccess(function() {
            callback(undefined, result);
        });
        task.onError(function(error) {
            callback(error);
        });
        task.enqueue();
    };

    googleHelper.rename = function(fileId, title, accountId, callback) {
        var result;
        var task = new AsyncTask();
        connect(task);
        authenticate(task, 'gdrive', accountId);
        task.onRun(function() {
            var body = {'title': title};
            runWithToken(accountId, function() {
                var request = gapi.client.drive.files.patch({
                    'fileId': fileId,
                    'resource': body
                });
                request.execute(function(response) {
                    if(response && response.id) {
                        // Rename success
                        result = response;
                        task.chain();
                        return;
                    }
                    var error = response.error;
                    // Handle error
                    if(error !== undefined && fileId !== undefined) {
                        if(error.code === 404) {
                            error = 'File ID "' + fileId + '" not found on Google Drive.|removePublish';
                        }
                    }
                    handleError(error, task);
                });
            });
        });
        task.onSuccess(function() {
            callback(undefined, result);
        });
        task.onError(function(error) {
            callback(error);
        });
        task.enqueue();
    };

    googleHelper.createRealtimeFile = function(parentId, title, accountId, callback) {
        var result;
        var task = new AsyncTask();
        connect(task);
        authenticate(task, 'gdrive', accountId);
        task.onRun(function() {
            var metadata = {
                title: title,
                mimeType: 'application/vnd.google-apps.drive-sdk',
            };
            if(parentId !== undefined) {
                // Specify the directory
                metadata.parents = [
                    {
                        kind: 'drive#fileLink',
                        id: parentId
                    }
                ];
            }
            runWithToken(accountId, function() {
                var request = gapi.client.drive.files.insert({
                    'resource': metadata
                });
                request.execute(function(response) {
                    if(response && response.id) {
                        // Upload success
                        result = response;
                        task.chain();
                        return;
                    }
                    handleError(response.error, task);
                });
            });
        });
        task.onSuccess(function() {
            callback(undefined, result);
        });
        task.onError(function(error) {
            callback(error);
        });
        task.enqueue();
    };

    googleHelper.checkChanges = function(lastChangeId, accountId, callback) {
        var changes = [];
        var newChangeId = lastChangeId || 0;
        var task = new AsyncTask();
        connect(task);
        authenticate(task, 'gdrive', accountId);
        task.onRun(function() {
            var nextPageToken;
            function retrievePageOfChanges() {
                runWithToken(accountId, function() {
                    var request;
                    if(nextPageToken === undefined) {
                        request = gapi.client.drive.changes.list({
                            'startChangeId': newChangeId + 1
                        });
                    }
                    else {
                        request = gapi.client.drive.changes.list({
                            'pageToken': nextPageToken
                        });
                    }

                    request.execute(function(response) {
                        if(!response || !response.largestChangeId) {
                            // Handle error
                            handleError(response.error, task);
                            return;
                        }
                        // Retrieve success
                        newChangeId = response.largestChangeId;
                        nextPageToken = response.nextPageToken;
                        if(response.items !== undefined) {
                            changes = changes.concat(response.items);
                        }
                        if(nextPageToken !== undefined) {
                            task.chain(retrievePageOfChanges);
                        }
                        else {
                            task.chain();
                        }
                    });
                });
            }
            task.chain(retrievePageOfChanges);
        });
        task.onSuccess(function() {
            callback(undefined, changes, newChangeId);
        });
        task.onError(function(error) {
            callback(error);
        });
        task.enqueue();
    };

    googleHelper.downloadMetadata = function(ids, accountId, callback, skipAuth) {
        var result = [];
        var task = new AsyncTask();
        connect(task);
        if(!skipAuth) {
            authenticate(task, 'gdrive', accountId);
        }
        task.onRun(function() {
            function recursiveDownloadMetadata() {
                if(ids.length === 0) {
                    task.chain();
                    return;
                }
                var id = ids[0];
                var headers = {};
                var authorizationMgr = authorizationMgrMap[accountId];
                if(authorizationMgr && authorizationMgr.token) {
                    headers.Authorization = "Bearer " + authorizationMgr.token.access_token;
                }
                $.ajax({
                    url: "https://www.googleapis.com/drive/v2/files/" + id,
                    headers: headers,
                    data: {
                        key: constants.GOOGLE_API_KEY
                    },
                    dataType: "json",
                    timeout: constants.AJAX_TIMEOUT
                }).done(function(data) {
                    result.push(data);
                    ids.shift();
                    task.chain(recursiveDownloadMetadata);
                }).fail(function(jqXHR) {
                    var error = {
                        code: jqXHR.status,
                        message: jqXHR.statusText
                    };
                    // Handle error
                    if(error.code === 404) {
                        error = 'File ID "' + id + '" not found on Google Drive.';
                    }
                    handleError(error, task);
                });
            }
            task.chain(recursiveDownloadMetadata);
        });
        task.onSuccess(function() {
            callback(undefined, result);
        });
        task.onError(function(error) {
            callback(error);
        });
        task.enqueue();
    };

    googleHelper.downloadContent = function(objects, accountId, callback, skipAuth) {
        var result = [];
        var task = new AsyncTask();
        // Add some time for user to choose his files
        task.timeout = constants.ASYNC_TASK_LONG_TIMEOUT;
        connect(task);
        if(!skipAuth) {
            authenticate(task, 'gdrive', accountId);
        }
        task.onRun(function() {
            function recursiveDownloadContent() {
                if(objects.length === 0) {
                    task.chain();
                    return;
                }
                var object = objects[0];
                result.push(object);
                var file;
                // object may be a file
                if(object.kind == "drive#file") {
                    file = object;
                }
                // object may be a change
                else if(object.kind == "drive#change") {
                    file = object.file;
                }
                if(!file) {
                    objects.shift();
                    task.chain(recursiveDownloadContent);
                    return;
                }
                // if file is a real time document
                if(file.mimeType.indexOf("application/vnd.google-apps.drive-sdk") === 0) {
                    file.content = "";
                    file.isRealtime = true;
                    objects.shift();
                    task.chain(recursiveDownloadContent);
                    return;
                }
                var headers = {};
                var authorizationMgr = authorizationMgrMap[accountId];
                if(authorizationMgr && authorizationMgr.token) {
                    headers.Authorization = "Bearer " + authorizationMgr.token.access_token;
                }
                $.ajax({
                    url: file.downloadUrl,
                    headers: headers,
                    data: {
                        key: constants.GOOGLE_API_KEY
                    },
                    dataType: "text",
                    timeout: constants.AJAX_TIMEOUT
                }).done(function(data) {
                    file.content = data;
                    objects.shift();
                    task.chain(recursiveDownloadContent);
                }).fail(function(jqXHR) {
                    var error = {
                        code: jqXHR.status,
                        message: jqXHR.statusText
                    };
                    // Handle error
                    handleError(error, task);
                });
            }
            task.chain(recursiveDownloadContent);
        });
        task.onSuccess(function() {
            callback(undefined, result);
        });
        task.onError(function(error) {
            callback(error);
        });
        task.enqueue();
    };

    googleHelper.loadRealtime = function(fileId, content, accountId, callback, errorCallback) {
        var doc;
        var task = new AsyncTask();
        connect(task);
        authenticate(task, 'gdrive', accountId);
        task.onRun(function() {
            var authorizationMgr = authorizationMgrMap[accountId];
            gapi.auth.setToken(authorizationMgr.token);
            gapi.drive.realtime.load(fileId, function(result) {
                // onFileLoaded
                doc = result;
                task.chain();
            }, function(model) {
                // initializeModel
                var string = model.createString(content);
                model.getRoot().set('content', string);
            }, function(err) {
                errorCallback(err);
                task.error(new Error(err.message));
            });
        });
        task.onSuccess(function() {
            callback(undefined, doc);
        });
        task.onError(function(error) {
            callback(error);
        });
        task.enqueue();
    };

    googleHelper.uploadImg = function(name, content, albumId, callback) {
        var accountId = 'google.picasa0';
        var result;
        var task = new AsyncTask();
        connect(task);
        authenticate(task, 'picasa', accountId);
        task.onRun(function() {
            var headers = {
                "Slug": name
            };
            if(name.match(/.jpe?g$/i)) {
                headers["Content-Type"] = "image/jpeg";
            }
            else if(name.match(/.png$/i)) {
                headers["Content-Type"] = "image/png";
            }
            else if(name.match(/.gif$/i)) {
                headers["Content-Type"] = "image/gif";
            }
            var authorizationMgr = authorizationMgrMap[accountId];
            if(authorizationMgr && authorizationMgr.token) {
                headers.Authorization = "Bearer " + authorizationMgr.token.access_token;
            }

            $.ajax({
                url: constants.PICASA_PROXY_URL + "upload/" + albumId,
                headers: headers,
                data: content,
                processData: false,
                dataType: "xml",
                timeout: constants.AJAX_TIMEOUT,
                type: "POST"
            }).done(function(data) {
                result = data;
                task.chain();
            }).fail(function(jqXHR) {
                var error = {
                    code: jqXHR.status,
                    message: jqXHR.statusText
                };
                if(error.code == 200) {
                    error.message = jqXHR.responseText;
                }
                handleError(error, task);
            });
        });
        task.onSuccess(function() {
            callback(undefined, result);
        });
        task.onError(function(error) {
            callback(error);
        });
        task.enqueue();
    };

    function handleError(error, task) {
        var errorMsg;
        if(error) {
            logger.error(error);
            // Try to analyze the error
            if(typeof error === "string") {
                errorMsg = error;
            }
            else {
                errorMsg = "Google error (" + error.code + ": " + error.message + ").";
                if(error.code >= 500 && error.code < 600) {
                    // Retry as described in Google's best practices
                    task.retry(new Error(errorMsg));
                    return;
                }
                else if(error.code === 401 || error.code === 403 || error.code == "token_refresh_required") {
                    _.each(authorizationMgrMap, function(authorizationMgr) {
                        authorizationMgr.setRefreshFlag();
                    });
                    errorMsg = "Access to Google account is not authorized.";
                    task.retry(new Error(errorMsg), 1);
                    return;
                }
                else if(error.code === 0 || error.code === -1) {
                    connected = false;
                    _.each(authorizationMgrMap, function(authorizationMgr) {
                        authorizationMgr.setRefreshFlag();
                    });
                    core.setOffline();
                    errorMsg = "|stopPublish";
                }
            }
        }
        task.error(new Error(errorMsg));
    }

    var pickerLoaded = false;
    function loadPicker(task) {
        task.onRun(function() {
            if(pickerLoaded === true) {
                task.chain();
                return;
            }
            $.ajax({
                url: "//www.google.com/jsapi",
                data: {
                    key: constants.GOOGLE_API_KEY
                },
                dataType: "script",
                timeout: constants.AJAX_TIMEOUT
            }).done(function() {
                google.load('picker', '1', {
                    callback: function() {
                        task.chain();
                    }
                });
                pickerLoaded = true;
            }).fail(function(jqXHR) {
                var error = {
                    code: jqXHR.status,
                    message: jqXHR.statusText
                };
                handleError(error, task);
            });
        });
    }

    googleHelper.picker = function(callback, pickerType, accountId) {
        var docs = [];
        var picker;
        function hidePicker() {
            if(picker !== undefined) {
                picker.setVisible(false);
                $(".modal-backdrop, .picker").remove();
            }
        }
        var task = new AsyncTask();
        // Add some time for user to choose his files
        task.timeout = constants.ASYNC_TASK_LONG_TIMEOUT;
        connect(task);
        if(pickerType == 'doc' || pickerType == 'folder') {
            authenticate(task, 'gdrive', accountId);
        }
        else {
            accountId = 'google.picasa0';
            authenticate(task, 'picasa', accountId);
        }
        loadPicker(task);
        task.onRun(function() {
            var authorizationMgr = authorizationMgrMap[accountId];
            var pickerBuilder = new google.picker.PickerBuilder();
            pickerBuilder.setAppId(constants.GOOGLE_DRIVE_APP_ID);
            var view;
            if(pickerType == 'doc') {
                view = new google.picker.DocsView(google.picker.ViewId.DOCS);
                view.setParent('root');
                view.setIncludeFolders(true);
                view.setMimeTypes([
                    "text/x-markdown",
                    "text/plain",
                    "application/octet-stream",
                    "application/vnd.google-apps.drive-sdk." + constants.GOOGLE_DRIVE_APP_ID
                ].join(","));
                pickerBuilder.enableFeature(google.picker.Feature.NAV_HIDDEN);
                pickerBuilder.enableFeature(google.picker.Feature.MULTISELECT_ENABLED);
                pickerBuilder.addView(view);
                authorizationMgr && authorizationMgr.token && pickerBuilder.setOAuthToken(authorizationMgr.token.access_token);
            }
            else if(pickerType == 'folder') {
                view = new google.picker.DocsView(google.picker.ViewId.FOLDERS);
                view.setParent('root');
                view.setIncludeFolders(true);
                view.setSelectFolderEnabled(true);
                view.setMimeTypes('application/vnd.google-apps.folder');
                pickerBuilder.enableFeature(google.picker.Feature.NAV_HIDDEN);
                pickerBuilder.addView(view);
                authorizationMgr && authorizationMgr.token && pickerBuilder.setOAuthToken(authorizationMgr.token.access_token);
            }
            else if(pickerType == 'img') {
                view = new google.picker.PhotosView();
                view.setType('flat');
                pickerBuilder.addView(view);
                view = new google.picker.PhotosView();
                view.setType('ofuser');
                pickerBuilder.addView(view);
                pickerBuilder.addView(google.picker.ViewId.PHOTO_UPLOAD);
                authorizationMgr && authorizationMgr.token && pickerBuilder.setOAuthToken(authorizationMgr.token.access_token);
            }
            pickerBuilder.setCallback(function(data) {
                if(data.action == google.picker.Action.PICKED || data.action == google.picker.Action.CANCEL) {
                    if(data.action == google.picker.Action.PICKED) {
                        docs = data.docs;
                    }
                    hidePicker();
                    task.chain();
                }
            });
            picker = pickerBuilder.build();
            $(utils.createBackdrop()).click(function() {
                hidePicker();
                task.chain();
            });
            picker.setVisible(true);
        });
        task.onSuccess(function() {
            callback(undefined, docs);
        });
        task.onError(function(error) {
            hidePicker();
            callback(error);
        });
        task.enqueue();
    };

    googleHelper.uploadBlogger = function(blogUrl, blogId, postId, labelList, isDraft, publishDate, title, content, callback) {
        var accountId = 'google.blogger0';
        var task = new AsyncTask();
        connect(task);
        authenticate(task, 'blogger', accountId);
        task.onRun(function() {
            var headers = {};
            var authorizationMgr = authorizationMgrMap[accountId];
            if(authorizationMgr && authorizationMgr.token) {
                headers.Authorization = "Bearer " + authorizationMgr.token.access_token;
            }
            function uploadPost() {
                var url = "https://www.googleapis.com/blogger/v3/blogs/" + blogId + "/posts/";
                var data = {
                    kind: "blogger#post",
                    blog: {
                        id: blogId
                    },
                    labels: labelList,
                    title: title,
                    content: content
                };
                var type = "POST";
                // If it's an update
                if(postId !== undefined) {
                    url += postId;
                    data.id = postId;
                    type = "PUT";
                }
                $.ajax({
                    url: url,
                    data: JSON.stringify(data),
                    headers: headers,
                    type: type,
                    contentType: "application/json",
                    dataType: "json",
                    timeout: constants.AJAX_TIMEOUT
                }).done(function(post) {
                    postId = post.id;
                    task.chain(publish);
                }).fail(function(jqXHR) {
                    var error = {
                        code: jqXHR.status,
                        message: jqXHR.statusText
                    };
                    // Handle error
                    if(error.code === 404 && postId !== undefined) {
                        error = 'Post ' + postId + ' not found on Blogger.|removePublish';
                    }
                    handleError(error, task);
                });
            }
            function publish() {
                var url = "https://www.googleapis.com/blogger/v3/blogs/" + blogId + "/posts/" + postId;
                if(isDraft) {
                    url += "/revert";
                }
                else {
                    url += "/publish";
                    if(publishDate) {
                        url += '?publishDate=' + publishDate.toISOString();
                    }
                }
                $.ajax({
                    url: url,
                    headers: headers,
                    type: 'POST',
                    dataType: "json",
                    timeout: constants.AJAX_TIMEOUT
                }).done(function() {
                    task.chain();
                }).fail(function(jqXHR) {
                    var error = {
                        code: jqXHR.status,
                        message: jqXHR.statusText
                    };
                    // Handle error
                    if(error.code === 404) {
                        error = 'Post ' + postId + ' not found on Blogger.|removePublish';
                    }
                    handleError(error, task);
                });
            }
            function getBlogId() {
                if(blogId !== undefined) {
                    task.chain(uploadPost);
                    return;
                }
                $.ajax({
                    url: "https://www.googleapis.com/blogger/v3/blogs/byurl",
                    data: {
                        url: blogUrl
                    },
                    headers: headers,
                    dataType: "json",
                    timeout: constants.AJAX_TIMEOUT
                }).done(function(blog) {
                    blogId = blog.id;
                    task.chain(uploadPost);
                }).fail(function(jqXHR) {
                    var error = {
                        code: jqXHR.status,
                        message: jqXHR.statusText
                    };
                    // Handle error
                    if(error.code === 404) {
                        error = 'Blog "' + blogUrl + '" not found on Blogger.|removePublish';
                    }
                    handleError(error, task);
                });
            }
            task.chain(getBlogId);
        });
        task.onSuccess(function() {
            callback(undefined, blogId, postId);
        });
        task.onError(function(error) {
            callback(error);
        });
        task.enqueue();
    };

    googleHelper.uploadBloggerPage = function(blogUrl, blogId, pageId, isDraft, publishDate, title, content, callback) {
        var accountId = 'google.blogger0';
        var task = new AsyncTask();
        connect(task);
        authenticate(task, 'blogger', accountId);
        task.onRun(function() {
            var headers = {};
            var authorizationMgr = authorizationMgrMap[accountId];
            if(authorizationMgr && authorizationMgr.token) {
                headers.Authorization = "Bearer " + authorizationMgr.token.access_token;
            }
            function uploadPage() {
                var url = "https://www.googleapis.com/blogger/v3/blogs/" + blogId + "/pages/";
                var data = {
                    kind: "blogger#page",
                    blog: {
                        id: blogId
                    },
                    title: title,
                    content: content
                };
                var type = "POST";
                // If it's an update
                if(pageId !== undefined) {
                    url += pageId;
                    data.id = pageId;
                    type = "PUT";
                }
                $.ajax({
                    url: url,
                    data: JSON.stringify(data),
                    headers: headers,
                    type: type,
                    contentType: "application/json",
                    dataType: "json",
                    timeout: constants.AJAX_TIMEOUT
                }).done(function(page) {
                    pageId = page.id;
                    task.chain();
                }).fail(function(jqXHR) {
                    var error = {
                        code: jqXHR.status,
                        message: jqXHR.statusText
                    };
                    // Handle error
                    if(error.code === 404 && pageId !== undefined) {
                        error = 'Page ' + pageId + ' not found on Blogger.|removePublish';
                    }
                    handleError(error, task);
                });
            }
            function getBlogId() {
                if(blogId !== undefined) {
                    task.chain(uploadPage);
                    return;
                }
                $.ajax({
                    url: "https://www.googleapis.com/blogger/v3/blogs/byurl",
                    data: {
                        url: blogUrl
                    },
                    headers: headers,
                    dataType: "json",
                    timeout: constants.AJAX_TIMEOUT
                }).done(function(blog) {
                    blogId = blog.id;
                    task.chain(uploadPage);
                }).fail(function(jqXHR) {
                    var error = {
                        code: jqXHR.status,
                        message: jqXHR.statusText
                    };
                    // Handle error
                    if(error.code === 404) {
                        error = 'Blog "' + blogUrl + '" not found on Blogger.|removePublish';
                    }
                    handleError(error, task);
                });
            }
            task.chain(getBlogId);
        });
        task.onSuccess(function() {
            callback(undefined, blogId, pageId);
        });
        task.onError(function(error) {
            callback(error);
        });
        task.enqueue();
    };

    // Use by Google's client.js
    window.delayedFunction = undefined;
    window.runDelayedFunction = function() {
        if(window.delayedFunction !== undefined) {
            window.delayedFunction();
        }
    };

    return googleHelper;
});