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
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
|
#!/usr/bin/python3
import atexit
import colorama
import fcntl
import io
import os
import pickle
import signal
import selectors
import subprocess
import sys
import sisyphus.checkenv
import sisyphus.revdepsolve
import sisyphus.syncdb
import sisyphus.watchdog
from colorama import Fore, Back, Style
colorama.init()
def set_nonblocking(fd):
flags = fcntl.fcntl(fd, fcntl.F_GETFL)
fcntl.fcntl(fd, fcntl.F_SETFL, flags | os.O_NONBLOCK)
def spinner_animation():
spinner = ['-', '\\', '|', '/']
sel = selectors.DefaultSelector()
sel.register(sys.stdin, selectors.EVENT_READ)
for _ in range(10):
for char in spinner:
sys.stdout.write('\b' + char)
sys.stdout.flush()
events = sel.select(timeout=0.1)
if events:
return
sys.stdout.write('\b')
def sigint_handler(signal, frame):
sys.exit(0)
signal.signal(signal.SIGINT, sigint_handler)
def start(depclean=False, gfx_ui=False):
args = ['--quiet', '--depclean']
if not sisyphus.checkenv.root() and depclean:
print(f"{Fore.RED}{Style.BRIGHT}\nRoot permissions are required to perform this action.\n{Style.RESET_ALL}")
sys.exit()
else:
if gfx_ui:
sisyphus.revdepsolve.start.__wrapped__(depclean=True)
else:
sisyphus.revdepsolve.start(depclean=True)
is_installed, is_needed, is_vague, rm_list = pickle.load(
open(os.path.join(sisyphus.getfs.p_mtd_dir, "sisyphus_pkgrevdeps.pickle"), "rb"))
if len(rm_list) == 0:
if gfx_ui:
print("\nThe system is clean; no orphaned packages found.\n")
else:
print(
f"{Fore.GREEN}{Style.BRIGHT}\nThe system is clean; no orphaned packages found.\n{Style.RESET_ALL}")
sys.exit()
else:
if gfx_ui:
p_exe = subprocess.Popen(
['emerge'] + args, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
# kill portage if the program dies or it's terminated by the user
atexit.register(sisyphus.watchdog.start, p_exe)
for p_out in io.TextIOWrapper(p_exe.stdout, encoding="utf-8"):
print(p_out.rstrip())
p_exe.wait()
sisyphus.syncdb.lcl_tbl()
else:
print(f"\n{Fore.GREEN}These are the orphaned packages that would be{Style.RESET_ALL} 'safely' {Fore.GREEN}unmerged, in order:{Style.RESET_ALL}\n")
print(
f"\n{Fore.MAGENTA}{', '.join(rm_list)}{Style.RESET_ALL}\n")
print(
f"\n{Fore.WHITE}{Style.BRIGHT}Total: {len(rm_list)} orphaned package(s){Style.RESET_ALL}\n")
while True:
user_input = input(
f"{Fore.WHITE}{Style.BRIGHT}Would you like to proceed?{Style.RESET_ALL} [{Fore.GREEN}{Style.BRIGHT}Yes{Style.RESET_ALL}/{Fore.RED}{Style.BRIGHT}No{Style.RESET_ALL}] ")
if user_input.lower() in ['yes', 'y', '']:
p_exe = subprocess.Popen(['emerge'] + args)
try:
set_nonblocking(sys.stdout.fileno())
spinner_animation()
sel = selectors.DefaultSelector()
sel.register(sys.stdin, selectors.EVENT_READ)
while True:
events = sel.select(timeout=0.1)
for key, mask in events:
if key.fileobj == sys.stdin:
line = sys.stdin.readline().strip()
if line.lower() == 'q':
sys.exit()
if p_exe.poll() is not None:
break
except KeyboardInterrupt:
p_exe.terminate()
try:
p_exe.wait(1)
except subprocess.TimeoutExpired:
p_exe.kill()
sys.exit()
finally:
p_exe.wait()
sisyphus.syncdb.lcl_tbl()
break
elif user_input.lower() in ['no', 'n']:
break
else:
print(
f"\nApologies, the response '{user_input}' was not recognized.\n")
|
