func NewServer(rpc *cosmos.RPC, eventPublisher *publisher.EventPublisher, tokenToRunnerHash *sync.Map, logger tmlog.Logger) *Server {
	return &Server{
		rpc:               rpc,
		eventPublisher:    eventPublisher,
		tokenToRunnerHash: tokenToRunnerHash,
		execInProgress:    &sync.Map{},
		logger:            logger,
	}
}
NewServer creates a new Server.
package runner
import (
	"context"
	"fmt"
	"sync"
	"time"
	sdk "github.com/cosmos/cosmos-sdk/types"
	"github.com/mesg-foundation/engine/cosmos"
	"github.com/mesg-foundation/engine/event/publisher"
	"github.com/mesg-foundation/engine/execution"
	"github.com/mesg-foundation/engine/ext/xstrings"
	"github.com/mesg-foundation/engine/hash"
	"github.com/mesg-foundation/engine/protobuf/acknowledgement"
	"github.com/mesg-foundation/engine/runner"
	executionmodule "github.com/mesg-foundation/engine/x/execution"
	runnermodule "github.com/mesg-foundation/engine/x/runner"
	tmlog "github.com/tendermint/tendermint/libs/log"
	"google.golang.org/grpc/metadata"
)
const CredentialToken = "mesg_credential_token"
type Server struct {
	rpc               *cosmos.RPC
	eventPublisher    *publisher.EventPublisher
	tokenToRunnerHash *sync.Map
	execInProgress    *sync.Map
	logger            tmlog.Logger
}