All files / src cli.module.ts

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
global.doNotStartAutomatically = true
import { promises as fs } from 'fs';
import { NestFactory } from "@nestjs/core";
import { AppModule } from "./app.module";
import { Erc721SalesService } from "./erc721sales.service";
import { exit } from "process";
import { config } from "./config";
import { ethers } from "ethers";
import erc721abi from './abi/erc721.json'
import { StatisticsService } from "./extensions/statistics.extension.service";
 
async function bootstrap() {
  const args = require('yargs')
    .option('action', { string: true })
    .option('contract', { string: true })
    .option('tx', { string: true })
    .argv;
 
  Iif (!args.action) {
    console.log('missing --action=[index or tweet] parameter')
    exit(1)
    return
  }
  Iif (!args.block && args.action !== 'extract') {
    console.log('missing --block=[ethereum block number] parameter')
    exit(1)
    return
  }
  Iif (!args.tx && args.action !== 'extract') {
    console.log('missing --tx=[ethereum tx hash] parameter')
    exit(1)
    return
  }
 
  console.log('starting up')
  const app = await NestFactory.createApplicationContext(AppModule);
 
  const saleService = app.get(Erc721SalesService);
  const statService = app.get(StatisticsService);
 
  // saleService.startProvider()
  await delay(5000)
 
  const provider = saleService.getWeb3Provider()
 
  Iif (args.contract)
    config.contract_address = args.contract
  
  const tokenContract = new ethers.Contract(config.contract_address, erc721abi, provider);
  let filter = tokenContract.filters.Transfer();
  const block = args.block
 
  if (!args.dryRun || args.dryRun !== 'true') {
 
    Iif (args.action === 'extract') {
      for (let i=0; i<10000; i++) {
        const tokenId = i.toString().padStart(4, '0')
        await saleService.getTokenMetadata(tokenId, false)
      }
      return 
    }
 
    const events = (await tokenContract.queryFilter(filter, 
      block, 
      block))
      .filter(e => e.transactionHash === args.tx)
        
    if (args.action === 'tweet') {
      const results = await Promise.all(
        events.map(async (e) => await saleService.getTransactionDetails(e))
      )
      
      let logs = ''
      results.filter(r => r !== undefined).forEach(r => {
        logs += `${r.tokenId} sold for ${r.alternateValue}\n`
      })
      console.log(logs)      
      for (let r of results) {
          await saleService.dispatch(r)
      }
    } else {
      statService.prepareStatements()
      await statService.handleEvents(events)
    }
  } else {
    console.log('not dispatching event ')
  }
  
  console.log('shuting down')
 
  await app.close();
  console.log('end')
  exit(0)
}
 
bootstrap();
 
 
function delay(ms: number) {
  return new Promise( resolve => setTimeout(resolve, ms) );
}