import { Router, Request, Response } from 'express' import { GoogleMerchantService, ProductData } from '../services/googleMerchantService' const router = Router() // Lazy initialization - só cria o serviço quando necessário let merchantService: GoogleMerchantService | null = null function getMerchantService(): GoogleMerchantService { if (!merchantService) { try { merchantService = new GoogleMerchantService() } catch (error) { throw new Error( `Google Merchant Service não configurado: ${error instanceof Error ? error.message : 'Unknown error'}. ` + `Configure GOOGLE_MERCHANT_CLIENT_ID e GOOGLE_MERCHANT_CLIENT_SECRET no arquivo .env` ) } } return merchantService } /** * GET /api/merchant/auth * Inicia o fluxo de autenticação OAuth */ router.get('/auth', (req: Request, res: Response) => { try { const service = getMerchantService() const authUrl = service.getAuthUrl() const redirectUri = process.env.GOOGLE_MERCHANT_REDIRECT_URI || 'http://localhost:3000/api/merchant/callback' res.json({ authUrl, redirectUri, instructions: [ 'Se receber erro "redirect_uri_mismatch":', '1. Vá em https://console.cloud.google.com/apis/credentials', '2. Clique no seu OAuth 2.0 Client ID', `3. Adicione esta URI exata em "Authorized redirect URIs": ${redirectUri}`, '4. Salve e tente novamente', ], }) } catch (error) { res.status(500).json({ error: 'Failed to generate auth URL', message: error instanceof Error ? error.message : 'Unknown error', }) } }) /** * GET /api/merchant/callback * Callback OAuth - recebe o código e retorna o refresh token */ router.get('/callback', async (req: Request, res: Response) => { try { const { code, error } = req.query if (error) { return res.send(` Erro de Autenticação

❌ Erro de Autenticação

Erro: ${error}

Tente novamente ou verifique as configurações no Google Cloud Console.

`) } if (!code) { return res.send(` Erro - Código não fornecido

❌ Código de autorização não fornecido

O Google não retornou o código de autorização. Tente autenticar novamente.

`) } const service = getMerchantService() const tokens = await service.getTokens(code as string) if (!tokens.refresh_token) { return res.send(` Refresh Token não recebido

⚠️ Refresh Token não recebido

O Google não forneceu um refresh token. Isso geralmente acontece quando você já autorizou este app antes.

Solução:

  1. Vá em https://myaccount.google.com/permissions
  2. Encontre "100mlstore Analytics" ou seu app
  3. Clique em "Remover acesso"
  4. Volte e autentique novamente
`) } // Página HTML amigável com o refresh token res.send(` Autenticação Concluída - Google Merchant

✅ Autenticação Concluída com Sucesso!

Você recebeu o refresh token. Siga as instruções abaixo para completar a configuração.

📋 Refresh Token:

${tokens.refresh_token}

📝 Próximos Passos:

  1. Copie o refresh_token acima (ou clique no botão copiar)
  2. Abra o arquivo backend/.env
  3. Adicione a linha: GOOGLE_MERCHANT_REFRESH_TOKEN=${tokens.refresh_token}
  4. Salve o arquivo
  5. Reinicie o servidor backend (Ctrl+C e depois npm run dev)
  6. Volte para a página Merchant e teste a sincronização

Nota: Este token é sensível. Não compartilhe publicamente.

Você pode fechar esta janela após copiar o token.

`) } catch (error) { console.error('OAuth callback error:', error) res.status(500).send(` Erro

❌ Erro ao processar autenticação

Erro: ${error instanceof Error ? error.message : 'Unknown error'}

Verifique o console do servidor para mais detalhes.

