project init

This commit is contained in:
cebgcontract 2022-11-22 15:57:19 +08:00
commit b53fa7e605
57 changed files with 13117 additions and 0 deletions

0
.env Normal file
View File

22
.env.development Normal file
View File

@ -0,0 +1,22 @@
API_PORT=3002
API_HOST=127.0.0.1
API_TOKEN_SECRET=sdf(**&*&xx2213
API_TOKEN_EXPIRESIN=1d
DB_MAIN=mongodb://192.168.100.22/chain-flow2-development
CHAIN_MAX_TRY=6
CHAIN_CONFIRM_NUM=6
CHAIN_MASTER_KEY=0x81b1853d9affd3faf0c64680b1c982afee1fcae7991b4f7e31c4c999663e3599
CHAIN_MINT_KEY=0x9c0b7c5625f79245ca168b655cd5a07cfa7bf2f9acaa7f4cf9109f9b522c81f2
CHAIN_ADMIN_KEY=0x0fe56c1461b1b8ef4d4cf10e86fde7aaa797024cd7d1c41dce35116094008cbf
CHAIN_RPC_URL='https://robin.rangersprotocol.com/api/jsonrpc'
CHAIN_FT_ADDRESS=0xb592244aa6477eBDDc14475aaeF921cdDcC0170f
CHAIN_NFT_ADDRESS=0xd45A464a2412A2f83498d13635698a041b9dBe9b
CHAIN_FTLOCKER_ADDRESS=0x7a0D4dca33d97ae2bF8a661541CE83dF27c2a3e8
CHAIN_NFTLOCKER_ADDRESS=0xdf45a88833607a70E2fAEf81dB30FfeA1527aa5A
INFO_SVR_HOST=http://localhost:2900
RUN_USER=604b365803b864b84d40ded5

8
.env.production Normal file
View File

@ -0,0 +1,8 @@
API_PORT=3001
API_HOST=127.0.0.1
API_TOKEN_SECRET=sdf(**&*&xx2214
API_TOKEN_EXPIRESIN=1d
CHAIN_MAX_TRY=3
CHAIN_MASTER_KEY=1212
CHAIN_RPC_URL='ws://localhost:7545'

1
.eslintignore Normal file
View File

@ -0,0 +1 @@
dist/*.js

14
.eslintrc.js Normal file
View File

@ -0,0 +1,14 @@
/** @format */
module.exports = {
parser: '@typescript-eslint/parser', //定义ESLint的解析器
extends: [
'plugin:prettier/recommended', // 使用prettier中的样式规范且如果使得ESLint会检测prettier的格式问题同样将格式问题以error的形式抛出
],
parserOptions: {ecmaVersion: 2019, sourceType: 'module'},
env: {
//指定代码的运行环境
browser: true,
node: true,
},
}

5
.gitignore vendored Normal file
View File

@ -0,0 +1,5 @@
.idea
node_modules
build
dist
.DS_Store

13
.prettierrc.js Normal file
View File

@ -0,0 +1,13 @@
module.exports = {
"printWidth": 120,
"semi": false, // 在语句末尾添加分号
"singleQuote": true, // 使用单引号而非双引号
"trailingComma": "all", // 在任何可能的多行中输入尾逗号
"bracketSpacing": true, // 在对象字面量声明所使用的的花括号前后({})输出空格
"jsxBracketSameLine": true, // 在多行JSX元素最后一行的末尾添加 > 而使 > 单独一行(不适用于自闭和元素)
"arrowParens": "avoid", // 为单行箭头函数的参数添加圆括号。
"requirePragma": false, // Prettier可以严格按照按照文件顶部的一些特殊的注释格式化代码
"insertPragma": false, // 顶部插入一个 @format
"tabWidth": 2,
"useTabs": false,
};

21
.vscode/launch.json vendored Normal file
View File

@ -0,0 +1,21 @@
{
// Use IntelliSense to learn about possible attributes.
// Hover to view descriptions of existing attributes.
// For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
"version": "0.2.0",
"configurations": [
{
"name": "Debug Api",
"request": "launch",
"runtimeArgs": [
"run-script",
"dev:api"
],
"runtimeExecutable": "npm",
"skipFiles": [
"<node_internals>/**"
],
"type": "pwa-node"
},
]
}

61
package.json Normal file
View File

@ -0,0 +1,61 @@
{
"name": "flow_chain",
"version": "1.0.0",
"description": "",
"main": "index.js",
"scripts": {
"build": "tsc -p tsconfig.json",
"test": "echo \"Error: no test specified\" && exit 1",
"prod:api": "NODE_PATH=./dist node dist/api.js",
"run:prod": "NODE_ENV=production ts-node -r tsconfig-paths/register src/api.ts",
"dev:api": "ts-node -r tsconfig-paths/register src/api.ts",
"lint": "eslint --ext .ts src/**",
"format": "eslint --ext .ts src/** --fix"
},
"author": "z",
"license": "ISC",
"engines": {
"node": ">=16.0.0"
},
"dependencies": {
"@metamask/eth-sig-util": "^4.0.1",
"@typegoose/auto-increment": "^0.4.1",
"@typegoose/typegoose": "^7.4.6",
"axios": "^0.21.1",
"bson": "^4.0.4",
"dotenv": "^16.0.3",
"ethereumjs-util": "^7.1.5",
"fast-rbac": "^1.3.0",
"fastify": "^3.9.2",
"fastify-cors": "^5.1.0",
"fastify-file-upload": "^3.0.0",
"fastify-formbody": "^5.0.0",
"fastify-helmet": "^5.0.3",
"fastify-jwt": "^2.2.0",
"fastify-plugin": "^3.0.0",
"mongoose": "5.10.3",
"mongoose-findorcreate": "^3.0.0",
"node-schedule": "^2.0.0",
"redis": "^3.1.2",
"tracer": "^1.1.6",
"web3": "^1.7.4"
},
"devDependencies": {
"@types/dotenv": "^8.2.0",
"@types/mongoose": "5.10.3",
"@types/node": "^14.14.20",
"@types/node-schedule": "^2.1.0",
"@types/redis": "^2.8.28",
"@typescript-eslint/eslint-plugin": "^4.25.0",
"@typescript-eslint/parser": "^4.25.0",
"eslint": "^7.27.0",
"eslint-config-prettier": "^8.3.0",
"eslint-plugin-prettier": "^3.4.0",
"prettier": "^2.3.0",
"ts-node": "^10.9.1",
"ts-node-dev": "^2.0.0",
"tsconfig-paths": "^3.9.0",
"tslint": "^6.1.1",
"typescript": "^4.1.3"
}
}

1
pm2_dev.sh Executable file
View File

@ -0,0 +1 @@
pm2 start npm --name "flow-chain" --log-date-format "YYYY-MM-DD HH:mm:ss" -- run "dev:api"

168
src/api.server.ts Normal file
View File

@ -0,0 +1,168 @@
import fastify, { FastifyError, FastifyInstance, FastifyReply, FastifyRequest } from 'fastify'
import helmet from 'fastify-helmet'
import { IncomingMessage, Server, ServerResponse } from 'http'
import { RouterMap } from 'decorators/router'
import { mongoose } from '@typegoose/typegoose'
import logger from 'logger/logger'
import config from 'config/config'
import { Schedule } from './clock/Schedule'
import { RedisClient } from './redis/RedisClient'
import BlocknumSchedule from 'schedule/blocknum.schedule'
import { restartAllUnFinishedTask } from 'service/chain.service'
const zReqParserPlugin = require('plugins/zReqParser')
const zTokenParserPlugin = require('plugins/zTokenParser')
const apiAuthPlugin = require('plugins/apiauth')
const fs = require('fs')
const join = require('path').join
require('./common/Extend')
export class ApiServer {
server: FastifyInstance<Server, IncomingMessage, ServerResponse>
public constructor() {
this.server = fastify({ logger: true, trustProxy: true })
this.registerPlugins()
}
private registerPlugins() {
this.server.register(require('fastify-formbody'))
this.server.register(zReqParserPlugin)
this.server.register(helmet, { hidePoweredBy: false })
this.server.register(zTokenParserPlugin)
this.server.register(apiAuthPlugin, {
secret: config.api.token_secret,
expiresIn: config.api.token_expiresIn,
})
this.server.register(require('fastify-cors'), {})
}
private registerRouter() {
logger.log('register api routers')
let self = this
for (let [controller, config] of RouterMap.decoratedRouters) {
for (let data of config.data) {
logger.info(
'add router',
data.method || 'all',
data.path,
`${data.target.constructor.name}.${controller.name}()`,
)
// @ts-ignore
self.server[data.method || 'all'](
data.path,
{
preValidation: async function (request: FastifyRequest, reply: FastifyReply) {
request.roles = config.roles
await this.apiAuth(request, reply)
},
},
controller,
)
}
}
}
/**
* controller
*/
initControllers() {
logger.info('Bootstrap controllers...')
const controllers = join(__dirname, './controllers')
fs.readdirSync(controllers)
.filter((file: string) => ~file.search(/^[^.].*\.(ts|js)$/))
.forEach((file: any) => {
// logger.log(file);
return require(join(controllers, file))
})
}
async connectDB() {
const options = {
useNewUrlParser: true,
poolSize: 5,
keepAlive: true,
keepAliveInitialDelay: 300000,
useUnifiedTopology: true,
}
const uri = config.db_main
logger.info(`connect to ${uri} ...`)
try {
// await mongoose.createConnection(uri, options)
await mongoose.connect(uri, options)
logger.log('DB Connected')
} catch (err) {
logger.log(`DB Connection Error: ${err.message}`)
}
let opts = { url: config.redis }
// new RedisClient(opts)
// logger.log('REDIS Connected')
}
private initSchedules() {
new BlocknumSchedule().scheduleAll()
}
private restoreChainQueue() {}
private setErrHandler() {
this.server.setNotFoundHandler(function (
request: any,
reply: { send: (arg0: { errcode: number; errmsg: string }) => void },
) {
reply.send({ errcode: 404, errmsg: 'page not found' })
})
this.server.setErrorHandler(function (error: FastifyError, request: FastifyRequest, reply: FastifyReply) {
let statusCode = (error && error.statusCode) || 100
if (statusCode >= 500) {
logger.error(error)
} else if (statusCode >= 400) {
logger.info(error)
} else {
logger.error(error)
}
reply.code(200).send({ errcode: statusCode, errmsg: error ? error.message : 'unknown error' })
})
}
/**
* ,
* {
* code: 0,
* msg?: '',
* data: any
* }
* @private
*/
private setFormatSend() {
this.server.addHook('preSerialization', async (request: FastifyRequest, reply: FastifyReply, payload) => {
reply.header('X-Powered-By', 'PHP/5.4.16')
// @ts-ignore
if (!payload.errcode) {
payload = {
errcode: 0,
data: payload,
}
}
return payload
})
}
public async start() {
let self = this
return new Promise(async (resolve, reject) => {
await self.connectDB()
self.initControllers()
self.registerRouter()
self.setErrHandler()
self.setFormatSend()
self.initSchedules()
restartAllUnFinishedTask()
this.server.listen({ port: config.api.port }, (err: any, address: any) => {
if (err) {
logger.log(err)
process.exit(0)
}
resolve && resolve(address)
})
})
}
}

12
src/api.ts Normal file
View File

@ -0,0 +1,12 @@
import { ApiServer } from './api.server'
import logger from './logger/logger'
class Server extends ApiServer {
constructor() {
super()
}
}
let server = new Server()
server.start().then(address => {
logger.log(`Api Server listening at ${address}`)
})

64
src/chain/BlockChain.ts Normal file
View File

@ -0,0 +1,64 @@
import { singleton } from 'decorators/singleton'
import logger from 'logger/logger'
import { ConfirmQueue } from 'queue/confirm.queue'
import Web3 from 'web3'
import { TransactionReceipt, AddedAccount } from 'web3-core'
import { ERC20Reactor } from './ERC20Reactor'
import { ERC721Reactor } from './ERC721Reactor'
@singleton
export class BlockChain {
private web3: Web3
instanceCacheMap: Map<string, any>
private accountMaster: AddedAccount
public erc20Reactor: ERC20Reactor
public erc721Reactor: ERC721Reactor
public confirmQueue: ConfirmQueue
public currentBlockNum: number = 0
constructor() {
this.web3 = new Web3(process.env.CHAIN_RPC_URL)
this.confirmQueue = new ConfirmQueue(this.web3)
let key = process.env.CHAIN_MASTER_KEY
this.accountMaster = this.web3.eth.accounts.wallet.add(key)
this.web3.eth.accounts.wallet.add(process.env.CHAIN_MINT_KEY)
this.web3.eth.accounts.wallet.add(process.env.CHAIN_ADMIN_KEY)
this.instanceCacheMap = new Map()
this.erc20Reactor = new ERC20Reactor(this.web3, process.env.CHAIN_FT_ADDRESS, process.env.CHAIN_FTLOCKER_ADDRESS)
this.erc721Reactor = new ERC721Reactor(
this.web3,
process.env.CHAIN_NFT_ADDRESS,
process.env.CHAIN_NFTLOCKER_ADDRESS,
)
// this.web3.eth.subscribe('newBlockHeaders', (error, event) => {
// if (!error) {
// console.log(event.number)
// return
// }
// console.log(error)
// })
}
public async getContractInstance(address: string, abi: any) {
if (!this.instanceCacheMap.has(address)) {
const instance = new this.web3.eth.Contract(abi, address, { from: this.accountMaster.address })
this.instanceCacheMap.set(address, instance)
}
return this.instanceCacheMap.get(address)
}
public async getTransactionReceipt(txHash: string) {
return this.web3.eth.getTransactionReceipt(txHash)
}
public async getTxConfirms(txhash: string) {
const receipt: TransactionReceipt = await this.getTransactionReceipt(txhash)
const latest = await this.web3.eth.getBlockNumber()
return latest - receipt.blockNumber + 1
}
public async updateCurrenBlockNum() {
this.currentBlockNum = await this.web3.eth.getBlockNumber()
logger.debug(`update block num: ${this.currentBlockNum}`)
}
}

3512
src/chain/Contracts.ts Normal file

File diff suppressed because it is too large Load Diff

204
src/chain/ERC20Reactor.ts Normal file
View File

@ -0,0 +1,204 @@
import { BN } from 'ethereumjs-util'
import Web3 from 'web3'
import { FT_ABI, FT_LOCKER_ABI } from './Contracts'
import { Contract } from 'web3-eth-contract'
import { Account } from 'web3-core'
export class ERC20Reactor {
private web3: Web3
private contract: Contract
private locker: Contract
private account: Account
private lockerAddress: string
constructor(web3: Web3, address: string, lockerAddress?: string) {
this.web3 = web3
this.account = this.web3.eth.accounts.wallet[0]
this.contract = new this.web3.eth.Contract(FT_ABI, address, { from: this.account.address })
if (lockerAddress) {
this.lockerAddress = lockerAddress
this.locker = new this.web3.eth.Contract(FT_LOCKER_ABI, lockerAddress, { from: this.account.address })
}
}
/**
* Get balance or count for current account on specific asset contract.
*
* @param address - Asset ERC20 contract address.
* @param selectedAddress - Current account public address.
* @returns Promise resolving to BN object containing balance for current account on specific asset contract.
*/
async getBalanceOf({ address, selectedAddress }: { address?: string; selectedAddress: string }): Promise<BN> {
const contract = address
? new this.web3.eth.Contract(FT_ABI, address, { from: this.account.address })
: this.contract
return new Promise<BN>((resolve, reject) => {
contract.methods.balanceOf(selectedAddress).call({ from: selectedAddress }, (error: Error, result: BN) => {
/* istanbul ignore if */
if (error) {
reject(error)
return
}
resolve(result)
})
})
}
/**
* Query for the decimals for a given ERC20 asset.
*
* @param address - ERC20 asset contract string.
* @returns Promise resolving to the 'decimals'.
*/
async getTokenDecimals(address?: string): Promise<string> {
const contract = address
? new this.web3.eth.Contract(FT_ABI, address, { from: this.account.address })
: this.contract
return new Promise<string>((resolve, reject) => {
contract.methods.decimals().call((error: Error, result: BN | string) => {
/* istanbul ignore if */
if (error) {
reject(error)
return
}
resolve(result.toString())
})
})
}
/**
* Query for symbol for a given ERC20 asset.
*
* @param address - ERC20 asset contract address.
* @returns Promise resolving to the 'symbol'.
*/
async getTokenSymbol(address?: string): Promise<string> {
const contract = address
? new this.web3.eth.Contract(FT_ABI, address, { from: this.account.address })
: this.contract
return new Promise<string>((resolve, reject) => {
contract.methods.symbol().call((error: Error, result: BN | string) => {
/* istanbul ignore if */
if (error) {
reject(error)
return
}
resolve(result.toString())
})
})
}
/**
* Query if a contract implements an interface.
*
* @param address - Asset contract address.
* @param userAddress - The public address for the currently active user's account.
* @returns Promise resolving an object containing the standard, decimals, symbol and balance of the given contract/userAddress pair.
*/
async getDetails({ address, userAddress }: { address?: string; userAddress: string }): Promise<{
standard: string
symbol: string | undefined
decimals: string | undefined
balance: BN | undefined
}> {
const [decimals, symbol] = await Promise.all([this.getTokenDecimals(address), this.getTokenSymbol(address)])
let balance
if (userAddress) {
balance = await this.getBalanceOf({ address, selectedAddress: userAddress })
}
return {
decimals,
symbol,
balance,
standard: 'ERC20',
}
}
async transfer({
address,
from,
to,
amount,
account,
gas,
}: {
address: string
from: string
to: string
account?: string
amount: number | string
gas?: number
}) {
const contract = new this.web3.eth.Contract(FT_ABI, address, { from: account || this.account.address })
const amountBN = Web3.utils.toBN(Web3.utils.toWei(amount + ''))
return contract.methods.transfer(to, amountBN).send({
gas: gas || 1000000,
})
}
async mint({ address, to, amount, account }: { account?: string; address?: string; to: string; amount: string }) {
const contract = address
? new this.web3.eth.Contract(FT_ABI, address, { from: account || this.account.address })
: this.contract
// amount = this.web3.utils.toWei(amount + '')
let amountBN = Web3.utils.toBN(Web3.utils.toWei(amount + ''))
let gas = await contract.methods.mint(to, amountBN).estimateGas({ gas: 1000000 })
return contract.methods.mint(to, amountBN).send({ gas: (gas * 1.1) | 0 })
}
async lock({ address, amount, account }: { account?: string; address?: string; amount: string }) {
address = address || this.contract.options.address
// amount = this.web3.utils.toWei(amount + '')
const contract = address
? new this.web3.eth.Contract(FT_ABI, address, { from: account || this.account.address })
: this.contract
let locker = account
? new this.web3.eth.Contract(FT_LOCKER_ABI, this.lockerAddress, { from: account })
: this.locker
const amountBN = Web3.utils.toBN(Web3.utils.toWei(amount + ''))
await contract.methods.increaseAllowance(locker.options.address, amountBN).send({ gas: 1000000 })
let gas = await locker.methods.lock(address, amountBN).estimateGas({ gas: 1000000 })
return locker.methods.lock(address, amountBN).send({ gas: (gas * 1.1) | 0 })
}
async unLock({ address, to, amount, account }: { account?: string; address?: string; to: string; amount: string }) {
address = address || this.contract.options.address
let locker = account
? new this.web3.eth.Contract(FT_LOCKER_ABI, this.lockerAddress, { from: account })
: this.locker
const contract = address
? new this.web3.eth.Contract(FT_ABI, address, { from: account || this.account.address })
: this.contract
const amountBN = Web3.utils.toBN(Web3.utils.toWei(amount + ''))
let gas = await locker.methods.unlock(address, to, amountBN).estimateGas({ gas: 1000000 })
return locker.methods.unlock(address, to, amountBN).send({ gas: (gas * 1.1) | 0 })
}
async getLockedNum({ address, account }: { address?: string; account: string }) {
address = address || this.contract.options.address
return this.locker.methods.lockedNum(address, account).call()
}
async getPastEvents({ address, fromBlock }: { address?: string; fromBlock: number }) {
const contract = address
? new this.web3.eth.Contract(FT_ABI, address, { from: this.account.address })
: this.contract
return contract.getPastEvents('Transfer', {
fromBlock,
toBlock: fromBlock + 50000,
})
}
async getPastLockEvents({ address, fromBlock }: { address?: string; fromBlock: number }) {
return this.locker.getPastEvents('Lock', {
fromBlock,
toBlock: fromBlock + 50000,
})
}
async getPastUnLockEvents({ address, fromBlock }: { address?: string; fromBlock: number }) {
return this.locker.getPastEvents('UnLock', {
fromBlock,
toBlock: fromBlock + 50000,
})
}
}

448
src/chain/ERC721Reactor.ts Normal file
View File

@ -0,0 +1,448 @@
import { timeoutFetch } from 'utils/net.util'
import { getFormattedIpfsUrl } from 'utils/wallet.util'
import Web3 from 'web3'
import { Contract } from 'web3-eth-contract'
import { NFT_ABI, NFT_LOCKER_ABI, PRESALE_ABI } from './Contracts'
import { Account } from 'web3-core'
import { runInThisContext } from 'vm'
export const ERC721 = 'ERC721'
export const ERC721_INTERFACE_ID = '0x80ac58cd'
export const ERC721_METADATA_INTERFACE_ID = '0x5b5e139f'
export const ERC721_ENUMERABLE_INTERFACE_ID = '0x780e9d63'
export class ERC721Reactor {
private web3: Web3
private contract: Contract
private locker: Contract
private account: Account
private lockerAddress: string
constructor(web3: Web3, address: string, lockerAddress?: string) {
this.web3 = web3
this.account = this.web3.eth.accounts.wallet[0]
this.contract = new this.web3.eth.Contract(NFT_ABI, address, { from: this.account.address })
if (lockerAddress) {
this.lockerAddress = lockerAddress
this.locker = new this.web3.eth.Contract(NFT_LOCKER_ABI, lockerAddress, { from: this.account.address })
}
}
/**
* Query if contract implements ERC721Metadata interface.
*
* @param address - ERC721 asset contract address.
* @returns Promise resolving to whether the contract implements ERC721Metadata interface.
*/
contractSupportsMetadataInterface = async (address?: string): Promise<boolean> => {
return this.contractSupportsInterface({ address, interfaceId: ERC721_METADATA_INTERFACE_ID })
}
/**
* Query if contract implements ERC721Enumerable interface.
*
* @param address - ERC721 asset contract address.
* @returns Promise resolving to whether the contract implements ERC721Enumerable interface.
*/
contractSupportsEnumerableInterface = async (address?: string): Promise<boolean> => {
return this.contractSupportsInterface({ address, interfaceId: ERC721_ENUMERABLE_INTERFACE_ID })
}
/**
* Query if contract implements ERC721 interface.
*
* @param address - ERC721 asset contract address.
* @returns Promise resolving to whether the contract implements ERC721 interface.
*/
contractSupportsBase721Interface = async (address?: string): Promise<boolean> => {
return this.contractSupportsInterface({ address, interfaceId: ERC721_INTERFACE_ID })
}
/**
* Enumerate assets assigned to an owner.
*
* @param address - ERC721 asset contract address.
* @param selectedAddress - Current account public address.
* @param index - A collectible counter less than `balanceOf(selectedAddress)`.
* @returns Promise resolving to token identifier for the 'index'th asset assigned to 'selectedAddress'.
*/
getCollectibleTokenId = async ({
address,
selectedAddress,
index,
}: {
address?: string
selectedAddress: string
index: number
}): Promise<string> => {
const contract = address
? new this.web3.eth.Contract(NFT_ABI, address, { from: this.account.address })
: this.contract
return new Promise<string>((resolve, reject) => {
contract.methods.tokenOfOwnerByIndex(selectedAddress, index).call((error: Error, result: string) => {
/* istanbul ignore if */
if (error) {
reject(error)
return
}
resolve(result)
})
})
}
getBalance = async ({ address, selectedAddress }: { address?: string; selectedAddress: string }): Promise<number> => {
const contract = address
? new this.web3.eth.Contract(NFT_ABI, address, { from: this.account.address })
: this.contract
return new Promise<number>((resolve, reject) => {
contract.methods.balanceOf(selectedAddress).call((error: Error, result: number) => {
/* istanbul ignore if */
if (error) {
reject(error)
return
}
resolve(result)
})
})
}
/**
* Query for tokenURI for a given asset.
*
* @param address - ERC721 asset contract address.
* @param tokenId - ERC721 asset identifier.
* @returns Promise resolving to the 'tokenURI'.
*/
getTokenURI = async ({ address, tokenId }: { address?: string; tokenId: string }): Promise<string> => {
const contract = address
? new this.web3.eth.Contract(NFT_ABI, address, { from: this.account.address })
: this.contract
const supportsMetadata = await this.contractSupportsMetadataInterface(address)
if (!supportsMetadata) {
throw new Error('Contract does not support ERC721 metadata interface.')
}
return new Promise<string>((resolve, reject) => {
contract.methods.tokenURI(tokenId).call((error: Error, result: string) => {
/* istanbul ignore if */
if (error) {
reject(error)
return
}
resolve(result)
})
})
}
/**
* Query for name for a given asset.
*
* @param address - ERC721 asset contract address.
* @returns Promise resolving to the 'name'.
*/
getAssetName = async (address?: string): Promise<string> => {
const contract = address
? new this.web3.eth.Contract(NFT_ABI, address, { from: this.account.address })
: this.contract
return new Promise<string>((resolve, reject) => {
contract.methods.name().call((error: Error, result: string) => {
/* istanbul ignore if */
if (error) {
reject(error)
return
}
resolve(result)
})
})
}
/**
* Query for symbol for a given asset.
*
* @param address - ERC721 asset contract address.
* @returns Promise resolving to the 'symbol'.
*/
getAssetSymbol = async (address?: string): Promise<string> => {
const contract = address
? new this.web3.eth.Contract(NFT_ABI, address, { from: this.account.address })
: this.contract
return new Promise<string>((resolve, reject) => {
contract.methods.symbol().call((error: Error, result: string) => {
/* istanbul ignore if */
if (error) {
reject(error)
return
}
resolve(result)
})
})
}
/**
* Query for owner for a given ERC721 asset.
*
* @param address - ERC721 asset contract address.
* @param tokenId - ERC721 asset identifier.
* @returns Promise resolving to the owner address.
*/
async getOwnerOf({ address, tokenId }: { address?: string; tokenId: string }): Promise<string> {
const contract = address
? new this.web3.eth.Contract(NFT_ABI, address, { from: this.account.address })
: this.contract
return new Promise<string>((resolve, reject) => {
contract.methods.ownerOf(tokenId).call((error: Error, result: string) => {
/* istanbul ignore if */
if (error) {
reject(error)
return
}
resolve(result)
})
})
}
/**
* Query if a contract implements an interface.
*
* @param address - Asset contract address.
* @param interfaceId - Interface identifier.
* @returns Promise resolving to whether the contract implements `interfaceID`.
*/
private contractSupportsInterface = async ({
address,
interfaceId,
}: {
address?: string
interfaceId: string
}): Promise<boolean> => {
const contract = address
? new this.web3.eth.Contract(NFT_ABI, address, { from: this.account.address })
: this.contract
return new Promise<boolean>((resolve, reject) => {
contract.methods.supportsInterface(interfaceId).call((error: Error, result: boolean) => {
/* istanbul ignore if */
if (error) {
reject(error)
return
}
resolve(result)
})
})
}
/**
* Query if a contract implements an interface.
*
* @param address - Asset contract address.
* @param ipfsGateway - The user's preferred IPFS gateway.
* @param tokenId - tokenId of a given token in the contract.
* @returns Promise resolving an object containing the standard, tokenURI, symbol and name of the given contract/tokenId pair.
*/
getDetails = async ({
address,
ipfsGateway,
tokenId,
}: {
address?: string
ipfsGateway: string
tokenId?: string
}): Promise<{
standard: string
tokenURI: string | undefined
symbol: string | undefined
name: string | undefined
image: string | undefined
}> => {
const isERC721 = await this.contractSupportsBase721Interface(address)
if (!isERC721) {
throw new Error("This isn't a valid ERC721 contract")
}
let tokenURI, image, symbol, name
// TODO upgrade to use Promise.allSettled for name/symbol when we can refactor to use es2020 in tsconfig
try {
symbol = await this.getAssetSymbol(address)
} catch {
// ignore
}
try {
name = await this.getAssetName(address)
} catch {
// ignore
}
if (tokenId) {
try {
tokenURI = await this.getTokenURI({ address, tokenId })
if (tokenURI.startsWith('ipfs://')) {
tokenURI = getFormattedIpfsUrl(ipfsGateway, tokenURI, true)
}
const response = await timeoutFetch(tokenURI)
const object = await response.json()
image = object ? object.image : ''
if (image.startsWith('ipfs://')) {
image = getFormattedIpfsUrl(ipfsGateway, image, true)
}
} catch {
// ignore
}
}
return {
standard: ERC721,
tokenURI,
symbol,
name,
image,
}
}
async transfer({
address,
from,
to,
tokenId,
account,
gas,
}: {
address?: string
from: string
to: string
tokenId: string
account?: string
gas?: number
}) {
const contract = address
? new this.web3.eth.Contract(NFT_ABI, address, { from: account || this.account.address })
: this.contract
return contract.methods.safeTransferFrom(from, to, tokenId).send({
from,
gas: gas || 1000000,
})
}
async mint({ address, to, tokenId, configId }: { address?: string; to: string; tokenId: string; configId: string }) {
const contract = address
? new this.web3.eth.Contract(NFT_ABI, address, { from: this.account.address })
: this.contract
let gas = await contract.methods.mint(to, tokenId, configId).estimateGas({ gas: 1000000 })
return contract.methods.mint(to, tokenId, configId).send({ gas: (gas * 1.1) | 0 })
}
async batchMint({
account,
address,
to,
tokenIds,
configIds,
}: {
account?: string
address?: string
to: string
tokenIds: string[]
configIds: string[]
}) {
const contract = address
? new this.web3.eth.Contract(NFT_ABI, address, { from: account || this.account.address })
: this.contract
let gas = await contract.methods.batchMint(to, tokenIds, configIds).estimateGas({ gas: 1000000 })
// try {
// let result = await contract.methods.batchMint(to, tokenIds, configIds).send({ gas: (gas * 1.1) | 0 })
// return result
// } catch (err) {
// throw new err()
// }
return contract.methods.batchMint(to, tokenIds, configIds).send({ gas: 1000000 })
}
async mintBox({
account,
address,
to,
tokenId,
nftType,
}: {
account?: string
address?: string
to: string
tokenId: string
nftType: string
}) {
const contract = address
? new this.web3.eth.Contract(PRESALE_ABI, address, { from: account || this.account.address })
: this.contract
let gas = await contract.methods.mintBox(to, tokenId, nftType).estimateGas({ gas: 1000000 })
return contract.methods.mintBox(to, tokenId, nftType).send({ gas: 1000000 })
}
async lock({ address, tokenId, account }: { account?: string; address?: string; tokenId: string }) {
address = address || this.contract.options.address
const contract = address
? new this.web3.eth.Contract(NFT_ABI, address, { from: this.account.address })
: this.contract
let locker = account
? new this.web3.eth.Contract(NFT_LOCKER_ABI, this.lockerAddress, { from: account })
: this.locker
await contract.methods.setApprovalForAll(locker.options.address, true).send({ gas: 1000000 })
let gas = await locker.methods.lock(address, tokenId).estimateGas({ gas: 1000000 })
return locker.methods.lock(address, tokenId).send({ gas: (gas * 1.1) | 0 })
}
async batchLock({ address, tokenIds, account }: { account?: string; address?: string; tokenIds: string[] }) {
address = address || this.contract.options.address
const contract = address
? new this.web3.eth.Contract(NFT_ABI, address, { from: account || this.account.address })
: this.contract
let locker = account
? new this.web3.eth.Contract(NFT_LOCKER_ABI, this.lockerAddress, { from: account })
: this.locker
await contract.methods.setApprovalForAll(locker.options.address, true).send({ gas: 1000000 })
let gas = await locker.methods.batchLock(address, tokenIds).estimateGas({ gas: 1000000 })
return locker.methods.batchLock(address, tokenIds).send({ gas: 1000000 })
}
async unLock({ address, to, tokenId, account }: { account?: string; address?: string; to: string; tokenId: string }) {
address = address || this.contract.options.address
let locker = account
? new this.web3.eth.Contract(NFT_LOCKER_ABI, this.lockerAddress, { from: account })
: this.locker
let gas = await locker.methods.unlock(address, to, tokenId).estimateGas({ gas: 1000000 })
return locker.methods.unlock(address, to, tokenId).send({ gas: (gas * 1.1) | 0 })
}
async getLockedNum({ address, account }: { address?: string; account: string }) {
address = address || this.contract.options.address
return this.locker.methods.lockedNum(address, account).call()
}
async getLockedNft({ address, account }: { address?: string; account: string }) {
address = address || this.contract.options.address
return this.locker.methods.lockedNft(address, account).call()
}
async getPastEvents({ address, fromBlock }: { address?: string; fromBlock: number }) {
const contract = address
? new this.web3.eth.Contract(NFT_ABI, address, { from: this.account.address })
: this.contract
return contract.getPastEvents('BatchMint', {
fromBlock,
toBlock: fromBlock + 50000,
})
}
async getPastLockEvents({ address, fromBlock }: { address?: string; fromBlock: number }) {
return this.locker.getPastEvents('Lock', {
fromBlock,
toBlock: fromBlock + 50000,
})
}
async getPastUnLockEvents({ address, fromBlock }: { address?: string; fromBlock: number }) {
return this.locker.getPastEvents('UnLock', {
fromBlock,
toBlock: fromBlock + 50000,
})
}
}

View File

@ -0,0 +1,89 @@
import Web3 from 'web3'
const DEFAULT_INTERVAL = 500
const DEFAULT_BLOCKS_TO_WAIT = 6
interface Options {
interval: number
blocksToWait: number
}
/**
* Wait for one or multiple transactions to confirm.
*
* @param web3
* @param txnHash A transaction hash or list of those
* @param options Wait timers
* @return Transaction receipt
*/
export function waitTransaction(web3: Web3, txnHash: string | string[], options: Options = null): Promise<any> {
const interval = options && options.interval ? options.interval : DEFAULT_INTERVAL
const blocksToWait = options && options.blocksToWait ? options.blocksToWait : DEFAULT_BLOCKS_TO_WAIT
var transactionReceiptAsync = async function (txnHash, resolve, reject) {
try {
var receipt = web3.eth.getTransactionReceipt(txnHash)
if (!receipt) {
setTimeout(function () {
transactionReceiptAsync(txnHash, resolve, reject)
}, interval)
} else {
if (blocksToWait > 0) {
var resolvedReceipt = await receipt
if (!resolvedReceipt || !resolvedReceipt.blockNumber)
setTimeout(function () {
transactionReceiptAsync(txnHash, resolve, reject)
}, interval)
else {
try {
var block = await web3.eth.getBlock(resolvedReceipt.blockNumber)
var current = await web3.eth.getBlock('latest')
if (current.number - block.number >= blocksToWait) {
var txn = await web3.eth.getTransaction(txnHash)
if (txn.blockNumber != null) resolve(resolvedReceipt)
else reject(new Error('Transaction with hash: ' + txnHash + ' ended up in an uncle block.'))
} else
setTimeout(function () {
transactionReceiptAsync(txnHash, resolve, reject)
}, interval)
} catch (e) {
setTimeout(function () {
transactionReceiptAsync(txnHash, resolve, reject)
}, interval)
}
}
} else resolve(receipt)
}
} catch (e) {
reject(e)
}
}
// Resolve multiple transactions once
if (Array.isArray(txnHash)) {
var promises = []
txnHash.forEach(function (oneTxHash) {
promises.push(waitTransaction(web3, oneTxHash, options))
})
return Promise.all(promises)
} else {
return new Promise(function (resolve, reject) {
transactionReceiptAsync(txnHash, resolve, reject)
})
}
}
/**
* Check if the transaction was success based on the receipt.
*
* https://ethereum.stackexchange.com/a/45967/620
*
* @param receipt Transaction receipt
*/
export function isSuccessfulTransaction(receipt: any): boolean {
if (receipt.status == '0x1' || receipt.status == 1) {
return true
} else {
return false
}
}

56
src/clock/Clock.ts Normal file
View File

@ -0,0 +1,56 @@
export class Clock {
public running: boolean = false
public paused: boolean = false
public deltaTime: number
public currentTime: number
public elapsedTime: number
protected now: Function =
(typeof window !== 'undefined' &&
window.performance &&
window.performance.now &&
window.performance.now.bind(window.performance)) ||
Date.now
protected _interval
constructor(useInterval: boolean = true) {
this.start(useInterval)
}
start(useInterval: boolean = true) {
this.deltaTime = 0
this.currentTime = this.now()
this.elapsedTime = 0
this.running = true
if (useInterval) {
// auto set interval to 60 ticks per second
this._interval = setInterval(this.tick.bind(this), 1000 / 60)
}
}
stop() {
this.running = false
if (this._interval) {
clearInterval(this._interval)
}
}
tick(newTime = this.now()) {
if (!this.paused) {
this.deltaTime = newTime - this.currentTime
this.elapsedTime += this.deltaTime
}
this.currentTime = newTime
}
pause() {
this.paused = true
}
resume() {
this.paused = false
}
}

50
src/clock/ClockTimer.ts Normal file
View File

@ -0,0 +1,50 @@
import { Delayed, Type } from './Delayed'
import { Clock } from './Clock'
export default class ClockTimer extends Clock {
delayed: Delayed[] = []
constructor(autoStart: boolean = false) {
super(autoStart)
}
tick() {
super.tick()
if (this.paused) {
return
}
let delayedList = this.delayed
let i = delayedList.length
while (i--) {
const delayed = delayedList[i]
if (delayed.active) {
delayed.tick(this.deltaTime)
} else {
delayedList.splice(i, 1)
continue
}
}
}
setInterval(handler: Function, time: number, ...args: any[]) {
let delayed = new Delayed(handler, args, time, Type.Interval)
this.delayed.push(delayed)
return delayed
}
setTimeout(handler: Function, time: number, ...args: any[]) {
let delayed = new Delayed(handler, args, time, Type.Timeout)
this.delayed.push(delayed)
return delayed
}
clear() {
let i = this.delayed.length
while (i--) {
this.delayed[i].clear()
}
this.delayed = []
}
}

61
src/clock/Delayed.ts Normal file
View File

@ -0,0 +1,61 @@
export enum Type {
Interval,
Timeout,
}
export class Delayed {
public active: boolean = true
public paused: boolean = false
public time: number
public elapsedTime: number = 0
protected handler: Function
protected args: any
protected type: number
constructor(handler: Function, args: any, time: number, type: number) {
this.handler = handler
this.args = args
this.time = time
this.type = type
}
tick(deltaTime: number) {
if (this.paused) {
return
}
this.elapsedTime += deltaTime
if (this.elapsedTime >= this.time) {
this.execute()
}
}
execute() {
this.handler.apply(this, this.args)
if (this.type === Type.Timeout) {
this.active = false
} else {
this.elapsedTime -= this.time
}
}
reset() {
this.elapsedTime = 0
}
pause() {
this.paused = true
}
resume() {
this.paused = false
}
clear() {
this.active = false
}
}

73
src/clock/Schedule.ts Normal file
View File

@ -0,0 +1,73 @@
import { singleton } from '../decorators/singleton'
import Clock from './ClockTimer'
import { Delayed } from './Delayed'
/**
*
*/
@singleton
export class Schedule {
clock: Clock = new Clock()
gameClock: Map<string, Delayed> = new Map()
public start() {
this.clock.start()
}
beginSchedule(millisecond: number, handler: Function, name: string): void {
if (this.gameClock.has(name) && this.gameClock.get(name)?.active) {
console.log(`当前已存在进行中的clock: ${name}`)
this.gameClock.get(name).clear()
this.gameClock.delete(name)
}
let timeOverFun = function () {
handler && handler()
}
this.gameClock.set(name, this.clock.setTimeout(timeOverFun, millisecond, name))
}
/**
*
*/
stopSchedule(name: string): number {
console.log(`manual stop schedule: ${name}`)
if (!this.gameClock.has(name)) {
return -1
}
let clock = this.gameClock.get(name)
if (!clock.active) {
this.gameClock.delete(name)
return -1
}
let time = clock.elapsedTime
clock.clear()
this.gameClock.delete(name)
return time
}
/**
* active
* @param {string} name
* @return {boolean}
*/
scheduleActive(name: string): boolean {
return this.gameClock.has(name) && this.gameClock.get(name).active
}
/**
*
* @param {string} name
* @return {number}
*/
getLeftTime(name: string) {
if (!this.gameClock.has(name)) {
return 0
}
let clock = this.gameClock.get(name)
if (!clock.active) {
this.gameClock.delete(name)
return 0
}
return clock.time - clock.elapsedTime
}
}

107
src/common/AsyncQueue.ts Normal file
View File

@ -0,0 +1,107 @@
type Callback<T> = () => Promise<T>
export type AsyncQueue<T = void> = {
push: (task: Callback<T>) => Promise<T>
flush: () => Promise<void>
size: number
}
/**
* Ensures that each callback pushed onto the queue is executed in series.
* Such a quetie 😻
* @param opts.dedupeConcurrent If dedupeConcurrent is `true` it ensures that if multiple
* tasks are pushed onto the queue while there is an active task, only the
* last one will be executed, once the active task has completed.
* e.g. in the below example, only 0 and 3 will be executed.
* ```
* const queue = createAsyncQueue({ dedupeConcurrent: true })
* queue.push(async () => console.log(0)) // returns 0
* queue.push(async () => console.log(1)) // returns 3
* queue.push(async () => console.log(2)) // returns 3
* queue.push(async () => console.log(3)) // returns 3
* ```
* */
export function createAsyncQueue<T = void>(opts = { dedupeConcurrent: false }): AsyncQueue<T> {
const { dedupeConcurrent } = opts
let queue: Callback<T>[] = []
let running: Promise<void> | undefined
let nextPromise = new DeferredPromise<T>()
const push = (task: Callback<T>) => {
let taskPromise = new DeferredPromise<T>()
if (dedupeConcurrent) {
queue = []
if (nextPromise.started) nextPromise = new DeferredPromise<T>()
taskPromise = nextPromise
}
queue.push(() => {
taskPromise.started = true
task().then(taskPromise.resolve).catch(taskPromise.reject)
return taskPromise.promise
})
if (!running) running = start()
return taskPromise.promise
}
const start = async () => {
while (queue.length) {
const task = queue.shift()!
await task().catch(() => {})
}
running = undefined
}
return {
push,
flush: () => running || Promise.resolve(),
get size() {
return queue.length
},
}
}
export const createAsyncQueues = <T = void>(opts = { dedupeConcurrent: false }) => {
const queues: { [queueId: string]: AsyncQueue<T> } = {}
const push = (queueId: string, task: Callback<T>) => {
if (!queues[queueId]) queues[queueId] = createAsyncQueue<T>(opts)
return queues[queueId].push(task)
}
const flush = (queueId: string) => {
if (!queues[queueId]) queues[queueId] = createAsyncQueue<T>(opts)
return queues[queueId].flush()
}
return { push, flush }
}
class DeferredPromise<T = void, E = any> {
started = false
resolve: (x: T | PromiseLike<T>) => void = () => {}
reject: (x: E) => void = () => {}
promise: Promise<T>
constructor() {
this.promise = new Promise<T>((res, rej) => {
this.resolve = res
this.reject = rej
})
}
}
// function main() {
// const queue = createAsyncQueue()
// queue.push(async () => {
// console.log(0)
// }) // returns 0
// queue.push(async () => {
// console.log(1)
// return new Promise((resolve, reject) => {
// setTimeout(() => {
// console.log('12')
// resolve()
// }, 1000)
// })
// }) // returns 3
// queue.push(async () => console.log(2)) // returns 3
// queue.push(async () => console.log(3)) // returns 3
// console.log('hi')
// }
// main()

6
src/common/Debug.ts Normal file
View File

@ -0,0 +1,6 @@
import debug from 'debug'
debug.log = console.info.bind(console)
export const error = debug('chain:error')
error.log = console.error.bind(console)

966
src/common/Extend.ts Normal file
View File

@ -0,0 +1,966 @@
/**
* 0
* @param value 0
* @param length
* @return 0
*/
function zeroize(value: number | string, length: number = 2): string {
let str = '' + value
let zeros = ''
for (let i = 0, len = length - str.length; i < len; i++) {
zeros += '0'
}
return zeros + str
}
/****************************************扩展Object****************************************/
interface Object {
/**
*
* key value
*
* @memberOf Object
*/
clone?(): Object
/**
* to
* @param to
*/
copyto?(to: Object): void
/**
*
* @param property
*/
getPropertyDescriptor?(property: string): PropertyDescriptor
zssign?(target: any): any
}
Object.defineProperties(Object.prototype, {
clone: {
value: function () {
let o = {}
for (let n in this) {
// @ts-ignore
o[n] = this[n]
}
return o
},
writable: true,
},
getPropertyDescriptor: {
value: function (property: string): any {
let data = Object.getOwnPropertyDescriptor(this, property)
if (data) {
return data
}
let prototype = Object.getPrototypeOf(this)
if (prototype) {
return prototype.getPropertyDescriptor(property)
}
return
},
writable: true,
},
copyto: {
value: function (to: Object) {
for (let p in this) {
if (!(p in to)) {
// 本身没有这个属性
// @ts-ignore
to[p] = this[p]
} else {
let data: PropertyDescriptor = to.getPropertyDescriptor(p)
if (data) {
if (data.set || data.writable) {
// 可进行赋值
// @ts-ignore
to[p] = this[p]
}
}
}
}
},
writable: true,
},
zssign: {
value: function (target: Object) {
if (target === undefined || target === null) {
throw new TypeError('Cannot convert undefined or null to object')
}
let output = Object(target)
for (let nextKey in this) {
if (!(nextKey in output)) {
// 本身没有这个属性
output[nextKey] = this[nextKey]
}
// else {
// let data: PropertyDescriptor = output.getPropertyDescriptor(nextKey);
// if (data) {
// if (data.set || data.writable) {// 可进行赋值
// output[nextKey] = this[nextKey];
// }
// }
// }
}
return output
},
writable: true,
},
})
/****************************************扩展Math****************************************/
interface Math {
/**
*
* Math.PI / 180
* @type {number}
* @memberOf Math
*/
DEG_TO_RAD: number
/**
*
* 180 / Math.PI
*/
RAD_TO_DEG: number
/**
*
*/
PI2: number
/**
* 90°
*
* @type {number}
* @memberOf Math
*/
PI_1_2: number
/**
*
* @param value
* @param min
* @param max
*/
clamp?(value: number, min: number, max: number): number
/**
* [min,max)
*/
random2?(min: number, max: number): number
}
Math.DEG_TO_RAD = Math.PI / 180
Math.RAD_TO_DEG = 180 / Math.PI
Math.PI2 = 2 * Math.PI
Math.PI_1_2 = Math.PI * 0.5
Math.clamp = (value, min, max) => {
if (value < min) {
value = min
}
if (value > max) {
value = max
}
return value
}
Math.random2 = (min, max) => {
return min + Math.random() * (max - min)
}
/****************************************扩展Number********************************************/
interface Number {
/**
* 0
* @param length
* @return 0
*/
zeroize?(length: number): string
/**
* `min` `max`minmax
* [min,max]
*
* @param {number} min
* @param {number} max
* @returns {boolean}
*/
between?(min: number, max: number): boolean
}
Object.defineProperties(Number.prototype, {
zeroize: {
value: function (this: number, length: number) {
return zeroize(this, length)
},
writable: true,
},
between: {
value: function (this: number, min: number, max: number) {
return min <= this && max >= this
},
writable: true,
},
})
/****************************************扩展String****************************************/
interface String {
/**
* {0}{1}{2}{a} {b}obj对应key替换key的数据替换
*/
substitute?(args: any[]): string
/**
* 0
* @param length
* @return 0
*/
zeroize?(length: number): string
/**
*
* <font color="#ff0000">hash的字符串并不一定唯一</font>
*/
hash?(): number
/**
*
*/
trueLength?(): number
/**
*
* */
cnLength?(): number
/**
*
* */
versionCompare?(target: string): number
}
Object.defineProperties(String.prototype, {
zeroize: {
value: function (length: number) {
return zeroize(this, length)
},
writable: true,
},
substitute: {
value: function (this: string) {
let len = arguments.length
if (len > 0) {
let obj: IArguments
if (len == 1) {
obj = arguments[0]
if (typeof obj !== 'object') {
obj = arguments
}
} else {
obj = arguments
}
if (obj instanceof Object && !(obj instanceof RegExp)) {
return this.replace(/\{(?:%([^{}]+)%)?([^{}]+)\}/g, function (match: string, handler: string, key: string) {
//检查key中是否为%开头,如果是,则尝试按方法处理
// @ts-ignore
let value = obj[key]
if (handler) {
//如果有处理器,拆分处理器
let func = String.subHandler[handler]
if (func) {
value = func(value)
}
}
return value !== undefined ? '' + value : match
})
}
}
return this.toString() //防止生成String对象ios反射String对象会当成一个NSDictionary处理
},
writable: true,
},
hash: {
value: function () {
let len = this.length
let hash = 5381
for (let i = 0; i < len; i++) {
hash += (hash << 5) + this.charCodeAt(i)
}
return hash & 0x7fffffff
},
writable: true,
},
trueLength: {
value: function () {
let arr: string[] = this.match(/[^x00-xff]/gi)
return this.length + (arr ? arr.length : 0)
},
writable: true,
},
cnLength: {
value: function () {
// /[\u2E80-\u9FBF]
let arr: string[] = this.match(/[^x00-xff]/gi)
return arr ? arr.length : 0
},
writable: true,
},
versionCompare: {
value: function (target: string): number {
const GTR = 1 //大于
const LSS = -1 //小于
const EQU = 0 //等于
if (!target) {
return GTR
}
let v1arr = String(this)
.split('.')
.map(function (a) {
return parseInt(a)
})
let v2arr = String(target)
.split('.')
.map(function (a) {
return parseInt(a)
})
let arrLen = Math.max(v1arr.length, v2arr.length)
let result
//排除错误调用
if (this == undefined || target == undefined) {
throw new Error()
}
//检查空字符串,任何非空字符串都大于空字符串
if (this.length == 0 && target.length == 0) {
return EQU
} else if (this.length == 0) {
return LSS
} else if (target.length == 0) {
return GTR
}
//循环比较版本号
for (let i = 0; i < arrLen; i++) {
result = versionComp(v1arr[i], v2arr[i])
if (result == EQU) {
continue
} else {
break
}
}
return result
function versionComp(n1: number, n2: number) {
if (typeof n1 != 'number') {
n1 = 0
}
if (typeof n2 != 'number') {
n2 = 0
}
if (n1 > n2) {
return GTR
} else if (n1 < n2) {
return LSS
} else {
return EQU
}
}
},
writable: true,
},
})
interface StringConstructor {
/**
* 0
* @param value 0
* @param length
* @return 0
*/
zeroize?: (value: number, length: number) => string
/**
* substitute的回调函数
*
* @type {Readonly<{ [index: string]: { (input: any): string } }>}
* @memberOf StringConstructor
*/
subHandler?: Readonly<{ [index: string]: { (input: any): string } }>
}
String.zeroize = zeroize
/****************************************扩展Date****************************************/
interface Date {
/**
*
*
* @param {string} mask
* @param {boolean} [local] UTC时间显示
* @returns {string}
*/
format(mask: string, local?: boolean): string
/**
* n天
* @param {number} days
* @return {Date}
*/
addDays(days: number): Date
}
Object.defineProperties(Date.prototype, {
format: {
value: function (mask: string, local?: boolean) {
let d: Date = this
// @ts-ignore
return mask.replace(/"[^"]*"|'[^']*'|(?:d{1,2}|m{1,2}|yy(?:yy)?|([hHMs])\1?)/g, function ($0: string) {
switch ($0) {
case 'd':
return gd()
case 'dd':
return zeroize(gd())
case 'M':
return gM() + 1
case 'MM':
return zeroize(gM() + 1)
case 'yy':
return (gy() + '').substr(2)
case 'yyyy':
return gy()
case 'h':
return gH() % 12 || 12
case 'hh':
return zeroize(gH() % 12 || 12)
case 'H':
return gH()
case 'HH':
return zeroize(gH())
case 'm':
return gm()
case 'mm':
return zeroize(gm())
case 's':
return gs()
case 'ss':
return zeroize(gs())
default:
return $0.substr(1, $0.length - 2)
}
})
function gd() {
return local ? d.getDate() : d.getUTCDate()
}
function gM() {
return local ? d.getMonth() : d.getUTCMonth()
}
function gy() {
return local ? d.getFullYear() : d.getUTCFullYear()
}
function gH() {
return local ? d.getHours() : d.getUTCHours()
}
function gm() {
return local ? d.getMinutes() : d.getUTCMinutes()
}
function gs() {
return local ? d.getSeconds() : d.getUTCSeconds()
}
},
writable: true,
},
addDays: {
value: function (days: number) {
this.setDate(this.getDate() + days)
return this
},
writable: true,
},
})
/****************************************扩展Array****************************************/
const enum ArraySort {
/**
*
*/
ASC = 0,
/**
*
*/
DESC = 1,
}
interface ArrayConstructor {
// binaryInsert<T>(partArr: T[], item: T, filter: { (tester: T, ...args): boolean }, ...args);
SORT_DEFAULT: { number: 0; string: ''; boolean: false }
}
/**
* Array排序时undefined
*/
Array.SORT_DEFAULT = {
number: 0,
string: '',
boolean: false,
}
Object.freeze(Array.SORT_DEFAULT)
interface Array<T> {
/**
*
*
* @param {T} t
* @returns {number}
*
* @member Array
*/
pushOnce?(t: T): number
/**
*
*
* @param {T} t
* @returns {boolean} true
* false
*/
zremove?(t: T): boolean
/**
*
* ,
* @param {(keyof T)[]} kArr
* @param {(boolean[] | ArraySort[])} [dArr]
* @returns {this}
*
* @member Array
*/
multiSort?(kArr: (keyof T)[], dArr?: boolean[] | ArraySort[]): this
/**
*
*
* @param {string} [key]
* @param {boolean} [descend]
*
* @member Array
*/
doSort?(key?: keyof T, descend?: boolean | ArraySort): this
doSort?(descend?: boolean | ArraySort, key?: keyof T): this
/**
* to
* to的数组长度会和当前数组一致
*
* @template T
* @param {Array<T>} to
*/
cloneTo?<T>(to: Array<T>): void
/**
* to中
*
* @template T
* @param {Array<T>} to
*
* @member ArrayConstructor
*/
appendTo?<T>(to: Array<T>): void
/**
* index位置的元素, slice效率高
* @param index
*/
spliceOne?(index: number): boolean
/**
*
*/
randomSort?(): void
/**
* object
* @param obj obj | | child字段的值 | child字段的数组
* @param child
*/
contains?<T>(obj: T | T[] | {} | {}[], child?: string): boolean
/**
*
* @param arr
*/
randomInsert?<T>(arr: Array<T>): void
/**
* n个元素
* @param count
*/
randomGet?<T>(count?: number): T[]
/**
* 1
*/
randomOne?<T>(): T
/**
* n个元素
* @param count
*/
randomRemove?<T>(count?: number): T[]
/**
* n位
* @param n n > 0 , n<0 左移
*/
moveElement?<T>(n: number): T[]
/**
*
* @param arr
*/
union?<T>(arr: T[]): T[]
/**
*
* @param arr
*/
intersect?<T>(arr: T[]): T[]
/**
* arr的差集
* @param arr
*/
difference?<T>(arr: T[]): T[]
/**
* Map
* @param {string} key map的key字段名
* @return {Map<any, T>}
*/
toMap?<T>(key: string): Map<any, T>
}
Object.defineProperties(Array.prototype, {
cloneTo: {
value: function <T>(this: T[], b: any[]) {
b.length = this.length
let len = this.length
b.length = len
for (let i = 0; i < len; i++) {
b[i] = this[i]
}
},
writable: true,
},
appendTo: {
value: function <T>(this: T[], b: any[]) {
let len = this.length
for (let i = 0; i < len; i++) {
b.push(this[i])
}
},
writable: true,
},
pushOnce: {
value: function <T>(this: T[], t: T) {
let idx = this.indexOf(t)
if (!~idx) {
idx = this.length
this.push(t)
}
return idx
},
writable: true,
},
zremove: {
value: function <T>(this: T[], t: T) {
let idx = this.indexOf(t)
if (~idx) {
this.splice(idx, 1)
return true
}
return false
},
writable: true,
},
doSort: {
value: function () {
let key: string, descend: boolean
let len = arguments.length
for (let i = 0; i < len; i++) {
let arg = arguments[i]
let t = typeof arg
if (t === 'string') {
key = arg
} else {
descend = !!arg
}
}
if (key) {
return this.sort((a: any, b: any) => (descend ? b[key] - a[key] : a[key] - b[key]))
} else {
return this.sort((a: any, b: any) => (descend ? b - a : a - b))
}
},
writable: true,
},
multiSort: {
value: function (kArr: string[], dArr?: boolean[] | boolean) {
let isArr = Array.isArray(dArr)
return this.sort((a: any, b: any): number => {
const def = Array.SORT_DEFAULT
for (let idx = 0, len = kArr.length; idx < len; idx++) {
let key = kArr[idx]
// @ts-ignore
let mode = isArr ? !!dArr[idx] : !!dArr
let av = a[key]
let bv = b[key]
let typea = typeof av
let typeb = typeof bv
if (typea == 'object' || typeb == 'object') {
return 0
} else if (typea != typeb) {
if (typea == 'undefined') {
// @ts-ignore
bv = def[typeb]
} else if (typeb == 'undefined') {
// @ts-ignore
av = def[typea]
} else {
return 0
}
}
if (av < bv) {
return mode ? 1 : -1
} else if (av > bv) {
return mode ? -1 : 1
} else {
continue
}
}
return 0
})
},
writable: true,
},
spliceOne: {
value: function (index: number): boolean {
if (index === -1 || index >= this.length) {
return false
}
const len = this.length - 1
for (let i = index; i < len; i++) {
this[i] = this[i + 1]
}
this.length = len
return true
},
writable: true,
},
randomSort: {
value: function <T>() {
for (let j, x, i = this.length; i; j = (Math.random() * i) | 0, x = this[--i], this[i] = this[j], this[j] = x) {}
},
writable: true,
},
contains: {
value: function <T>(obj: T | T[] | {} | {}[], child?: string): boolean {
let result = false
if (child) {
const isArr = Array.isArray(obj)
if (isArr) {
// @ts-ignore
if (obj[0].hasOwnProperty(child)) {
let set0 = new Set()
// @ts-ignore
for (let s of obj) {
// @ts-ignore
set0.add(s[child])
}
// @ts-ignore
let set1 = new Set(this.filter(x => set0.has(x)))
return set0.size === set1.size
} else {
// @ts-ignore
let set0 = new Set(obj)
let set1 = new Set(this.filter((x: {}) => set0.has(x)))
return set1.size === set0.size
}
} else {
if (obj.hasOwnProperty(child)) {
for (let sub of this) {
if (sub.hasOwnProperty(child)) {
// @ts-ignore
if (sub[child] === obj[child]) {
result = true
break
}
}
}
} else {
for (let sub of this) {
if (sub.hasOwnProperty(child)) {
// @ts-ignore
if (sub[child] === obj) {
result = true
break
}
}
}
}
}
} else {
// 不指定 比较字段 的话, 只处理2种情况
// 1: obj 为数组
// 2: obj 不是数组
if (Array.isArray(obj)) {
let set0 = new Set(obj)
// @ts-ignore
let set1 = new Set(this.filter(x => set0.has(x)))
return set1.size === set0.size
} else {
let idx = this.indexOf(obj)
return !!~idx
}
}
return result
},
writable: true,
},
randomInsert: {
value: function <T>(arr: Array<T>) {
const length = this.length
arr.forEach(value => {
this.splice(Math.random() * length, 0, value)
})
},
writable: true,
},
randomGet: {
value: function <T>(count: number = 1): T[] {
let shuffled: T[] = this.slice(0),
i = this.length,
min = i - count,
temp,
index
if (min < 0) {
return shuffled
}
while (i-- > min) {
index = Math.floor((i + 1) * Math.random())
temp = shuffled[index]
shuffled[index] = shuffled[i]
shuffled[i] = temp
}
return shuffled.slice(min)
},
writable: true,
},
randomOne: {
value: function <T>(): T {
let results = this.randomGet(1)
if (results.length > 0) {
return results[0]
} else {
return null
}
},
writable: true,
},
randomRemove: {
value: function <T>(count: number = 1): T[] {
let result = []
while (count-- > 0 && this.length > 0) {
let index = (Math.random() * this.length) | 0
result.push(...this.splice(index, 1))
}
return result
},
writable: true,
},
moveElement: {
value: function <T>(n: number): T[] {
if (Math.abs(n) > this.length) n = n % this.length
return this.slice(-n).concat(this.slice(0, -n))
},
writable: true,
},
union: {
value: function <T>(this: T[], b: any[]): T[] {
let a = this.concat(b)
return [...new Set(a)]
},
writable: true,
},
intersect: {
value: function <T>(this: T[], b: any[]): T[] {
let set0 = new Set(b)
let set1 = new Set(this.filter(x => set0.has(x)))
return [...set1]
},
writable: true,
},
difference: {
value: function <T>(this: T[], b: any[]): T[] {
let set0 = new Set(b)
let set1 = new Set(this.filter(x => !set0.has(x)))
return [...set1]
},
writable: true,
},
toMap: {
value: function <T>(this: T[], key: string) {
let result: Map<any, T> = new Map()
for (const o of this) {
// @ts-ignore
result.set(o[key], o)
}
return result
},
writable: true,
},
})
interface Map<K, V> {
/**
* V为number的Map, , V, set
* V为其他类型时, set
* @param key
* @param value
*/
inc?(key: K, value: V): number
}
Object.defineProperties(Map.prototype, {
inc: {
value: function <K, V>(key: K, value: V) {
if (typeof value == 'number') {
this.set(key, (this.get(key) || 0) + value)
} else {
this.set(key, value)
}
return this.get(key)
},
},
})

