Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

🎉 New Connector: Fleetio source #1

Merged
merged 33 commits into from
Feb 21, 2024
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
33 commits
Select commit Hold shift + click to select a range
536b00b
update schema files
jmmizerany Jul 10, 2023
4eb5603
add in yaml
jmmizerany Jul 10, 2023
95921c5
finish source-fleetio specs
jmmizerany Jul 11, 2023
766b4f4
added integration tests, and expected schemas
jmmizerany Jul 11, 2023
6afbdef
update request headers
jmmizerany Jul 14, 2023
d28bdff
add incremental for submitted_inspection_forms stream
jmmizerany Sep 13, 2023
4ab8b68
add incremental for issues stream
jmmizerany Sep 13, 2023
f8f18d8
add incremental for service_entries stream
jmmizerany Sep 13, 2023
380ccba
add incremental for vehicles stream
jmmizerany Sep 13, 2023
5be6380
add in remaining streams for v1
jmmizerany Nov 21, 2023
fcdfa04
Merge branch 'master' into fleetio-source-connector
jmmizerany Nov 22, 2023
200fd7b
fix schemas
jmmizerany Nov 22, 2023
57e58f8
stop cron action
jmmizerany Nov 22, 2023
ca86dde
update manifest
jmmizerany Jan 26, 2024
2272b7d
update schemas
jmmizerany Jan 26, 2024
4c3f464
Merge branch 'airbytehq:master' into fleetio-source-connector-cursor-…
jmmizerany Jan 26, 2024
743339b
update schemas, and connector configs
jmmizerany Feb 8, 2024
0f61b6b
update sample configs
jmmizerany Feb 8, 2024
edad403
update issues schema
jmmizerany Feb 12, 2024
8f3983a
Merge branch 'airbytehq:master' into fleetio-source-connector-cursor-…
jmmizerany Feb 12, 2024
ac95145
update schemas for new api version
jmmizerany Feb 12, 2024
e1a6fd8
add in per_page spec
jmmizerany Feb 12, 2024
5641620
Merge branch 'airbytehq:master' into fleetio-source-connector-cursor-…
jmmizerany Feb 12, 2024
37e47b6
uncomment CI workflow
jmmizerany Feb 12, 2024
a1ab25a
update metadata
jmmizerany Feb 12, 2024
75eff0b
uncomment zombie build
jmmizerany Feb 15, 2024
156b5ad
Merge branch 'master' into fleetio-source-connector-cursor-pagination
jmmizerany Feb 15, 2024
6d67fbd
update icon
jmmizerany Feb 20, 2024
314f2b2
update manifest for airbyte tests
jmmizerany Feb 20, 2024
4ed12d0
undo
jmmizerany Feb 20, 2024
57801fa
Merge branch 'master' into fleetio-source-connector-cursor-pagination
jmmizerany Feb 20, 2024
1227bc3
update README
jmmizerany Feb 20, 2024
faa1b5a
Merge branch 'master' into fleetio-source-connector-cursor-pagination
jmmizerany Feb 21, 2024
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion .github/workflows/terminate-zombie-build-instances.yml
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
# Also a failsafe against a dev writing a workflow that does not terminate build instances.
# Though the average Airbyte build runtime as of this commit is ~20 mins, connector builds
# can take up to 3 hours. Set this to 3 hours to include these longer runs.
name: Terminate Zombie Build Instances
- name: Terminate Zombie Build Instances

on:
workflow_dispatch:
Expand Down
6 changes: 6 additions & 0 deletions airbyte-integrations/connectors/source-fleetio/.dockerignore
Original file line number Diff line number Diff line change
@@ -0,0 +1,6 @@
*
!Dockerfile
!main.py
!source_fleetio
!setup.py
!secrets
38 changes: 38 additions & 0 deletions airbyte-integrations/connectors/source-fleetio/Dockerfile
Original file line number Diff line number Diff line change
@@ -0,0 +1,38 @@
FROM python:3.9.11-alpine3.15 as base

# build and load all requirements
FROM base as builder
WORKDIR /airbyte/integration_code

# upgrade pip to the latest version
RUN apk --no-cache upgrade \
&& pip install --upgrade pip \
&& apk --no-cache add tzdata build-base


COPY setup.py ./
# install necessary packages to a temporary folder
RUN pip install --prefix=/install .

# build a clean environment
FROM base
WORKDIR /airbyte/integration_code

# copy all loaded and built libraries to a pure basic image
COPY --from=builder /install /usr/local
# add default timezone settings
COPY --from=builder /usr/share/zoneinfo/Etc/UTC /etc/localtime
RUN echo "Etc/UTC" > /etc/timezone

# bash is installed for more convenient debugging.
RUN apk --no-cache add bash

# copy payload code only
COPY main.py ./
COPY source_fleetio ./source_fleetio

ENV AIRBYTE_ENTRYPOINT "python /airbyte/integration_code/main.py"
ENTRYPOINT ["python", "/airbyte/integration_code/main.py"]

