File: netsync-hooks_with_notes.lua

package info (click to toggle)
monotone 1.1-9
  • links: PTS, VCS
  • area: main
  • in suites: stretch
  • size: 20,984 kB
  • ctags: 8,622
  • sloc: cpp: 86,450; sh: 6,906; perl: 924; makefile: 813; python: 517; lisp: 379; sql: 118; exp: 91; ansic: 52
file content (95 lines) | stat: -rw-r--r-- 4,222 bytes parent folder | download | duplicates (5)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
logfile = nil

function note_netsync_start(session_id, my_role, sync_type,
                            remote_host, remote_key,
                            includes, excludes)
   logfile = io.open("testnotes-" .. my_role .. ".log","w")
   logfile:write(session_id .. " start ---------------------------------------------------\n")
   logfile:write(session_id .. " start: sync_type = " .. sync_type .. "\n")
   logfile:write(session_id .. " start: remote_host = " .. remote_host .. "\n")
   logfile:write(session_id .. " start: remote_keyname = " .. remote_key.given_name .. "\n")
   logfile:write(session_id .. " start: includes = " .. includes .. "\n")
   logfile:write(session_id .. " start: excludes = " .. excludes .. "\n")
end

function note_netsync_revision_received(new_id, revision, certs, session_id)
   logfile:write(session_id .. " revision: new_id    = " .. new_id .. "\n")
   logfile:write(session_id .. " revision: revision  = " .. revision .. "\n")
   for i, cert in pairs(certs)
   do
      logfile:write(session_id .. " revision: cert.name  = " .. cert.name .. "\n")
      logfile:write(session_id .. " revision: cert.value = " .. cert.value .. "\n")
      logfile:write(session_id .. " revision: cert.key   = " .. cert.key.given_name .. "\n")
   end
end

function note_netsync_revision_sent(new_id, revision, certs, session_id)
   logfile:write(session_id .. " sent revision: new_id    = " .. new_id .. "\n")
   logfile:write(session_id .. " sent revision: revision  = " .. revision .. "\n")
   for i, cert in pairs(certs)
   do
      logfile:write(session_id .. " sent revision: cert.name  = " .. cert.name .. "\n")
      logfile:write(session_id .. " sent revision: cert.value = " .. cert.value .. "\n")
      logfile:write(session_id .. " sent revision: cert.key   = " .. cert.key.given_name .. "\n")
   end
end

function note_netsync_cert_received(rev_id, key, name, value, session_id)
   logfile:write(session_id .. " cert: rev_id = " .. rev_id .. "\n")
   logfile:write(session_id .. " cert: name   = " .. name .. "\n")
   logfile:write(session_id .. " cert: value  = " .. value .. "\n")
   logfile:write(session_id .. " cert: key    = " .. key.given_name .. "\n")
end

function note_netsync_cert_sent(rev_id, key, name, value, session_id)
   logfile:write(session_id .. " sent cert: rev_id = " .. rev_id .. "\n")
   logfile:write(session_id .. " sent cert: name   = " .. name .. "\n")
   logfile:write(session_id .. " sent cert: value  = " .. value .. "\n")
   logfile:write(session_id .. " sent cert: key    = " .. key.given_name .. "\n")
end

function note_netsync_pubkey_received(key, session_id)
   logfile:write(session_id .. " pubkey: " .. key.given_name .. "\n")
end

function note_netsync_pubkey_sent(key, session_id)
   logfile:write(session_id .. " sent pubkey: " .. key.given_name .. "\n")
end

function note_netsync_end(session_id, status,
                          bytes_in, bytes_out,
                          certs_in, certs_out,
                          revs_in, revs_out,
                          keys_in, keys_out)
   logfile:write(session_id .. " end: status = " .. status .. "\n")
   logfile:write(session_id .. " end: bytes in/out = " .. bytes_in .. "/" .. bytes_out .. "\n")
   logfile:write(session_id .. " end: certs in/out = " .. certs_in .. "/" .. certs_out .. "\n")
   logfile:write(session_id .. " end: revs in/out = " .. revs_in .. "/" .. revs_out .. "\n")
   logfile:write(session_id .. " end: keys in/out = " .. keys_in .. "/" .. keys_out .. "\n")
   logfile:write(session_id .. " end -----------------------------------------------------\n")
   logfile:close()
end

do
   local old = get_netsync_read_permitted
   function get_netsync_read_permitted(pattern, identity)
      local permfile = io.open(get_confdir() .. "/read-permissions", "r")
      if (permfile == nil) then
	 return true
      end
      io.close(permfile)
      return old(pattern, identity)
   end
end

do
   local old = get_netsync_write_permitted
   function get_netsync_write_permitted(identity)
      local permfile = io.open(get_confdir() .. "/write-permissions", "r")
      if (permfile == nil) then
	 return true
      end
      io.close(permfile)
      return old(identity)
   end
end