EquilibrateIT/go_anvil-client
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

modified: functions.go

Browse Source 
OpenSSH, OpenHTTP functions
modified:   main.go
	Client instantiation work
This commit is contained in:
Mike Holloway 2024-08-29 03:15:13 -04:00
parent f8385e173d
commit ef318b10e5
2 changed files with 41 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
functions.go
View File

@ -2,14 +2,39 @@ package main
import (
"database/sql"
"log"
"net/http"
"github.com/uptrace/bun"
"github.com/uptrace/bun/dialect/pgdialect"
"github.com/uptrace/bun/driver/pgdriver"
"golang.org/x/crypto/ssh"
"golang.org/x/crypto/ssh/knownhosts"
)
func OpenDB(dsn string) PostgresClient {
func OpenDB(dsn string) *bun.DB {
sqldb := sql.OpenDB(pgdriver.NewConnector(pgdriver.WithDSN(dsn)))
r := PostgresClient{bun.NewDB(sqldb, pgdialect.New())}
r := bun.NewDB(sqldb, pgdialect.New())
return r
}
func OpenHTTP() *http.Client {
var cli *http.Client
return cli
}
func OpenSSH(dsn string) *ssh.Client {
knownHosts, _ := knownhosts.New("/home/m00t/.ssh/known_hosts")
config := &ssh.ClientConfig{
User: "admin",
Auth: []ssh.AuthMethod{
ssh.Password("Initial1"),
},
HostKeyCallback: knownHosts,
}
client, err := ssh.Dial("tcp", dsn, config)
if err != nil {
log.Fatal("Failed to dial: ", err)
}
defer client.Close()
return client
}

22
main.go
View File

@ -1,12 +1,7 @@
package main
import (
"database/sql"
"fmt"
"github.com/uptrace/bun"
"github.com/uptrace/bun/dialect/pgdialect"
"github.com/uptrace/bun/driver/pgdriver"
)
// Tofu Provider is the goal
@ -23,14 +18,25 @@ import (
func main() {
var (
pgdsn = "postgres://postgres:Initial1@localhost:15432/anvil?sslmode=disable"
pgdsn = "postgres://postgres:Initial1@localhost:15432/anvil?sslmode=disable"
sshdsn = "192.168.1.165:22"
// webdsn = "http://192.168.1.165"
)
anvil := new(Anvil)
anvil.AddStriker(Striker{})
// anvil.Strikers[0].SetFQDN("mh-striker01.libre.audio")
e := &PostgresClient{bun.NewDB(sql.OpenDB(pgdriver.NewConnector(pgdriver.WithDSN(pgdsn))), pgdialect.New())}
pge := &PostgresClient{OpenDB(pgdsn)}
anvil.Strikers[0].AddEndpoint(pge)
webe := &WebClient{OpenHTTP()}
anvil.Strikers[0].AddEndpoint(webe)
sshe := &SSHClient{OpenSSH(sshdsn)}
anvil.Strikers[0].AddEndpoint(sshe)
anvil.Strikers[0].AddEndpoint(e)
fmt.Printf("Strikers[0].Endpoints.PostgresClient = %s.\n", anvil.Strikers[0].Endpoints.PostgresClient)
fmt.Printf("Strikers[0].Endpoints.WebClient = %s.\n", anvil.Strikers[0].Endpoints.WebClient)
fmt.Printf("Strikers[0].Endpoints.SSHClient = %s.\n", anvil.Strikers[0].Endpoints.SSHClient)
// fmt.Printf("Strikers[0].FQDN = %s.\n", anvil.Strikers[0].FQDN)
}