Merge ubuntu-debuginfod:overhaul into ubuntu-debuginfod:master

[Sergio Durigan Junior]

This MP is the big overhaul/rewrite of ubuntu-debuginfod that we talked about.

There are many new things being done here, but most of the diff is basically code reorganization to make better use of Python's capabilities.

I'll try to make a list of important things to consider when reviewing this code:

1) I'm make heavy use of base classes for pollers and getters. Using pollers and as example:

- You will see that there is the most basic class, Poller, which implements only the necessary/common bits for a generic poller to operate.

- On top of it, there is a CommonLaunchpadPoller class, which extends Poller and implements generic methods for both a ddeb and a source package poller to work. The class also inherits from BaseLaunchpadClass, which follows the mixin design pattern and is useful because it provides a "launchpad_login" methods to classes that need this feature.

- On top of CommonLaunchpadPoller you will find the DdebPoller and SourcePackagePoller classes, which finally implement the necessary method (in this case, poll_artifacts) that will do the polling of their respective artifacts.

- PPAs are kind of a special beast, so they have their own base class (CommonPPAPoller) which is actually crafted to be used specifically in multiple-inheritance scenarios. This base class is used alongside both DdebPoller and SourcePackagePoller to implement the PPA methods to fetch ddebs and source packages (for public and private PPAs).

The design of getters follows exactly the same rationale.

2) You will find that I broke down the "poll_lp.py" service in two:

- The first one, "launchpad-poller.py", only performs the polling of artifacts from LP and adds them to a local database named "jobs2dispatch". It's important to say that this poller does *not* do any complex filtering to determine if the artifact is actually interesting for debuginfod or not; it simply dumps the contents of a getPublished{Sources,Binaries} call into the local table. This was required because the service was hitting some strange "Error 400" problems with LP, and part of the reason seemed to be the fact that "poll_lp.py" was performing too many calls to the API.

- There is a second service now, called "launchpad-dispatcher.py". This service is responsible for iterating over the entries of the "jobs2dispatch" table and determine if they are interesting to us. If positive, the service dispatches the job to Celery.

Currently, the dispatcher is a single service that runs sequentially over the table. Until now I haven't found any issues with this approach, but eventually I intend to transform "launchpad-dispatcher.py" into a Celery service as well, so that the processing & dispatching operations can be done in parallel.

3) This is now a Python package. You should be able to use virtualenv and pip to install it locally. I also revamped the README file and included instructions on how to set things up locally.

4) I disabled a bunch of pylint warnings that were, IMO, false positives in my case. pylint is happy with the code, as well as flake8 and mypy. But I'm open to suggestions/comments, of course.

5) The package now has a testsuite. It is aimed at unittesting so far, but it did help me catch a few silly mistakes when I was developing things. I consider the testsuite to be a WIP; I still want to add more tests and, eventually, work towards having a proper CI/CD setup (thanks for the idea, Athos!).

I think that's it. I'm not in a big hurry to get this approved/deployed, so I'm fine to wait if you would like to talk in person about the MP during the upcoming sprint.

[Athos Ribeiro (athos-ribeiro)]

Hi Sergio,

As we discussed before, I will review this one :)

[Sergio Durigan Junior (sergiodj)]

Thanks, Athos.

I'm marking this MP as WIP for now because I decided that it actually makes sense to work on debianizing the package now. I should have something ready by tomorrow.

[Sergio Durigan Junior (sergiodj)]

This is ready for review.

[Sergio Durigan Junior (sergiodj)]

A few more notes here:

1) The package has been debianized. It needs a version of setuptools that isn't available in Jammy, so I set up a special PPA where I keep "extra dependencies" needed to build the package. It's here:

  https://launchpad.net/~ubuntu-debuginfod-devs/+archive/ubuntu/ubuntu-debuginfod-deps/+packages

This means that you'll need to pass this PPA as an extra repository to sbuild locally.

2) I reorganized the way the services are located in the source tree. It should be clearer to determine what is part of the Python library and what is not.

[Athos Ribeiro (athos-ribeiro)]

Hi Sergio, as we discussed before, I injected my reviews as comments in https://code.launchpad.net/~athos-ribeiro/ubuntu-debuginfod/+git/ubuntu-debuginfod/+ref/overhaul.

This should now be complete.

Nice work refactoring the whole code base to make it way more pythonic!

As we discussed offline, I have a few suggestions in my comments, but overall, the work looks great and I see no reason to block deploying it due to any of the review points I raised!

LGTM!

review: Approve

diff --git a/README.md b/README.md
index a0f5d14..c74b164 100644
--- a/README.md
+++ b/README.md
@@ -12,8 +12,11 @@ python3-git
 python3-celery
 python3-launchpadlib
 python3-requests
+python3-requests-oauthlib
 python3-sdnotify
 python3-psycopg2
+python3-pytest (test-only)
+python3-freezegun (test-only)
 ```
 
 * Applications
@@ -27,10 +30,157 @@ postgresql*
    support Jammy.
 ```
 
-## Setup
+## Installation
+
+You can install the package from the following PPA:
+
+  https://launchpad.net/~ubuntu-debuginfod-devs/+archive/ubuntu/ubuntu-debuginfod
+
+## Manual setup
+
+Nowadays, it is strongly recommended to install the package directly
+from the PPA:
+
+  https://launchpad.net/~ubuntu-debuginfod-devs/+archive/ubuntu/ubuntu-debuginfod
+
+The `.deb` package will take care of setting (almost) everything up,
+and will provide instructions on how to configure anything that might
+be missing.  However, if you would like to set the package up
+manually, follow the instructions below.
+
+### Create user & clone repository
+
+First, create a user.  Currently the scripts are hardcoded to assume
+that the username is `mirror`, so let's create it:
+
+```
+# adduser --disabled-password mirror
+```
+
+For the sake of keeping things simple, we will assume that the
+`ubuntu-debuginfod` repository is cloned at
+`/home/mirror/ubuntu-debuginfod/`.
+
+`ubuntu-debuginfod` is a proper Python package, so you can install it
+using `virtualenv` and `pip`.  Make sure to install all the required
+dependencies before proceeding.
+
+Create the `ubuntu-debuginfod` directory under `~mirror/.config`:
+
+```
+# su - mirror
+$ mkdir -p $HOME/.config/ubuntu-debuginfod
+$ chmod -R 0700 $HOME/.config/
+```
+
+### Create mirror directory
+
+The scripts assume by default that the mirror directory (i.e., the
+directory where the debuginfo files will be saved) will be
+`/srv/debug-mirror/`.  Let's create it:
+
+```
+# mkdir -p /srv/debug-mirror/
+# chown -R mirror:mirror /srv/debug-mirror/
+```
+
+### Create a database
+
+Now, create the PostgreSQL database for the service:
 
 ```
 # su - postgres
 $ createuser -d mirror
 $ createdb -O mirror ubuntu-debuginfod
 ```
+
+### Configure RabbitMQ
+
+We will also need to tweak RabbitMQ's `consumer_timeout` to a higher
+value.
+
+```
+# cat >> /etc/rabbitmq/rabbitmq.conf << __EOF__
+# 3 hours
+consumer_timeout = 10800000
+__EOF__
+```
+
+Let's restart the service so that the new setting takes effect:
+
+```
+# systemctl restart rabbitmq.service
+```
+
+### Install the configuration files
+
+For now, you will need to manually install the configuration files.
+Let's do it:
+
+```
+# cd /etc/systemd/system/
+# ln -s /home/mirror/ubuntu-debuginfod/conf/ubuntu-debuginfod-celery.service
+# for file in dispatcher poller; do \
+  ln -s /home/mirror/ubuntu-debuginfod/conf/launchpad-${file}.service; \
+  ln -s /home/mirror/ubuntu-debuginfod/conf/launchpad-${file}.timer; \
+  done
+# cd /etc/default/
+# ln -s \ 
+  /home/mirror/ubuntu-debuginfod/conf/ubuntu-debuginfod-celery.default \
+  ubuntu-debuginfod-celery
+# ln -s \
+  /home/mirror/ubuntu-debuginfod/conf/ubuntu-debuginfod-launchpad-poller.default \
+  ubuntu-debuginfod-launchpad-poller
+```
+
+Feel free to make any adjustments to the `.default` files.
+
+### Start the service
+
+Now, let's reload the systemd daemon and start the Celery service:
+
+```
+# systemctl daemon-reload
+# systemctl start ubuntu-debuginfod-celery.service
+```
+
+Take a look at the logs to see if everything is OK.
+
+### Run the Launchpad poller for the first time
+
+To run the Launchpad poller, simply do:
+
+```
+systemctl start ubuntu-debuginfod-launchpad-poller.service
+```
+
+You might want to open another terminal and follow the service logs
+there.
+
+If you want to enable the systemd timer and have the poller be
+executed every 30 minutes, do:
+
+```
+systemctl enable ubuntu-debuginfod-launchpad-poller.timer
+```
+
+### Run the dispatcher
+
+Now that the initial polling has been done, you can run the
+dispatcher.
+
+```
+systemctl start ubuntu-debuginfod-launchpad-dispatcher.service
+```
+
+Again, you may want to check the logs from another terminal.
+
+If the poller was able to find any valid jobs to be dispatched, you
+should start seeing the `/srv/debug-mirror/` directory be populated.
+
+If you want to enable the systemd timer and have the dispatcher be
+executed every 30 minutes, do:
+
+```
+systemctl enable ubuntu-debuginfod-launchpad-dispatcher.timer
+```
diff --git a/conf/ubuntu-debuginfod-celery.default b/conf/ubuntu-debuginfod-celery.default
index 9f915b0..6741b04 100644
--- a/conf/ubuntu-debuginfod-celery.default
+++ b/conf/ubuntu-debuginfod-celery.default
@@ -1,5 +1,5 @@
 # App instance to use.
-CELERY_APP="debuginfod"
+CELERY_APP="ubuntu_debuginfod.debuginfod"
 
 # Extra command-line arguments to the worker.
 #
diff --git a/conf/ubuntu-debuginfod-celery.service b/conf/ubuntu-debuginfod-celery.service
index 37b1b9c..edbb388 100644
--- a/conf/ubuntu-debuginfod-celery.service
+++ b/conf/ubuntu-debuginfod-celery.service
@@ -10,7 +10,6 @@ User=mirror
 Group=mirror
 Environment=LP_CREDENTIALS_FILE=/home/mirror/.config/ubuntu-debuginfod/lp.cred
 EnvironmentFile=/etc/default/ubuntu-debuginfod-celery
-WorkingDirectory=/home/mirror/ubuntu-debuginfod/
 ExecStart=/usr/bin/celery -A ${CELERY_APP} worker --loglevel=${CELERYD_LOG_LEVEL} ${CELERYD_OPTS}
 Restart=always
 TimeoutStopSec=600
diff --git a/conf/ubuntu-debuginfod-launchpad-dispatcher.service b/conf/ubuntu-debuginfod-launchpad-dispatcher.service
new file mode 100644
index 0000000..169accf
--- /dev/null
+++ b/conf/ubuntu-debuginfod-launchpad-dispatcher.service
@@ -0,0 +1,24 @@
+[Unit]
+Description=Dispatcher for ubuntu-debuginfod
+After=network.target ubuntu-debuginfod-celery.service
+Requires=ubuntu-debuginfod-celery.service
+ConditionPathExists=/home/mirror/.config/ubuntu-debuginfod/lp.cred
+
+[Service]
+Type=oneshot
+User=mirror
+Group=mirror
+Environment=LP_CREDENTIALS_FILE=/home/mirror/.config/ubuntu-debuginfod/lp.cred
+ExecStart=/usr/bin/python3 /usr/share/ubuntu-debuginfod/services/launchpad-dispatcher.py
+PrivateDevices=true
+PrivateUsers=true
+ProtectKernelTunables=true
+ProtectControlGroups=true
+ProtectKernelLogs=true
+ProtectKernelModules=true
+MemoryDenyWriteExecute=true
+RestrictRealtime=true
+ReadOnlyPaths=/home/mirror/.config/ubuntu-debuginfod/
+
+[Install]
+WantedBy=multi-user.target
diff --git a/conf/ubuntu-debuginfod-launchpad-dispatcher.timer b/conf/ubuntu-debuginfod-launchpad-dispatcher.timer
new file mode 100644
index 0000000..e5cabd4
--- /dev/null
+++ b/conf/ubuntu-debuginfod-launchpad-dispatcher.timer
@@ -0,0 +1,10 @@
+[Unit]
+Description=Dispatch jobs for ubuntu-debuginfod
+
+[Timer]
+# Every 30 minutes
+OnCalendar=*:0/30
+Persistent=true
+
+[Install]
+WantedBy=timers.target
diff --git a/conf/ubuntu-debuginfod-poll-lp.default b/conf/ubuntu-debuginfod-launchpad-poller.default
similarity index 100%
rename from conf/ubuntu-debuginfod-poll-lp.default
rename to conf/ubuntu-debuginfod-launchpad-poller.default
diff --git a/conf/ubuntu-debuginfod-poll-lp.service b/conf/ubuntu-debuginfod-launchpad-poller.service
similarity index 87%
rename from conf/ubuntu-debuginfod-poll-lp.service
rename to conf/ubuntu-debuginfod-launchpad-poller.service
index a97ffb6..dd98d14 100644
--- a/conf/ubuntu-debuginfod-poll-lp.service
+++ b/conf/ubuntu-debuginfod-launchpad-poller.service
@@ -9,9 +9,8 @@ Type=oneshot
 User=mirror
 Group=mirror
 Environment=LP_CREDENTIALS_FILE=/home/mirror/.config/ubuntu-debuginfod/lp.cred
-EnvironmentFile=/etc/default/ubuntu-debuginfod-poll-lp
-WorkingDirectory=/home/mirror/ubuntu-debuginfod/
-ExecStart=/usr/bin/python3 /home/mirror/ubuntu-debuginfod/poll_launchpad.py
+EnvironmentFile=/etc/default/ubuntu-debuginfod-launchpad-poller
+ExecStart=/usr/bin/python3 /usr/share/ubuntu-debuginfod/services/launchpad-poller.py
 PrivateDevices=true
 PrivateUsers=true
 ProtectKernelTunables=true
