Draft: feat: node agent api implementation

.github/workflows/ci.yml

@@ -2,29 +2,32 @@ name: Kudo CI
 
 on:
   push:
-    branches: [ "main" ]
+    branches: ["main", "project-demo-202208"]
   pull_request:
-    branches: [ "main" ]
+    branches: ["main", "project-demo-202208"]
 
 env:
   CARGO_TERM_COLOR: always
 
 jobs:
   build:
-
     runs-on: ubuntu-latest
 
     steps:
-    - uses: actions/checkout@v3
-    - name: Install clippy
-      run: rustup component add clippy
-    - name: Install rustfmt
-      run: rustup component add rustfmt
-    - name: Build
-      run: make kudo
-    - name: Lint
-      run: make lint
-    - name: Format
-      run: make format
-    - name: Tests
-      run: make check
+      - uses: actions/checkout@v3
+      - name: Install clippy
+        run: rustup component add clippy
+      - name: Install rustfmt
+        run: rustup component add rustfmt
+      - name: Cargo setup
+        run: |
+          echo "[target.x86_64-unknown-linux-gnu]" >> ~/.cargo/config
+          echo "runner = 'sudo -E'" >> ~/.cargo/config
+      - name: Build
+        run: make kudo
+      - name: Lint
+        run: make lint
+      - name: Format
+        run: make format
+      - name: Tests
+        run: make check

controller/lib/Cargo.toml

@@ -13,6 +13,5 @@ tonic = "0.7.2"
 proto = { path = "../../proto" }
 log = "0.4.0"
 tokio = { version = "1.20.0", features = ["rt-multi-thread", "macros"] }
-
 serde_json = "1.0"
 

controller/lib/src/external_api/generic/filter.rs

@@ -0,0 +1,59 @@
+use super::model::FilterError;
+/// `FilterService` is a struct that can be used as a services to filter result.
+pub struct FilterService {}
+
+impl Default for FilterService {
+    fn default() -> Self {
+        Self::new()
+    }
+}
+
+impl FilterService {
+    pub fn new() -> Self {
+        FilterService {}
+    }
+
+    /// It takes a vector of <T> and a limit, and returns a vector that is limited to the
+    /// number specified by the limit
+    ///
+    /// # Arguments:
+    ///
+    /// * `vector`: A vector.
+    /// * `limit`: The number of elements in the vector to return.
+    ///
+    /// # Returns:
+    ///
+    /// A vector.
+
+    pub fn limit<T: Clone>(&mut self, vector: &Vec<T>, mut limit: u32) -> Vec<T> {
+        if limit > vector.len() as u32 {
+            limit = vector.len() as u32;
+        }
+        vector[0..limit as usize].to_vec()
+    }
+
+    /// "Return a subset of the vector, starting at the offset index."
+    ///
+    /// The first thing we do is check if the offset is greater than the length of the vector. If
+    /// it is, we return an error
+    ///
+    /// # Arguments:
+    ///
+    /// * `vector`: A vector.
+    /// * `offset`: The offset to start from.
+    ///
+    /// # Returns:
+    ///
+    /// A vector.
+
+    pub fn offset<T: Clone>(
+        &mut self,
+        vector: &Vec<T>,
+        offset: u32,
+    ) -> Result<Vec<T>, FilterError> {
+        if offset > vector.len() as u32 {
+            return Err(FilterError::OutOfRange);
+        }
+        Ok(vector[offset as usize..].to_vec())
+    }
+}

controller/lib/src/external_api/generic/mod.rs

@@ -0,0 +1,2 @@
+pub mod filter;
+pub mod model;