@@ -309,27 +309,26 @@ async function addTaskTags() {
309309 for ( const task_tag of task_tags ) {
310310 taskTagQueue . add ( async ( ) => {
311311 try {
312- const registeredTaskTag = await prisma . taskTag . findMany ( {
312+ const registeredTaskTag = await prisma . taskTag . findUnique ( {
313313 where : {
314- AND : [ { task_id : task_tag . task_id } , { tag_id : task_tag . tag_id } ] ,
314+ task_id_tag_id : {
315+ task_id : task_tag . task_id ,
316+ tag_id : task_tag . tag_id ,
317+ } ,
315318 } ,
316319 } ) ;
317- const registeredTask = await prisma . task . findMany ( {
320+ const registeredTask = await prisma . task . findUnique ( {
318321 where : {
319322 task_id : task_tag . task_id ,
320323 } ,
321324 } ) ;
322- const registeredTag = await prisma . tag . findMany ( {
325+ const registeredTag = await prisma . tag . findUnique ( {
323326 where : {
324327 id : task_tag . tag_id ,
325328 } ,
326329 } ) ;
327330
328- if (
329- registeredTaskTag . length === 0 &&
330- registeredTag . length === 1 &&
331- registeredTask . length === 1
332- ) {
331+ if ( ! registeredTaskTag && registeredTag && registeredTask ) {
333332 await addTaskTag ( task_tag , taskTagFactory ) ;
334333 console . log ( 'tag id:' , task_tag . tag_id , 'task_id:' , task_tag . task_id , 'was registered.' ) ;
335334 }
@@ -367,13 +366,13 @@ async function addSubmissionStatuses() {
367366 for ( const submission_status of submission_statuses ) {
368367 submissionStatusQueue . add ( async ( ) => {
369368 try {
370- const registeredSubmissionStatus = await prisma . submissionStatus . findMany ( {
369+ const registeredSubmissionStatus = await prisma . submissionStatus . findUnique ( {
371370 where : {
372371 id : submission_status . id ,
373372 } ,
374373 } ) ;
375374
376- if ( registeredSubmissionStatus . length === 0 ) {
375+ if ( ! registeredSubmissionStatus ) {
377376 await addSubmissionStatus ( submission_status , submissionStatusFactory ) ;
378377 console . log ( 'submission_status id:' , submission_status . id , 'was registered.' ) ;
379378 }
@@ -410,27 +409,30 @@ async function addAnswers() {
410409 for ( const answer of answers ) {
411410 answerQueue . add ( async ( ) => {
412411 try {
413- const registeredAnswer = await prisma . taskAnswer . findMany ( {
412+ const registeredAnswer = await prisma . taskAnswer . findUnique ( {
414413 where : {
415- id : answer . id ,
414+ task_id_user_id : {
415+ task_id : answer . task_id ,
416+ user_id : answer . user_id ,
417+ } ,
416418 } ,
417419 } ) ;
418420
419- const registeredUser = await prisma . user . findMany ( {
421+ const registeredUser = await prisma . user . findUnique ( {
420422 where : {
421423 id : answer . user_id ,
422424 } ,
423425 } ) ;
424426
425- if ( registeredAnswer . length === 0 && registeredUser . length === 1 ) {
427+ if ( ! registeredAnswer && registeredUser ) {
426428 await addAnswer ( answer , answerFactory ) ;
427429 console . log ( 'answer id:' , answer . id , 'was registered.' ) ;
428430 } else {
429431 console . warn (
430- 'answer len :' ,
431- registeredAnswer . length ,
432- 'user len :' ,
433- registeredUser . length ,
432+ 'answer exists :' ,
433+ ! ! registeredAnswer ,
434+ 'user exists :' ,
435+ ! ! registeredUser ,
434436 answer . id ,
435437 'was not registered.' ,
436438 ) ;
0 commit comments