Add link to github project to footer, move FanOutOnWriteService calls to

DistributionWorker. That isn't the heaviest service, yet, but gotta start
somewhere
feature/8296-invite_api
Eugen Rochko 7 years ago
parent 42dcb0d4cb
commit 8eeec389c1
  1. 15
      app/assets/stylesheets/application.scss
  2. 6
      app/services/post_status_service.rb
  3. 2
      app/services/process_feed_service.rb
  4. 6
      app/views/layouts/public.html.haml
  5. 7
      app/workers/distribution_worker.rb

@ -262,6 +262,21 @@ body {
font-weight: 400;
font-family: 'Roboto Mono', monospace;
}
.powered-by {
font-size: 12px;
font-weight: 400;
color: darken(#d9e1e8, 25%);
a {
color: inherit;
text-decoration: underline;
&:hover {
text-decoration: none;
}
}
}
}
.mastodon {

@ -7,7 +7,7 @@ class PostStatusService < BaseService
def call(account, text, in_reply_to = nil)
status = account.statuses.create!(text: text, thread: in_reply_to)
process_mentions_service.(status)
fan_out_on_write_service.(status)
DistributionWorker.perform_async(status.id)
account.ping!(account_url(account, format: 'atom'), [Rails.configuration.x.hub_url])
status
end
@ -17,8 +17,4 @@ class PostStatusService < BaseService
def process_mentions_service
@process_mentions_service ||= ProcessMentionsService.new
end
def fan_out_on_write_service
@fan_out_on_write_service ||= FanOutOnWriteService.new
end
end

@ -38,7 +38,7 @@ class ProcessFeedService < BaseService
# If we added a status, go through accounts it mentions and create respective relations
unless status.new_record?
record_remote_mentions(status, entry.xpath('./xmlns:link[@rel="mentioned"]'))
fan_out_on_write_service.(status)
DistributionWorker.perform_async(status.id)
end
end

@ -1,6 +1,10 @@
- content_for :content do
.container= yield
.footer
.domain= Rails.configuration.x.local_domain
%span.domain= Rails.configuration.x.local_domain
%span.powered-by
\//
powered by
= link_to 'Mastodon', 'https://github.com/Gargron/mastodon'
= render template: "layouts/application"

@ -0,0 +1,7 @@
class DistributionWorker
include Sidekiq::Worker
def perform(status_id)
FanOutOnWriteService.new.(Status.find(status_id))
end
end
Loading…
Cancel
Save