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 # enable zlib compression 78 compression = self.set_gzip_compression(session_id, True) 79 80 rc = self.do_generic_handler(cmd, session_id, compression = compression) 81 82 # disable compression 83 self.set_gzip_compression(session_id, False) 84 85 return rc

86

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

88 89 cmd = "%s %s %s" % ( 90 session_id, 91 'systemsrv:remove_queue_ids', 92 ' '.join([str(x) for x in queue_ids]), 93 ) 94 return self.do_generic_handler(cmd, session_id)

95

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

97 98 cmd = "%s %s %s" % ( 99 session_id, 100 'systemsrv:pause_queue', 101 do_pause, 102 ) 103 return self.do_generic_handler(cmd, session_id)

104

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

106 107 cmd = "%s %s %s" % ( 108 session_id, 109 'systemsrv:kill_processing_queue_id', 110 queue_id, 111 ) 112 return self.do_generic_handler(cmd, session_id)

113

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

115 116 cmd = "%s %s %d %d" % ( 117 session_id, 118 'systemsrv:swap_items_in_queue', 119 queue_id1, 120 queue_id2, 121 ) 122 return self.do_generic_handler(cmd, session_id)

123

124 - def get_pinboard_data(self, session_id):

125 cmd = "%s %s" % ( 126 session_id, 127 'systemsrv:get_pinboard_data', 128 ) 129 return self.do_generic_handler(cmd, session_id)

130

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

132 133 mydict = { 134 'note': note, 135 'extended_text': extended_text, 136 } 137 xml_string = self.entropyTools.xml_from_dict(mydict) 138 139 cmd = "%s %s %s" % ( 140 session_id, 141 'systemsrv:add_to_pinboard', 142 xml_string, 143 ) 144 return self.do_generic_handler(cmd, session_id)

145

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

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

154

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

156 cmd = "%s %s %s %s" % ( 157 session_id, 158 'systemsrv:set_pinboard_items_done', 159 ' '.join([str(x) for x in pinboard_ids]), 160 status, 161 ) 162 return self.do_generic_handler(cmd, session_id)

163

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

165 cmd = "%s %s %s %s %s" % ( 166 session_id, 167 'systemsrv:write_to_running_command_pipe', 168 queue_id, 169 write_to_stdout, 170 txt, 171 ) 172 return self.do_generic_handler(cmd, session_id)

175 176 import entropy.dump as dumpTools 177

178 - def sync_spm(self, session_id):

179 180 cmd = "%s %s" % ( 181 session_id, 182 'srvrepo:sync_spm', 183 ) 184 return self.do_generic_handler(cmd, session_id)

185

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

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

225

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

227 228 s_pretend = "0" 229 s_verbose = "0" 230 s_nocolor = "0" 231 if pretend: s_pretend = "1" 232 if verbose: s_verbose = "1" 233 if nocolor: s_nocolor = "1" 234 mydict = { 235 'atoms': ' '.join(atoms), 236 'pretend': s_pretend, 237 'verbose': s_verbose, 238 'nocolor': s_nocolor, 239 } 240 xml_string = self.entropyTools.xml_from_dict(mydict) 241 242 cmd = "%s %s %s" % ( 243 session_id, 244 'srvrepo:spm_remove_atoms', 245 xml_string, 246 ) 247 return self.do_generic_handler(cmd, session_id)

248

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

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

257

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

259 260 cmd = "%s %s %s" % ( 261 session_id, 262 'srvrepo:get_spm_categories_installed', 263 ' '.join(categories), 264 ) 265 return self.do_generic_handler(cmd, session_id)

266

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

268 269 mydict = { 270 'atoms': ' '.join(atoms), 271 'useflags': ' '.join(useflags), 272 } 273 xml_string = self.entropyTools.xml_from_dict(mydict) 274 275 cmd = "%s %s %s" % ( 276 session_id, 277 'srvrepo:enable_uses_for_atoms', 278 xml_string, 279 ) 280 return self.do_generic_handler(cmd, session_id)

281

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

283 284 mydict = { 285 'atoms': ' '.join(atoms), 286 'useflags': ' '.join(useflags), 287 } 288 xml_string = self.entropyTools.xml_from_dict(mydict) 289 290 cmd = "%s %s %s" % ( 291 session_id, 292 'srvrepo:disable_uses_for_atoms', 293 xml_string, 294 ) 295 return self.do_generic_handler(cmd, session_id)

296

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

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

305

306 - def run_spm_info(self, session_id):

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

313

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

