RubyOnRails

Ruby on Rails Volltextsuche mit ElasticSearch und Tire

2012-10-09T08:10:48Z

Installation

OS X

Unter OS X kann man sich die aktuelle Version via homebrew [tooltip title=“Help“ content=“Homebrew ist ein OpenSource Paketmanager für OS X“ type=“info“](?)[/tooltip] installieren:

Debian / Ubuntu
Eine Installationsanleitung für Debian basierte Systeme befindet sich direkt auf elasticsearch.org: http://www.elasticsearch.org/tutorials/2010/07/02/setting-up-elasticsearch-on-debian.html

RedHat / CentOS …
Für RedHat basierte Systeme hat Tavisto (https://github.com/tavisto/elasticsearch-rpms) entsprechende SPEC-Files für die ElasticSearch RPM Erstellung bereitgestellt.

andere Systeme
Alternativ kann die aktuelle Version hier heruntergeladen und installiert werden: http://www.elasticsearch.org/download/

Nach der Installation und dem Start des Services sollte der ElasticSearch Server erreichbar sein. Der ElasticSearch Server liefert den Status, seine Versionsnummer und weitere Zusatzinformationen als JSON zurück:

Zustand der ElasticSearch überwachen

Für einen späteren produktiven Einsatz der ElasticSearch sollte das Monitoring nicht außer Acht gelassen werden. Hierbei haben sich verschiedene Monitoring-Tools bewährt:

Elasticsearch-head mobz.github.com/elasticsearch-head
Elasticsearch-head ist eine statische Webseite mit JavaScript. Hilft die Performance der einzelnen Shards [tooltip title=“Help“ content=“engl. für Scherben“ type=“info“](?)[/tooltip] zu überwachen. Man kann sich direkt ähnlich wie bei PHPMyAdmin oder Futon(CouchDB) direkt die Daten anzeigen lassen.
Kibana github.com/rashidkpc/Kibana
Kibana ist eine eigene Rails-Anwendung und sehr benutzerfreundlich. Manuelles Suchen, komplette Visualisierungen und Analysen z.B. auf Basis der Logs können konfiguriert und dargestellt werden.
Bigdesk github.com/lukas-vlcek/bigdesk
Bigdesk eignet sich gut für das Monitoring der Hauptparameter des ElasticSearch Servers (Speicher, CPU, …).

ElasticSearch Funktionsweise / Daten speichern

Angenommen wir möchten eine Suche für einen Blog anlegen. Der Blog besteht aus mehreren Artikeln. Jeder Artikel enthält einen Text, eine Überschrift, ein Datum, sowie einen User. Da ElasticSearch eine RESTful-HTTP Schnittstelle bereitstellt, können wir mit Hilfe von z.B. curl [tooltip title=“Help“ content=“Curl ist ein Kommandozeilen-Programm zum Übertragen von Dateien im Netzwerk“ type=“info“](?)[/tooltip] alle Artikeldatensätze im JSON-Format an die ElasticSearch übergeben. Im nachfolgenden Beispiel übermitteln wir zwei Artikel, samt Inhalt an die ElasticSearch.
[ruby]
curl -XPUT ‚http://localhost:9200/artikel/text/1‘ -d ‚{
"user" : "Alex",
"post_date" : "2012-10-05T14:12:12",
"ueberschrift" : "Alles wird schlechter",
"text" : "Hamburg – Immer mehr Arbeitnehmer in Deutschland haben zwei Jobs…"}‘
curl -XPUT ‚http://localhost:9200/artikel/text/2‘ -d ‚{
"user" : "Alex",
"post_date" : "2012-10-04T14:12:12",
"ueberschrift" : "96 gewinnt",
"text" : "Hannover 96 – Der neue große HSV von 1896 schlägt Levante daheim in Unterzahl 2:1"}‘
[/ruby]

Jeder einzelne Request wird bestätigt:
[ruby]
{"ok":true,"_index":"artikel","_type":"text","_id":"1","_version":1}
[/ruby]

