/* This Source Code Form is subject to the terms of the Mozilla Public
 * License, v. 2.0. If a copy of the MPL was not distributed with this
 * file, You can obtain one at http://mozilla.org/MPL/2.0/. */

Components.utils.import("resource://gre/modules/XPCOMUtils.jsm");
Components.utils.import("resource://calendar/modules/calUtils.jsm");

//
// calCompositeCalendar.js
//

/**
 * Calendar specific utility functions
 */
const calIOperationListener = Components.interfaces.calIOperationListener;

function calCompositeCalendarObserverHelper (compCalendar) {
    this.compCalendar = compCalendar;
    this.pendingLoads = {};
}

calCompositeCalendarObserverHelper.prototype = {
    pendingLoads: null,

    QueryInterface: XPCOMUtils.generateQI([Components.interfaces.calIObserver]),

    onStartBatch: function() {
        this.compCalendar.mObservers.notify("onStartBatch");
    },

    onEndBatch: function() {
        this.compCalendar.mObservers.notify("onEndBatch");
    },

    onLoad: function(calendar) {
        // avoid unnecessary onLoad events:
        if (this.pendingLoads[calendar.id]) {
            // don't forward if caused by composite:
            delete this.pendingLoads[calendar.id];
        } else {
            // any refreshed dependent calendar logically refreshes
            // this composite calendar, thus we send out an onLoad
            // for this composite calendar:
            this.compCalendar.mObservers.notify("onLoad", [this.compCalendar]);
        }
    },

    onAddItem: function(aItem) {
        this.compCalendar.mObservers.notify("onAddItem", arguments);
    },

    onModifyItem: function(aNewItem, aOldItem) {
        this.compCalendar.mObservers.notify("onModifyItem", arguments);
    },

    onDeleteItem: function(aDeletedItem) {
        this.compCalendar.mObservers.notify("onDeleteItem", arguments);
    },

    onError: function(aCalendar, aErrNo, aMessage) {
        this.compCalendar.mObservers.notify("onError", arguments);
    },

    onPropertyChanged: function(aCalendar, aName, aValue, aOldValue) {
        this.compCalendar.mObservers.notify("onPropertyChanged", arguments);
    },

    onPropertyDeleting: function(aCalendar, aName) {
        this.compCalendar.mObservers.notify("onPropertyDeleting", arguments);
    }
};

function calCompositeCalendar () {
    this.mObserverHelper = new calCompositeCalendarObserverHelper(this);
    this.wrappedJSObject = this;

    this.mCalendars = new Array();
    this.mCompositeObservers = new cal.ObserverBag(Components.interfaces.calICompositeObserver);
    this.mObservers = new cal.ObserverBag(Components.interfaces.calIObserver);
    this.mDefaultCalendar = null;
    this.mStatusObserver = null;
}

