integration-tests: video counter and moderator action tests fail if p…

…rocessor is behind
Joystream · Jan 11, 2024 · 78c5d4d · 78c5d4d
1 parent 8e88b27
commit 78c5d4d
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 1 deletion.
diff --git a/tests/network-tests/package.json b/tests/network-tests/package.json
@@ -33,7 +33,8 @@
     "long": "^4.0.0",
     "node-cleanup": "^2.1.2",
     "@joystream/js": "^1.6.0",
-    "uuid": "^7.0.3"
+    "uuid": "^7.0.3",
+    "sleep-promise": "^9.1.0"
   },
   "devDependencies": {
     "@graphql-codegen/cli": "^1.21.4",

diff --git a/tests/network-tests/src/flows/content/activeVideoCounters.ts b/tests/network-tests/src/flows/content/activeVideoCounters.ts
@@ -9,6 +9,7 @@ import {
 } from '../../fixtures/content'
 import BN from 'bn.js'
 import { createJoystreamCli } from '../utils'
+import sleep from 'sleep-promise'
 
 export default async function activeVideoCounters({ api, query, env }: FlowProps): Promise<void> {
   const debug = extendDebug('flow:active-video-counters')
@@ -50,6 +51,9 @@ export default async function activeVideoCounters({ api, query, env }: FlowProps
   await new FixtureRunner(createChannelsAndVideos).run()
   const { channelIds, videosData } = createChannelsAndVideos.getCreatedItems()
 
+  // Allow time for processor to process videos created
+  await sleep(10 * 1000)
+
   // check that active video counters are working
   const activeVideoCountersFixture = new ActiveVideoCountersFixture(
     api,

diff --git a/tests/network-tests/src/flows/content/curatorModerationActions.ts b/tests/network-tests/src/flows/content/curatorModerationActions.ts
@@ -25,6 +25,7 @@ import {
   DeleteChannelAsModeratorFixture,
   DeleteChannelAsModeratorParams,
 } from '../../fixtures/content/curatorModeration/DeleteChannelAsModerator'
+import sleep from 'sleep-promise'
 
 export default async function curatorModerationActions({ api, query, env }: FlowProps): Promise<void> {
   const debug = extendDebug('flow:curator-moderation-actions')
@@ -108,6 +109,9 @@ export default async function curatorModerationActions({ api, query, env }: Flow
   const addCuratorToGroupFixture = new AddCuratorToCuratorGroupFixture(api, query, addCuratorToGroupParams)
   await new FixtureRunner(addCuratorToGroupFixture).run()
 
+  // Allow time for processor to process videos created
+  await sleep(10 * 1000)
+
   // test curator moderation actions
 
   /**