Wir sehen, dass der Index automatisch von der ElasticSearch erstellt wird, falls dieser noch nicht existiert. In unserem Fall heißt der Index „artikel“. Jeder Index besteht aus mehreren sogenannten Shards[tooltip title=“Help“ content=“engl. für Scherbe“ type=“info“](?)[/tooltip]. Diese wiederum werden automatisch über die einzelnen Nodes (Server), falls vorhanden, verteilt. Standardmäßig hat jeder Index fünf primäre Shards (0-4). Die Anzahl der primären Shards können nach Erstellung des Index nicht mehr geändert werden.
Jede Shard kann null oder mehr Replica-Shards haben. Ein Replica-Shard ist eine Kopie einer primären Shard. Die Anzahl der Replica-Shards kann zur Laufzeit dynamisch geändert werden.
Die Hauptaufgabe der Replica-Shards sind das Failover Verhalten zu verbessern, falls die primäre Shard nicht mehr zur Verfügung steht und die Performance der Elasticsearch bei Get- und Search-Requests zu verbessern.

Möchte man andere Parameter bei der Indexerstellung setzen, hilft einem die Reference Guide weiter (elasticsearch.org/guide/reference/api/admin-indices-create-index.html). Die ElasticSearch arbeitet mit Versionierung. D.h. laden wir unseren ersten Artikel erneut, z.B. mit korrigiertem Text hoch, so erhalten wir nachfolgende Artwort:
[ruby]
{"ok":true,"_index":"artikel","_type":"text","_id":"1","_version":2}
[/ruby]
Anders als z.B. bei CouchDB oder anderen NoSQL-Datenbanken hat man bei ElasticSearch keinen Zugriff mehr auf eine ältere Version eines Dokuments.

ElasticSearch gespeicherte Daten ausgeben

Wir können uns, wie bei einer RESTful NoSQL-Datenbank zum Beispiel CouchDB, einen Eintrag zurückgeben lassen:
[ruby]
curl -XGET ‚http://localhost:9200/artikel/text/1‘
{
"_index" : "artikel",
"_type" : "text",
"_id" : "1",
"_version" : 1,
"exists" : true, "_source" : {
"user" : "Alex",
"post_date" : "2012-10-05T14:12:12",
"ueberschrift" : "Alles wird schlechter",
"text" : "Hamburg – Immer mehr Arbeitnehmer in Deutschland haben zwei Jobs…"}
}
[/ruby]

Datensätze suchen

Ausführliche Informationen findet man unter dem Stichwort Query-DSL sowie Search-API der Reference Guide. An dieser Stelle möchte ich lediglich beispielhaft alle Datensätze des Users Alex finden:
[ruby]
curl -XGET ‚http://localhost:9200/artikel/_search?q=user:Alex‘
{
"took" : 1,
"timed_out" : false,
"_shards" : {
"total" : 5,
"successful" : 5,
"failed" : 0
},
"hits" : {
"total" : 2,
"max_score" : 1.0,
"hits" : [ {
"_index" : "artikel",
"_type" : "text",
"_id" : "1",
"_score" : 1.0, "_source" : {
"user" : "Alex",
"post_date" : "2012-10-05T14:12:12",
"ueberschrift" : "Alles wird schlechter",
"text" : "Hamburg – Immer mehr Arbeitnehmer in Deutschland haben zwei Jobs…"}
}, {
"_index" : "artikel",
"_type" : "text",
"_id" : "2",
"_score" : 1.0, "_source" : {
"user" : "Alex",
"post_date" : "2012-10-04T14:12:12",
"ueberschrift" : "96 gewinnt",
"text" : "Hannover 96 – Der neue große HSV von 1896 schlägt Levante daheim in Unterzahl 2:1"}
} ]
}
}
[/ruby]

ElasticSearch in Ruby on Rails Anwendungen mit dem Gem Tire einbinden

