1 #ifdef ENABLE_RPMMD
2
3 #include <stdio.h>
4 #include <stdlib.h>
5 #include <unistd.h>
6
7 #include "pool.h"
8 #include "repo.h"
9 #include "chksum.h"
10 #include "repo_rpmmd.h"
11 #include "repo_deltainfoxml.h"
12 #include "repo_updateinfoxml.h"
13 #include "repo_repomdxml.h"
14 #ifdef ENABLE_APPDATA
15 #include "repo_appdata.h"
16 #endif
17 #ifdef SUSE
18 #include "repo_autopattern.h"
19 #endif
20
21 #include "repoinfo.h"
22 #include "repoinfo_cache.h"
23 #include "repoinfo_download.h"
24 #include "repoinfo_type_rpmmd.h"
25
26
27
28 static const char *
repomd_find(Repo * repo,const char * what,const unsigned char ** chksump,Id * chksumtypep)29 repomd_find(Repo *repo, const char *what, const unsigned char **chksump, Id *chksumtypep)
30 {
31 Pool *pool = repo->pool;
32 Dataiterator di;
33 const char *filename;
34
35 filename = 0;
36 *chksump = 0;
37 *chksumtypep = 0;
38 dataiterator_init(&di, pool, repo, SOLVID_META, REPOSITORY_REPOMD_TYPE, what, SEARCH_STRING);
39 dataiterator_prepend_keyname(&di, REPOSITORY_REPOMD);
40 if (dataiterator_step(&di))
41 {
42 dataiterator_setpos_parent(&di);
43 filename = pool_lookup_str(pool, SOLVID_POS, REPOSITORY_REPOMD_LOCATION);
44 *chksump = pool_lookup_bin_checksum(pool, SOLVID_POS, REPOSITORY_REPOMD_CHECKSUM, chksumtypep);
45 }
46 dataiterator_free(&di);
47 if (filename && !*chksumtypep)
48 {
49 printf("no %s file checksum!\n", what);
50 filename = 0;
51 }
52 return filename;
53 }
54
55 static void
repomd_add_ext(Repo * repo,Repodata * data,const char * what,const char * ext)56 repomd_add_ext(Repo *repo, Repodata *data, const char *what, const char *ext)
57 {
58 Id chksumtype, handle;
59 const unsigned char *chksum;
60 const char *filename;
61
62 filename = repomd_find(repo, what, &chksum, &chksumtype);
63 if (!filename && !strcmp(what, "deltainfo"))
64 filename = repomd_find(repo, "prestodelta", &chksum, &chksumtype);
65 if (!filename)
66 return;
67 handle = repodata_new_handle(data);
68 repodata_set_poolstr(data, handle, REPOSITORY_REPOMD_TYPE, what);
69 repodata_set_str(data, handle, REPOSITORY_REPOMD_LOCATION, filename);
70 repodata_set_bin_checksum(data, handle, REPOSITORY_REPOMD_CHECKSUM, chksumtype, chksum);
71 add_ext_keys(data, handle, ext);
72 repodata_add_flexarray(data, SOLVID_META, REPOSITORY_EXTERNAL, handle);
73 }
74
75 int
repomd_load_ext(Repo * repo,Repodata * data)76 repomd_load_ext(Repo *repo, Repodata *data)
77 {
78 const char *filename, *repomdtype;
79 char ext[3];
80 FILE *fp;
81 struct repoinfo *cinfo;
82 const unsigned char *filechksum;
83 Id filechksumtype;
84 int r = 0;
85
86 cinfo = repo->appdata;
87 repomdtype = repodata_lookup_str(data, SOLVID_META, REPOSITORY_REPOMD_TYPE);
88 if (!repomdtype)
89 return 0;
90 if (!strcmp(repomdtype, "filelists"))
91 strcpy(ext, "FL");
92 else if (!strcmp(repomdtype, "deltainfo"))
93 strcpy(ext, "DL");
94 else
95 return 0;
96 printf("[%s:%s", repo->name, ext);
97 if (usecachedrepo(cinfo, ext, 0))
98 {
99 printf(" cached]\n"); fflush(stdout);
100 return 1;
101 }
102 printf(" fetching]\n"); fflush(stdout);
103 filename = repodata_lookup_str(data, SOLVID_META, REPOSITORY_REPOMD_LOCATION);
104 filechksumtype = 0;
105 filechksum = repodata_lookup_bin_checksum(data, SOLVID_META, REPOSITORY_REPOMD_CHECKSUM, &filechksumtype);
106 if ((fp = curlfopen(cinfo, filename, 1, filechksum, filechksumtype, 0)) == 0)
107 return 0;
108 if (!strcmp(ext, "FL"))
109 r = repo_add_rpmmd(repo, fp, ext, REPO_USE_LOADING|REPO_EXTEND_SOLVABLES|REPO_LOCALPOOL);
110 else if (!strcmp(ext, "DL"))
111 r = repo_add_deltainfoxml(repo, fp, REPO_USE_LOADING);
112 fclose(fp);
113 if (r)
114 {
115 printf("%s\n", pool_errstr(repo->pool));
116 return 0;
117 }
118 if (cinfo->extcookieset)
119 writecachedrepo(cinfo, ext, data);
120 return 1;
121 }
122
123 int
repomd_load(struct repoinfo * cinfo,Pool ** sigpoolp)124 repomd_load(struct repoinfo *cinfo, Pool **sigpoolp)
125 {
126 Repo *repo = cinfo->repo;
127 Pool *pool = repo->pool;
128 Repodata *data;
129 const char *filename;
130 const unsigned char *filechksum;
131 Id filechksumtype;
132 FILE *fp;
133
134 printf("rpmmd repo '%s':", cinfo->alias);
135 fflush(stdout);
136 if ((fp = curlfopen(cinfo, "repodata/repomd.xml", 0, 0, 0, 0)) == 0)
137 {
138 printf(" no repomd.xml file\n");
139 cinfo->incomplete = 1;
140 return 0;
141 }
142 calc_cookie_fp(fp, REPOKEY_TYPE_SHA256, cinfo->cookie);
143 cinfo->cookieset = 1;
144 if (usecachedrepo(cinfo, 0, 1))
145 {
146 printf(" cached\n");
147 fclose(fp);
148 return 1;
149 }
150 if (cinfo->repo_gpgcheck && !downloadchecksig(cinfo, fp, "repodata/repomd.xml.asc", sigpoolp))
151 {
152 fclose(fp);
153 cinfo->incomplete = 1;
154 return 0;
155 }
156 if (repo_add_repomdxml(repo, fp, 0))
157 {
158 printf("repomd.xml: %s\n", pool_errstr(pool));
159 cinfo->incomplete = 1;
160 fclose(fp);
161 return 0;
162 }
163 fclose(fp);
164 printf(" fetching\n");
165 filename = repomd_find(repo, "primary", &filechksum, &filechksumtype);
166 if (filename && (fp = curlfopen(cinfo, filename, 1, filechksum, filechksumtype, 1)) != 0)
167 {
168 if (repo_add_rpmmd(repo, fp, 0, 0))
169 {
170 printf("primary: %s\n", pool_errstr(pool));
171 cinfo->incomplete = 1;
172 }
173 fclose(fp);
174 }
175 if (cinfo->incomplete)
176 return 0; /* hopeless */
177
178 filename = repomd_find(repo, "updateinfo", &filechksum, &filechksumtype);
179 if (filename && (fp = curlfopen(cinfo, filename, 1, filechksum, filechksumtype, 1)) != 0)
180 {
181 if (repo_add_updateinfoxml(repo, fp, 0))
182 {
183 printf("updateinfo: %s\n", pool_errstr(pool));
184 cinfo->incomplete = 1;
185 }
186 fclose(fp);
187 }
188
189 #ifdef ENABLE_APPDATA
190 filename = repomd_find(repo, "appdata", &filechksum, &filechksumtype);
191 if (filename && (fp = curlfopen(cinfo, filename, 1, filechksum, filechksumtype, 1)) != 0)
192 {
193 if (repo_add_appdata(repo, fp, 0))
194 {
195 printf("appdata: %s\n", pool_errstr(pool));
196 cinfo->incomplete = 1;
197 }
198 fclose(fp);
199 }
200 #endif
201 #ifdef SUSE
202 repo_add_autopattern(repo, 0);
203 #endif
204 data = repo_add_repodata(repo, 0);
205 repodata_extend_block(data, repo->start, repo->end - repo->start);
206 repomd_add_ext(repo, data, "deltainfo", "DL");
207 repomd_add_ext(repo, data, "filelists", "FL");
208 repodata_internalize(data);
209 writecachedrepo(cinfo, 0, 0);
210 repodata_create_stubs(repo_last_repodata(repo));
211 return 1;
212 }
213
214 #endif
215