chore(release): 2.4.1

CHANGELOG.md

@@ -1,5 +1,41 @@
 # Changelog
 
+## [2.4.1](https://git.personal.ksv741.ru/WealthLedger/backend/compare/v2.4.0...v2.4.1) (2026-11-06)
+
+### Bug Fixes
+
+* **events:** refresh saved payout calendars once per hourly pass (WealthLedger/backend[#53](https://git.personal.ksv741.ru/WealthLedger/backend/issues/53)) ([#157](https://git.personal.ksv741.ru/WealthLedger/backend/issues/157)) ([aeb4647](https://git.personal.ksv741.ru/WealthLedger/backend/commit/aeb4647fda3806a419ff3578834c34fff97ae3e8))
+* **portfolio:** publish new complete forecast regardless of request window (WealthLedger/backend[#55](https://git.personal.ksv741.ru/WealthLedger/backend/issues/55)) ([#156](https://git.personal.ksv741.ru/WealthLedger/backend/issues/156)) ([169bee1](https://git.personal.ksv741.ru/WealthLedger/backend/commit/169bee1da5731a1330e995a4a508da544f791387))
+
+### Refactoring
+
+* **api:** describe bank operation create body as oneOf by kind (WealthLedger/backend[#172](https://git.personal.ksv741.ru/WealthLedger/backend/issues/172)) ([#173](https://git.personal.ksv741.ru/WealthLedger/backend/issues/173)) ([02e0d56](https://git.personal.ksv741.ru/WealthLedger/backend/commit/02e0d560c84606d6372cbac001dc94edc348995e))
+* check persisted json payload shape instead of double casts ([#152](https://git.personal.ksv741.ru/WealthLedger/backend/issues/152)) ([#154](https://git.personal.ksv741.ru/WealthLedger/backend/issues/154)) ([a80bbbf](https://git.personal.ksv741.ru/WealthLedger/backend/commit/a80bbbf1e28954812d2d32c6e8f9f67f5a5d42a4))
+* enforce repository boundary in application (WealthLedger/backend[#171](https://git.personal.ksv741.ru/WealthLedger/backend/issues/171)) ([e3ecb8c](https://git.personal.ksv741.ru/WealthLedger/backend/commit/e3ecb8c15e61ccd8de9acb4954a38932099eefc3))
+* expose upcoming-events public api and guard its boundary (WealthLedger/backend[#163](https://git.personal.ksv741.ru/WealthLedger/backend/issues/163)) ([#195](https://git.personal.ksv741.ru/WealthLedger/backend/issues/195)) ([83b515a](https://git.personal.ksv741.ru/WealthLedger/backend/commit/83b515a4536a6c534bcdec82f9f43f9005a44c35))
+* extract catalog enrichment source loader (WealthLedger/backend[#169](https://git.personal.ksv741.ru/WealthLedger/backend/issues/169)) ([#186](https://git.personal.ksv741.ru/WealthLedger/backend/issues/186)) ([c5ccfea](https://git.personal.ksv741.ru/WealthLedger/backend/commit/c5ccfeadea7a9235ebdd6171d9b6f7b89ed2e1e7))
+* inject TbankAccessService directly into stock screener ([#151](https://git.personal.ksv741.ru/WealthLedger/backend/issues/151)) ([#155](https://git.personal.ksv741.ru/WealthLedger/backend/issues/155)) ([554410a](https://git.personal.ksv741.ru/WealthLedger/backend/commit/554410a2716ce13d7202fd27a621c72734b5e6c8))
+* move auth persistence into repository (WealthLedger/backend[#171](https://git.personal.ksv741.ru/WealthLedger/backend/issues/171)) ([61c5525](https://git.personal.ksv741.ru/WealthLedger/backend/commit/61c55256e756b9187e1087215d35db3fd30ac148))
+* move bank card queries into repository (WealthLedger/backend[#171](https://git.personal.ksv741.ru/WealthLedger/backend/issues/171)) ([b3d4801](https://git.personal.ksv741.ru/WealthLedger/backend/commit/b3d4801cfe67ecf301c58c894676b13b8833c4a6))
+* move category persistence into bank repository (WealthLedger/backend[#171](https://git.personal.ksv741.ru/WealthLedger/backend/issues/171)) ([efac720](https://git.personal.ksv741.ru/WealthLedger/backend/commit/efac7201e06f49b264854566b2e3f73931f3f6cc))
+* replace deep imports with native node aliases (WealthLedger/backend[#165](https://git.personal.ksv741.ru/WealthLedger/backend/issues/165)) ([#193](https://git.personal.ksv741.ru/WealthLedger/backend/issues/193)) ([07cfd08](https://git.personal.ksv741.ru/WealthLedger/backend/commit/07cfd08df9b13ac3fd13da153b12acf159329cea))
+* retire legacy tbank-sync status and sync=observe (WealthLedger/backend[#196](https://git.personal.ksv741.ru/WealthLedger/backend/issues/196)) ([d792baa](https://git.personal.ksv741.ru/WealthLedger/backend/commit/d792baaf59a1c204458ec249ee3ce907f3564455))
+* route bank card reads through repository (WealthLedger/backend[#171](https://git.personal.ksv741.ru/WealthLedger/backend/issues/171)) ([b3ca11d](https://git.personal.ksv741.ru/WealthLedger/backend/commit/b3ca11d1410899bb9c6707113ba9fd1f3b30e4bf))
+* route bank operation queries through repository (WealthLedger/backend[#171](https://git.personal.ksv741.ru/WealthLedger/backend/issues/171)) ([cea77f6](https://git.personal.ksv741.ru/WealthLedger/backend/commit/cea77f6d568809d989462c121f50b4e07e7efca5))
+* share prisma json codec and check progress shape (WealthLedger/backend[#170](https://git.personal.ksv741.ru/WealthLedger/backend/issues/170)) ([#191](https://git.personal.ksv741.ru/WealthLedger/backend/issues/191)) ([85a7196](https://git.personal.ksv741.ru/WealthLedger/backend/commit/85a71967fa4e85427a991c973c6528206332cf5e))
+* share sync reservation join rule (WealthLedger/backend[#119](https://git.personal.ksv741.ru/WealthLedger/backend/issues/119)) ([#162](https://git.personal.ksv741.ru/WealthLedger/backend/issues/162)) ([fa0a6e5](https://git.personal.ksv741.ru/WealthLedger/backend/commit/fa0a6e56030bb1c0302cd7588d30e7fa91e19c11))
+* share tbank-sync claim and generation lock (WealthLedger/backend[#166](https://git.personal.ksv741.ru/WealthLedger/backend/issues/166)) ([#188](https://git.personal.ksv741.ru/WealthLedger/backend/issues/188)) ([5d31b3e](https://git.personal.ksv741.ru/WealthLedger/backend/commit/5d31b3e6dd37d1c79b61c43ed820947b5b38aaa1))
+* single bank operation projection and domain rules (WealthLedger/backend[#168](https://git.personal.ksv741.ru/WealthLedger/backend/issues/168)) ([#189](https://git.personal.ksv741.ru/WealthLedger/backend/issues/189)) ([deda7ff](https://git.personal.ksv741.ru/WealthLedger/backend/commit/deda7ffc2cc8185eba48a18c37272c404a3e9983))
+* split brokerage operations repository and cursor codec (WealthLedger/backend[#167](https://git.personal.ksv741.ru/WealthLedger/backend/issues/167)) ([#190](https://git.personal.ksv741.ru/WealthLedger/backend/issues/190)) ([cd78b43](https://git.personal.ksv741.ru/WealthLedger/backend/commit/cd78b43783cb7469e44b9531d165603df258b55e))
+
+### CI
+
+* drop stale npm audit advisory ignore (WealthLedger/backend[#158](https://git.personal.ksv741.ru/WealthLedger/backend/issues/158)) ([#159](https://git.personal.ksv741.ru/WealthLedger/backend/issues/159)) ([1a5de9b](https://git.personal.ksv741.ru/WealthLedger/backend/commit/1a5de9bebd060a5ff2ca188ad862c4ec5aa06ffd))
+
+### Maintenance
+
+* **deps:** set Renovate release age, PR limit and update groups (WealthLedger/main[#6](https://git.personal.ksv741.ru/WealthLedger/backend/issues/6)) ([#160](https://git.personal.ksv741.ru/WealthLedger/backend/issues/160)) ([bade5fa](https://git.personal.ksv741.ru/WealthLedger/backend/commit/bade5fae1c3170b38717b26eda56ca20183f4ec8))
+
 ## [2.4.0](https://git.personal.ksv741.ru/WealthLedger/backend/compare/v2.3.1...v2.4.0) (2026-11-01)
 
 ### Features

eslint-suppressions.json

@@ -53,11 +53,6 @@
       "count": 1
     }
   },
-  "src/modules/investments/instruments/application/catalog-discovery.service.ts": {
-    "sonarjs/no-nested-conditional": {
-      "count": 1
-    }
-  },
   "src/modules/investments/instruments/application/catalog-enrichment.service.ts": {
     "sonarjs/no-nested-conditional": {
       "count": 1
@@ -135,11 +130,6 @@
       "count": 1
     }
   },
-  "src/modules/investments/tbank-sync/tbank-sync.service.ts": {
-    "sonarjs/no-nested-conditional": {
-      "count": 6
-    }
-  },
   "test/bank-cards-durability.cjs": {
     "sonarjs/no-nested-template-literals": {
       "count": 1
@@ -158,9 +148,6 @@
   "test/tbank-ledger-local.e2e-spec.ts": {
     "sonarjs/no-nested-conditional": {
       "count": 1
-    },
-    "sonarjs/no-nested-template-literals": {
-      "count": 3
     }
   }
 }

eslint.config.mjs

@@ -15,6 +15,18 @@ import globals from 'globals';
 import tseslint from 'typescript-eslint';
 
 const tests = ['**/*.spec.ts', 'test/**/*.ts'];
+const guardedModules = [
+  {
+    name: 'tbank-sync',
+    except: [
+      './tbank-sync.api.ts',
+      './tbank-sync.dto.ts',
+      './tbank-sync.module.ts',
+      './tbank-sync-repository.module.ts',
+    ],
+  },
+  { name: 'upcoming-events', except: ['./upcoming-events.api.ts', './upcoming-events.module.ts'] },
+];
 const prismaImports = [
   '@prisma/*', '**/generated/prisma/**', '**/prisma.service',
 ];
@@ -213,24 +225,20 @@ export default defineConfig(
       '@typescript-eslint/no-unsafe-enum-comparison': 'error',
     },
   },
-  {
+  // Separate rule so it does not replace layer-specific no-restricted-imports configs.
-    files: ['src/**/*.ts'],
+  // A module may import its own internals, so each guarded module gets a block without its zone.
-    ignores: [...tests, 'src/modules/investments/tbank-sync/**'],
+  ...[undefined, ...guardedModules].map((own) => ({
+    files: own ? [`src/modules/investments/${own.name}/**/*.ts`] : ['src/**/*.ts'],
+    ignores: own ? tests : [...tests, ...guardedModules.map(({ name }) => `src/modules/investments/${name}/**`)],
     rules: {
-      // Separate rule so it does not replace layer-specific no-restricted-imports configs.
       'import-x/no-restricted-paths': ['error', {
-        zones: [{
+        zones: guardedModules.filter((module) => module !== own).map(({ except, name }) => ({
           target: './src',
-          from: './src/modules/investments/tbank-sync',
+          from: `./src/modules/investments/${name}`,
-          except: [
+          except,
-            './tbank-sync.api.ts',
+          message: `Use ${name}.api for cross-module access.`,
-            './tbank-sync.dto.ts',
+        })),
-            './tbank-sync.module.ts',
-            './tbank-sync-repository.module.ts',
-          ],
-          message: 'Use tbank-sync.api for cross-module access.',
-        }],
       }],
     },
-  },
+  })),
 );

package-lock.json

@@ -1,12 +1,12 @@
 {
   "name": "wealth-ledger-backend",
-  "version": "2.4.0",
+  "version": "2.4.1",
   "lockfileVersion": 3,
   "requires": true,
   "packages": {
     "": {
       "name": "wealth-ledger-backend",
-      "version": "2.4.0",
+      "version": "2.4.1",
       "license": "UNLICENSED",
       "dependencies": {
         "@grpc/grpc-js": "1.14.6",

package.json

@@ -1,9 +1,19 @@
 {
   "name": "wealth-ledger-backend",
-  "version": "2.4.0",
+  "version": "2.4.1",
   "description": "",
   "author": "",
   "private": true,
+  "imports": {
+    "#generated/*": {
+      "development": "./dist-dev/generated/*",
+      "default": "./dist/generated/*"
+    },
+    "#src/*": {
+      "development": "./dist-dev/src/*",
+      "default": "./dist/src/*"
+    }
+  },
   "license": "UNLICENSED",
   "engines": {
     "node": "v24.22.1"
@@ -14,8 +24,8 @@
     "openapi:check": "npm run build && node scripts/generate-openapi.cjs --check",
     "format": "npm run lint:fix",
     "start": "nest start",
-    "start:dev": "NODE_ENV=development nest start --watch --path tsconfig.dev.json",
+    "start:dev": "NODE_ENV=development NODE_OPTIONS=--conditions=development nest start --watch --path tsconfig.dev.json",
-    "start:debug": "NODE_ENV=development nest start --debug --watch --path tsconfig.dev.json",
+    "start:debug": "NODE_ENV=development NODE_OPTIONS=--conditions=development nest start --debug --watch --path tsconfig.dev.json",
     "start:prod": "node dist/src/main.js",
     "lint": "npm run lint:check",
     "lint:check": "eslint . --max-warnings=0",
@@ -131,6 +141,10 @@
     }
   },
   "jest": {
+    "moduleNameMapper": {
+      "^#generated/(.*)$": "<rootDir>/../generated/$1",
+      "^#src/(.*)$": "<rootDir>/$1"
+    },
     "moduleFileExtensions": [
       "js",
       "json",

src/integrations/tbank/instrument-metadata.repository.ts

@@ -5,7 +5,8 @@ import { isDeepStrictEqual } from 'node:util';
 import type {
   TbankInstrumentLookup as MetadataLookupRow,
   TbankInstrument as MetadataRow,
-} from '../../../generated/prisma/client';
+} from '#generated/prisma/client';
+
 import type { TbankInstrument } from './tbank.client';
 
 import { PrismaService } from '../../prisma/prisma.service';

src/integrations/tbank/tbank-sync-claim.ts

@@ -1,4 +1,5 @@
-import type { Prisma } from '../../../generated/prisma/client';
+import type { Prisma } from '#generated/prisma/client';
+
 import type { TbankSyncAttempt } from './tbank-access.service';
 
 const NO_UPDATED_ROWS = 0;

src/modules/auth/application/auth.service.spec.ts

@@ -9,7 +9,7 @@ jest.mock('bcrypt', () => ({
   compare: jest.fn(() => Promise.resolve(true)),
 }));
 
-jest.mock('../../../prisma/prisma.service', () => ({
+jest.mock('#src/prisma/prisma.service', () => ({
   PrismaService: class PrismaService {},
 }));
 

src/modules/auth/application/auth.service.ts

@@ -7,9 +7,10 @@ import { JwtService } from '@nestjs/jwt';
 import * as bcrypt from 'bcrypt';
 import { createHash, randomUUID } from 'crypto';
 
-import type { Session, User } from '../../../../generated/prisma/client';
+import type { Session, User } from '#generated/prisma/client';
+
+import { HttpErrorCode } from '#src/common/error-code';
 
-import { HttpErrorCode } from '../../../common/error-code';
 import { AuthRepository } from '../infrastructure/auth.repository';
 import { AuthErrorCode } from './auth-error-code';
 import { AuthenticationResult, AuthUser, RefreshPayload } from './auth.types';

src/modules/auth/infrastructure/auth.repository.ts

@@ -1,7 +1,7 @@
 import { Injectable } from '@nestjs/common';
 
-import { isPrismaErrorCode, PrismaErrorCode } from '../../../prisma/prisma-error-code';
+import { isPrismaErrorCode, PrismaErrorCode } from '#src/prisma/prisma-error-code';
-import { PrismaService } from '../../../prisma/prisma.service';
+import { PrismaService } from '#src/prisma/prisma.service';
 
 const EXPECTED_ROTATED_SESSIONS = 1;
 

src/modules/auth/infrastructure/jwt.strategy.ts

@@ -3,8 +3,9 @@ import { ConfigService } from '@nestjs/config';
 import { PassportStrategy } from '@nestjs/passport';
 import { ExtractJwt, Strategy } from 'passport-jwt';
 
-import { HttpErrorCode } from '../../../common/error-code';
+import { HttpErrorCode } from '#src/common/error-code';
-import { Environment } from '../../../config/env.validation';
+import { Environment } from '#src/config/env.validation';
+
 import { AccessPayload } from '../application/auth.types';
 
 @Injectable()

src/modules/auth/presentation/auth.controller.ts

@@ -20,8 +20,9 @@ import {
   ApiTags,
 } from '@nestjs/swagger';
 
-import { ApiProblemResponses } from '../../../common/decorators/api-safe-error-response.decorator';
+import { ApiProblemResponses } from '#src/common/decorators/api-safe-error-response.decorator';
-import { HttpErrorCode } from '../../../common/error-code';
+import { HttpErrorCode } from '#src/common/error-code';
+
 import { AuthService, REFRESH_TTL_MS } from '../application/auth.service';
 import { AccessPayload, AuthenticationResult } from '../application/auth.types';
 import { LoginDto, RegisterDto } from './auth.dto';

src/modules/banking/bank-cards/application/bank-card-input.ts

@@ -5,7 +5,8 @@ import {
 } from '@nestjs/common';
 import { createHash } from 'node:crypto';
 
-import { ISO_DATE_LENGTH, ISO_DATE_START } from '../../../../common/time';
+import { ISO_DATE_LENGTH, ISO_DATE_START } from '#src/common/time';
+
 import {
   MAX_CARD_NAME_LENGTH,
   MAX_OPERATION_DESCRIPTION_LENGTH,

src/modules/banking/bank-cards/application/bank-cards.service.ts

@@ -1,6 +1,6 @@
 import { Injectable } from '@nestjs/common';
 
-import type { BankCard, Prisma } from '../../../../../generated/prisma/client';
+import type { BankCard, Prisma } from '#generated/prisma/client';
 
 import { bankBalance } from '../domain/bank-card.calculations';
 import { rubMoney } from '../domain/rub-money';

src/modules/banking/bank-cards/application/bank-operations.service.ts

@@ -3,7 +3,7 @@ import { GoneException, Injectable } from '@nestjs/common';
 import type {
   BankCardOperation,
   Prisma,
-} from '../../../../../generated/prisma/client';
+} from '#generated/prisma/client';
 
 import { FIRST_PAGE } from '../domain/bank-card-limits';
 import { BankOperationKind } from '../domain/bank-operation-kind';

src/modules/banking/bank-cards/application/get-bank-summary.use-case.spec.ts

@@ -1,8 +1,9 @@
-jest.mock('../../../../prisma/prisma.service', () => ({
+jest.mock('#src/prisma/prisma.service', () => ({
   PrismaService: class {},
 }));
-jest.mock('../../../../../generated/prisma/client', () => ({ Prisma: {} }));
+jest.mock('#generated/prisma/client', () => ({ Prisma: {} }));
-import { PrismaService } from '../../../../prisma/prisma.service';
+import { PrismaService } from '#src/prisma/prisma.service';
+
 import { BankCardsRepository } from '../infrastructure/bank-cards.repository';
 import { GetBankSummaryUseCase } from './get-bank-summary.use-case';
 

src/modules/banking/bank-cards/domain/bank-card.calculations.ts

@@ -1,4 +1,5 @@
-import { ISO_DATE_LENGTH, ISO_DATE_START } from '../../../../common/time';
+import { ISO_DATE_LENGTH, ISO_DATE_START } from '#src/common/time';
+
 import { BankOperationKind } from './bank-operation-kind';
 import { ZERO_KOPECKS } from './rub-money';
 

src/modules/banking/bank-cards/domain/rub-money.ts

@@ -1,6 +1,6 @@
-import type { Money } from '../../../../common/money.types';
+import type { Money } from '#src/common/money.types';
 
-import { DECIMAL_RADIX, decimalFromString, formatDecimal } from '../../../../common/decimal';
+import { DECIMAL_RADIX, decimalFromString, formatDecimal } from '#src/common/decimal';
 
 export const ZERO_KOPECKS = 0n;
 

src/modules/banking/bank-cards/infrastructure/bank-cards.repository.ts

@@ -1,9 +1,10 @@
 import { Injectable } from '@nestjs/common';
 import { randomUUID } from 'node:crypto';
 
-import { BankCard, BankCardOperation, Prisma } from '../../../../../generated/prisma/client';
+import { BankCard, BankCardOperation, Prisma } from '#generated/prisma/client';
-import { isPrismaErrorCode, PrismaErrorCode } from '../../../../prisma/prisma-error-code';
+import { isPrismaErrorCode, PrismaErrorCode } from '#src/prisma/prisma-error-code';
-import { PrismaService } from '../../../../prisma/prisma.service';
+import { PrismaService } from '#src/prisma/prisma.service';
+
 import {
   BankErrorCode,
   conflict,

src/modules/banking/bank-cards/presentation/bank-card.dto.ts

@@ -24,7 +24,8 @@ import {
   ValidateNested,
 } from 'class-validator';
 
-import { MoneyDto } from '../../../../common/money.dto';
+import { MoneyDto } from '#src/common/money.dto';
+
 import {
   FIRST_PAGE,
   MAX_CARD_NAME_LENGTH,

src/modules/banking/bank-cards/presentation/bank-cards.controller.ts

@@ -29,8 +29,9 @@ import {
 import {
   ApiProblemResponses,
   ProblemDetailsDto,
-} from '../../../../common/decorators/api-safe-error-response.decorator';
+} from '#src/common/decorators/api-safe-error-response.decorator';
-import { AccessPayload, JwtAuthGuard } from '../../../auth/auth.api';
+import { AccessPayload, JwtAuthGuard } from '#src/modules/auth/auth.api';
+
 import { BankCardsService } from '../application/bank-cards.service';
 import { BankOperationsService } from '../application/bank-operations.service';
 import { ExpenseCategoriesService } from '../application/expense-categories.service';

src/modules/investments/brokerage-accounts/brokerage-account.dto.ts

@@ -1,6 +1,7 @@
 import { ApiProperty } from '@nestjs/swagger';
 
-import { MoneyDto } from '../../../common/money.dto';
+import { MoneyDto } from '#src/common/money.dto';
+
 import { InvestmentResourceMetaDto } from '../investment-resource.dto';
 import { PortfolioStructureDto } from '../portfolio/portfolio.api';
 import { HourlySyncStatusDto } from '../tbank-sync/tbank-sync.dto';

src/modules/investments/brokerage-accounts/brokerage-accounts.controller.ts

@@ -3,7 +3,8 @@ import type { Request } from 'express';
 import { Controller, Get, Req, UseGuards } from '@nestjs/common';
 import { ApiBearerAuth, ApiOkResponse, ApiTags } from '@nestjs/swagger';
 
-import { ApiProblemResponses } from '../../../common/decorators/api-safe-error-response.decorator';
+import { ApiProblemResponses } from '#src/common/decorators/api-safe-error-response.decorator';
+
 import { AccessPayload, JwtAuthGuard } from '../../auth/auth.api';
 import { BrokerageAccountsResourceDto } from './brokerage-account.dto';
 import { BrokerageAccountsService } from './brokerage-accounts.service';

src/modules/investments/brokerage-accounts/brokerage-accounts.module.ts

@@ -1,6 +1,7 @@
 import { Module } from '@nestjs/common';
 
-import { TbankModule } from '../../../integrations/tbank/tbank.module';
+import { TbankModule } from '#src/integrations/tbank/tbank.module';
+
 import { AuthModule } from '../../auth/auth.module';
 import { PortfolioModule } from '../portfolio/portfolio.module';
 import { TbankSyncRepositoryModule } from '../tbank-sync/tbank-sync-repository.module';

src/modules/investments/brokerage-accounts/brokerage-accounts.service.spec.ts

@@ -1,4 +1,4 @@
-jest.mock('../../../prisma/prisma.service', () => ({
+jest.mock('#src/prisma/prisma.service', () => ({
   PrismaService: class {},
 }));
 import { investmentResourceMeta } from '../investment-resource.mapper';

src/modules/investments/brokerage-accounts/brokerage-accounts.service.ts

@@ -7,7 +7,8 @@ import {
   formatDecimal,
   isZero,
   multiply,
-} from '../../../common/decimal';
+} from '#src/common/decimal';
+
 import { investmentResourceMeta } from '../investment-resource.mapper';
 import { sumMoneyByCurrency } from '../portfolio/domain/portfolio-totals';
 import { PortfolioPositionDto, PortfolioService } from '../portfolio/portfolio.api';

src/modules/investments/income/income-analytics.controller.ts

@@ -3,9 +3,9 @@ import type { Request } from 'express';
 import { Controller, Get, Param, Query, Req, UseGuards } from '@nestjs/common';
 import { ApiBearerAuth, ApiOkResponse, ApiTags } from '@nestjs/swagger';
 
-import { ApiProblemResponses } from '../../../common/decorators/api-safe-error-response.decorator';
+import { ApiProblemResponses } from '#src/common/decorators/api-safe-error-response.decorator';
+
 import { AccessPayload, JwtAuthGuard } from '../../auth/auth.api';
-import { InvestmentReadQueryDto } from '../investment-resource.dto';
 import {
   IncomeAnalyticsQueryDto,
   IncomeAnalyticsResourceDto,
@@ -25,12 +25,10 @@ export class IncomeAnalyticsController {
   @ApiOkResponse({ type: IncomeSummaryResourceDto })
   allSummary(
     @Req() request: Request & { user: AccessPayload },
-    @Query() query: InvestmentReadQueryDto,
   ) {
     return this.income.summary(
       request.user.sub,
       'all',
-      query.sync === 'observe',
     );
   }
 
@@ -45,7 +43,6 @@ export class IncomeAnalyticsController {
       'all',
       query.from,
       query.to,
-      query.sync === 'observe',
     );
   }
 
@@ -54,12 +51,10 @@ export class IncomeAnalyticsController {
   summary(
     @Req() request: Request & { user: AccessPayload },
     @Param('accountId') accountId: string,
-    @Query() query: InvestmentReadQueryDto,
   ) {
     return this.income.summary(
       request.user.sub,
       accountId,
-      query.sync === 'observe',
     );
   }
 
@@ -75,7 +70,6 @@ export class IncomeAnalyticsController {
       accountId,
       query.from,
       query.to,
-      query.sync === 'observe',
     );
   }
 }

src/modules/investments/income/income-analytics.dto.ts

@@ -1,17 +1,17 @@
 import { ApiProperty, ApiPropertyOptional } from '@nestjs/swagger';
 import { IsOptional, Matches } from 'class-validator';
 
-import { MoneyDto } from '../../../common/money.dto';
+import { MoneyDto } from '#src/common/money.dto';
+
 import {
   InvestmentDependencyDto,
-  InvestmentReadQueryDto,
   InvestmentResourceMetaDto,
 } from '../investment-resource.dto';
 import { BrokerageOperationDto } from '../operations/operations.api';
 
 const dateOnly = /^\d{4}-\d{2}-\d{2}$/;
 
-export class IncomeAnalyticsQueryDto extends InvestmentReadQueryDto {
+export class IncomeAnalyticsQueryDto {
   @ApiPropertyOptional({
     format: 'date',
     description:

src/modules/investments/income/income-analytics.service.spec.ts

@@ -1,4 +1,4 @@
-jest.mock('../../../prisma/prisma.service', () => ({
+jest.mock('#src/prisma/prisma.service', () => ({
   PrismaService: class {},
 }));
 jest.mock('../operations/application/brokerage-operations.service', () => ({

src/modules/investments/income/income-analytics.service.ts

@@ -6,8 +6,9 @@ import {
   compare,
   decimalFromString,
   formatDecimal,
-} from '../../../common/decimal';
+} from '#src/common/decimal';
-import { isTbankProtocolValue, TbankOperationType } from '../../../integrations/tbank/tbank-protocol';
+import { isTbankProtocolValue, TbankOperationType } from '#src/integrations/tbank/tbank-protocol';
+
 import { DateOnlyRange, moscowDate } from '../investment-calendar';
 import { investmentResourceMeta } from '../investment-resource.mapper';
 import {
@@ -43,14 +44,12 @@ export class IncomeAnalyticsService {
   async summary(
     userId: string,
     accountId: string,
-    observe = false,
   ): Promise<IncomeSummaryResourceDto> {
     const plan = planIncomePeriod(undefined, undefined);
     const [selected] = await this.operations.collectRanges(
       userId,
       accountId,
       () => [plan.selected],
-      observe,
     );
     if (selected.items === null) return { data: null, meta: selected.meta };
     assert(selected.meta.lastSuccessfulAt);
@@ -70,14 +69,12 @@ export class IncomeAnalyticsService {
     accountId: string,
     from: string | undefined,
     to: string | undefined,
-    observe = false,
   ): Promise<IncomeAnalyticsResourceDto> {
     const plan = planIncomePeriod(from, to);
     const [current] = await this.operations.collectRanges(
       userId,
       accountId,
       () => [plan.selected],
-      observe,
     );
     const dependencies: IncomeDependencyDto[] = [
       { ...current.meta, role: 'selected' },

src/modules/investments/income/income-period.ts

@@ -1,6 +1,7 @@
 import { BadRequestException } from '@nestjs/common';
 
-import { ISO_DATE_LENGTH, ISO_DATE_START, MILLISECONDS_PER_DAY } from '../../../common/time';
+import { ISO_DATE_LENGTH, ISO_DATE_START, MILLISECONDS_PER_DAY } from '#src/common/time';
+
 import {
   DateOnlyRange,
   dateParts,

src/modules/investments/instruments/application/candle.service.spec.ts

@@ -4,7 +4,7 @@ jest.mock('../infrastructure/candle.repository', () => ({
 jest.mock('./catalog-enrichment.service', () => ({
   CatalogEnrichmentService: class {},
 }));
-jest.mock('../../../../integrations/tbank/tbank.api', () => ({
+jest.mock('#src/integrations/tbank/tbank.api', () => ({
   TbankAccessService: class {},
   TbankClient: class {},
 }));

src/modules/investments/instruments/application/candle.service.ts

@@ -5,15 +5,16 @@ import {
 } from '@nestjs/common';
 import { randomUUID } from 'node:crypto';
 
-import { StructuredLogger } from '../../../../common/logging/structured-logger.service';
+import { StructuredLogger } from '#src/common/logging/structured-logger.service';
-import { MILLISECONDS_PER_DAY } from '../../../../common/time';
+import { MILLISECONDS_PER_DAY } from '#src/common/time';
-import { isTbankErrorCode, TbankErrorCode } from '../../../../integrations/tbank/tbank-error-code';
+import { isTbankErrorCode, TbankErrorCode } from '#src/integrations/tbank/tbank-error-code';
 import {
   TbankAccessService,
   TbankClient,
   type TbankShare,
   type TbankSyncAttempt,
-} from '../../../../integrations/tbank/tbank.api';
+} from '#src/integrations/tbank/tbank.api';
+
 import { investmentResourceMeta } from '../../investment-resource.mapper';
 import {
   candleGaps,
@@ -98,7 +99,7 @@ export class CandleService {
     private readonly logger: StructuredLogger,
   ) {}
 
-  async read(userId: string, input: CandleInput, observe = false) {
+  async read(userId: string, input: CandleInput) {
     const { revision } = await this.access.local(userId);
     const [detail] = await this.sources.readMany(
       userId,
@@ -118,7 +119,7 @@ export class CandleService {
     const hasCompleteRange = Boolean(
       range && saved && candleGaps(range, saved.coverage, now).length === NO_CANDLE_GAPS,
     );
-    if (!observe && (!saved || !hasCompleteRange)) {
+    if (!saved || !hasCompleteRange) {
       await this.request(userId, revision, input, now);
     }
     const work = await this.repository.work(userId, revision, scope(input));

src/modules/investments/instruments/application/catalog-discovery.service.ts

@@ -8,16 +8,15 @@ import {
   TbankAccessService,
   TbankClient,
   tbankSourceTtlMs,
-} from '../../../../integrations/tbank/tbank.api';
+} from '#src/integrations/tbank/tbank.api';
+
 import { investmentResourceMeta } from '../../investment-resource.mapper';
 import { InstrumentErrorCode } from '../domain/instrument-error-code';
 import {
-  CatalogDiscoveryRepository,
   catalogQuery,
   type CatalogQuery,
   catalogScope,
 } from '../infrastructure/catalog-discovery.repository';
-import { CatalogEnrichmentService } from './catalog-enrichment.service';
 import {
   catalogSearchLimit,
   selectCatalogInstruments,
@@ -25,7 +24,6 @@ import {
 import { publicInstrument } from './public-instrument';
 
 const UNAMBIGUOUS_MATCH_COUNT = 1;
-const NO_MATCHES = 0;
 const FIRST_RESULT_OFFSET = 0;
 
 const tickerAmbiguityLimit = 2;
@@ -33,203 +31,56 @@ const tickerAmbiguityLimit = 2;
 @Injectable()
 export class CatalogDiscoveryService {
   constructor(
-    private readonly repository: CatalogDiscoveryRepository,
     private readonly access: TbankAccessService,
     private readonly tbank: TbankClient,
-    private readonly enrichment: CatalogEnrichmentService,
   ) {}
 
-  async read(userId: string, input: CatalogQuery) {
+  async search(userId: string, input: CatalogQuery) {
-    input = catalogQuery(input);
+    return this.onlineSearch(userId, catalogQuery(input));
-    const connection = await this.access.local(userId);
-    const saved = await this.repository.read(input);
-    return {
-      data: saved.data,
-      meta: investmentResourceMeta({
-        resourceKey: catalogScope(input),
-        dataRevision: saved.dataRevision,
-        availability: saved.data === null ? 'missing' : 'complete',
-        fetchedAt: saved.fetchedAt,
-        freshForMs: Number.MAX_SAFE_INTEGER,
-        work: await this.repository.work(userId, connection.revision, input),
-      }),
-    };
-  }
-
-  async search(userId: string, input: CatalogQuery, observe = false) {
-    if (!observe) return this.onlineSearch(userId, catalogQuery(input));
-    const discovery = await this.read(userId, input);
-    const sources = discovery.data
-      ? await this.enrichment.readMany(
-          userId,
-          input.instrumentType,
-          discovery.data.map((item) => item.uid),
-          observe,
-        )
-      : [];
-    const dependencies = [
-      discovery.meta,
-      ...sources.map((source) => source.meta),
-    ];
-    return {
-      data:
-        discovery.data?.map((short) => ({
-          ...short,
-          detail:
-            sources.find(
-              (source) =>
-                source.input.uid === short.uid &&
-                source.input.kind === 'detail',
-            )?.instrument ?? null,
-          price:
-            sources.find(
-              (source) =>
-                source.input.uid === short.uid &&
-                source.input.kind === 'last-price',
-            )?.price ?? null,
-        })) ?? null,
-      meta: investmentResourceMeta({
-        resourceKey: `search:${catalogScope(catalogQuery(input))}`,
-        dataRevision: dependencies
-          .map((dependency) => dependency.dataRevision)
-          .join('/'),
-        availability:
-          discovery.data === null
-            ? 'missing'
-            : sources.every((source) => source.meta.completeness === 'complete')
-              ? 'complete'
-              : 'partial',
-        fetchedAt: discovery.meta.lastSuccessfulAt
-          ? new Date(discovery.meta.lastSuccessfulAt)
-          : null,
-        freshForMs: Number.MAX_SAFE_INTEGER,
-        work: discovery.meta.sync.id
-          ? {
-              id: discovery.meta.sync.id,
-              state: discovery.meta.sync.state,
-              errorCode: discovery.meta.sync.errorCode,
-            }
-          : null,
-        dependencies,
-      }),
-    };
   }
 
   async detail(
     userId: string,
     instrumentType: 'bond' | 'share',
     uid: string,
-    observe = false,
   ) {
-    if (!observe) {
+    const instrument = await this.access.online(userId, ({ token }) =>
-      const instrument = await this.access.online(userId, ({ token }) =>
+      instrumentType === 'share'
-        instrumentType === 'share'
+        ? this.tbank.getShare(token, uid)
-          ? this.tbank.getShare(token, uid)
+        : this.tbank.getBond(token, uid),
-          : this.tbank.getBond(token, uid),
-      );
-      if (!instrument) throw new NotFoundException();
-      return {
-        data: { ...publicInstrument({ ...instrument, uid }), uid, slug: instrument.ticker?.toUpperCase() ?? uid },
-        meta: investmentResourceMeta({
-          resourceKey: `${instrumentType}/detail/${uid}`,
-          dataRevision: `online:${Date.now()}`,
-          availability: 'complete',
-          fetchedAt: new Date(),
-          freshForMs: tbankSourceTtlMs.portfolio,
-          work: null,
-        }),
-      };
-    }
-    const sources = await this.enrichment.readMany(
-      userId,
-      instrumentType,
-      [uid],
-      observe,
-      ['detail'],
     );
-    const source = sources[0];
+    if (!instrument) throw new NotFoundException();
-    if (source.meta.completeness === 'complete' && !source.instrument) {
-      throw new NotFoundException();
-    }
-    const instrument = source.instrument;
-    let slug = uid;
-    const dependencies = [source.meta];
-    if (
-      instrument?.ticker &&
-      /^[A-Z0-9][\w.@+-]{0,79}$/i.test(instrument.ticker)
-    ) {
-      const alias = await this.read(userId, {
-        instrumentType,
-        query: instrument.ticker,
-        exactTicker: true,
-      });
-      if (alias.data?.length === UNAMBIGUOUS_MATCH_COUNT && alias.data[0].uid === uid) {
-        slug = instrument.ticker.toUpperCase();
-      }
-      dependencies.push(alias.meta);
-    }
     return {
-      data: instrument ? { ...instrument, uid, slug } : null,
+      data: { ...publicInstrument({ ...instrument, uid }), uid, slug: instrument.ticker?.toUpperCase() ?? uid },
       meta: investmentResourceMeta({
         resourceKey: `${instrumentType}/detail/${uid}`,
-        dataRevision: dependencies
+        dataRevision: `online:${Date.now()}`,
-          .map((dependency) => dependency.dataRevision)
+        availability: 'complete',
-          .join('/'),
+        fetchedAt: new Date(),
-        availability: source.meta.availability,
-        fetchedAt: source.meta.lastSuccessfulAt
-          ? new Date(source.meta.lastSuccessfulAt)
-          : null,
         freshForMs: tbankSourceTtlMs.portfolio,
-        work: source.meta.sync.id
+        work: null,
-          ? {
-              id: source.meta.sync.id,
-              state: source.meta.sync.state,
-              errorCode: source.meta.sync.errorCode,
-            }
-          : null,
-        dependencies,
       }),
     };
   }
 
-  // eslint-disable-next-line sonarjs/cognitive-complexity -- Online and observe paths intentionally preserve distinct error semantics.
   async byTicker(
     userId: string,
     instrumentType: 'bond' | 'share',
     ticker: string,
-    observe = false,
   ) {
-    if (!observe) {
+    const query = ticker.trim().toUpperCase();
-      const query = ticker.trim().toUpperCase();
+    const found = await this.access.online(userId, ({ token }) =>
-      const found = await this.access.online(userId, ({ token }) =>
+      instrumentType === 'share'
-        instrumentType === 'share'
+        ? this.tbank.findShares(token, query)
-          ? this.tbank.findShares(token, query)
+        : this.tbank.findBonds(token, query),
-          : this.tbank.findBonds(token, query),
+    );
-      );
+    const matches = selectCatalogInstruments(
-      const matches = selectCatalogInstruments(
+      found.filter((item) => item.ticker?.trim().toUpperCase() === query),
-        found.filter((item) => item.ticker?.trim().toUpperCase() === query),
+      query,
-        query,
-        instrumentType,
-      ).slice(FIRST_RESULT_OFFSET, tickerAmbiguityLimit);
-      if (!matches.length) throw new NotFoundException();
-      if (matches.length > UNAMBIGUOUS_MATCH_COUNT) {
-        throw new ConflictException({
-          code:
-            instrumentType === 'share'
-              ? InstrumentErrorCode.StockTickerAmbiguous
-              : InstrumentErrorCode.BondTickerAmbiguous,
-        });
-      }
-      const result = await this.detail(userId, instrumentType, matches[0].uid);
-      return { ...result, data: result.data ? { ...result.data, slug: query } : null };
-    }
-    const lookup = await this.read(userId, {
       instrumentType,
-      query: ticker,
+    ).slice(FIRST_RESULT_OFFSET, tickerAmbiguityLimit);
-      exactTicker: true,
+    if (!matches.length) throw new NotFoundException();
-    });
+    if (matches.length > UNAMBIGUOUS_MATCH_COUNT) {
-    if (lookup.data?.length === NO_MATCHES) throw new NotFoundException();
-    if (lookup.data && lookup.data.length > UNAMBIGUOUS_MATCH_COUNT) {
       throw new ConflictException({
         code:
           instrumentType === 'share'
@@ -237,34 +88,8 @@ export class CatalogDiscoveryService {
             : InstrumentErrorCode.BondTickerAmbiguous,
       });
     }
-    const result = lookup.data
+    const result = await this.detail(userId, instrumentType, matches[0].uid);
-      ? await this.detail(userId, instrumentType, lookup.data[0].uid, observe)
+    return { ...result, data: result.data ? { ...result.data, slug: query } : null };
-      : null;
-    const dependencies = [lookup.meta, ...(result ? [result.meta] : [])];
-    return {
-      data: result?.data
-        ? { ...result.data, slug: ticker.trim().toUpperCase() }
-        : null,
-      meta: investmentResourceMeta({
-        resourceKey: `${instrumentType}/ticker/${ticker.trim().toUpperCase()}`,
-        dataRevision: dependencies
-          .map((dependency) => dependency.dataRevision)
-          .join('/'),
-        availability: result?.meta.availability ?? 'missing',
-        fetchedAt: lookup.meta.lastSuccessfulAt
-          ? new Date(lookup.meta.lastSuccessfulAt)
-          : null,
-        freshForMs: tbankSourceTtlMs.portfolio,
-        work: lookup.meta.sync.id
-          ? {
-              id: lookup.meta.sync.id,
-              state: lookup.meta.sync.state,
-              errorCode: lookup.meta.sync.errorCode,
-            }
-          : null,
-        dependencies,
-      }),
-    };
   }
 
   private async onlineSearch(userId: string, input: CatalogQuery) {

src/modules/investments/instruments/application/catalog-enrichment.service.ts

@@ -1,8 +1,8 @@
 import { Injectable, NotFoundException } from '@nestjs/common';
 import { randomUUID } from 'node:crypto';
 
-import { StructuredLogger } from '../../../../common/logging/structured-logger.service';
+import { StructuredLogger } from '#src/common/logging/structured-logger.service';
-import { isTbankErrorCode, TbankErrorCode } from '../../../../integrations/tbank/tbank-error-code';
+import { isTbankErrorCode, TbankErrorCode } from '#src/integrations/tbank/tbank-error-code';
 import {
   TbankAccessService,
   TbankClient,
@@ -10,7 +10,8 @@ import {
   tbankSourceNeedsRefresh,
   tbankSourceTtlMs,
   type TbankSyncAttempt,
-} from '../../../../integrations/tbank/tbank.api';
+} from '#src/integrations/tbank/tbank.api';
+
 import { investmentResourceMeta } from '../../investment-resource.mapper';
 import {
   CatalogDiscoveryRepository,
@@ -221,9 +222,8 @@ export class CatalogEnrichmentService {
     instrumentType: 'bond' | 'share',
     uid: string,
     section: 'company' | 'metrics' | 'quote',
-    observe = false,
   ) {
-    if (section === 'company' && !observe) {
+    if (section === 'company') {
       const { description, fundamentals, instrument } = await this.access.online(userId, async ({ token }) => {
         const instrument =
           instrumentType === 'share'
@@ -253,25 +253,22 @@ export class CatalogEnrichmentService {
         observedAt: meta.lastSuccessfulAt ?? new Date().toISOString(),
       };
     }
-    const kinds: CatalogSource['kind'][] =
+    const kinds: CatalogSource['kind'][] = [
-      section === 'company'
+      ...(instrumentType === 'bond'
-        ? ['detail', 'description', 'fundamentals']
+        ? ['bond-current' as const]
-        : [
+        : ['detail' as const]),
-            ...(instrumentType === 'bond'
+      'last-price',
-              ? ['bond-current' as const]
+      'trading-status',
-              : ['detail' as const]),
+      'comparison',
-            'last-price',
+      ...(section === 'metrics'
-            'trading-status',
+        ? ['coupons' as const, 'yield' as const, 'rating' as const]
-            'comparison',
+        : []),
-            ...(section === 'metrics'
+    ];
-              ? ['coupons' as const, 'yield' as const, 'rating' as const]
-              : []),
-          ];
     const sources = await this.readMany(
       userId,
       instrumentType,
       [uid],
-      observe,
+      false,
       kinds,
     );
     const first = sources[0];
@@ -299,7 +296,7 @@ export class CatalogEnrichmentService {
       fetchedAt: first.meta.lastSuccessfulAt
         ? new Date(first.meta.lastSuccessfulAt)
         : null,
-      freshForMs: section === 'company' ? Number.MAX_SAFE_INTEGER : tbankSourceTtlMs.quote,
+      freshForMs: tbankSourceTtlMs.quote,
       work: null,
       dependencies,
     });

src/modules/investments/instruments/application/catalog-selection.ts

@@ -1,6 +1,6 @@
-import type { TbankShare } from '../../../../integrations/tbank/tbank.api';
+import type { TbankShare } from '#src/integrations/tbank/tbank.api';
 
-import { TbankInstrumentType } from '../../../../integrations/tbank/tbank-protocol';
+import { TbankInstrumentType } from '#src/integrations/tbank/tbank-protocol';
 
 export const catalogSearchLimit = 30;
 

src/modules/investments/instruments/application/catalog-source.loader.ts

@@ -3,13 +3,13 @@ import { Injectable } from '@nestjs/common';
 import {
   decimalFromString,
   divide,
-} from '../../../../common/decimal';
+} from '#src/common/decimal';
 import {
   MILLISECONDS_PER_DAY,
   MILLISECONDS_PER_SECOND,
-} from '../../../../common/time';
+} from '#src/common/time';
-import { type MoexBondEvent, MoexClient } from '../../../../integrations/moex/moex.api';
+import { type MoexBondEvent, MoexClient } from '#src/integrations/moex/moex.api';
-import { NcrRatingsClient } from '../../../../integrations/ncr/ncr.api';
+import { NcrRatingsClient } from '#src/integrations/ncr/ncr.api';
 import {
   type TbankBond,
   type TbankCandle,
@@ -20,7 +20,8 @@ import {
   type TbankLastPrice,
   type TbankShare,
   type TbankSyncAttempt,
-} from '../../../../integrations/tbank/tbank.api';
+} from '#src/integrations/tbank/tbank.api';
+
 import { candleGaps, utcDay } from '../domain/candle-coverage';
 import { CandleRepository } from '../infrastructure/candle.repository';
 import {

src/modules/investments/instruments/application/instrument-market.ts

@@ -1,9 +1,9 @@
 import type {
   TbankCandle,
   TbankTimestamp,
-} from '../../../../integrations/tbank/tbank.api';
+} from '#src/integrations/tbank/tbank.api';
 
-import { ISO_DATE_LENGTH, ISO_DATE_START, MILLISECONDS_PER_SECOND } from '../../../../common/time';
+import { ISO_DATE_LENGTH, ISO_DATE_START, MILLISECONDS_PER_SECOND } from '#src/common/time';
 
 const MIN_TIMESTAMP_SECONDS_EXCLUSIVE = 0;
 

src/modules/investments/instruments/application/instrument-position.ts

@@ -4,8 +4,9 @@ import {
   divide,
   formatDecimal,
   multiply,
-} from '../../../../common/decimal';
+} from '#src/common/decimal';
-import { MoneyDto } from '../../../../common/money.dto';
+import { MoneyDto } from '#src/common/money.dto';
+
 import {
   PortfolioDto,
   PortfolioPositionDto,

src/modules/investments/instruments/application/public-instrument.spec.ts

@@ -1,7 +1,7 @@
 import type {
   TbankBond,
   TbankShare,
-} from '../../../../integrations/tbank/tbank.api';
+} from '#src/integrations/tbank/tbank.api';
 
 import { publicInstrument } from './public-instrument';
 

src/modules/investments/instruments/application/public-instrument.ts

@@ -1,7 +1,7 @@
 import type {
   TbankBond,
   TbankShare,
-} from '../../../../integrations/tbank/tbank.api';
+} from '#src/integrations/tbank/tbank.api';
 
 export function publicInstrument(value: TbankBond | TbankShare) {
   const bond = value as TbankBond;

src/modules/investments/instruments/bonds/application/bond-catalog.service.ts

@@ -1,9 +1,10 @@
 import { Injectable } from '@nestjs/common';
 
-import type { TbankBond } from '../../../../../integrations/tbank/tbank.api';
+import type { TbankBond } from '#src/integrations/tbank/tbank.api';
+
+import { formatDecimal } from '#src/common/decimal';
+import { decimal } from '#src/integrations/tbank/decimal';
 
-import { formatDecimal } from '../../../../../common/decimal';
-import { decimal } from '../../../../../integrations/tbank/decimal';
 import { CatalogDiscoveryService } from '../../application/catalog-discovery.service';
 import { timestamp } from '../../application/instrument-market';
 import {
@@ -14,7 +15,8 @@ import {
 
 type IdentifiedBond = TbankBond & { uid: string };
 
-import { ISO_DATE_LENGTH, ISO_DATE_START } from '../../../../../common/time';
+import { ISO_DATE_LENGTH, ISO_DATE_START } from '#src/common/time';
+
 import { money } from '../infrastructure/bond-money.mapper';
 
 const MIN_LOT_EXCLUSIVE = 0;
@@ -25,12 +27,10 @@ export class BondCatalogService {
   async search(
     userId: string,
     query: string,
-    observe = false,
   ): Promise<BondSearchResourceDto> {
     const result = await this.discovery.search(
       userId,
       { instrumentType: 'bond', query },
-      observe,
     );
     return {
       ...result,
@@ -58,9 +58,8 @@ export class BondCatalogService {
   async get(
     userId: string,
     uid: string,
-    observe = false,
   ): Promise<BondResourceDto> {
-    const result = await this.discovery.detail(userId, 'bond', uid, observe);
+    const result = await this.discovery.detail(userId, 'bond', uid);
     return {
       ...result,
       data: result.data
@@ -72,13 +71,11 @@ export class BondCatalogService {
   async getByTicker(
     userId: string,
     ticker: string,
-    observe = false,
   ): Promise<BondResourceDto> {
     const result = await this.discovery.byTicker(
       userId,
       'bond',
       ticker,
-      observe,
     );
     return {
       ...result,

src/modules/investments/instruments/bonds/application/bond-income.service.ts

@@ -5,19 +5,20 @@ import {
   divide,
   formatDecimal,
   multiply,
-} from '../../../../../common/decimal';
+} from '#src/common/decimal';
-import { ISO_DATE_LENGTH, ISO_DATE_START } from '../../../../../common/time';
+import { ISO_DATE_LENGTH, ISO_DATE_START } from '#src/common/time';
-import { isTbankProtocolValue, TbankCouponType } from '../../../../../integrations/tbank/tbank-protocol';
+import { isTbankProtocolValue, TbankCouponType } from '#src/integrations/tbank/tbank-protocol';
 import {
   TbankAccessService,
   type TbankBond,
   type TbankCoupon,
   tbankSourceNeedsRefresh,
-} from '../../../../../integrations/tbank/tbank.api';
+} from '#src/integrations/tbank/tbank.api';
 import {
   ForecastService,
   PortfolioService,
-} from '../../../portfolio/portfolio.api';
+} from '#src/modules/investments/portfolio/portfolio.api';
+
 import {
   CatalogEnrichmentService,
   type CatalogPayload,
@@ -54,14 +55,12 @@ export class BondIncomeService {
   async metrics(
     userId: string,
     uid: string,
-    observe = false,
   ): Promise<BondMetricsResourceDto> {
     const result = await this.sources.section(
       userId,
       'bond',
       uid,
       'metrics',
-      observe,
     );
     return {
       data: result.values.instrument
@@ -82,7 +81,6 @@ export class BondIncomeService {
   async coupons(
     userId: string,
     uid: string,
-    observe = false,
   ): Promise<BondCouponsResourceDto> {
     const connection = await this.access.local(userId);
     const today = moscowDay(new Date().toISOString());
@@ -93,7 +91,7 @@ export class BondIncomeService {
       userId,
       'bond',
       [uid],
-      observe,
+      false,
       ['detail', 'coupons'],
       { from, to },
     );

src/modules/investments/instruments/bonds/application/bond-market.service.ts

@@ -1,6 +1,6 @@
 import { Injectable } from '@nestjs/common';
 
-import type { TbankBond } from '../../../../../integrations/tbank/tbank.api';
+import type { TbankBond } from '#src/integrations/tbank/tbank.api';
 
 import {
   add,
@@ -9,9 +9,10 @@ import {
   formatDecimal,
   multiply,
   subtract,
-} from '../../../../../common/decimal';
+} from '#src/common/decimal';
-import { ISO_DATE_LENGTH, ISO_DATE_START } from '../../../../../common/time';
+import { ISO_DATE_LENGTH, ISO_DATE_START } from '#src/common/time';
-import { decimal } from '../../../../../integrations/tbank/decimal';
+import { decimal } from '#src/integrations/tbank/decimal';
+
 import { CandleService } from '../../application/candle.service';
 import {
   CatalogEnrichmentService,
@@ -38,14 +39,12 @@ export class BondMarketService {
   async quote(
     userId: string,
     uid: string,
-    observe = false,
   ): Promise<BondQuoteResourceDto> {
     const result = await this.sources.section(
       userId,
       'bond',
       uid,
       'quote',
-      observe,
     );
     return {
       data: result.values.instrument
@@ -59,12 +58,10 @@ export class BondMarketService {
     userId: string,
     uid: string,
     period: BondCandlesQueryDto['period'] = 'month',
-    observe = false,
   ) {
     return this.history.read(
       userId,
       { uid, instrumentType: 'bond', period },
-      observe,
     );
   }
 }

src/modules/investments/instruments/bonds/application/bond.spec.ts

@@ -1,9 +1,9 @@
-import type { PortfolioDto } from '../../../portfolio/portfolio.api';
+import type { PortfolioDto } from '#src/modules/investments/portfolio/portfolio.api';
 
 import { instrumentPosition } from '../../application/instrument-position';
 import { bondCoupons, bondMetrics } from './bond-income.service';
 import { bondQuote } from './bond-market.service';
-jest.mock('../../../../../prisma/prisma.service', () => ({
+jest.mock('#src/prisma/prisma.service', () => ({
   PrismaService: class {},
 }));
 const time = (value: string) => ({ seconds: String(Date.parse(value) / 1000) });

src/modules/investments/instruments/bonds/infrastructure/bond-money.mapper.ts

@@ -1,6 +1,6 @@
-import { formatDecimal } from '../../../../../common/decimal';
+import { formatDecimal } from '#src/common/decimal';
-import { decimal } from '../../../../../integrations/tbank/decimal';
+import { decimal } from '#src/integrations/tbank/decimal';
-import { type TbankMoney } from '../../../../../integrations/tbank/tbank.api';
+import { type TbankMoney } from '#src/integrations/tbank/tbank.api';
 
 export function money(value?: TbankMoney) {
   const currency = value?.currency?.toUpperCase();

src/modules/investments/instruments/bonds/presentation/bond.controller.ts

@@ -11,9 +11,9 @@ import {
 } from '@nestjs/common';
 import { ApiBearerAuth, ApiOkResponse, ApiTags } from '@nestjs/swagger';
 
-import { ApiProblemResponses } from '../../../../../common/decorators/api-safe-error-response.decorator';
+import { ApiProblemResponses } from '#src/common/decorators/api-safe-error-response.decorator';
-import { AccessPayload, JwtAuthGuard } from '../../../../auth/auth.api';
+import { AccessPayload, JwtAuthGuard } from '#src/modules/auth/auth.api';
-import { InvestmentReadQueryDto } from '../../../investment-resource.dto';
+
 import { BondCatalogService } from '../application/bond-catalog.service';
 import { BondIncomeService } from '../application/bond-income.service';
 import { BondMarketService } from '../application/bond-market.service';
@@ -47,9 +47,8 @@ export class BondController {
   metrics(
     @Req() request: Request & { user: AccessPayload },
     @Param('uid', new ParseUUIDPipe()) uid: string,
-    @Query() query: InvestmentReadQueryDto,
   ) {
-    return this.income.metrics(request.user.sub, uid, query.sync === 'observe');
+    return this.income.metrics(request.user.sub, uid);
   }
 
   @Get()
@@ -61,7 +60,6 @@ export class BondController {
     return this.bonds.search(
       request.user.sub,
       query.query,
-      query.sync === 'observe',
     );
   }
 
@@ -70,12 +68,10 @@ export class BondController {
   getByTicker(
     @Req() request: Request & { user: AccessPayload },
     @Param() params: BondTickerParamsDto,
-    @Query() query: InvestmentReadQueryDto,
   ) {
     return this.bonds.getByTicker(
       request.user.sub,
       params.ticker,
-      query.sync === 'observe',
     );
   }
 
@@ -84,9 +80,8 @@ export class BondController {
   get(
     @Req() request: Request & { user: AccessPayload },
     @Param('uid', new ParseUUIDPipe()) uid: string,
-    @Query() query: InvestmentReadQueryDto,
   ) {
-    return this.bonds.get(request.user.sub, uid, query.sync === 'observe');
+    return this.bonds.get(request.user.sub, uid);
   }
 
   @Get(':uid/quote')
@@ -94,9 +89,8 @@ export class BondController {
   quote(
     @Req() request: Request & { user: AccessPayload },
     @Param('uid', new ParseUUIDPipe()) uid: string,
-    @Query() query: InvestmentReadQueryDto,
   ) {
-    return this.market.quote(request.user.sub, uid, query.sync === 'observe');
+    return this.market.quote(request.user.sub, uid);
   }
 
   @Get(':uid/candles')
@@ -110,7 +104,6 @@ export class BondController {
       request.user.sub,
       uid,
       query.period,
-      query.sync === 'observe',
     );
   }
 
@@ -128,8 +121,7 @@ export class BondController {
   coupons(
     @Req() request: Request & { user: AccessPayload },
     @Param('uid', new ParseUUIDPipe()) uid: string,
-    @Query() query: InvestmentReadQueryDto,
   ) {
-    return this.income.coupons(request.user.sub, uid, query.sync === 'observe');
+    return this.income.coupons(request.user.sub, uid);
   }
 }

src/modules/investments/instruments/bonds/presentation/bond.dto.ts

@@ -1,7 +1,8 @@
 import { ApiProperty } from '@nestjs/swagger';
 
-import { MoneyDto } from '../../../../../common/money.dto';
+import { MoneyDto } from '#src/common/money.dto';
-import { InvestmentResourceMetaDto } from '../../../investment-resource.dto';
+import { InvestmentResourceMetaDto } from '#src/modules/investments/investment-resource.dto';
+
 import {
   StockCandlesDto,
   StockCandlesQueryDto,

src/modules/investments/instruments/domain/candle-coverage.ts

@@ -1,4 +1,4 @@
-import { MILLISECONDS_PER_DAY } from '../../../../common/time';
+import { MILLISECONDS_PER_DAY } from '#src/common/time';
 
 const FIRST_RANGE_END_INDEX = 1;
 

src/modules/investments/instruments/infrastructure/candle.repository.ts

@@ -1,18 +1,19 @@
 import { Injectable } from '@nestjs/common';
 import { createHash, randomUUID } from 'node:crypto';
 
-import type { Prisma } from '../../../../../generated/prisma/client';
+import type { Prisma } from '#generated/prisma/client';
 
 import {
   claimSyncWork,
   lockConnectionGeneration,
-} from '../../../../integrations/tbank/tbank-sync-claim';
+} from '#src/integrations/tbank/tbank-sync-claim';
 import {
   isJoinableRunningAttempt,
   type TbankSyncAttempt,
-} from '../../../../integrations/tbank/tbank.api';
+} from '#src/integrations/tbank/tbank.api';
-import { PrismaService } from '../../../../prisma/prisma.service';
+import { PrismaService } from '#src/prisma/prisma.service';
-import { toJson } from '../../../../prisma/to-json';
+import { toJson } from '#src/prisma/to-json';
+
 import {
   type CandleRange,
   confirmedCandleCoverage,

src/modules/investments/instruments/infrastructure/catalog-discovery.repository.ts

@@ -2,11 +2,11 @@ import { Injectable } from '@nestjs/common';
 import { randomUUID } from 'node:crypto';
 import { isDeepStrictEqual } from 'node:util';
 
-import { TbankErrorCode } from '../../../../integrations/tbank/tbank-error-code';
+import { TbankErrorCode } from '#src/integrations/tbank/tbank-error-code';
-import { claimSyncWork, lockConnectionGeneration } from '../../../../integrations/tbank/tbank-sync-claim';
+import { claimSyncWork, lockConnectionGeneration } from '#src/integrations/tbank/tbank-sync-claim';
-import { isJoinableRunningAttempt, type TbankBond, type TbankShare, type TbankSyncAttempt } from '../../../../integrations/tbank/tbank.api';
+import { isJoinableRunningAttempt, type TbankBond, type TbankShare, type TbankSyncAttempt } from '#src/integrations/tbank/tbank.api';
-import { PrismaService } from '../../../../prisma/prisma.service';
+import { PrismaService } from '#src/prisma/prisma.service';
-import { toJson } from '../../../../prisma/to-json';
+import { toJson } from '#src/prisma/to-json';
 
 const UNCHANGED_REVISION_INCREMENT = 0;
 const REVISION_INCREMENT = 1;

src/modules/investments/instruments/infrastructure/tbank-candle.mapper.ts

@@ -1,8 +1,10 @@
-import type { TbankCandle } from '../../../../integrations/tbank/tbank.api';
+import type { TbankCandle } from '#src/integrations/tbank/tbank.api';
+
+import { formatDecimal } from '#src/common/decimal';
+import { decimal } from '#src/integrations/tbank/decimal';
+
 import type { SavedCandle } from '../domain/candle-coverage';
 
-import { formatDecimal } from '../../../../common/decimal';
-import { decimal } from '../../../../integrations/tbank/decimal';
 import { timestamp } from '../application/instrument-market';
 
 function toSavedCandle(candle: TbankCandle): SavedCandle {

src/modules/investments/instruments/instrument-sources.module.ts

@@ -1,8 +1,9 @@
 import { Module } from '@nestjs/common';
 
-import { MoexModule } from '../../../integrations/moex/moex.module';
+import { MoexModule } from '#src/integrations/moex/moex.module';
-import { NcrModule } from '../../../integrations/ncr/ncr.module';
+import { NcrModule } from '#src/integrations/ncr/ncr.module';
-import { TbankModule } from '../../../integrations/tbank/tbank.module';
+import { TbankModule } from '#src/integrations/tbank/tbank.module';
+
 import { CandleService } from './application/candle.service';
 import { CatalogDiscoveryService } from './application/catalog-discovery.service';
 import { CatalogEnrichmentService } from './application/catalog-enrichment.service';

src/modules/investments/instruments/instruments.module.ts

@@ -1,6 +1,7 @@
 import { Module } from '@nestjs/common';
 
-import { TbankModule } from '../../../integrations/tbank/tbank.module';
+import { TbankModule } from '#src/integrations/tbank/tbank.module';
+
 import { AuthModule } from '../../auth/auth.module';
 import { PortfolioModule } from '../portfolio/portfolio.module';
 import { BondCatalogService } from './bonds/application/bond-catalog.service';

src/modules/investments/instruments/stocks/application/get-stock-company.use-case.ts

@@ -1,6 +1,6 @@
 import { Injectable } from '@nestjs/common';
 
-import type { TbankFundamentals } from '../../../../../integrations/tbank/tbank.api';
+import type { TbankFundamentals } from '#src/integrations/tbank/tbank.api';
 
 import { CatalogEnrichmentService } from '../../application/catalog-enrichment.service';
 import {
@@ -13,14 +13,12 @@ export class GetStockCompanyUseCase {
   async execute(
     userId: string,
     uid: string,
-    observe = false,
   ): Promise<StockCompanyResourceDto> {
     const result = await this.sources.section(
       userId,
       'share',
       uid,
       'company',
-      observe,
     );
     return {
       data: result.values.instrument

src/modules/investments/instruments/stocks/application/stock-catalog.service.ts

@@ -1,9 +1,10 @@
 import { Injectable } from '@nestjs/common';
 
-import type { TbankShare } from '../../../../../integrations/tbank/tbank.api';
+import type { TbankShare } from '#src/integrations/tbank/tbank.api';
+
+import { formatDecimal } from '#src/common/decimal';
+import { decimal } from '#src/integrations/tbank/decimal';
 
-import { formatDecimal } from '../../../../../common/decimal';
-import { decimal } from '../../../../../integrations/tbank/decimal';
 import { CatalogDiscoveryService } from '../../application/catalog-discovery.service';
 import { timestamp } from '../../application/instrument-market';
 import {
@@ -22,12 +23,10 @@ export class StockCatalogService {
   async search(
     userId: string,
     query: string,
-    observe = false,
   ): Promise<StockSearchResourceDto> {
     const result = await this.discovery.search(
       userId,
       { instrumentType: 'share', query },
-      observe,
     );
     return {
       ...result,
@@ -59,9 +58,8 @@ export class StockCatalogService {
   async get(
     userId: string,
     uid: string,
-    observe = false,
   ): Promise<StockResourceDto> {
-    const result = await this.discovery.detail(userId, 'share', uid, observe);
+    const result = await this.discovery.detail(userId, 'share', uid);
     return {
       ...result,
       data: result.data
@@ -73,13 +71,11 @@ export class StockCatalogService {
   async getByTicker(
     userId: string,
     ticker: string,
-    observe = false,
   ): Promise<StockResourceDto> {
     const result = await this.discovery.byTicker(
       userId,
       'share',
       ticker,
-      observe,
     );
     return {
       ...result,

src/modules/investments/instruments/stocks/application/stock-income.service.ts

@@ -4,18 +4,19 @@ import {
   decimalFromString,
   formatDecimal,
   multiply,
-} from '../../../../../common/decimal';
+} from '#src/common/decimal';
-import { ISO_DATE_LENGTH, ISO_DATE_START } from '../../../../../common/time';
+import { ISO_DATE_LENGTH, ISO_DATE_START } from '#src/common/time';
-import { decimal } from '../../../../../integrations/tbank/decimal';
+import { decimal } from '#src/integrations/tbank/decimal';
 import {
   TbankAccessService,
   type TbankDividend,
   tbankSourceNeedsRefresh,
-} from '../../../../../integrations/tbank/tbank.api';
+} from '#src/integrations/tbank/tbank.api';
 import {
   ForecastService,
   PortfolioService,
-} from '../../../portfolio/portfolio.api';
+} from '#src/modules/investments/portfolio/portfolio.api';
+
 import { CatalogEnrichmentService } from '../../application/catalog-enrichment.service';
 import { moscowDay, timestamp } from '../../application/instrument-market';
 import { instrumentPosition } from '../../application/instrument-position';
@@ -51,7 +52,6 @@ export class StockIncomeService {
   async dividends(
     userId: string,
     uid: string,
-    observe = false,
   ): Promise<StockDividendsResourceDto> {
     const connection = await this.access.local(userId);
     const today = moscowDay(new Date().toISOString());
@@ -62,7 +62,7 @@ export class StockIncomeService {
       userId,
       'share',
       [uid],
-      observe,
+      false,
       ['detail', 'dividends'],
       { from, to },
     );

src/modules/investments/instruments/stocks/application/stock-market.service.ts

@@ -6,9 +6,10 @@ import {
   formatDecimal,
   multiply,
   subtract,
-} from '../../../../../common/decimal';
+} from '#src/common/decimal';
-import { ISO_DATE_LENGTH, ISO_DATE_START } from '../../../../../common/time';
+import { ISO_DATE_LENGTH, ISO_DATE_START } from '#src/common/time';
-import { decimal } from '../../../../../integrations/tbank/decimal';
+import { decimal } from '#src/integrations/tbank/decimal';
+
 import { CandleService } from '../../application/candle.service';
 import {
   CatalogEnrichmentService,
@@ -34,14 +35,12 @@ export class StockMarketService {
   async quote(
     userId: string,
     uid: string,
-    observe = false,
   ): Promise<StockQuoteResourceDto> {
     const result = await this.sources.section(
       userId,
       'share',
       uid,
       'quote',
-      observe,
     );
     return {
       data: result.values.instrument
@@ -55,12 +54,10 @@ export class StockMarketService {
     userId: string,
     uid: string,
     period: StockCandlesQueryDto['period'] = 'month',
-    observe = false,
   ) {
     return this.history.read(
       userId,
       { uid, instrumentType: 'share', period },
-      observe,
     );
   }
 }

src/modules/investments/instruments/stocks/application/stock-screener.service.spec.ts

@@ -1,10 +1,10 @@
-jest.mock('../../../../../integrations/tbank/tbank.api', () => ({
+jest.mock('#src/integrations/tbank/tbank.api', () => ({
   TbankAccessService: class {},
 }));
 
 import { NotFoundException, ServiceUnavailableException } from '@nestjs/common';
 
-import type { TbankShare } from '../../../../../integrations/tbank/tbank.api';
+import type { TbankShare } from '#src/integrations/tbank/tbank.api';
 
 import { StockScreenerService } from './stock-screener.service';
 

src/modules/investments/instruments/stocks/application/stock-screener.service.ts

@@ -6,11 +6,12 @@ import {
 } from '@nestjs/common';
 import { randomUUID } from 'node:crypto';
 
-import type { TbankShare } from '../../../../../integrations/tbank/tbank-market.types';
+import type { TbankShare } from '#src/integrations/tbank/tbank-market.types';
+
+import { StructuredLogger } from '#src/common/logging/structured-logger.service';
+import { TbankAccessService } from '#src/integrations/tbank/tbank.api';
+import { TbankClient } from '#src/integrations/tbank/tbank.client';
 
-import { StructuredLogger } from '../../../../../common/logging/structured-logger.service';
-import { TbankAccessService } from '../../../../../integrations/tbank/tbank.api';
-import { TbankClient } from '../../../../../integrations/tbank/tbank.client';
 import {
   selectStockScreenerInstruments,
   type StockScreenerConditions,

src/modules/investments/instruments/stocks/application/stock.spec.ts

@@ -2,7 +2,7 @@ import { previousClose } from '../../application/instrument-market';
 import { metrics } from './get-stock-company.use-case';
 import { stockDividends } from './stock-income.service';
 import { stockQuote } from './stock-market.service';
-jest.mock('../../../../../prisma/prisma.service', () => ({
+jest.mock('#src/prisma/prisma.service', () => ({
   PrismaService: class {},
 }));
 const time = (value: string) => ({ seconds: String(Date.parse(value) / 1000) });

src/modules/investments/instruments/stocks/domain/stock-screener-selection.rules.spec.ts

@@ -1,4 +1,4 @@
-import type { TbankShare } from '../../../../../integrations/tbank/tbank.api';
+import type { TbankShare } from '#src/integrations/tbank/tbank.api';
 
 import { selectStockScreenerInstruments } from './stock-screener-selection.rules';
 

src/modules/investments/instruments/stocks/domain/stock-screener-selection.rules.ts

@@ -1,4 +1,4 @@
-import type { TbankShare } from '../../../../../integrations/tbank/tbank.api';
+import type { TbankShare } from '#src/integrations/tbank/tbank.api';
 
 export type StockScreenerCatalog = {
   asOf: Date;

src/modules/investments/instruments/stocks/presentation/stock.controller.ts

@@ -17,9 +17,9 @@ import {
 } from '@nestjs/common';
 import { ApiBearerAuth, ApiOkResponse, ApiOperation, ApiTags } from '@nestjs/swagger';
 
-import { ApiProblemResponses } from '../../../../../common/decorators/api-safe-error-response.decorator';
+import { ApiProblemResponses } from '#src/common/decorators/api-safe-error-response.decorator';
-import { AccessPayload, JwtAuthGuard } from '../../../../auth/auth.api';
+import { AccessPayload, JwtAuthGuard } from '#src/modules/auth/auth.api';
-import { InvestmentReadQueryDto } from '../../../investment-resource.dto';
+
 import { GetStockCompanyUseCase } from '../application/get-stock-company.use-case';
 import { StockCatalogService } from '../application/stock-catalog.service';
 import { StockIncomeService } from '../application/stock-income.service';
@@ -64,7 +64,6 @@ export class StockController {
     return this.stocks.search(
       request.user.sub,
       query.query,
-      query.sync === 'observe',
     );
   }
 
@@ -73,12 +72,10 @@ export class StockController {
   getByTicker(
     @Req() request: Request & { user: AccessPayload },
     @Param() params: StockTickerParamsDto,
-    @Query() query: InvestmentReadQueryDto,
   ) {
     return this.stocks.getByTicker(
       request.user.sub,
       params.ticker,
-      query.sync === 'observe',
     );
   }
 
@@ -115,9 +112,8 @@ export class StockController {
   get(
     @Req() request: Request & { user: AccessPayload },
     @Param('uid', new ParseUUIDPipe()) uid: string,
-    @Query() query: InvestmentReadQueryDto,
   ) {
-    return this.stocks.get(request.user.sub, uid, query.sync === 'observe');
+    return this.stocks.get(request.user.sub, uid);
   }
 
   @Get(':uid/quote')
@@ -125,9 +121,8 @@ export class StockController {
   quote(
     @Req() request: Request & { user: AccessPayload },
     @Param('uid', new ParseUUIDPipe()) uid: string,
-    @Query() query: InvestmentReadQueryDto,
   ) {
-    return this.market.quote(request.user.sub, uid, query.sync === 'observe');
+    return this.market.quote(request.user.sub, uid);
   }
 
   @Get(':uid/candles')
@@ -141,7 +136,6 @@ export class StockController {
       request.user.sub,
       uid,
       query.period,
-      query.sync === 'observe',
     );
   }
 
@@ -159,12 +153,10 @@ export class StockController {
   company(
     @Req() request: Request & { user: AccessPayload },
     @Param('uid', new ParseUUIDPipe()) uid: string,
-    @Query() query: InvestmentReadQueryDto,
   ) {
     return this.companyInfo.execute(
       request.user.sub,
       uid,
-      query.sync === 'observe',
     );
   }
 
@@ -173,12 +165,10 @@ export class StockController {
   dividends(
     @Req() request: Request & { user: AccessPayload },
     @Param('uid', new ParseUUIDPipe()) uid: string,
-    @Query() query: InvestmentReadQueryDto,
   ) {
     return this.income.dividends(
       request.user.sub,
       uid,
-      query.sync === 'observe',
     );
   }
 }

src/modules/investments/instruments/stocks/presentation/stock.dto.ts

@@ -11,16 +11,15 @@ import {
   MinLength,
 } from 'class-validator';
 
-import { MoneyDto } from '../../../../../common/money.dto';
+import { MoneyDto } from '#src/common/money.dto';
 import {
   MAX_INSTRUMENT_QUERY_LENGTH,
   MIN_INSTRUMENT_QUERY_LENGTH,
-} from '../../../instrument-query';
+} from '#src/modules/investments/instrument-query';
 import {
-  InvestmentReadQueryDto,
   InvestmentResourceMetaDto,
-} from '../../../investment-resource.dto';
+} from '#src/modules/investments/investment-resource.dto';
-import { PortfolioPositionDto } from '../../../portfolio/portfolio.api';
+import { PortfolioPositionDto } from '#src/modules/investments/portfolio/portfolio.api';
 
 const MIN_TICKER_LENGTH = 1;
 const MAX_SCREENER_QUERY_LENGTH = 80;
@@ -104,7 +103,7 @@ export class StockScreenerPageDto {
   @ApiProperty({ type: StockScreenerItemDto, isArray: true, maxItems: 30 }) declare items: StockScreenerItemDto[];
 }
 
-export class StockSearchQueryDto extends InvestmentReadQueryDto {
+export class StockSearchQueryDto {
   @ApiProperty({ minLength: MIN_INSTRUMENT_QUERY_LENGTH, maxLength: MAX_INSTRUMENT_QUERY_LENGTH })
   @Transform(({ value }: { value: unknown }) =>
     typeof value === 'string' ? value.trim() : value,
@@ -126,7 +125,7 @@ export class StockTickerParamsDto {
   @Matches(/^[A-Z0-9][\w.@+-]*$/i)
   declare ticker: string;
 }
-export class StockCandlesQueryDto extends InvestmentReadQueryDto {
+export class StockCandlesQueryDto {
   @ApiPropertyOptional({
     enum: ['month', 'halfYear', 'year', 'all'],
     default: 'month',

src/modules/investments/investment-resource.dto.ts

@@ -1,5 +1,4 @@
 import { ApiProperty, ApiPropertyOptional } from '@nestjs/swagger';
-import { IsIn, IsOptional } from 'class-validator';
 
 export const availabilityValues = [
   'available',
@@ -17,13 +16,6 @@ export const attemptStateValues = [
   'failed',
 ] as const;
 
-export class InvestmentReadQueryDto {
-  @ApiPropertyOptional({ enum: ['observe'] })
-  @IsOptional()
-  @IsIn(['observe'])
-  declare sync?: 'observe';
-}
-
 export class InvestmentAttemptProblemDto {
   @ApiProperty({ enum: ['membership', 'portfolio', 'operations', 'events'] })
   declare section: 'events' | 'membership' | 'operations' | 'portfolio';

src/modules/investments/operations/application/brokerage-operations-sync.service.ts

@@ -1,11 +1,12 @@
 import { Injectable, NotFoundException } from '@nestjs/common';
 import { randomUUID } from 'node:crypto';
 
-import { StructuredLogger } from '../../../../common/logging/structured-logger.service';
+import { StructuredLogger } from '#src/common/logging/structured-logger.service';
-import { MILLISECONDS_PER_SECOND } from '../../../../common/time';
+import { MILLISECONDS_PER_SECOND } from '#src/common/time';
-import { isTbankErrorCode, TbankErrorCode } from '../../../../integrations/tbank/tbank-error-code';
+import { isTbankErrorCode, TbankErrorCode } from '#src/integrations/tbank/tbank-error-code';
-import { TbankOperationState } from '../../../../integrations/tbank/tbank-protocol';
+import { TbankOperationState } from '#src/integrations/tbank/tbank-protocol';
-import { TbankAccessService, TbankClient } from '../../../../integrations/tbank/tbank.api';
+import { TbankAccessService, TbankClient } from '#src/integrations/tbank/tbank.api';
+
 import {
   type OperationInterval,
   operationIntervals,

src/modules/investments/operations/application/brokerage-operations.service.ts

@@ -7,7 +7,8 @@ import {
   TbankAccessService,
   type TbankOperationItem,
   tbankSourceTtlMs,
-} from '../../../../integrations/tbank/tbank.api';
+} from '#src/integrations/tbank/tbank.api';
+
 import { dateOnlyBounds, DateOnlyRange } from '../../investment-calendar';
 import { investmentResourceMeta } from '../../investment-resource.mapper';
 import { ledgerRange } from '../../investment-sync-plan';
@@ -237,7 +238,6 @@ export class BrokerageOperationsService {
     userId: string,
     accountId: string,
     ranges: (openedAt: Date | undefined) => DateOnlyRange[],
-    observe = false,
   ) {
     const connection = await this.access.local(userId, accountId);
     const input = {
@@ -251,21 +251,19 @@ export class BrokerageOperationsService {
       periods: ranges,
     };
     let saved = await this.repository.readPage(input);
-    if (!observe) {
+    const targets = (saved?.connection.accounts ?? []).flatMap((account) =>
-      const targets = (saved?.connection.accounts ?? []).flatMap((account) =>
+      (saved?.periods ?? []).map((period) => ({
-        (saved?.periods ?? []).map((period) => ({
+        accountId: account.accountId,
-          accountId: account.accountId,
+        ...period,
-          ...period,
+      })),
-        })),
+    );
-      );
+    if (targets.length) {
-      if (targets.length) {
+      await this.sync.readPlan(userId, targets, {
-        await this.sync.readPlan(userId, targets, {
+        movingEnd: saved?.periods?.some((period) => period.movingEnd),
-          movingEnd: saved?.periods?.some((period) => period.movingEnd),
+        revision: connection.revision,
-          revision: connection.revision,
+      });
-        });
-      }
-      saved = await this.repository.readPage(input);
     }
+    saved = await this.repository.readPage(input);
     const now = new Date();
     const hourly = await this.hourlySync.hourly(userId);
     const membership = investmentResourceMeta({

src/modules/investments/operations/infrastructure/brokerage-operation.mapper.ts

@@ -1,8 +1,9 @@
-import { formatDecimal } from '../../../../common/decimal';
+import { formatDecimal } from '#src/common/decimal';
-import { MILLISECONDS_PER_SECOND } from '../../../../common/time';
+import { MILLISECONDS_PER_SECOND } from '#src/common/time';
-import { decimal } from '../../../../integrations/tbank/decimal';
+import { decimal } from '#src/integrations/tbank/decimal';
-import { TbankOperationType } from '../../../../integrations/tbank/tbank-protocol';
+import { TbankOperationType } from '#src/integrations/tbank/tbank-protocol';
-import { TbankMoney, TbankOperationItem } from '../../../../integrations/tbank/tbank.api';
+import { TbankMoney, TbankOperationItem } from '#src/integrations/tbank/tbank.api';
+
 import { type OperationCategory } from '../../operation-category';
 import { BrokerageOperationDto } from '../presentation/brokerage-operation.dto';
 

src/modules/investments/operations/infrastructure/brokerage-operations-read.repository.ts

@@ -5,7 +5,8 @@ import {
 } from '@nestjs/common';
 import { createHash } from 'node:crypto';
 
-import { PrismaService } from '../../../../prisma/prisma.service';
+import { PrismaService } from '#src/prisma/prisma.service';
+
 import {
   dateOnlyBounds,
   DateOnlyRange,

src/modules/investments/operations/infrastructure/brokerage-operations.repository.ts

@@ -2,17 +2,18 @@ import { Injectable, NotFoundException } from '@nestjs/common';
 import { createHash, randomUUID } from 'node:crypto';
 import { isDeepStrictEqual } from 'node:util';
 
-import type { Prisma } from '../../../../../generated/prisma/client';
+import type { Prisma } from '#generated/prisma/client';
 
-import { TbankErrorCode } from '../../../../integrations/tbank/tbank-error-code';
+import { TbankErrorCode } from '#src/integrations/tbank/tbank-error-code';
-import { isTbankProtocolValue, TbankOperationState } from '../../../../integrations/tbank/tbank-protocol';
+import { isTbankProtocolValue, TbankOperationState } from '#src/integrations/tbank/tbank-protocol';
-import { claimSyncWork, lockConnectionGeneration } from '../../../../integrations/tbank/tbank-sync-claim';
+import { claimSyncWork, lockConnectionGeneration } from '#src/integrations/tbank/tbank-sync-claim';
 import {
   isJoinableRunningAttempt,
   type TbankOperationItem, type TbankOperationsByCursorResponse,
-} from '../../../../integrations/tbank/tbank.api';
+} from '#src/integrations/tbank/tbank.api';
-import { PrismaService } from '../../../../prisma/prisma.service';
+import { PrismaService } from '#src/prisma/prisma.service';
-import { toJson } from '../../../../prisma/to-json';
+import { toJson } from '#src/prisma/to-json';
+
 import {
   decodeInterval,
   extendRunningIntent,

src/modules/investments/operations/operations.module.ts

@@ -1,6 +1,7 @@
 import { Module } from '@nestjs/common';
 
-import { TbankModule } from '../../../integrations/tbank/tbank.module';
+import { TbankModule } from '#src/integrations/tbank/tbank.module';
+
 import { AuthModule } from '../../auth/auth.module';
 import { TbankSyncRepositoryModule } from '../tbank-sync/tbank-sync-repository.module';
 import { BrokerageOperationsSyncService } from './application/brokerage-operations-sync.service';

src/modules/investments/operations/presentation/brokerage-operation.dto.ts

@@ -13,7 +13,8 @@ import {
   Min,
 } from 'class-validator';
 
-import { MoneyDto } from '../../../../common/money.dto';
+import { MoneyDto } from '#src/common/money.dto';
+
 import { AccountReferenceDto } from '../../account-reference.dto';
 import { InvestmentResourceMetaDto } from '../../investment-resource.dto';
 import { operationCategories, type OperationCategory } from '../../operation-category';

src/modules/investments/operations/presentation/brokerage-operations.controller.spec.ts

@@ -1,4 +1,4 @@
-jest.mock('../../../../prisma/prisma.service', () => ({
+jest.mock('#src/prisma/prisma.service', () => ({
   PrismaService: class PrismaService {},
 }));
 

src/modules/investments/operations/presentation/brokerage-operations.controller.ts

@@ -3,8 +3,9 @@ import type { Request } from 'express';
 import { Controller, Get, Param, Query, Req, UseGuards } from '@nestjs/common';
 import { ApiBearerAuth, ApiOkResponse, ApiTags } from '@nestjs/swagger';
 
-import { ApiProblemResponses } from '../../../../common/decorators/api-safe-error-response.decorator';
+import { ApiProblemResponses } from '#src/common/decorators/api-safe-error-response.decorator';
-import { AccessPayload, JwtAuthGuard } from '../../../auth/auth.api';
+import { AccessPayload, JwtAuthGuard } from '#src/modules/auth/auth.api';
+
 import { BrokerageOperationsService } from '../application/brokerage-operations.service';
 import {
   BrokerageOperationsQueryDto,

src/modules/investments/portfolio/application/forecast.service.ts

@@ -1,8 +1,9 @@
 import { Injectable } from '@nestjs/common';
 
+import { add, decimalFromString, formatDecimal } from '#src/common/decimal';
+
 import type { InvestmentResourceMetaDto } from '../../investment-resource.dto';
 
-import { add, decimalFromString, formatDecimal } from '../../../../common/decimal';
 import { investmentResourceMeta } from '../../investment-resource.mapper';
 import {
   ForecastRepository,

src/modules/investments/portfolio/application/portfolio.service.spec.ts

@@ -1,5 +1,5 @@
 import assert from 'node:assert/strict';
-jest.mock('../../../../prisma/prisma.service', () => ({
+jest.mock('#src/prisma/prisma.service', () => ({
   PrismaService: class {},
 }));
 import { PortfolioDto } from '../presentation/portfolio.dto';

src/modules/investments/portfolio/application/portfolio.service.ts

@@ -4,10 +4,10 @@ import {
 } from '@nestjs/common';
 import { randomUUID } from 'node:crypto';
 
-import type { Prisma } from '../../../../../generated/prisma/client';
+import type { Prisma } from '#generated/prisma/client';
 
-import { StructuredLogger } from '../../../../common/logging/structured-logger.service';
+import { StructuredLogger } from '#src/common/logging/structured-logger.service';
-import { isTbankErrorCode, TbankErrorCode } from '../../../../integrations/tbank/tbank-error-code';
+import { isTbankErrorCode, TbankErrorCode } from '#src/integrations/tbank/tbank-error-code';
 import {
   InstrumentMetadataService,
   metadataKey,
@@ -17,7 +17,8 @@ import {
   type TbankMoney,
   type TbankPortfolio,
   tbankSourceTtlMs,
-} from '../../../../integrations/tbank/tbank.api';
+} from '#src/integrations/tbank/tbank.api';
+
 import { investmentResourceMeta } from '../../investment-resource.mapper';
 import {
   hourlyAttempt,

src/modules/investments/portfolio/application/position-classification.service.spec.ts

@@ -1,8 +1,9 @@
 import { NotFoundException } from '@nestjs/common';
 
-jest.mock('../../../../prisma/prisma.service', () => ({ PrismaService: class {} }));
+jest.mock('#src/prisma/prisma.service', () => ({ PrismaService: class {} }));
-import { TbankErrorCode } from '../../../../integrations/tbank/tbank-error-code';
+import { TbankErrorCode } from '#src/integrations/tbank/tbank-error-code';
-import { InstrumentIdType } from '../../../../integrations/tbank/tbank-protocol';
+import { InstrumentIdType } from '#src/integrations/tbank/tbank-protocol';
+
 import { PositionClassificationService } from './position-classification.service';
 
 describe('PositionClassificationService', () => {

src/modules/investments/portfolio/application/position-classification.service.ts

@@ -1,12 +1,13 @@
 import { Injectable, NotFoundException } from '@nestjs/common';
 
-import { isZero } from '../../../../common/decimal';
+import { isZero } from '#src/common/decimal';
-import { StructuredLogger } from '../../../../common/logging/structured-logger.service';
+import { StructuredLogger } from '#src/common/logging/structured-logger.service';
-import { MILLISECONDS_PER_DAY } from '../../../../common/time';
+import { MILLISECONDS_PER_DAY } from '#src/common/time';
-import { decimal } from '../../../../integrations/tbank/decimal';
+import { decimal } from '#src/integrations/tbank/decimal';
-import { isTbankErrorCode, TbankErrorCode } from '../../../../integrations/tbank/tbank-error-code';
+import { isTbankErrorCode, TbankErrorCode } from '#src/integrations/tbank/tbank-error-code';
-import { InstrumentIdType } from '../../../../integrations/tbank/tbank-protocol';
+import { InstrumentIdType } from '#src/integrations/tbank/tbank-protocol';
-import { metadataKey, TbankClient, type TbankPortfolio } from '../../../../integrations/tbank/tbank.api';
+import { metadataKey, TbankClient, type TbankPortfolio } from '#src/integrations/tbank/tbank.api';
+
 import { PositionClassificationRepository } from '../infrastructure/position-classification.repository';
 
 export type Classification = { issuer: null | { id: string; name: string }; sector: null | string };

src/modules/investments/portfolio/domain/portfolio-structure.ts

@@ -1,11 +1,11 @@
-import type { Money } from '../../../../common/money.types';
+import type { Money } from '#src/common/money.types';
 
 import {
   add,
   DECIMAL_RADIX,
   decimalFromString,
   formatDecimal,
-} from '../../../../common/decimal';
+} from '#src/common/decimal';
 
 const ZERO_AMOUNT = 0n;
 const INITIAL_UNVALUED_COUNT = 0;

src/modules/investments/portfolio/domain/portfolio-totals.ts

@@ -1,10 +1,10 @@
-import type { Money } from '../../../../common/money.types';
+import type { Money } from '#src/common/money.types';
 
 import {
   add,
   decimalFromString,
   formatDecimal,
-} from '../../../../common/decimal';
+} from '#src/common/decimal';
 
 export function sumMoneyByCurrency(amounts: Money[]): Money[] {
   const totals = new Map<string, ReturnType<typeof decimalFromString>>();

src/modules/investments/portfolio/infrastructure/forecast.repository.ts

@@ -1,10 +1,10 @@
 import { Injectable } from '@nestjs/common';
 import { isDeepStrictEqual } from 'node:util';
 
-import type { Prisma } from '../../../../../generated/prisma/client';
+import type { Prisma } from '#generated/prisma/client';
 
-import { PrismaService } from '../../../../prisma/prisma.service';
+import { PrismaService } from '#src/prisma/prisma.service';
-import { toJson } from '../../../../prisma/to-json';
+import { toJson } from '#src/prisma/to-json';
 
 const FIRST_BATCH_OFFSET = 0;
 

src/modules/investments/portfolio/infrastructure/portfolio.repository.ts

@@ -1,14 +1,15 @@
 import { Injectable } from '@nestjs/common';
 import { randomUUID } from 'node:crypto';
 
-import type { Prisma } from '../../../../../generated/prisma/client';
+import type { Prisma } from '#generated/prisma/client';
-import type { PortfolioDto } from '../presentation/portfolio.dto';
 
-import { TbankErrorCode } from '../../../../integrations/tbank/tbank-error-code';
+import { TbankErrorCode } from '#src/integrations/tbank/tbank-error-code';
-import { lockConnectionGeneration } from '../../../../integrations/tbank/tbank-sync-claim';
+import { lockConnectionGeneration } from '#src/integrations/tbank/tbank-sync-claim';
-import { isJoinableRunningAttempt, tbankSourceNeedsRefresh, tbankSourceTtlMs } from '../../../../integrations/tbank/tbank.api';
+import { isJoinableRunningAttempt, tbankSourceNeedsRefresh, tbankSourceTtlMs } from '#src/integrations/tbank/tbank.api';
-import { PrismaService } from '../../../../prisma/prisma.service';
+import { PrismaService } from '#src/prisma/prisma.service';
-import { toJson } from '../../../../prisma/to-json';
+import { toJson } from '#src/prisma/to-json';
+
+import type { PortfolioDto } from '../presentation/portfolio.dto';
 
 const EXPECTED_UPDATED_ACCOUNTS = 1;
 

src/modules/investments/portfolio/infrastructure/position-classification.repository.ts

@@ -1,6 +1,6 @@
 import { Injectable } from '@nestjs/common';
 
-import { PrismaService } from '../../../../prisma/prisma.service';
+import { PrismaService } from '#src/prisma/prisma.service';
 
 @Injectable()
 export class PositionClassificationRepository {

src/modules/investments/portfolio/infrastructure/tbank-portfolio.mapper.ts

@@ -1,6 +1,4 @@
-import type { Money } from '../../../../common/money.types';
+import type { Money } from '#src/common/money.types';
-import type { Classification } from '../application/position-classification.service';
-import type { PortfolioDto, PortfolioPositionDto } from '../presentation/portfolio.dto';
 
 import {
   add,
@@ -9,15 +7,19 @@ import {
   isZero,
   multiply,
   subtract,
-} from '../../../../common/decimal';
+} from '#src/common/decimal';
-import { decimal } from '../../../../integrations/tbank/decimal';
+import { decimal } from '#src/integrations/tbank/decimal';
 import {
   metadataKey,
   type TbankInstrument,
   type TbankMoney,
   TbankPortfolio,
   TbankPositions,
-} from '../../../../integrations/tbank/tbank.api';
+} from '#src/integrations/tbank/tbank.api';
+
+import type { Classification } from '../application/position-classification.service';
+import type { PortfolioDto, PortfolioPositionDto } from '../presentation/portfolio.dto';
+
 import { portfolioStructure } from '../domain/portfolio-structure';
 
 const types: Record<string, string> = {

src/modules/investments/portfolio/portfolio.module.ts

@@ -1,6 +1,7 @@
 import { Module } from '@nestjs/common';
 
-import { TbankModule } from '../../../integrations/tbank/tbank.module';
+import { TbankModule } from '#src/integrations/tbank/tbank.module';
+
 import { AuthModule } from '../../auth/auth.module';
 import { TbankSyncRepositoryModule } from '../tbank-sync/tbank-sync-repository.module';
 import { ForecastService } from './application/forecast.service';

src/modules/investments/portfolio/presentation/portfolio.controller.ts

@@ -3,8 +3,9 @@ import type { Request } from 'express';
 import { Controller, Get, Param, Req, UseGuards } from '@nestjs/common';
 import { ApiBearerAuth, ApiOkResponse, ApiTags } from '@nestjs/swagger';
 
-import { ApiProblemResponses } from '../../../../common/decorators/api-safe-error-response.decorator';
+import { ApiProblemResponses } from '#src/common/decorators/api-safe-error-response.decorator';
-import { AccessPayload, JwtAuthGuard } from '../../../auth/auth.api';
+import { AccessPayload, JwtAuthGuard } from '#src/modules/auth/auth.api';
+
 import { PortfolioService } from '../application/portfolio.service';
 import { PortfolioResourceDto } from './portfolio.dto';
 

src/modules/investments/portfolio/presentation/portfolio.dto.ts

@@ -1,6 +1,7 @@
 import { ApiProperty, ApiPropertyOptional } from '@nestjs/swagger';
 
-import { MoneyDto } from '../../../../common/money.dto';
+import { MoneyDto } from '#src/common/money.dto';
+
 import { AccountReferenceDto } from '../../account-reference.dto';
 import { InvestmentResourceMetaDto } from '../../investment-resource.dto';
 

src/modules/investments/tbank-connection/tbank-connection.controller.ts

@@ -18,7 +18,8 @@ import {
   ApiTags,
 } from '@nestjs/swagger';
 
-import { ApiProblemResponses } from '../../../common/decorators/api-safe-error-response.decorator';
+import { ApiProblemResponses } from '#src/common/decorators/api-safe-error-response.decorator';
+
 import { AccessPayload, JwtAuthGuard } from '../../auth/auth.api';
 import {
   PutTbankConnectionDto,

src/modules/investments/tbank-connection/tbank-connection.module.ts

@@ -1,6 +1,7 @@
 import { Module } from '@nestjs/common';
 
-import { TbankModule } from '../../../integrations/tbank/tbank.module';
+import { TbankModule } from '#src/integrations/tbank/tbank.module';
+
 import { AuthModule } from '../../auth/auth.module';
 import { TbankSyncModule } from '../tbank-sync/tbank-sync.module';
 import { TbankConnectionController } from './tbank-connection.controller';

src/modules/investments/tbank-connection/tbank-connection.service.ts

@@ -1,12 +1,12 @@
 import { BadRequestException, Inject, Injectable } from '@nestjs/common';
 
-import { HttpErrorCode } from '../../../common/error-code';
+import { HttpErrorCode } from '#src/common/error-code';
 import {
   supportedTbankAccounts,
   TbankClient,
   TbankTokenService,
-} from '../../../integrations/tbank/tbank.api';
+} from '#src/integrations/tbank/tbank.api';
-import { PrismaService } from '../../../prisma/prisma.service';
+import { PrismaService } from '#src/prisma/prisma.service';
 
 type TbankTokenValidator = Pick<TbankClient, 'validateToken'>;
 

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

@@ -1,17 +1,18 @@
 import { Injectable, OnModuleDestroy, OnModuleInit } from '@nestjs/common';
 import { randomUUID } from 'node:crypto';
 
-import { StructuredLogger } from '../../../common/logging/structured-logger.service';
+import { StructuredLogger } from '#src/common/logging/structured-logger.service';
-import { TbankErrorCode } from '../../../integrations/tbank/tbank-error-code';
+import { TbankErrorCode } from '#src/integrations/tbank/tbank-error-code';
 import {
   TbankAccessService,
   TbankMembershipService,
   type TbankSyncAttempt,
-} from '../../../integrations/tbank/tbank.api';
+} from '#src/integrations/tbank/tbank.api';
-import { PrismaService } from '../../../prisma/prisma.service';
+import { PrismaService } from '#src/prisma/prisma.service';
+
 import { BrokerageOperationsSyncService } from '../operations/operations.api';
 import { PortfolioService } from '../portfolio/portfolio.api';
-import { UpcomingEventsService } from '../upcoming-events/upcoming-events.service';
+import { UpcomingEventsService } from '../upcoming-events/upcoming-events.api';
 import {
   HOURLY_CAUSE_INTERRUPTED,
   type HourlyCause,

src/modules/investments/tbank-sync/tbank-screen.ts

@@ -1,8 +1,9 @@
 import { BadRequestException } from '@nestjs/common';
 
+import { ISO_DATE_LENGTH, ISO_DATE_START } from '#src/common/time';
+
 import type { InvestmentScreenDto } from './tbank-sync.dto';
 
-import { ISO_DATE_LENGTH, ISO_DATE_START } from '../../../common/time';
 import { MIN_INSTRUMENT_QUERY_LENGTH } from '../instrument-query';
 
 // Reject fields from other screens before reserving any source work.

src/modules/investments/tbank-sync/tbank-sync.controller.ts

@@ -1,42 +0,0 @@
-import type { Request } from 'express';
-
-import { Controller, Get, Param, Req, UseGuards } from '@nestjs/common';
-import {
-  ApiBearerAuth,
-  ApiExtraModels,
-  ApiOkResponse,
-  ApiTags,
-} from '@nestjs/swagger';
-
-import { ApiProblemResponses } from '../../../common/decorators/api-safe-error-response.decorator';
-import { AccessPayload, JwtAuthGuard } from '../../auth/auth.api';
-import {
-  EventsInvestmentScreenDto,
-  IncomeInvestmentScreenDto,
-  TbankSyncStatusDto,
-  TimestampInvestmentScreenDto,
-} from './tbank-sync.dto';
-import { TbankSyncService } from './tbank-sync.service';
-
-@ApiTags('tbank-sync')
-@ApiExtraModels(
-  EventsInvestmentScreenDto,
-  IncomeInvestmentScreenDto,
-  TimestampInvestmentScreenDto,
-  TbankSyncStatusDto,
-)
-@ApiProblemResponses()
-@ApiBearerAuth()
-@UseGuards(JwtAuthGuard)
-@Controller('tbank-sync')
-export class TbankSyncController {
-  constructor(private readonly sync: TbankSyncService) {}
-  @Get(':id')
-  @ApiOkResponse({ type: TbankSyncStatusDto })
-  status(
-    @Req() request: Request & { user: AccessPayload },
-    @Param('id') id: string,
-  ) {
-    return this.sync.status(request.user.sub, id);
-  }
-}

src/modules/investments/tbank-sync/tbank-sync.dto.ts

@@ -209,19 +209,6 @@ export const investmentScreenSchema = {
   },
 };
 
-export class TbankSyncStatusDto {
-  @ApiProperty({ format: 'uuid' }) declare id: string;
-  @ApiProperty({ type: Object, ...investmentScreenSchema, nullable: true })
-  declare scope: InvestmentScreenDto | null;
-
-  @ApiProperty({ format: 'date-time' }) declare now: string;
-  @ApiProperty({ enum: ['running', 'succeeded', 'failed', 'cancelled'] })
-  declare state: 'cancelled' | 'failed' | 'running' | 'succeeded';
-
-  @ApiProperty({ type: String, nullable: true }) declare errorCode:
-    null | string;
-}
-
 export class HourlySyncStatusDto {
   @ApiProperty({
     enum: ['running', 'succeeded', 'partial', 'failed', 'cancelled'],

src/modules/investments/tbank-sync/tbank-sync.module.ts

@@ -1,6 +1,7 @@
 import { Module } from '@nestjs/common';
 
-import { TbankModule } from '../../../integrations/tbank/tbank.module';
+import { TbankModule } from '#src/integrations/tbank/tbank.module';
+
 import { AuthModule } from '../../auth/auth.module';
 import { InstrumentSourcesModule } from '../instruments/instrument-sources.module';
 import { OperationsModule } from '../operations/operations.module';
@@ -8,8 +9,6 @@ import { PortfolioModule } from '../portfolio/portfolio.module';
 import { UpcomingEventsModule } from '../upcoming-events/upcoming-events.module';
 import { TbankHourlyScheduler } from './tbank-hourly.scheduler';
 import { TbankSyncRepositoryModule } from './tbank-sync-repository.module';
-import { TbankSyncController } from './tbank-sync.controller';
-import { TbankSyncService } from './tbank-sync.service';
 @Module({
   imports: [
     AuthModule,
@@ -20,8 +19,7 @@ import { TbankSyncService } from './tbank-sync.service';
     UpcomingEventsModule,
     TbankSyncRepositoryModule,
   ],
-  controllers: [TbankSyncController],
+  providers: [TbankHourlyScheduler],
-  providers: [TbankSyncService, TbankHourlyScheduler],
   exports: [TbankHourlyScheduler],
 })
 export class TbankSyncModule {}

src/modules/investments/tbank-sync/tbank-sync.repository.spec.ts

@@ -1,22 +1,12 @@
-jest.mock('../../../prisma/prisma.service', () => ({
+jest.mock('#src/prisma/prisma.service', () => ({
   PrismaService: class {},
 }));
 
 import {
   hourlyProgress,
-  screenIntent,
   screenProgress,
 } from './tbank-sync.repository';
 
-describe('screen sync intent', () => {
-  it('restores a persisted intent and rejects a corrupted one', () => {
-    const intent = { now: '2026-11-02T00:00:00.000Z', scope: { screen: 'accounts' } };
-    expect(screenIntent(intent)).toEqual(intent);
-    expect(() => screenIntent({ source: 'hourly' })).toThrow('Corrupted screen sync intent');
-    expect(() => screenIntent(null)).toThrow('Corrupted screen sync intent');
-  });
-});
-
 describe('screen sync progress', () => {
   it('restores a persisted progress unchanged', () => {
     const progress = { attempts: { 'work-1': 'attempt-1' }, children: ['work-1'], dispatched: true };

src/modules/investments/tbank-sync/tbank-sync.repository.ts

@@ -1,24 +1,15 @@
 import { Injectable } from '@nestjs/common';
 import { randomUUID } from 'node:crypto';
 
-import type { Prisma } from '../../../../generated/prisma/client';
+import type { Prisma } from '#generated/prisma/client';
-import type { TbankSyncAttempt } from '../../../integrations/tbank/tbank.api';
+import type { TbankSyncAttempt } from '#src/integrations/tbank/tbank.api';
+
+import { claimSyncWork, lockConnectionGeneration } from '#src/integrations/tbank/tbank-sync-claim';
+import { PrismaService } from '#src/prisma/prisma.service';
+import { toJson } from '#src/prisma/to-json';
+
 import type { InvestmentAttemptDto } from '../investment-resource.dto';
 import type { InvestmentScreenDto } from './tbank-sync.dto';
-
-import { claimSyncWork, lockConnectionGeneration } from '../../../integrations/tbank/tbank-sync-claim';
-import { PrismaService } from '../../../prisma/prisma.service';
-import { toJson } from '../../../prisma/to-json';
-export type ScreenIntent = { now: string; scope: InvestmentScreenDto };
-
-// Json columns are written only by this repository; a shape check turns corruption into an explicit 500.
-export function screenIntent(value: Prisma.JsonValue): ScreenIntent {
-  const intent = value as null | Partial<ScreenIntent>;
-  if (typeof intent?.now !== 'string' || typeof intent.scope?.screen !== 'string') {
-    throw new Error('Corrupted screen sync intent');
-  }
-  return intent as ScreenIntent;
-}
 export type ScreenProgress = {
   attempts?: Record<string, string>;
   children: string[];
@@ -188,30 +179,6 @@ export class TbankSyncRepository {
     });
   }
 
-  read(userId: string, revision: string, id: string) {
-    return this.prisma.$transaction(async (tx) => {
-      const work = await tx.tbankSyncWork.findFirst({
-        where: { userId, revision, id },
-      });
-      if (!work) return null;
-      const progress = screenProgress(work.progress);
-      const children = await tx.tbankSyncWork.findMany({
-        where: { userId, revision, id: { in: progress.children ?? [] } },
-        select: { id: true, attemptId: true, state: true, errorCode: true },
-      });
-      return {
-        work,
-        children: children.map((child) =>
-          progress.attempts?.[child.id] &&
-          progress.attempts[child.id] !== child.attemptId
-            ? { ...child, state: 'cancelled', errorCode: null }
-            : child,
-        ),
-        progress,
-      };
-    });
-  }
-
   async progress(
     attempt: TbankSyncAttempt,
     children: string[],

src/modules/investments/tbank-sync/tbank-sync.service.ts

@@ -1,102 +0,0 @@
-import {
-  ConflictException,
-  Injectable,
-  NotFoundException,
-} from '@nestjs/common';
-import { randomUUID } from 'node:crypto';
-
-import { TbankAccessService } from '../../../integrations/tbank/tbank.api';
-import { BrokerageOperationsSyncService } from '../operations/operations.api';
-import { TbankSyncStatusDto } from './tbank-sync.dto';
-import { screenIntent, TbankSyncRepository } from './tbank-sync.repository';
-
-@Injectable()
-export class TbankSyncService {
-  private readonly runId = randomUUID();
-  private readonly startedAt = new Date();
-  constructor(
-    private readonly repository: TbankSyncRepository,
-    private readonly access: TbankAccessService,
-    private readonly operations: BrokerageOperationsSyncService,
-  ) {}
-
-  async status(userId: string, id: string): Promise<TbankSyncStatusDto> {
-    const connection = await this.access
-      .local(userId)
-      .catch((error: unknown) => {
-        if (error instanceof ConflictException) throw new NotFoundException();
-        throw error;
-      });
-    const saved = await this.repository.read(userId, connection.revision, id);
-    if (!saved) throw new NotFoundException();
-    if (!saved.work.scopeKey.startsWith('screen:')) {
-      return this.sourceStatus(userId, saved.work);
-    }
-    const intent = screenIntent(saved.work.intent);
-    await this.access.local(userId, intent.scope.accountId);
-    const children = await Promise.all(
-      saved.children.map((child) =>
-        child.state === 'superseded'
-          ? this.operations.observe(userId, child.id)
-          : Promise.resolve(child),
-      ),
-    );
-    const running = children.some((child) => child.state === 'running');
-    const failed =
-      saved.work.errorCode ??
-      children.find((child) => child.errorCode)?.errorCode ??
-      null;
-    const state =
-      saved.work.processRunId !== this.runId &&
-      (!saved.progress.dispatched || running)
-        ? 'cancelled'
-        : !saved.progress.dispatched || running
-            ? 'running'
-            : failed
-              ? 'failed'
-              : children.some((child) => child.state === 'cancelled')
-                ? 'cancelled'
-                : 'succeeded';
-    if (
-      (await this.access.local(userId, intent.scope.accountId)).revision !==
-      connection.revision
-    ) {
-      throw new NotFoundException();
-    }
-    return {
-      id,
-      ...intent,
-      state,
-      errorCode: failed,
-    };
-  }
-
-  private async sourceStatus(
-    userId: string,
-    work: NonNullable<Awaited<ReturnType<TbankSyncRepository['read']>>>['work'],
-  ): Promise<TbankSyncStatusDto> {
-    const observed = work.scopeKey.startsWith('operations:')
-      ? await this.operations.observe(userId, work.id)
-      : work;
-    const state =
-      observed.state === 'running'
-        ? observed.updatedAt < this.startedAt
-          ? 'cancelled'
-          : 'running'
-        : observed.state === 'failed'
-          ? 'failed'
-          : observed.state === 'cancelled'
-            ? 'cancelled'
-            : 'succeeded';
-    if ((await this.access.local(userId)).revision !== work.revision) {
-      throw new NotFoundException();
-    }
-    return {
-      id: work.id,
-      scope: null,
-      now: work.createdAt.toISOString(),
-      state,
-      errorCode: observed.errorCode,
-    };
-  }
-}