dbgate/packages/web/src/widgets/DatabaseWidget.js

import React from 'react';
import _ from 'lodash';

import { AppObjectList } from '../appobj/AppObjectList';
import ConnectionAppObject from '../appobj/ConnectionAppObject';
import DatabaseAppObject from '../appobj/DatabaseAppObject';
import { useSetCurrentDatabase, useCurrentDatabase, useOpenedConnections } from '../utility/globalState';
import InlineButton from './InlineButton';
import DatabaseObjectAppObject from '../appobj/DatabaseObjectAppObject';
import {
  // useSqlObjectList,
  useDatabaseList,
  useConnectionList,
  useServerStatus,
  useDatabaseStatus,
  useDatabaseInfo,
  useConfig,
} from '../utility/metadataLoaders';
import { SearchBoxWrapper, WidgetsInnerContainer } from './WidgetStyles';
import axios from '../utility/axios';
import LoadingInfo from './LoadingInfo';
import SearchInput from './SearchInput';
import ErrorInfo from './ErrorInfo';
import WidgetColumnBar, { WidgetColumnBarItem } from './WidgetColumnBar';
import ToolbarButton from './ToolbarButton';
import useShowModal from '../modals/showModal';
import ConnectionModal from '../modals/ConnectionModal';
import SubColumnParamList from '../appobj/SubColumnParamList';

function SubDatabaseList({ data }) {
  const setDb = useSetCurrentDatabase();
  const handleDatabaseClick = database => {
    setDb({
      ...database,
      connection: data,
    });
  };
  const { _id } = data;
  const databases = useDatabaseList({ conid: _id });
  return (
    <AppObjectList
      list={(databases || []).map(db => ({ ...db, connection: data }))}
      AppObjectComponent={DatabaseAppObject}
      // makeAppObj={databaseAppObject({ boldCurrentDatabase: true })}
      onObjectClick={handleDatabaseClick}
    />
  );
}

function ConnectionList() {
  const connections = useConnectionList();
  const serverStatus = useServerStatus();
  const openedConnections = useOpenedConnections();
  const connectionsWithStatus =
    connections && serverStatus ? connections.map(conn => ({ ...conn, status: serverStatus[conn._id] })) : connections;
  const showModal = useShowModal();

  const handleRefreshConnections = () => {
    for (const conid of openedConnections) {
      axios.post('server-connections/refresh', { conid });
    }
  };

  const showNewConnection = () => {
    showModal(modalState => <ConnectionModal modalState={modalState} />);
  };

  const [filter, setFilter] = React.useState('');
  return (
    <>
      <SearchBoxWrapper>
        <SearchInput placeholder="Search connection" filter={filter} setFilter={setFilter} />
        <InlineButton onClick={handleRefreshConnections}>Refresh</InlineButton>
      </SearchBoxWrapper>

      <WidgetsInnerContainer>
        <AppObjectList
          list={_.sortBy(connectionsWithStatus, ({ displayName, server }) =>
            (displayName || server || '').toUpperCase()
          )}
          AppObjectComponent={ConnectionAppObject}
          // makeAppObj={connectionAppObject({ boldCurrentDatabase: true })}
          SubItems={SubDatabaseList}
          filter={filter}
          isExpandable={data => openedConnections.includes(data._id)}
          expandOnClick
        />
        {connections && connections.length == 0 && (
          <ToolbarButton icon="icon new-connection" onClick={showNewConnection}>
            Add new connection
          </ToolbarButton>
        )}
      </WidgetsInnerContainer>
    </>
  );
}

function SqlObjectList({ conid, database }) {
  const objects = useDatabaseInfo({ conid, database });
  const status = useDatabaseStatus({ conid, database });

  const handleRefreshDatabase = () => {
    axios.post('database-connections/refresh', { conid, database });
  };

  const [filter, setFilter] = React.useState('');
  const objectList = _.flatten(
    ['tables', 'views', 'procedures', 'functions'].map(objectTypeField =>
      _.sortBy(
        ((objects || {})[objectTypeField] || []).map(obj => ({ ...obj, objectTypeField })),
        ['schemaName', 'pureName']
      )
    )
  );

  const inputRef = React.useRef(null);

  if (status && status.name == 'error') {
    return (
      <WidgetsInnerContainer>
        <ErrorInfo message={status.message} icon="img error" />
        <InlineButton onClick={handleRefreshDatabase}>Refresh</InlineButton>
      </WidgetsInnerContainer>
    );
  }

  if (objectList.length == 0 && (status && status.name) != 'pending') {
    return (
      <WidgetsInnerContainer>
        <ErrorInfo
          message={`Database ${database} is empty or structure is not loaded, press Refresh button to reload structure`}
          icon="img alert"
        />
        <InlineButton onClick={handleRefreshDatabase}>Refresh</InlineButton>
      </WidgetsInnerContainer>
    );
  }

  return (
    <>
      <SearchBoxWrapper>
        <SearchInput inputRef={inputRef} placeholder="Search tables or objects" filter={filter} setFilter={setFilter} />
        <InlineButton onClick={handleRefreshDatabase}>Refresh</InlineButton>
      </SearchBoxWrapper>
      <WidgetsInnerContainer>
        {status && status.name == 'pending' ? (
          <LoadingInfo message="Loading database structure" />
        ) : (
          <AppObjectList
            list={objectList.map(x => ({ ...x, conid, database }))}
            AppObjectComponent={DatabaseObjectAppObject}
            groupFunc={data => _.startCase(data.objectTypeField)}
            filter={filter}
            SubItems={SubColumnParamList}
            isExpandable={data => data.objectTypeField == 'tables'}
          />
        )}
      </WidgetsInnerContainer>
    </>
  );
}

function SqlObjectListWrapper() {
  const db = useCurrentDatabase();

  if (!db) {
    return (
      <WidgetsInnerContainer>
        <ErrorInfo message="Database not selected" icon="img alert" />
      </WidgetsInnerContainer>
    );
  }
  const { name, connection } = db;

  return <SqlObjectList conid={connection._id} database={name} />;
  // return <div>tables of {db && db.name}</div>
  // return <div>tables of {JSON.stringify(db)}</div>
}

export default function DatabaseWidget() {
  const config = useConfig();
  return (
    <WidgetColumnBar>
      {!config.singleDatabase && (
        <WidgetColumnBarItem title="Connections" name="connections" height="50%">
          <ConnectionList />
        </WidgetColumnBarItem>
      )}
      <WidgetColumnBarItem title="Tables, views, functions" name="dbObjects">
        <SqlObjectListWrapper />
      </WidgetColumnBarItem>
    </WidgetColumnBar>
  );
}