owenclave / app/src/main/java/io/nekohasekai/sagernet/fmt/internal/ChainBean.java

github - dev - back to tree - upstream
/****************************************************************************** * * * Copyright (C) 2021 by nekohasekai * * * * This program is free software: you can redistribute it and/or modify * * it under the terms of the GNU General Public License as published by * * the Free Software Foundation, either version 3 of the License, or * * (at your option) any later version. * * * * This program is distributed in the hope that it will be useful, * * but WITHOUT ANY WARRANTY; without even the implied warranty of * * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * * GNU General Public License for more details. * * * * You should have received a copy of the GNU General Public License * * along with this program. If not, see . * * * ******************************************************************************/ package io.nekohasekai.sagernet.fmt.internal; import androidx.annotation.NonNull; import com.esotericsoftware.kryo.io.ByteBufferInput; import com.esotericsoftware.kryo.io.ByteBufferOutput; import org.jetbrains.annotations.NotNull; import java.util.ArrayList; import java.util.List; import io.nekohasekai.sagernet.database.ProxyEntity; import io.nekohasekai.sagernet.database.SagerDatabase; import io.nekohasekai.sagernet.fmt.KryoConverters; public class ChainBean extends InternalBean { public List proxies; @Override public String displayName() { if (!name.isEmpty()) { return name; } else { return "Chain " + Math.abs(hashCode()); } } @Override public void initializeDefaultValues() { super.initializeDefaultValues(); if (name == null) name = ""; if (proxies == null) { proxies = new ArrayList<>(); } } @Override public void serialize(ByteBufferOutput output) { output.writeInt(1); output.writeInt(proxies.size()); for (Long proxy : proxies) { output.writeLong(proxy); } } @Override public void deserialize(ByteBufferInput input) { int version = input.readInt(); if (version < 1) { input.readString(); input.readInt(); } int length = input.readInt(); proxies = new ArrayList<>(); for (int i = 0; i < length; i++) { proxies.add(input.readLong()); } } @NotNull @Override public ChainBean clone() { return KryoConverters.deserialize(new ChainBean(), KryoConverters.serialize(this)); } public static final Creator CREATOR = new CREATOR<>() { @NonNull @Override public ChainBean newInstance() { return new ChainBean(); } @Override public ChainBean[] newArray(int size) { return new ChainBean[size]; } }; @Override public boolean canMapping() { List proxyEntities = SagerDatabase.Companion.getProxyDao().getEntities(proxies); if (proxyEntities.isEmpty()) { return false; } try { for (ProxyEntity proxyEntity: proxyEntities) { if (!proxyEntity.requireBean().canMapping()) { return false; } } } catch (Exception e) { return false; } return true; } @Override public boolean isInsecure() { List proxyEntities = SagerDatabase.Companion.getProxyDao().getEntities(proxies); if (proxyEntities.isEmpty()) { return false; } try { for (ProxyEntity proxyEntity: proxyEntities) { if (!proxyEntity.requireBean().isInsecure()) { return false; } } } catch (Exception e) { return false; } return true; } }