#
#
# add_file "contrib/monotone-mail-notify-standalone.lua"
#  content [be58dde21383408beaafcda9dd51a86446f0838b]
# 
# patch "contrib/README"
#  from [f333b7972b375370ce12808907956ea31c25cce6]
#    to [e58bd5210e07853201e169e8f4f4fde9eb2dd308]
#
============================================================
--- contrib/monotone-mail-notify-standalone.lua	be58dde21383408beaafcda9dd51a86446f0838b
+++ contrib/monotone-mail-notify-standalone.lua	be58dde21383408beaafcda9dd51a86446f0838b
@@ -0,0 +1,175 @@
+-- Create a file "notify" next to "read-permissions" and ensure
+-- its contents are in the same format as "read-permissions",
+-- except that the values for allow and deny must be real email
+-- addresses.
+--
+-- Requires a "mail" executable
+--
+-- Copyright (c) 2007, Matthew Sackman (matthew at wellquite dot org)
+--                     LShift Ltd (http://www.lshift.net)
+--                     Thomas Keller <address@hidden>
+--                     Whoever wrote the function "get_netsync_read_permitted"
+-- License: GPLv2 or later
+
+_outfile = "/tmp/processor-out"
+_errfile = "/tmp/processor-err"
+_sender = "address@hidden"
+
+function get_notify_recipients(branch)
+   local emailfile = io.open(get_confdir() .. "/notify", "r")
+   if (emailfile == nil) then return nil end
+   local dat = emailfile:read("*a")
+   io.close(emailfile)
+   local res = parse_basic_io(dat)
+   if res == nil then
+      io.stderr:write("file notify cannot be parsed\n")
+      return nil
+   end
+
+   local results = {}
+   local denied = {}
+   local matches = false
+   local cont = false
+   for i, item in pairs(res)
+   do
+      -- legal names: pattern, allow, deny, continue
+      if item.name == "pattern" then
+         if matches and not cont then return table.toarray(results) end
+         matches = false
+         cont = false
+         for j, val in pairs(item.values) do
+            if globish_match(val, branch) then matches = true end
+         end
+      elseif item.name == "allow" then if matches then
+         for j, val in pairs(item.values) do
+            if nil == denied[val] then results[val] = val end
+         end
+      end elseif item.name == "deny" then if matches then
+         for j, val in pairs(item.values) do
+            denied[val] = val
+         end
+      end elseif item.name == "continue" then if matches then
+         cont = true
+         for j, val in pairs(item.values) do
+            if val == "false" or val == "no" then cont = false end
+         end
+      end elseif item.name ~= "comment" then
+         io.stderr:write("unknown symbol in notify: " .. item.name .. "\n")
+      end
+   end
+   return table.toarray(results)
+end
+
+function table.toarray(t)
+   local t1 = {}
+   for j, val in pairs(t) do
+      table.insert(t1, val)
+   end
+   return t1
+end
+
+_emails_to_send = {}
+
+function note_netsync_start (session_id, my_role, sync_type, remote_host, remote_keyname, includes, excludes)
+    _emails_to_send[session_id] = {}
+end
+
+function note_netsync_revision_received (new_id, revision, certs, session_id)
+    if _emails_to_send[session_id] == nil then
+        -- no session present
+        return
+    end
+
+    local rev_data = {["certs"] = {}, ["revision"] = new_id, ["manifest"] = revision}
+    for _,cert in ipairs(certs) do
+        if cert["name"] == "branch" then
+           rev_data["recipients"] = get_notify_recipients(cert["value"])
+        end
+	if cert["name"] ~= nil then
+           if nil == rev_data["certs"][cert["name"]] then
+	      rev_data["certs"][cert["name"]] = {}
+	   end
+           table.insert(rev_data["certs"][cert["name"]], cert["value"])
+        end
+    end
+    _emails_to_send[session_id][new_id] = rev_data
+end
+
+function note_netsync_end (session_id, status, bytes_in, bytes_out, certs_in, certs_out, revs_in, revs_out, keys_in, keys_out)
+    if _emails_to_send[session_id] == nil then
+        -- no session present
+        return
+    end
+
+    if status ~= 200 then
+        -- some error occured, no further processing takes place
+        return
+    end
+
+    if _emails_to_send[session_id] == "" then
+        -- we got no interesting revisions
+        return
+    end
+    
+    for rev_id,rev_data in pairs(_emails_to_send[session_id]) do
+       if # (rev_data["recipients"]) > 0 then
+	  file,filename = temp_file("notify")
+	  file:write(summarize_certs(rev_data))
+	  file:close()
+	  local subject = make_subject_line(rev_data)
+	  local from_header = "From: " .. rev_data["certs"]["author"][1]
+
+	  for j,addr in pairs(rev_data["recipients"]) do
+	     spawn_redirected(filename, _outfile, _errfile, "/usr/bin/mail", "-e", "-a", from_header, "-a", "Sender: " .. _sender, "-s", subject, addr)
+	  end
+
+	  os.remove(filename)
+       end
+    end
+     
+    _emails_to_send[session_id] = nil
+end
+
+function summarize_certs(t)
+   local str = "revision:            " .. t["revision"] .. "\n"
+   local changelog
+   for name,values in pairs(t["certs"]) do
+      local formatted_value = ""
+      for j,val in pairs(values) do
+	 formatted_value = formatted_value .. name .. ":"
+	 if string.match(val, "\n")
+	 then formatted_value = formatted_value .. "\n"
+	 else formatted_value = formatted_value .. (string.rep(" ", 20 - (# name))) end
+         formatted_value = formatted_value .. val .. "\n"
+      end
+      if name == "changelog" then changelog = formatted_value else str = str .. formatted_value end
+   end
+   if nil ~= changelog then str = str .. changelog end
+   return (str .. "manifest:\n" .. t["manifest"])
+end
+
+function make_subject_line(t)
+   local str = ""
+   for j,val in pairs(t["certs"]["branch"]) do
+      str = str .. val
+      if j < # t["certs"]["branch"] then str = str .. ", " end
+   end
+   return str .. ": " .. t["revision"]
+end
+
+function table.print(T)
+        local done = {}
+        local function tprint_r(T, prefix)
+                for k,v in pairs(T) do
+                        print(prefix..tostring(k),'=',tostring(v))
+                        if type(v) == 'table' then
+                                if not done[v] then
+                                        done[v] = true
+                                        tprint_r(v, prefix.."  ")
+                                end
+                        end
+                end
+        end
+        done[T] = true
+        tprint_r(T, "")
+end
============================================================
--- contrib/README	f333b7972b375370ce12808907956ea31c25cce6
+++ contrib/README	e58bd5210e07853201e169e8f4f4fde9eb2dd308
@@ -58,3 +58,9 @@ licenses.
   -- extra-commands.lua: Some simple lua user commands to automate common
      command sequences.  The lua code should be copied to a monotonerc file
      for use.
+
+  -- monotone-mail-notify-standalone.lua: a mail notification script which
+     runs without any other external dependencies than /usr/bin/mail and
+     offers an individual per-branch recipient configuration with a syntax
+     similar to the one found in ~/.monotone/read-permissions
+