Service - Integration Testing: Difference between revisions

From Izara Wiki
Jump to navigation Jump to search
No edit summary
No edit summary
 
(36 intermediate revisions by the same user not shown)
Line 7: Line 7:
= DynamoDB tables =
= DynamoDB tables =


== TestRecord ==
== TestRecords ==


=== Fields ===
=== Fields ===
Line 15: Line 15:
; testStartedTimestamp
; testStartedTimestamp
: (sort key)
: (sort key)
: time that the integration test was started/created.
: time the integration test was started/created.
; testCompleteTimestamp
: time the integration test completed.
; testSettings
: straight copy of test configuration testSettings property
; stages
; stages
: an object that holds the details and status of each stage [[#testRecord.stages structure]]
: an object that holds the details and status of each stage [[#testRecord.stages structure]]
; testStatus
; testStatus
: current status of the integration test, either '''processing''', '''passed''', or '''failed'''
: current status of the integration test, either '''processing''', '''passed''', or '''failed'''
; errors
; testErrors
: an array of any misc errors found
: an array of any misc errors found (probably stored as a set, ordering is not important and should not have any duplicates)
 
= Lambda Functions =
 
== initiateIntegrationTest ==
 
<syntaxhighlight lang="JavaScript">
/**
* Starts integration test/s
* @param {string} [integrationTestTag] - Only initiate test with matching integrationTestTag
* @param {string} [serviceName] - Only initiate tests where initialStage serviceName matches
* @param {string} [resourceType] - Only initiate tests where initialStage resourceType matches
* @param {string} [resourceName] - Only initiate tests where initialStage resourceName matches
*
* @returns {boolean} true if the test was initiated successfully, false if the test could not be initiated (? or an error thrown ?)
*/
module.exports.handler = middleware.wrap(async (event, context, callback) => {
</syntaxhighlight>
 
=== logic ===
 
# Invoke [[Service - Integration Test Config:getIntegrationTests]] to get configurations of all matching tests
# For each integration test:
## For each integration test stage:
### Invoke [[Service - Integration Test Config:getEventConfig]] for inputEventTag, outputEventTag, record these in the stages config
### For each invokes element:
#### Invoke [[Service - Integration Test Config:getEventConfig]] for inputEventTag, outputEventTag, record these in the stages invoke config
####: (we could cache getEventConfig results, as many will be duplicated)
### Store in a variable config for the initialStage
###: (we do not want to invoke the initial request until all stages are saved into TestRecord table, to avoid race conditions)
## Save the resulting test's config into TestRecord table, testStatus set to ''processing''
## If no initialStage found add an error to testRecord.errors
## For the initialStage:
### Build initial event to start the test using the initialStage's input event
### Add intTest-xx correlation ids
### Invoke the initialStage's Lambda function
 
== receiveMsgResourceInput ==
 
<syntaxhighlight lang="JavaScript">
/**
* Triggered when a resource is invoked from an integration test request
* Triggered by it's own SQS queue, which subscribes to the tested services msgOut queue
* Checks if any stages in integration test config match resource invocation, if yes perform tests and record results
* @param {object} requestParams - The event body received by the resource
* @param {string} serviceName
* @param {string} resourceType
* @param {string} resourceName
*/
module.exports.handler = middleware.wrap(async (event, context, callback) => {
</syntaxhighlight>
 
=== logic ===
 
# Use intTest-tag and intTest-time correlation ids in received message to query TestRecord table for matching record, none found can return, but should send an system log because should not happen
# Iterate testRecord.stages to find matching stage using:
## serviceName / resourceType / resourceName
## For each testRecord.stages.{stage}.inputEventTag.properties if forStageMatching != false values should match
# If no matching stage found can return
# For each testRecord.stages.{stage}.inputEventTag.properties where testValueMatches != false test if value matches
# update testRecord.stages.{stage}.results.input values using a DynamoDB Conditional Expression to make sure testRecord.stages.{stage}.results.input does not already exist, if it exists add an element to testRecord.stages.{stage}.results.errors array because should only update once (message triggering receiveMsgResourceInput might get delivered multiple times, if experience that maybe adjust logic) ?? not sure can conditional expression on nested property in JSON, probably not, might need to move stage results into another table ??
# check if any tests for this stage remain using [[#checkStageTestsComplete]]
# if no tests remain, update testRecord.stages.{stage}.status to either passed or failed, use a DynamoDB Conditional Expression to make sure testRecord.stages.{stage}.status set to '''waiting''', if conditional expression does not pass means another process already updated it, should not happen,  add an element to testRecord.stages.{stage}.results.errors array (message triggering receiveMsgResourceInput might get delivered multiple times, if experience this maybe adjust logic) ?? not sure can conditional expression on nested property in JSON, probably not, might need to move stages into another table ??
 
== receiveMsgResourceOutput ==
 
<syntaxhighlight lang="JavaScript">
/**
* Triggered when a resource invoked by an integration test returns
* Triggered by it's own SQS queue, which subscribes to the tested services msgOut queue
* Checks if any stages in integration test config match resource invocation, if yes perform tests on return value and record results
* @param {object} requestParams - The event body received by the resource
* @param {string} serviceName
* @param {string} resourceType
* @param {string} resourceName
* @param {object} returnValue //how to handle errors? Maybe place the actual value into a property, and have other properties for error/other settings
*/
module.exports.handler = middleware.wrap(async (event, context, callback) => {
</syntaxhighlight>
 
=== logic ===
 
# Use intTest-tag and intTest-time correlation ids in received message to query TestRecord table for matching record, none found can return, but should send an system log because should not happen
# Iterate testRecord.stages to find matching stage using:
## serviceName / resourceType / resourceName
## For each testRecord.stages.{stage}.inputEventTag.properties if forStageMatching != false values should match
# If no matching stage found can return
# For each testRecord.stages.{stage}.inputEventTag.properties where testValueMatches != false test if value matches
# update testRecord.stages.{stage}.results.input values using a DynamoDB Conditional Expression to make sure testRecord.stages.{stage}.results.input does not already exist, if it exists add an element to testRecord.stages.{stage}.results.errors array because should only update once (message triggering receiveMsgResourceInput might get delivered multiple times, if experience that maybe adjust logic) ?? not sure can conditional expression on nested property in JSON, probably not, might need to move stage results into another table ??
# check if any tests for this stage remain using [[#checkStageTestsComplete]]
# if no tests remain, update testRecord.stages.{stage}.status to either passed or failed, use a DynamoDB Conditional Expression to make sure testRecord.stages.{stage}.status set to '''waiting''', if conditional expression does not pass means another process already updated it, should not happen,  add an element to testRecord.stages.{stage}.results.errors array (message triggering receiveMsgResourceInput might get delivered multiple times, if experience this maybe adjust logic) ?? not sure can conditional expression on nested property in JSON, probably not, might need to move stages into another table ??
 
= Functions =
 
== findMatchingStage ==
 
<syntaxhighlight lang="JavaScript">
/**
* Tests whether any tests for a single stage are waiting results
* @param {object} stage - the stage object to check
*
* @returns {boolean} true if all stage tests have results saved
*/
module.exports.checkStageTestsComplete = (stage, invokes) => {
</syntaxhighlight>
 
=== logic ===
 
# check if any tests for this stage remain:
## if the stage.config.inputEventTag set, has stage.results.input been set?
## if the stage.config.outputEventTag set, has stage.results.output been set?
## For each stage.config.invokes check has result set in stage.results.invokes.{invoke identifier}?
# if all stage tests have results return true
 
== checkStageTestsComplete ==
 
<syntaxhighlight lang="JavaScript">
/**
* Tests whether any tests for a single stage are waiting results
* @param {object} stage - the stage object to check
*
* @returns {boolean} true if all stage tests have results saved
*/
module.exports.checkStageTestsComplete = (stage, invokes) => {
</syntaxhighlight>
 
=== logic ===
 
# check if any tests for this stage remain:
## if the stage.config.inputEventTag set, has stage.results.input been set?
## if the stage.config.outputEventTag set, has stage.results.output been set?
## For each stage.config.invokes check has result set in stage.results.invokes.{invoke identifier}?
# if all stage tests have results return true


= testRecord.stages structure =
= testRecord.stages structure =
Line 160: Line 32:
[
[
     {
     {
         config: {
         stageConfig: {
             //straight copy of this stage from integration test config
             //straight copy of this stage from integration test config
         },
         },
         status: waiting|passed|failed,
         stageStatus: waiting|passed|failed,
         stageFinishedTimestamp: {time that all tests finished and testRecord.stages.{stage}.status updated}
         stageFinishedTimestamp: {time that all tests finished and testRecord.stages.{stageKey}.stageStatus updated}
         results: {
         stageResults: {
             input: {
             //results at the point of entering the resource (eg a Lambda function is invoked)
                //results at the point of entering the resource (eg a Lambda function is invoked)
            inputResult: {
                 timestamp: {when beginStage results were saved},
                 resultTimestamp: {time result saved},
                 status: passed|failed,
                 resultStatus: passed|failed,
                 requestParams: {a copy of the requestParams}
                 requestParams: {a copy of the requestParams}
             },
             },
             output: {
             //results at the point of returning from the resource (eg a Lambda function returns)
                //results at the point of entering the resource (eg a Lambda function is invoked)
            outputResult: {
                 timestamp: {when beginStage results were saved},
                 resultTimestamp: {time result saved},
                 status: passed|failed,
                 resultStatus: passed|failed,
                 returnValue: {a copy of the value returned by the resource}  
                 returnValue: {a copy of the value returned by the resource}  
                 //.. maybe other settings for errors etc..
                 //.. maybe other settings for errors etc..
             },
             },
            //results at the point of invoking an external resource (eg the tested Lambda function is invoking another Lambda function)
             invokes: {
             invokes: {
                 {serviceName_resourceType_resourceName_inputEventTag_outputEventTag}: {
                 {serviceName_resourceType_resourceName_inputEventTag}: {
                     //results at the point of invoking an external resource (eg the tested Lambda function is invoking another Lambda function)
                     invokeTimestamp: {time result saved},
                     timestamp: {when beginStage results were saved},
                     resultTimestamp: {time result saved},
                     status: passed|failed,
                     resultStatus: passed|failed,
                     requestParams: {a copy of the requestParams}
                     invokeParams: {a copy of the parameters sent to the resource}
                    returnValue: {a copy of the value returned by the resource}
                 },
                 },
                 ..
                 ..
             },
             },
            errors: [
        },
                //misc errors encountered
        stageErrors: [
            ]
            //misc errors encountered
        }
        ]
     },
     },
     ...
     ...
Line 199: Line 73:
= Initiating tests =
= Initiating tests =


When the initial request is sent to begin an integration test the middleware LOG_LEVEL is set to DEBUG, this causes all Lambda functions and requests to external services to also add a message to the services MsgOut queue.
When the initial request is sent add the following Correlation Ids to the initial request so we can track the integration test, filter messages, etc.:
 
The Integration Testing service subscribes to these queues and uses these messages to monitor each stage of the workflow to ensure input and output is as expected, and that the integration test completes fully.
 
Add the following Correlation Ids to the initial request so we can track the integration test, filter messages, etc.:


; intTest-tag
; intTest-tag
Line 209: Line 79:
; intTest-time
; intTest-time
: matches the test's testStartedTimestamp
: matches the test's testStartedTimestamp
; intTest-serviceName
: this services name, so other functions can generate the integration test topic names to send messages to


These can also be used in production environment to exclude requests that middleware randomly set to debug from requests initiated by Integration Test service.
These can also be used in production environment to exclude requests that middleware randomly set to debug from requests initiated by Integration Test service.


The Integration Testing service monitors each stage of the workflow to ensure input and output is as expected, and that the integration test completes fully.
When a lambda receives a request that has these correlation ids it generates the integration test topic name by using the intTest-serviceName + stage + hardcoded topic name.
= Ideas =
== More granular resource types ==
Currently API Gateway and SNS-SQS queue triggers for Lambda's are wrapped into the lambda event and test stage configurations, we could pull these out as separate resources that invoke the Lambda resource.
This would more clearly compartmentize each resource, increase configuration re-usablilty, and allow us to more clearly add additional tests, for example subscriptions to the SNS queues.
These new resource types could be an initial stage in the test configuration, when running integration tests the request would be sent to those resources (eg REST request to API Gateway or publish to SNS queue), on local unit tests we would need to build the triggered Lambda function directly, we could do this by following the invoke setting in the initial stage's config to find the triggered Lambda/s and building the event object for them.
= Bash script to invoke initiate tests =
<syntaxhighlight lang="bash">
declare -a groupTests=(
'{ "serviceName": "Permission", "resourceType": "Lambda", "resourceName": "CheckPermission"}'
'{ "serviceName": "Permission", "resourceType": "Lambda", "resourceName": "CheckPermission", "integrationTestTags": ["valueMatchCheck_oneRule_AnyCanPass_MustPassTrue__pass"] }'
'{ "serviceName": "Permission", "resourceType": "Lambda", "resourceName": "CheckPermission", "integrationTestTags": ["serviceCheck__oneRule__basic__targetUserId_admin__pass"] }'
)
stage="Test"
region="us-east-2"
for test in "${groupTests[@]}"; do
echo "=================================="
echo "start one set of tests"
echo ${test}
#... invoke InitateTests....
aws lambda invoke \
--function-name "IntTesting${stage}InitiateIntegrationTestHdrInv" \
--invocation-type Event \
--payload "${test}" \
--log-type Tail response.json \
--cli-binary-format raw-in-base64-out \
--region=${region}
done
</syntaxhighlight>
= Working documents =
[[:Category:Working_documents - Integration Testing|Working_documents - Integration Testing]]


[[Category:Backend services| Integration Testing]]
[[Category:Backend services| Integration Testing]]

Latest revision as of 03:30, 19 August 2021

Overview

Service that pulls integration tests from the Integration Test Config service, invokes each test and monitors the steps execute as expected.

This service is intended to be run in a deployed AWS environment, all services and resources required for the integration tests need to be operational.

DynamoDB tables

TestRecords

Fields

integrationTestTag
(partition key)
testStartedTimestamp
(sort key)
time the integration test was started/created.
testCompleteTimestamp
time the integration test completed.
testSettings
straight copy of test configuration testSettings property
stages
an object that holds the details and status of each stage #testRecord.stages structure
testStatus
current status of the integration test, either processing, passed, or failed
testErrors
an array of any misc errors found (probably stored as a set, ordering is not important and should not have any duplicates)

testRecord.stages structure

[
    {
        stageConfig: {
            //straight copy of this stage from integration test config
        },
        stageStatus: waiting|passed|failed,
        stageFinishedTimestamp: {time that all tests finished and testRecord.stages.{stageKey}.stageStatus updated}
        stageResults: {
            //results at the point of entering the resource (eg a Lambda function is invoked)
            inputResult: {
                resultTimestamp: {time result saved},
                resultStatus: passed|failed,
                requestParams: {a copy of the requestParams}
            },
            //results at the point of returning from the resource (eg a Lambda function returns)
            outputResult: {
                resultTimestamp: {time result saved},
                resultStatus: passed|failed,
                returnValue: {a copy of the value returned by the resource} 
                //.. maybe other settings for errors etc..
            },
            //results at the point of invoking an external resource (eg the tested Lambda function is invoking another Lambda function)
            invokes: {
                {serviceName_resourceType_resourceName_inputEventTag}: {
                    invokeTimestamp: {time result saved},
                    resultTimestamp: {time result saved},
                    resultStatus: passed|failed,
                    invokeParams: {a copy of the parameters sent to the resource}
                    returnValue: {a copy of the value returned by the resource}
                },
                ..
            },
        },
        stageErrors: [
            //misc errors encountered
        ]
    },
    ...
]

Initiating tests

When the initial request is sent add the following Correlation Ids to the initial request so we can track the integration test, filter messages, etc.:

intTest-tag
matches the test's integrationTestTag
intTest-time
matches the test's testStartedTimestamp
intTest-serviceName
this services name, so other functions can generate the integration test topic names to send messages to

These can also be used in production environment to exclude requests that middleware randomly set to debug from requests initiated by Integration Test service.

The Integration Testing service monitors each stage of the workflow to ensure input and output is as expected, and that the integration test completes fully.

When a lambda receives a request that has these correlation ids it generates the integration test topic name by using the intTest-serviceName + stage + hardcoded topic name.

Ideas

More granular resource types

Currently API Gateway and SNS-SQS queue triggers for Lambda's are wrapped into the lambda event and test stage configurations, we could pull these out as separate resources that invoke the Lambda resource.

This would more clearly compartmentize each resource, increase configuration re-usablilty, and allow us to more clearly add additional tests, for example subscriptions to the SNS queues.

These new resource types could be an initial stage in the test configuration, when running integration tests the request would be sent to those resources (eg REST request to API Gateway or publish to SNS queue), on local unit tests we would need to build the triggered Lambda function directly, we could do this by following the invoke setting in the initial stage's config to find the triggered Lambda/s and building the event object for them.

Bash script to invoke initiate tests

declare -a groupTests=(
	'{ "serviceName": "Permission", "resourceType": "Lambda", "resourceName": "CheckPermission"}'
	'{ "serviceName": "Permission", "resourceType": "Lambda", "resourceName": "CheckPermission", "integrationTestTags": ["valueMatchCheck_oneRule_AnyCanPass_MustPassTrue__pass"] }'
	'{ "serviceName": "Permission", "resourceType": "Lambda", "resourceName": "CheckPermission", "integrationTestTags": ["serviceCheck__oneRule__basic__targetUserId_admin__pass"] }'
)

stage="Test"
region="us-east-2"

for test in "${groupTests[@]}"; do
	echo "=================================="
	echo "start one set of tests"
	echo ${test}
	
	#... invoke InitateTests....
	aws lambda invoke \
	--function-name "IntTesting${stage}InitiateIntegrationTestHdrInv" \
	--invocation-type Event \
	--payload "${test}" \
	--log-type Tail response.json \
	--cli-binary-format raw-in-base64-out \
	--region=${region}
done

Working documents

Working_documents - Integration Testing