############################################################################### # # SageMathCloud: A collaborative web-based interface to Sage, IPython, LaTeX and the Terminal. # # Copyright (C) 2014, William Stein # # This program is free software: you can redistribute it and/or modify # it under the terms of the GNU General Public License as published by # the Free Software Foundation, either version 3 of the License, or # (at your option) any later version. # # This program is distributed in the hope that it will be useful, # but WITHOUT ANY WARRANTY; without even the implied warranty of # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the # GNU General Public License for more details. # # You should have received a copy of the GNU General Public License # along with this program. If not, see . # ############################################################################### ########################################################################## # # Misc. functions that are needed elsewhere. # ########################################################################## # ############################################################################### # Copyright (c) 2013, William Stein # All rights reserved. # # Redistribution and use in source and binary forms, with or without # modification, are permitted provided that the following conditions are met: # # 1. Redistributions of source code must retain the above copyright notice, this # list of conditions and the following disclaimer. # 2. 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. # # 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 OWNER 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. ############################################################################### # startswith(s, x) is true if s starts with the string x or any of the strings in x. exports.startswith = (s, x) -> if typeof(x) == "string" return s.indexOf(x) == 0 else for v in x if s.indexOf(v) == 0 return true return false # modifies in place the object dest so that it includes all values in objs and returns dest exports.merge = (dest, objs ...) -> for obj in objs dest[k] = v for k, v of obj dest # Return a random element of an array exports.random_choice = (array) -> array[Math.floor(Math.random() * array.length)] # Given an object map {foo:bar, ...} returns an array [foo, bar] randomly # chosen from the object map. exports.random_choice_from_obj = (obj) -> k = exports.random_choice(exports.keys(obj)) return [k, obj[k]] # Returns a random integer in the range, inclusive (like in Python) exports.randint = (lower, upper) -> Math.floor(Math.random()*(upper - lower + 1)) + lower # Like Python's string split -- splits on whitespace exports.split = (s) -> r = s.match(/\S+/g) if r return r else return [] # Like the exports.split method, but quoted terms are grouped together for an exact search. Like bing. exports.search_split = (search) -> terms = [] search = search.split('"') length = search.length for element, i in search element = element.trim() if element.length != 0 # the even elements lack quotation # if there are an even number of elements that means there is an unclosed quote, # so the last element shouldn't be grouped. if i % 2 == 0 or (i == length - 1 and length % 2 == 0) terms.push(element.split(" ")...) else terms.push(element) return terms # Count number of occurrences of m in s-- see http://stackoverflow.com/questions/881085/count-the-number-of-occurences-of-a-character-in-a-string-in-javascript exports.count = (str, strsearch) -> index = -1 count = -1 loop index = str.indexOf(strsearch, index + 1) count++ break unless index isnt -1 return count # modifies target in place, so that the properties of target are the # same as those of upper_bound, and each is <=. exports.min_object = (target, upper_bounds) -> if not target? target = {} for prop, val of upper_bounds target[prop] = if target.hasOwnProperty(prop) then target[prop] = Math.min(target[prop], upper_bounds[prop]) else upper_bounds[prop] # Returns a new object with properties determined by those of obj1 and # obj2. The properties in obj1 *must* all also appear in obj2. If an # obj2 property has value "defaults.required", then it must appear in # obj1. For each property P of obj2 not specified in obj1, the # corresponding value obj1[P] is set (all in a new copy of obj1) to # be obj2[P]. DEBUG = false exports.defaults = (obj1, obj2, allow_extra) -> if not obj1? obj1 = {} error = () -> try s = "(obj1=#{exports.trunc(exports.to_json(obj1),1024)}, obj2=#{exports.trunc(exports.to_json(obj2),1024)})" console.log(s) return s catch error return "" if typeof(obj1) != 'object' # We put explicit traces before the errors in this function, # since otherwise they can be very hard to debug. err = "misc.defaults -- TypeError: function takes inputs as an object #{error()}" console.log(err) console.trace() if DEBUG throw err else return obj2 r = {} for prop, val of obj2 if obj1.hasOwnProperty(prop) and obj1[prop]? if obj2[prop] == exports.defaults.required and not obj1[prop]? err = "misc.defaults -- TypeError: property '#{prop}' must be specified: #{error()}" console.log(err) console.trace() if DEBUG throw err r[prop] = obj1[prop] else if obj2[prop]? # only record not undefined properties if obj2[prop] == exports.defaults.required err = "misc.defaults -- TypeError: property '#{prop}' must be specified: #{error()}" console.log(err) console.trace() if DEBUG throw err else r[prop] = obj2[prop] if not allow_extra for prop, val of obj1 if not obj2.hasOwnProperty(prop) err = "misc.defaults -- TypeError: got an unexpected argument '#{prop}' #{error()}" console.log(err) console.trace() if DEBUG throw err return r # WARNING -- don't accidentally use this as a default: exports.required = exports.defaults.required = "__!!!!!!this is a required property!!!!!!__" # Current time in milliseconds since epoch exports.mswalltime = (t) -> if t? return (new Date()).getTime() - t else return (new Date()).getTime() # Current time in seconds since epoch, as a floating point number (so much more precise than just seconds). exports.walltime = (t) -> if t? return exports.mswalltime()/1000.0 - t else return exports.mswalltime()/1000.0 # We use this uuid implementation only for the browser client. For node code, use node-uuid. exports.uuid = -> `'xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx'.replace(/[xy]/g, function(c) { var r = Math.random()*16|0, v = c == 'x' ? r : (r&0x3|0x8); return v.toString(16); });` exports.is_valid_uuid_string = (uuid) -> return typeof(uuid) == "string" and uuid.length == 36 and /[a-fA-F0-9]{8}-[a-fA-F0-9]{4}-[a-fA-F0-9]{4}-[a-fA-F0-9]{4}-[a-fA-F0-9]{12}/i.test(uuid) # /[0-9a-f]{22}|[0-9a-f]{8}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{12}/i.test(uuid) # Return a very rough benchmark of the number of times f will run per second. exports.times_per_second = (f, max_time=5, max_loops=1000) -> # return number of times per second that f() can be called t = exports.walltime() i = 0 tm = 0 while true f() tm = exports.walltime() - t i += 1 if tm >= max_time or i >= max_loops break return Math.ceil(i/tm) # convert basic structure to a JSON string exports.to_json = (x) -> JSON.stringify(x) # convert object x to a JSON string, removing any keys that have "pass" in them and # any values that are potentially big -- this is meant to only be used for loging. exports.to_safe_str = (x) -> obj = {} for key, value of x sanitize = false if key.indexOf("pass") != -1 sanitize = true else if typeof(value)=='string' and value.slice(0,7) == "sha512$" sanitize = true if sanitize obj[key] = '(unsafe)' else if typeof(value) == "object" value = "[object]" # many objects, e.g., buffers can block for seconds to JSON... else if typeof(value) == "string" value = exports.trunc(value,250) # long strings are not SAFE -- since JSON'ing them for logging blocks for seconds! obj[key] = value x = exports.to_json(obj) # convert from a JSON string to Javascript exports.from_json = (x) -> try JSON.parse(x) catch err console.log("from_json: error parsing #{x} (=#{exports.to_json(x)}) from JSON") throw err # convert to JSON even if there are circular references # http://stackoverflow.com/questions/4816099/chrome-sendrequest-error-typeerror-converting-circular-structure-to-json censor = (censor) -> i = 0 return (key, value) -> if i and typeof(censor) == 'object' and typeof(value) == 'object' and censor == value return '[Circular]' if i >= 29 # seems to be a harded maximum of 30 serialized objects? return '[Unknown]'; ++i # so we know we aren't using the original object anymore return value exports.to_json_circular = (x) -> JSON.stringify(x, censor(x)) # converts a Date object to an ISO string in UTC. # NOTE -- we remove the +0000 (or whatever) timezone offset, since *all* machines within # the SMC servers are assumed to be on UTC. exports.to_iso = (d) -> (new Date(d - d.getTimezoneOffset()*60*1000)).toISOString().slice(0,-5) # returns true if the given object has no keys exports.is_empty_object = (obj) -> Object.keys(obj).length == 0 # returns the number of keys of an object, e.g., {a:5, b:7, d:'hello'} --> 3 exports.len = (obj) -> a = obj.length if a? return a Object.keys(obj).length # return the keys of an object, e.g., {a:5, xyz:'10'} -> ['a', 'xyz'] exports.keys = (obj) -> (key for key of obj) # as in python, makes a map from an array of pairs [(x,y),(z,w)] --> {x:y, z:w} exports.dict = (obj) -> x = {} for a in obj x[a[0]] = a[1] return x # remove first occurrence of value (just like in python); # throws an exception if val not in list. exports.remove = (obj, val) -> for i in [0...obj.length] if obj[i] == val obj.splice(i, 1) return throw "ValueError -- item not in array" # convert an array of 2-element arrays to an object, e.g., [['a',5], ['xyz','10']] --> {a:5, xyz:'10'} exports.pairs_to_obj = (v) -> o = {} for x in v o[x[0]] = x[1] return o exports.obj_to_pairs = (obj) -> ([x,y] for x,y of obj) # from http://stackoverflow.com/questions/4009756/how-to-count-string-occurrence-in-string via http://js2coffee.org/ exports.substring_count = (string, subString, allowOverlapping) -> string += "" subString += "" return string.length + 1 if subString.length <= 0 n = 0 pos = 0 step = (if (allowOverlapping) then (1) else (subString.length)) loop pos = string.indexOf(subString, pos) if pos >= 0 n++ pos += step else break return n exports.max = (array) -> (array.reduce((a,b) -> Math.max(a, b))) exports.min = (array) -> (array.reduce((a,b) -> Math.min(a, b))) filename_extension_re = /(?:\.([^.]+))?$/ exports.filename_extension = (filename) -> ext = filename_extension_re.exec(filename)[1] if ext? return ext else return '' exports.copy = (obj) -> r = {} for x, y of obj r[x] = y return r # From http://coffeescriptcookbook.com/chapters/classes_and_objects/cloning exports.deep_copy = (obj) -> if not obj? or typeof obj isnt 'object' return obj if obj instanceof Date return new Date(obj.getTime()) if obj instanceof RegExp flags = '' flags += 'g' if obj.global? flags += 'i' if obj.ignoreCase? flags += 'm' if obj.multiline? flags += 'y' if obj.sticky? return new RegExp(obj.source, flags) newInstance = new obj.constructor() for key of obj newInstance[key] = exports.deep_copy(obj[key]) return newInstance # Split a pathname. Returns an object {head:..., tail:...} where tail is # everything after the final slash. Either part may be empty. # (Same as os.path.split in Python.) exports.path_split = (path) -> v = path.split('/') return {head:v.slice(0,-1).join('/'), tail:v[v.length-1]} exports.meta_file = (path, ext) -> p = exports.path_split(path) path = p.head if p.head != '' path += '/' return path + "." + p.tail + ".sage-" + ext # "foobar" --> "foo..." exports.trunc = (s, max_length) -> if not s? return s if not max_length? max_length = 1024 if s.length > max_length return s.slice(0,max_length-3) + "..." else return s # "foobar" --> "...bar" exports.trunc_left = (s, max_length) -> if not s? return s if not max_length? max_length = 1024 if s.length > max_length return "..." + s.slice(s.length-max_length+3) else return s exports.git_author = (first_name, last_name, email_address) -> "#{first_name} #{last_name} <#{email_address}>" # More canonical email address -- lower case and remove stuff between + and @. # This is mainly used for banning users. exports.canonicalize_email_address = (email_address) -> if typeof(email_address) != 'string' # silly, but we assume it is a string, and I'm concerned about a hacker attack involving that email_address = JSON.stringify(email_address) # remove + part from email address: foo+bar@example.com i = email_address.indexOf('+') if i != -1 j = email_address.indexOf('@') if j != -1 email_address = email_address.slice(0,i) + email_address.slice(j) # make email address lower case return email_address.toLowerCase() exports.lower_email_address = (email_address) -> if typeof(email_address) != 'string' # silly, but we assume it is a string, and I'm concerned about a hacker attack involving that email_address = JSON.stringify(email_address) # make email address lower case return email_address.toLowerCase() exports.parse_user_search = (query) -> queries = (q.trim().toLowerCase() for q in query.split(',')) r = {string_queries:[], email_queries:[]} for x in queries if x.indexOf('@') == -1 r.string_queries.push(x.split(/\s+/g)) else r.email_queries.push(x) return r # Delete trailing whitespace in the string s. See exports.delete_trailing_whitespace = (s) -> return s.replace(/[^\S\n]+$/gm, "") exports.assert = (condition, mesg) -> if not condition throw mesg exports.retry_until_success = (opts) -> opts = exports.defaults opts, f : exports.required # f((err) => ) start_delay : 100 # milliseconds max_delay : 20000 # milliseconds -- stop increasing time at this point factor : 1.4 # multiply delay by this each time max_tries : undefined # maximum number of times to call f max_time : undefined # milliseconds -- don't call f again if the call would start after this much time from first call log : undefined name : '' cb : undefined # called with cb() on *success*; cb(error) if max_tries is exceeded delta = opts.start_delay tries = 0 if opts.max_time? start_time = new Date() g = () -> tries += 1 if opts.log? if opts.max_tries? opts.log("retry_until_success(#{opts.name}) -- try #{tries}/#{opts.max_tries}") if opts.max_time? opts.log("retry_until_success(#{opts.name}) -- try #{tries} (started #{new Date() - start_time}ms ago; will stop before #{opts.max_time}ms max time)") if not opts.max_tries? and not opts.max_time? opts.log("retry_until_success(#{opts.name}) -- try #{tries}") opts.f (err)-> if err if opts.log? opts.log("retry_until_success(#{opts.name}) -- err=#{err}") if opts.max_tries? and opts.max_tries <= tries opts.cb?("maximum tries (=#{opts.max_tries}) exceeded - last error #{err}") return delta = Math.min(opts.max_delay, opts.factor * delta) if opts.max_time? and (new Date() - start_time) + delta > opts.max_time opts.cb?("maximum time (=#{opts.max_time}ms) exceeded - last error #{err}") return setTimeout(g, delta) else opts.cb?() g() # Attempt (using exponential backoff) to execute the given function. # Will keep retrying until it succeeds, then call "cb()". You may # call this multiple times and all callbacks will get called once the # connection succeeds, since it keeps a stack of all cb's. # The function f that gets called should make one attempt to do what it # does, then on success do cb() and on failure cb(err). # It must *NOT* call the RetryUntilSuccess callable object. # # Usage # # @foo = retry_until_success_wrapper(f:@_foo) # @bar = retry_until_success_wrapper(f:@_foo, start_delay:100, max_delay:10000, exp_factor:1.5) # exports.retry_until_success_wrapper = (opts) -> _X = new RetryUntilSuccess(opts) return (cb) -> _X.call(cb) class RetryUntilSuccess constructor: (opts) -> @opts = exports.defaults opts, f : exports.defaults.required # f(cb); cb(err) start_delay : 100 # initial delay beforing calling f again. times are all in milliseconds max_delay : 20000 exp_factor : 1.4 max_tries : undefined min_interval : 100 # if defined, all calls to f will be separated by *at least* this amount of time (to avoid overloading services, etc.) logname : undefined verbose : false if @opts.min_interval? if @opts.start_delay < @opts.min_interval @opts.start_delay = @opts.min_interval @f = @opts.f call: (cb, retry_delay) => if @opts.logname? console.log("#{@opts.logname}(... #{retry_delay})") if not @_cb_stack? @_cb_stack = [] if cb? @_cb_stack.push(cb) if @_calling return @_calling = true if not retry_delay? @attempts = 0 if @opts.logname? console.log("actually calling -- #{@opts.logname}(... #{retry_delay})") g = () => if @opts.min_interval? @_last_call_time = exports.mswalltime() @f (err) => @attempts += 1 @_calling = false if err if @opts.verbose console.log("#{@opts.logname}: error=#{err}") if @opts.max_tries? and @attempts >= @opts.max_tries while @_cb_stack.length > 0 @_cb_stack.pop()(err) return if not retry_delay? retry_delay = @opts.start_delay else retry_delay = Math.min(@opts.max_delay, @opts.exp_factor*retry_delay) f = () => @call(undefined, retry_delay) setTimeout(f, retry_delay) else while @_cb_stack.length > 0 @_cb_stack.pop()() if not @_last_call_time? or not @opts.min_interval? g() else w = exports.mswalltime(@_last_call_time) if w < @opts.min_interval setTimeout(g, @opts.min_interval - w) else g() # WARNING: params below have different semantics than above; these are what *really* make sense.... exports.eval_until_defined = (opts) -> opts = exports.defaults opts, code : exports.required start_delay : 100 # initial delay beforing calling f again. times are all in milliseconds max_time : 10000 # error if total time spent trying will exceed this time exp_factor : 1.4 cb : exports.required # cb(err, eval(code)) delay = undefined total = 0 f = () -> result = eval(opts.code) if result? opts.cb(false, result) else if not delay? delay = opts.start_delay else delay *= opts.exp_factor total += delay if total > opts.max_time opts.cb("failed to eval code within #{opts.max_time}") else setTimeout(f, delay) f() # Class to use for mapping a collection of strings to characters (e.g., for use with diff/patch/match). class exports.StringCharMapping constructor: (opts={}) -> opts = exports.defaults opts, to_char : undefined to_string : undefined @_to_char = {} @_to_string = {} @_next_char = 'A' if opts.to_string? for ch, st of opts.to_string @_to_string[ch] = st @_to_char[st] = ch if opts.to_char? for st,ch of opts.to_char @_to_string[ch] = st @_to_char[st] = ch @_find_next_char() _find_next_char: () => loop @_next_char = String.fromCharCode(@_next_char.charCodeAt(0) + 1) break if not @_to_string[@_next_char]? to_string: (strings) => t = '' for s in strings a = @_to_char[s] if a? t += a else t += @_next_char @_to_char[s] = @_next_char @_to_string[@_next_char] = s @_find_next_char() return t to_array: (string) => return (@_to_string[s] for s in string) # Given a string s, return the string obtained by deleting all later duplicate characters from s. exports.uniquify_string = (s) -> seen_already = {} t = '' for c in s if not seen_already[c]? t += c seen_already[c] = true return t exports.endswith = (s, t) -> return s.slice(s.length - t.length) == t # Return string t=s+'\n'*k so that t ends in at least n newlines. # Returns s itself (so no copy made) if s already ends in n newlines (a common case). ### -- not used exports.ensure_string_ends_in_newlines = (s, n) -> j = s.length-1 while j >= 0 and j >= s.length-n and s[j] == '\n' j -= 1 # Now either j = -1 or s[j] is not a newline (and it is the first character not a newline from the right). console.log(j) k = n - (s.length - (j + 1)) console.log(k) if k == 0 return s else return s + Array(k+1).join('\n') # see http://stackoverflow.com/questions/1877475/repeat-character-n-times ### # Used in the database, etc., for different types of users of a project exports.PROJECT_GROUPS = ['owner', 'collaborator', 'viewer', 'invited_collaborator', 'invited_viewer'] # turn an arbitrary string into a nice clean identifier that can safely be used in an URL exports.make_valid_name = (s) -> # for now we just delete anything that isn't alphanumeric. # See http://stackoverflow.com/questions/9364400/remove-not-alphanumeric-characters-from-string-having-trouble-with-the-char/9364527#9364527 # whose existence surprised me! return s.replace(/\W/g, '_').toLowerCase() # format is 2014-04-04-061502 exports.parse_bup_timestamp = (s) -> v = [s.slice(0,4), s.slice(5,7), s.slice(8,10), s.slice(11,13), s.slice(13,15), s.slice(15,17), '0'] return new Date("#{v[1]}/#{v[2]}/#{v[0]} #{v[3]}:#{v[4]}:#{v[5]} UTC") exports.hash_string = (s) -> # see http://stackoverflow.com/questions/7616461/generate-a-hash-from-string-in-javascript-jquery hash = 0 i = undefined chr = undefined len = undefined return hash if s.length is 0 i = 0 len = s.length while i < len chr = s.charCodeAt(i) hash = ((hash << 5) - hash) + chr hash |= 0 # convert to 32-bit integer i++ return hash exports.parse_hashtags = (t) -> # return list of pairs (i,j) such that t.slice(i,j) is a hashtag (starting with #). v = [] if not t? return v base = 0 while true i = t.indexOf('#') if i == -1 or i == t.length-1 return v base += i+1 if t[i+1] == '#' or not (i == 0 or t[i-1].match(/\s/)) t = t.slice(i+1) continue t = t.slice(i+1) # find next whitespace or non-alphanumeric or dash # TODO: this lines means hashtags must be US ASCII -- # see http://stackoverflow.com/questions/1661197/valid-characters-for-javascript-variable-names i = t.match(/\s|[^A-Za-z0-9_\-]/) if i i = i.index else i = -1 if i == 0 # hash followed immediately by whitespace -- markdown desc base += i+1 t = t.slice(i+1) else # a hash tag if i == -1 # to the end v.push([base-1, base+t.length]) return v else v.push([base-1, base+i]) base += i+1 t = t.slice(i+1) mathjax_delim = [['$$','$$'], ['\\(','\\)'], ['\\[','\\]'], ['\\begin{equation}', '\\end{equation}'], ['\\begin{equation*}', '\\end{equation*}'], ['\\begin{align}', '\\end{align}'], ['\\begin{align*}', '\\end{align*}'], ['\\begin{eqnarray}', '\\end{eqnarray}'], ['\\begin{eqnarray*}', '\\end{eqnarray*}'], ['$', '$'] # must be after $$ ] exports.parse_mathjax = (t) -> # Return list of pairs (i,j) such that t.slice(i,j) is a mathjax, including delimiters. # The delimiters are given in the mathjax_delim list above. v = [] i = 0 while i < t.length if t.slice(i,i+2) == '\\$' i += 2 continue for d in mathjax_delim if t.slice(i,i+d[0].length) == d[0] # a match -- find the close j = i+1 while j < t.length and t.slice(j,j+d[1].length) != d[1] j += 1 j += d[1].length v.push([i,j]) i = j break i += 1 return v # If you're going to set some innerHTML then mathjax it, exports.mathjax_escape = (html) -> return html.replace(/&(?!#?\w+;)/g, "&").replace(//g, ">").replace(/"/g, """).replace(/'/g, "'") exports.path_is_in_public_paths = (path, paths) -> # Return share object {path:.,description:.} if (1) path is contained in one # of the given paths (a list of strings) -- or path without zip extension is in paths, # or if (2) path is undefined. # then true if paths has length at least 1. if paths.length == 0 return false if not path? return paths.length > 0 if path.indexOf('../') != -1 # just deny any potentially trickiery involving relative path segments (TODO: maybe too restrictive?) return false for p in paths if p.path == "" # the whole project is public, which matches everything return p if path == p.path # exact match return p if path.slice(0,p.path.length+1) == p.path + '/' return p if exports.filename_extension(path) == "zip" # is path something_public.zip ? return exports.path_is_in_public_paths(path.slice(0,path.length-4), paths) return false # encode a UNIX path, which might have # and % in it. exports.encode_path = (path) -> path = encodeURI(path) # doesn't escape # and ?, since they are special for urls (but not unix paths) return path.replace(/#/g,'%23').replace(/\?/g,'%3F') # add a method _call_with_lock to obj, which makes it so it's easy to make it so only # one method can be called at a time of an object -- all calls until completion # of the first one get an error. exports.call_lock = (opts) -> opts = exports.defaults opts, obj : exports.required timeout_s : 30 # lock expire timeout after this many seconds obj = opts.obj obj._call_lock = () -> obj.__call_lock = true obj.__call_lock_timeout = () -> obj.__call_lock = false delete obj.__call_lock_timeout setTimeout(obj.__call_lock_timeout, opts.timeout_s * 1000) obj._call_unlock = () -> if obj.__call_lock_timeout? clearTimeout(obj.__call_lock_timeout) delete obj.__call_lock_timeout obj.__call_lock = false obj._call_with_lock = (f, cb) -> if obj.__call_lock cb?("error -- hit call_lock") return obj._call_lock() f (args...) -> obj._call_unlock() cb?(args...) exports.cmp = (a,b) -> if a < b return -1 else if a > b return 1 return 0 exports.timestamp_cmp = (a,b) -> a = a.timestamp b = b.timestamp if not a? return 1 if not b? return -1 if a > b return -1 else if a < b return +1 return 0 timestamp_cmp0 = (a,b) -> a = a.timestamp b = b.timestamp if not a? return -1 if not b? return 1 if a < b return -1 else if a > b return +1 return 0 ##################### # temporary location for activity_log code, shared by front and backend. ##################### class ActivityLog constructor: (opts) -> opts = exports.defaults opts, events : undefined account_id : exports.required # user notifications : {} @notifications = opts.notifications @account_id = opts.account_id if opts.events? @process(opts.events) obj: () => return {notifications:@notifications, account_id:@account_id} path: (e) => "#{e.project_id}/#{e.path}" process: (events) => #t0 = exports.mswalltime() by_path = {} for e in events ##if e.account_id == @account_id # ignore our own events ## continue key = @path(e) events_with_path = by_path[key] if not events_with_path? events_with_path = by_path[key] = [e] else events_with_path.push(e) for path, events_with_path of by_path events_with_path.sort(timestamp_cmp0) # oldest to newest for event in events_with_path @_process_event(event, path) #winston.debug("ActivityLog: processed #{events.length} in #{exports.mswalltime(t0)}ms") _process_event: (event, path) => # process the given event, assuming all older events have been # processed already; this updates the notifications object. if not path? path = @path(event) a = @notifications[path] if not a? @notifications[path] = a = {} a.timestamp = event.timestamp #console.log("process_event", event, path) #console.log(event.seen_by?.indexOf(@account_id)) #console.log(event.read_by?.indexOf(@account_id)) if event.seen_by? and event.seen_by.indexOf(@account_id) != -1 a.seen = event.timestamp if event.read_by? and event.read_by.indexOf(@account_id) != -1 a.read = event.timestamp if event.action? who = a[event.action] if not who? who = a[event.action] = {} who[event.account_id] = event.timestamp # The code below (instead of the line above) would include *all* times. # I'm not sure whether or not I want to use that information, since it # could get really big. #times = who[event.account_id] #if not times? # times = who[event.account_id] = [] #times.push(event.timestamp) exports.activity_log = (opts) -> new ActivityLog(opts) # see http://stackoverflow.com/questions/1144783/replacing-all-occurrences-of-a-string-in-javascript exports.replace_all = (string, search, replace) -> string.split(search).join(replace) exports.remove_c_comments = (s) -> while true i = s.indexOf('/*') if i == -1 return s j = s.indexOf('*/') if i >= j return s s = s.slice(0, i) + s.slice(j+2) exports.date_to_snapshot_format = (d) -> if not d? d = 0 if typeof(d) == "number" d = new Date(d) s = d.toJSON() s = s.replace('T','-').replace(/:/g, '') i = s.lastIndexOf('.') return s.slice(0,i) exports.stripe_date = (d) -> return new Date(d*1000).toLocaleDateString( 'lookup', { year: 'numeric', month: 'long', day: 'numeric' }) exports.capitalize = (s) -> return s.charAt(0).toUpperCase() + s.slice(1) exports.is_array = (obj) -> Object.prototype.toString.call(obj) == "[object Array]"