fix error with new pipeline creation after editing, show normal forbi…

…dden error

src/pages/pipeline/index.js

@@ -1,7 +1,7 @@
 import React from 'react';
 import {RxState} from '../../stores/util';
 import PipelineEditor from '../../components/pipelineEditor';
-import pipelineStore, {getPipeline} from '../../stores/pipeline';
+import pipelineStore, {getPipeline, newPipeline} from '../../stores/pipeline';
 
 const Pipeline = React.createClass({
     mixins: [RxState],
@@ -29,6 +29,7 @@ const Pipeline = React.createClass({
     updatePipeline(props) {
         // clear if new route
         if (props.params.user === 'new') {
+            newPipeline();
             return;
         }
         // if user and component name present - get component from server
@@ -43,6 +44,18 @@ const Pipeline = React.createClass({
     },
 
     render() {
+        if (this.state.pipeline && this.state.pipeline.error) {
+            return (
+                <div className="row">
+                    <div className="col-xs-6 col-xs-offset-3 text-center">
+                        <h4>{this.state.pipeline.error === 'Forbidden' ? (
+                            `Looks like you don't have rights to see this!`
+                        ) : this.state.pipeline.error}</h4>
+                    </div>
+                </div>
+            );
+        }
+
         return <PipelineEditor {...this.state.pipeline} />;
     },
 });

src/stores/pipeline/get.js

@@ -18,7 +18,7 @@ const stream = getPipeline.$
         .map(res => res.body)
         .catch(e => {
             createNotification({type: 'danger', message: e.message});
-            return Observable.return([]);
+            return Observable.return({error: e.message});
         })
     )
     .map(data => fromJS({

src/stores/pipeline/index.js

@@ -12,6 +12,7 @@ import logStream, {getPipelineLog} from './getLog';
 import getStream, {getPipeline} from './get';
 import statusStream, {pipelineStatus} from './status';
 import deleteStream, {deletePipeline} from './delete';
+import newStream, {newPipeline} from './new';
 
 // create bus
 const pipelinesSubject = new ReplaySubject(1);
@@ -26,6 +27,7 @@ stopStream.subscribe(pipelinesSubject);
 getStream.subscribe(pipelinesSubject);
 statusStream.subscribe(pipelinesSubject);
 deleteStream.subscribe(pipelinesSubject);
+newStream.subscribe(pipelinesSubject);
 
 // create result store stream
 const pipelines = pipelinesSubject
@@ -44,5 +46,6 @@ export {
     getPipeline,
     pipelineStatus,
     deletePipeline,
+    newPipeline,
 };
 export default pipelines;

src/stores/pipeline/new.js

@@ -0,0 +1,16 @@
+import {fromJS} from 'immutable';
+import {createAction} from '../util';
+
+const newPipeline = createAction();
+
+const stream = newPipeline.$
+    .map(() => fromJS({
+        pipeline: {
+            id: undefined,
+            name: 'My new pipeline',
+            isPublic: false,
+        },
+    }));
+
+export {newPipeline};
+export default stream;