public ReqT intercept()

in custos-services/custos-integration-services/resource-secret-management-service/src/main/java/org/apache/custos/resource/secret/management/interceptors/ResourceSecretManagementInputValidator.java [66:93]


    public <ReqT> ReqT intercept(String method, Metadata headers, ReqT msg) {


        if (method.equals("addSSHCredential") || method.equals("addPasswordCredential")
                || method.equals("addCertificateCredential")) {
            validate(method, msg, headers);
            validateSecretMetadata(msg, method);
        } else if (method.equals("addKVCredential") || method.equals("getKVCredential") ||
                method.equals("updateKVCredential") || method.equals("deleteKVCredential")) {
            validate(method, msg, headers);
            if (msg instanceof KVCredential) {
                String key = ((KVCredential) msg).getKey();
                String value = (((KVCredential) msg)).getValue();
                String token = (((KVCredential) msg)).getToken();
                if ((token == null || token.trim().equals("")) && (key == null || key.trim().equals(""))) {
                    throw new MissingParameterException("At least key or token should be added ", null);
                }

                if ((method.equals("addKVCredential") || method.equals("updateKVCredential")) && (value == null || value.trim().equals(""))) {
                    throw new MissingParameterException("Value should not be null ", null);
                }

            } else {
                throw new RuntimeException("Unknown message type", null);
            }
        }
        return msg;
    }