Merge branch 'trunk' into woomob-1131-woo-poshistorical-orders-orders-fetching

Author: staskus

Modules/Sources/Experiments/DefaultFeatureFlagService.swift

@@ -100,6 +100,8 @@ public struct DefaultFeatureFlagService: FeatureFlagService {
             return true
         case .pointOfSaleHistoricalOrdersi1:
             return buildConfig == .localDeveloper || buildConfig == .alpha
+        case .pointOfSaleLocalCatalogi1:
+            return buildConfig == .localDeveloper || buildConfig == .alpha
         default:
             return true
         }

Modules/Sources/Experiments/FeatureFlag.swift

@@ -206,4 +206,9 @@ public enum FeatureFlag: Int {
     /// Enables the entry point for Point of Sale Orders
     ///
     case pointOfSaleHistoricalOrdersi1
+
+    /// Enables Local Catalog i1 in Point of Sale.
+    /// It syncs products and variations to local storage and display them in POS for quick access.
+    ///
+    case pointOfSaleLocalCatalogi1
 }

Modules/Sources/Networking/Remote/POSCatalogSyncRemote.swift

@@ -0,0 +1,73 @@
+import Foundation
+
+/// POS Catalog Sync: Remote Endpoints
+///
+public class POSCatalogSyncRemote: Remote {
+    private let dateFormatter = ISO8601DateFormatter()
+
+    /// Loads POS products modified after the specified date.
+    ///
+    /// - Parameters:
+    ///   - modifiedAfter: Only products modified after this date will be returned.
+    ///   - siteID: Site ID to load products from.
+    ///   - pageNumber: Page number for pagination.
+    /// - Returns: Paginated list of POS products.
+    ///
+    // periphery:ignore - TODO - remove this periphery ignore comment when this endpoint is integrated with catalog sync
+    public func loadProducts(modifiedAfter: Date, siteID: Int64, pageNumber: Int)
+    async throws -> PagedItems<POSProduct> {
+        let path = "products"
+        let parameters = [
+            ParameterKey.modifiedAfter: dateFormatter.string(from: modifiedAfter),
+            ParameterKey.page: String(pageNumber),
+            ParameterKey.perPage: String(Constants.defaultPageSize),
+            ParameterKey.fields: POSProduct.requestFields.joined(separator: ",")
+        ]
+
+        let request = JetpackRequest(wooApiVersion: .mark3, method: .get, siteID: siteID, path: path, parameters: parameters)
+        let mapper = ListMapper<POSProduct>(siteID: siteID)
+        let (products, responseHeaders) = try await enqueueWithResponseHeaders(request, mapper: mapper)
+
+        return createPagedItems(items: products, responseHeaders: responseHeaders, currentPageNumber: pageNumber)
+    }
+
+    /// Loads POS product variations modified after the specified date.
+    ///
+    /// - Parameters:
+    ///   - modifiedAfter: Only variations modified after this date will be returned.
+    ///   - siteID: Site ID to load variations from.
+    ///   - pageNumber: Page number for pagination.
+    /// - Returns: Paginated list of POS product variations.
+    ///
+    // periphery:ignore - TODO - remove this periphery ignore comment when this endpoint is integrated with catalog sync
+    public func loadProductVariations(modifiedAfter: Date, siteID: Int64, pageNumber: Int) async throws -> PagedItems<POSProductVariation> {
+        let path = "variations"
+        let parameters = [
+            ParameterKey.modifiedAfter: dateFormatter.string(from: modifiedAfter),
+            ParameterKey.page: String(pageNumber),
+            ParameterKey.perPage: String(Constants.defaultPageSize),
+            ParameterKey.fields: POSProductVariation.requestFields.joined(separator: ",")
+        ]
+
+        let request = JetpackRequest(wooApiVersion: .wcAnalytics, method: .get, siteID: siteID, path: path, parameters: parameters)
+        let mapper = ListMapper<POSProductVariation>(siteID: siteID)
+        let (variations, responseHeaders) = try await enqueueWithResponseHeaders(request, mapper: mapper)
+
+        return createPagedItems(items: variations, responseHeaders: responseHeaders, currentPageNumber: pageNumber)
+    }
+}
+
+// MARK: - Constants
+//
+private extension POSCatalogSyncRemote {
+    enum Constants {
+        static let defaultPageSize = 100
+    }
+
+    enum ParameterKey {
+        static let modifiedAfter = "modified_after"
+        static let page = "page"
+        static let perPage = "per_page"
+        static let fields = "_fields"
+    }
+}

