PullPoolTest.ts 1.5 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152
  1. import history from '../scripts/interface/history'
  2. import contracts from "../config/contracts";
  3. import logger from "../utils/logger";
  4. import v2_routers from "../config/v2_routers";
  5. import fs from 'fs'
  6. describe('Pull pool test', () => {
  7. it ('pull v3', async () => {
  8. logger.debug('start pull v3')
  9. const rst = await history.findByHashOrBlockOrDataVague('0', '', contracts.UNIV3, 0, 3000)
  10. logger.debug(rst.msg)
  11. const v3PoolList = []
  12. for (let v3Index in rst.data) {
  13. let v3Lp = rst.data[v3Index].dataObj
  14. v3PoolList.push(v3Lp)
  15. }
  16. logger.debug(v3PoolList.length)
  17. fs.writeFile('./config/v3PoolList.json', JSON.stringify(v3PoolList), (err) => {
  18. if (err) {
  19. logger.error(err)
  20. } else {
  21. logger.debug("File written successfully\n")
  22. }
  23. })
  24. })
  25. it ('pull v2', async () => {
  26. logger.debug('start pull v2')
  27. const v2PoolList = []
  28. for (let v2RouterIndex in v2_routers) {
  29. const rst = await history.findByHashOrBlockOrDataVague('0', '', v2_routers[v2RouterIndex], 0, 110000)
  30. logger.debug(v2_routers[v2RouterIndex])
  31. for (let v2Index in rst.data) {
  32. let v2Lp = rst.data[v2Index].dataObj
  33. v2PoolList.push(v2Lp)
  34. }
  35. }
  36. logger.debug(v2PoolList.length)
  37. fs.writeFile('./config/v2PoolList.json', JSON.stringify(v2PoolList), (err) => {
  38. if (err) {
  39. logger.error(err);
  40. } else {
  41. logger.debug("File written successfully\n");
  42. }
  43. })
  44. })
  45. })