Turn fil-deal-ingestor into automated service

.dockerignore

@@ -0,0 +1,3 @@
+node_modules
+generated
+target

.gitignore

@@ -139,3 +139,6 @@ generated/update-spark-db.sql
 # Added by cargo
 
 /target
+
+# Added manually
+generated

Dockerfile

@@ -0,0 +1,33 @@
+# build rust binary from src
+FROM rust:1.79-slim AS builder
+
+WORKDIR /usr/src/app
+
+COPY ./src ./src
+COPY ./Cargo.* .
+
+RUN cargo build --release
+
+# use node image to run the binary
+FROM node:22-slim AS runtime
+
+WORKDIR /usr/src/app
+
+# install psql
+RUN apt-get update && apt-get install -y postgresql-client curl
+
+# copy built binary from builder
+COPY --from=builder /usr/src/app/target/release/fil-deal-ingester .
+
+# copy package.json and package-lock.lock
+COPY ./package.json .
+COPY ./package-lock.json .
+
+# copy scripts 
+COPY ./scripts ./scripts
+COPY ./run.sh .
+
+# install node modules
+RUN npm install
+
+CMD ["./run.sh"]

README.md

@@ -32,3 +32,30 @@ DATABASE_URL=postgres://user:password@localhost:5454/spark ./run.sh
 
 > If you want to free up disk space, `generated/StateMarketDeals.ndjson` can weigh in at 40GB or more.
 > Feel free to delete all files in the `generated` folder after the script finished running.
+
+
+## Deploying to fly.io
+
+**NOTE: Make sure you have the fly.io CLI installed and logged in.**
+
+Creating scheduled machine has to be done by hand as it's not possible to set up a schedule inside the `fly.toml` file. In order to setup scheduled machine we will first have to setup app, volumes and secrets.
+
+```sh
+fly apps create --name=fil-deal-ingester --org=<org-name>
+fly volumes create fil_deal_ingester_data --size=80 --app=fil-deal-ingester --region=<region> --snapshot-retention=1
+fly secrets set DATABASE_URL=<postgres-connection-string> --app=fil-deal-ingester
+fly secrets set SLACK_WEBHOOK_URL=<slack-webhook-url> --app=fil-deal-ingester
+```
+
+Finally, create the machine with the following command:
+
+```sh
+fly machine run . \
+--app=fil-deal-ingester \
+--schedule=daily \
+--region=<region> \
+--volume fil_deal_ingester_data:/usr/src/app/generated \
+--env JSON_CONVERTER_BIN=/usr/src/app/fil-deal-ingester \
+--env ENVIRONMENT=docker \
+--vm-size=shared-cpu-1x
+```

run.sh

@@ -3,17 +3,23 @@
 set -e
 
 DATABASE_URL="${DATABASE_URL?Missing required env var: DATABASE_URL}"
+# defaults to ./target/release/fil-deal-ingester to support local ingestion and backwards compatibility
+JSON_CONVERTER_BIN="${JSON_CONVERTER_BIN:-./target/release/fil-deal-ingester}"
 
 mkdir -p generated
 
-echo "** Building the JSON->NDJSON converter **"
-cargo build --release
+if [ $ENVIRONMENT = "docker" ]; then
+  echo "Skipping JSON->NDJSON converter build in docker environment"
+else
+  echo "** Building the JSON->NDJSON converter **"
+  cargo build --release
+fi
 
 echo "** Downloading the latest market deals state **"
 curl --fail -o ./generated/StateMarketDeals.json.zst https://marketdeals.s3.amazonaws.com/StateMarketDeals.json.zst
 
 echo "** Converting from .json.zst to .ndjson **"
-./target/release/fil-deal-ingester ./generated/StateMarketDeals.json.zst > generated/StateMarketDeals.ndjson
+$JSON_CONVERTER_BIN ./generated/StateMarketDeals.json.zst > generated/StateMarketDeals.ndjson
 
 echo "** Parsing retrievable deals **"
 node scripts/parse-retrievable-deals.js
@@ -27,7 +33,16 @@ psql "$DATABASE_URL" -f generated/update-spark-db.sql | tee generated/dbupdate.l
 echo "** Updating client-allocator mappings **"
 node scripts/update-allocator-clients.js | tee generated/allocator-update.log
 
+MESSAGE=$(
 echo "** FINISHED INGESTION OF f05 DEALS**"
 grep "^DELETE" < generated/dbupdate.log | awk '{s+=$2} END {print "Deleted: " s}'
 grep "^INSERT" < generated/dbupdate.log | awk '{s+=$3} END {print "Added: " s}'
 tail -1 generated/allocator-update.log
+)
+
+if [ -n "$SLACK_WEBHOOK_URL" ]; then
+  echo "** Sending message to slack **"
+  curl -X POST -H 'Content-type: application/json' --data "{\"text\":\"$MESSAGE\"}" $SLACK_WEBHOOK_URL
+else 
+  echo $MESSAGE
+fi