Merge pull request #168 from vtex-apps/feature/long-export-list

Feature: Long exporlist

dotnet/Data/IWishListRepository.cs

@@ -12,5 +12,6 @@ public interface IWishListRepository
         Task VerifySchema();
         Task <int> GetListsSize();
         Task <WishListsWrapper> GetAllLists();
+        Task <WishListsWrapper> GetAllListsPaged(int pageSize);
     }
 }

dotnet/Data/WishListRepository.cs

@@ -281,6 +281,7 @@ private async Task<string> FirstScroll()
             string responseContent = string.Empty;
             try
             {
+
                 var client = _clientFactory.CreateClient();
                 var request = new HttpRequestMessage
                 {
@@ -289,6 +290,7 @@ private async Task<string> FirstScroll()
                 };
 
                 string authToken = this._httpContextAccessor.HttpContext.Request.Headers[WishListConstants.HEADER_VTEX_CREDENTIAL];
+
                 if (authToken != null)
                 {
                     request.Headers.Add(WishListConstants.AUTHORIZATION_HEADER_NAME, authToken);
@@ -297,6 +299,8 @@ private async Task<string> FirstScroll()
                 }
                 request.Headers.Add("Cache-Control", "no-cache");
                 var response = await client.SendAsync(request);
+
+                Console.WriteLine(response.Headers);
                 tokenResponse = response.Headers.GetValues("X-VTEX-MD-TOKEN").FirstOrDefault();
 
                 responseContent = await response.Content.ReadAsStringAsync();
@@ -438,5 +442,60 @@ public async Task<WishListsWrapper> GetAllLists()
 
             return wishListsWrapper;
         }
+
+        public async Task<WishListsWrapper> GetAllListsPaged(int pageList)
+        {
+            await this.VerifySchema();
+            var i = 0;
+            var status = true;
+            JArray searchResult = new JArray();
+
+            while (status)
+            {
+                if( i == 0)
+                {
+                    var res = await FirstScroll();
+                    JArray resArray = JArray.Parse(res);
+                    searchResult.Merge(resArray);
+                }
+                else
+                {
+                    var res = await SubScroll();
+                    JArray resArray = JArray.Parse(res);
+                    if (resArray.Count < 200) 
+                    {
+                        status = false;
+                    }
+                    searchResult.Merge(resArray);
+                }
+                i++;
+            }
+
+            WishListsWrapper wishListsWrapper = new WishListsWrapper();
+            wishListsWrapper.WishLists = new List<WishListWrapper>();
+            WishListWrapper responseListWrapper = new WishListWrapper();
+
+            try
+            {
+                for (int l = (pageList - 1) * 5000; l < pageList * 5000; l++)
+                {
+                    JToken listWrapper = searchResult[l];
+                    if (listWrapper != null)
+                    {
+                        responseListWrapper = JsonConvert.DeserializeObject<WishListWrapper>(listWrapper.ToString());
+                        if (responseListWrapper != null)
+                        {
+                            wishListsWrapper.WishLists.Add(responseListWrapper);
+                        }
+                    }
+                }
+            }
+            catch (Exception ex)
+            {
+                _context.Vtex.Logger.Error("GetAllLists", null, "Error getting lists", ex);
+            }
+
+            return wishListsWrapper;
+        }
     }
 }

dotnet/GraphQL/Query.cs

@@ -302,6 +302,31 @@ public Query(IWishListService wishListService)
                      return wishListsWrapper.WishLists;
                  }
              );
+
+            FieldAsync<ListGraphType<WishListWrapperType>>(
+                 "exportListPaged",
+                 arguments: new QueryArguments(
+                    new QueryArgument<NonNullGraphType<IntGraphType>> { Name = "pageList", Description = "page list" }
+                 ),
+                 resolve: async context =>
+                 {
+                     HttpStatusCode isValidAuthUser = await wishListService.IsValidAuthUser();
+                     if (isValidAuthUser != HttpStatusCode.OK)
+                     {
+                         context.Errors.Add(new ExecutionError(isValidAuthUser.ToString())
+                         {
+                             Code = isValidAuthUser.ToString()
+                         });
+
+                         return null;
+                     }
+
+                     int pageList = context.GetArgument<int>("pageList");
+
+                     WishListsWrapper wishListsWrapper = await wishListService.ExportAllWishListsPaged(pageList);
+                     return wishListsWrapper.WishLists;
+                 }
+             );
         }
     }
 }

dotnet/Services/IWishListService.cs

