execute method

USyncSubscribeReposMessage execute(
  1. dynamic data
)

Implementation

USyncSubscribeReposMessage execute(final dynamic data) {
  final repos = const FirehoseAdaptor().execute(data);
  if (!_isRepoCommit(repos)) {
    return const USyncSubscribeReposMessageConverter().fromJson(repos);
  }

  final blocks = _getBlocks(repos);
  final ops = _getOps(repos);

  return const USyncSubscribeReposMessageConverter().fromJson({
    ...repos,
    'ops': ops,
    'blocks': _convertBlocks(blocks, ops),
    'commit': _getCommitCidLink(repos),
  });
}