paul@0 | 1 | var EXPORTED_SYMBOLS = [ "fburl" ]; |
paul@0 | 2 | |
paul@0 | 3 | const Cc = Components.classes; |
paul@0 | 4 | const Ci = Components.interfaces; |
paul@0 | 5 | const Cu = Components.utils; |
paul@0 | 6 | |
paul@0 | 7 | Cu.import("resource://calendar/modules/calUtils.jsm"); |
paul@3 | 8 | Cu.import("resource://calendar/modules/calIteratorUtils.jsm"); |
paul@1 | 9 | Cu.import("resource:///modules/mailServices.js"); |
paul@1 | 10 | Cu.import("resource://gre/modules/XPCOMUtils.jsm"); |
paul@0 | 11 | |
paul@0 | 12 | if ("undefined" == typeof(fburl)) { |
paul@0 | 13 | var fburl = {}; |
paul@0 | 14 | }; |
paul@0 | 15 | |
paul@0 | 16 | const calIFreeBusyInterval = Ci.calIFreeBusyInterval; |
paul@0 | 17 | const calIDateTime = Ci.calIDateTime; |
paul@0 | 18 | |
paul@1 | 19 | fburl.fbUrlProvider = function(cal) { |
paul@1 | 20 | this.cal = cal; |
paul@1 | 21 | this._query = null; |
paul@1 | 22 | this._context = null; |
paul@1 | 23 | this._result = null; |
paul@1 | 24 | this._searched = false; |
paul@1 | 25 | this._error = null; |
paul@2 | 26 | this._listener = null; |
paul@2 | 27 | this._url = null; |
paul@3 | 28 | this._calId = null; |
paul@3 | 29 | this._periods = null; |
paul@1 | 30 | }; |
paul@0 | 31 | |
paul@0 | 32 | fburl.fbUrlProvider.prototype = { |
paul@1 | 33 | classID: Components.ID("{11291d94-b457-4322-bfba-ae9df4b6a3c1}"), |
paul@0 | 34 | |
paul@0 | 35 | getFreeBusyIntervals: function (aCalId, aRangeStart, aRangeEnd, aBusyTypes, aListener) { |
paul@0 | 36 | |
paul@3 | 37 | this._listener = aListener; |
paul@3 | 38 | this._calId = aCalId; |
paul@3 | 39 | this._periods = null; |
paul@3 | 40 | this.startSearch(aCalId); |
paul@1 | 41 | }, |
paul@1 | 42 | |
paul@1 | 43 | getLDAPAddressBooks: function () { |
paul@1 | 44 | |
paul@1 | 45 | var abManager = Cc["@mozilla.org/abmanager;1"].getService(Ci.nsIAbManager); |
paul@1 | 46 | var allAddressBooks = abManager.directories; |
paul@1 | 47 | var books = []; |
paul@1 | 48 | |
paul@1 | 49 | while (allAddressBooks.hasMoreElements()) { |
paul@1 | 50 | var addressBook = allAddressBooks.getNext().QueryInterface(Ci.nsIAbDirectory); |
paul@1 | 51 | if (addressBook instanceof Ci.nsIAbLDAPDirectory) { |
paul@1 | 52 | books.push(addressBook); |
paul@1 | 53 | } |
paul@1 | 54 | } |
paul@1 | 55 | |
paul@1 | 56 | return books; |
paul@1 | 57 | }, |
paul@1 | 58 | |
paul@1 | 59 | startSearch: function (aCalId) { |
paul@1 | 60 | |
paul@1 | 61 | var service = Cc["@mozilla.org/network/ldap-service;1"].getService(Ci.nsILDAPService); |
paul@1 | 62 | var books = this.getLDAPAddressBooks(); |
paul@1 | 63 | |
paul@1 | 64 | this._result = null; |
paul@1 | 65 | aCalId = aCalId.replace(/^mailto:/i, ""); |
paul@1 | 66 | |
paul@1 | 67 | for each (var book in books) { |
paul@1 | 68 | var ldap = book.QueryInterface(Ci.nsIAbLDAPDirectory); |
paul@1 | 69 | var attrmap = Cc["@mozilla.org/addressbook/ldap-attribute-map;1"].createInstance(Ci.nsIAbLDAPAttributeMap); |
paul@1 | 70 | var args = Cc["@mozilla.org/addressbook/directory/query-arguments;1"].createInstance(Ci.nsIAbDirectoryQueryArguments); |
paul@1 | 71 | |
paul@1 | 72 | attrmap.setAttributeList("PrimaryEmail", "mail", true); |
paul@1 | 73 | attrmap.setAttributeList("FBURL", "calFbUrl", true); |
paul@1 | 74 | args.filter = service.createFilter(aCalId.length * 2, "(%a=%v)", "", "", "mail", aCalId); |
paul@1 | 75 | args.typeSpecificArg = attrmap; |
paul@1 | 76 | args.querySubDirectories = true; |
paul@1 | 77 | |
paul@1 | 78 | this._query = Cc["@mozilla.org/addressbook/ldap-directory-query;1"].createInstance(Ci.nsIAbDirectoryQuery); |
paul@1 | 79 | this._context = this._query.doQuery(ldap, args, this, ldap.maxHits, 0); |
paul@1 | 80 | this._searched = true; |
paul@1 | 81 | |
paul@1 | 82 | // NOTE: Do only one query for now. |
paul@1 | 83 | |
paul@1 | 84 | break; |
paul@1 | 85 | } |
paul@1 | 86 | }, |
paul@1 | 87 | |
paul@1 | 88 | stopSearch: function stopSearch() { |
paul@1 | 89 | if (this._context) { |
paul@1 | 90 | this._query.stopQuery(this._context); |
paul@1 | 91 | this._context = null; |
paul@2 | 92 | this._listener = null; |
paul@1 | 93 | } |
paul@1 | 94 | }, |
paul@1 | 95 | |
paul@1 | 96 | onSearchFinished: function (aResult, aErrorMsg) { |
paul@1 | 97 | this._context = null; |
paul@1 | 98 | this._error = aErrorMsg; |
paul@1 | 99 | }, |
paul@1 | 100 | |
paul@1 | 101 | onSearchFoundCard: function (aCard) { |
paul@1 | 102 | |
paul@2 | 103 | this._result = aCard; |
paul@2 | 104 | |
paul@2 | 105 | // Obtain the URL from the card. |
paul@2 | 106 | |
paul@2 | 107 | this._url = aCard.getProperty("FBURL", ""); |
paul@2 | 108 | |
paul@2 | 109 | // Retrieve the resource and parse it. |
paul@1 | 110 | |
paul@2 | 111 | var parser = Cc["@mozilla.org/calendar/ics-service;1"].getService(Ci.calIICSService); |
paul@2 | 112 | //var parser = Cc["@mozilla.org/calendar/ics-parser;1"].createInstance(Ci.calIIcsParser); |
paul@2 | 113 | var service = Cc["@mozilla.org/network/io-service;1"].getService(Ci.nsIIOService); |
paul@2 | 114 | var stream = Cc["@mozilla.org/scriptableinputstream;1"].createInstance(Ci.nsIScriptableInputStream); |
paul@2 | 115 | var channel = service.newChannelFromURI(service.newURI(this._url, null, null)); |
paul@2 | 116 | |
paul@2 | 117 | stream.init(channel.open()); |
paul@3 | 118 | var resource = parser.parseICS(stream.read(-1), null); |
paul@3 | 119 | |
paul@3 | 120 | // Obtain the free/busy periods. |
paul@3 | 121 | |
paul@3 | 122 | this._periods = []; |
paul@3 | 123 | var fbTypeMap = {}; |
paul@3 | 124 | |
paul@3 | 125 | fbTypeMap["FREE"] = calIFreeBusyInterval.FREE; |
paul@3 | 126 | fbTypeMap["BUSY"] = calIFreeBusyInterval.BUSY; |
paul@3 | 127 | fbTypeMap["BUSY-UNAVAILABLE"] = calIFreeBusyInterval.BUSY_UNAVAILABLE; |
paul@3 | 128 | fbTypeMap["BUSY-TENTATIVE"] = calIFreeBusyInterval.BUSY_TENTATIVE; |
paul@3 | 129 | |
paul@3 | 130 | // Iterate over components in the response. |
paul@3 | 131 | |
paul@3 | 132 | for (var comp in cal.ical.calendarComponentIterator(resource)) { |
paul@3 | 133 | |
paul@3 | 134 | // Iterate over free/busy properties. |
paul@3 | 135 | |
paul@3 | 136 | for (var fbProp in cal.ical.propertyIterator(comp, "FREEBUSY")) { |
paul@3 | 137 | |
paul@3 | 138 | // Assign the stated type or busy otherwise. |
paul@3 | 139 | |
paul@3 | 140 | var fbType = fbProp.getParameter("FBTYPE"); |
paul@3 | 141 | |
paul@3 | 142 | if (fbType) { |
paul@3 | 143 | fbType = fbTypeMap[fbType]; |
paul@3 | 144 | } else { |
paul@3 | 145 | fbType = calIFreeBusyInterval.BUSY; |
paul@3 | 146 | } |
paul@3 | 147 | |
paul@3 | 148 | var parts = fbProp.value.split("/"); |
paul@3 | 149 | var begin = cal.createDateTime(parts[0]); |
paul@3 | 150 | var end; |
paul@3 | 151 | |
paul@3 | 152 | // Support durations. |
paul@3 | 153 | |
paul@3 | 154 | if (parts[1].charAt(0) == "P") { |
paul@3 | 155 | end = begin.clone(); |
paul@3 | 156 | end.addDuration(cal.createDuration(parts[1])); |
paul@3 | 157 | |
paul@3 | 158 | // Support plain datetimes. |
paul@3 | 159 | |
paul@3 | 160 | } else { |
paul@3 | 161 | end = cal.createDateTime(parts[1]); |
paul@3 | 162 | } |
paul@3 | 163 | |
paul@3 | 164 | interval = new cal.FreeBusyInterval(this._calId, fbType, begin, end); |
paul@3 | 165 | this._periods.push(interval); |
paul@3 | 166 | } |
paul@3 | 167 | } |
paul@3 | 168 | |
paul@3 | 169 | this._listener.onResult(null, this._periods); |
paul@1 | 170 | }, |
paul@1 | 171 | |
paul@1 | 172 | QueryInterface: XPCOMUtils.generateQI([Ci.nsIObserver, Ci.nsIAbDirSearchListener]) |
paul@0 | 173 | }; |
paul@0 | 174 | |
paul@0 | 175 | fburl.initProvider = function() { |
paul@0 | 176 | cal.getFreeBusyService().addProvider(new fburl.fbUrlProvider(cal)); |
paul@0 | 177 | } |
paul@1 | 178 | |
paul@1 | 179 | fburl.test = function(aCalId) { |
paul@1 | 180 | var fbp = new fburl.fbUrlProvider(cal); |
paul@1 | 181 | fbp.startSearch(aCalId); |
paul@1 | 182 | return fbp; |
paul@1 | 183 | } |
paul@1 | 184 | |
paul@1 | 185 | const NSGetFactory = XPCOMUtils.generateNSGetFactory([fburl.fbUrlProvider]); |