Merge pull request #2 from Eunhye0k/sprint2

Sprint 2 과제 제출

Author: Eunhye0k

Message.ser

@@ -1,8 +1,12 @@
 package com.sprint.mission.discodeit.entity;
 
+import java.io.Serial;
+import java.io.Serializable;
 import java.util.UUID;
 
-public class BaseEntity {
+public class BaseEntity implements Serializable {
+    @Serial
+    private static final long serialVersionUID = 1L;
 
     private UUID id;
     private Long createdAt;

channels.ser

@@ -1,15 +1,20 @@
 package com.sprint.mission.discodeit.entity;
+import java.io.Serial;
+import java.io.Serializable;
 import java.util.ArrayList;
 import java.util.List;
+import java.util.UUID;
 
-public class Channel extends BaseEntity {
-    private String channel;
+public class Channel extends BaseEntity implements Serializable {
+    @Serial
+    private static final long serialVersionUID = 1L;
+    private String title;
     private final List<Message> messages;
     private final List<User> users;
 
     public Channel(String channel) {
         super();
-        this.channel = channel;
+        this.title = channel;
 
         this.messages = new ArrayList<>();
         this.users = new ArrayList<>();
@@ -20,22 +25,20 @@ public List<User> getUsers() {
     }
 
     public String getChannel() {
-        return channel;
+        return title;
     }
 
     public void updateChannel(String updateChannel){
-        this.channel = updateChannel;
+        this.title = updateChannel;
         updateTimeStamp();
     }
 
-    //추가
     public void addUser(User user){
         if(!users.contains(user)) {
             users.add(user);
             user.addChannel(this);
         }
     }
-    //추가
     public void addMessage(Message message){
         if(!messages.contains(message)) {
             messages.add(message);
@@ -56,8 +59,12 @@ public void deleteUser(User user){
         }
     }
 
-    //추가
     public List<Message> getMessages(){
         return messages;
     }
+
+    @Override
+    public UUID getId(){
+        return super.getId();
+    }
 }

src/main/java/com/sprint/mission/Main.java

@@ -1,10 +1,14 @@
 package com.sprint.mission.discodeit.entity;
 
+import java.io.Serial;
+import java.io.Serializable;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.UUID;
 
-public class Message extends BaseEntity {
+public class Message extends BaseEntity implements Serializable {
+    @Serial
+    private static final long serialVersionUID = 1L;
     private String content;
     private User user;
     private Channel channel;
@@ -20,7 +24,6 @@ public String getContent() {
         return content;
     }
 
-
     public void addUser(User user){
         this.user = user;
     }

src/main/java/com/sprint/mission/discodeit/JavaApplication.java

@@ -1,12 +1,15 @@
 package com.sprint.mission.discodeit.entity;
 
+import java.io.*;
 import java.lang.reflect.Array;
 import java.nio.channels.Channels;
 import java.util.ArrayList;
 import java.util.Collections;
 import java.util.List;
 
-public class User extends BaseEntity {
+public class User extends BaseEntity implements Serializable {
+    @Serial
+    private static final long serialVersionUID = 1L;
     private String username;
     private final List<Message> messages;
     private final List<Channel> channels;
@@ -15,7 +18,6 @@ public User(String name) {
         super();
         this.username = name;
 
-        //추가
         this.messages = new ArrayList<Message>();
         this.channels = new ArrayList<Channel>();
     }

src/main/java/com/sprint/mission/discodeit/entity/BaseEntity.java

@@ -0,0 +1,21 @@
+package com.sprint.mission.discodeit.repository;
+
+import com.sprint.mission.discodeit.entity.Channel;
+import com.sprint.mission.discodeit.entity.User;
+
+import java.util.List;
+import java.util.Map;
+import java.util.Optional;
+import java.util.UUID;
+
+public interface ChannelRepository {
+//  Channel createChannel(Channel name);
+    Channel getChannel(UUID name);
+    List<Channel> getChannels();
+//  void updateChannel(UUID name, String updateChannel);
+//  void deleteChannel(UUID name);
+//Optional<Channel> findByChannelName(String title);
+    Optional<Channel> findByChannelName(String title);
+    void save(Channel channel);  // create or update
+    void delete(UUID id);
+}

src/main/java/com/sprint/mission/discodeit/entity/Channel.java

@@ -0,0 +1,22 @@
+package com.sprint.mission.discodeit.repository;
+
+import com.sprint.mission.discodeit.entity.Channel;
+import com.sprint.mission.discodeit.entity.Message;
+import com.sprint.mission.discodeit.entity.User;
+
+import java.util.List;
+import java.util.Map;
+import java.util.Optional;
+import java.util.UUID;
+
+public interface MessageRepository {
+    //  Message createMessage(Message create, User user, Channel channel);
+    Message getMessage(UUID id);
+    List<Message> getMessages();
+    //  void updateMessage (UUID id, String message);
+    //  void deleteMessage (UUID id);
+    //Optional<Message> findByMessage(String content);
+    Optional<Message> validationMessage(UUID id);
+    void save(Message message);
+    void delete(UUID id);
+}

src/main/java/com/sprint/mission/discodeit/entity/Message.java

@@ -0,0 +1,19 @@
+package com.sprint.mission.discodeit.repository;
+
+import com.sprint.mission.discodeit.entity.User;
+
+import java.util.List;
+import java.util.Map;
+import java.util.Optional;
+import java.util.UUID;
+
+public interface UserRepository {
+//  User createUser(User user);
+    User getUser(UUID id);
+    List<User> getUsers();
+//  void updateUser (UUID id, String username);
+//  void deleteUser (UUID id);
+    Optional<User> findByUserId(UUID id);
+    void save(User user);  // create or update
+    void delete(UUID id);
+}

src/main/java/com/sprint/mission/discodeit/entity/User.java

@@ -0,0 +1,63 @@
+package com.sprint.mission.discodeit.repository.file;
+
+import com.sprint.mission.discodeit.entity.Channel;
+import com.sprint.mission.discodeit.repository.ChannelRepository;
+import com.sprint.mission.discodeit.repository.UserRepository;
+
+import java.io.*;
+import java.util.*;
+
+public class FileChannelRepository implements ChannelRepository {
+    private final String filePath = "channels.ser";
+
+
+    public Channel getChannel(UUID id) {
+        Map<UUID, Channel> data = readChannelFile();
+        return data.get(id);
+    }
+
+    public List<Channel> getChannels() {
+        return new ArrayList<>(readChannelFile().values());
+    }
+
+    @Override
+    public void save(Channel channel) {
+        Map<UUID, Channel> data = readChannelFile();
+        data.put(channel.getId(), channel);
+        writeChannelFile(data);
+    }
+
+    @Override
+    public void delete(UUID id) {
+        Map<UUID, Channel> data = readChannelFile();
+        data.remove(id);
+        writeChannelFile(data);
+    }
+
+
+    public Optional<Channel> findByChannelName(String title) {
+        Map<UUID, Channel> data = readChannelFile();
+        return data.values()
+                .stream()
+                .filter(channel -> channel.getChannel().equals(title))
+                .findFirst();
+    }
+
+    //채널 파일 READ
+    private Map<UUID, Channel> readChannelFile() {
+        try(ObjectInputStream in = new ObjectInputStream(new FileInputStream(filePath))){
+            return (Map<UUID, Channel>) in.readObject();
+        } catch (IOException | ClassNotFoundException e) {
+            return new HashMap<>();
+        }
+    }
+
+    //채널 파일에 WRITE
+    private void writeChannelFile(Map<UUID, Channel> data) {
+        try(ObjectOutputStream out = new ObjectOutputStream(new FileOutputStream("channels.ser"))){
+            out.writeObject(data);
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+}