feat(sponsor)

Author: Ajit Kumar

server/apis/sponsor.js

@@ -0,0 +1,76 @@
+const { Router } = require('express');
+const { writeFile, mkdir } = require('node:fs/promises');
+const Sponsor = require('../entities/sponsor');
+const { resolve } = require('node:path');
+const { existsSync } = require('node:fs');
+const { google } = require('googleapis');
+
+const router = Router();
+const androidpublisher = google.androidpublisher('v3');
+const sponsorImagesPath = resolve(__dirname, '../../data/sponsors');
+
+router.get('/', async (req, res) => {
+  const { page, limit } = req.query;
+
+  const rows = await Sponsor.get(Sponsor.safeColumns, [[Sponsor.STATUS, Sponsor.STATE_PURCHASED]], { page, limit });
+
+  res.send(rows);
+});
+
+router.post('/', async (req, res) => {
+  const { name, tier, email, image, public: show = 0, website, packageName, purchaseToken } = req.body;
+
+  if (!name) {
+    return res.status(400).json({
+      error: 'Missing required field: name',
+    });
+  }
+
+  if (!purchaseToken) {
+    return res.status(400).json({
+      error: 'Missing required field: purchaseToken',
+    });
+  }
+
+  if (!packageName) {
+    return res.status(400).json({
+      error: 'Missing required field: packageName',
+    });
+  }
+
+  try {
+    const { data: purchase } = await androidpublisher.purchases.products.get({
+      packageName,
+      productId: tier,
+      token: purchaseToken,
+    });
+
+    const filename = `${crypto.randomUUID()}.png`;
+    const path = resolve(sponsorImagesPath, filename);
+
+    if (!existsSync(sponsorImagesPath)) {
+      await mkdir(sponsorImagesPath, { recursive: true });
+    }
+
+    await writeFile(path, image.split(';base64,')[1], { encoding: 'base64' });
+    await Sponsor.insert(
+      [Sponsor.NAME, name],
+      [Sponsor.TIER, tier],
+      [Sponsor.EMAIL, email],
+      [Sponsor.PUBLIC, show],
+      [Sponsor.IMAGE, filename],
+      [Sponsor.WEBSITE, website],
+      [Sponsor.TOKEN, purchaseToken],
+      [Sponsor.PACKAGE_NAME, packageName],
+      [Sponsor.ORDER_ID, purchase.orderId],
+      [Sponsor.STATUS, purchase.purchaseState],
+    );
+
+    res.status(201).json({ message: 'Thank you for becoming a sponsor!' });
+  } catch (error) {
+    console.error('Error processing sponsorship:', error);
+    res.status(403).json({ error: 'Purchase not valid' });
+  }
+});
+
+module.exports = router;

server/crons/index.js

@@ -2,10 +2,12 @@ const { CronJob } = require('cron');
 const updateOrders = require('./updateOrders');
 const updateEarnings = require('../lib/updateEarnings');
 const cleanDb = require('./cleanDb');
+const updateSponsors = require('./updateSponsors');
 
 const daily = new CronJob('0 1 * * *', async () => {
   await updateOrders();
   await cleanDb();
+  await updateSponsors();
 });
 
 const monthly = new CronJob('0 0 16 * *', async () => {

server/crons/updateSponsors.js

@@ -0,0 +1,30 @@
+const { google } = require('googleapis');
+const Sponsor = require('../entities/sponsor');
+
+const androidpublisher = google.androidpublisher('v3');
+
+module.exports = async () => {
+  const sponsors = await Sponsor.get(Sponsor.columns, []);
+
+  for (const sponsor of sponsors) {
+    const { package_name: packageName, token, tier } = sponsor;
+
+    try {
+      const { data: purchase } = await androidpublisher.purchases.products.get({
+        token,
+        packageName,
+        productId: tier,
+      });
+
+      await Sponsor.update(
+        [
+          [Sponsor.STATUS, purchase.purchaseState],
+          [Sponsor.ORDER_ID, purchase.orderId],
+        ],
+        [Sponsor.ID, sponsor.id],
+      );
+    } catch (error) {
+      console.error(`Error updating sponsor ${sponsor.id}:`, error);
+    }
+  }
+};

server/entities/sponsor.js

@@ -0,0 +1,70 @@
+const Entity = require('./entity');
+
+const table = `create table if not exists sponsor (
+  id integer primary key,
+  name text not null,
+  token text not null,
+  email text not null,
+  order_id text not null,
+  amount integer,
+  user_id integer,
+  package_name text,
+  website text,
+  image text,
+  tier_name text,
+  tier_id text,
+  public integer default 0,
+  status integer default 2,
+  created_at timestamp default current_timestamp,
+  foreign key (user_id) references user(id) on delete set null
+);`;
+
+class Sponsor extends Entity {
+  ID = 'id';
+  NAME = 'name';
+  TIER = 'tier';
+  TOKEN = 'token';
+  EMAIL = 'email';
+  IMAGE = 'image';
+  AMOUNT = 'amount';
+  STATUS = 'status';
+  PUBLIC = 'public';
+  USER_ID = 'user_id';
+  WEBSITE = 'website';
+  ORDER_ID = 'order_id';
+  CREATED_AT = 'created_at';
+  PACKAGE_NAME = 'package_name';
+
+  STATE_PURCHASED = 0;
+  STATE_CANCELED = 1;
+  STATE_PENDING = 2;
+
+  constructor() {
+    super(table);
+  }
+
+  get columns() {
+    return [
+      this.ID,
+      this.NAME,
+      this.TIER,
+      this.TOKEN,
+      this.EMAIL,
+      this.IMAGE,
+      this.AMOUNT,
+      this.STATUS,
+      this.PUBLIC,
+      this.WEBSITE,
+      this.USER_ID,
+      this.ORDER_ID,
+      this.CREATED_AT,
+      this.PACKAGE_NAME,
+    ];
+  }
+
+  get safeColumns() {
+    return [this.ID, this.NAME, this.TIER, this.EMAIL, this.IMAGE, this.AMOUNT, this.STATUS, this.WEBSITE, this.CREATED_AT, this.PACKAGE_NAME];
+  }
+}
+
+module.exports = new Sponsor();

server/main.js

@@ -43,7 +43,11 @@ async function main() {
       },
     }),
   );
-  app.use(express.json());
+  app.use(
+    express.json({
+      limit: '50mb',
+    }),
+  );
 
   app.get('/sitemap.xml', (_req, res) => {
     res.setHeader('Content-Type', 'application/xml');
@@ -97,6 +101,17 @@ async function main() {
     res.status(404).send({ error: 'File not found' });
   });
 
+  app.get('/sponsor/image/:filename', async (req, res) => {
+    const { filename } = req.params;
+    const imagePath = path.resolve(__dirname, '../data/sponsors', filename);
+
+    if (!fs.existsSync(imagePath)) {
+      return res.status(404).json({ error: 'Image not found' });
+    }
+
+    res.sendFile(imagePath);
+  });
+
   app.get('/manifest.json', (_req, res) => {
     res.sendFile(path.resolve(__dirname, './manifest.json'));
   });

server/routes/apis.js

@@ -12,6 +12,7 @@ apis.use('/otp', require('../apis/otp'));
 apis.use(['/comments', '/comment'], require('../apis/comment'));
 apis.use('/faqs', require('../apis/faqs'));
 apis.use('/admin', require('../apis/admin'));
+apis.use(['/sponsor', '/sponsors'], require('../apis/sponsor'));
 // apis.use('/completion', require('../apis/completion'));
 
 apis.get('/status', (_req, res) => {