SearchServiceImpl.java

package org.cardanofoundation.explorer.api.service.impl;

import java.util.List;
import java.util.Objects;
import java.util.Optional;

import lombok.RequiredArgsConstructor;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageImpl;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Pageable;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;

import org.cardanofoundation.explorer.api.common.constant.CommonConstant;
import org.cardanofoundation.explorer.api.common.constant.CommonConstant.NetworkType;
import org.cardanofoundation.explorer.api.model.response.BaseFilterResponse;
import org.cardanofoundation.explorer.api.model.response.pool.projection.PoolInfoProjection;
import org.cardanofoundation.explorer.api.model.response.search.*;
import org.cardanofoundation.explorer.api.repository.ledgersync.BlockRepository;
import org.cardanofoundation.explorer.api.repository.ledgersync.DrepInfoRepository;
import org.cardanofoundation.explorer.api.repository.ledgersync.EpochRepository;
import org.cardanofoundation.explorer.api.repository.ledgersync.MultiAssetRepository;
import org.cardanofoundation.explorer.api.repository.ledgersync.PoolHashRepository;
import org.cardanofoundation.explorer.api.repository.ledgersync.ScriptRepository;
import org.cardanofoundation.explorer.api.repository.ledgersync.StakeAddressRepository;
import org.cardanofoundation.explorer.api.repository.ledgersync.TxRepository;
import org.cardanofoundation.explorer.api.service.SearchService;
import org.cardanofoundation.explorer.api.util.AddressUtils;
import org.cardanofoundation.explorer.common.entity.enumeration.ScriptType;
import org.cardanofoundation.explorer.common.entity.ledgersync.Block;
import org.cardanofoundation.explorer.common.entity.ledgersync.DRepInfo;
import org.cardanofoundation.explorer.common.entity.ledgersync.MultiAsset;
import org.cardanofoundation.explorer.common.entity.ledgersync.Script;

@Service
@RequiredArgsConstructor
public class SearchServiceImpl implements SearchService {

  private final EpochRepository epochRepository;
  private final BlockRepository blockRepository;
  private final TxRepository txRepository;
  private final MultiAssetRepository multiAssetRepository;
  private final PoolHashRepository poolHashRepository;
  private final StakeAddressRepository stakeAddressRepository;
  private final ScriptRepository scriptRepository;
  private final DrepInfoRepository drepInfoRepository;

  @Value("${application.network}")
  private String network;

  @Override
  public SearchResponse search(String query) {
    String rawQuery = query;
    query = query.trim().toLowerCase();
    SearchResponse searchResponse = new SearchResponse();
    searchEpoch(query, searchResponse);
    searchBlock(query, searchResponse);
    searchTx(query, searchResponse);
    searchToken(query, searchResponse);
    searchAddress(rawQuery, searchResponse);
    searchPool(query, searchResponse);
    searchScriptHash(query, searchResponse);
    searchDRep(query, searchResponse);
    return searchResponse;
  }

  @Override
  public SearchStakingLifecycle searchForStakingLifecycle(String query, Pageable pageable) {
    String rawQuery = query;
    query = query.trim().toLowerCase();
    SearchStakingLifecycle response = new SearchStakingLifecycle();
    if (query.isBlank() || query.isEmpty()) {
      return response;
    }
    searchPoolIdAndHash(query, response, pageable);
    searchAddress(rawQuery, response);
    return response;
  }

  private void searchDRep(String query, SearchResponse searchResponse) {
    Optional<DRepInfo> dRepInfo = drepInfoRepository.findByDRepHashOrDRepId(query);
    dRepInfo.ifPresent(repInfo -> searchResponse.setDRep(repInfo.getDrepId()));
  }

