feat(specs): add runSource endpoint (#3453)

Author: millotp

specs/ingestion/common/schemas/source.yml

@@ -492,3 +492,32 @@ SourceWatchResponse:
       type: string
   required:
     - message
+
+RunSourcePayload:
+  type: object
+  additionalProperties: false
+  properties:
+    indexToInclude:
+      type: array
+      description: List of index names to include in reidexing/update.
+      items:
+        type: string
+    indexToExclude:
+      type: array
+      description: List of index names to exclude in reidexing/update.
+      items:
+        type: string
+    entityIDs:
+      type: array
+      items:
+        type: string
+      description: List of entityID to update.
+    entityType:
+      $ref: '#/EntityType'
+
+EntityType:
+  type: string
+  description: Type of entity to update.
+  enum:
+    - product
+    - collection

specs/ingestion/paths/sources/runSource.yml

@@ -0,0 +1,39 @@
+post:
+  tags:
+    - sources
+  summary: Run all tasks linked to a source
+  description: Runs all tasks linked to a source, only available for Shopify sources. It will create 1 run per task.
+  operationId: runSource
+  x-acl:
+    - addObject
+    - deleteIndex
+    - editSettings
+  parameters:
+    - $ref: '../../common/parameters.yml#/pathSourceID'
+  requestBody:
+    description: ''
+    content:
+      application/json:
+        schema:
+          $ref: '../../common/schemas/source.yml#/RunSourcePayload'
+  responses:
+    '200':
+      description: OK
+      content:
+        application/json:
+          schema:
+            title: runSourceResponse
+            type: object
+            properties:
+              taskWithRunID:
+                type: object
+                description: Map of taskID sent for reindex with the corresponding runID.
+                additionalProperties:
+                  type: string
+              createdAt:
+                $ref: '../../common/schemas/common.yml#/createdAt'
+            required:
+              - taskWithRunID
+              - createdAt
+    '400':
+      $ref: '../../../common/responses/BadRequest.yml'

specs/ingestion/spec.yml

@@ -137,6 +137,8 @@ paths:
     $ref: 'paths/sources/validateID.yml'
   /1/sources/{sourceID}/discover:
     $ref: 'paths/sources/discover.yml'
+  /1/sources/{sourceID}/run:
+    $ref: 'paths/sources/runSource.yml'
 
   # tasks API.
   /1/tasks:

tests/CTS/requests/ingestion/runSource.json

@@ -0,0 +1,33 @@
+[
+  {
+    "parameters": {
+      "sourceID": "6c02aeb1-775e-418e-870b-1faccd4b2c0f",
+      "runSourcePayload": {
+        "indexToInclude": [
+          "products_us",
+          "products eu"
+        ],
+        "entityIDs": [
+          "1234",
+          "5678"
+        ],
+        "entityType": "product"
+      }
+    },
+    "request": {
+      "path": "/1/sources/6c02aeb1-775e-418e-870b-1faccd4b2c0f/run",
+      "method": "POST",
+      "body": {
+        "indexToInclude": [
+          "products_us",
+          "products eu"
+        ],
+        "entityIDs": [
+          "1234",
+          "5678"
+        ],
+        "entityType": "product"
+      }
+    }
+  }
+]