fix(edulint): dedupe requests

fi-ksi · Jun 30, 2024 · 7e49951 · 7e49951
1 parent a2c73fd
commit 7e49951
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 2 deletions.
diff --git a/...components/tasks/task-module/task-module-programming/task-module-programming.component.ts b/...components/tasks/task-module/task-module-programming/task-module-programming.component.ts
@@ -96,7 +96,8 @@ export class TaskModuleProgrammingComponent implements OnInit, OnDestroy {
         if (result.result === 'ok') {
           this.lintCode();
         }
-      })
+      }),
+      shareReplay(1),
     );
     (this.codeRun$ = this.codeRunResult$.pipe(mapTo(undefined))).subscribe(() => {
       this.codeRun$ = null;

diff --git a/src/app/services/tasks/edulint.service.ts b/src/app/services/tasks/edulint.service.ts
@@ -3,7 +3,7 @@ import { HttpClient } from '@angular/common/http';
 import { APIService, Configuration, WebService } from '../../../api/edulint';
 import { environment } from '../../../environments/environment';
 import { combineLatest, Observable, of } from 'rxjs';
-import { catchError, filter, map, mergeMap } from 'rxjs/operators';
+import {catchError, filter, map, mergeMap, shareReplay, take} from 'rxjs/operators';
 import { EdulintReport } from '../../models';
 
 @Injectable({
@@ -31,13 +31,17 @@ export class EdulintService {
     code += `\n# edulint: config=${this.config}\n`;
 
     return this.linter.apiCodePost({code}).pipe(
+      take(1),
+      shareReplay(1),
       catchError((e) => {
         environment.logger.error('[EduLint] Code post error', e);
         return of({hash: undefined});
       }),
       filter((response) => response.hash !== undefined),
       map(response => `${response.hash}`),
       mergeMap((hash) => combineLatest([this.linter.analyzeUploaded(this.version, hash), of(hash)])),
+      take(1),
+      shareReplay(1),
       map(([problems, hash]) => ({
         problems,
         editorUrl:  `${this.url}/editor/${hash}`