Account id counter (#273)

* email delivery attempt export (#271)

* fix: 💚 remove falinig test on migration

since now we have dropped the new migration logic

.github/workflows/tests.yml

@@ -83,22 +83,3 @@ jobs:
         run: make prepare
       - name: Run tests
         run: npm run tests:mail-scheduler
-  post-update-migrations:
-    name: Post update migrations tests
-    needs: [migrations]
-    runs-on: ${{ matrix.os }}
-    strategy:
-      matrix:
-        os: [ubuntu-latest]
-        node-version: [16.x]
-      fail-fast: true
-    steps:
-      - uses: actions/checkout@v2
-      - name: Use Node.js ${{matrix.node-version}}
-        uses: actions/setup-node@v1
-        with:
-          node-version: ${{matrix.node-version}}
-      - name: Prepare workspace
-        run: make prepare
-      - name: Run tests
-        run: npm run tests:migrations

src/mappings/utils.ts

@@ -10,7 +10,6 @@ import { createType } from '@joystream/types'
 import { u8aToHex } from '@polkadot/util'
 import { CommentCountersManager } from '../utils/CommentsCountersManager'
 import { VideoRelevanceManager } from '../utils/VideoRelevanceManager'
-import { NextEntityIdManager } from '../utils/NextEntityIdManager'
 
 export const commentCountersManager = new CommentCountersManager()
 export const videoRelevanceManager = new VideoRelevanceManager()
@@ -19,8 +18,6 @@ void videoRelevanceManager.init({
   fullUpdateLoopTime: 1000 * 60 * 60 * 12, // 12 hrs
   scheduledUpdateLoopTime: 1000 * 60 * 10, // 10 mins
 })
-export const migrateCounters = new NextEntityIdManager()
-
 export const JOYSTREAM_SS58_PREFIX = 126
 
 export function bytesToString(b: Uint8Array): string {

src/processor.ts

@@ -88,7 +88,7 @@ import { Event } from './types/support'
 import { assertAssignable } from './utils/misc'
 import { EntityManagerOverlay } from './utils/overlay'
 import { EventNames, EventHandler, eventConstructors, EventInstance } from './utils/events'
-import { commentCountersManager, migrateCounters, videoRelevanceManager } from './mappings/utils'
+import { commentCountersManager, videoRelevanceManager } from './mappings/utils'
 import { EntityManager } from 'typeorm'
 import { OffchainState } from './utils/offchainState'
 
@@ -331,7 +331,6 @@ processor.run(new TypeormDatabase({ isolationLevel: 'READ COMMITTED' }), async (
       await commentCountersManager.updateVideoCommentsCounters(em, true)
       await commentCountersManager.updateParentRepliesCounters(em, true)
       await videoRelevanceManager.updateVideoRelevanceValue(em, true)
-      await migrateCounters.migrateCounters(overlay)
       ctx.log.info(`Offchain state successfully imported!`)
     }
   }

src/utils/offchainState.ts

@@ -260,6 +260,10 @@ export class OffchainState {
       )
     }
 
+    // migrate counter values
+    const { exportedVersion } = exportFile
+    await this.migrateCounters(exportedVersion, em)
+
     const renamedExportFilePath = `${exportFilePath}.imported`
     this.logger.info(`Renaming export file to ${renamedExportFilePath})...`)
     fs.renameSync(exportFilePath, renamedExportFilePath)