mleku/indra
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

commenting out for now

Browse Source
This commit is contained in:
greg stone
2023-03-01 09:31:53 +00:00
parent e5d1089a96
commit e8babbf8e8
1 changed files with 66 additions and 65 deletions
Download Patch File Download Diff File Expand all files Collapse all files

131
cmd/indra/relay.go
View File

@@ -1,67 +1,68 @@
package main package main
import ( //
"github.com/spf13/cobra" //import (
"github.com/spf13/viper" // "github.com/spf13/cobra"
// "github.com/spf13/viper"
"git-indra.lan/indra-labs/indra" //
"git-indra.lan/indra-labs/indra/pkg/crypto/key/prv" // "git-indra.lan/indra-labs/indra"
"git-indra.lan/indra-labs/indra/pkg/crypto/key/pub" // "git-indra.lan/indra-labs/indra/pkg/crypto/key/prv"
"git-indra.lan/indra-labs/indra/pkg/interrupt" // "git-indra.lan/indra-labs/indra/pkg/crypto/key/pub"
log2 "git-indra.lan/indra-labs/indra/pkg/proc/log" // "git-indra.lan/indra-labs/indra/pkg/interrupt"
"git-indra.lan/indra-labs/indra/pkg/relay" // log2 "git-indra.lan/indra-labs/indra/pkg/proc/log"
"git-indra.lan/indra-labs/indra/pkg/relay/transport" // "git-indra.lan/indra-labs/indra/pkg/relay"
"git-indra.lan/indra-labs/indra/pkg/util/slice" // "git-indra.lan/indra-labs/indra/pkg/relay/transport"
) // "git-indra.lan/indra-labs/indra/pkg/util/slice"
//)
var ( //
eng *relay.Engine //var (
engineP2P []string // eng *relay.Engine
engineRPC []string // engineP2P []string
) // engineRPC []string
//)
func init() { //
pf := relayCmd.PersistentFlags() //func init() {
pf.StringSliceVarP(&engineP2P, "engineP2P-relay", "P", // pf := relayCmd.PersistentFlags()
[]string{"127.0.0.1:8337", "::1:8337"}, // pf.StringSliceVarP(&engineP2P, "engineP2P-relay", "P",
"address/ports for IPv4 and v6 listeners") // []string{"127.0.0.1:8337", "::1:8337"},
pf.StringSliceVarP(&engineRPC, "relay-control", "r", // "address/ports for IPv4 and v6 listeners")
[]string{"127.0.0.1:8339", "::1:8339"}, // pf.StringSliceVarP(&engineRPC, "relay-control", "r",
"address/ports for IPv4 and v6 listeners") // []string{"127.0.0.1:8339", "::1:8339"},
viper.BindPFlag("engineP2P-relay", seedCommand.PersistentFlags().Lookup("engineP2P-relay")) // "address/ports for IPv4 and v6 listeners")
viper.BindPFlag("relay-control", seedCommand.PersistentFlags().Lookup( // viper.BindPFlag("engineP2P-relay", seedCommand.PersistentFlags().Lookup("engineP2P-relay"))
"relay-control")) // viper.BindPFlag("relay-control", seedCommand.PersistentFlags().Lookup(
rootCmd.AddCommand(relayCmd) // "relay-control"))
} // rootCmd.AddCommand(relayCmd)
//}
var relayCmd = &cobra.Command{ //
Use: "relay", //var relayCmd = &cobra.Command{
Short: "Runs a relay server.", // Use: "relay",
Long: `Runs a server that can be controlled with RPC and CLI interfaces.`, // Short: "Runs a relay server.",
Run: func(cmd *cobra.Command, args []string) { // Long: `Runs a server that can be controlled with RPC and CLI interfaces.`,
// Run: func(cmd *cobra.Command, args []string) {
log2.SetLogLevel(log2.Trace) //
// log2.SetLogLevel(log2.Trace)
log.I.Ln("-- ", log2.App, "("+viper.GetString(""+ //
"network")+") -", // log.I.Ln("-- ", log2.App, "("+viper.GetString(""+
indra.SemVer, "- Network Freedom. --") // "network")+") -",
// indra.SemVer, "- Network Freedom. --")
var e error //
var idPrv *prv.Key // var e error
if idPrv, e = prv.GenerateKey(); check(e) { // var idPrv *prv.Key
return // if idPrv, e = prv.GenerateKey(); check(e) {
} // return
idPub := pub.Derive(idPrv) // }
nTotal := 5 // idPub := pub.Derive(idPrv)
tpt := transport.NewSim(nTotal) // nTotal := 5
addr := slice.GenerateRandomAddrPortIPv4() // tpt := transport.NewSim(nTotal)
nod, _ := relay.NewNode(addr, idPub, idPrv, tpt, 50000, true) // addr := slice.GenerateRandomAddrPortIPv4()
eng, e = relay.NewEngine(tpt, idPrv, nod, nil, 5) // nod, _ := relay.NewNode(addr, idPub, idPrv, tpt, 50000, true)
interrupt.AddHandler(func() { eng.Q() }) // eng, e = relay.NewEngine(tpt, idPrv, nod, nil, 5)
log.D.Ln("starting up server") // interrupt.AddHandler(func() { eng.Q() })
eng.Start() // log.D.Ln("starting up server")
eng.Wait() // eng.Start()
log.I.Ln("fin") // eng.Wait()
return // log.I.Ln("fin")
}, // return
} // },
//}