const calCompositeCalendarClassID = Components.ID("{aeff788d-63b0-4996-91fb-40a7654c6224}");
const calCompositeCalendarInterfaces = [
    Components.interfaces.calICalendarProvider,
    Components.interfaces.calICalendar,
    Components.interfaces.calICompositeCalendar,
];
calCompositeCalendar.prototype = {
    classID: calCompositeCalendarClassID,
    QueryInterface: XPCOMUtils.generateQI(calCompositeCalendarInterfaces),
    classInfo: XPCOMUtils.generateCI({
        classID: calCompositeCalendarClassID,
        contractID: "@mozilla.org/calendar/calendar;1?type=composite",
        classDescription: "Composite Calendar Provider",
        interfaces: calCompositeCalendarInterfaces,
    }),

    //
    // calICalendarProvider interface
    //
    get prefChromeOverlay() null,
    get displayName() cal.calGetString("calendar", "compositeName"),

    createCalendar: function comp_createCal() {
        throw NS_ERROR_NOT_IMPLEMENTED;
    },

    deleteCalendar: function comp_deleteCal(calendar, listener) {
        // You shouldn't be able to delete from the composite calendar.
        throw NS_ERROR_NOT_IMPLEMENTED;
    },

    //
    // calICompositeCalendar interface
    //

    mCalendars: null,
    mDefaultCalendar: null,
    mPrefPrefix: null,
    mDefaultPref: null,
    mActivePref: null,

    get enabledCalendars() {
      return this.mCalendars.filter(
        function(e) { return !e.getProperty("disabled"); }
      );
    },

    set prefPrefix (aPrefPrefix) {
        if (this.mPrefPrefix) {
            for each (let calendar in this.mCalendars) {
                this.removeCalendar(calendar);
            }
        }
        this.mPrefPrefix = aPrefPrefix;
        this.mActivePref = aPrefPrefix + "-in-composite";
        this.mDefaultPref = aPrefPrefix + "-default";
        let mgr = cal.getCalendarManager();
        let cals = mgr.getCalendars({});

        cals.forEach(function (c) {
            if (c.getProperty(this.mActivePref))
                this.addCalendar(c);
            if (c.getProperty(this.mDefaultPref))
                this.setDefaultCalendar(c, false);
        }, this);
    },

    get prefPrefix () {
        return this.mPrefPrefix;
    },

    addCalendar: function cCC_addCalendar(aCalendar) {
        cal.ASSERT(aCalendar.id, "calendar does not have an id!", true);

        // check if the calendar already exists
        if (this.getCalendarById(aCalendar.id)) {
            return;
        }

        // add our observer helper
        aCalendar.addObserver(this.mObserverHelper);

        this.mCalendars.push(aCalendar);
        if (this.mPrefPrefix) {
            aCalendar.setProperty(this.mActivePref, true);
        }
        this.mCompositeObservers.notify("onCalendarAdded", [aCalendar]);

        // if we have no default calendar, we need one here
        if (this.mDefaultCalendar == null && !aCalendar.getProperty("disabled")) {
            this.setDefaultCalendar(aCalendar, false);
        }
    },

    removeCalendar: function cCC_removeCalendar(aCalendar) {
        let id = aCalendar.id;
        let newCalendars = this.mCalendars.filter(function(calendar) { return calendar.id != id; });
        if (newCalendars.length != this.mCalendars) {
            this.mCalendars = newCalendars;
            if (this.mPrefPrefix) {
                aCalendar.deleteProperty(this.mActivePref);
                aCalendar.deleteProperty(this.mDefaultPref);
            }
            aCalendar.removeObserver(this.mObserverHelper);
            this.mCompositeObservers.notify("onCalendarRemoved", [aCalendar]);
        }
    },

    getCalendarById: function cCC_getCalendarById(aId) {
        for each (let calendar in this.mCalendars) {
            if (calendar.id == aId) {
                return calendar;
            }
        }
        return null;
    },

    getCalendars: function getCalendars(count) {
        count.value = this.mCalendars.length;
        return this.mCalendars;
    },

    get defaultCalendar() {
        return this.mDefaultCalendar;
    },

    setDefaultCalendar: function (calendar, usePref) {
        // Don't do anything if the passed calendar is the default calendar
        if (calendar && this.mDefaultCalendar && this.mDefaultCalendar.id == calendar.id) {
            return;
        }
        if (usePref && this.mPrefPrefix) {
            if (this.mDefaultCalendar) {
                this.mDefaultCalendar.deleteProperty(this.mDefaultPref);
            }
            // if not null set the new calendar as default in the preferences
            if (calendar)  {
                calendar.setProperty(this.mDefaultPref, true);
            }
        }
        this.mDefaultCalendar = calendar;
        this.mCompositeObservers.notify("onDefaultCalendarChanged", [calendar]);
    },

    set defaultCalendar(v) {
        this.setDefaultCalendar(v, true);
    },

    //
    // calICalendar interface
    //
    // Write operations here are forwarded to either the item's
    // parent calendar, or to the default calendar if one is set.
    // Get operations are sent to each calendar.
    //

    get id() {
        throw Components.results.NS_ERROR_NOT_IMPLEMENTED;
    },
    set id(id) {
        throw Components.results.NS_ERROR_NOT_IMPLEMENTED;
    },

    get superCalendar() {
        // There shouldn't be a superCalendar for the composite
        return this;
    },
    set superCalendar(val) {
        throw Components.results.NS_ERROR_NOT_IMPLEMENTED;
    },

    // this could, at some point, return some kind of URI identifying
    // all the child calendars, thus letting us create nifty calendar
    // trees.
    get uri() {
        throw Components.results.NS_ERROR_NOT_IMPLEMENTED;
    },
    set uri(v) {
        throw Components.results.NS_ERROR_NOT_IMPLEMENTED;
    },

    get readOnly() {
        throw Components.results.NS_ERROR_NOT_IMPLEMENTED;
    },
    set readOnly(bool) {
        throw Components.results.NS_ERROR_NOT_IMPLEMENTED;
    },

    get canRefresh() {
        return true;
    },

    get name() {
        throw Components.results.NS_ERROR_NOT_IMPLEMENTED;
    },
    set name(v) {
        throw Components.results.NS_ERROR_NOT_IMPLEMENTED;
    },

    get type() {
        return "composite";
    },

    getProperty: function(aName) {
        return this.mDefaultCalendar.getProperty(aName);
    },

    setProperty: function(aName, aValue) {
        return this.mDefaultCalendar.setProperty(aName, aValue);
    },

    deleteProperty: function(aName) {
        return this.mDefaultCalendar.deleteProperty(aName);
    },

    // void addObserver( in calIObserver observer );
    mCompositeObservers: null,
    mObservers: null,
    addObserver: function (aObserver) {
        let wrappedCObserver = cal.wrapInstance(aObserver, Components.interfaces.calICompositeObserver);
        if (wrappedCObserver) {
            this.mCompositeObservers.add(wrappedCObserver);
        }
        this.mObservers.add(aObserver);
    },

    // void removeObserver( in calIObserver observer );
    removeObserver: function (aObserver) {
        let wrappedCObserver = cal.wrapInstance(aObserver, Components.interfaces.calICompositeObserver);
        if (wrappedCObserver) {
            this.mCompositeObservers.remove(wrappedCObserver);
        }
        this.mObservers.remove(aObserver);
    },

    refresh: function cCC_refresh() {
        if (this.mStatusObserver) {
            this.mStatusObserver.startMeteors(Components.interfaces.calIStatusObserver.DETERMINED_PROGRESS, this.mCalendars.length);
        }
        for each (let calendar in this.enabledCalendars) {
            try {
                if (calendar.canRefresh) {
                    this.mObserverHelper.pendingLoads[calendar.id] = true;
                    calendar.refresh();
                }
            } catch (e) {
                cal.ASSERT(false, e);
                delete this.mObserverHelper.pendingLoads[calendar.id];
            }
        }
        // send out a single onLoad for this composite calendar,
        // although e.g. the ics provider will trigger another
        // onLoad asynchronously; we cannot rely on every calendar
        // sending an onLoad:
        this.mObservers.notify("onLoad", [this]);
    },

    // void modifyItem( in calIItemBase aNewItem, in calIItemBase aOldItem, in calIOperationListener aListener );
    modifyItem: function (aNewItem, aOldItem, aListener) {
        cal.ASSERT(aNewItem.calendar, "Composite can't modify item with null calendar", true);
        cal.ASSERT(aNewItem.calendar != this, "Composite can't modify item with this calendar", true);

        return aNewItem.calendar.modifyItem(aNewItem, aOldItem, aListener);
    },

    // void deleteItem( in string id, in calIOperationListener aListener );
    deleteItem: function (aItem, aListener) {
        cal.ASSERT(aItem.calendar, "Composite can't delete item with null calendar", true);
        cal.ASSERT(aItem.calendar != this, "Composite can't delete item with this calendar", true);

        return aItem.calendar.deleteItem(aItem, aListener);
    },

    // void addItem( in calIItemBase aItem, in calIOperationListener aListener );
    addItem: function (aItem, aListener) {
        return this.mDefaultCalendar.addItem(aItem, aListener);
    },

    // void getItem( in string aId, in calIOperationListener aListener );
    getItem: function (aId, aListener) {
        let enabledCalendars = this.enabledCalendars;
        let cmpListener = new calCompositeGetListenerHelper(this, aListener);
        for each (let calendar in enabledCalendars) {
            try {
                cmpListener.opGroup.add(calendar.getItem(aId, cmpListener));
            } catch (exc) {
                cal.ASSERT(false, exc);
            }
        }
        return cmpListener.opGroup;
    },

    // void getItems( in unsigned long aItemFilter, in unsigned long aCount,
    //                in calIDateTime aRangeStart, in calIDateTime aRangeEnd,
    //                in calIOperationListener aListener );
    getItems: function (aItemFilter, aCount, aRangeStart, aRangeEnd, aListener) {
        // If there are no calendars, then we just call onOperationComplete
        let enabledCalendars = this.enabledCalendars;
        if (enabledCalendars.length == 0) {
            aListener.onOperationComplete (this,
                                           Components.results.NS_OK,
                                           calIOperationListener.GET,
                                           null,
                                           null);
            return null;
        }
        if (this.mStatusObserver) {
            if (this.mStatusObserver.spinning == Components.interfaces.calIStatusObserver.NO_PROGRESS) {
                this.mStatusObserver.startMeteors(Components.interfaces.calIStatusObserver.UNDETERMINED_PROGRESS, -1);
            }
        }
        let cmpListener = new calCompositeGetListenerHelper(this, aListener, aCount);

        for each (let calendar in enabledCalendars) {
            try {
                cmpListener.opGroup.add(calendar.getItems(aItemFilter,
                                                          aCount,
                                                          aRangeStart,
                                                          aRangeEnd,
                                                          cmpListener));
            } catch (exc) {
                cal.ASSERT(false, exc);
            }
        }
        return cmpListener.opGroup;
    },

    startBatch: function () {
        this.mCompositeObservers.notify("onStartBatch");
    },
    endBatch: function () {
        this.mCompositeObservers.notify("onEndBatch");
    },

    get statusDisplayed() {
        if (!this.mStatusObserver){
            return false;
        } else {
            return this.mStatusObserver.spinning != Components.interfaces.calIStatusObserver.NO_PROGRESS;
        }
    },

    setStatusObserver: function(aStatusObserver, aWindow){
        this.mStatusObserver = aStatusObserver;
        if (this.mStatusObserver) {
            this.mStatusObserver.initialize(aWindow);
        }
    }
};

