arnaucube
arnaucube/goBlockchainDataAnalysisPublic Self-hosted repository
goBlockchainDataAnalysis/addressTree.go
addressTree.goRaw
 1package main
 2
 3import (
 4	"fmt"
 5	"log"
 6
 7	"github.com/fatih/color"
 8
 9	"gopkg.in/mgo.v2/bson"
10)
11
12func upTree(address string, network NetworkModel) NetworkModel {
13	var upNetwork NetworkModel
14
15	//add address node to network
16	node := NodeModel{}
17	err := nodeCollection.Find(bson.M{"id": address}).One(&node)
18	check(err)
19	if nodeInNodes(network.Nodes, node) == false {
20		network.Nodes = append(network.Nodes, node)
21	}
22
23	//get edges before the address
24	edges := []EdgeModel{}
25	err = edgeCollection.Find(bson.M{"to": address}).All(&edges)
26	check(err)
27	for _, e := range edges {
28		if edgeInEdges(network.Edges, e) == false {
29			network.Edges = append(network.Edges, e)
30		}
31		//get the nodes involved in edges
32		/*
33			nodes := []NodeModel{}
34			err := nodeCollection.Find(bson.M{"id": }).All(&edges)
35			check(err)
36		*/
37		endBranch := false
38		edgeUpCheck := EdgeModel{}
39		err := edgeCollection.Find(bson.M{"to": e.From}).One(&edgeUpCheck)
40		if err != nil {
41			log.Println(err)
42			color.Blue("not found")
43			endBranch = true
44		}
45
46		//need to be fixed when there is a bucle between the addresses (A-->B, B-->C, C-->A)
47		fmt.Println(e.From + " - " + e.To)
48		if edgeInEdges(network.Edges, edgeUpCheck) == false && endBranch == false && edgeUpCheck.BlockHeight <= e.BlockHeight && e.To != edgeUpCheck.From {
49			upNetwork = upTree(e.From, network)
50			for _, upN := range upNetwork.Nodes {
51				if nodeInNodes(network.Nodes, upN) == false {
52					network.Nodes = append(network.Nodes, upN)
53				}
54			}
55			for _, upE := range upNetwork.Edges {
56				if edgeInEdges(network.Edges, upE) == false {
57					network.Edges = append(network.Edges, upE)
58				}
59			}
60		}
61	}
62
63	return network
64}
65func addressTree(address string) NetworkModel {
66	var network NetworkModel
67
68	network = upTree(address, network)
69	return network
70
71}