import { Customer, Product, Search } from 'commerce-sdk'

export default async function getProducts(searchQuery) {
  const clientConfig = {
    headers: {
      authorization: ``,
    },
    parameters: {
      clientId: process.env.SFDC_CLIENT_ID,
      secret: process.env.SFDC_SECRET,
      organizationId: process.env.SFDC_ORGANIZATIONID,
      shortCode: process.env.SFDC_SHORTCODE,
      siteId: process.env.SFDC_SITEID,
    },
  }

  const credentials = `${clientConfig.parameters.clientId}:${clientConfig.parameters.secret}`
  const base64data = Buffer.from(credentials).toString('base64')
  const headers = { Authorization: `Basic ${base64data}` }
  const client = new Customer.ShopperLogin(clientConfig)

  const shopperToken = await client.getAccessToken({
    headers,
    body: {
      grant_type: 'client_credentials',
    },
  })

  const configWithAuth = {
    ...clientConfig,
    headers: { authorization: `Bearer ${shopperToken.access_token}` },
  }

  const searchClient = new Search.ShopperSearch(configWithAuth)
  const searchResults = await searchClient.productSearch({
    parameters: { q: searchQuery },
  })

  const results = []

  const productsClient = new Product.ShopperProducts(configWithAuth)
  await Promise.all(
    searchResults.hits.map(async (product) => {
      const productResults = await productsClient.getProduct({
        parameters: {
          organizationId: clientConfig.parameters.organizationId,
          siteId: clientConfig.parameters.siteId,
          id: product.productId,
        },
      })

      results.push(productResults)
    })
  )

  return results
}