  private void searchEpoch(String query, SearchResponse searchResponse) {
    try {
      Integer epochNo = Integer.parseInt(query);
      var epoch = epochRepository.findFirstByNo(epochNo);
      if (epoch.isPresent()) {
        searchResponse.setEpoch(epochNo);
      }
    } catch (NumberFormatException e) {
      searchResponse.setEpoch(null);
    }
  }

  private void searchBlock(String query, SearchResponse searchResponse) {
    Optional<Block> block;
    try {
      Long blockNo = Long.parseLong(query);
      block = blockRepository.findFirstByBlockNo(blockNo);
    } catch (NumberFormatException e) {
      block = blockRepository.findFirstByHash(query);
    }
    if (block.isPresent()) {
      searchResponse.setBlock(query);
    }
  }

  private void searchTx(String query, SearchResponse searchResponse) {
    var tx = txRepository.findByHash(query);
    if (tx.isPresent()) {
      searchResponse.setTx(query);
    }
  }

  private void searchToken(String query, SearchResponse searchResponse) {
    var token = multiAssetRepository.findByFingerprint(query);
    if (token.isPresent()) {
      searchResponse.setToken(
          new TokenSearchResponse(token.get().getNameView(), token.get().getFingerprint()));
    } else {
      Pageable pageable = PageRequest.of(0, 2);
      var tokenList = multiAssetRepository.findByNameViewLike(query, pageable);
      if (tokenList.size() == 1) {
        MultiAsset multiAsset = tokenList.get(0);
        searchResponse.setToken(
            new TokenSearchResponse(multiAsset.getNameView(), multiAsset.getFingerprint()));
      }
      if (!CollectionUtils.isEmpty(tokenList)) {
        searchResponse.setValidTokenName(true);
      }
    }
  }

  private void searchAddress(String query, SearchResponse searchResponse) {
    if (query.startsWith(CommonConstant.STAKE_ADDRESS_PREFIX)) {
      var stakeAddress = stakeAddressRepository.findByView(query);
      stakeAddress.ifPresent(
          address ->
              searchResponse.setAddress(
                  new AddressSearchResponse(address.getView(), address.getView(), false, true)));
    } else {
      final int ADDRESS_MIN_LENGTH = 56;
      if (query.length() < ADDRESS_MIN_LENGTH) {
        return;
      }
      try {
        if (checkNetworkAddress(query)) {
          String stakeAddress = AddressUtils.checkStakeAddress(query);
          if (Objects.nonNull(stakeAddress)) {
            searchResponse.setAddress(new AddressSearchResponse(query, stakeAddress, true, false));
          } else {
            searchResponse.setAddress(new AddressSearchResponse(query, null, true, false));
          }
        }
      } catch (Exception e) {
        // ignore
      }
    }
  }

  private void searchAddress(String query, SearchStakingLifecycle response) {
    if (query.startsWith(CommonConstant.STAKE_ADDRESS_PREFIX)) {
      var stakeAddress = stakeAddressRepository.findByView(query);
      stakeAddress.ifPresent(
          address ->
              response.setAddress(
                  new AddressSearchResponse(address.getView(), address.getView(), false, true)));
    } else {
      final int ADDRESS_MIN_LENGTH = 56;
      if (query.length() < ADDRESS_MIN_LENGTH) {
        return;
      }
      try {
        if (checkNetworkAddress(query)) {
          String stakeAddress = AddressUtils.checkStakeAddress(query);
          if (Objects.nonNull(stakeAddress)) {
            response.setAddress(new AddressSearchResponse(query, stakeAddress, true, false));
          } else {
            response.setAddress(new AddressSearchResponse(query, null, true, false));
          }
        }
      } catch (Exception e) {
        // ignore
      }
    }
  }

  private void searchPoolIdAndHash(
      String query, SearchStakingLifecycle response, Pageable pageable) {
    var pool = poolHashRepository.getPoolInfo(query);
    if (Objects.nonNull(pool)) {
      Page<PoolSearchResponse> poolPage =
          new PageImpl<>(
              List.of(
                  new PoolSearchResponse(pool.getPoolName(), pool.getPoolView(), pool.getIcon())),
              pageable,
              1);
      response.setPoolList(new BaseFilterResponse<>(poolPage));
    }
  }

