还global吗

[simon300000]

SuperSpider/packages/superspider-ana/index.js

Lines 21 to 22 in b7ad1df

	global.amdb = false
	global.utrdb = false

SuperSpider/packages/superspider-ana/index.js

Lines 62 to 63 in b7ad1df

	global.amdb = client.db('amdb').collection('maindb')
	global.utrdb = client.db('amdb').collection('utrdb')

SuperSpider/packages/superspider-ana/module/core.js

Lines 7 to 8 in b7ad1df

	if (!global.amdb) return
	const amdb = global.amdb

SuperSpider/packages/superspider-ana/module/untr.js

Lines 8 to 11 in b7ad1df

	if (!global.amdb) return
	const amdb = global.amdb
	if (!global.utrdb) return
	const utrdb = global.utrdb

SuperSpider/packages/superspider-db/index.js

Line 15 in b7ad1df

global.adbRunning = false

SuperSpider/packages/superspider-db/modules/adb.js

Lines 9 to 10 in b7ad1df

	if (global.adbRunning) return
	global.adbRunning = true

SuperSpider/packages/superspider-mcore/api/sc.js

Lines 20 to 210 in b7ad1df

	if (!global.amdb) {
	ctx.response.status = 500
	ctx.response.body = 'Internal Server Error: AMDB ERR'
	await next()
	return
	}
	if (!global.predb) {
	ctx.response.status = 500
	ctx.response.body = 'Internal Server Error: PreDB ERR'
	await next()
	return
	}
	const amdb = global.amdb
	const predb = global.predb
	if (!ctx.request.body.roomid || isNaN(Number(ctx.request.body.roomid))) {
	ctx.response.status = 404
	ctx.response.body = 'Bad Request Format'
	await next()
	} else {
	try {
	ctx.response.status = 200
	const roomid = Number(ctx.request.body.roomid)
	log(`LOG req in rid ${roomid}`)
	const finded = await amdb
	.find({ roomid })
	.sort('ts', -1)
	.limit(50)
	.toArray()
	log(`LOG amdb complete ${roomid}`)
	const preFinded = await predb
	.find({ roomid })
	.sort('ts', -1)
	.limit(30)
	.toArray()
	log(`LOG predb complete ${roomid}`)
	const tsList = new Array()
	const rList = []
	for (const item of finded) {
	if (!item.livets) continue
	if (Number(item.hide) > 0) continue
	let lts = Number(item.livets)
	for (i = lts; i > lts - 300; i--) {
	if (tsList.includes(Number(i))) {
	lts = Number(i)
	break
	}
	}
	if (!tsList.includes(lts)) tsList.push(lts)
	if (!rList[lts]) rList[lts] = new Array()
	rList[lts].push({ ...item, ts: Number(item.ts * 1000), sc: 1 })
	}
	for (const item of preFinded) {
	if (
	ctx.request.body.filter &&
	(isNaN(Number(item.price)) || Number(item.price) < 30)
	)
	continue
	if (!item.livets) continue
	if (Number(item.hide) > 0) continue
	let lts = Number(item.livets)
	/// lts是本次直播开始的时间
	/// 现在需要将时间间隔在300000000ms内的两场直播合并
	/// 并找出那次直播的时间（livets），赋值给lts
	// for (i = lts; i > lts - 300000000; i--) {
	// if (tsList.includes(Number(i))) {
	// lts = Number(i)
	// break
	// }
	// }
	/// 以上为Il Harper@绝赞自裁中的……算了丢人
	/// 以下为群中的大佬写的示例
	let newlts = lts - 300000001
	for (let num of tsList) {
	newlts = newlts < num && num <= lts ? num : newlts
	}
	if (newlts !== lts - 300000001) lts = newlts
	/// END
	if (!tsList.includes(lts)) tsList.push(lts)
	if (!rList[lts]) rList[lts] = new Array()
	rList[lts].push({ ...item, ...giftConv(item), sc: 0 })
	}
	// for (const tl of rList) {
	// tl.sort((a, b) => Number(b.ts) - Number(a.ts))
	// }
	log(`LOG local sort ${roomid}`)
	const output = []
	for (const ts of tsList) {
	// rList[ts].sort((a, b) => Number(b.ts) - Number(a.ts))
	output.push({
	ts,
	data: rList[ts]
	})
	}
	// output.sort((a, b) => Number(b.ts) - Number(a.ts))
	log(`LOG output ${roomid}`)
	ctx.response.body = output
	log(`LOG next start ${roomid}`)
	await next()
	log(`LOG next end ${roomid}`)
	} catch (e) {
	ctx.response.status = 500
	ctx.response.body = 'Internal Server Error'
	await next()
	console.log(e)
	}
	}
	})
	// /sc/submit
	sc.post('/submit', async (ctx, next) => {
	if (!global.amdb) {
	ctx.response.status = 500
	ctx.response.body = 'Internal Server Error: AMDB ERR'
	await next()
	return
	}
	if (!global.udb) {
	ctx.response.status = 500
	ctx.response.body = 'Internal Server Error: UDB ERR'
	await next()
	return
	}
	const amdb = global.amdb
	const udb = global.udb
	if (
	!ctx.request.body.username ||
	!ctx.request.body.password ||
	!ctx.request.body.id ||
	!ctx.request.body.tr
	) {
	ctx.response.status = 404
	ctx.response.body = 'Bad Request Format'
	await next()
	return
	}
	try {
	const u = await udb
	.find({
	username: ctx.request.body.username,
	password: ctx.request.body.password
	})
	.limit(1)
	.toArray()
	if (u.length < 1) {
	ctx.response.status = 403
	ctx.response.body = 'Forbidden'
	await next()
	return
	}
	const ust = u[0].trstatus
	const item = await amdb
	.find({ _id: Number(ctx.request.body.id) })
	.limit(1)
	.toArray()
	if (Number(item.trstatus) > Number(ust)) {
	ctx.response.status = 200
	ctx.response.body = 1
	await next()
	return
	}
	await amdb.updateOne(
	{ _id: Number(ctx.request.body.id) },
	{ $set: { msgtr: ctx.request.body.tr } }
	)
	ctx.response.status = 200
	ctx.response.body = 0
	await next()
	} catch (e) {
	ctx.response.status = 500
	ctx.response.body = 'Internal Server Error'
	await next()
	console.log(e)
	}
	})
	// /sc/hide
	sc.post('/hide', async (ctx, next) => {
	if (!global.amdb) {
	ctx.response.status = 500
	ctx.response.body = 'Internal Server Error: AMDB ERR'
	await next()
	return
	}
	if (!global.udb) {
	ctx.response.status = 500
	ctx.response.body = 'Internal Server Error: UDB ERR'
	await next()
	return
	}
	const amdb = global.amdb
	const udb = global.udb

SuperSpider/packages/superspider-mcore/index.js

Lines 10 to 11 in b7ad1df

	global.amdb = false
	global.udb = false

SuperSpider/packages/superspider-mdb/index.js

Lines 64 to 113 in b7ad1df

	try {
	await client.connect()
	global.amdb = client.db('amdb').collection('maindb')
	global.utrdb = client.db('amdb').collection('utrdb')
	} catch (err) {
	console.log('ERR when connect to AMDB')
	console.log(err)
	process.exit(1)
	}
	global.amdb.createIndex(
	{
	// _id: -1,
	roomid: -1,
	livets: -1
	// ts: -1
	},
	(e, s) => {}
	)
	global.amdb.createIndex(
	{
	_id: -1
	},
	(e, s) => {}
	)
	global.amdb.createIndex(
	{
	roomid: -1
	},
	(e, s) => {}
	)
	global.amdb.createIndex(
	{
	ts: -1
	},
	(e, s) => {}
	)
	global.utrdb.createIndex(
	{
	uname: -1
	},
	(e, s) => {}
	)
	// global.amdb.createIndex(
	// {
	// _id: -1,
	// status: -1
	// },
	// (e, s) => {}
	// )

SuperSpider/packages/superspider-mdb/modules/rdb.js

Lines 21 to 24 in b7ad1df

	if (!global.amdb) return
	const amdb = global.amdb
	if (!global.utrdb) return
	const utrdb = global.utrdb

SuperSpider/packages/superspider-predb/index.js

Lines 16 to 22 in b7ad1df

	// global.adbRunning = false
	global.predb = false
	global.utrdb = false
	// global.rmdb = false
	// global.umdb = false
	global.usingAtHome = process.env.USINGATHOME

SuperSpider/packages/superspider-predb/modules/rdb.js

Lines 25 to 28 in b7ad1df

	if (!global.predb) return
	const predb = global.predb
	if (!global.utrdb) return
	const utrdb = global.utrdb

[simon300000]

建议把这些db独立出一个shared然后在api里面的文件访问ya

[ilharp]

好的，之后有时间的话会进行修改。