Add transaction tax report

test/config/default.json

@@ -1,7 +1,9 @@
 {
   "app": {
     "port": 31339,
-    "host": "127.0.0.1"
+    "host": "127.0.0.1",
+    "httpRpcTimeout": 600000,
+    "wsRpcTimeout": 3600000
   },
   "grenacheClient": {
     "query": "rest:report:api",

test/helpers/mock-data.js

@@ -130,7 +130,7 @@ module.exports = new Map([
     'trades',
     [
       [
-        12345,
+        100012345,
         'tBTCUSD',
         _ms,
         12345,
@@ -143,7 +143,33 @@ module.exports = new Map([
         'USD'
       ],
       [
-        10012346,
+        110012345,
+        'tETHUSD',
+        _ms,
+        12345,
+        0.12345,
+        12345,
+        null,
+        null,
+        false,
+        -3.0001,
+        'USD'
+      ],
+      [
+        120012345,
+        'tETHUSD',
+        _ms,
+        12345,
+        -0.011,
+        12355,
+        null,
+        null,
+        false,
+        -3.0001,
+        'USD'
+      ],
+      [
+        130012345,
         'tBTCEUR',
         _ms,
         12345,
@@ -156,7 +182,20 @@ module.exports = new Map([
         'BTC'
       ],
       [
-        20012347,
+        140012345,
+        'tBTCEUR',
+        _ms,
+        12345,
+        -0.011,
+        12355,
+        null,
+        null,
+        false,
+        -0.0001,
+        'BTC'
+      ],
+      [
+        150012347,
         'tBTCGBP',
         _ms,
         12345,
@@ -169,7 +208,20 @@ module.exports = new Map([
         'BTC'
       ],
       [
-        30012345,
+        160012347,
+        'tBTCGBP',
+        _ms,
+        12345,
+        -0.011,
+        12355,
+        null,
+        null,
+        false,
+        -0.0001,
+        'BTC'
+      ],
+      [
+        170012345,
         'tBTCJPY',
         _ms,
         12345,
@@ -180,6 +232,58 @@ module.exports = new Map([
         false,
         -0.0001,
         'BTC'
+      ],
+      [
+        180012345,
+        'tBTCJPY',
+        _ms,
+        12345,
+        -0.011,
+        12355,
+        null,
+        null,
+        false,
+        -0.0001,
+        'BTC'
+      ],
+      [
+        190012345,
+        'tETHBTC',
+        _ms,
+        12345,
+        0.01,
+        12345,
+        null,
+        null,
+        false,
+        -0.0001,
+        'BTC'
+      ],
+      [
+        200012345,
+        'tETHBTC',
+        _ms,
+        12345,
+        -0.01,
+        12355,
+        null,
+        null,
+        false,
+        -0.0001,
+        'BTC'
+      ],
+      [
+        210012345,
+        'tBTCUSD',
+        _ms,
+        12345,
+        0.12345,
+        12345,
+        null,
+        null,
+        false,
+        -3.0001,
+        'USD'
       ]
     ]
   ],

test/test-cases/additional-api-sync-mode-sqlite-test-cases.js

@@ -413,6 +413,82 @@ module.exports = (
     }
   })
 
+  it('it should be successfully performed by the getTransactionTaxReport method, LIFO strategy', async function () {
+    this.timeout(60000)
+
+    const res = await agent
+      .post(`${basePath}/json-rpc`)
+      .type('json')
+      .send({
+        auth,
+        method: 'getTransactionTaxReport',
+        params: {
+          end,
+          start: start + (45 * 24 * 60 * 60 * 1000),
+          strategy: 'LIFO'
+        },
+        id: 5
+      })
+      .expect('Content-Type', /json/)
+      .expect(200)
+
+    assert.isObject(res.body)
+    assert.propertyVal(res.body, 'id', 5)
+    assert.isArray(res.body.result)
+    assert.isAtLeast(res.body.result.length, 1)
+
+    res.body.result.forEach((item) => {
+      assert.isObject(item)
+      assert.containsAllKeys(item, [
+        'asset',
+        'amount',
+        'mtsAcquired',
+        'mtsSold',
+        'proceeds',
+        'cost',
+        'gainOrLoss'
+      ])
+    })
+  })
+
+  it('it should be successfully performed by the getTransactionTaxReport method, FIFO strategy', async function () {
+    this.timeout(60000)
+
+    const res = await agent
+      .post(`${basePath}/json-rpc`)
+      .type('json')
+      .send({
+        auth,
+        method: 'getTransactionTaxReport',
+        params: {
+          end,
+          start: start + (45 * 24 * 60 * 60 * 1000),
+          strategy: 'FIFO'
+        },
+        id: 5
+      })
+      .expect('Content-Type', /json/)
+      .expect(200)
+
+    assert.isObject(res.body)
+    assert.propertyVal(res.body, 'id', 5)
+    assert.isArray(res.body.result)
+    assert.isAtLeast(res.body.result.length, 1)
+
+    res.body.result.forEach((item) => {
+      assert.isObject(item)
+      assert.containsAllKeys(item, [
+        'asset',
+        'amount',
+        'mtsAcquired',
+        'mtsSold',
+        'proceeds',
+        'cost',
+        'gainOrLoss'
+      ])
+    })
+  })
+
   it('it should be successfully performed by the getTradedVolume method', async function () {
     this.timeout(60000)
 
@@ -1034,6 +1110,33 @@ module.exports = (
     )
   })
 
+  it('it should be successfully performed by the getTransactionTaxReportFile method', async function () {
+    this.timeout(60000)
+
+    const procPromise = queueToPromise(params.processorQueue)
+    const aggrPromise = queueToPromise(params.aggregatorQueue)
+
+    const res = await agent
+      .post(`${basePath}/json-rpc`)
+      .type('json')
+      .send({
+        auth,
+        method: 'getTransactionTaxReportFile',
+        params: {
+          isPDFRequired,
+          end,
+          start,
+          strategy: 'LIFO',
+          email
+        },
+        id: 5
+      })
+      .expect('Content-Type', /json/)
+      .expect(200)
+
+    await testMethodOfGettingReportFile(procPromise, aggrPromise, res)
+  })
+
   it('it should be successfully performed by the getTradedVolumeFile method', async function () {
     this.timeout(60000)
 

test/test-cases/api-sync-mode-sqlite-test-cases.js

@@ -1808,7 +1808,7 @@ module.exports = (
           symbol: ['tBTCUSD', 'tETHUSD'],
           start: 0,
           end,
-          limit: 10
+          limit: 2
         },
         id: 5
       })

workers/loc.api/di/app.deps.js

@@ -97,6 +97,7 @@ const {
   fullTaxReportCsvWriter
 } = require('../generate-report-file/csv-writer')
 const FullTaxReport = require('../sync/full.tax.report')
+const TransactionTaxReport = require('../sync/transaction.tax.report')
 const WeightedAveragesReport = require('../sync/weighted.averages.report')
 const SqliteDbMigrator = require(
   '../sync/dao/db-migrations/sqlite.db.migrator'
@@ -151,6 +152,7 @@ module.exports = ({
           ['_positionsSnapshot', TYPES.PositionsSnapshot],
           ['_fullSnapshotReport', TYPES.FullSnapshotReport],
           ['_fullTaxReport', TYPES.FullTaxReport],
+          ['_transactionTaxReport', TYPES.TransactionTaxReport],
           ['_tradedVolume', TYPES.TradedVolume],
           ['_totalFeesReport', TYPES.TotalFeesReport],
           ['_performingLoan', TYPES.PerformingLoan],
@@ -393,6 +395,8 @@ module.exports = ({
       )
     bind(TYPES.FullTaxReport)
       .to(FullTaxReport)
+    bind(TYPES.TransactionTaxReport)
+      .to(TransactionTaxReport)
     rebind(TYPES.WeightedAveragesReport)
       .to(WeightedAveragesReport)
     rebind(TYPES.ReportFileJobData)

workers/loc.api/di/types.js

@@ -69,5 +69,6 @@ module.exports = {
   SyncUserStepData: Symbol.for('SyncUserStepData'),
   SyncUserStepDataFactory: Symbol.for('SyncUserStepDataFactory'),
   HTTPRequest: Symbol.for('HTTPRequest'),
-  SummaryByAsset: Symbol.for('SummaryByAsset')
+  SummaryByAsset: Symbol.for('SummaryByAsset'),
+  TransactionTaxReport: Symbol.for('TransactionTaxReport')
 }

workers/loc.api/errors/index.js

@@ -248,6 +248,24 @@ class AuthTokenTTLSettingError extends ArgsParamsError {
   }
 }
 
+class CurrencyConversionError extends BaseError {
+  constructor (data, message = 'ERR_CURRENCY_HAS_NOT_BEEN_CONVERTED_TO_USD') {
+    super({ data, message })
+  }
+}
+
+class CurrencyPairSeparationError extends BaseError {
+  constructor (data, message = 'ERR_CURRENCY_PAIR_HAS_NOT_BEEN_SEPARATED_CORRECTLY') {
+    super({ data, message })
+  }
+}
+
+class TrxTaxReportGenerationTimeoutError extends BaseError {
+  constructor (message = 'ERR_TRX_TAX_REPORT_GENERATION_TIMEOUT') {
+    super(message)
+  }
+}
+
 module.exports = {
   BaseError,
   CollSyncPermissionError,
@@ -284,5 +302,8 @@ module.exports = {
   LastSyncedInfoGettingError,
   SyncInfoUpdatingError,
   AuthTokenGenerationError,
-  AuthTokenTTLSettingError
+  AuthTokenTTLSettingError,
+  CurrencyConversionError,
+  CurrencyPairSeparationError,
+  TrxTaxReportGenerationTimeoutError
 }