1 package org.argeo.slc.rpmfactory.core;
2
3 import java.io.File;
4 import java.io.IOException;
5 import java.util.ArrayList;
6 import java.util.List;
7
8 import org.apache.commons.exec.Executor;
9 import org.apache.commons.io.FileUtils;
10 import org.apache.commons.logging.Log;
11 import org.apache.commons.logging.LogFactory;
12 import org.argeo.slc.SlcException;
13 import org.argeo.slc.core.execution.tasks.SystemCall;
14 import org.argeo.slc.rpmfactory.RpmFactory;
15
16
17 public class ReleaseStaging implements Runnable {
18 private final static Log log = LogFactory.getLog(ReleaseStaging.class);
19
20 private RpmFactory rpmFactory;
21 private Executor executor;
22
23 private String debuginfoDirName = "debuginfo";
24
25 @Override
26 public void run() {
27 String sourceWorkspace = rpmFactory.getStagingWorkspace();
28 File sourceRepoDir = rpmFactory.getWorkspaceDir(sourceWorkspace);
29 String targetWorkspace = rpmFactory.getTestingWorkspace() != null ? rpmFactory
30 .getTestingWorkspace() : rpmFactory.getStableWorkspace();
31 File targetRepoDir = rpmFactory.getWorkspaceDir(targetWorkspace);
32 List<File> reposToRecreate = new ArrayList<File>();
33
34 stagingChildren: for (File dir : sourceRepoDir.listFiles()) {
35 if (!dir.isDirectory())
36 continue stagingChildren;
37 if (dir.getName().equals("lost+found"))
38 continue stagingChildren;
39
40 File targetDir = new File(targetRepoDir, dir.getName());
41 try {
42 FileUtils.copyDirectory(dir, targetDir);
43 if (log.isDebugEnabled())
44 log.debug(dir + " => " + targetDir);
45 } catch (IOException e) {
46 throw new SlcException(sourceRepoDir
47 + " could not be copied properly, check it manually."
48 + " Metadata have NOT been updated.", e);
49 }
50
51 reposToRecreate.add(dir);
52 reposToRecreate.add(targetDir);
53 File debugInfoDir = new File(dir, debuginfoDirName);
54 if (debugInfoDir.exists())
55 reposToRecreate.add(debugInfoDir);
56 File targetDebugInfoDir = new File(targetDir, debuginfoDirName);
57 if (targetDebugInfoDir.exists())
58 reposToRecreate.add(targetDebugInfoDir);
59
60 }
61
62
63 for (File dir : sourceRepoDir.listFiles()) {
64 try {
65 if (dir.getName().equals("lost+found"))
66 continue;
67 if (dir.isDirectory())
68 FileUtils.deleteDirectory(dir);
69 } catch (IOException e) {
70 log.error("Could not delete " + dir + ". " + e);
71 }
72 }
73
74
75 for (File repoToRecreate : reposToRecreate) {
76 repoToRecreate.mkdirs();
77 SystemCall createrepo = new SystemCall();
78 createrepo.arg("createrepo");
79
80 createrepo.arg("-d");
81
82 if (!repoToRecreate.getName().equals(debuginfoDirName))
83 createrepo.arg("-x").arg(debuginfoDirName + "/*");
84
85 createrepo.arg("-q");
86 createrepo.arg(repoToRecreate.getAbsolutePath());
87
88 createrepo.setExecutor(executor);
89 createrepo.run();
90 log.info("Updated repo " + repoToRecreate);
91 }
92
93 rpmFactory.indexWorkspace(sourceWorkspace);
94 rpmFactory.indexWorkspace(targetWorkspace);
95 }
96
97 public void setRpmFactory(RpmFactory rpmFactory) {
98 this.rpmFactory = rpmFactory;
99 }
100
101 public void setExecutor(Executor executor) {
102 this.executor = executor;
103 }
104
105 public void setDebuginfoDirName(String debuginfoDirName) {
106 this.debuginfoDirName = debuginfoDirName;
107 }
108
109 }