Change to new team-sharing based access to anchor

anchor/Makefile

@@ -8,15 +8,7 @@ test:
 
 .PHONY: install
 install:
-	pip3 install -r requirements.txt
-
-.PHONY: docker-build
-docker-build:
-	docker build -t openpodcast/anchor-connector .
-
-.PHONY: docker-run
-docker-run:
-	docker run --init -it --env-file .env -e 'CRON_SCHEDULE=* * * * *' openpodcast/anchor-connector
+	pipenv run pip3 install -r requirements.txt
 
 .env.sample:
 	@envsync -e OPENPODCAST_API_ENDPOINT=https://api.openpodcast.dev \

anchor/Pipfile

@@ -0,0 +1,20 @@
+[[source]]
+url = "https://pypi.org/simple"
+verify_ssl = true
+name = "pypi"
+
+[packages]
+anchorconnector = "==0.6.1"
+certifi = "==2022.12.7"
+charset-normalizer = "==3.1.0"
+idna = "==3.4"
+loguru = "==0.7.0"
+pyyaml = "==6.0"
+requests = "==2.29.0"
+tenacity = "==8.2.2"
+urllib3 = "==1.26.15"
+
+[dev-packages]
+
+[requires]
+python_version = "3.12"

anchor/README.md

@@ -14,15 +14,3 @@ Copy the file to `.env` and set the variables accordingly.
 
 One peculiarity of the API is that the podcast ID is
 called `webstation_id`.
-
-## Docker Image
-
-We provide a Docker image for the connector. You can use it to run the connector locally.
-
-By default, the connector will fetch data from Anchor once a day.
-You can set your own schedule for executing the connector like so:
-
-```bash
-docker build -t openpodcast/anchor-connector .
-docker run --init -it --env-file .env -e 'CRON_SCHEDULE=00 10 * * *' openpodcast/anchor-connector
-```

anchor/job/__main__.py

@@ -118,12 +118,6 @@ def episode_all_time_video_data(connector, web_episode_id):
 
 
 endpoints = [
-    FetchParams(
-        openpodcast_endpoint="podcastEpisode",
-        anchor_call=lambda: anchor.podcast_episode(),
-        start_date=date_range.start,
-        end_date=date_range.end,
-    ),
     FetchParams(
         openpodcast_endpoint="plays",
         anchor_call=get_request_lambda(
@@ -275,6 +269,13 @@ def episode_all_time_video_data(connector, web_episode_id):
             end_date=date_range.end,
             meta=meta,
         ),
+        FetchParams(
+            openpodcast_endpoint="podcastEpisode",
+            anchor_call = (lambda: [get_request_lambda(anchor.episode_metadata, web_episode_id)])(),
+            start_date=date_range.start,
+            end_date=date_range.end,
+            meta=meta,
+        ),
 
         # TODO: This endpoint is not supported by the Open Podcast API yet
         # FetchParams(

anchor/requirements.txt

@@ -1,4 +1,4 @@
-anchorconnector==0.4.0
+anchorconnector==0.6.1
 certifi==2022.12.7
 charset-normalizer==3.1.0
 idna==3.4