Daniel Negri danielnegri

Golang Workers / Job Queue

A running example of the code from:

This gist creates a working example from blog post, and a alternate example using simple worker pool.

TLDR: if you want simple and controlled concurrency use a worker pool.

How To TCP NAT Traversal using Node.js and a STUN Server

With the scarecity of IPv4 addresses, and IPv6 still not available at large, NAT traversal is becoming a necessity. Especially with the generalisation of Carrier-grade NATs that you can find on mobile connections. Even with IPv6 you may suffer NAT66. Imagine your mobile device that gets only a single Ipv6 address, and you want to share it on your computer.

The solution might be in a decentralized protocol for address attribution such

Fetch a Tree with Neo4j

Today I came across a really interesting StackOverflow question:

Given a forest of trees in a Neo4j REST server, I`m trying to return a single tree given the root vertex. Being each tree quite large, I need a de-duplicated list of all vertices and edges in order to be able to reconstruct the full tree on the client side.

	CREATE TABLE books (
	isbn char(14) NOT NULL,
	title varchar(255),
	author varchar(255),
	price decimal(5,2)
	);

	INSERT INTO books (isbn, title, author, price) VALUES
	('978-1503261969', 'Emma', 'Jayne Austen', 9.44),
	('978-1514274873', 'Journal of a Soldier', NULL, 5.49),

	var bitcore = require('bitcore');
	var request = require('request');

	var utxo = {
	'txId' : '0c5d827a24b0822abbff73f1adbfd2be7efaf4e368b4baac7e280865eb13f497',
	'outputIndex' : 1,
	'script' : 'a91431f2ae5b333c56a4f01df6209382ec8f892e4f3687',
	'satoshis' : 1000000
	};

	/**
	* Implementation example of writable response bodies.
	* Based on the draft of the Streams API (19 March 2014)
	* https://dvcs.w3.org/hg/streams-api/raw-file/tip/Overview.htm
	* Design document for response body reading/writing:
	* https://docs.google.com/document/d/1iE6M-YSmPtMOsec7pR-ILWveQie8JQQXTm15JKEcUT8
	*/
	/* globals chrome, ByteStream, URL, XMLHttpRequest */
	'use strict';

	package main

	import (
	"bufio"
	"encoding/csv"
	"encoding/json"
	"fmt"
	"io"
	"os"
	"path/filepath"

	const store = createStore((state = { counter: 0 }, action) => {
	switch(action.type) {
	case "INCREMENT":
	return { counter: state.counter + 1 }
	case "DECREMENT":
	return { counter: state.counter - 1 }
	default:
	return state
	}
	})

	function pwdx {
	lsof -a -p $1 -d cwd -n \| tail -1 \| awk '{print $NF}'
	}

	def trapBOM(fileBytes []byte) []byte{
	trimmedBytes := bytes.Trim(fileBytes, "\xef\xbb\xbf")
	return trimmedBytes
	}