@@ -17,5 +17,6 @@ public interface IWishListService
         Task<ValidatedUser> ValidateUserToken(string token);
         Task<int> GetListSizeBase();
         Task<WishListsWrapper> ExportAllWishLists();
+        Task<WishListsWrapper> ExportAllWishListsPaged(int pageList);
     }
 }

dotnet/Services/WishListService.cs

@@ -351,5 +351,11 @@ public async Task<WishListsWrapper> ExportAllWishLists()
             WishListsWrapper wishListsWrapper = await _wishListRepository.GetAllLists();
             return wishListsWrapper;
         }
+
+        public async Task<WishListsWrapper> ExportAllWishListsPaged(int pageList)
+        {
+            WishListsWrapper wishListsWrapper = await _wishListRepository.GetAllListsPaged(pageList);
+            return wishListsWrapper;
+        }
     }
 }

graphql/schema.graphql

@@ -57,6 +57,8 @@ type Query {
     @cacheControl(scope: PRIVATE)
   exportList: [WishListWrapperType]
     @cacheControl(scope: PRIVATE)
+  exportListPaged(pageList: Int!): [WishListWrapperType]
+    @cacheControl(scope: PRIVATE)
 }
 
 type Mutation {

manifest.json

@@ -3,7 +3,7 @@
   "vendor": "vtex",
   "version": "1.16.6",
   "title": "Wish List",
-  "description": "The Wishlist app is designed for B2C. It adds a heart icon to the Shelfs and Product Page, so the user can add it to the Wishlist, you can list all the Wishlisted items at /wishlist",
+  "description": "The Wishlist a  pp is designed for B2C. It adds a heart icon to the Shelfs and Product Page, so the user can add it to the Wishlist, you can list all the Wishlisted items at /wishlist",
   "categories": [],
   "settingsSchema": {},
   "builders": {

messages/en.json

@@ -10,5 +10,6 @@
   "store/wishlist-not-logged": "You need to log in before adding it to the list",
   "admin/wishlist.menu.label": "Wishlist",
   "admin/settings.title": "Wishlist Export",
-  "admin/settings.download": "Download Wishlists"
+  "admin/settings.download": "Download Wishlists",
+  "admin/settings.page": "Page"
 }

messages/es.json

@@ -10,5 +10,6 @@
   "store/wishlist-not-logged": "Necesitas iniciar sesión antes de agregar un producto a la lista",
   "admin/wishlist.menu.label": "Lista de deseos",
   "admin/settings.title": "Exportar lista de deseos",
-  "admin/settings.download": "Descargar listas de deseos"
+  "admin/settings.download": "Descargar listas de deseos",
+  "admin/settings.page": "Página"
 }

messages/pt.json

@@ -10,5 +10,6 @@
   "store/wishlist-not-logged": "Você precisa entrar antes de adicionar um produto à sua lista",
   "admin/wishlist.menu.label": "Lista de desejos",
   "admin/settings.title": "Exportar lista de desejos",
-  "admin/settings.download": "Baixar lista de desejos"
+  "admin/settings.download": "Baixar lista de desejos",
+  "admin/settings.page": "Página"
 }

react/WishlistAdmin.tsx

@@ -1,4 +1,4 @@
-import React, { FC, useState } from 'react'
+import React, { FC, useEffect, useState } from 'react'
 import { injectIntl, defineMessages } from 'react-intl'
 import { useQuery } from 'react-apollo'
 import {
@@ -7,15 +7,21 @@ import {
   PageHeader,
   ButtonWithIcon,
   IconDownload,
+  Dropdown
 } from 'vtex.styleguide'
 import XLSX from 'xlsx'
 
 import exportList from './queries/exportList.gql'
+import exportListPaged from './queries/exportListPaged.gql'
+import listSize from './queries/listSize.gql'
 
 const WishlistAdmin: FC<any> = ({ intl }) => {
   const [state, setState] = useState<any>({
     loading: false,
   })
+  const [isLongList, setIsLongList] = useState<boolean>(false)
+  const [selected1, setSelected1] = useState<any>(null)
+  const [options, setOptions] = useState<any>([])
 
   const { loading } = state
 
@@ -39,19 +45,70 @@ const WishlistAdmin: FC<any> = ({ intl }) => {
       }
     }
 
+
     const ws = XLSX.utils.json_to_sheet(data, { header })
     const wb = XLSX.utils.book_new()
     XLSX.utils.book_append_sheet(wb, ws, 'Sheet1')
-    const exportFileName = `wishlists.xls`
-    XLSX.writeFile(wb, exportFileName)
+    if(selected1 != null) {
+      const exportFileName = `wishlists_page_${selected1}.xls`
+      XLSX.writeFile(wb, exportFileName)
+    } else {
+      const exportFileName = `wishlists.xls`
+      XLSX.writeFile(wb, exportFileName)
+
+    }
   }
 
   const { data, loading: queryLoading } = useQuery(exportList, {
     fetchPolicy: 'no-cache',
+    variables: { pageList: 1 },
+  })
+
+  const { data: dataSize, loading: queryLoadingSize } = useQuery(listSize, {
+    fetchPolicy: 'no-cache'
+  })   
+
+  const { data: dataPaged, loading: queryLoadingPaged, refetch } = useQuery(exportListPaged, {
+    fetchPolicy: 'no-cache',
+    variables: { pageList: selected1 },
   })
 
