entropy.client.services.system.commands

17 18 import entropy.dump as dumpTools

19 - def __init__(self, *args, **kwargs):

20 Base.__init__(self, *args, **kwargs)

21

22 - def service_login(self, username, password, session_id):

23 24 cmd = "%s %s %s %s %s" % ( 25 session_id, 26 'login', 27 username, 28 'plain', 29 password, 30 ) 31 return self.do_generic_handler(cmd, session_id)

32

33 - def get_queue(self, session_id, extended):

34 35 cmd = "%s %s %s" % ( 36 session_id, 37 'systemsrv:get_queue', 38 extended, 39 ) 40 return self.do_generic_handler(cmd, session_id)

41

42 - def get_queue_item_by_id(self, session_id, queue_id):

43 44 cmd = "%s %s %d" % ( 45 session_id, 46 'systemsrv:get_queue_item_by_id', 47 queue_id, 48 ) 49 return self.do_generic_handler(cmd, session_id)

50

51 - def get_queue_id_stdout(self, session_id, queue_id, last_bytes):

52 53 cmd = "%s %s %d %d" % ( 54 session_id, 55 'systemsrv:get_queue_id_stdout', 56 queue_id, 57 last_bytes, 58 ) 59 60 # enable zlib compression 61 compression = self.set_gzip_compression(session_id, True) 62 63 rc = self.do_generic_handler(cmd, session_id, compression = compression) 64 65 # disable compression 66 self.set_gzip_compression(session_id, False) 67 68 return rc

69

70 - def get_queue_id_result(self, session_id, queue_id):

71 72 cmd = "%s %s %d" % ( 73 session_id, 74 'systemsrv:get_queue_id_result', 75 queue_id, 76 ) 77 return self.do_generic_handler(cmd, session_id)

78

79 - def remove_queue_ids(self, session_id, queue_ids):

80 81 cmd = "%s %s %s" % ( 82 session_id, 83 'systemsrv:remove_queue_ids', 84 ' '.join([str(x) for x in queue_ids]), 85 ) 86 return self.do_generic_handler(cmd, session_id)

87

88 - def pause_queue(self, session_id, do_pause):

89 90 cmd = "%s %s %s" % ( 91 session_id, 92 'systemsrv:pause_queue', 93 do_pause, 94 ) 95 return self.do_generic_handler(cmd, session_id)

96

97 - def kill_processing_queue_id(self, session_id, queue_id):

98 99 cmd = "%s %s %s" % ( 100 session_id, 101 'systemsrv:kill_processing_queue_id', 102 queue_id, 103 ) 104 return self.do_generic_handler(cmd, session_id)

105

106 - def swap_items_in_queue(self, session_id, queue_id1, queue_id2):

107 108 cmd = "%s %s %d %d" % ( 109 session_id, 110 'systemsrv:swap_items_in_queue', 111 queue_id1, 112 queue_id2, 113 ) 114 return self.do_generic_handler(cmd, session_id)

115

116 - def get_pinboard_data(self, session_id):

117 cmd = "%s %s" % ( 118 session_id, 119 'systemsrv:get_pinboard_data', 120 ) 121 return self.do_generic_handler(cmd, session_id)

122

123 - def add_to_pinboard(self, session_id, note, extended_text):

124 125 mydict = { 126 'note': note, 127 'extended_text': extended_text, 128 } 129 xml_string = self.entropyTools.xml_from_dict(mydict) 130 131 cmd = "%s %s %s" % ( 132 session_id, 133 'systemsrv:add_to_pinboard', 134 xml_string, 135 ) 136 return self.do_generic_handler(cmd, session_id)

137

138 - def remove_from_pinboard(self, session_id, pinboard_ids):

139 140 cmd = "%s %s %s" % ( 141 session_id, 142 'systemsrv:remove_from_pinboard', 143 ' '.join([str(x) for x in pinboard_ids]), 144 ) 145 return self.do_generic_handler(cmd, session_id)

146

147 - def set_pinboard_items_done(self, session_id, pinboard_ids, status):

