feat(config): read concurrency from config file

src/api/process-manager.ts

@@ -7,6 +7,7 @@ import { getRepositoryDetails, generateCommands } from './config';
 import { killContainer } from './docker';
 import * as logger from './logger';
 import { blue, yellow, green, cyan } from 'chalk';
+import { getConfig } from './utils';
 
 export interface BuildMessage {
   type: string;
@@ -37,6 +38,7 @@ export interface JobProcessEvent {
   data?: string;
 }
 
+const config: any = getConfig();
 let queueBlocked: boolean;
 export let jobProcesses: JobProcess[] = [];
 export let jobEvents: BehaviorSubject<JobProcessEvent> = new BehaviorSubject({});
@@ -54,9 +56,8 @@ jobEvents
 Observable.interval(1000)
   .map(() => {
     if (this.queueBlocked) { return; }
-
     let runningJobs = jobProcesses.filter(jp => jp.status === 'running').length;
-    let parallelJobsAvailable = 2;
+    let parallelJobsAvailable = config.concurrency;
     if (runningJobs < parallelJobsAvailable) {
       let newJobProcesses = jobProcesses.filter(jp => jp.status === 'queued');
       if (newJobProcesses.length) {

src/api/utils.ts

@@ -9,6 +9,7 @@ import * as uuid from 'uuid';
 const defaultConfig = {
   port: 6500,
   wsport: 6501,
+  concurrency: 10,
   db: {
     client: 'sqlite3',
     connection: {

src/app/components/app-setup/app-setup.component.ts

@@ -2,6 +2,7 @@ import { Component, OnInit } from '@angular/core';
 import { Router } from '@angular/router';
 import { ApiService } from '../../services/api.service';
 import { SocketService } from '../../services/socket.service';
+import { AuthService } from '../../services/auth.service';
 
 export interface ServerStatus {
   sqlite: boolean;
@@ -33,7 +34,8 @@ export class AppSetupComponent implements OnInit {
   constructor(
     private apiService: ApiService,
     private socketService: SocketService,
-    private router: Router
+    private router: Router,
+    private authService: AuthService
   ) {
     this.serverStatus = {
       sqlite: false,
@@ -52,6 +54,10 @@ export class AppSetupComponent implements OnInit {
       if (event) {
         this.router.navigate(['/login']);
       } else {
+        if (this.authService.isLoggedIn()) {
+          this.authService.logout();
+        }
+
         this.checkConfiguration();
       }
     });