update method

  1. @override
Future<T?> update(
  1. String? correlationId,
  2. T? item
)
override

Updates a data item.

  • correlation_id (optional) transaction id to trace execution through call chain.
  • item an item to be updated. Return (optional) Future that receives updated item Throws error.

Implementation

@override
Future<T?> update(String? correlationId, T? item) async {
  var index = List.from(items.map((x) {
    return x.id;
  })).indexOf(item?.id);

  if (index < 0) {
    logger.trace(correlationId, 'Item %s was not found', [item?.id]);
    return null;
  }

  var clone_item;
  if (item is ICloneable) {
    clone_item = (item as ICloneable).clone();
  } else {
    var jsonMap = json.decode(json.encode(item));
    clone_item = TypeReflector.createInstanceByType(T, []);
    clone_item.fromJson(jsonMap);
  }

  if (clone_item.id == null) {
    ObjectWriter.setProperty(clone_item, 'id', IdGenerator.nextLong());
  }

  items[index] = clone_item;
  logger.trace(correlationId, 'Updated item %s', [clone_item.id]);

  await save(correlationId);

  return clone_item;
}