87338ac220
Adds functionality for admins to update media outlet descriptions via an API endpoint and UI modal, including an option to use a predefined alternative description. Replit-Commit-Author: Agent Replit-Commit-Session-Id: 069d4324-6c40-4355-955e-c714a50de1ea Replit-Commit-Checkpoint-Type: full_checkpoint Replit-Commit-Screenshot-Url: https://storage.googleapis.com/screenshot-production-us-central1/3df548ff-50ae-432f-9be4-25d34eccc983/069d4324-6c40-4355-955e-c714a50de1ea/UXwUwik
398 lines
13 KiB
TypeScript
398 lines
13 KiB
TypeScript
import type { Express } from "express";
|
|
import { createServer, type Server } from "http";
|
|
import { storage } from "./storage";
|
|
import { setupAuth, isAuthenticated } from "./simpleAuth";
|
|
import { insertArticleSchema, insertMediaOutletRequestSchema, insertBidSchema, insertCommentSchema, insertPredictionBetSchema } from "@shared/schema";
|
|
|
|
export async function registerRoutes(app: Express): Promise<Server> {
|
|
// Auth middleware
|
|
await setupAuth(app);
|
|
|
|
// Auth routes
|
|
app.get('/api/auth/user', isAuthenticated, async (req: any, res) => {
|
|
try {
|
|
const user = req.user;
|
|
res.json(user);
|
|
} catch (error) {
|
|
console.error("Error fetching user:", error);
|
|
res.status(500).json({ message: "Failed to fetch user" });
|
|
}
|
|
});
|
|
|
|
// Media outlet routes
|
|
app.get('/api/media-outlets', async (req, res) => {
|
|
try {
|
|
const category = req.query.category as string;
|
|
const outlets = await storage.getMediaOutlets(category);
|
|
res.json(outlets);
|
|
} catch (error) {
|
|
console.error("Error fetching media outlets:", error);
|
|
res.status(500).json({ message: "Failed to fetch media outlets" });
|
|
}
|
|
});
|
|
|
|
app.get('/api/media-outlets/:slug', async (req, res) => {
|
|
try {
|
|
const outlet = await storage.getMediaOutletBySlug(req.params.slug);
|
|
if (!outlet) {
|
|
return res.status(404).json({ message: "Media outlet not found" });
|
|
}
|
|
res.json(outlet);
|
|
} catch (error) {
|
|
console.error("Error fetching media outlet:", error);
|
|
res.status(500).json({ message: "Failed to fetch media outlet" });
|
|
}
|
|
});
|
|
|
|
app.patch('/api/media-outlets/:slug', isAuthenticated, async (req: any, res) => {
|
|
try {
|
|
const user = req.user;
|
|
|
|
if (!user || (user.role !== 'admin' && user.role !== 'superadmin')) {
|
|
return res.status(403).json({ message: "Insufficient permissions" });
|
|
}
|
|
|
|
const { description } = req.body;
|
|
const outlet = await storage.getMediaOutletBySlug(req.params.slug);
|
|
|
|
if (!outlet) {
|
|
return res.status(404).json({ message: "Media outlet not found" });
|
|
}
|
|
|
|
await storage.updateMediaOutlet(outlet.id, { description });
|
|
const updated = await storage.getMediaOutletBySlug(req.params.slug);
|
|
res.json(updated);
|
|
} catch (error) {
|
|
console.error("Error updating media outlet:", error);
|
|
res.status(500).json({ message: "Failed to update media outlet" });
|
|
}
|
|
});
|
|
|
|
// Article routes
|
|
app.get('/api/media-outlets/:outletId/articles', async (req, res) => {
|
|
try {
|
|
const articles = await storage.getArticlesByOutlet(req.params.outletId);
|
|
res.json(articles);
|
|
} catch (error) {
|
|
console.error("Error fetching articles:", error);
|
|
res.status(500).json({ message: "Failed to fetch articles" });
|
|
}
|
|
});
|
|
|
|
app.get('/api/media-outlets/:slug/articles', async (req, res) => {
|
|
try {
|
|
const outlet = await storage.getMediaOutletBySlug(req.params.slug);
|
|
if (!outlet) {
|
|
return res.status(404).json({ message: "Media outlet not found" });
|
|
}
|
|
const articles = await storage.getArticlesByOutlet(outlet.id);
|
|
res.json(articles);
|
|
} catch (error) {
|
|
console.error("Error fetching articles by slug:", error);
|
|
res.status(500).json({ message: "Failed to fetch articles" });
|
|
}
|
|
});
|
|
|
|
app.get('/api/articles/:slug', async (req, res) => {
|
|
try {
|
|
const article = await storage.getArticleBySlug(req.params.slug);
|
|
if (!article) {
|
|
return res.status(404).json({ message: "Article not found" });
|
|
}
|
|
res.json(article);
|
|
} catch (error) {
|
|
console.error("Error fetching article:", error);
|
|
res.status(500).json({ message: "Failed to fetch article" });
|
|
}
|
|
});
|
|
|
|
app.get('/api/articles/:slug/markets', async (req, res) => {
|
|
try {
|
|
const article = await storage.getArticleBySlug(req.params.slug);
|
|
if (!article) {
|
|
return res.status(404).json({ message: "Article not found" });
|
|
}
|
|
const markets = await storage.getPredictionMarkets(article.id);
|
|
res.json(markets);
|
|
} catch (error) {
|
|
console.error("Error fetching prediction markets for article:", error);
|
|
res.status(500).json({ message: "Failed to fetch prediction markets" });
|
|
}
|
|
});
|
|
|
|
app.get('/api/articles/featured', async (req, res) => {
|
|
try {
|
|
const limit = parseInt(req.query.limit as string) || 10;
|
|
const articles = await storage.getFeaturedArticles(limit);
|
|
res.json(articles);
|
|
} catch (error) {
|
|
console.error("Error fetching featured articles:", error);
|
|
res.status(500).json({ message: "Failed to fetch featured articles" });
|
|
}
|
|
});
|
|
|
|
app.post('/api/articles', isAuthenticated, async (req: any, res) => {
|
|
try {
|
|
const user = req.user;
|
|
|
|
if (!user || (user.role !== 'admin' && user.role !== 'superadmin')) {
|
|
return res.status(403).json({ message: "Insufficient permissions" });
|
|
}
|
|
|
|
const articleData = insertArticleSchema.parse({
|
|
...req.body,
|
|
authorId: user.id
|
|
});
|
|
|
|
const article = await storage.createArticle(articleData);
|
|
res.status(201).json(article);
|
|
} catch (error) {
|
|
console.error("Error creating article:", error);
|
|
res.status(500).json({ message: "Failed to create article" });
|
|
}
|
|
});
|
|
|
|
// Prediction market routes
|
|
app.get('/api/prediction-markets', async (req, res) => {
|
|
try {
|
|
const articleId = req.query.articleId as string;
|
|
const markets = await storage.getPredictionMarkets(articleId);
|
|
res.json(markets);
|
|
} catch (error) {
|
|
console.error("Error fetching prediction markets:", error);
|
|
res.status(500).json({ message: "Failed to fetch prediction markets" });
|
|
}
|
|
});
|
|
|
|
// Auction routes
|
|
app.get('/api/auctions', async (req, res) => {
|
|
try {
|
|
const auctions = await storage.getActiveAuctions();
|
|
res.json(auctions);
|
|
} catch (error) {
|
|
console.error("Error fetching auctions:", error);
|
|
res.status(500).json({ message: "Failed to fetch auctions" });
|
|
}
|
|
});
|
|
|
|
app.get('/api/media-outlets/:slug/auction', async (req, res) => {
|
|
try {
|
|
const outlet = await storage.getMediaOutletBySlug(req.params.slug);
|
|
if (!outlet) {
|
|
return res.status(404).json({ message: "Media outlet not found" });
|
|
}
|
|
const auction = await storage.getAuctionByMediaOutlet(outlet.id);
|
|
res.json(auction || null);
|
|
} catch (error) {
|
|
console.error("Error fetching auction:", error);
|
|
res.status(500).json({ message: "Failed to fetch auction" });
|
|
}
|
|
});
|
|
|
|
app.get('/api/auctions/:id/bids', async (req, res) => {
|
|
try {
|
|
const bids = await storage.getBidsByAuctionId(req.params.id);
|
|
res.json(bids);
|
|
} catch (error) {
|
|
console.error("Error fetching bids:", error);
|
|
res.status(500).json({ message: "Failed to fetch bids" });
|
|
}
|
|
});
|
|
|
|
app.post('/api/auctions/:id/bid', isAuthenticated, async (req: any, res) => {
|
|
try {
|
|
const userId = req.user.claims?.sub || req.user.id;
|
|
const bidData = insertBidSchema.parse({
|
|
...req.body,
|
|
auctionId: req.params.id,
|
|
bidderId: userId
|
|
});
|
|
|
|
const bid = await storage.placeBid(bidData);
|
|
res.status(201).json(bid);
|
|
} catch (error) {
|
|
console.error("Error placing bid:", error);
|
|
res.status(500).json({ message: "Failed to place bid" });
|
|
}
|
|
});
|
|
|
|
app.post('/api/media-outlets/:slug/auction/bids', isAuthenticated, async (req: any, res) => {
|
|
try {
|
|
const outlet = await storage.getMediaOutletBySlug(req.params.slug);
|
|
if (!outlet) {
|
|
return res.status(404).json({ message: "Media outlet not found" });
|
|
}
|
|
|
|
const auction = await storage.getAuctionByMediaOutlet(outlet.id);
|
|
if (!auction) {
|
|
return res.status(404).json({ message: "No active auction found for this media outlet" });
|
|
}
|
|
|
|
const userId = req.user.claims?.sub || req.user.id;
|
|
const bidData = insertBidSchema.parse({
|
|
...req.body,
|
|
auctionId: auction.id,
|
|
bidderId: userId
|
|
});
|
|
|
|
const bid = await storage.placeBid(bidData);
|
|
res.status(201).json(bid);
|
|
} catch (error) {
|
|
console.error("Error placing bid:", error);
|
|
res.status(500).json({ message: "Failed to place bid" });
|
|
}
|
|
});
|
|
|
|
// Prediction market betting endpoints
|
|
app.post('/api/prediction-markets/:marketId/bets', isAuthenticated, async (req: any, res) => {
|
|
try {
|
|
const userId = req.user.claims?.sub || req.user.id;
|
|
const { side, amount } = req.body;
|
|
|
|
// Validate request
|
|
if (!side || !amount || !["yes", "no"].includes(side)) {
|
|
return res.status(400).json({ message: "Invalid bet data" });
|
|
}
|
|
|
|
if (parseFloat(amount) <= 0) {
|
|
return res.status(400).json({ message: "Bet amount must be positive" });
|
|
}
|
|
|
|
const betData = insertPredictionBetSchema.parse({
|
|
marketId: req.params.marketId,
|
|
userId,
|
|
side,
|
|
amount: amount.toString()
|
|
});
|
|
|
|
const bet = await storage.createPredictionBet(betData);
|
|
res.status(201).json(bet);
|
|
} catch (error) {
|
|
console.error("Error placing prediction bet:", error);
|
|
if (error.message === "Prediction market not found") {
|
|
return res.status(404).json({ message: "Prediction market not found" });
|
|
}
|
|
res.status(500).json({ message: "Failed to place bet" });
|
|
}
|
|
});
|
|
|
|
// Media outlet request routes
|
|
app.get('/api/media-outlet-requests', isAuthenticated, async (req: any, res) => {
|
|
try {
|
|
const userId = req.user.claims?.sub || req.user.id;
|
|
const user = await storage.getUser(userId);
|
|
|
|
if (!user || user.role !== 'superadmin') {
|
|
return res.status(403).json({ message: "Insufficient permissions" });
|
|
}
|
|
|
|
const status = req.query.status as string;
|
|
const requests = await storage.getMediaOutletRequests(status);
|
|
res.json(requests);
|
|
} catch (error) {
|
|
console.error("Error fetching requests:", error);
|
|
res.status(500).json({ message: "Failed to fetch requests" });
|
|
}
|
|
});
|
|
|
|
app.post('/api/media-outlet-requests', isAuthenticated, async (req: any, res) => {
|
|
try {
|
|
const userId = req.user.claims?.sub || req.user.id;
|
|
const requestData = insertMediaOutletRequestSchema.parse({
|
|
...req.body,
|
|
requesterId: userId
|
|
});
|
|
|
|
const request = await storage.createMediaOutletRequest(requestData);
|
|
res.status(201).json(request);
|
|
} catch (error) {
|
|
console.error("Error creating request:", error);
|
|
res.status(500).json({ message: "Failed to create request" });
|
|
}
|
|
});
|
|
|
|
app.patch('/api/media-outlet-requests/:id', isAuthenticated, async (req: any, res) => {
|
|
try {
|
|
const userId = req.user.claims?.sub || req.user.id;
|
|
const user = await storage.getUser(userId);
|
|
|
|
if (!user || user.role !== 'superadmin') {
|
|
return res.status(403).json({ message: "Insufficient permissions" });
|
|
}
|
|
|
|
const { status } = req.body;
|
|
const request = await storage.updateMediaOutletRequestStatus(req.params.id, status, userId);
|
|
res.json(request);
|
|
} catch (error) {
|
|
console.error("Error updating request:", error);
|
|
res.status(500).json({ message: "Failed to update request" });
|
|
}
|
|
});
|
|
|
|
// Comment routes
|
|
app.get('/api/articles/:articleId/comments', async (req, res) => {
|
|
try {
|
|
const comments = await storage.getCommentsByArticle(req.params.articleId);
|
|
res.json(comments);
|
|
} catch (error) {
|
|
console.error("Error fetching comments:", error);
|
|
res.status(500).json({ message: "Failed to fetch comments" });
|
|
}
|
|
});
|
|
|
|
app.post('/api/articles/:articleId/comments', isAuthenticated, async (req: any, res) => {
|
|
try {
|
|
const userId = req.user.claims?.sub || req.user.id;
|
|
const commentData = insertCommentSchema.parse({
|
|
...req.body,
|
|
articleId: req.params.articleId,
|
|
authorId: userId
|
|
});
|
|
|
|
const comment = await storage.createComment(commentData);
|
|
res.status(201).json(comment);
|
|
} catch (error) {
|
|
console.error("Error creating comment:", error);
|
|
res.status(500).json({ message: "Failed to create comment" });
|
|
}
|
|
});
|
|
|
|
// Analytics routes
|
|
app.get('/api/analytics', isAuthenticated, async (req: any, res) => {
|
|
try {
|
|
const userId = req.user.claims?.sub || req.user.id;
|
|
const user = await storage.getUser(userId);
|
|
|
|
if (!user || (user.role !== 'admin' && user.role !== 'superadmin')) {
|
|
return res.status(403).json({ message: "Insufficient permissions" });
|
|
}
|
|
|
|
const analytics = await storage.getAnalytics();
|
|
res.json(analytics);
|
|
} catch (error) {
|
|
console.error("Error fetching analytics:", error);
|
|
res.status(500).json({ message: "Failed to fetch analytics" });
|
|
}
|
|
});
|
|
|
|
// Search routes
|
|
app.get('/api/search', async (req, res) => {
|
|
try {
|
|
const { q } = req.query;
|
|
|
|
if (!q || typeof q !== 'string' || q.trim().length === 0) {
|
|
return res.json({ outlets: [], articles: [] });
|
|
}
|
|
|
|
const results = await storage.search(q.trim());
|
|
res.json(results);
|
|
} catch (error) {
|
|
console.error("Error performing search:", error);
|
|
res.status(500).json({ message: "Failed to perform search" });
|
|
}
|
|
});
|
|
|
|
const httpServer = createServer(app);
|
|
return httpServer;
|
|
}
|