add push notification

pom.xml

@@ -35,6 +35,12 @@
             <artifactId>spring-boot-starter-data-redis</artifactId>
         </dependency>
 
+        <dependency>
+            <groupId>com.google.firebase</groupId>
+            <artifactId>firebase-admin</artifactId>
+            <version>9.2.0</version>
+        </dependency>
+
         <dependency>
             <groupId>redis.clients</groupId>
             <artifactId>jedis</artifactId>

src/main/java/com/utility/utilitycommonservice/UtilityCommonServiceApplication.java

@@ -1,9 +1,7 @@
 package com.utility.utilitycommonservice;
 
-import com.utility.utilitycommonservice.common.properties.BitbucketProperties;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.boot.context.properties.EnableConfigurationProperties;
 import org.springframework.cloud.openfeign.EnableFeignClients;
 
 @SpringBootApplication

src/main/java/com/utility/utilitycommonservice/api/controller/bitbucket/BitbucketController.java

@@ -7,7 +7,7 @@ import com.utility.utilitycommonservice.common.base.controller.BaseController;
 import com.utility.utilitycommonservice.common.base.response.MessageResponse;
 import com.utility.utilitycommonservice.domain.model.bitbucket.input.UploadFileInput;
 import com.utility.utilitycommonservice.domain.service.bitbucket.BitbucketService;
-import com.utility.utilitycommonservice.integration.service.model.response.CreateBranchClientResponse;
+import com.utility.utilitycommonservice.integration.service.model.response.bitbucket.CreateBranchClientResponse;
 import lombok.RequiredArgsConstructor;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.multipart.MultipartFile;

src/main/java/com/utility/utilitycommonservice/api/controller/localize/LocalizeController.java

@@ -1,5 +1,6 @@
 package com.utility.utilitycommonservice.api.controller.localize;
 
+import com.utility.utilitycommonservice.api.model.request.AddLocalizeRequest;
 import com.utility.utilitycommonservice.api.model.request.RequestByKey;
 import com.utility.utilitycommonservice.api.model.response.ResponseByKey;
 import com.utility.utilitycommonservice.common.base.controller.BaseController;
@@ -11,6 +12,8 @@ import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.io.IOException;
+
 @RestController
 @RequiredArgsConstructor
 @RequestMapping("/api/v1/localize")
@@ -24,4 +27,10 @@ public class LocalizeController extends BaseController {
         return responseSuccess(output.toResponse());
     }
 
+    @PostMapping("/addLocalize")
+    public MessageResponse<Void> addLocalize(@RequestBody AddLocalizeRequest request) throws IOException {
+       localizeService.addLocalize(request.toInput());
+       return responseSuccess();
+    }
+
 }

src/main/java/com/utility/utilitycommonservice/api/controller/notification/PushController.java

@@ -0,0 +1,34 @@
+package com.utility.utilitycommonservice.api.controller.notification;
+
+import com.utility.utilitycommonservice.api.model.request.CrudNotificationRequest;
+import com.utility.utilitycommonservice.api.model.request.PushNotificationByDomainRequest;
+import com.utility.utilitycommonservice.api.model.response.CrudNotificationResponse;
+import com.utility.utilitycommonservice.common.base.controller.BaseController;
+import com.utility.utilitycommonservice.common.base.response.MessageResponse;
+import com.utility.utilitycommonservice.domain.service.clientbe.notification.PushService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequiredArgsConstructor
+@RequestMapping("/api/v1/notification")
+public class PushController extends BaseController {
+
+    private final PushService pushService;
+
+    @PostMapping("/pushByDomain")
+    public MessageResponse<Void> pushNotificationByDomain(@RequestBody PushNotificationByDomainRequest request) {
+        pushService.pushNotificationByDomain(request.toInput());
+        return responseSuccess();
+    }
+
+    @PostMapping("/crudNotification")
+    public MessageResponse<CrudNotificationResponse> crudNotification(@RequestBody CrudNotificationRequest request) {
+        var output = pushService.crudNotification(request.toInput());
+        return responseSuccess(output.toResponse());
+    }
+
+}

src/main/java/com/utility/utilitycommonservice/{domain/model/localize → api/model}/KeyValueParameter.java

@@ -1,4 +1,4 @@
-package com.utility.utilitycommonservice.domain.model.localize;
+package com.utility.utilitycommonservice.api.model;
 
 import lombok.AllArgsConstructor;
 import lombok.Builder;

src/main/java/com/utility/utilitycommonservice/api/model/request/AddLocalizeRequest.java

@@ -0,0 +1,22 @@
+package com.utility.utilitycommonservice.api.model.request;
+
+import com.utility.utilitycommonservice.domain.model.localize.input.AddLocalizeInput;
+import lombok.Builder;
+import lombok.Data;
+
+@Data
+@Builder
+public class AddLocalizeRequest {
+    private String language;
+    private String key;
+    private String value;
+
+    public AddLocalizeInput toInput() {
+        return AddLocalizeInput.builder()
+                .language(language)
+                .key(key)
+                .value(value)
+                .build();
+    }
+
+}

src/main/java/com/utility/utilitycommonservice/api/model/request/CrudNotificationRequest.java