13
src/common/ZError.ts Normal file
View File

@ -0,0 +1,13 @@
import { FastifyError } from 'fastify'
export class ZError implements FastifyError {
code: string
statusCode?: number
message: string
name: string
constructor(statusCode: number, message: string) {
this.statusCode = statusCode
this.message = message
}
}

View File

@ -0,0 +1,6 @@
import fastify = require('fastify')
class BaseController {
aotoRoute(req: fastify.FastifyRequest, res) {}
}
export default BaseController

43
src/config/config.ts Normal file
View File

@ -0,0 +1,43 @@
import * as dotenv from 'dotenv'
const NODE_ENV = process.env.NODE_ENV || 'development'
dotenv.config()
let path
switch (process.env.NODE_ENV) {
case 'test':
path = `${__dirname}/../../.env.development`
break
case 'production':
path = `${__dirname}/../../.env.production`
break
default:
path = `${__dirname}/../../.env.development`
}
dotenv.config({ path: path, debug: NODE_ENV === 'development' })
let baseConfig = {
api: {
port: parseInt(process.env.API_PORT),
host: process.env.API_HOST,
token_secret: process.env.API_TOKEN_SECRET,
token_expiresIn: process.env.API_TOKEN_EXPIRESIN,
},
file: {
port: parseInt(process.env.FILE_PORT),
host: process.env.FILE_HOST,
token_secret: process.env.FILE_TOKEN_SECRET,
token_expiresIn: process.env.FILE_TOKEN_EXPIRESIN,
upload_location: process.env.FILE_UPLOAD_LOCATION,
show_url: process.env.FILE_SHOW_URL,
},
admin: {
port: parseInt(process.env.ADMIN_PORT),
token_secret: process.env.ADMIN_TOKEN_SECRET,
token_expiresIn: process.env.ADMIN_TOKEN_EXPIRESIN,
},
db_main: process.env.DB_MAIN,
db_second: process.env.DB_SECOND,
redis: process.env.REDIS,
susuHost: process.env.SUSU_HOST,
}
export default baseConfig

