diff --git a/corrlib/integrity.py b/corrlib/integrity.py index db242f6..bf890db 100644 --- a/corrlib/integrity.py +++ b/corrlib/integrity.py @@ -1,32 +1,5 @@ import datetime as dt -from pathlib import Path -from .tools import get_db_file -import pandas as pd -import sqlite3 -def has_valid_times(result: pd.DataFrame) -> bool: - # we expect created_at <= updated_at <= now - created_at = dt.datetime.fromisoformat(result['created_at']) - updated_at = dt.datetime.fromisoformat(result['updated_at']) - if created_at > updated_at: - return False - if updated_at > dt.datetime.now(): - return False - return True - - -def check_db_integrity(path: Path) -> None: - db = get_db_file(path) - search_expr = "SELECT * FROM 'backlogs'" - conn = sqlite3.connect(db) - results = pd.read_sql(search_expr, conn) - - for result in results: - if not has_valid_times(result): - raise ValueError(f"Result with id {result[id]} has wrong time signatures.") - - -def full_integrity_check(path: Path) -> None: - check_db_integrity(path) - +def check_time_validity(created_at: dt.datetime, updated_at: dt.datetime) -> bool: + return not (created_at > updated_at)