A task, that can be run once off or periodically, that looks up a specific table in a PostgreSQL data.
It expects a specific column in that table to be the way to identify the contact, and the other columns in that table to be the contact fields that we want to update.
It will go through every row in the table, and use RapidPro's API to update each contact.
Configuration is handled using environment variables
DATABASE_DSN - How to connect to the database, eg. postgresql://user:pass@host:port/db
DATABASE_TABLE - The database table to pull data from, eg. contacts
RAPIDPRO_HOST - The hostname of the rapidpro instance, eg. textit.in
RAPIDPRO_TOKEN - The token to use to authenticate to the RapidPro API, eg. b50c919959954e5a8c5476c2b9d671e2
CONCURRENCY - How many requests to make to the RapidPro API in parallel. Defaults to 1
URN_TYPE - The type of URN that we're using to lookup the contact, eg. "whatsapp". The table will need a column named this, whose values are the URNs of the contacts
This project uses poetry. Start by installing it first.
You will also need a PostgreSQL instance running, you can use the DATABASE_DSN environment variable to tell the tests how to find and connect to this instance.
poetry install will install all the dependancies.
poetry shell to enter a shell inside the created virtual environment.
There are various auto formatters and linters used in this project, so after making any changes run them first:
black .
isort .
mypy .
flake8
Then you can run the unit tests:
pytest