Update @streamr/sdk to 102.0.0. Add version identifier to the node table.

Author: tumppi

package-lock.json

@@ -47,7 +47,7 @@
     "@sentry/react": "^8.34.0",
     "@streamr/config": "^5.4.0",
     "@streamr/hub-contracts": "^1.1.2",
-    "@streamr/sdk": "^101.1.2",
+    "@streamr/sdk": "^102.0.0",
     "@streamr/streamr-icons": "^0.1.9",
     "@streamr/streamr-layout": "^2.5.3",
     "@tanstack/react-query": "^5.51.21",
@@ -100,8 +100,7 @@
     "rich-markdown-editor": "^11.21.3",
     "storybook": "^8.3.3",
     "stream-browserify": "^3.0.0",
-    "streamr-client-protocol": "^13.0.0",
-    "streamr-client-react": "^3.1.0-internal.5",
+    "streamr-client-react": "^3.3.0",
     "stringify-object": "^5.0.0",
     "styled-components": "^5.3.10",
     "toasterhea": "^1.0.4",

package.json

@@ -33,13 +33,17 @@ export function useInterceptHeartbeats(operatorId: string | undefined) {
                 }
 
                 const {
-                    parsedContent: { peerDescriptor },
+                    parsedContent: { peerDescriptor, applicationVersion },
                     messageId: { timestamp },
                 } = message as HeartbeatMessage
 
                 setHeartbeats((prev) => ({
                     ...prev,
-                    [peerDescriptor.nodeId]: { ...peerDescriptor, timestamp },
+                    [peerDescriptor.nodeId]: {
+                        ...peerDescriptor,
+                        timestamp,
+                        applicationVersion,
+                    },
                 }))
             },
         },
@@ -54,6 +58,7 @@ const HeartbeatMessage = z.object({
     }),
     parsedContent: z.object({
         msgType: z.literal('heartbeat'),
+        applicationVersion: z.string().optional(),
         peerDescriptor: z.object({
             nodeId: z.string(),
             type: z.optional(z.nativeEnum(NetworkNodeType)),
@@ -78,4 +83,5 @@ function isHeartbeatMessage(arg: unknown): arg is HeartbeatMessage {
 
 export type Heartbeat = HeartbeatMessage['parsedContent']['peerDescriptor'] & {
     timestamp: number
+    applicationVersion: string | undefined
 }

src/hooks/useInterceptHeartbeats.ts

@@ -48,6 +48,13 @@ export function LiveNodesTable({
                     valueMapper: ({ timestamp }) =>
                         moment(timestamp).format('YYYY-MM-DD HH:mm'),
                 },
+                {
+                    align: 'start',
+                    displayName: 'Version',
+                    isSticky: false,
+                    key: 'version',
+                    valueMapper: ({ applicationVersion }) => applicationVersion || 'N/A',
+                },
                 {
                     align: 'start',
                     displayName: 'Host',

src/pages/OperatorPage/LiveNodesTable.tsx

@@ -154,7 +154,7 @@ export function UndelegationQueue({ operatorId }: Props) {
                     ),
                     align: 'end',
                     isSticky: false,
-                    key: 'requestDate',
+                    key: 'requestTime',
                 },
                 {
                     displayName: '',

src/pages/OperatorPage/UndelegationQueue.tsx

@@ -294,7 +294,10 @@ function StreamEntityForm(props: StreamEntityFormProps) {
                  * and, if so, invalidate associated stream abilities.
                  */
 
-                if ('user' in assignment && assignment.user.toLowerCase() === account) {
+                if (
+                    'userId' in assignment &&
+                    assignment.userId.toLowerCase() === account
+                ) {
                     invalidateAbilities(streamId, account)
 
                     break

src/pages/StreamPage/index.tsx

@@ -34,7 +34,8 @@ export function parseStream(value: unknown, options: ParseStreamOptions) {
         const permissions: Record<string, number | null | undefined> = {}
 
         permissionAssignments.forEach((assignment) => {
-            const user = 'user' in assignment ? assignment.user.toLowerCase() : address0
+            const user =
+                'userId' in assignment ? assignment.userId.toLowerCase() : address0
 
             permissions[user] = assignment.permissions.reduce(
                 (memo, permission) => memo | Bits[permission],

src/parsers/StreamParser.ts

@@ -69,13 +69,8 @@ const UnstyledStreamPreview: FunctionComponent<StreamPreviewPros> = ({
     )
     const [partition, setPartition] = useState<number>(activePartition)
     const [loading, setIsLoading] = useState<boolean>()
-    const [stream, setStream] = useState<Stream>()
-    const { partitions } = stream?.getMetadata() || {}
-    const partitionOptions = useMemo(
-        () =>
-            partitions ? [...new Array(partitions)].map((_, index) => index) : undefined,
-        [partitions],
-    )
+    const [_, setStream] = useState<Stream>()
+    const [partitions, setPartitions] = useState<number>()
     const streamData = useStreamData(selectedStreamId, {
         tail: 20,
         partition,
@@ -85,14 +80,26 @@ const UnstyledStreamPreview: FunctionComponent<StreamPreviewPros> = ({
         const loadStreamData = async () => {
             if (client) {
                 setIsLoading(true)
-                const result = await client.getStream(selectedStreamId)
-                setIsLoading(false)
-                setStream(result)
+                try {
+                    const result = await client.getStream(selectedStreamId)
+                    setStream(result)
+                    const metadata = await result.getMetadata()
+                    const partitionCount = metadata.partitions as number
+                    setPartitions(partitionCount)
+                } finally {
+                    setIsLoading(false)
+                }
             }
         }
         loadStreamData()
     }, [selectedStreamId, client])
 
+    const partitionOptions = useMemo(
+        () =>
+            partitions ? [...new Array(partitions)].map((_, index) => index) : undefined,
+        [partitions],
+    )
+
     return (
         <>
             <LoadingIndicator loading={loading} />

src/shared/components/StreamPreview/index.tsx

@@ -105,7 +105,7 @@ const useStreamAbilitiesStore = create<Store>((set, get) => {
                               public: true,
                           }
                         : {
-                              user: account,
+                              userId: account,
                               permission,
                               allowPublic: true,
                           },

src/shared/stores/streamAbilities.ts

@@ -96,7 +96,7 @@ export function useStreamEntityQuery() {
                     throw new StreamNotFoundError(streamId)
                 }
 
-                const metadata = stream.getMetadata()
+                const metadata = await stream.getMetadata()
 
                 let storageNodes: string[] | undefined
 
@@ -215,7 +215,7 @@ export function usePersistStreamDraft(options: UsePersistStreamDraftOptions = {}
                 }
 
                 permissionAssignments.push({
-                    user: account,
+                    userId: account,
                     permissions,
                 })
             }
@@ -419,10 +419,11 @@ export function usePersistStreamDraft(options: UsePersistStreamDraftOptions = {}
 
                         await checkBalance(client)
 
-                        return client.updateStream({
+                        await client.setStreamMetadata(streamId, {
                             ...finalMetadata,
-                            id: streamId,
                         })
+
+                        return client.getStream(streamId)
                     }
 
                     client = await getStreamrClientInstance(chainId)
@@ -431,10 +432,11 @@ export function usePersistStreamDraft(options: UsePersistStreamDraftOptions = {}
                 })()
 
                 const currentStreamId = stream.id
+                const currentMetadata = await stream.getMetadata()
 
                 const newMetadata = parseStream(stream, {
                     chainId,
-                    metadata: stream.getMetadata(),
+                    metadata: currentMetadata,
                 }).metadata
 
                 update((hot, cold) => {