Migrate update scripts and delete prisma1

Author: Riron

back/package.json

@@ -10,7 +10,7 @@
     "watch-graphql": "npm run graphql-codegen -- --watch",
     "start": "node src/index.js",
     "update": "node prisma/scripts/index.js",
-    "update:dev": "ts-node prisma/scripts/index.ts",
+    "update:dev": "ts-node -r tsconfig-paths/register prisma/scripts/index.ts",
     "test": "jest",
     "build": "tsc && copyfiles -e **/*.ts src/**/*.{graphql,pdf,png,ttf} prisma/**/*.{yml,prisma} dist/",
     "lint": "eslint -c .eslintrc.js --ext .ts ./src",
@@ -64,7 +64,6 @@
     "passport-local": "^1.0.0",
     "passport-oauth2-client-password": "^0.1.2",
     "pdf-lib": "^1.12.0",
-    "prisma-client-lib": "1.34.10",
     "rate-limit-redis": "^2.0.0",
     "request": "^2.88.2",
     "winston": "^3.2.1",
@@ -119,7 +118,6 @@
     "jsonwebtoken": "^8.5.1",
     "nodemon": "^2.0.4",
     "prettier": "^2.0.5",
-    "prisma1": "^1.34.11",
     "supertest": "^4.0.2",
     "ts-jest": "26.0.0",
     "ts-node": "^8.10.2",

back/prisma1/scripts/__tests__/migrate-packagings.test.ts renamed to back/prisma/scripts/__tests__/migrate-packagings.test.ts

