quilling.dev
1mod consumer
2mod parakeet
3mod parakeet-index
4
5alias run-consumer := consumer::run
6alias run-parakeet := parakeet::run
7alias run-index := parakeet-index::run
8
9@reset-db:
10 echo "Resetting and redoing Diesel migrations..."
11 diesel migration redo -a --locked-schema
12
13@reset-redis:
14 echo "Resetting Redis lists..."
15 redis-cli DEL backfill_queue
16 redis-cli DEL backfill_processing
17
18@reset-and-backfill *dids: reset-db reset-redis
19 for PARAMETER_VALUE in {{dids}}; do \
20 psql parakeet -c "INSERT INTO actors (did) VALUES ('$PARAMETER_VALUE');" > /dev/null 2>&1 \
21 redis-cli LPUSH backfill_queue "$PARAMETER_VALUE" > /dev/null 2>&1; \
22 done
23 export RUST_LOG=info,consumer=trace,consumer::firehose=info
24 just run-consumer --backfill