mirror of
https://github.com/blakeblackshear/frigate.git
synced 2026-02-03 01:35:22 +03:00
Cleanup db creation
This commit is contained in:
parent
e711f42a10
commit
c4de7da548
@ -1,5 +1,6 @@
|
|||||||
import datetime
|
import datetime
|
||||||
import logging
|
import logging
|
||||||
|
import os
|
||||||
import unittest
|
import unittest
|
||||||
from unittest.mock import patch, MagicMock
|
from unittest.mock import patch, MagicMock
|
||||||
|
|
||||||
@ -15,7 +16,31 @@ from frigate.test.const import TEST_DB
|
|||||||
|
|
||||||
|
|
||||||
class TestHttp(unittest.TestCase):
|
class TestHttp(unittest.TestCase):
|
||||||
|
|
||||||
|
def setup_test_db(self) -> SqliteQueueDatabase:
|
||||||
|
"""Setup a functional db"""
|
||||||
|
|
||||||
|
# close and delete db before each test
|
||||||
|
if self.db:
|
||||||
|
if not self.db.is_closed():
|
||||||
|
self.db.close()
|
||||||
|
|
||||||
|
os.remove("test.db")
|
||||||
|
|
||||||
|
migrate_db = SqliteExtDatabase("test.db")
|
||||||
|
del logging.getLogger("peewee_migrate").handlers[:]
|
||||||
|
router = Router(migrate_db)
|
||||||
|
router.run()
|
||||||
|
|
||||||
|
migrate_db.close()
|
||||||
|
|
||||||
|
self.db = SqliteQueueDatabase(TEST_DB)
|
||||||
|
models = [Event, Recordings]
|
||||||
|
self.db.bind(models)
|
||||||
|
return self.db
|
||||||
|
|
||||||
def setUp(self):
|
def setUp(self):
|
||||||
|
self.db = None
|
||||||
self.minimal_config = {
|
self.minimal_config = {
|
||||||
"mqtt": {"host": "mqtt"},
|
"mqtt": {"host": "mqtt"},
|
||||||
"cameras": {
|
"cameras": {
|
||||||
@ -143,32 +168,17 @@ class TestHttp(unittest.TestCase):
|
|||||||
}
|
}
|
||||||
|
|
||||||
def test_get_good_event(self):
|
def test_get_good_event(self):
|
||||||
db = _setup_test_db()
|
db = self.setup_test_db()
|
||||||
app = create_app(FrigateConfig(**self.minimal_config), db, None, None, None)
|
app = create_app(FrigateConfig(**self.minimal_config), db, None, None, None)
|
||||||
id = "123456.someid"
|
id = "123456.someid"
|
||||||
_insert_mock_event(id)
|
|
||||||
|
|
||||||
with app.test_client() as client:
|
with app.test_client() as client:
|
||||||
|
_insert_mock_event(id)
|
||||||
event = client.get(f"/events/{id}").json
|
event = client.get(f"/events/{id}").json
|
||||||
|
|
||||||
assert event
|
assert event
|
||||||
assert event["id"] == id
|
assert event["id"] == id
|
||||||
|
|
||||||
|
|
||||||
def _setup_test_db() -> SqliteQueueDatabase:
|
|
||||||
"""Setup a functional db"""
|
|
||||||
migrate_db = SqliteExtDatabase("test.db")
|
|
||||||
del logging.getLogger("peewee_migrate").handlers[:]
|
|
||||||
router = Router(migrate_db)
|
|
||||||
router.run()
|
|
||||||
|
|
||||||
migrate_db.close()
|
|
||||||
|
|
||||||
db = SqliteQueueDatabase(TEST_DB)
|
|
||||||
models = [Event, Recordings]
|
|
||||||
db.bind(models)
|
|
||||||
return db
|
|
||||||
|
|
||||||
def _insert_mock_event(id: str) -> Event:
|
def _insert_mock_event(id: str) -> Event:
|
||||||
"""Inserts a basic event model with a given id."""
|
"""Inserts a basic event model with a given id."""
|
||||||
return Event.insert(
|
return Event.insert(
|
||||||
@ -186,4 +196,4 @@ def _insert_mock_event(id: str) -> Event:
|
|||||||
area=0,
|
area=0,
|
||||||
has_clip=True,
|
has_clip=True,
|
||||||
has_snapshot=True,
|
has_snapshot=True,
|
||||||
)
|
).execute()
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user