// composite listener helper
function calCompositeGetListenerHelper(aCompositeCalendar, aRealListener, aMaxItems) {
    this.wrappedJSObject = this;
    this.mCompositeCalendar = aCompositeCalendar;
    this.mNumQueries = aCompositeCalendar.enabledCalendars.length;
    this.mRealListener = aRealListener;
    this.mMaxItems = aMaxItems;
}

calCompositeGetListenerHelper.prototype = {
    mNumQueries: 0,
    mRealListener: null,
    mOpGroup: null,
    mReceivedCompletes: 0,
    mFinished: false,
    mMaxItems: 0,
    mItemsReceived: 0,

    get opGroup() {
        if (!this.mOpGroup) {
            this.mOpGroup = new cal.calOperationGroup(() => {
                let listener = this.mRealListener;
                this.mRealListener = null;
                if (listener) {
                    listener.onOperationComplete(
                        this, Components.interfaces.calIErrors.OPERATION_CANCELLED,
                        calIOperationListener.GET, null, null);
                    if (this.mCompositeCalendar.statusDisplayed) {
                        this.mCompositeCalendar.mStatusObserver.stopMeteors();
                    }
                }
            });
        }
        return this.mOpGroup;
    },

    QueryInterface: function (aIID) {
        if (!aIID.equals(Components.interfaces.nsISupports) &&
            !aIID.equals(Components.interfaces.calIOperationListener))
        {
            throw Components.results.NS_ERROR_NO_INTERFACE;
        }

        return this;
    },

    onOperationComplete: function (aCalendar, aStatus, aOperationType, aId, aDetail) {
        if (!this.mRealListener) {
            // has been cancelled, ignore any providers firing on this...
            return;
        }
        if (this.mFinished) {
            dump ("+++ calCompositeGetListenerHelper.onOperationComplete: called with mFinished == true!");
            return;
        }
        if (this.mCompositeCalendar.statusDisplayed) {
            this.mCompositeCalendar.mStatusObserver.calendarCompleted(aCalendar);
        }
        if (!Components.isSuccessCode(aStatus)) {
            // proxy this to a onGetResult
            // XXX - do we want to give the real calendar? or this?
            // XXX - get rid of iid param
            this.mRealListener.onGetResult(aCalendar, aStatus,
                                           Components.interfaces.nsISupports,
                                           aDetail, 0, []);
        }

        this.mReceivedCompletes++;
        if (this.mReceivedCompletes == this.mNumQueries) {
            if (this.mCompositeCalendar.statusDisplayed) {
                this.mCompositeCalendar.mStatusObserver.stopMeteors();
            }
            // we're done here.
            this.mFinished = true;
            this.opGroup.notifyCompleted();
            this.mRealListener.onOperationComplete (this,
                                                    aStatus,
                                                    calIOperationListener.GET,
                                                    null,
                                                    null);
        }
    },

    onGetResult: function (aCalendar, aStatus, aItemType, aDetail, aCount, aItems) {
        if (!this.mRealListener) {
            // has been cancelled, ignore any providers firing on this...
            return;
        }
        if (this.mFinished) {
            dump ("+++ calCompositeGetListenerHelper.onGetResult: called with mFinished == true!");
            return;
        }

        // ignore if we have a max and we're past it
        if (this.mMaxItems && this.mItemsReceived >= this.mMaxItems)
            return;

        if (Components.isSuccessCode(aStatus) &&
            this.mMaxItems &&
            ((this.mItemsReceived + aCount) > this.mMaxItems))
        {
            // this will blow past the limit
            aCount = this.mMaxItems - this.mItemsReceived;
            aItems = aItems.slice(0, aCount);
        }

        // send GetResults to the real listener
        this.mRealListener.onGetResult (aCalendar, aStatus, aItemType, aDetail, aCount, aItems);
        this.mItemsReceived += aCount;
    }

};

/** Module Registration */
var NSGetFactory = XPCOMUtils.generateNSGetFactory([calCompositeCalendar]);
