feat: reset path memory in mpay

tools/plugins/mpay/data/reset.py

@@ -0,0 +1,31 @@
+import json
+
+from pyln.client import Plugin
+from sqlalchemy import delete
+from sqlalchemy.orm import Session
+
+from plugins.mpay.db.db import Database
+from plugins.mpay.db.models import Attempt, Hop, Payment
+
+
+class Reset:
+    _pl: Plugin
+    _db: Database
+
+    def __init__(self, pl: Plugin, db: Database) -> None:
+        self._pl = pl
+        self._db = db
+
+    def reset_all(self) -> dict[str, int]:
+        res: dict[str, int] = {}
+
+        with Session(self._db.engine) as e:
+            res["hops"] = e.execute(delete(Hop)).rowcount
+            res["attempts"] = e.execute(delete(Attempt)).rowcount
+            res["payments"] = e.execute(delete(Payment)).rowcount
+
+            e.commit()
+
+        self._pl.log(f"Reset path memory: {json.dumps(res)}")
+
+        return res

tools/plugins/mpay/mpay.py

@@ -12,6 +12,7 @@
 from plugins.mpay.config import Config, register_options
 from plugins.mpay.consts import PLUGIN_NAME, VERSION
 from plugins.mpay.data.payments import Payments
+from plugins.mpay.data.reset import Reset
 from plugins.mpay.data.route_stats import RouteStatsFetcher
 from plugins.mpay.db.db import Database
 from plugins.mpay.errors import Errors
@@ -26,6 +27,7 @@
 register_options(pl)
 
 db = Database(pl)
+reset = Reset(pl, db)
 payments_fetcher = Payments(pl, db)
 route_stats_fetcher = RouteStatsFetcher(pl, db)
 
@@ -136,4 +138,13 @@ def mpay_list(request: Request, bolt11: str = "", payment_hash: str = "") -> dic
     return {"payments": payments}
 
 
+@pl.async_method(
+    method_name="mpay-resetpm",
+    category=PLUGIN_NAME,
+)
+@thread_method(executor=executor)
+def mpay_reset(request: Request) -> dict[str, Any]:
+    return {"deleted": reset.reset_all()}
+
+
 pl.run()