([]);
const [loading, setLoading] = useState(true);
useEffect(() => {
- fetch('/api/product-categories')
+ fetch('/api/categories')
.then(res => res.json())
.then(data => {
setCategories(data.data);
@@ -390,14 +390,12 @@ function getDescendantCategoryIds(categories: any[], selectedId: string): string
}
const columns = [
- 'brandName',
- 'productName',
- 'department',
- 'category',
- 'subcategory',
- 'retailPrice',
- 'salePrice',
- 'imageUrl',
+ 'name',
+ 'brand',
+ 'description',
+ 'slug',
+ 'createdAt',
+ 'updatedAt',
];
export default function PartsPage() {
@@ -413,6 +411,20 @@ export default function PartsPage() {
const [category, setCategory] = useState('');
const [subcategory, setSubcategory] = useState('');
+ // Category data from canonical API
+ const { categories, loading: categoriesLoading } = useCanonicalCategories();
+ const flatCategories = useMemo(() => flattenCategories(categories), [categories]);
+
+ // Updated filter options
+ const categoryOptions = useMemo(
+ () => flatCategories.filter(cat => cat.parentId === null).map(cat => ({ value: String(cat.id), label: cat.name })),
+ [flatCategories]
+ );
+ const subcategoryOptions = useMemo(
+ () => flatCategories.filter(cat => cat.parentId === parseInt(category)).map(cat => ({ value: String(cat.id), label: cat.name })),
+ [flatCategories, category]
+ );
+
useEffect(() => {
setLoading(true);
setError(null);
@@ -431,16 +443,14 @@ export default function PartsPage() {
// Get unique filter options from all products
const brandOptions = useMemo(() => Array.from(new Set(products.map(p => p.brandName).filter(Boolean))).sort(), [products]);
const departmentOptions = useMemo(() => Array.from(new Set(products.map(p => p.department).filter(Boolean))).sort(), [products]);
- const categoryOptions = useMemo(() => Array.from(new Set(products.map(p => p.category).filter(Boolean))).sort(), [products]);
- const subcategoryOptions = useMemo(() => Array.from(new Set(products.map(p => p.subcategory).filter(Boolean))).sort(), [products]);
- // Filter products before rendering
+ // Filter products before rendering (match by category/subcategory ID if available)
const filteredProducts = useMemo(() => {
return products.filter(p =>
(!brand || p.brandName === brand) &&
(!department || p.department === department) &&
- (!category || p.category === category) &&
- (!subcategory || p.subcategory === subcategory)
+ (!category || String(p.categoryId) === category) &&
+ (!subcategory || String(p.subcategoryId) === subcategory)
);
}, [products, brand, department, category, subcategory]);
@@ -465,25 +475,18 @@ export default function PartsPage() {
{brandOptions.map(opt => )}
-
-
-
-
-
@@ -505,19 +508,19 @@ export default function PartsPage() {
) : paginatedProducts.length === 0 ? (
| No products found. |
) : (
- paginatedProducts.map((product, i) => (
-
- {columns.map(col => (
-
- {col === 'imageUrl' && product[col] ? (
- 
- ) : (
- product[col] ?? ''
- )}
- |
- ))}
-
- ))
+ paginatedProducts
+ .filter(product => columns.some(col => product[col] && String(product[col]).trim() !== ''))
+ .map((product, i) => (
+
+ {columns.map(col => (
+ |
+ {typeof product[col] === 'object' && product[col] !== null
+ ? JSON.stringify(product[col])
+ : product[col] ?? ''}
+ |
+ ))}
+
+ ))
)}
diff --git a/src/app/api/products/[slug]/route.ts b/src/app/api/products/[slug]/route.ts
index 5cfdf07..e51c1b4 100644
--- a/src/app/api/products/[slug]/route.ts
+++ b/src/app/api/products/[slug]/route.ts
@@ -1,5 +1,5 @@
import { db } from '@/db';
-import { bb_products } from '@/db/schema';
+import { products } from '@/db/schema';
function slugify(name: string): string {
return name
@@ -13,7 +13,7 @@ export async function GET(
{ params }: { params: { slug: string } }
) {
try {
- const allProducts = await db.select().from(bb_products);
+ const allProducts = await db.select().from(products);
const mapped = allProducts.map((item: any) => ({
id: item.uuid,
name: item.productName,
diff --git a/src/app/api/products/route.ts b/src/app/api/products/route.ts
index cc25942..fb4b6f1 100644
--- a/src/app/api/products/route.ts
+++ b/src/app/api/products/route.ts
@@ -1,5 +1,5 @@
import { db } from '@/db';
-import { bb_products } from '@/db/schema';
+import { products } from '@/db/schema';
import { NextResponse } from 'next/server';
import { sql } from 'drizzle-orm';
@@ -18,11 +18,11 @@ export async function GET(req: Request) {
const offset = (page - 1) * limit;
// Get total count using raw SQL
- const totalResult = await db.execute(sql`SELECT COUNT(*)::int AS count FROM bb_products`);
+ const totalResult = await db.execute(sql`SELECT COUNT(*)::int AS count FROM products`);
const total = Number(totalResult.rows?.[0]?.count || 0);
// Get paginated products
- const allProducts = await db.select().from(bb_products).limit(limit).offset(offset);
+ const allProducts = await db.select().from(products).limit(limit).offset(offset);
const mapped = allProducts.map((item: any) => ({
...item,
slug: slugify(item.productName || item.product_name || item.name || ''),
diff --git a/src/app/api/test-products/route.ts b/src/app/api/test-products/route.ts
index 8072201..7ccad9d 100644
--- a/src/app/api/test-products/route.ts
+++ b/src/app/api/test-products/route.ts
@@ -1,9 +1,9 @@
import { db } from "@/db";
-import { bb_products } from "@/db/schema";
+import { products } from "@/db/schema";
export async function GET() {
try {
- const allProducts = await db.select().from(bb_products).limit(50);
+ const allProducts = await db.select().from(products).limit(50);
const mapped = allProducts.map((item: any) => ({
id: item.uuid,
name: item.productName,
diff --git a/src/db/schema-org.ts b/src/db/schema-org.ts
new file mode 100644
index 0000000..54bce38
--- /dev/null
+++ b/src/db/schema-org.ts
@@ -0,0 +1,571 @@
+import { pgTableCreator, integer, varchar, text, numeric, timestamp, unique, check, date, boolean, uuid, bigint, real, doublePrecision, primaryKey, pgView, index, serial } from "drizzle-orm/pg-core";
+import { relations, sql } from "drizzle-orm";
+import { DATABASE_PREFIX as prefix } from "@/lib/constants";
+
+export const pgTable = pgTableCreator((name) => (prefix == "" || prefix == null) ? name: `${prefix}_${name}`);
+///
+export const products = pgTable("products", {
+ id: integer().primaryKey().generatedAlwaysAsIdentity({ name: "products_id_seq", startWith: 1, increment: 1, minValue: 1, maxValue: 2147483647, cache: 1 }),
+ name: varchar({ length: 255 }).notNull(),
+ description: text().notNull(),
+ price: numeric().notNull(),
+ resellerId: integer("reseller_id").notNull(),
+ categoryId: integer("category_id").notNull(),
+ stockQty: integer("stock_qty").default(0),
+ updatedAt: timestamp("updated_at", { mode: 'string' }).defaultNow().notNull(),
+ createdAt: timestamp("created_at", { mode: 'string' }).defaultNow().notNull(),
+ deletedAt: timestamp("deleted_at", { mode: 'string' }),
+});
+
+export const categories = pgTable("categories", {
+ id: integer().primaryKey().generatedAlwaysAsIdentity({ name: "categories_id_seq", startWith: 1, increment: 1, minValue: 1, maxValue: 2147483647, cache: 1 }),
+ name: varchar({ length: 100 }).notNull(),
+ parentCategoryId: integer("parent_category_id"),
+ updatedAt: timestamp("updated_at", { mode: 'string' }).defaultNow().notNull(),
+ createdAt: timestamp("created_at", { mode: 'string' }).defaultNow().notNull(),
+ deletedAt: timestamp("deleted_at", { mode: 'string' }),
+ uuid: uuid().defaultRandom(),
+});
+
+export const productFeeds = pgTable("product_feeds", {
+ id: integer().primaryKey().generatedAlwaysAsIdentity({ name: "productfeeds_id_seq", startWith: 1, increment: 1, minValue: 1, maxValue: 2147483647, cache: 1 }),
+ resellerId: integer("reseller_id").notNull(),
+ feedUrl: varchar("feed_url", { length: 255 }).notNull(),
+ lastUpdate: timestamp("last_update", { mode: 'string' }),
+ updatedAt: timestamp("updated_at", { mode: 'string' }).defaultNow().notNull(),
+ createdAt: timestamp("created_at", { mode: 'string' }).defaultNow().notNull(),
+ deletedAt: timestamp("deleted_at", { mode: 'string' }),
+ uuid: uuid().defaultRandom(),
+}, (table) => {
+ return {
+ productFeedsUuidUnique: unique("product_feeds_uuid_unique").on(table.uuid),
+ }
+});
+
+export const userActivityLog = pgTable("user_activity_log", {
+ // You can use { mode: "bigint" } if numbers are exceeding js number limitations
+ id: bigint({ mode: "number" }).primaryKey().generatedAlwaysAsIdentity({ name: "user_activity_id_seq", startWith: 1, increment: 1, minValue: 1, maxValue: 2147483647, cache: 1 }),
+ // You can use { mode: "bigint" } if numbers are exceeding js number limitations
+ userId: bigint("user_id", { mode: "number" }).notNull(),
+ activity: text().notNull(),
+ timestamp: timestamp({ mode: 'string' }).default(sql`CURRENT_TIMESTAMP`),
+});
+
+export const brands = pgTable("brands", {
+ id: integer().primaryKey().generatedAlwaysAsIdentity({ name: "brands_id_seq", startWith: 1, increment: 1, minValue: 1, maxValue: 2147483647, cache: 1 }),
+ name: varchar({ length: 100 }).notNull(),
+ updatedAt: timestamp("updated_at", { mode: 'string' }).defaultNow().notNull(),
+ createdAt: timestamp("created_at", { mode: 'string' }).defaultNow().notNull(),
+ deletedAt: timestamp("deleted_at", { mode: 'string' }),
+ uuid: uuid().defaultRandom(),
+}, (table) => {
+ return {
+ brandsUuidUnique: unique("brands_uuid_unique").on(table.uuid),
+ }
+});
+
+
+export const manufacturer = pgTable("manufacturer", {
+ id: integer().primaryKey().generatedAlwaysAsIdentity({ name: "manufacturer_id_seq", startWith: 1, increment: 1, minValue: 1, maxValue: 2147483647, cache: 1 }),
+ name: varchar({ length: 100 }).notNull(),
+ updatedAt: timestamp("updated_at", { mode: 'string' }).defaultNow().notNull(),
+ createdAt: timestamp("created_at", { mode: 'string' }).defaultNow().notNull(),
+ deletedAt: timestamp("deleted_at", { mode: 'string' }),
+ uuid: uuid().defaultRandom(),
+}, (table) => {
+ return {
+ manufacturerUuidUnique: unique("manufacturer_uuid_unique").on(table.uuid),
+ }
+});
+
+export const states = pgTable("states", {
+ id: integer().primaryKey().generatedByDefaultAsIdentity({ name: "states_id_seq", startWith: 1, increment: 1, minValue: 1, maxValue: 2147483647, cache: 1 }),
+ state: varchar({ length: 50 }),
+ abbreviation: varchar({ length: 50 }),
+});
+
+export const componentType = pgTable("component_type", {
+ id: integer().primaryKey().generatedAlwaysAsIdentity({ name: "component_type_id_seq", startWith: 1, increment: 1, minValue: 1, maxValue: 2147483647, cache: 1 }),
+ name: varchar({ length: 100 }).notNull(),
+ updatedAt: timestamp("updated_at", { mode: 'string' }).defaultNow().notNull(),
+ createdAt: timestamp("created_at", { mode: 'string' }).defaultNow().notNull(),
+ deletedAt: timestamp("deleted_at", { mode: 'string' }),
+ uuid: uuid().defaultRandom(),
+}, (table) => {
+ return {
+ componentTypeUuidUnique: unique("component_type_uuid_unique").on(table.uuid),
+ }
+});
+
+export const aeroPrecision = pgTable("aero_precision", {
+ sku: text().primaryKey().notNull(),
+ manufacturerId: text("manufacturer_id"),
+ brandName: text("brand_name"),
+ productName: text("product_name"),
+ longDescription: text("long_description"),
+ shortDescription: text("short_description"),
+ department: text(),
+ category: text(),
+ subcategory: text(),
+ thumbUrl: text("thumb_url"),
+ imageUrl: text("image_url"),
+ buyLink: text("buy_link"),
+ keywords: text(),
+ reviews: text(),
+ retailPrice: numeric("retail_price"),
+ salePrice: numeric("sale_price"),
+ brandPageLink: text("brand_page_link"),
+ brandLogoImage: text("brand_logo_image"),
+ productPageViewTracking: text("product_page_view_tracking"),
+ variantsXml: text("variants_xml"),
+ mediumImageUrl: text("medium_image_url"),
+ productContentWidget: text("product_content_widget"),
+ googleCategorization: text("google_categorization"),
+ itemBasedCommission: text("item_based_commission"),
+ uuid: uuid().defaultRandom(),
+});
+
+export const compartment = pgTable("compartment", {
+ id: uuid().defaultRandom().primaryKey().notNull(),
+ name: varchar({ length: 100 }).notNull(),
+ description: varchar({ length: 300 }),
+ updatedAt: timestamp("updated_at", { mode: 'string' }).defaultNow().notNull(),
+ createdAt: timestamp("created_at", { mode: 'string' }).defaultNow().notNull(),
+ deletedAt: timestamp("deleted_at", { mode: 'string' }),
+});
+
+export const builds = pgTable("builds", {
+ id: integer().primaryKey().generatedAlwaysAsIdentity({ name: "build_id_seq", startWith: 1, increment: 1, minValue: 1, maxValue: 2147483647, cache: 1 }),
+ accountId: integer("account_id").notNull(),
+ name: varchar({ length: 255 }).notNull(),
+ description: text(),
+ updatedAt: timestamp("updated_at", { mode: 'string' }).defaultNow().notNull(),
+ createdAt: timestamp("created_at", { mode: 'string' }).defaultNow().notNull(),
+ deletedAt: timestamp("deleted_at", { mode: 'string' }),
+ uuid: uuid().defaultRandom(),
+}, (table) => {
+ return {
+ buildsUuidUnique: unique("builds_uuid_unique").on(table.uuid),
+ }
+});
+
+export const bb_products = pgTable("bb_products", {
+ uuid: uuid().defaultRandom().primaryKey().notNull(),
+ upc: varchar("UPC", { length: 100 }),
+ sku: varchar("SKU", { length: 50 }),
+ manufacturerId: varchar("MANUFACTURER_ID", { length: 50 }),
+ brandName: varchar("BRAND_NAME", { length: 50 }),
+ productName: varchar("PRODUCT_NAME", { length: 255 }),
+ longDescription: text("LONG_DESCRIPTION"),
+ shortDescription: varchar("SHORT_DESCRIPTION", { length: 500 }),
+ department: varchar("DEPARTMENT", { length: 100 }),
+ category: varchar("CATEGORY", { length: 100 }),
+ subcategory: varchar("SUBCATEGORY", { length: 100 }),
+ thumbUrl: varchar("THUMB_URL", { length: 500 }),
+ imageUrl: varchar("IMAGE_URL", { length: 500 }),
+ buyLink: varchar("BUY_LINK", { length: 500 }),
+ keywords: varchar("KEYWORDS", { length: 500 }),
+ reviews: varchar("REVIEWS", { length: 500 }),
+ retailPrice: varchar("RETAIL_PRICE", { length: 50 }),
+ salePrice: varchar("SALE_PRICE", { length: 50 }),
+ brandPageLink: varchar("BRAND_PAGE_LINK", { length: 500 }),
+ brandLogoImage: varchar("BRAND_LOGO_IMAGE", { length: 500 }),
+ productPageViewTracking: varchar("PRODUCT_PAGE_VIEW_TRACKING", { length: 500 }),
+ parentGroupId: varchar("PARENT_GROUP_ID", { length: 200 }),
+ fineline: varchar("FINELINE", { length: 200 }),
+ superfineline: varchar("SUPERFINELINE", { length: 200 }),
+ modelnumber: varchar("MODELNUMBER", { length: 100 }),
+ caliber: varchar("CALIBER", { length: 200 }),
+ mediumImageUrl: varchar("MEDIUM_IMAGE_URL", { length: 500 }),
+ productContentWidget: varchar("PRODUCT_CONTENT_WIDGET", { length: 500 }),
+ googleCategorization: varchar("GOOGLE_CATEGORIZATION", { length: 500 }),
+ itemBasedCommission: varchar("ITEM_BASED_COMMISSION", { length: 500 }),
+ itemBasedCommissionRate: varchar("ITEM_BASED_COMMISSION RATE", { length: 50 }),
+ updatedAt: timestamp("updated_at", { mode: 'string' }).defaultNow().notNull(),
+ createdAt: timestamp("created_at", { mode: 'string' }).defaultNow().notNull(),
+ deletedAt: timestamp("deleted_at", { mode: 'string' }),
+});
+
+export const psa_old = pgTable("psa_old", {
+ sku: varchar("SKU", { length: 50 }),
+ manufacturerId: varchar("MANUFACTURER_ID", { length: 50 }),
+ brandName: varchar("BRAND_NAME", { length: 50 }),
+ productName: varchar("PRODUCT_NAME", { length: 255 }),
+ longDescription: text("LONG_DESCRIPTION"),
+ shortDescription: varchar("SHORT_DESCRIPTION", { length: 50 }),
+ department: varchar("DEPARTMENT", { length: 50 }),
+ category: varchar("CATEGORY", { length: 50 }),
+ subcategory: varchar("SUBCATEGORY", { length: 50 }),
+ thumbUrl: varchar("THUMB_URL", { length: 50 }),
+ imageUrl: varchar("IMAGE_URL", { length: 50 }),
+ buyLink: varchar("BUY_LINK", { length: 128 }),
+ keywords: varchar("KEYWORDS", { length: 50 }),
+ reviews: varchar("REVIEWS", { length: 50 }),
+ retailPrice: real("RETAIL_PRICE"),
+ salePrice: real("SALE_PRICE"),
+ brandPageLink: varchar("BRAND_PAGE_LINK", { length: 50 }),
+ brandLogoImage: varchar("BRAND_LOGO_IMAGE", { length: 50 }),
+ productPageViewTracking: varchar("PRODUCT_PAGE_VIEW_TRACKING", { length: 256 }),
+ parentGroupId: varchar("PARENT_GROUP_ID", { length: 50 }),
+ fineline: varchar("FINELINE", { length: 50 }),
+ superfineline: varchar("SUPERFINELINE", { length: 200 }),
+ modelnumber: varchar("MODELNUMBER", { length: 50 }),
+ caliber: varchar("CALIBER", { length: 200 }),
+ upc: varchar("UPC", { length: 100 }),
+ mediumImageUrl: varchar("MEDIUM_IMAGE_URL", { length: 50 }),
+ productContentWidget: varchar("PRODUCT_CONTENT_WIDGET", { length: 256 }),
+ googleCategorization: varchar("GOOGLE_CATEGORIZATION", { length: 50 }),
+ itemBasedCommission: varchar("ITEM_BASED_COMMISSION", { length: 50 }),
+ uuid: uuid().defaultRandom(),
+});
+export const psa = pgTable("psa", {
+ id: integer().primaryKey().generatedAlwaysAsIdentity({ name: "psa_id_seq", startWith: 1, increment: 1, minValue: 1, maxValue: 2147483647, cache: 1 }),
+ sku: varchar("SKU", { length: 50 }),
+ manufacturerId: varchar("MANUFACTURER_ID", { length: 50 }),
+ brandName: varchar("BRAND_NAME", { length: 50 }),
+ productName: varchar("PRODUCT_NAME", { length: 255 }),
+ longDescription: text("LONG_DESCRIPTION"),
+ shortDescription: varchar("SHORT_DESCRIPTION", { length: 50 }),
+ department: varchar("DEPARTMENT", { length: 50 }),
+ category: varchar("CATEGORY", { length: 50 }),
+ subcategory: varchar("SUBCATEGORY", { length: 50 }),
+ thumbUrl: varchar("THUMB_URL", { length: 50 }),
+ imageUrl: varchar("IMAGE_URL", { length: 50 }),
+ buyLink: varchar("BUY_LINK", { length: 128 }),
+ keywords: varchar("KEYWORDS", { length: 50 }),
+ reviews: varchar("REVIEWS", { length: 50 }),
+ retailPrice: real("RETAIL_PRICE"),
+ salePrice: real("SALE_PRICE"),
+ brandPageLink: varchar("BRAND_PAGE_LINK", { length: 50 }),
+ brandLogoImage: varchar("BRAND_LOGO_IMAGE", { length: 50 }),
+ productPageViewTracking: varchar("PRODUCT_PAGE_VIEW_TRACKING", { length: 256 }),
+ parentGroupId: varchar("PARENT_GROUP_ID", { length: 50 }),
+ fineline: varchar("FINELINE", { length: 50 }),
+ superfineline: varchar("SUPERFINELINE", { length: 200 }),
+ modelnumber: varchar("MODELNUMBER", { length: 50 }),
+ caliber: varchar("CALIBER", { length: 200 }),
+ upc: varchar("UPC", { length: 100 }),
+ mediumImageUrl: varchar("MEDIUM_IMAGE_URL", { length: 50 }),
+ productContentWidget: varchar("PRODUCT_CONTENT_WIDGET", { length: 256 }),
+ googleCategorization: varchar("GOOGLE_CATEGORIZATION", { length: 50 }),
+ itemBasedCommission: varchar("ITEM_BASED_COMMISSION", { length: 50 }),
+ uuid: uuid().defaultRandom(),
+});
+
+export const lipseycatalog = pgTable("lipseycatalog", {
+ id: integer().primaryKey().generatedAlwaysAsIdentity({ name: "lipseycatalog_id_seq", startWith: 1, increment: 1, minValue: 1, maxValue: 2147483647, cache: 1 }),
+ itemno: varchar({ length: 20 }).notNull(),
+ description1: text(),
+ description2: text(),
+ upc: varchar({ length: 20 }),
+ manufacturermodelno: varchar({ length: 30 }),
+ msrp: doublePrecision(),
+ model: text(),
+ calibergauge: text(),
+ manufacturer: text(),
+ type: text(),
+ action: text(),
+ barrellength: text(),
+ capacity: text(),
+ finish: text(),
+ overalllength: text(),
+ receiver: text(),
+ safety: text(),
+ sights: text(),
+ stockframegrips: text(),
+ magazine: text(),
+ weight: text(),
+ imagename: text(),
+ chamber: text(),
+ drilledandtapped: text(),
+ rateoftwist: text(),
+ itemtype: text(),
+ additionalfeature1: text(),
+ additionalfeature2: text(),
+ additionalfeature3: text(),
+ shippingweight: text(),
+ boundbookmanufacturer: text(),
+ boundbookmodel: text(),
+ boundbooktype: text(),
+ nfathreadpattern: text(),
+ nfaattachmentmethod: text(),
+ nfabaffletype: text(),
+ silencercanbedisassembled: text(),
+ silencerconstructionmaterial: text(),
+ nfadbreduction: text(),
+ silenceroutsidediameter: text(),
+ nfaform3Caliber: text(),
+ opticmagnification: text(),
+ maintubesize: text(),
+ adjustableobjective: text(),
+ objectivesize: text(),
+ opticadjustments: text(),
+ illuminatedreticle: text(),
+ reticle: text(),
+ exclusive: text(),
+ quantity: varchar({ length: 10 }).default(sql`NULL`),
+ allocated: text(),
+ onsale: text(),
+ price: doublePrecision(),
+ currentprice: doublePrecision(),
+ retailmap: doublePrecision(),
+ fflrequired: text(),
+ sotrequired: text(),
+ exclusivetype: text(),
+ scopecoverincluded: text(),
+ special: text(),
+ sightstype: text(),
+ case: text(),
+ choke: text(),
+ dbreduction: text(),
+ family: text(),
+ finishtype: text(),
+ frame: text(),
+ griptype: varchar({ length: 30 }),
+ handgunslidematerial: text(),
+ countryoforigin: varchar({ length: 4 }),
+ itemlength: text(),
+ itemwidth: text(),
+ itemheight: text(),
+ packagelength: doublePrecision(),
+ packagewidth: doublePrecision(),
+ packageheight: doublePrecision(),
+ itemgroup: varchar({ length: 40 }),
+ updatedAt: timestamp("updated_at", { mode: 'string' }).defaultNow().notNull(),
+ createdAt: timestamp("created_at", { mode: 'string' }).defaultNow().notNull(),
+ deletedAt: timestamp("deleted_at", { mode: 'string' }),
+});
+
+export const buildsComponents = pgTable("builds_components", {
+ id: integer().primaryKey().generatedAlwaysAsIdentity({ name: "build_components_id_seq", startWith: 1, increment: 1, minValue: 1, maxValue: 2147483647, cache: 1 }),
+ buildId: integer("build_id").notNull(),
+ productId: integer("product_id").notNull(),
+ updatedAt: timestamp("updated_at", { mode: 'string' }).defaultNow().notNull(),
+ createdAt: timestamp("created_at", { mode: 'string' }).defaultNow().notNull(),
+ deletedAt: timestamp("deleted_at", { mode: 'string' }),
+ uuid: uuid().defaultRandom(),
+}, (table) => {
+ return {
+ buildsComponentsUuidUnique: unique("builds_components_uuid_unique").on(table.uuid),
+ }
+});
+
+export const balResellers = pgTable("bal_resellers", {
+ id: integer().primaryKey().generatedAlwaysAsIdentity({ name: "resellers_id_seq", startWith: 1, increment: 1, minValue: 1, maxValue: 2147483647, cache: 1 }),
+ name: varchar({ length: 100 }).notNull(),
+ websiteUrl: varchar("website_url", { length: 255 }),
+ contactEmail: varchar("contact_email", { length: 100 }),
+ updatedAt: timestamp("updated_at", { mode: 'string' }).defaultNow().notNull(),
+ createdAt: timestamp("created_at", { mode: 'string' }).defaultNow().notNull(),
+ deletedAt: timestamp("deleted_at", { mode: 'string' }),
+ uuid: uuid().defaultRandom(),
+}, (table) => {
+ return {
+ balResellersUuidUnique: unique("bal_resellers_uuid_unique").on(table.uuid),
+ }
+});
+
+export const verificationTokens = pgTable("verificationTokens", {
+ identifier: varchar("identifier").notNull(),
+ token: varchar("token").notNull(),
+ expires: timestamp("expires").notNull(),
+});
+
+export const authenticator = pgTable("authenticator", {
+ credentialId: text().notNull(),
+ userId: text().notNull(),
+ providerAccountId: text().notNull(),
+ credentialPublicKey: text().notNull(),
+ counter: integer().notNull(),
+ credentialDeviceType: text().notNull(),
+ credentialBackedUp: boolean().notNull(),
+ transports: text(),
+}, (table) => {
+ return {
+ authenticatorUserIdCredentialIdPk: primaryKey({ columns: [table.credentialId, table.userId], name: "authenticator_userId_credentialID_pk"}),
+ authenticatorCredentialIdUnique: unique("authenticator_credentialID_unique").on(table.credentialId),
+ }
+});
+
+export const accounts = pgTable("accounts", {
+ id: uuid("id").primaryKey().defaultRandom(),
+ uuid: uuid("uuid").defaultRandom(),
+ userId: uuid("user_id").notNull(),
+ type: varchar("type").notNull(),
+ provider: text().notNull(),
+ providerAccountId: varchar("provider_account_id").notNull(),
+ refreshToken: text("refresh_token"),
+ accessToken: text("access_token"),
+ expiresAt: integer("expires_at"),
+ tokenType: varchar("token_type"),
+ idToken: text("id_token"),
+ sessionState: varchar("session_state"),
+ scope: text(),
+}
+);
+
+/* export const vw_accounts = pgView("vw_accounts", {
+ uuid: uuid().defaultRandom(),
+ userId: text("user_id").notNull(),
+ type: text().notNull(),
+ provider: text().notNull(),
+ providerAccountId: text("provider_account_id").notNull(),
+ refreshToken: text("refresh_token"),
+ accessToken: text("access_token"),
+ expiresAt: integer("expires_at"),
+ tokenType: text("token_type"),
+ scope: text(),
+ idToken: text("id_token"),
+ sessionState: text("session_state"),
+ first_name: text("first_name"),
+ last_name: text("last_name"),
+
+},) */
+
+/* From here down is the authentication library Lusia tables */
+
+export const users = pgTable("user",
+ {
+ id: varchar("id", { length: 21 }).primaryKey(),
+ name: varchar("name"),
+ username: varchar({ length: 50 }),
+ discordId: varchar("discord_id", { length: 255 }).unique(),
+ email: varchar("email", { length: 255 }).unique().notNull(),
+ emailVerified: boolean("email_verified").default(false).notNull(),
+ hashedPassword: varchar("hashed_password", { length: 255 }),
+ first_name: varchar("first_name", { length: 50 }),
+ last_name: varchar("last_name", { length: 50 }),
+ full_name: varchar("full_name", { length: 50 }),
+ profilePicture: varchar("profile_picture", { length: 255 }),
+ image: text("image"),
+ dateOfBirth: date("date_of_birth"),
+ phoneNumber: varchar("phone_number", { length: 20 }),
+ createdAt: timestamp("created_at", { mode: 'string' }).default(sql`CURRENT_TIMESTAMP`),
+ updatedAt: timestamp("updated_at", { mode: 'string' }).default(sql`CURRENT_TIMESTAMP`),
+ isAdmin: boolean("is_admin").default(false),
+ lastLogin: timestamp("last_login", { mode: 'string' }),
+ buildPrivacySetting: text("build_privacy_setting").default('public'),
+ uuid: uuid().defaultRandom(),
+ avatar: varchar("avatar", { length: 255 }),
+ stripeSubscriptionId: varchar("stripe_subscription_id", { length: 191 }),
+ stripePriceId: varchar("stripe_price_id", { length: 191 }),
+ stripeCustomerId: varchar("stripe_customer_id", { length: 191 }),
+ stripeCurrentPeriodEnd: timestamp("stripe_current_period_end"),
+}, (table) => ({
+ usersUsernameKey: unique("users_username_key").on(table.username),
+ usersEmailKey: unique("users_email_key").on(table.email),
+ usersBuildPrivacySettingCheck: check("users_build_privacy_setting_check", sql`build_privacy_setting = ANY (ARRAY['private'::text, 'public'::text])`),
+ emailIdx: index("user_email_idx").on(table.email),
+ discordIdx: index("user_discord_idx").on(table.discordId),
+ }),
+);
+export type User = typeof users.$inferSelect;
+export type NewUser = typeof users.$inferInsert;
+
+export const session = pgTable(
+ "session",
+ {
+ sessionToken: varchar("sessionToken", { length: 255 }).primaryKey(),
+ userId: varchar("userId", { length: 21 }).notNull(),
+ expires: timestamp("expires", { withTimezone: true, mode: "date" }).notNull(),
+ }
+);
+
+export const emailVerificationCodes = pgTable(
+ "email_verification_codes",
+ {
+ id: serial("id").primaryKey(),
+ userId: varchar("user_id", { length: 21 }).unique().notNull(),
+ email: varchar("email", { length: 255 }).notNull(),
+ code: varchar("code", { length: 8 }).notNull(),
+ expiresAt: timestamp("expires_at", { withTimezone: true, mode: "date" }).notNull(),
+ },
+ (t) => ({
+ userIdx: index("verification_code_user_idx").on(t.userId),
+ emailIdx: index("verification_code_email_idx").on(t.email),
+ }),
+ );
+
+ export const passwordResetTokens = pgTable(
+ "password_reset_tokens",
+ {
+ id: varchar("id", { length: 40 }).primaryKey(),
+ userId: varchar("user_id", { length: 21 }).notNull(),
+ expiresAt: timestamp("expires_at", { withTimezone: true, mode: "date" }).notNull(),
+ },
+ (t) => ({
+ userIdx: index("password_token_user_idx").on(t.userId),
+ }),
+ );
+
+ export const posts = pgTable(
+ "posts",
+ {
+ id: varchar("id", { length: 15 }).primaryKey(),
+ userId: varchar("user_id", { length: 255 }).notNull(),
+ title: varchar("title", { length: 255 }).notNull(),
+ excerpt: varchar("excerpt", { length: 255 }).notNull(),
+ content: text("content").notNull(),
+ status: varchar("status", { length: 10, enum: ["draft", "published"] })
+ .default("draft")
+ .notNull(),
+ tags: varchar("tags", { length: 255 }),
+ createdAt: timestamp("created_at").defaultNow().notNull(),
+ updatedAt: timestamp("updated_at", { mode: "date" }).$onUpdate(() => new Date()),
+ },
+ (t) => ({
+ userIdx: index("post_user_idx").on(t.userId),
+ createdAtIdx: index("post_created_at_idx").on(t.createdAt),
+ }),
+ );
+
+ export const postRelations = relations(posts, ({ one }) => ({
+ user: one(users, {
+ fields: [posts.userId],
+ references: [users.id],
+ }),
+ }));
+
+ export type Post = typeof posts.$inferSelect;
+ export type NewPost = typeof posts.$inferInsert;
+
+ export const vwUserSessions = pgView("vw_user_sessions", { id: varchar({ length: 255 }),
+ userId: varchar("user_id", { length: 21 }),
+ uId: varchar("u_id", { length: 21 }),
+ uEmail: varchar("u_email", { length: 255 }),
+ expiresAt: timestamp("expires_at", { withTimezone: true, mode: 'string' }),
+ createdAt: timestamp("created_at", { mode: 'string' }),
+ updatedAt: timestamp("updated_at", { mode: 'string' }),
+}).existing();
+//as(sql`SELECT s.id, s.user_id, u.id AS u_id, u.email AS u_email, s.expires_at, s.created_at, s.updated_at FROM sessions s, users u WHERE s.user_id::text = u.id::text`);
+
+// Default Drizzle File
+
+// import { pgTable, serial, text, integer, timestamp } from "drizzle-orm/pg-core";
+
+// export const products = pgTable("products", {
+// id: serial("id").primaryKey(),
+// name: text("name").notNull(),
+// description: text("description"),
+// price: integer("price"),
+// createdAt: timestamp("created_at").defaultNow(),
+// // Add more fields as needed
+// });
+
+export const affiliateCategoryMap = pgTable("affiliate_category_map", {
+ id: integer().primaryKey().generatedAlwaysAsIdentity({ name: "affiliate_category_map_id_seq", startWith: 1, increment: 1 }),
+ feedname: varchar("feedname", { length: 100 }).notNull(),
+ affiliatecategory: varchar("affiliatecategory", { length: 255 }).notNull(),
+ buildercategoryid: integer("buildercategoryid").notNull(),
+ notes: varchar("notes", { length: 255 }),
+});
+
+export const product_categories = pgTable("product_categories", {
+ id: integer().primaryKey().generatedAlwaysAsIdentity({ name: "product_categories_id_seq", startWith: 1, increment: 1 }),
+ name: varchar({ length: 100 }).notNull(),
+ parent_category_id: integer("parent_category_id"),
+ type: varchar({ length: 50 }),
+ sort_order: integer("sort_order"),
+ created_at: timestamp("created_at", { mode: 'string' }).defaultNow(),
+ updated_at: timestamp("updated_at", { mode: 'string' }).defaultNow(),
+});
\ No newline at end of file
diff --git a/src/db/schema.ts b/src/db/schema.ts
index 54bce38..7bf1ae8 100644
--- a/src/db/schema.ts
+++ b/src/db/schema.ts
@@ -1,571 +1,108 @@
-import { pgTableCreator, integer, varchar, text, numeric, timestamp, unique, check, date, boolean, uuid, bigint, real, doublePrecision, primaryKey, pgView, index, serial } from "drizzle-orm/pg-core";
-import { relations, sql } from "drizzle-orm";
-import { DATABASE_PREFIX as prefix } from "@/lib/constants";
+import { pgTable, foreignKey, serial, varchar, integer, doublePrecision, timestamp, unique, text, numeric, boolean, jsonb } from "drizzle-orm/pg-core"
+import { sql } from "drizzle-orm"
-export const pgTable = pgTableCreator((name) => (prefix == "" || prefix == null) ? name: `${prefix}_${name}`);
-///
-export const products = pgTable("products", {
- id: integer().primaryKey().generatedAlwaysAsIdentity({ name: "products_id_seq", startWith: 1, increment: 1, minValue: 1, maxValue: 2147483647, cache: 1 }),
- name: varchar({ length: 255 }).notNull(),
- description: text().notNull(),
- price: numeric().notNull(),
- resellerId: integer("reseller_id").notNull(),
- categoryId: integer("category_id").notNull(),
- stockQty: integer("stock_qty").default(0),
- updatedAt: timestamp("updated_at", { mode: 'string' }).defaultNow().notNull(),
- createdAt: timestamp("created_at", { mode: 'string' }).defaultNow().notNull(),
- deletedAt: timestamp("deleted_at", { mode: 'string' }),
-});
+
+
+export const productCategoryMappings = pgTable("product_category_mappings", {
+ id: serial().primaryKey().notNull(),
+ feedName: varchar("feed_name", { length: 255 }),
+ feedCategoryValue: varchar("feed_category_value", { length: 255 }),
+ canonicalCategoryId: integer("canonical_category_id"),
+ confidenceScore: doublePrecision("confidence_score"),
+ lastReviewedBy: varchar("last_reviewed_by", { length: 255 }),
+ lastReviewedAt: timestamp("last_reviewed_at", { mode: 'string' }),
+}, (table) => [
+ foreignKey({
+ columns: [table.canonicalCategoryId],
+ foreignColumns: [categories.id],
+ name: "product_category_mappings_canonical_category_id_fkey"
+ }),
+]);
export const categories = pgTable("categories", {
- id: integer().primaryKey().generatedAlwaysAsIdentity({ name: "categories_id_seq", startWith: 1, increment: 1, minValue: 1, maxValue: 2147483647, cache: 1 }),
- name: varchar({ length: 100 }).notNull(),
- parentCategoryId: integer("parent_category_id"),
- updatedAt: timestamp("updated_at", { mode: 'string' }).defaultNow().notNull(),
- createdAt: timestamp("created_at", { mode: 'string' }).defaultNow().notNull(),
- deletedAt: timestamp("deleted_at", { mode: 'string' }),
- uuid: uuid().defaultRandom(),
-});
-
-export const productFeeds = pgTable("product_feeds", {
- id: integer().primaryKey().generatedAlwaysAsIdentity({ name: "productfeeds_id_seq", startWith: 1, increment: 1, minValue: 1, maxValue: 2147483647, cache: 1 }),
- resellerId: integer("reseller_id").notNull(),
- feedUrl: varchar("feed_url", { length: 255 }).notNull(),
- lastUpdate: timestamp("last_update", { mode: 'string' }),
- updatedAt: timestamp("updated_at", { mode: 'string' }).defaultNow().notNull(),
- createdAt: timestamp("created_at", { mode: 'string' }).defaultNow().notNull(),
- deletedAt: timestamp("deleted_at", { mode: 'string' }),
- uuid: uuid().defaultRandom(),
-}, (table) => {
- return {
- productFeedsUuidUnique: unique("product_feeds_uuid_unique").on(table.uuid),
- }
-});
-
-export const userActivityLog = pgTable("user_activity_log", {
- // You can use { mode: "bigint" } if numbers are exceeding js number limitations
- id: bigint({ mode: "number" }).primaryKey().generatedAlwaysAsIdentity({ name: "user_activity_id_seq", startWith: 1, increment: 1, minValue: 1, maxValue: 2147483647, cache: 1 }),
- // You can use { mode: "bigint" } if numbers are exceeding js number limitations
- userId: bigint("user_id", { mode: "number" }).notNull(),
- activity: text().notNull(),
- timestamp: timestamp({ mode: 'string' }).default(sql`CURRENT_TIMESTAMP`),
-});
-
-export const brands = pgTable("brands", {
- id: integer().primaryKey().generatedAlwaysAsIdentity({ name: "brands_id_seq", startWith: 1, increment: 1, minValue: 1, maxValue: 2147483647, cache: 1 }),
- name: varchar({ length: 100 }).notNull(),
- updatedAt: timestamp("updated_at", { mode: 'string' }).defaultNow().notNull(),
- createdAt: timestamp("created_at", { mode: 'string' }).defaultNow().notNull(),
- deletedAt: timestamp("deleted_at", { mode: 'string' }),
- uuid: uuid().defaultRandom(),
-}, (table) => {
- return {
- brandsUuidUnique: unique("brands_uuid_unique").on(table.uuid),
- }
-});
-
-
-export const manufacturer = pgTable("manufacturer", {
- id: integer().primaryKey().generatedAlwaysAsIdentity({ name: "manufacturer_id_seq", startWith: 1, increment: 1, minValue: 1, maxValue: 2147483647, cache: 1 }),
- name: varchar({ length: 100 }).notNull(),
- updatedAt: timestamp("updated_at", { mode: 'string' }).defaultNow().notNull(),
- createdAt: timestamp("created_at", { mode: 'string' }).defaultNow().notNull(),
- deletedAt: timestamp("deleted_at", { mode: 'string' }),
- uuid: uuid().defaultRandom(),
-}, (table) => {
- return {
- manufacturerUuidUnique: unique("manufacturer_uuid_unique").on(table.uuid),
- }
-});
-
-export const states = pgTable("states", {
- id: integer().primaryKey().generatedByDefaultAsIdentity({ name: "states_id_seq", startWith: 1, increment: 1, minValue: 1, maxValue: 2147483647, cache: 1 }),
- state: varchar({ length: 50 }),
- abbreviation: varchar({ length: 50 }),
-});
-
-export const componentType = pgTable("component_type", {
- id: integer().primaryKey().generatedAlwaysAsIdentity({ name: "component_type_id_seq", startWith: 1, increment: 1, minValue: 1, maxValue: 2147483647, cache: 1 }),
- name: varchar({ length: 100 }).notNull(),
- updatedAt: timestamp("updated_at", { mode: 'string' }).defaultNow().notNull(),
- createdAt: timestamp("created_at", { mode: 'string' }).defaultNow().notNull(),
- deletedAt: timestamp("deleted_at", { mode: 'string' }),
- uuid: uuid().defaultRandom(),
-}, (table) => {
- return {
- componentTypeUuidUnique: unique("component_type_uuid_unique").on(table.uuid),
- }
-});
-
-export const aeroPrecision = pgTable("aero_precision", {
- sku: text().primaryKey().notNull(),
- manufacturerId: text("manufacturer_id"),
- brandName: text("brand_name"),
- productName: text("product_name"),
- longDescription: text("long_description"),
- shortDescription: text("short_description"),
- department: text(),
- category: text(),
- subcategory: text(),
- thumbUrl: text("thumb_url"),
- imageUrl: text("image_url"),
- buyLink: text("buy_link"),
- keywords: text(),
- reviews: text(),
- retailPrice: numeric("retail_price"),
- salePrice: numeric("sale_price"),
- brandPageLink: text("brand_page_link"),
- brandLogoImage: text("brand_logo_image"),
- productPageViewTracking: text("product_page_view_tracking"),
- variantsXml: text("variants_xml"),
- mediumImageUrl: text("medium_image_url"),
- productContentWidget: text("product_content_widget"),
- googleCategorization: text("google_categorization"),
- itemBasedCommission: text("item_based_commission"),
- uuid: uuid().defaultRandom(),
-});
-
-export const compartment = pgTable("compartment", {
- id: uuid().defaultRandom().primaryKey().notNull(),
- name: varchar({ length: 100 }).notNull(),
- description: varchar({ length: 300 }),
- updatedAt: timestamp("updated_at", { mode: 'string' }).defaultNow().notNull(),
- createdAt: timestamp("created_at", { mode: 'string' }).defaultNow().notNull(),
- deletedAt: timestamp("deleted_at", { mode: 'string' }),
-});
-
-export const builds = pgTable("builds", {
- id: integer().primaryKey().generatedAlwaysAsIdentity({ name: "build_id_seq", startWith: 1, increment: 1, minValue: 1, maxValue: 2147483647, cache: 1 }),
- accountId: integer("account_id").notNull(),
+ id: serial().primaryKey().notNull(),
name: varchar({ length: 255 }).notNull(),
+ parentId: integer("parent_id"),
+ slug: varchar({ length: 255 }).notNull(),
+}, (table) => [
+ foreignKey({
+ columns: [table.parentId],
+ foreignColumns: [table.id],
+ name: "categories_parent_id_fkey"
+ }),
+ unique("categories_slug_key").on(table.slug),
+]);
+
+export const products = pgTable("products", {
+ id: serial().primaryKey().notNull(),
+ name: varchar({ length: 255 }).notNull(),
+ brand: varchar({ length: 255 }),
description: text(),
- updatedAt: timestamp("updated_at", { mode: 'string' }).defaultNow().notNull(),
- createdAt: timestamp("created_at", { mode: 'string' }).defaultNow().notNull(),
- deletedAt: timestamp("deleted_at", { mode: 'string' }),
- uuid: uuid().defaultRandom(),
-}, (table) => {
- return {
- buildsUuidUnique: unique("builds_uuid_unique").on(table.uuid),
- }
-});
+ upc: varchar({ length: 32 }),
+ mpn: varchar({ length: 64 }),
+ canonicalCategoryId: integer("canonical_category_id"),
+ createdAt: timestamp("created_at", { mode: 'string' }).defaultNow(),
+ updatedAt: timestamp("updated_at", { mode: 'string' }).defaultNow(),
+}, (table) => [
+ foreignKey({
+ columns: [table.canonicalCategoryId],
+ foreignColumns: [categories.id],
+ name: "products_canonical_category_id_fkey"
+ }),
+]);
-export const bb_products = pgTable("bb_products", {
- uuid: uuid().defaultRandom().primaryKey().notNull(),
- upc: varchar("UPC", { length: 100 }),
- sku: varchar("SKU", { length: 50 }),
- manufacturerId: varchar("MANUFACTURER_ID", { length: 50 }),
- brandName: varchar("BRAND_NAME", { length: 50 }),
- productName: varchar("PRODUCT_NAME", { length: 255 }),
- longDescription: text("LONG_DESCRIPTION"),
- shortDescription: varchar("SHORT_DESCRIPTION", { length: 500 }),
- department: varchar("DEPARTMENT", { length: 100 }),
- category: varchar("CATEGORY", { length: 100 }),
- subcategory: varchar("SUBCATEGORY", { length: 100 }),
- thumbUrl: varchar("THUMB_URL", { length: 500 }),
- imageUrl: varchar("IMAGE_URL", { length: 500 }),
- buyLink: varchar("BUY_LINK", { length: 500 }),
- keywords: varchar("KEYWORDS", { length: 500 }),
- reviews: varchar("REVIEWS", { length: 500 }),
- retailPrice: varchar("RETAIL_PRICE", { length: 50 }),
- salePrice: varchar("SALE_PRICE", { length: 50 }),
- brandPageLink: varchar("BRAND_PAGE_LINK", { length: 500 }),
- brandLogoImage: varchar("BRAND_LOGO_IMAGE", { length: 500 }),
- productPageViewTracking: varchar("PRODUCT_PAGE_VIEW_TRACKING", { length: 500 }),
- parentGroupId: varchar("PARENT_GROUP_ID", { length: 200 }),
- fineline: varchar("FINELINE", { length: 200 }),
- superfineline: varchar("SUPERFINELINE", { length: 200 }),
- modelnumber: varchar("MODELNUMBER", { length: 100 }),
- caliber: varchar("CALIBER", { length: 200 }),
- mediumImageUrl: varchar("MEDIUM_IMAGE_URL", { length: 500 }),
- productContentWidget: varchar("PRODUCT_CONTENT_WIDGET", { length: 500 }),
- googleCategorization: varchar("GOOGLE_CATEGORIZATION", { length: 500 }),
- itemBasedCommission: varchar("ITEM_BASED_COMMISSION", { length: 500 }),
- itemBasedCommissionRate: varchar("ITEM_BASED_COMMISSION RATE", { length: 50 }),
- updatedAt: timestamp("updated_at", { mode: 'string' }).defaultNow().notNull(),
- createdAt: timestamp("created_at", { mode: 'string' }).defaultNow().notNull(),
- deletedAt: timestamp("deleted_at", { mode: 'string' }),
-});
+export const offers = pgTable("offers", {
+ id: serial().primaryKey().notNull(),
+ productId: integer("product_id"),
+ feedName: varchar("feed_name", { length: 255 }).notNull(),
+ feedSku: varchar("feed_sku", { length: 255 }),
+ price: numeric({ precision: 10, scale: 2 }),
+ url: text(),
+ inStock: boolean("in_stock"),
+ vendor: varchar({ length: 255 }),
+ lastSeenAt: timestamp("last_seen_at", { mode: 'string' }).defaultNow(),
+ rawData: jsonb("raw_data"),
+}, (table) => [
+ foreignKey({
+ columns: [table.productId],
+ foreignColumns: [products.id],
+ name: "offers_product_id_fkey"
+ }).onDelete("cascade"),
+ unique("offers_product_id_feed_name_feed_sku_key").on(table.productId, table.feedName, table.feedSku),
+ unique("offers_feed_unique").on(table.feedName, table.feedSku),
+]);
-export const psa_old = pgTable("psa_old", {
- sku: varchar("SKU", { length: 50 }),
- manufacturerId: varchar("MANUFACTURER_ID", { length: 50 }),
- brandName: varchar("BRAND_NAME", { length: 50 }),
- productName: varchar("PRODUCT_NAME", { length: 255 }),
- longDescription: text("LONG_DESCRIPTION"),
- shortDescription: varchar("SHORT_DESCRIPTION", { length: 50 }),
- department: varchar("DEPARTMENT", { length: 50 }),
- category: varchar("CATEGORY", { length: 50 }),
- subcategory: varchar("SUBCATEGORY", { length: 50 }),
- thumbUrl: varchar("THUMB_URL", { length: 50 }),
- imageUrl: varchar("IMAGE_URL", { length: 50 }),
- buyLink: varchar("BUY_LINK", { length: 128 }),
- keywords: varchar("KEYWORDS", { length: 50 }),
- reviews: varchar("REVIEWS", { length: 50 }),
- retailPrice: real("RETAIL_PRICE"),
- salePrice: real("SALE_PRICE"),
- brandPageLink: varchar("BRAND_PAGE_LINK", { length: 50 }),
- brandLogoImage: varchar("BRAND_LOGO_IMAGE", { length: 50 }),
- productPageViewTracking: varchar("PRODUCT_PAGE_VIEW_TRACKING", { length: 256 }),
- parentGroupId: varchar("PARENT_GROUP_ID", { length: 50 }),
- fineline: varchar("FINELINE", { length: 50 }),
- superfineline: varchar("SUPERFINELINE", { length: 200 }),
- modelnumber: varchar("MODELNUMBER", { length: 50 }),
- caliber: varchar("CALIBER", { length: 200 }),
- upc: varchar("UPC", { length: 100 }),
- mediumImageUrl: varchar("MEDIUM_IMAGE_URL", { length: 50 }),
- productContentWidget: varchar("PRODUCT_CONTENT_WIDGET", { length: 256 }),
- googleCategorization: varchar("GOOGLE_CATEGORIZATION", { length: 50 }),
- itemBasedCommission: varchar("ITEM_BASED_COMMISSION", { length: 50 }),
- uuid: uuid().defaultRandom(),
-});
-export const psa = pgTable("psa", {
- id: integer().primaryKey().generatedAlwaysAsIdentity({ name: "psa_id_seq", startWith: 1, increment: 1, minValue: 1, maxValue: 2147483647, cache: 1 }),
- sku: varchar("SKU", { length: 50 }),
- manufacturerId: varchar("MANUFACTURER_ID", { length: 50 }),
- brandName: varchar("BRAND_NAME", { length: 50 }),
- productName: varchar("PRODUCT_NAME", { length: 255 }),
- longDescription: text("LONG_DESCRIPTION"),
- shortDescription: varchar("SHORT_DESCRIPTION", { length: 50 }),
- department: varchar("DEPARTMENT", { length: 50 }),
- category: varchar("CATEGORY", { length: 50 }),
- subcategory: varchar("SUBCATEGORY", { length: 50 }),
- thumbUrl: varchar("THUMB_URL", { length: 50 }),
- imageUrl: varchar("IMAGE_URL", { length: 50 }),
- buyLink: varchar("BUY_LINK", { length: 128 }),
- keywords: varchar("KEYWORDS", { length: 50 }),
- reviews: varchar("REVIEWS", { length: 50 }),
- retailPrice: real("RETAIL_PRICE"),
- salePrice: real("SALE_PRICE"),
- brandPageLink: varchar("BRAND_PAGE_LINK", { length: 50 }),
- brandLogoImage: varchar("BRAND_LOGO_IMAGE", { length: 50 }),
- productPageViewTracking: varchar("PRODUCT_PAGE_VIEW_TRACKING", { length: 256 }),
- parentGroupId: varchar("PARENT_GROUP_ID", { length: 50 }),
- fineline: varchar("FINELINE", { length: 50 }),
- superfineline: varchar("SUPERFINELINE", { length: 200 }),
- modelnumber: varchar("MODELNUMBER", { length: 50 }),
- caliber: varchar("CALIBER", { length: 200 }),
- upc: varchar("UPC", { length: 100 }),
- mediumImageUrl: varchar("MEDIUM_IMAGE_URL", { length: 50 }),
- productContentWidget: varchar("PRODUCT_CONTENT_WIDGET", { length: 256 }),
- googleCategorization: varchar("GOOGLE_CATEGORIZATION", { length: 50 }),
- itemBasedCommission: varchar("ITEM_BASED_COMMISSION", { length: 50 }),
- uuid: uuid().defaultRandom(),
-});
+export const offerPriceHistory = pgTable("offer_price_history", {
+ id: serial().primaryKey().notNull(),
+ offerId: integer("offer_id"),
+ price: numeric({ precision: 10, scale: 2 }).notNull(),
+ seenAt: timestamp("seen_at", { mode: 'string' }).defaultNow(),
+}, (table) => [
+ foreignKey({
+ columns: [table.offerId],
+ foreignColumns: [offers.id],
+ name: "offer_price_history_offer_id_fkey"
+ }).onDelete("cascade"),
+]);
-export const lipseycatalog = pgTable("lipseycatalog", {
- id: integer().primaryKey().generatedAlwaysAsIdentity({ name: "lipseycatalog_id_seq", startWith: 1, increment: 1, minValue: 1, maxValue: 2147483647, cache: 1 }),
- itemno: varchar({ length: 20 }).notNull(),
- description1: text(),
- description2: text(),
- upc: varchar({ length: 20 }),
- manufacturermodelno: varchar({ length: 30 }),
- msrp: doublePrecision(),
- model: text(),
- calibergauge: text(),
- manufacturer: text(),
- type: text(),
- action: text(),
- barrellength: text(),
- capacity: text(),
- finish: text(),
- overalllength: text(),
- receiver: text(),
- safety: text(),
- sights: text(),
- stockframegrips: text(),
- magazine: text(),
- weight: text(),
- imagename: text(),
- chamber: text(),
- drilledandtapped: text(),
- rateoftwist: text(),
- itemtype: text(),
- additionalfeature1: text(),
- additionalfeature2: text(),
- additionalfeature3: text(),
- shippingweight: text(),
- boundbookmanufacturer: text(),
- boundbookmodel: text(),
- boundbooktype: text(),
- nfathreadpattern: text(),
- nfaattachmentmethod: text(),
- nfabaffletype: text(),
- silencercanbedisassembled: text(),
- silencerconstructionmaterial: text(),
- nfadbreduction: text(),
- silenceroutsidediameter: text(),
- nfaform3Caliber: text(),
- opticmagnification: text(),
- maintubesize: text(),
- adjustableobjective: text(),
- objectivesize: text(),
- opticadjustments: text(),
- illuminatedreticle: text(),
- reticle: text(),
- exclusive: text(),
- quantity: varchar({ length: 10 }).default(sql`NULL`),
- allocated: text(),
- onsale: text(),
- price: doublePrecision(),
- currentprice: doublePrecision(),
- retailmap: doublePrecision(),
- fflrequired: text(),
- sotrequired: text(),
- exclusivetype: text(),
- scopecoverincluded: text(),
- special: text(),
- sightstype: text(),
- case: text(),
- choke: text(),
- dbreduction: text(),
- family: text(),
- finishtype: text(),
- frame: text(),
- griptype: varchar({ length: 30 }),
- handgunslidematerial: text(),
- countryoforigin: varchar({ length: 4 }),
- itemlength: text(),
- itemwidth: text(),
- itemheight: text(),
- packagelength: doublePrecision(),
- packagewidth: doublePrecision(),
- packageheight: doublePrecision(),
- itemgroup: varchar({ length: 40 }),
- updatedAt: timestamp("updated_at", { mode: 'string' }).defaultNow().notNull(),
- createdAt: timestamp("created_at", { mode: 'string' }).defaultNow().notNull(),
- deletedAt: timestamp("deleted_at", { mode: 'string' }),
-});
+export const feeds = pgTable("feeds", {
+ id: serial().primaryKey().notNull(),
+ name: varchar({ length: 255 }).notNull(),
+ url: text(),
+ lastImportedAt: timestamp("last_imported_at", { mode: 'string' }),
+}, (table) => [
+ unique("feeds_name_key").on(table.name),
+]);
-export const buildsComponents = pgTable("builds_components", {
- id: integer().primaryKey().generatedAlwaysAsIdentity({ name: "build_components_id_seq", startWith: 1, increment: 1, minValue: 1, maxValue: 2147483647, cache: 1 }),
- buildId: integer("build_id").notNull(),
- productId: integer("product_id").notNull(),
- updatedAt: timestamp("updated_at", { mode: 'string' }).defaultNow().notNull(),
- createdAt: timestamp("created_at", { mode: 'string' }).defaultNow().notNull(),
- deletedAt: timestamp("deleted_at", { mode: 'string' }),
- uuid: uuid().defaultRandom(),
-}, (table) => {
- return {
- buildsComponentsUuidUnique: unique("builds_components_uuid_unique").on(table.uuid),
- }
-});
-
-export const balResellers = pgTable("bal_resellers", {
- id: integer().primaryKey().generatedAlwaysAsIdentity({ name: "resellers_id_seq", startWith: 1, increment: 1, minValue: 1, maxValue: 2147483647, cache: 1 }),
- name: varchar({ length: 100 }).notNull(),
- websiteUrl: varchar("website_url", { length: 255 }),
- contactEmail: varchar("contact_email", { length: 100 }),
- updatedAt: timestamp("updated_at", { mode: 'string' }).defaultNow().notNull(),
- createdAt: timestamp("created_at", { mode: 'string' }).defaultNow().notNull(),
- deletedAt: timestamp("deleted_at", { mode: 'string' }),
- uuid: uuid().defaultRandom(),
-}, (table) => {
- return {
- balResellersUuidUnique: unique("bal_resellers_uuid_unique").on(table.uuid),
- }
-});
-
-export const verificationTokens = pgTable("verificationTokens", {
- identifier: varchar("identifier").notNull(),
- token: varchar("token").notNull(),
- expires: timestamp("expires").notNull(),
-});
-
-export const authenticator = pgTable("authenticator", {
- credentialId: text().notNull(),
- userId: text().notNull(),
- providerAccountId: text().notNull(),
- credentialPublicKey: text().notNull(),
- counter: integer().notNull(),
- credentialDeviceType: text().notNull(),
- credentialBackedUp: boolean().notNull(),
- transports: text(),
-}, (table) => {
- return {
- authenticatorUserIdCredentialIdPk: primaryKey({ columns: [table.credentialId, table.userId], name: "authenticator_userId_credentialID_pk"}),
- authenticatorCredentialIdUnique: unique("authenticator_credentialID_unique").on(table.credentialId),
- }
-});
-
-export const accounts = pgTable("accounts", {
- id: uuid("id").primaryKey().defaultRandom(),
- uuid: uuid("uuid").defaultRandom(),
- userId: uuid("user_id").notNull(),
- type: varchar("type").notNull(),
- provider: text().notNull(),
- providerAccountId: varchar("provider_account_id").notNull(),
- refreshToken: text("refresh_token"),
- accessToken: text("access_token"),
- expiresAt: integer("expires_at"),
- tokenType: varchar("token_type"),
- idToken: text("id_token"),
- sessionState: varchar("session_state"),
- scope: text(),
-}
-);
-
-/* export const vw_accounts = pgView("vw_accounts", {
- uuid: uuid().defaultRandom(),
- userId: text("user_id").notNull(),
- type: text().notNull(),
- provider: text().notNull(),
- providerAccountId: text("provider_account_id").notNull(),
- refreshToken: text("refresh_token"),
- accessToken: text("access_token"),
- expiresAt: integer("expires_at"),
- tokenType: text("token_type"),
- scope: text(),
- idToken: text("id_token"),
- sessionState: text("session_state"),
- first_name: text("first_name"),
- last_name: text("last_name"),
-
-},) */
-
-/* From here down is the authentication library Lusia tables */
-
-export const users = pgTable("user",
- {
- id: varchar("id", { length: 21 }).primaryKey(),
- name: varchar("name"),
- username: varchar({ length: 50 }),
- discordId: varchar("discord_id", { length: 255 }).unique(),
- email: varchar("email", { length: 255 }).unique().notNull(),
- emailVerified: boolean("email_verified").default(false).notNull(),
- hashedPassword: varchar("hashed_password", { length: 255 }),
- first_name: varchar("first_name", { length: 50 }),
- last_name: varchar("last_name", { length: 50 }),
- full_name: varchar("full_name", { length: 50 }),
- profilePicture: varchar("profile_picture", { length: 255 }),
- image: text("image"),
- dateOfBirth: date("date_of_birth"),
- phoneNumber: varchar("phone_number", { length: 20 }),
- createdAt: timestamp("created_at", { mode: 'string' }).default(sql`CURRENT_TIMESTAMP`),
- updatedAt: timestamp("updated_at", { mode: 'string' }).default(sql`CURRENT_TIMESTAMP`),
- isAdmin: boolean("is_admin").default(false),
- lastLogin: timestamp("last_login", { mode: 'string' }),
- buildPrivacySetting: text("build_privacy_setting").default('public'),
- uuid: uuid().defaultRandom(),
- avatar: varchar("avatar", { length: 255 }),
- stripeSubscriptionId: varchar("stripe_subscription_id", { length: 191 }),
- stripePriceId: varchar("stripe_price_id", { length: 191 }),
- stripeCustomerId: varchar("stripe_customer_id", { length: 191 }),
- stripeCurrentPeriodEnd: timestamp("stripe_current_period_end"),
-}, (table) => ({
- usersUsernameKey: unique("users_username_key").on(table.username),
- usersEmailKey: unique("users_email_key").on(table.email),
- usersBuildPrivacySettingCheck: check("users_build_privacy_setting_check", sql`build_privacy_setting = ANY (ARRAY['private'::text, 'public'::text])`),
- emailIdx: index("user_email_idx").on(table.email),
- discordIdx: index("user_discord_idx").on(table.discordId),
- }),
-);
-export type User = typeof users.$inferSelect;
-export type NewUser = typeof users.$inferInsert;
-
-export const session = pgTable(
- "session",
- {
- sessionToken: varchar("sessionToken", { length: 255 }).primaryKey(),
- userId: varchar("userId", { length: 21 }).notNull(),
- expires: timestamp("expires", { withTimezone: true, mode: "date" }).notNull(),
- }
-);
-
-export const emailVerificationCodes = pgTable(
- "email_verification_codes",
- {
- id: serial("id").primaryKey(),
- userId: varchar("user_id", { length: 21 }).unique().notNull(),
- email: varchar("email", { length: 255 }).notNull(),
- code: varchar("code", { length: 8 }).notNull(),
- expiresAt: timestamp("expires_at", { withTimezone: true, mode: "date" }).notNull(),
- },
- (t) => ({
- userIdx: index("verification_code_user_idx").on(t.userId),
- emailIdx: index("verification_code_email_idx").on(t.email),
- }),
- );
-
- export const passwordResetTokens = pgTable(
- "password_reset_tokens",
- {
- id: varchar("id", { length: 40 }).primaryKey(),
- userId: varchar("user_id", { length: 21 }).notNull(),
- expiresAt: timestamp("expires_at", { withTimezone: true, mode: "date" }).notNull(),
- },
- (t) => ({
- userIdx: index("password_token_user_idx").on(t.userId),
- }),
- );
-
- export const posts = pgTable(
- "posts",
- {
- id: varchar("id", { length: 15 }).primaryKey(),
- userId: varchar("user_id", { length: 255 }).notNull(),
- title: varchar("title", { length: 255 }).notNull(),
- excerpt: varchar("excerpt", { length: 255 }).notNull(),
- content: text("content").notNull(),
- status: varchar("status", { length: 10, enum: ["draft", "published"] })
- .default("draft")
- .notNull(),
- tags: varchar("tags", { length: 255 }),
- createdAt: timestamp("created_at").defaultNow().notNull(),
- updatedAt: timestamp("updated_at", { mode: "date" }).$onUpdate(() => new Date()),
- },
- (t) => ({
- userIdx: index("post_user_idx").on(t.userId),
- createdAtIdx: index("post_created_at_idx").on(t.createdAt),
- }),
- );
-
- export const postRelations = relations(posts, ({ one }) => ({
- user: one(users, {
- fields: [posts.userId],
- references: [users.id],
- }),
- }));
-
- export type Post = typeof posts.$inferSelect;
- export type NewPost = typeof posts.$inferInsert;
-
- export const vwUserSessions = pgView("vw_user_sessions", { id: varchar({ length: 255 }),
- userId: varchar("user_id", { length: 21 }),
- uId: varchar("u_id", { length: 21 }),
- uEmail: varchar("u_email", { length: 255 }),
- expiresAt: timestamp("expires_at", { withTimezone: true, mode: 'string' }),
- createdAt: timestamp("created_at", { mode: 'string' }),
- updatedAt: timestamp("updated_at", { mode: 'string' }),
-}).existing();
-//as(sql`SELECT s.id, s.user_id, u.id AS u_id, u.email AS u_email, s.expires_at, s.created_at, s.updated_at FROM sessions s, users u WHERE s.user_id::text = u.id::text`);
-
-// Default Drizzle File
-
-// import { pgTable, serial, text, integer, timestamp } from "drizzle-orm/pg-core";
-
-// export const products = pgTable("products", {
-// id: serial("id").primaryKey(),
-// name: text("name").notNull(),
-// description: text("description"),
-// price: integer("price"),
-// createdAt: timestamp("created_at").defaultNow(),
-// // Add more fields as needed
-// });
-
-export const affiliateCategoryMap = pgTable("affiliate_category_map", {
- id: integer().primaryKey().generatedAlwaysAsIdentity({ name: "affiliate_category_map_id_seq", startWith: 1, increment: 1 }),
- feedname: varchar("feedname", { length: 100 }).notNull(),
- affiliatecategory: varchar("affiliatecategory", { length: 255 }).notNull(),
- buildercategoryid: integer("buildercategoryid").notNull(),
- notes: varchar("notes", { length: 255 }),
-});
-
-export const product_categories = pgTable("product_categories", {
- id: integer().primaryKey().generatedAlwaysAsIdentity({ name: "product_categories_id_seq", startWith: 1, increment: 1 }),
- name: varchar({ length: 100 }).notNull(),
- parent_category_id: integer("parent_category_id"),
- type: varchar({ length: 50 }),
- sort_order: integer("sort_order"),
- created_at: timestamp("created_at", { mode: 'string' }).defaultNow(),
- updated_at: timestamp("updated_at", { mode: 'string' }).defaultNow(),
-});
\ No newline at end of file
+export const productAttributes = pgTable("product_attributes", {
+ id: serial().primaryKey().notNull(),
+ productId: integer("product_id"),
+ name: varchar({ length: 255 }).notNull(),
+ value: varchar({ length: 255 }).notNull(),
+}, (table) => [
+ foreignKey({
+ columns: [table.productId],
+ foreignColumns: [products.id],
+ name: "product_attributes_product_id_fkey"
+ }).onDelete("cascade"),
+]);