freddi301

var pg = require ('pg');

var pgConString = "postgres://postgres:mysecretpassword@localhost/postgres"

pg.connect(pgConString, function(err, client) {
  if(err) {
    console.log(err);
  }
  client.on('notification', function(msg) {
    console.log(msg);

freddi301

const mongodb = require('mongodb')
const Bluebird = require('bluebird')

class EventStore {
  constructor(dbUrl, collectionName){
    this.db = mongodb.MongoClient.connect(dbUrl);
    this.cappedCollection = this.db.then(db=>
      db.createCollection(collectionName, { capped: true, size: 1024*1024 })
      .then(()=> db.collection(collectionName).createIndex({__t: 1}, {unique: true}))
      .then(()=> db.collection(collectionName))

freddi301

const g = require('graphql'),
  graphql = g.graphql,
  GraphQLSchema = g.GraphQLSchema,
  GraphQLObjectType = g.GraphQLObjectType,
  GraphQLString = g.GraphQLString

const schema = new GraphQLSchema({
  query: new GraphQLObjectType({ name: 'RootQueryType', fields: {
    hello: { type: GraphQLString, resolve() { return 'world'; } },
    ciao: { type: GraphQLString, resolve(){return Promise.resolve("heila")} }

freddi301

// @flow
//"use strict";

interface Evaluable {
  evaluate(scope: Object): ()=> Evaluable
}

/*
  { type: Lambda ,name:String , argument: String, body: Evaluable }
*/

freddi301

function prev(prev){return (self)=>(next)=>prev};
function self(prev){return (self)=>(next)=>self};
function next(prev){return (self)=>(next)=>next};

function node(self){return (next)=>(prev)=>(select)=>select(prev)(self)(next?next(node(self)(next)(prev)):next)};

function array2doublelist(array, index){
  return index<array.length?
    node(array[index])(array2doublelist(array,index+1))
    :null;