feat: add isWarmingUp flag to getStatus (#1054)

* feat: add isWarmingUp flag to getStatus

* chore: fix lint issues

Author: Cafe137

src/manifest/manifest.ts

@@ -33,6 +33,7 @@ export class Fork {
       b.prefix = b.prefix.slice(commonPart.length)
       b.node.parent = a.node
       a.node.forks.set(remainingB[0], b)
+
       return a
     }
 
@@ -42,6 +43,7 @@ export class Fork {
       a.prefix = a.prefix.slice(commonPart.length)
       a.node.parent = b.node
       b.node.forks.set(remainingA[0], a)
+
       return b
     }
 

src/modules/debug/status.ts

@@ -37,6 +37,7 @@ export async function getDebugStatus(requestOptions: BeeRequestOptions): Promise
     isReachable: Types.asBoolean(body.isReachable, { name: 'isReachable' }),
     lastSyncedBlock: Types.asNumber(body.lastSyncedBlock, { name: 'lastSyncedBlock' }),
     committedDepth: Types.asNumber(body.committedDepth, { name: 'committedDepth' }),
+    isWarmingUp: Types.asBoolean(body.isWarmingUp, { name: 'isWarmingUp' }),
   }
 }
 

src/modules/status.ts

@@ -19,6 +19,7 @@ export async function isGateway(requestOptions: BeeRequestOptions): Promise<bool
       url: '/gateway',
     })
     const data = Types.asObject(response.data)
+
     return Types.asBoolean(data.gateway)
   } catch (error) {
     return false

src/types/debug.ts

@@ -105,6 +105,7 @@ export interface DebugStatus {
   isReachable: boolean
   lastSyncedBlock: number
   committedDepth: number
+  isWarmingUp: boolean
 }
 
 export interface Health {

test/integration/feed.ux.spec.ts

@@ -10,7 +10,7 @@ test('Feed read/write as payload', async () => {
   writer.uploadPayload(batch(), 'Feed payload', { deferred: false })
 
   await System.waitFor(
-    () => bee.isFeedRetrievable(writer.owner, writer.topic, FeedIndex.fromBigInt(0n)),
+    async () => bee.isFeedRetrievable(writer.owner, writer.topic, FeedIndex.fromBigInt(0n)),
     Dates.seconds(1),
     30,
   )
@@ -32,7 +32,7 @@ test('Feed read/write as reference', async () => {
   await writer.uploadReference(batch(), uploadResult.reference)
 
   await System.waitFor(
-    () => bee.isFeedRetrievable(writer.owner, writer.topic, FeedIndex.fromBigInt(0n)),
+    async () => bee.isFeedRetrievable(writer.owner, writer.topic, FeedIndex.fromBigInt(0n)),
     Dates.seconds(1),
     30,
   )
@@ -52,7 +52,7 @@ test('Feed read/write 40 bytes payload', async () => {
   writer.uploadPayload(batch(), 'This string is exactly 40 bytes in utf-8', { deferred: false })
 
   await System.waitFor(
-    () => bee.isFeedRetrievable(writer.owner, writer.topic, FeedIndex.fromBigInt(0n)),
+    async () => bee.isFeedRetrievable(writer.owner, writer.topic, FeedIndex.fromBigInt(0n)),
     Dates.seconds(1),
     30,
   )
@@ -70,7 +70,7 @@ test('Feed read/write as payload when data does not fit into one chunk', async (
   writer.uploadPayload(batch(), text, { deferred: false })
 
   await System.waitFor(
-    () => bee.isFeedRetrievable(writer.owner, writer.topic, FeedIndex.fromBigInt(0n)),
+    async () => bee.isFeedRetrievable(writer.owner, writer.topic, FeedIndex.fromBigInt(0n)),
     Dates.seconds(1),
     30,
   )

test/integration/stamp.ux.spec.ts

@@ -45,7 +45,7 @@ test('bee.getSizeExtensionCost', async () => {
     )
     expect(cost.toSignificantDigits(3)).toBe('72.011')
 
-    await expect(() =>
+    await expect(async () =>
       bee.getSizeExtensionCost(
         'f8b2ad296d64824a8fe51a33ff15fe8668df13a20ad3d4eea4bb97ca600029aa',
         Size.fromGigabytes(1),
@@ -72,7 +72,7 @@ test('bee.buyStorage with extensions', async () => {
     await bee.extendStorageDuration(batchId, Duration.fromDays(1))
     await bee.extendStorageSize(batchId, Size.fromGigabytes(8))
     await bee.extendStorageSize(batchId, Size.fromGigabytes(24))
-    await expect(() => bee.extendStorageSize(batchId, Size.fromGigabytes(1))).rejects.toThrow(
+    await expect(async () => bee.extendStorageSize(batchId, Size.fromGigabytes(1))).rejects.toThrow(
       'New depth has to be greater than the original depth',
     )
   })

test/integration/status.spec.ts

@@ -78,6 +78,8 @@ test('GET wallet', async () => {
 test('GET status', async () => {
   const status = await bee.getStatus()
   expect(status).toBeTruthy()
+  expect(status.beeMode).toBe('full')
+  expect(status.isWarmingUp).toBe(false)
 })
 
 test('GET topology', async () => {

test/integration/withdraw.spec.ts

@@ -10,6 +10,7 @@ test('withdraw to external wallet', async () => {
   await System.waitFor(
     async () => {
       const pendingTransactions = await bee.getAllPendingTransactions()
+
       return pendingTransactions.length === 0
     },
     Dates.seconds(1),
@@ -20,6 +21,7 @@ test('withdraw to external wallet', async () => {
   await System.waitFor(
     async () => {
       const pendingTransactions = await bee.getAllPendingTransactions()
+
       return pendingTransactions.length === 0
     },
     Dates.seconds(1),

test/unit/ws-undefined.spec.ts

@@ -7,8 +7,12 @@ test('WebSocket undefined headers', async () => {
   })
 
   const subscription = bee.gsocSubscribe(NULL_OWNER, NULL_IDENTIFIER, {
-    onMessage: () => {},
-    onError: () => {},
+    onMessage: () => {
+      void 0
+    },
+    onError: () => {
+      void 0
+    },
   })
 
   subscription.cancel()