gocryptoadmin

README

gocryptoadmin

This module contains functions to read, write, calculate on exchange CSV exports. It is also possible to blend manual edited CSV with exchanges.

Example

Group and Keep Accounting Globally and each Individual Exchange

This example is taken from an unit test where it uses three CSV files.

NOTE: This sample uses the coinbase pro format since it is completely manually edited and fake!

1. Bank - buy EUR from Svensk Krona and transfer
2. Kraken - receive EUR to buy LTC, transfer, and sell LTC
3. Coinbase Pro - receive LTC and sell it there

lf.csv (Bank)

portfolio,trade id,product,side,sideid,created at,size,size unit,price,fee,total,price/fee/total unit
default,1,EUR-SEK,BUY,lf,2017-12-06T08:00:00.000Z,50.0,EUR,10,50.000000000,-550,SEK
default,2,EUR-EUR,TRANSFER,kr,2017-12-06T09:00:00.000Z,48,EUR,1,2,-50,EUR

kr.csv (Kraken)

portfolio,trade id,product,side,sideid,created at,size,size unit,price,fee,total,price/fee/total unit
default,1,EUR-EUR,RECEIVE,lf,2017-12-06T10:00:00.000Z,48,EUR,1,3.000000000,45,EUR
default,2,LTC-EUR,BUY,kr,2017-12-06T11:00:00.000Z,2,LTC,10,4,-24,EUR
default,3,LTC-LTC,TRANSFER,cb,2017-12-06T12:00:00.000Z,0.9,LTC,1,0.1,-1,LTC
default,4,LTC-EUR,SELL,kr,2017-12-06T14:00:00.000Z,1,LTC,20,2,18,EUR

cb.csv (Coinbase Pro)

portfolio,trade id,product,side,sideid,created at,size,size unit,price,fee,total,price/fee/total unit
default,1,LTC-LTC,RECEIVE,kr,2017-12-06T13:00:00.000Z,0.9,LTC,1,0.1,0.8,LTC
default,2,LTC-EUR,SELL,cb,2017-12-06T15:00:00.000Z,0.8,LTC,30,2,22,EUR

Running read all CSV , default chronological sorter, transaction group processor (20h window), and multi account processor, the following output can be emitted.

------------------------------------------------------------------------------------------------------------------------------------------------------------
|Exchange  |Side     |Tx Date             |Pair    |Price / Unit     |Fee          |Total Price      |Account EUR      |Account LTC      |Account SEK      |
------------------------------------------------------------------------------------------------------------------------------------------------------------
|lf        |BUY      |2017-12-06 08:00:00 |EUR-SEK | 10.000000       | 50.000000   |-550.000000      | 50.000000       | 0.000000        |-550.000000      |
|lf        |TRANSFER |2017-12-06 09:00:00 |EUR-EUR | 1.000000        | 2.000000    |-50.000000       | 0.000000        | 0.000000        |-550.000000      |
|kr        |RECEIVE  |2017-12-06 10:00:00 |EUR-EUR | 1.000000        | 3.000000    | 45.000000       | 45.000000       | 0.000000        |-550.000000      |
|kr        |BUY      |2017-12-06 11:00:00 |LTC-EUR | 10.000000       | 4.000000    |-24.000000       | 21.000000       | 2.000000        |-550.000000      |
|kr        |TRANSFER |2017-12-06 12:00:00 |LTC-LTC | 1.000000        | 0.100000    |-1.000000        | 21.000000       | 1.000000        |-550.000000      |
|cbx       |RECEIVE  |2017-12-06 13:00:00 |LTC-LTC | 1.000000        | 0.100000    | 0.800000        | 21.000000       | 1.800000        |-550.000000      |
|kr        |SELL     |2017-12-06 14:00:00 |LTC-EUR | 20.000000       | 2.000000    | 18.000000       | 39.000000       | 0.800000        |-550.000000      |
|cbx       |SELL     |2017-12-06 15:00:00 |LTC-EUR | 30.000000       | 2.000000    | 22.000000       | 61.000000       | 0.000000        |-550.000000      |