@@ -0,0 +1,22 @@
+package com.utility.utilitycommonservice.api.model.request;
+
+import com.utility.utilitycommonservice.domain.model.notification.enums.CrudType;
+import com.utility.utilitycommonservice.domain.model.notification.input.CrudNotificationInput;
+import lombok.Builder;
+import lombok.Data;
+
+@Data
+@Builder
+public class CrudNotificationRequest {
+
+    private CrudType crudType;
+    private String uid;
+
+    public CrudNotificationInput toInput() {
+        return CrudNotificationInput.builder()
+                .crudType(crudType)
+                .uid(uid)
+                .build();
+    }
+
+}

src/main/java/com/utility/utilitycommonservice/api/model/request/PushNotificationByDomainRequest.java

@@ -0,0 +1,21 @@
+package com.utility.utilitycommonservice.api.model.request;
+
+import com.utility.utilitycommonservice.domain.model.notification.InfoModel;
+import com.utility.utilitycommonservice.domain.model.notification.input.PushNotificationByDomainInput;
+import lombok.Builder;
+import lombok.Data;
+
+@Data
+@Builder
+public class PushNotificationByDomainRequest {
+    private InfoModel infoModel;
+    private String domainCode;
+
+    public PushNotificationByDomainInput toInput() {
+        return PushNotificationByDomainInput.builder()
+                .infoModel(infoModel)
+                .domainCode(domainCode)
+                .build();
+    }
+
+}

src/main/java/com/utility/utilitycommonservice/api/model/response/CrudNotificationResponse.java

@@ -0,0 +1,15 @@
+package com.utility.utilitycommonservice.api.model.response;
+
+import com.utility.utilitycommonservice.domain.model.notification.Notification;
+import lombok.Builder;
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+@Builder
+public class CrudNotificationResponse {
+
+    private List<Notification> notifications;
+
+}

src/main/java/com/utility/utilitycommonservice/api/model/response/MenuResponse.java

@@ -1,5 +1,6 @@
 package com.utility.utilitycommonservice.api.model.response;
 
+import com.utility.utilitycommonservice.api.model.KeyValueParameter;
 import com.utility.utilitycommonservice.domain.model.clientbe.MenuModel;
 import lombok.Builder;
 import lombok.Data;
@@ -9,5 +10,5 @@ import java.util.List;
 @Data
 @Builder
 public class MenuResponse {
-    private List<MenuModel> menuList;
+    private List<KeyValueParameter<String,Integer>> menuList;
 }

src/main/java/com/utility/utilitycommonservice/common/base/controller/BaseController.java

@@ -22,4 +22,8 @@ public abstract class BaseController {
         return MsgResponseBuilder.build(true,messageBox,data);
     }
 
+    protected MessageResponse<Void> responseSuccess() {
+        return MsgResponseBuilder.build(true);
+    }
+
 }

src/main/java/com/utility/utilitycommonservice/common/base/response/MessageResponse.java

@@ -39,4 +39,9 @@ public class MessageResponse<T> {
         this.executionDate = ZonedDateTime.now().format(DateTimeFormatter.ISO_LOCAL_DATE);
     }
 
+    public MessageResponse(boolean success){
+        this.success = success;
+        this.executionDate = ZonedDateTime.now().format(DateTimeFormatter.ISO_LOCAL_DATE);
+    }
+
 }

src/main/java/com/utility/utilitycommonservice/common/base/response/builder/MsgResponseBuilder.java

@@ -25,4 +25,8 @@ public class MsgResponseBuilder {
         return new MessageResponse<>(success,data,messageBox);
     }
 
+    public static <T>MessageResponse<T> build(boolean success) {
+        return new MessageResponse<>(success);
+    }
+
 }

src/main/java/com/utility/utilitycommonservice/common/interceptor/ResponseErrorHandler.java

@@ -13,12 +13,11 @@ import org.springframework.web.bind.annotation.ExceptionHandler;
 import org.springframework.web.bind.annotation.ResponseStatus;
 import org.springframework.web.bind.annotation.RestControllerAdvice;
 import org.springframework.web.client.HttpClientErrorException;
-import org.springframework.web.method.HandlerMethod;
 
 import java.util.ArrayList;
 import java.util.List;
 
-import static com.utility.utilitycommonservice.common.constant.BitbucketServiceConstant.*;
+import static com.utility.utilitycommonservice.domain.constant.BitbucketServiceConstant.*;
 
 @RestControllerAdvice
 @RequiredArgsConstructor

src/main/java/com/utility/utilitycommonservice/common/redis/RedisUtil.java

@@ -21,6 +21,10 @@ public class RedisUtil {
         valueOperations.set(key,value,expirationTime,expirationTimeUnit);
     }
 
+    public void putValue(String key, Object value) {
+        valueOperations.set(key,value);
+    }
+
     public Object getValue(String key) {
         return valueOperations.get(key);
     }

src/main/java/com/utility/utilitycommonservice/common/service/SessionService.java

@@ -6,6 +6,8 @@ public interface SessionService {
 
     <T> T getSession(String sessionKey, Class<T> returnType, boolean... isNullable);
 
+    <T> void setSession(String sessionKey, T object);
+
     void removeSession(String sessionKey);
 
 }

src/main/java/com/utility/utilitycommonservice/common/service/impl/SessionServiceImpl.java

