/mandos/trunk : revision 711

3

#

4

# Mandos Monitor - Control and monitor the Mandos server

5

#

6

7

6

7

8

#

9

# This program is free software: you can redistribute it and/or modify

10

# it under the terms of the GNU General Public License as published by

26

from __future__ import (division, absolute_import, print_function,

27

unicode_literals)

28

29

try:

30

from future_builtins import *

31

except ImportError:

32

pass

29

from future_builtins import *

33

30

34

31

import sys

35

32

import argparse

42

39

43

40

import dbus

44

41

45

if sys.version_info.major == 2:

46

str = unicode

47

48

42

locale.setlocale(locale.LC_ALL, "")

49

43

50

44

tablewords = {

64

58

"ApprovalDelay": "Approval Delay",

65

59

"ApprovalDuration": "Approval Duration",

66

60

"Checker": "Checker",

67

"ExtendedTimeout": "Extended Timeout"

68

}

61

"ExtendedTimeout" : "Extended Timeout"

62

}

69

63

defaultkeywords = ("Name", "Enabled", "Timeout", "LastCheckedOK")

70

64

domain = "se.recompile"

71

65

busname = domain + ".Mandos"

72

66

server_path = "/"

73

67

server_interface = domain + ".Mandos"

74

68

client_interface = domain + ".Mandos.Client"

75

version = "1.6.9"

69

version = "1.6.6"

76

70

71

def timedelta_to_milliseconds(td):

72

"""Convert a datetime.timedelta object to milliseconds"""

73

return ((td.days * 24 * 60 * 60 * 1000)

74

+ (td.seconds * 1000)

75

+ (td.microseconds // 1000))

77

76

78

77

def milliseconds_to_string(ms):

79

78

td = datetime.timedelta(0, 0, 0, ms)

80

return ("{days}{hours:02}:{minutes:02}:{seconds:02}".format(

81

days = "{}T".format(td.days) if td.days else "",

82

hours = td.seconds // 3600,

83

minutes = (td.seconds % 3600) // 60,

84

seconds = td.seconds % 60))

79

return ("{days}{hours:02}:{minutes:02}:{seconds:02}"

80

.format(days = "{0}T".format(td.days) if td.days else "",

81

hours = td.seconds // 3600,

82

minutes = (td.seconds % 3600) // 60,

83

seconds = td.seconds % 60,

84

))

85

86

87

def rfc3339_duration_to_delta(duration):

111

# avoid excessive use of external libraries.

112

113

# New type for defining tokens, syntax, and semantics all-in-one

114

Token = collections.namedtuple("Token", (

115

"regexp", # To match token; if "value" is not None, must have

116

# a "group" containing digits

117

"value", # datetime.timedelta or None

118

"followers")) # Tokens valid after this token

114

Token = collections.namedtuple("Token",

115

("regexp", # To match token; if

116

# "value" is not None,

117

# must have a "group"

118

# containing digits

119

"value", # datetime.timedelta or

120

# None

121

"followers")) # Tokens valid after

122

# this token

119

123

# RFC 3339 "duration" tokens, syntax, and semantics; taken from

120

124

# the "duration" ABNF definition in RFC 3339, Appendix A.

121

125

token_end = Token(re.compile(r"$"), None, frozenset())

122

126

token_second = Token(re.compile(r"(\d+)S"),

123

127

datetime.timedelta(seconds=1),

124

frozenset((token_end, )))

128

frozenset((token_end,)))

125

129

token_minute = Token(re.compile(r"(\d+)M"),

126

130

datetime.timedelta(minutes=1),

127

131

frozenset((token_second, token_end)))

143

147

frozenset((token_month, token_end)))

144

148

token_week = Token(re.compile(r"(\d+)W"),

145

149

datetime.timedelta(weeks=1),

146

frozenset((token_end, )))

150

frozenset((token_end,)))

147

151

token_duration = Token(re.compile(r"P"), None,

148

152

frozenset((token_year, token_month,

149

153

token_day, token_time,

150

token_week)))

154

token_week))),

151

155

# Define starting values

152

156

value = datetime.timedelta() # Value so far

153

157

found_token = None

154

followers = frozenset((token_duration, )) # Following valid tokens

158

followers = frozenset(token_duration,) # Following valid tokens

155

159

s = duration # String left to parse

156

160

# Loop until end token is found

157

161

while found_token is not token_end:

174

178

break

175

179

else:

176

180

# No currently valid tokens were found

177

raise ValueError("Invalid RFC 3339 duration: {!r}"

178

.format(duration))

181

raise ValueError("Invalid RFC 3339 duration")

179

182

# End token found

180

183

return value

181

184

183

186

def string_to_delta(interval):

184

187

"""Parse a string and return a datetime.timedelta

185

188

186

>>> string_to_delta('7d')

189

>>> string_to_delta("7d")

187

190

datetime.timedelta(7)

188

>>> string_to_delta('60s')

191

>>> string_to_delta("60s")

189

192

datetime.timedelta(0, 60)

190

>>> string_to_delta('60m')

193

>>> string_to_delta("60m")

191

194

datetime.timedelta(0, 3600)

192

>>> string_to_delta('24h')

195

>>> string_to_delta("24h")

193

196

datetime.timedelta(1)

194

>>> string_to_delta('1w')

197

>>> string_to_delta("1w")

195

198

datetime.timedelta(7)

196

>>> string_to_delta('5m 30s')

199

>>> string_to_delta("5m 30s")

197

200

datetime.timedelta(0, 330)

198

201

"""

