From fb270a1b668e92bbcf654e23bdb02a3746a6f984 Mon Sep 17 00:00:00 2001 From: Christopher Talib Date: Wed, 4 Mar 2020 16:34:14 +0100 Subject: [PATCH] Mutating data without needing to get it back --- plugins/certstream.go | 34 ++++++++++++++++------------------ 1 file changed, 16 insertions(+), 18 deletions(-) diff --git a/plugins/certstream.go b/plugins/certstream.go index 99dca5d..786a093 100644 --- a/plugins/certstream.go +++ b/plugins/certstream.go @@ -3,7 +3,6 @@ package plugins import ( "context" "encoding/json" - "fmt" "sync" "github.com/CaliDog/certstream-go" @@ -89,26 +88,25 @@ func (c *CertStreamPlugin) doRun(graphClient *dgo.Dgraph) { logrus.Fatal(err) } mu.SetJson = marshaled - assigned, err := graphClient.NewTxn().Mutate(context.Background(), mu) + _, err = graphClient.NewTxn().Mutate(context.Background(), mu) if err != nil { logrus.Fatal(err) } - variables := map[string]string{"$id": assigned.Uids[mainNode.ID]} - q := `query Node($id: string){ -node(func: uid($id)) { -uid -ID -Type -Data -Created -Modified -} -}` - resp, err := graphClient.NewTxn().QueryWithVars(context.Background(), q, variables) - if err != nil { - logrus.Fatal(err) - } - fmt.Println(resp) + // variables := map[string]string{"$id": assigned.Uids[mainNode.ID]} + // q := `query Node($id: string){ + // node(func: uid($id)) { + // uid + // ID + // type + // data + // dreated + // modified + // } + // }` + // _, err := graphClient.NewTxn().QueryWithVars(context.Background(), q, variables) + // if err != nil { + // logrus.Fatal(err) + // } } }