------------------------------------------------------------------------------------------------------------------------------------------
|Exchange  |Side     |Tx Date             |Pair    |Price / Unit     |Fee          |Total Price      |Account EUR      |Account SEK      |
------------------------------------------------------------------------------------------------------------------------------------------
|lf        |BUY      |2017-12-06 08:00:00 |EUR-SEK | 10.000000       | 50.000000   |-550.000000      | 50.000000       |-550.000000      |
|lf        |TRANSFER |2017-12-06 09:00:00 |EUR-EUR | 1.000000        | 2.000000    |-50.000000       | 0.000000        |-550.000000      |

------------------------------------------------------------------------------------------------------------------------------------------
|Exchange  |Side     |Tx Date             |Pair    |Price / Unit     |Fee          |Total Price      |Account EUR      |Account LTC      |
------------------------------------------------------------------------------------------------------------------------------------------
|kr        |RECEIVE  |2017-12-06 10:00:00 |EUR-EUR | 1.000000        | 3.000000    | 45.000000       | 45.000000       | 0.000000        |
|kr        |BUY      |2017-12-06 11:00:00 |LTC-EUR | 10.000000       | 4.000000    |-24.000000       | 21.000000       | 2.000000        |
|kr        |TRANSFER |2017-12-06 12:00:00 |LTC-LTC | 1.000000        | 0.100000    |-1.000000        | 21.000000       | 1.000000        |
|kr        |SELL     |2017-12-06 14:00:00 |LTC-EUR | 20.000000       | 2.000000    | 18.000000       | 39.000000       | 0.000000        |

------------------------------------------------------------------------------------------------------------------------------------------
|Exchange  |Side     |Tx Date             |Pair    |Price / Unit     |Fee          |Total Price      |Account EUR      |Account LTC      |
------------------------------------------------------------------------------------------------------------------------------------------
|cbx       |RECEIVE  |2017-12-06 13:00:00 |LTC-LTC | 1.000000        | 0.100000    | 0.800000        | 0.000000        | 0.800000        |
|cbx       |SELL     |2017-12-06 15:00:00 |LTC-EUR | 30.000000       | 2.000000    | 22.000000       | 22.000000       | 0.000000        |

The code to output this is the following.

func TestMultiExchangeMultiAccount(t *testing.T) {

	txr := txlog.NewTxLogReader(NewChronologicalTxEntryProcessor()).
		RegisterReader("lf", coinbasepro.NewTransactionLogReader()).
		RegisterReader("kr", coinbasepro.NewTransactionLogReader()).
		RegisterReader("cbx", coinbasepro.NewTransactionLogReader())

	tx := txr.ReadBufferAsExchange(
		"lf", utils.ReadFile("testfiles/multi-exchange/lf.csv"),
	)

	tx = append(
		tx,
		txr.ReadBufferAsExchange(
			"kr", utils.ReadFile("testfiles/multi-exchange/kr.csv"))...,
	)

	tx = append(
		tx,
		txr.ReadBufferAsExchange(
			"cbx", utils.ReadFile("testfiles/multi-exchange/cb.csv"))...,
	)

	proc := NewTxGroupProcessor(time.Hour * 20 /*20h*/)

	for _, tx := range tx {
		proc.Process(&tx)
	}

	txg := proc.Flush()

	acc := NewMultiExchangeAccountingProcessor()
	for i := range txg {
		acc.Process(&txg[i]) // Since accepting interface, use indexer
	}

	for _, transactions := range acc.Flush() {

		op := output.NewStdPrinterDefaults(os.Stdout, "default")

		for _, tx := range transactions {

			op.Process(tx)
		}

		op.Flush()
		fmt.Println()

	}

}

Development

• This project uses golines - do a go install github.com/segmentio/golines@latest (outside of gocryptoadmin) to install

• Follow the setup instructions for golines for vs code