fix!: pss target length verification

src/bee.ts

@@ -511,7 +511,7 @@ export class Bee {
    *
    * @param postageBatchId Postage BatchId that will be assigned to sent message
    * @param topic Topic name
-   * @param target Target message address prefix
+   * @param target Target message address prefix. Has a limit on length. Recommend to use `Utils.Pss.makeMaxTarget()` to get the most specific target that Bee node will accept.
    * @param data Message to be sent
    * @param recipient Recipient public key
    * @throws TypeError if `data`, `batchId`, `target` or `recipient` are in invalid format

src/modules/pss.ts

@@ -28,7 +28,7 @@ export async function send(
 ): Promise<void> {
   await http<BeeGenericResponse>(ky, {
     method: 'post',
-    path: `${endpoint}/send/${topic}/${target.slice(0, 4)}`,
+    path: `${endpoint}/send/${topic}/${target}`,
     body: await prepareData(data),
     responseType: 'json',
     searchParams: { recipient },

src/types/index.ts

@@ -21,6 +21,7 @@ export interface Dictionary<T> {
 }
 
 export const ADDRESS_HEX_LENGTH = 64
+export const PSS_TARGET_HEX_LENGTH_MAX = 4
 export const PUBKEY_HEX_LENGTH = 66
 export const BATCH_ID_HEX_LENGTH = 64
 export const REFERENCE_HEX_LENGTH = 64

src/utils/expose.ts

@@ -7,3 +7,4 @@ export * as Tar from './tar'
 export * as Eth from './eth'
 export * as Stream from './stream'
 export { keccak256Hash } from './hash'
+export { makeMaxTarget } from './pss'

src/utils/pss.ts

@@ -0,0 +1,16 @@
+import { AddressPrefix, PSS_TARGET_HEX_LENGTH_MAX } from '../types'
+
+/**
+ * Utility function that for given strings/reference takes the most specific
+ * target that Bee node will except.
+ *
+ * @param target is a non-prefixed hex string Bee address
+ * @see [Bee docs - PSS](https://docs.ethswarm.org/docs/dapps-on-swarm/pss)
+ */
+export function makeMaxTarget(target: string): AddressPrefix {
+  if (typeof target !== 'string') {
+    throw new TypeError('target has to be an string!')
+  }
+
+  return target.slice(0, PSS_TARGET_HEX_LENGTH_MAX)
+}

src/utils/type.ts

@@ -18,6 +18,7 @@ import {
   Tag,
   TAGS_LIMIT_MAX,
   TAGS_LIMIT_MIN,
+  PSS_TARGET_HEX_LENGTH_MAX,
   UploadOptions,
   TransactionHash,
 } from '../types'
@@ -191,9 +192,9 @@ export function assertTag(value: unknown): asserts value is Tag {
 export function assertAddressPrefix(value: unknown): asserts value is AddressPrefix {
   assertHexString(value, undefined, 'AddressPrefix')
 
-  if (value.length > ADDRESS_HEX_LENGTH) {
+  if (value.length > PSS_TARGET_HEX_LENGTH_MAX) {
     throw new BeeArgumentError(
-      `AddressPrefix must have length of ${ADDRESS_HEX_LENGTH} at most! Got string with ${value.length}`,
+      `AddressPrefix must have length of ${PSS_TARGET_HEX_LENGTH_MAX} at most! Got string with ${value.length}`,
       value,
     )
   }

test/integration/bee-class.browser.spec.ts

@@ -203,7 +203,7 @@ describe('Bee class - in browser', () => {
               const beePeer = new window.BeeJs.Bee(BEE_PEER_URL)
 
               const receive = bee.pssReceive(topic)
-              await beePeer.pssSend(batchIdPeer, topic, overlay, message)
+              await beePeer.pssSend(batchIdPeer, topic, window.BeeJs.Utils.makeMaxTarget(overlay), message)
 
               const msg = await receive
 
@@ -242,7 +242,13 @@ describe('Bee class - in browser', () => {
               const beePeer = new window.BeeJs.Bee(BEE_PEER_URL)
 
               const receive = bee.pssReceive(topic)
-              await beePeer.pssSend(batchIdPeer, topic, overlay, message, pssPublicKey)
+              await beePeer.pssSend(
+                batchIdPeer,
+                topic,
+                window.BeeJs.Utils.makeMaxTarget(overlay),
+                message,
+                pssPublicKey,
+              )
 
               const msg = await receive
 

test/integration/bee-class.spec.ts

@@ -1,4 +1,4 @@
-import { Bee, BeeArgumentError, BeeDebug, Collection } from '../../src'
+import { Bee, BeeArgumentError, BeeDebug, Collection, PssSubscription } from '../../src'
 import { makeSigner } from '../../src/chunk/signer'
 import { makeSOCAddress, uploadSingleOwnerChunkData } from '../../src/chunk/soc'
 import { ChunkReference } from '../../src/feed'
@@ -30,6 +30,7 @@ import {
 } from '../utils'
 import { Readable } from 'stream'
 import { TextEncoder } from 'util'
+import { makeMaxTarget } from '../../src/utils/pss'
 
 commonMatchers()
 
@@ -300,7 +301,7 @@ describe('Bee class', () => {
             })
 
             const { overlay } = await beeDebug.getNodeAddresses()
-            await beePeer.pssSend(getPostageBatch(BEE_DEBUG_PEER_URL), topic, overlay, message)
+            await beePeer.pssSend(getPostageBatch(BEE_DEBUG_PEER_URL), topic, makeMaxTarget(overlay), message)
           })().catch(reject)
         })
       },
@@ -323,7 +324,13 @@ describe('Bee class', () => {
             })
 
             const { overlay, pssPublicKey } = await beeDebug.getNodeAddresses()
-            await beePeer.pssSend(getPostageBatch(BEE_DEBUG_PEER_URL), topic, overlay, message, pssPublicKey)
+            await beePeer.pssSend(
+              getPostageBatch(BEE_DEBUG_PEER_URL),
+              topic,
+              makeMaxTarget(overlay),
+              message,
+              pssPublicKey,
+            )
           })().catch(reject)
         })
       },
@@ -334,15 +341,16 @@ describe('Bee class', () => {
       'should subscribe to topic',
       async () => {
         return new Promise<void>((resolve, reject) => {
+          let subscription: PssSubscription
           ;(async () => {
             const topic = 'bee-class-subscribe-topic'
             const message = new Uint8Array([1, 2, 3])
             const beeDebug = new BeeDebug(beeDebugUrl())
 
-            const subscription = bee.pssSubscribe(topic, {
+            subscription = bee.pssSubscribe(topic, {
               onMessage: receivedMessage => {
                 // without cancel jest complains for leaking handles and may hang
-                subscription.cancel()
+                subscription?.cancel()
 
                 expect(receivedMessage).toEqual(message)
                 resolve()
@@ -353,8 +361,12 @@ describe('Bee class', () => {
             })
 
             const { overlay } = await beeDebug.getNodeAddresses()
-            await beePeer.pssSend(getPostageBatch(BEE_DEBUG_PEER_URL), topic, overlay, message)
-          })().catch(reject)
+            await beePeer.pssSend(getPostageBatch(BEE_DEBUG_PEER_URL), topic, makeMaxTarget(overlay), message)
+          })().catch(e => {
+            // without cancel jest complains for leaking handles and may hang
+            subscription?.cancel()
+            reject(e)
+          })
         })
       },
       PSS_TIMEOUT,

test/integration/modules/pss.spec.ts

@@ -1,6 +1,7 @@
 import * as pss from '../../../src/modules/pss'
 import * as connectivity from '../../../src/modules/debug/connectivity'
 import { beeDebugKy, beeKy, beePeerDebugUrl, beePeerKy, beeUrl, getPostageBatch, PSS_TIMEOUT } from '../../utils'
+import { makeMaxTarget } from '../../../src/utils/pss'
 
 const BEE_KY = beeKy()
 const BEE_URL = beeUrl()
@@ -20,7 +21,7 @@ describe('modules/pss', () => {
       expect(peers.length).toBeGreaterThan(0)
 
       const target = peers[0].address
-      await pss.send(BEE_KY, topic, target, message, getPostageBatch()) // Nothing is asserted as nothing is returned, will throw error if something is wrong
+      await pss.send(BEE_KY, topic, makeMaxTarget(target), message, getPostageBatch()) // Nothing is asserted as nothing is returned, will throw error if something is wrong
     },
     PSS_TIMEOUT,
   )
@@ -48,7 +49,7 @@ describe('modules/pss', () => {
 
           const addresses = await connectivity.getNodeAddresses(BEE_DEBUG_KY)
           const target = addresses.overlay
-          await pss.send(BEE_PEER_KY, topic, target, message, getPostageBatch(BEE_DEBUG_PEER_URL))
+          await pss.send(BEE_PEER_KY, topic, makeMaxTarget(target), message, getPostageBatch(BEE_DEBUG_PEER_URL))
         })().catch(reject)
       })
     },
@@ -80,7 +81,14 @@ describe('modules/pss', () => {
           const addresses = await connectivity.getNodeAddresses(BEE_DEBUG_KY)
           const target = addresses.overlay
           const recipient = addresses.pssPublicKey
-          await pss.send(BEE_PEER_KY, topic, target, message, getPostageBatch(BEE_DEBUG_PEER_URL), recipient)
+          await pss.send(
+            BEE_PEER_KY,
+            topic,
+            makeMaxTarget(target),
+            message,
+            getPostageBatch(BEE_DEBUG_PEER_URL),
+            recipient,
+          )
         })().catch(reject)
       })
     },

test/unit/assertions.ts

@@ -141,19 +141,13 @@ export function testAddressPrefixAssertions(executor: (input: unknown) => void):
     await expect(() => executor('')).rejects.toThrow(TypeError)
 
     // Not an valid hexstring (ZZZ)
-    await expect(() => executor('ZZZfb5a872396d9693e5c9f9d7233cfa93f395c093371017ff44aa9ae6564cdd')).rejects.toThrow(
-      TypeError,
-    )
+    await expect(() => executor('ZZZf')).rejects.toThrow(TypeError)
 
     // Prefixed hexstring is not accepted
-    await expect(() => executor('0x634fb5a872396d9693e5c9f9d7233cfa93f395c093371017ff44aa9ae6564cdd')).rejects.toThrow(
-      TypeError,
-    )
+    await expect(() => executor('0x634f')).rejects.toThrow(TypeError)
 
     // Too long hexstring
-    await expect(() => executor('123634fb5a872396d9693e5c9f9d7233cfa93f395c093371017ff44aa9ae6564cdd')).rejects.toThrow(
-      BeeArgumentError,
-    )
+    await expect(() => executor('12364')).rejects.toThrow(BeeArgumentError)
   })
 }