Browse Source

Integration tests - fix debugging

Leszek Wiesner 3 years ago
parent
commit
8d7005f602
37 changed files with 79 additions and 70 deletions
  1. 1 1
      tests/integration-tests/run-storage-node-tests.sh
  2. 1 1
      tests/integration-tests/run-test-scenario.sh
  3. 2 2
      tests/integration-tests/src/Api.ts
  4. 9 0
      tests/integration-tests/src/Debugger.ts
  5. 2 2
      tests/integration-tests/src/Fixture.ts
  6. 2 2
      tests/integration-tests/src/Job.ts
  7. 2 2
      tests/integration-tests/src/QueryNodeApi.ts
  8. 2 2
      tests/integration-tests/src/Resources.ts
  9. 2 2
      tests/integration-tests/src/Scenario.ts
  10. 2 2
      tests/integration-tests/src/flows/council/elect.ts
  11. 2 2
      tests/integration-tests/src/flows/forum/categories.ts
  12. 2 2
      tests/integration-tests/src/flows/forum/moderation.ts
  13. 2 2
      tests/integration-tests/src/flows/forum/multiplePostDeletionsBug.ts
  14. 2 2
      tests/integration-tests/src/flows/forum/polls.ts
  15. 2 2
      tests/integration-tests/src/flows/forum/posts.ts
  16. 2 2
      tests/integration-tests/src/flows/forum/threads.ts
  17. 2 2
      tests/integration-tests/src/flows/membership/creatingMemberships.ts
  18. 2 2
      tests/integration-tests/src/flows/membership/invitingMembers.ts
  19. 2 2
      tests/integration-tests/src/flows/membership/managingStakingAccounts.ts
  20. 2 2
      tests/integration-tests/src/flows/membership/membershipSystem.ts
  21. 2 2
      tests/integration-tests/src/flows/membership/transferringInvites.ts
  22. 2 2
      tests/integration-tests/src/flows/membership/updatingAccounts.ts
  23. 2 2
      tests/integration-tests/src/flows/membership/updatingProfile.ts
  24. 2 2
      tests/integration-tests/src/flows/proposals/cancellingProposal.ts
  25. 2 2
      tests/integration-tests/src/flows/proposals/exactExecutionBlock.ts
  26. 2 2
      tests/integration-tests/src/flows/proposals/expireProposal.ts
  27. 2 2
      tests/integration-tests/src/flows/proposals/index.ts
  28. 2 2
      tests/integration-tests/src/flows/proposals/runtimeUpgradeProposal.ts
  29. 2 2
      tests/integration-tests/src/flows/proposals/vetoProposal.ts
  30. 2 2
      tests/integration-tests/src/flows/working-groups/groupBudget.ts
  31. 2 2
      tests/integration-tests/src/flows/working-groups/groupStatus.ts
  32. 2 2
      tests/integration-tests/src/flows/working-groups/leadOpening.ts
  33. 2 2
      tests/integration-tests/src/flows/working-groups/openingsAndApplications.ts
  34. 2 2
      tests/integration-tests/src/flows/working-groups/upcomingOpenings.ts
  35. 2 2
      tests/integration-tests/src/flows/working-groups/workerActions.ts
  36. 2 2
      tests/integration-tests/src/sender.ts
  37. 2 2
      tests/integration-tests/src/utils.ts

+ 1 - 1
tests/integration-tests/run-storage-node-tests.sh

@@ -49,4 +49,4 @@ yes | yarn joystream-cli media:uploadVideo ./assets/joystream.MOV \
   --input ./assets/TestVideo.json \
   --confirm
 
-time DEBUG=* yarn workspace integration-tests run-test-scenario storage-node
+time DEBUG=integration-tests:* yarn workspace integration-tests run-test-scenario storage-node

+ 1 - 1
tests/integration-tests/run-test-scenario.sh

@@ -17,4 +17,4 @@ if [ -n "$RUNTIME_UPGRADE_TARGET_IMAGE_TAG" ]; then
 fi
 
 # Execute the tests
