# client-server
['/inbox/object', '/outbox/object'].each do |path|
  get path do
    protected!
    Dir[File.join(path.sub('/', ''), '*', '*.json')].collect { |f| JSON.load_file(f) }.to_json
  end
end

post '/delete' do
  protected!
  params['id'].each do |id|
    file = find_file id
    halt 404 unless file
    # if file.match(%r{outbox/}) # find/delete activity

    %w[inbox outbox].each do |box|
      Dir[File.join box, 'announce', '*.json'].each do |announce_file|
        announce = JSON.load_file(announce_file)
        next unless announce['object']['id'] == id

        outbox 'Undo', announce, announce['to']
        FileUtils.rm(announce_file)
      end
      Dir[File.join box, 'create', '*.json'].each do |create_file|
        create = JSON.load_file(create_file)
        next unless create['object']['id'] == id

        object = JSON.load_file(file)
        outbox 'Delete', object, object['to']
        FileUtils.rm(create_file)
      end
    end
    FileUtils.rm(file) if File.exist? file
  end
  200
end

post '/undo' do # TODO: generalize for announce
  protected!
  Dir[File.join('outbox', '*', '*.json')].each do |f|
    activity = JSON.load_file(f)
    next unless activity['id'] == params['id']

    object_file = find_file activity['object']['id']
    outbox 'Undo', params['id'], activity['to']
    FileUtils.rm(object_file)
    FileUtils.rm(f)
  end
  200
end

post '/follow' do
  protected!
  params['id'] = actor params['mention'] if params['mention']
  outbox 'Follow', params['id'], [params['id']]
  200
end

post '/unfollow' do
  protected!
  params['id'] = actor params['mention'] if params['mention']
  following = Dir[File.join(OUTBOX[:dir], 'follow', '*.json')].collect { |f| JSON.load_file(f) }
  activity = following.find { |a| a['object'] == params['id'] }
  activity ||= {
    "@context": 'https://www.w3.org/ns/activitystreams',
    "type": 'Follow',
    "actor": 'https://social.pdp8.info/pdp8',
    "object": params['id']
  }
  outbox 'Undo', activity, [params['id']]
  update_collection FOLLOWING, params['id'], true
  200
end

post '/share' do # TODO
  protected!
  src = find_file params['id']
  object = JSON.load_file(src)
  recipients = ['https://www.w3.org/ns/activitystreams#Public']
  recipients += JSON.load_file(FOLLOWERS)['orderedItems']
  recipients << object['attributedTo']
  outbox 'Announce', object, recipients
  dest = src.sub('inbox/', 'outbox/')
  FileUtils.mkdir_p File.dirname(dest)
  FileUtils.mv src, dest
  200
end

post '/login' do
  session['client'] = (OpenSSL::Digest::SHA256.base64digest(params['secret']) == File.read('.digest').chomp)
  200
end

helpers do
  def protected!
    halt 403 unless session['client']
  end
end