42
src/config/wallet.ts Normal file
View File

@ -0,0 +1,42 @@
export const ACCOUNTS = {
1: {
//MINT_FT
address: '0x87C2FbD9b469E41120C22a7a0E15857F0F575941',
key: '9c0b7c5625f79245ca168b655cd5a07cfa7bf2f9acaa7f4cf9109f9b522c81f2',
},
2: {
//MINT_NFT
address: '0x87C2FbD9b469E41120C22a7a0E15857F0F575941',
key: '9c0b7c5625f79245ca168b655cd5a07cfa7bf2f9acaa7f4cf9109f9b522c81f2',
},
3: {
//LOCK_FT
address: '0x2Ab567855cbFa6f49041bCEd49749D3fBfa8Dc00',
key: '0fe56c1461b1b8ef4d4cf10e86fde7aaa797024cd7d1c41dce35116094008cbf',
},
4: {
//UNLOCK_FT
address: '0x2Ab567855cbFa6f49041bCEd49749D3fBfa8Dc00',
key: '0fe56c1461b1b8ef4d4cf10e86fde7aaa797024cd7d1c41dce35116094008cbf',
},
5: {
//LOCK_NFT
address: '0x2Ab567855cbFa6f49041bCEd49749D3fBfa8Dc00',
key: '0fe56c1461b1b8ef4d4cf10e86fde7aaa797024cd7d1c41dce35116094008cbf',
},
6: {
//UNLOCK_NFT
address: '0x2Ab567855cbFa6f49041bCEd49749D3fBfa8Dc00',
key: '0fe56c1461b1b8ef4d4cf10e86fde7aaa797024cd7d1c41dce35116094008cbf',
},
7: {
//TRANSFER_FT
address: '0x2Ab567855cbFa6f49041bCEd49749D3fBfa8Dc00',
key: '0fe56c1461b1b8ef4d4cf10e86fde7aaa797024cd7d1c41dce35116094008cbf',
},
8: {
//TRANSFER_NFT
address: '0x2Ab567855cbFa6f49041bCEd49749D3fBfa8Dc00',
key: '0fe56c1461b1b8ef4d4cf10e86fde7aaa797024cd7d1c41dce35116094008cbf',
},
}