-time DEBUG=* yarn workspace integration-tests node-ts-strict src/scenarios/${SCENARIO}.ts
+time DEBUG=integration-tests:* yarn workspace integration-tests node-ts-strict src/scenarios/${SCENARIO}.ts

+ 2 - 2
tests/integration-tests/src/Api.ts

@@ -12,7 +12,7 @@ import { Utils } from './utils'
 import { types } from '@joystream/types'
 
 import { v4 as uuid } from 'uuid'
-import Debugger from 'debug'
+import { extendDebug } from './Debugger'
 import { DispatchError } from '@polkadot/types/interfaces/system'
 import {
   EventDetails,
@@ -57,7 +57,7 @@ export class ApiFactory {
     treasuryAccountUri: string,
     sudoAccountUri: string
   ): Promise<ApiFactory> {
-    const debug = Debugger('api-factory')
+    const debug = extendDebug('api-factory')
     let connectAttempts = 0
     while (true) {
       connectAttempts++

+ 9 - 0
tests/integration-tests/src/Debugger.ts

@@ -0,0 +1,9 @@
+import Debugger from 'debug'
+
+// Global debugger
+const debug = Debugger('integration-tests')
+
+// Extend function bound to the global debugger
+const extendDebug = debug.extend.bind(debug)
+
+export { Debugger, debug, extendDebug }

+ 2 - 2
tests/integration-tests/src/Fixture.ts

@@ -4,7 +4,7 @@ import { ISubmittableResult } from '@polkadot/types/types/'
 import { DispatchResult } from '@polkadot/types/interfaces/system'
 import { QueryNodeApi } from './QueryNodeApi'
 import { SubmittableExtrinsic } from '@polkadot/api/types'
-import Debugger from 'debug'
+import { extendDebug, Debugger } from './Debugger'
 import { AnyQueryNodeEvent, EventDetails } from './types'
 
 export abstract class BaseFixture {
@@ -16,7 +16,7 @@ export abstract class BaseFixture {
 
   constructor(api: Api) {
     this.api = api
-    this.debug = Debugger(`fixture:${this.constructor.name}`)
+    this.debug = extendDebug(`fixture:${this.constructor.name}`)
   }
 
   // Derviced classes must not override this

+ 2 - 2
tests/integration-tests/src/Job.ts

@@ -1,4 +1,4 @@
-import Debugger from 'debug'
+import { extendDebug, Debugger } from './Debugger'
 import { EventEmitter } from 'events'
 import { ApiFactory } from './Api'
 import { QueryNodeApi } from './QueryNodeApi'
@@ -30,7 +30,7 @@ export class Job {
     this._flows = flows
     this._outcome = new InvertedPromise<JobOutcome>()
     this._manager.on('run', this.run.bind(this))
-    this.debug = Debugger(`job:${this._label}`)
+    this.debug = extendDebug(`job:${this._label}`)
   }
 
   // Depend on another job to complete successfully

+ 2 - 2
tests/integration-tests/src/QueryNodeApi.ts

@@ -1,6 +1,6 @@
 import { ApolloClient, DocumentNode, NormalizedCacheObject } from '@apollo/client'
 import { MemberId, PostId, ThreadId } from '@joystream/types/common'
-import Debugger from 'debug'
+import { extendDebug, Debugger } from './Debugger'
 import { ApplicationId, OpeningId, WorkerId } from '@joystream/types/working-group'
 import { EventDetails, WorkingGroupModuleName } from './types'
 import {
@@ -278,7 +278,7 @@ export class QueryNodeApi {
 
   constructor(queryNodeProvider: ApolloClient<NormalizedCacheObject>) {
     this.queryNodeProvider = queryNodeProvider
-    this.debug = Debugger('query-node-api')
+    this.debug = extendDebug('query-node-api')
     this.queryDebug = this.debug.extend('query')
     this.tryDebug = this.debug.extend('try')
   }

+ 2 - 2
tests/integration-tests/src/Resources.ts

@@ -1,8 +1,8 @@
 import { assert } from 'chai'
 import { Utils } from './utils'
-import Debugger from 'debug'
+import { extendDebug } from './Debugger'
 
-const debug = Debugger('resources')
+const debug = extendDebug('resources')
 
 type NamedLocks = Record<Resource, Lock>
 export type ResourceLocker = (resource: Resource, timeout?: number) => Promise<() => void>

+ 2 - 2
tests/integration-tests/src/Scenario.ts

@@ -3,7 +3,7 @@ import { ApiFactory } from './Api'
 import { QueryNodeApi } from './QueryNodeApi'
 import { config } from 'dotenv'
 import { ApolloClient, InMemoryCache, HttpLink } from '@apollo/client'
-import Debugger from 'debug'
+import { extendDebug, Debugger } from './Debugger'
 import { Flow } from './Flow'
 import { Job } from './Job'
 import { JobManager } from './JobManager'
@@ -42,7 +42,7 @@ export async function scenario(scene: (props: ScenarioProps) => Promise<void>):
 
   const query = new QueryNodeApi(queryNodeProvider)
 
-  const debug = Debugger('scenario')
+  const debug = extendDebug('scenario')
 
   const jobs = new JobManager({ apiFactory, query, env })
 

+ 2 - 2
tests/integration-tests/src/flows/council/elect.ts

@@ -1,12 +1,12 @@
 import { FlowProps } from '../../Flow'
-import Debugger from 'debug'
+import { extendDebug } from '../../Debugger'
 import { FixtureRunner } from '../../Fixture'
 import { ElectCouncilFixture } from '../../fixtures/council/ElectCouncilFixture'
 
 // Currently only used by proposals flow
 
 export default async function electCouncil({ api, query }: FlowProps): Promise<void> {
-  const debug = Debugger('flow:elect-council')
+  const debug = extendDebug('flow:elect-council')
   debug('Started')
   api.enableDebugTxLogs()
 

+ 2 - 2
tests/integration-tests/src/flows/forum/categories.ts

@@ -1,5 +1,5 @@
 import { FlowProps } from '../../Flow'
-import Debugger from 'debug'
+import { extendDebug } from '../../Debugger'
 import { FixtureRunner } from '../../Fixture'
 import {
   CategoryParams,
@@ -13,7 +13,7 @@ import {
 import { HireWorkersFixture } from '../../fixtures/workingGroups/HireWorkersFixture'
 
 export default async function categories({ api, query }: FlowProps): Promise<void> {
-  const debug = Debugger(`flow:cateogries`)
+  const debug = extendDebug(`flow:cateogries`)
   debug('Started')
   api.enableDebugTxLogs()
 

+ 2 - 2
tests/integration-tests/src/flows/forum/moderation.ts

@@ -1,5 +1,5 @@
 import { FlowProps } from '../../Flow'
-import Debugger from 'debug'
+import { extendDebug } from '../../Debugger'
 import { FixtureRunner } from '../../Fixture'
 import {
   InitializeForumFixture,
@@ -10,7 +10,7 @@ import {
 } from '../../fixtures/forum'
 
 export default async function threads({ api, query }: FlowProps): Promise<void> {
-  const debug = Debugger(`flow:threads`)
+  const debug = extendDebug(`flow:threads`)
   debug('Started')
   api.enableDebugTxLogs()
 

+ 2 - 2
tests/integration-tests/src/flows/forum/multiplePostDeletionsBug.ts

@@ -1,12 +1,12 @@
 import { FlowProps } from '../../Flow'
-import Debugger from 'debug'
+import { extendDebug } from '../../Debugger'
 import { FixtureRunner } from '../../Fixture'
 import { DeletePostsFixture, InitializeForumFixture, PostsRemovalInput } from '../../fixtures/forum'
 import { POST_DEPOSIT } from '../../consts'
 import { formatBalance } from '@polkadot/util'
 
 export default async function threads({ api, query, env }: FlowProps): Promise<void> {
-  const debug = Debugger(`flow:multiple-post-deletions-bug`)
+  const debug = extendDebug(`flow:multiple-post-deletions-bug`)
   debug('Started')
   api.enableDebugTxLogs()
 

+ 2 - 2
tests/integration-tests/src/flows/forum/polls.ts

@@ -1,5 +1,5 @@
 import { FlowProps } from '../../Flow'
-import Debugger from 'debug'
+import { extendDebug } from '../../Debugger'
 import { FixtureRunner } from '../../Fixture'
 import {
   CategoryParams,
@@ -12,7 +12,7 @@ import {
 import { BuyMembershipHappyCaseFixture } from '../../fixtures/membership'
 
 export default async function polls({ api, query }: FlowProps): Promise<void> {
-  const debug = Debugger(`flow:polls`)
+  const debug = extendDebug(`flow:polls`)
   debug('Started')
   api.enableDebugTxLogs()
 

+ 2 - 2
tests/integration-tests/src/flows/forum/posts.ts

@@ -1,5 +1,5 @@
 import { FlowProps } from '../../Flow'
-import Debugger from 'debug'
+import { extendDebug } from '../../Debugger'
 import { FixtureRunner } from '../../Fixture'
 import {
   AddPostsFixture,
@@ -15,7 +15,7 @@ import {
 import { ForumPostReaction } from '@joystream/metadata-protobuf'
 
 export default async function threads({ api, query }: FlowProps): Promise<void> {
-  const debug = Debugger(`flow:threads`)
+  const debug = extendDebug(`flow:threads`)
   debug('Started')
   api.enableDebugTxLogs()
 

+ 2 - 2
tests/integration-tests/src/flows/forum/threads.ts

@@ -1,5 +1,5 @@
 import { FlowProps } from '../../Flow'
-import Debugger from 'debug'
+import { extendDebug } from '../../Debugger'
 import { FixtureRunner } from '../../Fixture'
 import {
   DeleteThreadsFixture,
@@ -15,7 +15,7 @@ import {
 import { CategoryId } from '@joystream/types/forum'
 
 export default async function threads({ api, query }: FlowProps): Promise<void> {
-  const debug = Debugger(`flow:threads`)
+  const debug = extendDebug(`flow:threads`)
   debug('Started')
   api.enableDebugTxLogs()
 

+ 2 - 2
tests/integration-tests/src/flows/membership/creatingMemberships.ts

@@ -1,12 +1,12 @@
 import { FlowProps } from '../../Flow'
 import { BuyMembershipHappyCaseFixture, BuyMembershipWithInsufficienFundsFixture } from '../../fixtures/membership'
 
-import Debugger from 'debug'
+import { extendDebug } from '../../Debugger'
 import { FixtureRunner } from '../../Fixture'
 import { assert } from 'chai'
 
 export default async function creatingMemberships({ api, query, env }: FlowProps): Promise<void> {
-  const debug = Debugger('flow:creating-members')
+  const debug = extendDebug('flow:creating-members')
   debug('Started')
   api.enableDebugTxLogs()
 

+ 2 - 2
tests/integration-tests/src/flows/membership/invitingMembers.ts

@@ -1,12 +1,12 @@
 import { FlowProps } from '../../Flow'
 import { BuyMembershipHappyCaseFixture, InviteMembersHappyCaseFixture } from '../../fixtures/membership'
 
-import Debugger from 'debug'
+import { extendDebug } from '../../Debugger'
 import { FixtureRunner } from '../../Fixture'
 import { assert } from 'chai'
 
 export default async function invitingMembers({ api, query, env }: FlowProps): Promise<void> {
-  const debug = Debugger('flow:inviting-members')
+  const debug = extendDebug('flow:inviting-members')
   debug('Started')
   api.enableDebugTxLogs()
 

+ 2 - 2
tests/integration-tests/src/flows/membership/managingStakingAccounts.ts

@@ -5,12 +5,12 @@ import {
   RemoveStakingAccountsHappyCaseFixture,
 } from '../../fixtures/membership'
 
-import Debugger from 'debug'
+import { extendDebug } from '../../Debugger'
 import { FixtureRunner } from '../../Fixture'
 import { assert } from 'chai'
 
 export default async function managingStakingAccounts({ api, query, env }: FlowProps): Promise<void> {
-  const debug = Debugger('flow:adding-staking-accounts')
+  const debug = extendDebug('flow:adding-staking-accounts')
   debug('Started')
   api.enableDebugTxLogs()
 

+ 2 - 2
tests/integration-tests/src/flows/membership/membershipSystem.ts

@@ -1,12 +1,12 @@
 import { FlowProps } from '../../Flow'
 import { SudoUpdateMembershipSystem } from '../../fixtures/membership'
 
-import Debugger from 'debug'
+import { extendDebug } from '../../Debugger'
 import { FixtureRunner } from '../../Fixture'
 import BN from 'bn.js'
 
 export default async function membershipSystem({ api, query, env }: FlowProps): Promise<void> {
-  const debug = Debugger('flow:membership-system')
+  const debug = extendDebug('flow:membership-system')
   debug('Started')
   api.enableDebugTxLogs()
 

+ 2 - 2
tests/integration-tests/src/flows/membership/transferringInvites.ts

@@ -1,11 +1,11 @@
 import { FlowProps } from '../../Flow'
 import { BuyMembershipHappyCaseFixture, TransferInvitesHappyCaseFixture } from '../../fixtures/membership'
 
-import Debugger from 'debug'
+import { extendDebug } from '../../Debugger'
 import { FixtureRunner } from '../../Fixture'
 
 export default async function transferringInvites({ api, query, env }: FlowProps): Promise<void> {
-  const debug = Debugger('flow:transferring-invites')
+  const debug = extendDebug('flow:transferring-invites')
   debug('Started')
   api.enableDebugTxLogs()
 

+ 2 - 2
tests/integration-tests/src/flows/membership/updatingAccounts.ts

@@ -1,11 +1,11 @@
 import { FlowProps } from '../../Flow'
 import { BuyMembershipHappyCaseFixture, UpdateAccountsHappyCaseFixture } from '../../fixtures/membership'
 
-import Debugger from 'debug'
+import { extendDebug } from '../../Debugger'
 import { FixtureRunner } from '../../Fixture'
 
 export default async function updatingAccounts({ api, query }: FlowProps): Promise<void> {
-  const debug = Debugger('flow:member-accounts-update')
+  const debug = extendDebug('flow:member-accounts-update')
   debug('Started')
   api.enableDebugTxLogs()
 

+ 2 - 2
tests/integration-tests/src/flows/membership/updatingProfile.ts

@@ -1,11 +1,11 @@
 import { FlowProps } from '../../Flow'
 import { BuyMembershipHappyCaseFixture, UpdateProfileHappyCaseFixture } from '../../fixtures/membership'
 
-import Debugger from 'debug'
+import { extendDebug } from '../../Debugger'
 import { FixtureRunner } from '../../Fixture'
 
 export default async function updatingProfile({ api, query }: FlowProps): Promise<void> {
-  const debug = Debugger('flow:member-profile-update')
+  const debug = extendDebug('flow:member-profile-update')
   debug('Started')
   api.enableDebugTxLogs()
 

+ 2 - 2
tests/integration-tests/src/flows/proposals/cancellingProposal.ts

@@ -1,12 +1,12 @@
 import { FlowProps } from '../../Flow'
-import Debugger from 'debug'
+import { extendDebug } from '../../Debugger'
 import { FixtureRunner } from '../../Fixture'
 import { BuyMembershipHappyCaseFixture } from '../../fixtures/membership'
 import { CreateProposalsFixture, CancelProposalsFixture } from '../../fixtures/proposals'
 import { Resource } from '../../Resources'
 
 export default async function cancellingProposals({ api, query, lock }: FlowProps): Promise<void> {
-  const debug = Debugger('flow:cancelling-proposals')
+  const debug = extendDebug('flow:cancelling-proposals')
   debug('Started')
   api.enableDebugTxLogs()
 

+ 2 - 2
tests/integration-tests/src/flows/proposals/exactExecutionBlock.ts

@@ -1,12 +1,12 @@
 import { FlowProps } from '../../Flow'
-import Debugger from 'debug'
+import { extendDebug } from '../../Debugger'
 import { FixtureRunner } from '../../Fixture'
 import { BuyMembershipHappyCaseFixture } from '../../fixtures/membership'
 import { CreateProposalsFixture, DecideOnProposalStatusFixture } from '../../fixtures/proposals'
 import { Resource } from '../../Resources'
 
 export default async function exactExecutionBlock({ api, query, lock }: FlowProps): Promise<void> {
-  const debug = Debugger('flow:proposal-exact-execution-block')
+  const debug = extendDebug('flow:proposal-exact-execution-block')
   debug('Started')
   api.enableDebugTxLogs()
 

+ 2 - 2
tests/integration-tests/src/flows/proposals/expireProposal.ts

@@ -1,12 +1,12 @@
 import { FlowProps } from '../../Flow'
-import Debugger from 'debug'
+import { extendDebug } from '../../Debugger'
 import { FixtureRunner } from '../../Fixture'
 import { BuyMembershipHappyCaseFixture } from '../../fixtures/membership'
 import { CreateProposalsFixture, ExpireProposalsFixture } from '../../fixtures/proposals'
 import { Resource } from '../../Resources'
 
 export default async function expireProposal({ api, query, lock }: FlowProps): Promise<void> {
-  const debug = Debugger('flow:expire-proposal')
+  const debug = extendDebug('flow:expire-proposal')
   debug('Started')
   api.enableDebugTxLogs()
 

+ 2 - 2
tests/integration-tests/src/flows/proposals/index.ts

@@ -1,5 +1,5 @@
 import { FlowProps } from '../../Flow'
-import Debugger from 'debug'
+import { extendDebug } from '../../Debugger'
 import { FixtureRunner } from '../../Fixture'
 import { AddStakingAccountsHappyCaseFixture, BuyMembershipHappyCaseFixture } from '../../fixtures/membership'
 import { Utils } from '../../utils'
@@ -12,7 +12,7 @@ import { OpeningMetadata } from '@joystream/metadata-protobuf'
 import { AllProposalsOutcomesFixture, TestedProposal } from '../../fixtures/proposals'
 
 export default async function creatingProposals({ api, query, lock }: FlowProps): Promise<void> {
-  const debug = Debugger('flow:creating-proposals')
+  const debug = extendDebug('flow:creating-proposals')
   debug('Started')
   api.enableDebugTxLogs()
 

+ 2 - 2
tests/integration-tests/src/flows/proposals/runtimeUpgradeProposal.ts

@@ -1,5 +1,5 @@
 import { FlowProps } from '../../Flow'
-import Debugger from 'debug'
+import { extendDebug } from '../../Debugger'
 import { FixtureRunner } from '../../Fixture'
 import { Utils } from '../../utils'
 import fs from 'fs'
@@ -14,7 +14,7 @@ import { assert } from 'chai'
 import { Resource } from '../../Resources'
 
 export default async function runtimeUpgradeProposal({ api, query, lock, env }: FlowProps): Promise<void> {
-  const debug = Debugger('flow:runtime-upgrade-proposal')
+  const debug = extendDebug('flow:runtime-upgrade-proposal')
   debug('Started')
   api.enableVerboseTxLogs()
 

+ 2 - 2
tests/integration-tests/src/flows/proposals/vetoProposal.ts

@@ -1,12 +1,12 @@
 import { FlowProps } from '../../Flow'
-import Debugger from 'debug'
+import { extendDebug } from '../../Debugger'
 import { FixtureRunner } from '../../Fixture'
 import { BuyMembershipHappyCaseFixture } from '../../fixtures/membership'
 import { CreateProposalsFixture, DecideOnProposalStatusFixture } from '../../fixtures/proposals'
 import { Resource } from '../../Resources'
 
 export default async function vetoProposal({ api, query, lock }: FlowProps): Promise<void> {
-  const debug = Debugger('flow:creating-proposals')
+  const debug = extendDebug('flow:creating-proposals')
   debug('Started')
   api.enableDebugTxLogs()
 

+ 2 - 2
tests/integration-tests/src/flows/working-groups/groupBudget.ts

@@ -1,6 +1,6 @@
 import BN from 'bn.js'
 import { FlowProps } from '../../Flow'
-import Debugger from 'debug'
+import { extendDebug } from '../../Debugger'
 import { FixtureRunner } from '../../Fixture'
 import { workingGroups } from '../../consts'
 import { SetBudgetFixture } from '../../fixtures/workingGroups/SetBudgetFixture'
@@ -11,7 +11,7 @@ export default async function groupBudget({ api, query }: FlowProps): Promise<vo
     workingGroups.map(async (group) => {
       const budgets: BN[] = [new BN(1000000)]
 
-      const debug = Debugger(`flow:group-budget:${group}`)
+      const debug = extendDebug(`flow:group-budget:${group}`)
       debug('Started')
       api.enableDebugTxLogs()
 

+ 2 - 2
tests/integration-tests/src/flows/working-groups/groupStatus.ts

@@ -1,7 +1,7 @@
 import { FlowProps } from '../../Flow'
 import { UpdateGroupStatusFixture } from '../../fixtures/workingGroups'
 
-import Debugger from 'debug'
+import { extendDebug } from '../../Debugger'
 import { FixtureRunner } from '../../Fixture'
 import { workingGroups } from '../../consts'
 import { IWorkingGroupMetadata } from '@joystream/metadata-protobuf'
@@ -51,7 +51,7 @@ export default async function groupStatus({ api, query, env }: FlowProps): Promi
         },
       ]
 
-      const debug = Debugger(`flow:group-status:${group}`)
+      const debug = extendDebug(`flow:group-status:${group}`)
       debug('Started')
       api.enableDebugTxLogs()
 

+ 2 - 2
tests/integration-tests/src/flows/working-groups/leadOpening.ts

@@ -7,7 +7,7 @@ import {
   DEFAULT_OPENING_PARAMS,
 } from '../../fixtures/workingGroups'
 
-import Debugger from 'debug'
+import { extendDebug } from '../../Debugger'
 import { FixtureRunner } from '../../Fixture'
 import { AddStakingAccountsHappyCaseFixture, BuyMembershipHappyCaseFixture } from '../../fixtures/membership'
 import { workingGroups } from '../../consts'
@@ -15,7 +15,7 @@ import { workingGroups } from '../../consts'
 export default async function leadOpening({ api, query, env }: FlowProps): Promise<void> {
   await Promise.all(
     workingGroups.map(async (group) => {
-      const debug = Debugger(`flow:lead-opening:${group}`)
+      const debug = extendDebug(`flow:lead-opening:${group}`)
       debug('Started')
       api.enableDebugTxLogs()
 

+ 2 - 2
tests/integration-tests/src/flows/working-groups/openingsAndApplications.ts

@@ -9,7 +9,7 @@ import {
   OpeningParams,
 } from '../../fixtures/workingGroups'
 
-import Debugger from 'debug'
+import { extendDebug } from '../../Debugger'
 import { FixtureRunner } from '../../Fixture'
 import { AddStakingAccountsHappyCaseFixture, BuyMembershipHappyCaseFixture } from '../../fixtures/membership'
 import { workingGroups, LEADER_OPENING_STAKE } from '../../consts'
@@ -69,7 +69,7 @@ export default async function openingsAndApplications({ api, query, env }: FlowP
 
   await Promise.all(
     workingGroups.map(async (group) => {
-      const debug = Debugger(`flow:openings-and-applications:${group}`)
+      const debug = extendDebug(`flow:openings-and-applications:${group}`)
       debug('Started')
       api.enableDebugTxLogs()
 

+ 2 - 2
tests/integration-tests/src/flows/working-groups/upcomingOpenings.ts

@@ -6,7 +6,7 @@ import {
   UpcomingOpeningParams,
 } from '../../fixtures/workingGroups'
 
-import Debugger from 'debug'
+import { extendDebug } from '../../Debugger'
 import { FixtureRunner } from '../../Fixture'
 import { workingGroups } from '../../consts'
 import Long from 'long'
@@ -68,7 +68,7 @@ const upcomingOpeningsToCreate: UpcomingOpeningParams[] = [
 export default async function upcomingOpenings({ api, query, env }: FlowProps): Promise<void> {
   await Promise.all(
     workingGroups.map(async (group) => {
-      const debug = Debugger(`flow:upcoming-openings:${group}`)
+      const debug = extendDebug(`flow:upcoming-openings:${group}`)
       debug('Started')
       api.enableDebugTxLogs()
       const createUpcomingOpeningFixture = new CreateUpcomingOpeningsFixture(

+ 2 - 2
tests/integration-tests/src/flows/working-groups/workerActions.ts

@@ -1,5 +1,5 @@
 import { FlowProps } from '../../Flow'
-import Debugger from 'debug'
+import { extendDebug } from '../../Debugger'
 import { FixtureRunner } from '../../Fixture'
 import { workingGroups } from '../../consts'
 import { HireWorkersFixture } from '../../fixtures/workingGroups/HireWorkersFixture'
@@ -18,7 +18,7 @@ import { TerminateWorkersFixture } from '../../fixtures/workingGroups/TerminateW
 export default async function workerActions({ api, query, env }: FlowProps): Promise<void> {
   await Promise.all(
     workingGroups.map(async (group) => {
-      const debug = Debugger(`flow:worker-actions:${group}`)
+      const debug = extendDebug(`flow:worker-actions:${group}`)
       debug('Started')
       api.enableDebugTxLogs()
 

+ 2 - 2
tests/integration-tests/src/sender.ts

@@ -4,7 +4,7 @@ import { ISubmittableResult, AnyJson } from '@polkadot/types/types/'
 import { AccountId, EventRecord } from '@polkadot/types/interfaces'
 import { DispatchError, DispatchResult } from '@polkadot/types/interfaces/system'
 import { KeyringPair } from '@polkadot/keyring/types'
-import Debugger from 'debug'
+import { extendDebug, Debugger } from './Debugger'
 import AsyncLock from 'async-lock'
 import { assert } from 'chai'
 import BN from 'bn.js'
@@ -28,7 +28,7 @@ export class Sender {
   constructor(api: ApiPromise, keyring: Keyring, label: string) {
     this.api = api
     this.keyring = keyring
-    this.debug = Debugger(`Sender:${Sender.instance++}:${label}`)
+    this.debug = extendDebug(`Sender:${Sender.instance++}:${label}`)
   }
 
   // Synchronize all sending of transactions into mempool, so we can always safely read

+ 2 - 2
tests/integration-tests/src/utils.ts

@@ -6,7 +6,7 @@ import fs from 'fs'
 import { decodeAddress } from '@polkadot/keyring'
 import { Bytes } from '@polkadot/types'
 import { createType } from '@joystream/types'
-import Debugger from 'debug'
+import { extendDebug, Debugger } from './Debugger'
 import { BLOCKTIME } from './consts'
 import { MetadataInput } from './types'
 
@@ -114,7 +114,7 @@ export class Utils {
     intervalMs = BLOCKTIME,
     timeoutMs = 10 * 60 * 1000
   ): Promise<void> {
-    const debug = Debugger(`awaiting:${name}`)
+    const debug = extendDebug(`awaiting:${name}`)
     return new Promise((resolve, reject) => {
       const timeout = setTimeout(() => reject(new Error(`Awaiting ${name} - timoeut reached`)), timeoutMs)
       const check = async () => {