Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Bump CF CLI to 6.49.0 #4182

Merged
merged 15 commits into from
Apr 6, 2020
Merged
Show file tree
Hide file tree
Changes from 10 commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,7 @@ export class DeployApplicationDeployer {
// Status of file transfers
fileTransferStatus$ = new BehaviorSubject<FileTransferStatus>(undefined);

public messages: Observable<string>;
public messages = new BehaviorSubject<string>('');

// Are we deploying?
deploying = false;
Expand Down Expand Up @@ -140,7 +140,7 @@ export class DeployApplicationDeployer {
);

this.inputStream = new Subject<string>();
this.messages = websocketConnect(streamUrl)
const buffer = websocketConnect(streamUrl)
.pipe(
switchMap((get) => get(this.inputStream)),
catchError(e => {
Expand All @@ -158,7 +158,16 @@ export class DeployApplicationDeployer {
map((log) => log.message),
share(),
);
this.msgSub = this.messages.subscribe();

// Buffer messges until each newline character
let b = '';
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I think you could have achieved something similar with

share(),
bufferWhen(m => m.endsWith('\n'))),
map(parts => parts.join(''))

this.msgSub = buffer.subscribe(m => {
b = b + m;
if (b.endsWith('\n')) {
this.messages.next(b);
b = '';
}
});
})
).subscribe();

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ <h1>{{ getTitle() }}</h1>
<app-deploy-application-options-step #step4></app-deploy-application-options-step>
</app-step>
<app-step [title]="deployButtonText" [valid]="step3.valid$ | async" [canClose]="step3.closeable$ | async"
disablePrevious=true cancelButtonText="Close" [onEnter]="step3.onEnter" [onNext]="step3.onNext" [blocked]="step3.busy"
disablePrevious=true cancelButtonText="Close" [onEnter]="step3.onEnter" [onNext]="step3.onNext" [showBusy]="step3.busy"
finishButtonText="Go to App Summary">
<app-deploy-application-step3 [appGuid]="appGuid" #step3></app-deploy-application-step3>
</app-step>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -90,6 +90,9 @@ export class StepComponent {
@Input()
skip = false;

@Input()
showBusy = false;

@Input()
onNext: StepOnNextFunction = () => observableOf({ success: true })

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -3,11 +3,11 @@
<div class="steppers__inner">
<div class="steppers__headers" *ngIf="steps.length > 1">
<div *ngFor="let step of steps; let i = index"
[ngClass]="{'steppers__header--active': step.active, 'steppers__header--busy': step.blocked}"
[ngClass]="{'steppers__header--active': step.active, 'steppers__header--busy': step.blocked || step.showBusy}"
class="steppers__header">
<div class="steppers__header-inner" *ngIf="steps.length !== 1">
<!-- Blocked -->
<mat-spinner *ngIf="step.blocked; else notBlocked" diameter="20"></mat-spinner>
<mat-spinner *ngIf="(step.blocked || step.showBusy); else notBlocked" diameter="20"></mat-spinner>
<!-- Not Blocked -->
<ng-template #notBlocked>
<app-dot-content [disabled]="step.skip">
Expand Down
25 changes: 22 additions & 3 deletions src/jetstream/go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -5,14 +5,21 @@ go 1.12
require (
bitbucket.org/liamstask/goose v0.0.0-20150115234039-8488cc47d90c
code.cloudfoundry.org/bytefmt v0.0.0-20180906201452-2aa6f33b730c // indirect
code.cloudfoundry.org/cli v6.43.0+incompatible
code.cloudfoundry.org/cfnetworking-cli-api v0.0.0-20190103195135-4b04f26287a6 // indirect
code.cloudfoundry.org/cli v6.49.0+incompatible
code.cloudfoundry.org/diego-ssh v0.0.0-20200312183824-517d22c5d890 // indirect
code.cloudfoundry.org/gofileutils v0.0.0-20170111115228-4d0c80011a0f // indirect
code.cloudfoundry.org/inigo v0.0.0-20200318144131-597cd5dbfe8b // indirect
code.cloudfoundry.org/lager v2.0.0+incompatible // indirect
code.cloudfoundry.org/ykk v0.0.0-20170424192843-e4df4ce2fd4d // indirect
github.com/Azure/go-ansiterm v0.0.0-20170929234023-d6e3b3328b78 // indirect
github.com/SermoDigital/jose v0.9.1
github.com/SermoDigital/jose v0.9.1 // indirect
github.com/Sirupsen/logrus v0.0.0-00010101000000-000000000000 // indirect
github.com/antonlindstrom/pgstore v0.0.0-20170604072116-a407030ba6d0
github.com/apoydence/eachers v0.0.0-20181020210610-23942921fe77 // indirect
github.com/blang/semver v3.5.1+incompatible // indirect
github.com/bmatcuk/doublestar v1.1.1 // indirect
github.com/bmizerany/pat v0.0.0-20170815010413-6226ea591a40 // indirect
github.com/cf-stratos/mysqlstore v0.0.0-20170822100912-304308519d13
github.com/charlievieth/fs v0.0.0-20170613215519-7dc373669fa1 // indirect
github.com/cloudfoundry-community/go-cfenv v1.17.0
Expand All @@ -24,13 +31,18 @@ require (
github.com/cppforlife/go-patch v0.2.0 // indirect
github.com/cyphar/filepath-securejoin v0.2.2 // indirect
github.com/dgrijalva/jwt-go v3.2.0+incompatible // indirect
github.com/docker/distribution v2.7.1+incompatible // indirect
github.com/docker/docker v1.13.1 // indirect
github.com/domodwyer/mailyak v3.1.1+incompatible
github.com/dsnet/compress v0.0.0-20171208185109-cc9eb1d7ad76 // indirect
github.com/elazarl/goproxy v0.0.0-20200315184450-1f3cb6622dad // indirect
github.com/elazarl/goproxy/ext v0.0.0-20200315184450-1f3cb6622dad // indirect
github.com/fatih/color v1.7.0 // indirect
github.com/go-sql-driver/mysql v1.4.1
github.com/gogo/protobuf v1.2.1 // indirect
github.com/golang/snappy v0.0.1 // indirect
github.com/google/go-querystring v1.0.0 // indirect
github.com/google/martian v2.1.0+incompatible // indirect
github.com/gopherjs/gopherjs v0.0.0-20190411002643-bd77b112433e // indirect
github.com/gorilla/context v1.1.1
github.com/gorilla/securecookie v1.1.1
Expand All @@ -40,7 +52,8 @@ require (
github.com/jessevdk/go-flags v1.4.0 // indirect
github.com/jtolds/gls v4.20.0+incompatible // indirect
github.com/kat-co/vala v0.0.0-20170210184112-42e1d8b61f12
github.com/kubeapps/common v0.0.0-20181107174310-61d8eb6f11b4
github.com/kr/pty v1.1.8 // indirect
github.com/kubeapps/common v0.0.0-20181107174310-61d8eb6f11b4 // indirect
github.com/kylelemons/go-gypsy v0.0.0-20160905020020-08cad365cd28 // indirect
github.com/labstack/echo v3.3.10+incompatible
github.com/labstack/gommon v0.3.0 // indirect
Expand All @@ -59,12 +72,18 @@ require (
github.com/nwmac/sqlitestore v0.0.0-20180824125213-7d2ab221fb3f
github.com/onsi/ginkgo v1.11.0 // indirect
github.com/onsi/gomega v1.8.1 // indirect
github.com/opencontainers/go-digest v1.0.0-rc1 // indirect
github.com/pierrec/lz4 v2.0.5+incompatible // indirect
github.com/pkg/errors v0.8.1 // indirect
github.com/poy/eachers v0.0.0-20181020210610-23942921fe77 // indirect
github.com/sabhiram/go-gitignore v0.0.0-20180611051255-d3107576ba94 // indirect
github.com/sajari/fuzzy v1.0.0 // indirect
github.com/satori/go.uuid v1.2.0
github.com/sirupsen/logrus v1.3.0
github.com/smartystreets/assertions v0.0.0-20190401211740-f487f9de1cd3 // indirect
github.com/smartystreets/goconvey v0.0.0-20190222223459-a17d461953aa
github.com/tedsuo/ifrit v0.0.0-20191009134036-9a97d0632f00 // indirect
github.com/tedsuo/rata v1.0.0 // indirect
github.com/ulikunitz/xz v0.5.6 // indirect
github.com/valyala/fasttemplate v1.1.0 // indirect
github.com/vito/go-interact v0.0.0-20171111012221-fa338ed9e9ec // indirect
Expand Down
Loading