new aggregations UI

designer/client/cypress/e2e/aggregations.cy.ts

@@ -0,0 +1,30 @@
+describe("Aggregations", () => {
+    const seed = "aggregations";
+
+    before(() => {
+        cy.deleteAllTestProcesses({
+            filter: seed,
+            force: true,
+        });
+    });
+
+    after(() => {
+        cy.deleteAllTestProcesses({ filter: seed });
+    });
+
+    ["aggregate-sliding", "aggregate-tumbling", "aggregate-session"].forEach((component) => {
+        it(`should display updated UI for ${component}`, () => {
+            cy.visitNewProcess(seed, "aggregations", "Default");
+            cy.getNode(component).dblclick();
+            cy.get("[data-testid=window]").should("be.visible");
+            cy.get("[title='Aggregations']")
+                .parent()
+                .should("be.visible")
+                .matchImage({
+                    screenshotConfig: {
+                        padding: [80, 10, 10, 10],
+                    },
+                });
+        });
+    });
+});

designer/client/cypress/e2e/jsonEditor.cy.ts

@@ -15,7 +15,7 @@ describe("JSON editor", () => {
             .should("be.enabled")
             .click();
         cy.get("[data-testid=window]").as("modal");
-        cy.get("[title='Input schema']").next().find(".ace_editor").should("be.visible").as("editor");
+        cy.get("[title='Input schema']").next().find(".ace_editor").should("be.visible").parent().as("editor");
 
         cy.get("@editor").matchImage({
             maxDiffThreshold: 0.0025,

designer/client/cypress/e2e/sqlEditor.cy.ts

@@ -15,7 +15,9 @@ describe("Sql editor", () => {
         cy.layoutScenario();
         cy.get("[model-id=sql-source]").should("be.visible").trigger("dblclick");
         cy.get("[data-testid=window]").should("be.visible");
-        cy.get("#ace-editor").should("not.have.class", "tokenizer-working").parent().matchImage({ maxDiffThreshold });
+        cy.get("#ace-editor").should("not.have.class", "tokenizer-working");
+        cy.wait(1000);
+        cy.get("#ace-editor").parent().matchImage({ maxDiffThreshold });
         cy.get("[data-testid=window]").matchImage();
     });
 
@@ -26,7 +28,9 @@ describe("Sql editor", () => {
 
         cy.wrap(["sql-source", "sql-source2", "sql-source3"]).each((name) => {
             cy.get(`[model-id=${name}]`).should("be.visible").trigger("dblclick");
-            cy.get("#ace-editor").should("not.have.class", "tokenizer-working").parent().matchImage({ maxDiffThreshold });
+            cy.get("#ace-editor").should("not.have.class", "tokenizer-working");
+            cy.wait(1000);
+            cy.get("#ace-editor").parent().matchImage({ maxDiffThreshold });
             cy.get("[data-testid=window]")
                 .contains(/^cancel$/i)
                 .click();

designer/client/cypress/fixtures/aggregations.json

@@ -0,0 +1,283 @@
+{
+    "metaData": {
+        "id": "test",
+        "additionalFields": {
+            "description": null,
+            "properties": {
+                "parallelism": "1",
+                "spillStateToDisk": "true",
+                "useAsyncInterpretation": "",
+                "checkpointIntervalInSeconds": ""
+            },
+            "metaDataType": "StreamMetaData",
+            "showDescription": false
+        }
+    },
+    "nodes": [
+        {
+            "id": "periodic",
+            "ref": {
+                "typ": "periodic",
+                "parameters": [
+                    {
+                        "name": "period",
+                        "expression": {
+                            "language": "spel",
+                            "expression": "T(java.time.Duration).parse('PT1M')"
+                        }
+                    },
+                    {
+                        "name": "count",
+                        "expression": {
+                            "language": "spel",
+                            "expression": "1"
+                        }
+                    },
+                    {
+                        "name": "value",
+                        "expression": {
+                            "language": "spel",
+                            "expression": "1"
+                        }
+                    }
+                ]
+            },
+            "additionalFields": {
+                "description": null,
+                "layoutData": {
+                    "x": 360,
+                    "y": 0
+                }
+            },
+            "type": "Source"
+        },
+        {
+            "nexts": [
+                [
+                    {
+                        "id": "aggregate-session",
+                        "outputVar": "outputVar",
+                        "nodeType": "aggregate-session",
+                        "parameters": [
+                            {
+                                "name": "groupBy",
+                                "expression": {
+                                    "language": "spel",
+                                    "expression": "{ #input.floatValue }.toString"
+                                }
+                            },
+                            {
+                                "name": "aggregator",
+                                "expression": {
+                                    "language": "spel",
+                                    "expression": "#AGG.map({\n  count: #AGG.sum\n})"
+                                }
+                            },
+                            {
+                                "name": "aggregateBy",
+                                "expression": {
+                                    "language": "spel",
+                                    "expression": "{\n  count: 1\n}"
+                                }
+                            },
+                            {
+                                "name": "endSessionCondition",
+                                "expression": {
+                                    "language": "spel",
+                                    "expression": "true"
+                                }
+                            },
+                            {
+                                "name": "sessionTimeout",
+                                "expression": {
+                                    "language": "spel",
+                                    "expression": "T(java.time.Duration).parse('PT1H')"
+                                }
+                            },
+                            {
+                                "name": "emitWhen",
+                                "expression": {
+                                    "language": "spel",
+                                    "expression": "T(pl.touk.nussknacker.engine.flink.util.transformer.aggregate.SessionWindowTrigger).OnEvent"
+                                }
+                            }
+                        ],
+                        "additionalFields": {
+                            "description": null,
+                            "layoutData": {
+                                "x": 720,
+                                "y": 360
+                            }
+                        },
+                        "type": "CustomNode"
+                    },
+                    {
+                        "id": "dead-end",
+                        "ref": {
+                            "typ": "dead-end",
+                            "parameters": []
+                        },
+                        "endResult": null,
+                        "isDisabled": null,
+                        "additionalFields": {
+                            "description": null,
+                            "layoutData": {
+                                "x": 720,
+                                "y": 540
+                            }
+                        },
+                        "type": "Sink"
+                    }
+                ],
+                [
+                    {
+                        "id": "aggregate-sliding",
+                        "outputVar": "outputVar",
+                        "nodeType": "aggregate-sliding",
+                        "parameters": [
+                            {
+                                "name": "groupBy",
+                                "expression": {
+                                    "language": "spel",
+                                    "expression": "{ #input.longValue }.toString"
+                                }
+                            },
+                            {
+                                "name": "aggregator",
+                                "expression": {
+                                    "language": "spel",
+                                    "expression": "#AGG.map({\n  count: #AGG.sum\n})"
+                                }
+                            },
+                            {
+                                "name": "aggregateBy",
+                                "expression": {
+                                    "language": "spel",
+                                    "expression": "{\n  count: 1\n}"
+                                }
+                            },
+                            {
+                                "name": "windowLength",
+                                "expression": {
+                                    "language": "spel",
+                                    "expression": "T(java.time.Duration).parse('PT1H')"
+                                }
+                            },
+                            {
+                                "name": "emitWhenEventLeft",
+                                "expression": {
+                                    "language": "spel",
+                                    "expression": "false"
+                                }
+                            }
+                        ],
+                        "additionalFields": {
+                            "description": null,
+                            "layoutData": {
+                                "x": 0,
+                                "y": 360
+                            }
+                        },
+                        "type": "CustomNode"
+                    },
+                    {
+                        "id": "dead-end 1",
+                        "ref": {
+                            "typ": "dead-end",
+                            "parameters": []
+                        },
+                        "endResult": null,
+                        "isDisabled": null,
+                        "additionalFields": {
+                            "description": null,
+                            "layoutData": {
+                                "x": 0,
+                                "y": 540
+                            }
+                        },
+                        "type": "Sink"
+                    }
+                ],
+                [
+                    {
+                        "id": "aggregate-tumbling",
+                        "outputVar": "outputVar",
+                        "nodeType": "aggregate-tumbling",
+                        "parameters": [
+                            {
+                                "name": "groupBy",
+                                "expression": {
+                                    "language": "spel",
+                                    "expression": "{ #input.longValue }.toString"
+                                }
+                            },
+                            {
+                                "name": "aggregator",
+                                "expression": {
+                                    "language": "spel",
+                                    "expression": "#AGG.map({\n  count: #AGG.sum\n})"
+                                }
+                            },
+                            {
+                                "name": "aggregateBy",
+                                "expression": {
+                                    "language": "spel",
+                                    "expression": "{\n  count: 1\n}"
+                                }
+                            },
+                            {
+                                "name": "windowLength",
+                                "expression": {
+                                    "language": "spel",
+                                    "expression": "T(java.time.Duration).parse('PT1H')"
+                                }
+                            },
+                            {
+                                "name": "emitWhen",
+                                "expression": {
+                                    "language": "spel",
+                                    "expression": "T(pl.touk.nussknacker.engine.flink.util.transformer.aggregate.TumblingWindowTrigger).OnEvent"
+                                }
+                            }
+                        ],
+                        "additionalFields": {
+                            "description": null,
+                            "layoutData": {
+                                "x": 360,
+                                "y": 360
+                            }
+                        },
+                        "type": "CustomNode"
+                    },
+                    {
+                        "id": "dead-end 2",
+                        "ref": {
+                            "typ": "dead-end",
+                            "parameters": []
+                        },
+                        "endResult": null,
+                        "isDisabled": null,
+                        "additionalFields": {
+                            "description": null,
+                            "layoutData": {
+                                "x": 360,
+                                "y": 540
+                            }
+                        },
+                        "type": "Sink"
+                    }
+                ]
+            ],
+            "id": "split",
+            "additionalFields": {
+                "description": null,
+                "layoutData": {
+                    "x": 360,
+                    "y": 180
+                }
+            },
+            "type": "Split"
+        }
+    ],
+    "additionalBranches": []
+}