|
|
@ -105,12 +105,14 @@ end
|
|
|
|
|
|
|
|
|
|
|
|
Kemal::CLI.new ARGV
|
|
|
|
Kemal::CLI.new ARGV
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if CONFIG.check_tables
|
|
|
|
# Check table integrity
|
|
|
|
# Check table integrity
|
|
|
|
analyze_table(PG_DB, logger, "channel_videos", ChannelVideo)
|
|
|
|
analyze_table(PG_DB, logger, "channel_videos", ChannelVideo)
|
|
|
|
analyze_table(PG_DB, logger, "nonces", Nonce)
|
|
|
|
analyze_table(PG_DB, logger, "nonces", Nonce)
|
|
|
|
analyze_table(PG_DB, logger, "session_ids", SessionId)
|
|
|
|
analyze_table(PG_DB, logger, "session_ids", SessionId)
|
|
|
|
analyze_table(PG_DB, logger, "users", User)
|
|
|
|
analyze_table(PG_DB, logger, "users", User)
|
|
|
|
analyze_table(PG_DB, logger, "videos", Video)
|
|
|
|
analyze_table(PG_DB, logger, "videos", Video)
|
|
|
|
|
|
|
|
end
|
|
|
|
|
|
|
|
|
|
|
|
# Start jobs
|
|
|
|
# Start jobs
|
|
|
|
refresh_channels(PG_DB, logger, config.channel_threads, config.full_refresh)
|
|
|
|
refresh_channels(PG_DB, logger, config.channel_threads, config.full_refresh)
|
|
|
|