Feature: Organizations

src/main/java/co/novu/api/organizations/OrganizationHandler.java

@@ -0,0 +1,59 @@
+package co.novu.api.organizations;
+
+import co.novu.api.organizations.requests.CreateOrganizationRequest;
+import co.novu.api.organizations.requests.UpdateMemberRoleRequest;
+import co.novu.api.organizations.requests.UpdateOrganizationBrandRequest;
+import co.novu.api.organizations.requests.UpdateOrganizationNameRequest;
+import co.novu.api.organizations.responses.FetchMembersResponse;
+import co.novu.api.organizations.responses.UpdateOrganizationBrandResponse;
+import co.novu.api.organizations.responses.MemberResponse;
+import co.novu.api.organizations.responses.OrganizationResponse;
+import co.novu.api.organizations.responses.FetchOrganizationResponse;
+import co.novu.api.organizations.responses.UpdateOrganizationNameResponse;
+import co.novu.common.base.NovuConfig;
+import co.novu.common.rest.RestHandler;
+import lombok.RequiredArgsConstructor;
+
+@RequiredArgsConstructor
+public class OrganizationHandler {
+
+    private final RestHandler restHandler;
+
+    private final NovuConfig novuConfig;
+    private static final String ENDPOINT = "organizations";
+
+
+    public OrganizationResponse createOrganization(CreateOrganizationRequest request) {
+        return restHandler.handlePost(request, OrganizationResponse.class, novuConfig, ENDPOINT);
+    }
+
+    public FetchOrganizationResponse fetchAllOrganizations() {
+        return restHandler.handleGet(FetchOrganizationResponse.class, novuConfig, ENDPOINT);
+    }
+
+    public UpdateOrganizationNameResponse updateOrganizationName(UpdateOrganizationNameRequest request) {
+        return restHandler.handlePatch(request, UpdateOrganizationNameResponse.class, novuConfig, ENDPOINT);
+    }
+
+    public OrganizationResponse fetchCurrentOrganization() {
+        return restHandler.handleGet(OrganizationResponse.class, novuConfig, ENDPOINT + "/me");
+    }
+
+    public MemberResponse removeMemberWithId(String memberId) {
+        return restHandler.handleDelete(MemberResponse.class, novuConfig, ENDPOINT + memberId);
+    }
+
+    public MemberResponse updateMemberRole(UpdateMemberRoleRequest request, String memberId) {
+        return restHandler.handlePut(request, MemberResponse.class, novuConfig, ENDPOINT + "/members/" + memberId + "/roles");
+    }
+
+    public FetchMembersResponse fetchMembersOfOrganization() {
+        return restHandler.handleGet(FetchMembersResponse.class, novuConfig, ENDPOINT + "/members");
+    }
+
+    public UpdateOrganizationBrandResponse updateOrganizationBrand(UpdateOrganizationBrandRequest request) {
+        return restHandler.handlePut(request, UpdateOrganizationBrandResponse.class, novuConfig, ENDPOINT + "/branding");
+    }
+
+
+}

src/main/java/co/novu/api/organizations/pojos/Branding.java

@@ -0,0 +1,13 @@
+package co.novu.api.organizations.pojos;
+
+import lombok.Data;
+
+@Data
+public class Branding {
+    private String direction;
+    private String logo;
+    private String color;
+    private String fontColor;
+    private String contentBackground;
+    private String fontFamily;
+}

src/main/java/co/novu/api/organizations/pojos/InviteDetails.java

@@ -0,0 +1,14 @@
+package co.novu.api.organizations.pojos;
+
+import lombok.Data;
+
+@Data
+public class InviteDetails {
+    private String email;
+    private String token;
+    private String invitationDate;
+    private String answerDate;
+    private String _inviterId;
+}
+
+

src/main/java/co/novu/api/organizations/pojos/PartnerConfigurations.java

@@ -0,0 +1,14 @@
+package co.novu.api.organizations.pojos;
+
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class PartnerConfigurations {
+    private List<String> projectIds;
+    private String accessToken;
+    private String configurationId;
+    private String teamId;
+    private String partnerType;
+}

src/main/java/co/novu/api/organizations/pojos/UserDetails.java

@@ -0,0 +1,13 @@
+package co.novu.api.organizations.pojos;
+
+import lombok.Data;
+
+@Data
+public class UserDetails {
+    private String _id;
+    private String firstName;
+    private String lastName;
+    private String email;
+}
+
+

src/main/java/co/novu/api/organizations/requests/CreateOrganizationRequest.java

