Change Pull -> Push

Author: Villaquiranm

examples/gno.land/p/demo/teritori/worx/gno.mod

@@ -0,0 +1 @@
+module gno.land/p/demo/teritori/worx

examples/gno.land/p/demo/teritori/worx/worx.gno

@@ -0,0 +1,22 @@
+package worx
+
+import "std"
+
+
+type Worx struct {
+	Hours int
+	Metadata string
+	Address std.Address
+	Points int
+    Timestamp  int64
+}
+
+func NewWorx(hours int, metadata string, addr std.Address, points int, timestamp int64) *Worx{
+    return &Worx{
+		Hours: hours,
+        Metadata: metadata,
+        Address: addr,
+        Points: points,
+        Timestamp: timestamp,
+	}
+}

examples/gno.land/p/demo/teritori/worx/worxs.gno

@@ -0,0 +1,13 @@
+package worx
+
+type WorxKeeper struct {
+	worxs []*Worx
+}
+
+func (keeper *WorxKeeper) Store(worx *Worx) {
+	keeper.worxs = append(keeper.worxs, worx)
+}
+
+func (keeper *WorxKeeper) Get() []*Worx {
+	return keeper.worxs 
+}

examples/gno.land/r/demo/teritori/providers/gno.mod

@@ -0,0 +1,6 @@
+module gno.land/r/demo/teritori/social_follow
+
+require (
+    gno.land/p/demo/avl v0.0.0-latest
+    gno.land/p/demo/testutils v0.0.0-latest
+)

…ri/worx_aggregator/providers/profile.gno …nd/r/demo/teritori/providers/profile.gnoexamples/gno.land/r/demo/teritori/worx_aggregator/providers/profile.gno renamed to examples/gno.land/r/demo/teritori/providers/profile.gno examples/gno.land/r/demo/teritori/worx_aggregator/providers/profile.gno renamed to examples/gno.land/r/demo/teritori/providers/profile.gno

@@ -0,0 +1,66 @@
+package provider
+
+import (
+	"std"
+	"gno.land/p/demo/avl"
+	"gno.land/p/demo/ufmt"
+	"gno.land/r/demo/teritori/registry"
+)
+
+var profiles avl.Tree
+
+func init() {
+    registry.Register("profiles", RegisterHandler)
+}
+
+
+func Get(dataName string, addr std.Address) interface{} {
+	if dataName != "profile"{
+		panic("invalid dataname")
+	}
+	profile:=getProfile(addr)
+
+	return profile.ToString()
+}
+
+func SupportedTypes() interface{}{
+	return []interface{}{"profile"}
+}
+
+func UpsertProfile(field string, value string){
+	caller := std.GetOrigCaller()
+	profile := getProfile(caller)
+	profile.SetField(field, value)
+	profiles.Set(caller.String(), profile)
+}
+
+
+func getProfile(addr std.Address ) *Profile {
+	profile, found:=profiles.Get(addr.String())
+	if !found{
+		return &Profile{}
+	}
+
+	return profile.(*Profile)
+}
+
+func RegisterHandler(functionName string, args ...interface{}) interface{} {
+	switch functionName {
+	case "get":
+		if len(args) != 2{
+			panic("invalid number of arguments")
+		}
+		dataname := args[0].(string)
+		address := args[1].(std.Address)
+		return Get(dataname,address)
+	case "supportedTypes":
+		if len(args) != 0{
+			panic("invalid number of arguments")
+		}
+		dataname := args[0].(string)
+		address := args[1].(std.Address)
+		return SupportedTypes()
+	default:
+		panic("invalid function name")
+	}
+}

examples/gno.land/r/demo/teritori/providers/profiles.gno

@@ -20,5 +20,14 @@ func TestGetProfile(t *testing.T) {
 	if !strings.Contains(result,"name: Gopher"){
 		t.Error("Bad")
 	}
+}
+
+func TestRegisterHandler(t *testing.T) {
+	user1 := testutils.TestAddress("user1")
+	std.TestSetOrigCaller(user1)
+	supportedTypes := RegisterHandler("supportedTypes")
+	if len(supportedTypes) != 1{
+		t.Error("Supported types is wrong")
+	}
+}
 
-}

…x_aggregator/providers/profiles_test.gno …emo/teritori/providers/profiles_test.gnoexamples/gno.land/r/demo/teritori/worx_aggregator/providers/profiles_test.gno renamed to examples/gno.land/r/demo/teritori/providers/profiles_test.gno examples/gno.land/r/demo/teritori/worx_aggregator/providers/profiles_test.gno renamed to examples/gno.land/r/demo/teritori/providers/profiles_test.gno

@@ -0,0 +1,18 @@
+package provider
+
+import (
+	"std"
+	"gno.land/r/demo/teritori/worx_aggregator"
+	"gno.land/p/demo/rand"
+)
+
+var admin     std.Address
+
+func init() {
+    admin = std.GetOrigCaller()
+}
+
+func RandWorx(addr std.Address){
+	r := rand.New()
+	worx_aggregator.Push(r.Intn(25), "", addr, r.Intn(100), std.GetHeight())
+}

examples/gno.land/r/demo/teritori/providers/worx_dao.gno

@@ -0,0 +1,27 @@
+package registry
+
+import (
+	"gno.land/p/demo/avl"
+	"std"
+)
+
+var callbacks avl.Tree
+type FunctionCB func(functionName string, args ...interface{}) interface{}
+
+func Register(id string, callback FunctionCB){
+	_,exists:=callbacks.Get(id)
+	if exists{
+		panic("A callback already exists for the id")
+	}
+
+	callbacks.Set(id, callback)
+}
+
+func Exec(id string, functionName string, args ...interface{}) interface{} {
+	cb, ok:= callbacks.Get(id)
+	if !ok{
+		panic("Callback not found")
+	}
+	function := cb.(FunctionCB)
+	return function(functionName, args)
+}

examples/gno.land/r/demo/teritori/registry/registry.gno

@@ -0,0 +1,22 @@
+package registry
+
+import (
+	"std"
+	"testing"
+
+	"gno.land/p/demo/avl"
+	"gno.land/p/demo/testutils"
+	"strings"
+)
+
+func TestGetProfile(t *testing.T) {
+	user1 := testutils.TestAddress("user1")
+	std.TestSetOrigCaller(user1)
+	functionID:="SOMEID"
+	var cb functionCB = func(args ...interface{})[]interface{}{
+		//t.Errorf("dataType",dataType)
+		return nil
+	}
+	Register(functionID, cb)
+	Exec(functionID)
+}