View File

@ -0,0 +1,45 @@
import BaseController from 'common/base.controller'
import { role, router } from 'decorators/router'
import { ChainTask, ChainTaskClass, TaskStatus } from 'models/ChainTask'
import { ReqTaskStatus, RequestTask } from 'models/RequestTask'
import { ChainQueue } from 'queue/chain.queue'
import { DocumentType } from '@typegoose/typegoose'
import { ConfirmQueue } from 'queue/confirm.queue'
import { BlockChain } from 'chain/BlockChain'
class ChainController extends BaseController {
@role('anon')
@router('post /client/login')
async clientLogin(req, res) {
const { code, token } = req.params
return {}
}
@role('anon')
@router('post /chain/req')
async addChainRequest(req, res) {
// data是一个数组!!
const { data, type, taskId, force, max } = req.params
let maxTryCount = max !== undefined ? parseInt(max) : parseInt(process.env.CHAIN_MAX_TRY)
let chainTask: DocumentType<ChainTaskClass> = await ChainTask.insertOrUpdate({ taskId }, { type, data })
if ((!chainTask.newRecord && force) || chainTask.newRecord) {
for (let sub of data) {
let subType = sub.type || type
let subTask = new RequestTask({
taskId,
chainTaskId: chainTask.id,
taskType: subType,
reqData: sub,
maxTryCount,
})
await subTask.save()
chainTask.tasks.pushOnce(subTask.id)
new ChainQueue().addTaskToQueue(subTask)
}
}
await chainTask.save()
return chainTask.toJson()
}
}
export default ChainController