@@ -0,0 +1,10 @@
+package co.novu.api.organizations.requests;
+
+import co.novu.common.contracts.IRequest;
+import lombok.Data;
+
+@Data
+public class CreateOrganizationRequest implements IRequest {
+    private String name;
+    private String logo;
+}

src/main/java/co/novu/api/organizations/requests/UpdateMemberRoleRequest.java

@@ -0,0 +1,9 @@
+package co.novu.api.organizations.requests;
+
+import co.novu.common.contracts.IRequest;
+import lombok.Data;
+
+@Data
+public class UpdateMemberRoleRequest implements IRequest {
+    private String role;
+}

src/main/java/co/novu/api/organizations/requests/UpdateOrganizationBrandRequest.java

@@ -0,0 +1,13 @@
+package co.novu.api.organizations.requests;
+
+import co.novu.common.contracts.IRequest;
+import lombok.Data;
+
+@Data
+public class UpdateOrganizationBrandRequest implements IRequest {
+    private String logo;
+    private String color;
+    private String fontColor;
+    private String contentBackground;
+    private String fontFamily;
+}

src/main/java/co/novu/api/organizations/requests/UpdateOrganizationNameRequest.java

@@ -0,0 +1,9 @@
+package co.novu.api.organizations.requests;
+
+import co.novu.common.contracts.IRequest;
+import lombok.Data;
+
+@Data
+public class UpdateOrganizationNameRequest implements IRequest {
+    private String name;
+}

src/main/java/co/novu/api/organizations/responses/FetchMembersResponse.java

@@ -0,0 +1,10 @@
+package co.novu.api.organizations.responses;
+
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class FetchMembersResponse {
+    private List<MemberResponseData> data;
+}

src/main/java/co/novu/api/organizations/responses/FetchOrganizationResponse.java

@@ -0,0 +1,10 @@
+package co.novu.api.organizations.responses;
+
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class FetchOrganizationResponse {
+    private List<OrganizationResponseData> data;
+}

src/main/java/co/novu/api/organizations/responses/MemberResponse.java

@@ -0,0 +1,8 @@
+package co.novu.api.organizations.responses;
+
+import lombok.Data;
+
+@Data
+public class MemberResponse {
+    private MemberResponseData data;
+}

src/main/java/co/novu/api/organizations/responses/MemberResponseData.java

@@ -0,0 +1,21 @@
+package co.novu.api.organizations.responses;
+
+import co.novu.api.organizations.pojos.InviteDetails;
+import co.novu.api.organizations.pojos.UserDetails;
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class MemberResponseData {
+    private String _id;
+    private String _userId;
+    private UserDetails user;
+    private List<String> roles;
+    private InviteDetails invite;
+    private String memberStatus;
+    private String _organizationId;
+
+}
+
+

src/main/java/co/novu/api/organizations/responses/OrganizationResponse.java

@@ -0,0 +1,8 @@
+package co.novu.api.organizations.responses;
+
+import lombok.Data;
+
+@Data
+public class OrganizationResponse {
+    private OrganizationResponseData data;
+}

src/main/java/co/novu/api/organizations/responses/OrganizationResponseData.java

@@ -0,0 +1,15 @@
+package co.novu.api.organizations.responses;
+
+import co.novu.api.organizations.pojos.Branding;
+import co.novu.api.organizations.pojos.PartnerConfigurations;
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class OrganizationResponseData {
+    private String name;
+    private String logo;
+    private Branding branding;
+    private List<PartnerConfigurations> partnerConfigurations;
+}

src/main/java/co/novu/api/organizations/responses/UpdateOrganizationBrandResponse.java

@@ -0,0 +1,11 @@
+package co.novu.api.organizations.responses;
+
+import co.novu.api.organizations.pojos.Branding;
+import lombok.Data;
+
+
+
+@Data
+public class UpdateOrganizationBrandResponse {
+    private Branding data;
+}

src/main/java/co/novu/api/organizations/responses/UpdateOrganizationNameResponse.java

@@ -0,0 +1,8 @@
+package co.novu.api.organizations.responses;
+
+import lombok.Data;
+
+@Data
+public class UpdateOrganizationNameResponse {
+    private UpdateOrganizationNameResponseData data;
+}

src/main/java/co/novu/api/organizations/responses/UpdateOrganizationNameResponseData.java

@@ -0,0 +1,8 @@
+package co.novu.api.organizations.responses;
+
+import lombok.Data;
+
+@Data
+public class UpdateOrganizationNameResponseData {
+    private String name;
+}

