feat: wasm eventhook

proto/ununifi/eventhook/eventhook.proto

@@ -2,16 +2,15 @@ syntax = "proto3";
 package nftvault.eventhook;
 
 import "gogoproto/gogo.proto";
-import "ununifi/eventhook/params.proto";
 
 option go_package = "github.com/UnUniFi/chain/x/eventhook/types";
 
 message Hook {
   uint64                id               = 1;
-  string                event_type       = 2;
+  string                name             = 2;
   string                contract_address = 3;
-  string                name             = 4;
-  string                git_url          = 5;
+  string                git_url          = 4;
+  string                event_type       = 5;
   repeated KeyValuePair event_attributes = 6;
 }
 

proto/ununifi/eventhook/tx.proto

@@ -1,13 +1,37 @@
 syntax = "proto3";
 package nftvault.eventhook;
 
+import "ununifi/eventhook/eventhook.proto";
 // this line is used by starport scaffolding # proto/tx/import
 
 option go_package = "github.com/UnUniFi/chain/x/eventhook/types";
 
 // Msg defines the Msg service.
 service Msg {
     // this line is used by starport scaffolding # proto/tx/rpc
+    rpc RegisterHook(MsgRegisterHook) returns (MsgRegisterHookResponse);
+    rpc UnregisterHook(MsgUnregisterHook) returns (MsgUnregisterHookResponse);
 }
 
 // this line is used by starport scaffolding # proto/tx/message
+message MsgRegisterHook {
+  string                sender           = 1;
+  string                name             = 2;
+  string                contract_address = 3;
+  string                git_url          = 4;
+  string                event_type       = 5;
+  repeated KeyValuePair event_attributes = 6;
+}
+
+message MsgRegisterHookResponse {
+  uint64 id = 1;
+}
+
+message MsgUnregisterHook {
+  string sender = 1;
+  string event_type = 2;
+  uint64 id = 3;
+}
+
+message MsgUnregisterHookResponse {
+}

x/eventhook/keeper/abci.go

@@ -1,9 +1,13 @@
 package keeper
 
 import (
+	"encoding/json"
+
 	abci "github.com/cometbft/cometbft/abci/types"
 	sdk "github.com/cosmos/cosmos-sdk/types"
 
+	authtypes "github.com/cosmos/cosmos-sdk/x/auth/types"
+
 	"github.com/UnUniFi/chain/x/eventhook/types"
 )
 
@@ -26,8 +30,26 @@ func inspectEventForHook(event sdk.Event, hook types.Hook) bool {
 	return true
 }
 