18
src/decorators/dbconn.ts Normal file
View File

@ -0,0 +1,18 @@
import { mongoose } from '@typegoose/typegoose'
import config from 'config/config'
/**
* model指定数据库连接
* @param {string} name config中必须要有对应的配置 main db_main
* */
export function dbconn(name?: string) {
return target => {
name = name || 'main'
const url = config['db_' + name]
target['db'] = mongoose.createConnection(url, {
useNewUrlParser: true,
useCreateIndex: true,
useFindAndModify: false,
useUnifiedTopology: true,
})
}
}

29
src/decorators/nojson.ts Normal file
View File

@ -0,0 +1,29 @@
import 'reflect-metadata'
import { singleton } from './singleton'
@singleton
export class NoJsonClass {
private noJsonPropSet: Set<string> = new Set()
public addKey(className: string, propertyKey: string) {
this.noJsonPropSet.add(className + '_' + propertyKey)
}
public checkExist(className: string, propertyKey: string) {
return this.noJsonPropSet.has(className + '_' + propertyKey)
}
}
/**
* toJson方法输出的字段上加上 @noJson
* @return {{(target: Function): void, (target: Object, propertyKey: (string | symbol)): void}}
*/
export function noJson() {
// return Reflect.metadata(noJsonMetadataKey, !0)
return function (target: Object, propertyKey: string) {
new NoJsonClass().addKey(target.constructor.name, propertyKey)
}
}
export function checkJson(target: any, propertyKey: string) {
return !new NoJsonClass().checkExist(target.constructor.modelName, propertyKey)
}

142
src/decorators/router.ts Normal file
View File

@ -0,0 +1,142 @@
import BaseController from '../common/base.controller'
export class RouterData {
target?: any
method?: string
path?: string
fun?: Function
}
export class RouterMap {
static decoratedRouters: Map<
Function,
{
roles?: string[]
permissions?: string[][]
data?: RouterData[]
depts?: string[]
}
> = new Map()
}
export function router(route?: string) {
return (target: BaseController, name: string, value: PropertyDescriptor) => {
if (!route) {
const controller = target.constructor.name
const controllerName = controller.toLowerCase().replace('.controller', '')
route = 'all ' + ['', controllerName, name].join('/')
}
const split = route.split(' ')
if (split.length > 2) {
throw new Error('路由中只允许一个空格')
}
const [method, path] = split
// @ts-ignore
const key = target[name]
let routerData = new RouterData()
routerData.target = target
routerData.method = method
routerData.path = path
// @ts-ignore
routerData.fun = target[name]
if (RouterMap.decoratedRouters.has(key)) {
let objCurrent = RouterMap.decoratedRouters.get(key)
if (!objCurrent.data) {
objCurrent.data = [routerData]
} else {
objCurrent.data.push(routerData)
}
// @ts-ignore
RouterMap.decoratedRouters.set(target[name], objCurrent)
} else {
let routerObj = {
data: [routerData],
}
// @ts-ignore
RouterMap.decoratedRouters.set(target[name], routerObj)
}
}
}
export function role(roles?: string | string[]) {
return (target: BaseController, name: string, value: PropertyDescriptor) => {
let roleList: string[] = []
if (roles) {
if (Array.isArray(roles)) {
roleList = roles
} else {
roleList = [roles]
}
}
// @ts-ignore
const key = target[name]
let roleObj = { roles: roleList }
if (RouterMap.decoratedRouters.has(key)) {
let objCurrent = RouterMap.decoratedRouters.get(key)
Object.assign(objCurrent, roleObj)
// @ts-ignore
RouterMap.decoratedRouters.set(target[name], objCurrent)
} else {
// @ts-ignore
RouterMap.decoratedRouters.set(target[name], roleObj)
}
}
}
export function permission(permissions?: string | string[]) {
return (target: BaseController, name: string, value: PropertyDescriptor) => {
let permissionList: string[][] = [[]]
if (permissions) {
if (Array.isArray(permissions)) {
let arr = []
for (let sub of permissions) {
arr.push(sub.split(':'))
}
permissionList = arr
} else {
permissionList = [permissions.split(':')]
}
}
// @ts-ignore
const key = target[name]
let permissionObj = { permissions: permissionList }
if (RouterMap.decoratedRouters.has(key)) {
let objCurrent = RouterMap.decoratedRouters.get(key)
Object.assign(objCurrent, permissionObj)
// @ts-ignore
RouterMap.decoratedRouters.set(target[name], objCurrent)
} else {
// @ts-ignore
RouterMap.decoratedRouters.set(target[name], permissionObj)
}
}
}
/**
* dept修饰器的, id是否存在
*/
export function dept(depts?: string | string[]) {
return (target: BaseController, name: string, value: PropertyDescriptor) => {
let deptList: string[] = []
if (depts) {
if (Array.isArray(depts)) {
deptList = depts
} else {
deptList = [depts]
}
}
// @ts-ignore
const key = target[name]
let deptObj = { depts: deptList }
if (RouterMap.decoratedRouters.has(key)) {
let objCurrent = RouterMap.decoratedRouters.get(key)
Object.assign(objCurrent, deptObj)
// @ts-ignore
RouterMap.decoratedRouters.set(target[name], objCurrent)
} else {
// @ts-ignore
RouterMap.decoratedRouters.set(target[name], deptObj)
}
}
}

View File

@ -0,0 +1,29 @@
/**
* class
* 使:
* @singleton
* class Test {}
* new Test() === new Test() // returns `true`
* 使 decorator
* const TestSingleton = singleton(Test)
* new TestSingleton() === new TestSingleton() //returns 'true'
*/
export const SINGLETON_KEY = Symbol()
export type Singleton<T extends new (...args: any[]) => any> = T & {
[SINGLETON_KEY]: T extends new (...args: any[]) => infer I ? I : never
}
export const singleton = <T extends new (...args: any[]) => any>(classTarget: T) =>
new Proxy(classTarget, {
construct(target: Singleton<T>, argumentsList, newTarget) {
// Skip proxy for children
if (target.prototype !== newTarget.prototype) {
return Reflect.construct(target, argumentsList, newTarget)
}
if (!target[SINGLETON_KEY]) {
target[SINGLETON_KEY] = Reflect.construct(target, argumentsList, newTarget)
}
return target[SINGLETON_KEY]
},
})

2
src/logger/logger.ts Normal file
View File

@ -0,0 +1,2 @@
const logger = require('tracer').colorConsole({ dateformat: 'yyyy-mm-dd HH:MM:ss.L' })
export default logger

201
src/models/Base.ts Normal file
View File