@@ -33,6 +33,12 @@ public class SessionServiceImpl implements SessionService {
         redisUtil.putValue(key,object,Integer.parseInt(expireTime), TimeUnit.MINUTES);
     }
 
+    @Override
+    public <T> void setSession(String sessionKey, T object) {
+        String key = StringUtils.isEmpty(sessionKey) ? requestHeaderScope.getRequestHeader().getSessionId() : sessionKey;
+        redisUtil.putValue(key,object);
+    }
+
     @Override
     public <T> T getSession(String sessionKey, Class<T> returnType, boolean... isNullable) {
         Object sessionObject = null;

src/main/java/com/utility/utilitycommonservice/common/util/BitbucketBasicAuthGenerator.java

@@ -1,6 +1,6 @@
 package com.utility.utilitycommonservice.common.util;
 
-import com.utility.utilitycommonservice.common.properties.BitbucketProperties;
+import com.utility.utilitycommonservice.domain.properties.BitbucketProperties;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Component;
 

src/main/java/com/utility/utilitycommonservice/dao/entity/PushNotificationLog.java

@@ -0,0 +1,51 @@
+package com.utility.utilitycommonservice.dao.entity;
+
+import com.utility.utilitycommonservice.domain.model.notification.Notification;
+import com.utility.utilitycommonservice.domain.model.notification.attributes.LogTypeAttribute;
+import com.utility.utilitycommonservice.domain.model.notification.enums.LogType;
+import jakarta.persistence.Column;
+import jakarta.persistence.Convert;
+import jakarta.persistence.Entity;
+import jakarta.persistence.Id;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.time.LocalDate;
+import java.util.ArrayList;
+import java.util.List;
+
+@AllArgsConstructor
+@NoArgsConstructor
+@Data
+@Entity
+@Builder
+public class PushNotificationLog {
+
+    @Id
+    private String uid;
+    private String messageId;
+    private String customerNumber;
+    private String domainCode;
+    private Boolean isRead; // false - okunmadı, true - okundu
+    private Boolean isRemove; // false - sininmedi, true - silindi
+    private LocalDate createDate;
+
+    @Column(name = "text", columnDefinition = "text")
+    private String text;
+
+    @Convert(converter = LogTypeAttribute.class)
+    private LogType logType;
+
+    public static List<Notification> toNotificationList(List<PushNotificationLog> pushNotificationLogs) {
+        List<Notification> notifications = new ArrayList<>();
+
+        pushNotificationLogs.forEach(pushNotificationLog -> {
+            Notification notification = Notification.toNotification(pushNotificationLog);
+            notifications.add(notification);
+        });
+        return notifications;
+    }
+
+}

src/main/java/com/utility/utilitycommonservice/dao/repository/PushNotificationLogRepository.java

@@ -0,0 +1,18 @@
+package com.utility.utilitycommonservice.dao.repository;
+
+import com.utility.utilitycommonservice.dao.entity.PushNotificationLog;
+import com.utility.utilitycommonservice.domain.model.notification.enums.LogType;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+import java.time.LocalDate;
+import java.util.List;
+import java.util.Optional;
+
+@Repository
+public interface PushNotificationLogRepository extends JpaRepository<PushNotificationLog, String> {
+    List<PushNotificationLog> findAllByCustomerNumberEqualsIgnoreCaseAndLogTypeAndIsRemoveIsFalseAndCreateDateBetween(String customerNumber,
+                                                                                                                                     LogType logType, LocalDate startDate,
+                                                                                                                                     LocalDate endDate);
+    Optional<PushNotificationLog> findAllByUidAndIsRemoveIsFalse(String uuid);
+}

src/main/java/com/utility/utilitycommonservice/domain/assembler/CrudAssembler.java

@@ -0,0 +1,69 @@
+package com.utility.utilitycommonservice.domain.assembler;
+
+import com.utility.utilitycommonservice.common.helper.RequestScopeHelper;
+import com.utility.utilitycommonservice.dao.entity.PushNotificationLog;
+import com.utility.utilitycommonservice.dao.repository.PushNotificationLogRepository;
+import com.utility.utilitycommonservice.domain.model.notification.Notification;
+import com.utility.utilitycommonservice.domain.model.notification.enums.CrudType;
+import com.utility.utilitycommonservice.domain.model.notification.enums.LogType;
+import com.utility.utilitycommonservice.domain.model.notification.input.CrudNotificationInput;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+
+import java.time.LocalDate;
+import java.util.List;
+import java.util.Objects;
+import java.util.Optional;
+
+@Component
+@RequiredArgsConstructor
+public class CrudAssembler {
+
+    private final PushNotificationLogRepository pushNotificationLogRepository;
+
+    public List<Notification> assemble(CrudNotificationInput input) {
+        if (Objects.requireNonNull(input.getCrudType()) == CrudType.LIST) {
+            return getNotifications();
+        } else if (Objects.requireNonNull(input.getCrudType()) == CrudType.READ) {
+            updateReadStatus(input.getUid());
+        } else if (Objects.requireNonNull(input.getCrudType()) == CrudType.REMOVE) {
+            updateRemoveStatus(input.getUid());
+        }
+        return List.of();
+    }
+
+    private void updateReadStatus(String uid) {
+
+        Optional<PushNotificationLog> optPushNotificationLog = pushNotificationLogRepository.findAllByUidAndIsRemoveIsFalse(uid);
+        if (optPushNotificationLog.isPresent()) {
+            PushNotificationLog pushNotificationLog = optPushNotificationLog.get();
+            if (Boolean.FALSE.equals(pushNotificationLog.getIsRead())) {
+                pushNotificationLog.setIsRead(Boolean.TRUE);
+            } else {
+                pushNotificationLog.setIsRead(Boolean.FALSE);
+            }
+            pushNotificationLogRepository.saveAndFlush(pushNotificationLog);
+        }
+    }
+
+    private void updateRemoveStatus(String uid) {
+        Optional<PushNotificationLog> optPushNotificationLog = pushNotificationLogRepository.findAllByUidAndIsRemoveIsFalse(uid);
+        if (optPushNotificationLog.isPresent()) {
+            PushNotificationLog pushNotificationLog = optPushNotificationLog.get();
+            pushNotificationLog.setIsRemove(Boolean.TRUE);
+            pushNotificationLogRepository.saveAndFlush(pushNotificationLog);
+        }
+    }
+
+    private List<Notification> getNotifications() {
+
+        List<PushNotificationLog> pushNotificationLogs = pushNotificationLogRepository.findAllByCustomerNumberEqualsIgnoreCaseAndLogTypeAndIsRemoveIsFalseAndCreateDateBetween(
+                RequestScopeHelper.getCustomerNumber(),
+                LogType.INFO,
+                LocalDate.now().minusMonths(2),
+                LocalDate.now());
+
+        return PushNotificationLog.toNotificationList(pushNotificationLogs);
+    }
+
+}

src/main/java/com/utility/utilitycommonservice/{common → domain}/constant/BitbucketServiceConstant.java

@@ -1,4 +1,4 @@
-package com.utility.utilitycommonservice.common.constant;
+package com.utility.utilitycommonservice.domain.constant;
 
 public class BitbucketServiceConstant {
 

src/main/java/com/utility/utilitycommonservice/{common → domain}/constant/LocalizeConstant.java

@@ -1,4 +1,4 @@
-package com.utility.utilitycommonservice.common.constant;
+package com.utility.utilitycommonservice.domain.constant;
 
 
 public class LocalizeConstant {

src/main/java/com/utility/utilitycommonservice/domain/model/bitbucket/output/CreateBranchOutput.java

@@ -1,7 +1,7 @@
 package com.utility.utilitycommonservice.domain.model.bitbucket.output;
 
 import com.utility.utilitycommonservice.integration.service.model.Target;
-import com.utility.utilitycommonservice.integration.service.model.response.CreateBranchClientResponse;
+import com.utility.utilitycommonservice.integration.service.model.response.bitbucket.CreateBranchClientResponse;
 import lombok.Builder;
 import lombok.Data;
 

src/main/java/com/utility/utilitycommonservice/domain/model/clientbe/output/MenuOutput.java

@@ -1,5 +1,6 @@
 package com.utility.utilitycommonservice.domain.model.clientbe.output;
 
+import com.utility.utilitycommonservice.api.model.KeyValueParameter;
 import com.utility.utilitycommonservice.api.model.response.MenuResponse;
 import com.utility.utilitycommonservice.dao.entity.Menu;
 import com.utility.utilitycommonservice.domain.model.clientbe.MenuModel;
@@ -17,7 +18,7 @@ import java.util.List;
 @NoArgsConstructor
 public class MenuOutput {
 
-    private List<MenuModel> menuList;
+    private List<KeyValueParameter<String,Integer>> menuList;
 
     public MenuResponse toResponse() {
         return MenuResponse.builder()
@@ -27,11 +28,11 @@ public class MenuOutput {
 
     public static MenuOutput toOutput(List<Menu> menuList) {
 
-        List<MenuModel> menuModels = new ArrayList<>();
+        List<KeyValueParameter<String,Integer>> menuModels = new ArrayList<>();
         menuList.forEach(menu -> {
-            MenuModel menuModel = MenuModel.builder()
-                    .name(menu.getName())
-                    .navigationCode(menu.getNavigationCode())
+            KeyValueParameter<String,Integer> menuModel = KeyValueParameter.<String,Integer>builder()
+                    .key(menu.getName())
+                    .value(menu.getNavigationCode())
                     .build();
             menuModels.add(menuModel);
         });

src/main/java/com/utility/utilitycommonservice/domain/model/localize/LocalizeInitModel.java

@@ -1,5 +1,6 @@
 package com.utility.utilitycommonservice.domain.model.localize;
 
+import com.utility.utilitycommonservice.api.model.KeyValueParameter;
 import com.utility.utilitycommonservice.common.base.model.BaseModel;
 import lombok.Builder;
 import lombok.Data;

src/main/java/com/utility/utilitycommonservice/domain/model/notification/Deeplink.java

@@ -0,0 +1,17 @@
+package com.utility.utilitycommonservice.domain.model.notification;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.List;
+
+@Data
+@Builder
+@AllArgsConstructor
+@NoArgsConstructor
+public class Deeplink {
+    private List<String> parameters; // ilerde parametre gerekirse
+    private String navigationCode; // code için (web ve mobile ortak çalışacak)
+}

src/main/java/com/utility/utilitycommonservice/domain/model/notification/InfoModel.java

@@ -0,0 +1,18 @@
+package com.utility.utilitycommonservice.domain.model.notification;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@Builder
+@AllArgsConstructor
+@NoArgsConstructor
+public class InfoModel {
+
+    private String title;
+    private String text;
+    private String imageUrl;
+    private Deeplink deeplink;
+}

src/main/java/com/utility/utilitycommonservice/domain/model/notification/Notification.java

@@ -0,0 +1,50 @@
+package com.utility.utilitycommonservice.domain.model.notification;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.utility.utilitycommonservice.dao.entity.PushNotificationLog;
+import lombok.Builder;
+import lombok.Data;
+import lombok.extern.slf4j.Slf4j;
+
+import java.util.Objects;
+
+@Data
+@Builder
+@Slf4j
+public class Notification {
+
+    private String uid;
+    private String title;
+    private String body;
+    private String imageUrl;
+    private String url;
+    private String topic;
+    private Boolean isRead;
+
+    public static Notification toNotification(PushNotificationLog pushNotificationLog) {
+        ObjectMapper mapper = new ObjectMapper();
+        InfoModel infoModel = null;
+
+        try {
+            infoModel = mapper.readValue(pushNotificationLog.getText(), InfoModel.class);
+        } catch (JsonProcessingException e) {
+            log.error("a process error occurrence: {}", e.getMessage());
+        }
+
+        if (!Objects.isNull(infoModel)) {
+            return Notification.builder()
+                    .uid(pushNotificationLog.getUid())
+                    .title(infoModel.getTitle())
+                    .body(infoModel.getText())
+                    .imageUrl(infoModel.getImageUrl())
+                    .url(infoModel.getDeeplink().getNavigationCode())
+                    .topic(pushNotificationLog.getDomainCode())
+                    .isRead(pushNotificationLog.getIsRead())
+                    .build();
+        }
+        return Notification.builder()
+                .build();
+    }
+
+}

src/main/java/com/utility/utilitycommonservice/domain/model/notification/PushNotificationBody.java

@@ -0,0 +1,16 @@
+package com.utility.utilitycommonservice.domain.model.notification;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@Builder
+@AllArgsConstructor
+@NoArgsConstructor
+public class PushNotificationBody {
+    private String text;
+    private Boolean isRead;
+
+}

src/main/java/com/utility/utilitycommonservice/domain/model/notification/attributes/LogTypeAttribute.java

@@ -0,0 +1,19 @@
+package com.utility.utilitycommonservice.domain.model.notification.attributes;
+
+import com.utility.utilitycommonservice.domain.model.notification.enums.LogType;
+import jakarta.persistence.AttributeConverter;
+import jakarta.persistence.Converter;
+
+@Converter(autoApply = true)
+public class LogTypeAttribute implements AttributeConverter<LogType,String> {
+
+    @Override
+    public String convertToDatabaseColumn(LogType logType) {
+        return LogType.fromCode(logType);
+    }
+
+    @Override
+    public LogType convertToEntityAttribute(String s) {
+        return LogType.fromType(s);
+    }
+}

src/main/java/com/utility/utilitycommonservice/domain/model/notification/enums/CrudType.java

@@ -0,0 +1,5 @@
+package com.utility.utilitycommonservice.domain.model.notification.enums;
+
+public enum CrudType {
+    READ,REMOVE,LIST
+}

src/main/java/com/utility/utilitycommonservice/domain/model/notification/enums/LogType.java

@@ -0,0 +1,34 @@
+package com.utility.utilitycommonservice.domain.model.notification.enums;
+
+public enum LogType {
+    INFO,ERROR,NONE;
+
+    public static String fromCode(LogType logType) {
+        switch (logType) {
+            case INFO -> {
+                return "Info";
+            }
+            case ERROR -> {
+                return "Error";
+            }
+            default -> {
+                return "";
+            }
+        }
+    }
+
+    public static LogType fromType(String logType) {
+        switch (logType) {
+            case "Info" -> {
+                return INFO;
+            }
+            case "Error" -> {
+                return ERROR;
+            }
+            default -> {
+                return NONE;
+            }
+        }
+    }
+
+}

src/main/java/com/utility/utilitycommonservice/domain/model/notification/input/CrudNotificationInput.java

@@ -0,0 +1,14 @@
+package com.utility.utilitycommonservice.domain.model.notification.input;
+
+import com.utility.utilitycommonservice.domain.model.notification.enums.CrudType;
+import lombok.Builder;
+import lombok.Data;
+
+@Data
+@Builder
+public class CrudNotificationInput {
+
+    private CrudType crudType;
+    private String uid;
+
+}

src/main/java/com/utility/utilitycommonservice/domain/model/notification/input/PushNotificationByDomainInput.java

@@ -0,0 +1,13 @@
+package com.utility.utilitycommonservice.domain.model.notification.input;
+
+import com.utility.utilitycommonservice.domain.model.notification.InfoModel;
+import lombok.Builder;
+import lombok.Data;
+
+@Data
+@Builder
+public class PushNotificationByDomainInput {
+    private InfoModel infoModel;
+    private String domainCode; // campaign, ai vs.
+
+}

src/main/java/com/utility/utilitycommonservice/domain/model/notification/output/CrudNotificationOutput.java

@@ -0,0 +1,22 @@
+package com.utility.utilitycommonservice.domain.model.notification.output;
+
+import com.utility.utilitycommonservice.api.model.response.CrudNotificationResponse;
+import com.utility.utilitycommonservice.domain.model.notification.Notification;
+import lombok.Builder;
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+@Builder
+public class CrudNotificationOutput {
+
+   private List<Notification> notifications;
+
+   public CrudNotificationResponse toResponse() {
+      return CrudNotificationResponse.builder()
+              .notifications(notifications)
+              .build();
+   }
+
+}

src/main/java/com/utility/utilitycommonservice/{common → domain}/properties/BitbucketProperties.java

@@ -1,4 +1,4 @@
-package com.utility.utilitycommonservice.common.properties;
+package com.utility.utilitycommonservice.domain.properties;
 
 import lombok.Data;
 import org.springframework.boot.context.properties.ConfigurationProperties;

src/main/java/com/utility/utilitycommonservice/domain/service/clientbe/notification/PushService.java

@@ -0,0 +1,14 @@
+package com.utility.utilitycommonservice.domain.service.clientbe.notification;
+
+import com.utility.utilitycommonservice.domain.model.notification.input.CrudNotificationInput;
+import com.utility.utilitycommonservice.domain.model.notification.input.PushNotificationByDomainInput;
+import com.utility.utilitycommonservice.domain.model.notification.output.CrudNotificationOutput;
+
+public interface PushService {
+    void pushNotificationByDomain(PushNotificationByDomainInput input);
+
+    // okundu-silindi-listele
+    CrudNotificationOutput crudNotification(CrudNotificationInput input);
+
+
+}

src/main/java/com/utility/utilitycommonservice/domain/service/clientbe/notification/notificationImpl/PushServiceImpl.java

@@ -0,0 +1,89 @@
+package com.utility.utilitycommonservice.domain.service.clientbe.notification.notificationImpl;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.utility.utilitycommonservice.common.helper.RequestScopeHelper;
+import com.utility.utilitycommonservice.dao.entity.PushNotificationLog;
+import com.utility.utilitycommonservice.dao.repository.PushNotificationLogRepository;
+import com.utility.utilitycommonservice.domain.assembler.CrudAssembler;
+import com.utility.utilitycommonservice.domain.model.notification.PushNotificationBody;
+import com.utility.utilitycommonservice.domain.model.notification.enums.LogType;
+import com.utility.utilitycommonservice.domain.model.notification.input.CrudNotificationInput;
+import com.utility.utilitycommonservice.domain.model.notification.input.PushNotificationByDomainInput;
+import com.utility.utilitycommonservice.domain.model.notification.output.CrudNotificationOutput;
+import com.utility.utilitycommonservice.domain.service.clientbe.notification.PushService;
+import com.utility.utilitycommonservice.integration.service.model.request.firebase.SendToTopicClientRequest;
+import com.utility.utilitycommonservice.integration.service.service.firebase.PushClientService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+import java.time.LocalDate;
+import java.util.UUID;
+
+@Service
+@RequiredArgsConstructor
+@Slf4j
+public class PushServiceImpl implements PushService {
+
+    private final PushClientService clientService;
+    private final PushNotificationLogRepository pushNotificationLogRepository;
+    private final CrudAssembler crudAssembler;
+    private final ObjectMapper mapper = new ObjectMapper();
+
+    @Override
+    public void pushNotificationByDomain(PushNotificationByDomainInput input) {
+
+        try {
+            var pnBody = PushNotificationBody.builder()
+                    .text(input.getInfoModel().getText())
+                    .isRead(false)
+                    .build();
+            String jsonBody = mapper.writeValueAsString(pnBody);
+            var clientResponse = clientService.sendToTopic(SendToTopicClientRequest.builder()
+                    .title(input.getInfoModel().getTitle())
+                    .body(jsonBody)
+                    .imageUrl(input.getInfoModel().getImageUrl())
+                    .url(input.getInfoModel().getDeeplink().getNavigationCode())
+                    .topic(input.getDomainCode())
+                    .build());
+            saveLog(input, LogType.INFO, clientResponse.getMessageId());
+
+        } catch (Exception e) {
+            log.error("An error occurrence: {}", e.getMessage());
+            saveLog(input, LogType.ERROR, null);
+        }
+
+    }
+
+    @Override
+    public CrudNotificationOutput crudNotification(CrudNotificationInput input) {
+        var notifications = crudAssembler.assemble(input);
+        return CrudNotificationOutput.builder()
+                .notifications(notifications)
+                .build();
+    }
+
+    private void saveLog(PushNotificationByDomainInput input, LogType logType, String messageId) {
+
+        try {
+            String jsonBody = mapper.writeValueAsString(input.getInfoModel());
+            PushNotificationLog pushNotificationLog = PushNotificationLog.builder()
+                    .uid(UUID.randomUUID().toString())
+                    .messageId(messageId)
+                    .logType(logType)
+                    .text(jsonBody)
+                    .domainCode(input.getDomainCode())
+                    .isRead(false)
+                    .isRemove(false)
+                    .customerNumber(RequestScopeHelper.getCustomerNumber())
+                    .createDate(LocalDate.now())
+                    .build();
+            pushNotificationLogRepository.save(pushNotificationLog);
+
+        }catch (JsonProcessingException e) {
+            log.error("a process error occurrence: {}", e.getMessage());
+        }
+    }
+
+}

src/main/java/com/utility/utilitycommonservice/domain/service/localize/impl/LocalizeServiceImpl.java

@@ -2,7 +2,7 @@ package com.utility.utilitycommonservice.domain.service.localize.impl;
 
 import com.utility.utilitycommonservice.common.helper.RequestScopeHelper;
 import com.utility.utilitycommonservice.common.service.SessionService;
-import com.utility.utilitycommonservice.domain.model.localize.KeyValueParameter;
+import com.utility.utilitycommonservice.api.model.KeyValueParameter;
 import com.utility.utilitycommonservice.domain.model.localize.LocalizeInitModel;
 import com.utility.utilitycommonservice.domain.model.localize.LocalizeInitSession;
 import com.utility.utilitycommonservice.domain.model.localize.input.AddLocalizeInput;
@@ -14,13 +14,11 @@ import lombok.RequiredArgsConstructor;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 
-import java.io.FileInputStream;
-import java.io.IOException;
-import java.io.InputStreamReader;
+import java.io.*;
 import java.nio.charset.StandardCharsets;
 import java.util.*;
 
-import static com.utility.utilitycommonservice.common.constant.LocalizeConstant.LOCALIZE_INIT_SESSION;
+import static com.utility.utilitycommonservice.domain.constant.LocalizeConstant.LOCALIZE_INIT_SESSION;
 
 @Service
 @RequiredArgsConstructor
@@ -61,7 +59,7 @@ public class LocalizeServiceImpl implements LocalizeService {
                         .tr(tr).en(en).build())
                 .build();
 
-        sessionService.setSession(LOCALIZE_INIT_SESSION, "1000", session); //todo: expire olmamamlı
+        sessionService.setSession(LOCALIZE_INIT_SESSION, session);
 
     }
 
@@ -77,19 +75,11 @@ public class LocalizeServiceImpl implements LocalizeService {
 
         if (RequestScopeHelper.getLanguage().equals("tr")) {
             List<KeyValueParameter<String,String>> parameters = initModel.getTr();
-            Optional<KeyValueParameter<String,String>> optional = parameters.stream()
-                    .filter(p -> p.getKey().equals(input.getKey())).findFirst();
-            if (optional.isPresent()) {
-                keyValueParameter = optional.get();
-            }
+            keyValueParameter = getKeyValueParameter(parameters, input.getKey());
 
         } else  if (RequestScopeHelper.getLanguage().equals("en")) {
             List<KeyValueParameter<String,String>> parameters = initModel.getEn();
-            Optional<KeyValueParameter<String,String>> optional = parameters.stream()
-                    .filter(p -> p.getKey().equals(input.getKey())).findFirst();
-            if (optional.isPresent()) {
-                keyValueParameter = optional.get();
-            }
+            keyValueParameter = getKeyValueParameter(parameters, input.getKey());
         }
 
         return OutputByKey.builder()
@@ -100,7 +90,27 @@ public class LocalizeServiceImpl implements LocalizeService {
 
     @Override
     public void addLocalize(AddLocalizeInput input) throws IOException {
+        Properties props = loadProperties(input.getLanguage());
+        props.setProperty(input.getKey(), input.getValue());
 
+        try (OutputStreamWriter writer = new OutputStreamWriter(
+                new FileOutputStream(basePath + input.getLanguage() + ".properties"),
+                StandardCharsets.UTF_8)) {
+            props.store(writer, "Updated by MessageService");
+        }
+    }
+
+    private KeyValueParameter<String,String> getKeyValueParameter(List<KeyValueParameter<String, String>> parameters,
+                                                                  String key) {
+
+        KeyValueParameter<String,String> keyValueParameter = null;
+
+        Optional<KeyValueParameter<String,String>> optional = parameters.stream()
+                .filter(p -> p.getKey().equals(key)).findFirst();
+        if (optional.isPresent()) {
+            keyValueParameter = optional.get();
+        }
+        return keyValueParameter;
     }
 
     private Properties loadProperties(String lang) throws IOException {

src/main/java/com/utility/utilitycommonservice/integration/config/firebase/FirebaseConfig.java

@@ -0,0 +1,45 @@
+package com.utility.utilitycommonservice.integration.config.firebase;
+
+import com.google.auth.oauth2.GoogleCredentials;
+import com.google.firebase.FirebaseApp;
+import com.google.firebase.FirebaseOptions;
+import io.micrometer.common.util.StringUtils;
+import jakarta.annotation.PostConstruct;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
+
+import java.io.ByteArrayInputStream;
+import java.io.FileInputStream;
+import java.io.IOException;
+import java.util.Base64;
+
+@Component
+public class FirebaseConfig {
+
+    @Value("${push.firebase.credentials.credentials-base64}")
+    private String credentialsBase64;
+
+    @PostConstruct
+    public void init() throws IOException {
+        FirebaseOptions options = FirebaseOptions.builder()
+                .setCredentials(resolveCredentials())
+                .build();
+
+        if (FirebaseApp.getApps().isEmpty()) {
+            FirebaseApp.initializeApp(options);
+        }
+    }
+
+    private GoogleCredentials resolveCredentials() throws IOException {
+        if (StringUtils.isNotBlank(credentialsBase64)) {
+            byte[] json = Base64.getDecoder().decode(credentialsBase64);
+            return GoogleCredentials.fromStream(new ByteArrayInputStream(json));
+        }
+        throw new IllegalStateException(
+                "Firebase credentials not provided. " +
+                        "Provide firebase.credentials-base64 or firebase.credentials-json, " +
+                        "or set client-email and private-key."
+        );
+    }
+
+}

src/main/java/com/utility/utilitycommonservice/integration/service/model/request/firebase/SendToTokenClientRequest.java

@@ -0,0 +1,16 @@
+package com.utility.utilitycommonservice.integration.service.model.request.firebase;
+
+import lombok.Builder;
+import lombok.Data;
+
+@Data
+@Builder
+public class SendToTokenClientRequest {
+
+    private String token;
+    private String title;
+    private String body;
+    private String imageUrl;
+    private String url;
+
+}

src/main/java/com/utility/utilitycommonservice/integration/service/model/request/firebase/SendToTopicClientRequest.java

@@ -0,0 +1,14 @@
+package com.utility.utilitycommonservice.integration.service.model.request.firebase;
+
+import lombok.Builder;
+import lombok.Data;
+
+@Data
+@Builder
+public class SendToTopicClientRequest {
+    private String topic;
+    private String title;
+    private String body;
+    private String imageUrl;
+    private String url;
+}

src/main/java/com/utility/utilitycommonservice/integration/service/model/response/{CreateBranchClientResponse.java → bitbucket/CreateBranchClientResponse.java}

@@ -1,4 +1,4 @@
-package com.utility.utilitycommonservice.integration.service.model.response;
+package com.utility.utilitycommonservice.integration.service.model.response.bitbucket;
 
 import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
 import com.utility.utilitycommonservice.domain.model.bitbucket.output.CreateBranchOutput;

src/main/java/com/utility/utilitycommonservice/integration/service/model/response/firebase/SendToTokenClientResponse.java

@@ -0,0 +1,18 @@
+package com.utility.utilitycommonservice.integration.service.model.response.firebase;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@Builder
+@AllArgsConstructor
+@NoArgsConstructor
+@JsonIgnoreProperties(ignoreUnknown = true)
+public class SendToTokenClientResponse {
+
+    private String messageId;
+
+}

src/main/java/com/utility/utilitycommonservice/integration/service/model/response/firebase/SendToTopicClientResponse.java

@@ -0,0 +1,18 @@
+package com.utility.utilitycommonservice.integration.service.model.response.firebase;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@Builder
+@AllArgsConstructor
+@NoArgsConstructor
+@JsonIgnoreProperties(ignoreUnknown = true)
+public class SendToTopicClientResponse {
+
+    private String messageId;
+
+}

src/main/java/com/utility/utilitycommonservice/integration/service/service/bitbucket/BitbucketClientService.java

@@ -1,7 +1,7 @@
 package com.utility.utilitycommonservice.integration.service.service.bitbucket;
 
 import com.utility.utilitycommonservice.integration.service.model.request.bitbucket.*;
-import com.utility.utilitycommonservice.integration.service.model.response.CreateBranchClientResponse;
+import com.utility.utilitycommonservice.integration.service.model.response.bitbucket.CreateBranchClientResponse;
 
 public interface BitbucketClientService {
 

src/main/java/com/utility/utilitycommonservice/integration/service/service/{impl/bitbucket → bitbucket/impl}/BitbucketClientServiceImpl.java

@@ -1,11 +1,11 @@
-package com.utility.utilitycommonservice.integration.service.service.impl.bitbucket;
+package com.utility.utilitycommonservice.integration.service.service.bitbucket.impl;
 
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
-import com.utility.utilitycommonservice.common.properties.BitbucketProperties;
+import com.utility.utilitycommonservice.domain.properties.BitbucketProperties;
 import com.utility.utilitycommonservice.integration.service.model.MultipartInputStreamFileResource;
 import com.utility.utilitycommonservice.integration.service.model.request.bitbucket.*;
-import com.utility.utilitycommonservice.integration.service.model.response.CreateBranchClientResponse;
+import com.utility.utilitycommonservice.integration.service.model.response.bitbucket.CreateBranchClientResponse;
 import com.utility.utilitycommonservice.integration.service.service.bitbucket.BitbucketClientService;
 import lombok.RequiredArgsConstructor;
 import org.springframework.http.HttpEntity;

src/main/java/com/utility/utilitycommonservice/integration/service/service/firebase/PushClientService.java

@@ -0,0 +1,12 @@
+package com.utility.utilitycommonservice.integration.service.service.firebase;
+
+import com.google.firebase.messaging.FirebaseMessagingException;
+import com.utility.utilitycommonservice.integration.service.model.request.firebase.SendToTokenClientRequest;
+import com.utility.utilitycommonservice.integration.service.model.request.firebase.SendToTopicClientRequest;
+import com.utility.utilitycommonservice.integration.service.model.response.firebase.SendToTokenClientResponse;
+import com.utility.utilitycommonservice.integration.service.model.response.firebase.SendToTopicClientResponse;
+
+public interface PushClientService {
+    SendToTokenClientResponse sendToToken(SendToTokenClientRequest request) throws FirebaseMessagingException;
+    SendToTopicClientResponse sendToTopic(SendToTopicClientRequest request) throws FirebaseMessagingException;
+}