diff --git a/conf/ubuntu-debuginfod-poll-lp.timer b/conf/ubuntu-debuginfod-launchpad-poller.timer
similarity index 100%
rename from conf/ubuntu-debuginfod-poll-lp.timer
rename to conf/ubuntu-debuginfod-launchpad-poller.timer
diff --git a/ddebgetter.py b/ddebgetter.py
deleted file mode 100644
index c441bc6..0000000
--- a/ddebgetter.py
+++ /dev/null
@@ -1,356 +0,0 @@
-#!/usr/bin/python3
-
-# Copyright (C) 2022 Canonical Ltd.
-
-# This program is free software: you can redistribute it and/or modify
-# it under the terms of the GNU General Public License as published by
-# the Free Software Foundation, either version 3 of the License, or
-# (at your option) any later version.
-
-# This program is distributed in the hope that it will be useful,
-# but WITHOUT ANY WARRANTY; without even the implied warranty of
-# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-# GNU General Public License for more details.
-
-# You should have received a copy of the GNU General Public License
-# along with this program.  If not, see <https://www.gnu.org/licenses/>.
-
-# Authors: Sergio Durigan Junior <[e-mail]>
-
-import os
-import lzma
-import tarfile
-import subprocess
-
-import tempfile
-
-from git import Git, Repo
-from git.exc import GitCommandError
-
-from debuggetter import DebugGetter, DebugGetterRetry, DEFAULT_MIRROR_DIR
-
-
-def _validate_generic_request(request):
-    """Validate a request coming from Celery.
-
-    :param dict[str, str] request: The dictionary containing the
-        request to be validated."""
-    if request is None:
-        raise TypeError("Invalid request (None)")
-    if request.get("architecture") is None:
-        raise TypeError("No 'architecture' in request")
-
-def validate_ddeb_request(request):
-    """Validate a request to fetch a ddeb from the main archive.
-
-    :param dict[str, str] request: The dictionary containing the
-        request to be validated."""
-    _validate_generic_request(request)
-    if request.get("ddeb_url") is None:
-        raise TypeError("No 'ddeb_url' in request")
-    if request["architecture"] == "source":
-        raise ValueError("Wrong request: source fetch")
-
-def validate_source_code_request(request):
-    """Validate a request to fetch a source package from the main
-    archive.
-
-    :param dict[str, str] request: The dictionary containing the
-        request to be validated."""
-    _validate_generic_request(request)
-    if request.get("source_urls") is None:
-        raise TypeError("No 'source_urls' in request")
-    if request["architecture"] != "source":
-        raise ValueError("Wrong request: ddeb fetch")
-
-
-class DdebGetter(DebugGetter):
-    """Get (fetch) a ddeb."""
-
-    def __init__(self, subdir="ddebs", mirror_dir=DEFAULT_MIRROR_DIR):
-        """Initialize the object.
-
-        See DebugGetter's __init__ for an explanation of the arguments."""
-        super().__init__(subdir=subdir, mirror_dir=mirror_dir)
-
-    def process_request(self, request):
-        """Process a request, usually coming from Celery.
-
-        :param dict[str, str] request: The dictionary containing the
-            information necessary to fetch this ddeb."""
-        validate_ddeb_request(request)
-        self.do_process_request(request)
-
-    def do_process_request(self, request, credentials=None):
-        """Perform the actual processing of the request.
-
-        :param dict[str, str] request: The dictionary containing the
-            information necessary to fetch this ddeb.
-
-        :param requests_oauthlib.OAuth1 credentials: The credentials
-            to be used when downloading the artifact from Launchpad.
-            Default is None, which means anonymous."""
-        self._logger.debug(f"Processing request to download ddeb: {request}")
-        self._download_ddeb(
-            request["source_package"],
-            request["component"],
-            request["ddeb_url"],
-            credentials=credentials,
-        )
-
-    def _download_ddeb(self, source_package, component, ddeb_url, credentials=None):
-        """Download a ddeb associated with a package.
-
-        :param str source_package: Source package name.
-
-        :param str component: Source package component.
-
-        :param str ddeb_url: The ddeb URL.
-
-        :param requests_oauthlib.OAuth1 credentials: The credentials
-            to be used when downloading the artifact from Launchpad.
-            Default is None, which means anonymous."""
-        savepath = self._make_savepath(source_package, component)
-        self._logger.debug(f"Downloading '{ddeb_url}' into '{savepath}'")
-        if credentials is not None:
-            self._logger.debug("Downloading with credentials")
-        self._download_from_lp(ddeb_url, savepath, credentials=credentials)
-
-
-# The function below was taken from git-ubuntu.  We need to make
-# sure we perform the same version -> tag transformation as it
-# does.
-def git_dep14_tag(version):
-    """Munge a version string according to http://dep.debian.net/deps/dep14/
-
-    :param str version: The version to be adjusted."""
-    version = version.replace("~", "_").replace(":", "%").replace("..", ".#.")
-    if version.endswith("."):
-        version = version + "#"
-    if version.endswith(".lock"):
-        pre, _, _ = version.partition(".lock")
-        version = pre + ".#lock"
-    return version
-
-
-def adjust_tar_filepath(tarinfo):
-    """Adjust the filepath for a TarInfo file.
-
-    This function is needed because TarFile.add strips the leading
-    slash from the filenames, so we have to workaround it by
-    re-adding the slash ourselves.
-
-    This function is intended to be used as a callback provided to
-    TarFile.add.
-
-    :param TarInfo tarinfo: The tarinfo."""
-    tarinfo.name = os.path.join("/", tarinfo.name)
-    return tarinfo
-
-
-class DdebSourceCodeGetter(DebugGetter):
-    """Get (fetch) the source code associated with a ddeb."""
-
-    def __init__(self, subdir="ddebs", mirror_dir=DEFAULT_MIRROR_DIR):
-        super().__init__(subdir=subdir, mirror_dir=mirror_dir)
-
-    def process_request(self, request):
-        """Process a request, usually coming from Celery.
-
-        :param dict[str, str] request: The dictionary containing the
-            information necessary to fetch this source code."""
-        validate_source_code_request(request)
-        self.do_process_request(request)
-
-    def do_process_request(self, request, fallback_to_git=True, credentials=None):
-        """Perform the actual processing of the request.
-
-        :param dict[str, str] request: The dictionary containing the
-            information necessary to fetch this source code.
-
-        :param requests_oauthlib.OAuth1 credentials: The credentials
-            to be used when downloading the artifact from Launchpad.
-            Default is None, which means anonymous."""
-        self._logger.debug(f"Processing request to download source code: {request}")
-        self._download_source_code(
-            request["source_package"],
-            request["version"],
-            request["component"],
-            request["source_urls"],
-            fallback_to_git=fallback_to_git,
-            credentials=credentials,
-        )
-
-    def _download_source_code_from_git(self, source_package, version, filepath):
-        """Download the source code using Launchpad's git repository.
-
-        :param str source_package: Source package name.
-
-        :param str version: Source package version.
-
-        :param str filepath: The full pathname where the resulting
-            source code tarball should be saved.
-
-        :rtype: bool
-
-        This method returns True when the operation succeeds, or False
-        *iff* the "git clone" command fails to run.  Otherwise, this
-        function will throw an exception."""
-        with tempfile.TemporaryDirectory(ignore_cleanup_errors=True) as source_dir:
-            g = Git()
-            git_dir = os.path.join(source_dir, f"{source_package}")
-            tag = "applied/" + git_dep14_tag(f"{version}")
-            self._logger.debug(
-                f"Cloning '{source_package}' git repo into '{git_dir}' (tag: '{tag}')"
-            )
-            try:
-                g.clone(
-                    f"https://git.launchpad.net/ubuntu/+source/{source_package}",
-                    git_dir,
-                    depth=1,
-                    branch=tag,
-                )
-            except GitCommandError as e:
-                # Couldn't perform the download.  Let's signal and
-                # bail out.
-                self._logger.warning(
-                    f"Could not clone git repo for '{source_package}': {e}"
-                )
-                return False
-            repo = Repo(git_dir)
-            prefix_path = os.path.join("/usr/src/", f"{source_package}-{version}/")
-            self._logger.debug(
-                f"Archiving git repo for '{source_package}-{version}' as '{filepath}'"
-            )
-            with tempfile.NamedTemporaryFile() as tmpfile:
-                with lzma.open(tmpfile.name, "w") as xzfile:
-                    repo.archive(xzfile, prefix=prefix_path, format="tar")
-                self._try_to_move_atomically(tmpfile.name, filepath)
-
-        return True
-
-    def _download_source_code_from_dsc(
-        self, source_package, version, filepath, source_urls, credentials=None
-    ):
-        """Download the source code using the .dsc file.
-
-        :param str source_package: Source package name.
-
-        :param str version: Source package version.
-
-        :param str filepath: The full pathname where the resulting
-            source code tarball should be saved.
-
-        :param list source_urls: List of URLs used to fetch the source
-            package.  This is usually the list returned by the
-            sourceFileUrls() Launchpad API call.
-
-        :param requests_oauthlib.OAuth1 credentials: The credentials
-            to be used when downloading the artifact from Launchpad.
-            Default is None, which means anonymous.
-
-        :rtype: bool
-        This method returns True when the operation succeeds, or False
-        *iff* the "dpkg-source -x" command fails to run.  Otherwise,
-        this function will throw an exception."""
-        with tempfile.TemporaryDirectory(ignore_cleanup_errors=True) as source_dir:
-            for url in source_urls:
-                self._download_from_lp(url, source_dir, credentials=credentials)
-
-            dscfile = None
-            for f in os.listdir(source_dir):
-                newf = os.path.join(source_dir, f)
-                if os.path.isfile(newf) and f.endswith(".dsc"):
-                    dscfile = newf
-                    break
-
-            if dscfile is None:
-                self._logger.warning(
-                    "Could not find .dsc file, even though it should exist."
-                )
-                return False
-
-            outdir = os.path.join(source_dir, "outdir")
-            self._logger.debug(f"Will call 'dpkg-source -x {dscfile} {outdir}'")
-            try:
-                subprocess.run(
-                    ["/usr/bin/dpkg-source", "-x", dscfile, outdir],
-                    cwd=source_dir,
-                    check=True,
-                )
-            except subprocess.CalledProcessError:
-                self._logger.warning(f"Call to 'dpkg-source -x' failed.")
-                return False
-
-            if not os.path.isdir(outdir):
-                self._logger.warning(
-                    f"'{outdir}' has not been created by 'dpkg-source -x'."
-                )
-                return False
-
-            prefix_path = os.path.join("/usr/src/", f"{source_package}-{version}/")
-
-            with tempfile.NamedTemporaryFile() as tmpfile:
-                with tarfile.open(tmpfile.name, "w:xz") as tfile:
-                    tfile.add(outdir, arcname=prefix_path, filter=adjust_tar_filepath)
-                self._try_to_move_atomically(tmpfile.name, filepath)
-
-            return True
-
-    def _download_source_code(
-        self,
-        source_package,
-        version,
-        component,
-        source_urls,
-        fallback_to_git=True,
-        credentials=None,
-    ):
-
-        """Download the source code for a package.
-
-        :param str source_package: Source package name.
-
-        :param str version: Source package version.
-
-        :param str component: Source package component.
-
-        :param list source_urls: List of source file URLS.
-
-        :param boolean fallback_to_git: Whether we should try to fetch
-            the source code using git if the regular approach (via
-            dget) fails.  Default to True.
-
-        :param requests_oauthlib.OAuth1 credentials: The credentials
-            to be used when downloading the artifact from Launchpad.
-            Default is None, which means anonymous."""
-        savepath = self._make_savepath(source_package, component)
-        txzfilepath = os.path.join(savepath, f"{source_package}-{version}.tar.xz")
-        if os.path.exists(txzfilepath):
-            self._logger.debug(f"'{txzfilepath}' already exists; doing nothing.")
-            return
-
-        if self._download_source_code_from_dsc(
-            source_package,
-            version,
-            txzfilepath,
-            source_urls,
-            credentials=credentials
-        ):
-            self._logger.info(
-                f"Downloaded source code from dsc for '{source_package}-{version}' as '{txzfilepath}'"
-            )
-            return
-
-        if fallback_to_git and self._download_source_code_from_git(
-            source_package, version, txzfilepath
-        ):
-            self._logger.info(
-                f"Downloaded source code from git for '{source_package}-{version}' as '{txzfilepath}'"
-            )
-            return
-
-        # In the (likely?) event that there is a problem with
-        # Launchpad, let's raise an exception signalling that we'd
-        # like to retry the task.
-        raise DebugGetterRetry()
diff --git a/ddebpoller.py b/ddebpoller.py
deleted file mode 100644
index 9883782..0000000
--- a/ddebpoller.py
+++ /dev/null
@@ -1,200 +0,0 @@
-#!/usr/bin/python3
-
-# Copyright (C) 2022 Canonical Ltd.
-
-# This program is free software: you can redistribute it and/or modify
-# it under the terms of the GNU General Public License as published by
-# the Free Software Foundation, either version 3 of the License, or
-# (at your option) any later version.
-
-# This program is distributed in the hope that it will be useful,
-# but WITHOUT ANY WARRANTY; without even the implied warranty of
-# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-# GNU General Public License for more details.
-
-# You should have received a copy of the GNU General Public License
-# along with this program.  If not, see <https://www.gnu.org/licenses/>.
-
-# Authors: Sergio Durigan Junior <[e-mail]>
-
-import os
-from urllib import parse
-import datetime
-from debugpoller import DebugPoller
-
-
-class DdebPoller(DebugPoller):
-    """Perform the Launchpad polling and obtain a list of ddebs and source
-    packages."""
-
-    def __init__(
-        self,
-        initial_interval=1,
-        force_initial_interval=False,
-        fetch_all_on_first_run=False,
-        dry_run=False,
-        anonymous=True,
-    ):
-        """Initialize the object using 'ddeb' as its name.
-
-        Look at DebugPoller's docstring for an explanation about the arguments."""
-        super().__init__(
-            initial_interval=initial_interval,
-            force_initial_interval=force_initial_interval,
-            fetch_all_on_first_run=fetch_all_on_first_run,
-            dry_run=dry_run,
-            anonymous=anonymous,
-        )
-
-    def get_ddebs(self, archive=None, ppainfo=None):
-        """Get the list of ddebs that have been published since the last
-        timestamp from Launchpad.
-
-        :param archive Launchpad archive: The Launchpad archive that
-            should be queried for new binaries.  Defaults to
-            self._main_archive.
-
-        :param ppainfo dict(str, str): A dictionary containing three
-            keys: "ppauser", "ppaname" and "isprivateppa".  It should
-            only be provided when dealing with a PPA; otherwise, the
-            default is None.
-
-        :rtype: dict, datetime.datetime
-
-        Return a dictionary containing all ddebs found, and also the
-        new timestamp that should then be recorded by calling
-        record_timestamp.
-
-        """
-        timestamp, real_timestamp = self._get_normal_and_real_timestamps()
-
-        if archive is None:
-            archive = self._main_archive
-
-        if ppainfo is None:
-            archive_label = f"'{archive.displayname}' archive"
-        else:
-            archive_label = f"ppa:{ppainfo['ppauser']}/{ppainfo['ppaname']} (private: {ppainfo['isprivateppa']})"
-
-        self._logger.info(f"Polling ddebs created since '{real_timestamp}' from {archive_label}")
-
-        result = []
-        latest_timestamp_created = timestamp
-        for pkg in archive.getPublishedBinaries(
-            order_by_date=True, created_since_date=real_timestamp
-        ):
-            if pkg.status not in ("Pending", "Published"):
-                continue
-            if not pkg.is_debug:
-                continue
-
-            ddeb_urls = pkg.binaryFileUrls()
-            if len(ddeb_urls) == 0:
-                # Safety check.
-                continue
-
-            if (
-                latest_timestamp_created is None
-                or pkg.date_created > latest_timestamp_created
-            ):
-                latest_timestamp_created = pkg.date_created
-
-            srcname = pkg.source_package_name
-            binname = pkg.binary_package_name
-            binver = pkg.binary_package_version
-            component = pkg.component_name
-
-            # We create one message (which will eventually become a
-            # Celery task) per ddeb.  This makes it easier later to do
-            # deduplication, and also has the benefit of making the
-            # downloading process more granular for multiple ddebs.
-            for url in ddeb_urls:
-                # Obtain the ddeb filename and its architecture.
-                ddeb = os.path.basename(parse.urlparse(url).path)
-                _, _, arch_and_extension = ddeb.split("_")
-                arch, _ = arch_and_extension.split(".")
-
-                msg = {
-                    "source_package": srcname,
-                    "binary_package": binname,
-                    "version": binver,
-                    "component": component,
-                    "ddeb_url": url,
-                    "ddeb_filename": ddeb,
-                    "architecture": arch,
-                }
-                if ppainfo is not None:
-                    msg.update(ppainfo)
-
-                result.append(msg)
-
-        return result, latest_timestamp_created
-
-    def get_sources(self, archive=None, ppainfo=None):
-        """Get the list of source packages that have been published since the
-        last timestamp from Launchpad.
-
-        :param archive Launchpad archive: The Launchpad archive that
-            should be queried for new sources.  Defaults to
-            self._main_archive.
-
-        :param ppainfo dict(str, str): A dictionary containing three
-            keys: "ppauser", "ppaname" and "isprivateppa".  It should
-            only be provided when dealing with a PPA; otherwise, the
-            default is None.
-
-        :rtype: dict, datetime.datetime
-
-        Return a dictionary containing all source packages found, and
-        also the new timestamp that should then be recorded by calling
-        record_timestamp.
-
-        """
-        timestamp, real_timestamp = self._get_normal_and_real_timestamps()
-
-        if archive is None:
-            archive = self._main_archive
-
-        if ppainfo is None:
-            archive_label = f"'{archive.displayname}' archive"
-        else:
-            archive_label = f"ppa:{ppainfo['ppauser']}/{ppainfo['ppaname']} (private: {ppainfo['isprivateppa']})"
-
-        self._logger.info(f"Polling source packages created since '{real_timestamp}' from {archive_label}")
-
-        result = []
-        latest_timestamp_created = timestamp
-        for pkg in archive.getPublishedSources(
-            order_by_date=True, created_since_date=real_timestamp
-        ):
-            if pkg.status not in ("Pending", "Published"):
-                continue
-
-            src_urls = pkg.sourceFileUrls()
-            if len(src_urls) == 0:
-                # Safety check.
-                continue
-
-            if (
-                latest_timestamp_created is None
-                or pkg.date_created > latest_timestamp_created
-            ):
-                latest_timestamp_created = pkg.date_created
-
-            srcname = pkg.source_package_name
-            srcver = pkg.source_package_version
-            component = pkg.component_name
-
-            msg = {
-                "source_package": srcname,
-                "version": srcver,
-                "component": component,
-                "source_urls": src_urls,
-                "architecture": "source",
-            }
-            if ppainfo is not None:
-                msg.update(ppainfo)
-
-            result.append(msg)
-
-        return result, latest_timestamp_created
diff --git a/debian/changelog b/debian/changelog
new file mode 100644
index 0000000..ca2645a
--- /dev/null
+++ b/debian/changelog
@@ -0,0 +1,5 @@
+ubuntu-debuginfod (0.1.0) UNRELEASED; urgency=medium
+
+  * Initial Release.
+
+ -- Sergio Durigan Junior <[e-mail]>  Wed, 26 Apr 2023 15:20:29 -0400
diff --git a/debian/control b/debian/control
new file mode 100644
index 0000000..e2e8a88
--- /dev/null
+++ b/debian/control
@@ -0,0 +1,50 @@
+Source: ubuntu-debuginfod
+Section: devel
+Priority: optional
+Maintainer: Ubuntu Server <[e-mail]>
+Uploaders: Sergio Durigan Junior <[e-mail]>
+Build-Depends: debhelper-compat (= 13),
+               dh-python,
+               python3-setuptools,
+               pybuild-plugin-pyproject,
+               python3-all,
+               python3-git,
+               python3-celery,
+               python3-launchpadlib,
+               python3-requests,
+               python3-requests-oauthlib,
+               python3-sdnotify,
+               python3-psycopg2,
+               python3-pytest <!nocheck>,
+               python3-freezegun <!nocheck>,
+Standards-Version: 4.6.0
+Homepage: https://launchpad.net/ubuntu-debuginfod
+Vcs-Browser: https://git.launchpad.net/ubuntu-debuginfod
+Vcs-Git: https://git.launchpad.net/ubuntu-debuginfod
+#Testsuite: autopkgtest-pkg-python
+Rules-Requires-Root: no
+
+Package: ubuntu-debuginfod
+Architecture: all
+Pre-Depends: adduser, ucf
+Depends: ${python3:Depends},
+         ${misc:Depends},
+         python3-ubuntu-debuginfod (= ${source:Version}),
+Description: Scripts to poll/fetch artifacts for Ubuntu's debuginfod instance
+ This package offers a set of scripts and utilities that are used to
+ manage Ubuntu's debuginfod instance (<https://debuginfod.ubuntu.com>).
+
+Package: python3-ubuntu-debuginfod
+Section: python
+Architecture: all
+Depends: ${python3:Depends},
+         ${misc:Depends},
+         rabbitmq-server,
+         celery,
+         postgresql,
+Suggests: ubuntu-debuginfod (= ${source:Version})
+Description: Scripts to poll/fetch artifacts for Ubuntu's debuginfod instance (Python library)
+ This package offers a set of scripts and utilities that are used to
+ manage Ubuntu's debuginfod instance (<https://debuginfod.ubuntu.com>).
+ .
+ This is the Python library.
diff --git a/debian/copyright b/debian/copyright
new file mode 100644
index 0000000..7aec2cb
--- /dev/null
+++ b/debian/copyright
@@ -0,0 +1,29 @@
+Format: https://www.debian.org/doc/packaging-manuals/copyright-format/1.0/
+Upstream-Name: ubuntu-debuginfod
+Upstream-Contact: Sergio Durigan Junior <[e-mail]>
+Source: https://launchpad.net/ubuntu-debuginfod
+
+Files: *
+Copyright: 2022-2023 Canonical Ltd.
+License: GPL-3.0+
+
+Files: debian/*
+Copyright: 2022-2023 Canonical Ltd.
+License: GPL-3.0+
+
+License: GPL-3.0+
+ This program is free software: you can redistribute it and/or modify
+ it under the terms of the GNU General Public License as published by
+ the Free Software Foundation, either version 3 of the License, or
+ (at your option) any later version.
+ .
+ This package is distributed in the hope that it will be useful,
+ but WITHOUT ANY WARRANTY; without even the implied warranty of
+ MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ GNU General Public License for more details.
+ .
+ You should have received a copy of the GNU General Public License
+ along with this program. If not, see <https://www.gnu.org/licenses/>.
+ .
+ On Debian/Ubuntu systems, the complete text of the GNU General
+ Public License version 3 can be found in "/usr/share/common-licenses/GPL-3".
diff --git a/debian/rules b/debian/rules
new file mode 100755
index 0000000..f31c23e
--- /dev/null
+++ b/debian/rules
@@ -0,0 +1,19 @@
+#!/usr/bin/make -f
+
+export PYBUILD_NAME = ubuntu-debuginfod
+
+%:
+	dh $@ --with python3 --buildsystem=pybuild
+
+override_dh_auto_test:
+ifeq (,$(findstring nocheck,$(DEB_BUILD_OPTIONS)))
+	PYBUILD_SYSTEM=custom \
+		PYBUILD_TEST_ARGS="PYTHONPATH={build_dir} \
+			{interpreter} -m pytest -v" \
+		dh_auto_test
+endif
+
+override_dh_installsystemd:
+	dh_installsystemd --name=ubuntu-debuginfod-celery
+	dh_installsystemd --name=ubuntu-debuginfod-launchpad-poller --no-start --no-enable
+	dh_installsystemd --name=ubuntu-debuginfod-launchpad-dispatcher --no-start --no-enable
diff --git a/debian/source/format b/debian/source/format
new file mode 100644
index 0000000..89ae9db
--- /dev/null
+++ b/debian/source/format
@@ -0,0 +1 @@
+3.0 (native)
diff --git a/debian/source/options b/debian/source/options
new file mode 100644
index 0000000..cb61fa5
--- /dev/null
+++ b/debian/source/options
@@ -0,0 +1 @@
+extend-diff-ignore = "^[^/]*[.]egg-info/"
diff --git a/debian/ubuntu-debuginfod.install b/debian/ubuntu-debuginfod.install
new file mode 100644
index 0000000..52b779e
--- /dev/null
+++ b/debian/ubuntu-debuginfod.install
@@ -0,0 +1,3 @@
+services/ usr/share/ubuntu-debuginfod/
+conf/*.default usr/share/ubuntu-debuginfod/etc-default/
+utils/ usr/share/ubuntu-debuginfod/
diff --git a/debian/ubuntu-debuginfod.postinst b/debian/ubuntu-debuginfod.postinst
new file mode 100644
index 0000000..e01120c
--- /dev/null
+++ b/debian/ubuntu-debuginfod.postinst
@@ -0,0 +1,168 @@
+#!/bin/sh
+# postinst script for ubuntu-debuginfod
+#
+# see: dh_installdeb(1)
+
+set -e
+
+# summary of how this script can be called:
+#        * <postinst> `configure' <most-recently-configured-version>
+#        * <old-postinst> `abort-upgrade' <new version>
+#        * <conflictor's-postinst> `abort-remove' `in-favour' <package>
+#          <new-version>
+#        * <postinst> `abort-remove'
+#        * <deconfigured's-postinst> `abort-deconfigure' `in-favour'
+#          <failed-install-package> <version> `removing'
+#          <conflicting-package> <version>
+# for details, see https://www.debian.org/doc/debian-policy/ or
+# the debian-policy package
+
+# The user we will run the services as.
+UD_USER=$(grep '^User=' /lib/systemd/system/ubuntu-debuginfod-celery.service | cut -d= -f2)
+# The mirror directory.
+UD_MIRROR_DIR="/srv/debug-mirror"
+# The database name.
+UD_DB="ubuntu-debuginfod"
+# The location of the Launchpad credential file.
+UD_LP_CREDENTIAL_FILE=$(grep '^Environment=LP_CREDENTIALS_FILE' /lib/systemd/system/ubuntu-debuginfod-celery.service | cut -d= -f3)
+
+# Install the *.default files.
+install_etc_default_files()
+{
+    for file in celery launchpad-poller; do
+        ucf --three-way \
+            "/usr/share/ubuntu-debuginfod/etc-default/ubuntu-debuginfod-${file}.default" \
+            "/etc/default/ubuntu-debuginfod-${file}"
+        ucfr ubuntu-debuginfod \
+             "/etc/default/ubuntu-debuginfod-${file}"
+    done
+}
+
+# Create a user if it doesn't exist.
+create_user()
+{
+    if ! getent passwd "${UD_USER}" > /dev/null; then
+        adduser --quiet --disabled-password \
+                --gecos "ubuntu-debuginfod mirror user" \
+                "${UD_USER}"
+    fi
+
+    lpcreddir=$(dirname "${UD_LP_CREDENTIAL_FILE}")
+    if [ ! -d "${lpcreddir}" ]; then
+        mkdir -p "${lpcreddir}"
+        chown "${UD_USER}":"${UD_USER}" "${lpcreddir}"
+    fi
+}
+
+# Helper function to run commands as the postgres user.
+runuser_postgres()
+{
+    cd /tmp && runuser -u postgres -- "$@" && cd -
+}
+
+# Create the mirror directory if it doesn't exist.
+create_mirror_dir()
+{
+    if [ ! -d "${UD_MIRROR_DIR}" ]; then
+        mkdir -p "${UD_MIRROR_DIR}"
+        chown "${UD_USER}":"${UD_USER}" "${UD_MIRROR_DIR}"
+    fi
+}
+
+# Create the database user if it doesn't exist.
+create_database_user()
+{
+    if ! runuser_postgres psql postgres -tAc \
+         "SELECT 1 FROM pg_roles WHERE rolname='${UD_USER}'" | \
+            grep -qFx 1; then
+        runuser -u postgres -- createuser -d "${UD_USER}"
+    fi
+}
+
+# Create the database if it doesn't exist.
+create_database()
+{
+    create_database_user
+
+    if ! runuser_postgres psql -ltq | \
+            cut -d \| -f 1 | \
+            grep -qFw "${UD_DB}"; then
+        runuser_postgres createdb -O "${UD_USER}" "${UD_DB}"
+    fi
+}
+
+# Check that the recommended RabbitMQ configuration is present.  If it
+# isn't, display a warning.
+check_rabbitmq_configuration()
+{
+    rabconf="/etc/rabbitmq/rabbitmq.conf"
+    if [ -f "${rabconf}" ] && \
+           grep -q '^consumer_timeout' "${rabconf}"; then
+        return
+    fi
+
+    cat << __EOF__
+
+  * It is suggested that RabbitMQ be configured with the following option:
+
+    \$ cat ${rabconf}
+    consumer_timeout = 10800000
+__EOF__
+}
+
+# Obtain the Launchpad credentials.
+#
+# TODO: See if there's a way to allow the user to bail out.
+# obtain_launchpad_credentials()
+# {
+#     if [ ! -f "${UD_LP_CREDENTIAL_FILE}" ]; then
+#         /usr/share/ubuntu-debuginfod/utils/obtain-launchpad-credentials.py \
+#             "${UD_LP_CREDENTIAL_FILE}"
+#         chown "${UD_USER}":"${UD_USER}" "${UD_LP_CREDENTIAL_FILE}"
+#     fi
+# }
+
+# Check if the Launchpad credentials exist, and warn the user
+# otherwise.
+check_launchpad_credentials()
+{
+    if [ ! -f "${UD_LP_CREDENTIAL_FILE}" ]; then
+        cat << __EOF__
+
+  * The Launchpad credentials have not been obtained yet.  You need to
+    obtain them in order to properly start the services.  To do that,
+    please run:
+
+    \$ runuser -u ${UD_USER} -- \\
+       /usr/share/ubuntu-debuginfod/utils/obtain-launchpad-credentials.py \\
+       ${UD_LP_CREDENTIAL_FILE}
+__EOF__
+    fi
+}
+
+case "$1" in
+    configure)
+        install_etc_default_files
+        create_user
+        create_mirror_dir
+        create_database
+        check_rabbitmq_configuration
+        #obtain_launchpad_credentials
+        check_launchpad_credentials
+    ;;
+
+    abort-upgrade|abort-remove|abort-deconfigure)
+    ;;
+
+    *)
+        echo "postinst called with unknown argument \`$1'" >&2
+        exit 1
+    ;;
+esac
+
+# dh_installdeb will replace this with shell code automatically
+# generated by other debhelper scripts.
+
+#DEBHELPER#
+
+exit 0
diff --git a/debian/ubuntu-debuginfod.postrm b/debian/ubuntu-debuginfod.postrm
new file mode 100644
index 0000000..366eee5
--- /dev/null
+++ b/debian/ubuntu-debuginfod.postrm
@@ -0,0 +1,39 @@
+#!/bin/sh
+
+set -e
+
+purge_etc_default_files()
+{
+    for file in celery launchpad-poller; do
+        if command -v ucf > /dev/null; then
+            ucf --purge \
+                "/etc/default/ubuntu-debuginfod-${file}"
+        fi
+
+        if command -v ucfr > /dev/null; then
+            ucfr --purge ubuntu-debuginfod \
+                "/etc/default/ubuntu-debuginfod-${file}"
+        fi
+    done
+}
+
+case "$1" in
+    purge)
+        purge_etc_default_files
+	;;
+
+    remove|upgrade|failed-upgrade|abort-install|abort-upgrade|disappear)
+	;;
+
+    *)
+        echo "postrm called with unknown argument \`$1'" >&2
+        exit 1
+	;;
+esac
+
+# dh_installdeb will replace this with shell code automatically
+# generated by other debhelper scripts.
+
+#DEBHELPER#
+
+exit 0
diff --git a/debian/ubuntu-debuginfod.ubuntu-debuginfod-celery.service b/debian/ubuntu-debuginfod.ubuntu-debuginfod-celery.service
new file mode 120000
index 0000000..6537f37
--- /dev/null
+++ b/debian/ubuntu-debuginfod.ubuntu-debuginfod-celery.service
@@ -0,0 +1 @@
+../conf/ubuntu-debuginfod-celery.service
\ No newline at end of file
diff --git a/debian/ubuntu-debuginfod.ubuntu-debuginfod-launchpad-dispatcher.service b/debian/ubuntu-debuginfod.ubuntu-debuginfod-launchpad-dispatcher.service
new file mode 120000
index 0000000..9f7c034
--- /dev/null
+++ b/debian/ubuntu-debuginfod.ubuntu-debuginfod-launchpad-dispatcher.service
@@ -0,0 +1 @@
+../conf/ubuntu-debuginfod-launchpad-dispatcher.service
\ No newline at end of file
diff --git a/debian/ubuntu-debuginfod.ubuntu-debuginfod-launchpad-dispatcher.timer b/debian/ubuntu-debuginfod.ubuntu-debuginfod-launchpad-dispatcher.timer
new file mode 120000
index 0000000..a921a02
--- /dev/null
+++ b/debian/ubuntu-debuginfod.ubuntu-debuginfod-launchpad-dispatcher.timer
@@ -0,0 +1 @@
+../conf/ubuntu-debuginfod-launchpad-dispatcher.timer
\ No newline at end of file
diff --git a/debian/ubuntu-debuginfod.ubuntu-debuginfod-launchpad-poller.service b/debian/ubuntu-debuginfod.ubuntu-debuginfod-launchpad-poller.service
new file mode 120000
index 0000000..aae0131
--- /dev/null
+++ b/debian/ubuntu-debuginfod.ubuntu-debuginfod-launchpad-poller.service
@@ -0,0 +1 @@
+../conf/ubuntu-debuginfod-launchpad-poller.service
\ No newline at end of file
diff --git a/debian/ubuntu-debuginfod.ubuntu-debuginfod-launchpad-poller.timer b/debian/ubuntu-debuginfod.ubuntu-debuginfod-launchpad-poller.timer
new file mode 120000
index 0000000..253a01c
--- /dev/null
+++ b/debian/ubuntu-debuginfod.ubuntu-debuginfod-launchpad-poller.timer
@@ -0,0 +1 @@
+../conf/ubuntu-debuginfod-launchpad-poller.timer
\ No newline at end of file
diff --git a/debuggetter.py b/debuggetter.py
deleted file mode 100644
index e5500a7..0000000
--- a/debuggetter.py
+++ /dev/null
@@ -1,149 +0,0 @@
-#!/usr/bin/python3
-
-# Copyright (C) 2022 Canonical Ltd.
-
-# This program is free software: you can redistribute it and/or modify
-# it under the terms of the GNU General Public License as published by
-# the Free Software Foundation, either version 3 of the License, or
-# (at your option) any later version.
-
-# This program is distributed in the hope that it will be useful,
-# but WITHOUT ANY WARRANTY; without even the implied warranty of
-# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-# GNU General Public License for more details.
-
-# You should have received a copy of the GNU General Public License
-# along with this program.  If not, see <https://www.gnu.org/licenses/>.
-
-# Authors: Sergio Durigan Junior <[e-mail]>
-
-import os
-import requests
-from urllib import parse
-import logging
-import tempfile
-import shutil
-import re
-
-
-class DebugGetterTimeout(Exception):
-    """Default exception to raise when there's a timeout issue."""
-
-
-class DebugGetterRetry(Exception):
-    """Default exception to raise when we'd like to signal that the task
-    should be retried."""
-
-
-DEFAULT_MIRROR_DIR = "/srv/debug-mirror"
-
-
-class DebugGetter:
-    """Base class for a Debug Getter."""
-
-    def __init__(self, subdir, mirror_dir=DEFAULT_MIRROR_DIR):
-        """Initialize the object.
-
-        :param str mirror_dir: The directory we use to save the
-            mirrored files from Launchpad.
-
-        :param str subdir: The subdirectory (insider mirror_dir) where
-            the module will save its files.  For example, a ddeb
-            getter module should specify "ddebs" here."""
-        self._mirror_dir = mirror_dir
-        self._subdir = subdir
-        self._logger = logging.getLogger(__name__)
-
-    def _make_savepath(self, source_package, component):
-        """Return the full save path for a package.
-
-        :param str source_package: The package name.
-        :param str component: The component name (main, universe, etc.)."""
-        if source_package.startswith("lib"):
-            pkgname_initials = source_package[:4]
-        else:
-            pkgname_initials = source_package[0]
-
-        return os.path.join(
-            self._mirror_dir,
-            self._subdir,
-            component,
-            pkgname_initials,
-            source_package,
-        )
-
-    def _try_to_move_atomically(self, src, dst):
-        """Try to move SRC to DST atomically.
-
-        This function assumes that SRC and DST have different filenames.
-
-        :param str src: The source file (full path).
-
-        :param str dst: The destination file (full path)."""
-        self._logger.debug(f"Trying to move '{src}' to '{dst}' atomically")
-        savepath = os.path.dirname(dst)
-        os.makedirs(savepath, mode=0o755, exist_ok=True)
-        newtmpfile = os.path.join(savepath, os.path.basename(src))
-        shutil.copyfile(src, newtmpfile)
-        try:
-            shutil.move(newtmpfile, dst)
-        except shutil.SameFileError:
-            os.remove(newtmpfile)
-            self._logger.warning(
-                f"Could not create '{dst}' atomically: same file already exists"
-            )
-
-    def _download_from_lp(self, url, savepath, credentials=None):
-        """Download a file from Launchpad.
-
-        This method tries to download the file in chunks into a
-        temporary file and then does an atomic move to the final
-        destination.
-
-        :param str url: The URL that should be downloaded.
-
-        :param str savepath: The full path (minus the filename) where
-        the file should be saved.
-
-        :param requests_oauthlib.OAuth1 credentials: The credentials
-            to be used when downloading the artifact from Launchpad.
-            Default is None, which means anonymous."""
-        filepath = os.path.join(savepath, os.path.basename(parse.urlparse(url).path))
-        if os.path.exists(filepath):
-            self._logger.debug(f"'{filepath}' exists, doing nothing")
-            return
-
-        # Launchpad only accepts authenticated requests if we use
-        # 'https://api.launchpad.net...'
-        if credentials is not None:
-            url = re.sub(r"^https://launchpad.net/", "https://api.launchpad.net/devel/", url)
-
-        try:
-            with requests.Session() as s:
-                with s.get(
-                    url, allow_redirects=True, timeout=10, stream=True, auth=credentials
-                ) as r:
-                    r.raise_for_status()
-                    with tempfile.NamedTemporaryFile(mode="wb") as tmpfile:
-                        shutil.copyfileobj(r.raw, tmpfile)
-                        tmpfile.flush()
-                        self._try_to_move_atomically(tmpfile.name, filepath)
-        except (
-            requests.ConnectionError,
-            requests.HTTPError,
-            requests.ConnectTimeout,
-            requests.ReadTimeout,
-            requests.Timeout,
-        ) as e:
-            self._logger.warning(f"Timeout while downloading '{url}': '{e}'")
-            raise DebugGetterTimeout()
-
-        self._logger.debug(f"Saved '{filepath}'")
-
-    @property
-    def subdir(self):
-        return self._subdir
-
-    @subdir.setter
-    def subdir(self, subdir):
-        self._subdir = subdir
diff --git a/poll_launchpad.py b/poll_launchpad.py
deleted file mode 100644
index d8645a8..0000000
--- a/poll_launchpad.py
+++ /dev/null
@@ -1,198 +0,0 @@
-#!/usr/bin/python3
-
-# Copyright (C) 2022 Canonical Ltd.
-
-# This program is free software: you can redistribute it and/or modify
-# it under the terms of the GNU General Public License as published by
-# the Free Software Foundation, either version 3 of the License, or
-# (at your option) any later version.
-
-# This program is distributed in the hope that it will be useful,
-# but WITHOUT ANY WARRANTY; without even the implied warranty of
-# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-# GNU General Public License for more details.
-
-# You should have received a copy of the GNU General Public License
-# along with this program.  If not, see <https://www.gnu.org/licenses/>.
-
-# Authors: Sergio Durigan Junior <[e-mail]>
-
-import os
-from ddebpoller import DdebPoller
-from ppapoller import PPAPoller, PrivatePPAPoller
-from debuginfod import (
-    grab_ddebs,
-    grab_ddebs_sources,
-    grab_ppa_ddebs,
-    grab_ppa_sources,
-    grab_private_ppa_ddebs,
-    grab_private_ppa_sources,
-)
-from utils import DebugDB
-
-import psycopg2
-
-
-def _ensure_task(msg, conn, cursor):
-    """Return True if the task described by MSG should be processed.
-
-    Also, if True, then insert the task information into the database.
-
-    :param DebugDB conn: The database connection handler.
-
-    :param psycopg2.cursor cursor: The cursor to the SQL database.
-
-    :param dict msg: The message describing a task.
-
-    :rtype: int
-    :return: The taskid if the task should be processed (or None otherwise)."""
-    if msg["architecture"] == "source":
-        pkgname = msg["source_package"]
-    else:
-        pkgname = msg["binary_package"]
-    pkgver = msg["version"]
-    architecture = msg["architecture"]
-
-    if "ppauser" in msg.keys():
-        sql_select = "SELECT * FROM tasks WHERE source = %s AND version = %s AND arch = %s AND isfromppa = TRUE AND ppauser = %s AND ppaname = %s"
-        sql_insert = "INSERT INTO tasks (source, version, arch, isfromppa, ppauser, ppaname, created_date) VALUES (%s, %s, %s, TRUE, %s, %s, NOW()) RETURNING id"
-        sqlparams = (pkgname, pkgver, architecture, msg["ppauser"], msg["ppaname"])
-    else:
-        sql_select = "SELECT * FROM tasks WHERE source = %s AND version = %s AND arch = %s AND isfromppa = FALSE"
-        sql_insert = "INSERT INTO tasks (source, version, arch, isfromppa, created_date) VALUES (%s, %s, %s, FALSE, NOW()) RETURNING id"
-        sqlparams = (pkgname, pkgver, architecture)
-
-    cursor.execute(sql_select, sqlparams)
-
-    if cursor.rowcount > 0:
-        return None
-
-    cursor.execute(sql_insert, sqlparams)
-
-    taskid = cursor.fetchone()[0]
-    conn.commit()
-    return taskid
-
-
-def _process_msg(msg, conn, cursor):
-    """Add a task to the database to download the source or binary ddebs,
-    if it isn't there already.
-
-    :param str msg: The message to be processed.
-
-    :param DebugDB conn: The database connection handler.
-
-    :param psycopg2.cursor cursor: The cursor to the database.
-
-    """
-    taskid = _ensure_task(msg, conn, cursor)
-    if taskid is not None:
-        if msg.get("ppaname") is None:
-            ddeb_fn = grab_ddebs
-            src_fn = grab_ddebs_sources
-        elif msg["isprivateppa"] == "no":
-            ddeb_fn = grab_ppa_ddebs
-            src_fn = grab_ppa_sources
-        else:
-            ddeb_fn = grab_private_ppa_ddebs
-            src_fn = grab_private_ppa_sources
-
-        # We append the ID to the message so that we can efficiently
-        # remove the task once it's been processed.
-        msg["taskid"] = str(taskid)
-        if msg["architecture"] == "source":
-            # Source packages have "source" as their architecture.
-            src_fn.delay(msg)
-        else:
-            ddeb_fn.delay(msg)
-
-
-def _poll_launchpad_generic(poller, conn, cursor):
-    """Poll Launchpad and process the list of ddebs and source packages.
-
-    :param DebugDB conn: The SQL connection handler.
-
-    :param psycopg2.cursor cursor: The cursor to the SQL database."""
-
-    # Process ddebs.
-    messages, new_timestamp_ddebs = poller.get_ddebs()
-    for msg in messages:
-        _process_msg(msg, conn, cursor)
-
-    # Process source packages.
-    messages, new_timestamp_src = poller.get_sources()
-    for msg in messages:
-        _process_msg(msg, conn, cursor)
-
-    # Choose the earliest timestamp.
-    new_timestamp = min(new_timestamp_ddebs, new_timestamp_src)
-
-    poller.record_timestamp(new_timestamp)
-
-
-def _should_poll_archive(archive):
-    """Whether we should poll a certain archive.
-
-    This function relies on the value of environment variables named
-    "POLL_{archive}".  See the /etc/default/ubuntu-debuginfod-poll-lp
-    file for more details.
-
-    :param archive string: The archive name, in uppercase.
-
-    :rtype boolean: True if we should poll the archive, False
-        otherwise.
-    """
-    return os.environ.get(f"POLL_{archive.upper()}") == "yes"
-
-
-def poll_launchpad(conn, cursor):
-    """Poll Launchpad and process the list of ddebs and source packages
-    from the main archive.
-
-    :param DebugDB conn: The SQL connection handler.
-
-    :param psycopg2.cursor cursor: The cursor to the SQL database.
-
-    """
-    if _should_poll_archive("MAIN_ARCHIVE"):
-        _poll_launchpad_generic(DdebPoller(), conn, cursor)
-
-
-def poll_launchpad_ppas(conn, cursor):
-    """Poll Launchpad and process the list of ddebs and source packages
-    from PPAs.
-
-    :param DebugDB conn: The SQL connection handler.
-
-    :param psycopg2.cursor cursor: The cursor to the SQL database.
-
-    """
-    if _should_poll_archive("PPAS"):
-        _poll_launchpad_generic(PPAPoller(), conn, cursor)
-
-
-def poll_launchpad_private_ppas(conn, cursor):
-    """Poll Launchpad and process the list of ddebs and source packages
-    from private PPAs.
-
-    :param DebugDB conn: The SQL connection handler.
-
-    :param psycopg2.cursor cursor: The cursor to the SQL database.
-
-    """
-    if _should_poll_archive("PRIVATE_PPAS"):
-        _poll_launchpad_generic(PrivatePPAPoller(), conn, cursor)
-
-
-def main():
-    # Connect to the database.
-    with DebugDB() as db:
-        db.create_tables()
-        with db.cursor() as cursor:
-            poll_launchpad(db, cursor)
-            poll_launchpad_ppas(db, cursor)
-            poll_launchpad_private_ppas(db, cursor)
-
-
-if __name__ == "__main__":
-    main()
diff --git a/ppagetter.py b/ppagetter.py
deleted file mode 100644
index 0f0f323..0000000
--- a/ppagetter.py
+++ /dev/null
@@ -1,227 +0,0 @@
-#!/usr/bin/python3
-
-# Copyright (C) 2023 Canonical Ltd.
-
-# This program is free software: you can redistribute it and/or modify
-# it under the terms of the GNU General Public License as published by
-# the Free Software Foundation, either version 3 of the License, or
-# (at your option) any later version.
-
-# This program is distributed in the hope that it will be useful,
-# but WITHOUT ANY WARRANTY; without even the implied warranty of
-# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-# GNU General Public License for more details.
-
-# You should have received a copy of the GNU General Public License
-# along with this program.  If not, see <https://www.gnu.org/licenses/>.
-
-# Authors: Sergio Durigan Junior <[e-mail]>
-
-import os
-import configparser
-from ddebgetter import (
-    DdebGetter,
-    DdebSourceCodeGetter,
-    validate_ddeb_request,
-    validate_source_code_request,
-)
-from debuggetter import DebugGetterRetry, DEFAULT_MIRROR_DIR
-
-
-import requests_oauthlib
-from launchpadlib.launchpad import Credentials
-
-
-def _validate_generic_ppa_request(request):
-    """Validate a request to fetch an artifact from a PPA (private or
-    not).
-
-    :param dict[str, str] request: The dictionary containing the
-        request to be validated."""
-    if request.get("ppauser") is None:
-        raise TypeError("No 'ppauser' in request")
-    if request.get("ppaname") is None:
-        raise TypeError("No 'ppaname' in request")
-    if request.get("isprivateppa") is None:
-        raise TypeError("No 'isprivateppa' in request")
-
-
-def validate_ppa_ddeb_request(request):
-    """Validate a request to fetch a ddeb from a PPA.
-
-    :param dict[str, str] request: The dictionary containing the
-        request to be validated."""
-
-    validate_ddeb_request(request)
-    _validate_generic_ppa_request(request)
-    if request["isprivateppa"] == "yes":
-        raise ValueError("Wrong request: from private PPA")
-
-
-def validate_ppa_source_code_request(request):
-    """Validate a request to fetch a source package from a PPA.
-
-    :param dict[str, str] request: The dictionary containing the
-        request to be validated."""
-
-    validate_source_code_request(request)
-    _validate_generic_ppa_request(request)
-    if request["isprivateppa"] == "yes":
-        raise ValueError("Wrong request: from private PPA")
-
-
-def validate_private_ppa_ddeb_request(request):
-    """Validate a request to fetch a ddeb from a private PPA.
-
-    :param dict[str, str] request: The dictionary containing the
-        request to be validated."""
-
-    validate_ddeb_request(request)
-    _validate_generic_ppa_request(request)
-    if request["isprivateppa"] == "no":
-        raise ValueError("Wrong request: not from private PPA")
-
-
-def validate_private_ppa_source_code_request(request):
-    """Validate a request to fetch a source package from a private
-    PPA.
-
-    :param dict[str, str] request: The dictionary containing the
-        request to be validated."""
-    validate_source_code_request(request)
-    _validate_generic_ppa_request(request)
-    if request["isprivateppa"] == "no":
-        raise ValueError("Wrong request: not from private PPA")
-
-
-class PPADdebGetter(DdebGetter):
-    """Get a ddeb from a Launchpad PPA."""
-
-    def __init__(self, subdir="ppas", mirror_dir=DEFAULT_MIRROR_DIR):
-        """Initialize the object.
-
-        See DebugGetter's __init__ for an explanation of the arguments."""
-        super().__init__(subdir=subdir, mirror_dir=mirror_dir)
-
-    def process_request(self, request):
-        """Process a request, usually coming from Celery.
-
-        :param request: The dictionary containing the information
-            necessary to fetch this ddeb.
-        :type request: dict(str : str)"""
-        validate_ppa_ddeb_request(request)
-
-        # Adjust the subdirectory to account for the PPA name.
-        new_subdir = os.path.join(self._subdir, request["ppauser"], request["ppaname"])
-        self.subdir = new_subdir
-
-        self.do_process_request(request)
-
-
-class PPASourceCodeGetter(DdebSourceCodeGetter):
-    """Get source code from a Launchpad PPA."""
-
-    def __init__(self, subdir="ppas", mirror_dir=DEFAULT_MIRROR_DIR):
-        """Initialize the object.
-
-        See DebugGetter's __init__ for an explanation of the arguments."""
-        super().__init__(subdir=subdir, mirror_dir=mirror_dir)
-
-    def process_request(self, request):
-        """Process a request, usually coming from Celery.
-
-        :param request: The dictionary containing the information
-            necessary to fetch this source code.
-        :type request: dict(str : str)"""
-        validate_ppa_source_code_request(request)
-
-        # Adjust the subdirectory to account for the PPA name.
-        new_subdir = os.path.join(self._subdir, request["ppauser"], request["ppaname"])
-        self.subdir = new_subdir
-
-        self.do_process_request(request, fallback_to_git=False)
-
-
-def obtain_lp_oauth_credentials():
-    """Obtain the necessary OAuth credentials to perform authenticated
-    operations against Launchpad.
-
-    :rtype requests_oauthlib.OAuth1: The OAuth1 object containing the
-        Launchpad credentials."""
-    lpcredfile = os.environ.get("LP_CREDENTIALS_FILE")
-    if lpcredfile is None:
-        raise ValueError(
-            "Could not obtain Launchpad credentials: environment variable LP_CREDENTIALS_FILE must be set"
-        )
-    if not os.path.isfile(lpcredfile):
-        raise FileNotFoundError(
-            f"Could not obtain Launchpad credentials: file {lpcredfile} does not exist"
-        )
-
-    lpcred = Credentials()
-    with open(lpcredfile, "r", encoding="UTF-8") as f:
-        lpcred.load(f)
-
-    return requests_oauthlib.OAuth1(
-        lpcred.consumer.key,
-        client_secret=lpcred.consumer.secret,
-        resource_owner_key=lpcred.access_token.key,
-        resource_owner_secret=lpcred.access_token.secret,
-        signature_method="PLAINTEXT",
-    )
-
-
-class PrivatePPADdebGetter(PPADdebGetter):
-    """Get a ddeb from a private Launchpad PPA."""
-
-    def __init__(self, subdir="private-ppas", mirror_dir=DEFAULT_MIRROR_DIR):
-        """Initialize the object.
-
-        See DebugGetter's __init__ for an explanation of the arguments."""
-        super().__init__(subdir=subdir, mirror_dir=mirror_dir)
-
-    def process_request(self, request):
-        """Process a request, usually coming from Celery.
-
-        :param request: The dictionary containing the information
-            necessary to fetch this ddeb.
-        :type request: dict(str : str)"""
-        validate_private_ppa_ddeb_request(request)
-
-        ppauser = request["ppauser"]
-        ppaname = request["ppaname"]
-        creds = obtain_lp_oauth_credentials()
-
-        # Adjust the subdirectory to account for the PPA name.
-        new_subdir = os.path.join(self._subdir, ppauser, ppaname)
-        self.subdir = new_subdir
-
-        self.do_process_request(request, credentials=creds)
-
-
-class PrivatePPASourceCodeGetter(PPASourceCodeGetter):
-    """Get source code from a private Launchpad PPA."""
-
-    def __init__(self, subdir="private-ppas", mirror_dir=DEFAULT_MIRROR_DIR):
-        """Initialize the object.
-
-        See DebugGetter's __init__ for an explanation of the arguments."""
-        super().__init__(subdir=subdir, mirror_dir=mirror_dir)
-
-    def process_request(self, request):
-        """Process a request, usually coming from Celery.
-
-        :param request: The dictionary containing the information
-            necessary to fetch this source code.
-        :type request: dict(str : str)"""
-        validate_private_ppa_source_code_request(request)
-
-        ppauser = request["ppauser"]
-        ppaname = request["ppaname"]
-        creds = obtain_lp_oauth_credentials()
-
-        # Adjust the subdirectory to account for the PPA name.
-        new_subdir = os.path.join(self._subdir, ppauser, ppaname)
-        self.subdir = new_subdir
-
-        self.do_process_request(request, fallback_to_git=False, credentials=creds)
diff --git a/ppapoller.py b/ppapoller.py
deleted file mode 100644
index 27f844c..0000000
--- a/ppapoller.py
+++ /dev/null
@@ -1,191 +0,0 @@
-#!/usr/bin/python3
-
-# Copyright (C) 2023 Canonical Ltd.
-
-# This program is free software: you can redistribute it and/or modify
-# it under the terms of the GNU General Public License as published by
-# the Free Software Foundation, either version 3 of the License, or
-# (at your option) any later version.
-
-# This program is distributed in the hope that it will be useful,
-# but WITHOUT ANY WARRANTY; without even the implied warranty of
-# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-# GNU General Public License for more details.
-
-# You should have received a copy of the GNU General Public License
-# along with this program.  If not, see <https://www.gnu.org/licenses/>.
-
-# Authors: Sergio Durigan Junior <[e-mail]>
-
-import os
-import lazr.restfulclient.errors
-from ddebpoller import DdebPoller
-
-
-class PPAPoller(DdebPoller):
-    """Perform the Launchpad polling and obtain a list of ddebs and source
-    packages from a PPA."""
-
-    def __init__(
-        self,
-        initial_interval=1,
-        force_initial_interval=False,
-        fetch_all_on_first_run=True,
-        dry_run=False,
-        anonymous=True,
-    ):
-        """Initialize the object using 'ppa' as its name.
-
-        Look at DebugPoller's docstring for an explanation about the arguments."""
-        super().__init__(
-            initial_interval=initial_interval,
-            force_initial_interval=force_initial_interval,
-            fetch_all_on_first_run=fetch_all_on_first_run,
-            dry_run=dry_run,
-            anonymous=anonymous,
-        )
-
-    def _get_list_of_ppas(self, private=False):
-        """Get the list of PPAs to be polled.
-
-        :param private boolean: Whether the list will contain private
-            or non-private PPAs.  Default is False.
-
-        :rtype list: The list of PPAs.  This list will contain one
-            dictionary per PPA, with the following keys:
-                { "ppauser" : string,
-                  "ppaname" : string,
-                  "isprivateppa" : string }
-        """
-        ppafile = os.path.expanduser("~/.config/ubuntu-debuginfod/ppalist")
-        if private:
-            ppafile += "-private"
-
-        self._logger.debug(f"Processing '{ppafile}'")
-
-        if not os.path.isfile(ppafile):
-            self._logger.info(f"{ppafile} does not exist; doing nothing")
-            return []
-
-        ppas = []
-        with open(ppafile, "r", encoding="UTF-8") as f:
-            for ppa in f.readlines():
-                ppa = ppa.rstrip()
-                if ppa == "" or ppa.startswith("#"):
-                    continue
-                ppa = ppa.split(":")[1].split("/")
-                ppa_user = ppa[0]
-                ppa_name = ppa[1]
-                self._logger.info(f"Processing ppa:{ppa_user}/{ppa_name}")
-                ppas.append(
-                    {
-                        "ppauser": ppa_user,
-                        "ppaname": ppa_name,
-                        "isprivateppa": "yes" if private else "no",
-                    }
-                )
-        return ppas
-
-    def get_ddebs(self, private=False):
-        """Get the list of ddebs from Launchpad PPAs.
-
-        :param private boolean: Whether the PPAs are private or not.
-            Default is False.
-
-        :rtype dict, datetime.datetime:
-        Return a dictionary containing all source packages found, and
-        also the new timestamp that should then be recorded by calling
-        record_timestamp."""
-        messages = []
-        new_timestamp = self._generate_timestamp()
-        for ppa in self._get_list_of_ppas(private=private):
-            ppauser = ppa["ppauser"]
-            ppaname = ppa["ppaname"]
-            try:
-                lpuser = self._lp.people[ppauser]
-            except KeyError:
-                self._logger.error(f"Launchpad user {ppauser} does not exist")
-                continue
-
-            try:
-                lpppa = lpuser.getPPAByName(name=ppaname)
-            except lazr.restfulclient.errors.NotFound:
-                self._logger.error(
-                    f"Launchpad PPA ppa:{ppauser}/{ppaname} does not exist"
-                )
-                continue
-
-            self._logger.info(f"Getting list of ddebs from ppa:{ppauser}/{ppaname}")
-            msg, ts = super().get_ddebs(archive=lpppa, ppainfo=ppa)
-            messages += msg
-
-        return messages, new_timestamp
-
-    def get_sources(self, private=False):
-        """Get the list of source packages from Launchpad PPAs.
-
-        :param private boolean: Whether the PPAs are private or not.
-            Default is False.
-
-        :rtype dict, datetime.datetime:
-        Return a dictionary containing all source packages found, and
-        also the new timestamp that should then be recorded by calling
-        record_timestamp.
-
-        """
-        messages = []
-        new_timestamp = self._generate_timestamp()
-        for ppa in self._get_list_of_ppas(private=private):
-            ppauser = ppa["ppauser"]
-            ppaname = ppa["ppaname"]
-            try:
-                lpuser = self._lp.people[ppauser]
-            except KeyError:
-                self._logger.error(f"Launchpad user {ppauser} does not exist")
-                continue
-
-            try:
-                lpppa = lpuser.getPPAByName(name=ppaname)
-            except lazr.restfulclient.errors.NotFound:
-                self._logger.error(
-                    f"Launchpad PPA ppa:{ppauser}/{ppaname} does not exist"
-                )
-                continue
-
-            self._logger.info(f"Getting list of source packages from ppa:{ppauser}/{ppaname}")
-            msg, ts = super().get_sources(archive=lpppa, ppainfo=ppa)
-            messages += msg
-
-        return messages, new_timestamp
-
-
-class PrivatePPAPoller(PPAPoller):
-    """Perform the Launchpad polling and obtain a list of ddebs and source
-    packages from a private PPA."""
-
-    def __init__(
-        self,
-        initial_interval=1,
-        force_initial_interval=False,
-        fetch_all_on_first_run=True,
-        dry_run=False,
-        anonymous=False,
-    ):
-        """Initialize the object using 'privateppa' as its name.
-
-        Look at DebugPoller's docstring for an explanation about the arguments."""
-        super().__init__(
-            initial_interval=initial_interval,
-            force_initial_interval=force_initial_interval,
-            fetch_all_on_first_run=fetch_all_on_first_run,
-            dry_run=dry_run,
-            anonymous=anonymous,
-        )
-
-    def get_ddebs(self):
-        """Get the list of ddebs from private Launchpad PPAs."""
-        return super().get_ddebs(private=True)
-
-    def get_sources(self):
-        """Get the list of source packages from private Launchpad PPAs."""
-        return super().get_sources(private=True)
diff --git a/pyproject.toml b/pyproject.toml
new file mode 100644
index 0000000..b16fcbd
--- /dev/null
+++ b/pyproject.toml
@@ -0,0 +1,40 @@
+[build-system]
+requires = [ "setuptools >= 61.0.0" ]
+build-backend = "setuptools.build_meta"
+
+[project]
+name = "ubuntu_debuginfod"
+version = "0.1.0"
+authors = [
+  { name="Sergio Durigan Junior", email="[e-mail]" },
+]
+keywords = [ "ubuntu", "debuginfod" ]
+readme = "README.md"
+requires-python = ">= 3.7"
+classifiers = [
+  "Programming Language :: Python :: 3",
+  "Development Status :: 4 - Beta",
+  "Framework :: Celery",
+  "License :: OSI Approved :: GNU General Public License v3 or later (GPLv3+)",
+  "Operating System :: POSIX :: Linux",
+  "Topic :: Software Development :: Debuggers",
+]
+dependencies = [
+  "GitPython",
+  "celery",
+  "launchpadlib",
+  "requests",
+  "requests-oauthlib",
+  "sdnotify",
+  "psycopg2",
+]
+
+[project.optional-dependencies]
+tests = [
+  "pytest",
+  "freezegun",
+]
+
+[project.urls]
+"Homepage" = "https://launchpad.net/ubuntu-debuginfod"
+"Bug Tracker" = "https://bugs.launchpad.net/ubuntu-debuginfod"
diff --git a/services/launchpad-dispatcher.py b/services/launchpad-dispatcher.py
new file mode 100755
index 0000000..81bb754
--- /dev/null
+++ b/services/launchpad-dispatcher.py
@@ -0,0 +1,451 @@
+#!/usr/bin/python3
+
+# Copyright (C) 2022 Canonical Ltd.
+
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+
+# You should have received a copy of the GNU General Public License
+# along with this program.  If not, see <https://www.gnu.org/licenses/>.
+
+# Authors: Sergio Durigan Junior <[e-mail]>
+
+import os
+import time
+import logging
+from urllib import parse
+import lazr.restfulclient.errors
+import tempfile
+import gzip
+import re
+from ubuntu_debuginfod.utils.debugdb import DebugDB
+from ubuntu_debuginfod.utils.utils import download_from_lp, obtain_lp_oauth_credentials
+from ubuntu_debuginfod.utils.baselp import BaseLaunchpadClass
+from ubuntu_debuginfod.debuginfod import (
+    grab_ddebs,
+    grab_sources,
+    grab_ppa_ddebs,
+    grab_ppa_sources,
+    grab_private_ppa_ddebs,
+    grab_private_ppa_sources,
+)
+
+
+def ensure_task(msg, db, cursor):
+    """Return the task id if the task described by MSG should be
+    processed.
+
+    Also, if true, then insert the task information into the database.
+
+    :param DebugDB db: The database connection handler.
+
+    :param psycopg2.cursor cursor: The cursor to the SQL database.
+
+    :param dict[str -> str] msg: The message describing a task.
+
+    :rtype: int
+    :return: The taskid if the task should be processed (or None otherwise)."""
+    if msg["architecture"] == "source":
+        pkgname = msg["source_package"]
+    else:
+        pkgname = msg["binary_package"]
+    pkgver = msg["version"]
+    architecture = msg["architecture"]
+
+    if "ppauser" in msg.keys():
+        sql_select = "SELECT * FROM tasks WHERE source = %s AND version = %s AND arch = %s AND isfromppa = TRUE AND ppauser = %s AND ppaname = %s"
+        sql_insert = "INSERT INTO tasks (source, version, arch, isfromppa, ppauser, ppaname, created_date) VALUES (%s, %s, %s, TRUE, %s, %s, NOW()) RETURNING id"
+        sqlparams = (pkgname, pkgver, architecture, msg["ppauser"], msg["ppaname"])
+    else:
+        sql_select = "SELECT * FROM tasks WHERE source = %s AND version = %s AND arch = %s AND isfromppa = FALSE"
+        sql_insert = "INSERT INTO tasks (source, version, arch, isfromppa, created_date) VALUES (%s, %s, %s, FALSE, NOW()) RETURNING id"
+        sqlparams = (pkgname, pkgver, architecture)
+
+    cursor.execute(sql_select, sqlparams)
+
+    if cursor.rowcount > 0:
+        return None
+
+    cursor.execute(sql_insert, sqlparams)
+
+    taskid = cursor.fetchone()[0]
+    db.commit()
+    return taskid
+
+
+class LaunchpadDispatcher(BaseLaunchpadClass):
+    """Dispatch Launchpad jobs to be processed by the
+    ubuntu-debuginfod getters."""
+
+    SOURCE_PACKAGE_INDEXABLE_REGEX = re.compile(r"-fdebug-prefix-map=[^=]+=/usr/src/")
+
+    def __init__(self, anonymous):
+        """Initialize class.
+
+        :param bool anonymous: Whether we should log into Launchpad
+            anonymously or not."""
+        self._anonymous = anonymous
+        self._logger = logging.getLogger(__name__)
+        self.launchpad_login()
+
+    def _get_pkg(self, uri):
+        """Obtain the Launchpad entry associated with URI.
+
+        This function handles possible exceptions that might come from
+        Launchpad, and performs retries accordingly.
+
+        :param str uri: The URI associated with the package.
+
+        :rtype: lazr.restfulclient.resource.Entry
+        :return: The Launchpad object representing the package."""
+        retry = 0
+        while True:
+            try:
+                self._logger.debug(f"Obtaining package from URI '{uri}'")
+                pkg = self._lp.load(uri)
+            except (
+                lazr.restfulclient.errors.BadRequest,
+                lazr.restfulclient.errors.HTTPError,
+                lazr.restfulclient.errors.ServerError,
+                lazr.restfulclient.errors.UnexpectedResponseError,
+                lazr.restfulclient.errors.ResponseError,
+                IndexError,
+            ) as e:
+                self._logger.warning(
+                    f"Exception when obtaining information from URI '{uri}': {e}"
+                )
+                if retry >= 4:
+                    self._logger.warning(
+                        f"Maximum number of retries exceeded.  Raising {e}"
+                    )
+                    raise e
+                retry += 1
+                time.sleep(2)
+                continue
+            self._logger.debug(f"Obtained package information: '{pkg}'")
+            return pkg
+
+    def _remove_id_from_database(self, jobid, db, cursor):
+        """Helper function to remove a job ID from the database.
+
+        This function is invoked when the job is either invalid or
+        complete.
+
+        :param str jobid: The job ID.
+
+        :param DebugDB db: The database handler.
+
+        :param psycopg2.cursor cursor: The cursor to the database."""
+        self._logger.debug(f"Removing {jobid} from dispatcher table")
+        cursor.execute("DELETE FROM jobs2dispatch WHERE id = %s", (jobid,))
+        db.commit()
+
+    def _dispatch_binpkg_job(self, pkg, jobid, uri, ppainfo, db, cursor):
+        """Dispatch a job for a binary package package.
+
+        :param lazr.restfulclient.resource.Entry pkg: The binary
+            package object.
+
+        :param str jobid: The job ID.
+
+        :param str uri: The URI for this artifact.
+
+        :param dict[str -> str] ppainfo: The PPA information, if
+            applicable.
+
+        :param DebugDB db: The database handler.
+
+        :param psycopg2.cursor cursor: The cursor to the database.
+
+        :rtype bool:
+        :return: True if the package should be removed from the
+            database, False otherwise."""
+        self._logger.debug(
+            f"Processing binary package {pkg}, with ID {jobid}, ppainfo = {ppainfo}"
+        )
+        if not pkg.is_debug:
+            self._logger.debug(
+                f"Package {pkg} is not a debug package; nothing to be done"
+            )
+            return True
+
+        ddeb_urls = pkg.binaryFileUrls()
+        if len(ddeb_urls) == 0:
+            self._logger.debug(
+                f"Package {pkg} does not have binaryFileUrls associated with it"
+            )
+            return True
+
+        msg = {
+            "uri": uri,
+            "source_package": pkg.source_package_name,
+            "binary_package": pkg.binary_package_name,
+            "version": pkg.binary_package_version,
+            "component": pkg.component_name,
+            "ddeb_url": "",
+            "ddeb_filename": "",
+            "architecture": "",
+        }
+        if ppainfo is not None:
+            msg.update(ppainfo)
+
+        for url in ddeb_urls:
+            # Obtain the ddeb filename and its architecture.
+            ddeb = os.path.basename(parse.urlparse(url).path)
+            _, _, arch_and_extension = ddeb.split("_")
+            arch, _ = arch_and_extension.split(".")
+
+            msg["ddeb_url"] = url
+            msg["ddeb_filename"] = ddeb
+            msg["architecture"] = arch
+
+            taskid = ensure_task(msg, db, cursor)
+            if taskid is not None:
+                msg["taskid"] = str(taskid)
+                self._logger.debug(f"Dispatching the following message: {msg}")
+                # Do the actual dispatching here.
+                if ppainfo is None:
+                    grab_ddebs.delay(msg)
+                elif ppainfo["isprivateppa"] == "no":
+                    grab_ppa_ddebs.delay(msg)
+                else:
+                    grab_private_ppa_ddebs.delay(msg)
+
+        return True
+
+    def _srcpkg_is_indexable(self, binpkg):
+        """Check if the source package associated with the binary
+        package PKG is indexable, and mark it as such in the database.
+
+        This approach has a few downsides.  Namely, it relies on the
+        verboseness of build log files.  If the source package
+        "prettifies" the output of "make", we're doomed.  However,
+        this will have to do for now until we come up with a better
+        way to examine the ddebs.
+
+        :param lazr.restfulclient.resource.Entry binpkg: A Launchpad
+            object to a binary package associated with the source
+            package to be examined.
+
+        :rtype: bool
+        :return: True is the source package is indexable by
+        debuginfod, False otherwise."""
+        if not self._anonymous:
+            # It's currently impossible for us to check build logs of
+            # anonymous PPAs, so we just assume the source is
+            # indexable.  This should not be a big problem.
+            return True
+
+        credentials = None if self._anonymous else obtain_lp_oauth_credentials()
+        log_url = self._lp.load(binpkg.build_link).build_log_url
+        if not log_url:
+            return False
+        with tempfile.TemporaryDirectory() as tempdir:
+            logfile = download_from_lp(log_url, tempdir, credentials=credentials)
+            if not logfile.endswith(".txt.gz"):
+                return False
+            try:
+                with gzip.open(logfile, "rt") as f:
+                    for line in f:
+                        if re.search(self.SOURCE_PACKAGE_INDEXABLE_REGEX, line):
+                            return True
+            except gzip.BadGzipFile:
+                self._logger.warning(f"Could not un-gzip {logfile} (URL: {log_url})")
+        return False
+
+    def _dispatch_srcpkg_job(self, pkg, jobid, uri, ppainfo, db, cursor):
+        """Process a job for a source package.
+
+        :param lazr.restfulclient.resource.Entry pkg: The source
+            package object.
+
+        :param str jobid: The job ID.
+
+        :param str uri: The URI for this artifact.
+
+        :param dict[str -> str] ppainfo: The PPA information, if
+            applicable.
+
+        :param DebugDB db: The database handler.
+
+        :param psycopg2.cursor cursor: The cursor to the database.
+
+        :rtype bool:
+        :return: True if the package should be removed from the
+            database, False otherwise."""
+        self._logger.debug(
+            f"Processing source package {pkg}, with ID {jobid}, ppainfo = {ppainfo}"
+        )
+
+        srcpkgname = pkg.source_package_name
+        if srcpkgname.startswith("linux"):
+            # We know Linux tarballs are not indexable, so let's save
+            # time.
+            return True
+
+        src_urls = pkg.sourceFileUrls()
+        if len(src_urls) == 0:
+            self._logger.debug(
+                f"Package {pkg} does not have sourceFileUrls associated with it"
+            )
+            return True
+
+        # Check if the source package is actually indexable by
+        # debuginfod.
+        binpkgs = pkg.getPublishedBinaries()
+        if len(binpkgs) == 0:
+            # This means that no binary has been published yet.  We
+            # return without removing the ID from the database in
+            # order to make sure this source package will be
+            # re-evaluated later.
+            return False
+        if not self._srcpkg_is_indexable(binpkgs[0]):
+            # The package is not indexable.  Just remove it from the
+            # DB.
+            return True
+
+        msg = {
+            "uri": uri,
+            "source_package": srcpkgname,
+            "version": pkg.source_package_version,
+            "component": pkg.component_name,
+            "source_urls": src_urls,
+            "architecture": "source",
+        }
+
+        taskid = ensure_task(msg, db, cursor)
+        if taskid is not None:
+            msg["taskid"] = str(taskid)
+            self._logger.debug(f"Dispatching the following message: {msg}")
+            if ppainfo is None:
+                grab_sources.delay(msg)
+            else:
+                msg.update(ppainfo)
+                if ppainfo["isprivateppa"] == "no":
+                    grab_ppa_sources.delay(msg)
+                else:
+                    grab_private_ppa_sources.delay(msg)
+
+        return True
+
+    def _dispatch_pkg_job(self, pkg, jobid, uri, ppainfo, db, cursor):
+        """Process a job for a package.
+
+        This is a generic function that will call the respective
+        _dispatch_{srcpkg,binpkg}_job methods when applicable.
+
+        :param lazr.restfulclient.resource.Entry pkg: The package
+            object.
+
+        :param str jobid: The job ID.
+
+        :param str uri: The URI for this job.
+
+        :param dict[str -> str] ppainfo: The PPA information, if
+            applicable.
+
+        :param DebugDB db: The database handler.
+
+        :param psycopg2.cursor cursor: The cursor to the database."""
+        # We're only interested in packages that have been published
+        # or are pending publication.
+        if pkg.status in (
+            "Published",
+            "Pending",
+        ):
+            if "/+binarypub/" in uri:
+                self._logger.debug(f"Binary package {pkg} (ID {jobid}) detected")
+                if not self._dispatch_binpkg_job(pkg, jobid, uri, ppainfo, db, cursor):
+                    return
+            elif "/+sourcepub/" in uri:
+                self._logger.debug(f"Source package {pkg} (ID {jobid}) detected")
+                if not self._dispatch_srcpkg_job(pkg, jobid, uri, ppainfo, db, cursor):
+                    return
+            else:
+                raise ValueError(f"Invalid URI when processing package '{pkg}': {uri}")
+
+        self._remove_id_from_database(jobid, db, cursor)
+
+    def dispatch_jobs(self, db, cursor):
+        """Dispatch jobs.
+
+        This function goes over the existing jobs in the
+        "jobs2dispatch" table and filters out those jobs that are
+        interesting to debuginfod.  This means that the job must:
+
+          * Be related to debuginfo (ddebs) or source packages.
+
+          * Be public or private, depending on which dispatcher called
+            us.
+
+          * Be in a valid publication state (published or pending).
+
+        :param DebugDB db: The database handler.
+
+        :param psycopg2.cursor cursor: The cursor to the database."""
+        cursor.execute(
+            "SELECT id, uri, isfromppa, ppauser, ppaname FROM jobs2dispatch WHERE private = %s",
+            (not self._anonymous,),
+        )
+        results = cursor.fetchall()
+        self._logger.info(f"Starting to dispatch {len(results)} entries")
+        for (jobid, uri, isfromppa, ppauser, ppaname) in results:
+            try:
+                pkg = self._get_pkg(uri)
+            except Exception as e:
+                # Record the error and continue processing.  We don't
+                # delete the entry from the table in case we decide to
+                # retry it later.
+                cursor.execute(
+                    "INSERT INTO errors VALUES (%s, %s, NOW())", (uri, str(e))
+                )
+                continue
+
+            ppainfo = None
+            if isfromppa:
+                ppainfo = {
+                    "ppauser": ppauser,
+                    "ppaname": ppaname,
+                    "isprivateppa": "no" if self._anonymous else "yes",
+                }
+            self._dispatch_pkg_job(pkg, jobid, uri, ppainfo, db, cursor)
+
+
+class PublicLaunchpadDispatcher(LaunchpadDispatcher):
+    """Dispatch Launchpad public jobs.
+
+    Public here means that we don't need to log into Launchpad using
+    credentials."""
+
+    def __init__(self):
+        super().__init__(anonymous=True)
+
+
+class PrivateLaunchpadDispatcher(LaunchpadDispatcher):
+    """Dispatch Launchpad private jobs.
+
+    Private here means that we need to log into Launchpad using
+    credentials."""
+
+    def __init__(self):
+        super().__init__(anonymous=False)
+
+
+def main():
+    # Connect to the database.
+    with DebugDB() as db:
+        db.create_tables()
+        with db.cursor() as cursor:
+            PublicLaunchpadDispatcher().dispatch_jobs(db, cursor)
+            PrivateLaunchpadDispatcher().dispatch_jobs(db, cursor)
+
+
+if __name__ == "__main__":
+    main()
diff --git a/services/launchpad-poller.py b/services/launchpad-poller.py
new file mode 100755
index 0000000..e38f549
--- /dev/null
+++ b/services/launchpad-poller.py
@@ -0,0 +1,156 @@
+#!/usr/bin/python3
+
+# Copyright (C) 2022 Canonical Ltd.
+
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+
+# You should have received a copy of the GNU General Public License
+# along with this program.  If not, see <https://www.gnu.org/licenses/>.
+
+# Authors: Sergio Durigan Junior <[e-mail]>
+
+import os
+from ubuntu_debuginfod.pollers.ddebpoller import DdebPoller
+from ubuntu_debuginfod.pollers.sourcepackagepoller import SourcePackagePoller
+from ubuntu_debuginfod.pollers.ppaddebpoller import PPADdebPoller, PrivatePPADdebPoller
+from ubuntu_debuginfod.pollers.ppasourcepackagepoller import (
+    PPASourcePackagePoller,
+    PrivatePPASourcePackagePoller,
+)
+from ubuntu_debuginfod.utils.debugdb import DebugDB
+
+
+def _process_msg(msg, db, cursor):
+    """Add a task to the database to download the source or binary ddebs,
+    if it isn't there already.
+
+    :param str msg: The message to be processed.
+
+    :param DebugDB db: The database connection handler.
+
+    :param psycopg2.cursor cursor: The cursor to the database.
+
+    """
+    if "ppauser" in msg.keys():
+        sqlinsert = "INSERT INTO jobs2dispatch (uri, private, isfromppa, ppauser, ppaname, date) VALUES (%s, %s, %s, %s, %s, NOW())"
+        sqlvalues = (
+            msg["uri"],
+            msg["isprivateppa"] == "yes",
+            True,
+            msg["ppauser"],
+            msg["ppaname"],
+        )
+    else:
+        sqlinsert = "INSERT INTO jobs2dispatch (uri, private, isfromppa, date) VALUES (%s, %s, %s, NOW())"
+        sqlvalues = (msg["uri"], False, False)
+
+    cursor.execute(sqlinsert, sqlvalues)
+    db.commit()
+
+
+def _poll_launchpad_generic(poller, db, cursor):
+    """Poll Launchpad and process the list of ddebs and source packages.
+
+    :param DebugDB db: The SQL connection handler.
+
+    :param psycopg2.cursor cursor: The cursor to the SQL database."""
+
+    messages, timestamp = poller.poll_artifacts()
+    for msg in messages:
+        _process_msg(msg, db, cursor)
+
+    if timestamp is not None:
+        poller.record_timestamp(timestamp)
+    # # Process ddebs.
+    # messages, new_timestamp_ddebs = poller.get_ddebs()
+    # for msg in messages:
+    #     _process_msg(msg, db, cursor)
+
+    # # Process source packages.
+    # messages, new_timestamp_src = poller.get_sources()
+    # for msg in messages:
+    #     _process_msg(msg, db, cursor)
+
+    # # Choose the earliest timestamp.
+    # new_timestamp = min(new_timestamp_ddebs, new_timestamp_src)
+
+    # poller.record_timestamp(new_timestamp)
+
+
+def _should_poll_archive(archive):
+    """Whether we should poll a certain archive.
+
+    This function relies on the value of environment variables named
+    "POLL_{archive}".  See the /etc/default/ubuntu-debuginfod-poll-lp
+    file for more details.
+
+    :param archive string: The archive name, in uppercase.
+
+    :rtype: boolean
+
+    :return: True if we should poll the archive, False otherwise."""
+    return os.environ.get(f"POLL_{archive.upper()}") == "yes"
+
+
+def poll_launchpad(db, cursor):
+    """Poll Launchpad and process the list of ddebs and source packages
+    from the main archive.
+
+    :param DebugDB db: The SQL connection handler.
+
+    :param psycopg2.cursor cursor: The cursor to the SQL database.
+
+    """
+    if _should_poll_archive("MAIN_ARCHIVE"):
+        _poll_launchpad_generic(DdebPoller(), db, cursor)
+        _poll_launchpad_generic(SourcePackagePoller(), db, cursor)
+
+
+def poll_launchpad_ppas(db, cursor):
+    """Poll Launchpad and process the list of ddebs and source packages
+    from PPAs.
+
+    :param DebugDB db: The SQL connection handler.
+
+    :param psycopg2.cursor cursor: The cursor to the SQL database.
+
+    """
+    if _should_poll_archive("PPAS"):
+        _poll_launchpad_generic(PPADdebPoller(), db, cursor)
+        _poll_launchpad_generic(PPASourcePackagePoller(), db, cursor)
+
+
+def poll_launchpad_private_ppas(db, cursor):
+    """Poll Launchpad and process the list of ddebs and source packages
+    from private PPAs.
+
+    :param DebugDB db: The SQL connection handler.
+
+    :param psycopg2.cursor cursor: The cursor to the SQL database.
+
+    """
+    if _should_poll_archive("PRIVATE_PPAS"):
+        _poll_launchpad_generic(PrivatePPADdebPoller(), db, cursor)
+        _poll_launchpad_generic(PrivatePPASourcePackagePoller(), db, cursor)
+
+
+def main():
+    # Connect to the database.
+    with DebugDB() as db:
+        db.create_tables()
+        with db.cursor() as cursor:
+            poll_launchpad(db, cursor)
+            poll_launchpad_ppas(db, cursor)
+            poll_launchpad_private_ppas(db, cursor)
+
+
+if __name__ == "__main__":
+    main()
diff --git a/setup.cfg b/setup.cfg
new file mode 100644
index 0000000..2f0184a
--- /dev/null
+++ b/setup.cfg
@@ -0,0 +1,14 @@
+[options]
+packages = find:
+include_package_data = True
+
+[flake8]
+# Ignore line-too-long
+extend-ignore = E501
+
+[mypy]
+# Ignore warning about missing packages when assessing imports.
+ignore_missing_imports = True
+
+[pylint.'MESSAGES CONTROL']
+disable = logging-fstring-interpolation,line-too-long,missing-module-docstring,too-many-arguments,import-error,invalid-name,too-few-public-methods,duplicate-code
diff --git a/tests/test_baselp.py b/tests/test_baselp.py
new file mode 100644
index 0000000..ba27670
--- /dev/null
+++ b/tests/test_baselp.py
@@ -0,0 +1,58 @@
+#!/usr/bin/python3
+
+# Copyright (C) 2023 Canonical Ltd.
+
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+
+# You should have received a copy of the GNU General Public License
+# along with this program.  If not, see <https://www.gnu.org/licenses/>.
+
+# Authors: Sergio Durigan Junior <[e-mail]>
+
+from unittest.mock import patch
+import unittest
+from ubuntu_debuginfod.utils import baselp
+
+
+class FakeArchive:
+    """A fake Launchpad archive object."""
+
+    def __init__(self):
+        self.main_archive = []
+
+
+class FakeLaunchpad:
+    """A fake Launchpad object."""
+
+    def __init__(self):
+        self.distributions = {"ubuntu": FakeArchive()}
+
+
+@patch(
+    "launchpadlib.launchpad.Launchpad.login_anonymously", return_value=FakeLaunchpad()
+)
+@patch("launchpadlib.launchpad.Launchpad.login_with", return_value=FakeLaunchpad())
+class TestBaseLP(baselp.BaseLaunchpadClass):
+    def test_anonymous_login(self, mock_login_with, mock_login_anon):
+        self._anonymous = True
+        self.launchpad_login()
+        assert mock_login_anon.called is True
+        assert mock_login_with.called is False
+
+    def test_non_anonymous_login(self, mock_login_with, mock_login_anon):
+        self._anonymous = False
+        self.launchpad_login()
+        assert mock_login_anon.called is False
+        assert mock_login_with.called is True
+
+
+if __name__ == "__main__":
+    unittest.main()
diff --git a/tests/test_common_lp_getter.py b/tests/test_common_lp_getter.py
new file mode 100644
index 0000000..5663dc0
--- /dev/null
+++ b/tests/test_common_lp_getter.py
@@ -0,0 +1,91 @@
+#!/usr/bin/python3
+
+# Copyright (C) 2023 Canonical Ltd.
+
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+
+# You should have received a copy of the GNU General Public License
+# along with this program.  If not, see <https://www.gnu.org/licenses/>.
+
+# Authors: Sergio Durigan Junior <[e-mail]>
+
+import os
+import re
+import unittest
+import pytest
+from ubuntu_debuginfod.getters import common_lp_getter
+
+
+class TestCommonLaunchpadGetter:
+
+    VALID_GENERIC_REQ = {
+        "architecture": "amd64",
+        "uri": "URL",
+    }
+
+    def test_make_savepath_no_lib(self):
+        subdir = "test"
+        d = common_lp_getter.CommonLaunchpadGetter(subdir=subdir)
+        source_package = "foo"
+        component = "bar"
+        expected_path = os.path.join(
+            d.DEFAULT_MIRROR_DIR, subdir, component, source_package[0], source_package
+        )
+        assert d.make_savepath(source_package, component) == expected_path
+
+    def test_make_savepath_lib(self):
+        subdir = "test"
+        d = common_lp_getter.CommonLaunchpadGetter(subdir=subdir)
+        source_package = "libfoo"
+        component = "bar"
+        expected_path = os.path.join(
+            d.DEFAULT_MIRROR_DIR, subdir, component, source_package[:4], source_package
+        )
+        assert d.make_savepath(source_package, component) == expected_path
+
+    @pytest.mark.parametrize(
+        "req, exception, ex_message",
+        [
+            (None, TypeError, "Invalid request"),
+            ({"foo": "bar"}, ValueError, "No 'architecture' in request"),
+            (
+                {"architecture": None},
+                ValueError,
+                "Invalid 'architecture' (None) in request",
+            ),
+            ({"architecture": "amd64"}, ValueError, "No 'uri' in request"),
+            (
+                {"architecture": "amd64", "uri": None},
+                ValueError,
+                "Invalid 'uri' (None) in request",
+            ),
+        ],
+    )
+    def test_validate_request_invalid_request(self, req, exception, ex_message):
+        d = common_lp_getter.CommonLaunchpadGetter(subdir="test")
+        with pytest.raises(exception, match=re.escape(ex_message)):
+            d.validate_request(req)
+
+    def test_validate_request_valid_request(self):
+        d = common_lp_getter.CommonLaunchpadGetter(subdir="test")
+        assert d.validate_request(self.VALID_GENERIC_REQ) is None
+
+    def test_download_artifact_raises_notimplemented(self):
+        d = common_lp_getter.CommonLaunchpadGetter(subdir="test")
+        with pytest.raises(
+            NotImplementedError,
+            match=re.escape("Wrong call to 'download_artifact' from base class"),
+        ):
+            d.download_artifact()
+
+
+if __name__ == "__main__":
+    unittest.main()
diff --git a/tests/test_common_ppa_getter.py b/tests/test_common_ppa_getter.py
new file mode 100644
index 0000000..8eb736a
--- /dev/null
+++ b/tests/test_common_ppa_getter.py
@@ -0,0 +1,112 @@
+#!/usr/bin/python3
+
+# Copyright (C) 2023 Canonical Ltd.
+
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+
+# You should have received a copy of the GNU General Public License
+# along with this program.  If not, see <https://www.gnu.org/licenses/>.
+
+# Authors: Sergio Durigan Junior <[e-mail]>
+
+import re
+import pytest
+import unittest
+from ubuntu_debuginfod.getters import common_ppa_getter
+
+
+class MockValidateRequest:
+    def validate_request(self, request):
+        pass
+
+
+class MockCommonPPAGetter(common_ppa_getter.CommonPPAGetter, MockValidateRequest):
+    def __init__(self):
+        super().__init__()
+
+
+class TestCommonPPAGetter:
+    @pytest.mark.parametrize(
+        "req, exception, ex_message",
+        [
+            (
+                {"architecture": "amd64", "uri": "URL", "ddeb_url": "URL"},
+                TypeError,
+                "No 'ppauser' in request",
+            ),
+            (
+                {
+                    "architecture": "amd64",
+                    "ddeb_url": "URL",
+                    "uri": "URL",
+                    "ppauser": "foo",
+                },
+                TypeError,
+                "No 'ppaname' in request",
+            ),
+            (
+                {
+                    "architecture": "amd64",
+                    "uri": "URL",
+                    "ddeb_url": "URL",
+                    "ppauser": "foo",
+                    "ppaname": "bar",
+                },
+                TypeError,
+                "No 'isprivateppa' in request",
+            ),
+            (
+                {
+                    "architecture": "amd64",
+                    "uri": "URL",
+                    "ddeb_url": "URL",
+                    "ppauser": None,
+                    "ppaname": "bar",
+                    "isprivateppa": "no",
+                },
+                ValueError,
+                "Invalid 'ppauser' (None) in request",
+            ),
+            (
+                {
+                    "architecture": "amd64",
+                    "uri": "URL",
+                    "ddeb_url": "URL",
+                    "ppauser": "foo",
+                    "ppaname": None,
+                    "isprivateppa": "no",
+                },
+                ValueError,
+                "Invalid 'ppaname' (None) in request",
+            ),
+            (
+                {
+                    "architecture": "amd64",
+                    "uri": "URL",
+                    "ddeb_url": "URL",
+                    "ppauser": "foo",
+                    "ppaname": "bar",
+                    "isprivateppa": None,
+                },
+                ValueError,
+                "Invalid 'isprivateppa' (None) in request",
+            ),
+        ],
+    )
+    def test_validate_generic_ppa_request_invalid_request(
+        self, req, exception, ex_message
+    ):
+        with pytest.raises(exception, match=re.escape(ex_message)):
+            MockCommonPPAGetter().validate_request(req)
+
+
+if __name__ == "__main__":
+    unittest.main()
diff --git a/tests/test_ddebgetter.py b/tests/test_ddebgetter.py
new file mode 100644
index 0000000..3a67894
--- /dev/null
+++ b/tests/test_ddebgetter.py
@@ -0,0 +1,64 @@
+#!/usr/bin/python3
+
+# Copyright (C) 2023 Canonical Ltd.
+
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+
+# You should have received a copy of the GNU General Public License
+# along with this program.  If not, see <https://www.gnu.org/licenses/>.
+
+# Authors: Sergio Durigan Junior <[e-mail]>
+
+import re
+import pytest
+import unittest
+from ubuntu_debuginfod.getters import ddebgetter
+
+
+class TestDdebGetter:
+
+    VALID_DDEB_REQ = {
+        "architecture": "amd64",
+        "ddeb_url": "URL",
+        "uri": "URL",
+    }
+
+    def test_validate_ddeb_request_valid_request(self):
+        assert ddebgetter.DdebGetter().validate_request(self.VALID_DDEB_REQ) is None
+
+    @pytest.mark.parametrize(
+        "req, exception, ex_message",
+        [
+            (None, TypeError, "Invalid request"),
+            (
+                {"architecture": "amd64", "uri": "URL", "foo": "bar"},
+                TypeError,
+                "No 'ddeb_url' in request",
+            ),
+            (
+                {"architecture": "amd64", "uri": "URL", "ddeb_url": None},
+                ValueError,
+                "Invalid 'ddeb_url' (None) in request",
+            ),
+            (
+                {"architecture": "source", "uri": "URL", "ddeb_url": "URL"},
+                ValueError,
+                "Wrong request: source fetch",
+            ),
+        ],
+    )
+    def test_validate_ddeb_request_invalid_request(self, req, exception, ex_message):
+        with pytest.raises(exception, match=re.escape(ex_message)):
+            ddebgetter.DdebGetter().validate_request(req)
+
+
+if __name__ == "__main__":
+    unittest.main()
diff --git a/tests/test_exceptions.py b/tests/test_exceptions.py
new file mode 100644
index 0000000..0a64163
--- /dev/null
+++ b/tests/test_exceptions.py
@@ -0,0 +1,33 @@
+#!/usr/bin/python3
+
+# Copyright (C) 2023 Canonical Ltd.
+
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+
+# You should have received a copy of the GNU General Public License
+# along with this program.  If not, see <https://www.gnu.org/licenses/>.
+
+# Authors: Sergio Durigan Junior <[e-mail]>
+
+import unittest
+from ubuntu_debuginfod.utils import exceptions
+
+
+class TestExceptions:
+    def test_timeout_exception_inherits_ok(self):
+        assert issubclass(exceptions.UbuntuDebuginfodTimeout, Exception)
+
+    def test_retry_exception_inherits_ok(self):
+        assert issubclass(exceptions.UbuntuDebuginfodRetry, Exception)
+
+
+if __name__ == "__main__":
+    unittest.main()
diff --git a/tests/test_getter.py b/tests/test_getter.py
new file mode 100644
index 0000000..933370c
--- /dev/null
+++ b/tests/test_getter.py
@@ -0,0 +1,38 @@
+#!/usr/bin/python3
+
+# Copyright (C) 2023 Canonical Ltd.
+
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+
+# You should have received a copy of the GNU General Public License
+# along with this program.  If not, see <https://www.gnu.org/licenses/>.
+
+# Authors: Sergio Durigan Junior <[e-mail]>
+
+import unittest
+from ubuntu_debuginfod import getter
+
+
+class TestGetter:
+    def test_getter_get_subdir(self):
+        subdir = "test"
+        d = getter.Getter(subdir=subdir)
+        assert d.subdir == subdir
+
+    def test_getter_set_subdir(self):
+        d = getter.Getter(subdir="test")
+        newsubdir = "newtest"
+        d.subdir = newsubdir
+        assert d.subdir == newsubdir
+
+
+if __name__ == "__main__":
+    unittest.main()
diff --git a/tests/test_ppaddebgetter.py b/tests/test_ppaddebgetter.py
new file mode 100644
index 0000000..3ca3dd1
--- /dev/null
+++ b/tests/test_ppaddebgetter.py
@@ -0,0 +1,94 @@
+#!/usr/bin/python3
+
+# Copyright (C) 2023 Canonical Ltd.
+
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+
+# You should have received a copy of the GNU General Public License
+# along with this program.  If not, see <https://www.gnu.org/licenses/>.
+
+# Authors: Sergio Durigan Junior <[e-mail]>
+
+import re
+import pytest
+import unittest
+from ubuntu_debuginfod.getters import ppaddebgetter
+
+
+class TestPPADdebGetter:
+
+    VALID_PUBLIC_PPA_DDEB_REQ = {
+        "architecture": "amd64",
+        "ddeb_url": "URL",
+        "ppauser": "foo",
+        "ppaname": "bar",
+        "isprivateppa": "no",
+        "uri": "URL",
+    }
+
+    VALID_PRIVATE_PPA_DDEB_REQ = {
+        "architecture": "amd64",
+        "ddeb_url": "URL",
+        "ppauser": "foo",
+        "ppaname": "bar",
+        "isprivateppa": "yes",
+        "uri": "URL",
+    }
+
+    def test_validate_ppa_generic_valid_request(self):
+        assert (
+            ppaddebgetter.PPADdebGetter().validate_request(
+                self.VALID_PUBLIC_PPA_DDEB_REQ
+            )
+            is None
+        )
+        assert (
+            ppaddebgetter.PrivatePPADdebGetter().validate_request(
+                self.VALID_PRIVATE_PPA_DDEB_REQ
+            )
+            is None
+        )
+
+    def test_validate_ppa_ddeb_request_valid_request(self):
+        assert (
+            ppaddebgetter.PPADdebGetter().validate_request(
+                self.VALID_PUBLIC_PPA_DDEB_REQ
+            )
+            is None
+        )
+
+    def test_validate_ppa_ddeb_request_invalid_request(self):
+        with pytest.raises(
+            ValueError, match=re.escape("Wrong request: from private PPA")
+        ):
+            ppaddebgetter.PPADdebGetter().validate_request(
+                self.VALID_PRIVATE_PPA_DDEB_REQ
+            )
+
+    def test_validate_private_ppa_ddeb_request_valid_request(self):
+        assert (
+            ppaddebgetter.PrivatePPADdebGetter().validate_request(
+                self.VALID_PRIVATE_PPA_DDEB_REQ
+            )
+            is None
+        )
+
+    def test_validate_private_ddeb_request_invalid_request(self):
+        with pytest.raises(
+            ValueError, match=re.escape("Wrong request: not from private PPA")
+        ):
+            ppaddebgetter.PrivatePPADdebGetter().validate_request(
+                self.VALID_PUBLIC_PPA_DDEB_REQ
+            )
+
+
+if __name__ == "__main__":
+    unittest.main()
diff --git a/tests/test_ppasourcepackagegetter.py b/tests/test_ppasourcepackagegetter.py
new file mode 100644
index 0000000..aec5b95
--- /dev/null
+++ b/tests/test_ppasourcepackagegetter.py
@@ -0,0 +1,94 @@
+#!/usr/bin/python3
+
+# Copyright (C) 2023 Canonical Ltd.
+
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+
+# You should have received a copy of the GNU General Public License
+# along with this program.  If not, see <https://www.gnu.org/licenses/>.
+
+# Authors: Sergio Durigan Junior <[e-mail]>
+
+import re
+import pytest
+import unittest
+from ubuntu_debuginfod.getters import ppasourcepackagegetter
+
+
+class TestPPASourcePackageGetter:
+
+    VALID_PUBLIC_PPA_SOURCE_PACKAGE_REQ = {
+        "architecture": "source",
+        "source_urls": ["URL1", "URL2"],
+        "ppauser": "foo",
+        "ppaname": "bar",
+        "isprivateppa": "no",
+        "uri": "URL",
+    }
+
+    VALID_PRIVATE_PPA_SOURCE_PACKAGE_REQ = {
+        "architecture": "source",
+        "source_urls": ["URL1", "URL2"],
+        "ppauser": "foo",
+        "ppaname": "bar",
+        "isprivateppa": "yes",
+        "uri": "URL",
+    }
+
+    def test_validate_request_valid_request(self):
+        assert (
+            ppasourcepackagegetter.PPASourcePackageGetter().validate_request(
+                self.VALID_PUBLIC_PPA_SOURCE_PACKAGE_REQ
+            )
+            is None
+        )
+        assert (
+            ppasourcepackagegetter.PrivatePPASourcePackageGetter().validate_request(
+                self.VALID_PRIVATE_PPA_SOURCE_PACKAGE_REQ
+            )
+            is None
+        )
+
+    def test_validate_ppa_source_code_request_valid_request(self):
+        assert (
+            ppasourcepackagegetter.PPASourcePackageGetter().validate_request(
+                self.VALID_PUBLIC_PPA_SOURCE_PACKAGE_REQ
+            )
+            is None
+        )
+
+    def test_validate_ppa_source_code_request_invalid_request(self):
+        with pytest.raises(
+            ValueError, match=re.escape("Wrong request: from private PPA")
+        ):
+            ppasourcepackagegetter.PPASourcePackageGetter().validate_request(
+                self.VALID_PRIVATE_PPA_SOURCE_PACKAGE_REQ
+            )
+
+    def test_validate_private_ppa_source_code_request_valid_request(self):
+        assert (
+            ppasourcepackagegetter.PrivatePPASourcePackageGetter().validate_request(
+                self.VALID_PRIVATE_PPA_SOURCE_PACKAGE_REQ
+            )
+            is None
+        )
+
+    def test_validate_private_ppa_source_code_request_invalid_request(self):
+        with pytest.raises(
+            ValueError, match=re.escape("Wrong request: not from private PPA")
+        ):
+            ppasourcepackagegetter.PrivatePPASourcePackageGetter().validate_request(
+                self.VALID_PUBLIC_PPA_SOURCE_PACKAGE_REQ
+            )
+
+
+if __name__ == "__main__":
+    unittest.main()
diff --git a/tests/test_sourcepackagegetter.py b/tests/test_sourcepackagegetter.py
new file mode 100644
index 0000000..f82c4f7
--- /dev/null
+++ b/tests/test_sourcepackagegetter.py
@@ -0,0 +1,69 @@
+#!/usr/bin/python3
+
+# Copyright (C) 2023 Canonical Ltd.
+
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+
+# You should have received a copy of the GNU General Public License
+# along with this program.  If not, see <https://www.gnu.org/licenses/>.
+
+# Authors: Sergio Durigan Junior <[e-mail]>
+
+import re
+import pytest
+import unittest
+from ubuntu_debuginfod.getters import sourcepackagegetter
+
+
+class TestSourcePackageGetter:
+
+    VALID_SOURCE_PACKAGE_REQ = {
+        "architecture": "source",
+        "source_urls": [],
+        "uri": "URL",
+    }
+
+    def test_validate_request_valid_request(self):
+        assert (
+            sourcepackagegetter.SourcePackageGetter().validate_request(
+                self.VALID_SOURCE_PACKAGE_REQ
+            )
+            is None
+        )
+
+    @pytest.mark.parametrize(
+        "req, exception, ex_message",
+        [
+            (None, TypeError, "Invalid request"),
+            (
+                {"architecture": "source", "uri": "URL", "foo": "bar"},
+                TypeError,
+                "No 'source_urls' in request",
+            ),
+            (
+                {"architecture": "source", "uri": "URL", "source_urls": None},
+                ValueError,
+                "Invalid 'source_urls' (None) in request",
+            ),
+            (
+                {"architecture": "amd64", "uri": "URL", "source_urls": "URL"},
+                ValueError,
+                "Wrong request: ddeb fetch",
+            ),
+        ],
+    )
+    def test_validate_request_invalid_request(self, req, exception, ex_message):
+        with pytest.raises(exception, match=re.escape(ex_message)):
+            sourcepackagegetter.SourcePackageGetter().validate_request(req)
+
+
+if __name__ == "__main__":
+    unittest.main()
diff --git a/tests/test_utils.py b/tests/test_utils.py
new file mode 100644
index 0000000..7cac497
--- /dev/null
+++ b/tests/test_utils.py
@@ -0,0 +1,114 @@
+#!/usr/bin/python3
+
+# Copyright (C) 2023 Canonical Ltd.
+
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+
+# You should have received a copy of the GNU General Public License
+# along with this program.  If not, see <https://www.gnu.org/licenses/>.
+
+# Authors: Sergio Durigan Junior <[e-mail]>
+
+import os
+import re
+import unittest
+import datetime
+import tempfile
+import filecmp
+import pytest
+from freezegun import freeze_time
+from ubuntu_debuginfod.utils import utils
+
+
+class TestUtils:
+    def test_generate_timestamp_without_interval(self, *args):
+        curdate = datetime.datetime.now(datetime.timezone.utc)
+        with freeze_time(curdate):
+            ret = utils.generate_timestamp()
+            assert isinstance(ret, datetime.datetime)
+            assert ret == curdate
+
+    def test_generate_timestamp_with_interval(self, *args):
+        curdate = datetime.datetime.now(datetime.timezone.utc)
+        interval = 8
+        with freeze_time(curdate):
+            ret = utils.generate_timestamp(interval=interval)
+            assert isinstance(ret, datetime.datetime)
+            assert ret == curdate - datetime.timedelta(hours=interval)
+
+    @pytest.mark.skip(
+        reason="currently broken when dealing with files in the same directory"
+    )
+    def test_move_atomically_same_dir(self):
+        with tempfile.TemporaryDirectory() as tmp:
+            file1 = os.path.join(tmp, "file1")
+            file2 = os.path.join(tmp, "file2")
+
+            with open(file1, "w") as f:
+                f.write("This is a test")
+                f.flush()
+
+            utils.move_atomically(file1, file2)
+            filecmp.clear_cache()
+            assert filecmp.cmp(file1, file2, shallow=False)
+
+    def test_move_atomically_different_dirs(self):
+        with tempfile.TemporaryDirectory() as tmp1:
+            file1 = os.path.join(tmp1, "file1")
+            with open(file1, "w") as f:
+                f.write("This is a test")
+
+            with tempfile.TemporaryDirectory() as tmp2:
+                file2 = os.path.join(tmp2, "file2")
+
+                utils.move_atomically(file1, file2)
+                filecmp.clear_cache()
+                assert filecmp.cmp(file1, file2, shallow=False)
+
+    @pytest.mark.parametrize(
+        "version,expected_result",
+        [
+            ("1.0-1", "1.0-1"),
+            ("1.0-1~ppa1", "1.0-1_ppa1"),
+            ("2:1.0-1", "2%1.0-1"),
+            ("1.0..1", "1.0.#.1"),
+            ("1.0..1.", "1.0.#.1.#"),
+            ("1.0-1.lock", "1.0-1.#lock"),
+            ("3:1.0-1..~ppa1.lock", "3%1.0-1.#._ppa1.#lock"),
+        ],
+    )
+    def test_git_dep14_tag(self, version, expected_result):
+        assert utils.git_dep14_tag(version) == expected_result
+
+    def test_obtain_lp_oauth_credentials_no_LP_CREDENTIALS_FILE_set(self):
+        if "LP_CREDENTIALS_FILE" in os.environ:
+            del os.environ["LP_CREDENTIALS_FILE"]
+        with pytest.raises(
+            ValueError,
+            match=re.escape(
+                "Could not obtain Launchpad credentials: environment variable LP_CREDENTIALS_FILE must be set"
+            ),
+        ):
+            utils.obtain_lp_oauth_credentials()
+
+    def test_obtain_lp_oauth_credentials_LP_CREDENTIALS_FILE_invalid_file(self):
+        os.environ["LP_CREDENTIALS_FILE"] = "/path/to/nonexistent/file"
+        with pytest.raises(
+            FileNotFoundError,
+            match=re.escape(
+                "Could not obtain Launchpad credentials: file /path/to/nonexistent/file does not exist"
+            ),
+        ):
+            utils.obtain_lp_oauth_credentials()
+
+
+if __name__ == "__main__":
+    unittest.main()
diff --git a/ubuntu_debuginfod/__init__.py b/ubuntu_debuginfod/__init__.py
new file mode 100644
index 0000000..c63b042
--- /dev/null
+++ b/ubuntu_debuginfod/__init__.py
@@ -0,0 +1,10 @@
+"""Init."""
+
+import logging
+
+logging.basicConfig(
+    level=logging.INFO,
+    format=(
+        "%(levelname) -10s %(asctime)s %(name) -20s %(funcName) " "-25s : %(message)s"
+    ),
+)
diff --git a/debuginfod.py b/ubuntu_debuginfod/debuginfod.py
similarity index 61%
rename from debuginfod.py
rename to ubuntu_debuginfod/debuginfod.py
index ef39a95..54d73c9 100644
--- a/debuginfod.py
+++ b/ubuntu_debuginfod/debuginfod.py
@@ -24,18 +24,24 @@ from celery.signals import (
     task_postrun,
     celeryd_init,
 )
+import sdnotify
 
-from debuggetter import DebugGetterTimeout, DebugGetterRetry
-from ddebgetter import DdebGetter, DdebSourceCodeGetter
-from ppagetter import (
+from ubuntu_debuginfod.utils.exceptions import (
+    UbuntuDebuginfodRetry,
+    UbuntuDebuginfodTimeout,
+)
+from ubuntu_debuginfod.getters.ddebgetter import DdebGetter
+from ubuntu_debuginfod.getters.sourcepackagegetter import SourcePackageGetter
+from ubuntu_debuginfod.getters.ppaddebgetter import (
     PPADdebGetter,
-    PPASourceCodeGetter,
     PrivatePPADdebGetter,
-    PrivatePPASourceCodeGetter,
 )
-from utils import DebugDB
-
-import sdnotify
+from ubuntu_debuginfod.getters.ppasourcepackagegetter import (
+    PPASourcePackageGetter,
+    PrivatePPASourcePackageGetter,
+)
+from ubuntu_debuginfod.utils.debugdb import DebugDB
+from ubuntu_debuginfod.utils.utils import record_error_into_db
 
 app = Celery("debuginfod", broker="pyamqp://guest@localhost//")
 
@@ -55,29 +61,14 @@ app.conf.update(
 
 sdnotifier = sdnotify.SystemdNotifier()
 
-
-def _record_error_into_db(exc, msg):
-    """Record an error into the database.
-
-    :param Exception exc: The Exception that was triggered.
-
-    :param dict msg: The message that triggere the error."""
-    with DebugDB() as db:
-        with db.cursor() as cur:
-            cur.execute(
-                "INSERT INTO errors (task, exception, date) VALUES (%s, %s, NOW())",
-                (
-                    str(msg),
-                    str(exc),
-                ),
-            )
+# 1 day
+DEFAULT_RETRY_DELAY = 24 * 60 * 60
 
 
 @app.task(
     name="grab_ddebs",
-    autoretry_for=(DebugGetterTimeout, DebugGetterRetry),
-    # 1 day
-    default_retry_delay=24 * 60 * 60,
+    autoretry_for=(UbuntuDebuginfodTimeout, UbuntuDebuginfodRetry),
+    default_retry_delay=DEFAULT_RETRY_DELAY,
     # Launchpad can be problematic, so we retry every day for a
     # week.
     retry_kwargs={"max_retries": 7},
@@ -91,41 +82,40 @@ def grab_ddebs(msg):
         g = DdebGetter()
         g.process_request(msg)
     except Exception as e:
-        if not isinstance(e, DebugGetterRetry) and not isinstance(
-            e, DebugGetterTimeout
+        if not isinstance(e, UbuntuDebuginfodRetry) and not isinstance(
+            e, UbuntuDebuginfodTimeout
         ):
             # This is some other kind of error that we need to deal
             # with.  Mark it as such.
-            _record_error_into_db(e, msg)
+            record_error_into_db(e, msg)
         # We still need to raise the exception here.  Celery will
         # reschedule the task if applicable.
         raise e
 
 
 @app.task(
-    name="grab_ddebs_sources",
-    autoretry_for=(DebugGetterTimeout, DebugGetterRetry),
-    # 1 day
-    default_retry_delay=24 * 60 * 60,
+    name="grab_sources",
+    autoretry_for=(UbuntuDebuginfodTimeout, UbuntuDebuginfodRetry),
+    default_retry_delay=DEFAULT_RETRY_DELAY,
     # Launchpad can be problematic, so we retry every day for a
     # week.
     retry_kwargs={"max_retries": 7},
 )
-def grab_ddebs_sources(msg):
-    """Dispatch the DdebSourceCodeGetter task.
+def grab_sources(msg):
+    """Dispatch the SourceCodeGetter task.
 
     :param dict[str, str] msg: The dictionary containing the message
         that will be processed by the getter."""
     try:
-        g = DdebSourceCodeGetter()
+        g = SourcePackageGetter()
         g.process_request(msg)
     except Exception as e:
-        if not isinstance(e, DebugGetterRetry) and not isinstance(
-            e, DebugGetterTimeout
+        if not isinstance(e, UbuntuDebuginfodRetry) and not isinstance(
+            e, UbuntuDebuginfodTimeout
         ):
             # This is some other kind of error that we need to deal
             # with.  Mark it as such.
-            _record_error_into_db(e, msg)
+            record_error_into_db(e, msg)
         # We still need to raise the exception here.  Celery will
         # reschedule the task if applicable.
         raise e
@@ -133,9 +123,8 @@ def grab_ddebs_sources(msg):
 
 @app.task(
     name="grab_ppa_ddebs",
-    autoretry_for=(DebugGetterTimeout, DebugGetterRetry),
-    # 1 day
-    default_retry_delay=24 * 60 * 60,
+    autoretry_for=(UbuntuDebuginfodTimeout, UbuntuDebuginfodRetry),
+    default_retry_delay=DEFAULT_RETRY_DELAY,
     # Launchpad can be problematic, so we retry every day for a
     # week.
     retry_kwargs={"max_retries": 7},
@@ -149,12 +138,12 @@ def grab_ppa_ddebs(msg):
         g = PPADdebGetter()
         g.process_request(msg)
     except Exception as e:
-        if not isinstance(e, DebugGetterRetry) and not isinstance(
-            e, DebugGetterTimeout
+        if not isinstance(e, UbuntuDebuginfodRetry) and not isinstance(
+            e, UbuntuDebuginfodTimeout
         ):
             # This is some other kind of error that we need to deal
             # with.  Mark it as such.
-            _record_error_into_db(e, msg)
+            record_error_into_db(e, msg)
         # We still need to raise the exception here.  Celery will
         # reschedule the task if applicable.
         raise e
@@ -162,28 +151,27 @@ def grab_ppa_ddebs(msg):
 
 @app.task(
     name="grab_ppa_sources",
-    autoretry_for=(DebugGetterTimeout, DebugGetterRetry),
-    # 1 day
-    default_retry_delay=24 * 60 * 60,
+    autoretry_for=(UbuntuDebuginfodTimeout, UbuntuDebuginfodRetry),
+    default_retry_delay=DEFAULT_RETRY_DELAY,
     # Launchpad can be problematic, so we retry every day for a
     # week.
     retry_kwargs={"max_retries": 7},
 )
 def grab_ppa_sources(msg):
-    """Dispatch the PPASourceCodeGetter task.
+    """Dispatch the PPASourcePackageGetter task.
 
     :param dict[str, str] msg: The dictionary containing the message
         that will be processed by the getter."""
     try:
-        g = PPASourceCodeGetter()
+        g = PPASourcePackageGetter()
         g.process_request(msg)
     except Exception as e:
-        if not isinstance(e, DebugGetterRetry) and not isinstance(
-            e, DebugGetterTimeout
+        if not isinstance(e, UbuntuDebuginfodRetry) and not isinstance(
+            e, UbuntuDebuginfodTimeout
         ):
             # This is some other kind of error that we need to deal
             # with.  Mark it as such.
-            _record_error_into_db(e, msg)
+            record_error_into_db(e, msg)
         # We still need to raise the exception here.  Celery will
         # reschedule the task if applicable.
         raise e
@@ -191,9 +179,8 @@ def grab_ppa_sources(msg):
 
 @app.task(
     name="grab_private_ppa_ddebs",
-    autoretry_for=(DebugGetterTimeout, DebugGetterRetry),
-    # 1 day
-    default_retry_delay=24 * 60 * 60,
+    autoretry_for=(UbuntuDebuginfodTimeout, UbuntuDebuginfodRetry),
+    default_retry_delay=DEFAULT_RETRY_DELAY,
     # Launchpad can be problematic, so we retry every day for a
     # week.
     retry_kwargs={"max_retries": 7},
@@ -207,12 +194,12 @@ def grab_private_ppa_ddebs(msg):
         g = PrivatePPADdebGetter()
         g.process_request(msg)
     except Exception as e:
-        if not isinstance(e, DebugGetterRetry) and not isinstance(
-            e, DebugGetterTimeout
+        if not isinstance(e, UbuntuDebuginfodRetry) and not isinstance(
+            e, UbuntuDebuginfodTimeout
         ):
             # This is some other kind of error that we need to deal
             # with.  Mark it as such.
-            _record_error_into_db(e, msg)
+            record_error_into_db(e, msg)
         # We still need to raise the exception here.  Celery will
         # reschedule the task if applicable.
         raise e
@@ -220,28 +207,27 @@ def grab_private_ppa_ddebs(msg):
 
 @app.task(
     name="grab_private_ppa_sources",
-    autoretry_for=(DebugGetterTimeout, DebugGetterRetry),
-    # 1 day
-    default_retry_delay=24 * 60 * 60,
+    autoretry_for=(UbuntuDebuginfodTimeout, UbuntuDebuginfodRetry),
+    default_retry_delay=DEFAULT_RETRY_DELAY,
     # Launchpad can be problematic, so we retry every day for a
     # week.
     retry_kwargs={"max_retries": 7},
 )
 def grab_private_ppa_sources(msg):
-    """Dispatch the PrivatePPASourceCodeGetter task.
+    """Dispatch the PrivatePPASourcePackageGetter task.
 
     :param dict[str, str] msg: The dictionary containing the message
         that will be processed by the getter."""
     try:
-        g = PrivatePPASourceCodeGetter()
+        g = PrivatePPASourcePackageGetter()
         g.process_request(msg)
     except Exception as e:
-        if not isinstance(e, DebugGetterRetry) and not isinstance(
-            e, DebugGetterTimeout
+        if not isinstance(e, UbuntuDebuginfodRetry) and not isinstance(
+            e, UbuntuDebuginfodTimeout
         ):
             # This is some other kind of error that we need to deal
             # with.  Mark it as such.
-            _record_error_into_db(e, msg)
+            record_error_into_db(e, msg)
         # We still need to raise the exception here.  Celery will
         # reschedule the task if applicable.
         raise e
@@ -259,13 +245,42 @@ def notify_worker_shutting_down(**kwargs):
     sdnotifier.notify("STOPPING=1")
 
 
+def _get_msg_field(msg, field):
+    """Return a specific field from msg.
+
+    :param dict[str -> str] msg: The dictionary received by this
+        Celery job.
+
+    :param str field: The field name that we want.
+
+    :rtype str or list:
+    :return: The value for field.
+
+    :raises: RuntimeError if field does not exist or if it doesn't
+        have a non-None value."""
+    if field not in msg.keys():
+        e = RuntimeError(f"{field} could not be found in {msg}")
+        record_error_into_db(e, "Failed during _get_msg_field")
+        raise e
+    val = msg[field]
+    if val is None:
+        e = RuntimeError(f"{field} is None")
+        record_error_into_db(e, "Failed during _get_msg_field")
+        raise e
+    return val
+
+
 @task_postrun.connect
-def task_postrun(sender, args, state, **kwargs):
+def debuginfod_task_postrun(sender, args, state, **kwargs):
     """Process a task that's just finished.
 
     We keep the state of each task in a SQL database, and this
     function is responsible for cleaning up the state for tasks that have
-    succeeded."""
+    succeeded.
+
+    Moreover, it also records information about the downloaded
+    artifact so that we can keep track of it later (i.e., when we need
+    to clean things up)."""
     if state not in ("SUCCESS",):
         return
 
@@ -274,13 +289,9 @@ def task_postrun(sender, args, state, **kwargs):
             msg = args[0]
             if not msg:
                 e = RuntimeError("Could not obtain message to be processed.")
-                _record_error_into_db(e, "Failed during task_postrun")
-                raise e
-            if not msg.get("taskid"):
-                e = RuntimeError("Could not obtain taskid.")
-                _record_error_into_db(e, "Failed during task_postrun")
+                record_error_into_db(e, "Failed during task_postrun")
                 raise e
-            taskid = msg["taskid"]
+            taskid = _get_msg_field(msg, "taskid")
             cur.execute("DELETE FROM tasks WHERE id = %s", (taskid,))
 
 
diff --git a/ubuntu_debuginfod/getter.py b/ubuntu_debuginfod/getter.py
new file mode 100644
index 0000000..7ced991
--- /dev/null
+++ b/ubuntu_debuginfod/getter.py
@@ -0,0 +1,57 @@
+#!/usr/bin/python3
+
+# Copyright (C) 2022 Canonical Ltd.
+
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+
+# You should have received a copy of the GNU General Public License
+# along with this program.  If not, see <https://www.gnu.org/licenses/>.
+
+# Authors: Sergio Durigan Junior <[e-mail]>
+
+import logging
+
+
+class Getter:
+    """Base class for a Debug Getter."""
+
+    # The default directory where the debug artifacts will be saved.
+    DEFAULT_MIRROR_DIR = "/srv/debug-mirror"
+
+    def __init__(self, subdir, mirror_dir=None, anonymous=True):
+        """Initialize the object.
+
+        :param str mirror_dir: The directory we use to save the
+            mirrored files from Launchpad.
+
+        :param str subdir: The subdirectory (insider mirror_dir) where
+            the module will save its files.  For example, a ddeb
+            getter module should specify "ddebs"here.  If None, use
+            DEFAULT_MIRROR_DIR.
+
+        :param bool anonymous: Whether this getter handles anonymous
+            (public) artifacts.  Default to True."""
+        self._mirror_dir = self.DEFAULT_MIRROR_DIR if mirror_dir is None else mirror_dir
+        self._subdir = subdir
+        self._anonymous = anonymous
+        self._logger = logging.getLogger(__name__)
+        self._logger.debug(
+            f"Initializing Getter with subdir={subdir}, mirror_dir={mirror_dir}, anonymous={anonymous}"
+        )
+
+    @property
+    def subdir(self):
+        return self._subdir
+
+    @subdir.setter
+    def subdir(self, subdir):
+        self._logger.debug(f"Setting {type(self).__name__} subdir to '{subdir}'")
+        self._subdir = subdir
diff --git a/ubuntu_debuginfod/getters/__init__.py b/ubuntu_debuginfod/getters/__init__.py
new file mode 100644
index 0000000..14e8999
--- /dev/null
+++ b/ubuntu_debuginfod/getters/__init__.py
@@ -0,0 +1 @@
+"""Init."""
diff --git a/ubuntu_debuginfod/getters/common_lp_getter.py b/ubuntu_debuginfod/getters/common_lp_getter.py
new file mode 100644
index 0000000..4852678
--- /dev/null
+++ b/ubuntu_debuginfod/getters/common_lp_getter.py
@@ -0,0 +1,104 @@
+#!/usr/bin/python3
+
+# Copyright (C) 2022-2023 Canonical Ltd.
+
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+
+# You should have received a copy of the GNU General Public License
+# along with this program.  If not, see <https://www.gnu.org/licenses/>.
+
+# Authors: Sergio Durigan Junior <[e-mail]>
+
+import os
+from ubuntu_debuginfod.getter import Getter
+from ubuntu_debuginfod.utils.debugdb import DebugDB
+from ubuntu_debuginfod.utils.utils import obtain_lp_oauth_credentials
+
+
+class CommonLaunchpadGetter(Getter):
+    """Common getter class for dealing with Launchpad."""
+
+    def __init__(self, subdir, mirror_dir=None, anonymous=True):
+        """Initialize the object.
+
+        See Getter's __init__ for an explanation of the arguments."""
+        super().__init__(subdir=subdir, mirror_dir=mirror_dir, anonymous=anonymous)
+        self._logger.debug(
+            f"Initializing CommonLaunchpadGetter with subdir={subdir}, mirror_dir={mirror_dir}, anonymous={anonymous}"
+        )
+
+    def make_savepath(self, source_package, component):
+        """Return the full save path for a package.
+
+        :param str source_package: The package name.
+
+        :param str component: The component name (main, universe,
+            etc.)."""
+        if source_package.startswith("lib"):
+            pkgname_initials = source_package[:4]
+        else:
+            pkgname_initials = source_package[0]
+
+        return os.path.join(
+            self._mirror_dir,
+            self._subdir,
+            component,
+            pkgname_initials,
+            source_package,
+        )
+
+    def process_request(self, request):
+        """Process a request.
+
+        :param dict[str, str] request: The dictionary containing the
+            information necessary to fetch this ddeb.
+
+        :param requests_oauthlib.OAuth1 credentials: The credentials
+            to be used when downloading the artifact from Launchpad.
+            Default is None, which means anonymous."""
+        self._logger.debug(
+            f"Processing request from {type(self).__name__} to download artifact: {request}"
+        )
+        credentials = None if self._anonymous else obtain_lp_oauth_credentials()
+        fpath = self.download_artifact(
+            request,
+            credentials=credentials,
+        )
+        if fpath is not None:
+            with DebugDB() as db:
+                with db.cursor() as cur:
+                    cur.execute(
+                        "INSERT INTO artifacts (fullpath, uri, private, date) VALUES (%s, %s, %s, NOW())",
+                        (fpath, request["uri"], not self._anonymous),
+                    )
+
+    def validate_request(self, request):
+        """Validate a request coming from Celery.
+
+        :param dict[str, str] request: The dictionary containing the
+            request to be validated."""
+        if request is None:
+            raise TypeError("Invalid request (None)")
+
+        if "architecture" not in request.keys():
+            raise ValueError("No 'architecture' in request")
+        if request.get("architecture") is None:
+            raise ValueError("Invalid 'architecture' (None) in request")
+
+        if "uri" not in request.keys():
+            raise ValueError("No 'uri' in request")
+        if request.get("uri") is None:
+            raise ValueError("Invalid 'uri' (None) in request")
+
+    def download_artifact(self, *args):
+        """Interface for download_artifact.  Subclasses of
+        CommonLaunchpadGetter are expected to implement it."""
+        raise NotImplementedError("Wrong call to 'download_artifact' from base class")
diff --git a/ubuntu_debuginfod/getters/common_ppa_getter.py b/ubuntu_debuginfod/getters/common_ppa_getter.py
new file mode 100644
index 0000000..290bbe7
--- /dev/null
+++ b/ubuntu_debuginfod/getters/common_ppa_getter.py
@@ -0,0 +1,65 @@
+#!/usr/bin/python3
+
+# Copyright (C) 2023 Canonical Ltd.
+
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+
+# You should have received a copy of the GNU General Public License
+# along with this program.  If not, see <https://www.gnu.org/licenses/>.
+
+# Authors: Sergio Durigan Junior <[e-mail]>
+
+import os
+import logging
+
+
+class CommonPPAGetter:
+    """A common class for PPA getters."""
+
+    def __init__(self, *args, **kwargs):
+        """Initialize the object.
+
+        We're not interested in doing anything here, since this is a
+        base class that should be used in multiple-inheritance
+        scenarios."""
+        super().__init__(*args, **kwargs)
+        self._logger = logging.getLogger(__name__)
+        self._logger.debug("Initializing CommonPPAGetter")
+
+    def validate_request(self, request):
+        """Validate a request to fetch an artifact from a PPA (private or
+        not).
+
+        :param dict[str, str] request: The dictionary containing the
+            request to be validated."""
+        super().validate_request(request)
+        keys = request.keys()
+        if "ppauser" not in keys:
+            raise TypeError("No 'ppauser' in request")
+        if "ppaname" not in keys:
+            raise TypeError("No 'ppaname' in request")
+        if "isprivateppa" not in keys:
+            raise TypeError("No 'isprivateppa' in request")
+
+        if request.get("ppauser") is None:
+            raise ValueError("Invalid 'ppauser' (None) in request")
+        if request.get("ppaname") is None:
+            raise ValueError("Invalid 'ppaname' (None) in request")
+        if request.get("isprivateppa") is None:
+            raise ValueError("Invalid 'isprivateppa' (None) in request")
+
+    def process_request(self, request, credentials=None):
+        """Process a request, usually coming from Celery.
+
+        :param dict[str -> str] request: The dictionary containing the
+            information necessary to fetch this ddeb."""
+        self.subdir = os.path.join(self._subdir, request["ppauser"], request["ppaname"])
+        super().process_request(request, credentials=credentials)
diff --git a/ubuntu_debuginfod/getters/ddebgetter.py b/ubuntu_debuginfod/getters/ddebgetter.py
new file mode 100644
index 0000000..633ed93
--- /dev/null
+++ b/ubuntu_debuginfod/getters/ddebgetter.py
@@ -0,0 +1,70 @@
+#!/usr/bin/python3
+
+# Copyright (C) 2022 Canonical Ltd.
+
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+
+# You should have received a copy of the GNU General Public License
+# along with this program.  If not, see <https://www.gnu.org/licenses/>.
+
+# Authors: Sergio Durigan Junior <[e-mail]>
+
+from ubuntu_debuginfod.getters.common_lp_getter import CommonLaunchpadGetter
+from ubuntu_debuginfod.utils.utils import download_from_lp
+
+
+class DdebGetter(CommonLaunchpadGetter):
+    """Get (fetch) a ddeb."""
+
+    def __init__(self, subdir="ddebs", mirror_dir=None, anonymous=True):
+        """Initialize the object.
+
+        See Getter's __init__ for an explanation of the arguments."""
+        super().__init__(subdir=subdir, mirror_dir=mirror_dir, anonymous=anonymous)
+        self._logger.debug(
+            f"Initializing DdebGetter with subdir={subdir}, mirror_dir={mirror_dir}, anonymous={anonymous}"
+        )
+
+    def download_artifact(self, request, credentials=None):
+        """Download a ddeb associated with a package.
+
+        :param dict[str, str] request: The dictionary containing the
+            information necessary to fetch this ddeb.
+
+        :param requests_oauthlib.OAuth1 credentials: The credentials
+            to be used when downloading the artifact from Launchpad.
+            Default is None, which means anonymous.
+
+        :rtype: str
+        :return: The full path for the file that was saved, or None if
+            the file already exists."""
+        self.validate_request(request)
+        source_package = request["source_package"]
+        component = request["component"]
+        ddeb_url = request["ddeb_url"]
+        savepath = self.make_savepath(source_package, component)
+        self._logger.debug(f"Downloading '{ddeb_url}' into '{savepath}'")
+        if credentials is not None:
+            self._logger.debug("Downloading with credentials")
+        return download_from_lp(ddeb_url, savepath, credentials=credentials)
+
+    def validate_request(self, request):
+        """Validate a request to fetch a ddeb from the main archive.
+
+        :param dict[str, str] request: The dictionary containing the
+            request to be validated."""
+        super().validate_request(request)
+        if "ddeb_url" not in request.keys():
+            raise TypeError("No 'ddeb_url' in request")
+        if request.get("ddeb_url") is None:
+            raise ValueError("Invalid 'ddeb_url' (None) in request")
+        if request["architecture"] == "source":
+            raise ValueError("Wrong request: source fetch")
diff --git a/ubuntu_debuginfod/getters/ppaddebgetter.py b/ubuntu_debuginfod/getters/ppaddebgetter.py
new file mode 100644
index 0000000..4d86232
--- /dev/null
+++ b/ubuntu_debuginfod/getters/ppaddebgetter.py
@@ -0,0 +1,65 @@
+#!/usr/bin/python3
+
+# Copyright (C) 2023 Canonical Ltd.
+
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+
+# You should have received a copy of the GNU General Public License
+# along with this program.  If not, see <https://www.gnu.org/licenses/>.
+
+# Authors: Sergio Durigan Junior <[e-mail]>
+
+from ubuntu_debuginfod.getters.ddebgetter import DdebGetter
+from ubuntu_debuginfod.getters.common_ppa_getter import CommonPPAGetter
+
+
+class PPADdebGetter(CommonPPAGetter, DdebGetter):
+    """Get a ddeb from a Launchpad PPA."""
+
+    def __init__(self, subdir="ppas", mirror_dir=None):
+        """Initialize the object.
+
+        See Getter's __init__ for an explanation of the arguments."""
+        super().__init__(subdir=subdir, mirror_dir=mirror_dir, anonymous=True)
+        self._logger.debug(
+            f"Initializing PPADdebGetter with subdir={subdir}, mirror_dir={mirror_dir}"
+        )
+
+    def validate_request(self, request):
+        """Validate a request to fetch a ddeb from a PPA.
+
+        :param dict[str, str] request: The dictionary containing the
+            request to be validated."""
+        super().validate_request(request)
+        if request["isprivateppa"] == "yes":
+            raise ValueError("Wrong request: from private PPA")
+
+
+class PrivatePPADdebGetter(CommonPPAGetter, DdebGetter):
+    """Get a ddeb from a private Launchpad PPA."""
+
+    def __init__(self, subdir="private-ppas", mirror_dir=None):
+        """Initialize the object.
+
+        See Getter's __init__ for an explanation of the arguments."""
+        super().__init__(subdir=subdir, mirror_dir=mirror_dir, anonymous=False)
+        self._logger.debug(
+            f"Initializing PrivatePPADdebGetter with subdir={subdir}, mirror_dir={mirror_dir}"
+        )
+
+    def validate_request(self, request):
+        """Validate a request to fetch a ddeb from a private PPA.
+
+        :param dict[str, str] request: The dictionary containing the
+            request to be validated."""
+        super().validate_request(request)
+        if request["isprivateppa"] == "no":
+            raise ValueError("Wrong request: not from private PPA")
diff --git a/ubuntu_debuginfod/getters/ppasourcepackagegetter.py b/ubuntu_debuginfod/getters/ppasourcepackagegetter.py
new file mode 100644
index 0000000..ae488a4
--- /dev/null
+++ b/ubuntu_debuginfod/getters/ppasourcepackagegetter.py
@@ -0,0 +1,70 @@
+#!/usr/bin/python3
+
+# Copyright (C) 2023 Canonical Ltd.
+
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+
+# You should have received a copy of the GNU General Public License
+# along with this program.  If not, see <https://www.gnu.org/licenses/>.
+
+# Authors: Sergio Durigan Junior <[e-mail]>
+
+from ubuntu_debuginfod.getters.sourcepackagegetter import SourcePackageGetter
+from ubuntu_debuginfod.getters.common_ppa_getter import CommonPPAGetter
+
+
+class PPASourcePackageGetter(CommonPPAGetter, SourcePackageGetter):
+    """Get a source package from a Launchpad PPA."""
+
+    def __init__(self, subdir="ppas", mirror_dir=None):
+        """Initialize the object.
+
+        See Getter's __init__ for an explanation of the arguments."""
+        super().__init__(
+            subdir=subdir, mirror_dir=mirror_dir, anonymous=True, fallback_to_git=False
+        )
+        self._logger.debug(
+            f"Initializing PPASourcePackageGetter with subdir={subdir}, mirror_dir={mirror_dir}"
+        )
+
+    def validate_request(self, request):
+        """Validate a request to fetch a source package from a PPA.
+
+        :param dict[str, str] request: The dictionary containing the
+            request to be validated."""
+        super().validate_request(request)
+        if request["isprivateppa"] == "yes":
+            raise ValueError("Wrong request: from private PPA")
+
+
+class PrivatePPASourcePackageGetter(CommonPPAGetter, SourcePackageGetter):
+    """Get a source package from a private Launchpad PPA."""
+
+    def __init__(self, subdir="private-ppas", mirror_dir=None):
+        """Initialize the object.
+
+        See Getter's __init__ for an explanation of the arguments."""
+        super().__init__(
+            subdir=subdir, mirror_dir=mirror_dir, anonymous=False, fallback_to_git=False
+        )
+        self._logger.debug(
+            f"Initializing PrivatePPASourcePackageGetter with subdir={subdir}, mirror_dir={mirror_dir}"
+        )
+
+    def validate_request(self, request):
+        """Validate a request to fetch a source package from a private
+        PPA.
+
+        :param dict[str, str] request: The dictionary containing the
+            request to be validated."""
+        super().validate_request(request)
+        if request["isprivateppa"] == "no":
+            raise ValueError("Wrong request: not from private PPA")
diff --git a/ubuntu_debuginfod/getters/sourcepackagegetter.py b/ubuntu_debuginfod/getters/sourcepackagegetter.py
new file mode 100644
index 0000000..2287620
--- /dev/null
+++ b/ubuntu_debuginfod/getters/sourcepackagegetter.py
@@ -0,0 +1,255 @@
+#!/usr/bin/python3
+
+# Copyright (C) 2022-2023 Canonical Ltd.
+
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+
+# You should have received a copy of the GNU General Public License
+# along with this program.  If not, see <https://www.gnu.org/licenses/>.
+
+# Authors: Sergio Durigan Junior <[e-mail]>
+
+import os
+import lzma
+import tarfile
+import subprocess
+import tempfile
+from git import Git, Repo
+from git.exc import GitCommandError
+from ubuntu_debuginfod.getters.common_lp_getter import CommonLaunchpadGetter
+from ubuntu_debuginfod.utils.utils import (
+    git_dep14_tag,
+    download_from_lp,
+    move_atomically,
+)
+from ubuntu_debuginfod.utils.exceptions import UbuntuDebuginfodRetry
+
+
+def adjust_tar_filepath(tarinfo):
+    """Adjust the filepath for a TarInfo file.
+
+    This function is needed because TarFile.add strips the leading
+    slash from the filenames, so we have to workaround it by
+    re-adding the slash ourselves.
+
+    This function is intended to be used as a callback provided to
+    TarFile.add.
+
+    :param TarInfo tarinfo: The tarinfo."""
+    tarinfo.name = os.path.join("/", tarinfo.name)
+    return tarinfo
+
+
+class SourcePackageGetter(CommonLaunchpadGetter):
+    """Get (fetch) the source package artifact."""
+
+    def __init__(
+        self, subdir="ddebs", mirror_dir=None, anonymous=True, fallback_to_git=True
+    ):
+        """Initialize the object.
+
+        :param boolean fallback_to_git: Whether we should try to fetch
+            the source package using git if the regular approach (via
+            dget) fails.  Default to True.
+
+        See Getter's __init__ for an explanation of the other arguments."""
+        super().__init__(subdir=subdir, mirror_dir=mirror_dir)
+        self._fallback_to_git = fallback_to_git
+        self._logger.debug(
+            f"Initializing SourcePackageGetter with subdir={subdir}, mirror_dir={mirror_dir}, anonymous={anonymous}, fallback_to_git={fallback_to_git}"
+        )
+
+    def _download_source_package_from_git(self, source_package, version, filepath):
+        """Download the source package using Launchpad's git repository.
+
+        :param str source_package: Source package name.
+
+        :param str version: Source package version.
+
+        :param str filepath: The full pathname where the resulting
+            source package tarball should be saved.
+
+        :rtype: bool
+        :return: This method returns True when the operation succeeds, or False
+            *iff* the "git clone" command fails to run.  Otherwise, this
+            function will throw an exception."""
+        with tempfile.TemporaryDirectory(ignore_cleanup_errors=True) as source_dir:
+            g = Git()
+            git_dir = os.path.join(source_dir, f"{source_package}")
+            tag = "applied/" + git_dep14_tag(f"{version}")
+            self._logger.debug(
+                f"Cloning '{source_package}' git repo into '{git_dir}' (tag: '{tag}')"
+            )
+            try:
+                g.clone(
+                    f"https://git.launchpad.net/ubuntu/+source/{source_package}",
+                    git_dir,
+                    depth=1,
+                    branch=tag,
+                )
+            except GitCommandError as e:
+                # Couldn't perform the download.  Let's signal and
+                # bail out.
+                self._logger.warning(
+                    f"Could not clone git repo for '{source_package}': {e}"
+                )
+                return False
+            repo = Repo(git_dir)
+            prefix_path = os.path.join("/usr/src/", f"{source_package}-{version}/")
+            self._logger.debug(
+                f"Archiving git repo for '{source_package}-{version}' as '{filepath}'"
+            )
+            with tempfile.NamedTemporaryFile() as tmpfile:
+                with lzma.open(tmpfile.name, "w") as xzfile:
+                    repo.archive(xzfile, prefix=prefix_path, format="tar")
+                move_atomically(tmpfile.name, filepath)
+
+        return True
+
+    def _download_source_package_from_dsc(
+        self, source_package, version, filepath, source_urls, credentials=None
+    ):
+        """Download the source package using the .dsc file.
+
+        :param str source_package: Source package name.
+
+        :param str version: Source package version.
+
+        :param str filepath: The full pathname where the resulting
+            source package tarball should be saved.
+
+        :param list source_urls: List of URLs used to fetch the source
+            package.  This is usually the list returned by the
+            sourceFileUrls() Launchpad API call.
+
+        :param requests_oauthlib.OAuth1 credentials: The credentials
+            to be used when downloading the artifact from Launchpad.
+            Default is None, which means anonymous.
+
+        :rtype: bool
+        :return: This method returns True when the operation succeeds, or False
+            *iff* the "dpkg-source -x"command fails to run.
+            Otherwise, this function will throw an exception."""
+        with tempfile.TemporaryDirectory(ignore_cleanup_errors=True) as source_dir:
+            for url in source_urls:
+                download_from_lp(url, source_dir, credentials=credentials)
+
+            dscfile = None
+            for f in os.listdir(source_dir):
+                newf = os.path.join(source_dir, f)
+                if os.path.isfile(newf) and f.endswith(".dsc"):
+                    dscfile = newf
+                    break
+
+            if dscfile is None:
+                self._logger.warning(
+                    "Could not find .dsc file, even though it should exist."
+                )
+                return False
+
+            outdir = os.path.join(source_dir, "outdir")
+            self._logger.debug(f"Will call 'dpkg-source -x {dscfile} {outdir}'")
+            try:
+                subprocess.run(
+                    ["/usr/bin/dpkg-source", "-x", dscfile, outdir],
+                    cwd=source_dir,
+                    check=True,
+                )
+            except subprocess.CalledProcessError:
+                self._logger.warning("Call to 'dpkg-source -x' failed.")
+                return False
+
+            if not os.path.isdir(outdir):
+                self._logger.warning(
+                    f"'{outdir}' has not been created by 'dpkg-source -x'."
+                )
+                return False
+
+            prefix_path = os.path.join("/usr/src/", f"{source_package}-{version}/")
+
+            with tempfile.NamedTemporaryFile() as tmpfile:
+                with tarfile.open(tmpfile.name, "w:xz") as tfile:
+                    tfile.add(outdir, arcname=prefix_path, filter=adjust_tar_filepath)
+                move_atomically(tmpfile.name, filepath)
+
+            return True
+
+    def download_artifact(
+        self,
+        request,
+        credentials=None,
+    ):
+        """Download the source package.
+
+        :param str source_package: Source package name.
+
+        :param str version: Source package version.
+
+        :param str component: Source package component.
+
+        :param list source_urls: List of source file URLS.
+
+        :param boolean fallback_to_git: Whether we should try to fetch
+            the source package using git if the regular approach (via
+            dget) fails.  Default to True.
+
+        :param requests_oauthlib.OAuth1 credentials: The credentials
+            to be used when downloading the artifact from Launchpad.
+            Default is None, which means anonymous.
+
+        :rtype: str
+        :return: The full path for the file that was saved, or None if
+            the file already exists."""
+        source_package = request["source_package"]
+        version = request["version"]
+        component = request["component"]
+        source_urls = request["source_urls"]
+
+        savepath = self.make_savepath(source_package, component)
+        txzfilepath = os.path.join(savepath, f"{source_package}-{version}.tar.xz")
+        if os.path.exists(txzfilepath):
+            self._logger.debug(f"'{txzfilepath}' already exists; doing nothing.")
+            return None
+
+        if self._download_source_package_from_dsc(
+            source_package, version, txzfilepath, source_urls, credentials=credentials
+        ):
+            self._logger.info(
+                f"Downloaded source package from dsc for '{source_package}-{version}' as '{txzfilepath}'"
+            )
+            return txzfilepath
+
+        if self._fallback_to_git and self._download_source_package_from_git(
+            source_package, version, txzfilepath
+        ):
+            self._logger.info(
+                f"Downloaded source package from git for '{source_package}-{version}' as '{txzfilepath}'"
+            )
+            return txzfilepath
+
+        # In the (likely?) event that there is a problem with
+        # Launchpad, let's raise an exception signalling that we'd
+        # like to retry the task.
+        raise UbuntuDebuginfodRetry()
+
+    def validate_request(self, request):
+        """Validate a request to fetch a source package from the main
+        archive.
+
+        :param dict[str, str] request: The dictionary containing the
+            request to be validated."""
+        super().validate_request(request)
+        if "source_urls" not in request.keys():
+            raise TypeError("No 'source_urls' in request")
+        if request.get("source_urls") is None:
+            raise ValueError("Invalid 'source_urls' (None) in request")
+        if request["architecture"] != "source":
+            raise ValueError("Wrong request: ddeb fetch")
diff --git a/debugpoller.py b/ubuntu_debuginfod/poller.py
similarity index 66%
rename from debugpoller.py
rename to ubuntu_debuginfod/poller.py
index 4e4a657..d6f32d0 100644
--- a/debugpoller.py
+++ b/ubuntu_debuginfod/poller.py
@@ -18,14 +18,13 @@
 # Authors: Sergio Durigan Junior <[e-mail]>
 
 import os
-import sys
-from launchpadlib.launchpad import Launchpad
 import datetime
 import logging
+from ubuntu_debuginfod.utils.utils import generate_timestamp
 
 
-class DebugPoller:
-    """The DebugPoller class implements the basics of a poller for the
+class Poller:
+    """The Poller class implements the basics of a poller for the
     debuginfod service."""
 
     # The timestamp file we will save our timestamp into.
@@ -43,7 +42,7 @@ class DebugPoller:
         dry_run=False,
         anonymous=True,
     ):
-        """Initalize the DebugPoller object.
+        """Initalize the Poller object.
 
         :param int initial_interval: The initial interval (in hours),
             i.e., if no timestamp file has been found then we use this
@@ -65,60 +64,27 @@ class DebugPoller:
             the timestamp in the file when the operation finishes.
             Default is False.
 
-        :param bool anonymous: Whether we should login anonymously.
-            Default is True.
-
-        """
-        if anonymous:
-            self._lp = Launchpad.login_anonymously(
-                "ubuntu-debuginfod poller", "production", version="devel"
-            )
-        else:
-            self._lp = Launchpad.login_with(
-                "ubuntu-debuginfod poller", "production", version="devel"
-            )
-
-        self._main_archive = self._lp.distributions["ubuntu"].main_archive
-
-        self._logger = logging.getLogger(__name__)
-        logging.basicConfig(
-            level=logging.INFO,
-            format=(
-                "%(levelname) -10s %(asctime)s %(name) -20s %(funcName) "
-                "-25s : %(message)s"
-            ),
-        )
-
+        :param bool anonymous: Whether we should poll anonymously.
+            Default is True."""
         self._initial_interval = initial_interval
         self._force_initial_interval = force_initial_interval
         self._fetch_all_on_first_run = fetch_all_on_first_run
         self._dry_run = dry_run
+        self._anonymous = anonymous
+        self._logger = logging.getLogger(__name__)
+        self._logger.debug(
+            f"Initializing Poller with initial_interval={initial_interval}, force_initial_interval={force_initial_interval}, fetch_all_on_first_run={fetch_all_on_first_run}, dry_run={dry_run}, anonymous={anonymous}"
+        )
 
     @property
     def timestamp_filename(self):
         """Get the filename that contains the timestamp for this module.
 
-        :rtype str: The timestamp filename."""
-        module_name = type(self).__name__.replace('Poller', '').lower()
+        :rtype: str
+        :return: The timestamp filename."""
+        module_name = type(self).__name__.replace("Poller", "").lower()
         return f"{self.TIMESTAMP_FILE}-{module_name}"
 
-    def _generate_timestamp(self, interval=None):
-        """Generate a timestamp that can be used when querying Launchpad
-        (via getPublished{Sources,Binaries}).
-
-        :param interval: Specify how long ago (in hours) the timestamp must
-            refer to.  If not specified, the timestamp is generated for
-            the current time.
-        :type interval: int or None"""
-        d = datetime.datetime.now(datetime.timezone.utc)
-
-        if interval is not None:
-            self._logger.debug(f"Generating timestamp with interval {interval}")
-            d = d - datetime.timedelta(hours=interval)
-
-        self._logger.debug(f"Generated timestamp '{d}'")
-        return d
-
     def _get_timestamp(self):
         """Get the timestamp from the timestamp file, or generate a
         new one.
@@ -138,15 +104,17 @@ class DebugPoller:
             self._logger.debug(
                 f"Or force_initial_interval = {self._force_initial_interval}"
             )
-            return self._generate_timestamp(interval=self._initial_interval)
+            return generate_timestamp(interval=self._initial_interval)
 
-        with open(tfile, "r", encoding="UTF-8") as f:
-            ts = int(f.readline().rstrip())
-            d = datetime.datetime.fromtimestamp(ts, tz=datetime.timezone.utc)
+        with open(tfile, "r", encoding="UTF-8") as file:
+            ts_int = int(file.readline().rstrip())
+            last_timestamp = datetime.datetime.fromtimestamp(
+                ts_int, tz=datetime.timezone.utc
+            )
 
-            if not isinstance(d, datetime.datetime):
-                raise RuntimeError(f"Invalid timestamp {d}")
-            return d
+            if not isinstance(last_timestamp, datetime.datetime):
+                raise RuntimeError(f"Invalid timestamp {last_timestamp}")
+            return last_timestamp
 
     def _get_normal_and_real_timestamps(self):
         """Get the previous timestamp and adjust it to account for
@@ -175,5 +143,8 @@ class DebugPoller:
         os.makedirs(dirname, mode=0o755, exist_ok=True)
         with open(tfile, "w", encoding="UTF-8") as f:
             epoch = datetime.datetime.fromtimestamp(0, tz=datetime.timezone.utc)
-            ts = int((timestamp - epoch).total_seconds())
-            f.write("%d" % ts)
+            ts_int = int((timestamp - epoch).total_seconds())
+            self._logger.debug(
+                f"Recording timestamp '{ts_int}' for {type(self).__name__}"
+            )
+            f.write(f"{ts_int}")
diff --git a/ubuntu_debuginfod/pollers/__init__.py b/ubuntu_debuginfod/pollers/__init__.py
new file mode 100644
index 0000000..14e8999
--- /dev/null
+++ b/ubuntu_debuginfod/pollers/__init__.py
@@ -0,0 +1 @@
+"""Init."""
diff --git a/ubuntu_debuginfod/pollers/common_lp_poller.py b/ubuntu_debuginfod/pollers/common_lp_poller.py
new file mode 100644
index 0000000..93a958e
--- /dev/null
+++ b/ubuntu_debuginfod/pollers/common_lp_poller.py
@@ -0,0 +1,86 @@
+#!/usr/bin/python3
+
+# Copyright (C) 2022 Canonical Ltd.
+
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+
+# You should have received a copy of the GNU General Public License
+# along with this program.  If not, see <https://www.gnu.org/licenses/>.
+
+# Authors: Sergio Durigan Junior <[e-mail]>
+
+from ubuntu_debuginfod.utils.utils import lp_pub_iterator
+from ubuntu_debuginfod.poller import Poller
+from ubuntu_debuginfod.utils.baselp import BaseLaunchpadClass
+
+
+class CommonLaunchpadPoller(Poller, BaseLaunchpadClass):
+    """Common poller class when dealing with Launchpad archives."""
+
+    def __init__(self, *args, **kwargs):
+        """Initialize the object.
+
+        Look at BaseLaunchpadClass's docstring for an explanation
+        about the arguments."""
+        super().__init__(*args, **kwargs)
+        self.launchpad_login()
+        self._logger.debug("Initializing CommonLaunchpadPoller")
+
+    def poll_artifacts(self, archive, ppainfo, poller_fn):
+        """Poll artifacts from an archive.
+
+        :param lazr.restfulclient.resource.Entry archive: The Launchpad archive.
+
+        :param dict[str -> str] ppainfo: The dictionary containing
+            information about the PPA, if applicable.  Otherwise,
+            None.
+
+        :param function poller_fn: The polling function to be called.
+
+        :rtype: dict[str -> str], datetime.datetime
+        :return: A dictionary containing "uri" as key, listing all
+            packages' self_link found.  The most recent package
+            timestamp processed."""
+        timestamp, real_timestamp = self._get_normal_and_real_timestamps()
+
+        if ppainfo is None:
+            archive_label = f"'{archive.displayname}' archive"
+        else:
+            archive_label = f"ppa:{ppainfo['ppauser']}/{ppainfo['ppaname']} (private: {ppainfo['isprivateppa']})"
+
+        self._logger.info(
+            f"Polling artifacts ({type(self).__name__}) created since '{real_timestamp}' from {archive_label}"
+        )
+
+        result = []
+        latest_timestamp_created = timestamp
+        # Create an iterator for the Launchpad publications.
+        pkgiter = lp_pub_iterator(
+            poller_fn(order_by_date=True, created_since_date=real_timestamp)
+        )
+
+        for pkg in pkgiter:
+            msg = {
+                "uri": pkg.self_link,
+            }
+
+            if (
+                latest_timestamp_created is None
+                or pkg.date_created > latest_timestamp_created
+            ):
+                latest_timestamp_created = pkg.date_created
+
+            if ppainfo is not None:
+                msg.update(ppainfo)
+
+            result.append(msg)
+
+        return result, latest_timestamp_created
diff --git a/ubuntu_debuginfod/pollers/common_ppa_poller.py b/ubuntu_debuginfod/pollers/common_ppa_poller.py
new file mode 100644
index 0000000..7f1c2ca
--- /dev/null
+++ b/ubuntu_debuginfod/pollers/common_ppa_poller.py
@@ -0,0 +1,121 @@
+#!/usr/bin/python3
+
+# Copyright (C) 2023 Canonical Ltd.
+
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+
+# You should have received a copy of the GNU General Public License
+# along with this program.  If not, see <https://www.gnu.org/licenses/>.
+
+# Authors: Sergio Durigan Junior <[e-mail]>
+
+import os
+import lazr.restfulclient.errors
+from ubuntu_debuginfod.utils.utils import generate_timestamp
+
+
+class CommonPPAPoller:
+    """A common poller for PPAs."""
+
+    PPALIST_PATH = os.path.expanduser("~/.config/ubuntu-debuginfod/ppalist")
+    PRIVATE_PPALIST_PATH = os.path.expanduser(
+        "~/.config/ubuntu-debuginfod/ppalist-private"
+    )
+
+    def __init__(self, *args, **kwargs):
+        """Initialize the object.
+
+        This class is meant to be use in a multiple-inheritance scenario."""
+        super().__init__(*args, **kwargs)
+        self._logger.debug("Initializing CommonPPAPoller")
+
+    def get_list_of_ppas(self):
+        """Get the list of PPAs to be polled.
+
+        :rtype: list
+        :return: The list of PPAs.  This list will contain one
+            dictionary per PPA, with the following keys:
+
+                { "ppauser" : string,
+                  "ppaname" : string,
+                  "isprivateppa" : string }"""
+        ppafile = self.PPALIST_PATH if self._anonymous else self.PRIVATE_PPALIST_PATH
+
+        self._logger.debug(f"Processing '{ppafile}'")
+
+        if not os.path.isfile(ppafile):
+            self._logger.info(f"{ppafile} does not exist; doing nothing")
+            return []
+
+        ppas = []
+        with open(ppafile, "r", encoding="UTF-8") as f:
+            for ppa in f.readlines():
+                ppa = ppa.rstrip()
+                if ppa == "" or ppa.startswith("#"):
+                    continue
+                ppa = ppa.split(":")[1].split("/")
+                ppa_user = ppa[0]
+                ppa_name = ppa[1]
+                self._logger.info(f"Processing ppa:{ppa_user}/{ppa_name}")
+                ppas.append(
+                    {
+                        "ppauser": ppa_user,
+                        "ppaname": ppa_name,
+                        "isprivateppa": "no" if self._anonymous else "yes",
+                    }
+                )
+        return ppas
+
+    def poll_artifacts(self):
+        """Get the list of artifacts from Launchpad PPAs.
+
+        :param poller_fn function: The poller function that should be
+            used when polling for artifacts.
+
+        :param lp_people launchpadlib.launchpad.PersonSet: The pointer
+            to a Launchpad "people"set.  This is usually
+            "self._lp.people".
+
+        :rtype: dict, datetime.datetime
+        :return: Return a dictionary containing all artifacts found,
+            and also the new timestamp that should then be recorded by
+            calling record_timestamp.  Timestamp can be None, in which
+            case nothing should be recorded."""
+        ppalist = self.get_list_of_ppas()
+        if len(ppalist) == 0:
+            return [], None
+
+        messages = []
+        new_timestamp = generate_timestamp()
+        for ppainfo in ppalist:
+            ppauser = ppainfo["ppauser"]
+            ppaname = ppainfo["ppaname"]
+            try:
+                lpuser = self._lp.people[ppauser]
+            except KeyError:
+                self._logger.error(f"Launchpad user {ppauser} does not exist")
+                continue
+
+            try:
+                lpppa = lpuser.getPPAByName(name=ppaname)
+            except lazr.restfulclient.errors.NotFound:
+                self._logger.error(
+                    f"Launchpad PPA ppa:{ppauser}/{ppaname} does not exist"
+                )
+                continue
+
+            self._logger.info(
+                f"Getting list of artifacts ({type(self).__name__}) from ppa:{ppauser}/{ppaname} (private: {not self._anonymous})"
+            )
+            msg, _ = super().poll_artifacts(archive=lpppa, ppainfo=ppainfo)
+            messages += msg
+
+        return messages, new_timestamp
diff --git a/ubuntu_debuginfod/pollers/ddebpoller.py b/ubuntu_debuginfod/pollers/ddebpoller.py
new file mode 100644
index 0000000..ea96030
--- /dev/null
+++ b/ubuntu_debuginfod/pollers/ddebpoller.py
@@ -0,0 +1,69 @@
+#!/usr/bin/python3
+
+# Copyright (C) 2022 Canonical Ltd.
+
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+
+# This program is distributed in the hope that it will be useful,