@ -0,0 +1,201 @@
import { FindOrCreate } from '@typegoose/typegoose/lib/defaultClasses'
import { checkJson } from '../decorators/nojson'
import { plugin, ReturnModelType } from '@typegoose/typegoose'
// @ts-ignore
import findOrCreate from 'mongoose-findorcreate'
import { Connection } from 'mongoose'
import { ObjectId } from 'bson'
import { isTrue } from '../utils/string.util'
import { AnyParamConstructor } from '@typegoose/typegoose/lib/types'
const jsonExcludeKeys = ['updatedAt', '__v']
const saveExcludeKeys = ['createdAt', 'updatedAt', '__v', '_id']
@plugin(findOrCreate)
export abstract class BaseModule extends FindOrCreate {
static db: Connection
public updateFromReq(data: any) {
for (let key in data) {
if (saveExcludeKeys.indexOf(key) == -1) {
this[key] = data[key]
}
}
}
/**
*
* @param condition
* @param data
*/
public static insertOrUpdate<T extends BaseModule>(
this: ReturnModelType<AnyParamConstructor<T>>,
condition: any,
data: any,
) {
return this.findOneAndUpdate(condition, data, { upsert: true, new: true, setDefaultsOnInsert: true })
}
/**
*
* @param {string[]} ids
*/
public static deleteVirtual<T extends BaseModule>(this: ReturnModelType<AnyParamConstructor<T>>, ids: string[]) {
return this.updateMany(
// @ts-ignore
{
_id: { $in: ids },
},
{
$set: {
deleted: true,
deleteTime: new Date(),
},
},
)
}
/**
*
* @param data
* @param {boolean} json
*/
public static async pageQuery<T extends BaseModule>(
this: ReturnModelType<AnyParamConstructor<T>>,
data: any,
json: boolean = false,
) {
let { start, limit, page } = data
limit = +limit || 10
start = +start || (+page - 1) * limit || 0
// @ts-ignore
let { opt, sort } = this.parseQueryParam(data)
let records = await this.find(opt).sort(sort).skip(start).limit(limit)
let total = await this.countDocuments(opt)
if (json) {
records.map((o: T) => o.toJson())
}
return { records, total, start, limit }
}
public toJson() {
let result: any = {}
// @ts-ignore
for (let key in this._doc) {
if (checkJson(this, key + '') && jsonExcludeKeys.indexOf(key) == -1) {
result[key] = this[key]
}
}
return result
}
/**
*
* @param {{}} params req.params
* @param options
* sort: 排序 : {createdAt: 1} {_id: 1}
* opt: 设置一些特殊的过滤条件, {deleted: 0}
* timeKey: 如果需要查询创建时间, createdAt,
* matchKey: 指定关键字查询的匹配字段, string或[string]
*
* @return {{opt: any, sort: {_id: number}}}
*/
public static parseQueryParam(params: {}, options?: any) {
const opt: any = { deleted: false }
// @ts-ignore
let obj = this.schema.paths
for (let key in params) {
if (key !== 'sort' && obj.hasOwnProperty(key)) {
switch (obj[key].instance) {
case 'String':
opt[key] = { $regex: params[key], $options: 'i' }
break
case 'Number':
opt[key] = params[key]
break
case 'Array':
if (Array.isArray(params[key])) {
opt[key] = { $in: params[key] }
} else {
opt[key] = params[key]
}
break
case 'Date':
// TODO:
break
case 'Boolean':
opt[key] = isTrue(params[key])
break
case 'ObjectID':
if (/^[0-9a-fA-F]{24}$/.test(params[key])) {
opt[key] = new ObjectId(params[key])
}
break
}
}
}
if (params.hasOwnProperty('key') && params['key']) {
let orArr = []
if (options?.matchKey) {
if (Array.isArray(options?.matchKey)) {
for (let key in options?.matchKey) {
let _tmp = {}
_tmp[key] = { $regex: params['key'], $options: 'i' }
orArr.push(_tmp)
}
} else {
let _tmp = {}
_tmp[options.matchKey] = { $regex: params['key'], $options: 'i' }
orArr.push(_tmp)
}
} else {
for (let key in obj) {
if (obj[key].instance === 'String') {
let _tmp = {}
_tmp[key] = { $regex: params['key'], $options: 'i' }
orArr.push(_tmp)
}
}
}
Object.assign(opt, { $or: orArr })
}
let timeKey = options?.timeKey ? options.timeKey : 'createdAt'
if (params.hasOwnProperty('timeBegin') && !params.hasOwnProperty('timeEnd')) {
let timeBegin = params['timeBegin']
if (!(timeBegin instanceof Date)) {
timeBegin = new Date(parseInt(timeBegin))
}
opt[timeKey] = { $gte: timeBegin }
} else if (params.hasOwnProperty('timeBegin') && params.hasOwnProperty('timeEnd')) {
let timeBegin = params['timeBegin']
if (!(timeBegin instanceof Date)) {
timeBegin = new Date(parseInt(timeBegin))
}
let timeEnd = params['timeEnd']
if (!(timeEnd instanceof Date)) {
timeEnd = new Date(parseInt(timeEnd))
}
let tmpB = {}
tmpB[timeKey] = { $gte: timeBegin }
let tmpE = {}
tmpE[timeKey] = { $lte: timeEnd }
opt['$and'] = [tmpB, tmpE]
} else if (!params.hasOwnProperty('timeBegin') && params.hasOwnProperty('timeEnd')) {
let timeEnd = params['timeEnd']
if (!(timeEnd instanceof Date)) {
timeEnd = new Date(parseInt(timeEnd))
}
opt[timeKey] = { $lte: timeEnd }
}
if (options?.opt) {
Object.assign(opt, options.opt)
}
let sort = { _id: 1 }
if (params.hasOwnProperty('sort')) {
sort = params['sort']
}
return { opt, sort }
}
}

112
src/models/ChainTask.ts Normal file
View File

@ -0,0 +1,112 @@
import { recoverTypedSignature } from '@metamask/eth-sig-util'
import { getModelForClass, index, modelOptions, mongoose, pre, prop, Ref, Severity } from '@typegoose/typegoose'
import { dbconn } from 'decorators/dbconn'
import logger from 'logger/logger'
import { InfoSvr } from 'service/info.service'
import { BaseModule } from './Base'
import { ReqTaskStatus, RequestTask, RequestTaskClass } from './RequestTask'
export enum TaskStatus {
NOTSTART = 0,
PEDING = 1,
SUCCESS = 2,
PART_ERROR = 8,
ERROR = 9,
}
@dbconn()
@modelOptions({
schemaOptions: { collection: 'chain_task', timestamps: true },
options: { allowMixed: Severity.ALLOW },
})
export class ChainTaskClass extends BaseModule {
@prop({ required: true })
public taskId!: string
@prop({ type: mongoose.Schema.Types.Mixed })
public taskData: any
@prop({ enum: TaskStatus, default: TaskStatus.NOTSTART })
public status: TaskStatus
@prop()
public startTime: number
@prop()
public endTime: number
@prop({ required: true, default: true })
public newRecord: boolean
@prop({ required: true, default: false })
public allEnd: boolean
@prop({ required: true, default: 0 })
public successCount: number
@prop({ required: true, default: 0 })
public errorCount: number
@prop({ type: String, required: true, default: [] })
public tasks!: Array<string>
/**
* ()
*
* 1. request task
* 2. request task
* @param chainTaskId
*/
public static async checkStatus(chainTaskId: string) {
let record = await ChainTask.findById(chainTaskId)
let sCount = 0
let errCount = 0
for (let subId of record.tasks) {
let subData = await RequestTask.findById(subId)
if (subData.status === ReqTaskStatus.SUCCESS) {
sCount += 1
} else if (subData.status === ReqTaskStatus.ERROR) {
errCount += 1
}
}
record.successCount = sCount
record.errorCount = errCount
if (sCount === record.tasks.length) {
record.status = TaskStatus.SUCCESS
record.allEnd = true
} else {
record.allEnd = false
if (record.status === TaskStatus.NOTSTART && sCount > 0) {
record.status = TaskStatus.PEDING
} else if (errCount === record.tasks.length) {
record.status = TaskStatus.ERROR
record.allEnd = true
} else if (errCount + sCount === record.tasks.length) {
record.status = TaskStatus.PART_ERROR
record.allEnd = true
}
}
await record.save()
if (record.allEnd) {
setImmediate(async function () {
try {
let result = await new InfoSvr().reportTaskResult({
id: record.taskId,
result: record.status,
comment: `success: ${record.successCount}, errcor: ${record.errorCount}`,
})
logger.log(result)
} catch (err) {
logger.log(err)
}
})
}
}
public static async allUnFinishedTask() {
return ChainTask.find({ allEnd: false })
}
}
export const ChainTask = getModelForClass(ChainTaskClass, { existingConnection: ChainTaskClass['db'] })

136
src/models/RequestTask.ts Normal file
View File

@ -0,0 +1,136 @@
import { getModelForClass, DocumentType, modelOptions, mongoose, prop, Severity } from '@typegoose/typegoose'
import { BlockChain } from 'chain/BlockChain'
import { ACCOUNTS } from 'config/wallet'
import { dbconn } from 'decorators/dbconn'
import logger from 'logger/logger'
import { BaseModule } from './Base'
export enum TaskType {
UNKNOW = 0,
MINT_FT = 1,
MINT_NFT = 2,
LOCK_FT = 3,
UNLOCK_FT = 4,
LOCK_NFT = 5,
UNLOCK_NFT = 6,
TRANSFER_FT = 7,
TRANSFER_NFT = 8,
MINT_PRESALE_BOX = 9,
}
export enum ReqTaskStatus {
NOTSTART = 0,
PEDING = 1,
WAIT_CONFIRM = 2,
SUCCESS = 3,
REVERT = 8,
ERROR = 9,
}
@dbconn()
@modelOptions({
schemaOptions: { collection: 'chain_request_task', timestamps: true },
options: { allowMixed: Severity.ALLOW },
})
export class RequestTaskClass extends BaseModule {
@prop({ required: true })
public taskId!: string
@prop({ required: true })
public chainTaskId!: string
@prop({ enum: TaskType, default: TaskType.UNKNOW })
public taskType: TaskType
@prop({ required: true, default: 0 })
public tryCount: number
@prop({ required: true, default: 0 })
public maxTryCount: number
/**
* address: string
*/
@prop({ type: mongoose.Schema.Types.Mixed })
public reqData: any
@prop({ enum: ReqTaskStatus, default: ReqTaskStatus.NOTSTART })
public status: ReqTaskStatus
@prop({ required: true, default: true })
public newRecord: boolean
@prop()
public startTime: number
@prop()
public endTime: number
@prop()
public txHash: string
/**
* block num
*/
@prop()
public blockAdd: number
/**
* block num
*/
@prop()
public blockReq: number
@prop({ type: mongoose.Schema.Types.Mixed, default: [] })
public errMsg: any[]
public async requestChain(this: DocumentType<RequestTaskClass>) {
let result
let self = this
self.blockReq = new BlockChain().currentBlockNum
await self.save()
let accountCfg = ACCOUNTS[self.taskType]
let account
if (accountCfg) {
account = accountCfg.address
self.reqData.account = account
}
switch (self.taskType) {
case TaskType.MINT_FT:
result = await new BlockChain().erc20Reactor.mint(self.reqData)
break
case TaskType.MINT_NFT:
result = await new BlockChain().erc721Reactor.batchMint(self.reqData)
break
case TaskType.LOCK_FT:
result = await new BlockChain().erc20Reactor.lock(self.reqData)
break
case TaskType.UNLOCK_FT:
result = await new BlockChain().erc20Reactor.unLock(self.reqData)
break
case TaskType.LOCK_NFT:
result = await new BlockChain().erc721Reactor.batchLock(self.reqData)
break
case TaskType.UNLOCK_NFT:
result = await new BlockChain().erc721Reactor.unLock(self.reqData)
break
case TaskType.TRANSFER_FT:
result = await new BlockChain().erc20Reactor.transfer(self.reqData)
break
case TaskType.TRANSFER_NFT:
result = await new BlockChain().erc721Reactor.transfer(self.reqData)
break
case TaskType.MINT_PRESALE_BOX:
result = await new BlockChain().erc721Reactor.mintBox(self.reqData)
break
}
logger.info(result)
let { transactionHash } = result
self.txHash = transactionHash
self.status = ReqTaskStatus.WAIT_CONFIRM
await self.save()
}
public static async allUnFinishedTask(chainTaskId: string) {
return RequestTask.find({ chainTaskId, status: { $ne: ReqTaskStatus.SUCCESS } })
}
}
export const RequestTask = getModelForClass(RequestTaskClass, { existingConnection: RequestTaskClass['db'] })

49
src/plugins/apiauth.ts Normal file
View File

@ -0,0 +1,49 @@
import { FastifyPluginAsync, FastifyReply, FastifyRequest } from 'fastify'
import fastifyPlugin from 'fastify-plugin'
declare module 'fastify' {
interface FastifyRequest {
roles?: string[]
user?: any
token?: string
}
interface FastifyInstance {
apiAuth: (request: FastifyRequest, reply: FastifyReply) => {}
}
}
export interface ApiAuthOptions {
secret: string
expiresIn: string
}
const apiAuthPlugin: FastifyPluginAsync<ApiAuthOptions> = async function (fastify, opts) {
fastify.register(require('fastify-jwt'), {
secret: opts.secret,
sign: { expiresIn: opts.expiresIn },
})
// 只有路由配置的role为anon才不需要过滤
fastify.decorate('apiAuth', async function (request: FastifyRequest, reply: FastifyReply) {
if (!request.roles || request.roles.indexOf('anon') == -1) {
try {
if (!request.token) {
return reply.send({ code: 11, msg: 'need login' })
}
//@ts-ignore
const data = this.jwt.verify(request.token)
if (!data || !data.id) {
return reply.send({ code: 10, msg: 'need login' })
}
// let account = await Account.findById(data.id)
// if (!account) {
// return reply.send({ code: 10, msg: 'need login' })
// }
// request.user = account
} catch (err) {
return reply.send({ code: 401, msg: 'need auth' })
}
}
})
}
export default fastifyPlugin(apiAuthPlugin, '3.x')

26
src/plugins/zReqParser.ts Normal file
View File

@ -0,0 +1,26 @@
import { FastifyInstance, FastifyPluginAsync, FastifyReply, FastifyRequest } from 'fastify'
import fastifyPlugin from 'fastify-plugin'
/**
* post get req.params
*/
declare module 'fastify' {
interface FastifyInstance {
zReqParser: (request: FastifyRequest, reply: FastifyReply) => {}
}
}
const zReqParserPlugin: FastifyPluginAsync = async function (fastify: FastifyInstance, options?: any) {
fastify.addHook('preValidation', async (request: FastifyRequest, reply: FastifyReply) => {
let params = request.params || {}
if (request.query) {
Object.assign(params, request.query)
}
if (request.body) {
Object.assign(params, request.body)
}
request.params = params
})
return
}
export default fastifyPlugin(zReqParserPlugin, '3.x')

View File

@ -0,0 +1,62 @@
import { FastifyInstance, FastifyPluginAsync, FastifyReply, FastifyRequest } from 'fastify'
import fastifyPlugin from 'fastify-plugin'
const getTokenFromHeader = function (request) {
let token: string | undefined
if (request.headers && request.headers.authorization) {
const parts = request.headers.authorization.split(' ')
if (parts.length === 2) {
const scheme = parts[0]
if (/^Bearer$/i.test(scheme)) {
token = parts[1]
}
}
}
return token
}
const getTokenFromCookie = function (request) {
let token: string | undefined
if (request.cookies) {
if (request.cookies['token']) {
token = request.cookies['token']
}
}
return token
}
const getTokenFromParams = function (request) {
let token: string | undefined
token = request.params && request.params.token
return token
}
const getTokenFromQuery = function (request) {
let token: string | undefined
token = request.query && request.query.token
return token
}
const getTokenFromBody = function (request) {
let token: string | undefined
token = request.body && request.body.token
return token
}
const zTokenParserPlugin: FastifyPluginAsync = async function (fastify: FastifyInstance, options?: any) {
fastify.addHook('preValidation', async (request: FastifyRequest, reply: FastifyReply) => {
request['token'] =
getTokenFromHeader(request) ||
getTokenFromCookie(request) ||
getTokenFromParams(request) ||
getTokenFromQuery(request) ||
getTokenFromBody(request)
})
return
}
/**
* request的header, cookie, params, query和body中获取token, request.token中
* header中的字段key为authorization, Bearer xxxx
* key都为 token
*/
export default fastifyPlugin(zTokenParserPlugin, '3.x')

26
src/plugins/zrbac.ts Normal file
View File

@ -0,0 +1,26 @@
import { FastifyInstance, FastifyPluginAsync } from 'fastify'
import fastifyPlugin from 'fastify-plugin'
import RBAC from 'fast-rbac'
declare module 'fastify' {
interface FastifyInstance {
/**
* RBAC interface
*/
rbac: RBAC
}
}
const zRBACPlugin: FastifyPluginAsync = async function fastifyMetrics(
fastify: FastifyInstance,
options?: RBAC.Options,
) {
const rbac = new RBAC(options)
fastify.decorate('rbac', rbac)
return
}
export = fastifyPlugin(zRBACPlugin, {
fastify: '>=3.0.0',
name: 'zrbac',
})

61
src/queue/chain.queue.ts Normal file
View File

