optimize: 提供给插件的内部接口

CHANGELOG.MD

@@ -2,15 +2,17 @@
 
 更新日志文档，版本顺序从新到旧，最新版本在最前(上)面。
 
-# 0.15.11
+# 0.16.0
 
 ## 新特性
 
 - Console支持管理和加载全局header和footer配置
 
 ## 插件支持
 
-- 添加`MetaOperate`以支持插件调用三方元数据插件条目查寻
+- 添加`MetaOperate`以支持插件调用三方元数据插件条目查询
+- 添加`TagOperate`以支持插件对标签的查询和新增
+- 出于安全性考虑插件的内部接口移除所有的删除方法
 
 # 0.15.10
 

api/src/main/java/run/ikaros/api/core/attachment/AttachmentOperate.java

@@ -13,19 +13,13 @@ public interface AttachmentOperate extends AllowPluginOperate {
 
     Mono<PagingWrap<Attachment>> listByCondition(AttachmentSearchCondition searchCondition);
 
-    Mono<Void> removeById(Long attachmentId);
-
     Mono<Attachment> upload(AttachmentUploadCondition uploadCondition);
 
     Mono<Attachment> findById(Long attachmentId);
 
     Mono<Attachment> findByTypeAndParentIdAndName(AttachmentType type, @Nullable Long parentId,
                                                   String name);
 
-    Mono<Void> removeByTypeAndParentIdAndName(
-        AttachmentType type, @Nullable Long parentId, String name);
-
-
     Mono<Attachment> createDirectory(@Nullable Long parentId, @NotBlank String name);
 
     Mono<Boolean> existsByParentIdAndName(@Nullable Long parentId, String name);

api/src/main/java/run/ikaros/api/core/attachment/AttachmentReferenceOperate.java

@@ -11,11 +11,6 @@ public interface AttachmentReferenceOperate extends AllowPluginOperate {
     Flux<AttachmentReference> findAllByTypeAndAttachmentId(
         AttachmentReferenceType type, Long attachmentId);
 
-    Mono<Void> removeById(Long attachmentRefId);
-
-    Mono<Void> removeByTypeAndAttachmentIdAndReferenceId(
-        AttachmentReferenceType type, Long attachmentId, Long referenceId);
-
     Mono<Void> matchingAttachmentsAndSubjectEpisodes(Long subjectId, Long[] attachmentIds);
 
     Mono<Void> matchingAttachmentsAndSubjectEpisodes(Long subjectId, Long[] attachmentIds,

api/src/main/java/run/ikaros/api/core/collection/EpisodeCollectionOperate.java

@@ -5,8 +5,6 @@
 public interface EpisodeCollectionOperate extends CollectionOperate {
     Mono<EpisodeCollection> create(Long userId, Long episodeId);
 
-    Mono<EpisodeCollection> remove(Long userId, Long episodeId);
-
     Mono<EpisodeCollection> findByUserIdAndEpisodeId(Long userId, Long episodeId);
 
     Mono<Void> updateEpisodeCollectionProgress(Long userId, Long episodeId,

api/src/main/java/run/ikaros/api/core/collection/SubjectCollectionOperate.java

@@ -9,8 +9,6 @@ public interface SubjectCollectionOperate extends CollectionOperate {
     Mono<Void> collect(Long userId, Long subjectId,
                        CollectionType type, Boolean isPrivate);
 
-    Mono<Void> unCollect(Long userId, Long subjectId);
-
     Mono<SubjectCollection> findCollection(Long userId, Long subjectId);
 
     Mono<PagingWrap<SubjectCollection>> findCollections(Long userId, Integer page,

api/src/main/java/run/ikaros/api/core/subject/SubjectOperate.java

@@ -19,7 +19,6 @@ public interface SubjectOperate extends AllowPluginOperate {
 
     Mono<Void> update(Subject subject);
 
-    Mono<Void> removeById(Long id);
 
     Mono<Subject> syncByPlatform(@Nullable Long subjectId, SubjectSyncPlatform platform,
                                  String platformId);

api/src/main/java/run/ikaros/api/core/subject/SubjectRelationOperate.java

@@ -12,5 +12,4 @@ public interface SubjectRelationOperate extends AllowPluginOperate {
 
     Mono<SubjectRelation> createSubjectRelation(SubjectRelation subjectRelation);
 
-    Mono<SubjectRelation> removeSubjectRelation(SubjectRelation subjectRelation);
 }

api/src/main/java/run/ikaros/api/core/subject/SubjectSyncPlatformOperate.java

@@ -14,8 +14,6 @@ public interface SubjectSyncPlatformOperate extends AllowPluginOperate {
 
     Mono<SubjectSync> save(SubjectSync subjectSync);
 
-    Mono<Void> remove(SubjectSync subjectSync);
-
     Flux<SubjectSync> findSubjectSyncsBySubjectId(long subjectId);
 
     Mono<SubjectSync> findSubjectSyncBySubjectIdAndPlatform(long subjectId,

api/src/main/java/run/ikaros/api/core/tag/TagOperate.java

@@ -0,0 +1,14 @@
+package run.ikaros.api.core.tag;
+
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+import run.ikaros.api.plugin.AllowPluginOperate;
+import run.ikaros.api.store.enums.TagType;
+
+public interface TagOperate extends AllowPluginOperate {
+    Flux<Tag> findAll(TagType type, Long masterId, Long userId, String name);
+
+    Flux<SubjectTag> findSubjectTags(Long subjectId);
+
+    Mono<Tag> create(Tag tag);
+}

gradle.properties

@@ -1 +1 @@
-version=0.15.11
+version=0.16.0

server/src/main/java/run/ikaros/server/core/attachment/operator/AttachmentOperator.java

@@ -31,11 +31,6 @@ public Mono<PagingWrap<Attachment>> listByCondition(AttachmentSearchCondition se
         return service.listByCondition(searchCondition);
     }
 
-    @Override
-    public Mono<Void> removeById(Long attachmentId) {
-        return service.removeById(attachmentId);
-    }
-
     @Override
     public Mono<Attachment> upload(AttachmentUploadCondition uploadCondition) {
         return service.upload(uploadCondition);
@@ -52,12 +47,6 @@ public Mono<Attachment> findByTypeAndParentIdAndName(AttachmentType type,
         return service.findByTypeAndParentIdAndName(type, parentId, name);
     }
 
-    @Override
-    public Mono<Void> removeByTypeAndParentIdAndName(AttachmentType type, @Nullable Long parentId,
-                                                     String name) {
-        return service.removeByTypeAndParentIdAndName(type, parentId, name);
-    }
-
     @Override
     public Mono<Attachment> createDirectory(@Nullable Long parentId, String name) {
         return service.createDirectory(parentId, name);

server/src/main/java/run/ikaros/server/core/attachment/operator/AttachmentReferenceOperator.java

@@ -29,18 +29,6 @@ public Flux<AttachmentReference> findAllByTypeAndAttachmentId(AttachmentReferenc
         return service.findAllByTypeAndAttachmentId(type, attachmentId);
     }
 
-    @Override
-    public Mono<Void> removeById(Long attachmentRefId) {
-        return service.removeById(attachmentRefId);
-    }
-
-    @Override
-    public Mono<Void> removeByTypeAndAttachmentIdAndReferenceId(AttachmentReferenceType type,
-                                                                Long attachmentId,
-                                                                Long referenceId) {
-        return service.removeByTypeAndAttachmentIdAndReferenceId(type, attachmentId, referenceId);
-    }
-
     @Override
     public Mono<Void> matchingAttachmentsAndSubjectEpisodes(Long subjectId, Long[] attachmentIds) {
         return service.matchingAttachmentsAndSubjectEpisodes(subjectId, attachmentIds);

server/src/main/java/run/ikaros/server/core/collection/EpisodeCollectionOperator.java

@@ -21,11 +21,6 @@ public Mono<EpisodeCollection> create(Long userId, Long episodeId) {
         return service.create(userId, episodeId);
     }
 
-    @Override
-    public Mono<EpisodeCollection> remove(Long userId, Long episodeId) {
-        return service.remove(userId, episodeId);
-    }
-
     @Override
     public Mono<EpisodeCollection> findByUserIdAndEpisodeId(Long userId, Long episodeId) {
         return service.findByUserIdAndEpisodeId(userId, episodeId);

server/src/main/java/run/ikaros/server/core/collection/SubjectCollectionOperator.java

@@ -22,11 +22,6 @@ public Mono<Void> collect(Long userId, Long subjectId, CollectionType type, Bool
         return service.collect(userId, subjectId, type, isPrivate);
     }
 
-    @Override
-    public Mono<Void> unCollect(Long userId, Long subjectId) {
-        return service.unCollect(userId, subjectId);
-    }
-
     @Override
     public Mono<SubjectCollection> findCollection(Long userId, Long subjectId) {
         return service.findCollection(userId, subjectId);

server/src/main/java/run/ikaros/server/core/subject/SubjectOperator.java

@@ -50,11 +50,6 @@ public Mono<Void> update(Subject subject) {
         return subjectService.update(subject);
     }
 
-    @Override
-    public Mono<Void> removeById(Long id) {
-        return subjectService.deleteById(id);
-    }
-
     @Override
     public Mono<Subject> syncByPlatform(@Nullable Long subjectId, SubjectSyncPlatform platform,
                                         String platformId) {

server/src/main/java/run/ikaros/server/core/subject/SubjectRelationOperator.java

@@ -34,8 +34,4 @@ public Mono<SubjectRelation> createSubjectRelation(SubjectRelation subjectRelati
         return subjectRelationService.createSubjectRelation(subjectRelation);
     }
 
-    @Override
-    public Mono<SubjectRelation> removeSubjectRelation(SubjectRelation subjectRelation) {
-        return subjectRelationService.removeSubjectRelation(subjectRelation);
-    }
 }

server/src/main/java/run/ikaros/server/core/subject/SubjectSyncPlatformOperator.java

@@ -37,11 +37,6 @@ public Mono<SubjectSync> save(SubjectSync subjectSync) {
         return service.save(subjectSync);
     }
 
-    @Override
-    public Mono<Void> remove(SubjectSync subjectSync) {
-        return service.remove(subjectSync);
-    }
-
     @Override
     public Flux<SubjectSync> findSubjectSyncsBySubjectId(long subjectId) {
         return service.findSubjectSyncsBySubjectId(subjectId);

server/src/main/java/run/ikaros/server/core/tag/DefaultTagOperator.java

@@ -0,0 +1,35 @@
+package run.ikaros.server.core.tag;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+import run.ikaros.api.core.tag.SubjectTag;
+import run.ikaros.api.core.tag.Tag;
+import run.ikaros.api.core.tag.TagOperate;
+import run.ikaros.api.store.enums.TagType;
+
+@Slf4j
+@Service
+public class DefaultTagOperator implements TagOperate {
+    private final TagService tagService;
+
+    public DefaultTagOperator(TagService tagService) {
+        this.tagService = tagService;
+    }
+
+    @Override
+    public Flux<Tag> findAll(TagType type, Long masterId, Long userId, String name) {
+        return tagService.findAll(type, masterId, userId, name);
+    }
+
+    @Override
+    public Flux<SubjectTag> findSubjectTags(Long subjectId) {
+        return tagService.findSubjectTags(subjectId);
+    }
+
+    @Override
+    public Mono<Tag> create(Tag tag) {
+        return tagService.create(tag);
+    }
+}

server/src/main/java/run/ikaros/server/core/tag/DefaultTagService.java

@@ -17,6 +17,7 @@
 import run.ikaros.api.infra.exception.NotFoundException;
 import run.ikaros.api.infra.utils.StringUtils;
 import run.ikaros.api.store.enums.TagType;
+import run.ikaros.server.core.user.UserService;
 import run.ikaros.server.store.entity.TagEntity;
 import run.ikaros.server.store.repository.TagRepository;
 
@@ -25,10 +26,17 @@
 public class DefaultTagService implements TagService {
     private final TagRepository tagRepository;
     private final R2dbcEntityTemplate r2dbcEntityTemplate;
+    private final UserService userService;
 
-    public DefaultTagService(TagRepository tagRepository, R2dbcEntityTemplate r2dbcEntityTemplate) {
+    /**
+     * Construct.
+     */
+    public DefaultTagService(TagRepository tagRepository,
+                             R2dbcEntityTemplate r2dbcEntityTemplate,
+                             UserService userService) {
         this.tagRepository = tagRepository;
         this.r2dbcEntityTemplate = r2dbcEntityTemplate;
+        this.userService = userService;
     }
 
     @Override
@@ -76,8 +84,9 @@ public Mono<Tag> create(Tag tag) {
         Assert.notNull(tag.getType(), "'type' must not null.");
         Assert.isTrue(tag.getMasterId() >= 0, "'masterId' must >=0.");
         Assert.hasText(tag.getName(), "'name' must has text.");
-        return Mono.just(tag)
-            .flatMap(tag1 -> copyProperties(tag1, new TagEntity()))
+        return userService.getUserIdFromSecurityContext()
+            .map(tag::setUserId)
+            .flatMap(t -> copyProperties(t, new TagEntity()))
             .flatMap(tagRepository::save)
             .flatMap(tagEntity -> copyProperties(tagEntity, tag));
     }