TwP

def fix_escape( str )
  str.gsub(%r/\\(\d+|[nr])/) { |match|
    case $1
    when 'n': "\n"
    when 'r': "\r"
    else
      [$1.to_i(8)].pack('C')
    end
  }

TwP

require 'socket'
require 'open-uri'

require 'rubygems'
require 'servolux'
require 'nokogiri'

PATH = '/tmp/web_fetch.socket'

# Create a UNIX socket at the tmp PATH

TwP

require 'yajl'

module Rack

  # A Rack middleware for parsing POST/PUT body data when Content-Type is
  # <tt>application/json</tt>.
  #
  class JsonPostBody

TwP

#!/usr/bin/env ruby

require 'rubygems'
Thread.abort_on_exception = true

require 'directory_watcher'

STDOUT.sync = true
puts "Directory Watcher v #{DirectoryWatcher.version}"

TwP

#!/usr/bin/env

# Possibly one of the faster wasy to concatenate two files in ruby.
# Another way might be to use the lower level IO#sysread, IO#syswrite methods
# I think the main benefit in this case is the reusing of the String instance as
# the buffer.

dest = ARGV.shift
src  = ARGV.shift

TwP

# This is a very simple-minded and inelegant way to prevent others from
# modifying (monkey patching) your code. A global method "monkey_proof" is
# provided that can be used to prevent monkey patching on most any Object or
# Class.
#
moddule MonkeyProof

  VERSION = '1.0.0'

  def self.included( other )

TwP

require 'servolux'
require 'logging'

# This is a simple demonstration server that shows how to register a signal handler
# for toggling the log level of your application. This is very useful in a production
# application where you want to enable debug messages for a brief period of time. The
# Servolux::Server class looks for a few special methods and registers them as signal
# handlers. Here, the "usr1" method will be called when the USR1 signal is sent to the
# process.

TwP

{
  "filter": {
    "and": { "_cache": true, "filters": [
      { "or": { "_cache": true, "filters": [
        {"prefix": { "_id": "http://www.example.com" }}
      ]}},

      { "not": { "_cache": true, "filter": { "or": { "_cache": true, "filters": [
        {"term": { "_id": "http://www.example.com" }},
        {"term": { "_id": "http://www.example.com/sitemap" }},

TwP

{
  "filter": { "bool": {
    "must": [
      { "prefix": { "_id": "http://www.example.com" }}
    ]
  }}
}

TwP

#!/usr/bin/env ruby

require 'rubygems'
$:.unshift 'lib'
Thread.abort_on_exception = true

require 'logging'
include Logging.globally

require 'directory_watcher'