feat(python): add AWS dynamoDB NoSQLi rule (CWE-943)

rules/python/third_parties/aws_query_injection.yml

@@ -0,0 +1,149 @@
+imports:
+  - python_shared_common_user_input
+  - python_shared_lang_import1
+patterns:
+  # simple db
+  - pattern: $<CALLER>.select($<...>SelectExpression=$<USER_INPUT>$<...>)
+    filters:
+      - variable: CALLER
+        detection: python_third_parties_aws_query_injection_simpledb_caller
+        scope: result
+      - variable: USER_INPUT
+        detection: python_third_parties_aws_query_injection_user_input
+        scope: result
+  # dynamodb
+  - pattern: $<CALLER>.$<METHOD>($<...>FilterExpression=$<USER_INPUT>$<...>)
+    filters:
+      - variable: CALLER
+        detection: python_third_parties_aws_query_injection_dynamodb_caller
+        scope: result
+      - variable: METHOD
+        values:
+          - query
+          - scan
+      - variable: USER_INPUT
+        detection: python_third_parties_aws_query_injection_user_input
+        scope: result
+  - pattern: $<CALLER>.update_item($<...>UpdateExpression=$<USER_INPUT>$<...>)
+    filters:
+      - variable: CALLER
+        detection: python_third_parties_aws_query_injection_dynamodb_caller
+        scope: result
+      - variable: USER_INPUT
+        detection: python_third_parties_aws_query_injection_user_input
+        scope: result
+  # legacy dynamodb
+  - pattern: $<CALLER>.query($<...>QueryFilter=$<USER_INPUT>$<...>)
+    filters:
+      - variable: CALLER
+        detection: python_third_parties_aws_query_injection_dynamodb_caller
+        scope: result
+      - variable: USER_INPUT
+        detection: python_third_parties_aws_query_injection_user_input
+        scope: result
+  - pattern: $<CALLER>.scan($<...>ScanFilter=$<USER_INPUT>$<...>)
+    filters:
+      - variable: CALLER
+        detection: python_third_parties_aws_query_injection_dynamodb_caller
+        scope: result
+      - variable: USER_INPUT
+        detection: python_third_parties_aws_query_injection_user_input
+        scope: result
+auxiliary:
+  - id: python_third_parties_aws_query_injection_simpledb_caller
+    patterns:
+      - pattern: $<BOTO3_CLIENT>($<SIMPLEDB>$<...>)
+        filters:
+          - variable: SIMPLEDB
+            string_regex: \Asdb\z
+          - variable: BOTO3_CLIENT
+            detection: python_shared_lang_import1
+            scope: cursor
+            filters:
+              - variable: MODULE1
+                values: [boto3]
+              - variable: NAME
+                values: [client]
+  - id: python_third_parties_aws_query_injection_dynamodb_caller
+    patterns:
+      - pattern: $<DYNAMODB_INIT>.Table($<...>)
+        filters:
+          - variable: DYNAMODB_INIT
+            detection: python_third_parties_aws_query_injection_dynamodb_init
+            scope: result
+      - pattern: $<BOTO3_CLIENT>($<DYNAMODB>$<...>)
+        filters:
+          - variable: DYNAMODB
+            string_regex: \Adynamodb\z
+          - variable: BOTO3_CLIENT
+            detection: python_shared_lang_import1
+            scope: cursor
+            filters:
+              - variable: MODULE1
+                values: [boto3]
+              - variable: NAME
+                values: [client]
+  - id: python_third_parties_aws_query_injection_dynamodb_init
+    patterns:
+      - pattern: $<BOTO3_RESOURCE>($<DYNAMODB>$<...>)
+        filters:
+          - variable: DYNAMODB
+            string_regex: \Adynamodb\z
+          - variable: BOTO3_RESOURCE
+            detection: python_shared_lang_import1
+            scope: cursor
+            filters:
+              - variable: MODULE1
+                values: [boto3]
+              - variable: NAME
+                values: [resource]
+  - id: python_third_parties_aws_query_injection_user_input
+    sanitizer: python_third_parties_aws_query_injection_sanitizer
+    patterns:
+      - pattern: $<USER_INPUT>
+        filters:
+          - variable: USER_INPUT
+            detection: python_shared_common_user_input
+            scope: cursor
+  - id: python_third_parties_aws_query_injection_sanitizer
+    patterns:
+      - pattern: |
+          { $<_>: $<!>$<_> }
+languages:
+  - python
+severity: critical
+metadata:
+  description: Unsanitized user input in AWS query
+  remediation_message: |
+    ## Description
+
+    Including unsanitized data, such as user input or request data, in raw queries makes your application vulnerable to injection attacks.
+
+    ## Remediations
+
+    - **Do** always sanitize user input especially if it is to be used in database queries. Where possible, such sanitization should include the removal of special characters (like ' or ") that could be used to alter the semantics of a database query.
+    - **Do** validate user input wherever possible, to ensure it is the expected format and length
+    - **Do** use parameterized queries rather than concatenating user input directly into a query string. This separates query logic from user input, which is good practice. With DynamoDB, for example, you can make use of `ExpressionAttributeNames` and `ExpressionAttributeValues` parameters for this separation: 
+      ```python
+        dynamodb = boto3.resource('dynamodb')
+        table = dynamodb.Table('users')
+        
+        table.update_item(
+          Key={
+              'username': 'johndoe',
+              'last_name': 'Doe'
+          },
+          UpdateExpression='SET age = :val1',
+          ExpressionAttributeValues={
+              ':val1': 42
+          }
+        )
+      ```
+
+    ## References
+    - [AWS DynamoDB docs](https://docs.aws.amazon.com/dynamodb/)
+    - [AWS SimpleDB docs](https://docs.aws.amazon.com/AmazonSimpleDB/latest/DeveloperGuide/Welcome.html)
+  cwe_id:
+    - 943
+  id: python_third_parties_aws_query_injection
+  documentation_url: https://docs.bearer.com/reference/rules/python_third_parties_aws_query_injection

tests/python/third_parties/aws_query_injection/test.js

@@ -0,0 +1,20 @@
+const {
+  createNewInvoker,
+  getEnvironment,
+} = require("../../../helper.js")
+const { ruleId, ruleFile, testBase } = getEnvironment(__dirname)
+
+describe(ruleId, () => {
+  const invoke = createNewInvoker(ruleId, ruleFile, testBase)
+
+  test("aws_query_injection", () => {
+    const testCase = "main.py"
+
+    const results = invoke(testCase)
+
+    expect(results).toEqual({
+      Missing: [],
+      Extra: []
+    })
+  })
+})

tests/python/third_parties/aws_query_injection/testdata/main.py

@@ -0,0 +1,60 @@
+import boto3
+
+DYNAMODB = 'dynamodb'
+# dynamo db
+def bad(event, context):
+  dynamodb = boto3.resource(DYNAMODB, '')
+  users_table = dynamodb.Table('users')
+
+  # bearer:expected python_third_parties_aws_query_injection
+  users_table.query(
+    Select = 'ALL_ATTRIBUTES', 
+    FilterExpression = event.body.filter
+  )
+
+  # bearer:expected python_third_parties_aws_query_injection
+  users_table.scan(
+    Select = 'ALL_ATTRIBUTES', 
+    FilterExpression = event.body.filter
+  )
+
+  dynamodb = boto3.client('dynamodb')
+  # bearer:expected python_third_parties_aws_query_injection
+  dynamodb.query(
+     TableName='users',
+     FilterExpression = event.body.filter,
+     Select = "ALL_ATTRIBUTES"
+  )
+
+# simple db
+def bad2(event, context):
+   client = boto3.client('sdb')
+  # bearer:expected python_third_parties_aws_query_injection
+   client.select(
+      SelectExpression = event.body.select_expr,
+      NextToken = "string",
+      ConsistentRead = true
+   )
+
+# dynamodb, simple db OK cases
+def ok(event, context):   
+  client = boto3.client('sdb')
+  client.select(
+    SelectExpression = "select * from 'users' where 'username' = 'john smith'",
+    NextToken = "string",
+    ConsistentRead = true
+  )
+
+  dynamodb = boto3.resource('dynamodb', '')
+  users_table = dynamodb.Table('users')
+  user_table.query(
+    Select = 'ALL_ATTRIBUTES', 
+    FilterExpression = {'username': event.body.username},
+  )
+
+  dynamodb = boto3.client('dynamodb')
+  dynamodb.query(
+    TableName='users',
+    FilterExpression = {'username': event.body.username},
+    Select = "ALL_ATTRIBUTES"
+  )