Enable a containerized version of the ADD API endpoint

[CLOUDDST-28643]

Author: lipoja

iib/web/api_v1.py

@@ -44,8 +44,8 @@
 from iib.web.s3_utils import get_object_from_s3_bucket
 from botocore.response import StreamingBody
 from iib.web.utils import pagination_metadata, str_to_bool
-from iib.workers.tasks.build import (
-    handle_add_request,
+from iib.workers.tasks.build_containerized_add import (
+    handle_containerized_add_request,
 )
 from iib.workers.tasks.build_containerized_rm import handle_containerized_rm_request
 from iib.workers.tasks.build_add_deprecations import handle_add_deprecations_request
@@ -619,7 +619,7 @@ def add_bundles() -> Tuple[flask.Response, int]:
         args.append(current_user.username)
 
     try:
-        handle_add_request.apply_async(
+        handle_containerized_add_request.apply_async(
             args=args,
             link_error=error_callback,
             argsrepr=repr(safe_args),
@@ -990,7 +990,7 @@ def regenerate_bundle_batch() -> Tuple[flask.Response, int]:
 @api_v1.route('/builds/add-rm-batch', methods=['POST'])
 @login_required
 @instrument_tracing(span_name="web.api_v1.add_rm_batch")
-def add_rm_batch() -> Tuple[flask.Response, int]:
+def add_rm_batch(handle_containerized_add_request=None) -> Tuple[flask.Response, int]:
     """
     Submit a batch of requests to add or remove operators from an index image.
 
@@ -1066,7 +1066,7 @@ def add_rm_batch() -> Tuple[flask.Response, int]:
         error_callback = failed_request_callback.s(request.id)
         try:
             if isinstance(request, RequestAdd):
-                handle_add_request.apply_async(
+                handle_containerized_add_request.apply_async(
                     args=args,
                     link_error=error_callback,
                     argsrepr=repr(safe_args),

iib/workers/config.py

@@ -94,6 +94,7 @@ class Config(object):
         'iib.workers.tasks.build_create_empty_index',
         'iib.workers.tasks.build_fbc_operations',
         'iib.workers.tasks.build_add_deprecations',
+        'iib.workers.tasks.build_containerized_add',
         'iib.workers.tasks.build_containerized_fbc_operations',
         'iib.workers.tasks.build_containerized_rm',
         'iib.workers.tasks.general',
@@ -246,9 +247,9 @@ class DevelopmentConfig(Config):
     iib_registry: str = 'registry:8443'
     iib_request_logs_dir: Optional[str] = '/var/log/iib/requests'
     iib_request_related_bundles_dir: Optional[str] = '/var/lib/requests/related_bundles'
-    iib_request_recursive_related_bundles_dir: Optional[
-        str
-    ] = '/var/lib/requests/recursive_related_bundles'
+    iib_request_recursive_related_bundles_dir: Optional[str] = (
+        '/var/lib/requests/recursive_related_bundles'
+    )
     iib_dogpile_backend: str = 'dogpile.cache.memcached'
     iib_ocp_opm_mapping: dict = {
         "v4.6": "opm-v1.26.4",