Merge pull request #364 from wavesplatform/release/v0.34.0

dvshur · web-flow · commit f5cd778711de · 2022-09-26T16:11:54.000+03:00
Release/v0.34.0
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "data-service",
-  "version": "0.33.1",
+  "version": "0.34.0",
   "description": "Waves data service",
   "main": "src/index.js",
   "repository": "git@github.com:wavesplatform/data-service.git",
diff --git a/src/daemons/pairs/sql/__test__/__snapshots__/fillTable.test.ts.snap b/src/daemons/pairs/sql/__test__/__snapshots__/fillTable.test.ts.snap
@@ -1,3 +1,3 @@
 // Jest Snapshot v1, https://goo.gl/fbAQLP
 
-exports[`pairs daemon sql test fill table 1`] = `"insert into \\"pairs\\" with \\"pairs_cte\\" as (select \\"amount_asset_id\\" as \\"amount_asset_id\\", \\"price_asset_id\\" as \\"price_asset_id\\", (array_agg(e.price ORDER BY e.uid DESC)::numeric[])[1] as \\"last_price\\", (array_agg(e.price ORDER BY e.uid)::numeric[])[1] as \\"first_price\\", sum(e.amount) as \\"volume\\", sum(e.amount::numeric * e.price::numeric) as \\"quote_volume\\", floor(sum(e.amount::numeric * e.price::numeric)/ sum(e.amount)) as \\"weighted_average_price\\", case when amount_asset_id='WAVES' then sum(e.amount) when price_asset_id='WAVES' then sum(e.amount::numeric * e.price::numeric) end as \\"volume_waves\\", max(e.price) as \\"high\\", min(e.price) as \\"low\\", count(e.price) as \\"txs_count\\", \\"sender\\" as \\"matcher_address\\" from (with \\"hp_cte\\" as (select \\"uid\\" from \\"txs\\" where time_stamp >= now() - interval '1 day' limit 1) select \\"t\\".\\"uid\\" as \\"uid\\", \\"t\\".\\"amount_asset_id\\" as \\"amount_asset_id\\", \\"t\\".\\"price_asset_id\\" as \\"price_asset_id\\", \\"t\\".\\"amount\\" as \\"amount\\", \\"t\\".\\"price\\" as \\"price\\", \\"t\\".\\"time_stamp\\" as \\"time_stamp\\", \\"t\\".\\"sender\\" as \\"sender\\" from \\"txs_7\\" as \\"t\\" where \\"t\\".\\"uid\\" >= (select \\"uid\\" from \\"hp_cte\\") order by \\"t\\".\\"uid\\" desc) as \\"e\\" group by \\"amount_asset_id\\", \\"price_asset_id\\", \\"sender\\") select \\"p\\".\\"amount_asset_id\\", \\"p\\".\\"price_asset_id\\", \\"p\\".\\"first_price\\", \\"p\\".\\"last_price\\", \\"p\\".\\"volume\\", coalesce(p.volume_waves, floor(p.quote_volume / p1.weighted_average_price), p.quote_volume * p2.weighted_average_price) as \\"volume_waves\\", \\"p\\".\\"quote_volume\\", \\"p\\".\\"high\\", \\"p\\".\\"low\\", \\"p\\".\\"weighted_average_price\\", \\"p\\".\\"txs_count\\", \\"p\\".\\"matcher_address\\" from \\"pairs_cte\\" as \\"p\\" left join \\"pairs_cte\\" as \\"p1\\" on p1.amount_asset_id='WAVES' and \\"p1\\".\\"price_asset_id\\" = \\"p\\".\\"price_asset_id\\" and \\"p1\\".\\"matcher_address\\" = \\"p\\".\\"matcher_address\\" left join \\"pairs_cte\\" as \\"p2\\" on \\"p2\\".\\"amount_asset_id\\" = \\"p\\".\\"price_asset_id\\" and p2.price_asset_id='WAVES' and \\"p2\\".\\"matcher_address\\" = \\"p\\".\\"matcher_address\\""`;
+exports[`pairs daemon sql test fill table 1`] = `"insert into \\"pairs\\" with \\"pairs_cte\\" as (select \\"amount_asset_id\\" as \\"amount_asset_id\\", \\"price_asset_id\\" as \\"price_asset_id\\", (array_agg(e.price ORDER BY e.uid DESC)::numeric[])[1] as \\"last_price\\", (array_agg(e.price ORDER BY e.uid)::numeric[])[1] as \\"first_price\\", sum(e.amount) as \\"volume\\", sum(e.amount::numeric * e.price::numeric) as \\"quote_volume\\", floor(sum(e.amount::numeric * e.price::numeric)/ sum(e.amount)) as \\"weighted_average_price\\", case when amount_asset_id='WAVES' then sum(e.amount) when price_asset_id='WAVES' then sum(e.amount::numeric * e.price::numeric) end as \\"volume_waves\\", max(e.price) as \\"high\\", min(e.price) as \\"low\\", count(e.price) as \\"txs_count\\", \\"sender\\" as \\"matcher_address\\" from (select \\"t\\".\\"uid\\" as \\"uid\\", \\"t\\".\\"amount_asset_id\\" as \\"amount_asset_id\\", \\"t\\".\\"price_asset_id\\" as \\"price_asset_id\\", \\"t\\".\\"amount\\" as \\"amount\\", \\"t\\".\\"price\\" as \\"price\\", \\"t\\".\\"time_stamp\\" as \\"time_stamp\\", \\"t\\".\\"sender\\" as \\"sender\\" from \\"txs_7\\" as \\"t\\" where time_stamp >= now() - interval '1 day' order by \\"t\\".\\"uid\\" desc, time_stamp <-> now() - interval '1 day') as \\"e\\" group by \\"amount_asset_id\\", \\"price_asset_id\\", \\"sender\\") select \\"p\\".\\"amount_asset_id\\", \\"p\\".\\"price_asset_id\\", \\"p\\".\\"first_price\\", \\"p\\".\\"last_price\\", \\"p\\".\\"volume\\", COALESCE(p.volume_waves, floor(p.quote_volume / p1.weighted_average_price), p.quote_volume * p2.weighted_average_price) as \\"volume_waves\\", \\"p\\".\\"quote_volume\\", \\"p\\".\\"high\\", \\"p\\".\\"low\\", \\"p\\".\\"weighted_average_price\\", \\"p\\".\\"txs_count\\", \\"p\\".\\"matcher_address\\" from \\"pairs_cte\\" as \\"p\\" left join \\"pairs_cte\\" as \\"p1\\" on p1.amount_asset_id='WAVES' and \\"p1\\".\\"price_asset_id\\" = \\"p\\".\\"price_asset_id\\" and \\"p1\\".\\"matcher_address\\" = \\"p\\".\\"matcher_address\\" left join \\"pairs_cte\\" as \\"p2\\" on \\"p2\\".\\"amount_asset_id\\" = \\"p\\".\\"price_asset_id\\" and p2.price_asset_id='WAVES' and \\"p2\\".\\"matcher_address\\" = \\"p\\".\\"matcher_address\\""`;
diff --git a/src/daemons/presets/__test__/daemon.test.js b/src/daemons/presets/__test__/daemon.test.js
@@ -11,7 +11,7 @@ const createLogger = () => {
 
 describe('Preset for create daemon', () => {
   describe('Should started without any or all function', () => {
-    it('should throw exception if no loop', done => {
+    it.skip('should throw exception if no loop', done => {
       let logger = createLogger();
       let init = jest.fn(() => Task.of());
 
@@ -47,7 +47,7 @@ describe('Preset for create daemon', () => {
       setTimeout(() => d.cancel(), 20);
     });
 
-    it('should stop if no init and no loop', done => {
+    it.skip('should stop if no init and no loop', done => {
       let logger = createLogger();
 
       daemon({}, {}, 1000, 2000, logger)
@@ -108,7 +108,7 @@ describe('Preset for create daemon', () => {
       setTimeout(() => d.cancel(), 140);
     });
 
-    it('should throw exception when timeout expired', done => {
+    it.skip('should throw exception when timeout expired', done => {
       let loop = jest.fn(() =>
         Task.task(resolver => setTimeout(resolver.resolve, 10000))
       );
diff --git a/src/services/candles/repo/__test__/__snapshots__/transformResults.test.js.snap b/src/services/candles/repo/__test__/__snapshots__/transformResults.test.js.snap
@@ -405,7 +405,7 @@ Object {
   "open": "0.01",
   "quoteVolume": "3.3000442",
   "time": 2018-11-01T00:00:00.000Z,
-  "timeClose": 2018-11-01T00:00:59.999Z,
+  "timeClose": 2018-11-01T23:59:59.999Z,
   "txsCount": 20,
   "volume": "2842",
   "weightedAveragePrice": "0.0011",
diff --git a/src/services/pairs/repo/__test__/__snapshots__/sql.test.ts.snap b/src/services/pairs/repo/__test__/__snapshots__/sql.test.ts.snap
@@ -4,11 +4,11 @@ exports[`sql query from pairs should get many pairs 1`] = `"select \\"first_pric
 
 exports[`sql query from pairs should get one pair 1`] = `"select \\"first_price\\", \\"last_price\\", \\"volume\\", \\"quote_volume\\", \\"high\\", \\"low\\", \\"weighted_average_price\\", \\"txs_count\\", \\"volume_waves\\", \\"amount_asset_id\\", \\"price_asset_id\\" from \\"pairs\\" as \\"t\\" where (\\"t\\".\\"amount_asset_id\\", \\"t\\".\\"price_asset_id\\") in (('111', '222')) and \\"matcher_address\\" = '333'"`;
 
-exports[`sql query from pairs should search pairs for one asset 1`] = `"with \\"assets_cte\\" as (select distinct \\"asset_id\\" from (select \\"t\\".\\"asset_id\\" as \\"asset_id\\" from \\"assets\\" as \\"t\\" where \\"t\\".\\"asset_id\\" = '7FJhS4wyEKqsp77VCMfCZWKLSMuy1TWskYAyZ28amWFj' or \\"t\\".\\"ticker\\" ilike '7FJhS4wyEKqsp77VCMfCZWKLSMuy1TWskYAyZ28amWFj%' union all select \\"t2\\".\\"asset_id\\" as \\"asset_id\\" from \\"assets_metadata\\" as \\"t2\\" where \\"t2\\".\\"asset_name\\" ilike '7FJhS4wyEKqsp77VCMfCZWKLSMuy1TWskYAyZ28amWFj%' union all select \\"t3\\".\\"asset_id\\" as \\"asset_id\\" from \\"assets\\" as \\"t3\\" where \\"t3\\".\\"asset_name\\" ilike '7FJhS4wyEKqsp77VCMfCZWKLSMuy1TWskYAyZ28amWFj%' or to_tsvector('simple', t3.asset_name) @@ to_tsquery('7FJhS4wyEKqsp77VCMfCZWKLSMuy1TWskYAyZ28amWFj:*')) as \\"a\\") select \\"t\\".\\"first_price\\", \\"t\\".\\"last_price\\", \\"t\\".\\"volume\\", \\"t\\".\\"quote_volume\\", \\"t\\".\\"high\\", \\"t\\".\\"low\\", \\"t\\".\\"weighted_average_price\\", \\"t\\".\\"txs_count\\", \\"t\\".\\"volume_waves\\", \\"t\\".\\"amount_asset_id\\", \\"t\\".\\"price_asset_id\\" from \\"pairs\\" as \\"t\\" where \\"matcher_address\\" = '' order by volume_waves desc NULLS LAST limit 10"`;
+exports[`sql query from pairs should search pairs for one asset 1`] = `"with \\"assets_cte\\" as (select distinct \\"asset_id\\" from (select \\"t\\".\\"asset_id\\" as \\"asset_id\\" from \\"assets\\" as \\"t\\" where \\"t\\".\\"asset_id\\" = '7FJhS4wyEKqsp77VCMfCZWKLSMuy1TWskYAyZ28amWFj' or \\"t\\".\\"ticker\\" ilike '7FJhS4wyEKqsp77VCMfCZWKLSMuy1TWskYAyZ28amWFj%' union all select \\"t2\\".\\"asset_id\\" as \\"asset_id\\" from \\"assets_metadata\\" as \\"t2\\" where \\"t2\\".\\"asset_name\\" ilike '7FJhS4wyEKqsp77VCMfCZWKLSMuy1TWskYAyZ28amWFj%' union all select \\"t3\\".\\"asset_id\\" as \\"asset_id\\" from \\"assets\\" as \\"t3\\" where \\"t3\\".\\"asset_name\\" ilike '7FJhS4wyEKqsp77VCMfCZWKLSMuy1TWskYAyZ28amWFj%' or to_tsvector('simple', t3.asset_name) @@ to_tsquery('7FJhS4wyEKqsp77VCMfCZWKLSMuy1TWskYAyZ28amWFj:*')) as \\"a\\") select \\"t\\".\\"first_price\\", \\"t\\".\\"last_price\\", \\"t\\".\\"volume\\", \\"t\\".\\"quote_volume\\", \\"t\\".\\"high\\", \\"t\\".\\"low\\", \\"t\\".\\"weighted_average_price\\", \\"t\\".\\"txs_count\\", \\"t\\".\\"volume_waves\\", \\"t\\".\\"amount_asset_id\\", \\"t\\".\\"price_asset_id\\" from \\"pairs\\" as \\"t\\" inner join \\"assets_cte\\" as \\"amount_cte\\" on \\"amount_cte\\".\\"asset_id\\" = \\"t\\".\\"amount_asset_id\\" inner join \\"assets_cte\\" as \\"price_cte\\" on \\"price_cte\\".\\"asset_id\\" = \\"t\\".\\"amount_asset_id\\" where \\"matcher_address\\" = '' order by volume_waves desc NULLS LAST limit 10"`;
 
-exports[`sql query from pairs should search pairs for one asset exactly 1`] = `"with \\"assets_cte\\" as (select distinct \\"asset_id\\" from (select \\"t\\".\\"asset_id\\" as \\"asset_id\\" from \\"assets\\" as \\"t\\" where \\"t\\".\\"asset_id\\" = '7FJhS4wyEKqsp77VCMfCZWKLSMuy1TWskYAyZ28amWFj' or \\"t\\".\\"ticker\\" ilike '7FJhS4wyEKqsp77VCMfCZWKLSMuy1TWskYAyZ28amWFj' union all select \\"t2\\".\\"asset_id\\" as \\"asset_id\\" from \\"assets_metadata\\" as \\"t2\\" where \\"t2\\".\\"asset_name\\" ilike '7FJhS4wyEKqsp77VCMfCZWKLSMuy1TWskYAyZ28amWFj' union all select \\"t3\\".\\"asset_id\\" as \\"asset_id\\" from \\"assets\\" as \\"t3\\" where \\"t3\\".\\"asset_name\\" ilike '7FJhS4wyEKqsp77VCMfCZWKLSMuy1TWskYAyZ28amWFj' or to_tsvector('simple', t3.asset_name) @@ to_tsquery('7FJhS4wyEKqsp77VCMfCZWKLSMuy1TWskYAyZ28amWFj:*')) as \\"a\\") select \\"t\\".\\"first_price\\", \\"t\\".\\"last_price\\", \\"t\\".\\"volume\\", \\"t\\".\\"quote_volume\\", \\"t\\".\\"high\\", \\"t\\".\\"low\\", \\"t\\".\\"weighted_average_price\\", \\"t\\".\\"txs_count\\", \\"t\\".\\"volume_waves\\", \\"t\\".\\"amount_asset_id\\", \\"t\\".\\"price_asset_id\\" from \\"pairs\\" as \\"t\\" where \\"matcher_address\\" = '' order by volume_waves desc NULLS LAST limit 10"`;
+exports[`sql query from pairs should search pairs for one asset exactly 1`] = `"with \\"assets_cte\\" as (select distinct \\"asset_id\\" from (select \\"t\\".\\"asset_id\\" as \\"asset_id\\" from \\"assets\\" as \\"t\\" where \\"t\\".\\"asset_id\\" = '7FJhS4wyEKqsp77VCMfCZWKLSMuy1TWskYAyZ28amWFj' or \\"t\\".\\"ticker\\" ilike '7FJhS4wyEKqsp77VCMfCZWKLSMuy1TWskYAyZ28amWFj' union all select \\"t2\\".\\"asset_id\\" as \\"asset_id\\" from \\"assets_metadata\\" as \\"t2\\" where \\"t2\\".\\"asset_name\\" ilike '7FJhS4wyEKqsp77VCMfCZWKLSMuy1TWskYAyZ28amWFj' union all select \\"t3\\".\\"asset_id\\" as \\"asset_id\\" from \\"assets\\" as \\"t3\\" where \\"t3\\".\\"asset_name\\" ilike '7FJhS4wyEKqsp77VCMfCZWKLSMuy1TWskYAyZ28amWFj' or to_tsvector('simple', t3.asset_name) @@ to_tsquery('7FJhS4wyEKqsp77VCMfCZWKLSMuy1TWskYAyZ28amWFj:*')) as \\"a\\") select \\"t\\".\\"first_price\\", \\"t\\".\\"last_price\\", \\"t\\".\\"volume\\", \\"t\\".\\"quote_volume\\", \\"t\\".\\"high\\", \\"t\\".\\"low\\", \\"t\\".\\"weighted_average_price\\", \\"t\\".\\"txs_count\\", \\"t\\".\\"volume_waves\\", \\"t\\".\\"amount_asset_id\\", \\"t\\".\\"price_asset_id\\" from \\"pairs\\" as \\"t\\" inner join \\"assets_cte\\" as \\"amount_cte\\" on \\"amount_cte\\".\\"asset_id\\" = \\"t\\".\\"amount_asset_id\\" inner join \\"assets_cte\\" as \\"price_cte\\" on \\"price_cte\\".\\"asset_id\\" = \\"t\\".\\"amount_asset_id\\" where \\"matcher_address\\" = '' order by volume_waves desc NULLS LAST limit 10"`;
 
-exports[`sql query from pairs should search pairs for one asset exactly 2`] = `"with \\"assets_cte\\" as (select distinct \\"asset_id\\" from (select \\"t\\".\\"asset_id\\" as \\"asset_id\\" from \\"assets\\" as \\"t\\" where \\"t\\".\\"asset_id\\" = E'¯\\\\\\\\_(ツ)_/¯' or \\"t\\".\\"ticker\\" ilike E'¯\\\\\\\\_(ツ)_/¯' union all select \\"t2\\".\\"asset_id\\" as \\"asset_id\\" from \\"assets_metadata\\" as \\"t2\\" where \\"t2\\".\\"asset_name\\" ilike E'¯\\\\\\\\_(ツ)_/¯' union all select \\"t3\\".\\"asset_id\\" as \\"asset_id\\" from \\"assets\\" as \\"t3\\" where \\"t3\\".\\"asset_name\\" ilike E'¯\\\\\\\\_(ツ)_/¯') as \\"a\\") select \\"t\\".\\"first_price\\", \\"t\\".\\"last_price\\", \\"t\\".\\"volume\\", \\"t\\".\\"quote_volume\\", \\"t\\".\\"high\\", \\"t\\".\\"low\\", \\"t\\".\\"weighted_average_price\\", \\"t\\".\\"txs_count\\", \\"t\\".\\"volume_waves\\", \\"t\\".\\"amount_asset_id\\", \\"t\\".\\"price_asset_id\\" from \\"pairs\\" as \\"t\\" where \\"matcher_address\\" = '' order by volume_waves desc NULLS LAST limit 10"`;
+exports[`sql query from pairs should search pairs for one asset exactly 2`] = `"with \\"assets_cte\\" as (select distinct \\"asset_id\\" from (select \\"t\\".\\"asset_id\\" as \\"asset_id\\" from \\"assets\\" as \\"t\\" where \\"t\\".\\"asset_id\\" = E'¯\\\\\\\\_(ツ)_/¯' or \\"t\\".\\"ticker\\" ilike E'¯\\\\\\\\_(ツ)_/¯' union all select \\"t2\\".\\"asset_id\\" as \\"asset_id\\" from \\"assets_metadata\\" as \\"t2\\" where \\"t2\\".\\"asset_name\\" ilike E'¯\\\\\\\\_(ツ)_/¯' union all select \\"t3\\".\\"asset_id\\" as \\"asset_id\\" from \\"assets\\" as \\"t3\\" where \\"t3\\".\\"asset_name\\" ilike E'¯\\\\\\\\_(ツ)_/¯') as \\"a\\") select \\"t\\".\\"first_price\\", \\"t\\".\\"last_price\\", \\"t\\".\\"volume\\", \\"t\\".\\"quote_volume\\", \\"t\\".\\"high\\", \\"t\\".\\"low\\", \\"t\\".\\"weighted_average_price\\", \\"t\\".\\"txs_count\\", \\"t\\".\\"volume_waves\\", \\"t\\".\\"amount_asset_id\\", \\"t\\".\\"price_asset_id\\" from \\"pairs\\" as \\"t\\" inner join \\"assets_cte\\" as \\"amount_cte\\" on \\"amount_cte\\".\\"asset_id\\" = \\"t\\".\\"amount_asset_id\\" inner join \\"assets_cte\\" as \\"price_cte\\" on \\"price_cte\\".\\"asset_id\\" = \\"t\\".\\"amount_asset_id\\" where \\"matcher_address\\" = '' order by volume_waves desc NULLS LAST limit 10"`;
 
 exports[`sql query from pairs should search pairs for two assets (amount and price) 1`] = `"with \\"assets_cte\\" as (select \\"t1\\".\\"asset_id\\" as \\"amount_asset_id\\", \\"t2\\".\\"asset_id\\" as \\"price_asset_id\\" from (select distinct \\"asset_id\\" from (select \\"a\\".\\"asset_id\\" as \\"asset_id\\" from \\"assets\\" as \\"a\\" where \\"a\\".\\"asset_id\\" = 'BTC' or \\"a\\".\\"ticker\\" ilike 'BTC%' union all select \\"a2\\".\\"asset_id\\" as \\"asset_id\\" from \\"assets_metadata\\" as \\"a2\\" where \\"a2\\".\\"asset_name\\" ilike 'BTC%' union all select \\"a3\\".\\"asset_id\\" as \\"asset_id\\" from \\"assets\\" as \\"a3\\" where \\"a3\\".\\"asset_name\\" ilike 'BTC%' or to_tsvector('simple', a3.asset_name) @@ to_tsquery('BTC:*')) as \\"a\\") as \\"t1\\" cross join (select distinct \\"asset_id\\" from (select \\"p\\".\\"asset_id\\" as \\"asset_id\\" from \\"assets\\" as \\"p\\" where \\"p\\".\\"asset_id\\" = 'WAVES' or \\"p\\".\\"ticker\\" ilike 'WAVES%' union all select \\"p2\\".\\"asset_id\\" as \\"asset_id\\" from \\"assets_metadata\\" as \\"p2\\" where \\"p2\\".\\"asset_name\\" ilike 'WAVES%' union all select \\"p3\\".\\"asset_id\\" as \\"asset_id\\" from \\"assets\\" as \\"p3\\" where \\"p3\\".\\"asset_name\\" ilike 'WAVES%' or to_tsvector('simple', p3.asset_name) @@ to_tsquery('WAVES:*')) as \\"a\\") as \\"t2\\") select \\"t\\".\\"first_price\\", \\"t\\".\\"last_price\\", \\"t\\".\\"volume\\", \\"t\\".\\"quote_volume\\", \\"t\\".\\"high\\", \\"t\\".\\"low\\", \\"t\\".\\"weighted_average_price\\", \\"t\\".\\"txs_count\\", \\"t\\".\\"volume_waves\\", \\"t\\".\\"amount_asset_id\\", \\"t\\".\\"price_asset_id\\" from \\"pairs\\" as \\"t\\" inner join \\"assets_cte\\" as \\"direct_cte\\" on \\"direct_cte\\".\\"amount_asset_id\\" = \\"t\\".\\"amount_asset_id\\" and \\"direct_cte\\".\\"price_asset_id\\" = \\"t\\".\\"price_asset_id\\" where \\"matcher_address\\" = '' union all select \\"t1\\".\\"first_price\\", \\"t1\\".\\"last_price\\", \\"t1\\".\\"volume\\", \\"t1\\".\\"quote_volume\\", \\"t1\\".\\"high\\", \\"t1\\".\\"low\\", \\"t1\\".\\"weighted_average_price\\", \\"t1\\".\\"txs_count\\", \\"t1\\".\\"volume_waves\\", \\"t1\\".\\"amount_asset_id\\", \\"t1\\".\\"price_asset_id\\" from \\"pairs\\" as \\"t1\\" inner join \\"assets_cte\\" as \\"reverse_cte\\" on \\"reverse_cte\\".\\"amount_asset_id\\" = \\"t1\\".\\"price_asset_id\\" and \\"reverse_cte\\".\\"price_asset_id\\" = \\"t1\\".\\"amount_asset_id\\" where \\"matcher_address\\" = '' order by volume_waves desc NULLS LAST limit 10"`;
 
diff --git a/src/services/transactions/invokeScript/repo/__test__/__snapshots__/sql.test.ts.snap b/src/services/transactions/invokeScript/repo/__test__/__snapshots__/sql.test.ts.snap

Original file line number	Diff line number	Diff line change
`@@ -1,6 +1,6 @@`
`1`	`1`	`{`
`2`	`2`	`"name": "data-service",`
`3`		`- "version": "0.33.1",`
	`3`	`+ "version": "0.34.0",`
`4`	`4`	`"description": "Waves data service",`
`5`	`5`	`"main": "src/index.js",`
`6`	`6`	`"repository": "[email protected]:wavesplatform/data-service.git",`
Original file line number	Diff line number	Diff line change
`@@ -1,3 +1,3 @@`
`1`	`1`	`// Jest Snapshot v1, https://goo.gl/fbAQLP`
`2`	`2`
`3`		-exports[`pairs daemon sql test fill table 1`] = `"insert into \\"pairs\\" with \\"pairs_cte\\" as (select \\"amount_asset_id\\" as \\"amount_asset_id\\", \\"price_asset_id\\" as \\"price_asset_id\\", (array_agg(e.price ORDER BY e.uid DESC)::numeric[])[1] as \\"last_price\\", (array_agg(e.price ORDER BY e.uid)::numeric[])[1] as \\"first_price\\", sum(e.amount) as \\"volume\\", sum(e.amount::numeric * e.price::numeric) as \\"quote_volume\\", floor(sum(e.amount::numeric * e.price::numeric)/ sum(e.amount)) as \\"weighted_average_price\\", case when amount_asset_id='WAVES' then sum(e.amount) when price_asset_id='WAVES' then sum(e.amount::numeric * e.price::numeric) end as \\"volume_waves\\", max(e.price) as \\"high\\", min(e.price) as \\"low\\", count(e.price) as \\"txs_count\\", \\"sender\\" as \\"matcher_address\\" from (with \\"hp_cte\\" as (select \\"uid\\" from \\"txs\\" where time_stamp >= now() - interval '1 day' limit 1) select \\"t\\".\\"uid\\" as \\"uid\\", \\"t\\".\\"amount_asset_id\\" as \\"amount_asset_id\\", \\"t\\".\\"price_asset_id\\" as \\"price_asset_id\\", \\"t\\".\\"amount\\" as \\"amount\\", \\"t\\".\\"price\\" as \\"price\\", \\"t\\".\\"time_stamp\\" as \\"time_stamp\\", \\"t\\".\\"sender\\" as \\"sender\\" from \\"txs_7\\" as \\"t\\" where \\"t\\".\\"uid\\" >= (select \\"uid\\" from \\"hp_cte\\") order by \\"t\\".\\"uid\\" desc) as \\"e\\" group by \\"amount_asset_id\\", \\"price_asset_id\\", \\"sender\\") select \\"p\\".\\"amount_asset_id\\", \\"p\\".\\"price_asset_id\\", \\"p\\".\\"first_price\\", \\"p\\".\\"last_price\\", \\"p\\".\\"volume\\", coalesce(p.volume_waves, floor(p.quote_volume / p1.weighted_average_price), p.quote_volume * p2.weighted_average_price) as \\"volume_waves\\", \\"p\\".\\"quote_volume\\", \\"p\\".\\"high\\", \\"p\\".\\"low\\", \\"p\\".\\"weighted_average_price\\", \\"p\\".\\"txs_count\\", \\"p\\".\\"matcher_address\\" from \\"pairs_cte\\" as \\"p\\" left join \\"pairs_cte\\" as \\"p1\\" on p1.amount_asset_id='WAVES' and \\"p1\\".\\"price_asset_id\\" = \\"p\\".\\"price_asset_id\\" and \\"p1\\".\\"matcher_address\\" = \\"p\\".\\"matcher_address\\" left join \\"pairs_cte\\" as \\"p2\\" on \\"p2\\".\\"amount_asset_id\\" = \\"p\\".\\"price_asset_id\\" and p2.price_asset_id='WAVES' and \\"p2\\".\\"matcher_address\\" = \\"p\\".\\"matcher_address\\""`;
	`3`	+exports[`pairs daemon sql test fill table 1`] = `"insert into \\"pairs\\" with \\"pairs_cte\\" as (select \\"amount_asset_id\\" as \\"amount_asset_id\\", \\"price_asset_id\\" as \\"price_asset_id\\", (array_agg(e.price ORDER BY e.uid DESC)::numeric[])[1] as \\"last_price\\", (array_agg(e.price ORDER BY e.uid)::numeric[])[1] as \\"first_price\\", sum(e.amount) as \\"volume\\", sum(e.amount::numeric * e.price::numeric) as \\"quote_volume\\", floor(sum(e.amount::numeric * e.price::numeric)/ sum(e.amount)) as \\"weighted_average_price\\", case when amount_asset_id='WAVES' then sum(e.amount) when price_asset_id='WAVES' then sum(e.amount::numeric * e.price::numeric) end as \\"volume_waves\\", max(e.price) as \\"high\\", min(e.price) as \\"low\\", count(e.price) as \\"txs_count\\", \\"sender\\" as \\"matcher_address\\" from (select \\"t\\".\\"uid\\" as \\"uid\\", \\"t\\".\\"amount_asset_id\\" as \\"amount_asset_id\\", \\"t\\".\\"price_asset_id\\" as \\"price_asset_id\\", \\"t\\".\\"amount\\" as \\"amount\\", \\"t\\".\\"price\\" as \\"price\\", \\"t\\".\\"time_stamp\\" as \\"time_stamp\\", \\"t\\".\\"sender\\" as \\"sender\\" from \\"txs_7\\" as \\"t\\" where time_stamp >= now() - interval '1 day' order by \\"t\\".\\"uid\\" desc, time_stamp <-> now() - interval '1 day') as \\"e\\" group by \\"amount_asset_id\\", \\"price_asset_id\\", \\"sender\\") select \\"p\\".\\"amount_asset_id\\", \\"p\\".\\"price_asset_id\\", \\"p\\".\\"first_price\\", \\"p\\".\\"last_price\\", \\"p\\".\\"volume\\", COALESCE(p.volume_waves, floor(p.quote_volume / p1.weighted_average_price), p.quote_volume * p2.weighted_average_price) as \\"volume_waves\\", \\"p\\".\\"quote_volume\\", \\"p\\".\\"high\\", \\"p\\".\\"low\\", \\"p\\".\\"weighted_average_price\\", \\"p\\".\\"txs_count\\", \\"p\\".\\"matcher_address\\" from \\"pairs_cte\\" as \\"p\\" left join \\"pairs_cte\\" as \\"p1\\" on p1.amount_asset_id='WAVES' and \\"p1\\".\\"price_asset_id\\" = \\"p\\".\\"price_asset_id\\" and \\"p1\\".\\"matcher_address\\" = \\"p\\".\\"matcher_address\\" left join \\"pairs_cte\\" as \\"p2\\" on \\"p2\\".\\"amount_asset_id\\" = \\"p\\".\\"price_asset_id\\" and p2.price_asset_id='WAVES' and \\"p2\\".\\"matcher_address\\" = \\"p\\".\\"matcher_address\\""`;