199

202

220

223

value += datetime.timedelta(0, 0, 0, int(num))

221

224

return value

222

225

223

224

226

def print_clients(clients, keywords):

225

227

def valuetostring(value, keyword):

226

228

if type(value) is dbus.Boolean:

228

230

if keyword in ("Timeout", "Interval", "ApprovalDelay",

229

231

"ApprovalDuration", "ExtendedTimeout"):

230

232

return milliseconds_to_string(value)

231

return str(value)

233

return unicode(value)

232

234

233

235

# Create format string to print table rows

234

236

format_string = " ".join("{{{key}:{width}}}".format(

235

width = max(len(tablewords[key]),

236

max(len(valuetostring(client[key], key))

237

for client in clients)),

238

key = key)

239

for key in keywords)

237

width = max(len(tablewords[key]),

238

max(len(valuetostring(client[key],

239

key))

240

for client in

241

clients)),

242

key = key) for key in keywords)

240

243

# Print header line

241

244

print(format_string.format(**tablewords))

242

245

for client in clients:

243

print(format_string.format(**{

244

key: valuetostring(client[key], key)

245

for key in keywords }))

246

print(format_string.format(**dict((key,

247

valuetostring(client[key],

248

key))

249

for key in keywords)))

247

250

248

251

def has_actions(options):

249

252

return any((options.enable,

265

268

options.approve,

266

269

options.deny))

267

270

268

269

271

def main():

270

272

parser = argparse.ArgumentParser()

271

273

parser.add_argument("--version", action="version",

272

version = "%(prog)s {}".format(version),

274

version = "%(prog)s {0}".format(version),

273

275

help="show version number and exit")

274

276

parser.add_argument("-a", "--all", action="store_true",

275

277

help="Select all clients")

308

310

parser.add_argument("--approval-duration",

309

311

help="Set duration of one client approval")

310

312

parser.add_argument("-H", "--host", help="Set host for client")

311

parser.add_argument("-s", "--secret",

312

type=argparse.FileType(mode="rb"),

313

parser.add_argument("-s", "--secret", type=file,

313

314

help="Set password blob (file) for client")

314

315

parser.add_argument("-A", "--approve", action="store_true",

315

316

help="Approve any current client request")

336

337

bus = dbus.SystemBus()

337

338

mandos_dbus_objc = bus.get_object(busname, server_path)

338

339

except dbus.exceptions.DBusException:

339

print("Could not connect to Mandos server", file=sys.stderr)

340

print("Could not connect to Mandos server",

341

file=sys.stderr)

340

342

sys.exit(1)

341

343

342

344

mandos_serv = dbus.Interface(mandos_dbus_objc,

363

365

clients={}

364

366

365

367

if options.all or not options.client:

366

clients = { bus.get_object(busname, path): properties

367

for path, properties in mandos_clients.items() }

368

clients = dict((bus.get_object(busname, path), properties)

369

for path, properties in

370

mandos_clients.iteritems())

368

371

else:

369

372

for name in options.client:

370

for path, client in mandos_clients.items():

373

for path, client in mandos_clients.iteritems():

371

374

if client["Name"] == name:

372

375

client_objc = bus.get_object(busname, path)

373

376

clients[client_objc] = client

374

377

break

375

378

else:

376

print("Client not found on server: {!r}"

379

print("Client not found on server: {0!r}"

377

380

.format(name), file=sys.stderr)

378

381

sys.exit(1)

379

382

380

383

if not has_actions(options) and clients:

381

384

if options.verbose:

382

keywords = ("Name", "Enabled", "Timeout", "LastCheckedOK",

383

"Created", "Interval", "Host", "Fingerprint",

384

"CheckerRunning", "LastEnabled",

385

"ApprovalPending", "ApprovedByDefault",

385

keywords = ("Name", "Enabled", "Timeout",

386

"LastCheckedOK", "Created", "Interval",

387

"Host", "Fingerprint", "CheckerRunning",

388

"LastEnabled", "ApprovalPending",

389

"ApprovedByDefault",

386

390

"LastApprovalRequest", "ApprovalDelay",

387

391

"ApprovalDuration", "Checker",

388

392

"ExtendedTimeout")

393

397

else:

394

398

# Process each client in the list by all selected options

395

399

for client in clients:

396

397

400

def set_client_prop(prop, value):

398

401

"""Set a Client D-Bus property"""

399

402

client.Set(client_interface, prop, value,

400

403

dbus_interface=dbus.PROPERTIES_IFACE)

401

402

404

def set_client_prop_ms(prop, value):

403

405

"""Set a Client D-Bus property, converted

404

406

from a string to milliseconds."""

405

407

set_client_prop(prop,

406

string_to_delta(value).total_seconds()

407

* 1000)

408

timedelta_to_milliseconds

409

(string_to_delta(value)))

409

410

if options.remove:

410

411

mandos_serv.RemoveClient(client.__dbus_object_path__)

411

412

if options.enable:

455

456

client.Approve(dbus.Boolean(False),

456

457

dbus_interface=client_interface)

457

458

459

if __name__ == "__main__":

460

main()