Modules/Sources/Networking/Remote/ProductVariationsRemote.swift

@@ -97,18 +97,7 @@ public class ProductVariationsRemote: Remote, ProductVariationsRemoteProtocol {
         let mapper = ListMapper<POSProductVariation>(siteID: siteID)
 
         let (variations, responseHeaders) = try await enqueueWithResponseHeaders(request, mapper: mapper)
-
-        // Extracts the total number of pages from the response headers.
-        // Response header names are case insensitive.
-        let totalPages = responseHeaders?.first(where: { $0.key.lowercased() == Remote.PaginationHeaderKey.totalPagesCount.lowercased() })
-            .flatMap { Int($0.value) }
-        let hasMorePages = totalPages.map { pageNumber < $0 } ?? true
-
-        // Extract total count from X-WP-Total header
-        let totalItems = responseHeaders?.first(where: { $0.key.lowercased() == Remote.PaginationHeaderKey.totalCount.lowercased() })
-            .flatMap { Int($0.value) }
-
-        return PagedItems(items: variations, hasMorePages: hasMorePages, totalItems: totalItems)
+        return createPagedItems(items: variations, responseHeaders: responseHeaders, currentPageNumber: pageNumber)
     }
 
     private func productVariationsRequest(for siteID: Int64,

Modules/Sources/Networking/Remote/ProductsRemote.swift

@@ -286,18 +286,7 @@ public final class ProductsRemote: Remote, ProductsRemoteProtocol {
         let mapper = ListMapper<POSProduct>(siteID: siteID)
 
         let (products, responseHeaders) = try await enqueueWithResponseHeaders(request, mapper: mapper)
-
-        // Extracts the total number of pages from the response headers.
-        // Response header names are case insensitive.
-        let totalPages = responseHeaders?.first(where: { $0.key.lowercased() == Remote.PaginationHeaderKey.totalPagesCount.lowercased() })
-            .flatMap { Int($0.value) }
-        let hasMorePages = totalPages.map { pageNumber < $0 } ?? true
-
-        // Extract total count from X-WP-Total header
-        let totalItems = responseHeaders?.first(where: { $0.key.lowercased() == Remote.PaginationHeaderKey.totalCount.lowercased() })
-            .flatMap { Int($0.value) }
-
-        return .init(items: products, hasMorePages: hasMorePages, totalItems: totalItems)
+        return createPagedItems(items: products, responseHeaders: responseHeaders, currentPageNumber: pageNumber)
     }
 
     /// Remote search of products for the Point of Sale. Simple and variable products are loaded for WC version 9.6+, otherwise only simple products are loaded.

Modules/Sources/NetworkingCore/Remote/Remote.swift

@@ -362,6 +362,35 @@ public struct PagedItems<T> {
     }
 }
 
+// MARK: - Pagination Helpers
+//
+public extension Remote {
+    /// Creates a PagedItems instance from response data and headers.
+    ///
+    /// - Parameters:
+    ///   - items: The parsed items from the response.
+    ///   - responseHeaders: HTTP response headers containing pagination info.
+    ///   - currentPageNumber: The current page number for determining if more pages exist.
+    /// - Returns: PagedItems instance with pagination metadata.
+    func createPagedItems<T>(items: [T],
+                             responseHeaders: [String: String]?,
+                             currentPageNumber: Int) -> PagedItems<T> {
+        // Extract total pages from response headers (case insensitive)
+        let totalPages = responseHeaders?.first(where: {
+            $0.key.lowercased() == PaginationHeaderKey.totalPagesCount.lowercased()
+        }).flatMap { Int($0.value) }
+
+        let hasMorePages = totalPages.map { currentPageNumber < $0 } ?? true
+
+        // Extract total count from response headers (case insensitive)
+        let totalItems = responseHeaders?.first(where: {
+            $0.key.lowercased() == PaginationHeaderKey.totalCount.lowercased()
+        }).flatMap { Int($0.value) }
+
+        return PagedItems(items: items, hasMorePages: hasMorePages, totalItems: totalItems)
+    }
+}
+
 // MARK: - Constants!
 //
 public extension Remote {