Add delete_sampling_policy api

- Add mutation to timeseries.
- Delete timeseries from database by id.

Close: #351

src/graphql.rs

@@ -53,7 +53,10 @@ pub struct Query(
 );
 
 #[derive(Default, MergedObject)]
-pub struct Mutation(status::GigantoConfigMutation);
+pub struct Mutation(
+    status::GigantoConfigMutation,
+    timeseries::TimeSeriesMutation,
+);
 
 #[derive(InputObject, Serialize)]
 pub struct TimeRange {

src/graphql/timeseries.rs

@@ -1,7 +1,7 @@
-use super::{get_timestamp, load_connection, FromKeyValue};
+use super::{get_timestamp, load_connection, network::key_prefix, FromKeyValue};
 use crate::{
     graphql::{RawEventFilter, TimeRange},
-    storage::Database,
+    storage::{lower_closed_bound_key, upper_open_bound_key, Database},
 };
 use async_graphql::{
     connection::{query, Connection},
@@ -14,6 +14,9 @@ use std::{fmt::Debug, net::IpAddr};
 #[derive(Default)]
 pub(super) struct TimeSeriesQuery;
 
+#[derive(Default)]
+pub(super) struct TimeSeriesMutation;
+
 // #[allow(clippy::module_name_repetitions)]
 #[derive(InputObject)]
 pub struct TimeSeriesFilter {
@@ -91,6 +94,31 @@ impl TimeSeriesQuery {
     }
 }
 
+#[Object]
+impl TimeSeriesMutation {
+    async fn delete_time_series<'ctx>(
+        &self,
+        ctx: &Context<'ctx>,
+        ids: Vec<String>,
+    ) -> Result<String> {
+        let store = ctx.data::<Database>()?.periodic_time_series_store()?;
+        for id in ids {
+            // 각 id에 대한 TimeSeries 데이터 삭제
+            let prefix = key_prefix(&id);
+            let mut iter = store.boundary_iter(
+                &lower_closed_bound_key(&prefix, None),
+                &upper_open_bound_key(&prefix, None),
+                rocksdb::Direction::Forward,
+            );
+            while let Some(item) = iter.next() {
+                let (key, _) = item.map_err(|e| format!("failed to read database: {e}"))?;
+                if store.delete(&key).is_err() {}
+            }
+        }
+        Ok("deleted".to_string())
+    }
+}
+
 #[cfg(test)]
 mod tests {
     use crate::{graphql::TestSchema, storage::RawEventStore};

src/main.rs

@@ -32,6 +32,7 @@ ARG:
     <CONFIG>    A TOML config file
 ";
 
+#[allow(clippy::too_many_lines)]
 #[tokio::main]
 async fn main() -> Result<()> {
     let mut settings = if let Some(config_filename) = parse() {

src/publish.rs

@@ -598,8 +598,8 @@ where
                     if last_ts > ts {
                         continue;
                     }
-                    if send_bytes(&mut sender, &buf).await.is_err(){
-                        for r_key in channel_remove_keys{
+                    if send_bytes(&mut sender, &buf).await.is_err() {
+                        for r_key in channel_remove_keys {
                             stream_direct_channel
                             .write()
                             .await