Skip to content

Commit 1d18c3b

Browse files
committed
#RI-810 - integration with consumer groups list
1 parent 6df7166 commit 1d18c3b

File tree

3 files changed

+17
-6
lines changed

3 files changed

+17
-6
lines changed

redisinsight/ui/src/constants/keys.ts

Lines changed: 13 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -118,12 +118,24 @@ export const KEY_TYPES_ACTIONS: KeyTypesActions = Object.freeze({
118118
[KeyTypes.ReJSON]: {}
119119
})
120120

121+
export const STREAM_ADD_GROUP_VIEW_TYPES = [
122+
StreamViewType.Groups,
123+
StreamViewType.Consumers,
124+
StreamViewType.Messages
125+
]
126+
121127
export const STREAM_ADD_ACTION = Object.freeze({
122-
[StreamViewType.Streams]: {
128+
[StreamViewType.Data]: {
123129
name: 'New Entry'
124130
},
125131
[StreamViewType.Groups]: {
126132
name: 'New Group'
133+
},
134+
[StreamViewType.Consumers]: {
135+
name: 'New Group'
136+
},
137+
[StreamViewType.Messages]: {
138+
name: 'New Group'
127139
}
128140
})
129141

redisinsight/ui/src/pages/browser/components/key-details/KeyDetails/KeyDetails.tsx

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ import {
2323
keysSelector,
2424
} from 'uiSrc/slices/browser/keys'
2525
import { cleanRangeFilter, streamSelector } from 'uiSrc/slices/browser/stream'
26-
import { KeyTypes, ModulesKeyTypes, MODULES_KEY_TYPES_NAMES } from 'uiSrc/constants'
26+
import { KeyTypes, ModulesKeyTypes, MODULES_KEY_TYPES_NAMES, STREAM_ADD_GROUP_VIEW_TYPES } from 'uiSrc/constants'
2727
import { connectedInstanceSelector } from 'uiSrc/slices/instances/instances'
2828
import { StreamViewType } from 'uiSrc/slices/interfaces/stream'
2929
import { sendEventTelemetry, TelemetryEvent, getBasedOnViewTypeEvent } from 'uiSrc/telemetry'
@@ -207,10 +207,10 @@ const KeyDetails = ({ ...props }: Props) => {
207207
)}
208208
{selectedKeyType === KeyTypes.Stream && (
209209
<>
210-
{streamViewType === StreamViewType.Streams && (
210+
{streamViewType === StreamViewType.Data && (
211211
<AddStreamEntries onCancel={closeAddItemPanel} />
212212
)}
213-
{streamViewType === StreamViewType.Groups && (
213+
{STREAM_ADD_GROUP_VIEW_TYPES.includes(streamViewType) && (
214214
<AddStreamGroup onCancel={closeAddItemPanel} />
215215
)}
216216
</>

redisinsight/ui/src/slices/browser/stream.ts

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -490,8 +490,7 @@ export function addNewGroupAction(
490490

491491
if (isStatusSuccessful(status)) {
492492
dispatch(addNewGroupSuccess())
493-
// TODO refreshStreamGroups
494-
//dispatch<any>(refreshStreamEntries(data.keyName, false))
493+
dispatch<any>(fetchConsumerGroups(false))
495494
dispatch<any>(refreshKeyInfoAction(data.keyName))
496495
onSuccess?.()
497496
}

0 commit comments

Comments
 (0)