Schema registry start

Author: AspidDark

e2e-playwright/src/features/SchemaRegistry.feature

@@ -0,0 +1,16 @@
+Feature: Schema page
+
+  Scenario: SchemaRegistry and SchemaRegistryCreate visibility
+    Given Schema Registry is visible
+    When click on Schema Registry link
+    Then Schema Registry heading visible
+    Given SchemaRegistry CheateSchema clicked
+    
+    Given SchemaRegistryCreate is visible
+    Given SchemaRegistryCreate Subject visible is: "true"
+    Given SchemaRegistryCreate Schema visible is: "true"
+    Given SchemaRegistryCreate SchemaType visible is: "true"
+    When SchemaRegistryCreate Subject input starts with: "SchemaSubject"
+    When SchemaRegistryCreate Schema input from avro
+    When SchemaRegistryCreate Submit clicked
+    Then SchemaRegistrySchemaName starts with: "SchemaSubject", visible is: "true"

e2e-playwright/src/pages/Locators.ts

@@ -11,6 +11,7 @@ import DashboardLocators from "./Dashboard/DashboardLocators";
 import TopicsTopickNameLocators from "./Topics/TopicsTopickNameLocators"
 import ProduceMessageLocators from "./Topics/ProduceMessageLocators"
 import BrokerDetailsLocators from "./Brokers/BrokerDetailsLocators"
