schema.spec.js

/// <reference types="cypress" />

const contextPath = process.env.QDB_HTTP_CONTEXT_WEB_CONSOLE || ""
const baseUrl = `http://localhost:9999${contextPath}`;

const tables = [
  "btc_trades",
  "chicago_weather_stations",
  "ecommerce_stats",
  "gitlog",
];

const materializedViews = ["btc_trades_mv"];

describe("questdb schema with working tables", () => {
  before(() => {
    cy.loadConsoleWithAuth();

    tables.forEach((table) => {
      cy.createTable(table);
    });
    cy.expandTables();
    cy.refreshSchema();
  });
  it("should show all the tables when there are no suspended", () => {
    tables.forEach((table) => {
      cy.getByDataHook("schema-table-title").should("contain", table);
    });
    cy.getByDataHook("schema-filter-suspended-button").should("not.exist");
    cy.getByDataHook("schema-suspension-popover-trigger").should("not.exist");
  });

  it("should filter the table with input field", () => {
    // Table name search
    cy.get('input[name="table_filter"]').type("btc_trades");
    cy.getByDataHook("schema-search-clear-button").should("exist");
    cy.getByDataHook("schema-table-title").should("contain", "btc_trades");
    cy.getByDataHook("schema-table-title").should("not.contain", "ź");
    cy.getByDataHook("schema-table-title").should(
      "not.contain",
      "ecommerce_stats"
    );
    cy.getByDataHook("schema-table-title").should("not.contain", "gitlog");
    cy.getByDataHook("schema-search-clear-button").click();
    cy.getByDataHook("schema-table-title").should(
      "have.length.least",
      tables.length
    );
  });

  after(() => {
    cy.loadConsoleWithAuth();
    tables.forEach((table) => {
      cy.dropTable(table);
    });
  });
});

describe("questdb schema with suspended tables with Linux OS error codes", () => {
  before(() => {
    cy.loadConsoleWithAuth();

    tables.forEach((table) => {
      cy.createTable(table);
    });
    cy.refreshSchema();
    cy.typeQuery(
      "ALTER TABLE btc_trades SUSPEND WAL WITH 24, 'Too many open files';"
    )
      .clickRun()
      .clearEditor();

    cy.typeQuery(
      "ALTER TABLE ecommerce_stats SUSPEND WAL WITH 12, 'Out of memory';"
    )
      .clickRun()
      .clearEditor();
  });
  beforeEach(() => {
    cy.loadConsoleWithAuth();
    cy.expandTables();
  });

  it("should work with 2 suspended tables, btc_trades and ecommerce_stats", () => {
    cy.getByDataHook("schema-filter-suspended-button").should(
      "not.be.disabled"
    );
    cy.getByDataHook("schema-filter-suspended-button").should("contain", "2");
  });

  it("should filter out non-suspended tables on click", () => {
    cy.getByDataHook("schema-filter-suspended-button").click();
    cy.getByDataHook("schema-table-title").should("have.length", 2);
    cy.getByDataHook("schema-table-title").should("contain", "btc_trades");
    cy.getByDataHook("schema-table-title").should("contain", "ecommerce_stats");
    cy.getByDataHook("schema-table-title").should("not.contain", "gitlog");
    cy.getByDataHook("schema-table-title").should(
      "not.contain",
      "chicago_weather_stations"
    );
    cy.getByDataHook("schema-filter-suspended-button").click();
  });

  it("should show the suspension dialog on click with details for btc_trades", () => {
    cy.get('input[name="table_filter"]').click().type("btc_trades");
    cy.getByDataHook("schema-suspension-dialog-trigger").click();
    cy.getByDataHook("schema-suspension-dialog").should(
      "have.attr",
      "data-table-name",
      "btc_trades"
    );
    cy.getByDataHook("schema-suspension-dialog-error-message").should(
      "contain",
      "Too many open files, please, increase the maximum number of open file handlers OS limit"
    );
    cy.getByDataHook("schema-suspension-dialog-error-link").should(
      "have.attr",
      "href",
      "https://questdb.io/docs/deployment/capacity-planning/#maximum-open-files"
    );
  });

  it("should resume WAL for btc_trades from the suspension popover", () => {
    cy.get('input[name="table_filter"]').click().type("btc_trades");
    cy.contains("Suspended").click();
    cy.getByDataHook("schema-suspension-dialog-restart-transaction").click();
    cy.getByDataHook("schema-suspension-dialog-dismiss").click();
    cy.getByDataHook("schema-suspension-dialog").should("not.exist");
    cy.getByDataHook("schema-suspension-dialog-trigger").should("not.exist");
  });

  after(() => {
    cy.loadConsoleWithAuth();
    tables.forEach((table) => {
      cy.dropTable(table);
    });
  });
});

