eagle-core/eagle-metadata/eagle-metadata-base/src/main/java/org/apache/eagle/metadata/utils/PolicyIdConversions.java

/*
 *  Licensed to the Apache Software Foundation (ASF) under one or more
 *  contributor license agreements.  See the NOTICE file distributed with
 *  this work for additional information regarding copyright ownership.
 *  The ASF licenses this file to You under the Apache License, Version 2.0
 *  (the "License"); you may not use this file except in compliance with
 *  the License.  You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 *  Unless required by applicable law or agreed to in writing, software
 *  distributed under the License is distributed on an "AS IS" BASIS,
 *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 *  See the License for the specific language governing permissions and
 *  limitations under the License.
 */

package org.apache.eagle.metadata.utils;

import com.google.common.base.Preconditions;

public class PolicyIdConversions {

    public static String generateUniquePolicyId(String siteId, String policyName) {
        String subffix = String.format("_%s", siteId.toLowerCase());
        if (policyName.toLowerCase().endsWith(subffix)) {
            return policyName;
        }
        return String.format("%s_%s", policyName, siteId.toLowerCase());
    }

    public static String parsePolicyId(String siteId, String policyName) {
        String subffix = String.format("_%s", siteId.toLowerCase());
        if (policyName.toLowerCase().endsWith(subffix)) {
            int streamTypeIdLength = policyName.length() - subffix.length();
            Preconditions.checkArgument(streamTypeIdLength > 0, "Invalid policyId: " + policyName + ", policyId is empty");
            return policyName.substring(0, streamTypeIdLength);
        } else {
            return policyName;
        }
    }
}