New.tsx 9.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258
  1. import React from 'react';
  2. import { ClusterName, CleanupPolicy, TopicFormData, TopicName } from 'redux/interfaces';
  3. import Breadcrumb from 'components/common/Breadcrumb/Breadcrumb';
  4. import CustomParamsContainer from "./CustomParams/CustomParamsContainer";
  5. import { clusterTopicsPath } from 'lib/paths';
  6. import { useForm, FormContext, ErrorMessage } from 'react-hook-form';
  7. import {
  8. TOPIC_NAME_VALIDATION_PATTERN,
  9. MILLISECONDS_IN_DAY,
  10. BYTES_IN_GB,
  11. } from 'lib/constants';
  12. interface Props {
  13. clusterName: ClusterName;
  14. isTopicCreated: boolean;
  15. createTopic: (clusterName: ClusterName, form: TopicFormData) => void;
  16. redirectToTopicPath: (clusterName: ClusterName, topicName: TopicName) => void;
  17. resetUploadedState: () => void;
  18. }
  19. const New: React.FC<Props> = ({
  20. clusterName,
  21. isTopicCreated,
  22. createTopic,
  23. redirectToTopicPath,
  24. resetUploadedState
  25. }) => {
  26. const methods = useForm<TopicFormData>();
  27. const [isSubmitting, setIsSubmitting] = React.useState<boolean>(false);
  28. React.useEffect(
  29. () => {
  30. if (isSubmitting && isTopicCreated) {
  31. const {name} = methods.getValues();
  32. redirectToTopicPath(clusterName, name);
  33. }
  34. },
  35. [isSubmitting, isTopicCreated, redirectToTopicPath, clusterName, methods.getValues],
  36. );
  37. const onSubmit = async (data: TopicFormData) => {
  38. //TODO: need to fix loader. After success loading the first time, we won't wait for creation any more, because state is
  39. //loaded, and we will try to get entity immediately after pressing the button, and we will receive null
  40. //going to object page on the second creation. Resetting loaded state is workaround, need to tweak loader logic
  41. resetUploadedState();
  42. setIsSubmitting(true);
  43. createTopic(clusterName, data);
  44. };
  45. return (
  46. <div className="section">
  47. <div className="level">
  48. <div className="level-item level-left">
  49. <Breadcrumb links={[
  50. {href: clusterTopicsPath(clusterName), label: 'All Topics'},
  51. ]}>
  52. New Topic
  53. </Breadcrumb>
  54. </div>
  55. </div>
  56. <div className="box">
  57. <FormContext {...methods}>
  58. <form onSubmit={methods.handleSubmit(onSubmit)}>
  59. <div className="columns">
  60. <div className="column is-three-quarters">
  61. <label className="label">
  62. Topic Name *
  63. </label>
  64. <input
  65. className="input"
  66. placeholder="Topic Name"
  67. ref={methods.register({
  68. required: 'Topic Name is required.',
  69. pattern: {
  70. value: TOPIC_NAME_VALIDATION_PATTERN,
  71. message: 'Only alphanumeric, _, -, and . allowed',
  72. },
  73. })}
  74. name="name"
  75. autoComplete="off"
  76. disabled={isSubmitting}
  77. />
  78. <p className="help is-danger">
  79. <ErrorMessage errors={methods.errors} name="name"/>
  80. </p>
  81. </div>
  82. <div className="column">
  83. <label className="label">
  84. Number of partitions *
  85. </label>
  86. <input
  87. className="input"
  88. type="number"
  89. placeholder="Number of partitions"
  90. defaultValue="1"
  91. ref={methods.register({required: 'Number of partitions is required.'})}
  92. name="partitions"
  93. disabled={isSubmitting}
  94. />
  95. <p className="help is-danger">
  96. <ErrorMessage errors={methods.errors} name="partitions"/>
  97. </p>
  98. </div>
  99. </div>
  100. <div className="columns">
  101. <div className="column">
  102. <label className="label">
  103. Replication Factor *
  104. </label>
  105. <input
  106. className="input"
  107. type="number"
  108. placeholder="Replication Factor"
  109. defaultValue="1"
  110. ref={methods.register({required: 'Replication Factor is required.'})}
  111. name="replicationFactor"
  112. disabled={isSubmitting}
  113. />
  114. <p className="help is-danger">
  115. <ErrorMessage errors={methods.errors} name="replicationFactor"/>
  116. </p>
  117. </div>
  118. <div className="column">
  119. <label className="label">
  120. Min In Sync Replicas *
  121. </label>
  122. <input
  123. className="input"
  124. type="number"
  125. placeholder="Replication Factor"
  126. defaultValue="1"
  127. ref={methods.register({required: 'Min In Sync Replicas is required.'})}
  128. name="minInSyncReplicas"
  129. disabled={isSubmitting}
  130. />
  131. <p className="help is-danger">
  132. <ErrorMessage errors={methods.errors} name="minInSyncReplicas"/>
  133. </p>
  134. </div>
  135. </div>
  136. <div className="columns">
  137. <div className="column is-one-third">
  138. <label className="label">
  139. Cleanup policy
  140. </label>
  141. <div className="select is-block">
  142. <select
  143. defaultValue={CleanupPolicy.Delete}
  144. name="cleanupPolicy"
  145. ref={methods.register}
  146. disabled={isSubmitting}
  147. >
  148. <option value={CleanupPolicy.Delete}>
  149. Delete
  150. </option>
  151. <option value={CleanupPolicy.Compact}>
  152. Compact
  153. </option>
  154. </select>
  155. </div>
  156. </div>
  157. <div className="column is-one-third">
  158. <label className="label">
  159. Time to retain data
  160. </label>
  161. <div className="select is-block">
  162. <select
  163. defaultValue={MILLISECONDS_IN_DAY * 7}
  164. name="retentionMs"
  165. ref={methods.register}
  166. disabled={isSubmitting}
  167. >
  168. <option value={MILLISECONDS_IN_DAY / 2}>
  169. 12 hours
  170. </option>
  171. <option value={MILLISECONDS_IN_DAY}>
  172. 1 day
  173. </option>
  174. <option value={MILLISECONDS_IN_DAY * 2}>
  175. 2 days
  176. </option>
  177. <option value={MILLISECONDS_IN_DAY * 7}>
  178. 1 week
  179. </option>
  180. <option value={MILLISECONDS_IN_DAY * 7 * 4}>
  181. 4 weeks
  182. </option>
  183. </select>
  184. </div>
  185. </div>
  186. <div className="column is-one-third">
  187. <label className="label">
  188. Max size on disk in GB
  189. </label>
  190. <div className="select is-block">
  191. <select
  192. defaultValue={-1}
  193. name="retentionBytes"
  194. ref={methods.register}
  195. disabled={isSubmitting}
  196. >
  197. <option value={-1}>
  198. Not Set
  199. </option>
  200. <option value={BYTES_IN_GB}>
  201. 1 GB
  202. </option>
  203. <option value={BYTES_IN_GB * 10}>
  204. 10 GB
  205. </option>
  206. <option value={BYTES_IN_GB * 20}>
  207. 20 GB
  208. </option>
  209. <option value={BYTES_IN_GB * 50}>
  210. 50 GB
  211. </option>
  212. </select>
  213. </div>
  214. </div>
  215. </div>
  216. <div className="columns">
  217. <div className="column">
  218. <label className="label">
  219. Maximum message size in bytes *
  220. </label>
  221. <input
  222. className="input"
  223. type="number"
  224. defaultValue="1000012"
  225. ref={methods.register({required: 'Maximum message size in bytes is required'})}
  226. name="maxMessageBytes"
  227. disabled={isSubmitting}
  228. />
  229. <p className="help is-danger">
  230. <ErrorMessage errors={methods.errors} name="maxMessageBytes"/>
  231. </p>
  232. </div>
  233. </div>
  234. <CustomParamsContainer isSubmitting={isSubmitting} />
  235. <input type="submit" className="button is-primary" disabled={isSubmitting}/>
  236. </form>
  237. </FormContext>
  238. </div>
  239. </div>
  240. );
  241. };
  242. export default New;