Ad Reward System with Server-Side Verification (SSV) Android

This is a Test Ad ID that you need to add in your AndroidManifest.xml file. This is needed or otherwise you'll get a compile-time error when you launch the app:

<meta-data
android:name="com.google.android.gms.ads.APPLICATION_ID"
android:value="ca-app-pub-3940256099942544~3347511713" />

exports = async function(authEvent) {

  const user = authEvent.user;

  const myUserCollection = context.services.get("mongodb-atlas").db("mydb").collection("MyUser");

  try {

    const existingUser = await myUserCollection.findOne({ ownerId: user.id });

    if (!existingUser) {

      const newUser = {

        ownerId: user.id,

        coins: 0,

        name: user.data.firstName,

        email: user.data.email,

        picture: user.data.picture

      };

      const result = await myUserCollection.insertOne(newUser);

      console.log(result)

      if (result.insertedId) {

        console.log(newUser)

        return newUser;

      } else {

        console.log("Insert failed.");

        return null;

      }

    } else {

      console.log("User already exists.");

      return null;

    }

  } catch (error) {

    console.error("Error:", error);

    return null;

  }

};

exports = async function(changeEvent) { try {

    if (changeEvent.operationType === "insert") {

        const serviceName = "mongodb-atlas";

        const databaseName = "mydb";

        const myUserCol = "MyUser"

        const rewardCol = "Reward"

        const ownerId = changeEvent.fullDocument.ownerId

        const title = changeEvent.fullDocument.title

        const myUserCollection = context.services.get(serviceName).db(databaseName).collection(myUserCol);

        const rewardCollection = context.services.get(serviceName).db(databaseName).collection(rewardCol);

        const reward = await rewardCollection.findOne({ title: title});

        const updateQuery = { ownerId: ownerId };

        const updateCoins = { $inc: { coins: -reward.coins } };

        await myUserCollection.updateOne(updateQuery, updateCoins);

    }

} catch(err) {

console.log("error performing mongodb write: ", err.message);

}

};