You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ri...@apache.org on 2023/02/21 08:47:37 UTC
[streampipes] branch 1333-endpoint-to-receive-pipelines-is-broken updated: Rename endpoint to fetch all pipelines from API (#1333)
This is an automated email from the ASF dual-hosted git repository.
riemer pushed a commit to branch 1333-endpoint-to-receive-pipelines-is-broken
in repository https://gitbox.apache.org/repos/asf/streampipes.git
The following commit(s) were added to refs/heads/1333-endpoint-to-receive-pipelines-is-broken by this push:
new e4bcf07ac Rename endpoint to fetch all pipelines from API (#1333)
e4bcf07ac is described below
commit e4bcf07ac64baa7aa942d89e9e63b08d7f33b810
Author: Dominik Riemer <do...@gmail.com>
AuthorDate: Tue Feb 21 09:46:50 2023 +0100
Rename endpoint to fetch all pipelines from API (#1333)
---
.../java/org/apache/streampipes/client/api/PipelineApi.java | 2 +-
.../platform-services/src/lib/apis/pipeline.service.ts | 12 ++----------
ui/src/app/assets/dialog/base-asset-links.directive.ts | 2 +-
ui/src/app/home/components/status.component.ts | 2 +-
ui/src/app/notifications/notifications.component.ts | 2 +-
ui/src/app/pipelines/pipelines.component.ts | 2 +-
6 files changed, 7 insertions(+), 15 deletions(-)
diff --git a/streampipes-client/src/main/java/org/apache/streampipes/client/api/PipelineApi.java b/streampipes-client/src/main/java/org/apache/streampipes/client/api/PipelineApi.java
index c49e2511a..c599fee2d 100644
--- a/streampipes-client/src/main/java/org/apache/streampipes/client/api/PipelineApi.java
+++ b/streampipes-client/src/main/java/org/apache/streampipes/client/api/PipelineApi.java
@@ -43,7 +43,7 @@ public class PipelineApi extends AbstractTypedClientApi<Pipeline> implements CRU
*/
@Override
public List<Pipeline> all() {
- return getAll(getBaseResourcePath().addToPath("own"));
+ return getAll(getBaseResourcePath());
}
@Override
diff --git a/ui/projects/streampipes/platform-services/src/lib/apis/pipeline.service.ts b/ui/projects/streampipes/platform-services/src/lib/apis/pipeline.service.ts
index 734a7c1a3..5a11c93a8 100644
--- a/ui/projects/streampipes/platform-services/src/lib/apis/pipeline.service.ts
+++ b/ui/projects/streampipes/platform-services/src/lib/apis/pipeline.service.ts
@@ -116,8 +116,8 @@ export class PipelineService {
);
}
- getOwnPipelines(): Observable<Pipeline[]> {
- return this.http.get(`${this.apiBasePath}/pipelines/own`).pipe(
+ getPipelines(): Observable<Pipeline[]> {
+ return this.http.get(`${this.apiBasePath}/pipelines`).pipe(
map(response => {
return (response as any[]).map(p => Pipeline.fromData(p));
}),
@@ -128,14 +128,6 @@ export class PipelineService {
return this.http.delete(`${this.apiBasePath}/pipelines/${pipelineId}`);
}
- getSystemPipelines(): Observable<Pipeline[]> {
- return this.http.get(`${this.apiBasePath}/pipelines/system`).pipe(
- map(response => {
- return (response as any[]).map(p => Pipeline.fromData(p));
- }),
- );
- }
-
getPipelineStatusById(pipelineId): Observable<PipelineStatusMessage[]> {
return this.http
.get(`${this.apiBasePath}/pipelines/${pipelineId}/status`)
diff --git a/ui/src/app/assets/dialog/base-asset-links.directive.ts b/ui/src/app/assets/dialog/base-asset-links.directive.ts
index 6c29c9ece..b7ec09568 100644
--- a/ui/src/app/assets/dialog/base-asset-links.directive.ts
+++ b/ui/src/app/assets/dialog/base-asset-links.directive.ts
@@ -65,7 +65,7 @@ export abstract class BaseAssetLinksDirective {
getAllResources() {
zip(
- this.pipelineService.getOwnPipelines(),
+ this.pipelineService.getPipelines(),
this.dataViewService.getDataViews(),
this.dashboardService.getDashboards(),
this.pipelineElementService.getDataStreams(),
diff --git a/ui/src/app/home/components/status.component.ts b/ui/src/app/home/components/status.component.ts
index 4963dc5d9..08f491a00 100644
--- a/ui/src/app/home/components/status.component.ts
+++ b/ui/src/app/home/components/status.component.ts
@@ -53,7 +53,7 @@ export class StatusComponent implements OnInit {
}
getPipelines() {
- this.pipelineService.getOwnPipelines().subscribe(pipelines => {
+ this.pipelineService.getPipelines().subscribe(pipelines => {
this.pipelines = pipelines.length;
this.runningPipelines = pipelines.filter(p => p.running).length;
});
diff --git a/ui/src/app/notifications/notifications.component.ts b/ui/src/app/notifications/notifications.component.ts
index 515885c95..e7d02be34 100644
--- a/ui/src/app/notifications/notifications.component.ts
+++ b/ui/src/app/notifications/notifications.component.ts
@@ -167,7 +167,7 @@ export class NotificationsComponent implements OnInit, OnDestroy {
getPipelinesWithNotifications() {
this.notificationsLoading = true;
- this.pipelineService.getOwnPipelines().subscribe(pipelines => {
+ this.pipelineService.getPipelines().subscribe(pipelines => {
this.existingNotifications =
this.getAllExistingNotifications(pipelines);
this.notificationsLoading = false;
diff --git a/ui/src/app/pipelines/pipelines.component.ts b/ui/src/app/pipelines/pipelines.component.ts
index d5ceba5de..69d5994da 100644
--- a/ui/src/app/pipelines/pipelines.component.ts
+++ b/ui/src/app/pipelines/pipelines.component.ts
@@ -124,7 +124,7 @@ export class PipelinesComponent implements OnInit {
getPipelines() {
this.pipelines = [];
- this.pipelineService.getOwnPipelines().subscribe(pipelines => {
+ this.pipelineService.getPipelines().subscribe(pipelines => {
this.pipelines = pipelines;
this.checkForImmediateStart(pipelines);
this.pipelinesReady = true;