Merge branch 'master' of https://github.com/tootsuite/mastodon
# Conflicts: # app/controllers/settings/exports_controller.rb # app/models/media_attachment.rb # app/models/status.rb # app/views/about/show.html.haml # docker_entrypoint.sh # spec/views/about/show.html.haml_spec.rbmain
imncls
7 years ago
commit
bb6988a7ac
|
After Width: | Height: | Size: 205 B |
|
After Width: | Height: | Size: 271 B |
|
After Width: | Height: | Size: 3.0 KiB |
@ -0,0 +1,122 @@
|
|||||||
|
import React from 'react';
|
||||||
|
import ImmutablePropTypes from 'react-immutable-proptypes';
|
||||||
|
import ImmutablePureComponent from 'react-immutable-pure-component';
|
||||||
|
import { connect } from 'react-redux';
|
||||||
|
import ImageLoader from './image_loader';
|
||||||
|
import classNames from 'classnames';
|
||||||
|
import { changeUploadCompose } from '../../../actions/compose';
|
||||||
|
import { getPointerPosition } from '../../video';
|
||||||
|
|
||||||
|
const mapStateToProps = (state, { id }) => ({
|
||||||
|
media: state.getIn(['compose', 'media_attachments']).find(item => item.get('id') === id),
|
||||||
|
});
|
||||||
|
|
||||||
|
const mapDispatchToProps = (dispatch, { id }) => ({
|
||||||
|
|
||||||
|
onSave: (x, y) => {
|
||||||
|
dispatch(changeUploadCompose(id, { focus: `${x.toFixed(2)},${y.toFixed(2)}` }));
|
||||||
|
},
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
@connect(mapStateToProps, mapDispatchToProps)
|
||||||
|
export default class FocalPointModal extends ImmutablePureComponent {
|
||||||
|
|
||||||
|
static propTypes = {
|
||||||
|
media: ImmutablePropTypes.map.isRequired,
|
||||||
|
};
|
||||||
|
|
||||||
|
state = {
|
||||||
|
x: 0,
|
||||||
|
y: 0,
|
||||||
|
focusX: 0,
|
||||||
|
focusY: 0,
|
||||||
|
dragging: false,
|
||||||
|
};
|
||||||
|
|
||||||
|
componentWillMount () {
|
||||||
|
this.updatePositionFromMedia(this.props.media);
|
||||||
|
}
|
||||||
|
|
||||||
|
componentWillReceiveProps (nextProps) {
|
||||||
|
if (this.props.media.get('id') !== nextProps.media.get('id')) {
|
||||||
|
this.updatePositionFromMedia(nextProps.media);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
componentWillUnmount () {
|
||||||
|
document.removeEventListener('mousemove', this.handleMouseMove);
|
||||||
|
document.removeEventListener('mouseup', this.handleMouseUp);
|
||||||
|
}
|
||||||
|
|
||||||
|
handleMouseDown = e => {
|
||||||
|
document.addEventListener('mousemove', this.handleMouseMove);
|
||||||
|
document.addEventListener('mouseup', this.handleMouseUp);
|
||||||
|
|
||||||
|
this.updatePosition(e);
|
||||||
|
this.setState({ dragging: true });
|
||||||
|
}
|
||||||
|
|
||||||
|
handleMouseMove = e => {
|
||||||
|
this.updatePosition(e);
|
||||||
|
}
|
||||||
|
|
||||||
|
handleMouseUp = () => {
|
||||||
|
document.removeEventListener('mousemove', this.handleMouseMove);
|
||||||
|
document.removeEventListener('mouseup', this.handleMouseUp);
|
||||||
|
|
||||||
|
this.setState({ dragging: false });
|
||||||
|
this.props.onSave(this.state.focusX, this.state.focusY);
|
||||||
|
}
|
||||||
|
|
||||||
|
updatePosition = e => {
|
||||||
|
const { x, y } = getPointerPosition(this.node, e);
|
||||||
|
const focusX = (x - .5) * 2;
|
||||||
|
const focusY = (y - .5) * -2;
|
||||||
|
|
||||||
|
this.setState({ x, y, focusX, focusY });
|
||||||
|
}
|
||||||
|
|
||||||
|
updatePositionFromMedia = media => {
|
||||||
|
const focusX = media.getIn(['meta', 'focus', 'x']);
|
||||||
|
const focusY = media.getIn(['meta', 'focus', 'y']);
|
||||||
|
|
||||||
|
if (focusX && focusY) {
|
||||||
|
const x = (focusX / 2) + .5;
|
||||||
|
const y = (focusY / -2) + .5;
|
||||||
|
|
||||||
|
this.setState({ x, y, focusX, focusY });
|
||||||
|
} else {
|
||||||
|
this.setState({ x: 0.5, y: 0.5, focusX: 0, focusY: 0 });
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
setRef = c => {
|
||||||
|
this.node = c;
|
||||||
|
}
|
||||||
|
|
||||||
|
render () {
|
||||||
|
const { media } = this.props;
|
||||||
|
const { x, y, dragging } = this.state;
|
||||||
|
|
||||||
|
const width = media.getIn(['meta', 'original', 'width']) || null;
|
||||||
|
const height = media.getIn(['meta', 'original', 'height']) || null;
|
||||||
|
|
||||||
|
return (
|
||||||
|
<div className='modal-root__modal media-modal'>
|
||||||
|
<div className={classNames('media-modal__content focal-point', { dragging })} ref={this.setRef}>
|
||||||
|
<ImageLoader
|
||||||
|
previewSrc={media.get('preview_url')}
|
||||||
|
src={media.get('url')}
|
||||||
|
width={width}
|
||||||
|
height={height}
|
||||||
|
/>
|
||||||
|
|
||||||
|
<div className='focal-point__reticle' style={{ top: `${y * 100}%`, left: `${x * 100}%` }} />
|
||||||
|
<div className='focal-point__overlay' onMouseDown={this.handleMouseDown} />
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,11 @@
|
|||||||
|
# frozen_string_literal: true
|
||||||
|
|
||||||
|
class FastGeometryParser
|
||||||
|
def self.from_file(file)
|
||||||
|
width, height = FastImage.size(file.path)
|
||||||
|
|
||||||
|
raise Paperclip::Errors::NotIdentifiedByImageMagickError if width.nil?
|
||||||
|
|
||||||
|
Paperclip::Geometry.new(width, height)
|
||||||
|
end
|
||||||
|
end
|
||||||
@ -0,0 +1,22 @@
|
|||||||
|
# frozen_string_literal: true
|
||||||
|
# == Schema Information
|
||||||
|
#
|
||||||
|
# Table name: backups
|
||||||
|
#
|
||||||
|
# id :integer not null, primary key
|
||||||
|
# user_id :integer
|
||||||
|
# dump_file_name :string
|
||||||
|
# dump_content_type :string
|
||||||
|
# dump_file_size :integer
|
||||||
|
# dump_updated_at :datetime
|
||||||
|
# processed :boolean default(FALSE), not null
|
||||||
|
# created_at :datetime not null
|
||||||
|
# updated_at :datetime not null
|
||||||
|
#
|
||||||
|
|
||||||
|
class Backup < ApplicationRecord
|
||||||
|
belongs_to :user, inverse_of: :backups
|
||||||
|
|
||||||
|
has_attached_file :dump
|
||||||
|
do_not_validate_attachment_file_type :dump
|
||||||
|
end
|
||||||
@ -0,0 +1,9 @@
|
|||||||
|
# frozen_string_literal: true
|
||||||
|
|
||||||
|
class BackupPolicy < ApplicationPolicy
|
||||||
|
MIN_AGE = 1.week
|
||||||
|
|
||||||
|
def create?
|
||||||
|
user_signed_in? && current_user.backups.where('created_at >= ?', MIN_AGE.ago).count.zero?
|
||||||
|
end
|
||||||
|
end
|
||||||
@ -0,0 +1,128 @@
|
|||||||
|
# frozen_string_literal: true
|
||||||
|
|
||||||
|
require 'rubygems/package'
|
||||||
|
|
||||||
|
class BackupService < BaseService
|
||||||
|
attr_reader :account, :backup, :collection
|
||||||
|
|
||||||
|
def call(backup)
|
||||||
|
@backup = backup
|
||||||
|
@account = backup.user.account
|
||||||
|
|
||||||
|
build_json!
|
||||||
|
build_archive!
|
||||||
|
end
|
||||||
|
|
||||||
|
private
|
||||||
|
|
||||||
|
def build_json!
|
||||||
|
@collection = serialize(collection_presenter, ActivityPub::CollectionSerializer)
|
||||||
|
|
||||||
|
account.statuses.with_includes.find_in_batches do |statuses|
|
||||||
|
statuses.each do |status|
|
||||||
|
item = serialize(status, ActivityPub::ActivitySerializer)
|
||||||
|
item.delete(:'@context')
|
||||||
|
|
||||||
|
unless item[:type] == 'Announce' || item[:object][:attachment].blank?
|
||||||
|
item[:object][:attachment].each do |attachment|
|
||||||
|
attachment[:url] = Addressable::URI.parse(attachment[:url]).path.gsub(/\A\/system\//, '')
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
|
@collection[:orderedItems] << item
|
||||||
|
end
|
||||||
|
|
||||||
|
GC.start
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
|
def build_archive!
|
||||||
|
tmp_file = Tempfile.new(%w(archive .tar.gz))
|
||||||
|
|
||||||
|
File.open(tmp_file, 'wb') do |file|
|
||||||
|
Zlib::GzipWriter.wrap(file) do |gz|
|
||||||
|
Gem::Package::TarWriter.new(gz) do |tar|
|
||||||
|
dump_media_attachments!(tar)
|
||||||
|
dump_outbox!(tar)
|
||||||
|
dump_actor!(tar)
|
||||||
|
end
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
|
archive_filename = ['archive', Time.now.utc.strftime('%Y%m%d%H%M%S'), SecureRandom.hex(2)].join('-') + '.tar.gz'
|
||||||
|
|
||||||
|
@backup.dump = ActionDispatch::Http::UploadedFile.new(tempfile: tmp_file, filename: archive_filename)
|
||||||
|
@backup.processed = true
|
||||||
|
@backup.save!
|
||||||
|
ensure
|
||||||
|
tmp_file.close
|
||||||
|
tmp_file.unlink
|
||||||
|
end
|
||||||
|
|
||||||
|
def dump_media_attachments!(tar)
|
||||||
|
MediaAttachment.attached.where(account: account).find_in_batches do |media_attachments|
|
||||||
|
media_attachments.each do |m|
|
||||||
|
download_to_tar(tar, m.file, m.file.path)
|
||||||
|
end
|
||||||
|
|
||||||
|
GC.start
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
|
def dump_outbox!(tar)
|
||||||
|
json = Oj.dump(collection)
|
||||||
|
|
||||||
|
tar.add_file_simple('outbox.json', 0o444, json.bytesize) do |io|
|
||||||
|
io.write(json)
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
|
def dump_actor!(tar)
|
||||||
|
actor = serialize(account, ActivityPub::ActorSerializer)
|
||||||
|
|
||||||
|
actor[:icon][:url] = 'avatar' + File.extname(actor[:icon][:url]) if actor[:icon]
|
||||||
|
actor[:image][:url] = 'header' + File.extname(actor[:image][:url]) if actor[:image]
|
||||||
|
|
||||||
|
download_to_tar(tar, account.avatar, 'avatar' + File.extname(account.avatar.path)) if account.avatar.exists?
|
||||||
|
download_to_tar(tar, account.header, 'header' + File.extname(account.header.path)) if account.header.exists?
|
||||||
|
|
||||||
|
json = Oj.dump(actor)
|
||||||
|
|
||||||
|
tar.add_file_simple('actor.json', 0o444, json.bytesize) do |io|
|
||||||
|
io.write(json)
|
||||||
|
end
|
||||||
|
|
||||||
|
tar.add_file_simple('key.pem', 0o444, account.private_key.bytesize) do |io|
|
||||||
|
io.write(account.private_key)
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
|
def collection_presenter
|
||||||
|
ActivityPub::CollectionPresenter.new(
|
||||||
|
id: account_outbox_url(account),
|
||||||
|
type: :ordered,
|
||||||
|
size: account.statuses_count,
|
||||||
|
items: []
|
||||||
|
)
|
||||||
|
end
|
||||||
|
|
||||||
|
def serialize(object, serializer)
|
||||||
|
ActiveModelSerializers::SerializableResource.new(
|
||||||
|
object,
|
||||||
|
serializer: serializer,
|
||||||
|
adapter: ActivityPub::Adapter
|
||||||
|
).as_json
|
||||||
|
end
|
||||||
|
|
||||||
|
CHUNK_SIZE = 1.megabyte
|
||||||
|
|
||||||
|
def download_to_tar(tar, attachment, filename)
|
||||||
|
adapter = Paperclip.io_adapters.for(attachment)
|
||||||
|
|
||||||
|
tar.add_file_simple(filename, 0o444, adapter.size) do |io|
|
||||||
|
while (buffer = adapter.read(CHUNK_SIZE))
|
||||||
|
io.write(buffer)
|
||||||
|
end
|
||||||
|
end
|
||||||
|
end
|
||||||
|
end
|
||||||
@ -0,0 +1,14 @@
|
|||||||
|
- if @instance_presenter.open_registrations
|
||||||
|
= render 'registration'
|
||||||
|
- else
|
||||||
|
- if @instance_presenter.closed_registrations_message.blank?
|
||||||
|
%p= t('about.closed_registrations')
|
||||||
|
- else
|
||||||
|
= @instance_presenter.closed_registrations_message.html_safe
|
||||||
|
|
||||||
|
= link_to t('auth.register'), 'https://joinmastodon.org', class: 'button button-primary'
|
||||||
|
|
||||||
|
.separator-or
|
||||||
|
%span= t('auth.or')
|
||||||
|
|
||||||
|
= link_to t('auth.login'), new_user_session_path, class: 'button button-alternative-2 webapp-btn'
|
||||||
@ -0,0 +1,59 @@
|
|||||||
|
%table.email-table{ cellspacing: 0, cellpadding: 0 }
|
||||||
|
%tbody
|
||||||
|
%tr
|
||||||
|
%td.email-body
|
||||||
|
.email-container
|
||||||
|
%table.content-section{ cellspacing: 0, cellpadding: 0 }
|
||||||
|
%tbody
|
||||||
|
%tr
|
||||||
|
%td.content-cell.hero
|
||||||
|
.email-row
|
||||||
|
.col-6
|
||||||
|
%table.column{ cellspacing: 0, cellpadding: 0 }
|
||||||
|
%tbody
|
||||||
|
%tr
|
||||||
|
%td.column-cell.text-center.padded
|
||||||
|
%table.hero-icon{ align: 'center', cellspacing: 0, cellpadding: 0 }
|
||||||
|
%tbody
|
||||||
|
%tr
|
||||||
|
%td
|
||||||
|
= image_tag full_pack_url('icon_file_download.png'), alt: ''
|
||||||
|
|
||||||
|
%h1= t 'user_mailer.backup_ready.title'
|
||||||
|
|
||||||
|
%table.email-table{ cellspacing: 0, cellpadding: 0 }
|
||||||
|
%tbody
|
||||||
|
%tr
|
||||||
|
%td.email-body
|
||||||
|
.email-container
|
||||||
|
%table.content-section{ cellspacing: 0, cellpadding: 0 }
|
||||||
|
%tbody
|
||||||
|
%tr
|
||||||
|
%td.content-cell.content-start
|
||||||
|
.email-row
|
||||||
|
.col-6
|
||||||
|
%table.column{ cellspacing: 0, cellpadding: 0 }
|
||||||
|
%tbody
|
||||||
|
%tr
|
||||||
|
%td.column-cell.text-center
|
||||||
|
%p= t 'user_mailer.backup_ready.explanation'
|
||||||
|
|
||||||
|
%table.email-table{ cellspacing: 0, cellpadding: 0 }
|
||||||
|
%tbody
|
||||||
|
%tr
|
||||||
|
%td.email-body
|
||||||
|
.email-container
|
||||||
|
%table.content-section{ cellspacing: 0, cellpadding: 0 }
|
||||||
|
%tbody
|
||||||
|
%tr
|
||||||
|
%td.content-cell
|
||||||
|
%table.column{ cellspacing: 0, cellpadding: 0 }
|
||||||
|
%tbody
|
||||||
|
%tr
|
||||||
|
%td.column-cell.button-cell
|
||||||
|
%table.button{ align: 'center', cellspacing: 0, cellpadding: 0 }
|
||||||
|
%tbody
|
||||||
|
%tr
|
||||||
|
%td.button-primary
|
||||||
|
= link_to full_asset_url(@backup.dump.url) do
|
||||||
|
%span= t 'exports.archive_takeout.download'
|
||||||
@ -0,0 +1,7 @@
|
|||||||
|
<%= t 'user_mailer.backup_ready.title' %>
|
||||||
|
|
||||||
|
===
|
||||||
|
|
||||||
|
<%= t 'user_mailer.backup_ready.explanation' %>
|
||||||
|
|
||||||
|
=> <%= full_asset_url(@backup.dump.url) %>
|
||||||
@ -0,0 +1,17 @@
|
|||||||
|
# frozen_string_literal: true
|
||||||
|
|
||||||
|
class BackupWorker
|
||||||
|
include Sidekiq::Worker
|
||||||
|
|
||||||
|
sidekiq_options queue: 'pull'
|
||||||
|
|
||||||
|
def perform(backup_id)
|
||||||
|
backup = Backup.find(backup_id)
|
||||||
|
user = backup.user
|
||||||
|
|
||||||
|
BackupService.new.call(backup)
|
||||||
|
|
||||||
|
user.backups.where.not(id: backup.id).destroy_all
|
||||||
|
UserMailer.backup_ready(user, backup).deliver_later
|
||||||
|
end
|
||||||
|
end
|
||||||
@ -0,0 +1,16 @@
|
|||||||
|
# frozen_string_literal: true
|
||||||
|
require 'sidekiq-scheduler'
|
||||||
|
|
||||||
|
class Scheduler::BackupCleanupScheduler
|
||||||
|
include Sidekiq::Worker
|
||||||
|
|
||||||
|
def perform
|
||||||
|
old_backups.find_each(&:destroy!)
|
||||||
|
end
|
||||||
|
|
||||||
|
private
|
||||||
|
|
||||||
|
def old_backups
|
||||||
|
Backup.where('created_at < ?', 7.days.ago)
|
||||||
|
end
|
||||||
|
end
|
||||||
@ -0,0 +1,11 @@
|
|||||||
|
class CreateBackups < ActiveRecord::Migration[5.1]
|
||||||
|
def change
|
||||||
|
create_table :backups do |t|
|
||||||
|
t.references :user, foreign_key: { on_delete: :nullify }
|
||||||
|
t.attachment :dump
|
||||||
|
t.boolean :processed, null: false, default: false
|
||||||
|
|
||||||
|
t.timestamps
|
||||||
|
end
|
||||||
|
end
|
||||||
|
end
|
||||||
@ -1,14 +0,0 @@
|
|||||||
#!/bin/sh
|
|
||||||
|
|
||||||
### 1. Adds local user (UID and GID are provided from environment variables).
|
|
||||||
### 2. Updates permissions, except for ./public/system (should be chown on previous installations).
|
|
||||||
### 3. Executes the command as that user.
|
|
||||||
|
|
||||||
echo "Creating mastodon user (UID : ${UID} and GID : ${GID})..."
|
|
||||||
addgroup -g ${GID} mastodon && adduser -h /mastodon -s /bin/sh -D -G mastodon -u ${UID} mastodon
|
|
||||||
|
|
||||||
echo "Updating permissions..."
|
|
||||||
find /mastodon -path /mastodon/public/system -prune -o -not -user mastodon -not -group mastodon -print0 | xargs -0 chown -f mastodon:mastodon
|
|
||||||
|
|
||||||
echo "Executing process..."
|
|
||||||
LD_PRELOAD=/lib/stack-fix.so exec su-exec mastodon:mastodon /sbin/tini -- "$@"
|
|
||||||
@ -0,0 +1,24 @@
|
|||||||
|
# frozen_string_literal: true
|
||||||
|
|
||||||
|
module Paperclip
|
||||||
|
class LazyThumbnail < Paperclip::Thumbnail
|
||||||
|
def make
|
||||||
|
return File.open(@file.path) unless needs_convert?
|
||||||
|
Paperclip::Thumbnail.make(file, options, attachment)
|
||||||
|
end
|
||||||
|
|
||||||
|
private
|
||||||
|
|
||||||
|
def needs_convert?
|
||||||
|
needs_different_geometry? || needs_different_format?
|
||||||
|
end
|
||||||
|
|
||||||
|
def needs_different_geometry?
|
||||||
|
!@target_geometry.nil? && @current_geometry.width != @target_geometry.width && @current_geometry.height != @target_geometry.height
|
||||||
|
end
|
||||||
|
|
||||||
|
def needs_different_format?
|
||||||
|
@format.present? && @current_format != @format
|
||||||
|
end
|
||||||
|
end
|
||||||
|
end
|
||||||
@ -0,0 +1,3 @@
|
|||||||
|
Fabricator(:backup) do
|
||||||
|
user
|
||||||
|
end
|
||||||
@ -0,0 +1,5 @@
|
|||||||
|
require 'rails_helper'
|
||||||
|
|
||||||
|
RSpec.describe Backup, type: :model do
|
||||||
|
|
||||||
|
end
|
||||||
Loading…
Reference in new issue