  /**
   * Check address is valid in this network
   *
   * @param address address view value
   * @return true if valid and false if not
   */
  private boolean checkNetworkAddress(String address) {
    if (address.startsWith(CommonConstant.TESTNET_ADDRESS_PREFIX)) {
      return !network.equals(NetworkType.MAINNET);
    } else {
      return network.equals(NetworkType.MAINNET);
    }
  }

  private void searchPool(String query, SearchResponse searchResponse) {
    var pool = poolHashRepository.getPoolInfo(query);
    if (Objects.nonNull(pool)) {
      searchResponse.setPool(
          new PoolSearchResponse(pool.getPoolName(), pool.getPoolView(), pool.getIcon()));
    } else {
      Pageable pageable = PageRequest.of(0, 2);
      var poolList = poolHashRepository.findByPoolNameLike(query, pageable);
      if (poolList.getTotalElements() == 1) {
        PoolInfoProjection poolInfo = poolList.getContent().get(0);
        searchResponse.setPool(
            new PoolSearchResponse(
                poolInfo.getPoolName(), poolInfo.getPoolView(), poolInfo.getIcon()));
      }
      if (!CollectionUtils.isEmpty(poolList.getContent())) {
        searchResponse.setValidPoolName(true);
      }
    }
  }

  public void searchScriptHash(String query, SearchResponse searchResponse) {
    Script script = scriptRepository.findByHash(query).orElse(null);

    if (Objects.nonNull(script)) {
      boolean isSmartContract =
          ScriptType.PLUTUSV1.equals(script.getType())
              || ScriptType.PLUTUSV2.equals(script.getType())
              || ScriptType.PLUTUSV3.equals(script.getType());

      ScriptSearchResponse scriptSearchResponse =
          ScriptSearchResponse.builder().scriptHash(script.getHash()).build();

      if (isSmartContract) {
        scriptSearchResponse.setSmartContract(true);
      } else {
        scriptSearchResponse.setNativeScript(true);
      }
      searchResponse.setScript(scriptSearchResponse);
    }
  }
}

































































Active mutators

CONDITIONALS_BOUNDARY
EMPTY_RETURNS
FALSE_RETURNS
INCREMENTS
INVERT_NEGS
MATH
NEGATE_CONDITIONALS
NULL_RETURNS
PRIMITIVE_RETURNS
TRUE_RETURNS
VOID_METHOD_CALLS

Tests examined

