Merge branch 'main' into sse-changes

Author: parmesant

.github/workflows/build-push-edge-debug.yaml

@@ -12,7 +12,7 @@ on:
 
 jobs:
   docker:
-    runs-on: ubuntu-latest
+    runs-on: self-hosted
     steps:
       - name: Checkout
         uses: actions/checkout@v3
@@ -36,6 +36,9 @@ jobs:
         uses: docker/metadata-action@v5
         with:
           images: parseable/parseable
+      
+      - name: Clean up builder cache
+        run: docker builder prune -f
 
       - name: Build and push
         uses: docker/build-push-action@v6

.github/workflows/build-push-edge-kafka.yaml

@@ -12,7 +12,7 @@ on:
 
 jobs:
   docker:
-    runs-on: ubuntu-latest
+    runs-on: self-hosted
     steps:
       - name: Checkout
         uses: actions/checkout@v4
@@ -58,3 +58,6 @@ jobs:
           platforms: linux/arm64
           build-args: |
             LIB_DIR=aarch64-linux-gnu
+      
+      - name: Clean up builder cache
+        run: docker builder prune -f

.github/workflows/build-push-edge.yaml

@@ -12,7 +12,7 @@ on:
 
 jobs:
   docker:
-    runs-on: ubuntu-latest
+    runs-on: self-hosted
     steps:
       - name: Checkout
         uses: actions/checkout@v3
@@ -36,6 +36,9 @@ jobs:
         uses: docker/metadata-action@v5
         with:
           images: parseable/parseable
+      
+      - name: Clean up builder cache
+        run: docker builder prune -f
 
       - name: Build and push
         uses: docker/build-push-action@v6

.github/workflows/release.yml

@@ -348,7 +348,7 @@ jobs:
           GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
 
   build-push-docker-image:
-    runs-on: ubuntu-latest
+    runs-on: self-hosted
     steps:
       - name: Checkout
         uses: actions/checkout@v3
@@ -403,3 +403,6 @@ jobs:
           platforms: linux/arm64
           build-args: |
             LIB_DIR=aarch64-linux-gnu
+      
+      - name: Clean up builder cache
+        run: docker builder prune -f

src/alerts/mod.rs

@@ -607,7 +607,7 @@ impl AlertConfig {
 
     pub async fn trigger_notifications(&self, message: String) -> Result<(), AlertError> {
         let mut context = self.get_context();
-        context.message = message.clone();
+        context.message.clone_from(&message);
 
         for target_id in &self.targets {
             let target = TARGETS.get_target_by_id(target_id).await?;
@@ -619,7 +619,7 @@ impl AlertConfig {
         let active_sessions = sessions().get_active_sessions();
         let mut broadcast_to = vec![];
         for session in active_sessions {
-            if let Ok(_) = user_auth_for_query(&session, &self.query).await
+            if user_auth_for_query(&session, &self.query).await.is_ok()
                 && let SessionKey::SessionId(id) = &session
             {
                 broadcast_to.push(*id);