1.    private Mono<ProvisioningPojo> provisionClass(List<Member> namesRoleMembers, ProvisioningPojo provisioningPojo) {
2.         return this.checkIfClassExists(provisioningPojo).flatMap(isClassPresent -> {
3.            
4.  /****  Move the code into a new private method     ****/
5.             if (isClassPresent) {
6.                 if (isTeacher(provisioningPojo, provisioningPojo.getToolUserId())) {
7.                     List<Staff> existingTeacher = provisioningPojo.getRoster().getExistingTeacherIds()
8.                         .stream()
9.                         .filter(staff -> staff.getStaffPiId().equalsIgnoreCase(provisioningPojo.getToolUserId()))
10.                         .collect(Collectors.toList());
11.                     if(existingTeacher.isEmpty()) {
12.                         // call the roster service to update Roster with teacher
13.                     }
14.                 } else if (isStudent(provisioningPojo, provisioningPojo.getToolUserId())) {
15.                     List<Student> existingStudent = provisioningPojo.getRoster().getExistingStudentIds()
16.                         .stream()
17.                         .filter(staff -> staff.getStudentPiId().equalsIgnoreCase(provisioningPojo.getToolUserId()))
18.                         .collect(Collectors.toList());
19.                     if (existingStudent.isEmpty()) {
20.                         // call the roster service to update Roster with Student
21.                     }
22.                 }
23.                
24.                 // update product
25.                 List<Product> existingProduct = provisioningPojo.getRoster().getExistingProductIds()
26.                     .stream()
27.                     .filter(products -> products.getProductId().equalsIgnoreCase(provisioningPojo.getProductId()))
28.                     .collect(Collectors.toList());
29.                 if (existingProduct.isEmpty()) {
30.                     // call the roster service to update Roster with Product
31.                 }
32.                    
33.                 return Mono.just(provisioningPojo);
34.             } else {
35.                 return processMembersFromNamesRolesResponse(namesRoleMembers, provisioningPojo)
36.                         .flatMap(this::createClassAndMapping);
37.             }
38.         });
39.     }
40.  
41.     private Mono<Boolean> checkIfClassExists(ProvisioningPojo provisioningPojo) {
42.         return emsClassMappingClient.classExistsForExternalClassId(provisioningPojo.getRoster().getExternalClassId())
43.             .flatMap(externalClassMappingData -> {
44.                 Optional<String> optionalClassId = Optional.ofNullable(externalClassMappingData)
45.                     .map(ExternalClassMappingData::getData)
46.                     .map(map -> map.entrySet().stream())
47.                     .map(Stream::findFirst)
48.                     .map(Optional::get)
49.                     .map(Entry::getValue)
50.                     .map(ExternalClassMapping::getClassId);
51.  
52.                 if (optionalClassId.isPresent()) {
53.                     return rosterServiceClient.getClassBySectionId(optionalClassId.get())
54.                         .flatMap(cmsClass -> {
55.                             Optional<String> cmsClassId = Optional.ofNullable(cmsClass)
56.                                 .map(CMSClass::getData)
57.                                 .map(ClassData::getSection)
58.                                 .map(Section::getId);
59.                             /****  update ProvisioningPojo Pojo     ****/
60.                             if (cmsClassId.isPresent()) {
61.                                 provisioningPojo.getRoster().setToolSectionId(cmsClassId.get());
62.                                 provisioningPojo.getRoster()
63.                                         .setExistingTeacherIds(cmsClass.getData().getSection().getData().getSectionInfo().getStaff());
64.                                 provisioningPojo.getRoster()
65.                                         .setExistingStudentIds(cmsClass.getData().getSection().getData().getSectionInfo().getStudents());
66.                                 provisioningPojo.getRoster()
67.                                         .setExistingProductIds(cmsClass.getData().getSection().getData().getSectionProductsAssociationList());
68.                                
69.                                 if (isStudent(provisioningPojo, provisioningPojo.getToolUserId()) && provisioningPojo.getRoster().getExistingTeacherIds().isEmpty()) {
70.                                     provisioningPojo.setUpdateStaffIfStudent(true);
71.                                 }
72.                                
73.                                 return Mono.just(Boolean.TRUE);
74.                             }
75.                             return Mono.just(Boolean.FALSE);
76.                         });
77.                 }
78.                 return Mono.just(Boolean.FALSE);
79.  
80.             });
81.     }
82.  
83.     private Mono<ProvisioningPojo> processMembersFromNamesRolesResponse(List<Member> namesRoleMembers, ProvisioningPojo provisioningPojo) {
84.         LOGGER.debug("provisioning additional Teacher users from names and roles API ");
85.  
86.         Optional<Member> instructor = namesRoleMembers.stream()
87.                 .filter(member -> RumbaRole.T.name()
88.                         .equalsIgnoreCase(classProvisoningHelper.obtainRumbaRoleFromLTIRoles(member.getRoles())))
89.                 .findFirst();
90.  
91.         /****  If student user then check if staff present in cms class if not then add the staff to Staff Roster     ****/
92.         if(provisioningPojo.getRole().equals(RumbaRole.S.name()) && instructor.isPresent()) {
93.             if (provisioningPojo.updateStaffIfStudent) {
94.                 // call Roster service to update the Staff
95.             }
96.             MemberData memberData = constructMemberData(instructor.get(), provisioningPojo);
97.             return provisioningService.enableUserProvisioning(memberData)
98.                     .map(rumbaTeacherId -> {
99.                         RosterMember rosterMember = new RosterMember();
100.                         rosterMember.setUserId(instructor.get().getUserId());
101.                         rosterMember.setRole(memberData.getRole());
102.                         rosterMember.setExternalUserId(memberData.getExternalUserId());
103.                         rosterMember.setToolUserId(rumbaTeacherId);
104.                         provisioningPojo.getMembers().add(rosterMember);
105.                         LOGGER.debug("provisioningPojo : {}", provisioningPojo);
106.                         return provisioningPojo;
107.                     });
108.         }
109.         return Mono.just(provisioningPojo);
110.     }
111.  
112.