feat: add expand and flatten

Signed-off-by: Alex Collins <[email protected]>

go.mod

@@ -12,7 +12,7 @@ require (
  github.com/TwinProduction/go-color v0.0.3
  github.com/aliyun/aliyun-oss-go-sdk v2.1.5+incompatible
  github.com/antonmedv/expr v1.8.9
- github.com/argoproj-labs/argo-dataflow v0.0.8
+ github.com/argoproj-labs/argo-dataflow v0.0.9
  github.com/argoproj/argo-events v1.2.0
  github.com/argoproj/pkg v0.8.1
  github.com/baiyubin/aliyun-sts-go-sdk v0.0.0-20180326062324-cfa1a18b161f // indirect

go.sum

@@ -130,6 +130,8 @@ github.com/ardielle/ardielle-go v1.5.2/go.mod h1:I4hy1n795cUhaVt/ojz83SNVCYIGsAF
 github.com/ardielle/ardielle-tools v1.5.4/go.mod h1:oZN+JRMnqGiIhrzkRN9l26Cej9dEx4jeNG6A+AdkShk=
 github.com/argoproj-labs/argo-dataflow v0.0.8 h1:11zr8P3qMTTyyys01bJbqrHiX5SnEaWIsuw5iFfKiK0=
 github.com/argoproj-labs/argo-dataflow v0.0.8/go.mod h1:85K86NqyK8WH+Efa8Iinh7jU8r1daKPtuTDJsZeX1KI=
+github.com/argoproj-labs/argo-dataflow v0.0.9 h1:GcfxD6uVGx2rbd/ZIcD+W6jpsANh/uKTUSfWoB1qlTA=
+github.com/argoproj-labs/argo-dataflow v0.0.9/go.mod h1:1toXoRvFZm0LgQfupTo5aT6MgOx8FE3h2XIBCrEu+Ls=
 github.com/argoproj/argo-events v1.2.0 h1:CjF8hVUkeflhaOt9uWjJK6ai6b4pw0CCUUmOnmhWnNY=
 github.com/argoproj/argo-events v1.2.0/go.mod h1:eY+egQNBLXAz/AF4mqgHsMMa4Aur7frHjUfBg+RpX04=
 github.com/argoproj/pkg v0.8.1 h1:9h/sqAjUNyk0LaHkXR+2h94KNcSchvFX5aELNjXSOoc=

ui/src/app/pipelines/components/pipeline-details/pipeline-details.tsx

@@ -120,7 +120,9 @@ export const PipelineDetails = ({history, match, location}: RouteComponentProps<
  cat: true,
  container: true,
  cron: true,
+ expand: true,
  filter: true,
+ flatten: true,
  git: true,
  group: true,
  handler: true,

ui/src/app/pipelines/components/pipeline-details/pipeline-graph.ts

@@ -3,16 +3,20 @@ import {Step} from '../../../../models/step';
 import {Graph} from '../../../shared/components/graph/types';
 import {Icon} from '../../../shared/components/icon';
 
-type Type = '' | 'cat' | 'container' | 'filter' | 'git' | 'group' | 'handler' | 'map';
+type Type = '' | 'cat' | 'container' | 'expand' | 'filter' | 'flatten' | 'git' | 'group' | 'handler' | 'map';
 
 const stepIcon = (type: Type): Icon => {
  switch (type) {
  case 'cat':
  return 'arrows-alt-h';
  case 'container':
  return 'cube';
+ case 'expand':
+ return 'expand';
  case 'filter':
  return 'filter';
+ case 'flatten':
+ return 'compress';
  case 'git':
  return 'code-branch';
  case 'group':
@@ -44,10 +48,14 @@ export const graph = (pipeline: Pipeline, steps: Step[]) => {
  ? 'cat'
  : spec.container
  ? 'container'
+ : spec.expand
+ ? 'expand'
  : spec.filter
  ? 'filter'
  : spec.git
  ? 'git'
+ : spec.flatten
+ ? 'flatten'
  : spec.group
  ? 'group'
  : spec.handler

ui/src/app/shared/components/icon.ts

@@ -8,6 +8,7 @@ export type Icon =
  | 'box'
  | 'calendar'
  | 'cloud'
+ | 'compress'
  | 'cube'
  | 'chevron-circle-right'
  | 'chevron-right'
@@ -24,6 +25,7 @@ export type Icon =
  | 'check'
  | 'database'
  | 'envelope'
+ | 'expand'
  | 'edit'
  | 'ellipsis-h'
  | 'exchange-alt'

ui/src/app/shared/components/icons.ts

@@ -12,6 +12,7 @@ export const icons: {[key: string]: string} = {
  'circle-notch': '\uf1ce',
  'clock': '\uf017',
  'code': '\uf121',
+ 'compress': '\uf066',
  'cube': '\uf1b2',
  'cog': '\uf013',
  'comment': '\uf075',
@@ -22,6 +23,7 @@ export const icons: {[key: string]: string} = {
  'envelope': '\uf0e0',
  'ellipsis-h': '\uf141',
  'exchange-alt': '\uf362',
+ 'expand': '\uf065',
  'file': '\uf15b',
  'file-alt': '\uf15c',
  'file-code': '\uf1c9',

ui/src/models/step.ts

@@ -11,7 +11,9 @@ export interface Step {
  name: string;
  cat?: {};
  container?: {};
+ expand?: {};
  filter?: string;
+ flatten?: {};
  git?: {};
  group?: {};
  handler?: {};