github/diaspora
1
1
Fork 0
mirror of https://github.com/diaspora/diaspora.git synced 2026-04-29 03:01:03 -04:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'master' of github.com:diaspora/diaspora into production

Browse Source 
Conflicts:
	config/deploy.rb
	config/environments/production.rb
	spec/models/request_spec.rb
This commit is contained in:
Raphael
2010-09-15 22:37:05 -07:00
parent de93fd2818 7334501f2b
commit c67a8ea100
95 changed files with 589 additions and 468 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
.gitignore vendored
View File

@@ -1,3 +1,4 @@
.bundle
.idea
*.swap
*.swp
@@ -10,4 +11,5 @@ tmp/**/*
gpg/diaspora-development/*.gpg
gpg/diaspora-production/*.gpg
gpg/*/random_seed
public/uploads/*
public/uploads/*
.rvmrc

7
Gemfile
View File

@@ -35,14 +35,17 @@ gem 'thin'
gem 'carrierwave', :git => 'git://github.com/rsofaer/carrierwave.git' , :branch => 'master' #Untested mongomapper branch
gem 'mini_magick'
group :test, :development do
gem 'factory_girl_rails'
end
group :test do
gem 'rspec', '>= 2.0.0.beta.17'
gem 'rspec-rails', '2.0.0.beta.17'
gem 'rspec-rails', '2.0.0.beta.17'
gem 'mocha'
gem 'webrat', '0.7.2.beta.1'
gem 'redgreen'
gem 'autotest'
gem 'factory_girl_rails'
gem 'database_cleaner'
gem 'saucelabs-adapter', '= 0.8.12'
gem 'selenium-rc'

28
Gemfile.lock
View File

@@ -8,9 +8,9 @@ GIT
GIT
remote: git://github.com/igrigorik/em-http-request.git
revision: b09b26a2737cce3f41c3d7313054efdb9e2c623e
revision: 6f66010cda90991863669ca52fd4c320dd931a06
specs:
em-http-request (0.2.11)
em-http-request (0.2.12)
addressable (>= 2.0.0)
eventmachine (>= 0.12.9)
@@ -93,7 +93,7 @@ GEM
activemodel (= 3.0.0)
activesupport (= 3.0.0)
activesupport (3.0.0)
addressable (2.2.0)
addressable (2.2.1)
arel (1.0.1)
activesupport (~> 3.0.0)
autotest (4.3.2)
@@ -129,7 +129,7 @@ GEM
json (1.4.6)
linecache (0.43)
lsof (0.3.0)
mail (2.2.5)
mail (2.2.6.1)
activesupport (>= 2.3.6)
mime-types
treetop (>= 1.4.5)
@@ -140,7 +140,6 @@ GEM
rake
mongo (1.0.8)
bson (>= 1.0.5)
mongo_ext (0.19.3)
net-scp (1.0.3)
net-ssh (>= 1.99.1)
net-sftp (2.0.5)
@@ -149,7 +148,7 @@ GEM
net-ssh-gateway (1.0.1)
net-ssh (>= 1.99.1)
nifty-generators (0.4.0)
nokogiri (1.4.1)
nokogiri (1.4.3.1)
plucky (0.3.5)
mongo (~> 1.0.8)
polyglot (0.3.1)
@@ -178,14 +177,16 @@ GEM
redgreen (1.2.2)
rest-client (1.6.1)
mime-types (>= 1.16)
rspec (2.0.0.beta.20)
rspec-core (= 2.0.0.beta.20)
rspec-expectations (= 2.0.0.beta.20)
rspec-mocks (= 2.0.0.beta.20)
rspec-core (2.0.0.beta.20)
rspec-expectations (2.0.0.beta.20)
rspec (2.0.0.beta.22)
rspec-core (= 2.0.0.beta.22)
rspec-expectations (= 2.0.0.beta.22)
rspec-mocks (= 2.0.0.beta.22)
rspec-core (2.0.0.beta.22)
rspec-expectations (2.0.0.beta.22)
diff-lcs (>= 1.1.2)
rspec-mocks (2.0.0.beta.20)
rspec-mocks (2.0.0.beta.22)
rspec-core (= 2.0.0.beta.22)
rspec-expectations (= 2.0.0.beta.22)
rspec-rails (2.0.0.beta.17)
rspec (>= 2.0.0.beta.14)
webrat (>= 0.7.0)
@@ -243,7 +244,6 @@ DEPENDENCIES
json
mini_magick
mocha
mongo_ext
mongo_mapper (= 0.8.4)!
nifty-generators
pubsubhubbub

65
README.md
View File

@@ -10,7 +10,7 @@ GEMS: We would like to keep external dependencies unduplicated. We're using No
The privacy aware, personally controlled, do-it-all, open source social network.
**DISCLAIMER: THIS IS PRE-ALPHA SOFTWARE AND SHOULD BE TREATED ACCORDINGLY.**
These instructions are for machines running [Ubuntu](http://www.ubuntu.com/) or Mac OS X. We are developing Diaspora for the latest and greatest browsers, so please update your Firefox, Chrome or Safari to the latest and greatest.
These instructions are for machines running [Ubuntu](http://www.ubuntu.com/), [Fedora](http://www.fedoraproject.org) or Mac OS X. We are developing Diaspora for the latest and greatest browsers, so please update your Firefox, Chrome or Safari to the latest and greatest.
## Preparing your system
In order to run Diaspora, you will need to download the following dependencies (specific instructions follow):
@@ -27,7 +27,7 @@ After you have Ruby installed on your system, you will need to get RubyGems, the
- [RubyGems](http://rubygems.org/) - Source for Ruby gems.
- [Bundler](http://gembundler.com/) - Gem management tool for Ruby projects.
**We suggest using a package management system to download these dependencies. Trust us, it's going to make your life a lot easier. If you're using Mac OS X, you can use [homebrew](http://mxcl.github.com/homebrew/); and if you're using Ubuntu, just use [Synaptic](http://www.nongnu.org/synaptic/) (it comes pre-installed). The instructions below assume you have these installed.**
**We suggest using a package management system to download these dependencies. Trust us, it's going to make your life a lot easier. If you're using Mac OS X, you can use [homebrew](http://mxcl.github.com/homebrew/); if you're using Ubuntu, just use [Synaptic](http://www.nongnu.org/synaptic/) (it comes pre-installed); if you're using Fedora simply use [yum](http://yum.baseurl.org/). The instructions below assume you have these installed.**
### Build Tools
@@ -35,6 +35,10 @@ To install build tools on **Ubuntu**, run the following (includes the gcc and xm
sudo apt-get install build-essential libxslt1.1 libxslt1-dev libxml2
To install build tools on **Fedora**, run the following:
sudo yum install libxslt libxslt-devel libxml2 libxml2-devel
To install build tools on **Mac OS X**, you need to download and install [Xcode](http://developer.apple.com/technologies/tools/xcode.html).
### Ruby
@@ -43,6 +47,13 @@ To install Ruby 1.8.7 on **Ubuntu**, run the following command:
sudo apt-get install ruby-full
At this time Fedora does not have Ruby 1.8.7. As a workaround it is possible to use [rvm](http://rvm.beginrescueend.com/) with a locally compiled Ruby installation. A semi automated method for doing this is available. It is highly recommended that you review the script before running it so you understand what will occur. The script can be executed by running the following command:
./script/bootstrap-fedora-diaspora.sh
After reviewing and executing the above script you will need to follow the "MongoDB" section and then you should skip all the way down to "Start Mongo".
If you're on **Mac OS X**, you already have Ruby on your system. Yay!
### MongoDB
@@ -71,13 +82,36 @@ If you're running a 32-bit system, run `wget http://fastdl.mongodb.org/linux/mon
sudo chmod -Rv 777 /data/
To install MongoDB on a x86_64 **Fedora** system, add the official MongoDB repository from MongoDB (http://www.mongodb.org/display/DOCS/CentOS+and+Fedora+Packages) into /etc/yum.repos.d/10gen.repo:
[10gen]
name=10gen Repository
baseurl=http://downloads.mongodb.org/distros/fedora/13/os/x86_64/
gpgcheck=0
enabled=1
Then use yum to install the packages:
sudo yum install mongo-stable mongo-stable-server
If you're running a 32-bit system, run `wget http://fastdl.mongodb.org/linux/mongodb-linux-i686-1.6.2.tgz`. If you're running a 64-bit system, run `wget http://fastdl.mongodb.org/linux/mongodb-linux-x86_64-1.6.2.tgz`.
# extract
tar xzf mongodb-linux-i686-1.4.0.tgz
# create the required data directory
sudo mkdir -p /data/db
sudo chmod -Rv 777 /data/
To install MongoDB on **Mac OS X**, run the following:
brew install mongo
### OpenSSL
If you're running either **Ubuntu** or **Mac OS X** you already have OpenSSL installed!
If you're running either **Ubuntu**, **Fedora** or **Mac OS X** you already have OpenSSL installed!
### ImageMagick
@@ -85,6 +119,10 @@ To install ImageMagick on **Ubuntu**, run the following:
sudo apt-get install imagemagick libmagick9-dev
To install ImageMagick on **Fedora**, run the following:
sudo yum install ImageMagick
To install ImageMagick on **Mac OS X**, run the following:
brew install imagemagick
@@ -95,6 +133,11 @@ To install Git on **Ubuntu**, run the following:
sudo apt-get install git-core
To install Git on **Fedora**, run the following:
sudo yum install git
To install Git on **Mac OS X**, run the following:
brew install git
@@ -110,6 +153,10 @@ On **Ubuntu**, run the following:
sudo ruby setup.rb
sudo ln -s /usr/bin/gem1.8 /usr/bin/gem
On **Fedora**, run the following:
sudo yum install rubygems
On **Mac OS X**, RubyGems comes preinstalled; however, you might need to update it for use with the latest Bundler. To update RubyGems, run `sudo gem update --system`.
@@ -120,7 +167,7 @@ After RubyGems is updated, simply run `sudo gem install bundler` to get Bundler.
## Getting Diaspora
git clone git@github.com:diaspora/diaspora.git
git clone http://github.com/diaspora/diaspora.git
If you have never used github before, their [help desk](http://help.github.com/) has a pretty awesome guide on getting setup.
@@ -131,13 +178,19 @@ If you have never used github before, their [help desk](http://help.github.com/)
To start the app server for the first time, you need to use Bundler to install Diaspora's gem depencencies. Run `bundle install` from Diaspora's root directory. Bundler will also warn you if there is a new dependency and you need to bundle install again.
### Start Mongo
After installing the above, run `sudo mongod` from where mongo is installed to start mongo.
If you installed the Ubuntu package, MongoDB should already be running (if not, run `service mongodb start`). If you installed the binary manually, run `sudo mongod` from where mongo is installed to start mongo.
If you installed the Fedora package, MongoDB will need to be started via `service mongodb start`. If you installed the binary manually, run `sudo mongod` from where mongo is installed to start mongo.
Diaspora will not run unless mongo is running. Mongo will not run by default, and will need to be started every time you wish to use or run the test suite for Diaspora.
### Run the app server
Once mongo is running and bundler has finished, run `bundle exec thin start` from the root Diaspora directory. This will start the app server in development mode[.](http://bit.ly/9mwtUw)
### Logging in
Run `rake db:seed:tom`, then login with user `tom` and password `evankorth`. More details in db/seeds/tom.rb.
### Testing
Diaspora's test suite uses [rspec](http://rspec.info/), a behavior driven testing framework. In order to run the tests, run `bundle exec rspec spec`.

10
app/controllers/albums_controller.rb
View File

@@ -12,25 +12,25 @@ class AlbumsController < ApplicationController
@albums = current_user.albums_by_aspect(@aspect).paginate
respond_with @albums, :aspect => @aspect
end
def create
aspect = params[:album][:to]
@album = current_user.post(:album, params[:album])
flash[:notice] = "You've created an album called #{@album.name}."
redirect_to :action => :show, :id => @album.id, :aspect => aspect
end
def new
@album = Album.new
end
def destroy
@album = Album.find_by_id params[:id]
@album.destroy
flash[:notice] = "Album #{@album.name} deleted."
respond_with :location => albums_url
end
def show
@photo = Photo.new
@album = Album.find_by_id params[:id]
@@ -47,7 +47,7 @@ class AlbumsController < ApplicationController
def update
@album = Album.find_params_by_id params[:id]
if @album.update_attributes params[:album]
flash[:notice] = "Album #{@album.name} successfully edited."
flash[:notice] = "Album #{@album.name} successfully edited."
respond_with @album
else
flash[:error] = "Failed to edit album #{@album.name}."

10
app/controllers/application_controller.rb
View File

@@ -4,9 +4,9 @@
class ApplicationController < ActionController::Base
protect_from_forgery :except => :receive
before_filter :set_friends_and_status, :except => [:create, :update]
before_filter :count_requests
@@ -19,7 +19,7 @@ class ApplicationController < ActionController::Base
"application"
end
end
def set_friends_and_status
if current_user
if params[:aspect] == nil || params[:aspect] == 'all'
@@ -27,7 +27,7 @@ class ApplicationController < ActionController::Base
else
@aspect = current_user.aspect_by_id( params[:aspect])
end
@aspects = current_user.aspects
@friends = current_user.friends
end
@@ -36,5 +36,5 @@ class ApplicationController < ActionController::Base
def count_requests
@request_count = Request.for_user(current_user).size if current_user
end
end

8
app/controllers/aspects_controller.rb
View File

@@ -19,18 +19,18 @@ class AspectsController < ApplicationController
flash[:notice] = "Click on the plus on the left side to tell Diaspora who can see your new aspect."
respond_with :location => aspects_manage_path
end
def new
@aspect = Aspect.new
end
def destroy
@aspect = Aspect.find_by_id params[:id]
@aspect.destroy
flash[:notice] = "You are no longer sharing the aspect called #{@aspect.name}."
respond_with :location => aspects_url
end
def show
@aspect = Aspect.find_by_id params[:id]
@friends = @aspect.people
@@ -66,7 +66,7 @@ class AspectsController < ApplicationController
end
def move_friend
unless current_user.move_friend( :friend_id => params[:friend_id], :from => params[:from], :to => params[:to][:to])
unless current_user.move_friend( :friend_id => params[:friend_id], :from => params[:from], :to => params[:to][:to])
flash[:error] = "didn't work #{params.inspect}"
end
if aspect = Aspect.first(:id => params[:to][:to])

2
app/controllers/comments_controller.rb
View File

@@ -5,7 +5,7 @@
class CommentsController < ApplicationController
before_filter :authenticate_user!
respond_to :html
respond_to :json, :only => :show

26
app/controllers/dev_utilities_controller.rb
View File

@@ -10,14 +10,14 @@ class DevUtilitiesController < ApplicationController
def warzombie
render :nothing => true
if current_user.email == "tom@tom.joindiaspora.com" && StatusMessage.where(:message => "There's a bomb in the lasagna!?").first == nil
current_user.post(:status_message, :message => "There's a bomb in the lasagna!?")
current_user.post(:status_message, :message => "There's a bomb in the lasagna!?")
current_user.post(:status_message, :message => "xkcd \nhttp://xkcd.com/743/" )
current_user.post(:status_message, :message => "I switched to Motoroi today, a Motorola Android-based phone, in Korea. Now, I am using Android phones in both the U.S. and Korea", :created_at => Time.now-930)
current_user.post(:status_message, :message => "I had 5 hours to study for it :-( GREs on Thursday. Wunderbar.", :created_at => Time.now-43990)
current_user.post(:status_message, :message => "Spotted in toy story 3: google maps, OSX, and windows XP. Two out of three isn't bad.", :created_at => Time.now-4390)
current_user.post(:status_message, :message => "Reddit\nhttp://reddit.com", :created_at => Time.now-54390)
current_user.post(:status_message, :message => "Commercials for IE make me SO MAD and my friends just don't get why.", :created_at => Time.now-30900)
current_user.post(:status_message, :message => "Zombo.com\nhttp://zombo.com", :created_at => Time.now-9090)
current_user.post(:status_message, :message => "Zombo.com\nhttp://zombo.com", :created_at => Time.now-9090)
current_user.post(:status_message, :message => "Why do I have \"No More Heroes\" by Westlife on repeat all day?", :created_at => Time.now-590000)
current_user.post(:status_message, :message => "Mmm. Friday night. Acknowledged.", :created_at => Time.now-503900)
current_user.post(:status_message, :message => "Getting a universal remote is the epitome of laziness, I do declare.", :created_at => Time.now-4400)
@@ -30,7 +30,7 @@ def warzombie
render :nothing => true
bkr_info = backer_info
if current_user.email == "tom@tom.joindiaspora.com"
if current_user.email == "tom@tom.joindiaspora.com"
bkr_info.each do |backer|
backer_email = "#{backer['username']}@#{backer['username']}.joindiaspora.com"
rel_hash = relationship_flow(backer_email)
@@ -43,13 +43,13 @@ def warzombie
def zombiefriendaccept
render :nothing => true
Request.all.each{|r|
Request.all.each{|r|
current_user.accept_and_respond(r.id, current_user.aspects.first.id)
}
end
def backer_info
config = YAML.load_file(File.dirname(__FILE__) + '/../../config/deploy_config.yml')
config = YAML.load_file(File.dirname(__FILE__) + '/../../config/deploy_config.yml')
config['servers']['backer']
end
@@ -67,28 +67,28 @@ def warzombie
album = Album.create(:person => current_user.person, :name => "Profile Photos")
current_user.raw_visible_posts << album
current_user.save
backer_number = YAML.load_file(Rails.root.join('config','backer_number.yml'))[:seed_number].to_i
username = backer_info[backer_number]['username'].gsub(/ /,'').downcase
@fixture_name = File.dirname(__FILE__) + "/../../public/images/user/#{username}.jpg"
photo = Photo.new(:person => current_user.person, :album => album)
photo.image.store! File.open(@fixture_name)
photo.save
photo.reload
current_user.raw_visible_posts << photo
current_user.save
current_user.update_profile(:image_url => photo.url(:thumb_medium))
current_user.save
end
def log
@log = `tail -n 200 log/development.log`
render "shared/log"
end
end

12
app/controllers/people_controller.rb
View File

@@ -8,27 +8,27 @@ class PeopleController < ApplicationController
respond_to :html
respond_to :json, :only => [:index, :show]
def index
@aspects_dropdown_array = current_user.aspects.collect{|x| [x.to_s, x.id]}
@aspects_dropdown_array = current_user.aspects.collect{|x| [x.to_s, x.id]}
@people = Person.search params[:q]
respond_with @people
end
def show
@person = current_user.visible_person_by_id(params[:id])
@profile = @person.profile
@aspects_with_person = current_user.aspects_with_person(@person)
@aspects_dropdown_array = current_user.aspects.collect{|x| [x.to_s, x.id]}
@aspects_dropdown_array = current_user.aspects.collect{|x| [x.to_s, x.id]}
@posts = current_user.visible_posts_from_others(:from => @person).paginate :page => params[:page], :order => 'created_at DESC'
@latest_status_message = current_user.raw_visible_posts.find_all_by__type_and_person_id("StatusMessage", params[:id]).last
@post_count = @posts.count
respond_with @person
end
def destroy
current_user.unfriend(current_user.visible_person_by_id(params[:id]))
respond_with :location => root_url
end
end

16
app/controllers/photos_controller.rb
View File

@@ -8,9 +8,9 @@ class PhotosController < ApplicationController
respond_to :html
respond_to :json, :only => :show
def create
album = Album.find_by_id params[:album_id]
begin
@@ -30,15 +30,15 @@ class PhotosController < ApplicationController
Tempfile.send(:define_method, "original_filename") {return file_name}
##############
params[:user_file] = file
params[:user_file] = file
@photo = current_user.post(:photo, params)
respond_to do |format|
format.json{render(:layout => false , :json => {"success" => true, "data" => @photo}.to_json )}
end
rescue TypeError
message = "Photo upload failed. Are you sure an image was added?"
respond_with :location => album, :error => message
@@ -53,20 +53,20 @@ class PhotosController < ApplicationController
raise e
end
end
def new
@photo = Photo.new
@album = current_user.album_by_id(params[:album_id])
render :partial => 'new_photo'
end
def destroy
@photo = Photo.find_by_id params[:id]
@photo.destroy
flash[:notice] = "Photo deleted."
respond_with :location => @photo.album
end
def show
@photo = Photo.find_by_id params[:id]
@album = @photo.album

6
app/controllers/publics_controller.rb
View File

@@ -7,7 +7,7 @@ class PublicsController < ApplicationController
require 'lib/diaspora/parser'
include Diaspora::Parser
layout false
def hcard
@person = Person.find_by_id params[:id]
puts @person
@@ -26,7 +26,7 @@ class PublicsController < ApplicationController
render 'webfinger', :content_type => 'application/xrd+xml'
end
end
def receive
render :nothing => true
return unless params[:xml]
@@ -38,5 +38,5 @@ class PublicsController < ApplicationController
end
@user.receive_salmon params[:xml]
end
end

4
app/controllers/registrations_controller.rb
View File

@@ -8,7 +8,7 @@ class RegistrationsController < Devise::RegistrationsController
end
def create
begin
begin
user = User.instantiate!(params[:user])
rescue MongoMapper::DocumentNotValid => e
user = nil
@@ -20,7 +20,7 @@ class RegistrationsController < Devise::RegistrationsController
#redirect_to root_url
sign_in_and_redirect(:user, user)
else
redirect_to "/get_to_the_choppa"
redirect_to new_user_registration_path
end
end

14
app/controllers/requests_controller.rb
View File

@@ -5,7 +5,7 @@
class RequestsController < ApplicationController
before_filter :authenticate_user!
include RequestsHelper
include RequestsHelper
respond_to :html
@@ -25,24 +25,24 @@ class RequestsController < ApplicationController
respond_with :location => requests_url
end
end
def new
@request = Request.new
end
def create
aspect = current_user.aspect_by_id(params[:request][:aspect_id])
begin
begin
rel_hash = relationship_flow(params[:request][:destination_url])
rescue Exception => e
flash[:error] = "No diaspora seed found with this email!"
flash[:error] = "No diaspora seed found with this email!"
respond_with :location => aspect
return
end
Rails.logger.debug("Sending request: #{rel_hash}")
begin
@request = current_user.send_friend_request_to(rel_hash[:friend], aspect)
rescue Exception => e

6
app/controllers/sockets_controller.rb
View File

@@ -3,7 +3,7 @@
# the COPYRIGHT file.
class SocketsController < ApplicationController
class SocketsController < ApplicationController
include ApplicationHelper
include SocketsHelper
include Rails.application.routes.url_helpers
@@ -11,10 +11,10 @@ class SocketsController < ApplicationController
def incoming(msg)
Rails.logger.info("Socket received connection to: #{msg}")
end
def outgoing(uid,object,opts={})
@_request = ActionDispatch::Request.new({})
Diaspora::WebSocket.push_to_user(uid, action_hash(uid, object, opts))
end
end

4
app/controllers/status_messages_controller.rb
View File

@@ -14,13 +14,13 @@ class StatusMessagesController < ApplicationController
@status_message = current_user.post(:status_message, params[:status_message])
respond_with @status_message
end
def destroy
@status_message = StatusMessage.find_by_id params[:id]
@status_message.destroy
respond_with :location => root_url
end
def show
@status_message = StatusMessage.find_by_id params[:id]
respond_with @status_message

4
app/controllers/users_controller.rb
View File

@@ -25,7 +25,7 @@ class UsersController < ApplicationController
def update
@user = User.find_by_id params[:id]
prep_image_url(params[:user])
@user.update_profile params[:user]
respond_with(@user, :location => root_url)
end
@@ -35,7 +35,7 @@ class UsersController < ApplicationController
def prep_image_url(params)
if params[:profile][:image_url].empty?
params[:profile].delete(:image_url)
else
else
params[:profile][:image_url] = "http://" + request.host + ":" + request.port.to_s + params[:profile][:image_url]
end
end

2
app/helpers/albums_helper.rb
View File

@@ -11,7 +11,7 @@ module AlbumsHelper
link_to 'Friends Albums', albums_path({:friends => true})
end
end
def your_albums_link
if params[:friends]
link_to 'Your Albums', albums_path

12
app/helpers/application_helper.rb
View File

@@ -4,28 +4,28 @@
module ApplicationHelper
def current_aspect?(aspect)
!@aspect.is_a?(Symbol) && @aspect.id == aspect.id
end
def object_path(object, opts = {})
eval("#{object.class.to_s.underscore}_path(object, opts)")
end
def object_fields(object)
object.attributes.keys
object.attributes.keys
end
def mine?(post)
current_user.owns? post
end
def type_partial(post)
class_name = post.class.name.to_s.underscore
"#{class_name.pluralize}/#{class_name}"
end
def how_long_ago(obj)
"#{time_ago_in_words(obj.created_at)} ago."
end
@@ -63,7 +63,7 @@ module ApplicationHelper
def new_request(request_count)
"new_requests" if request_count > 0
end
def post_yield_tag(post)
(':' + post.id.to_s).to_sym
end

4
app/helpers/error_messages_helper.rb
View File

@@ -6,7 +6,7 @@
module ErrorMessagesHelper
# Render error messages for the given objects. The :message and :header_message options are allowed.
def error_messages_for(*objects)
options = objects.extract_options!
options = objects.extract_options!
options[:header_message] ||= "Invalid Fields"
options[:message] ||= "Correct the following errors and try again."
messages = objects.compact.map { |o| o.errors.full_messages }.flatten
@@ -17,7 +17,7 @@ module ErrorMessagesHelper
end
end
end
module FormBuilderAdditions
def error_messages(options = {})
@template.error_messages_for(@object, options)

6
app/helpers/layout_helper.rb
View File

@@ -12,15 +12,15 @@ module LayoutHelper
content_for(:title) { page_title.to_s }
@show_title = show_title
end
def show_title?
@show_title
end
def stylesheet(*args)
content_for(:head) { stylesheet_link_tag(*args) }
end
def javascript(*args)
content_for(:head) { javascript_include_tag(*args) }
end

4
app/helpers/people_helper.rb
View File

@@ -4,13 +4,13 @@
module PeopleHelper
def search_or_index
if params[:q]
" results for #{params[:q]}"
else
" people on pod is aware of"
end
end
end

2
app/helpers/photos_helper.rb
View File

@@ -4,7 +4,7 @@
module PhotosHelper
def linked_scaled_photo(photo, album)
link_to (image_tag photo.url(:scaled_full)), photo_path(album.next_photo(photo)), :rel => "prefetch"
end

2
app/helpers/publics_helper.rb
View File

@@ -15,7 +15,7 @@ module PublicsHelper
elsif opts[:verify] == 'async'
202
end
else
else
400
end
end

2
app/helpers/requests_helper.rb
View File

@@ -9,7 +9,7 @@ module RequestsHelper
if diaspora?(profile)
:friend
else
:none
:none
end
end

10
app/helpers/sockets_helper.rb
View File

@@ -4,8 +4,8 @@
module SocketsHelper
include ApplicationHelper
include ApplicationHelper
def obj_id(object)
(object.is_a? Post) ? object.id : object.post_id
end
@@ -16,10 +16,10 @@ module SocketsHelper
v = render_to_string(:partial => type_partial(object), :locals => {:post => object, :current_user => user}) unless object.is_a? Retraction
rescue Exception => e
Rails.logger.error("web socket view rendering failed for object #{object.inspect}.")
raise e
raise e
end
action_hash = {:class =>object.class.to_s.underscore.pluralize, :html => v, :post_id => obj_id(object)}
action_hash.merge! opts
action_hash.merge! opts
if object.is_a? Photo
action_hash[:photo_hash] = object.thumb_hash
elsif object.is_a? StatusMessage
@@ -34,6 +34,6 @@ module SocketsHelper
action_hash.to_json
end
end

4
app/models/album.rb
View File

@@ -16,12 +16,12 @@ class Album < Post
validates_presence_of :name, :person
before_destroy :destroy_photos
def self.mine_or_friends(friend_param, current_user)
friend_param ? Album.find_all_by_person_id(current_user.friend_ids) : current_user.person.albums
end
def prev_photo(photo)
n_photo = self.photos.where(:created_at.lt => photo.created_at).sort(:created_at.desc).first
n_photo ? n_photo : self.photos.sort(:created_at.desc).first

6
app/models/aspect.rb
View File

@@ -5,7 +5,7 @@
class Aspect
include MongoMapper::Document
key :name, String
key :person_ids, Array
key :request_ids, Array
@@ -20,11 +20,11 @@ class Aspect
validates_presence_of :name
timestamps!
def to_s
name
end
def posts_by_person_id( id )
id = id.to_id
posts.detect{|x| x.person.id == id }

20
app/models/comment.rb
View File

@@ -9,12 +9,12 @@ class Comment
include Diaspora::Webhooks
include Encryptable
include Diaspora::Socketable
xml_accessor :text
xml_accessor :person, :as => Person
xml_accessor :post_id
xml_accessor :_id
xml_accessor :_id
key :text, String
key :post_id, ObjectId
key :person_id, ObjectId
@@ -26,17 +26,17 @@ class Comment
validates_presence_of :text
timestamps!
#ENCRYPTION
xml_accessor :creator_signature
xml_accessor :post_creator_signature
key :creator_signature, String
key :post_creator_signature, String
def signable_accessors
accessors = self.class.roxml_attrs.collect{|definition|
accessors = self.class.roxml_attrs.collect{|definition|
definition.accessor}
accessors.delete 'person'
accessors.delete 'creator_signature'
@@ -45,16 +45,16 @@ class Comment
end
def signable_string
signable_accessors.collect{|accessor|
signable_accessors.collect{|accessor|
(self.send accessor.to_sym).to_s}.join ';'
end
def verify_post_creator_signature
verify_signature(post_creator_signature, post.person)
end
def signature_valid?
verify_signature(creator_signature, person)
end
end

18
app/models/person.rb
View File

@@ -15,10 +15,10 @@ class Person
xml_accessor :url
xml_accessor :profile, :as => Profile
xml_reader :exported_key
key :url, String
key :diaspora_handle, String, :unique => true
key :serialized_key, String
key :serialized_key, String
key :owner_id, ObjectId
@@ -30,11 +30,11 @@ class Person
before_destroy :remove_all_traces
before_validation :clean_url
validates_presence_of :url, :profile, :serialized_key
validates_presence_of :url, :profile, :serialized_key
validates_format_of :url, :with =>
/^(https?):\/\/[a-z0-9]+([\-\.]{1}[a-z0-9]+)*(\.[a-z]{2,5})?(:[0-9]{1,5})?(\/.*)?$/ix
def self.search(query)
Person.all('$where' => "function() { return this.diaspora_handle.match(/^#{query}/i) ||
this.profile.first_name.match(/^#{query}/i) ||
@@ -80,7 +80,7 @@ class Person
def self.by_webfinger( identifier )
local_person = Person.first(:diaspora_handle => identifier.gsub('acct:', ''))
if local_person
local_person
elsif !identifier.include?("localhost")
@@ -102,9 +102,9 @@ class Person
guid = profile.links.select{|x| x.rel == 'http://joindiaspora.com/guid'}.first.href
new_person.id = guid
new_person.diaspora_handle = identifier
hcard = HCard.find profile.hcard.first[:href]
new_person.url = hcard[:url]
@@ -115,7 +115,7 @@ class Person
nil
end
end
def remote?
owner.nil?
end

10
app/models/photo.rb
View File

@@ -7,10 +7,10 @@ class Photo < Post
require 'carrierwave/orm/mongomapper'
include MongoMapper::Document
mount_uploader :image, ImageUploader
xml_accessor :remote_photo
xml_accessor :caption
xml_reader :album_id
xml_reader :album_id
key :album_id, ObjectId
key :caption, String
@@ -29,7 +29,7 @@ class Photo < Post
def self.instantiate(params = {})
image_file = params[:user_file]
params.delete :user_file
photo = Photo.new(params)
photo.image.store! image_file
photo.save
@@ -39,7 +39,7 @@ class Photo < Post
def validate_album_person
album.person_id == person_id
end
def remote_photo
image.url.nil? ? (remote_photo_path + '/' + remote_photo_name) : image.url
end
@@ -63,7 +63,7 @@ class Photo < Post
users = Person.all('profile.image_url' => image.url(:thumb_medium) )
users.each{ |user|
user.profile.update_attributes!(:image_url => nil)
}
}
end
def thumb_hash

16
app/models/post.rb
View File

@@ -3,10 +3,10 @@
# the COPYRIGHT file.
class Post
class Post
require 'lib/encryptable'
include MongoMapper::Document
include ApplicationHelper
include ApplicationHelper
include ROXML
include Diaspora::Webhooks
include Diaspora::Socketable
@@ -15,16 +15,16 @@ class Post
xml_accessor :person, :as => Person
key :person_id, ObjectId
key :user_refs, Integer, :default => 0
key :user_refs, Integer, :default => 0
many :comments, :class_name => 'Comment', :foreign_key => :post_id
belongs_to :person, :class_name => 'Person'
timestamps!
cattr_reader :per_page
@@per_page = 10
before_destroy :propogate_retraction
after_destroy :destroy_comments
@@ -41,12 +41,12 @@ class Post
}
}
end
protected
def destroy_comments
comments.each{|c| c.destroy}
end
def propogate_retraction
self.person.owner.retract(self)
end

2
app/models/profile.rb
View File

@@ -23,7 +23,7 @@ class Profile
def person_id
self._parent_document.id
end
def person
self._parent_document
end

8
app/models/request.rb
View File

@@ -22,7 +22,7 @@ class Request
key :exported_key, String
belongs_to :person
validates_presence_of :destination_url, :callback_url
before_validation :clean_link
@@ -32,19 +32,19 @@ class Request
def self.instantiate(options = {})
person = options[:from]
self.new(:destination_url => options[:to],
:callback_url => person.receive_url,
:callback_url => person.receive_url,
:person => person,
:exported_key => person.exported_key,
:aspect_id => options[:into])
end
def reverse_for accepting_user
self.person = accepting_user.person
self.exported_key = accepting_user.exported_key
self.destination_url = self.callback_url
self.save
end
protected
def clean_link
if self.destination_url

2
app/models/retraction.rb
View File

@@ -43,7 +43,7 @@ class Retraction
def self.person_id_from(object)
object.is_a?(Person) ? object.id : object.person.id
end
def person
Person.find_by_id(self.person_id)
end

8
app/models/status_message.rb
View File

@@ -4,14 +4,14 @@
class StatusMessage < Post
xml_name :status_message
xml_accessor :message
key :message, String
validates_presence_of :message
def to_activity
<<-XML
<entry>
@@ -24,7 +24,7 @@ class StatusMessage < Post
</entry>
XML
end
def latest_hash
{ :text => message}
end

44
app/models/user.rb
View File

@@ -17,14 +17,14 @@ class User
devise :database_authenticatable, :registerable,
:recoverable, :rememberable, :trackable, :validatable
key :username, :unique => true
key :friend_ids, Array
key :pending_request_ids, Array
key :visible_post_ids, Array
key :visible_person_ids, Array
key :url, String
one :person, :class_name => 'Person', :foreign_key => :owner_id
many :friends, :in => :friend_ids, :class_name => 'Person'
@@ -37,7 +37,7 @@ class User
after_create :seed_aspects
before_validation_on_create :downcase_username
def self.find_for_authentication(conditions={})
if conditions[:username] =~ /^([\w\.%\+\-]+)@([\w\-]+\.)+([\w]{2,})$/i # email regex
conditions[:email] = conditions.delete(:username)
@@ -45,7 +45,7 @@ class User
conditions[:username].downcase!
end
super
end
end
######## Making things work ########
key :email, String
@@ -57,7 +57,7 @@ class User
def real_name
"#{person.profile.first_name.to_s} #{person.profile.last_name.to_s}"
end
######### Aspects ######################
def aspect( opts = {} )
opts[:user] = self
@@ -68,7 +68,7 @@ class User
return true if opts[:to] == opts[:from]
friend = Person.first(:_id => opts[:friend_id])
if self.friend_ids.include?(friend.id)
from_aspect = self.aspect_by_id(opts[:from])
from_aspect = self.aspect_by_id(opts[:from])
to_aspect = self.aspect_by_id(opts[:to])
if from_aspect && to_aspect
posts_to_move = from_aspect.posts.find_all_by_person_id(friend.id)
@@ -125,7 +125,7 @@ class User
aspects = self.aspects.find_all_by_id( aspect_ids )
end
#send to the aspects
target_people = []
target_people = []
aspects.each{ |aspect|
aspect.posts << post
@@ -145,7 +145,7 @@ class User
Rails.logger.debug("Adding xml for #{self} to message queue to #{url}")
QUEUE.add_post_request( person.receive_url, person.encrypt(xml) )
QUEUE.process
end
def salmon( post, opts = {} )
@@ -163,7 +163,7 @@ class User
end
comment
end
def build_comment( text, options = {})
raise "must comment on something!" unless options[:on]
comment = Comment.new(:person_id => self.person.id, :text => text, :post => options[:on])
@@ -183,10 +183,10 @@ class User
push_to_people comment, people_in_aspects(aspects_with_post(comment.post.id))
elsif owns? comment
comment.save
salmon comment, :to => comment.post.person
salmon comment, :to => comment.post.person
end
end
######### Posts and Such ###############
def retract( post )
aspect_ids = aspects_with_post( post.id )
@@ -248,9 +248,9 @@ else
elsif object.is_a? Profile
person = Diaspora::Parser.owner_id_from_xml xml
person.profile = object
person.save
person.save
elsif object.is_a?(Comment)
elsif object.is_a?(Comment)
object.person = Diaspora::Parser.parse_or_find_person_from_xml( xml ).save if object.person.nil?
self.visible_people = self.visible_people | [object.person]
self.save
@@ -267,12 +267,12 @@ else
Rails.logger.debug("Saving object: #{object}")
object.user_refs += 1
object.save
self.raw_visible_posts << object
self.save
aspects = self.aspects_with_person(object.person)
aspects.each{ |aspect|
aspects.each{ |aspect|
aspect.posts << object
aspect.save
object.socket_to_uid(id, :aspect_ids => [aspect.id]) if (object.respond_to?(:socket_to_uid) && !self.owns?(object))
@@ -293,11 +293,11 @@ else
aspect(:name => "Family")
aspect(:name => "Work")
end
def self.create(opts ={})
puts opts.inspect
end
def self.create(opts ={})
puts opts.inspect
end
def terse_url
terse = self.url.gsub(/(https?:|www\.)\/\//, '')
terse = terse.chop! if terse[-1, 1] == '/'
@@ -309,7 +309,7 @@ else
end
def downcase_username
username.downcase!
username.downcase! if username
end

6
app/views/devise/shared/_links.haml
View File

@@ -1,9 +1,9 @@
- if controller_name != 'sessions'
= link_to "Sign in", new_session_path(resource_name)
%br/
/- if devise_mapping.registerable? && controller_name != 'registrations'
/= link_to "Sign up", new_registration_path(resource_name)
/%br/
- if devise_mapping.registerable? && controller_name != 'registrations'
= link_to "Sign up", new_registration_path(resource_name)
%br/
- if devise_mapping.recoverable? && controller_name != 'passwords'
= link_to "Forgot your password?", new_password_path(resource_name)
%br/

2
config/application.rb
View File

@@ -23,7 +23,7 @@ module Diaspora
# Add additional load paths for your own custom dirs
#config.autoload_paths += %W(#{config.root}/lib)
config.autoload_paths += %W(#{config.root}/lib)
# Only load the plugins named here, in the order given (default is alphabetical).
# :all can be used as a placeholder for all plugins not explicitly named
# config.plugins = [ :exception_notification, :ssl_requirement, :all ]

26
config/deploy.rb
View File

@@ -14,7 +14,7 @@ set :deploy_to, all['deploy_to']
#set :current_dir, ""
# Source code
set :scm, :git
set :user, all['user']
set :user, all['user']
#set :user, ARGV[0]
set :password, all['password'] if all['password']
set :scm_verbose, true
@@ -42,19 +42,19 @@ namespace :deploy do
task :symlink_images do
run "mkdir -p #{shared_path}/uploads"
run "ln -s -f #{shared_path}/uploads #{current_path}/public/uploads"
run "ln -s -f #{shared_path}/uploads #{current_path}/public/uploads"
end
task :symlink_bundle do
run "mkdir -p #{shared_path}/bundle"
run "ln -s -f #{shared_path}/bundle #{current_path}/vendor/bundle"
run "ln -s -f #{shared_path}/bundle #{current_path}/vendor/bundle"
end
task :start do
start_mongo
start_thin
end
end
task :start_mongo do
run("mkdir -p -v #{current_path}/log/db/ ")
run("mkdir -p -v #{shared_path}/db/")
@@ -77,34 +77,34 @@ namespace :deploy do
end
task :stop_thin do
run("killall -s 2 ruby || true")
run("killall -s 2 ruby || true")
#run("cd #{current_path} && bundle exec thin stop -C config/thin.yml || true")
end
task :restart, :roles => :app, :except => { :no_release => true } do
stop
stop
start
end
task :bundle_gems do
run "cd #{current_path} && bundle install"
end
task :reinstall_old_bundler do
#run ("rm #{current_path}/Gemfile.lock || true")
run 'gem list | cut -d" " -f1 | xargs gem uninstall -aIx || true '
run "gem install bundler -v 0.9.26 || true"
end
task :update_bundler do
run 'gem install bundler'
end
task :migrate do
end
end
namespace :cloud do
task :reboot do
run('reboot')

2
config/environments/production.rb
View File

@@ -16,6 +16,8 @@ Diaspora::Application.configure do
# Specifies the header that your server uses for sending files
#config.action_dispatch.x_sendfile_header = "X-Sendfile"
config.active_support.deprecation = :notify
# For nginx:
config.action_dispatch.x_sendfile_header = 'X-Accel-Redirect'

4
config/environments/test.rb
View File

@@ -31,7 +31,7 @@ Diaspora::Application.configure do
config.action_mailer.delivery_method = :test
config.active_support.deprecation = :stderr
config.threadsafe!
# Use SQL instead of Active Record's schema dumper when creating the test database.
# This is necessary if your schema can't be completely dumped by the schema dumper,
@@ -46,5 +46,5 @@ begin
rescue LoadError => ignore_if_database_cleaner_not_present
puts "Error on cleaner"
end
end

7
config/initializers/_mongo.rb
View File

@@ -2,8 +2,11 @@
# licensed under the Affero General Public License version 3. See
# the COPYRIGHT file.
MongoMapper.connection = Mongo::Connection.new('localhost', 27017)
if ENV['MONGOHQ_URL']
MongoMapper.config = {RAILS_ENV => {'uri' => ENV['MONGOHQ_URL']}}
else
MongoMapper.connection = Mongo::Connection.new('localhost', 27017)
end
MongoMapper.database = "diaspora-#{Rails.env}"

8
config/initializers/devise.rb
View File

@@ -48,10 +48,10 @@ Devise.setup do |config|
# ==> Configuration for :confirmable
# The time you want to give your user to confirm his account. During this time
# he will be able to access your application without confirming. Default is nil.
# When confirm_within is zero, the user won't be able to sign in without confirming.
# You can use this to let your user access some features of your application
# without confirming the account, but blocking it after a certain period
# (ie 2 days).
# When confirm_within is zero, the user won't be able to sign in without confirming.
# You can use this to let your user access some features of your application
# without confirming the account, but blocking it after a certain period
# (ie 2 days).
# config.confirm_within = 2.days
# ==> Configuration for :rememberable

2
config/initializers/inflections.rb
View File

@@ -5,7 +5,7 @@
# Be sure to restart your server when you modify this file.
# Add new inflection rules using the following format
# Add new inflection rules using the following format
# (all these examples are active by default):
ActiveSupport::Inflector.inflections do |inflect|
# inflect.plural /^(ox)$/i, '\1en'

2
config/initializers/secret_token.rb
View File

@@ -7,6 +7,6 @@
# Your secret key for verifying the integrity of signed cookies.
# If you change this key, all old signed cookies will become invalid!
# Make sure the secret is at least 30 characters and all random,
# Make sure the secret is at least 30 characters and all random,
# no regular words or you'll be exposed to dictionary attacks.
Rails.application.config.secret_token = 'ea08916110cae7f10fe9e1f7c7cb8c1fee13c3c3bee35180ac3061c370bd9ad985f28fcf2eb5f5684d0d618855efdeb862918628e994ed3e7fc806777428ef40'

8
config/initializers/socket.rb
View File

@@ -8,15 +8,15 @@ require 'eventmachine'
require "lib/diaspora/websocket"
EM.next_tick {
Diaspora::WebSocket.initialize_channels
EventMachine::WebSocket.start(
:host => "0.0.0.0",
:host => "0.0.0.0",
:port => APP_CONFIG[:socket_port],
:debug =>APP_CONFIG[:socket_debug]) do |ws|
ws.onopen {
sid = Diaspora::WebSocket.subscribe(ws.request['Path'].gsub('/',''), ws)
ws.onmessage { |msg| SocketsController.new.incoming(msg) }
ws.onclose { Diaspora::WebSocket.unsubscribe(ws.request['Path'].gsub('/',''), sid) }

6
config/routes.rb
View File

@@ -29,15 +29,15 @@ Diaspora::Application.routes.draw do
devise_for :users, :controllers => {:registrations => "registrations"}
match 'login', :to => 'devise/sessions#new', :as => "new_user_session"
match 'logout', :to => 'devise/sessions#destroy', :as => "destroy_user_session"
match 'get_to_the_choppa', :to => 'registrations#new', :as => "new_user_registration"
match 'signup', :to => 'registrations#new', :as => "new_user_registration"
#public routes
#
match 'webfinger', :to => 'publics#webfinger'
match 'hcard/users/:id', :to => 'publics#hcard'
match '.well-known/host-meta',:to => 'publics#host_meta'
match 'receive/users/:id', :to => 'publics#receive'
match '.well-known/host-meta',:to => 'publics#host_meta'
match 'receive/users/:id', :to => 'publics#receive'
match 'log', :to => "dev_utilities#log"
#root

16
config/sprinkle/packages/database.rb
View File

@@ -6,23 +6,23 @@
#package :mongo, :provides => :database do
# description 'Mongodb'
# version '1.4.3'
# source "http://downloads.mongodb.org/src/mongodb-src-r#{version}.tar.gz"
# version '1.4.3'
# source "http://downloads.mongodb.org/src/mongodb-src-r#{version}.tar.gz"
#end
package :mongodb, :provides => :database do
description 'Mongodb debian package.'
version '1.4.3'
version '1.4.3'
binary "http://downloads.mongodb.org/linux/mongodb-linux-x86_64-static-legacy-#{version}.tgz" do
post :install, "ln -s -f /usr/local/bin/mongodb-linux-x86_64-static-#{version}/bin/mongod /usr/bin/mongod"
end
post :install, "ln -s -f /usr/local/bin/mongodb-linux-x86_64-static-#{version}/bin/mongod /usr/bin/mongod"
end
end
package :mongo_driver do
description 'Ruby mongo database driver'
gem 'mongo'
gem 'bson'
gem 'bson_ext'
requires :rubygems
gem 'bson'
gem 'bson_ext'
requires :rubygems
end

10
config/sprinkle/packages/essential.rb
View File

@@ -20,16 +20,16 @@ package :tools do
end
package :vim do
apt 'vim' do
apt 'vim' do
post :install, run("rm -r -f /root/vim-files")
end
apt 'vim' do
apt 'vim' do
post :install, run("git clone git://github.com/zhitomirskiyi/vim-files.git /root/vim-files")
end
apt 'vim' do
post :install, run("ln -s -f /root/vim-files/vimrc /root/.vimrc")
apt 'vim' do
post :install, run("ln -s -f /root/vim-files/vimrc /root/.vimrc")
end
apt 'vim' do
apt 'vim' do
post :install, run("ln -s -f -T /root/vim-files /root/.vim")
end
end

20
config/sprinkle/packages/ruby.rb
View File

@@ -25,25 +25,25 @@ package :rubygems do
source "http://production.cf.rubygems.org/rubygems/rubygems-#{version}.tgz" do
custom_install 'ruby setup.rb'
end
run( "PATH=$PATH:/var/lib/gems/1.8/bin")
run( "export PATH")
run( "PATH=$PATH:/var/lib/gems/1.8/bin")
run( "export PATH")
requires :ruby
end
package :bundler do
description 'bundler'
version '0.9.26'
gem 'bundler'
requires :rubygems
description 'bundler'
version '0.9.26'
gem 'bundler'
requires :rubygems
end
package :diaspora_dependencies do
description 'random dependencies'
apt %w(libxslt1.1 libxslt1-dev libxml2 libgpgme11-dev imagemagick libmagick9-dev)
description 'random dependencies'
apt %w(libxslt1.1 libxslt1-dev libxml2 libgpgme11-dev imagemagick libmagick9-dev)
end
#package :diaspora do
# description 'Diaspora'
# description 'Diaspora'
=begin
package :rails do
description 'Ruby on Rails'

8
config/sprinkle/packages/scm.rb
View File

@@ -6,25 +6,25 @@
package :git, :provides => :scm do
description 'Git Distributed Version Control'
apt %w( git-core )
apt %w( git-core )
requires :pubkey
end
package :privkey do
description 'checkout from github with it'
transfer "#{File.dirname(__FILE__)}/../deploy_key/id_rsa", '/root/.ssh/id_rsa', :render => false do
transfer "#{File.dirname(__FILE__)}/../deploy_key/id_rsa", '/root/.ssh/id_rsa', :render => false do
pre :install, "rm -rf /root/.ssh/ && mkdir -p /root/.ssh/"
post :install, "chmod go-rwx /root/.ssh/id_rsa"
end
end
package :pubkey do
transfer "#{File.dirname(__FILE__)}/../deploy_key/id_rsa.pub", '/root/.ssh/id_rsa.pub', :render => false
transfer "#{File.dirname(__FILE__)}/../deploy_key/id_rsa.pub", '/root/.ssh/id_rsa.pub', :render => false
requires :privkey
requires :known_hosts
end
package :known_hosts do
transfer "#{File.dirname(__FILE__)}/../deploy_key/known_hosts", '/root/.ssh/known_hosts', :render => false
transfer "#{File.dirname(__FILE__)}/../deploy_key/known_hosts", '/root/.ssh/known_hosts', :render => false
end

8
config/sprinkle/provision.rb
View File

@@ -17,7 +17,7 @@ policy :diaspora, :roles => [:pivots] do
# requires :clean_dreamhost
requires :tools
requires :rubygems
requires :bundler
requires :bundler
requires :diaspora_dependencies
requires :database
requires :webserver
@@ -40,9 +40,9 @@ deployment do
archives '/usr/local/sources'
builds '/usr/local/build'
end
binary do
prefix '/usr/local/bin'
binary do
prefix '/usr/local/bin'
archives '/usr/local/sources'
end
end
end

2
db/schema.rb
View File

@@ -4,7 +4,7 @@
# This file is auto-generated from the current state of the database. Instead of editing this file,
# This file is auto-generated from the current state of the database. Instead of editing this file,
# please use the migrations feature of Active Record to incrementally modify your database, and
# then regenerate this schema definition.
#

4
db/seeds/backer.rb
View File

@@ -15,7 +15,7 @@
require 'config/environment'
def create
config = YAML.load_file(File.dirname(__FILE__) + '/../../config/deploy_config.yml')
config = YAML.load_file(File.dirname(__FILE__) + '/../../config/deploy_config.yml')
backer_info = config['servers']['backer']
backer_number = YAML.load_file(Rails.root.join('config','backer_number.yml'))[:seed_number].to_i
@@ -28,7 +28,7 @@ def create
:url=> "http://#{username}.joindiaspora.com/",
:person => Person.new(
:diaspora_handle => "#{username}@#{username}.joindiaspora.com",
:profile => Profile.new( :first_name => backer_info[backer_number]['given_name'], :last_name => backer_info[backer_number]['family_name'],
:profile => Profile.new( :first_name => backer_info[backer_number]['given_name'], :last_name => backer_info[backer_number]['family_name'],
:image_url => "http://#{username}.joindiaspora.com/images/user/#{username}.jpg"),
:url=> "http://#{username}.joindiaspora.com/")
)

2
db/seeds/dev.rb
View File

@@ -28,7 +28,7 @@ user2 = User.instantiate!( :email => "korth@tom.joindiaspora.com",
:password => "evankorth",
:password_confirmation => "evankorth",
:person => Person.new( :diaspora_handle => "korth@tom.joindiaspora.com",
:url => url,
:url => url,
:profile => Profile.new( :first_name => "Evan",
:last_name => "Korth")))

2
db/seeds/tom.rb
View File

@@ -28,7 +28,7 @@ user2 = User.instantiate!( :email => "korth@tom.joindiaspora.com",
:username => "korth",
:url => remote_url,
:person => { :diaspora_handle => "korth@tom.joindiaspora.com",
:url => remote_url,
:url => remote_url,
:profile => { :first_name => "Evan",
:last_name => "Korth",
:image_url => "http://tom.joindiaspora.com/images/user/korth.jpg"}})

2
lib/chrome_frame.rb
View File

@@ -12,7 +12,7 @@ module Rack
@options = options
end
def call(env)
def call(env)
if env['HTTP_USER_AGENT'] =~ /MSIE/
if env['HTTP_USER_AGENT'] =~ /chromeframe/

16
lib/diaspora/user/friending.rb
View File

@@ -20,28 +20,28 @@ module Diaspora
aspect.requests << request
aspect.save
salmon request, :to => desired_friend
end
request
end
def accept_friend_request(friend_request_id, aspect_id)
request = Request.find_by_id(friend_request_id)
pending_requests.delete(request)
activate_friend(request.person, aspect_by_id(aspect_id))
request.reverse_for(self)
request
end
def dispatch_friend_acceptance(request, requester)
salmon request, :to => requester
request.destroy unless request.callback_url.include? url
end
end
def accept_and_respond(friend_request_id, aspect_id)
requester = Request.find_by_id(friend_request_id).person
reversed_request = accept_friend_request(friend_request_id, aspect_id)
@@ -61,7 +61,7 @@ module Diaspora
def receive_friend_request(friend_request)
Rails.logger.info("receiving friend request #{friend_request.to_json}")
if request_from_me?(friend_request)
aspect = self.aspect_by_id(friend_request.aspect_id)
activate_friend(friend_request.person, aspect)
@@ -83,7 +83,7 @@ module Diaspora
salmon( retraction, :to => bad_friend)
remove_friend(bad_friend)
end
def remove_friend(bad_friend)
raise "Friend not deleted" unless self.friend_ids.delete( bad_friend.id )
aspects.each{|g| g.person_ids.delete( bad_friend.id )}

8
lib/diaspora/websocket.rb
View File

@@ -7,14 +7,14 @@
module Diaspora
module WebSocket
def self.initialize_channels
@channels = {}
@channels = {}
end
def self.push_to_user(uid, data)
Rails.logger.debug "Websocketing to #{uid}"
@channels[uid.to_s][0].push(data) if @channels[uid.to_s]
end
def self.subscribe(uid, ws)
Rails.logger.debug "Subscribing socket to #{uid}"
self.ensure_channel(uid)
@@ -40,7 +40,7 @@ module Diaspora
def socket_to_uid(id, opts={})
SocketsController.new.outgoing(id, self, opts)
end
def unsocket_from_uid(id, opts={})
SocketsController.new.outgoing(id, Retraction.for(self), opts)
end

6
lib/encryptable.rb
View File

@@ -10,9 +10,9 @@
end
def signature_valid?
verify_signature(creator_signature, person)
verify_signature(creator_signature, person)
end
def verify_signature(signature, person)
if person.nil?
Rails.logger.info("Verifying sig on #{signable_string} but no person is here")
@@ -29,7 +29,7 @@
Rails.logger.debug("Validity: #{validity}")
validity
end
def sign_with_key(key)
Rails.logger.debug("Signing #{signable_string}")
Base64.encode64(key.sign "SHA", signable_string)

2
lib/encryptor.rb
View File

@@ -11,7 +11,7 @@ module Encryptor
ciphertext = aes_encrypt(cleartext, aes_key)
encrypted_key = encrypt_aes_key aes_key
cipher_hash = {:aes_key => encrypted_key, :ciphertext => ciphertext}
Base64.encode64( cipher_hash.to_json )
Base64.encode64( cipher_hash.to_json )
end
def gen_aes_key

10
lib/message_handler.rb
View File

@@ -4,12 +4,12 @@
class MessageHandler
class MessageHandler
NUM_TRIES = 3
TIMEOUT = 5 #seconds
def initialize
@queue = EM::Queue.new
end
@@ -41,12 +41,12 @@ class MessageHandler
Rails.logger.info("Failure from #{query.destination}, retrying...")
query.try_count +=1
@queue.push query unless query.try_count >= NUM_TRIES
@queue.push query unless query.try_count >= NUM_TRIES
process
}
} unless @queue.size == 0
end
def send_to_seed(message, http_response)
#DO SOMETHING!
end

12
lib/salmon/salmon.rb
View File

@@ -66,7 +66,7 @@ module Salmon
uri = doc.search('uri').text
slap.author_email = uri.split("acct:").last
slap
slap
end
def self.create(user, activity)
@@ -98,10 +98,10 @@ ENTRY
end
end
# Decode URL-safe-Base64. This implements
# Decode URL-safe-Base64. This implements
def self.decode64url(str)
# remove whitespace
sans_whitespace = str.gsub(/\s/, '')
@@ -115,7 +115,7 @@ ENTRY
end
# def verified?
#
#
# end
# Check whether this envelope's signature can be verified with the
@@ -128,7 +128,7 @@ ENTRY
signature = Base64.urlsafe_decode64(self.magic_sig.sig)
signed_data = self.magic_sig.signable_string# Base64.urlsafe_decode64(self.magic_sig.signable_string)
public_key.verify(OpenSSL::Digest::SHA256.new, signature, signed_data )
end
@@ -197,7 +197,7 @@ ENTRY
env.sig = Base64.urlsafe_encode64(
user.encryption_key.sign OpenSSL::Digest::SHA256.new, env.signable_string )
env
end

10
lib/tasks/whitespace.rake Normal file
View File

@@ -0,0 +1,10 @@
namespace :whitespace do
desc 'Removes trailing whitespace'
task :cleanup do
sh %{find . -name '*.rb' -exec sed -i '' 's/ *$//g' {} \\;}
end
task :retab do
sh %{find . -name '*.rb' -exec sed -i '' 's/\t/ /g' {} \\;}
end
end

48
script/bootstrap-fedora-diaspora.sh Executable file
View File

@@ -0,0 +1,48 @@
#!/bin/bash
export DIASPORADIR=`pwd`
echo "####"
echo "Installing build deps ..."
echo "####"
sleep 3
su -c "yum install git bison svn autoconf sqlite-devel gcc-c++ patch readline readline-devel zlib zlib-devel libyaml-devel libffi-devel ImageMagick git rubygems libxslt libxslt-devel libxml2 libxml2-devel openssl-devel"
echo "####"
echo "Installing RVM ..."
echo "####"
sleep 3
mkdir -p ~/.rvm/src/ && cd ~/.rvm/src && rm -rf ./rvm/ && git clone --depth 1 git://github.com/wayneeseguin/rvm.git && cd rvm && ./install
echo "####"
echo "Installing RVM into bashrc and sourcing bash ..."
echo "####"
sleep 3
if [[ `grep -l "rvm/scripts/rvm" $HOME/.bashrc | wc -l` -eq 0 ]]; then
echo 'if [[ -s "$HOME/.rvm/scripts/rvm" ]] ; then source "$HOME/.rvm/scripts/rvm" ; fi' >> $HOME/.bashrc
fi
source $HOME/.bashrc
echo "####"
echo "Installing ruby (will take forever) ..."
echo "####"
sleep 3
rvm install ruby-1.8.7-p302
rvm --default ruby-1.8.7
echo "####"
echo "Installing bundler ..."
echo "####"
sleep 3
gem install bundler
echo "####"
echo "Installing deps with bundle ..."
echo "####"
sleep 3
pushd $DIASPORADIR && bundle install && popd

6
spec/controllers/aspects_controller_spec.rb
View File

@@ -5,18 +5,18 @@
require File.dirname(__FILE__) + '/../spec_helper'
include ApplicationHelper
include ApplicationHelper
describe AspectsController do
render_views
before do
@user = Factory.create(:user)
@user.aspect(:name => "lame-os")
@person = Factory.create(:person)
sign_in :user, @user
sign_in :user, @user
end
it "on index sets a variable containing all a user's friends when a user is signed in" do
sign_in :user, @user
sign_in :user, @user
Factory.create :person
get :index
assigns[:friends].should == @user.friends

6
spec/controllers/people_controller_spec.rb
View File

@@ -5,13 +5,13 @@
require File.dirname(__FILE__) + '/../spec_helper'
describe PeopleController do
render_views
before do
@user = Factory.create(:user)
sign_in :user, @user
sign_in :user, @user
@user.aspect(:name => "lame-os")
end
@@ -20,7 +20,7 @@ describe PeopleController do
Person.should_receive(:search)
get :index, :q => "Eu"
end
it 'should go to the current_user show page' do
get :show, :id => @user.person.id
end

16
spec/controllers/publics_controller_spec.rb
View File

@@ -5,13 +5,13 @@
require File.dirname(__FILE__) + '/../spec_helper'
describe PublicsController do
render_views
before do
@user = Factory.create(:user)
sign_in :user, @user
sign_in :user, @user
end
describe 'receive endpoint' do
@@ -19,7 +19,7 @@ describe PublicsController do
post :receive, :id =>@user.person.id
response.code.should == '200'
end
it 'should accept a post from another node and save the information' do
user2 = Factory.create(:user)
message = user2.build_post(:status_message, :message => "hi")
@@ -46,20 +46,20 @@ describe PublicsController do
req = @user2.send_friend_request_to(@user.person, aspect)
@xml = @user.person.encrypt(@user2.salmon(req, :to => @user.person).to_xml)
req.delete
@user2.reload
@user2.pending_requests.count.should be 1
end
it 'should add the pending request to the right user if the target person exists locally' do
it 'should add the pending request to the right user if the target person exists locally' do
@user2.delete
post :receive, :id => @user.person.id, :xml => @xml
assigns(:user).should eq(@user)
end
it 'should add the pending request to the right user if the target person does not exist locally' do
it 'should add the pending request to the right user if the target person does not exist locally' do
Person.should_receive(:by_webfinger).with(@user2.person.diaspora_handle).and_return(@user2.person)
@user2.person.delete
@user2.delete

6
spec/controllers/requests_controller_spec.rb
View File

@@ -5,11 +5,11 @@
require File.dirname(__FILE__) + '/../spec_helper'
include ApplicationHelper
include RequestsHelper
include ApplicationHelper
include RequestsHelper
describe RequestsController do
render_views
before do
before do
@user = Factory.create :user
stub_success("tom@tom.joindiaspora.com")

6
spec/controllers/sockets_controller_spec.rb
View File

@@ -13,7 +13,7 @@ class SocketsController
end
describe SocketsController do
render_views
render_views
before do
@user = Factory.create(:user)
@controller = SocketsController.new
@@ -23,14 +23,14 @@ describe SocketsController do
Diaspora::WebSocket.initialize_channels
@controller.class.should == SocketsController
end
describe 'actionhash' do
before do
@aspect = @user.aspect :name => "losers"
@message = @user.post :status_message, :message => "post through user for victory", :to => @aspect.id
@fixture_name = File.dirname(__FILE__) + '/../fixtures/button.png'
end
it 'should actionhash photos' do
pending "Figure out how to make the photo posting api work in specs, it needs a file type"
@album = @user.post(:album, :name => "Loser faces", :to => @aspect.id)

2
spec/factories.rb
View File

@@ -34,7 +34,7 @@ Factory.define :user do |u|
u.sequence(:email) {|n| "bob#{n}@pivotallabs.com"}
u.password "bluepin7"
u.password_confirmation "bluepin7"
u.person { |a| Factory.create(:person_with_user, :owner_id => a._id)}
u.person { |a| Factory.create(:person_with_user, :owner_id => a._id)}
end
Factory.define :status_message do |m|

2
spec/helpers/application_helper_spec.rb
View File

@@ -6,7 +6,7 @@
require File.dirname(__FILE__) + '/../spec_helper'
include ApplicationHelper
include ApplicationHelper
describe ApplicationHelper do
before do
@user = Factory.create(:user)

2
spec/helpers/publics_helper_spec.rb
View File

@@ -6,7 +6,7 @@
require File.dirname(__FILE__) + '/../spec_helper'
include PublicsHelper
include PublicsHelper
describe PublicsHelper do
before do
@user = Factory.create(:user)

4
spec/helpers/requests_helper_spec.rb
View File

@@ -10,8 +10,8 @@ include RequestsHelper
describe RequestsHelper do
before do
before do
stub_success("tom@tom.joindiaspora.com")
stub_success("evan@status.net")
@tom = Redfinger.finger('tom@tom.joindiaspora.com')

64
spec/lib/diaspora_parser_spec.rb
View File

@@ -6,7 +6,7 @@
require File.dirname(__FILE__) + '/../spec_helper'
include ApplicationHelper
include ApplicationHelper
include Diaspora::Parser
@@ -19,40 +19,40 @@ describe Diaspora::Parser do
@user2 = Factory.create(:user)
end
describe "parsing compliant XML object" do
describe "parsing compliant XML object" do
before do
@xml = Factory.build(:status_message).to_diaspora_xml
@xml = Factory.build(:status_message).to_diaspora_xml
end
it 'should be able to correctly handle comments with person in db' do
person = Factory.create(:person, :diaspora_handle => "test@testing.com")
post = Factory.create(:status_message, :person => @user.person)
comment = Factory.build(:comment, :post => post, :person => person, :text => "Freedom!")
xml = comment.to_diaspora_xml
xml = comment.to_diaspora_xml
comment = Diaspora::Parser.from_xml(xml)
comment.text.should == "Freedom!"
comment.person.should == person
comment.post.should == post
end
it 'should be able to correctly handle person on a comment with person not in db' do
commenter = Factory.create(:user)
commenter_aspect = commenter.aspect :name => "bruisers"
friend_users(@user, @aspect, commenter, commenter_aspect)
post = @user.post :status_message, :message => "hello", :to => @aspect.id
comment = commenter.comment "Fool!", :on => post
xml = comment.to_diaspora_xml
xml = comment.to_diaspora_xml
commenter.delete
commenter.person.delete
parsed_person = Diaspora::Parser::parse_or_find_person_from_xml(xml)
parsed_person.save.should be true
parsed_person.diaspora_handle.should == commenter.person.diaspora_handle
parsed_person.profile.should_not be_nil
end
it 'should marshal retractions' do
person = Factory.create(:person)
message = Factory.create(:status_message, :person => person)
@@ -63,14 +63,14 @@ describe Diaspora::Parser do
@user.receive xml
StatusMessage.count.should == 0
end
it "should create a new person upon getting a person request" do
person_count = Person.all.count
request = Request.instantiate(:to =>"http://www.google.com/", :from => @person)
original_person_id = @person.id
xml = request.to_diaspora_xml
xml = request.to_diaspora_xml
@person.destroy
Person.all.count.should == person_count -1
@user.receive xml
@@ -80,19 +80,19 @@ describe Diaspora::Parser do
url = "http://" + request.callback_url.split("/")[2] + "/"
Person.where(:url => url).first.id.should == original_person_id
end
it "should not create a new person if the person is already here" do
person_count = Person.all.count
request = Request.instantiate(:to =>"http://www.google.com/", :from => @user2.person)
original_person_id = @user2.person.id
xml = request.to_diaspora_xml
Person.all.count.should be person_count
@user.receive xml
Person.all.count.should be person_count
@user2.reload
@user2.person.reload
@user2.person.serialized_key.include?("PRIVATE").should be true
@@ -101,12 +101,12 @@ describe Diaspora::Parser do
Person.where(:url => url).first.id.should == original_person_id
end
it "should activate the Person if I initiated a request to that url" do
it "should activate the Person if I initiated a request to that url" do
request = @user.send_friend_request_to( @user2.person, @aspect)
request.reverse_for @user2
request.reverse_for @user2
xml = request.to_diaspora_xml
xml = request.to_diaspora_xml
@user2.person.destroy
@user2.destroy
@@ -114,7 +114,7 @@ describe Diaspora::Parser do
@user.receive xml
new_person = Person.first(:url => @user2.person.url)
new_person.nil?.should be false
@user.reload
@aspect.reload
@aspect.people.include?(new_person).should be true
@@ -125,16 +125,16 @@ describe Diaspora::Parser do
it 'should process retraction for a person' do
person_count = Person.all.count
request = @user.send_friend_request_to( @user2.person, @aspect)
request.reverse_for @user2
xml = request.to_diaspora_xml
request.reverse_for @user2
xml = request.to_diaspora_xml
retraction = Retraction.for(@user2)
retraction_xml = retraction.to_diaspora_xml
@user2.person.destroy
@user2.destroy
@user.receive xml
@aspect.reload
aspect_people_count = @aspect.people.size
#They are now friends
@@ -146,7 +146,7 @@ describe Diaspora::Parser do
@aspect.reload
@aspect.people.size.should == aspect_people_count -1
end
it 'should marshal a profile for a person' do
#Create person
person = Factory.create(:person)
@@ -160,20 +160,20 @@ describe Diaspora::Parser do
#Build xml for profile, clear profile
xml = person.profile.to_diaspora_xml
reloaded_person = Person.first(:id => id)
reloaded_person = Person.first(:id => id)
reloaded_person.profile = nil
reloaded_person.save(:validate => false)
#Make sure profile is cleared
Person.first(:id => id).profile.should be nil
Person.first(:id => id).profile.should be nil
old_profile.first_name.should == 'bob'
#Marshal profile
@user.receive xml
#Check that marshaled profile is the same as old profile
person = Person.first(:id => person.id)
person.profile.should_not be nil
person.profile.should_not be nil
person.profile.first_name.should == old_profile.first_name
person.profile.last_name.should == old_profile.last_name
person.profile.image_url.should == old_profile.image_url

30
spec/lib/message_handler_spec.rb
View File

@@ -9,13 +9,13 @@ require File.dirname(__FILE__) + '/../spec_helper'
describe MessageHandler do
before do
@handler = MessageHandler.new
@message_body = "I want to pump you up"
@message_body = "I want to pump you up"
@message_urls = ["http://www.google.com/", "http://yahoo.com/", "http://foo.com/"]
end
describe 'GET messages' do
describe 'creating a GET query' do
describe 'creating a GET query' do
it 'should be able to add a GET query to the queue with required destinations' do
EventMachine.run{
@handler.add_get_request(@message_urls)
@@ -31,8 +31,8 @@ describe MessageHandler do
request = FakeHttpRequest.new(:success)
request.should_receive(:get).and_return(request)
EventMachine::HttpRequest.stub!(:new).and_return(request)
EventMachine.run {
EventMachine.run {
@handler.add_get_request("http://www.google.com/")
@handler.size.should == 1
@handler.process
@@ -60,14 +60,14 @@ describe MessageHandler do
end
describe 'POST messages' do
it 'should be able to add a post message to the queue' do
EventMachine.run {
@handler.size.should ==0
@handler.add_post_request(@message_urls.first, @message_body)
@handler.size.should == 1
EventMachine.stop
}
end
@@ -86,26 +86,26 @@ describe MessageHandler do
request.should_receive(:post).and_return(request)
EventMachine::HttpRequest.stub!(:new).and_return(request)
EventMachine.run{
@handler.add_post_request(@message_urls.first, @message_body)
@handler.size.should == 1
@handler.process
@handler.size.should == 0
@handler.size.should == 0
EventMachine.stop
EventMachine.stop
}
end
end
describe "Mixed Queries" do
describe "Mixed Queries" do
it 'should process both POST and GET requests in the same queue' do
request = FakeHttpRequest.new(:success)
request.should_receive(:get).exactly(3).times.and_return(request)
request.should_receive(:post).exactly(3).times.and_return(request)
EventMachine::HttpRequest.stub!(:new).and_return(request)
EventMachine.run{
@handler.add_post_request(@message_urls,@message_body)
@handler.size.should == 3
@@ -124,7 +124,7 @@ describe MessageHandler do
request.should_receive(:get).exactly(1).times.and_return(request)
request.should_receive(:post).exactly(1).times.and_return(request)
@handler.should_receive(:send_to_seed).once
EventMachine::HttpRequest.stub!(:new).and_return(request)
EventMachine.run{
@@ -143,7 +143,7 @@ class FakeHttpRequest
def initialize(callback_wanted)
@callback = callback_wanted
end
def response
def response
end
def post; end

8
spec/lib/salmon_salmon_spec.rb
View File

@@ -22,21 +22,21 @@ describe Salmon do
@sent_salmon.magic_sig.sig.should == @parsed_salmon.magic_sig.sig
@sent_salmon.magic_sig.signable_string.should == @parsed_salmon.magic_sig.signable_string
@parsed_salmon.verified_for_key?(OpenSSL::PKey::RSA.new(@user.exported_key)).should be true
@sent_salmon.verified_for_key?(OpenSSL::PKey::RSA.new(@user.exported_key)).should be true
end
it 'should return the data so it can be "received"' do
xml = @post.to_diaspora_xml
@parsed_salmon.data.should == xml
end
it 'should parse out the authors diaspora_handle' do
@parsed_salmon.author_email.should == @user.person.diaspora_handle
@parsed_salmon.author_email.should == @user.person.diaspora_handle
end

12
spec/misc_spec.rb
View File

@@ -5,7 +5,7 @@
require File.dirname(__FILE__) + '/spec_helper'
describe 'making sure the spec runner works' do
it 'should not delete the database mid-spec' do
@@ -13,11 +13,11 @@ describe 'making sure the spec runner works' do
Factory.create(:user)
User.count.should == 1
end
it 'should make sure the last user no longer exsists' do
User.count.should == 0
end
it 'should factory create a user with a person saved' do
user = Factory.create(:user)
loaded_user = User.first(:id => user.id)
@@ -26,12 +26,12 @@ describe 'making sure the spec runner works' do
describe 'testing a before do block' do
before do
Factory.create(:user)
end
it 'should have cleaned before the before do block runs' do
User.count.should == 1
end
end
end

6
spec/models/album_spec.rb
View File

@@ -52,9 +52,9 @@ describe Album do
photo.image.store! File.open @fixture_name
@photos << photo
end
@album.photos += @photos
@album.photos += @photos
end
it 'should traverse the album correctly' do
#should retrieve the next photo relative to a given photo
@album.next_photo(@photos[1]).id.should == @photos[2].id
@@ -65,7 +65,7 @@ describe Album do
#wrapping
#does next photo of last to first
@album.next_photo(@photos[2]).id.should == @photos[0].id
#does previous photo of first to last
@album.prev_photo(@photos[0]).id.should == @photos[2].id
end

32
spec/models/aspect_spec.rb
View File

@@ -28,19 +28,19 @@ describe Aspect do
it 'should be able to have other users' do
aspect = @user.aspect(:name => 'losers', :people => [@user2.person])
aspect.people.include?(@user.person).should be false
aspect.people.include?(@user2.person).should be true
aspect.people.include?(@user2.person).should be true
aspect.people.size.should == 1
end
end
it 'should be able to have users and people' do
aspect = @user.aspect(:name => 'losers', :people => [@user2.person, @friend_2])
aspect.people.include?(@user.person).should be false
aspect.people.include?(@user2.person).should be true
aspect.people.include?(@friend_2).should be true
aspect.people.include?(@user2.person).should be true
aspect.people.include?(@friend_2).should be true
aspect.people.size.should == 2
end
end
describe 'querying' do
before do
@aspect = @user.aspect(:name => 'losers')
@@ -71,12 +71,12 @@ describe Aspect do
end
describe 'posting' do
it 'should add post to aspect via post method' do
aspect = @user.aspect(:name => 'losers', :people => [@friend])
status_message = @user.post( :status_message, :message => "hey", :to => aspect.id )
aspect.reload
aspect.posts.include?(status_message).should be true
end
@@ -87,24 +87,24 @@ describe Aspect do
friend_users(@user, aspect, @user2, aspect2)
message = @user2.post(:status_message, :message => "Hey Dude", :to => aspect2.id)
@user.receive message.to_diaspora_xml
aspect.reload
aspect.posts.include?(message).should be true
@user.visible_posts(:by_members_of => aspect).include?(message).should be true
end
it 'should retract the post from the aspects as well' do
it 'should retract the post from the aspects as well' do
aspect = @user.aspect(:name => 'losers')
aspect2 = @user2.aspect(:name => 'winners')
friend_users(@user, aspect, @user2, aspect2)
message = @user2.post(:status_message, :message => "Hey Dude", :to => aspect2.id)
@user.receive message.to_diaspora_xml
aspect.reload
aspect.post_ids.include?(message.id).should be true
retraction = @user2.retract(message)
@@ -141,24 +141,24 @@ describe Aspect do
@aspect.people.include?(@friend).should be false
@aspect3.people.include?(@friend).should be false
end
it "should not move a person to a aspect that's not his" do
@user.move_friend(:friend_id => @user2.person.id, :from => @aspect.id, :to => @aspect2.id)
@aspect.reload
@aspect2.reload
@aspect.people.include?(@user2.person).should be true
@aspect.people.include?(@user2.person).should be true
@aspect2.people.include?(@user2.person).should be false
end
it 'should move all the by that user to the new aspect' do
message = @user2.post(:status_message, :message => "Hey Dude", :to => @aspect2.id)
@user.receive message.to_diaspora_xml
@aspect.reload
@aspect.posts.count.should be 1
@aspect3.posts.count.should be 0
@user.reload
@user.move_friend(:friend_id => @user2.person.id, :from => @aspect.id, :to => @aspect3.id)
@aspect.reload

18
spec/models/comments_spec.rb
View File

@@ -27,7 +27,7 @@ describe Comment do
person= Factory.create :person
status = Factory.create(:status_message, :person => person)
@user.comment "sup dog", :on => status
StatusMessage.first.comments.first.text.should == "sup dog"
StatusMessage.first.comments.first.person.should == @user.person
end
@@ -45,7 +45,7 @@ describe Comment do
@person = Factory.create(:person)
@user.activate_friend(@person, Aspect.first(:id => @aspect.id))
@person2 = Factory.create(:person)
@person2 = Factory.create(:person)
@person_status = Factory.build(:status_message, :person => @person)
@user.reload
@@ -54,7 +54,7 @@ describe Comment do
@aspect.reload
@user.reload
end
it 'should have the post in the aspects post list' do
aspect = Aspect.first(:id => @aspect.id)
aspect.people.size.should == 2
@@ -65,32 +65,32 @@ describe Comment do
User::QUEUE.should_receive(:add_post_request)
@user.comment "yo", :on => @person_status
end
it 'should send a user comment on his own post to lots of people' do
User::QUEUE.should_receive(:add_post_request).twice
@user.comment "yo", :on => @user_status
end
it 'should send a comment a person made on your post to all people' do
comment = Comment.new(:person_id => @person.id, :text => "balls", :post => @user_status)
User::QUEUE.should_receive(:add_post_request).twice
@user.receive(comment.to_diaspora_xml)
end
it 'should send a comment a user made on your post to all people' do
comment = @user2.comment( "balls", :on => @user_status)
User::QUEUE.should_receive(:add_post_request).twice
@user.receive(comment.to_diaspora_xml)
end
it 'should not send a comment a person made on his own post to anyone' do
User::QUEUE.should_not_receive(:add_post_request)
comment = Comment.new(:person_id => @person.id, :text => "balls", :post => @person_status)
@user.receive(comment.to_diaspora_xml)
end
it 'should not send a comment a person made on a person post to anyone' do
User::QUEUE.should_not_receive(:add_post_request)
comment = Comment.new(:person_id => @person2.id, :text => "balls", :post => @person_status)

30
spec/models/person_spec.rb
View File

@@ -21,7 +21,7 @@ describe Person do
end
describe 'xml' do
before do
before do
@xml = @person.to_xml.to_s
end
@@ -33,7 +33,7 @@ describe Person do
@xml.include?("first_name").should == true
end
end
it 'should know when a post belongs to it' do
person_message = Factory.create(:status_message, :person => @person)
person_two = Factory.create(:person)
@@ -51,7 +51,7 @@ describe Person do
Factory.create(:status_message, :person => person)
status_message = Factory.create(:status_message, :person => @person)
Factory.create(:comment, :person_id => person.id, :text => "yes i do", :post => status_message)
Factory.create(:comment, :person_id => person.id, :text => "i love you", :post => status_message)
Factory.create(:comment, :person_id => person.id, :text => "hello", :post => status_message)
@@ -68,9 +68,9 @@ describe Person do
it 'should not delete an orphaned friend' do
request = @user.send_friend_request_to @person, @aspect
@user.activate_friend(@person, @aspect)
@user.activate_friend(@person, @aspect)
@user.reload
Person.all.count.should == 3
@user.friends.count.should == 1
@user.unfriend(@person)
@@ -83,12 +83,12 @@ describe Person do
request = @user.send_friend_request_to @person, @aspect
request2 = @user2.send_friend_request_to @person, @aspect2
@user.activate_friend(@person, @aspect)
@user.activate_friend(@person, @aspect)
@user2.activate_friend(@person, @aspect2)
@user.reload
@user2.reload
Person.all.count.should == 3
@user.friends.count.should == 1
@user2.friends.count.should == 1
@@ -128,19 +128,19 @@ describe Person do
end
it 'should yield search results on partial names' do
people = Person.search("Eu")
people = Person.search("Eu")
people.include?(@friend_two).should == true
people.include?(@friend_one).should == false
people.include?(@friend_three).should == false
people.include?(@friend_four).should == false
people = Person.search("Wei")
people = Person.search("Wei")
people.include?(@friend_two).should == true
people.include?(@friend_one).should == false
people.include?(@friend_three).should == false
people.include?(@friend_four).should == false
people = Person.search("Gri")
people = Person.search("Gri")
people.include?(@friend_one).should == true
people.include?(@friend_four).should == true
people.include?(@friend_two).should == false
@@ -159,18 +159,18 @@ describe Person do
tom = Person.by_webfinger('tom@tom.joindiaspora.com')
tom.real_name.include?("Hamiltom").should be true
end
describe 'wall posting' do
describe 'wall posting' do
it 'should be able to post on another persons wall' do
pending
#user2 is in user's aspect, user is in aspect2 on user
friend_users(@user, @aspect, @user2, @aspect2)
@user.person.post_to_wall(:person => @user2.person, :message => "youve got a great smile")
@user.person.wall_posts.count.should == 1
end
end
end
end

20
spec/models/photo_spec.rb
View File

@@ -22,8 +22,8 @@ describe Photo do
it 'should have a constructor' do
pending "Figure out how to make the photo posting api work in specs, it needs a file type"
image = File.open(@fixture_name)
photo = Photo.instantiate(:person => @user.person, :album => @album, :user_file => [image])
image = File.open(@fixture_name)
photo = Photo.instantiate(:person => @user.person, :album => @album, :user_file => [image])
photo.created_at.nil?.should be false
photo.image.read.nil?.should be false
end
@@ -82,13 +82,13 @@ describe Photo do
end
end
describe 'with encryption' do
before do
unstub_mocha_stubs
end
after do
stub_signature_verification
end
@@ -99,15 +99,15 @@ describe Photo do
photo.save.should == true
photo.signature_valid?.should be true
end
end
describe 'remote photos' do
it 'should write the url on serialization' do
it 'should write the url on serialization' do
@photo.image = File.open(@fixture_name)
@photo.image.store!
@photo.save
xml = @photo.to_xml.to_s
xml.include?(@photo.image.url).should be true
@@ -124,7 +124,7 @@ describe Photo do
@photo.save
@photo.reload
url = @photo.url
thumb_url = @photo.url :thumb_medium
@@ -133,7 +133,7 @@ describe Photo do
@photo.destroy
@user.receive xml
new_photo = Photo.first(:id => id)
new_photo.url.nil?.should be false
new_photo.url.include?(url).should be true

2
spec/models/post_spec.rb
View File

@@ -11,7 +11,7 @@ describe Post do
@user = Factory.create(:user, :email => "bob@aol.com")
@user.person.save
end
describe 'xml' do
before do
@message = Factory.create(:status_message, :person => @user.person)

4
spec/models/profile_spec.rb
View File

@@ -18,13 +18,13 @@ describe Profile do
@person.profile.first_name = "Bob"
@person.profile.valid?.should be true
end
it "should include a last name" do
@person.profile = Factory.build(:profile, :last_name => nil)
@person.profile.valid?.should be false
@person.profile.last_name = "Smith"
@person.profile.valid?.should be true
end
end
end

8
spec/models/request_spec.rb
View File

@@ -6,7 +6,7 @@
require File.dirname(__FILE__) + '/../spec_helper'
describe Request do
describe Request do
before do
@user = Factory.create(:user)
@aspect = @user.aspect(:name => "dudes")
@@ -30,14 +30,14 @@ describe Request do
xml.include?(@user.profile.last_name).should be true
end
it 'should allow me to see only friend requests sent to me' do
it 'should allow me to see only friend requests sent to me' do
remote_person = Factory.build(:person, :diaspora_handle => "robert@grimm.com", :url => "http://king.com/")
Request.instantiate(:into => @aspect.id, :from => @user.person, :to => remote_person.receive_url).save
Request.instantiate(:into => @aspect.id, :from => @user.person, :to => remote_person.receive_url).save
Request.instantiate(:into => @aspect.id, :from => @user.person, :to => remote_person.receive_url).save
Request.instantiate(:into => @aspect.id, :from => remote_person, :to => @user.receive_url).save
Request.for_user(@user).all.count.should == 1
end

10
spec/models/status_message_spec.rb
View File

@@ -12,13 +12,13 @@ describe StatusMessage do
@aspect = @user.aspect(:name => "losers")
end
it "should have a message" do
it "should have a message" do
n = Factory.build(:status_message, :message => nil)
n.valid?.should be false
n.message = "wales"
n.valid?.should be true
end
it 'should be postable through the user' do
status = @user.post(:status_message, :message => "Users do things", :to => @aspect.id)
end
@@ -28,9 +28,9 @@ describe StatusMessage do
message = Factory.create(:status_message, :message => "I hate WALRUSES!", :person => @user.person)
message.to_xml.to_s.should include "<message>I hate WALRUSES!</message>"
end
it 'should marshal serialized XML to object' do
xml = "<statusmessage><message>I hate WALRUSES!</message></statusmessage>"
it 'should marshal serialized XML to object' do
xml = "<statusmessage><message>I hate WALRUSES!</message></statusmessage>"
parsed = StatusMessage.from_xml(xml)
parsed.message.should == "I hate WALRUSES!"
parsed.valid?.should be_true

8
spec/models/user/posting_spec.rb
View File

@@ -13,7 +13,7 @@ describe User do
@aspect1 = @user.aspect(:name => 'heroes')
@user2 = Factory.create(:user)
@aspect2 = @user2.aspect(:name => 'losers')
@aspect2 = @user2.aspect(:name => 'losers')
@user3 = Factory.create(:user)
@aspect3 = @user3.aspect(:name => 'heroes')
@@ -27,7 +27,7 @@ describe User do
end
it 'should not be able to post without a aspect' do
proc {@user.post(:status_message, :message => "heyheyhey")}.should raise_error /You must post to someone/
proc {@user.post(:status_message, :message => "heyheyhey")}.should raise_error /You must post to someone/
end
it 'should put the post in the aspect post array' do
@@ -61,7 +61,7 @@ describe User do
@user.should_receive(:salmon).twice
@user.push_to_people(@post, [@user2.person, @user3.person])
end
end
end

34
spec/models/user/receive_spec.rb
View File

@@ -13,7 +13,7 @@ describe User do
@aspect = @user.aspect(:name => 'heroes')
@user2 = Factory.create(:user)
@aspect2 = @user2.aspect(:name => 'losers')
@aspect2 = @user2.aspect(:name => 'losers')
@user3 = Factory.create(:user)
@aspect3 = @user3.aspect(:name => 'heroes')
@@ -30,14 +30,14 @@ describe User do
status_message.destroy
StatusMessage.all.size.should == 0
@user.receive( xml )
Post.all(:person_id => person.id).first.message.should == 'store this!'
StatusMessage.all.size.should == 1
end
it 'should not create new aspects on message receive' do
num_aspects = @user.aspects.size
(0..5).each{ |n|
status_message = @user2.post :status_message, :message => "store this #{n}!", :to => @aspect2.id
xml = status_message.to_diaspora_xml
@@ -51,7 +51,7 @@ describe User do
before do
end
it "should add the post to that user's posts when a user posts it" do
status_message = @user.post :status_message, :message => "hi", :to => @aspect.id
@user.reload
@@ -64,12 +64,12 @@ describe User do
@user.reload
@user.raw_visible_posts.count.should == 1
@user.unfriend(@user2.person)
@user.reload
@user.raw_visible_posts.count.should == 0
Post.count.should be 1
end
@@ -79,14 +79,14 @@ describe User do
@user.reload
@user.raw_visible_posts.count.should == 1
person = @user2.person
@user2.destroy
@user.unfriend(person)
@user.reload
@user.raw_visible_posts.count.should == 0
Post.count.should be 0
end
@@ -96,10 +96,10 @@ describe User do
@user.reload
@user.raw_visible_posts.count.should == 1
status_message.reload
status_message.user_refs.should == 1
@user.unfriend(@user2.person)
status_message.reload
@@ -108,7 +108,7 @@ describe User do
status_message.reload
status_message.user_refs.should == 0
Post.count.should be 1
end
@@ -123,10 +123,10 @@ describe User do
@user3.reload
@user.raw_visible_posts.count.should == 1
status_message.reload
status_message.user_refs.should == 2
@user.unfriend(@user2.person)
status_message.reload
@@ -135,14 +135,14 @@ describe User do
status_message.reload
status_message.user_refs.should == 1
Post.count.should be 1
end
end
describe 'comments' do
it 'should correctly marshal a stranger for the downstream user' do
friend_users(@user, @aspect, @user3, @aspect3)
post = @user.post :status_message, :message => "hello", :to => @aspect.id
@@ -167,7 +167,7 @@ describe User do
new_comment.should_not be_nil
new_comment.person.should_not be_nil
new_comment.person.profile.should_not be_nil
@user3.visible_person_by_id(commenter_id).should_not be_nil
end
end

32
spec/models/user/user_friending_spec.rb
View File

@@ -49,7 +49,7 @@ describe User do
end
it 'should not be able to friend request an existing friend' do friend = Factory.create(:person)
@user.friends << friend
@user.save
@@ -63,7 +63,7 @@ describe User do
before do
@person_one = Factory.create :person
@person_one.save
@user2 = Factory.create :user
@aspect2 = @user2.aspect(:name => "aspect two")
@@ -90,7 +90,7 @@ describe User do
@user2.receive @req_three_xml
@user2.pending_requests.size.should be 1
@user2.accept_friend_request @request_three.id, @aspect2.id
@user2.friends.include?(@user.person).should be true
@user2.friends.include?(@user.person).should be true
Person.all.count.should be 3
end
@@ -99,21 +99,21 @@ describe User do
@user2.receive @req_three_xml
@user2.pending_requests.size.should be 1
@user2.ignore_friend_request @request_three.id
@user2.friends.include?(@user.person).should be false
@user2.friends.include?(@user.person).should be false
Person.all.count.should be 3
end
it 'should both users should befriend the same person' do
@user.receive @req_xml
@user.pending_requests.size.should be 1
@user.accept_friend_request @request.id, @aspect.id
@user.friends.include?(@person_one).should be true
@user.friends.include?(@person_one).should be true
@user2.receive @req_two_xml
@user2.pending_requests.size.should be 1
@user2.accept_friend_request @request_two.id, @aspect2.id
@user2.friends.include?(@person_one).should be true
@user2.friends.include?(@person_one).should be true
Person.all.count.should be 3
end
@@ -122,12 +122,12 @@ describe User do
@user.receive @req_xml
@user.pending_requests.size.should be 1
@user.accept_friend_request @request.id, @aspect.id
@user.friends.include?(@person_one).should be true
@user.friends.include?(@person_one).should be true
@user2.receive @req_two_xml
@user2.pending_requests.size.should be 1
@user2.ignore_friend_request @request_two.id
@user2.friends.include?(@person_one).should be false
@user2.friends.include?(@person_one).should be false
Person.all.count.should be 3
end
@@ -135,12 +135,12 @@ describe User do
@user.receive @req_xml
@user.pending_requests.size.should be 1
@user.ignore_friend_request @user.pending_requests.first.id
@user.friends.include?(@person_one).should be false
@user.friends.include?(@person_one).should be false
@user2.receive @req_two_xml
@user2.pending_requests.size.should be 1
@user2.ignore_friend_request @user2.pending_requests.first.id#@request_two.id
@user2.friends.include?(@person_one).should be false
@user2.friends.include?(@person_one).should be false
Person.all.count.should be 3
end
@@ -158,9 +158,9 @@ describe User do
@request = Request.instantiate(:to => @user.receive_url, :from => @person_one)
@request_two = Request.instantiate(:to => @user.receive_url, :from => @person_two)
end
after do
@user.receive_friend_request @request
@user.receive_friend_request @request
@person_two.destroy
@user.pending_requests.size.should be 1
@@ -188,9 +188,9 @@ describe User do
before do
@user2 = Factory.create :user
@aspect2 = @user2.aspect(:name => "Gross people")
request = @user.send_friend_request_to( @user2, @aspect)
request.reverse_for @user2
request.reverse_for @user2
@user2.activate_friend(@user.person, @aspect2)
@user.receive request.to_diaspora_xml
end
@@ -201,7 +201,7 @@ describe User do
@user.friends.count.should == 1
@user2.friends.count.should == 1
@user2.unfriend @user.person
@user2.friends.count.should be 0

2
spec/models/user/visible_posts_spec.rb
View File

@@ -20,7 +20,7 @@ describe User do
@user3 = Factory.create :user
@user3_aspect = @user3.aspect(:name => 'dudes')
friend_users(@user, @aspect2, @user3, @user3_aspect)
@user4 = Factory.create :user
@user4_aspect = @user4.aspect(:name => 'dudes')
friend_users(@user, @aspect2, @user4, @user4_aspect)

6
spec/models/user_spec.rb
View File

@@ -22,11 +22,11 @@ describe User do
end
describe 'profiles' do
it 'should be able to update their profile and send it to their friends' do
it 'should be able to update their profile and send it to their friends' do
Factory.create(:person)
updated_profile = {:profile => {:first_name => 'bob', :last_name => 'billytown', :image_url => "http://clown.com"}}
@user.update_profile(updated_profile).should == true
@user.profile.image_url.should == "http://clown.com"
end

2
spec/spec_helper.rb
View File

@@ -75,7 +75,7 @@ end
def friend_users(user1, aspect1, user2, aspect2)
request = user1.send_friend_request_to(user2.person, aspect1)
reversed_request = user2.accept_friend_request( request.id, aspect2.id)
reversed_request = user2.accept_friend_request( request.id, aspect2.id)
user1.receive reversed_request.to_diaspora_xml
end

12
spec/user_encryption_spec.rb
View File

@@ -45,24 +45,24 @@ describe 'user encryption' do
it 'should receive and marshal a public key from a request' do
remote_user = Factory.build(:user)
remote_user.encryption_key.nil?.should== false
#should move this to friend request, but i found it here
#should move this to friend request, but i found it here
id = remote_user.person.id
original_key = remote_user.exported_key
request = remote_user.send_friend_request_to(
@user.person, remote_user.aspect(:name => "temp"))
xml = request.to_diaspora_xml
remote_user.person.destroy
remote_user.destroy
person_count = Person.all.count
proc {@user.receive xml}.should_not raise_error /ignature was not valid/
Person.all.count.should == person_count + 1
new_person = Person.first(:id => id)
new_person.exported_key.should == original_key
end
end
end
describe 'encryption' do