Wir clonen uns nachfolgende Rails-Anwendung und initialisieren diese:
[ruby]
git clone https://github.com/agilastic/blog-search-with-tire-and-elasticsearch
[/ruby]
[ruby]
cd blog-search-with-tire-and-elasticsearch
bundle install
bundle exec rake db:setup
[/ruby]
Die „blog-search-with-tire-and-elasticsearch“-Railsanwendung ist sehr überschaubar gehalten. Via Scaffolding haben wir „Article“ erzeugt.
[ruby]
rails generate scaffold Article author:string, content:text, tag:string, published_at:date, title:string
[/ruby]

Durchsucht werden sollen die Inhalte unseres Models „Article“. Hierzu muss das Model „Article“ angepasst werden. Um Tire einzubinden müssen im „Article“-Model zwei Module eingebunden werden. Das erste Modul dient zur Einstellung der Suche und der Indizierung. Das zweite Modul kümmert sich um die Callbacks und führt die automatische Updates des Index bei jede Änderung des Artikels aus. Außerdem muss ein Block für das Mapping definiert werden. Des Weiteren passen wir die search-Methode etwas an.
[ruby]
class Article < ActiveRecord::Base
include Tire::Model::Search
include Tire::Model::Callbacks
attr_accessible :author, :tag, :content, :published_at, :title

mapping do
indexes :id, :index => :not_analyzed
indexes :title, :analyzer => ’snowball‘, :boost => 100
indexes :content, :analyzer => ’snowball‘
indexes :author, :analyzer => ‚keyword‘
indexes :tag, :analyzer => ‚keyword‘
indexes :published_at, :type => ‚date‘, :include_in_all => false
end

def self.search(params)
tire.search(load: true) do
query {string params[:query]} if params[:query].present?
end
end
end
[/ruby]

Wer sich wundert was der „Snowball-Analyzer“ ist, kann sich auf der Projekt-Webseite genauer informieren snowball.tartarus.org/texts/introduction.html
Der Schneeball Analyzer kommt von Lucene und wurde ursprünglich in einem Projekt von snowball.tartarus.org entwickelt.

Das Suchformular in der articles#index-View wird angelegt:
[ruby]

<%= form_tag articles_path, method: :get do %>
<%= text_field_tag :query, params[:query] %>
<%= submit_tag "Suchen", name: nil %>
<% end %>

[/ruby]
Abschließend können Suchanfragen im Google-Stil durchgeführt werden:

Sollten bereits mehrere Artikel vor der Integration von Tire im Blog vorhanden sein oder der ElasticSearch-„Artikel“-Index korrupt sein, so kann dieser neu angelegt und reindeziert werden. Dazu kann beispielsweise der nachfolgende Raketask genutzt werden:
[ruby]
rake elasticsearch:recreate_index
[/ruby]

[ruby]
namespace :elasticsearch do
task :recreate_index => :environment do
@data_tables = ActiveRecord::Base.connection.tables
@data_tables.delete("schema_migrations")
@data_tables.each do |single_table|
model = single_table.capitalize.singularize.constantize
model.all.each do |a|
a.tire.update_index
end
end
end
[/ruby]

Viel Spaß beim Ausprobieren

Gastbeitrag von: Alexander Ebeling-Hoppe
Alexander Ebeling-Hoppe arbeitet bei der Zentralen Polizeidirektion Niedersachsen als Ruby on Rails, sowie als freiberuflicher Webentwickler (agilastic.de) und Lehrbeauftragter.

Werbung in eigener Sache:

Ich bieten Ihnen eine viertägige Ruby on Rails Grundlagenschulung bei der VHS Hannover (Büssingweg 9, 30165 Hannover) an:

27./28.10.2012, 09:00 Uhr – 16:00 Uhr (Sa/So)
03./04.11.2012, 09:00 Uhr – 16:00 Uhr (Sa/So)
Kursnummer: 54079D8
Gebühr: 156,40 € (regulär)
Schüler, Studenten, Azubis etc. 113,20 €

