@@ -26,7 +26,7 @@ import { timer, BehaviorSubject } from 'rxjs';
2626import { filter , takeUntil , first } from 'rxjs/operators' ;
2727
2828import Daemon from './daemon' ;
29- import V2 from './socket-daemon.v2' ;
29+ // import V2 from './socket-daemon.v2';
3030
3131// Required agent version
3232const browser = detect ( ) ;
@@ -63,17 +63,17 @@ export default class SocketDaemon extends Daemon {
6363
6464 this . openChannel ( ( ) => this . socket . emit ( 'command' , 'list' ) ) ;
6565
66- this . agentV2Found = new BehaviorSubject ( null ) ;
66+ // this.agentV2Found = new BehaviorSubject(null);
6767
6868 this . agentFound
6969 . subscribe ( agentFound => {
7070 if ( agentFound ) {
7171 this . _wsConnect ( ) ;
72- const v2 = new V2 ( this . pluginURL ) ;
72+ /* const v2 = new V2(this.pluginURL);
7373 v2.init().then(() => {
7474 this.v2 = v2;
7575 this.agentV2Found.next(this.v2);
76- } ) ;
76+ }); */
7777 }
7878 else {
7979 this . findAgent ( ) ;
@@ -471,15 +471,15 @@ export default class SocketDaemon extends Daemon {
471471 _upload ( uploadPayload , uploadCommandInfo ) {
472472 if ( Array . isArray ( uploadCommandInfo . tools ) ) {
473473 uploadCommandInfo . tools . forEach ( tool => {
474- if ( this . v2 ) {
475- this . downloading . next ( { status : this . DOWNLOAD_IN_PROGRESS } ) ;
476- this . v2 . installTool ( tool ) . then ( ( ) => {
477- this . downloading . next ( { status : this . DOWNLOAD_DONE } ) ;
478- } ) ;
479- }
480- else {
481- this . downloadTool ( tool . name , tool . version , tool . packager ) ;
482- }
474+ // if (this.v2) {
475+ // this.downloading.next({ status: this.DOWNLOAD_IN_PROGRESS });
476+ // this.v2.installTool(tool).then(() => {
477+ // this.downloading.next({ status: this.DOWNLOAD_DONE });
478+ // });
479+ // }
480+ // else {
481+ this . downloadTool ( tool . name , tool . version , tool . packager ) ;
482+ // }
483483 } ) ;
484484 }
485485
0 commit comments