@@ -33,9 +33,6 @@ function addCorsHeaders(reply: any) {
3333 reply . header ( "Access-Control-Allow-Headers" , "Origin, Accept, Content-Type, X-Requested-With, X-CSRF-Token" ) ;
3434}
3535
36- function sendJson ( reply : any , result : any ) {
37- return reply . type ( "application/json" ) . send ( result ) ;
38- }
3936function addScraperRoutes ( app :FastifyInstance ) {
4037 Object . values ( Server . scrapers ) . forEach ( scraper => {
4138 const routePath = `/${ kebabCase ( scraper . scraper_name ) } `
@@ -65,7 +62,7 @@ function addScraperRoutes(app:FastifyInstance) {
6562 if ( DirectCallCacheService . has ( cacheKey ) ) {
6663 try {
6764 const cachedResult = DirectCallCacheService . get ( cacheKey )
68- return sendJson ( reply , cachedResult ?? { result : null } )
65+ return cachedResult ?? { result : null }
6966 } catch ( error ) {
7067 console . error ( error )
7168 // Continue with normal execution if cache fails
@@ -115,7 +112,7 @@ function addScraperRoutes(app:FastifyInstance) {
115112 }
116113 }
117114
118- return sendJson ( reply , finalResults ?? { result : null } )
115+ return finalResults ?? { result : null }
119116 } finally {
120117 executor . decrementCapacity ( key )
121118 }
@@ -171,46 +168,46 @@ export function buildApp(scrapers:any[]): FastifyInstance {
171168 return reply . type ( 'text/html' ) . send ( html ) ;
172169 } ) ;
173170
174- app . post ( "/tasks/create-task-async" , async ( request , reply ) => {
171+ app . post ( "/tasks/create-task-async" , async ( request , _ ) => {
175172 const jsonData = request . body ;
176173 const result = await createAsyncTask ( jsonData ) ;
177- return sendJson ( reply , result ) ;
174+ return result ;
178175 } ) ;
179176
180- app . post ( "/tasks/create-task-sync" , async ( request , reply ) => {
177+ app . post ( "/tasks/create-task-sync" , async ( request , _ ) => {
181178 const jsonData = request . body ;
182179 const result = await createSyncTask ( jsonData ) ;
183- return sendJson ( reply , result ) ;
180+ return result ;
184181 } ) ;
185182
186- app . get ( "/tasks" , async ( request , reply ) => {
183+ app . get ( "/tasks" , async ( request , _ ) => {
187184 const queryParams = request . query ;
188185 const result = await getTasks ( queryParams ) ;
189- return sendJson ( reply , result ) ;
186+ return result ;
190187 } ) ;
191188
192189 app . get (
193190 "/tasks/:taskId" ,
194191 async (
195192 request : FastifyRequest < { Params : { taskId : number } } > ,
196- reply
193+ _
197194 ) => {
198195 const taskId = request . params . taskId ;
199196 const result = await getTask ( taskId ) ;
200- return sendJson ( reply , result ) ;
197+ return result ;
201198 }
202199 ) ;
203200
204201 app . post (
205202 "/tasks/:taskId/results" ,
206203 async (
207204 request : FastifyRequest < { Params : { taskId : number } ; Body : any } > ,
208- reply
205+ _
209206 ) => {
210207 const taskId = request . params . taskId ;
211208 const jsonData = request . body ;
212209 const results = await getTaskResults ( taskId , jsonData ) ;
213- return sendJson ( reply , results ) ;
210+ return results ;
214211 }
215212 ) ;
216213
@@ -230,67 +227,64 @@ export function buildApp(scrapers:any[]): FastifyInstance {
230227 "/tasks/:taskId/abort" ,
231228 async (
232229 request : FastifyRequest < { Params : { taskId : number } } > ,
233- reply
230+ _
234231 ) => {
235232
236233 const taskId = request . params . taskId ;
237234 const result = await abortSingleTask ( taskId ) ;
238- return sendJson ( reply , result ) ;
235+ return result ;
239236 }
240237 ) ;
241238
242239 app . delete (
243240 "/tasks/:taskId" ,
244241 async (
245242 request : FastifyRequest < { Params : { taskId : number } } > ,
246- reply
243+ _
247244 ) => {
248245 const taskId = request . params . taskId ;
249246 const result = await deleteSingleTask ( taskId ) ;
250- return sendJson ( reply , result ) ;
247+ return result ;
251248 }
252249 ) ;
253250
254- app . post ( "/tasks/bulk-abort" , async ( request , reply ) => {
251+ app . post ( "/tasks/bulk-abort" , async ( request , _ ) => {
255252 const jsonData = request . body ;
256253 const result = await bulkAbortTasks ( jsonData ) ;
257- return sendJson ( reply , result ) ;
254+ return result ;
258255 } ) ;
259256
260- app . post ( "/tasks/bulk-delete" , async ( request , reply ) => {
257+ app . post ( "/tasks/bulk-delete" , async ( request , _ ) => {
261258 const jsonData = request . body ;
262259 const result = await bulkDeleteTasks ( jsonData ) ;
263- return sendJson ( reply , result ) ;
260+ return result ;
264261 } ) ;
265262
266- app . get ( "/ui/app-props" , ( _ , reply ) => {
267- const result = getAppProps ( ) ;
268- return sendJson ( reply , result ) ;
269- } ) ;
263+ app . get ( "/ui/app-props" , getAppProps ) ;
270264
271- app . post ( "/ui/tasks/is-any-task-updated" , async ( request , reply ) => {
265+ app . post ( "/ui/tasks/is-any-task-updated" , async ( request , _ ) => {
272266 const jsonData = request . body ;
273267 const result = await isAnyTaskUpdated ( jsonData ) ;
274- return sendJson ( reply , result ) ;
268+ return result ;
275269 } ) ;
276270
277- app . post ( "/ui/tasks/is-task-updated" , async ( request , reply ) => {
271+ app . post ( "/ui/tasks/is-task-updated" , async ( request , _ ) => {
278272 const jsonData = request . body ;
279273 const result = await isTaskUpdated ( jsonData ) ;
280- return sendJson ( reply , result ) ;
274+ return result ;
281275 } ) ;
282276
283- app . get ( "/ui/tasks" , async ( request , reply ) => {
277+ app . get ( "/ui/tasks" , async ( request , _ ) => {
284278 const queryParams = request . query ;
285279 const result = await getTasksForUiDisplay ( queryParams ) ;
286- return sendJson ( reply , result ) ;
280+ return result ;
287281 } ) ;
288282
289- app . patch ( "/ui/tasks" , async ( request , reply ) => {
283+ app . patch ( "/ui/tasks" , async ( request , _ ) => {
290284 const queryParams = request . query ;
291285 const jsonData = request . body ;
292286 const result = await patchTask ( queryParams , jsonData ) ;
293- return sendJson ( reply , result ) ;
287+ return result ;
294288 } ) ;
295289
296290 app . post (
@@ -301,13 +295,13 @@ export function buildApp(scrapers:any[]): FastifyInstance {
301295 Body : any ;
302296 Querystring : any ;
303297 } > ,
304- reply
298+ _
305299 ) => {
306300 const taskId = request . params . taskId ;
307301 const jsonData = request . body ;
308302 const queryParams = request . query ;
309303 const final = await getUiTaskResults ( taskId , queryParams , jsonData ) ;
310- return sendJson ( reply , final ) ;
304+ return final ;
311305 }
312306 ) ;
313307
0 commit comments