Marcus finishes x auto poster

package.json

@@ -119,7 +119,6 @@
     "node-cache": "^5.1.2",
     "node-cron": "^3.0.3",
     "node-datetime": "^2.0.3",
-    "node-fetch": "^2.6.7",
     "node-schedule": "^2.1.1",
     "nodemailer": "^7.0.11",
     "parse-link-header": "^2.0.0",
@@ -144,5 +143,6 @@
     "watch": [
       "/src/**/*"
     ]
-  }
+  },
+  "packageManager": "yarn@1.22.22+sha512.a6b2f7906b721bba3d67d4aff083df04dad64c399707841b7acf00f6b133b7ac24255f2652fa22ae3534329dc6180534e98d17432037ff6fd140556e2bb3137e"
 }

src/controllers/timeZoneAPIController.js

@@ -1,5 +1,3 @@
-// eslint-disable-next-line import/no-extraneous-dependencies
-const fetch = require('node-fetch');
 const dotenv = require('dotenv');
 
 dotenv.config();

src/controllers/timeZoneAPIController.spec.js

@@ -2,9 +2,8 @@ jest.mock('../utilities/permissions', () => ({
   hasPermission: jest.fn(), // Mocking the hasPermission function
 }));
 
-jest.mock('node-fetch');
-// eslint-disable-next-line import/no-extraneous-dependencies
-const fetch = require('node-fetch');
+global.fetch = jest.fn();
+const { fetch } = global;
 
 const originalPremiumKey = process.env.TIMEZONE_PREMIUM_KEY;
 process.env.TIMEZONE_PREMIUM_KEY = 'mockPremiumKey';

src/controllers/userProfileController.js

@@ -8,8 +8,6 @@
 const moment = require('moment-timezone');
 const mongoose = require('mongoose');
 const bcrypt = require('bcryptjs');
-// eslint-disable-next-line import/no-extraneous-dependencies
-const fetch = require('node-fetch');
 const moment_ = require('moment');
 const jwt = require('jsonwebtoken');
 const userHelper = require('../helpers/userHelper')();

src/controllers/xPostController.js

@@ -0,0 +1,106 @@
+const XScheduledPost = require('../models/xScheduledPost');
+const {
+  asyncRoute,
+  ValidationError,
+  NotFoundError,
+  validateContent,
+  findPostOr404,
+  applyUpdates,
+  X_MAX_CONTENT_LENGTH,
+} = require('../helpers/xPostHelpers');
+
+const requireFutureDate = (value, msg = 'scheduledAt must be in the future') => {
+  if (new Date(value) <= new Date()) throw new ValidationError(msg);
+};
+
+exports.createPost = asyncRoute(async (req, res) => {
+  const { content } = req.body;
+  validateContent(content);
+  const now = new Date();
+  const doc = await XScheduledPost.create({
+    content,
+    scheduledAt: now,
+    status: 'posted',
+    postedAt: now,
+    createdBy: req.user?._id,
+  });
+  return res.status(201).json({
+    message: 'Post staged successfully',
+    postId: doc._id,
+    intentUrl: `https://x.com/intent/tweet?text=${encodeURIComponent(content)}`,
+  });
+});
+
+exports.schedulePost = asyncRoute(async (req, res) => {
+  const { content, scheduledAt, mediaBase64, altText } = req.body;
+  validateContent(content);
+  if (!scheduledAt) throw new ValidationError('scheduledAt is required');
+  requireFutureDate(scheduledAt);
+  const doc = await XScheduledPost.create({
+    content,
+    scheduledAt: new Date(scheduledAt),
+    mediaBase64: mediaBase64 || null,
+    altText: altText || '',
+    createdBy: req.user?._id,
+  });
+  return res.status(201).json({ message: 'Post scheduled', post: doc });
+});
+
+exports.getScheduled = asyncRoute(async (req, res) => {
+  const posts = await XScheduledPost.find({ status: { $in: ['pending', 'ready'] } })
+    .sort({ scheduledAt: 1 })
+    .lean();
+  return res.json(posts);
+});
+
+exports.deleteScheduled = asyncRoute(async (req, res) => {
+  const doc = await XScheduledPost.findByIdAndDelete(req.params.id);
+  if (!doc) throw new NotFoundError('Scheduled post not found');
+  return res.json({ message: 'Scheduled post cancelled' });
+});
+
+exports.getHistory = asyncRoute(async (req, res) => {
+  const posts = await XScheduledPost.find({ status: 'posted' }).sort({ postedAt: -1 }).lean();
+  return res.json(posts);
+});
+
+exports.markAsPosted = asyncRoute(async (req, res) => {
+  const doc = await XScheduledPost.findByIdAndUpdate(
+    req.params.id,
+    { status: 'posted', postedAt: new Date() },
+    { new: true },
+  );
+  if (!doc) throw new NotFoundError('Scheduled post not found');
+  return res.json(doc);
+});
+
+exports.updateScheduledPost = asyncRoute(async (req, res) => {
+  const doc = await findPostOr404(XScheduledPost, req.params.id);
+  if (doc.status !== 'pending' && doc.status !== 'ready') {
+    throw new ValidationError(`Cannot edit a post with status: ${doc.status}`);
+  }
+  const { content, scheduledAt } = req.body;
+  if (
+    content !== undefined &&
+    (typeof content !== 'string' || content.length > X_MAX_CONTENT_LENGTH)
+  ) {
+    throw new ValidationError('Content must be a string of 280 characters or fewer');
+  }
+  if (scheduledAt !== undefined) {
+    requireFutureDate(scheduledAt);
+    req.body.scheduledAt = new Date(scheduledAt);
+  }
+  applyUpdates(doc, req.body, ['content', 'scheduledAt', 'mediaBase64', 'altText']);
+  await doc.save();
+  return res.json(doc);
+});
+
+exports.skipPost = asyncRoute(async (req, res) => {
+  const doc = await XScheduledPost.findByIdAndUpdate(
+    req.params.id,
+    { status: 'skipped' },
+    { new: true },
+  );
+  if (!doc) throw new NotFoundError('Scheduled post not found');
+  return res.json(doc);
+});

src/cronjobs/xScheduleJob.js

@@ -0,0 +1,22 @@
+const cron = require('node-cron');
+const XScheduledPost = require('../models/xScheduledPost');
+
+const runScheduler = async () => {
+  try {
+    const result = await XScheduledPost.updateMany(
+      { scheduledAt: { $lte: new Date() }, status: 'pending' },
+      { $set: { status: 'ready' } },
+    );
+    if (result.modifiedCount > 0) {
+      // eslint-disable-next-line no-console
+      console.log(`[xScheduler] Promoted ${result.modifiedCount} post(s) to ready`);
+    }
+  } catch (err) {
+    // eslint-disable-next-line no-console
+    console.error('[xScheduler] Error promoting posts:', err.message);
+  }
+};
+
+const start = () => cron.schedule('* * * * *', runScheduler);
+
+module.exports = { start, runScheduler };

src/helpers/githubPRHelper.js

@@ -1,5 +1,3 @@
-// eslint-disable-next-line import/no-extraneous-dependencies
-const fetch = require('node-fetch');
 const { RateLimitedError } = require('../utilities/errorHandling/customError');
 
 function createGitHubClient({ owner, repo }) {