describe("table select UI", () => {
  before(() => {
    cy.loadConsoleWithAuth();

    tables.forEach((table) => {
      cy.createTable(table);
    });
    cy.refreshSchema();
  });
  beforeEach(() => {
    cy.loadConsoleWithAuth();
    cy.expandTables();
  });

  it("should show select ui on click", () => {
    cy.getByDataHook("schema-select-button").click();
    cy.getByDataHook("schema-copy-to-clipboard-button").should("be.visible");
    cy.getByDataHook("schema-copy-to-clipboard-button").should("be.disabled");
    cy.getByDataHook("schema-select-all-button").should("be.visible");
  });

  it("should select and deselect tables", () => {
    cy.getByDataHook("schema-select-button").click();
    cy.getByDataHook("schema-table-title").contains("btc_trades").click();
    cy.getByDataHook("schema-table-title")
      .contains("chicago_weather_stations")
      .click();
    cy.getByDataHook("schema-copy-to-clipboard-button")
      .should("not.be.disabled")
      .click();
    // Electron only!
    if (Cypress.isBrowser("electron")) {
      ["btc_trades", "chicago_weather_stations"].forEach((table) => {
        cy.window()
          .its("navigator.clipboard")
          .then((clip) => clip.readText())
          .should("contain", `CREATE TABLE '${table}'`);
      });
    }
  });

  after(() => {
    cy.loadConsoleWithAuth();
    tables.forEach((table) => {
      cy.dropTable(table);
    });
  });
});

describe("questdb schema in read-only mode", () => {
  before(() => {
    cy.intercept(
      {
        method: "GET",
        url: `${baseUrl}/assets/console-configuration.json`,
      },
      {
        savedQueries: [],
        readOnly: true,
      }
    ).as("getConsoleConfiguration");

    cy.loadConsoleWithAuth();
  });

  it("should disable Create Table action in read-only mode", () => {
    cy.getByDataHook("create-table-panel-button").trigger("mouseover");
    cy.getByDataHook("tooltip").should(
      "contain",
      "To use this feature, turn off read-only mode in the configuration file"
    );

    cy.getByDataHook("create-table-panel-button").click();
    cy.getByDataHook("create-table-panel").should("not.exist");
  });
});

describe("materialized views", () => {
  before(() => {
    cy.loadConsoleWithAuth();

    tables.forEach((table) => {
      cy.createTable(table);
    });
    materializedViews.forEach((mv) => {
      cy.createMaterializedView(mv);
    });
    cy.refreshSchema();
  });

  it("should create materialized views", () => {
    cy.getByDataHook("expand-tables").contains(`Tables (${tables.length})`);
    cy.getByDataHook("expand-materialized-views").contains(
      `Materialized Views (${materializedViews.length})`
    );

    cy.expandTables();
    cy.getByDataHook("schema-table-title").should("contain", "btc_trades");
    cy.expandMatViews();
    cy.getByDataHook("schema-table-title").should("contain", "btc_trades_mv");
  });

  it("should show the base table and copy DDL for a materialized view", () => {
    cy.collapseTables();
    cy.getByDataHook("schema-table-title").contains("btc_trades_mv").click();
    cy.getByDataHook("schema-info-title").contains("DDL").should("exist");
    cy.getByDataHook("copyable-value").should("exist").and("be.visible");
    cy.getByDataHook("copy-value").should("exist").click({ force: true });

    cy.window()
      .its("navigator.clipboard")
      .invoke("readText")
      .should(
        "match",
        /^CREATE MATERIALIZED VIEW.*'btc_trades_mv' WITH BASE 'btc_trades'/
      );
  });

  after(() => {
    cy.loadConsoleWithAuth();

    materializedViews.forEach((mv) => {
      cy.dropMaterializedView(mv);
    });

    tables.forEach((table) => {
      cy.dropTable(table);
    });
  });
});