feat(backend): add api for create spreadsheet

Author: BrotherJing

pom.xml

@@ -93,6 +93,21 @@
         <scope>provided</scope>
         <version>${lombok.version}</version>
       </dependency>
+      <dependency>
+        <groupId>com.fasterxml.jackson.core</groupId>
+        <artifactId>jackson-core</artifactId>
+        <version>${jackson.version}</version>
+      </dependency>
+      <dependency>
+        <groupId>com.fasterxml.jackson.core</groupId>
+        <artifactId>jackson-databind</artifactId>
+        <version>${jackson.version}</version>
+      </dependency>
+      <dependency>
+        <groupId>com.fasterxml.jackson.core</groupId>
+        <artifactId>jackson-annotations</artifactId>
+        <version>${jackson.version}</version>
+      </dependency>
       <!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter -->
       <dependency>
         <artifactId>spring-boot-starter</artifactId>

scalable-ot-api/src/main/java/com/brotherjing/controller/DocController.java

@@ -30,7 +30,13 @@ public class DocController {
     @RequestMapping(value = "/create", method = RequestMethod.POST)
     @ResponseBody
     BaseProto.Snapshot create() {
-        return docService.create();
+        return docService.create(BaseProto.DocType.PLAIN_TEXT);
+    }
+
+    @RequestMapping(value = "/create/sheet", method = RequestMethod.POST)
+    @ResponseBody
+    BaseProto.Snapshot createSheet() {
+        return docService.create(BaseProto.DocType.JSON);
     }
 
     @GetMapping(value = "/{docId}/fetch")

scalable-ot-core/pom.xml

@@ -52,6 +52,18 @@
       <groupId>junit</groupId>
       <scope>test</scope>
     </dependency>
+    <dependency>
+      <groupId>com.fasterxml.jackson.core</groupId>
+      <artifactId>jackson-core</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>com.fasterxml.jackson.core</groupId>
+      <artifactId>jackson-databind</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>com.fasterxml.jackson.core</groupId>
+      <artifactId>jackson-annotations</artifactId>
+    </dependency>
   </dependencies>
 
   <build>

scalable-ot-core/src/main/java/com/brotherjing/core/dto/SnapshotDto.java

@@ -13,11 +13,21 @@
 @Data
 @Document
 @CompoundIndex(def = "{'docId': 1, 'version': 1}")
-public class SnapshotDto implements Serializable {
+public class SnapshotDto implements Serializable, Cloneable {
     @Id
     String id;
 
     String docId;
     String data;
     int version;
+
+    @Override
+    public SnapshotDto clone() {
+        return new SnapshotDtoBuilder()
+                .id(id)
+                .docId(docId)
+                .data(data)
+                .version(version)
+                .build();
+    }
 }

scalable-ot-core/src/main/java/com/brotherjing/core/service/DocService.java

@@ -5,7 +5,7 @@
 import com.brotherjing.proto.BaseProto;
 
 public interface DocService {
-    BaseProto.Snapshot create();
+    BaseProto.Snapshot create(BaseProto.DocType docType);
 
     BaseProto.Snapshot get(String docId);
 

scalable-ot-core/src/main/java/com/brotherjing/core/service/impl/DocServiceImpl.java

@@ -1,5 +1,6 @@
 package com.brotherjing.core.service.impl;
 
+import java.util.Arrays;
 import java.util.Collections;
 import java.util.List;
 import java.util.stream.Collectors;
@@ -22,6 +23,8 @@
 import com.brotherjing.core.util.IDUtils;
 import com.brotherjing.core.util.ShortUUID;
 import com.brotherjing.proto.BaseProto;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
 import com.google.common.annotations.VisibleForTesting;
 import com.google.common.collect.Lists;
 
@@ -39,25 +42,37 @@ public class DocServiceImpl implements DocService {
     private CommandDao commandDao;
 
     @Override
-    public BaseProto.Snapshot create() {
+    public BaseProto.Snapshot create(BaseProto.DocType docType) {
         String docId = ShortUUID.generate();
         SnapshotDto dto = SnapshotDto.builder()
                                      .id(IDUtils.generateSnapshotPK(docId))
                                      .docId(docId)
-                                     .data("")
+                                     .data(getInitialData(docType))
                                      .version(0)
                                      .build();
         // also create initial snapshot
-        SnapshotDto initSnapshot = SnapshotDto.builder()
-                                              .id(IDUtils.generateSnapshotPK(docId, 0))
-                                              .docId(docId)
-                                              .data("")
-                                              .version(0)
-                                              .build();
+        SnapshotDto initSnapshot = dto.clone();
+        initSnapshot.setId(IDUtils.generateSnapshotPK(docId, 0));
         docDao.saveAll(Lists.newArrayList(dto, initSnapshot));
         return Converter.toSnapshotProto(dto);
     }
 
+    @VisibleForTesting
+    String getInitialData(BaseProto.DocType docType) {
+        if (BaseProto.DocType.JSON.equals(docType)) {
+            String[][] data = new String[10][10];
+            for (String[] row : data) {
+                Arrays.fill(row, "");
+            }
+            try {
+                return new ObjectMapper().writeValueAsString(data);
+            } catch (JsonProcessingException e) {
+                return "{}";
+            }
+        }
+        return "";
+    }
+
     @Override
     public BaseProto.Snapshot get(String docId) {
         return docDao.findById(IDUtils.generateSnapshotPK(docId))

scalable-ot-core/src/test/java/com/brotherjing/core/service/impl/DocServiceImplTest.java

@@ -18,11 +18,13 @@
 import com.brotherjing.Const;
 import com.brotherjing.config.MongoConfig;
 import com.brotherjing.core.dto.SnapshotDto;
+import com.brotherjing.core.executor.CommandExecutorRegistry;
+import com.brotherjing.core.executor.impl.TextCommandExecutor;
 import com.brotherjing.proto.BaseProto;
 
 @RunWith(SpringJUnit4ClassRunner.class)
 @ContextConfiguration(classes = MongoConfig.class)
-@Import(DocServiceImpl.class)
+@Import({ DocServiceImpl.class, CommandExecutorRegistry.class, TextCommandExecutor.class })
 public class DocServiceImplTest {
 
     @Autowired
@@ -43,9 +45,15 @@ public void tearDown() {
         mongoOps.dropCollection(SnapshotDto.class);
     }
 
+    @Test
+    public void testGetInitialData() {
+        String data = docService.getInitialData(BaseProto.DocType.JSON);
+        Assert.assertNotNull(data);
+    }
+
     @Test
     public void testTakeSnapshot() {
-        BaseProto.Snapshot doc = docService.create();
+        BaseProto.Snapshot doc = docService.create(BaseProto.DocType.PLAIN_TEXT);
         String docId = doc.getDocId();
         int toVersion = Const.TAKE_SNAPSHOT_INTERVAL + 1;
         List<BaseProto.Command> commands = IntStream.range(0, toVersion)