carlhoerberg

require "socket"

lib LibC
  {% if flag?(:linux) %}
    fun sendfile(fd_out : Int, fd_in : Int, offset : OffT*, count : SizeT) : SSizeT
    TCP_CORK = 3
  {% else %}
    struct SendfileHeader
      headers : IoVec*
      hdr_cnt : Int

carlhoerberg

# Buffered channel, using a queue.
class Channel::Buffered2(T) < Channel(T)
  def initialize(@capacity = 32)
    @queue = Deque(T).new(@capacity)
    super()
  end

  # Send a value to the channel.
  def send(value : T)
    while full?

carlhoerberg

Restarting RabbitMQ TLS Listeners with new TLS options

Edit your /etc/rabbitmq/rabbitmq.config and then reload the settings from there with:

sudo rabbitmqctl eval '{ok, [C]} = file:consult("/etc/rabbitmq/rabbitmq.config"), {rabbit, R} = proplists:lookup(rabbit, C), {ssl_options, O} = proplists:lookup(ssl_options, R), application:set_env(rabbit, ssl_options, O).'

Restart the TLS Listener on port 5671

carlhoerberg

require 'net/https'
require 'json'

class Castle
  def self.api_key=(api_key)
    @@api_key = api_key
  end

  # Usage
  # Sinatra:

carlhoerberg

var cookies = document.cookie.split("; ").reduce(function(o, c) { var s = c.split("="); o[s[0]] = s[1]; return o; }, {});

carlhoerberg

var amqp = require('amqplib/callback_api');

// if the connection is closed or fails to be established at all, we will reconnect
var amqpConn = null;
function start() {
  amqp.connect(process.env.CLOUDAMQP_URL + "?heartbeat=60", function(err, conn) {
    if (err) {
      console.error("[AMQP]", err.message);
      return setTimeout(start, 1000);
    }

carlhoerberg

Install:

apt-get install spamassassin postfix

in /etc/postfix/master.cf modify;

smtp inet n - - - - smtpd

carlhoerberg

Chromecast always uses Google's DNS servers so you can't just change DNS server on your local network, you have to redirect all DNS requests to another server. This guide will help you do so with a OS X computer and a phone.

Requirements for this guide:

• Phone with tethering
• OS X >=10.9
• unblock-us.com or another DNS resolver

Steps:

1. Tethering your computer through your phone, eg. connect to your wifi, and tether with USB.

carlhoerberg

b = Bunny.new ENV.fetch 'CLOUDAMQP_URL', connection_timeout: 10
b.start
ch = b.create_channel # by default only one thread will be used per channel for processing messages
ch.prefetch 50
ch.queue('my-jobs', durable: true).subscribe(ack: true) do |delivery, headers, body|
  data = JSON.parse body
  process(data)
  ch.ack delivery.delivery_tag
end

carlhoerberg

#!/usr/bin/env ruby
require 'bunny'
require 'securerandom'

conn = Bunny.new
conn.start

class FibonacciClient
  def initialize(conn, server_queue)
    ch              = conn.create_channel