[test-optimization] [SDTEST-1821] Implement impacted tests detection

integration-tests/ci-visibility-intake.js

@@ -24,7 +24,8 @@ const DEFAULT_SETTINGS = {
   known_tests_enabled: false,
   test_management: {
     enabled: false
-  }
+  },
+  impacted_tests_enabled: false
 }
 
 const DEFAULT_SUITES_TO_SKIP = []
@@ -39,6 +40,9 @@ const DEFAULT_KNOWN_TESTS = ['test-suite1.js.test-name1', 'test-suite2.js.test-n
 const DEFAULT_TEST_MANAGEMENT_TESTS = {}
 const DEFAULT_TEST_MANAGEMENT_TESTS_RESPONSE_STATUS = 200
 
+const DEFAULT_IMPACTED_TESTS = {}
+const DEFAULT_IMPACTED_TESTS_RESPONSE_STATUS = 200
+
 let settings = DEFAULT_SETTINGS
 let suitesToSkip = DEFAULT_SUITES_TO_SKIP
 let gitUploadStatus = DEFAULT_GIT_UPLOAD_STATUS
@@ -49,6 +53,8 @@ let knownTestsStatusCode = DEFAULT_KNOWN_TESTS_RESPONSE_STATUS
 let waitingTime = 0
 let testManagementResponse = DEFAULT_TEST_MANAGEMENT_TESTS
 let testManagementResponseStatusCode = DEFAULT_TEST_MANAGEMENT_TESTS_RESPONSE_STATUS
+let impactedTestsResponse = DEFAULT_IMPACTED_TESTS
+let impactedTestsResponseStatusCode = DEFAULT_IMPACTED_TESTS_RESPONSE_STATUS
 
 class FakeCiVisIntake extends FakeAgent {
   setKnownTestsResponseCode (statusCode) {
@@ -91,6 +97,14 @@ class FakeCiVisIntake extends FakeAgent {
     testManagementResponseStatusCode = newStatusCode
   }
 
+  setImpactedTests (newImpactedTests) {
+    impactedTestsResponse = newImpactedTests
+  }
+
+  setImpactedTestsResponseCode (newStatusCode) {
+    impactedTestsResponseStatusCode = newStatusCode
+  }
+
   async start () {
     const app = express()
     app.use(bodyParser.raw({ limit: Infinity, type: 'application/msgpack' }))
@@ -258,6 +272,23 @@ class FakeCiVisIntake extends FakeAgent {
       })
     })
 
+    app.post([
+      '/api/v2/ci/tests/diffs',
+      '/evp_proxy/:version/api/v2/ci/tests/diffs'
+    ], (req, res) => {
+      res.setHeader('content-type', 'application/json')
+      const data = JSON.stringify({
+        data: {
+          attributes: impactedTestsResponse
+        }
+      })
+      res.status(impactedTestsResponseStatusCode).send(data)
+      this.emit('message', {
+        headers: req.headers,
+        url: req.url
+      })
+    })
+
     return new Promise((resolve, reject) => {
       const timeoutObj = setTimeout(() => {
         reject(new Error('Intake timed out starting up'))
@@ -280,6 +311,8 @@ class FakeCiVisIntake extends FakeAgent {
     infoResponse = DEFAULT_INFO_RESPONSE
     testManagementResponseStatusCode = DEFAULT_TEST_MANAGEMENT_TESTS_RESPONSE_STATUS
     testManagementResponse = DEFAULT_TEST_MANAGEMENT_TESTS
+    impactedTestsResponseStatusCode = DEFAULT_IMPACTED_TESTS_RESPONSE_STATUS
+    impactedTestsResponse = DEFAULT_IMPACTED_TESTS
     this.removeAllListeners()
     if (this.waitingTimeoutId) {
       clearTimeout(this.waitingTimeoutId)

integration-tests/ci-visibility/test-impacted-test/test-impacted-1.js

@@ -0,0 +1,11 @@
+const { expect } = require('chai')
+
+describe('impacted tests', () => {
+  it('can pass normally', () => {
+    expect(1 + 2).to.equal(3)
+  })
+
+  it('can fail', () => {
+    expect(1 + 2).to.equal(4)
+  })
+})

integration-tests/ci-visibility/test-impacted-test/test-impacted-2.js

@@ -0,0 +1,11 @@
+const { expect } = require('chai')
+
+describe('impacted tests 2', () => {
+  it('can pass normally', () => {
+    expect(1 + 2).to.equal(3)
+  })
+
+  it('can fail', () => {
+    expect(1 + 2).to.equal(4)
+  })
+})