import org.apache.jackrabbit.webdav.io.InputContext; //导入依赖的package包/类
@Override
public void addMember( @Nullable DavResource davResource, @Nullable InputContext inputContext ) throws DavException {
    if( !isDirectory ) {
        throw new UnsupportedOperationException( "Not implemented: addMember to file" );
    }

    DavPath davPath = checkPath( davResource );

    //DavSession session = davPath.getSession();

    if( inputContext != null && inputContext.hasStream() ) { //session.isPutRequest() ) { // todo check
        createFile( n1( inputContext ), davPath );
    } else {
        createDir( davPath );

    }

}
 

import org.apache.jackrabbit.webdav.io.InputContext; //导入依赖的package包/类
/** */
protected void populateItem(InputContext inputContext)
    throws CosmoDavException {
    super.populateItem(inputContext);

    ContentItem content = (ContentItem) getItem();
    
    User user = getSecurityManager().getSecurityContext().getUser();
    content.setLastModifiedBy(user != null ? user.getEmail() : "");

    if (content.getUid() == null) {
        content.setTriageStatus(TriageStatusUtil.initialize(content
                .getFactory().createTriageStatus()));
        content.setLastModification(ContentItem.Action.CREATED);
        content.setSent(Boolean.FALSE);
        content.setNeedsReply(Boolean.FALSE);
    } else {
        content.setLastModification(ContentItem.Action.EDITED);
    }
}
 

import org.apache.jackrabbit.webdav.io.InputContext; //导入依赖的package包/类
public void createFile(final String fullFilePath, final InputContext inputContext) throws DavException {
    if (cassandraDao.getFile(fullFilePath) != null) {
        throw new DavException(DavServletResponse.SC_CONFLICT);
    }
    final String parentDirectory = getParentDirectory(fullFilePath);
    final String fileName = PathUtils.getFileName(fullFilePath);
    final UUID parentId = cassandraDao.getFile(parentDirectory);
    try {
        final UUID fileUUID = cassandraFileDao.createFile(parentId, fileName);
        if (inputContext.hasStream() && inputContext.getContentLength() >= 0) {

            final CountingInputStream countingInputStream = new CountingInputStream(inputContext.getInputStream());
            cassandraFileDao.writeFile(fileUUID, countingInputStream);
            cassandraFileDao.updateFileInfo(fileUUID, countingInputStream.getCount());
        }
    } catch (ConnectionException e) {
        throw new RuntimeException(e);
    }
}
 

import org.apache.jackrabbit.webdav.io.InputContext; //导入依赖的package包/类
private void createFile( InputContext inputContext, DavPath fileResource ) throws DavException {
    try( OutputStream out = Files.newOutputStream( fileResource.file ) ) {
        if( inputContext.hasStream() ) {
            IO.copy( inputContext.getInputStream(), out );
        }
    } catch( Exception e ) {
        Log.warn( "create file problems " + file, e );
        throw new DavException( DavServletResponse.SC_INTERNAL_SERVER_ERROR, e );
    }
}
 

import org.apache.jackrabbit.webdav.io.InputContext; //导入依赖的package包/类
/**
 * 
 * @param request 
 * @return InputContext 
 * @throws CosmoDavException 
 * @throws IOException 
 */
protected InputContext createInputContext(DavRequest request)
    throws CosmoDavException, IOException {
    String xfer = request.getHeader("Transfer-Encoding");
    boolean chunked = xfer != null && xfer.equals("chunked");
    if (xfer != null && ! chunked){
        throw new BadRequestException("Unknown Transfer-Encoding " + xfer);
    } 
    if (request.getContentLength() <= 0){
        throw new BadRequestException("no content length set to input stream.");
    }
    
    return new DavInputContext(request, request.getInputStream());
}
 

import org.apache.jackrabbit.webdav.io.InputContext; //导入依赖的package包/类
/**
 * this method is added as an extension to cosmo, to allow updating an event based on ticket auth.
 * 
 * @param content
 * @param context
 * @throws CosmoDavException
 */
public void updateContent(DavContent content, InputContext context) throws CosmoDavException {
    if(!(content instanceof DavContentBase)){
        throw new IllegalArgumentException("Expected type for 'content' member :[" + DavContentBase.class.getName()+"]");
    }
    
    DavContentBase base = (DavContentBase) content;
    base.populateItem(context);
    updateItem();
}
 

import org.apache.jackrabbit.webdav.io.InputContext; //导入依赖的package包/类
public void addContent(DavContent content, InputContext context) throws CosmoDavException {
    if(!(content instanceof DavContentBase)) {
        throw new IllegalArgumentException("Expected instance of : [" + DavContentBase.class.getName() + "]");
    }
    
    DavContentBase base = (DavContentBase) content;
    base.populateItem(context);
    saveContent(base);
    members.add(base);
}
 

