feat(@desktop/wallet): Implement loadTypes in collectibles controller

Fixes #13169
This commit is contained in:
Dario Gabriel Lipicar 2024-01-10 01:27:15 -03:00 committed by dlipicar
parent 1dd5f3d007
commit 2b6f2229c7
7 changed files with 61 additions and 19 deletions

View File

@ -45,7 +45,7 @@ proc newModule*(
result.controller = accountsc.newController(result, walletAccountService)
result.collectiblesController = collectiblesc.newController(
requestId = int32(backend_collectibles.CollectiblesRequestID.ProfileShowcase),
autofetch = false,
loadType = collectiblesc.LoadType.AutoLoadSingleUpdate,
networkService = networkService,
events = events
)

View File

@ -130,7 +130,7 @@ proc newModule*(
result.transactionService = transactionService
let collectiblesController = collectiblesc.newController(
requestId = int32(backend_collectibles.CollectiblesRequestID.WalletAccount),
autofetch = false,
loadType = collectiblesc.LoadType.OnDemand,
networkService = networkService,
events = events
)

View File

@ -76,7 +76,7 @@ proc newModule*(
transactionService, keycardService)
result.collectiblesController = collectiblesc.newController(
requestId = int32(backend_collectibles.CollectiblesRequestID.WalletSend),
autofetch = true,
loadType = collectiblesc.LoadType.AutoLoadSingleUpdate,
networkService = networkService,
events = events
)

View File

@ -338,9 +338,9 @@ QtObject:
QtProperty[string] networkIconUrl:
read = getNetworkIconURL
proc updateData*(self: CollectiblesEntry, update: backend.Collectible) =
proc updateDataIfSameID*(self: CollectiblesEntry, update: backend.Collectible): bool =
if self.id != update.id:
return
return false
self.setData(update)
@ -362,3 +362,4 @@ QtObject:
self.communityColorChanged()
self.communityPrivilegesLevelChanged()
self.communityImageChanged()
return true

View File

@ -350,8 +350,7 @@ QtObject:
let entry = self.items[i]
for j in countdown(updates.high, 0):
let update = updates[j]
if entry.getCollectibleUniqueID() == update.id:
entry.updateData(update)
if entry.updateDataIfSameID(update):
let index = self.createIndex(i, 0, nil)
defer: index.delete
self.dataChanged(index, index)

View File

@ -82,7 +82,8 @@ QtObject:
for jsonCollectible in jsonObj.getElems():
let collectible = fromJson(jsonCollectible, backend_collectibles.Collectible)
self.detailedEntry.updateData(collectible) # Will only update if UniqueID matches
if self.detailedEntry.updateDataIfSameID(collectible):
break
proc getDetailedCollectible*(self: Controller, chainId: int, contractAddress: string, tokenId: string) {.slot.} =
self.setIsDetailedEntryLoading(true)

View File

@ -14,6 +14,18 @@ import app_service/service/network/service as network_service
const FETCH_BATCH_COUNT_DEFAULT = 50
type
LoadType* {.pure.} = enum
AutoLoadSingleUpdate, # load all items and update the model once with full list
AutoLoadPaginated, # load items in batches (keep loading until the end of the list) and update the model appending each batch.
OnDemand # load items in batches (on demand when loadMoreItems is called) and update the model appending each batch.
proc isAutoLoad(self: LoadType): bool =
return self == LoadType.AutoLoadSingleUpdate or self == LoadType.AutoLoadPaginated
proc isPaginated(self: LoadType): bool =
return self == LoadType.AutoLoadPaginated or self == LoadType.OnDemand
QtObject:
type
Controller* = ref object of QObject
@ -21,6 +33,7 @@ QtObject:
model: Model
fetchFromStart: bool
tempItems: seq[CollectiblesEntry]
eventsHandler: EventsHandler
@ -31,7 +44,7 @@ QtObject:
ownershipStatus: Table[string, Table[int, OwnershipStatus]] # Table[address][chainID] -> OwnershipStatus
requestId: int32
autofetch: bool
loadType: LoadType
dataType: backend_collectibles.CollectibleDataType
fetchCriteria: backend_collectibles.FetchCriteria
@ -116,7 +129,10 @@ QtObject:
var offset = 0
if not self.fetchFromStart:
if self.loadType.isPaginated():
offset = self.model.getCollectiblesCount()
else:
offset = self.tempItems.len
self.fetchFromStart = false
let response = backend_collectibles.getOwnedCollectiblesAsync(self.requestId, self.chainIds, self.addresses, self.filter, offset, FETCH_BATCH_COUNT_DEFAULT, self.dataType, self.fetchCriteria)
@ -130,9 +146,15 @@ QtObject:
let network = self.networkService.getNetwork(chainID)
return getExtraData(network)
proc processGetOwnedCollectiblesResponse(self: Controller, response: JsonNode) =
self.model.setIsFetching(false)
proc setTempItems(self: Controller, newItems: seq[CollectiblesEntry], offset: int) =
if offset == 0:
self.tempItems = @[]
elif offset != self.tempItems.len:
error "invalid offset"
return
self.tempItems.add(newItems)
proc processGetOwnedCollectiblesResponse(self: Controller, response: JsonNode) =
let res = fromJson(response, backend_collectibles.GetOwnedCollectiblesResponse)
let isError = res.errorCode != backend_collectibles.ErrorCodeSuccess
@ -140,6 +162,7 @@ QtObject:
if isError:
error "error fetching collectibles entries: ", res.errorCode
self.model.setIsError(true)
self.model.setIsFetching(false)
return
try:
@ -147,15 +170,30 @@ QtObject:
let extradata = self.getExtraData(header.id.contractID.chainID)
newCollectibleDetailsFullEntry(header, extradata)
))
if self.loadType.isPaginated():
self.model.setItems(items, res.offset, res.hasMore)
else:
self.setTempItems(items, res.offset)
# If we reached the end of the list, commit the items to the model
if not res.hasMore:
self.model.setItems(self.tempItems, 0, false)
self.tempItems = @[]
except Exception as e:
error "Error converting activity entries: ", e.msg
self.model.setIsFetching(false)
self.setOwnershipStatus(res.ownershipStatus)
if self.autofetch and res.hasMore:
if self.loadType.isAutoLoad() and res.hasMore:
self.loadMoreItems()
proc updateTempItems(self: Controller, updates: seq[backend_collectibles.Collectible]) =
for i in countdown(self.tempItems.high, 0):
let entry = self.tempItems[i]
for j in countdown(updates.high, 0):
if entry.updateDataIfSameID(updates[j]):
break
proc processCollectiblesDataUpdate(self: Controller, jsonObj: JsonNode) =
if jsonObj.kind != JArray:
error "processCollectiblesDataUpdate expected an array"
@ -165,11 +203,14 @@ QtObject:
let collectible = fromJson(jsonCollectible, backend_collectibles.Collectible)
collectibles.add(collectible)
self.model.updateItems(collectibles)
if not self.loadType.isPaginated():
self.updateTempItems(collectibles)
proc resetModel(self: Controller) {.slot.} =
self.tempItems = @[]
self.model.setItems(@[], 0, true)
self.fetchFromStart = true
if self.autofetch:
if self.loadType.isAutoLoad():
self.loadMoreItems()
proc setupEventHandlers(self: Controller) =
@ -205,7 +246,7 @@ QtObject:
requestId: int32,
networkService: network_service.Service,
events: EventEmitter,
autofetch: bool = true,
loadType: LoadType,
dataType: backend_collectibles.CollectibleDataType = backend_collectibles.CollectibleDataType.Header,
fetchCriteria: backend_collectibles.FetchCriteria = backend_collectibles.FetchCriteria(
fetchType: backend_collectibles.FetchType.NeverFetch,
@ -213,7 +254,7 @@ QtObject:
new(result, delete)
result.requestId = requestId
result.autofetch = autofetch
result.loadType = loadType
result.dataType = dataType
result.fetchCriteria = fetchCriteria