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