dispatch256 with index

simon300000 · Sep 7, 2023 · ac82a14 · ac82a14
1 parent c0838f4
commit ac82a14
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/api/api.ts b/api/api.ts
@@ -202,8 +202,9 @@ router.post('/dispatch', ctx => {
   ctx.body = { url: dispatch() }
 })
 
-router.post('/dispatch256', ctx => {
-  ctx.body = { urls: dispatch256() }
+router.post('/dispatch256', koaBody(), ctx => {
+  const { i } = ctx.request.body
+  ctx.body = { urls: dispatch256(i) }
 })
 
 router.post('/receipt', koaBody(), ctx => {

diff --git a/api/dispatcher.ts b/api/dispatcher.ts
@@ -20,7 +20,7 @@ export const fetch = async (url: string) => {
 }
 
 export const dispatch = () => jobs[Math.floor(Math.random() * jobs.length)]?.url
-export const dispatch256 = () => jobs.filter((_, i) => i < 256).map(job => job.url)
+export const dispatch256 = (i = 0) => jobs.filter((_, i) => i >= i * 256).filter((_, i) => i < 256).map(job => job.url)
 
 export const receipt = (url: string, data: any) => {
   if (data.code === 0) {