Skip to content

Replace the old Matrix client with the new bot DSL #6

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
ananace wants to merge 3 commits into
base: master
Choose a base branch
from
Open

Replace the old Matrix client with the new bot DSL #6

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
ba6f5fb
Working on a bot DSL implementation
ananace Aug 15, 2022
e6dd978
Use new room state caching
ananace Aug 20, 2022
4c6baf0
Remove old sync token storage system
ananace Aug 21, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
30 changes: 11 additions & 19 deletions bin/tracker
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -38,19 +38,24 @@ class Releasetracker
@logger.level = options[:debug] ? :debug : :info

logger.info 'Loaded configuration.'
end

def run!
sync_thread = Thread.new { matrix_thread }
loop do
break if config.client

sleep 0.25
end

@client = config.client.client
@api = config.client.api
end

def run!
ensure_rooms

logger.info "Starting tracker with #{config.backends.count} backends."
@running = true

sync_thread = Thread.new { matrix_thread }

while running
update_backends
cleanup_data
Expand Down Expand Up @@ -222,21 +227,8 @@ class Releasetracker
end

def matrix_thread
logger.info 'Starting Matrix sync loop...'
client.sync_filter = ROOM_STATE_FILTER
while running
begin
client.sync(timeout: 10.0, set_presence: :offline, since: config.client.next_batch)

config.client.next_batch = client.next_batch
config.save!

sleep 10
rescue StandardError => e
logger.error "#{e.class} in sync: #{e}. Retrying in 30s"
sleep 30
end
end
logger.info 'Starting Matrix bot...'
MatrixReleasetracker::Client.run! { |instance| config.client = instance }
end

def fix_media_url(url)
Expand Down
Loading