Function run

packages/maintenance/src/import-users.ts:55–107

()

};

async function run() {
  if (process.argv.length < 4) {
    throw 'missing params, try: npm run script:import-user -- "accountId" "/full/path/file.csv"';
  }
  const accountId = process.argv[2];
  const file = fs.readFileSync(process.argv[3]);

  const { data } = Papa.parse(file.toString(), {
    header: true,
    skipEmptyLines: true,
  });
  const users = data as Users[];

  const toUpsert: Prisma.usersCreateInput[] = users.map((user) => {
    return {
      account: { connect: { id: accountId } },
      anonymousAlias: generateRandomWordSlug(),
      ...(shouldCreateAuth(user.status) && {
        auth: {
          connectOrCreate: {
            create: {
              email: user.email,
              password: v4(),
              salt: v4(),
              accountId,
            },
            where: { email: user.email },
          },
        },
      }),
      displayName: user.displayname || user.username,
      externalUserId: user.userid,
      role: mapRole(user.status),
      isAdmin: isAdmin(user.status),
      isBot: isBot(user.status),
    };
  });

  await Promise.all(
    toUpsert.map((data) =>
      prisma.users.upsert({
        create: data,
        update: data,
        where: {
          externalUserId_accountsId: {
            accountsId: accountId,
            externalUserId: data.externalUserId!,
          },
        },
      })
    )
  );
}

run().catch(console.error);