51 lines
1.8 KiB
TypeScript
51 lines
1.8 KiB
TypeScript
import { PrismaClient } from '@prisma/client';
|
|
import { Pool } from 'pg';
|
|
import { PrismaPg } from '@prisma/adapter-pg';
|
|
import { uploadToOpeninary } from '../lib/openinary';
|
|
import fs from 'fs';
|
|
import path from 'path';
|
|
import 'dotenv/config';
|
|
|
|
const pool = new Pool({ connectionString: process.env.DATABASE_URL });
|
|
const adapter = new PrismaPg(pool);
|
|
const prisma = new PrismaClient({ adapter });
|
|
|
|
async function main() {
|
|
console.log("Uploading default product image to Openinary...");
|
|
const localPath = path.join(process.cwd(), 'public', 'default-product.png');
|
|
const buffer = fs.readFileSync(localPath);
|
|
const file = new File([buffer], 'default-product.png', { type: 'image/png' });
|
|
|
|
let defaultPath = "";
|
|
try {
|
|
const result = await uploadToOpeninary(file, "kiteqr");
|
|
defaultPath = result.path;
|
|
console.log(`[SUCCESS] Default image uploaded to: ${defaultPath}`);
|
|
} catch (error) {
|
|
console.error("Failed to upload default image:", error);
|
|
return;
|
|
}
|
|
|
|
console.log("Updating products with missing or old images...");
|
|
const products = await prisma.products.findMany();
|
|
|
|
let updatedCount = 0;
|
|
for (const product of products) {
|
|
// If image_url is empty, null, or doesn't start with kiteqr/ (meaning it wasn't migrated successfully)
|
|
if (!product.image_url || !product.image_url.startsWith('kiteqr/')) {
|
|
await prisma.products.update({
|
|
where: { id: product.id },
|
|
data: { image_url: defaultPath }
|
|
});
|
|
updatedCount++;
|
|
console.log(`Updated product ${product.id} (${product.name}) with mock image.`);
|
|
}
|
|
}
|
|
|
|
console.log(`Done. ${updatedCount} products updated with the mock image.`);
|
|
}
|
|
|
|
main()
|
|
.catch(console.error)
|
|
.finally(() => prisma.$disconnect());
|