2026-01-20 13:58:13 -05:00
|
|
|
import pool from '../config/database';
|
|
|
|
|
|
|
|
|
|
// User types and queries
|
|
|
|
|
export interface User {
|
|
|
|
|
id: number;
|
|
|
|
|
email: string;
|
|
|
|
|
password_hash: string;
|
2026-01-21 07:58:11 -05:00
|
|
|
name: string | null;
|
|
|
|
|
is_admin: boolean;
|
2026-01-20 21:15:04 -05:00
|
|
|
telegram_bot_token: string | null;
|
|
|
|
|
telegram_chat_id: string | null;
|
|
|
|
|
discord_webhook_url: string | null;
|
2026-01-20 13:58:13 -05:00
|
|
|
created_at: Date;
|
|
|
|
|
}
|
|
|
|
|
|
2026-01-21 07:58:11 -05:00
|
|
|
export interface UserProfile {
|
|
|
|
|
id: number;
|
|
|
|
|
email: string;
|
|
|
|
|
name: string | null;
|
|
|
|
|
is_admin: boolean;
|
|
|
|
|
created_at: Date;
|
|
|
|
|
}
|
|
|
|
|
|
2026-01-20 21:15:04 -05:00
|
|
|
export interface NotificationSettings {
|
|
|
|
|
telegram_bot_token: string | null;
|
|
|
|
|
telegram_chat_id: string | null;
|
2026-01-22 14:07:44 -05:00
|
|
|
telegram_enabled: boolean;
|
2026-01-20 21:15:04 -05:00
|
|
|
discord_webhook_url: string | null;
|
2026-01-22 14:07:44 -05:00
|
|
|
discord_enabled: boolean;
|
2026-01-22 13:48:31 -05:00
|
|
|
pushover_user_key: string | null;
|
|
|
|
|
pushover_app_token: string | null;
|
2026-01-22 14:07:44 -05:00
|
|
|
pushover_enabled: boolean;
|
2026-01-20 21:15:04 -05:00
|
|
|
}
|
|
|
|
|
|
2026-01-21 21:49:55 -05:00
|
|
|
export interface AISettings {
|
|
|
|
|
ai_enabled: boolean;
|
|
|
|
|
ai_provider: 'anthropic' | 'openai' | null;
|
|
|
|
|
anthropic_api_key: string | null;
|
|
|
|
|
openai_api_key: string | null;
|
|
|
|
|
}
|
|
|
|
|
|
2026-01-20 13:58:13 -05:00
|
|
|
export const userQueries = {
|
|
|
|
|
findByEmail: async (email: string): Promise<User | null> => {
|
|
|
|
|
const result = await pool.query(
|
|
|
|
|
'SELECT * FROM users WHERE email = $1',
|
|
|
|
|
[email]
|
|
|
|
|
);
|
|
|
|
|
return result.rows[0] || null;
|
|
|
|
|
},
|
|
|
|
|
|
|
|
|
|
findById: async (id: number): Promise<User | null> => {
|
|
|
|
|
const result = await pool.query(
|
|
|
|
|
'SELECT * FROM users WHERE id = $1',
|
|
|
|
|
[id]
|
|
|
|
|
);
|
|
|
|
|
return result.rows[0] || null;
|
|
|
|
|
},
|
|
|
|
|
|
|
|
|
|
create: async (email: string, passwordHash: string): Promise<User> => {
|
|
|
|
|
const result = await pool.query(
|
|
|
|
|
'INSERT INTO users (email, password_hash) VALUES ($1, $2) RETURNING *',
|
|
|
|
|
[email, passwordHash]
|
|
|
|
|
);
|
|
|
|
|
return result.rows[0];
|
|
|
|
|
},
|
2026-01-20 21:15:04 -05:00
|
|
|
|
|
|
|
|
getNotificationSettings: async (id: number): Promise<NotificationSettings | null> => {
|
|
|
|
|
const result = await pool.query(
|
2026-01-22 14:07:44 -05:00
|
|
|
`SELECT telegram_bot_token, telegram_chat_id, COALESCE(telegram_enabled, true) as telegram_enabled,
|
|
|
|
|
discord_webhook_url, COALESCE(discord_enabled, true) as discord_enabled,
|
|
|
|
|
pushover_user_key, pushover_app_token, COALESCE(pushover_enabled, true) as pushover_enabled
|
|
|
|
|
FROM users WHERE id = $1`,
|
2026-01-20 21:15:04 -05:00
|
|
|
[id]
|
|
|
|
|
);
|
|
|
|
|
return result.rows[0] || null;
|
|
|
|
|
},
|
|
|
|
|
|
|
|
|
|
updateNotificationSettings: async (
|
|
|
|
|
id: number,
|
|
|
|
|
settings: Partial<NotificationSettings>
|
|
|
|
|
): Promise<NotificationSettings | null> => {
|
|
|
|
|
const fields: string[] = [];
|
2026-01-22 14:07:44 -05:00
|
|
|
const values: (string | boolean | null)[] = [];
|
2026-01-20 21:15:04 -05:00
|
|
|
let paramIndex = 1;
|
|
|
|
|
|
|
|
|
|
if (settings.telegram_bot_token !== undefined) {
|
|
|
|
|
fields.push(`telegram_bot_token = $${paramIndex++}`);
|
|
|
|
|
values.push(settings.telegram_bot_token);
|
|
|
|
|
}
|
|
|
|
|
if (settings.telegram_chat_id !== undefined) {
|
|
|
|
|
fields.push(`telegram_chat_id = $${paramIndex++}`);
|
|
|
|
|
values.push(settings.telegram_chat_id);
|
|
|
|
|
}
|
2026-01-22 14:07:44 -05:00
|
|
|
if (settings.telegram_enabled !== undefined) {
|
|
|
|
|
fields.push(`telegram_enabled = $${paramIndex++}`);
|
|
|
|
|
values.push(settings.telegram_enabled);
|
|
|
|
|
}
|
2026-01-20 21:15:04 -05:00
|
|
|
if (settings.discord_webhook_url !== undefined) {
|
|
|
|
|
fields.push(`discord_webhook_url = $${paramIndex++}`);
|
|
|
|
|
values.push(settings.discord_webhook_url);
|
|
|
|
|
}
|
2026-01-22 14:07:44 -05:00
|
|
|
if (settings.discord_enabled !== undefined) {
|
|
|
|
|
fields.push(`discord_enabled = $${paramIndex++}`);
|
|
|
|
|
values.push(settings.discord_enabled);
|
|
|
|
|
}
|
2026-01-22 13:48:31 -05:00
|
|
|
if (settings.pushover_user_key !== undefined) {
|
|
|
|
|
fields.push(`pushover_user_key = $${paramIndex++}`);
|
|
|
|
|
values.push(settings.pushover_user_key);
|
|
|
|
|
}
|
|
|
|
|
if (settings.pushover_app_token !== undefined) {
|
|
|
|
|
fields.push(`pushover_app_token = $${paramIndex++}`);
|
|
|
|
|
values.push(settings.pushover_app_token);
|
|
|
|
|
}
|
2026-01-22 14:07:44 -05:00
|
|
|
if (settings.pushover_enabled !== undefined) {
|
|
|
|
|
fields.push(`pushover_enabled = $${paramIndex++}`);
|
|
|
|
|
values.push(settings.pushover_enabled);
|
|
|
|
|
}
|
2026-01-20 21:15:04 -05:00
|
|
|
|
|
|
|
|
if (fields.length === 0) return null;
|
|
|
|
|
|
|
|
|
|
values.push(id.toString());
|
|
|
|
|
const result = await pool.query(
|
|
|
|
|
`UPDATE users SET ${fields.join(', ')} WHERE id = $${paramIndex}
|
2026-01-22 14:07:44 -05:00
|
|
|
RETURNING telegram_bot_token, telegram_chat_id, COALESCE(telegram_enabled, true) as telegram_enabled,
|
|
|
|
|
discord_webhook_url, COALESCE(discord_enabled, true) as discord_enabled,
|
|
|
|
|
pushover_user_key, pushover_app_token, COALESCE(pushover_enabled, true) as pushover_enabled`,
|
2026-01-20 21:15:04 -05:00
|
|
|
values
|
|
|
|
|
);
|
|
|
|
|
return result.rows[0] || null;
|
|
|
|
|
},
|
2026-01-21 07:58:11 -05:00
|
|
|
|
|
|
|
|
getProfile: async (id: number): Promise<UserProfile | null> => {
|
|
|
|
|
const result = await pool.query(
|
|
|
|
|
'SELECT id, email, name, is_admin, created_at FROM users WHERE id = $1',
|
|
|
|
|
[id]
|
|
|
|
|
);
|
|
|
|
|
return result.rows[0] || null;
|
|
|
|
|
},
|
|
|
|
|
|
|
|
|
|
updateProfile: async (
|
|
|
|
|
id: number,
|
|
|
|
|
updates: { name?: string }
|
|
|
|
|
): Promise<UserProfile | null> => {
|
|
|
|
|
const fields: string[] = [];
|
|
|
|
|
const values: (string | number)[] = [];
|
|
|
|
|
let paramIndex = 1;
|
|
|
|
|
|
|
|
|
|
if (updates.name !== undefined) {
|
|
|
|
|
fields.push(`name = $${paramIndex++}`);
|
|
|
|
|
values.push(updates.name);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (fields.length === 0) return null;
|
|
|
|
|
|
|
|
|
|
values.push(id);
|
|
|
|
|
const result = await pool.query(
|
|
|
|
|
`UPDATE users SET ${fields.join(', ')} WHERE id = $${paramIndex}
|
|
|
|
|
RETURNING id, email, name, is_admin, created_at`,
|
|
|
|
|
values
|
|
|
|
|
);
|
|
|
|
|
return result.rows[0] || null;
|
|
|
|
|
},
|
|
|
|
|
|
|
|
|
|
updatePassword: async (id: number, passwordHash: string): Promise<boolean> => {
|
|
|
|
|
const result = await pool.query(
|
|
|
|
|
'UPDATE users SET password_hash = $1 WHERE id = $2',
|
|
|
|
|
[passwordHash, id]
|
|
|
|
|
);
|
|
|
|
|
return (result.rowCount ?? 0) > 0;
|
|
|
|
|
},
|
|
|
|
|
|
|
|
|
|
// Admin queries
|
|
|
|
|
findAll: async (): Promise<UserProfile[]> => {
|
|
|
|
|
const result = await pool.query(
|
|
|
|
|
'SELECT id, email, name, is_admin, created_at FROM users ORDER BY created_at ASC'
|
|
|
|
|
);
|
|
|
|
|
return result.rows;
|
|
|
|
|
},
|
|
|
|
|
|
|
|
|
|
delete: async (id: number): Promise<boolean> => {
|
|
|
|
|
const result = await pool.query(
|
|
|
|
|
'DELETE FROM users WHERE id = $1',
|
|
|
|
|
[id]
|
|
|
|
|
);
|
|
|
|
|
return (result.rowCount ?? 0) > 0;
|
|
|
|
|
},
|
|
|
|
|
|
|
|
|
|
setAdmin: async (id: number, isAdmin: boolean): Promise<boolean> => {
|
|
|
|
|
const result = await pool.query(
|
|
|
|
|
'UPDATE users SET is_admin = $1 WHERE id = $2',
|
|
|
|
|
[isAdmin, id]
|
|
|
|
|
);
|
|
|
|
|
return (result.rowCount ?? 0) > 0;
|
|
|
|
|
},
|
2026-01-21 21:49:55 -05:00
|
|
|
|
|
|
|
|
getAISettings: async (id: number): Promise<AISettings | null> => {
|
|
|
|
|
const result = await pool.query(
|
|
|
|
|
'SELECT ai_enabled, ai_provider, anthropic_api_key, openai_api_key FROM users WHERE id = $1',
|
|
|
|
|
[id]
|
|
|
|
|
);
|
|
|
|
|
return result.rows[0] || null;
|
|
|
|
|
},
|
|
|
|
|
|
|
|
|
|
updateAISettings: async (
|
|
|
|
|
id: number,
|
|
|
|
|
settings: Partial<AISettings>
|
|
|
|
|
): Promise<AISettings | null> => {
|
|
|
|
|
const fields: string[] = [];
|
|
|
|
|
const values: (string | boolean | null)[] = [];
|
|
|
|
|
let paramIndex = 1;
|
|
|
|
|
|
|
|
|
|
if (settings.ai_enabled !== undefined) {
|
|
|
|
|
fields.push(`ai_enabled = $${paramIndex++}`);
|
|
|
|
|
values.push(settings.ai_enabled);
|
|
|
|
|
}
|
|
|
|
|
if (settings.ai_provider !== undefined) {
|
|
|
|
|
fields.push(`ai_provider = $${paramIndex++}`);
|
|
|
|
|
values.push(settings.ai_provider);
|
|
|
|
|
}
|
|
|
|
|
if (settings.anthropic_api_key !== undefined) {
|
|
|
|
|
fields.push(`anthropic_api_key = $${paramIndex++}`);
|
|
|
|
|
values.push(settings.anthropic_api_key);
|
|
|
|
|
}
|
|
|
|
|
if (settings.openai_api_key !== undefined) {
|
|
|
|
|
fields.push(`openai_api_key = $${paramIndex++}`);
|
|
|
|
|
values.push(settings.openai_api_key);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (fields.length === 0) return null;
|
|
|
|
|
|
|
|
|
|
values.push(id.toString());
|
|
|
|
|
const result = await pool.query(
|
|
|
|
|
`UPDATE users SET ${fields.join(', ')} WHERE id = $${paramIndex}
|
|
|
|
|
RETURNING ai_enabled, ai_provider, anthropic_api_key, openai_api_key`,
|
|
|
|
|
values
|
|
|
|
|
);
|
|
|
|
|
return result.rows[0] || null;
|
|
|
|
|
},
|
2026-01-21 07:58:11 -05:00
|
|
|
};
|
|
|
|
|
|
|
|
|
|
// System settings queries
|
|
|
|
|
export const systemSettingsQueries = {
|
|
|
|
|
get: async (key: string): Promise<string | null> => {
|
|
|
|
|
const result = await pool.query(
|
|
|
|
|
'SELECT value FROM system_settings WHERE key = $1',
|
|
|
|
|
[key]
|
|
|
|
|
);
|
|
|
|
|
return result.rows[0]?.value || null;
|
|
|
|
|
},
|
|
|
|
|
|
|
|
|
|
set: async (key: string, value: string): Promise<void> => {
|
|
|
|
|
await pool.query(
|
|
|
|
|
`INSERT INTO system_settings (key, value, updated_at)
|
|
|
|
|
VALUES ($1, $2, CURRENT_TIMESTAMP)
|
|
|
|
|
ON CONFLICT (key) DO UPDATE SET value = $2, updated_at = CURRENT_TIMESTAMP`,
|
|
|
|
|
[key, value]
|
|
|
|
|
);
|
|
|
|
|
},
|
|
|
|
|
|
|
|
|
|
getAll: async (): Promise<Record<string, string>> => {
|
|
|
|
|
const result = await pool.query('SELECT key, value FROM system_settings');
|
|
|
|
|
const settings: Record<string, string> = {};
|
|
|
|
|
for (const row of result.rows) {
|
|
|
|
|
settings[row.key] = row.value;
|
|
|
|
|
}
|
|
|
|
|
return settings;
|
|
|
|
|
},
|
2026-01-20 13:58:13 -05:00
|
|
|
};
|
|
|
|
|
|
|
|
|
|
// Product types and queries
|
2026-01-20 20:54:12 -05:00
|
|
|
export type StockStatus = 'in_stock' | 'out_of_stock' | 'unknown';
|
|
|
|
|
|
2026-01-20 13:58:13 -05:00
|
|
|
export interface Product {
|
|
|
|
|
id: number;
|
|
|
|
|
user_id: number;
|
|
|
|
|
url: string;
|
|
|
|
|
name: string | null;
|
|
|
|
|
image_url: string | null;
|
|
|
|
|
refresh_interval: number;
|
|
|
|
|
last_checked: Date | null;
|
2026-01-20 21:34:28 -05:00
|
|
|
next_check_at: Date | null;
|
2026-01-20 20:54:12 -05:00
|
|
|
stock_status: StockStatus;
|
2026-01-20 21:15:04 -05:00
|
|
|
price_drop_threshold: number | null;
|
2026-01-21 13:40:39 -05:00
|
|
|
target_price: number | null;
|
2026-01-20 21:15:04 -05:00
|
|
|
notify_back_in_stock: boolean;
|
2026-01-20 13:58:13 -05:00
|
|
|
created_at: Date;
|
|
|
|
|
}
|
|
|
|
|
|
2026-01-20 21:34:28 -05:00
|
|
|
// Generate jitter between -5 and +5 minutes (in seconds)
|
|
|
|
|
function getJitterSeconds(): number {
|
|
|
|
|
return Math.floor(Math.random() * 600) - 300;
|
|
|
|
|
}
|
|
|
|
|
|
2026-01-20 13:58:13 -05:00
|
|
|
export interface ProductWithLatestPrice extends Product {
|
|
|
|
|
current_price: number | null;
|
|
|
|
|
currency: string | null;
|
|
|
|
|
}
|
|
|
|
|
|
2026-01-20 19:32:25 -05:00
|
|
|
export interface SparklinePoint {
|
|
|
|
|
price: number;
|
|
|
|
|
recorded_at: Date;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
export interface ProductWithSparkline extends ProductWithLatestPrice {
|
|
|
|
|
sparkline: SparklinePoint[];
|
|
|
|
|
price_change_7d: number | null;
|
2026-01-21 13:40:39 -05:00
|
|
|
min_price: number | null;
|
2026-01-20 19:32:25 -05:00
|
|
|
}
|
|
|
|
|
|
2026-01-20 13:58:13 -05:00
|
|
|
export const productQueries = {
|
|
|
|
|
findByUserId: async (userId: number): Promise<ProductWithLatestPrice[]> => {
|
|
|
|
|
const result = await pool.query(
|
|
|
|
|
`SELECT p.*, ph.price as current_price, ph.currency
|
|
|
|
|
FROM products p
|
|
|
|
|
LEFT JOIN LATERAL (
|
|
|
|
|
SELECT price, currency FROM price_history
|
|
|
|
|
WHERE product_id = p.id
|
|
|
|
|
ORDER BY recorded_at DESC
|
|
|
|
|
LIMIT 1
|
|
|
|
|
) ph ON true
|
|
|
|
|
WHERE p.user_id = $1
|
|
|
|
|
ORDER BY p.created_at DESC`,
|
|
|
|
|
[userId]
|
|
|
|
|
);
|
|
|
|
|
return result.rows;
|
|
|
|
|
},
|
|
|
|
|
|
2026-01-20 19:32:25 -05:00
|
|
|
findByUserIdWithSparkline: async (userId: number): Promise<ProductWithSparkline[]> => {
|
|
|
|
|
// Get all products with current price
|
|
|
|
|
const productsResult = await pool.query(
|
|
|
|
|
`SELECT p.*, ph.price as current_price, ph.currency
|
|
|
|
|
FROM products p
|
|
|
|
|
LEFT JOIN LATERAL (
|
|
|
|
|
SELECT price, currency FROM price_history
|
|
|
|
|
WHERE product_id = p.id
|
|
|
|
|
ORDER BY recorded_at DESC
|
|
|
|
|
LIMIT 1
|
|
|
|
|
) ph ON true
|
|
|
|
|
WHERE p.user_id = $1
|
|
|
|
|
ORDER BY p.created_at DESC`,
|
|
|
|
|
[userId]
|
|
|
|
|
);
|
|
|
|
|
|
|
|
|
|
const products = productsResult.rows;
|
|
|
|
|
if (products.length === 0) return [];
|
|
|
|
|
|
|
|
|
|
// Get sparkline data for all products (last 7 days)
|
|
|
|
|
const productIds = products.map((p: Product) => p.id);
|
|
|
|
|
const sparklineResult = await pool.query(
|
|
|
|
|
`SELECT product_id, price, recorded_at
|
|
|
|
|
FROM price_history
|
|
|
|
|
WHERE product_id = ANY($1)
|
|
|
|
|
AND recorded_at >= CURRENT_TIMESTAMP - INTERVAL '7 days'
|
|
|
|
|
ORDER BY product_id, recorded_at ASC`,
|
|
|
|
|
[productIds]
|
|
|
|
|
);
|
|
|
|
|
|
2026-01-21 13:40:39 -05:00
|
|
|
// Get min prices for all products (all-time low)
|
|
|
|
|
const minPriceResult = await pool.query(
|
|
|
|
|
`SELECT product_id, MIN(price) as min_price
|
|
|
|
|
FROM price_history
|
|
|
|
|
WHERE product_id = ANY($1)
|
|
|
|
|
GROUP BY product_id`,
|
|
|
|
|
[productIds]
|
|
|
|
|
);
|
|
|
|
|
|
2026-01-20 19:32:25 -05:00
|
|
|
// Group sparkline data by product
|
|
|
|
|
const sparklineMap = new Map<number, SparklinePoint[]>();
|
|
|
|
|
for (const row of sparklineResult.rows) {
|
|
|
|
|
const points = sparklineMap.get(row.product_id) || [];
|
|
|
|
|
points.push({ price: row.price, recorded_at: row.recorded_at });
|
|
|
|
|
sparklineMap.set(row.product_id, points);
|
|
|
|
|
}
|
|
|
|
|
|
2026-01-21 13:40:39 -05:00
|
|
|
// Map min prices by product
|
|
|
|
|
const minPriceMap = new Map<number, number>();
|
|
|
|
|
for (const row of minPriceResult.rows) {
|
|
|
|
|
minPriceMap.set(row.product_id, parseFloat(row.min_price));
|
|
|
|
|
}
|
|
|
|
|
|
2026-01-20 19:32:25 -05:00
|
|
|
// Combine products with sparkline data
|
|
|
|
|
return products.map((product: ProductWithLatestPrice) => {
|
|
|
|
|
const sparkline = sparklineMap.get(product.id) || [];
|
|
|
|
|
let priceChange7d: number | null = null;
|
|
|
|
|
|
|
|
|
|
if (sparkline.length >= 2) {
|
|
|
|
|
const firstPrice = parseFloat(String(sparkline[0].price));
|
|
|
|
|
const lastPrice = parseFloat(String(sparkline[sparkline.length - 1].price));
|
|
|
|
|
if (firstPrice > 0) {
|
|
|
|
|
priceChange7d = ((lastPrice - firstPrice) / firstPrice) * 100;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return {
|
|
|
|
|
...product,
|
|
|
|
|
sparkline,
|
|
|
|
|
price_change_7d: priceChange7d,
|
2026-01-21 13:40:39 -05:00
|
|
|
min_price: minPriceMap.get(product.id) || null,
|
2026-01-20 19:32:25 -05:00
|
|
|
};
|
|
|
|
|
});
|
|
|
|
|
},
|
|
|
|
|
|
2026-01-20 13:58:13 -05:00
|
|
|
findById: async (id: number, userId: number): Promise<ProductWithLatestPrice | null> => {
|
|
|
|
|
const result = await pool.query(
|
|
|
|
|
`SELECT p.*, ph.price as current_price, ph.currency
|
|
|
|
|
FROM products p
|
|
|
|
|
LEFT JOIN LATERAL (
|
|
|
|
|
SELECT price, currency FROM price_history
|
|
|
|
|
WHERE product_id = p.id
|
|
|
|
|
ORDER BY recorded_at DESC
|
|
|
|
|
LIMIT 1
|
|
|
|
|
) ph ON true
|
|
|
|
|
WHERE p.id = $1 AND p.user_id = $2`,
|
|
|
|
|
[id, userId]
|
|
|
|
|
);
|
|
|
|
|
return result.rows[0] || null;
|
|
|
|
|
},
|
|
|
|
|
|
|
|
|
|
create: async (
|
|
|
|
|
userId: number,
|
|
|
|
|
url: string,
|
|
|
|
|
name: string | null,
|
|
|
|
|
imageUrl: string | null,
|
2026-01-20 20:54:12 -05:00
|
|
|
refreshInterval: number = 3600,
|
|
|
|
|
stockStatus: StockStatus = 'unknown'
|
2026-01-20 13:58:13 -05:00
|
|
|
): Promise<Product> => {
|
2026-01-20 21:34:28 -05:00
|
|
|
// Set initial next_check_at to a random time within the refresh interval
|
|
|
|
|
// This spreads out new products so they don't all check at once
|
|
|
|
|
const randomDelaySeconds = Math.floor(Math.random() * refreshInterval);
|
2026-01-20 13:58:13 -05:00
|
|
|
const result = await pool.query(
|
2026-01-20 21:34:28 -05:00
|
|
|
`INSERT INTO products (user_id, url, name, image_url, refresh_interval, stock_status, next_check_at)
|
|
|
|
|
VALUES ($1, $2, $3, $4, $5, $6, CURRENT_TIMESTAMP + ($7 || ' seconds')::interval)
|
2026-01-20 13:58:13 -05:00
|
|
|
RETURNING *`,
|
2026-01-20 21:34:28 -05:00
|
|
|
[userId, url, name, imageUrl, refreshInterval, stockStatus, randomDelaySeconds]
|
2026-01-20 13:58:13 -05:00
|
|
|
);
|
|
|
|
|
return result.rows[0];
|
|
|
|
|
},
|
|
|
|
|
|
|
|
|
|
update: async (
|
|
|
|
|
id: number,
|
|
|
|
|
userId: number,
|
2026-01-20 21:15:04 -05:00
|
|
|
updates: {
|
|
|
|
|
name?: string;
|
|
|
|
|
refresh_interval?: number;
|
|
|
|
|
price_drop_threshold?: number | null;
|
2026-01-21 13:40:39 -05:00
|
|
|
target_price?: number | null;
|
2026-01-20 21:15:04 -05:00
|
|
|
notify_back_in_stock?: boolean;
|
|
|
|
|
}
|
2026-01-20 13:58:13 -05:00
|
|
|
): Promise<Product | null> => {
|
|
|
|
|
const fields: string[] = [];
|
2026-01-20 21:15:04 -05:00
|
|
|
const values: (string | number | boolean | null)[] = [];
|
2026-01-20 13:58:13 -05:00
|
|
|
let paramIndex = 1;
|
|
|
|
|
|
|
|
|
|
if (updates.name !== undefined) {
|
|
|
|
|
fields.push(`name = $${paramIndex++}`);
|
|
|
|
|
values.push(updates.name);
|
|
|
|
|
}
|
|
|
|
|
if (updates.refresh_interval !== undefined) {
|
|
|
|
|
fields.push(`refresh_interval = $${paramIndex++}`);
|
|
|
|
|
values.push(updates.refresh_interval);
|
|
|
|
|
}
|
2026-01-20 21:15:04 -05:00
|
|
|
if (updates.price_drop_threshold !== undefined) {
|
|
|
|
|
fields.push(`price_drop_threshold = $${paramIndex++}`);
|
|
|
|
|
values.push(updates.price_drop_threshold);
|
|
|
|
|
}
|
2026-01-21 13:40:39 -05:00
|
|
|
if (updates.target_price !== undefined) {
|
|
|
|
|
fields.push(`target_price = $${paramIndex++}`);
|
|
|
|
|
values.push(updates.target_price);
|
|
|
|
|
}
|
2026-01-20 21:15:04 -05:00
|
|
|
if (updates.notify_back_in_stock !== undefined) {
|
|
|
|
|
fields.push(`notify_back_in_stock = $${paramIndex++}`);
|
|
|
|
|
values.push(updates.notify_back_in_stock);
|
|
|
|
|
}
|
2026-01-20 13:58:13 -05:00
|
|
|
|
|
|
|
|
if (fields.length === 0) return null;
|
|
|
|
|
|
|
|
|
|
values.push(id, userId);
|
|
|
|
|
const result = await pool.query(
|
|
|
|
|
`UPDATE products SET ${fields.join(', ')}
|
|
|
|
|
WHERE id = $${paramIndex++} AND user_id = $${paramIndex}
|
|
|
|
|
RETURNING *`,
|
|
|
|
|
values
|
|
|
|
|
);
|
|
|
|
|
return result.rows[0] || null;
|
|
|
|
|
},
|
|
|
|
|
|
|
|
|
|
delete: async (id: number, userId: number): Promise<boolean> => {
|
|
|
|
|
const result = await pool.query(
|
|
|
|
|
'DELETE FROM products WHERE id = $1 AND user_id = $2',
|
|
|
|
|
[id, userId]
|
|
|
|
|
);
|
|
|
|
|
return (result.rowCount ?? 0) > 0;
|
|
|
|
|
},
|
|
|
|
|
|
2026-01-20 21:34:28 -05:00
|
|
|
updateLastChecked: async (id: number, refreshInterval: number): Promise<void> => {
|
|
|
|
|
// Add jitter of ±5 minutes to spread out checks over time
|
|
|
|
|
const jitterSeconds = getJitterSeconds();
|
|
|
|
|
const nextCheckSeconds = refreshInterval + jitterSeconds;
|
2026-01-20 13:58:13 -05:00
|
|
|
await pool.query(
|
2026-01-20 21:34:28 -05:00
|
|
|
`UPDATE products
|
|
|
|
|
SET last_checked = CURRENT_TIMESTAMP,
|
|
|
|
|
next_check_at = CURRENT_TIMESTAMP + ($2 || ' seconds')::interval
|
|
|
|
|
WHERE id = $1`,
|
|
|
|
|
[id, nextCheckSeconds]
|
2026-01-20 13:58:13 -05:00
|
|
|
);
|
|
|
|
|
},
|
|
|
|
|
|
2026-01-20 20:54:12 -05:00
|
|
|
updateStockStatus: async (id: number, stockStatus: StockStatus): Promise<void> => {
|
|
|
|
|
await pool.query(
|
|
|
|
|
'UPDATE products SET stock_status = $1 WHERE id = $2',
|
|
|
|
|
[stockStatus, id]
|
|
|
|
|
);
|
|
|
|
|
},
|
|
|
|
|
|
2026-01-20 13:58:13 -05:00
|
|
|
findDueForRefresh: async (): Promise<Product[]> => {
|
|
|
|
|
const result = await pool.query(
|
|
|
|
|
`SELECT * FROM products
|
2026-01-20 21:34:28 -05:00
|
|
|
WHERE next_check_at IS NULL
|
|
|
|
|
OR next_check_at < CURRENT_TIMESTAMP`
|
2026-01-20 13:58:13 -05:00
|
|
|
);
|
|
|
|
|
return result.rows;
|
|
|
|
|
},
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
// Price History types and queries
|
|
|
|
|
export interface PriceHistory {
|
|
|
|
|
id: number;
|
|
|
|
|
product_id: number;
|
|
|
|
|
price: number;
|
|
|
|
|
currency: string;
|
|
|
|
|
recorded_at: Date;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
export const priceHistoryQueries = {
|
|
|
|
|
findByProductId: async (
|
|
|
|
|
productId: number,
|
|
|
|
|
days?: number
|
|
|
|
|
): Promise<PriceHistory[]> => {
|
|
|
|
|
let query = `
|
|
|
|
|
SELECT * FROM price_history
|
|
|
|
|
WHERE product_id = $1
|
|
|
|
|
`;
|
|
|
|
|
const values: (number | string)[] = [productId];
|
|
|
|
|
|
|
|
|
|
if (days) {
|
|
|
|
|
query += ` AND recorded_at >= CURRENT_TIMESTAMP - ($2 || ' days')::interval`;
|
|
|
|
|
values.push(days.toString());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
query += ' ORDER BY recorded_at ASC';
|
|
|
|
|
|
|
|
|
|
const result = await pool.query(query, values);
|
|
|
|
|
return result.rows;
|
|
|
|
|
},
|
|
|
|
|
|
|
|
|
|
create: async (
|
|
|
|
|
productId: number,
|
|
|
|
|
price: number,
|
|
|
|
|
currency: string = 'USD'
|
|
|
|
|
): Promise<PriceHistory> => {
|
|
|
|
|
const result = await pool.query(
|
|
|
|
|
`INSERT INTO price_history (product_id, price, currency)
|
|
|
|
|
VALUES ($1, $2, $3)
|
|
|
|
|
RETURNING *`,
|
|
|
|
|
[productId, price, currency]
|
|
|
|
|
);
|
|
|
|
|
return result.rows[0];
|
|
|
|
|
},
|
|
|
|
|
|
|
|
|
|
getLatest: async (productId: number): Promise<PriceHistory | null> => {
|
|
|
|
|
const result = await pool.query(
|
|
|
|
|
`SELECT * FROM price_history
|
|
|
|
|
WHERE product_id = $1
|
|
|
|
|
ORDER BY recorded_at DESC
|
|
|
|
|
LIMIT 1`,
|
|
|
|
|
[productId]
|
|
|
|
|
);
|
|
|
|
|
return result.rows[0] || null;
|
|
|
|
|
},
|
|
|
|
|
|
|
|
|
|
getStats: async (productId: number): Promise<{
|
|
|
|
|
min_price: number;
|
|
|
|
|
max_price: number;
|
|
|
|
|
avg_price: number;
|
|
|
|
|
price_count: number;
|
|
|
|
|
} | null> => {
|
|
|
|
|
const result = await pool.query(
|
|
|
|
|
`SELECT
|
|
|
|
|
MIN(price) as min_price,
|
|
|
|
|
MAX(price) as max_price,
|
|
|
|
|
AVG(price)::decimal(10,2) as avg_price,
|
|
|
|
|
COUNT(*) as price_count
|
|
|
|
|
FROM price_history
|
|
|
|
|
WHERE product_id = $1`,
|
|
|
|
|
[productId]
|
|
|
|
|
);
|
|
|
|
|
return result.rows[0] || null;
|
|
|
|
|
},
|
|
|
|
|
};
|
2026-01-22 14:23:55 -05:00
|
|
|
|
|
|
|
|
// Stock Status History types and queries
|
|
|
|
|
export interface StockStatusHistory {
|
|
|
|
|
id: number;
|
|
|
|
|
product_id: number;
|
|
|
|
|
status: StockStatus;
|
|
|
|
|
changed_at: Date;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
export interface StockStatusStats {
|
|
|
|
|
availability_percent: number;
|
|
|
|
|
outage_count: number;
|
|
|
|
|
avg_outage_days: number | null;
|
|
|
|
|
longest_outage_days: number | null;
|
|
|
|
|
current_status: StockStatus;
|
|
|
|
|
days_in_current_status: number;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
export const stockStatusHistoryQueries = {
|
|
|
|
|
// Get all status changes for a product
|
|
|
|
|
getByProductId: async (productId: number, days?: number): Promise<StockStatusHistory[]> => {
|
|
|
|
|
let query = `
|
|
|
|
|
SELECT * FROM stock_status_history
|
|
|
|
|
WHERE product_id = $1
|
|
|
|
|
`;
|
|
|
|
|
const values: (number | string)[] = [productId];
|
|
|
|
|
|
|
|
|
|
if (days) {
|
|
|
|
|
query += ` AND changed_at >= CURRENT_TIMESTAMP - ($2 || ' days')::interval`;
|
|
|
|
|
values.push(days.toString());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
query += ' ORDER BY changed_at ASC';
|
|
|
|
|
|
|
|
|
|
const result = await pool.query(query, values);
|
|
|
|
|
return result.rows;
|
|
|
|
|
},
|
|
|
|
|
|
|
|
|
|
// Get the most recent status for a product
|
|
|
|
|
getLatest: async (productId: number): Promise<StockStatusHistory | null> => {
|
|
|
|
|
const result = await pool.query(
|
|
|
|
|
`SELECT * FROM stock_status_history
|
|
|
|
|
WHERE product_id = $1
|
|
|
|
|
ORDER BY changed_at DESC
|
|
|
|
|
LIMIT 1`,
|
|
|
|
|
[productId]
|
|
|
|
|
);
|
|
|
|
|
return result.rows[0] || null;
|
|
|
|
|
},
|
|
|
|
|
|
|
|
|
|
// Record a status change (only if status actually changed)
|
|
|
|
|
recordChange: async (productId: number, status: StockStatus): Promise<StockStatusHistory | null> => {
|
|
|
|
|
// First check if this is actually a change
|
|
|
|
|
const latest = await stockStatusHistoryQueries.getLatest(productId);
|
|
|
|
|
|
|
|
|
|
// If status is the same as the last recorded status, don't create a new record
|
|
|
|
|
if (latest && latest.status === status) {
|
|
|
|
|
return null;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
const result = await pool.query(
|
|
|
|
|
`INSERT INTO stock_status_history (product_id, status)
|
|
|
|
|
VALUES ($1, $2)
|
|
|
|
|
RETURNING *`,
|
|
|
|
|
[productId, status]
|
|
|
|
|
);
|
|
|
|
|
return result.rows[0];
|
|
|
|
|
},
|
|
|
|
|
|
|
|
|
|
// Calculate availability statistics
|
|
|
|
|
getStats: async (productId: number, days: number = 30): Promise<StockStatusStats | null> => {
|
|
|
|
|
// Get all status changes within the period
|
|
|
|
|
const history = await stockStatusHistoryQueries.getByProductId(productId);
|
|
|
|
|
|
|
|
|
|
if (history.length === 0) {
|
|
|
|
|
return null;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
const now = new Date();
|
|
|
|
|
const periodStart = new Date(now.getTime() - days * 24 * 60 * 60 * 1000);
|
|
|
|
|
|
|
|
|
|
// Calculate time spent in each status
|
|
|
|
|
let inStockMs = 0;
|
|
|
|
|
let outOfStockMs = 0;
|
|
|
|
|
const outages: number[] = []; // Duration of each outage in ms
|
|
|
|
|
let currentOutageStart: Date | null = null;
|
|
|
|
|
|
|
|
|
|
for (let i = 0; i < history.length; i++) {
|
|
|
|
|
const entry = history[i];
|
|
|
|
|
const entryTime = new Date(entry.changed_at);
|
|
|
|
|
const nextEntry = history[i + 1];
|
|
|
|
|
const nextTime = nextEntry ? new Date(nextEntry.changed_at) : now;
|
|
|
|
|
|
|
|
|
|
// Only count time within our period
|
|
|
|
|
const segmentStart = entryTime < periodStart ? periodStart : entryTime;
|
|
|
|
|
const segmentEnd = nextTime;
|
|
|
|
|
|
|
|
|
|
if (segmentEnd <= periodStart) continue; // This segment is before our period
|
|
|
|
|
|
|
|
|
|
const duration = segmentEnd.getTime() - segmentStart.getTime();
|
|
|
|
|
|
|
|
|
|
if (entry.status === 'in_stock') {
|
|
|
|
|
inStockMs += duration;
|
|
|
|
|
if (currentOutageStart) {
|
|
|
|
|
// Outage ended
|
|
|
|
|
outages.push(entryTime.getTime() - currentOutageStart.getTime());
|
|
|
|
|
currentOutageStart = null;
|
|
|
|
|
}
|
|
|
|
|
} else if (entry.status === 'out_of_stock') {
|
|
|
|
|
outOfStockMs += duration;
|
|
|
|
|
if (!currentOutageStart) {
|
|
|
|
|
currentOutageStart = entryTime;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
const totalMs = inStockMs + outOfStockMs;
|
|
|
|
|
const availabilityPercent = totalMs > 0 ? Math.round((inStockMs / totalMs) * 100) : 0;
|
|
|
|
|
|
|
|
|
|
const avgOutageDays = outages.length > 0
|
|
|
|
|
? outages.reduce((a, b) => a + b, 0) / outages.length / (24 * 60 * 60 * 1000)
|
|
|
|
|
: null;
|
|
|
|
|
|
|
|
|
|
const longestOutageDays = outages.length > 0
|
|
|
|
|
? Math.max(...outages) / (24 * 60 * 60 * 1000)
|
|
|
|
|
: null;
|
|
|
|
|
|
|
|
|
|
const currentStatus = history[history.length - 1].status;
|
|
|
|
|
const lastChangeTime = new Date(history[history.length - 1].changed_at);
|
|
|
|
|
const daysInCurrentStatus = Math.floor((now.getTime() - lastChangeTime.getTime()) / (24 * 60 * 60 * 1000));
|
|
|
|
|
|
|
|
|
|
return {
|
|
|
|
|
availability_percent: availabilityPercent,
|
|
|
|
|
outage_count: outages.length,
|
|
|
|
|
avg_outage_days: avgOutageDays ? Math.round(avgOutageDays * 10) / 10 : null,
|
|
|
|
|
longest_outage_days: longestOutageDays ? Math.round(longestOutageDays * 10) / 10 : null,
|
|
|
|
|
current_status: currentStatus,
|
|
|
|
|
days_in_current_status: daysInCurrentStatus,
|
|
|
|
|
};
|
|
|
|
|
},
|
|
|
|
|
};
|