mod consumer
mod parakeet
mod parakeet-index

alias run-consumer := consumer::run
alias run-parakeet := parakeet::run
alias run-index := parakeet-index::run

@reset-db:
    echo "Resetting and redoing Diesel migrations..."
    diesel migration redo -a --locked-schema

@reset-redis:
    echo "Resetting Redis lists..."
    redis-cli DEL backfill_queue
    redis-cli DEL backfill_processing

@reset-and-backfill *dids: reset-db reset-redis
    for PARAMETER_VALUE in {{dids}}; do \
        psql parakeet -c "INSERT INTO actors (did) VALUES ('$PARAMETER_VALUE');" > /dev/null 2>&1 \
        redis-cli LPUSH backfill_queue "$PARAMETER_VALUE" > /dev/null 2>&1; \
    done
    export RUST_LOG=info,consumer=trace,consumer::firehose=info
    just run-consumer --backfill