+import SchemaRegistrySchemaNameLocators from "./SchemaRegistry/SchemaRegistrySchemaNameLocators"
 
 export class Locators {
   private readonly page: Page;
@@ -24,6 +25,7 @@ export class Locators {
   private _produceMessage?: ProduceMessageLocators;
   private _consumers?: ConsumersLocators;
   private _schemaRegistry?: SchemaRegistryLocators;
+  private _schemaName?: SchemaRegistrySchemaNameLocators;
   private _connectors?: ConnectorsLocators;
   private _ksqlDb?: ksqlDbLocators;
   private _dashboard?: DashboardLocators;
@@ -68,6 +70,10 @@ export class Locators {
     return (this._schemaRegistry ??= new SchemaRegistryLocators(this.page));
   }
 
+  get schemaName() {
+    return (this._schemaName ??= new SchemaRegistrySchemaNameLocators(this.page));
+  }
+
   get connectors() {
     return (this._connectors ??= new ConnectorsLocators(this.page));
   }

e2e-playwright/src/pages/SchemaRegistry/SchemaRegistryLocators.ts

@@ -10,4 +10,12 @@ export default class SchemaRegistryLocators {
     get heading(): Locator { return this.page.getByRole('heading', { name: 'Schema Registry' })};
     get searchBox(): Locator { return this.page.getByRole('textbox', { name: 'Search by Schema Name' })};
     get createSchemaButton(): Locator { return this.page.getByRole('button', { name: 'Create Schema' })};
+
+    get createHeading(): Locator { return this.page.getByText('Schema RegistryCreate')};
+    get subjectTextBox(): Locator { return this.page.getByRole('textbox', { name: 'Schema Name' })};
+    get schemaTextBox(): Locator { return this.page.locator('textarea[name="schema"]')};
+    get schemaTypeDropDown(): Locator { return this.page.locator('form path')};
+    get submit(): Locator { return this.page.getByRole('button', { name: 'Submit' })};
+
+    schemaTypeDropDownElement(value:string): Locator { return this.page.getByRole('option', { name: value })};
 }

e2e-playwright/src/pages/SchemaRegistry/SchemaRegistrySchemaNameLocators.ts

@@ -0,0 +1,11 @@
+import { Page, Locator } from "@playwright/test";
+
+export default class SchemaRegistrySchemaNameLocators {
+    private readonly page: Page;
+
+    constructor(page: Page) {
+      this.page = page;
+    }
+
+    heading(value: string): Locator { return this.page.getByText(`Schema Registry${value}`)};
+}

e2e-playwright/src/services/schemas.ts

@@ -0,0 +1,51 @@
+export function getAvroSchema(): string {
+  return JSON.stringify({
+    type: 'record',
+    name: 'Student',
+    namespace: 'DataFlair',
+    fields: [
+      { name: 'Name', type: 'string' },
+      { name: 'Age', type: 'int' }
+    ]
+  }, null, 2);
+}
+
+export function getAvroUpdatedSchema(): string {
+  return JSON.stringify({
+    type: "record",
+    name: "Message",
+    namespace: "io.kafbat.ui",
+    fields: [
+      {
+        name: "text",
+        type: "string",
+        default: null
+      },
+      {
+        name: "value",
+        type: "string",
+        default: null
+      }
+    ]
+  }, null, 2);
+}
+
+export function getJsonSchema(): string {
+  return JSON.stringify({
+    "connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector",
+    "connection.url": "jdbc:postgresql://postgres-db:5432/test",
+    "connection.user": "dev_user",
+    "connection.password": "12345",
+    "topics": "topic_for_connector"
+  }, null, 2);
+}
+
+export function getProtobufSchema(): string {
+  return `
+enum SchemaType {
+  AVRO = 0;
+  JSON = 1;
+  PROTOBUF = 2;
+}
+`.trim();
+}

e2e-playwright/src/steps/SchemaRegistry.steps.ts

@@ -0,0 +1,51 @@
+/* eslint-disable no-unused-vars */
+import { Given, When, Then, setDefaultTimeout } from "@cucumber/cucumber";
+import { PlaywrightWorld } from "../support/PlaywrightWorld";
+import { expectVisibility } from "../services/uiHelper";
+import { generateName   } from "../services/commonFunctions";
+import { getAvroSchema } from "../services/schemas"
+
+setDefaultTimeout(60 * 1000 * 2);
+
+Given('SchemaRegistry CheateSchema clicked', async function(this: PlaywrightWorld) {
+  await this.locators.schemaRegistry.createSchemaButton.click();
+});
+
+Given('SchemaRegistryCreate is visible', async function(this: PlaywrightWorld) {
+  await expectVisibility(this.locators.schemaRegistry.createHeading, "true");
+});
+
+Given('SchemaRegistryCreate Subject visible is: {string}', async function(this: PlaywrightWorld, visible: string) {
+  await expectVisibility(this.locators.schemaRegistry.subjectTextBox, visible);
+});
+
+Given('SchemaRegistryCreate Schema visible is: {string}', async function(this: PlaywrightWorld, visible: string) {
+  await expectVisibility(this.locators.schemaRegistry.schemaTextBox, visible);
+});
+
+Given('SchemaRegistryCreate SchemaType visible is: {string}', async function(this: PlaywrightWorld, visible: string) {
+  await expectVisibility(this.locators.schemaRegistry.schemaTypeDropDown, visible);
+});
+
+When('SchemaRegistryCreate Subject input starts with: {string}', async function(this: PlaywrightWorld, prefix: string) {
+  const subjectName = generateName(prefix);
+  await this.locators.schemaRegistry.subjectTextBox.fill(subjectName);
+  this.setValue(`subjectName-${prefix}`, subjectName);
+});
+
+When('SchemaRegistryCreate Schema input from avro', async function(this: PlaywrightWorld) {
+  const schema = getAvroSchema();
+  await this.locators.schemaRegistry.schemaTextBox.fill(schema);
+});
+
+When('SchemaRegistryCreate Submit clicked', async function(this: PlaywrightWorld) {
+  await this.locators.schemaRegistry.submit.click();
+});
+
+Then('SchemaRegistrySchemaName starts with: {string}, visible is: {string}',
+  async function(this: PlaywrightWorld, prefix: string, visible: string) {
+    const streamName = this.getValue<string>(`subjectName-${prefix}`);
+    const locator = this.locators.schemaName.heading(streamName);
+    await expectVisibility(locator, visible);
+  }
+);