001// -------------------------------------------------------------------------------- 002// Copyright 2002-2026 Echo Three, LLC 003// 004// Licensed under the Apache License, Version 2.0 (the "License"); 005// you may not use this file except in compliance with the License. 006// You may obtain a copy of the License at 007// 008// http://www.apache.org/licenses/LICENSE-2.0 009// 010// Unless required by applicable law or agreed to in writing, software 011// distributed under the License is distributed on an "AS IS" BASIS, 012// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 013// See the License for the specific language governing permissions and 014// limitations under the License. 015// -------------------------------------------------------------------------------- 016 017package com.echothree.control.user.forum.server.command; 018 019import com.echothree.control.user.forum.common.form.CreateForumMessageAttachmentForm; 020import com.echothree.model.control.core.common.EntityAttributeTypes; 021import com.echothree.model.control.core.server.control.MimeTypeControl; 022import com.echothree.model.control.forum.server.control.ForumControl; 023import com.echothree.model.data.forum.server.entity.ForumMessageAttachment; 024import com.echothree.model.data.user.common.pk.UserVisitPK; 025import com.echothree.util.common.command.BaseResult; 026import com.echothree.util.common.message.ExecutionErrors; 027import com.echothree.util.common.validation.FieldDefinition; 028import com.echothree.util.common.validation.FieldType; 029import com.echothree.util.server.control.BaseSimpleCommand; 030import com.echothree.util.server.persistence.Session; 031import java.util.List; 032import javax.enterprise.context.Dependent; 033 034@Dependent 035public class CreateForumMessageAttachmentCommand 036 extends BaseSimpleCommand<CreateForumMessageAttachmentForm> { 037 038 private final static List<FieldDefinition> FORM_FIELD_DEFINITIONS; 039 040 static { 041 FORM_FIELD_DEFINITIONS = List.of( 042 new FieldDefinition("ForumMessageName", FieldType.ENTITY_NAME, true, null, null), 043 new FieldDefinition("ForumMessageAttachmentSequence", FieldType.UNSIGNED_INTEGER, false, null, null), 044 new FieldDefinition("MimeTypeName", FieldType.MIME_TYPE, true, null, null), 045 new FieldDefinition("Clob", FieldType.STRING, false, 1L, null), 046 new FieldDefinition("String", FieldType.STRING, false, 1L, 512L) 047 ); 048 } 049 050 /** Creates a new instance of CreateForumMessageAttachmentCommand */ 051 public CreateForumMessageAttachmentCommand() { 052 super(null, FORM_FIELD_DEFINITIONS, false); 053 } 054 055 @Override 056 protected BaseResult execute() { 057 var forumControl = Session.getModelController(ForumControl.class); 058 var forumMessageName = form.getForumMessageName(); 059 var forumMessage = forumControl.getForumMessageByNameForUpdate(forumMessageName); 060 061 if(forumMessage != null) { 062 var mimeTypeControl = Session.getModelController(MimeTypeControl.class); 063 var mimeTypeName = form.getMimeTypeName(); 064 var mimeType = mimeTypeControl.getMimeTypeByName(mimeTypeName); 065 066 if(mimeType != null) { 067 var entityAttributeTypeName = mimeType.getLastDetail().getEntityAttributeType().getEntityAttributeTypeName(); 068 var blob = form.getBlob(); 069 var clob = form.getClob(); 070 071 if(entityAttributeTypeName.equals(EntityAttributeTypes.BLOB.name()) && blob == null) { 072 addExecutionError(ExecutionErrors.MissingBlob.name()); 073 } else { 074 if(entityAttributeTypeName.equals(EntityAttributeTypes.CLOB.name()) && clob == null) { 075 addExecutionError(ExecutionErrors.MissingClob.name()); 076 } 077 } 078 079 if(!hasExecutionErrors()) { 080 var partyPK = getPartyPK(); 081 var strForumMessageAttachmentSequence = form.getForumMessageAttachmentSequence(); 082 var forumMessageAttachmentSequence = strForumMessageAttachmentSequence == null ? null : Integer.valueOf(strForumMessageAttachmentSequence); 083 ForumMessageAttachment forumMessageAttachment; 084 var forumMessageStatus = forumControl.getOrCreateForumMessageStatusForUpdate(forumMessage); 085 086 if(forumMessageAttachmentSequence == null) { 087 forumMessageAttachmentSequence = forumMessageStatus.getForumMessageAttachmentSequence() + 1; 088 forumMessageStatus.setForumMessageAttachmentSequence(forumMessageAttachmentSequence); 089 } else { 090 forumMessageAttachment = forumControl.getForumMessageAttachmentBySequence(forumMessage, forumMessageAttachmentSequence); 091 092 if(forumMessageAttachment == null) { 093 // If the forumMessageAttachmentSequence is > the last one that was recorded in the OrderStatus, jump the 094 // one in OrderStatus forward - it should always record the greatest forumMessageAttachmentSequence used. 095 if(forumMessageAttachmentSequence > forumMessageStatus.getForumMessageAttachmentSequence()) { 096 forumMessageStatus.setForumMessageAttachmentSequence(forumMessageAttachmentSequence); 097 } 098 } else { 099 addExecutionError(ExecutionErrors.DuplicateForumMessageAttachmentSequence.name(), forumMessageName, forumMessageAttachmentSequence.toString()); 100 } 101 } 102 103 forumMessageAttachment = forumControl.createForumMessageAttachment(forumMessage, forumMessageAttachmentSequence, mimeType, partyPK); 104 105 if(entityAttributeTypeName.equals(EntityAttributeTypes.BLOB.name())) { 106 forumControl.createForumMessageBlobAttachment(forumMessageAttachment, blob, partyPK); 107 } else { 108 if(entityAttributeTypeName.equals(EntityAttributeTypes.CLOB.name())) { 109 forumControl.createForumMessageClobAttachment(forumMessageAttachment, clob, partyPK); 110 } 111 } 112 } 113 } else { 114 addExecutionError(ExecutionErrors.UnknownMimeTypeName.name(), mimeTypeName); 115 } 116 } else { 117 addExecutionError(ExecutionErrors.UnknownForumMessageName.name(), forumMessageName); 118 } 119 120 return null; 121 } 122 123}