+  useEffect(() => {
+
+    if(queryLoadingSize) return
+
+    let pages: number = dataSize.listSize/5000 + 1
+
+    for(let i=1; i <= pages; i++) {
+
+      setOptions((current: any) => [...current, 
+        {
+          value: `${i}`,
+          label: `${i}`
+        }
+      ])
+    }
+
+    if(dataSize?.listSize > 5000) {
+      setIsLongList(true)
+    }
+
+  },[queryLoadingSize, dataSize])
+
+  const GetAllWishlistsPaged = async () => {
+
+    setState({ ...state, loading: true })
+
+    if (!queryLoadingPaged) {
+      const parsedDataPaged = dataPaged?.exportListPaged
+      downloadWishlist(parsedDataPaged)
+    }
+    setState({ ...state, loading: false })
+  }
+
   const GetAllWishlists = async () => {
     setState({ ...state, loading: true })
+    console.log(loading)
 
     if (!queryLoading) {
       const parsedData = data?.exportList
@@ -73,6 +130,10 @@ const WishlistAdmin: FC<any> = ({ intl }) => {
       id: 'admin/settings.download',
       defaultMessage: 'Download Wishlists',
     },
+    page: {
+      id: 'admin/settings.page',
+      defaultMessage: 'Page',
+    },
   })
 
   const download = <IconDownload />
@@ -81,17 +142,47 @@ const WishlistAdmin: FC<any> = ({ intl }) => {
     <Layout
       pageHeader={<PageHeader title={intl.formatMessage(messages.title)} />}
     >
-      <PageBlock variation="full">
-        <ButtonWithIcon
-          icon={download}
-          isLoading={loading}
-          onClick={() => {
-            GetAllWishlists()
-          }}
-        >
-          {intl.formatMessage(messages.download)}
-        </ButtonWithIcon>
-      </PageBlock>
+      {isLongList ? 
+        <PageBlock variation="full">
+          <div className="w-100 mb4">
+            <div className="w-30">
+              <Dropdown
+                size="small"
+                label={intl.formatMessage(messages.page)}
+                options={options}
+                value={selected1}
+                onChange={(event: any) => {
+                  console.log(event.target.value)
+                  setSelected1(event.target.value)
+                  setTimeout(()=>{refetch()},500)
+
+                }}
+              />
+            </div>
+          </div>
+          <ButtonWithIcon
+            icon={download}
+            isLoading={queryLoadingPaged}
+            onClick={() => {
+              GetAllWishlistsPaged()
+            }}
+          >
+            {intl.formatMessage(messages.download)}
+          </ButtonWithIcon>
+        </PageBlock>
+      :
+        <PageBlock variation="full">
+          <ButtonWithIcon
+            icon={download}
+            isLoading={loading}
+            onClick={() => {
+              GetAllWishlists()
+            }}
+          >
+            {intl.formatMessage(messages.download)}
+          </ButtonWithIcon>
+        </PageBlock>
+      }
     </Layout>
   )
 }

react/queries/exportListPaged.gql

@@ -0,0 +1,15 @@
+query ExportListPaged(
+  $pageList: Int!
+) {
+   exportListPaged(pageList: $pageList) @context(provider: "vtex.wish-list") {
+      email
+      listItemsWrapper {
+         listItems {
+            id
+            productId
+            sku
+            title
+         }
+      }
+   }
+}

react/queries/listSize.gql

@@ -1,3 +1,3 @@
-query ListSise {
-   listSise @context(provider: "vtex.wish-list") 
+query ListSize {
+   listSize
 }