Coverage for dak/control

1#! /usr/bin/env python3

3""" Manipulate suite tags """

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

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

8# the Free Software Foundation; either version 2 of the License, or

9# (at your option) any later version.

11# This program is distributed in the hope that it will be useful,

12# but WITHOUT ANY WARRANTY; without even the implied warranty of

13# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

14# GNU General Public License for more details.

16# You should have received a copy of the GNU General Public License

17# along with this program; if not, write to the Free Software

18# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA

20#######################################################################################

22# 8to6Guy: "Wow, Bob, You look rough!"

23# BTAF: "Mbblpmn..."

24# BTAF <.oO>: "You moron! This is what you get for staying up all night drinking vodka and salad dressing!"

25# BTAF <.oO>: "This coffee I.V. drip is barely even keeping me awake! I need something with more kick! But what?"

26# BTAF: "OMIGOD! I OVERDOSED ON HEROIN"

27# CoWorker#n: "Give him air!!"

28# CoWorker#n+1: "We need a syringe full of adrenaline!"

29# CoWorker#n+2: "Stab him in the heart!"

30# BTAF: "*YES!*"

31# CoWorker#n+3: "Bob's been overdosing quite a bit lately..."

32# CoWorker#n+4: "Third time this week."

34# -- http://www.angryflower.com/8to6.gif

36#######################################################################################

38# Adds or removes packages from a suite. Takes the list of files

39# either from stdin or as a command line argument. Special action

40# "set", will reset the suite (!) and add all packages from scratch.

42#######################################################################################

44import sys

45import apt_pkg

46import functools

47import os

49from daklib.archive import ArchiveTransaction

50from daklib.config import Config

51from daklib.dbconn import *

52from daklib import daklog

53from daklib import utils

54from daklib.queue import get_suite_version_by_package, get_suite_version_by_source

56#######################################################################################

58Logger = None

60################################################################################

63def usage(exit_code=0):

64 print("""Usage: dak control-suite [OPTIONS] [FILE]

65Display or alter the contents of a suite using FILE(s), or stdin.

67 -a, --add=SUITE add to SUITE

68 -h, --help show this help and exit

69 -l, --list=SUITE list the contents of SUITE

70 -r, --remove=SUITE remove from SUITE

71 -s, --set=SUITE set SUITE

72 -b, --britney generate changelog entry for britney runs""")

74 sys.exit(exit_code)

76#######################################################################################

79def get_pkg(package, version, architecture, session):

80 if architecture == 'source':

81 q = session.query(DBSource).filter_by(source=package, version=version) \

82 .join(DBSource.poolfile)

83 else:

84 q = session.query(DBBinary).filter_by(package=package, version=version) \

85 .join(DBBinary.architecture).filter(Architecture.arch_string.in_([architecture, 'all'])) \

86 .join(DBBinary.poolfile)

88 pkg = q.first()

89 if pkg is None: 89 ↛ 90line 89 didn't jump to line 90, because the condition on line 89 was never true

90 utils.warn("Could not find {0}_{1}_{2}.".format(package, version, architecture))

91 return pkg

93#######################################################################################

96def britney_changelog(packages, suite, session):

98 old = {}

99 current = {}

100 Cnf = utils.get_conf()

101

102 try:

103 q = session.execute("SELECT changelog FROM suite WHERE id = :suiteid",

104 {'suiteid': suite.suite_id})

105 brit_file = q.fetchone()[0]

106 except:

107 brit_file = None

108

109 if brit_file: 109 ↛ 112line 109 didn't jump to line 112, because the condition on line 109 was never false

110 brit_file = os.path.join(Cnf['Dir::Root'], brit_file)

111 else:

112 return

113

114 q = session.execute("""SELECT s.source, s.version, sa.id

115 FROM source s, src_associations sa

116 WHERE sa.suite = :suiteid

117 AND sa.source = s.id""", {'suiteid': suite.suite_id})

118

119 for p in q.fetchall():

120 current[p[0]] = p[1]

121 for p in packages.keys(): 121 ↛ 122line 121 didn't jump to line 122, because the loop on line 121 never started

122 if p[2] == "source":

123 old[p[0]] = p[1]

124

125 new = {}

126 for p in current.keys():

127 if p in old: 127 ↛ 128line 127 didn't jump to line 128, because the condition on line 127 was never true

128 if apt_pkg.version_compare(current[p], old[p]) > 0:

129 new[p] = [current[p], old[p]]

130 else:

131 new[p] = [current[p], None]

132

133 params = {}

134 query = "SELECT source, changelog FROM changelogs WHERE"

135 for n, p in enumerate(new.keys()):

136 query += f" source = :source_{n} AND (:version1_{n} IS NULL OR version > :version1_{n}) AND version <= :version2_{n}"

137 query += " AND architecture LIKE '%source%' AND distribution in \

138 ('unstable', 'experimental', 'testing-proposed-updates') OR"

139 params[f'source_{n}'] = p

140 params[f'version1_{n}'] = new[p][1]

141 params[f'version2_{n}'] = new[p][0]

142 query += " False ORDER BY source, version DESC"

143 q = session.execute(query, params)

144

145 pu = None

146 with open(brit_file, 'w') as brit:

147

148 for u in q:

149 if pu and pu != u[0]: 149 ↛ 150line 149 didn't jump to line 150, because the condition on line 149 was never true

150 brit.write("\n")

151 brit.write("%s\n" % u[1])

152 pu = u[0]

153 if q.rowcount: 153 ↛ 156line 153 didn't jump to line 156, because the condition on line 153 was never false

154 brit.write("\n\n\n")

155

156 for p in list(set(old.keys()).difference(current.keys())): 156 ↛ 157line 156 didn't jump to line 157, because the loop on line 156 never started

157 brit.write("REMOVED: %s %s\n" % (p, old[p]))

158

159 brit.flush()

160

161

162#######################################################################################

163

164

165class VersionCheck:

166 def __init__(self, target_suite: str, force: bool, session):

167 self.target_suite = target_suite

168 self.force = force

169 self.session = session

170

171 self.must_be_newer_than = [vc.reference.suite_name for vc in get_version_checks(target_suite, "MustBeNewerThan", session)]

172 self.must_be_older_than = [vc.reference.suite_name for vc in get_version_checks(target_suite, "MustBeOlderThan", session)]

173

174 # Must be newer than an existing version in target_suite

175 if target_suite not in self.must_be_newer_than: 175 ↛ exitline 175 didn't return from function '__init__', because the condition on line 175 was never false

176 self.must_be_newer_than.append(target_suite)

177

178 def __call__(self, package: str, architecture: str, new_version: str):

179 if architecture == "source":

180 suite_version_list = get_suite_version_by_source(package, self.session)

181 else:

182 suite_version_list = get_suite_version_by_package(package, architecture, self.session)

183

184 violations = False

185

186 for suite, version in suite_version_list:

187 cmp = apt_pkg.version_compare(new_version, version)

188 # for control-suite we allow equal version (for uploads, we don't)

189 if suite in self.must_be_newer_than and cmp < 0:

190 utils.warn("%s (%s): version check violated: %s targeted at %s is *not* newer than %s in %s" % (package, architecture, new_version, self.target_suite, version, suite))

191 violations = True

192 if suite in self.must_be_older_than and cmp > 0: 192 ↛ 193line 192 didn't jump to line 193, because the condition on line 192 was never true

193 utils.warn("%s (%s): version check violated: %s targeted at %s is *not* older than %s in %s" % (package, architecture, new_version, self.target_suite, version, suite))