closes #69 ChainLP: Cache control

Author: anshooarora

chainlp/backend/chainlp/src/main/java/com/aventstack/chainlp/api/cache/CacheController.java

@@ -0,0 +1,29 @@
+package com.aventstack.chainlp.api.cache;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.DeleteMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping("/cache")
+public class CacheController {
+
+    @Autowired
+    private CacheService service;
+
+    @DeleteMapping
+    public ResponseEntity<Void> clearAll() {
+        service.clearAll();
+        return ResponseEntity.ok().build();
+    }
+
+    @DeleteMapping("/{name}")
+    public ResponseEntity<Void> clear(@PathVariable final String name) {
+        service.clearCache(name);
+        return ResponseEntity.ok().build();
+    }
+
+}

chainlp/backend/chainlp/src/main/java/com/aventstack/chainlp/api/cache/CacheService.java

@@ -0,0 +1,29 @@
+package com.aventstack.chainlp.api.cache;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.cache.CacheManager;
+import org.springframework.stereotype.Service;
+
+import java.util.Objects;
+
+@Slf4j
+@Service
+public class CacheService {
+
+    @Autowired
+    private CacheManager cache;
+
+    public void clearAll() {
+        log.info("Clearing all caches");
+        cache.getCacheNames().forEach(x -> Objects.requireNonNull(cache.getCache(x)).clear());
+        log.info("All caches cleared");
+    }
+
+    public void clearCache(final String name) {
+        log.info("Clearing cache: {}", name);
+        Objects.requireNonNull(cache.getCache(name)).clear();
+        log.info("Cache cleared: {}", name);
+    }
+
+}

chainlp/backend/chainlp/src/main/java/com/aventstack/chainlp/scheduler/CacheTask.java

@@ -0,0 +1,19 @@
+package com.aventstack.chainlp.scheduler;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.cache.CacheManager;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+@Component
+public class CacheTask {
+
+    @Autowired
+    private CacheManager cacheManager;
+
+    @Scheduled(cron="0 0 0 * * ?")
+    public void reportCurrentTime() {
+        cacheManager.getCacheNames().forEach(cacheManager::getCache);
+    }
+
+}

chainlp/frontend/chainlp/src/app/model/cache.model.ts

@@ -0,0 +1,3 @@
+export class Cache {
+  
+}

chainlp/frontend/chainlp/src/app/pages/settings/settings.component.html

@@ -30,6 +30,43 @@ <h5>Theme</h5>
               </ng-template>
             </li>
             <li [ngbNavItem]="2">
+              <button ngbNavLink>Cache</button>
+              <ng-template ngbNavContent>
+                <div class="row">
+                  <div class="col-3">
+                    <h5>Clear Individual Caches</h5>
+                    <div class="text-secondary">
+                      Clear individual caches in the app. This action cannot be undone.
+                    </div>
+                  </div>
+                  <div class="col-1"></div>
+                  <div class="col-5">
+                    <button class="btn btn-primary mb-1 me-1" type="button" (click)="clearCache('projects');clearCache('project');">Clear Projects Cache</button>
+                    <button class="btn btn-primary mb-1 me-1" type="button" (click)="clearCache('builds');clearCache('build');">Clear Builds Cache</button>
+                    <button class="btn btn-primary mb-1 me-1" type="button" (click)="clearCache('tests');clearCache('test');">Clear Tests Cache</button>
+                    <div class="mt-2">
+                      <span *ngIf="isCacheCleared" class="text-success">Cache cleared!</span>
+                    </div>
+                  </div>
+                </div>
+                <div class="row mt-5">
+                  <div class="col-3">
+                    <h5>Clear All Caches</h5>
+                    <div class="text-secondary">
+                      Clears all caches in the app. This action cannot be undone and may require additional time to rebuild the cache.
+                    </div>
+                  </div>
+                  <div class="col-1"></div>
+                  <div class="col-3">
+                    <button class="btn btn-danger" type="button" (click)="clearAllCaches()">Clear all</button>
+                    <div class="mt-2">
+                      <span *ngIf="areCachesCleared" class="text-success">All caches cleared!</span>
+                    </div>
+                  </div>
+                </div>
+              </ng-template>
+            </li>
+            <li [ngbNavItem]="3">
               <button ngbNavLink>Secrets</button>
               <ng-template ngbNavContent>
                 <div class="row mb-5">

chainlp/frontend/chainlp/src/app/pages/settings/settings.component.ts

@@ -5,6 +5,7 @@ import { ThemeService } from '../../services/theme.service';
 import { SecretsService } from '../../services/secrets.service';
 import { Secret } from '../../model/secret.model';
 import { ErrorHandlerService } from '../../services/error-handler.service';
+import { CacheService } from '../../services/cache.service';
 
 @Component({
   selector: 'app-settings',
@@ -14,10 +15,14 @@ import { ErrorHandlerService } from '../../services/error-handler.service';
 export class SettingsComponent implements OnInit, OnDestroy {
 
   private readonly _secrets$: Subject<any> = new Subject<any>();
+  private readonly _cache$: Subject<any> = new Subject<any>();
+  private readonly _caches$: Subject<any> = new Subject<any>();
 
   error: any;
   active: number = 1;
   version: string = '0.0.8';
+  isCacheCleared: boolean = false;
+  areCachesCleared: boolean = false;
 
   /* theme */
   themes: Theme[] = [
@@ -48,6 +53,7 @@ export class SettingsComponent implements OnInit, OnDestroy {
 
   constructor(private themeService: ThemeService, 
     private secretsService: SecretsService,
+    private cacheService: CacheService,
     private errorService: ErrorHandlerService) { }
 
   ngOnInit(): void {}
@@ -62,6 +68,38 @@ export class SettingsComponent implements OnInit, OnDestroy {
     this.themeService.setTheme(theme);
   }
 
+  clearCache(name: string) {
+    this.cacheService.clear(name)
+    .pipe(takeUntil(this._cache$))
+    .subscribe({
+      next: (response: any) => {
+        this.isCacheCleared = true;
+        setTimeout(() => {
+          this.isCacheCleared = false;
+        }, 2000);
+      },
+      error: (err) => {
+        this.error = this.errorService.getError(err);
+      }
+    });
+  }
+
+  clearAllCaches() {
+    this.cacheService.clearAll()
+    .pipe(takeUntil(this._caches$))
+    .subscribe({
+      next: (response: any) => {
+        this.areCachesCleared = true;
+        setTimeout(() => {
+          this.areCachesCleared = false;
+        }, 2000);
+      },
+      error: (err) => {
+        this.error = this.errorService.getError(err);
+      }
+    });
+  }
+
   saveSecrets(obj: any) {
     if (typeof obj === 'object') {
       for (const key in obj) {

chainlp/frontend/chainlp/src/app/services/cache.service.ts

@@ -0,0 +1,24 @@
+import { Injectable } from '@angular/core';
+import { HttpClient } from '@angular/common/http';
+import { Observable } from 'rxjs';
+import { BaseService } from './base.service';
+import { Cache } from '../model/cache.model';
+
+@Injectable({
+  providedIn: 'root'
+})
+export class CacheService extends BaseService<Cache> {
+
+  constructor(http: HttpClient) {
+    super('/cache', http);
+  }
+
+  clear(name: string): Observable<any> {
+    return this.http.delete(`${this._path}/${name}`);
+  }
+
+  clearAll(): Observable<any> {
+    return this.http.delete(`${this._path}`);
+  }
+
+}