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
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
|
# This file has parts from Buildbot and is modifyed by Gentoo Authors.
# Buildbot is free software: you can redistribute it and/or modify it
# under the terms of the GNU General Public License as published by the
# Free Software Foundation, version 2.
#
# This program is distributed in the hope that it will be useful, but WITHOUT
# ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
# FOR A PARTICULAR PURPOSE. See the GNU General Public License for more
# details.
#
# You should have received a copy of the GNU General Public License along with
# this program; if not, write to the Free Software Foundation, Inc., 51
# Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
#
# Copyright Buildbot Team Members
# Origins: buildbot.db.*
# Modifyed by Gentoo Authors.
# Copyright 2024 Gentoo Authors
from __future__ import annotations
from dataclasses import dataclass
from typing import TYPE_CHECKING
import uuid
import sqlalchemy as sa
from twisted.internet import defer
from buildbot.db import base
from buildbot.warnings import warn_deprecated
if TYPE_CHECKING:
import datetime
@dataclass
class ProjectsBuildsModel:
id : int
build_id : int
project_uuid : str
version_uuid : str
buildbot_build_id : int
bug_id : int
status : str
requested : bool
created_at : datetime.datetime | None
updated_at : datetime.datetime | None
deleted : bool
deleted_at: datetime.datetime | None
# For backward compatibility
def __getitem__(self, key: str):
warn_deprecated(
'4.1.0',
(
'VersionsConnectorComponent getVersionByName, '
'getBuildByNumber, getPrevSuccessfulBuild, '
'getBuildsForChange, getBuilds, '
'_getRecentBuilds, and _getBuild '
'no longer return Build as dictionnaries. '
'Usage of [] accessor is deprecated: please access the member directly'
),
)
if hasattr(self, key):
return getattr(self, key)
raise KeyError(key)
def _db2data_ProjectsBuilds(model: ProjectsBuildsModel):
if model is None:
return None
return {
'id' : model.id,
'build_id' : model.build_id,
'project_uuid' : model.project_uuid,
'version_uuid' : model.version_uuid,
'buildbot_build_id' : model.buildbot_build_id,
'bug_id' : model.bug_id,
'status' : model.status,
'requested' : model.requested,
'created_at' : model.created_at,
'updated_at' : model.updated_at,
'deleted' : model.deleted,
'deleted_at' : model.deleted_at
}
class BuildsConnectorComponent(base.DBConnectorComponent):
def addBuild(self, project_build_data):
def thd(conn):
# get the highest current number
tbl = self.db.model.projects_builds
r = conn.execute(
sa.select(sa.func.max(tbl.c.build_id)).where(tbl.c.project_uuid == project_build_data['project_uuid'])
)
number = r.scalar()
new_number = 1 if number is None else number + 1
insert_row = {
'project_uuid' : project_build_data['project_uuid'],
'version_uuid' : project_build_data['version_uuid'],
'status' : project_build_data['status'],
'requested' : project_build_data['requested'],
'created_at' : int(self.master.reactor.seconds()),
'buildbot_build_id' : 0,
'build_id' : new_number,
'bug_id' : 0,
}
try:
r = conn.execute(tbl.insert(), insert_row)
conn.commit()
except (sa.exc.IntegrityError, sa.exc.ProgrammingError):
conn.rollback()
return None, None
return r.inserted_primary_key[0], new_number
return self.db.pool.do(thd)
def setStatusBuilds(self, id, status):
def thd(conn):
tbl = self.db.model.projects_builds
q = tbl.update().where(tbl.c.id == id)
conn.execute(q.values(updated_at=int(self.master.reactor.seconds()), status=status))
return self.db.pool.do(thd)
def setBuildbotBuildIdBuilds(self, id, buildbot_build_id):
def thd(conn):
tbl = self.db.model.projects_builds
q = tbl.update().where(tbl.c.id == id)
conn.execute(q.values(updated_at=int(self.master.reactor.seconds()), buildbot_build_id=buildbot_build_id))
return self.db.pool.do(thd)
def setBugIdBuilds(self, id, bug_id):
def thd(conn):
tbl = self.db.model.projects_builds
q = tbl.update().where(tbl.c.id == id)
conn.execute(q.values(updated_at=int(self.master.reactor.seconds()), bug_id=bug_id))
return self.db.pool.do(thd)
def getBuildsByVersionUuid(self, uuid) -> defer.Deferred[list[ProjectsBuildsModel]]:
def thd(conn) -> list[ProjectsBuildsModel]:
tbl = self.db.model.projects_builds
q = tbl.select()
q = q.where(tbl.c.version_uuid == uuid)
res = conn.execute(q)
return list(self._model_from_row(row) for row in res.fetchall())
return self.db.pool.do(thd)
def removeBuild(self, id: int) -> defer.Deferred[None]:
def thd(conn) -> None:
tbl = self.db.model.projects_builds
q = tbl.delete().where(tbl.c.id == id)
res = conn.execute(q)
conn.commit()
res.close()
return self.db.pool.do(thd)
def _model_from_row(self, row):
return ProjectsBuildsModel(
id=row.id,
build_id=row.build_id,
project_uuid=row.project_uuid,
version_uuid=row.version_uuid,
buildbot_build_id=row.buildbot_build_id,
bug_id=row.bug_id,
status=row.status,
requested=row.requested,
created_at=row.created_at,
updated_at=row.updated_at,
deleted=row.deleted,
deleted_at=row.deleted_at
)
|
GitWeb