Add a high-level API for creating repodata

examples/python/simple_createrepo.py → examples/python/manual_createrepo.py

@@ -6,7 +6,7 @@
 import os.path
 import createrepo_c as cr
 
-def do_repodata(path):
+def manual_method(path):
     # Prepare repodata/ directory
     repodata_path = os.path.join(path, "repodata")
     if os.path.exists(repodata_path):
@@ -37,10 +37,10 @@ def do_repodata(path):
 
     # List directory and prepare list of files to process
     pkg_list = []
-    for filename in os.listdir(path):
-        filename = os.path.join(path, filename)
-        if os.path.isfile(filename) and filename.endswith(".rpm"):
-            pkg_list.append(filename)
+    with os.scandir(path) as entries:
+        for entry in entries:
+            if entry.is_file() and entry.path.endswith(".rpm"):
+                pkg_list.append(entry.path)
 
     pri_xml.set_num_of_pkgs(len(pkg_list))
     fil_xml.set_num_of_pkgs(len(pkg_list))
@@ -93,6 +93,6 @@ def do_repodata(path):
         print("Usage: %s <directory>" % (sys.argv[0]))
         sys.exit(1)
 
-    do_repodata(sys.argv[1])
+    manual_method(sys.argv[1])
 
     print("Repository created in %s" % sys.argv[1])

examples/python/simple_repository_reading.py

@@ -0,0 +1,21 @@
+#!/usr/bin/env python
+
+import os
+import sys
+import createrepo_c as cr
+
+REPO_PATH = "tests/testdata/repo_with_additional_metadata/"
+
+
+def parse_repository(path):
+    reader = cr.RepositoryReader.from_path(path)
+
+    for package in reader.iter_packages():
+        print("Package {}".format(package.nevra()))
+
+    for advisory in reader.advisories():
+        print("Advisory {}".format(advisory.id))
+
+
+if __name__ == "__main__":
+    parse_repository(REPO_PATH)

examples/python/simple_repository_writing.py

@@ -0,0 +1,67 @@
+#!/usr/bin/env python
+
+import os
+import sys
+import createrepo_c as cr
+
+
+def write_repository_v1(path):
+    # List directory and prepare list of files to process
+    pkg_list = []
+
+    with os.scandir(path) as entries:
+        for entry in entries:
+            if entry.is_file() and entry.path.endswith(".rpm"):
+                pkg_list.append(entry.path)
+
+    # create a RepositoryWriter with a context manager - finish() is called automatically
+    # let's just use the default options
+    with cr.RepositoryWriter(path) as writer:
+        writer.repomd.add_repo_tag("Fedora 34")
+        writer.repomd.set_revision("1628310033")
+        # we have to set the number of packages we will add, before we add them
+        writer.set_num_of_pkgs(len(pkg_list))
+
+        for filename in pkg_list:
+            pkg = writer.add_pkg_from_file(filename)
+            print("Added: %s" % pkg.nevra())
+
+
+def write_repository_v2(path):
+    # List directory and prepare list of files to process
+    pkg_list = []
+
+    with os.scandir(path) as entries:
+        for entry in entries:
+            if entry.is_file() and entry.path.endswith(".rpm"):
+                pkg_list.append(entry.path)
+
+    # create a writer without a context manager - you need to manually call finish()
+    # change a couple of the defaults too
+    writer = cr.RepositoryWriter(
+        path,
+        unique_md_filenames=False,
+        changelog_limit=4,
+        checksum_type=cr.SHA512,
+        compression=cr.GZ_COMPRESSION,
+    )
+    writer.repomd.add_repo_tag("Fedora 34")
+    writer.repomd.set_revision("1628310033")
+    writer.set_num_of_pkgs(len(pkg_list))
+
+    for filename in pkg_list:
+        pkg = writer.add_pkg_from_file(filename)
+        print("Added: %s" % pkg.nevra())
+
+    writer.finish()
+
+
+if __name__ == "__main__":
+    if len(sys.argv) != 2 or not os.path.isdir(sys.argv[1]):
+        print("Usage: %s <directory>" % (sys.argv[0]))
+        sys.exit(1)
+
+    write_repository_v1(sys.argv[1])
+    # write_repository_v2(sys.argv[1])
+
+    print("Repository created in %s" % sys.argv[1])

examples/python/updateinfo_gen_01.py

@@ -14,7 +14,7 @@ def generate():
     pkg.src = "foo.src.rpm"
     pkg.filename = "foo-1.2.3-1.rpm"
     pkg.sum = "123456789"
-    pkg.sum_type = cr.MD5
+    pkg.sum_type = cr.SHA256
     pkg.reboot_suggested = False
 
     col = cr.UpdateCollection()

examples/python/updateinfo_gen_02.py

@@ -15,7 +15,7 @@ def generate():
     pkg.src = "foo.src.rpm"
     pkg.filename = "foo-1.2.3-1.rpm"
     pkg.sum = "123456789"
-    pkg.sum_type = cr.MD5
+    pkg.sum_type = cr.SHA256
     pkg.reboot_suggested = False
 
     col = cr.UpdateCollection()

src/compression_wrapper.h

@@ -54,7 +54,7 @@ typedef enum {
     CR_CW_MODE_SENTINEL,        /*!< Sentinel of the list */
 } cr_OpenMode;
 
-/** Stat build about open content during compression (writting).
+/** Stat build about open content during compression (writing).
  */
 typedef struct {
     gint64          size;               /*!< Size of content */
@@ -87,7 +87,7 @@ typedef struct {
     void                *INNERFILE;     /*!< Pointer to underlying FILE */
     cr_OpenMode         mode;           /*!< Mode */
     cr_ContentStat      *stat;          /*!< Content stats */
-    cr_ChecksumCtx      *checksum_ctx;  /*!< Checksum contenxt */
+    cr_ChecksumCtx      *checksum_ctx;  /*!< Checksum context */
 } CR_FILE;
 
 #define CR_CW_ERR       -1      /*!< Return value - Error */

src/createrepo_c.c

@@ -1165,7 +1165,7 @@ main(int argc, char **argv)
                 fex_db_filename = g_strconcat(tmp_out_repo, "/filelists-ext.sqlite", NULL);
             oth_db_filename = g_strconcat(tmp_out_repo, "/other.sqlite", NULL);
         } else {
-            g_debug("Creating databases localy");
+            g_debug("Creating databases locally");
             const gchar *tmpdir = g_get_tmp_dir();
             pri_db_filename = g_build_filename(tmpdir, "primary.XXXXXX.sqlite", NULL);
             fil_db_filename = g_build_filename(tmpdir, "filelists.XXXXXX.sqlite", NULL);