org.cardanofoundation.explorer.api.service.SearchServiceTest.[engine:junit-jupiter]/[class:org.cardanofoundation.explorer.api.service.SearchServiceTest]/[method:testSearchLifeCycle_thenReturnAddress()] (2 ms)
org.cardanofoundation.explorer.api.service.SearchServiceTest.[engine:junit-jupiter]/[class:org.cardanofoundation.explorer.api.service.SearchServiceTest]/[method:testSearch_thenReturnMatchAddress_isStakeAddress()] (5 ms)
org.cardanofoundation.explorer.api.service.SearchServiceTest.[engine:junit-jupiter]/[class:org.cardanofoundation.explorer.api.service.SearchServiceTest]/[method:testSearch_thenReturnMatchMultiAssets_NoMatchToken()] (1 ms)
org.cardanofoundation.explorer.api.service.SearchServiceTest.[engine:junit-jupiter]/[class:org.cardanofoundation.explorer.api.service.SearchServiceTest]/[method:testSearch_thenReturnMatchBlock()] (2 ms)
org.cardanofoundation.explorer.api.service.SearchServiceTest.[engine:junit-jupiter]/[class:org.cardanofoundation.explorer.api.service.SearchServiceTest]/[method:testSearch_thenReturnMatchScript()] (2 ms)
org.cardanofoundation.explorer.api.service.SearchServiceTest.[engine:junit-jupiter]/[class:org.cardanofoundation.explorer.api.service.SearchServiceTest]/[method:testSearch_thenReturnMatchMultiAssets_MatchToken()] (2 ms)
org.cardanofoundation.explorer.api.service.SearchServiceTest.[engine:junit-jupiter]/[class:org.cardanofoundation.explorer.api.service.SearchServiceTest]/[method:testSearch_thenReturnMatchTx9()] (2 ms)
org.cardanofoundation.explorer.api.service.SearchServiceTest.[engine:junit-jupiter]/[class:org.cardanofoundation.explorer.api.service.SearchServiceTest]/[method:testSearch_thenReturnMatchPool()] (2 ms)
org.cardanofoundation.explorer.api.service.SearchServiceTest.[engine:junit-jupiter]/[class:org.cardanofoundation.explorer.api.service.SearchServiceTest]/[method:testSearchLifeCycle_thenReturnStakeAddress()] (2 ms)
org.cardanofoundation.explorer.api.service.SearchServiceTest.[engine:junit-jupiter]/[class:org.cardanofoundation.explorer.api.service.SearchServiceTest]/[method:testSearch_thenReturnMatchingEpoch()] (2 ms)

Report generated by PIT 1.14.2

1		package org.cardanofoundation.explorer.api.service.impl;
2
3		import java.util.List;
4		import java.util.Objects;
5		import java.util.Optional;
6
7		import lombok.RequiredArgsConstructor;
8
9		import org.springframework.beans.factory.annotation.Value;
10		import org.springframework.data.domain.Page;
11		import org.springframework.data.domain.PageImpl;
12		import org.springframework.data.domain.PageRequest;
13		import org.springframework.data.domain.Pageable;
14		import org.springframework.stereotype.Service;
15		import org.springframework.util.CollectionUtils;
16
17		import org.cardanofoundation.explorer.api.common.constant.CommonConstant;
18		import org.cardanofoundation.explorer.api.common.constant.CommonConstant.NetworkType;
19		import org.cardanofoundation.explorer.api.model.response.BaseFilterResponse;
20		import org.cardanofoundation.explorer.api.model.response.pool.projection.PoolInfoProjection;
21		import org.cardanofoundation.explorer.api.model.response.search.*;
22		import org.cardanofoundation.explorer.api.repository.ledgersync.BlockRepository;
23		import org.cardanofoundation.explorer.api.repository.ledgersync.DrepInfoRepository;
24		import org.cardanofoundation.explorer.api.repository.ledgersync.EpochRepository;
25		import org.cardanofoundation.explorer.api.repository.ledgersync.MultiAssetRepository;
26		import org.cardanofoundation.explorer.api.repository.ledgersync.PoolHashRepository;
27		import org.cardanofoundation.explorer.api.repository.ledgersync.ScriptRepository;
28		import org.cardanofoundation.explorer.api.repository.ledgersync.StakeAddressRepository;
29		import org.cardanofoundation.explorer.api.repository.ledgersync.TxRepository;
30		import org.cardanofoundation.explorer.api.service.SearchService;
31		import org.cardanofoundation.explorer.api.util.AddressUtils;
32		import org.cardanofoundation.explorer.common.entity.enumeration.ScriptType;
33		import org.cardanofoundation.explorer.common.entity.ledgersync.Block;
34		import org.cardanofoundation.explorer.common.entity.ledgersync.DRepInfo;
35		import org.cardanofoundation.explorer.common.entity.ledgersync.MultiAsset;
36		import org.cardanofoundation.explorer.common.entity.ledgersync.Script;
37
38		@Service
39		@RequiredArgsConstructor
40		public class SearchServiceImpl implements SearchService {

SearchServiceImpl.java

Mutations

Active mutators

Tests examined