Submission for source-bamboohr from Connector Builder

Author: parthiv11

airbyte-integrations/connectors/source-bamboohr/README.md

@@ -0,0 +1,33 @@
+# BambooHR
+This directory contains the manifest-only connector for `source-bamboohr`.
+
+The BambooHR source connector for Airbyte allows seamless extraction of HR data through multiple configurable streams, including `custom_reports_stream`, `employees_directory_stream`, `meta_fields_stream`, `time_off_requests_stream`, `timesheet_entries`, and `employees`.
+
+## Usage
+There are multiple ways to use this connector:
+- You can use this connector as any other connector in Airbyte Marketplace.
+- You can load this connector in `pyairbyte` using `get_source`!
+- You can open this connector in Connector Builder, edit it, and publish to your workspaces.
+
+Please refer to the manifest-only connector documentation for more details.
+
+## Local Development
+We recommend you use the Connector Builder to edit this connector.
+
+But, if you want to develop this connector locally, you can use the following steps.
+
+### Environment Setup
+You will need `airbyte-ci` installed. You can find the documentation [here](airbyte-ci).
+
+### Build
+This will create a dev image (`source-bamboohr:dev`) that you can use to test the connector locally.
+```bash
+airbyte-ci connectors --name=source-bamboohr build
+```
+
+### Test
+This will run the acceptance tests for the connector.
+```bash
+airbyte-ci connectors --name=source-bamboohr test
+```
+

airbyte-integrations/connectors/source-bamboohr/acceptance-test-config.yml

@@ -0,0 +1,17 @@
+# See [Connector Acceptance Tests](https://docs.airbyte.com/connector-development/testing-connectors/connector-acceptance-tests-reference)
+# for more information about how to configure these tests
+connector_image: airbyte/source-bamboohr:dev
+acceptance_tests:
+  spec:
+    tests:
+      - spec_path: "manifest.yaml"
+  connection:
+    bypass_reason: "This is a builder contribution, and we do not have secrets at this time"
+  discovery:
+    bypass_reason: "This is a builder contribution, and we do not have secrets at this time"
+  basic_read:
+    bypass_reason: "This is a builder contribution, and we do not have secrets at this time"
+  incremental:
+    bypass_reason: "This is a builder contribution, and we do not have secrets at this time"
+  full_refresh:
+    bypass_reason: "This is a builder contribution, and we do not have secrets at this time"

airbyte-integrations/connectors/source-bamboohr/components.py

@@ -0,0 +1,59 @@
+#
+# Copyright (c) 2023 Airbyte, Inc., all rights reserved.
+#
+
+from dataclasses import InitVar, dataclass
+from typing import Any, Mapping, Optional
+
+from airbyte_cdk.sources.declarative.interpolation.interpolated_string import InterpolatedString
+from airbyte_cdk.sources.declarative.schema.schema_loader import SchemaLoader
+
+
+@dataclass
+class CustomFieldsSchemaLoader(SchemaLoader):
+    config: Mapping[str, Any]
+    default_schema_loader: Optional[SchemaLoader] = None
+    fields_config_key: Optional[str] = None
+    include_default_fields: Optional[bool] = False
+    include_default_fields_config_key: Optional[bool] = False
+
+    def get_json_schema(self) -> Mapping[str, Any]:
+        """
+        Returns the JSON schema.
+
+        The final schema is constructed by first generating a schema for the fields
+        in the config and, if default fields should be included, adding these to the
+        schema.
+        """
+        schema = self._get_json_schema_from_config()
+        if self.default_schema_loader and self._include_default_fields:
+            default_schema = self.default_schema_loader.get_json_schema()
+            schema = self._union_schemas(default_schema, schema)
+        return schema
+
+    def _include_default_fields(self):
+        if self.include_default_fields:
+            return True
+        else:
+            return self.include_default_fields_config_key and self.config.get(self.include_default_fields_config_key, False)
+
+    def _get_json_schema_from_config(self):
+        if self.fields_config_key and self.config.get(self.fields_config_key, None):
+            properties = {
+                field.strip(): {"type": ["null", "string"]}
+                for field in self.convert_custom_reports_fields_to_list(self.config.get(self.fields_config_key))
+            }
+        else:
+            properties = {}
+        return {
+            "$schema": "http://json-schema.org/draft-07/schema#",
+            "type": "object",
+            "properties": properties,
+        }
+
+    def convert_custom_reports_fields_to_list(self, custom_reports_fields: str) -> list:
+        return custom_reports_fields.split(",") if custom_reports_fields else []
+
+    def _union_schemas(self, schema1, schema2):
+        schema1["properties"] = {**schema1["properties"], **schema2["properties"]}
+        return schema1