001/*
002 *  Copyright 2013 Anyware Services
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 */
016package org.ametys.plugins.skincommons;
017
018import java.io.File;
019import java.util.HashMap;
020import java.util.Map;
021
022import org.apache.avalon.framework.parameters.Parameters;
023import org.apache.avalon.framework.service.ServiceException;
024import org.apache.avalon.framework.service.ServiceManager;
025import org.apache.cocoon.acting.ServiceableAction;
026import org.apache.cocoon.environment.ObjectModelHelper;
027import org.apache.cocoon.environment.Redirector;
028import org.apache.cocoon.environment.Request;
029import org.apache.cocoon.environment.SourceResolver;
030
031import org.ametys.core.cocoon.JSonReader;
032import org.ametys.core.user.User;
033import org.ametys.core.user.UserIdentity;
034import org.ametys.core.user.UserManager;
035
036/**
037 * Used to protect skin edition pipelines.
038 * Stops the pipelines execution if the skin is locked by another user.
039 * If locked, set a JSON map in request attributes : {isLocked: true, lockOwner: XXX}
040 */
041public class CheckNotLockedAction extends ServiceableAction
042{
043    private UserManager _userManager;
044    private SkinLockManager _lockManager;
045    private SkinEditionHelper _skinHelper;
046
047    @Override
048    public void service(ServiceManager smanager) throws ServiceException
049    {
050        super.service(smanager);
051        _lockManager = (SkinLockManager) smanager.lookup(SkinLockManager.ROLE);
052        _userManager = (UserManager) smanager.lookup(UserManager.ROLE);
053        _skinHelper = (SkinEditionHelper) smanager.lookup(SkinEditionHelper.ROLE);
054    }
055    
056    @Override
057    public Map act(Redirector redirector, SourceResolver resolver, Map objectModel, String source, Parameters parameters) throws Exception
058    {
059        Request request = ObjectModelHelper.getRequest(objectModel);
060        String skinName = request.getParameter("skinName");
061        
062        File tempDir = _skinHelper.getTempDirectory(skinName);
063        
064        if (!_lockManager.canWrite(tempDir))
065        {
066            Map<String, Object> result = new HashMap<>();
067            
068            UserIdentity lockOwner = _lockManager.getLockOwner(tempDir);
069            User user = _userManager.getUser(lockOwner.getPopulationId(), lockOwner.getLogin());
070
071            result.put("isLocked", true);
072            result.put("lockOwner", user != null ? user.getFullName() + " (" + lockOwner + ")" : lockOwner);
073            result.put("success", false);
074            
075            request.setAttribute(JSonReader.OBJECT_TO_READ, result);
076            
077            // Stop pipelines execution
078            return EMPTY_MAP;
079        }
080        
081        // Continue
082        return null;
083    }
084
085}