atena

atena.js

export const save = async data => {
  if (isBot(data)) {
    return;
  }
  let valid = true;
  let interaction;
  // apply valid function to others integrations
  if (data.origin === "rocket") {
    await exportFunctions
      .validInteraction(data)
      .then(() => {
        interaction = rocketController.normalize(data);
      })
      .catch(() => {
        valid = false;
      });
  } else {
    interaction = exportFunctions.normalize(data);
  }

  if (valid) {
    const todayLimitScore = config.xprules.limits.daily;
    const score = await exportFunctions.todayScore(interaction.user);
    const todayLimitStatus = todayLimitScore - score;
    const instance = interactionModel(interaction);
    const maxSeconds = 5;

    analyticsSendCollect(interaction);

    if (
      interaction.type === "message" &&
      moment(interaction.date).diff(
        await lastMessageTime(instance),
        "seconds"
      ) < maxSeconds
    ) {
      console.log("FLOOD");
      return _throw("User makes flood");
    }

    if (todayLimitStatus > 0 || !todayLimitStatus) {
      instance.score = calculateScore(interaction);
      await userController.update(interaction);
      // await achievementController.save(interaction);
      // await achievementTemporaryController.save(interaction);

      if (
        ![
          "message",
          "issue",
          "review",
          "pull_request",
          "merged_pull_request",
          "comment"
        ].includes(interaction.type) &&
        interaction.parentUser !== interaction.user
      ) {
        await userController.updateParentUser(interaction);
      }
    }
    // const instance = interactionModel(interaction);
    return await instance.save();
  } else {
    return new Promise((resolve, reject) => {
      reject("add new interaction");
    });
  }
};