add transactions on L&E webhook

impactMarket · Jan 5, 2023 · 510fe41 · 510fe41
1 parent 587a710
commit 510fe41
Showing 1 changed file with 100 additions and 56 deletions.
diff --git a/packages/core/src/services/learnAndEarn/syncRemote.ts b/packages/core/src/services/learnAndEarn/syncRemote.ts
@@ -1,7 +1,7 @@
 import { PrismicDocument } from '@prismicio/types';
 import { Op } from 'sequelize';
 
-import { models } from '../../database';
+import { models, sequelize } from '../../database';
 import { BaseError } from '../../utils/baseError';
 import { client as prismic } from '../../utils/prismic';
 
@@ -11,46 +11,57 @@ import { client as prismic } from '../../utils/prismic';
 // }
 
 async function getPrismicLearnAndEarn() {
- try {
- const categoryIds: number[] = [],
- levelIds: number[] = [],
- lessonIds: number[] = [],
- quizIds: number[] = [];
+ const categoryIds: number[] = [],
+ levelIds: number[] = [],
+ lessonIds: number[] = [],
+ quizIds: number[] = [];
+
+ const response = await prismic.getAllByType('pwa-lae-category', {
+ lang: 'en-us',
+ fetchLinks: [
+ 'pwa-lae-level.reward',
+ 'pwa-lae-level.lessons',
+ 'pwa-lae-lesson.questions',
+ ],
+ });
+ for (
+ let categoryIndex = 0;
+ categoryIndex < response.length;
+ categoryIndex++
+ ) {
+ const t = await sequelize.transaction();
 
- const response = await prismic.getAllByType('pwa-lae-category', {
- lang: 'en-us',
- fetchLinks: [
- 'pwa-lae-level.reward',
- 'pwa-lae-level.lessons',
- 'pwa-lae-lesson.questions',
- ],
- });
- for (
- let categoryIndex = 0;
- categoryIndex < response.length;
- categoryIndex++
- ) {
+ try {
  const prismicCategory = response[categoryIndex];
  // INSERT CATEGORY
  const [category] = await models.learnAndEarnCategory.findOrCreate({
  where: {
  prismicId: prismicCategory.id,
  active: true,
  },
+ transaction: t,
  });
 
  categoryIds.push(category.id);
- await category.update({
- languages: prismicCategory.alternate_languages
- .map(({ lang }) => {
- const index_ = lang.indexOf('-');
- return lang.substring(
- 0,
- index_ !== -1 ? index_ : lang.length
- );
- })
- .concat(['en']),
- });
+ await models.learnAndEarnCategory.update(
+ {
+ languages: prismicCategory.alternate_languages
+ .map(({ lang }) => {
+ const index_ = lang.indexOf('-');
+ return lang.substring(
+ 0,
+ index_ !== -1 ? index_ : lang.length
+ );
+ })
+ .concat(['en']),
+ },
+ {
+ transaction: t,
+ where: {
+ id: category.id,
+ },
+ }
+ );
 
  for (
  let levelIndex = 0;
@@ -74,23 +85,32 @@ async function getPrismicLearnAndEarn() {
  active: true,
  categoryId: category.id,
  },
+ transaction: t,
  }
  );
  levelIds.push(level.id);
  const findLevelLanguages = await prismic.getByID(
  prismicLevel.id
  );
- await level.update({
- languages: findLevelLanguages.alternate_languages
- .map(({ lang }) => {
- const index_ = lang.indexOf('-');
- return lang.substring(
- 0,
- index_ !== -1 ? index_ : lang.length
- );
- })
- .concat(['en']),
- });
+ await models.learnAndEarnLevel.update(
+ {
+ languages: findLevelLanguages.alternate_languages
+ .map(({ lang }) => {
+ const index_ = lang.indexOf('-');
+ return lang.substring(
+ 0,
+ index_ !== -1 ? index_ : lang.length
+ );
+ })
+ .concat(['en']),
+ },
+ {
+ transaction: t,
+ where: {
+ id: level.id,
+ },
+ }
+ );
 
  for (
  let lessonIndex = 0;
@@ -114,25 +134,35 @@ async function getPrismicLearnAndEarn() {
  active: true,
  levelId: level.id,
  },
+ transaction: t,
  });
  lessonIds.push(lesson.id);
  const findLessonLanguages = await prismic.getByID(
  prismicLesson.id
  );
- await lesson.update({
- languages:
- findLessonLanguages.alternate_languages
- .map(({ lang }) => {
- const index_ = lang.indexOf('-');
- return lang.substring(
- 0,
- index_ !== -1
- ? index_
- : lang.length
- );
- })
- .concat(['en']),
- });
+ await models.learnAndEarnLesson.update(
+ {
+ languages:
+ findLessonLanguages.alternate_languages
+ .map(({ lang }) => {
+ const index_ =
+ lang.indexOf('-');
+ return lang.substring(
+ 0,
+ index_ !== -1
+ ? index_
+ : lang.length
+ );
+ })
+ .concat(['en']),
+ },
+ {
+ transaction: t,
+ where: {
+ id: lesson.id,
+ },
+ }
+ );
 
  for (
  let quizIndex = 0;
@@ -155,16 +185,24 @@ async function getPrismicLearnAndEarn() {
  lessonId: lesson.id,
  answer,
  },
+ transaction: t,
  });
  quizIds.push(quiz.id);
  }
  }
  }
  }
  }
+ await t.commit();
+ } catch (error) {
+ await t.rollback();
+ console.log('e', error);
  }
+ }
 
- // INACTIVATE REGISTRIES
+ // INACTIVATE REGISTRIES
+ const t = await sequelize.transaction();
+ try {
  await Promise.all([
  models.learnAndEarnCategory.update(
  {
@@ -176,6 +214,7 @@ async function getPrismicLearnAndEarn() {
  [Op.notIn]: categoryIds,
  },
  },
+ transaction: t,
  }
  ),
  models.learnAndEarnLevel.update(
@@ -188,6 +227,7 @@ async function getPrismicLearnAndEarn() {
  [Op.notIn]: levelIds,
  },
  },
+ transaction: t,
  }
  ),
  models.learnAndEarnLesson.update(
@@ -200,6 +240,7 @@ async function getPrismicLearnAndEarn() {
  [Op.notIn]: lessonIds,
  },
  },
+ transaction: t,
  }
  ),
  models.learnAndEarnQuiz.update(
@@ -212,10 +253,13 @@ async function getPrismicLearnAndEarn() {
  [Op.notIn]: quizIds,
  },
  },
+ transaction: t,
  }
  ),
  ]);
+ await t.commit();
  } catch (error) {
+ await t.rollback();
  console.log('e', error);
  }
 }