@ -0,0 +1,61 @@
import { AsyncQueue, createAsyncQueue } from 'common/AsyncQueue'
import { singleton } from 'decorators/singleton'
import { DocumentType } from '@typegoose/typegoose'
import { ReqTaskStatus, RequestTaskClass } from 'models/RequestTask'
import { BlockChain } from 'chain/BlockChain'
import { ChainTask } from 'models/ChainTask'
import logger from 'logger/logger'
@singleton
export class ChainQueue {
private queue: AsyncQueue
private blockChain: BlockChain
constructor() {
this.queue = createAsyncQueue()
this.blockChain = new BlockChain()
}
public async addTaskToQueue(subTask: DocumentType<RequestTaskClass>) {
if (subTask.maxTryCount && subTask.tryCount > subTask.maxTryCount) {
subTask.status = ReqTaskStatus.ERROR
await subTask.save()
await ChainTask.checkStatus(subTask.chainTaskId)
return
}
if (subTask.status === ReqTaskStatus.NOTSTART) {
subTask.blockAdd = this.blockChain.currentBlockNum
await subTask.save()
}
if (subTask.status === ReqTaskStatus.WAIT_CONFIRM) {
this.blockChain.confirmQueue.addTaskToQueue(subTask)
return
}
this.queue.push(async () => {
try {
subTask.tryCount += 1
if (subTask.status === ReqTaskStatus.NOTSTART) {
subTask.status = ReqTaskStatus.PEDING
}
if (!subTask.startTime) {
subTask.startTime = Date.now()
}
await subTask.save()
try {
await subTask.requestChain()
} catch (reqerr) {
logger.info(reqerr)
subTask.errMsg.push(JSON.stringify(reqerr))
await subTask.save()
// TODO:: 要排除数据已经提交到链上, 返回过程中的网络错误
this.addTaskToQueue(subTask)
return
}
this.blockChain.confirmQueue.addTaskToQueue(subTask)
} catch (err) {
subTask.errMsg.push(err)
await subTask.save()
}
})
}
}

View File

@ -0,0 +1,43 @@
import { AsyncQueue, createAsyncQueue } from 'common/AsyncQueue'
import { singleton } from 'decorators/singleton'
import { DocumentType } from '@typegoose/typegoose'
import { ReqTaskStatus, RequestTaskClass } from 'models/RequestTask'
import Web3 from 'web3'
import { isSuccessfulTransaction, waitTransaction } from 'chain/TransactionConfirm'
import { ChainTask } from 'models/ChainTask'
import { ChainQueue } from './chain.queue'
@singleton
export class ConfirmQueue {
private queue: AsyncQueue
private web3: Web3
constructor(web3: Web3) {
this.queue = createAsyncQueue()
this.web3 = web3
}
public addTaskToQueue(task: DocumentType<RequestTaskClass>) {
this.queue.push(async () => {
try {
let receipt = await waitTransaction(this.web3, task.txHash)
console.log(`receipt confirmed: ${task.txHash}`)
if (isSuccessfulTransaction(receipt)) {
task.status = ReqTaskStatus.SUCCESS
task.endTime = Date.now()
await task.save()
await ChainTask.checkStatus(task.chainTaskId)
} else {
task.status = ReqTaskStatus.REVERT
await task.save()
new ChainQueue().addTaskToQueue(task)
}
} catch (err) {
console.log(err)
task.errMsg.push(err)
await task.save()
new ChainQueue().addTaskToQueue(task)
}
})
}
}

297
src/redis/RedisClient.ts Normal file
View File

@ -0,0 +1,297 @@
import redis from 'redis'
import { promisify } from 'util'
import { singleton } from '../decorators/singleton'
type Callback = (...args: any[]) => void
@singleton
export class RedisClient {
public pub: redis.RedisClient
public sub: redis.RedisClient
protected subscribeAsync: any
protected unsubscribeAsync: any
protected publishAsync: any
protected subscriptions: { [channel: string]: Callback[] } = {}
protected smembersAsync: any
protected sismemberAsync: any
protected hgetAsync: any
protected hlenAsync: any
protected pubsubAsync: any
protected incrAsync: any
protected decrAsync: any
constructor(opts?: redis.ClientOpts) {
this.sub = redis.createClient(opts)
this.pub = redis.createClient(opts)
// no listener limit
this.sub.setMaxListeners(0)
// create promisified pub/sub methods.
this.subscribeAsync = promisify(this.sub.subscribe).bind(this.sub)
this.unsubscribeAsync = promisify(this.sub.unsubscribe).bind(this.sub)
this.publishAsync = promisify(this.pub.publish).bind(this.pub)
// create promisified redis methods.
this.smembersAsync = promisify(this.pub.smembers).bind(this.pub)
this.sismemberAsync = promisify(this.pub.sismember).bind(this.pub)
this.hlenAsync = promisify(this.pub.hlen).bind(this.pub)
this.hgetAsync = promisify(this.pub.hget).bind(this.pub)
this.pubsubAsync = promisify(this.pub.pubsub).bind(this.pub)
this.decrAsync = promisify(this.pub.decr).bind(this.pub)
this.incrAsync = promisify(this.pub.incr).bind(this.pub)
}
public async subscribe(topic: string, callback: Callback) {
if (!this.subscriptions[topic]) {
this.subscriptions[topic] = []
}
this.subscriptions[topic].push(callback)
if (this.sub.listeners('message').length === 0) {
this.sub.addListener('message', this.handleSubscription)
}
await this.subscribeAsync(topic)
return this
}
public async unsubscribe(topic: string, callback?: Callback) {
if (callback) {
const index = this.subscriptions[topic].indexOf(callback)
this.subscriptions[topic].splice(index, 1)
} else {
this.subscriptions[topic] = []
}
if (this.subscriptions[topic].length === 0) {
await this.unsubscribeAsync(topic)
}
return this
}
public async publish(topic: string, data: any) {
if (data === undefined) {
data = false
}
await this.publishAsync(topic, JSON.stringify(data))
}
public async exists(roomId: string): Promise<boolean> {
return (await this.pubsubAsync('channels', roomId)).length > 0
}
public async setex(key: string, value: string, seconds: number) {
return new Promise(resolve => this.pub.setex(key, seconds, value, resolve))
}
public async expire(key: string, seconds: number) {
return new Promise(resolve => this.pub.expire(key, seconds, resolve))
}
public async get(key: string) {
return new Promise((resolve, reject) => {
this.pub.get(key, (err, data) => {
if (err) {
return reject(err)
}
resolve(data)
})
})
}
public async del(roomId: string) {
return new Promise(resolve => {
this.pub.del(roomId, resolve)
})
}
public async sadd(key: string, value: any) {
return new Promise(resolve => {
this.pub.sadd(key, value, resolve)
})
}
public async smembers(key: string): Promise<string[]> {
return await this.smembersAsync(key)
}
public async sismember(key: string, field: string): Promise<number> {
return await this.sismemberAsync(key, field)
}
public async srem(key: string, value: any) {
return new Promise(resolve => {
this.pub.srem(key, value, resolve)
})
}
public async scard(key: string) {
return new Promise((resolve, reject) => {
this.pub.scard(key, (err, data) => {
if (err) {
return reject(err)
}
resolve(data)
})
})
}
public async srandmember(key: string) {
return new Promise((resolve, reject) => {
this.pub.srandmember(key, (err, data) => {
if (err) {
return reject(err)
}
resolve(data)
})
})
}
public async sinter(...keys: string[]) {
return new Promise<string[]>((resolve, reject) => {
this.pub.sinter(...keys, (err, data) => {
if (err) {
return reject(err)
}
resolve(data)
})
})
}
public async zadd(key: string, value: any, member: string) {
return new Promise(resolve => {
this.pub.zadd(key, value, member, resolve)
})
}
public async zrangebyscore(key: string, min: number, max: number) {
return new Promise((resolve, reject) => {
this.pub.zrangebyscore(key, min, max, 'withscores', (err, data) => {
if (err) {
return reject(err)
}
resolve(data)
})
})
}
public async zcard(key: string) {
return new Promise((resolve, reject) => {
this.pub.zcard(key, (err, data) => {
if (err) {
return reject(err)
}
resolve(data)
})
})
}
public async zcount(key: string, min: number, max: number) {
return new Promise((resolve, reject) => {
this.pub.zcount(key, min, max, (err, data) => {
if (err) {
return reject(err)
}
resolve(data)
})
})
}
public async zrevrank(key: string, member: string) {
return new Promise((resolve, reject) => {
this.pub.zrevrank(key, member, (err, data) => {
if (err) {
return reject(err)
}
resolve(data)
})
})
}
public async zscore(key: string, member: string) {
return new Promise((resolve, reject) => {
this.pub.zscore(key, member, (err, data) => {
if (err) {
return reject(err)
}
resolve(data)
})
})
}
public async zrevrange(key: string, start: number, end: number) {
return new Promise((resolve, reject) => {
this.pub.zrevrange(key, start, end, 'withscores', (err, data) => {
if (err) {
return reject(err)
}
resolve(data)
})
})
}
public async hset(key: string, field: string, value: string) {
return new Promise(resolve => {
this.pub.hset(key, field, value, resolve)
})
}
public async hincrby(key: string, field: string, value: number) {
return new Promise(resolve => {
this.pub.hincrby(key, field, value, resolve)
})
}
public async hget(key: string, field: string) {
return await this.hgetAsync(key, field)
}
public async hgetall(key: string) {
return new Promise<{ [key: string]: string }>((resolve, reject) => {
this.pub.hgetall(key, (err, values) => {
if (err) {
return reject(err)
}
resolve(values)
})
})
}
public async hdel(key: string, field: string) {
return new Promise((resolve, reject) => {
this.pub.hdel(key, field, (err, ok) => {
if (err) {
return reject(err)
}
resolve(ok)
})
})
}
public async hlen(key: string): Promise<number> {
return await this.hlenAsync(key)
}
public async incr(key: string): Promise<number> {
return await this.incrAsync(key)
}
public async decr(key: string): Promise<number> {
return await this.decrAsync(key)
}
protected handleSubscription = (channel: string, message: string) => {
if (this.subscriptions[channel]) {
for (let i = 0, l = this.subscriptions[channel].length; i < l; i++) {
this.subscriptions[channel][i](JSON.parse(message))
}
}
}
}

View File

@ -0,0 +1,15 @@
import { BlockChain } from 'chain/BlockChain'
import { singleton } from 'decorators/singleton'
import * as schedule from 'node-schedule'
@singleton
export default class BlocknumSchedule {
parseAllRecord() {
new BlockChain().updateCurrenBlockNum()
}
scheduleAll() {
const job = schedule.scheduleJob('*/5 * * * * *', async () => {
await this.parseAllRecord()
})
}
}

View File

@ -0,0 +1,17 @@
import logger from 'logger/logger'
import { ChainTask } from 'models/ChainTask'
import { RequestTask } from 'models/RequestTask'
import { ChainQueue } from 'queue/chain.queue'
export async function restartAllUnFinishedTask() {
let chainTasks = await ChainTask.allUnFinishedTask()
logger.info(`restore ${chainTasks.length} chain tasks`)
let chainQueue = new ChainQueue()
for (let cTask of chainTasks) {
let subTasks = await RequestTask.allUnFinishedTask(cTask.id)
logger.info(`restore ${subTasks.length} req tasks fro ${cTask.id}`)
for (let subTask of subTasks) {
chainQueue.addTaskToQueue(subTask)
}
}
}

View File

@ -0,0 +1,22 @@
import axios from 'axios'
import { singleton } from 'decorators/singleton'
const REPORT_TASK_URI = '/api/flow/client/result'
@singleton
export class InfoSvr {
reportTaskResult(data) {
data.user = process.env.RUN_USER
console.log('report to info svr: ' + JSON.stringify(data))
let url = `${process.env.INFO_SVR_HOST}${REPORT_TASK_URI}`
let reqConfig: any = {
method: 'post',
url,
headers: {
'Content-Type': 'application/json',
},
data: JSON.stringify(data),
}
return axios(reqConfig)
}
}

116
src/utils/net.util.ts Normal file
View File

@ -0,0 +1,116 @@
const TIMEOUT_ERROR = new Error('timeout')
const hexRe = /^[0-9A-Fa-f]+$/gu
/**
* Execute fetch and verify that the response was successful.
*
* @param request - Request information.
* @param options - Fetch options.
* @returns The fetch response.
*/
export async function successfulFetch(request: string, options?: RequestInit) {
const response = await fetch(request, options)
if (!response.ok) {
throw new Error(`Fetch failed with status '${response.status}' for request '${request}'`)
}
return response
}
/**
* Execute fetch and return object response.
*
* @param request - The request information.
* @param options - The fetch options.
* @returns The fetch response JSON data.
*/
export async function handleFetch(request: string, options?: RequestInit) {
const response = await successfulFetch(request, options)
const object = await response.json()
return object
}
/**
* Execute fetch and return object response, log if known error thrown, otherwise rethrow error.
*
* @param request - the request options object
* @param request.url - The request url to query.
* @param request.options - The fetch options.
* @param request.timeout - Timeout to fail request
* @param request.errorCodesToCatch - array of error codes for errors we want to catch in a particular context
* @returns The fetch response JSON data or undefined (if error occurs).
*/
export async function fetchWithErrorHandling({
url,
options,
timeout,
errorCodesToCatch,
}: {
url: string
options?: RequestInit
timeout?: number
errorCodesToCatch?: number[]
}) {
let result
try {
if (timeout) {
result = Promise.race([
await handleFetch(url, options),
new Promise<Response>((_, reject) =>
setTimeout(() => {
reject(TIMEOUT_ERROR)
}, timeout),
),
])
} else {
result = await handleFetch(url, options)
}
} catch (e) {
logOrRethrowError(e, errorCodesToCatch)
}
return result
}
/**
* Fetch that fails after timeout.
*
* @param url - Url to fetch.
* @param options - Options to send with the request.
* @param timeout - Timeout to fail request.
* @returns Promise resolving the request.
*/
export async function timeoutFetch(url: string, options?: RequestInit, timeout = 500): Promise<Response> {
return Promise.race([
successfulFetch(url, options),
new Promise<Response>((_, reject) =>
setTimeout(() => {
reject(TIMEOUT_ERROR)
}, timeout),
),
])
}
/**
* Utility method to log if error is a common fetch error and otherwise rethrow it.
*
* @param error - Caught error that we should either rethrow or log to console
* @param codesToCatch - array of error codes for errors we want to catch and log in a particular context
*/
function logOrRethrowError(error: any, codesToCatch: number[] = []) {
if (!error) {
return
}
const includesErrorCodeToCatch = codesToCatch.some(code =>
error.message.includes(`Fetch failed with status '${code}'`),
)
if (
error instanceof Error &&
(includesErrorCodeToCatch || error.message.includes('Failed to fetch') || error === TIMEOUT_ERROR)
) {
console.error(error)
} else {
throw error
}
}

216
src/utils/number.util.ts Normal file
View File

