vishnevskiy

def handle_call({:publish, message}, _from, %{sessions: sessions}=state) do
  Enum.each(sessions, &send(&1.pid, message))
  {:reply, :ok, state}
end

vishnevskiy

package main

import (
	"flag"
	"fmt"
	"io/ioutil"
	"log"
	"os"
	"os/exec"
	"os/signal"

vishnevskiy

defmodule Snowflake do
  use Application

  def start(_type, _args) do
    import Supervisor.Spec

    children = [
      worker(:riak_core_vnode_master, [Snowflake.VNode]),
    ]

vishnevskiy

import time
import pymongo
import gc

conn = pymongo.Connection('localhost', 27017)

system = conn.dkp.systems.find_one()

for raid in conn.dkp.raids.find({'system_id': system['_id']}):
    pass

vishnevskiy

import time
import pymongo

conn = pymongo.Connection('localhost', 27017)

system = conn.dkp.systems.find_one()
raids = list(conn.dkp.raids.find({'system_id': system['_id']}))
del raids

# no matter how much time passes, the RAM is not being reclaimed

vishnevskiy

import types

class Column(object):
    def __init__(self, name):
        self._name = name

    def __add__(self, other):
        return {self._name: {'$inc': other}}

    def __eq__(self, other):

vishnevskiy

from lib.mongomapper import Document
from lib.db import mongo

class Raid(Document):
    """
    _id = ObjectId
    event_id = ObjectId
    outcome = Integer
    participants = List
    loot = List

vishnevskiy

%%         if not value: return None
%%         parts = value.split("|")
%%         if len(parts) != 3: return None
%%         if include_name:
%%             signature = self._cookie_signature(name, parts[0], parts[1])
%%         else:
%%             signature = self._cookie_signature(parts[0], parts[1])
%%         if not _time_independent_equals(parts[2], signature):
%%             logging.warning("Invalid cookie signature %r", value)
%%             return None

vishnevskiy

@route('/forum/p/(\w+)/', 'forum_post')
class PostHandler(BaseHandler):
    def get(self, id):
        post = Post.documents.find_one({'_id': ObjectId(id), 'guild_id': self.guild_id}, fields=['thread_id', 'n'])
        assert post, 'Post does not exist.'
        thread = Thread.documents.get(post.thread_id, fields=['slug'])

        if post.n == None:
            post.n = Post.documents.eval("""function() {
                var n = -1;

vishnevskiy

def permission_required(*perms, **options):
    def decorator(method):
        def wrapper(self, *args, **kwargs):
            for perm in perms:
                perm = perm.split('.')

                assert self.perms[perm[0]][perm[1]], \
                    options.get('message', 'You have attempted to perform an action that you do not have permission to perform.')

            method(self, *args, **kwargs)