import org.apache.jackrabbit.webdav.io.InputContext; //导入依赖的package包/类
@Override
protected void populateItem(InputContext inputContext)
    throws CosmoDavException {
    super.populateItem(inputContext);

    DavInputContext dic = (DavInputContext) inputContext;
    Calendar calendar = dic.getCalendar();

    setCalendar(calendar);
}
 

import org.apache.jackrabbit.webdav.io.InputContext; //导入依赖的package包/类
/**
 * Sets the properties of the item backing this resource from the given
 * input context.
 */
protected void populateItem(InputContext inputContext)
        throws CosmoDavException {
    if (log.isDebugEnabled()) {
        log.debug("populating item for " + getResourcePath());
    }

    if (item.getUid() == null) {
        try {
            item.setName(UrlEncoding.decode(PathUtil.getBasename(getResourcePath()), "UTF-8"));
        } catch (UnsupportedEncodingException e) {
            throw new CosmoDavException(e);
        }
        if (item.getDisplayName() == null){
            item.setDisplayName(item.getName());
        }
    }

    // if we don't know specifically who the user is, then the
    // owner of the resource becomes the person who issued the
    // ticket

    // Only initialize owner once
    if (item.getOwner() == null) {
        User owner = getSecurityManager().getSecurityContext().getUser();
        if (owner == null) {
            Ticket ticket = getSecurityManager().getSecurityContext()
                    .getTicket();
            owner = ticket.getOwner();
        }
        item.setOwner(owner);
    }

    if (item.getUid() == null) {
        item.setClientCreationDate(Calendar.getInstance().getTime());
        item.setClientModifiedDate(item.getClientCreationDate());
    }
}
 

import org.apache.jackrabbit.webdav.io.InputContext; //导入依赖的package包/类
/** */
protected void populateItem(InputContext inputContext) throws CosmoDavException {
    super.populateItem(inputContext);

    CalendarCollectionStamp cc = getCalendarCollectionStamp();

    try {
        cc.setDescription(getItem().getName());
        // XXX: language should come from the input context
    } catch (DataSizeException e) {
        throw new MaxResourceSizeException(e.getMessage());
    }
}
 

import org.apache.jackrabbit.webdav.io.InputContext; //导入依赖的package包/类
@Override
public void addMember(DavResource resource, InputContext inputContext) throws DavException {
    final AbstractDavResource cassandraResource = (AbstractDavResource) resource;
    final String destPath = cassandraResource.getPath();
    if (cassandraResource.isCollection()) {
        getCassandraService().createDirectory(destPath);
    } else {
        getFileStorageService().createFile(destPath, inputContext);
    }
}
 

import org.apache.jackrabbit.webdav.io.InputContext; //导入依赖的package包/类
@Override
public void addMember( DavResource arg0, InputContext arg1 )
    throws DavException
{

}
 

import org.apache.jackrabbit.webdav.io.InputContext; //导入依赖的package包/类
public void addMember(org.apache.jackrabbit.webdav.DavResource member,
                      InputContext inputContext)
    throws org.apache.jackrabbit.webdav.DavException {
    throw new UnsupportedOperationException();
}
 

import org.apache.jackrabbit.webdav.io.InputContext; //导入依赖的package包/类
public void addMember(org.apache.jackrabbit.webdav.DavResource member, InputContext inputContext)
        throws org.apache.jackrabbit.webdav.DavException {
    throw new UnsupportedOperationException();
}
 

import org.apache.jackrabbit.webdav.io.InputContext; //导入依赖的package包/类
public void addContent(DavContent content, InputContext context) throws CosmoDavException {
    throw new UnsupportedOperationException();
}
 

import org.apache.jackrabbit.webdav.io.InputContext; //导入依赖的package包/类
/**
 * Adds a new content item to this resource.
 */
void addContent(DavContent content,
                       InputContext input)
    throws CosmoDavException;
 

import org.apache.jackrabbit.webdav.io.InputContext; //导入依赖的package包/类
public void addContent(DavContent content,
                       InputContext context)
    throws CosmoDavException {
    throw new UnsupportedOperationException();
}
 

import org.apache.jackrabbit.webdav.io.InputContext; //导入依赖的package包/类
public void addMember(org.apache.jackrabbit.webdav.DavResource member,
        InputContext inputContext)
        throws org.apache.jackrabbit.webdav.DavException {
    throw new UnsupportedOperationException();
}
 

import org.apache.jackrabbit.webdav.io.InputContext; //导入依赖的package包/类
/**
 * Method is not allowed.
 */
public void addMember(DavResource resource, InputContext inputContext) throws DavException {
    throw new DavException(DavServletResponse.SC_METHOD_NOT_ALLOWED, "Cannot add members to a non-collection resource");
}
 

import org.apache.jackrabbit.webdav.io.InputContext; //导入依赖的package包/类
@Override
public void addMember(DavResource resource, InputContext inputContext) throws DavException {
}