ExportArchiveDataPage.tsx 5.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200
  1. import React, { type JSX, useCallback, useEffect, useState } from 'react';
  2. import { useTranslation } from 'react-i18next';
  3. import { apiDelete } from '~/client/util/apiv1-client';
  4. import { apiv3Get } from '~/client/util/apiv3-client';
  5. import { toastError, toastSuccess } from '~/client/util/toastr';
  6. import { useAdminSocket } from '~/features/admin/states/socket-io';
  7. import LabeledProgressBar from './Common/LabeledProgressBar';
  8. import ArchiveFilesTable from './ExportArchiveData/ArchiveFilesTable';
  9. import SelectCollectionsModal from './ExportArchiveData/SelectCollectionsModal';
  10. const IGNORED_COLLECTION_NAMES = [
  11. 'sessions',
  12. 'rlflx',
  13. 'yjs-writings',
  14. 'transferkeys',
  15. ];
  16. const ExportArchiveDataPage = (): JSX.Element => {
  17. const socket = useAdminSocket();
  18. const { t } = useTranslation('admin');
  19. const [collections, setCollections] = useState<any[]>([]);
  20. const [zipFileStats, setZipFileStats] = useState<any[]>([]);
  21. const [progressList, setProgressList] = useState<any[]>([]);
  22. const [isExportModalOpen, setExportModalOpen] = useState(false);
  23. const [isExporting, setExporting] = useState(false);
  24. const [isZipping, setZipping] = useState(false);
  25. const [isExported, setExported] = useState(false);
  26. const fetchData = useCallback(async () => {
  27. const [{ data: collectionsData }, { data: statusData }] = await Promise.all(
  28. [
  29. apiv3Get<{ collections: any[] }>('/mongo/collections', {}),
  30. apiv3Get<{
  31. status: {
  32. zipFileStats: any[];
  33. isExporting: boolean;
  34. progressList: any[];
  35. };
  36. }>('/export/status', {}),
  37. ],
  38. );
  39. // filter only not ignored collection names
  40. const filteredCollections = collectionsData.collections.filter(
  41. (collectionName) => {
  42. return !IGNORED_COLLECTION_NAMES.includes(collectionName);
  43. },
  44. );
  45. const { zipFileStats, isExporting, progressList } = statusData.status;
  46. setCollections(filteredCollections);
  47. setZipFileStats(zipFileStats);
  48. setExporting(isExporting);
  49. setProgressList(progressList);
  50. }, []);
  51. const setupWebsocketEventHandler = useCallback(() => {
  52. if (socket == null) {
  53. return () => {};
  54. }
  55. const onProgress = ({ currentCount, totalCount, progressList }) => {
  56. setExporting(true);
  57. setProgressList(progressList);
  58. };
  59. const onStartZipping = () => {
  60. setZipping(true);
  61. };
  62. const onTerminateForExport = ({ addedZipFileStat }) => {
  63. setExporting(false);
  64. setZipping(false);
  65. setExported(true);
  66. setZipFileStats((prev) => prev.concat([addedZipFileStat]));
  67. toastSuccess(`New Archive Data '${addedZipFileStat.fileName}' is added`);
  68. };
  69. // Add listeners
  70. socket.on('admin:onProgressForExport', onProgress);
  71. socket.on('admin:onStartZippingForExport', onStartZipping);
  72. socket.on('admin:onTerminateForExport', onTerminateForExport);
  73. // Cleanup listeners
  74. return () => {
  75. socket.off('admin:onProgressForExport', onProgress);
  76. socket.off('admin:onStartZippingForExport', onStartZipping);
  77. socket.off('admin:onTerminateForExport', onTerminateForExport);
  78. };
  79. }, [socket]);
  80. const onZipFileStatRemove = useCallback(async (fileName) => {
  81. try {
  82. await apiDelete(`/v3/export/${fileName}`, {});
  83. setZipFileStats((prev) =>
  84. prev.filter((stat) => stat.fileName !== fileName),
  85. );
  86. toastSuccess(`Deleted ${fileName}`);
  87. } catch (err) {
  88. toastError(err);
  89. }
  90. }, []);
  91. const exportingRequestedHandler = useCallback(() => {}, []);
  92. const renderProgressBarsForCollections = useCallback(() => {
  93. const cols = progressList.map((progressData) => {
  94. const { collectionName, currentCount, totalCount } = progressData;
  95. return (
  96. <div className="col-md-6" key={collectionName}>
  97. <LabeledProgressBar
  98. header={collectionName}
  99. currentCount={currentCount}
  100. totalCount={totalCount}
  101. />
  102. </div>
  103. );
  104. });
  105. return <div className="row px-3">{cols}</div>;
  106. }, [progressList]);
  107. const renderProgressBarForZipping = useCallback(() => {
  108. const showZippingBar = isZipping || isExported;
  109. if (!showZippingBar) {
  110. return <></>;
  111. }
  112. return (
  113. <div className="row px-3">
  114. <div className="col-md-12" key="progressBarForZipping">
  115. <LabeledProgressBar
  116. header="Zip Files"
  117. currentCount={1}
  118. totalCount={1}
  119. isInProgress={isZipping}
  120. />
  121. </div>
  122. </div>
  123. );
  124. }, [isExported, isZipping]);
  125. useEffect(() => {
  126. fetchData();
  127. const cleanupWebsocket = setupWebsocketEventHandler();
  128. return () => {
  129. if (cleanupWebsocket) cleanupWebsocket();
  130. };
  131. }, [fetchData, setupWebsocketEventHandler]);
  132. const showExportingData = (isExported || isExporting) && progressList != null;
  133. return (
  134. <div data-testid="admin-export-archive-data">
  135. <h2>{t('export_management.export_archive_data')}</h2>
  136. <button
  137. type="button"
  138. className="btn btn-outline-secondary"
  139. disabled={isExporting}
  140. onClick={() => setExportModalOpen(true)}
  141. >
  142. {t('export_management.create_new_archive_data')}
  143. </button>
  144. {showExportingData && (
  145. <div className="mt-5">
  146. <h3>{t('export_management.exporting_collection_list')}</h3>
  147. {renderProgressBarsForCollections()}
  148. {renderProgressBarForZipping()}
  149. </div>
  150. )}
  151. <div className="mt-5">
  152. <h3 className="mb-3">{t('export_management.exported_data_list')}</h3>
  153. <ArchiveFilesTable
  154. zipFileStats={zipFileStats}
  155. onZipFileStatRemove={onZipFileStatRemove}
  156. />
  157. </div>
  158. <SelectCollectionsModal
  159. isOpen={isExportModalOpen}
  160. onExportingRequested={exportingRequestedHandler}
  161. onClose={() => setExportModalOpen(false)}
  162. collections={collections}
  163. />
  164. </div>
  165. );
  166. };
  167. export default ExportArchiveDataPage;