315 316 cmd = "%s %s %s" % ( 317 session_id, 318 'srvrepo:run_custom_shell_command', 319 command, 320 ) 321 return self.do_generic_handler(cmd, session_id)

322

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

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

331

332 - def get_available_repositories(self, session_id):

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

339

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

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

348

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

350 351 cmd = "%s %s %s" % ( 352 session_id, 353 'srvrepo:get_available_entropy_packages', 354 repoid, 355 ) 356 return self.do_generic_handler(cmd, session_id)

357

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

359 360 cmd = "%s %s %d %s" % ( 361 session_id, 362 'srvrepo:get_entropy_idpackage_information', 363 idpackage, 364 repoid, 365 ) 366 return self.do_generic_handler(cmd, session_id)

367

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

369 cmd = "%s %s %s" % ( 370 session_id, 371 'srvrepo:remove_entropy_packages', 372 ','.join(["%s:%s" % (str(x[0]), str(x[1]),) for x in matched_atoms]), # 1:repoid,2:repoid 373 ) 374 return self.do_generic_handler(cmd, session_id)

375

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

377 378 cmd = "%s %s %s %s %s" % ( 379 session_id, 380 'srvrepo:search_entropy_packages', 381 repoid, 382 search_type, 383 search_string, 384 ) 385 return self.do_generic_handler(cmd, session_id)

386

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

388 389 cmd = "%s %s %s %s %s %s" % ( 390 session_id, 391 'srvrepo:move_entropy_packages_to_repository', 392 from_repo, 393 to_repo, 394 do_copy, 395 ' '.join([str(x) for x in idpackages]), 396 ) 397 return self.do_generic_handler(cmd, session_id)

398

399 - def scan_entropy_packages_database_changes(self, session_id):

400 401 cmd = "%s %s" % ( 402 session_id, 403 'srvrepo:scan_entropy_packages_database_changes', 404 ) 405 return self.do_generic_handler(cmd, session_id)

406

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

408 409 cmd = "%s %s %s %s %s" % ( 410 session_id, 411 'srvrepo:run_entropy_database_updates', 412 ','.join(["%s:%s:%s" % (str(x[0]), str(x[1]), str(x[2]),) for x in to_add]), 413 ','.join(["%s:%s" % (str(x[0]), str(x[1]),) for x in to_remove]), 414 ','.join(["%s:%s" % (str(x[0]), str(x[1]),) for x in to_inject]), 415 ) 416 return self.do_generic_handler(cmd, session_id)

417

418 - def run_entropy_dependency_test(self, session_id):

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

425

426 - def run_entropy_library_test(self, session_id):

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

433

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

435 436 cmd = "%s %s %s" % ( 437 session_id, 438 'srvrepo:run_entropy_treeupdates', 439 repoid, 440 ) 441 return self.do_generic_handler(cmd, session_id)

442

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

444 445 cmd = "%s %s %s" % ( 446 session_id, 447 'srvrepo:scan_entropy_mirror_updates', 448 ' '.join(repositories), 449 ) 450 return self.do_generic_handler(cmd, session_id)

451

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

453 454 serialized_string = self.dumpTools.serialize_string(repository_data) 455 cmd = "%s %s %s" % ( 456 session_id, 457 'srvrepo:run_entropy_mirror_updates', 458 serialized_string, 459 ) 460 return self.do_generic_handler(cmd, session_id)

461

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

463 464 cmd = "%s %s %s %s" % ( 465 session_id, 466 'srvrepo:run_entropy_checksum_test', 467 repoid, 468 mode, 469 ) 470 return self.do_generic_handler(cmd, session_id)

471

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

473 474 cmd = "%s %s %s" % ( 475 session_id, 476 'srvrepo:get_notice_board', 477 repoid, 478 ) 479 return self.do_generic_handler(cmd, session_id)

480

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

482 483 cmd = "%s %s %s %s" % ( 484 session_id, 485 'srvrepo:remove_notice_board_entries', 486 repoid, 487 ' '.join([str(x) for x in entry_ids]), 488 ) 489 return self.do_generic_handler(cmd, session_id)

490

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

492 493 mydict = { 494 'repoid': repoid, 495 'title': title, 496 'notice_text': notice_text, 497 'link': link, 498 } 499 xml_string = self.entropyTools.xml_from_dict(mydict) 500 501 cmd = "%s %s %s" % ( 502 session_id, 503 'srvrepo:add_notice_board_entry', 504 xml_string, 505 ) 506 return self.do_generic_handler(cmd, session_id)

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