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
|
from flask import request, jsonify, redirect
from flask_classful import route
from werkzeug.datastructures import MultiDict
from app.sql.common import db, Session
from app.sql.models.annotation import Annotation, AnnotationForm
from app.controllers.crud_controller import CrudView
class AnnotationView(CrudView):
model = Annotation
form = AnnotationForm
index_all = False
use_limit = False
default_sort = "start_ts"
def where(self, query, args):
episode_id = args.get('episode_id', default=None)
if episode_id is not None:
query = query.filter(Annotation.episode_id == int(episode_id))
return query
def on_create(self, session, form, item):
if 'paragraph_id' in form:
item.paragraph_id = form['paragraph_id']
if 'start_ts' in form:
item.start_ts = form['start_ts']
if 'settings' in form:
item.settings = form['settings']
def on_update(self, session, form, item):
if 'paragraph_id' in form:
item.paragraph_id = form['paragraph_id']
if 'start_ts' in form:
item.start_ts = form['start_ts']
if 'settings' in form:
item.settings = form['settings']
@route('/splice', methods=['POST'])
def splice(self):
"""Add or remove time"""
session = Session()
try:
start_ts = float(request.json['start_ts'])
except:
print("Annotation splice: start_ts is invalid")
session.close()
return { 'status': 'error', 'error': 'start_ts is invalid '}
try:
duration = float(request.json['duration'])
except:
print("Annotation splice: duration is invalid")
session.close()
return { 'status': 'error', 'error': 'duration is invalid '}
try:
episode_id = float(request.json['episode_id'])
except:
print("Annotation splice: episode_id is undefined")
session.close()
return { 'status': 'error', 'error': 'episode_id is invalid '}
query = session.query(self.model)
query = query.filter(Annotation.start_ts > start_ts, Annotation.episode_id == episode_id)
items = query.all()
print(f"{len(items)} annotations would be updated")
print(f"start_ts: {start_ts}")
print(f"duration: {duration}")
for item in items:
item.start_ts += duration
session.add(item)
session.commit()
res = {
'status': 'ok',
'count': len(items),
}
session.close()
return jsonify(res)
|
