fix(performance): ignore non-RUB cash flows (WealthLedger/main#55)

Filter non-RUB data at ingest, collapse per-currency collections into single RUB Money, drop currency from TbankPortfolioValuePoint, remove NON_RUB_ACTIVITY and screener currency filter.

BREAKING CHANGE: per-currency API fields replaced with single RUB Money; stock screener currency param removed.

src/modules/investments/tbank-sync/tbank-hourly.scheduler.ts

@@ -244,23 +244,16 @@ export class TbankHourlyScheduler implements OnModuleDestroy, OnModuleInit {
     dispatchProblems: HourlySection[],
     walkStartedAt: Date,
   ) {
-    const portfolios: string[] = [];
     for (const account of accounts) {
       await this.dispatchPortfolio(
         userId,
         revision,
         account.accountId,
-        async (child) => {
+        dispatch,
-          portfolios.push(child.id);
-          await dispatch(child);
-        },
         dispatchProblems,
         walkStartedAt,
       );
     }
-    // Operations coverage must end after the Portfolio valuation it explains:
-    // performance requires coverage up to the snapshot fetchedAt.
-    await this.waitWorks(userId, portfolios);
     for (const account of accounts) {
       await this.dispatchOperations(
         userId,

test/tbank-hourly-lifecycle.e2e-spec.ts

@@ -167,29 +167,6 @@ describe('hourly attempt lifecycle (SQLite)', () => {
     expect(read?.state).toBe('succeeded');
   });
 
-  it('starts operations only after every portfolio work finished', async () => {
-    const portfolios: string[] = [];
-    portfolio.request.mockImplementation(
-      async (_userId: string, _revision: string, accountId: string) => {
-        const row = await child('running', null, `portfolio:${accountId}`);
-        portfolios.push(row.id);
-        return { id: row.id, done: Promise.resolve() };
-      },
-    );
-    const scheduler = createScheduler();
-    await scheduler.tick();
-    await pump();
-    expect(portfolios).toHaveLength(2);
-    expect(operations.request).not.toHaveBeenCalled();
-    await prisma.tbankSyncWork.updateMany({
-      where: { id: { in: portfolios } },
-      data: { state: 'complete' },
-    });
-    const row = await runWalk(scheduler);
-    expect(operations.request).toHaveBeenCalledTimes(2);
-    expect(row.state).toBe('complete');
-  });
-
   it('settles partial and keeps successful steps when one account fails', async () => {
     portfolio.request.mockImplementation(
       async (_userId: string, _revision: string, accountId: string) => {