crypto/chain_graphql
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

移除一些代码

Browse Source
This commit is contained in:
CounterFire2023 2023-06-29 19:03:02 +08:00
parent 64a0be6b5b
commit 79c1f1d9f2
1 changed files with 31 additions and 31 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

62
src/controllers/chain.controllers.ts
View File

@ -9,38 +9,38 @@ import { ZError } from 'common/ZError'
import { RedisClient } from 'redis/RedisClient'
class ChainController extends BaseController {
@role('anon')
@router('post /chain/req')
async addChainRequest(req, res) {
// data是一个数组!!
const { data, source, cb, taskId, force, max } = req.params
console.log(`income chain request:: taskId: ${taskId}, source: ${source}, cb: ${cb}`)
console.log(JSON.stringify(data))
let maxTryCount = max !== undefined ? parseInt(max) : parseInt(process.env.CHAIN_MAX_TRY)
let chainTask: DocumentType<ChainTaskClass> = await ChainTask.insertOrUpdate(
{ taskId },
{ source, taskData: data, cb },
)
// @role('anon')
// @router('post /chain/req')
// async addChainRequest(req, res) {
// // data是一个数组!!
// const { data, source, cb, taskId, force, max } = req.params
// console.log(`income chain request:: taskId: ${taskId}, source: ${source}, cb: ${cb}`)
// console.log(JSON.stringify(data))
// let maxTryCount = max !== undefined ? parseInt(max) : parseInt(process.env.CHAIN_MAX_TRY)
// let chainTask: DocumentType<ChainTaskClass> = await ChainTask.insertOrUpdate(
// { taskId },
// { source, taskData: data, cb },
// )
if ((!chainTask.newRecord && force) || chainTask.newRecord) {
for (let sub of data) {
let subType = sub.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)
}
}
chainTask.newRecord = false
await chainTask.save()
return chainTask.toJson()
}
// if ((!chainTask.newRecord && force) || chainTask.newRecord) {
// for (let sub of data) {
// let subType = sub.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)
// }
// }
// chainTask.newRecord = false
// await chainTask.save()
// return chainTask.toJson()
// }
@role('anon')
@router('post /chain/query_info')