wip

papi/main.py

@@ -80,18 +80,19 @@ def list_notification(idsonde: str):
 def post_sonde_data(
     idsonde: str, body: dict = Body(...), db: Session = Depends(get_db)
 ):
-
     if not (sonde := crud.get_sonde(db, idsonde)):
         return
-
-    mesures_ = mesures[idsonde]
+    mesures_ = []
+    mesures_.extend(crud.get_mesure(db, sonde.identifiant))
     if not mesures_:
-        mesures_.append(default_sample())
-    mesures_.append(body)
-
+        mesures_.append(
+            crud.create_mesure(db, sonde.sonde_id, content=default_sample())
+        )
+    mesures_.append(crud.create_mesure(db, sonde.sonde_id, content=body))
+    mesures[idsonde] = mesures_
     date = body["date"]
-    previous = utils.prepare(mesures_[-2])
-    present = utils.prepare(mesures_[-1])
+    previous = utils.prepare(mesures_[-2].content)
+    present = utils.prepare(mesures_[-1].content)
     all_channels = sorted(set((*previous["channels"], *present["channels"])))
 
     diff = utils.compare(all_channels, previous, present)

papi/sqlapp/crud.py

@@ -21,7 +21,7 @@ def create_mesure(db: Session, sonde_id: int, content: dict):
     db_mesure = models.Mesure(sonde_id=sonde_id, content=content)
     db.add(db_mesure)
     db.commit()
-    db.refesh(db_mesure)
+    db.refresh(db_mesure)
     return db_mesure
 
 

papi/sqlapp/schemas.py

@@ -20,3 +20,10 @@ class Sonde(SondeBase):
 
     class Config:
         orm_mode = True
+
+
+class Mesure(BaseModel):
+    content: dict
+
+    class Config:
+        orm_mode = True