LABEL io.airbyte.version=0.1.0
LABEL io.airbyte.name=airbyte/source-fleetio
85 changes: 85 additions & 0 deletions airbyte-integrations/connectors/source-fleetio/README.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,85 @@
# Fleetio Source

This is the repository for the Fleetio configuration based source connector.
For information about how to use this connector within Airbyte, see [the documentation](https://docs.airbyte.com/integrations/sources/fleetio).

## Overview
View the Fleetio website [here](https://fleetio.com). For for information the Fleetio API, check out out [Fleetio API Portal](https://developer.fleetio.com).

## Local development

#### Building via Gradle
You can also build the connector in Gradle. This is typically used in CI and not needed for your development workflow.

To build using Gradle, from the Airbyte repository root, run:
```
./gradlew :airbyte-integrations:connectors:source-fleetio:build
```

#### Create credentials
**If you are a community contributor**, follow the instructions in the [documentation](https://docs.airbyte.com/integrations/sources/fleetio)
to generate the necessary credentials. Then create a file `secrets/config.json` conforming to the `source_fleetio/spec.yaml` file.
Note that any directory named `secrets` is gitignored across the entire Airbyte repo, so there is no danger of accidentally checking in sensitive information.
See `integration_tests/sample_config.json` for a sample config file.

**If you are an Airbyte core member**, copy the credentials in Lastpass under the secret name `source fleetio test creds`
and place them into `secrets/config.json`.

### Locally running the connector docker image

#### Build
First, make sure you build the latest Docker image:
```
docker build . -t airbyte/source-fleetio:dev
```

You can also build the connector image via Gradle:
```
./gradlew :airbyte-integrations:connectors:source-fleetio:airbyteDocker
```
When building via Gradle, the docker image name and tag, respectively, are the values of the `io.airbyte.name` and `io.airbyte.version` `LABEL`s in
the Dockerfile.

#### Run
Then run any of the connector commands as follows:
```
docker run --rm airbyte/source-fleetio:dev spec
docker run --rm -v $(pwd)/secrets:/secrets airbyte/source-fleetio:dev check --config /secrets/config.json
docker run --rm -v $(pwd)/secrets:/secrets airbyte/source-fleetio:dev discover --config /secrets/config.json
docker run --rm -v $(pwd)/secrets:/secrets -v $(pwd)/integration_tests:/integration_tests airbyte/source-fleetio:dev read --config /secrets/config.json --catalog /integration_tests/configured_catalog.json
```
## Testing

#### Acceptance Tests
Customize `acceptance-test-config.yml` file to configure tests. See [Connector Acceptance Tests](https://docs.airbyte.com/connector-development/testing-connectors/connector-acceptance-tests-reference) for more information.
If your connector requires to create or destroy resources for use during acceptance tests create fixtures for it and place them inside integration_tests/acceptance.py.

To run your integration tests with Docker, run:
```
./acceptance-test-docker.sh
```

### Using gradle to run tests
All commands should be run from airbyte project root.
To run unit tests:
```
./gradlew :airbyte-integrations:connectors:source-fleetio:unitTest
```
To run acceptance and custom integration tests:
```
./gradlew :airbyte-integrations:connectors:source-fleetio:integrationTest
```

## Dependency Management
All of your dependencies should go in `setup.py`, NOT `requirements.txt`. The requirements file is only used to connect internal Airbyte dependencies in the monorepo for local development.
We split dependencies between two groups, dependencies that are:
* required for your connector to work need to go to `MAIN_REQUIREMENTS` list.
* required for the testing need to go to `TEST_REQUIREMENTS` list

### Publishing a new version of the connector
You've checked out the repo, implemented a million dollar feature, and you're ready to share your changes with the world. Now what?
1. Make sure your changes are passing unit and integration tests.
1. Bump the connector version in `Dockerfile` -- just increment the value of the `LABEL io.airbyte.version` appropriately (we use [SemVer](https://semver.org/)).
1. Create a Pull Request.
1. Pat yourself on the back for being an awesome contributor.
1. Someone from Airbyte will take a look at your PR and iterate with you to merge it into master.
3 changes: 3 additions & 0 deletions airbyte-integrations/connectors/source-fleetio/__init__.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,3 @@
#
# Copyright (c) 2023 Airbyte, Inc., all rights reserved.
#
Original file line number Diff line number Diff line change
@@ -0,0 +1,25 @@
# 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-fleetio:dev
acceptance_tests:
spec:
tests:
- spec_path: "source_fleetio/spec.yaml"
connection:
tests:
- config_path: "secrets/config.json"
status: "succeed"
- config_path: "integration_tests/invalid_config.json"
status: "failed"
discovery:
tests:
- config_path: "secrets/config.json"
basic_read:
tests:
- config_path: "secrets/config.json"
configured_catalog_path: "integration_tests/configured_catalog.json"
empty_streams: []
full_refresh:
tests:
- config_path: "secrets/config.json"
configured_catalog_path: "integration_tests/configured_catalog.json"
Original file line number Diff line number Diff line change
@@ -0,0 +1,3 @@
#!/usr/bin/env sh

source "$(git rev-parse --show-toplevel)/airbyte-integrations/bases/connector-acceptance-test/acceptance-test-docker.sh"
9 changes: 9 additions & 0 deletions airbyte-integrations/connectors/source-fleetio/build.gradle
Original file line number Diff line number Diff line change
@@ -0,0 +1,9 @@
plugins {
id 'airbyte-python'
id 'airbyte-docker'
id 'airbyte-connector-acceptance-test'
}

airbytePython {
moduleDirectory 'source_fleetio'
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,3 @@
#
# Copyright (c) 2023 Airbyte, Inc., all rights reserved.
#
Original file line number Diff line number Diff line change
@@ -0,0 +1,32 @@
{
"issues": {
"id": ""
},
"service_entries": {
"id": ""
},
"submitted_inspection_forms": {
"id": ""
},
"vehicles": {
"id": ""
},
"contacts": {
"id": ""
},
"expense_entries": {
"id": ""
},
"fuel_entries": {
"id": ""
},
"parts": {
"id": ""
},
"purchase_orders": {
"id": ""
},
"vehicle_assignments": {
"id": ""
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,16 @@
#
# Copyright (c) 2023 Airbyte, Inc., all rights reserved.
#


import pytest

pytest_plugins = ("connector_acceptance_test.plugin",)


@pytest.fixture(scope="session", autouse=True)
def connector_setup():
"""This fixture is a placeholder for external resources that acceptance test might require."""
# TODO: setup test dependencies if needed. otherwise remove the TODO comments
yield
# TODO: clean up test dependencies
Original file line number Diff line number Diff line change
@@ -0,0 +1,94 @@
{
"streams": [
{
"stream": {
"name": "issues",
"json_schema": {},
"supported_sync_modes": ["full_refresh"]
},
"sync_mode": "full_refresh",
"destination_sync_mode": "append"
},
{
"stream": {
"name": "service_entries",
"json_schema": {},
"supported_sync_modes": ["full_refresh"]
},
"sync_mode": "full_refresh",
"destination_sync_mode": "append"
},
{
"stream": {
"name": "submitted_inspection_forms",
"json_schema": {},
"supported_sync_modes": ["full_refresh"]
},
"sync_mode": "full_refresh",
"destination_sync_mode": "append"
},
{
"stream": {
"name": "vehicles",
"json_schema": {},
"supported_sync_modes": ["full_refresh"]
},
"sync_mode": "full_refresh",
"destination_sync_mode": "append"
},
{
"stream": {
"name": "contacts",
"json_schema": {},
"supported_sync_modes": ["full_refresh"]
},
"sync_mode": "full_refresh",
"destination_sync_mode": "append"
},
{
"stream": {
"name": "expense_entries",
"json_schema": {},
"supported_sync_modes": ["full_refresh"]
},
"sync_mode": "full_refresh",
"destination_sync_mode": "append"
},
{
"stream": {
"name": "fuel_entries",
"json_schema": {},
"supported_sync_modes": ["full_refresh"]
},
"sync_mode": "full_refresh",
"destination_sync_mode": "append"
},
{
"stream": {
"name": "parts",
"json_schema": {},
"supported_sync_modes": ["full_refresh"]
},
"sync_mode": "full_refresh",
"destination_sync_mode": "append"
},
{
"stream": {
"name": "purchase_orders",
"json_schema": {},
"supported_sync_modes": ["full_refresh"]
},
"sync_mode": "full_refresh",
"destination_sync_mode": "append"
},
{
"stream": {
"name": "vehicle_assignments",
"json_schema": {},
"supported_sync_modes": ["full_refresh"]
},
"sync_mode": "full_refresh",
"destination_sync_mode": "append"
}
]
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,4 @@
{
"api_token": "",
"account_token": ""
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,4 @@
{
"api_token": "xxx",
"account_token": "xxx"
}
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
{}
13 changes: 13 additions & 0 deletions airbyte-integrations/connectors/source-fleetio/main.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,13 @@
#
# Copyright (c) 2023 Airbyte, Inc., all rights reserved.
#


import sys

from airbyte_cdk.entrypoint import launch
from source_fleetio import SourceFleetio

if __name__ == "__main__":
source = SourceFleetio()
launch(source, sys.argv[1:])
21 changes: 21 additions & 0 deletions airbyte-integrations/connectors/source-fleetio/metadata.yaml
Original file line number Diff line number Diff line change
@@ -0,0 +1,21 @@
data:
registries:
cloud:
enabled: true
oss:
enabled: true
connectorSubtype: api
connectorType: source
definitionId: 13a7652d-1d94-4033-931a-613d22d3cbb3
dockerImageTag: 0.1.0
dockerRepository: airbyte/source-fleetio
githubIssueLabel: source-fleetio
icon: fleetio.svg
license: MIT
name: Fleetio
releaseDate: "2024-02-12"
releaseStage: alpha
documentationUrl: https://docs.airbyte.com/integrations/sources/fleetio
tags:
- language:lowcode
metadataSpecVersion: "1.0"
Original file line number Diff line number Diff line change
@@ -0,0 +1,2 @@
-e ../../bases/connector-acceptance-test
-e .
Loading
Loading