From dca1865a646e0d4f749b93e67ffbf944110992f6 Mon Sep 17 00:00:00 2001
From: Anthony De Meulemeester <anthony@academiclabs.co>
Date: Sat, 10 Mar 2018 13:09:15 +0100
Subject: [PATCH] cleanup repo structure. (#46)

---
 '       | 145 --------------------------------------------------------
 VERSION |   2 +-
 main.go |  15 ------
 3 files changed, 1 insertion(+), 161 deletions(-)
 delete mode 100644 '
 delete mode 100644 main.go

diff --git a/' b/'
deleted file mode 100644
index 6df537e3d..000000000
--- a/'
+++ /dev/null
@@ -1,145 +0,0 @@
-package network
-
-import (
-	"bytes"
-	"net"
-	"os"
-	"time"
-
-	"github.com/CityOfZion/neo-go/pkg/network/payload"
-	"github.com/CityOfZion/neo-go/pkg/util"
-	log "github.com/go-kit/kit/log"
-)
-
-// TCPPeer represents a connected remote node in the
-// network over TCP.
-type TCPPeer struct {
-	// The endpoint of the peer.
-	endpoint util.Endpoint
-
-	// underlying connection.
-	conn net.Conn
-
-	// The version the peer declared when connecting.
-	version *payload.Version
-
-	// connectedAt is the timestamp the peer connected to
-	// the network.
-	connectedAt time.Time
-
-	// handleProto is the handler that will handle the
-	// incoming message along with its peer.
-	handleProto protoHandleFunc
-
-	// Done is used to broadcast this peer has stopped running
-	// and should be removed as reference.
-	done chan struct{}
-	send chan *Message
-	disc chan struct{}
-
-	logger log.Logger
-}
-
-// NewTCPPeer creates a new peer from a TCP connection.
-func NewTCPPeer(conn net.Conn, fun protoHandleFunc) *TCPPeer {
-	e := util.NewEndpoint(conn.RemoteAddr().String())
-	logger := log.NewLogfmtLogger(os.Stderr)
-	logger = log.With(logger, "component", "peer", "endpoint", e)
-
-	return &TCPPeer{
-		endpoint:    e,
-		conn:        conn,
-		done:        make(chan struct{}),
-		send:        make(chan *Message),
-		logger:      logger,
-		connectedAt: time.Now().UTC(),
-		handleProto: fun,
-		disc:        make(chan struct{}, 1),
-	}
-}
-
-// Version implements the Peer interface.
-func (p *TCPPeer) Version() *payload.Version {
-	return p.version
-}
-
-// Endpoint implements the Peer interface.
-func (p *TCPPeer) Endpoint() util.Endpoint {
-	return p.endpoint
-}
-
-// Send implements the Peer interface.
-func (p *TCPPeer) Send(msg *Message) {
-	select {
-	case p.send <- msg:
-		break
-	case <-p.disc:
-		break
-	}
-}
-
-// Done implemnets the Peer interface.
-func (p *TCPPeer) Done() chan struct{} {
-	return p.done
-}
-
-func (p *TCPPeer) run() error {
-	errCh := make(chan error, 1)
-
-	go p.readLoop(errCh)
-	go p.writeLoop(errCh)
-
-	err := <-errCh
-	p.logger.Log("err", err)
-	p.cleanup()
-	return err
-}
-
-func (p *TCPPeer) readLoop(errCh chan error) {
-	for {
-		msg := &Message{}
-		if err := msg.decode(p.conn); err != nil {
-			errCh <- err
-			break
-		}
-		p.handleMessage(msg)
-	}
-}
-
-func (p *TCPPeer) writeLoop(errCh chan error) {
-	buf := new(bytes.Buffer)
-
-	for {
-		select {
-		case msg := <-p.send:
-			if err := msg.encode(buf); err != nil {
-				errCh <- err
-				return
-			}
-			if _, err := p.conn.Write(buf.Bytes()); err != nil {
-				errCh <- err
-				return
-			}
-			buf.Reset()
-		}
-	}
-}
-
-func (p *TCPPeer) cleanup() {
-	p.conn.Close()
-	p.disc <- struct{}{}
-	p.done <- struct{}{}
-	close(p.disc)
-	close(p.send)
-}
-
-func (p *TCPPeer) handleMessage(msg *Message) {
-	switch msg.CommandType() {
-	case CMDVersion:
-		version := msg.Payload.(*payload.Version)
-		p.version = version
-		p.handleProto(msg, p)
-	default:
-		p.handleProto(msg, p)
-	}
-}
diff --git a/VERSION b/VERSION
index 1b58cc101..697f087f3 100644
--- a/VERSION
+++ b/VERSION
@@ -1 +1 @@
-0.27.0
+0.28.0
diff --git a/main.go b/main.go
deleted file mode 100644
index b02e7f247..000000000
--- a/main.go
+++ /dev/null
@@ -1,15 +0,0 @@
-package main
-
-import (
-	"os"
-
-	log "github.com/go-kit/kit/log"
-)
-
-func main() {
-	logger := log.NewLogfmtLogger(log.NewSyncWriter(os.Stderr))
-	logger.Log("hello", true)
-
-	logger = log.With(logger, "module", "node")
-	logger.Log("foo", true)
-}