@ -0,0 +1,216 @@
import Web3 from 'web3';
import { BN } from 'ethereumjs-util';
/**
* Converts some token minimal unit to render format string, showing 5 decimals
*
* @param {Number|String|BN} tokenValue - Token value to convert
* @param {Number} decimals - Token decimals to convert
* @param {Number} decimalsToShow - Decimals to 5
* @returns {String} - Number of token minimal unit, in render format
* If value is less than 5 precision decimals will show '< 0.00001'
*/
export function renderFromTokenMinimalUnit(
tokenValue,
decimals,
decimalsToShow = 5
) {
const minimalUnit = fromTokenMinimalUnit(tokenValue || 0, decimals);
const minimalUnitNumber = parseFloat(minimalUnit);
let renderMinimalUnit;
if (minimalUnitNumber < 0.00001 && minimalUnitNumber > 0) {
renderMinimalUnit = "< 0.00001";
} else {
const base = Math.pow(10, decimalsToShow);
renderMinimalUnit = (
Math.round(minimalUnitNumber * base) / base
).toString();
}
return renderMinimalUnit;
}
/**
* Converts token minimal unit to readable string value
*
* @param {number|string|Object} minimalInput - Token minimal unit to convert
* @param {string} decimals - Token decimals to convert
* @returns {string} - String containing the new number
*/
export function fromTokenMinimalUnit(minimalInput, decimals) {
minimalInput = addHexPrefix(Number(minimalInput).toString(16));
let minimal = safeNumberToBN(minimalInput);
const negative = minimal.lt(new BN(0));
const base = Web3.utils.toBN(Math.pow(10, decimals).toString());
if (negative) {
minimal = minimal.mul(new BN(-1));
}
let fraction = minimal.mod(base).toString(10);
while (fraction.length < decimals) {
fraction = "0" + fraction;
}
fraction = fraction.match(/^([0-9]*[1-9]|0)(0*)/)[1];
const whole = minimal.div(base).toString(10);
let value = "" + whole + (fraction === "0" ? "" : "." + fraction);
if (negative) {
value = "-" + value;
}
return value;
}
/**
* Converts wei to render format string, showing 5 decimals
*
* @param {Number|String|BN} value - Wei to convert
* @param {Number} decimalsToShow - Decimals to 5
* @returns {String} - Number of token minimal unit, in render format
* If value is less than 5 precision decimals will show '< 0.00001'
*/
export function renderFromWei(value, decimalsToShow = 5) {
let renderWei = '0';
// avoid undefined
if (value) {
const wei = Web3.utils.fromWei(value);
const weiNumber = parseFloat(wei);
if (weiNumber < 0.00001 && weiNumber > 0) {
renderWei = '< 0.00001';
} else {
const base = Math.pow(10, decimalsToShow);
renderWei = (Math.round(weiNumber * base) / base).toString();
}
}
return renderWei;
}
/**
* Converts token BN value to hex string number to be sent
*
* @param {Object} value - BN instance to convert
* @param {number} decimals - Decimals to be considered on the conversion
* @returns {string} - String of the hex token value
*/
export function calcTokenValueToSend(value, decimals) {
return value ? (value * Math.pow(10, decimals)).toString(16) : 0;
}
/**
* Determines if a string is a valid decimal
*
* @param {string} value - String to check
* @returns {boolean} - True if the string is a valid decimal
*/
export function isDecimal(value) {
return (
Number.isFinite(parseFloat(value)) &&
!Number.isNaN(parseFloat(value)) &&
!isNaN(+value)
);
}
/**
* Creates a BN object from a string
*
* @param {string} value - Some numeric value represented as a string
* @returns {Object} - BN instance
*/
export function toBN(value) {
return Web3.utils.toBN(value);
}
/**
* Prefixes a hex string with '0x' or '-0x' and returns it. Idempotent.
*
* @param {string} str - The string to prefix.
* @returns {string} The prefixed string.
*/
export const addHexPrefix = (str: string) => {
if (typeof str !== "string" || str.match(/^-?0x/u)) {
return str;
}
if (str.match(/^-?0X/u)) {
return str.replace("0X", "0x");
}
if (str.startsWith("-")) {
return str.replace("-", "-0x");
}
return `0x${str}`;
};
/**
* Wraps 'numberToBN' method to avoid potential undefined and decimal values
*
* @param {number|string} value - number
* @returns {Object} - The converted value as BN instance
*/
export function safeNumberToBN(value: number | string) {
const safeValue = fastSplit(value.toString()) || "0";
return numberToBN(safeValue);
}
/**
* Performs a fast string split and returns the first item of the string based on the divider provided
*
* @param {number|string} value - number/string to be splitted
* @param {string} divider - string value to use to split the string (default '.')
* @returns {string} - the selected splitted element
*/
export function fastSplit(value, divider = ".") {
value += "";
const [from, to] = [value.indexOf(divider), 0];
return value.substring(from, to) || value;
}
export function stripHexPrefix(str: string) {
if (typeof str !== "string") {
return str;
}
return str.slice(0, 2) === "0x" ? str.slice(2) : str;
}
export function numberToBN(arg) {
if (typeof arg === "string" || typeof arg === "number") {
var multiplier = Web3.utils.toBN(1); // eslint-disable-line
var formattedString = String(arg).toLowerCase().trim();
var isHexPrefixed =
formattedString.substr(0, 2) === "0x" ||
formattedString.substr(0, 3) === "-0x";
var stringArg = stripHexPrefix(formattedString); // eslint-disable-line
if (stringArg.substr(0, 1) === "-") {
stringArg = stripHexPrefix(stringArg.slice(1));
multiplier = Web3.utils.toBN(-1);
}
stringArg = stringArg === "" ? "0" : stringArg;
if (
(!stringArg.match(/^-?[0-9]+$/) && stringArg.match(/^[0-9A-Fa-f]+$/)) ||
stringArg.match(/^[a-fA-F]+$/) ||
(isHexPrefixed === true && stringArg.match(/^[0-9A-Fa-f]+$/))
) {
return Web3.utils.toBN(stringArg).mul(multiplier);
}
if (
(stringArg.match(/^-?[0-9]+$/) || stringArg === "") &&
isHexPrefixed === false
) {
return Web3.utils.toBN(stringArg).mul(multiplier);
}
} else if (typeof arg === "object" && arg.toString && !arg.pop && !arg.push) {
if (
arg.toString(10).match(/^-?[0-9]+$/) &&
(arg.mul || arg.dividedToIntegerBy)
) {
return Web3.utils.toBN(arg.toString(10));
}
}
throw new Error(
"[number-to-bn] while converting number " +
JSON.stringify(arg) +
" to BN.js instance, error: invalid number value. Value must be an integer, hex string, BN or BigNumber instance. Note, decimals are not supported."
);
}

47
src/utils/promise.util.ts Normal file
View File

@ -0,0 +1,47 @@
/**
*
* @param {Function} cb
* @param {number} maxRetries
* @param {any[]} errorWhiteList
* @param {number} retries
* @return {Promise<T>}
*/
export function retry<T = any>(cb: Function, maxRetries: number = 3, errorWhiteList: any[] = [], retries: number = 0) {
return new Promise<T>((resolve, reject) => {
cb()
.then(resolve)
.catch(e => {
if (errorWhiteList.indexOf(e.constructor) !== -1 && retries++ < maxRetries) {
setTimeout(() => {
retry<T>(cb, maxRetries, errorWhiteList, retries)
.then(resolve)
.catch(e2 => reject(e2))
}, Math.floor(Math.random() * Math.pow(2, retries) * 400))
} else {
reject(e)
}
})
})
}
export class Deferred<T = any> {
public promise: Promise<T>
public resolve: Function
public reject: Function
constructor() {
this.promise = new Promise<T>((resolve, reject) => {
this.resolve = resolve
this.reject = reject
})
}
public then(func: (value: T) => any) {
return this.promise.then.apply(this.promise, arguments)
}
public catch(func: (value: any) => any) {
return this.promise.catch(func)
}
}

106
src/utils/string.util.ts Normal file
View File

@ -0,0 +1,106 @@
/**
* key升序生成 key1=val1&key2=val2的字符串
* @param {object} data
* @param {boolean} ignoreNull (null值不参与拼接)
* @param splitChar , &
* @param equalChar =
*/
export function generateKeyValStr(data: {}, ignoreNull = true, splitChar: string = '&', equalChar = '=') {
const keys = Object.keys(data)
keys.sort()
let result = ''
let i = 0
for (let key of keys) {
if (ignoreNull && !data[key]) {
return
}
if (i++ > 0) result += splitChar
result += `${key}${equalChar}${data[key]}`
}
return result
}
/**
* key1=val&key2=val的字符串组装成对象
* @param str key1=val&key2=val的字符串
* @param splitChar , &
* @param equalChar =
*/
export function keyValToObject(str: string, splitChar: string = '&', equalChar = '='): {} {
let result = {}
if (!str) {
return result
}
let arrs = str.split(splitChar)
for (let sub of arrs) {
let subArr = sub.split(equalChar)
result[subArr[0]] = subArr[1]
}
return result
}
/**
* true
* @param {Object} obj 'true','TRUE',1,'1','on','ON','YES','yes',true,false
* @return {boolean}
*/
export function isTrue(obj) {
return (
obj === 'true' ||
obj === 'TRUE' ||
obj === 'True' ||
obj === 'on' ||
obj === 'ON' ||
obj === true ||
obj === 1 ||
obj === '1' ||
obj === 'YES' ||
obj === 'yes'
)
}
/**
* ObjectId格式是否正确
* @param {string} id
* @return {boolean}
*/
export function isObjectId(id: string): boolean {
//mongoose.Types.ObjectId.isValid(id)
return /^[a-fA-F0-9]{24}$/.test(id)
}
/**
* 10 -> 62
* @param {string | number} number
* @return {string}
*/
export function string10to62(number: string | number) {
const chars = '0123456789abcdefghigklmnopqrstuvwxyzABCDEFGHIGKLMNOPQRSTUVWXYZ'.split('')
const radix = chars.length
let qutient = +number
const arr = []
do {
const mod = qutient % radix
qutient = (qutient - mod) / radix
arr.unshift(chars[mod])
} while (qutient)
return arr.join('')
}
/**
* 62 -> 10
* @param {string} numberCode
* @return {number}
*/
export function string62to10(numberCode: string) {
const chars = '0123456789abcdefghigklmnopqrstuvwxyzABCDEFGHIGKLMNOPQRSTUVWXYZ'
const radix = chars.length
numberCode = numberCode + ''
const len = numberCode.length
let i = 0
let originNumber = 0
while (i < len) {
originNumber += Math.pow(radix, i++) * (chars.indexOf(numberCode.charAt(len - i)) || 0)
}
return originNumber
}

119
src/utils/wallet.util.ts Normal file
View File

@ -0,0 +1,119 @@
import { renderFromTokenMinimalUnit } from "./number.util";
/**
* Removes IPFS protocol prefix from input string.
*
* @param ipfsUrl - An IPFS url (e.g. ipfs://{content id})
* @returns IPFS content identifier and (possibly) path in a string
* @throws Will throw if the url passed is not IPFS.
*/
export function removeIpfsProtocolPrefix(ipfsUrl: string) {
if (ipfsUrl.startsWith("ipfs://ipfs/")) {
return ipfsUrl.replace("ipfs://ipfs/", "");
} else if (ipfsUrl.startsWith("ipfs://")) {
return ipfsUrl.replace("ipfs://", "");
}
// this method should not be used with non-ipfs urls (i.e. startsWith('ipfs://') === true)
throw new Error("this method should not be used with non ipfs urls");
}
/**
* Extracts content identifier and path from an input string.
*
* @param ipfsUrl - An IPFS URL minus the IPFS protocol prefix
* @returns IFPS content identifier (cid) and sub path as string.
* @throws Will throw if the url passed is not ipfs.
*/
export function getIpfsCIDv1AndPath(ipfsUrl: string): {
cid: string;
path?: string;
} {
const url = removeIpfsProtocolPrefix(ipfsUrl);
// check if there is a path
// (CID is everything preceding first forward slash, path is everything after)
const index = url.indexOf("/");
const cid = index !== -1 ? url.substring(0, index) : url;
const path = index !== -1 ? url.substring(index) : undefined;
//TODO:
// We want to ensure that the CID is v1 (https://docs.ipfs.io/concepts/content-addressing/#identifier-formats)
// because most cid v0s appear to be incompatible with IPFS subdomains
// return {
// cid: CID.parse(cid).toV1().toString(),
// path,
// };
return {
cid,
path,
};
}
/**
* Adds URL protocol prefix to input URL string if missing.
*
* @param urlString - An IPFS URL.
* @returns A URL with a https:// prepended.
*/
export function addUrlProtocolPrefix(urlString: string): string {
if (!urlString.match(/(^http:\/\/)|(^https:\/\/)/u)) {
return `https://${urlString}`;
}
return urlString;
}
/**
* Formats URL correctly for use retrieving assets hosted on IPFS.
*
* @param ipfsGateway - The users preferred IPFS gateway (full URL or just host).
* @param ipfsUrl - The IFPS URL pointed at the asset.
* @param subdomainSupported - Boolean indicating whether the URL should be formatted with subdomains or not.
* @returns A formatted URL, with the user's preferred IPFS gateway and format (subdomain or not), pointing to an asset hosted on IPFS.
*/
export function getFormattedIpfsUrl(
ipfsGateway: string,
ipfsUrl: string,
subdomainSupported: boolean
): string {
const { host, protocol, origin } = new URL(addUrlProtocolPrefix(ipfsGateway));
if (subdomainSupported) {
const { cid, path } = getIpfsCIDv1AndPath(ipfsUrl);
return `${protocol}//${cid}.ipfs.${host}${path || ""}`;
}
const cidAndPath = removeIpfsProtocolPrefix(ipfsUrl);
return `${origin}/ipfs/${cidAndPath}`;
}
/**
* Returns whether the given code corresponds to a smart contract.
*
* @param code - The potential smart contract code.
* @returns Whether the code was smart contract code or not.
*/
export function isSmartContractCode(code: string) {
/* istanbul ignore if */
if (!code) {
return false;
}
// Geth will return '0x', and ganache-core v2.2.1 will return '0x0'
const smartContractCode = code !== '0x' && code !== '0x0';
return smartContractCode;
}
export function formatAddress(address: string) {
if (address.length >= 10) {
return address.substring(0, 6) + '...' + address.substring(address.length - 4)
} else if (address.length > 0 && address.length < 10) {
return address
} else {
return ''
}
}
export function formatMoney(balance: number | string, symbol: string) {
if (balance === '-') {
return `- ${symbol}`;
}
let money = renderFromTokenMinimalUnit(balance, 18, 4)
return `${money} ${symbol}`;
}

27
start.json Normal file
View File

@ -0,0 +1,27 @@
{
"apps": [
{
"name": "flow_chain",
"script": "npm",
"args": "run prod:api",
"cwd": "/var/data/apps/flow_chain",
"max_memory_restart": "1024M",
"log_date_format" : "YYYY-MM-DD HH:mm Z",
"watch": true,
"ignore_watch": [
"node_modules",
"logs",
"fixtures",
"tasks"
],
"instances": 1,
"exec_mode": "cluster",
"env": {
"NODE_ENV": "production"
},
"env_production": {
"NODE_ENV": "production"
}
}
]
}

22
tsconfig.json Normal file
View File

@ -0,0 +1,22 @@
{
"ts-node": {
"files": true
},
"compilerOptions": {
"experimentalDecorators": true,
"emitDecoratorMetadata": true,
"module": "commonjs",
"esModuleInterop": true,
"target": "es2018",
"moduleResolution": "node",
"sourceMap": true,
"outDir": "./dist",
"baseUrl": "./src",
"rootDir": "./src"
},
"lib": ["es2018"],
"include": [
"src/**/*.ts",
"typings/extend.d.ts"
]
}

11
tslint.json Normal file
View File

@ -0,0 +1,11 @@
{
"defaultSeverity": "error",
"extends": [
"tslint:recommended"
],
"jsRules": {},
"rules": {
"no-console": false
},
"rulesDirectory": []
}

11
typings/extend.d.ts vendored Normal file
View File

@ -0,0 +1,11 @@
import fastify from 'fastify'
declare module 'fastify' {
interface FastifyRequest {
roles?: string[]
user?: any
token?: string
permissions?: string[][]
depts?: string[]
}
}

5044
yarn.lock Normal file

File diff suppressed because it is too large Load Diff