148 cmd = "%s %s %s %s" % ( 149 session_id, 150 'systemsrv:set_pinboard_items_done', 151 ' '.join([str(x) for x in pinboard_ids]), 152 status, 153 ) 154 return self.do_generic_handler(cmd, session_id)

155

156 - def write_to_running_command_pipe(self, session_id, queue_id, write_to_stdout, txt):

157 cmd = "%s %s %s %s %s" % ( 158 session_id, 159 'systemsrv:write_to_running_command_pipe', 160 queue_id, 161 write_to_stdout, 162 txt, 163 ) 164 return self.do_generic_handler(cmd, session_id)

167 168 import entropy.dump as dumpTools 169

170 - def sync_spm(self, session_id):

171 172 cmd = "%s %s" % ( 173 session_id, 174 'srvrepo:sync_spm', 175 ) 176 return self.do_generic_handler(cmd, session_id)

177

178 - def compile_atoms(self, session_id, atoms, pretend = False, oneshot = False, 179 verbose = False, nocolor = True, fetchonly = False, buildonly = False, 180 nodeps = False, custom_use = '', ldflags = '', cflags = ''):

181 182 s_pretend = "0" 183 s_oneshot = "0" 184 s_verbose = "0" 185 s_nocolor = "0" 186 s_fetchonly = "0" 187 s_buildonly = "0" 188 s_nodeps = "0" 189 if pretend: s_pretend = "1" 190 if oneshot: s_oneshot = "1" 191 if verbose: s_verbose = "1" 192 if nocolor: s_nocolor = "1" 193 if fetchonly: s_fetchonly = "1" 194 if buildonly: s_buildonly = "1" 195 if nodeps: s_nodeps = "1" 196 mydict = { 197 'atoms': ' '.join(atoms), 198 'pretend': s_pretend, 199 'oneshot': s_oneshot, 200 'verbose': s_verbose, 201 'nocolor': s_nocolor, 202 'fetchonly': s_fetchonly, 203 'buildonly': s_buildonly, 204 'nodeps': s_nodeps, 205 'custom_use': custom_use, 206 'ldflags': ldflags, 207 'cflags': cflags, 208 } 209 xml_string = self.entropyTools.xml_from_dict(mydict) 210 211 cmd = "%s %s %s" % ( 212 session_id, 213 'srvrepo:compile_atoms', 214 xml_string, 215 ) 216 return self.do_generic_handler(cmd, session_id)

217

218 - def spm_remove_atoms(self, session_id, atoms, pretend = False, verbose = False, nocolor = True):

219 220 s_pretend = "0" 221 s_verbose = "0" 222 s_nocolor = "0" 223 if pretend: s_pretend = "1" 224 if verbose: s_verbose = "1" 225 if nocolor: s_nocolor = "1" 226 mydict = { 227 'atoms': ' '.join(atoms), 228 'pretend': s_pretend, 229 'verbose': s_verbose, 230 'nocolor': s_nocolor, 231 } 232 xml_string = self.entropyTools.xml_from_dict(mydict) 233 234 cmd = "%s %s %s" % ( 235 session_id, 236 'srvrepo:spm_remove_atoms', 237 xml_string, 238 ) 239 return self.do_generic_handler(cmd, session_id)

240

241 - def get_spm_categories_updates(self, session_id, categories):

242 243 cmd = "%s %s %s" % ( 244 session_id, 245 'srvrepo:get_spm_categories_updates', 246 ' '.join(categories), 247 ) 248 return self.do_generic_handler(cmd, session_id)

249

250 - def get_spm_categories_installed(self, session_id, categories):

251 252 cmd = "%s %s %s" % ( 253 session_id, 254 'srvrepo:get_spm_categories_installed', 255 ' '.join(categories), 256 ) 257 return self.do_generic_handler(cmd, session_id)

258

259 - def enable_uses_for_atoms(self, session_id, atoms, useflags):

