|
8 | 8 | import json |
9 | 9 | import logging |
10 | 10 | import connexion |
11 | | -from tinydb import TinyDB, Query |
12 | | -from tinydb.operations import delete |
| 11 | +import pigpio |
13 | 12 | from cachetools import cached, TTLCache |
14 | 13 | from coderbot import CoderBot |
15 | 14 | from program import ProgramEngine, Program |
16 | 15 | from config import Config |
| 16 | +from activity import Activities |
17 | 17 | from coderbotTestUnit import run_test as runCoderbotTestUnit |
18 | 18 | from cnn_manager import CNNManager |
19 | | -import pigpio |
20 | 19 | from musicPackages import MusicPackageManager |
21 | 20 |
|
22 | 21 | BUTTON_PIN = 16 |
|
27 | 26 | encoder=bool(bot_config.get("encoder")) |
28 | 27 | ) |
29 | 28 |
|
30 | | -query = Query() |
31 | | - |
32 | 29 | def get_serial(): |
33 | 30 | """ |
34 | 31 | Extract serial from cpuinfo file |
@@ -110,8 +107,7 @@ def get_info(): |
110 | 107 | prog = None |
111 | 108 | prog_engine = ProgramEngine.get_instance() |
112 | 109 |
|
113 | | -# Programs and Activities databases |
114 | | -activities = TinyDB("data/activities.json") |
| 110 | +activities = Activities.get_instance() |
115 | 111 |
|
116 | 112 | ## Robot control |
117 | 113 |
|
@@ -247,23 +243,17 @@ def listPrograms(): |
247 | 243 | ## Activities |
248 | 244 |
|
249 | 245 | def saveActivity(data): |
250 | | - data = data["activity"] |
251 | | - if activities.search(query.name == data["name"]) == []: |
252 | | - activities.insert(data) |
253 | | - return 200 |
254 | | - else: |
255 | | - activities.update(data, query.name == data["name"]) |
256 | | - return 200 |
| 246 | + activity = data["activity"] |
| 247 | + activities.save(activity) |
257 | 248 |
|
258 | 249 | def loadActivity(name): |
259 | | - return activities.search(query.name == name)[0], 200 |
| 250 | + return activities.load(name) |
260 | 251 |
|
261 | 252 | def deleteActivity(data): |
262 | | - activities.remove(query.name == data["name"]) |
263 | | - |
| 253 | + activities.delete(data), 200 |
264 | 254 |
|
265 | 255 | def listActivities(): |
266 | | - return activities.all() |
| 256 | + return activities.list() |
267 | 257 |
|
268 | 258 | def resetDefaultPrograms(): |
269 | 259 | """ |
|
0 commit comments