Weitere Details: VHS on RAILS

VHS on Rails

2012-10-08T08:00:06Z

Gebühr: 156,40 €

Dozent(en):Alexander Ebeling-Hoppe

Veranstaltungsort:Volkshochschule Büssingweg, Büssingweg 9
Ruby on RailsTermin(e):

27.10.2012, 09:00 Uhr – 16:00 Uhr (Samstag)
28.10.2012, 09:00 Uhr – 16:00 Uhr (Sonntag)
03.11.2012, 09:00 Uhr – 16:00 Uhr (Samstag)
04.11.2012, 09:00 Uhr – 16:00 Uhr (Sonntag)

Beschreibung:Sie lernen in diesem Kurs die Skriptsprache Ruby und darauf aufbauend das Web-Framework Ruby on Rails kennen. Anhand einfacher Beispiele erarbeiten wir gemeinsam die grundlegende Web-Anwendungsentwicklung vom Datenbankzugriff über das Design der Oberfläche bis hin zum Zugriff auf Web Services.
Inhalt:
– Schritt für Schritt Installation von Ruby und Ruby on Rails (RoR) unter OS X (eigene Notebooks mit eigener 3G Verbindung können mitgebracht werden)
– Vorstellung der Arbeitsumgebung
– Grundlagen von Ruby: Module, Klassen, Methoden und Attribute, etc.
– Rails Grundlagen: MVC-Prinzip, ActiveRecord, Routing, Ajax (asynchrone Kommunikations), CRUD-Zugriffe (Create, Read, Update, Delete), DRY Prinzip, Relationen, Validierung, Installation eines Ruby-fähigen Web Servers, Ausblick Testen (Cucumber, RSpec)
Empfohlene Vorkenntnisse: Grundlagen MAC OS X, Grundlagen HTML, keine Scheu vor dem Terminal (Eingabeaufforderung)

Weitere Details und Anmeldung: https://www.vhs-hannover.de/themen/kurs/details/webapplikationen-entwickeln-mit-ruby-on-rails-54079d8

Screencast: Bildbearbeitung mit RMagick

2012-08-17T06:26:09Z

Downloads in verschiedenen Formaten:

mp4
m4v
webm
ogg

Resourcen:

terminal

[bash]
brew install imagemagick
convert -version
convert octocat.png -resize ’70×70^‘ -gravity center -crop ’70×70+0+0′ -quantize GRAY -colors 256 -contrast source.png
composite stamp_overlay.png source.png source.png
convert -size 70×70 canvas:red ( octocat.png -resize ’70×70^‘ -gravity center -crop ’70×70+0+0′ -quantize GRAY -colors 256 -contrast stamp_overlay.png -composite -negate ) -compose copy-opacity -composite stamp.png
gem install rmagick
mate stamp.rb
ruby stamp.rb
[/bash]

stamp.rb

[ruby]

require "rmagick"

source = Magick::Image.read("octocat.png").first
source = source.resize_to_fill(70, 70).quantize(256, Magick::GRAYColorspace).contrast(true)
overlay = Magick::Image.read("stamp_overlay.png").first
source.composite!(overlay, 0, 0, Magick::OverCompositeOp)
colored = Magick::Image.new(70, 70) { self.background_color = "red" }
colored.composite!(source.negate, 0, 0, Magick::CopyOpacityCompositeOp)
colored.write("stamp.png")

# Or through the command line:
# system <<-COMMAND
# convert -size 70×70 canvas:red $ octocat.png
# -resize ’70×70^‘ -gravity center -crop ’70×70+0+0′
# -quantize GRAY -colors 256 -contrast stamp_overlay.png
# -composite -negate
# $ -compose copy-opacity -composite stamp.png
# COMMAND
[/ruby]

Gemfile

[ruby]
gem ‚rmagick‘
gem ‚carrierwave‘
[/ruby]

models/stamp.rb

[ruby]

mount_uploader :image, StampUploader
[/ruby]