src/main/java/co/novu/common/base/Novu.java

@@ -52,6 +52,17 @@
 import co.novu.api.notifications.responses.NotificationResponse;
 import co.novu.api.notifications.responses.NotificationStatsResponse;
 import co.novu.api.notifications.responses.NotificationsResponse;
+import co.novu.api.organizations.OrganizationHandler;
+import co.novu.api.organizations.requests.CreateOrganizationRequest;
+import co.novu.api.organizations.requests.UpdateMemberRoleRequest;
+import co.novu.api.organizations.requests.UpdateOrganizationBrandRequest;
+import co.novu.api.organizations.requests.UpdateOrganizationNameRequest;
+import co.novu.api.organizations.responses.FetchMembersResponse;
+import co.novu.api.organizations.responses.UpdateOrganizationBrandResponse;
+import co.novu.api.organizations.responses.MemberResponse;
+import co.novu.api.organizations.responses.OrganizationResponse;
+import co.novu.api.organizations.responses.FetchOrganizationResponse;
+import co.novu.api.organizations.responses.UpdateOrganizationNameResponse;
 import co.novu.api.subscribers.requests.BulkSubscriberRequest;
 import co.novu.api.subscribers.requests.MarkAllMessagesRequest;
 import co.novu.api.subscribers.responses.CreateBulkSubscriberResponse;
@@ -139,6 +150,8 @@ public class Novu {
 
     private final TenantsHandler tenantsHandler;
 
+    private final OrganizationHandler organizationHandler;
+
     public Novu(String apiKey) {
         this(new NovuConfig(apiKey));
     }
@@ -161,6 +174,7 @@ public Novu(NovuConfig novuConfig) {
         this.executiveDetailsHandler = new ExecutiveDetailsHandler(restHandler, novuConfig);
         this.blueprintsHandler = new BlueprintsHandler(restHandler, novuConfig);
         this.tenantsHandler = new TenantsHandler(restHandler, novuConfig);
+        this.organizationHandler = new OrganizationHandler(restHandler, novuConfig);
     }
 
     public TriggerEventResponse triggerEvent(TriggerEventRequest request) {
@@ -883,4 +897,80 @@ public DeleteTenantResponse deleteTenant(String identifier) {
             throw e;
         }
     }
+
+    public OrganizationResponse createOrganization(CreateOrganizationRequest request) {
+        try {
+            return organizationHandler.createOrganization(request);
+        } catch (Exception e) {
+            log.error("Error creating Organization", e);
+            throw e;
+        }
+    }
+
+    public FetchOrganizationResponse fetchAllOrganizations() {
+        try {
+            return organizationHandler.fetchAllOrganizations();
+        } catch (Exception e) {
+            log.error("Error fetching Organizations", e);
+            throw e;
+        }
+    }
+
+    public UpdateOrganizationNameResponse updateOrganizationName(UpdateOrganizationNameRequest request) {
+        try {
+            return organizationHandler.updateOrganizationName(request);
+        } catch (Exception e) {
+            log.error("Error Updating Organization Name", e);
+            throw e;
+        }
+    }
+
+    public OrganizationResponse fetchCurrentOrganization() {
+        try {
+            return organizationHandler.fetchCurrentOrganization();
+        } catch (Exception e) {
+            log.error("Error Fetching Current Organization", e);
+            throw e;
+        }
+    }
+
+    public MemberResponse removeMemberWithId(String memberId) {
+        try {
+            return organizationHandler.removeMemberWithId(memberId);
+        } catch (Exception e) {
+            log.error("Error Removing Member With MemberId", e);
+            throw e;
+        }
+    }
+
+    public MemberResponse updateMemberRole(UpdateMemberRoleRequest request,String memberId) {
+        try {
+            return organizationHandler.updateMemberRole(request,memberId);
+        } catch (Exception e) {
+            log.error("Error Updating Member Role", e);
+            throw e;
+        }
+    }
+
+    public FetchMembersResponse fetchMembersOfOrganization() {
+        try {
+            return organizationHandler.fetchMembersOfOrganization();
+        } catch (Exception e) {
+            log.error("Error Fetching Organization Members", e);
+            throw e;
+        }
+    }
+
+    public UpdateOrganizationBrandResponse UpdateOrganizationBrand(UpdateOrganizationBrandRequest request) {
+        try {
+            return organizationHandler.updateOrganizationBrand(request);
+        } catch (Exception e) {
+            log.error("Error Updating Organization Brand", e);
+            throw e;
+        }
+    }
+
+
+
+
 }