|
19 | 19 | Status = Literal["done", "false"] |
20 | 20 |
|
21 | 21 |
|
22 | | -async def _remove_bug_err_id(db: Connection, error_id: int, status: Status) -> int: |
23 | | - # find source |
24 | | - source_id = None |
25 | | - sql = "SELECT uuid,source_id,class FROM markers WHERE uuid_to_bigint(uuid) = $1" |
26 | | - for res in await db.fetch(sql, error_id): |
27 | | - uuid = res["uuid"] |
28 | | - source_id = res["source_id"] |
29 | | - class_id = res["class"] |
30 | | - |
31 | | - if not source_id: |
32 | | - return -1 |
33 | | - |
34 | | - async with db.transaction(): |
35 | | - await db.execute("DELETE FROM markers_status WHERE uuid=$1", uuid) |
36 | | - |
37 | | - await db.execute( |
38 | | - """INSERT INTO markers_status |
39 | | - (source_id,item,class,elems,date,status,lat,lon,subtitle,uuid) |
40 | | - SELECT source_id,item,class,elems,NOW(),$1, |
41 | | - lat,lon,subtitle,uuid |
42 | | - FROM markers |
43 | | - WHERE uuid = $2 |
44 | | - ON CONFLICT DO NOTHING""", |
45 | | - status, |
46 | | - uuid, |
47 | | - ) |
48 | | - |
49 | | - await db.execute("DELETE FROM markers WHERE uuid = $1", uuid) |
50 | | - await db.execute( |
51 | | - "UPDATE markers_counts SET count = count - 1 WHERE source_id = $1 AND class = $2", |
52 | | - source_id, |
53 | | - class_id, |
54 | | - ) |
55 | | - |
56 | | - return 0 |
57 | | - |
58 | | - |
59 | 22 | async def _remove_bug_uuid(db: Connection, uuid: UUID, status: Status) -> int: |
60 | 23 | # find source |
61 | 24 | source_id = None |
@@ -162,19 +125,6 @@ def expand_tags(tags): |
162 | 125 | return ret |
163 | 126 |
|
164 | 127 |
|
165 | | -@router.get("/0.2/error/{err_id}", tags=["0.2"]) |
166 | | -async def error_err_id( |
167 | | - err_id: int, db: Connection = Depends(database.db) |
168 | | -) -> Dict[str, Any]: |
169 | | - return _error( |
170 | | - 2, |
171 | | - db, |
172 | | - ["en"], |
173 | | - None, |
174 | | - await _get(db, err_id=err_id), |
175 | | - ) |
176 | | - |
177 | | - |
178 | 128 | @router.get("/0.3/issue/{uuid}", tags=["issues"]) |
179 | 129 | async def error_uuid( |
180 | 130 | uuid: UUID, |
@@ -297,19 +247,6 @@ def _error( |
297 | 247 | } |
298 | 248 |
|
299 | 249 |
|
300 | | -@router.get("/0.2/error/{err_id}/{status}", tags=["0.2"]) |
301 | | -async def status_err_id( |
302 | | - request: Request, |
303 | | - err_id: int, |
304 | | - status: Status, |
305 | | - db: Connection = Depends(database.db_rw), |
306 | | -) -> None: |
307 | | - if await _remove_bug_err_id(db, err_id, status) == 0: |
308 | | - return None |
309 | | - else: |
310 | | - raise HTTPException(status_code=410, detail="FAIL") |
311 | | - |
312 | | - |
313 | 250 | @router.get("/0.3/issue/{uuid}/{status}", tags=["issues"]) |
314 | 251 | async def status_uuid( |
315 | 252 | request: Request, |
|
0 commit comments