app/uploaders/stamp_uploader.rb

[ruby]

class StampUploader < CarrierWave::Uploader::Base
include CarrierWave::RMagick

# Include the Sprockets helpers for Rails 3.1+ asset pipeline compatibility:
include Sprockets::Helpers::RailsHelper
include Sprockets::Helpers::IsolatedHelper

# Choose what kind of storage to use for this uploader:
storage :file

# Override the directory where uploaded files will be stored.
# This is a sensible default for uploaders that are meant to be mounted:
def store_dir
"uploads/#{model.class.to_s.underscore}/#{mounted_as}/#{model.id}"
end

# Add a white list of extensions which are allowed to be uploaded.
# For images you might use something like this:
def extension_white_list
%w(jpg jpeg gif png)
end

%w[red green blue purple black].each do |color|
version(color) { process stamp: color }
end

def stamp(color)
manipulate! format: "png" do |source|
overlay_path = Rails.root.join("app/assets/images/stamp_overlay.png")
overlay = Magick::Image.read(overlay_path).first
source = source.resize_to_fill(70, 70).quantize(256, Magick::GRAYColorspace).contrast(true)
source.composite!(overlay, 0, 0, Magick::OverCompositeOp)
colored = Magick::Image.new(70, 70) { self.background_color = color }
colored.composite(source.negate, 0, 0, Magick::CopyOpacityCompositeOp)
end
end
end
[/ruby]

stamps/index.html

[html]
<%= image_tag stamp.image_url(:blue) %>
[/html]

Screencast: Bullet

2012-08-17T06:24:34Z

Downloads in verschiedenen Formaten:

mp4
m4v
webm
ogg

Resourcen:

Bullet

terminal

[bash]
rails g migration add_products_count_to_categories products_count:integer
rails g migration cache_products_count
rake db:migrate
[/bash]

Gemfile

[ruby]

gem ‚bullet‘, group: :development
[/ruby]

config/initializers/bullet.rb

[ruby]

if defined? Bullet
Bullet.enable = true
# Bullet.alert = true
Bullet.bullet_logger = true
end
[/ruby]

categories_controller.rb

[ruby]

def index
@categories = Category.order(:name).includes(:products)
end
[/ruby]

db/migrate/cache_products_count.rb

[ruby]

class CacheProductsCount < ActiveRecord::Migration
def up
execute "update categories set products_count=(select count(*) from products where category_id=categories.id)"
end

def down
end
end
[/ruby]

Screencast: Ransack

2012-08-09T14:45:40Z

Downloads in verschiedenen Formaten:

mp4
m4v
webm
ogg

Resourcen:

Gemfile

[ruby]

gem ‚ransack‘
[/ruby]

products_controller.rb

[ruby]

def index
@search = Product.search(params[:q])
@products = @search.result
end
[/ruby]

products/index.html.erb

[html]

<%= search_form_for @search, url: search_products_path, method: :post do |f| %>
<%= f.condition_fields do |c| %>
<%= render "condition_fields", f: c %>
<% end %>

<%= link_to_add_fields "Add Conditions", f, :condition %>

Sort:
<%= f.sort_fields do |s| %>
<%= s.sort_select %>
<% end %>

<%= f.submit "Search" %>

<% end %>

<% @products.each do |product| %>

<% end %>

<%= sort_link @search, :name, "Product Name" %>	<%= sort_link @search, :released_on, "Release Date" %>	<%= sort_link @search, :price, "Price" %>
<%= link_to(product.name, product) %>	<%= product.released_on.strftime("%B %e, %Y") %>	<%= number_to_currency(product.price) %>

[/html]

config/routes.rb

[ruby]

