This is an automated email from the ASF dual-hosted git repository.
riemer pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git
The following commit(s) were added to refs/heads/dev by this push:
new 71b4c5f [hotfix] Fix adapter preview in UI
71b4c5f is described below
commit 71b4c5feae4c94c67c8715bc899f0236c60b547a
Author: Dominik Riemer <[email protected]>
AuthorDate: Tue Feb 23 20:38:27 2021 +0100
[hotfix] Fix adapter preview in UI
---
.../dialog/adapter-started/adapter-started-dialog.component.ts | 4 ++--
ui/src/app/connect/services/rest.service.ts | 6 +++---
2 files changed, 5 insertions(+), 5 deletions(-)
diff --git
a/ui/src/app/connect/dialog/adapter-started/adapter-started-dialog.component.ts
b/ui/src/app/connect/dialog/adapter-started/adapter-started-dialog.component.ts
index 9c301ba..f443c49 100644
---
a/ui/src/app/connect/dialog/adapter-started/adapter-started-dialog.component.ts
+++
b/ui/src/app/connect/dialog/adapter-started/adapter-started-dialog.component.ts
@@ -86,7 +86,7 @@ export class AdapterStartedDialog {
this.isSetAdapter = true;
} else {
this.restService.getSourceDetails(x.notifications[0].title).subscribe(x => {
- this.streamDescription = x.spDataStreams[0];
+ this.streamDescription = x;
this.pollingActive = true;
});
}
@@ -127,4 +127,4 @@ export class AdapterStartedDialog {
this.ShepherdService.trigger("confirm_adapter_started_button");
}
-}
\ No newline at end of file
+}
diff --git a/ui/src/app/connect/services/rest.service.ts
b/ui/src/app/connect/services/rest.service.ts
index 55a5a94..70d1330 100644
--- a/ui/src/app/connect/services/rest.service.ts
+++ b/ui/src/app/connect/services/rest.service.ts
@@ -32,7 +32,7 @@ import {
FormatDescriptionList,
GuessSchema,
Message,
- ProtocolDescriptionList
+ ProtocolDescriptionList, SpDataStream
} from "../../core-model/gen/streampipes-model";
@Injectable()
@@ -79,10 +79,10 @@ export class RestService {
}
- getSourceDetails(sourceElementId): Observable<DataSourceDescription> {
+ getSourceDetails(sourceElementId): Observable<SpDataStream> {
return this.http
.get(this.makeUserDependentBaseUrl() + '/streams/' +
encodeURIComponent(sourceElementId)).pipe(map(response => {
- return DataSourceDescription.fromData(response as
DataSourceDescription);
+ return SpDataStream.fromData(response as SpDataStream);
}));
}