# Connector Definition Runner
This package provides the framework for connectors to be created with only schemas. It can make HTTP
calls based on what is defined in the schema.
## Asset Schema Structure
The asset schema defines the authentication that is used for the connector.
We currently support the following authentication methods:
* API Key (in the header, query parameters, or cookie)
* OAuth2
* Client Credential
* Password Grant
* HTTP Basic
* HTTP Bearer Token
Each authentication type has an asset file name and inputs that it requires. There is also a
`meta.security` key in the asset schema that contains the configuration for the authentication.
The asset file name must match the `name` field, unless it's a custom asset (See the examples below).
Examples:
### http_basic
```yaml
schema: asset/1
name: http_basic
title: HTTP Basic Authentication
description: 'Authenticates using username and password.'
inputs:
type: object
properties:
url:
title: URL
description: A URL to the target host.
type: string
default: https://www.example.com # change if it has a default cloud URL or remove if always custom.
username:
title: Username
description: Username
type: string
password:
title: Password
description: Password
type: string
format: password
verify_ssl:
title: Verify SSL Certificates
description: Verify SSL certificate
type: boolean
http_proxy:
title: HTTP(s) Proxy
description: A proxy to route requests through.
type: string
required:
- url
- username
- password
meta:
security:
type: http
scheme: basic
```
### http_bearer
```yaml
schema: asset/1
name: http_bearer
title: HTTP Bearer Authentication
description: 'Authenticates using bearer token such as a JWT, etc.'
inputs:
type: object
properties:
url:
title: URL
description: A URL to the target host.
type: string
default: https://www.example.com # change if it has a default cloud URL or remove if always custom.
token: # NEVER CHANGE THIS
title: Token # name this properly
description: The API key, token, etc. # name this properly
type: string
format: password
verify_ssl:
title: Verify SSL Certificates
description: Verify SSL certificate
type: boolean
http_proxy:
title: HTTP(s) Proxy
description: A proxy to route requests through.
type: string
required:
- url
- username
- password
meta:
security:
type: http
scheme: bearer
```
### apikey
```yaml
schema: asset/1
name: apikey
title: API Key Authentication
description: 'Authenticates using an API Key'
inputs:
type: object
properties:
url:
title: URL
description: A URL to the target host.
type: string
default: https://www.example.com # change if it has a default cloud URL or remove if always custom.
x-apikey: # example, replace with correct key name for product.
title: API Key
description: API key
type: string
format: password
verify_ssl:
title: Verify SSL Certificates
description: Verify SSL certificate
type: boolean
http_proxy:
title: HTTP(s) Proxy
description: A proxy to route requests through.
type: string
required:
- url
- x-apikey # example, replace with correct key name for product.
meta:
security:
type: apiKey
name: x-apikey # example, replace with correct key name for product.
in: header, cookie or query # please select the one applicable to the API and remove the others.
```
The `security` field inside `meta` could be an object or an array of objects.
**Examples:**
If you need to make a request with the header field `x-apikey` and add its value from the inputs, you can use the following schema.
In this case the `x-apikey` input field is mandatory.
```yaml
inputs:
type: object
properties:
x-apikey: # example, replace with correct key name for product.
title: API Key
type: string
format: password
meta:
security:
name: x-apikey
in: header
```
You can also define a template using mustache syntax with the input values. For example, if you want
to add to your header the field `Authorization: ApiToken my_token`, you can use the following schema
and use `my_token` as an input value.
```yaml
inputs:
type: object
properties:
token: # example, replace with correct key name for product.
title: Token
type: string
format: password
meta:
security:
name: Authorization
in: header
format: ApiToken {{token}}
```
### oauth2_client_credentials
The optional field `meta.security.token_endpoint` on this example can be used to set a token endpoint which will be
concatenated to the `url` input to create the token url. If you provide a `token_endpoint`, the `token_url` input
should not be required.
```yaml
schema: asset/1
name: oauth2_client_credentials
title: Oauth 2.0 Client Credentials
description: 'Authenticates using oauth 2.0 client credentials'
inputs:
type: object
properties:
url:
title: URL
description: A URL to the target host.
type: string
default: https://www.example.com # change if it has a default cloud URL or remove if always custom.
token_url:
title: Token URL
type: string
default: https://www.example.com/oauth/token # remove if this is static. Graph API requires tenant ID and would need the user input.
client_id:
title: Client ID
description: The client ID
type: string
client_secret:
title: Client Secret
description: The client secret.
type: string
format: password
scope:
title: Scope
description: Permission scopes for this action.
type: array
items:
type: string
default: [] # Add array of scopes we think are needed for the action.
verify_ssl:
title: Verify SSL Certificates
description: Verify SSL certificate
type: boolean
http_proxy:
title: HTTP(s) Proxy
description: A proxy to route requests through.
type: string
required:
- url
- client_id
- client_secret
- token_url
meta:
security:
token_endpoint: "api/oauth2/token"
type: oauth2
flow: client_credentials
```
### oauth2_password
The optional field `meta.security.token_endpoint` on this example can be used to set a token endpoint which will be
concatenated to the `url` input to create the token url. If you provide a `token_endpoint`, the `token_url` input
should not be required.
```yaml
schema: asset/1
name: oauth2_password
title: Oauth 2.0 Password Grant
description: 'Authenticates using oauth 2.0 client credentials'
inputs:
type: object
properties:
url:
title: URL
description: A URL to the target host.
type: string
default: https://www.example.com # change if it has a default cloud URL or remove if always custom.
token_url:
title: Token URL
type: string
default: https://www.example.com/oauth/token # remove if this is static. Graph API requires tenant ID and would need the user input.
oauth2_username:
title: OAuth2 Username
description: The username for authentication
type: string
oauth2_password:
title: OAuth2 Password
description: The password for authentication
type: string
format: password
client_id:
title: Client ID
description: The client ID
type: string
client_secret:
title: Client Secret
description: The client secret.
type: string
format: password
scope:
title: Scope
description: Permission scopes for this action.
type: array
items:
type: string
default: [] # Add array of scopes we think are needed for the action.
verify_ssl:
title: Verify SSL Certificates
description: Verify SSL certificate
type: boolean
http_proxy:
title: HTTP(s) Proxy
description: A proxy to route requests through.
type: string
required:
- url
- oauth2_username
- oauth2_password
- token_url
meta:
security:
token_endpoint: "api/oauth2/token"
type: oauth2
flow: password
```
## Action Schema Structure
The action schema will include the following fields:
* schema: The schema type, this differentiates the assets from actions.
* title: The action title
* name: The action internal name
* description: The action description
* inputs: object of input fields
* output: object with the output fields
* meta:
* endpoint: The HTTP endpoint
* method: The HTTP method
Example schema:
```yaml
schema: action/1
title: Delete Indicator
name: delete_indicator
description: Deletes an indicator
inputs:
type: object
properties:
json_body:
title: JSON Body
type: object
properties:
id:
title: ID
type: string
required:
- id
additionalProperties: false
required:
- json_body
additionalProperties: falase
output:
type: object
properties:
status_code:
title: Status Code
type: number
meta:
endpoint: iocs/entities/indicators/v1
method: DELETE
```
### Inputs
The `inputs` field must be an object type with the following properties:
* headers: Headers to send with the request.
* parameters: Parameters to send in the query string for the request.
* data_body: Raw data send in the body of the request.
* json_body: JSON data to send in the body of the request.
* files: Object or array of objects with the `contentDisposition: attachment` property.
* path_parameters: Parameters to be replaced in the URL.
**Path Parameters**
You can use mustaches to build the URL path based in the `path_parameters` values. For example, if you have the following URL:
```
https://api.crowdstrikefalcon/{{session_id}}/download/{{filename}}
```
and the following `path_parameters` inputs field:
```yaml
inputs:
type: object
properties:
path_parameters:
title: Path Parameters
type: object
properties:
session_id:
title: Session ID
type: string
filename:
title: File Name
type: string
required:
- session_id
- filename
```
Then the endpoint will be formatted using the input data in the `path_parameters` object.
**Files**
`files` inputs could also include binary inputs and additional properties for the file. For example:
```yaml
inputs:
type: object
properties:
attachments:
title: Attachments
type: array
items:
contentDisposition: attachment
type: object
additionalProperties: false
properties:
file:
type: string
format: binary
file_name:
type: string
examples: []
required:
- attachments
additionalProperties: true
```
You can also add additional properties into the attachment properties. For example, if you need to replicate the following
code:
```python
import requests
headers = {
'accept': 'application/json'
}
files = [
('file', open('decode.py;type=text/x-python-script', 'rb')),
('permission_type', (None, 'public')),
('platform', (None, 'linux'))
]
response = requests.post('https://api.crowdstrike.com/real-time-response/entities/scripts/v1', headers=headers, files=files)
```
You can use the following input:
```yaml
inputs:
type: object
properties:
attachments:
title: Attachments
type: array
items:
contentDisposition: attachment
type: object
additionalProperties: false
properties:
file:
type: string
format: binary
file_name:
type: string
permission_type:
type: string
platform:
type: string
required:
- attachments
additionalProperties: true
```
### Outputs
The `output` field works similar to `inputs`, with the difference that it could be an array instead of an object.
It will contain the following properties:
* `status_code`: The status code of the response.
* `response_headers`: The headers of the response.
* `reason`: A text corresponding to the status code. For example, OK for 200, Not Found for 404.
* `json_body`: A JSON object of the response
* `response_text`: If the response doesn't contain a JSON body and there is no `file` property defined in the manifest, the response body will be returned in text format.
* `file`: Object or array of objects with the `contentDisposition: attachment` property.
In order to get files as output, you must manually add a file property to the output section. See the following example:
```yaml
output:
type: object
properties:
attachments:
title: Attachments
type: array
items:
contentDisposition: attachment
type: object
additionalProperties: false
properties:
file:
type: string
format: binary
filename:
type: string
additionalProperties: true
```
## Custom Action
In order to add custom actions, you must create a `.py` file and its file name must match with the corresponding manifest.
The source code must have a `RunnerOverride` class with the following interface:
```python
class RunnerOverride:
def __init__(self, asset=asset, asset_schema=asset_schema, http_proxy=http_proxy):
pass
def run(self, inputs=inputs, action_schema=action_schema):
pass
```
For example, suppose you want to create an action that makes an add operation using LDAP protocol.
You can create the following schema in `connector/config/actions/add.yaml`:
```yaml
schema: action/1
title: Add
name: add
description: >-
The Add operation allows a client to request the addition of an entry into the
LDAP directory.
inputs:
type: object
properties:
dn:
title: Dn
examples:
- CN=Charles,OU=friends,DC=testdomain,DC=local
type: string
object_class:
title: Object Class
examples:
- - person
type: array
items:
type: string
attributes:
title: Attributes
examples:
- name: Charles Darwin
type: object
properties:
name:
title: Name
examples:
- Charles Darwin
type: string
required: []
additionalProperties: true
required:
- dn
- object_class
additionalProperties: true
output:
type: object
properties:
result:
title: Result
type: number
description:
title: Description
type: string
dn:
title: Dn
type: string
message:
title: Message
type: string
referrals:
title: Referrals
type: object
properties: {}
required: []
additionalProperties: true
type:
title: Type
type: string
required: []
additionalProperties: true
meta: {}
```
And then create the file `connector/src/add.py` with the source code:
```python
import json
import os
from ldap3 import Server, Connection
class RunnerOverride(LdapActionBasic):
def __init__(self, asset=asset, asset_schema=asset_schema, http_proxy=None):
self.server = Server(asset["ip"],
use_ssl=asset.get("verify_ssl", True),
connect_timeout=asset.get("connect_timeout", 10))
self.conn = Connection(self.server,
asset["username"],
asset["password"],
auto_bind=True)
def run(self, inputs=inputs, action_schema=None):
self.conn.add(inputs)
return self.conn.result
```
## Custom Authentication
In order to add custom authentication, you must create a `runner_override.py` file.
The file must have a `RunnerOverride` class with the following interface:
```python
class RunnerOverride:
def __init__(self, asset=asset, asset_schema=asset_schema, http_proxy=http_proxy):
pass
def run(self, inputs=inputs, action_schema=action_schema):
pass
```
When this file is present, all actions will use it.
## Custom headers
You can build your own header field templates using mustache syntax. For example
if you need to define a custom header field like: `auth: my_username:my_password` for all your actions, you can define the following asset schema:
```yaml
schema: asset/1
title: HTTP Custom Authentication
description: 'Authenticates using username and password.'
inputs:
type: object
properties:
url:
title: URL
description: A URL to the target host.
type: string
default: https://www.example.com # change if it has a default cloud URL or remove if always custom.
username:
title: Username
description: Username
type: string
password:
title: Password
description: Password
type: string
format: password
required:
- url
- username
- password
meta:
headers:
auth: {{username}}:{{password}}
```
This way the username and password will be replaced in the `meta.headers.auth` field. You can also define the same way custom headers for action schemas.
Raw data
{
"_id": null,
"home_page": "https://github.com/swimlane/connector-definition-runner",
"name": "connector_def_runner",
"maintainer": "Swimlane",
"docs_url": null,
"requires_python": "<4.0,>=3.7",
"maintainer_email": null,
"keywords": "connector, swimlane, connectors",
"author": "Swimlane",
"author_email": "integrations@swimlane.com",
"download_url": "https://files.pythonhosted.org/packages/23/a7/d2da837c7beba39f3428bd0688b011cc9cf1ddf5b0ad6ada3c7899738f49/connector_def_runner-2.3.7.tar.gz",
"platform": null,
"description": "# Connector Definition Runner\n\nThis package provides the framework for connectors to be created with only schemas. It can make HTTP \ncalls based on what is defined in the schema.\n## Asset Schema Structure\n\nThe asset schema defines the authentication that is used for the connector. \n\nWe currently support the following authentication methods:\n* API Key (in the header, query parameters, or cookie)\n* OAuth2\n * Client Credential\n * Password Grant\n* HTTP Basic\n* HTTP Bearer Token\n\nEach authentication type has an asset file name and inputs that it requires. There is also a \n`meta.security` key in the asset schema that contains the configuration for the authentication.\nThe asset file name must match the `name` field, unless it's a custom asset (See the examples below).\n\nExamples:\n\n### http_basic\n\n```yaml\nschema: asset/1\nname: http_basic\ntitle: HTTP Basic Authentication\ndescription: 'Authenticates using username and password.'\ninputs:\n type: object\n properties:\n url:\n title: URL\n description: A URL to the target host.\n type: string\n default: https://www.example.com # change if it has a default cloud URL or remove if always custom.\n username:\n title: Username\n description: Username\n type: string\n password:\n title: Password\n description: Password\n type: string\n format: password\n verify_ssl:\n title: Verify SSL Certificates\n description: Verify SSL certificate\n type: boolean\n http_proxy:\n title: HTTP(s) Proxy\n description: A proxy to route requests through.\n type: string\n required:\n - url\n - username\n - password\nmeta:\n security:\n type: http\n scheme: basic\n```\n\n### http_bearer\n\n```yaml\nschema: asset/1\nname: http_bearer\ntitle: HTTP Bearer Authentication\ndescription: 'Authenticates using bearer token such as a JWT, etc.'\ninputs:\n type: object\n properties:\n url:\n title: URL\n description: A URL to the target host.\n type: string\n default: https://www.example.com # change if it has a default cloud URL or remove if always custom.\n token: # NEVER CHANGE THIS\n title: Token # name this properly\n description: The API key, token, etc. # name this properly\n type: string\n format: password\n verify_ssl:\n title: Verify SSL Certificates\n description: Verify SSL certificate\n type: boolean\n http_proxy:\n title: HTTP(s) Proxy\n description: A proxy to route requests through.\n type: string\n required:\n - url\n - username\n - password\nmeta:\n security:\n type: http\n scheme: bearer\n```\n### apikey\n```yaml\nschema: asset/1\nname: apikey\ntitle: API Key Authentication\ndescription: 'Authenticates using an API Key'\ninputs:\n type: object\n properties:\n url:\n title: URL\n description: A URL to the target host.\n type: string\n default: https://www.example.com # change if it has a default cloud URL or remove if always custom.\n x-apikey: # example, replace with correct key name for product.\n title: API Key\n description: API key\n type: string\n format: password\n verify_ssl:\n title: Verify SSL Certificates\n description: Verify SSL certificate\n type: boolean\n http_proxy:\n title: HTTP(s) Proxy\n description: A proxy to route requests through.\n type: string\n required:\n - url\n - x-apikey # example, replace with correct key name for product.\nmeta:\n security:\n type: apiKey\n name: x-apikey # example, replace with correct key name for product.\n in: header, cookie or query # please select the one applicable to the API and remove the others.\n\n```\n\nThe `security` field inside `meta` could be an object or an array of objects. \n\n**Examples:**\n\nIf you need to make a request with the header field `x-apikey` and add its value from the inputs, you can use the following schema. \nIn this case the `x-apikey` input field is mandatory.\n\n```yaml\ninputs:\n type: object\n properties:\n x-apikey: # example, replace with correct key name for product.\n title: API Key\n type: string\n format: password\nmeta:\n security:\n name: x-apikey\n in: header\n```\n\nYou can also define a template using mustache syntax with the input values. For example, if you want \nto add to your header the field `Authorization: ApiToken my_token`, you can use the following schema\nand use `my_token` as an input value. \n\n\n```yaml\ninputs:\n type: object\n properties:\n token: # example, replace with correct key name for product.\n title: Token\n type: string\n format: password\nmeta:\n security:\n name: Authorization\n in: header\n format: ApiToken {{token}}\n```\n\n### oauth2_client_credentials\n\nThe optional field `meta.security.token_endpoint` on this example can be used to set a token endpoint which will be \nconcatenated to the `url` input to create the token url. If you provide a `token_endpoint`, the `token_url` input\nshould not be required.\n\n```yaml\nschema: asset/1\nname: oauth2_client_credentials\ntitle: Oauth 2.0 Client Credentials\ndescription: 'Authenticates using oauth 2.0 client credentials'\ninputs:\n type: object\n properties:\n url:\n title: URL\n description: A URL to the target host.\n type: string\n default: https://www.example.com # change if it has a default cloud URL or remove if always custom.\n token_url:\n title: Token URL\n type: string\n default: https://www.example.com/oauth/token # remove if this is static. Graph API requires tenant ID and would need the user input.\n client_id:\n title: Client ID\n description: The client ID\n type: string\n client_secret:\n title: Client Secret\n description: The client secret.\n type: string\n format: password\n scope:\n title: Scope\n description: Permission scopes for this action.\n type: array\n items:\n type: string\n default: [] # Add array of scopes we think are needed for the action.\n verify_ssl:\n title: Verify SSL Certificates\n description: Verify SSL certificate\n type: boolean\n http_proxy:\n title: HTTP(s) Proxy\n description: A proxy to route requests through.\n type: string\n required:\n - url\n - client_id\n - client_secret\n - token_url\nmeta:\n security:\n token_endpoint: \"api/oauth2/token\"\n type: oauth2\n flow: client_credentials\n```\n\n### oauth2_password\n\nThe optional field `meta.security.token_endpoint` on this example can be used to set a token endpoint which will be \nconcatenated to the `url` input to create the token url. If you provide a `token_endpoint`, the `token_url` input\nshould not be required.\n\n```yaml\nschema: asset/1\nname: oauth2_password\ntitle: Oauth 2.0 Password Grant\ndescription: 'Authenticates using oauth 2.0 client credentials'\ninputs:\n type: object\n properties:\n url:\n title: URL\n description: A URL to the target host.\n type: string\n default: https://www.example.com # change if it has a default cloud URL or remove if always custom.\n token_url:\n title: Token URL\n type: string\n default: https://www.example.com/oauth/token # remove if this is static. Graph API requires tenant ID and would need the user input.\n oauth2_username:\n title: OAuth2 Username\n description: The username for authentication\n type: string\n oauth2_password:\n title: OAuth2 Password\n description: The password for authentication\n type: string\n format: password\n client_id:\n title: Client ID\n description: The client ID\n type: string\n client_secret:\n title: Client Secret\n description: The client secret.\n type: string\n format: password\n scope:\n title: Scope\n description: Permission scopes for this action.\n type: array\n items:\n type: string\n default: [] # Add array of scopes we think are needed for the action.\n verify_ssl:\n title: Verify SSL Certificates\n description: Verify SSL certificate\n type: boolean\n http_proxy:\n title: HTTP(s) Proxy\n description: A proxy to route requests through.\n type: string\n required:\n - url\n - oauth2_username\n - oauth2_password\n - token_url\nmeta:\n security:\n token_endpoint: \"api/oauth2/token\"\n type: oauth2\n flow: password\n```\n\n## Action Schema Structure\n\nThe action schema will include the following fields:\n\n* schema: The schema type, this differentiates the assets from actions.\n* title: The action title\n* name: The action internal name\n* description: The action description\n* inputs: object of input fields\n* output: object with the output fields\n* meta:\n * endpoint: The HTTP endpoint\n * method: The HTTP method\n\nExample schema:\n\n```yaml\nschema: action/1\ntitle: Delete Indicator\nname: delete_indicator\ndescription: Deletes an indicator\ninputs:\n type: object\n properties:\n json_body:\n title: JSON Body\n type: object\n properties:\n id:\n title: ID\n type: string\n required:\n - id\n additionalProperties: false\n required: \n - json_body\n additionalProperties: falase\noutput:\n type: object\n properties:\n status_code:\n title: Status Code\n type: number\nmeta:\n endpoint: iocs/entities/indicators/v1\n method: DELETE\n```\n### Inputs\n\nThe `inputs` field must be an object type with the following properties:\n\n* headers: Headers to send with the request.\n* parameters: Parameters to send in the query string for the request.\n* data_body: Raw data send in the body of the request.\n* json_body: JSON data to send in the body of the request.\n* files: Object or array of objects with the `contentDisposition: attachment` property. \n* path_parameters: Parameters to be replaced in the URL.\n\n\n**Path Parameters**\n\nYou can use mustaches to build the URL path based in the `path_parameters` values. For example, if you have the following URL:\n\n```\nhttps://api.crowdstrikefalcon/{{session_id}}/download/{{filename}}\n```\n\nand the following `path_parameters` inputs field:\n\n\n```yaml\ninputs:\n type: object\n properties:\n path_parameters:\n title: Path Parameters\n type: object\n properties:\n session_id:\n title: Session ID\n type: string\n filename:\n title: File Name\n type: string\n required:\n - session_id\n - filename\n```\n\nThen the endpoint will be formatted using the input data in the `path_parameters` object.\n\n\n**Files**\n\n`files` inputs could also include binary inputs and additional properties for the file. For example:\n\n```yaml\ninputs:\n type: object\n properties:\n attachments:\n title: Attachments\n type: array\n items:\n contentDisposition: attachment\n type: object\n additionalProperties: false\n properties:\n file:\n type: string\n format: binary\n file_name:\n type: string\n examples: []\n required:\n - attachments\n additionalProperties: true\n```\n\nYou can also add additional properties into the attachment properties. For example, if you need to replicate the following\ncode:\n\n```python\nimport requests\n\nheaders = {\n 'accept': 'application/json'\n}\n\nfiles = [\n ('file', open('decode.py;type=text/x-python-script', 'rb')),\n ('permission_type', (None, 'public')),\n ('platform', (None, 'linux'))\n]\n\nresponse = requests.post('https://api.crowdstrike.com/real-time-response/entities/scripts/v1', headers=headers, files=files)\n```\n\nYou can use the following input:\n\n```yaml\ninputs:\n type: object\n properties:\n attachments:\n title: Attachments\n type: array\n items:\n contentDisposition: attachment\n type: object\n additionalProperties: false\n properties:\n file:\n type: string\n format: binary\n file_name:\n type: string\n permission_type:\n type: string\n platform:\n type: string\n required:\n - attachments\n additionalProperties: true\n```\n\n\n### Outputs\n\nThe `output` field works similar to `inputs`, with the difference that it could be an array instead of an object.\n\nIt will contain the following properties:\n\n* `status_code`: The status code of the response.\n* `response_headers`: The headers of the response.\n* `reason`: A text corresponding to the status code. For example, OK for 200, Not Found for 404.\n* `json_body`: A JSON object of the response\n* `response_text`: If the response doesn't contain a JSON body and there is no `file` property defined in the manifest, the response body will be returned in text format. \n* `file`: Object or array of objects with the `contentDisposition: attachment` property.\n\nIn order to get files as output, you must manually add a file property to the output section. See the following example:\n\n```yaml\noutput:\n type: object\n properties:\n attachments:\n title: Attachments\n type: array\n items:\n contentDisposition: attachment\n type: object\n additionalProperties: false\n properties:\n file:\n type: string\n format: binary\n filename:\n type: string\n additionalProperties: true\n```\n\n## Custom Action\n\nIn order to add custom actions, you must create a `.py` file and its file name must match with the corresponding manifest.\nThe source code must have a `RunnerOverride` class with the following interface:\n\n```python\nclass RunnerOverride:\n\n def __init__(self, asset=asset, asset_schema=asset_schema, http_proxy=http_proxy):\n pass\n\n def run(self, inputs=inputs, action_schema=action_schema):\n pass\n```\n\nFor example, suppose you want to create an action that makes an add operation using LDAP protocol. \nYou can create the following schema in `connector/config/actions/add.yaml`:\n\n```yaml\nschema: action/1\ntitle: Add\nname: add\ndescription: >-\n The Add operation allows a client to request the addition of an entry into the\n LDAP directory.\ninputs:\n type: object\n properties:\n dn:\n title: Dn\n examples:\n - CN=Charles,OU=friends,DC=testdomain,DC=local\n type: string\n object_class:\n title: Object Class\n examples:\n - - person\n type: array\n items:\n type: string\n attributes:\n title: Attributes\n examples:\n - name: Charles Darwin\n type: object\n properties:\n name:\n title: Name\n examples:\n - Charles Darwin\n type: string\n required: []\n additionalProperties: true\n required:\n - dn\n - object_class\n additionalProperties: true\noutput:\n type: object\n properties:\n result:\n title: Result\n type: number\n description:\n title: Description\n type: string\n dn:\n title: Dn\n type: string\n message:\n title: Message\n type: string\n referrals:\n title: Referrals\n type: object\n properties: {}\n required: []\n additionalProperties: true\n type:\n title: Type\n type: string\n required: []\n additionalProperties: true\nmeta: {}\n```\n\nAnd then create the file `connector/src/add.py` with the source code:\n\n```python\n\nimport json\nimport os\nfrom ldap3 import Server, Connection\n\n\nclass RunnerOverride(LdapActionBasic):\n\n def __init__(self, asset=asset, asset_schema=asset_schema, http_proxy=None):\n self.server = Server(asset[\"ip\"],\n use_ssl=asset.get(\"verify_ssl\", True),\n connect_timeout=asset.get(\"connect_timeout\", 10))\n self.conn = Connection(self.server,\n asset[\"username\"],\n asset[\"password\"],\n auto_bind=True)\n\n def run(self, inputs=inputs, action_schema=None):\n self.conn.add(inputs)\n return self.conn.result\n```\n\n## Custom Authentication\n\nIn order to add custom authentication, you must create a `runner_override.py` file.\nThe file must have a `RunnerOverride` class with the following interface:\n\n```python\nclass RunnerOverride:\n\n def __init__(self, asset=asset, asset_schema=asset_schema, http_proxy=http_proxy):\n pass\n\n def run(self, inputs=inputs, action_schema=action_schema):\n pass\n```\nWhen this file is present, all actions will use it.\n\n\n## Custom headers\n\nYou can build your own header field templates using mustache syntax. For example\nif you need to define a custom header field like: `auth: my_username:my_password` for all your actions, you can define the following asset schema:\n\n```yaml\nschema: asset/1\ntitle: HTTP Custom Authentication\ndescription: 'Authenticates using username and password.'\ninputs:\n type: object\n properties:\n url:\n title: URL\n description: A URL to the target host.\n type: string\n default: https://www.example.com # change if it has a default cloud URL or remove if always custom.\n username:\n title: Username\n description: Username\n type: string\n password:\n title: Password\n description: Password\n type: string\n format: password\n required:\n - url\n - username\n - password\nmeta:\n headers:\n auth: {{username}}:{{password}}\n```\n\nThis way the username and password will be replaced in the `meta.headers.auth` field. You can also define the same way custom headers for action schemas.\n",
"bugtrack_url": null,
"license": null,
"summary": "Run connectors by schema definitions",
"version": "2.3.7",
"project_urls": {
"Homepage": "https://github.com/swimlane/connector-definition-runner",
"Repository": "https://github.com/swimlane/connector-definition-runner"
},
"split_keywords": [
"connector",
" swimlane",
" connectors"
],
"urls": [
{
"comment_text": "",
"digests": {
"blake2b_256": "eaa0633ae00e68e8269194874c07784816291baf6d666ec15ef225e0a1458b69",
"md5": "6e222c469890f2e83d111a6ae007e2bc",
"sha256": "2ce3fb93d3c6b4ccd0074cdb22d176f3e4452f813588505eec918d39daed3ea4"
},
"downloads": -1,
"filename": "connector_def_runner-2.3.7-py3-none-any.whl",
"has_sig": false,
"md5_digest": "6e222c469890f2e83d111a6ae007e2bc",
"packagetype": "bdist_wheel",
"python_version": "py3",
"requires_python": "<4.0,>=3.7",
"size": 9791,
"upload_time": "2024-07-22T09:37:37",
"upload_time_iso_8601": "2024-07-22T09:37:37.474011Z",
"url": "https://files.pythonhosted.org/packages/ea/a0/633ae00e68e8269194874c07784816291baf6d666ec15ef225e0a1458b69/connector_def_runner-2.3.7-py3-none-any.whl",
"yanked": false,
"yanked_reason": null
},
{
"comment_text": "",
"digests": {
"blake2b_256": "23a7d2da837c7beba39f3428bd0688b011cc9cf1ddf5b0ad6ada3c7899738f49",
"md5": "1e946187dc38f36b656bd0a62192f303",
"sha256": "86bdf75c856d580870ba8998f8b7cd6e1bbb0908bd39d088a1ee690c5f58f6ad"
},
"downloads": -1,
"filename": "connector_def_runner-2.3.7.tar.gz",
"has_sig": false,
"md5_digest": "1e946187dc38f36b656bd0a62192f303",
"packagetype": "sdist",
"python_version": "source",
"requires_python": "<4.0,>=3.7",
"size": 11509,
"upload_time": "2024-07-22T09:37:38",
"upload_time_iso_8601": "2024-07-22T09:37:38.779911Z",
"url": "https://files.pythonhosted.org/packages/23/a7/d2da837c7beba39f3428bd0688b011cc9cf1ddf5b0ad6ada3c7899738f49/connector_def_runner-2.3.7.tar.gz",
"yanked": false,
"yanked_reason": null
}
],
"upload_time": "2024-07-22 09:37:38",
"github": true,
"gitlab": false,
"bitbucket": false,
"codeberg": false,
"github_user": "swimlane",
"github_project": "connector-definition-runner",
"github_not_found": true,
"lcname": "connector_def_runner"
}
JSON
