public Response requestReply()

in client/src/main/java/com/alibaba/nacos/client/naming/remote/gprc/NamingFuzzyWatchNotifyRequestHandler.java [53:126]
67 lines of code
18 McCabe index (conditional complexity)

    public Response requestReply(Request request, Connection connection) {
        
        if (request instanceof NamingFuzzyWatchSyncRequest) {
            NamingFuzzyWatchSyncRequest watchNotifySyncRequest = (NamingFuzzyWatchSyncRequest) request;
            NamingFuzzyWatchContext namingFuzzyWatchContext = namingFuzzyWatchServiceListHolder.getFuzzyMatchContextMap()
                    .get(watchNotifySyncRequest.getGroupKeyPattern());
            if (namingFuzzyWatchContext != null) {
                Collection<NamingFuzzyWatchSyncRequest.Context> serviceKeys = watchNotifySyncRequest.getContexts();
                if (watchNotifySyncRequest.getSyncType().equals(Constants.FUZZY_WATCH_INIT_NOTIFY)
                        || watchNotifySyncRequest.getSyncType().equals(Constants.FUZZY_WATCH_DIFF_SYNC_NOTIFY)) {
                    for (NamingFuzzyWatchSyncRequest.Context serviceKey : serviceKeys) {
                        // may have a 'change event' sent to client before 'init event'
                        if (namingFuzzyWatchContext.addReceivedServiceKey(serviceKey.getServiceKey())) {
                            NotifyCenter.publishEvent(NamingFuzzyWatchNotifyEvent.build(
                                    namingFuzzyWatchServiceListHolder.getNotifierEventScope(),
                                    watchNotifySyncRequest.getGroupKeyPattern(), serviceKey.getServiceKey(),
                                    serviceKey.getChangedType(), watchNotifySyncRequest.getSyncType()));
                        }
                    }
                } else if (watchNotifySyncRequest.getSyncType().equals(Constants.FINISH_FUZZY_WATCH_INIT_NOTIFY)) {
                    namingFuzzyWatchContext.markInitializationComplete();
                }
            }
            
            return new NamingFuzzyWatchChangeNotifyResponse();
            
        } else if (request instanceof NamingFuzzyWatchChangeNotifyRequest) {
            NamingFuzzyWatchChangeNotifyRequest notifyChangeRequest = (NamingFuzzyWatchChangeNotifyRequest) request;
            String[] serviceKeyItems = NamingUtils.parseServiceKey(notifyChangeRequest.getServiceKey());
            String namespace = serviceKeyItems[0];
            String groupName = serviceKeyItems[1];
            String serviceName = serviceKeyItems[2];
            
            Collection<String> matchedPattern = FuzzyGroupKeyPattern.filterMatchedPatterns(
                    namingFuzzyWatchServiceListHolder.getFuzzyMatchContextMap().keySet(), serviceName, groupName,
                    namespace);
            String serviceChangeType = notifyChangeRequest.getChangedType();
            
            switch (serviceChangeType) {
                case Constants.ServiceChangedType.ADD_SERVICE:
                case Constants.ServiceChangedType.INSTANCE_CHANGED:
                    for (String pattern : matchedPattern) {
                        NamingFuzzyWatchContext namingFuzzyWatchContext = namingFuzzyWatchServiceListHolder.getFuzzyMatchContextMap()
                                .get(pattern);
                        if (namingFuzzyWatchContext != null && namingFuzzyWatchContext.addReceivedServiceKey(
                                ((NamingFuzzyWatchChangeNotifyRequest) request).getServiceKey())) {
                            //publish local service add event
                            NotifyCenter.publishEvent(NamingFuzzyWatchNotifyEvent.build(
                                    namingFuzzyWatchServiceListHolder.getNotifierEventScope(), pattern,
                                    notifyChangeRequest.getServiceKey(), Constants.ServiceChangedType.ADD_SERVICE,
                                    FUZZY_WATCH_RESOURCE_CHANGED));
                        }
                    }
                    break;
                case Constants.ServiceChangedType.DELETE_SERVICE:
                    for (String pattern : matchedPattern) {
                        NamingFuzzyWatchContext namingFuzzyWatchContext = namingFuzzyWatchServiceListHolder.getFuzzyMatchContextMap()
                                .get(pattern);
                        if (namingFuzzyWatchContext != null && namingFuzzyWatchContext.removeReceivedServiceKey(
                                notifyChangeRequest.getServiceKey())) {
                            NotifyCenter.publishEvent(NamingFuzzyWatchNotifyEvent.build(
                                    namingFuzzyWatchServiceListHolder.getNotifierEventScope(), pattern,
                                    notifyChangeRequest.getServiceKey(), Constants.ServiceChangedType.DELETE_SERVICE,
                                    FUZZY_WATCH_RESOURCE_CHANGED));
                        }
                    }
                    break;
                default:
                    break;
            }
            return new NamingFuzzyWatchChangeNotifyResponse();
        }
        return null;
    }