mirror of
https://github.com/onsonr/sonr.git
synced 2025-03-10 13:07:09 +00:00
Prad Nukala
807b2e86ec
* feat: add docs and CI workflow for publishing to onsonr.dev * (refactor): Move hway,motr executables to their own repos * feat: simplify devnet and testnet configurations * refactor: update import path for didcrypto package * docs(networks): Add README with project overview, architecture, and community links * refactor: Move network configurations to deploy directory * build: update golang version to 1.23 * refactor: move logger interface to appropriate package * refactor: Move devnet configuration to networks/devnet * chore: improve release process with date variable * (chore): Move Crypto Library * refactor: improve code structure and readability in DID module * feat: integrate Trunk CI checks * ci: optimize CI workflow by removing redundant build jobs --------- Co-authored-by: Darp Alakun <i@prad.nu>
67 lines
1.5 KiB
Go
67 lines
1.5 KiB
Go
package accounts
|
|
|
|
import (
|
|
"fmt"
|
|
"reflect"
|
|
"strings"
|
|
|
|
codectypes "github.com/cosmos/cosmos-sdk/codec/types"
|
|
"github.com/cosmos/gogoproto/proto"
|
|
|
|
"github.com/onsonr/sonr/internal/transaction"
|
|
)
|
|
|
|
// ProtoMsgG is a generic interface for protobuf messages.
|
|
type ProtoMsgG[T any] interface {
|
|
*T
|
|
transaction.Msg
|
|
}
|
|
|
|
type Any = codectypes.Any
|
|
|
|
func FindMessageByName(name string) (transaction.Msg, error) {
|
|
typ := proto.MessageType(name)
|
|
if typ == nil {
|
|
return nil, fmt.Errorf("no message type found for %s", name)
|
|
}
|
|
return reflect.New(typ.Elem()).Interface().(transaction.Msg), nil
|
|
}
|
|
|
|
func MessageName(msg transaction.Msg) string {
|
|
return proto.MessageName(msg)
|
|
}
|
|
|
|
// PackAny packs a proto message into an anypb.Any.
|
|
func PackAny(msg transaction.Msg) (*Any, error) {
|
|
return codectypes.NewAnyWithValue(msg)
|
|
}
|
|
|
|
// UnpackAny unpacks an anypb.Any into a proto message.
|
|
func UnpackAny[T any, PT ProtoMsgG[T]](anyPB *Any) (PT, error) {
|
|
to := new(T)
|
|
return to, UnpackAnyTo(anyPB, PT(to))
|
|
}
|
|
|
|
func UnpackAnyTo(anyPB *Any, to transaction.Msg) error {
|
|
return proto.Unmarshal(anyPB.Value, to)
|
|
}
|
|
|
|
func UnpackAnyRaw(anyPB *Any) (proto.Message, error) {
|
|
split := strings.Split(anyPB.TypeUrl, "/")
|
|
name := split[len(split)-1]
|
|
typ := proto.MessageType(name)
|
|
if typ == nil {
|
|
return nil, fmt.Errorf("no message type found for %s", name)
|
|
}
|
|
to := reflect.New(typ.Elem()).Interface().(proto.Message)
|
|
return to, UnpackAnyTo(anyPB, to)
|
|
}
|
|
|
|
func Merge(a, b transaction.Msg) {
|
|
proto.Merge(a, b)
|
|
}
|
|
|
|
func Equal(a, b transaction.Msg) bool {
|
|
return proto.Equal(a, b)
|
|
}
|