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