001/*
002 * Sonar, open source software quality management tool.
003 * Copyright (C) 2008-2012 SonarSource
004 * mailto:contact AT sonarsource DOT com
005 *
006 * Sonar is free software; you can redistribute it and/or
007 * modify it under the terms of the GNU Lesser General Public
008 * License as published by the Free Software Foundation; either
009 * version 3 of the License, or (at your option) any later version.
010 *
011 * Sonar is distributed in the hope that it will be useful,
012 * but WITHOUT ANY WARRANTY; without even the implied warranty of
013 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
014 * Lesser General Public License for more details.
015 *
016 * You should have received a copy of the GNU Lesser General Public
017 * License along with Sonar; if not, write to the Free Software
018 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02
019 */
020package org.sonar.plugins.dbcleaner.period;
021
022import com.google.common.annotations.VisibleForTesting;
023import org.slf4j.Logger;
024import org.slf4j.LoggerFactory;
025import org.sonar.api.config.Settings;
026import org.sonar.api.resources.Project;
027import org.sonar.api.utils.DateUtils;
028import org.sonar.core.purge.PurgeDao;
029import org.sonar.core.purge.PurgeSnapshotQuery;
030import org.sonar.core.purge.PurgeableSnapshotDto;
031import org.sonar.plugins.dbcleaner.api.PeriodCleaner;
032
033import java.util.List;
034
035public class DefaultPeriodCleaner implements PeriodCleaner {
036
037  private static final Logger LOG = LoggerFactory.getLogger(DefaultPeriodCleaner.class);
038  private PurgeDao purgeDao;
039  private Settings settings;
040
041  public DefaultPeriodCleaner(PurgeDao purgeDao, Settings settings) {
042    this.purgeDao = purgeDao;
043    this.settings = settings;
044  }
045
046  public void purge(Project project, int projectSnapshotId) {
047    clean(project.getId());
048  }
049
050  public void clean(long projectId) {
051    doClean(projectId, new Filters(settings).getFilters());
052  }
053
054  @VisibleForTesting
055  void doClean(long projectId, List<Filter> filters) {
056    List<PurgeableSnapshotDto> history = selectProjectSnapshots(projectId);
057    for (Filter filter : filters) {
058      filter.log();
059      delete(filter.filter(history));
060    }
061  }
062
063  private void delete(List<PurgeableSnapshotDto> snapshots) {
064    for (PurgeableSnapshotDto snapshot : snapshots) {
065      LOG.info("<- Delete snapshot: " + DateUtils.formatDateTime(snapshot.getDate()) + " [" + snapshot.getSnapshotId() + "]");
066      purgeDao.deleteSnapshots(PurgeSnapshotQuery.create().setRootSnapshotId(snapshot.getSnapshotId()));
067      purgeDao.deleteSnapshots(PurgeSnapshotQuery.create().setId(snapshot.getSnapshotId()));
068    }
069  }
070
071  private List<PurgeableSnapshotDto> selectProjectSnapshots(long resourceId) {
072    return purgeDao.selectPurgeableSnapshots(resourceId);
073  }
074}