This is an automated email from the ASF dual-hosted git repository. zehnder pushed a commit to branch STREAMPIPES-380 in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git
commit 6d2a9f8932a97640249c138ff7ed14a80511d046 Author: Philipp Zehnder <[email protected]> AuthorDate: Tue Jun 22 15:43:12 2021 +0200 [STREAMPIPES-380] Add apache headers and fix linting issues --- ui/cypress/README.md | 2 +- ui/cypress/integration/adapter/fileStream.ts | 36 +++++++++--- .../integration/adapter/machineDataSimulator.ts | 28 ++++++++-- .../adapter/randomDataSimulatorStream.spec.ts | 28 ++++++++-- .../integration/dataexplorer/testDataExplorer.ts | 11 ---- .../fileManagement/testFileManagement.ts | 28 ++++++++-- ui/cypress/integration/pipeline/pipelineTest.ts | 39 +++++++++---- .../pipelineElement/fieldRenamerTest1.ts | 34 +++++++++--- .../pipelineElement/numericalFilterTest1.ts | 38 +++++++++---- ui/cypress/plugins/index.ts | 18 ++++++ .../support/builder/GenericAdapterBuilder.ts | 25 +++++++-- ui/cypress/support/builder/PipelineBuilder.ts | 23 +++++++- .../support/builder/PipelineElementBuilder.ts | 22 +++++++- .../support/builder/SpecificAdapterBuilder.ts | 24 +++++++- ui/cypress/support/general/dataCy.ts | 22 +++++++- ui/cypress/support/general/login.ts | 22 +++++++- ui/cypress/support/general/logout.ts | 22 +++++++- ui/cypress/support/index.ts | 25 ++++++++- ui/cypress/support/model/AdapterInput.ts | 20 ++++++- ui/cypress/support/model/GenericAdapterInput.ts | 26 +++++++-- ui/cypress/support/model/PipelineElementInput.ts | 22 +++++++- ui/cypress/support/model/PipelineInput.ts | 22 +++++++- ui/cypress/support/model/SpecificAdapterInput.ts | 26 +++++++-- ui/cypress/support/model/UserInput.ts | 18 ++++++ ui/cypress/support/utils/AdapterUtils.ts | 64 ++++++++++++++-------- ui/cypress/support/utils/DataLakeUtils.ts | 26 +++++++-- ui/cypress/support/utils/FileManagementUtils.ts | 42 +++++++++----- ui/cypress/support/utils/PipelineUtils.ts | 49 +++++++++++------ .../support/utils/ProcessingElementTestUtils.ts | 48 +++++++++++----- ui/cypress/support/utils/StaticPropertyUtils.ts | 28 ++++++++-- .../configuration-group.component.css | 18 ++++++ .../configuration-group.component.html | 18 ++++++ .../configuration-group.component.ts | 18 ++++++ .../format-configuration.component.css | 18 ++++++ .../format-configuration.component.html | 18 ++++++ .../format-configuration.component.ts | 18 ++++++ .../generic-adapter-configuration.component.css | 18 ++++++ .../generic-adapter-configuration.component.html | 18 ++++++ .../generic-adapter-configuration.component.ts | 18 ++++++ .../error-message/error-message.component.css | 18 ++++++ .../error-message/error-message.component.html | 18 ++++++ .../error-message/error-message.component.ts | 18 ++++++ .../loading-message/loading-message.component.css | 18 ++++++ .../loading-message/loading-message.component.html | 18 ++++++ .../loading-message/loading-message.component.ts | 18 ++++++ .../schema-editor-header.component.css | 18 ++++++ .../schema-editor-header.component.html | 18 ++++++ .../schema-editor-header.component.ts | 18 ++++++ .../specific-adapter-configuration.component.css | 18 ++++++ .../specific-adapter-configuration.component.html | 18 ++++++ .../specific-adapter-configuration.component.ts | 18 ++++++ .../start-adapter-configuration.component.css | 18 ++++++ .../start-adapter-configuration.component.html | 18 ++++++ .../start-adapter-configuration.component.ts | 18 ++++++ 54 files changed, 1093 insertions(+), 177 deletions(-) diff --git a/ui/cypress/README.md b/ui/cypress/README.md index b598d34..0d3ab5e 100644 --- a/ui/cypress/README.md +++ b/ui/cypress/README.md @@ -26,7 +26,7 @@ This folder contains a WIP framework for automated E2E tests of StreamPipes. npm run test-e2e ``` -**User**: [email protected] **Password**: test1234 +**User**: [email protected] **Password**: test1234 >**Note:** This can be changed in **support/general/login.ts** diff --git a/ui/cypress/integration/adapter/fileStream.ts b/ui/cypress/integration/adapter/fileStream.ts index fea214f..03f809b 100644 --- a/ui/cypress/integration/adapter/fileStream.ts +++ b/ui/cypress/integration/adapter/fileStream.ts @@ -1,10 +1,28 @@ -import {AdapterUtils} from '../../support/utils/AdapterUtils'; -import {FileManagementUtils} from '../../support/utils/FileManagementUtils'; -import {GenericAdapterBuilder} from '../../support/builder/GenericAdapterBuilder'; +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ -describe('Test File Stream Adapter', function () { +import { AdapterUtils } from '../../support/utils/AdapterUtils'; +import { FileManagementUtils } from '../../support/utils/FileManagementUtils'; +import { GenericAdapterBuilder } from '../../support/builder/GenericAdapterBuilder'; - it('Login', function () { +describe('Test File Stream Adapter', () => { + + it('Login', () => { cy.login(); }); @@ -14,11 +32,11 @@ describe('Test File Stream Adapter', function () { .create('File_Stream') .setName('File Stream Adapter Test') .setTimestampProperty('timestamp') - .addProtocolInput('input', 'speed','1') - .addProtocolInput('checkbox', 'replaceTimestamp','check') + .addProtocolInput('input', 'speed', '1') + .addProtocolInput('checkbox', 'replaceTimestamp', 'check') .setFormat('csv') - .addFormatInput('input', 'delimiter',';') - .addFormatInput('checkbox', 'header','check') + .addFormatInput('input', 'delimiter', ';') + .addFormatInput('checkbox', 'header', 'check') .build(); AdapterUtils.testGenericStreamAdapter(adapterInput); diff --git a/ui/cypress/integration/adapter/machineDataSimulator.ts b/ui/cypress/integration/adapter/machineDataSimulator.ts index b04a85d..d5ede86 100644 --- a/ui/cypress/integration/adapter/machineDataSimulator.ts +++ b/ui/cypress/integration/adapter/machineDataSimulator.ts @@ -1,14 +1,32 @@ -import {AdapterUtils} from '../../support/utils/AdapterUtils'; -import {SpecificAdapterBuilder} from '../../support/builder/SpecificAdapterBuilder'; +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ -describe('Test Random Data Simulator Stream Adapter', function () { +import { AdapterUtils } from '../../support/utils/AdapterUtils'; +import { SpecificAdapterBuilder } from '../../support/builder/SpecificAdapterBuilder'; + +describe('Test Random Data Simulator Stream Adapter', () => { const adapterInput = SpecificAdapterBuilder .create('Machine_Data_Simulator') .setName('Machine Data Simulator Test') - .addInput('input', 'wait-time-ms','1000') + .addInput('input', 'wait-time-ms', '1000') .build(); AdapterUtils.testSpecificStreamAdapter(adapterInput); -}); \ No newline at end of file +}); diff --git a/ui/cypress/integration/adapter/randomDataSimulatorStream.spec.ts b/ui/cypress/integration/adapter/randomDataSimulatorStream.spec.ts index 72505a2..5f85aa2 100644 --- a/ui/cypress/integration/adapter/randomDataSimulatorStream.spec.ts +++ b/ui/cypress/integration/adapter/randomDataSimulatorStream.spec.ts @@ -1,14 +1,30 @@ -import {UserInput} from '../../support/model/UserInput'; -import {AdapterUtils} from '../../support/utils/AdapterUtils'; -import {SpecificAdapterInput} from '../../support/model/SpecificAdapterInput'; -import {SpecificAdapterBuilder} from '../../support/builder/SpecificAdapterBuilder'; +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ -describe('Test Random Data Simulator Stream Adapter', function () { +import { AdapterUtils } from '../../support/utils/AdapterUtils'; +import { SpecificAdapterBuilder } from '../../support/builder/SpecificAdapterBuilder'; + +describe('Test Random Data Simulator Stream Adapter', () => { const adapterInput = SpecificAdapterBuilder .create('Random_Data_Simulator_\\(Stream\\)') .setName('Random Data Simulator Adapter Test') - .addInput('input', 'wait-time-ms','1000') + .addInput('input', 'wait-time-ms', '1000') .build(); AdapterUtils.testSpecificStreamAdapter(adapterInput); diff --git a/ui/cypress/integration/dataexplorer/testDataExplorer.ts b/ui/cypress/integration/dataexplorer/testDataExplorer.ts deleted file mode 100644 index bccdc11..0000000 --- a/ui/cypress/integration/dataexplorer/testDataExplorer.ts +++ /dev/null @@ -1,11 +0,0 @@ -import {DataLakeUtils} from '../../support/utils/DataLakeUtils'; - -describe('Test File Management', function () { - it('Login', function () { - cy.login(); - - - }); - - -}); \ No newline at end of file diff --git a/ui/cypress/integration/fileManagement/testFileManagement.ts b/ui/cypress/integration/fileManagement/testFileManagement.ts index 9dbff1a..49ec9c0 100644 --- a/ui/cypress/integration/fileManagement/testFileManagement.ts +++ b/ui/cypress/integration/fileManagement/testFileManagement.ts @@ -1,7 +1,25 @@ -import {FileManagementUtils} from '../../support/utils/FileManagementUtils'; +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ -describe('Test File Management', function () { - it('Login', function () { +import { FileManagementUtils } from '../../support/utils/FileManagementUtils'; + +describe('Test File Management', () => { + it('Login', () => { cy.login(); }); @@ -9,8 +27,8 @@ describe('Test File Management', function () { FileManagementUtils.deleteFile() - it('Logout', function () { + it('Logout', () => { cy.logout(); }); -}); \ No newline at end of file +}); diff --git a/ui/cypress/integration/pipeline/pipelineTest.ts b/ui/cypress/integration/pipeline/pipelineTest.ts index eb53c38..d3bd2a6 100644 --- a/ui/cypress/integration/pipeline/pipelineTest.ts +++ b/ui/cypress/integration/pipeline/pipelineTest.ts @@ -1,12 +1,29 @@ -import {UserInput} from '../../support/model/UserInput'; -import {AdapterUtils} from '../../support/utils/AdapterUtils'; -import {PipelineUtils} from '../../support/utils/PipelineUtils'; -import {PipelineElementBuilder} from '../../support/builder/PipelineElementBuilder'; -import {PipelineBuilder} from '../../support/builder/PipelineBuilder'; +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ -describe('Test Random Data Simulator Stream Adapter', function () { +import { AdapterUtils } from '../../support/utils/AdapterUtils'; +import { PipelineUtils } from '../../support/utils/PipelineUtils'; +import { PipelineElementBuilder } from '../../support/builder/PipelineElementBuilder'; +import { PipelineBuilder } from '../../support/builder/PipelineBuilder'; - it('Login', function () { +describe('Test Random Data Simulator Stream Adapter', () => { + + it('Login', () => { cy.login(); }); @@ -17,16 +34,16 @@ describe('Test Random Data Simulator Stream Adapter', function () { .addSource(adapterName) .addProcessingElement( PipelineElementBuilder.create('field_renamer') - .addInput('drop-down', 'convert-property','timestamp') - .addInput('input', 'field-name','t') + .addInput('drop-down', 'convert-property', 'timestamp') + .addInput('input', 'field-name', 't') .build()) .addSink( PipelineElementBuilder.create('dashboard_sink') - .addInput('input', 'visualization-name','Demo') + .addInput('input', 'visualization-name', 'Demo') .build()) .build(); PipelineUtils.testPipeline(pipelineInput); AdapterUtils.deleteAdapter(); -}); \ No newline at end of file +}); diff --git a/ui/cypress/integration/pipelineElement/fieldRenamerTest1.ts b/ui/cypress/integration/pipelineElement/fieldRenamerTest1.ts index cf81d0d..5d0414b 100644 --- a/ui/cypress/integration/pipelineElement/fieldRenamerTest1.ts +++ b/ui/cypress/integration/pipelineElement/fieldRenamerTest1.ts @@ -1,21 +1,39 @@ -import {ProcessingElementTestUtils} from '../../support/utils/ProcessingElementTestUtils'; -import {PipelineElementBuilder} from '../../support/builder/PipelineElementBuilder'; +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ -describe('Test Field Renamer 1', function () { +import { ProcessingElementTestUtils } from '../../support/utils/ProcessingElementTestUtils'; +import { PipelineElementBuilder } from '../../support/builder/PipelineElementBuilder'; - it('Login', function () { +describe('Test Field Renamer 1', () => { + + it('Login', () => { cy.login(); }); // Config - const testName = 'fieldRenamer1' + const testName = 'fieldRenamer1'; const inputFile = 'pipelineElement/fieldRenamer1/input.csv'; const expectedResultFile = 'pipelineElement/fieldRenamer1/expected.csv'; const processor = PipelineElementBuilder.create('field_renamer') - .addInput('drop-down', 'convert-property','count') - .addInput('input', 'field-name','newname') + .addInput('drop-down', 'convert-property', 'count') + .addInput('input', 'field-name', 'newname') .build(); ProcessingElementTestUtils.testElement(testName, inputFile, expectedResultFile, processor); -}); \ No newline at end of file +}); diff --git a/ui/cypress/integration/pipelineElement/numericalFilterTest1.ts b/ui/cypress/integration/pipelineElement/numericalFilterTest1.ts index e67d40f..1e18773 100644 --- a/ui/cypress/integration/pipelineElement/numericalFilterTest1.ts +++ b/ui/cypress/integration/pipelineElement/numericalFilterTest1.ts @@ -1,24 +1,40 @@ -import {UserInput} from '../../support/model/UserInput'; -import {PipelineElementInput} from '../../support/model/PipelineElementInput'; -import {ProcessingElementTestUtils} from '../../support/utils/ProcessingElementTestUtils'; -import {PipelineElementBuilder} from '../../support/builder/PipelineElementBuilder'; +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ -describe('Test Numerical Filter 1', function () { +import { ProcessingElementTestUtils } from '../../support/utils/ProcessingElementTestUtils'; +import { PipelineElementBuilder } from '../../support/builder/PipelineElementBuilder'; - it('Login', function () { +describe('Test Numerical Filter 1', () => { + + it('Login', () => { cy.login(); }); // Config - const testName = 'numericalFilter1' + const testName = 'numericalFilter1'; const inputFile = 'pipelineElement/numericalFilter1/input.csv'; const expectedResultFile = 'pipelineElement/numericalFilter1/expected.csv'; const processor = PipelineElementBuilder.create('numerical_filter') - .addInput('drop-down', 'number-mapping','randomnumber') - .addInput('radio', 'operation','\\>') - .addInput('input', 'value','50') + .addInput('drop-down', 'number-mapping', 'randomnumber') + .addInput('radio', 'operation', '\\>') + .addInput('input', 'value', '50') .build(); ProcessingElementTestUtils.testElement(testName, inputFile, expectedResultFile, processor); -}); \ No newline at end of file +}); diff --git a/ui/cypress/plugins/index.ts b/ui/cypress/plugins/index.ts index 6fbea7f..d1af6b8 100644 --- a/ui/cypress/plugins/index.ts +++ b/ui/cypress/plugins/index.ts @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + // *********************************************************** // This example plugins/index.js can be used to load plugins // diff --git a/ui/cypress/support/builder/GenericAdapterBuilder.ts b/ui/cypress/support/builder/GenericAdapterBuilder.ts index fbac9f8..d496758 100644 --- a/ui/cypress/support/builder/GenericAdapterBuilder.ts +++ b/ui/cypress/support/builder/GenericAdapterBuilder.ts @@ -1,6 +1,23 @@ -import {UserInput} from '../model/UserInput'; -import {SpecificAdapterInput} from '../model/SpecificAdapterInput'; -import {GenericAdapterInput} from '../model/GenericAdapterInput'; +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + +import { UserInput } from '../model/UserInput'; +import { GenericAdapterInput } from '../model/GenericAdapterInput'; export class GenericAdapterBuilder { genericAdapterInput: GenericAdapterInput; @@ -56,4 +73,4 @@ export class GenericAdapterBuilder { build() { return this.genericAdapterInput; } -} \ No newline at end of file +} diff --git a/ui/cypress/support/builder/PipelineBuilder.ts b/ui/cypress/support/builder/PipelineBuilder.ts index 9bba754..a65bf5b 100644 --- a/ui/cypress/support/builder/PipelineBuilder.ts +++ b/ui/cypress/support/builder/PipelineBuilder.ts @@ -1,6 +1,23 @@ -import {UserInput} from '../model/UserInput'; -import {PipelineInput} from '../model/PipelineInput'; -import {PipelineElementInput} from '../model/PipelineElementInput'; +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + +import { PipelineInput } from '../model/PipelineInput'; +import { PipelineElementInput } from '../model/PipelineElementInput'; export class PipelineBuilder { pipeline: PipelineInput; diff --git a/ui/cypress/support/builder/PipelineElementBuilder.ts b/ui/cypress/support/builder/PipelineElementBuilder.ts index 805e2db..09c13da 100644 --- a/ui/cypress/support/builder/PipelineElementBuilder.ts +++ b/ui/cypress/support/builder/PipelineElementBuilder.ts @@ -1,5 +1,23 @@ -import {UserInput} from '../model/UserInput'; -import {PipelineElementInput} from '../model/PipelineElementInput'; +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + +import { UserInput } from '../model/UserInput'; +import { PipelineElementInput } from '../model/PipelineElementInput'; export class PipelineElementBuilder { diff --git a/ui/cypress/support/builder/SpecificAdapterBuilder.ts b/ui/cypress/support/builder/SpecificAdapterBuilder.ts index 3ce498e..9474567 100644 --- a/ui/cypress/support/builder/SpecificAdapterBuilder.ts +++ b/ui/cypress/support/builder/SpecificAdapterBuilder.ts @@ -1,5 +1,23 @@ -import {UserInput} from '../model/UserInput'; -import {SpecificAdapterInput} from '../model/SpecificAdapterInput'; +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + +import { UserInput } from '../model/UserInput'; +import { SpecificAdapterInput } from '../model/SpecificAdapterInput'; export class SpecificAdapterBuilder { @@ -40,4 +58,4 @@ export class SpecificAdapterBuilder { build() { return this.specificAdapterInput; } -} \ No newline at end of file +} diff --git a/ui/cypress/support/general/dataCy.ts b/ui/cypress/support/general/dataCy.ts index 4926360..0162ce3 100644 --- a/ui/cypress/support/general/dataCy.ts +++ b/ui/cypress/support/general/dataCy.ts @@ -1,14 +1,32 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + declare global { namespace Cypress { interface Chainable { /** * Select cypress id's ([data-cy=...]) */ - dataCy(value: string): Chainable<Element> + dataCy(value: string): Chainable<Element>; } } } export const dataCy = (value) => { - return cy.get(`[data-cy=${value}]`) + return cy.get(`[data-cy=${value}]`); }; diff --git a/ui/cypress/support/general/login.ts b/ui/cypress/support/general/login.ts index a3bcfb3..a6e709e 100644 --- a/ui/cypress/support/general/login.ts +++ b/ui/cypress/support/general/login.ts @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + declare global { namespace Cypress { interface Chainable { @@ -12,11 +30,11 @@ declare global { export const login = () => { Cypress.Cookies.defaults({ - preserve: "JSESSIONID" + preserve: 'JSESSIONID' }); cy.request('POST', '/streampipes-backend/api/v2/admin/login', { - username: '[email protected]', + username: '[email protected]', password: 'test1234' }); }; diff --git a/ui/cypress/support/general/logout.ts b/ui/cypress/support/general/logout.ts index a195a5b..fced9fc 100644 --- a/ui/cypress/support/general/logout.ts +++ b/ui/cypress/support/general/logout.ts @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + declare global { namespace Cypress { interface Chainable { @@ -12,9 +30,9 @@ declare global { export const logout = () => { Cypress.Cookies.defaults({ - preserve: "JSESSIONID" + preserve: 'JSESSIONID' }); cy.dataCy('sp-user-preferences').click(); cy.dataCy('sp-logout').click(); -}; \ No newline at end of file +}; diff --git a/ui/cypress/support/index.ts b/ui/cypress/support/index.ts index 1f4d353..a9467ec 100644 --- a/ui/cypress/support/index.ts +++ b/ui/cypress/support/index.ts @@ -1,6 +1,25 @@ -import {login} from './general/login'; -import {logout} from './general/logout'; -import {dataCy} from './general/dataCy'; +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + +import { login } from './general/login'; +import { logout } from './general/logout'; +import { dataCy } from './general/dataCy'; +// tslint:disable-next-line:no-implicit-dependencies import 'cypress-file-upload'; // General commands diff --git a/ui/cypress/support/model/AdapterInput.ts b/ui/cypress/support/model/AdapterInput.ts index 73d54ee..ebd83e7 100644 --- a/ui/cypress/support/model/AdapterInput.ts +++ b/ui/cypress/support/model/AdapterInput.ts @@ -1,5 +1,23 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + export class AdapterInput { adapterType: string; adapterName: string; timestampProperty: string; -} \ No newline at end of file +} diff --git a/ui/cypress/support/model/GenericAdapterInput.ts b/ui/cypress/support/model/GenericAdapterInput.ts index 793f26c..fc9b148 100644 --- a/ui/cypress/support/model/GenericAdapterInput.ts +++ b/ui/cypress/support/model/GenericAdapterInput.ts @@ -1,8 +1,26 @@ -import {UserInput} from './UserInput'; -import {AdapterInput} from './AdapterInput'; +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ -export class GenericAdapterInput extends AdapterInput{ +import { UserInput } from './UserInput'; +import { AdapterInput } from './AdapterInput'; + +export class GenericAdapterInput extends AdapterInput { protocolConfiguration: UserInput[]; format: string; formatConfiguration: UserInput[]; -} \ No newline at end of file +} diff --git a/ui/cypress/support/model/PipelineElementInput.ts b/ui/cypress/support/model/PipelineElementInput.ts index 4c7a09b..025bc76 100644 --- a/ui/cypress/support/model/PipelineElementInput.ts +++ b/ui/cypress/support/model/PipelineElementInput.ts @@ -1,6 +1,24 @@ -import {UserInput} from './UserInput'; +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + +import { UserInput } from './UserInput'; export class PipelineElementInput { name: string; config: UserInput[]; -} \ No newline at end of file +} diff --git a/ui/cypress/support/model/PipelineInput.ts b/ui/cypress/support/model/PipelineInput.ts index f830fd1..b5463c5 100644 --- a/ui/cypress/support/model/PipelineInput.ts +++ b/ui/cypress/support/model/PipelineInput.ts @@ -1,4 +1,22 @@ -import {PipelineElementInput} from './PipelineElementInput'; +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + +import { PipelineElementInput } from './PipelineElementInput'; export class PipelineInput { pipelineName: string; @@ -7,4 +25,4 @@ export class PipelineInput { processingElement: PipelineElementInput; dataSink: PipelineElementInput; -} \ No newline at end of file +} diff --git a/ui/cypress/support/model/SpecificAdapterInput.ts b/ui/cypress/support/model/SpecificAdapterInput.ts index ffd3ab8..b5d60b0 100644 --- a/ui/cypress/support/model/SpecificAdapterInput.ts +++ b/ui/cypress/support/model/SpecificAdapterInput.ts @@ -1,6 +1,24 @@ -import {UserInput} from './UserInput'; -import {AdapterInput} from './AdapterInput'; +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ -export class SpecificAdapterInput extends AdapterInput{ +import { UserInput } from './UserInput'; +import { AdapterInput } from './AdapterInput'; + +export class SpecificAdapterInput extends AdapterInput { adapterConfiguration: UserInput[]; -} \ No newline at end of file +} diff --git a/ui/cypress/support/model/UserInput.ts b/ui/cypress/support/model/UserInput.ts index fbf1451..c431074 100644 --- a/ui/cypress/support/model/UserInput.ts +++ b/ui/cypress/support/model/UserInput.ts @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + export class UserInput { type: string | 'checkbox' | 'input' | 'file' | 'drop-down' | 'radio'; selector: string; diff --git a/ui/cypress/support/utils/AdapterUtils.ts b/ui/cypress/support/utils/AdapterUtils.ts index 1a2152a..c244ab4 100644 --- a/ui/cypress/support/utils/AdapterUtils.ts +++ b/ui/cypress/support/utils/AdapterUtils.ts @@ -1,8 +1,26 @@ -import {UserInput} from '../model/UserInput'; -import {StaticPropertyUtils} from './StaticPropertyUtils'; -import {SpecificAdapterInput} from '../model/SpecificAdapterInput'; -import {GenericAdapterInput} from '../model/GenericAdapterInput'; -import {SpecificAdapterBuilder} from '../builder/SpecificAdapterBuilder'; +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + +import { UserInput } from '../model/UserInput'; +import { StaticPropertyUtils } from './StaticPropertyUtils'; +import { SpecificAdapterInput } from '../model/SpecificAdapterInput'; +import { GenericAdapterInput } from '../model/GenericAdapterInput'; +import { SpecificAdapterBuilder } from '../builder/SpecificAdapterBuilder'; export class AdapterUtils { @@ -62,7 +80,7 @@ export class AdapterUtils { const configuration = SpecificAdapterBuilder .create('Machine_Data_Simulator') .setName(name) - .addInput('input', 'wait-time-ms','1000') + .addInput('input', 'wait-time-ms', '1000') .build(); AdapterUtils.goToConnect(); @@ -78,52 +96,52 @@ export class AdapterUtils { } private static goToConnect() { - it('Login', function () { + it('Login', () => { cy.login(); }); - it('Go to StreamPipes connect', function () { + it('Go to StreamPipes connect', () => { cy.visit('#/connect'); }); } private static selectAdapter(name) { - it('Select adapter', function () { + it('Select adapter', () => { cy.get('#' + name).click(); }); } private static configureAdapter(configs: UserInput[]) { - it('Next Button should be disabled', function () { + it('Next Button should be disabled', () => { cy.get('button').contains('Next').parent().should('be.disabled'); }); StaticPropertyUtils.input(configs); - it('Next Button should not be disabled', function () { + it('Next Button should not be disabled', () => { cy.get('button').contains('Next').parent().should('not.be.disabled'); }); - it('Click next', function () { + it('Click next', () => { cy.get('button').contains('Next').parent().click(); }); } private static configureFormat(adapterConfiguration: GenericAdapterInput) { - it('Select format', function () { + it('Select format', () => { cy.dataCy(adapterConfiguration.format).click(); }); StaticPropertyUtils.input(adapterConfiguration.formatConfiguration); - it('Click next', function () { + it('Click next', () => { // cy.dataCy('sp-format-selection-next-button').parent().should('not.be.disabled'); cy.dataCy('sp-format-selection-next-button').contains('Next').parent().click(); }); } private static markPropertyAsTimestamp(propertyName: string) { - it('Mark property as timestamp', function () { + it('Mark property as timestamp', () => { // Edit timestamp cy.dataCy('edit-' + propertyName).click(); @@ -137,7 +155,7 @@ export class AdapterUtils { } private static finishEventSchemaConfiguration() { - it('Click next', function () { + it('Click next', () => { cy.get('[data-cy=sp-connect-schema-editor]', { timeout: 10000 }).should('be.visible'); cy.get('#event-schema-next-button').click(); }); @@ -151,28 +169,28 @@ export class AdapterUtils { AdapterUtils.startAdapter(name, 'sp-connect-adapter-set-success'); } - private static startAdapter(name ,successElement) { - it('Set adapter name', function () { + private static startAdapter(name , successElement) { + it('Set adapter name', () => { cy.get('[data-cy=sp-adapter-name]').type(name); }); - it('Start adapter', function () { + it('Start adapter', () => { cy.get('#button-startAdapter').click(); cy.get('[data-cy=' + successElement + ']', { timeout: 10000 }).should('be.visible'); }); - it('Close adapter preview', function () { + it('Close adapter preview', () => { cy.get('button').contains('Close').parent().click(); }); } public static deleteAdapter() { - it('Delete adapter', function () { + it('Delete adapter', () => { cy.visit('#/connect'); cy.get('div').contains('My Adapters').parent().click(); - cy.dataCy('delete').should('have.length', 1) - cy.dataCy('delete').click() + cy.dataCy('delete').should('have.length', 1); + cy.dataCy('delete').click(); cy.get('[data-cy=delete]', { timeout: 10000 }).should('have.length', 0); }); } diff --git a/ui/cypress/support/utils/DataLakeUtils.ts b/ui/cypress/support/utils/DataLakeUtils.ts index 6d85802..480120e 100644 --- a/ui/cypress/support/utils/DataLakeUtils.ts +++ b/ui/cypress/support/utils/DataLakeUtils.ts @@ -1,10 +1,29 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + +// tslint:disable-next-line:no-implicit-dependencies import * as CSV from 'csv-string'; export class DataLakeUtils { public static checkResults(dataLakeIndex: string, fileRoute: string) { - it('Validate result in datalake', function () { + it('Validate result in datalake', () => { const streamPipesUser = '[email protected]'; cy.request('GET', '/streampipes-backend/api/v3/users/' + streamPipesUser + '/datalake/data/' + dataLakeIndex + '/download?format=csv', {'content-type': 'application/octet-stream'}).should((response) => { @@ -23,12 +42,11 @@ export class DataLakeUtils { } private static parseCsv(csv: string) { - const result = [] + const result = []; const index = CSV.readAll(csv, row => { result.push(row); }); return result; } - -} \ No newline at end of file +} diff --git a/ui/cypress/support/utils/FileManagementUtils.ts b/ui/cypress/support/utils/FileManagementUtils.ts index c9e5606..2abcf0e 100644 --- a/ui/cypress/support/utils/FileManagementUtils.ts +++ b/ui/cypress/support/utils/FileManagementUtils.ts @@ -1,33 +1,49 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + export class FileManagementUtils { public static addFile(filePath: string) { - it('Go to StreamPipes file management', function () { + it('Go to StreamPipes file management', () => { cy.visit('#/files'); }); - it('Open file upload dialog', function () { + it('Open file upload dialog', () => { cy.dataCy('sp-open-file-upload-dialog').click(); }); - it('Upload file', function () { + it('Upload file', () => { // const filepath = 'fileTest/test.csv' cy.dataCy('sp-file-management-file-input').attachFile(filePath); - cy.dataCy('sp-file-management-store-file').click() + cy.dataCy('sp-file-management-store-file').click(); }); } public static deleteFile() { - it('Go to StreamPipes file management', function () { + it('Go to StreamPipes file management', () => { cy.visit('#/files'); }); - it('Check if file was uploaded and delete it', function () { - cy.dataCy('delete').should('have.length', 1) - cy.dataCy('delete').click() - cy.dataCy('confirm-delete').click() - cy.dataCy('delete').should('have.length', 0) + it('Check if file was uploaded and delete it', () => { + cy.dataCy('delete').should('have.length', 1); + cy.dataCy('delete').click(); + cy.dataCy('confirm-delete').click(); + cy.dataCy('delete').should('have.length', 0); }); } - - -} \ No newline at end of file +} diff --git a/ui/cypress/support/utils/PipelineUtils.ts b/ui/cypress/support/utils/PipelineUtils.ts index c22b304..2f2178a 100644 --- a/ui/cypress/support/utils/PipelineUtils.ts +++ b/ui/cypress/support/utils/PipelineUtils.ts @@ -1,6 +1,23 @@ -import {PipelineInput} from '../model/PipelineInput'; -import {UserInput} from '../model/UserInput'; -import {StaticPropertyUtils} from './StaticPropertyUtils'; +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + +import { PipelineInput } from '../model/PipelineInput'; +import { StaticPropertyUtils } from './StaticPropertyUtils'; export class PipelineUtils { @@ -26,13 +43,13 @@ export class PipelineUtils { private static goToPipelineEditor() { - it('Go to StreamPipes connect', function () { + it('Go to StreamPipes connect', () => { cy.visit('#/editor'); }); } private static selectDataStream(pipelineInput: PipelineInput) { - it('Select a stream', function () { + it('Select a stream', () => { cy.dataCy('sp-editor-add-pipeline-element').click(); cy.dataCy(pipelineInput.dataSource).click(); }); @@ -41,32 +58,32 @@ export class PipelineUtils { private static configurePipeline(pipelineInput: PipelineInput) { - it('Select processor', function () { - cy.get('[data-cy=sp-possible-elements-' + pipelineInput.dataSource +']', { timeout: 10000 }).click(); + it('Select processor', () => { + cy.get('[data-cy=sp-possible-elements-' + pipelineInput.dataSource + ']', { timeout: 10000 }).click(); cy.dataCy('sp-compatible-elements-' + pipelineInput.processingElement.name).click(); }); StaticPropertyUtils.input(pipelineInput.processingElement.config); - it('Save configuration', function () { + it('Save configuration', () => { cy.dataCy('sp-element-configuration-save').click(); }); - it('Select sink', function () { + it('Select sink', () => { cy.dataCy('sp-possible-elements-' + pipelineInput.processingElement.name).click(); - cy.dataCy('sp-compatible-elements-'+ pipelineInput.dataSink.name).click(); + cy.dataCy('sp-compatible-elements-' + pipelineInput.dataSink.name).click(); }); StaticPropertyUtils.input(pipelineInput.dataSink.config); - it('Save sink configuration', function () { + it('Save sink configuration', () => { cy.dataCy('sp-element-configuration-save').click(); }); } private static startPipeline(pipelineInput: PipelineInput) { - it('Save and start pipeline', function () { + it('Save and start pipeline', () => { cy.dataCy('sp-editor-save-pipeline').click(); cy.dataCy('sp-editor-pipeline-name').type(pipelineInput.pipelineName); cy.dataCy('sp-editor-checkbox-start-immediately').children().click(); @@ -77,11 +94,11 @@ export class PipelineUtils { } public static deletePipeline() { - it('Delete pipeline', function () { + it('Delete pipeline', () => { cy.visit('#/pipelines'); - cy.dataCy('delete').should('have.length', 1) - cy.dataCy('delete').click() - cy.dataCy('sp-pipeline-stop-and-delete').click() + cy.dataCy('delete').should('have.length', 1); + cy.dataCy('delete').click(); + cy.dataCy('sp-pipeline-stop-and-delete').click(); cy.get('[data-cy=delete]', { timeout: 10000 }).should('have.length', 0); }); } diff --git a/ui/cypress/support/utils/ProcessingElementTestUtils.ts b/ui/cypress/support/utils/ProcessingElementTestUtils.ts index 967b3ab..cc0be3c 100644 --- a/ui/cypress/support/utils/ProcessingElementTestUtils.ts +++ b/ui/cypress/support/utils/ProcessingElementTestUtils.ts @@ -1,11 +1,29 @@ -import {FileManagementUtils} from './FileManagementUtils'; -import {AdapterUtils} from './AdapterUtils'; -import {PipelineElementInput} from '../model/PipelineElementInput'; -import {PipelineUtils} from './PipelineUtils'; -import {DataLakeUtils} from './DataLakeUtils'; -import {GenericAdapterBuilder} from '../builder/GenericAdapterBuilder'; -import {PipelineBuilder} from '../builder/PipelineBuilder'; -import {PipelineElementBuilder} from '../builder/PipelineElementBuilder'; +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + +import { FileManagementUtils } from './FileManagementUtils'; +import { AdapterUtils } from './AdapterUtils'; +import { PipelineElementInput } from '../model/PipelineElementInput'; +import { PipelineUtils } from './PipelineUtils'; +import { DataLakeUtils } from './DataLakeUtils'; +import { GenericAdapterBuilder } from '../builder/GenericAdapterBuilder'; +import { PipelineBuilder } from '../builder/PipelineBuilder'; +import { PipelineElementBuilder } from '../builder/PipelineElementBuilder'; export class ProcessingElementTestUtils { @@ -22,10 +40,10 @@ export class ProcessingElementTestUtils { .create('File_Set') .setName(adapterName) .setTimestampProperty('timestamp') - .addProtocolInput('input', 'interval-key','0') + .addProtocolInput('input', 'interval-key', '0') .setFormat('csv') - .addFormatInput('input', 'delimiter',';') - .addFormatInput('checkbox', 'header','check') + .addFormatInput('input', 'delimiter', ';') + .addFormatInput('checkbox', 'header', 'check') .build(); AdapterUtils.addGenericSetAdapter(adapterInput); @@ -36,15 +54,15 @@ export class ProcessingElementTestUtils { .addProcessingElement(processor) .addSink( PipelineElementBuilder.create('data_lake') - .addInput('input', 'db_measurement',dataLakeIndex) + .addInput('input', 'db_measurement', dataLakeIndex) .build()) .build(); PipelineUtils.addPipeline(pipelineInput); // // Wait - it('Wait till data is stored', function () { - cy.wait(10000) + it('Wait till data is stored', () => { + cy.wait(10000); }); DataLakeUtils.checkResults(dataLakeIndex, 'cypress/fixtures/' + expectedResultFile); @@ -55,4 +73,4 @@ export class ProcessingElementTestUtils { FileManagementUtils.deleteFile(); } -} \ No newline at end of file +} diff --git a/ui/cypress/support/utils/StaticPropertyUtils.ts b/ui/cypress/support/utils/StaticPropertyUtils.ts index 7fc414f..fdf7ef4 100644 --- a/ui/cypress/support/utils/StaticPropertyUtils.ts +++ b/ui/cypress/support/utils/StaticPropertyUtils.ts @@ -1,16 +1,34 @@ -import {UserInput} from '../model/UserInput'; +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + +import { UserInput } from '../model/UserInput'; export class StaticPropertyUtils { public static input(configs: UserInput[]) { - it('Configure Properties', function () { + it('Configure Properties', () => { configs.forEach(config => { - if (config.type == 'checkbox') { + if (config.type === 'checkbox') { cy.dataCy(config.selector).children().click(); - } else if (config.type == 'drop-down') { + } else if (config.type === 'drop-down') { cy.dataCy(config.selector).click().get('mat-option').contains(config.value).click(); - } else if (config.type == 'radio') { + } else if (config.type === 'radio') { cy.dataCy(config.selector + config.value ).click(); } else { cy.dataCy(config.selector).type(config.value); diff --git a/ui/src/app/connect/components/configuration-group/configuration-group.component.css b/ui/src/app/connect/components/configuration-group/configuration-group.component.css index e69de29..58ba04b 100644 --- a/ui/src/app/connect/components/configuration-group/configuration-group.component.css +++ b/ui/src/app/connect/components/configuration-group/configuration-group.component.css @@ -0,0 +1,18 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + diff --git a/ui/src/app/connect/components/configuration-group/configuration-group.component.html b/ui/src/app/connect/components/configuration-group/configuration-group.component.html index b7b12c8..2857534 100644 --- a/ui/src/app/connect/components/configuration-group/configuration-group.component.html +++ b/ui/src/app/connect/components/configuration-group/configuration-group.component.html @@ -1,3 +1,21 @@ +<!-- + ~ Licensed to the Apache Software Foundation (ASF) under one or more + ~ contributor license agreements. See the NOTICE file distributed with + ~ this work for additional information regarding copyright ownership. + ~ The ASF licenses this file to You under the Apache License, Version 2.0 + ~ (the "License"); you may not use this file except in compliance with + ~ the License. You may obtain a copy of the License at + ~ + ~ http://www.apache.org/licenses/LICENSE-2.0 + ~ + ~ Unless required by applicable law or agreed to in writing, software + ~ distributed under the License is distributed on an "AS IS" BASIS, + ~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + ~ See the License for the specific language governing permissions and + ~ limitations under the License. + ~ + --> + <div class="sp-blue-border padding" style="padding: 15px;"> <form [formGroup]="configurationGroup" fxFlex="100"> <div fxFlex="100" > diff --git a/ui/src/app/connect/components/configuration-group/configuration-group.component.ts b/ui/src/app/connect/components/configuration-group/configuration-group.component.ts index 763b71f..83ade47 100644 --- a/ui/src/app/connect/components/configuration-group/configuration-group.component.ts +++ b/ui/src/app/connect/components/configuration-group/configuration-group.component.ts @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + import { Component, Input, OnInit } from '@angular/core'; import { FormGroup } from '@angular/forms'; import { StaticPropertyUnion } from '../../../core-model/gen/streampipes-model'; diff --git a/ui/src/app/connect/components/format-configuration/format-configuration.component.css b/ui/src/app/connect/components/format-configuration/format-configuration.component.css index 16fe680..5050c24 100644 --- a/ui/src/app/connect/components/format-configuration/format-configuration.component.css +++ b/ui/src/app/connect/components/format-configuration/format-configuration.component.css @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + .stepper-button { margin-left:10px; } \ No newline at end of file diff --git a/ui/src/app/connect/components/format-configuration/format-configuration.component.html b/ui/src/app/connect/components/format-configuration/format-configuration.component.html index d453440..2eb4221 100644 --- a/ui/src/app/connect/components/format-configuration/format-configuration.component.html +++ b/ui/src/app/connect/components/format-configuration/format-configuration.component.html @@ -1,3 +1,21 @@ +<!-- + ~ Licensed to the Apache Software Foundation (ASF) under one or more + ~ contributor license agreements. See the NOTICE file distributed with + ~ this work for additional information regarding copyright ownership. + ~ The ASF licenses this file to You under the Apache License, Version 2.0 + ~ (the "License"); you may not use this file except in compliance with + ~ the License. You may obtain a copy of the License at + ~ + ~ http://www.apache.org/licenses/LICENSE-2.0 + ~ + ~ Unless required by applicable law or agreed to in writing, software + ~ distributed under the License is distributed on an "AS IS" BASIS, + ~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + ~ See the License for the specific language governing permissions and + ~ limitations under the License. + ~ + --> + <div style="margin-bottom: 2%;"> <div class="assemblyOptions sp-blue-bg"> diff --git a/ui/src/app/connect/components/format-configuration/format-configuration.component.ts b/ui/src/app/connect/components/format-configuration/format-configuration.component.ts index 8b7d1c0..078a246 100644 --- a/ui/src/app/connect/components/format-configuration/format-configuration.component.ts +++ b/ui/src/app/connect/components/format-configuration/format-configuration.component.ts @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + import { Component, EventEmitter, Input, OnInit, Output } from '@angular/core'; import { AdapterDescriptionUnion, diff --git a/ui/src/app/connect/components/generic-adapter-configuration/generic-adapter-configuration.component.css b/ui/src/app/connect/components/generic-adapter-configuration/generic-adapter-configuration.component.css index 16fe680..5050c24 100644 --- a/ui/src/app/connect/components/generic-adapter-configuration/generic-adapter-configuration.component.css +++ b/ui/src/app/connect/components/generic-adapter-configuration/generic-adapter-configuration.component.css @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + .stepper-button { margin-left:10px; } \ No newline at end of file diff --git a/ui/src/app/connect/components/generic-adapter-configuration/generic-adapter-configuration.component.html b/ui/src/app/connect/components/generic-adapter-configuration/generic-adapter-configuration.component.html index a0d22f1..1b2c549 100644 --- a/ui/src/app/connect/components/generic-adapter-configuration/generic-adapter-configuration.component.html +++ b/ui/src/app/connect/components/generic-adapter-configuration/generic-adapter-configuration.component.html @@ -1,3 +1,21 @@ +<!-- + ~ Licensed to the Apache Software Foundation (ASF) under one or more + ~ contributor license agreements. See the NOTICE file distributed with + ~ this work for additional information regarding copyright ownership. + ~ The ASF licenses this file to You under the Apache License, Version 2.0 + ~ (the "License"); you may not use this file except in compliance with + ~ the License. You may obtain a copy of the License at + ~ + ~ http://www.apache.org/licenses/LICENSE-2.0 + ~ + ~ Unless required by applicable law or agreed to in writing, software + ~ distributed under the License is distributed on an "AS IS" BASIS, + ~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + ~ See the License for the specific language governing permissions and + ~ limitations under the License. + ~ + --> + <div style="margin-bottom: 2%;"> <div > diff --git a/ui/src/app/connect/components/generic-adapter-configuration/generic-adapter-configuration.component.ts b/ui/src/app/connect/components/generic-adapter-configuration/generic-adapter-configuration.component.ts index 4669661..6d97444 100644 --- a/ui/src/app/connect/components/generic-adapter-configuration/generic-adapter-configuration.component.ts +++ b/ui/src/app/connect/components/generic-adapter-configuration/generic-adapter-configuration.component.ts @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + import { Component, EventEmitter, Input, OnInit, Output } from '@angular/core'; import { AdapterDescriptionUnion, diff --git a/ui/src/app/connect/components/schema-editor/error-message/error-message.component.css b/ui/src/app/connect/components/schema-editor/error-message/error-message.component.css index e69de29..58ba04b 100644 --- a/ui/src/app/connect/components/schema-editor/error-message/error-message.component.css +++ b/ui/src/app/connect/components/schema-editor/error-message/error-message.component.css @@ -0,0 +1,18 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + diff --git a/ui/src/app/connect/components/schema-editor/error-message/error-message.component.html b/ui/src/app/connect/components/schema-editor/error-message/error-message.component.html index 65bc617..3c7e8b0 100644 --- a/ui/src/app/connect/components/schema-editor/error-message/error-message.component.html +++ b/ui/src/app/connect/components/schema-editor/error-message/error-message.component.html @@ -1,3 +1,21 @@ +<!-- + ~ Licensed to the Apache Software Foundation (ASF) under one or more + ~ contributor license agreements. See the NOTICE file distributed with + ~ this work for additional information regarding copyright ownership. + ~ The ASF licenses this file to You under the Apache License, Version 2.0 + ~ (the "License"); you may not use this file except in compliance with + ~ the License. You may obtain a copy of the License at + ~ + ~ http://www.apache.org/licenses/LICENSE-2.0 + ~ + ~ Unless required by applicable law or agreed to in writing, software + ~ distributed under the License is distributed on an "AS IS" BASIS, + ~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + ~ See the License for the specific language governing permissions and + ~ limitations under the License. + ~ + --> + <div fxLayout="column" > <div fxLayout="row" fxLayoutAlign="center center"> <mat-icon style="margin-top: 10px" class="md-accent">warning</mat-icon> diff --git a/ui/src/app/connect/components/schema-editor/error-message/error-message.component.ts b/ui/src/app/connect/components/schema-editor/error-message/error-message.component.ts index 9ed18ec..febcb42 100644 --- a/ui/src/app/connect/components/schema-editor/error-message/error-message.component.ts +++ b/ui/src/app/connect/components/schema-editor/error-message/error-message.component.ts @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + import { Component, Input, OnInit } from '@angular/core'; import { Notification } from '../../../../core-model/gen/streampipes-model'; diff --git a/ui/src/app/connect/components/schema-editor/loading-message/loading-message.component.css b/ui/src/app/connect/components/schema-editor/loading-message/loading-message.component.css index e69de29..58ba04b 100644 --- a/ui/src/app/connect/components/schema-editor/loading-message/loading-message.component.css +++ b/ui/src/app/connect/components/schema-editor/loading-message/loading-message.component.css @@ -0,0 +1,18 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + diff --git a/ui/src/app/connect/components/schema-editor/loading-message/loading-message.component.html b/ui/src/app/connect/components/schema-editor/loading-message/loading-message.component.html index 7e140fe..f875923 100644 --- a/ui/src/app/connect/components/schema-editor/loading-message/loading-message.component.html +++ b/ui/src/app/connect/components/schema-editor/loading-message/loading-message.component.html @@ -1,3 +1,21 @@ +<!-- + ~ Licensed to the Apache Software Foundation (ASF) under one or more + ~ contributor license agreements. See the NOTICE file distributed with + ~ this work for additional information regarding copyright ownership. + ~ The ASF licenses this file to You under the Apache License, Version 2.0 + ~ (the "License"); you may not use this file except in compliance with + ~ the License. You may obtain a copy of the License at + ~ + ~ http://www.apache.org/licenses/LICENSE-2.0 + ~ + ~ Unless required by applicable law or agreed to in writing, software + ~ distributed under the License is distributed on an "AS IS" BASIS, + ~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + ~ See the License for the specific language governing permissions and + ~ limitations under the License. + ~ + --> + <div fxLayout="column" > <div fxLayoutAlign="center"> <mat-spinner fxLayoutAlign="center" style="margin: 10px 0 5px 0">Loading</mat-spinner> diff --git a/ui/src/app/connect/components/schema-editor/loading-message/loading-message.component.ts b/ui/src/app/connect/components/schema-editor/loading-message/loading-message.component.ts index 3b6c900..d76ff25 100644 --- a/ui/src/app/connect/components/schema-editor/loading-message/loading-message.component.ts +++ b/ui/src/app/connect/components/schema-editor/loading-message/loading-message.component.ts @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + import { Component, OnInit } from '@angular/core'; @Component({ diff --git a/ui/src/app/connect/components/schema-editor/schema-editor-header/schema-editor-header.component.css b/ui/src/app/connect/components/schema-editor/schema-editor-header/schema-editor-header.component.css index 39ec4fd..52bd5d6 100644 --- a/ui/src/app/connect/components/schema-editor/schema-editor-header/schema-editor-header.component.css +++ b/ui/src/app/connect/components/schema-editor/schema-editor-header/schema-editor-header.component.css @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + .add-schema button { color: white; } \ No newline at end of file diff --git a/ui/src/app/connect/components/schema-editor/schema-editor-header/schema-editor-header.component.html b/ui/src/app/connect/components/schema-editor/schema-editor-header/schema-editor-header.component.html index 448c0cb..a42a31f 100644 --- a/ui/src/app/connect/components/schema-editor/schema-editor-header/schema-editor-header.component.html +++ b/ui/src/app/connect/components/schema-editor/schema-editor-header/schema-editor-header.component.html @@ -1,3 +1,21 @@ +<!-- + ~ Licensed to the Apache Software Foundation (ASF) under one or more + ~ contributor license agreements. See the NOTICE file distributed with + ~ this work for additional information regarding copyright ownership. + ~ The ASF licenses this file to You under the Apache License, Version 2.0 + ~ (the "License"); you may not use this file except in compliance with + ~ the License. You may obtain a copy of the License at + ~ + ~ http://www.apache.org/licenses/LICENSE-2.0 + ~ + ~ Unless required by applicable law or agreed to in writing, software + ~ distributed under the License is distributed on an "AS IS" BASIS, + ~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + ~ See the License for the specific language governing permissions and + ~ limitations under the License. + ~ + --> + <div fxLayout="row"> <div fxLayoutAlign="space-between center" class="add-schema" fxFlex="0 1 100%"> <div> diff --git a/ui/src/app/connect/components/schema-editor/schema-editor-header/schema-editor-header.component.ts b/ui/src/app/connect/components/schema-editor/schema-editor-header/schema-editor-header.component.ts index d4d46ff..9c7eda3c 100644 --- a/ui/src/app/connect/components/schema-editor/schema-editor-header/schema-editor-header.component.ts +++ b/ui/src/app/connect/components/schema-editor/schema-editor-header/schema-editor-header.component.ts @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + import { Component, EventEmitter, Input, OnInit, Output } from '@angular/core'; @Component({ diff --git a/ui/src/app/connect/components/specific-adapter-configuration/specific-adapter-configuration.component.css b/ui/src/app/connect/components/specific-adapter-configuration/specific-adapter-configuration.component.css index 2835bd6..5c16e27 100644 --- a/ui/src/app/connect/components/specific-adapter-configuration/specific-adapter-configuration.component.css +++ b/ui/src/app/connect/components/specific-adapter-configuration/specific-adapter-configuration.component.css @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + .stepper-button { margin-left:10px; } diff --git a/ui/src/app/connect/components/specific-adapter-configuration/specific-adapter-configuration.component.html b/ui/src/app/connect/components/specific-adapter-configuration/specific-adapter-configuration.component.html index 3636756..5b14da8 100644 --- a/ui/src/app/connect/components/specific-adapter-configuration/specific-adapter-configuration.component.html +++ b/ui/src/app/connect/components/specific-adapter-configuration/specific-adapter-configuration.component.html @@ -1,3 +1,21 @@ +<!-- + ~ Licensed to the Apache Software Foundation (ASF) under one or more + ~ contributor license agreements. See the NOTICE file distributed with + ~ this work for additional information regarding copyright ownership. + ~ The ASF licenses this file to You under the Apache License, Version 2.0 + ~ (the "License"); you may not use this file except in compliance with + ~ the License. You may obtain a copy of the License at + ~ + ~ http://www.apache.org/licenses/LICENSE-2.0 + ~ + ~ Unless required by applicable law or agreed to in writing, software + ~ distributed under the License is distributed on an "AS IS" BASIS, + ~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + ~ See the License for the specific language governing permissions and + ~ limitations under the License. + ~ + --> + <div style="margin-bottom: 2%;"> <div> <div class="assemblyOptions sp-blue-bg"> diff --git a/ui/src/app/connect/components/specific-adapter-configuration/specific-adapter-configuration.component.ts b/ui/src/app/connect/components/specific-adapter-configuration/specific-adapter-configuration.component.ts index 1ba136b..75e8e5c 100644 --- a/ui/src/app/connect/components/specific-adapter-configuration/specific-adapter-configuration.component.ts +++ b/ui/src/app/connect/components/specific-adapter-configuration/specific-adapter-configuration.component.ts @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + import { Component, EventEmitter, Input, OnInit, Output } from '@angular/core'; import { AdapterDescriptionUnion } from '../../../core-model/gen/streampipes-model'; import { FormBuilder, FormGroup } from '@angular/forms'; diff --git a/ui/src/app/connect/components/start-adapter-configuration/start-adapter-configuration.component.css b/ui/src/app/connect/components/start-adapter-configuration/start-adapter-configuration.component.css index e69de29..58ba04b 100644 --- a/ui/src/app/connect/components/start-adapter-configuration/start-adapter-configuration.component.css +++ b/ui/src/app/connect/components/start-adapter-configuration/start-adapter-configuration.component.css @@ -0,0 +1,18 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + diff --git a/ui/src/app/connect/components/start-adapter-configuration/start-adapter-configuration.component.html b/ui/src/app/connect/components/start-adapter-configuration/start-adapter-configuration.component.html index 820c6b9..c26b2c9 100644 --- a/ui/src/app/connect/components/start-adapter-configuration/start-adapter-configuration.component.html +++ b/ui/src/app/connect/components/start-adapter-configuration/start-adapter-configuration.component.html @@ -1,3 +1,21 @@ +<!-- + ~ Licensed to the Apache Software Foundation (ASF) under one or more + ~ contributor license agreements. See the NOTICE file distributed with + ~ this work for additional information regarding copyright ownership. + ~ The ASF licenses this file to You under the Apache License, Version 2.0 + ~ (the "License"); you may not use this file except in compliance with + ~ the License. You may obtain a copy of the License at + ~ + ~ http://www.apache.org/licenses/LICENSE-2.0 + ~ + ~ Unless required by applicable law or agreed to in writing, software + ~ distributed under the License is distributed on an "AS IS" BASIS, + ~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + ~ See the License for the specific language governing permissions and + ~ limitations under the License. + ~ + --> + <div [formGroup]="startAdapterForm"> <div class="assemblyOptions sp-blue-bg"> <h4>Adapter settings</h4> diff --git a/ui/src/app/connect/components/start-adapter-configuration/start-adapter-configuration.component.ts b/ui/src/app/connect/components/start-adapter-configuration/start-adapter-configuration.component.ts index a5b361c..306dffc 100644 --- a/ui/src/app/connect/components/start-adapter-configuration/start-adapter-configuration.component.ts +++ b/ui/src/app/connect/components/start-adapter-configuration/start-adapter-configuration.component.ts @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + import { Component, EventEmitter, Input, OnInit, Output } from '@angular/core'; import { AdapterDescriptionUnion,