`) } }) /** * POST /api/merchant/sync-products * Sincroniza produtos do sistema para o Google Merchant Center */ router.post('/sync-products', async (req: Request, res: Response) => { try { const { orders } = req.body if (!orders || !Array.isArray(orders) || orders.length === 0) { return res.status(400).json({ error: 'Orders array is required', }) } // Agrupar produtos únicos por nome const uniqueProducts = new Map() orders.forEach((order: any) => { const key = order.productName if (!uniqueProducts.has(key)) { uniqueProducts.set(key, { productName: order.productName, category: order.productCategory || 'Outros', price: order.lineTotal || 0, link: `https://100mlstore.com/produto/${encodeURIComponent(order.productName)}`, imageLink: `https://100mlstore.com/images/${encodeURIComponent(order.productName)}.jpg`, availability: order.orderStatus === 'completed' ? 'in stock' : 'out of stock', }) } }) // Converter para formato Google Merchant const products: ProductData[] = Array.from(uniqueProducts.values()).map((product) => ({ offerId: `PROD-${product.productName.replace(/\s+/g, '-').replace(/[^a-zA-Z0-9-]/g, '').toUpperCase().substring(0, 50)}`, title: product.productName, description: `${product.productName} - ${product.category}`, link: product.link, imageLink: product.imageLink, price: { value: product.price.toFixed(2), currency: 'EUR', }, availability: product.availability, brand: '100mlstore', condition: 'new', category: product.category, })) // Enviar produtos para Google Merchant const service = getMerchantService() const results = [] for (const product of products) { try { const result = await service.insertProduct(product) results.push({ success: true, product: product.title, offerId: product.offerId, data: result, }) } catch (error: any) { console.error(`Error syncing product ${product.title}:`, error) // Extrair informações do erro const errorData = error.originalError?.response?.data || error.response?.data || {} const errorMessage = errorData.error?.message || error.message || 'Unknown error' const errorCode = errorData.error?.code || error.code const errorDetails = errorData ? JSON.stringify(errorData, null, 2) : '' // Se o produto já existe, tenta atualizar if (errorMessage.includes('already exists') || errorMessage.includes('duplicate') || errorMessage.includes('already_exist') || errorCode === 409) { try { const updateResult = await service.updateProduct(product.offerId, product) results.push({ success: true, product: product.title, offerId: product.offerId, action: 'updated', data: updateResult, }) } catch (updateError: any) { const updateErrorMessage = updateError.response?.data?.error?.message || updateError.message || 'Failed to update' results.push({ success: false, product: product.title, offerId: product.offerId, error: updateErrorMessage, details: updateError.response?.data ? JSON.stringify(updateError.response.data, null, 2) : '', }) } } else { results.push({ success: false, product: product.title, offerId: product.offerId, error: errorMessage, details: errorDetails, }) } } } const successCount = results.filter((r) => r.success).length const failCount = results.filter((r) => !r.success).length res.json({ message: 'Sincronização concluída', summary: { total: products.length, success: successCount, failed: failCount, }, results, }) } catch (error) { console.error('Sync products error:', error) res.status(500).json({ error: 'Erro ao sincronizar produtos', message: error instanceof Error ? error.message : 'Unknown error', }) } }) /** * GET /api/merchant/products * Lista produtos do Google Merchant Center */ router.get('/products', async (req: Request, res: Response) => { try { const service = getMerchantService() const maxResults = parseInt(req.query.maxResults as string) || 50 const products = await service.listProducts(maxResults) res.json(products) } catch (error) { console.error('List products error:', error) res.status(500).json({ error: 'Erro ao listar produtos', message: error instanceof Error ? error.message : 'Unknown error', }) } }) /** * GET /api/merchant/generate-feed * Gera feed XML no formato Google Merchant para upload manual */ router.post('/generate-feed', async (req: Request, res: Response) => { try { const { orders } = req.body if (!orders || !Array.isArray(orders)) { return res.status(400).json({ error: 'Orders array is required', }) } // Agrupar produtos únicos const uniqueProducts = new Map() orders.forEach((order: any) => { const key = order.productName if (!uniqueProducts.has(key)) { uniqueProducts.set(key, { offerId: `PROD-${order.productName.replace(/\s+/g, '-').replace(/[^a-zA-Z0-9-]/g, '').toUpperCase().substring(0, 50)}`, title: order.productName, description: `${order.productName} - ${order.productCategory || 'Outros'}`, link: `https://100mlstore.com/produto/${encodeURIComponent(order.productName)}`, imageLink: `https://100mlstore.com/images/${encodeURIComponent(order.productName)}.jpg`, price: (order.lineTotal || 0).toFixed(2), availability: order.orderStatus === 'completed' ? 'in stock' : 'out of stock', brand: '100mlstore', condition: 'new', category: order.productCategory || 'Outros', }) } }) // Gerar XML const xml = ` 100mlstore Products https://100mlstore.com Product feed for Google Merchant Center ${Array.from(uniqueProducts.values()) .map( (product) => ` ${escapeXml(product.offerId)} ${escapeXml(product.title)} ${escapeXml(product.description)} ${escapeXml(product.link)} ${escapeXml(product.imageLink)} ${product.price} EUR ${product.availability} ${escapeXml(product.brand)} ${product.condition} ${escapeXml(product.category)} ` ) .join('')} ` res.setHeader('Content-Type', 'application/xml') res.setHeader('Content-Disposition', 'attachment; filename="google-merchant-feed.xml"') res.send(xml) } catch (error) { console.error('Generate feed error:', error) res.status(500).json({ error: 'Erro ao gerar feed', message: error instanceof Error ? error.message : 'Unknown error', }) } }) function escapeXml(unsafe: string): string { return unsafe .replace(/&/g, '&') .replace(//g, '>') .replace(/"/g, '"') .replace(/'/g, ''') } export default router