260 261 mydict = { 262 'atoms': ' '.join(atoms), 263 'useflags': ' '.join(useflags), 264 } 265 xml_string = self.entropyTools.xml_from_dict(mydict) 266 267 cmd = "%s %s %s" % ( 268 session_id, 269 'srvrepo:enable_uses_for_atoms', 270 xml_string, 271 ) 272 return self.do_generic_handler(cmd, session_id)

273

274 - def disable_uses_for_atoms(self, session_id, atoms, useflags):

275 276 mydict = { 277 'atoms': ' '.join(atoms), 278 'useflags': ' '.join(useflags), 279 } 280 xml_string = self.entropyTools.xml_from_dict(mydict) 281 282 cmd = "%s %s %s" % ( 283 session_id, 284 'srvrepo:disable_uses_for_atoms', 285 xml_string, 286 ) 287 return self.do_generic_handler(cmd, session_id)

288

289 - def get_spm_atoms_info(self, session_id, atoms):

290 291 cmd = "%s %s %s" % ( 292 session_id, 293 'srvrepo:get_spm_atoms_info', 294 ' '.join(atoms), 295 ) 296 return self.do_generic_handler(cmd, session_id)

297

298 - def run_spm_info(self, session_id):

299 300 cmd = "%s %s" % ( 301 session_id, 302 'srvrepo:run_spm_info', 303 ) 304 return self.do_generic_handler(cmd, session_id)

305

306 - def run_custom_shell_command(self, session_id, command):

307 308 cmd = "%s %s %s" % ( 309 session_id, 310 'srvrepo:run_custom_shell_command', 311 command, 312 ) 313 return self.do_generic_handler(cmd, session_id)

314

315 - def get_spm_glsa_data(self, session_id, list_type):

316 317 cmd = "%s %s %s" % ( 318 session_id, 319 'srvrepo:get_spm_glsa_data', 320 list_type, 321 ) 322 return self.do_generic_handler(cmd, session_id)

323

324 - def get_available_repositories(self, session_id):

325 326 cmd = "%s %s" % ( 327 session_id, 328 'srvrepo:get_available_repositories', 329 ) 330 return self.do_generic_handler(cmd, session_id)

331

332 - def set_default_repository(self, session_id, repoid):

333 334 cmd = "%s %s %s" % ( 335 session_id, 336 'srvrepo:set_default_repository', 337 repoid, 338 ) 339 return self.do_generic_handler(cmd, session_id)

340

341 - def get_available_entropy_packages(self, session_id, repoid):

342 343 cmd = "%s %s %s" % ( 344 session_id, 345 'srvrepo:get_available_entropy_packages', 346 repoid, 347 ) 348 return self.do_generic_handler(cmd, session_id)

349

350 - def get_entropy_idpackage_information(self, session_id, idpackage, repoid):

351 352 cmd = "%s %s %d %s" % ( 353 session_id, 354 'srvrepo:get_entropy_idpackage_information', 355 idpackage, 356 repoid, 357 ) 358 return self.do_generic_handler(cmd, session_id)

359

360 - def remove_entropy_packages(self, session_id, matched_atoms):