+type EventHookMsg struct {
+	EventType       string                `json:"event_type"`
+	EventAttributes []*types.KeyValuePair `json:"event_attributes"`
+}
+
 func (k Keeper) CallHook(ctx sdk.Context, event sdk.Event, hook types.Hook) {
-	// TODO: call cosmwasm contract
+	contractAddr := sdk.MustAccAddressFromBech32(hook.ContractAddress)
+	address := authtypes.NewModuleAddress(types.ModuleName)
+	wasmMsg, err := json.Marshal(EventHookMsg{
+		EventType:       hook.EventType,
+		EventAttributes: hook.EventAttributes,
+	})
+	if err != nil {
+		k.Logger(ctx).Debug("failed to marshal wasm msg", "error", err)
+	}
+
+	_, err = k.wasmKeeper.Execute(ctx, contractAddr, address, []byte(wasmMsg), sdk.Coins{})
+	if err != nil {
+		k.Logger(ctx).Debug("failed to execute wasm contract", "error", err)
+	}
 }
 
 func (k Keeper) EndBlock(ctx sdk.Context, _ abci.RequestEndBlock) []abci.ValidatorUpdate {

x/eventhook/keeper/keeper.go

@@ -7,38 +7,34 @@ import (
 	"github.com/cosmos/cosmos-sdk/codec"
 	storetypes "github.com/cosmos/cosmos-sdk/store/types"
 	sdk "github.com/cosmos/cosmos-sdk/types"
-	paramtypes "github.com/cosmos/cosmos-sdk/x/params/types"
 
 	"github.com/UnUniFi/chain/x/eventhook/types"
+
+	wasmtypes "github.com/CosmWasm/wasmd/x/wasm/types"
 )
 
 type (
 	Keeper struct {
-		cdc        codec.BinaryCodec
-		storeKey   storetypes.StoreKey
-		memKey     storetypes.StoreKey
-		paramstore paramtypes.Subspace
+		cdc      codec.BinaryCodec
+		storeKey storetypes.StoreKey
+
+		wasmKeeper wasmtypes.ContractOpsKeeper
+		authority  string
 	}
 )
 
 func NewKeeper(
 	cdc codec.BinaryCodec,
-	storeKey,
-	memKey storetypes.StoreKey,
-	ps paramtypes.Subspace,
-
+	storeKey storetypes.StoreKey,
+	wasmKeeper wasmtypes.ContractOpsKeeper,
+	authority string,
 ) *Keeper {
-	// set KeyTable if it has not already been set
-	if !ps.HasKeyTable() {
-		ps = ps.WithKeyTable(types.ParamKeyTable())
-	}
 
 	return &Keeper{
-
 		cdc:        cdc,
 		storeKey:   storeKey,
-		memKey:     memKey,
-		paramstore: ps,
+		wasmKeeper: wasmKeeper,
+		authority:  authority,
 	}
 }
 

x/eventhook/keeper/msg_server_register_hook.go

@@ -0,0 +1,31 @@
+package keeper
+
+import (
+	"context"
+
+	sdk "github.com/cosmos/cosmos-sdk/types"
+	sdkerrors "github.com/cosmos/cosmos-sdk/types/errors"
+
+	"github.com/UnUniFi/chain/x/eventhook/types"
+)
+
+func (k msgServer) RegisterHook(goCtx context.Context, msg *types.MsgRegisterHook) (*types.MsgRegisterHookResponse, error) {
+	ctx := sdk.UnwrapSDKContext(goCtx)
+
+	if msg.Sender != k.authority {
+		return nil, sdkerrors.Wrap(sdkerrors.ErrUnauthorized, "unauthorized")
+	}
+
+	hook := types.Hook{
+		Name:            msg.Name,
+		ContractAddress: msg.ContractAddress,
+		GitUrl:          msg.GitUrl,
+		EventType:       msg.EventType,
+		EventAttributes: msg.EventAttributes,
+	}
+	id := k.AppendHook(ctx, msg.EventType, hook)
+
+	return &types.MsgRegisterHookResponse{
+		Id: id,
+	}, nil
+}

x/eventhook/keeper/msg_server_unregister_hook.go

@@ -0,0 +1,28 @@
+package keeper
+
+import (
+	"context"
+
+	sdk "github.com/cosmos/cosmos-sdk/types"
+	sdkerrors "github.com/cosmos/cosmos-sdk/types/errors"
+
+	"github.com/UnUniFi/chain/x/eventhook/types"
+)
+
+func (k msgServer) UnregisterHook(goCtx context.Context, msg *types.MsgUnregisterHook) (*types.MsgUnregisterHookResponse, error) {
+	ctx := sdk.UnwrapSDKContext(goCtx)
+
+	if msg.Sender != k.authority {
+		return nil, sdkerrors.Wrap(sdkerrors.ErrUnauthorized, "unauthorized")
+	}
+
+	_, found := k.GetHook(ctx, msg.EventType, msg.Id)
+
+	if !found {
+		return nil, sdkerrors.Wrap(types.ErrHookNotFound, "hook not found")
+	}
+
+	k.RemoveHook(ctx, msg.EventType, msg.Id)
+
+	return &types.MsgUnregisterHookResponse{}, nil
+}

x/eventhook/keeper/params.go

@@ -13,5 +13,5 @@ func (k Keeper) GetParams(ctx sdk.Context) types.Params {
 
 // SetParams set the params
 func (k Keeper) SetParams(ctx sdk.Context, params types.Params) {
-	k.paramstore.SetParamSet(ctx, &params)
+
 }

x/eventhook/types/errors.go

@@ -8,5 +8,5 @@ import (
 
 // x/eventhook module sentinel errors
 var (
-	ErrSample = sdkerrors.Register(ModuleName, 1100, "sample error")
+	ErrHookNotFound = sdkerrors.Register(ModuleName, 1, "hook not found")
 )