1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
|
package io.github.jshipit;
import com.fasterxml.jackson.databind.JsonNode;
import java.io.FileWriter;
import java.io.IOException;
import java.nio.file.FileAlreadyExistsException;
import java.nio.file.Files;
import java.nio.file.Path;
import java.sql.*;
import java.util.ArrayList;
import java.util.List;
public class OCIDataStore {
private String path;
private String databasePath;
public OCIDataStore(String path) {
this.path = path;
this.databasePath = path + "/datstore.db";
createStore();
try {
createStoreDatabase();
} catch (ClassNotFoundException | InstantiationException | IllegalAccessException e) {
throw new RuntimeException(e);
}
}
private void createStore() {
System.out.println("Creating OCI Data Store");
Path path = Path.of(this.path);
try {
Files.createDirectory(path);
} catch (IOException e) {
System.out.println("Failed to create directory: " + path);
e.printStackTrace();
}
}
private void createStoreDatabase() throws ClassNotFoundException, InstantiationException, IllegalAccessException {
String url = "jdbc:sqlite:" + this.databasePath;
try (Connection conn = DriverManager.getConnection(url)) {
if (conn != null) {
DatabaseMetaData meta = conn.getMetaData();
Statement statement = conn.createStatement();
statement.setQueryTimeout(30); // set timeout to 30 sec.
statement.executeUpdate("CREATE TABLE IF NOT EXISTS blobs (id INTEGER PRIMARY KEY AUTOINCREMENT, digest TEXT, path TEXT)");
System.out.println("A new database has been created.");
}
} catch (SQLException e) {
System.out.println(e.getMessage());
}
}
public void createImage(String apiRepo, String repo, String image, String tag) {
Path imgPath = Path.of(this.path+"/"+image);
try {
Files.createDirectory(imgPath);
} catch (IOException e) {
System.out.println("Failed to create directory: " + imgPath);
}
Path tagPath = Path.of(this.path+"/"+image+"/"+tag);
try {
Files.createDirectory(tagPath);
} catch (IOException e) {
System.out.println("Failed to create directory: " + tagPath);
e.printStackTrace();
return;
}
DockerAPIHelper api = new DockerAPIHelper(apiRepo, repo, image, tag);
JsonNode manifest = null;
try {
manifest = api.fetchManifestJson();
} catch (IOException ignored) {} // Proper error handling is bloat
System.out.println("Manifest: " + manifest);
Path path = Path.of(this.path+"/"+api.getImage()+"/"+api.getTag());
try {
Files.createDirectory(path);
} catch (IOException e) {
if (!(e instanceof FileAlreadyExistsException)) {
System.out.println("Failed to create directory: " + path);
e.printStackTrace();
return;
}
}
assert manifest != null;
JsonNode layers = manifest.get("layers");
List<String> digests = new ArrayList<String>();
String layerpath = this.path+"/blobs";
try {
Files.createDirectory(Path.of(layerpath));
} catch (IOException e) {
if (!(e instanceof FileAlreadyExistsException)) {
System.out.println("Failed to create directory: " + layerpath);
e.printStackTrace();
return;
}
}
for (JsonNode layer : layers) {
System.out.println("Layer: " + layer);
try {
api.fetchBlob(layer.get("digest").asText(), layerpath);
digests.add(layer.get("digest").asText());
} catch (IOException e) {
e.printStackTrace();
}
}
FileWriter writer = null;
try {
writer = new FileWriter(this.path+"/"+image+"/"+tag+"/layers");
writer.write(String.join("\n", digests));
writer.close();
} catch (IOException e) {
throw new RuntimeException(e);
}
}
}
|
