iris-subscription/src/main/java/org/iris_events/subscription/collection/Utils.java at 2c7c9351571315a1d6dc11eda33d6e526c968b29 · ratkokostov7/iris-subscription · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
package org.iris_events.subscription.collection;

import org.iris_events.subscription.model.Subscription;

public class Utils {

    public static final String SUB_TEMPLATE = "subscription|%s";
    public static final String SESSION_SUB_TEMPLATE = "sessionIdSub|%s";
    public static final String RESOURCE_SNAP_TEMPLATE = "resTypeResIdSnap|%s";
    public static final String RESOURCE_SUB_TEMPLATE = "resTypeResIdSub|%s";
    public static final String PIPE = "|";
    public static final String SUBSCRIPTION_ID_DELIMITER = "\\|";
    public static final int MIN_SUBSCRIPTION_PARTS = 4;
    public static final int RESOURCE_TYPE_INDEX = 2;
    public static final int RESOURCE_ID_INDEX = 3;


    public static String getResourceSubscriptionsSetId(final String resourceType, final String resourceId) {
        final var uniqueResId = getUniqueResId(resourceType, resourceId);
        return String.format(RESOURCE_SUB_TEMPLATE, uniqueResId);
    }

    public static String getResourceSnapshotKey(final String resourceType, final String resourceId) {
        final var uniqueResId = getUniqueResId(resourceType, resourceId);
        return String.format(RESOURCE_SNAP_TEMPLATE, uniqueResId);
    }

    public static String getUniqueResId(String resourceType, String resourceId) {
        return String.format("%s|%s", resourceType, resourceId);
    }

    public static String getSessionSubscriptionsSetId(final String sessionId) {
        return String.format(SESSION_SUB_TEMPLATE, sessionId);
    }

    public static String generateSubscriptionId(Subscription subscription) {
        final var subId = subscription.sessionId() + PIPE + subscription.resourceType() + PIPE + subscription.resourceId();
        return String.format(SUB_TEMPLATE, subId);
    }

    public static boolean isValidSubscriptionId(String subscriptionId) {
        return subscriptionId != null &&
                subscriptionId.split(SUBSCRIPTION_ID_DELIMITER).length >= MIN_SUBSCRIPTION_PARTS;
    }

    public static String getResourceSetKey(String subscriptionId) {
        String[] parts = subscriptionId.split(SUBSCRIPTION_ID_DELIMITER);
        return Utils.getResourceSubscriptionsSetId(parts[RESOURCE_TYPE_INDEX], parts[RESOURCE_ID_INDEX]);
    }
}