resources :products do
collection { post :search, to: ‚products#index‘ }
end
[/ruby]

products_controller.rb

[ruby]
def index
@search = Product.search(params[:q])
@products = @search.result
@search.build_condition if @search.conditions.empty?
@search.build_sort if @search.sorts.empty?
end
[/ruby]

products/index.html.erb

[html]
<%= search_form_for @search, url: search_products_path, method: :post do |f| %>
<%= f.condition_fields do |c| %>
<%= render "condition_fields", f: c %>
<% end %>

<%= link_to_add_fields "Add Conditions", f, :condition %>

Sort:
<%= f.sort_fields do |s| %>
<%= s.sort_select %>
<% end %>

<%= f.submit "Search" %>

<% end %>
[/html]

products/_condition_fields.html.erb

[html]

<%= f.attribute_fields do |a| %>
<%= a.attribute_select associations: [:category] %>
<% end %>
<%= f.predicate_select %>
<%= f.value_fields do |v| %>
<%= v.text_field :value %>
<% end %>
<%= link_to "remove", ‚#‘, class: "remove_fields" %>

[/html]

application_helper.rb

[ruby]

def link_to_add_fields(name, f, type)
new_object = f.object.send "build_#{type}"
id = "new_#{type}"
fields = f.send("#{type}_fields", new_object, child_index: id) do |builder|
render(type.to_s + "_fields", f: builder)
end
link_to(name, ‚#‘, class: "add_fields", data: {id: id, fields: fields.gsub("n", "")})
end
[/ruby]

products.js.coffee

[javascript]
jQuery ->
$(‚form‘).on ‚click‘, ‚.remove_fields‘, (event) ->
$(this).closest(‚.field‘).remove()
event.preventDefault()

$(‚form‘).on ‚click‘, ‚.add_fields‘, (event) ->
time = new Date().getTime()
regexp = new RegExp($(this).data(‚id‘), ‚g‘)
$(this).before($(this).data(‚fields‘).replace(regexp, time))
event.preventDefault()
[/javascript]

Screencast: MiniProfiler

2012-08-08T14:42:08Z

Downloads in verschiedenen Formaten:

mp4
m4v
webm
ogg

Resourcen:

Gemfile

[ruby]

gem ‚rack-mini-profiler‘
[/ruby]

products/index.html.erb

[html]
<%= pluralize project.tasks.size, "task" %>
[/html]

projects_controller.rb

[ruby]

@projects = Project.order(:created_at).select("projects.*, count(tasks.id) as tasks_count").joins("left outer join tasks on project_id=projects.id").group("projects.id")
Rack::MiniProfiler.step("fetch projects") do
@projects.all
end
[/ruby]

config/environments/production.rb

[ruby]

config.serve_static_assets = true
[/ruby]

terminal

[bash]
rake assets:precompile
rake db:setup RAILS_ENV=production
rails s -e production
[/bash]

application_controller.rb

[ruby]

before_filter :miniprofiler

private

def miniprofiler
Rack::MiniProfiler.authorize_request # if user.admin?
end
[/ruby]

Screencast: Sidekiq

2012-08-07T14:26:24Z

Downloads in verschiedenen Formaten:

mp4
m4v
webm
ogg

Resourcen:

terminal

[bash]

brew install redis
redis-server /usr/local/etc/redis.conf
bundle exec sidekiq
bundle exec sidekiq -q high,5 default
[/bash]

Gemfile

[ruby]
gem ’sidekiq‘
gem ’sinatra‘, require: false
gem ’slim‘
[/ruby]

snippets_controller.rb

[ruby]
PygmentsWorker.perform_async(@snippet.id)
# PygmentsWorker.perform_in(1.hour, @snippet.id)
[/ruby]

app/workers/pygments_worker.rb

[ruby]

class PygmentsWorker
include Sidekiq::Worker
sidekiq_options queue: "high"
# sidekiq_options retry: false

def perform(snippet_id)
snippet = Snippet.find(snippet_id)
uri = URI.parse("http://pygments.appspot.com/")
request = Net::HTTP.post_form(uri, lang: snippet.language, code: snippet.plain_code)
snippet.update_attribute(:highlighted_code, request.body)
end
end
[/ruby]

routes.rb

[ruby]

require ’sidekiq/web‘
# …
mount Sidekiq::Web, at: ‚/sidekiq‘
[/ruby]

Screencast: Active Records Reputation System

2012-08-06T14:19:48Z

Downloads in verschiedenen Formaten:

mp4
m4v
webm
ogg

Resourcen:

Active Record Reputation System

terminal

[bash]

rails g reputation_system
rake db:migrate
[/bash]

Gemfile

[ruby]

gem ‚activerecord-reputation-system‘, require: ‚reputation_system‘
[/ruby]

models/haiku.rb

[ruby]

has_reputation :votes, source: :user, aggregated_by: :sum
[/ruby]

models/user.rb

[ruby]

has_many :evaluations, class_name: "RSEvaluation", as: :source

has_reputation :votes, source: {reputation: :votes, of: :haikus}, aggregated_by: :sum

def voted_for?(haiku)
evaluations.where(target_type: haiku.class, target_id: haiku.id).present?
end
[/ruby]

config/routes.rb

[ruby]

resources :haikus do
member { post :vote }
end
[/ruby]

haikus_controller.rb

[ruby]

def index
@haikus = Haiku.find_with_reputation(:votes, :all, order: "votes desc")
end

def vote
value = params[:type] == "up" ? 1 : -1
@haiku = Haiku.find(params[:id])
@haiku.add_or_update_evaluation(:votes, value, current_user)
redirect_to :back, notice: "Thank you for voting"
end
[/ruby]

_haiku.html.erb

[html]

| <%= pluralize haiku.reputation_value_for(:votes).to_i, "vote" %>
<% if current_user && !current_user.voted_for?(haiku) %>
| <%= link_to "up", vote_haiku_path(haiku, type: "up"), method: "post" %>
| <%= link_to "down", vote_haiku_path(haiku, type: "down"), method: "post" %>
<% end %>
[/html]

application.html.erb

[html]

<%= current_user.reputation_value_for(:votes).to_i %>
[/html]

models/haiku_vote.rb

[ruby]

validates_uniqueness_of :haiku_id, scope: :user_id
validates_inclusion_of :value, in: [1, -1]
validate :ensure_not_author

def ensure_not_author
errors.add :user_id, "is the author of the haiku" if haiku.user_id == user_id
end
[/ruby]

models/haiku.rb

[ruby]

def self.by_votes
select(‚haikus.*, coalesce(value, 0) as votes‘).
joins(‚left join haiku_votes on haiku_id=haikus.id‘).
order(‚votes desc‘)
end

def votes
read_attribute(:votes) || haiku_votes.sum(:value)
end
[/ruby]

models/user.rb

[ruby]

def total_votes
HaikuVote.joins(:haiku).where(haikus: {user_id: self.id}).sum(‚value‘)
end

def can_vote_for?(haiku)
haiku_votes.build(value: 1, haiku: haiku).valid?
end
[/ruby]

haikus_controller.rb

[ruby]

def index
@haikus = Haiku.by_votes
end

def vote
vote = current_user.haiku_votes.new(value: params[:value], haiku_id: params[:id])
if vote.save
redirect_to :back, notice: "Thank you for voting."
else
redirect_to :back, alert: "Unable to vote, perhaps you already did."
end
end
[/ruby]

_haiku.html.erb

[html]

| <%= pluralize haiku.votes, "vote" %>
<% if current_user && current_user.can_vote_for?(haiku) %>
| <%= link_to "up", vote_haiku_path(haiku, value: 1), method: "post" %>
| <%= link_to "down", vote_haiku_path(haiku, value: -1), method: "post" %>
<% end %>
[/html]

application.html.erb

[html]

<%= current_user.total_votes %>
[/html]

Screencast: Datenexport nach Excel oder CSV

2012-07-05T06:17:51Z

Downloads in verschiedenen Formaten:

mp4
m4v
webm
ogg

Resourcen:

config/application.rb

[ruby]
require ‚csv‘
[/ruby]

products_controller.rb

[ruby]
def index
@products = Product.order(:name)
respond_to do |format|
format.html
format.csv { send_data @products.to_csv }
format.xls # { send_data @products.to_csv(col_sep: "t") }
end
end
[/ruby]

models/product.rb

[ruby]
def self.to_csv(options = {})
CSV.generate(options) do |csv|
csv << column_names
all.each do |product|
csv << product.attributes.values_at(*column_names)
end
end
end
[/ruby]

config/initializers/mime_types.rb

[ruby]
Mime::Type.register "application/xls", :xls
[/ruby]

views/products/index.xls.erb

[html]

xmlns:o="urn:schemas-microsoft-com:office:office"
xmlns:x="urn:schemas-microsoft-com:office:excel"
xmlns:ss="urn:schemas-microsoft-com:office:spreadsheet"
xmlns:html="http://www.w3.org/TR/REC-html40">

ID
Name
Release Date
Price

<% @products.each do |product| %>

<%= product.id %>
<%= product.name %>
<%= product.released_on %>
<%= product.price %>

<% end %>

[/html]

Screencast: Authentifizierung über Facebook

2012-07-05T06:13:26Z

Downloads in verschiedenen Formaten:

mp4
m4v
webm
ogg

Resourcen:

Gemfile

[ruby]
gem ‚omniauth-facebook‘
[/ruby]

config/initializers/omniauth.rb

[ruby]
OmniAuth.config.logger = Rails.logger

Rails.application.config.middleware.use OmniAuth::Builder do
provider :facebook, ENV[‚FACEBOOK_APP_ID‘], ENV[‚FACEBOOK_SECRET‘]
end
[/ruby]

terminal

[bash]
rails g model user provider uid name oauth_token oauth_expires_at:datetime
rake db:migrate
[/bash]

models/user.rb

[ruby]
def self.from_omniauth(auth)
where(auth.slice(:provider, :uid)).first_or_initialize.tap do |user|
user.provider = auth.provider
user.uid = auth.uid
user.name = auth.info.name
user.oauth_token = auth.credentials.token
user.oauth_expires_at = Time.at(auth.credentials.expires_at)
user.save!
end
end
[/ruby]

config/routes.rb

[ruby]
match ‚auth/:provider/callback‘, to: ’sessions#create‘
match ‚auth/failure‘, to: redirect(‚/‘)
match ’signout‘, to: ’sessions#destroy‘, as: ’signout‘
[/ruby]

sessions_controller.rb

[ruby]
class SessionsController < ApplicationController
def create
user = User.from_omniauth(env["omniauth.auth"])
session[:user_id] = user.id
redirect_to root_url
end

def destroy
session[:user_id] = nil
redirect_to root_url
end
end
[/ruby]

application_controller.rb

[ruby]
private

def current_user
@current_user ||= User.find(session[:user_id]) if session[:user_id]
end
helper_method :current_user
[/ruby]

layouts/application.html.erb

[html]

<% if current_user %>
Signed in as <%= current_user.name %>!
<%= link_to "Sign out", signout_path, id: "sign_out" %>
<% else %>
<%= link_to "Sign in with Facebook", "/auth/facebook", id: "sign_in" %>
<% end %>

[/html]

app/assets/javascripts/facebook.js.coffee.erb

[javascript]

jQuery ->
$(‚body‘).prepend(‚

‘)

$.ajax
url: "#{window.location.protocol}//connect.facebook.net/en_US/all.js"
dataType: ’script‘
cache: true

window.fbAsyncInit = ->
FB.init(appId: ‚<%= ENV["FACEBOOK_APP_ID"] %>‘, cookie: true)

$(‚#sign_in‘).click (e) ->
e.preventDefault()
FB.login (response) ->
window.location = ‚/auth/facebook/callback‘ if response.authResponse

$(‚#sign_out‘).click (e) ->
FB.getLoginStatus (response) ->
FB.logout() if response.authResponse
true
[/javascript]