feat: basic message recall

See #17

python/ichika/core/__init__.pyi

@@ -153,6 +153,8 @@ class RawMessageReceipt:
     seqs: VTuple[int]
     rands: VTuple[int]
     time: int
+    kind: str
+    target: int
 
 class PlumbingClient:
     # [impl 1]
@@ -184,6 +186,8 @@ class PlumbingClient:
     async def send_friend_message(self, uin: int, chain: list[dict[str, Any]]) -> RawMessageReceipt: ...
     async def upload_group_image(self, uin: int, data: bytes) -> dict[str, Any]: ...
     async def send_group_message(self, uin: int, chain: list[dict[str, Any]]) -> RawMessageReceipt: ...
+    async def recall_friend_message(self, uin: int, time: int, seq: int, rand: int): ...
+    async def recall_group_message(self, uin: int, seq: int, rand: int): ...
 
 # endregion: client
 

src/client/mod.rs

@@ -296,6 +296,8 @@ impl PlumbingClient {
                 seqs: PyTuple::new(py, seqs).into_py(py),
                 rands: PyTuple::new(py, rands).into_py(py),
                 time,
+                kind: "friend".into(),
+                target: uin,
             }))
         })
     }
@@ -324,17 +326,50 @@ impl PlumbingClient {
     ) -> PyResult<&'py PyAny> {
         let client = self.client.clone();
         let chain = deserialize_message_chain(chain)?;
-        tracing::info!("{:?}", chain);
         py_future(py, async move {
             let ricq::structs::MessageReceipt { seqs, rands, time } =
                 client.send_group_message(uin, chain).await?;
             Ok(Python::with_gil(|py| RawMessageReceipt {
                 seqs: PyTuple::new(py, seqs).into_py(py),
                 rands: PyTuple::new(py, rands).into_py(py),
                 time,
+                kind: "group".into(),
+                target: uin,
             }))
         })
     }
 
+    pub fn recall_friend_message<'py>(
+        &self,
+        py: Python<'py>,
+        uin: i64,
+        time: i64,
+        seq: i32,
+        rand: i32,
+    ) -> PyResult<&'py PyAny> {
+        let client = self.client.clone();
+        py_future(py, async move {
+            client
+                .recall_friend_message(uin, time, vec![seq], vec![rand])
+                .await?;
+            Ok(())
+        })
+    }
+
+    pub fn recall_group_message<'py>(
+        &self,
+        py: Python<'py>,
+        uin: i64,
+        seq: i32,
+        rand: i32,
+    ) -> PyResult<&'py PyAny> {
+        let client = self.client.clone();
+        py_future(py, async move {
+            client
+                .recall_group_message(uin, vec![seq], vec![rand])
+                .await?;
+            Ok(())
+        })
+    }
     // TODO: Send audio
 }

src/client/structs.rs

@@ -24,4 +24,6 @@ pub struct RawMessageReceipt {
     pub seqs: Py<PyTuple>,
     pub rands: Py<PyTuple>,
     pub time: i64,
+    pub kind: String,
+    pub target: i64,
 }