@@ -1,5 +1,5 @@
-import { Updater, registerUpdater } from "./helper/helper";
-import acceptPendingInvitations from "../../src/scripts/prisma/acceptPendingInvitations";
+import acceptPendingInvitations from "src/scripts/prisma/acceptPendingInvitations";
+import { registerUpdater, Updater } from "./helper/helper";
 
 @registerUpdater(
   "Accept pending invitations",

back/prisma1/scripts/accept-pending-invitations.ts renamed to back/prisma/scripts/accept-pending-invitations.ts

@@ -1,5 +1,5 @@
-import { prisma } from "../../src/generated/prisma-client";
-import { Updater, registerUpdater } from "./helper/helper";
+import prisma from "src/prisma";
+import { registerUpdater, Updater } from "./helper/helper";
 
 @registerUpdater(
   "Add the eco-organisme type",
@@ -8,14 +8,16 @@ import { Updater, registerUpdater } from "./helper/helper";
 )
 export class AddEcoOrganismeType implements Updater {
   async run() {
-    const ecoOrganismes = await prisma.ecoOrganismes();
+    const ecoOrganismes = await prisma.ecoOrganisme.findMany();
     for (const ecoOrganisme of ecoOrganismes) {
-      const company = await prisma.company({
+      const company = await prisma.company.findOne({where: {
+
         siret: ecoOrganisme.siret
+      }
       });
 
       if (company && !company.companyTypes.includes("ECO_ORGANISME")) {
-        await prisma.updateCompany({
+        await prisma.company.update({
           data: {
             companyTypes: {
               set: company.companyTypes.concat(["ECO_ORGANISME"])

back/prisma1/scripts/add-ecoorganisme-type.ts renamed to back/prisma/scripts/add-ecoorganisme-type.ts

@@ -1,7 +1,7 @@
 import * as readline from "readline";
-import { Updater, registerUpdater } from "./helper/helper";
-import { prisma } from "../../src/generated/prisma-client";
-import { Packagings } from "../../src/generated/graphql/types";
+import { Packagings } from "src/generated/graphql/types";
+import prisma from "src/prisma";
+import { registerUpdater, Updater } from "./helper/helper";
 
 @registerUpdater(
   "Migrate packagings",
@@ -16,7 +16,7 @@ export class MigratePackagingsUpdater implements Updater {
 
     try {
       // Cannot do { where: {wasteDetailsPackagingInfos: null}} here :(
-      const forms = await prisma.forms();
+      const forms = await prisma.form.findMany();
       const notMigratedForms = forms.filter(
         f => f.wasteDetailsPackagingInfos == null
       );
@@ -27,7 +27,7 @@ export class MigratePackagingsUpdater implements Updater {
 
       const updateParams = notMigratedForms.map(form => {
         const { wasteDetailsNumberOfPackages: numberOfPackages } = form;
-        const packagings: Packagings[] = form.wasteDetailsPackagings ?? [];
+        const packagings = form.wasteDetailsPackagings as Packagings[] ?? [];
 
         // If numberOfPackages is 0 or less we obviously have corrupted data
         // So we "kind of uncorrupt" the data by assigning 0 to each
@@ -67,7 +67,7 @@ export class MigratePackagingsUpdater implements Updater {
         await Promise.all(
           updateParams
             .splice(0, BATCH_SIZE)
-            .map(param => prisma.updateForm(param))
+            .map(param => prisma.form.update(param))
         );
         counter++;
 

back/prisma1/scripts/helper/helper.ts renamed to back/prisma/scripts/helper/helper.ts

@@ -0,0 +1,50 @@
+import axios from "axios";
+import { addContact } from "src/common/mails.helper";
+import prisma from "src/prisma";
+import { Updater, registerUpdater } from "./helper/helper";
+
+type Contact = { Email: string; Name?: string };
+
+@registerUpdater(
+  "Set contacts in Mailjet",
+  `Add every user to Mailjet, so that the newsletter are automatically sent to everyone`,
+  false
+)
+export class SetContactsUpdater implements Updater {
+  run() {
+    console.info("Starting script to set contacts in mailjet...");
+
+    try {
+      return prisma.user
+        .findMany({ orderBy: { createdAt: "desc" } })
+        .then(async users => {
+          const latestContacts = await axios.get<Contact[]>(
+            "http://td-mail/contact"
+          );
+
+          const contactsToCreate = [];
+          for (const user of users) {
+            // As soon as one of the user is in the 10 latest contacts, stop picking users
+            if (
+              latestContacts.data.find(e => e.Email === user.email) !==
+              undefined
+            ) {
+              break;
+            }
+            contactsToCreate.push(user);
+          }
+
+          return Promise.all(
+            contactsToCreate.map(c =>
+              addContact({ email: c.email, name: c.name }).catch(err =>
+                console.error(`Error for email ${c.email}`, err)
+              )
+            )
+          );
+        });
+    } catch (err) {
+      console.error("☠ Something went wrong during the update", err);
+      throw new Error();
+    }
+  }
+}

back/prisma1/scripts/index.ts renamed to back/prisma/scripts/index.ts

@@ -1,5 +1,5 @@
-import { Updater, registerUpdater } from "./helper/helper";
-import { prisma } from "../../src/generated/prisma-client";
+import prisma from "src/prisma";
+import { registerUpdater, Updater } from "./helper/helper";
 
 const ecoOrganismes = [
   {
@@ -112,7 +112,7 @@ const ecoOrganismes = [
 export class UpdateEcoOrganismesUpdater implements Updater {
   async run() {
     for (const ecoOrganisme of ecoOrganismes) {
-      await prisma.upsertEcoOrganisme({
+      await prisma.ecoOrganisme.upsert({
         create: ecoOrganisme,
         update: ecoOrganisme,
         where: {

back/prisma1/scripts/migrate-packagings.ts renamed to back/prisma/scripts/migrate-packagings.ts

@@ -1,5 +1,5 @@
-import { Updater, registerUpdater } from "./helper/helper";
-import { prisma } from "../../src/generated/prisma-client";
+import prisma from "src/prisma";
+import { registerUpdater, Updater } from "./helper/helper";
 
 @registerUpdater(
   "Set default value of FR for next destination company country",
@@ -8,12 +8,12 @@ import { prisma } from "../../src/generated/prisma-client";
 )
 export class UpdateNextDestinationCountry implements Updater {
   async run() {
-    await prisma.updateManyForms({
+    await prisma.form.updateMany({
       data: {
         nextDestinationCompanyCountry: "FR"
       },
       where: {
-        nextDestinationCompanySiret_not: null,
+        nextDestinationCompanySiret: { not: null },
         nextDestinationCompanyCountry: null
       }
     });

back/prisma/scripts/set-contacts.ts

@@ -0,0 +1,29 @@
+import fs from "fs";
+import path from "path";
+
+/**
+ * To seed the DB, run `ts-node prisma/seed.ts`
+ * It looks for a `seed.dev.ts` file and execute it.
+ * Content should look something like:
+ *
+ * ```
+ * import { PrismaClient } from "@prisma/client";
+ * const prisma = new PrismaClient();
+ * const main = async () => { ... }
+ *
+ * main()
+ *   .catch(e => console.error(e))
+ *   .finally(() => prisma.disconnect())
+ * ```
+ */
+const seedPath = path.join(__dirname, "seed.dev.ts");
+
+(() => {
+  try {
+    fs.accessSync(seedPath);
+  } catch (err) {
+    return;
+  }
+
+  import(seedPath);
+})();