public static List deserializeList()

in data-resource-management-service/drms-core/src/main/java/org/apache/airavata/drms/core/deserializer/TransferMappingDeserializer.java [16:47]

27 lines of code
6 McCabe index (conditional complexity)


    public static List<TransferMapping> deserializeList(List<Record> neo4jRecords) throws Exception {
        List<TransferMapping> transferMappings = new ArrayList<>();
        for (Record record : neo4jRecords) {
            InternalRecord internalRecord = (InternalRecord) record;
            List<Value> values = internalRecord.values();

            if (values.size() == 3) {
                Value srcStr = values.get(0);
                Value dstStr = values.get(1);
                Value tm = values.get(2);

                if (!srcStr.isNull() && !tm.isNull()
                        && !dstStr.isNull()) {
                    AnyStorage storage = AnyStorageDeserializer.deriveStorageFromMap(srcStr.asMap());
                    AnyStorage dstStorage = AnyStorageDeserializer.deriveStorageFromMap(dstStr.asMap());

                    Map<String, Object> map = tm.asMap();
                    TransferMapping transferMapping = TransferMapping.newBuilder()
                            .setTransferScope(TransferScope.valueOf(map.get("scope").toString()))
                            .setId(map.get("entityId").toString())
                            .setSourceStorage(storage)
                            .setDestinationStorage(dstStorage)
                            .setUserId(map.get("owner").toString())
                            .build();

                    transferMappings.add(transferMapping);

                }
            }
        }
        return transferMappings;
    }