rday

package main

import (
	"bytes"
	"github.com/go-martini/martini"
	"log"
	"net/http"
	"path"
	"time"
	"strings"

rday

// Struct to hold all my application's commonly used packages
type MySpecialContext struct {
    Render render.Render
    Logger   *log.Logger
    Session  sessions.Session
    Db       *mgo.Database
    Ctx      martini.Context
    App      *ApplicationConfig
}

rday

static void *rtp_thread(void *args)
{
        struct ap_info* thread_info = args;
        struct ast_frame *f = NULL;
        struct ast_rtp *astRtp = NULL;                  // XXX <-- Replaced by rtp_engine
        int pktCnt=0;
        int res = 0;

        astRtp = ast_rtp_new_fd(thread_info->sockFd);   // XXX <-- Doesn't event exist anymore

rday

import time
import numpy as np

def naive():
  x = 0
  y = 0
  for i in range(1, 1001):
    x += pow(i, 2)
    y += i
  return pow(y, 2) - x

rday

import numpy as np

def moving_average(data_set, periods=3):
    weights = np.ones(periods) / periods
    return np.convolve(data_set, weights, mode='valid')

data = [1, 2, 3, 6, 9, 12, 20, 28, 30, 25, 22, 20, 15, 12, 10]

ma = moving_average(np.asarray(data), 3)
assert (np.around(ma, decimals=2)==np.array([2.0, 3.67, 6.0, 9.0, 13.67, 20.0, 26.0, 27.67, 25.67, 22.33, 19.0, 15.67, 12.33])).all() == True

rday

def moving_average(data_set, period=3):
    avgs = []

    for idx, item in enumerate(data_set[period-1:]):
        avgs.append(round(sum(data_set[idx:period+idx]) / float(period), 2))

    return avgs

data = [1, 2, 3, 6, 9, 12, 20, 28, 30, 25, 22, 20, 15, 12, 10]

rday

@batch_transform
def bbands_transform(data, sid1):
    print "bbands_transform()"
    print data
    inputs = {}
    inputs['high'] = numpy.asarray([v for v in data.high[sid1]])
    inputs['open'] = numpy.asarray([v for v in data.open[sid1]])
    inputs['low'] = numpy.asarray([v for v in data.low[sid1]])
    inputs['close'] = numpy.asarray([v for v in data.close[sid1]])

rday

import numpy
from talib.abstract import Function
from numbers import Number
from collections import defaultdict

from zipline.transforms.utils import EventWindow, TransformMeta


class TATransform(object):
    """

rday

    # Verify that our benchmark msgpack file is up to date
    bm_list = msgpack.loads(fp_bm.read())
    bm_date, _ = bm_list[len(bm_list)-1]
    last_date = datetime(bm_date[0], bm_date[1], bm_date[2])
    today = datetime.today().replace(hour=0, minute=0, second=0, microsecond=0)
    if last_date < today-timedelta(days=1):
        update_benchmarks(last_date)
        fp_bm = get_datafile('benchmark.msgpack', "rb")

rday

'''
As usual, this is a wallofcode beta, don't use this in real life
'''

import numpy
import talib
from talib.abstract import Function
from numbers import Number
from collections import defaultdict