361 cmd = "%s %s %s" % ( 362 session_id, 363 'srvrepo:remove_entropy_packages', 364 ','.join(["%s:%s" % (str(x[0]),str(x[1]),) for x in matched_atoms]), # 1:repoid,2:repoid 365 ) 366 return self.do_generic_handler(cmd, session_id)

367

368 - def search_entropy_packages(self, session_id, search_type, search_string, repoid):

369 370 cmd = "%s %s %s %s %s" % ( 371 session_id, 372 'srvrepo:search_entropy_packages', 373 repoid, 374 search_type, 375 search_string, 376 ) 377 return self.do_generic_handler(cmd, session_id)

378

379 - def move_entropy_packages_to_repository(self, session_id, idpackages, from_repo, to_repo, do_copy):

380 381 cmd = "%s %s %s %s %s %s" % ( 382 session_id, 383 'srvrepo:move_entropy_packages_to_repository', 384 from_repo, 385 to_repo, 386 do_copy, 387 ' '.join([str(x) for x in idpackages]), 388 ) 389 return self.do_generic_handler(cmd, session_id)

390

391 - def scan_entropy_packages_database_changes(self, session_id):

392 393 cmd = "%s %s" % ( 394 session_id, 395 'srvrepo:scan_entropy_packages_database_changes', 396 ) 397 return self.do_generic_handler(cmd, session_id)

398

399 - def run_entropy_database_updates(self, session_id, to_add, to_remove, to_inject):

400 401 cmd = "%s %s %s %s %s" % ( 402 session_id, 403 'srvrepo:run_entropy_database_updates', 404 ','.join(["%s:%s:%s" % (str(x[0]),str(x[1]),str(x[2]),) for x in to_add]), 405 ','.join(["%s:%s" % (str(x[0]),str(x[1]),) for x in to_remove]), 406 ','.join(["%s:%s" % (str(x[0]),str(x[1]),) for x in to_inject]), 407 ) 408 return self.do_generic_handler(cmd, session_id)

409

410 - def run_entropy_dependency_test(self, session_id):

411 412 cmd = "%s %s" % ( 413 session_id, 414 'srvrepo:run_entropy_dependency_test', 415 ) 416 return self.do_generic_handler(cmd, session_id)

417

418 - def run_entropy_library_test(self, session_id):

419 420 cmd = "%s %s" % ( 421 session_id, 422 'srvrepo:run_entropy_library_test', 423 ) 424 return self.do_generic_handler(cmd, session_id)

425

426 - def run_entropy_treeupdates(self, session_id, repoid):

427 428 cmd = "%s %s %s" % ( 429 session_id, 430 'srvrepo:run_entropy_treeupdates', 431 repoid, 432 ) 433 return self.do_generic_handler(cmd, session_id)

434

435 - def scan_entropy_mirror_updates(self, session_id, repositories):

436 437 cmd = "%s %s %s" % ( 438 session_id, 439 'srvrepo:scan_entropy_mirror_updates', 440 ' '.join(repositories), 441 ) 442 return self.do_generic_handler(cmd, session_id)

443

444 - def run_entropy_mirror_updates(self, session_id, repository_data):

445 446 serialized_string = self.dumpTools.serialize_string(repository_data) 447 cmd = "%s %s %s" % ( 448 session_id, 449 'srvrepo:run_entropy_mirror_updates', 450 serialized_string, 451 ) 452 return self.do_generic_handler(cmd, session_id)

453

454 - def run_entropy_checksum_test(self, session_id, repoid, mode):

455 456 cmd = "%s %s %s %s" % ( 457 session_id, 458 'srvrepo:run_entropy_checksum_test', 459 repoid, 460 mode, 461 ) 462 return self.do_generic_handler(cmd, session_id)

463

464 - def get_notice_board(self, session_id, repoid):

465 466 cmd = "%s %s %s" % ( 467 session_id, 468 'srvrepo:get_notice_board', 469 repoid, 470 ) 471 return self.do_generic_handler(cmd, session_id)

472

473 - def remove_notice_board_entries(self, session_id, repoid, entry_ids):

474 475 cmd = "%s %s %s %s" % ( 476 session_id, 477 'srvrepo:remove_notice_board_entries', 478 repoid, 479 ' '.join([str(x) for x in entry_ids]), 480 ) 481 return self.do_generic_handler(cmd, session_id)

482

483 - def add_notice_board_entry(self, session_id, repoid, title, notice_text, link):

484 485 mydict = { 486 'repoid': repoid, 487 'title': title, 488 'notice_text': notice_text, 489 'link': link, 490 } 491 xml_string = self.entropyTools.xml_from_dict(mydict) 492 493 cmd = "%s %s %s" % ( 494 session_id, 495 'srvrepo:add_notice_board_entry', 496 xml_string, 497 ) 498 return self.do_generic_handler(cmd, session_id)

Source Code for Module entropy.client.services.system.commands