Merge pull request #199 from Zondax/dev

New release
Zondax · Jun 14, 2024 · 1364081 · 1364081
2 parents ddc8c47 + 23cfd93
commit 1364081
Show file tree

Hide file tree

Showing 92 changed files with 1,122 additions and 59 deletions.
diff --git a/.gitignore b/.gitignore
@@ -152,3 +152,5 @@ fabric.properties
 # Ignore all local history of files
 .history
 .ionide
+
+cmd/tracedl/tracedl
diff --git a/cmd/tracedl/README.md b/cmd/tracedl/README.md
@@ -3,8 +3,8 @@
 Helper tool to download raw logs from a node for testing purposes.
 
 ### Usage
-Replace values in `config.yaml` with desired values.  
 
+Replace values in `config.yaml` with desired values.  
 
 ```
 go build
@@ -18,12 +18,20 @@ go build
 
 Download native logs and store as gzip.  
 
-`./tracedl get --type nativelog --compress gz --height 3897964`
+`./tracedl get --type nativelog --compress gz --height 3897964 --outPath ../../data/heights`
 
 Download eth logs and store as gzip.  
 
-`./tracedl get --type ethlog --compress gz --height 3897964`
+`./tracedl get --type ethlog --compress gz --height 3897964 --outPath ../../data/heights`
 
 Download tipset and store as gzip.  
 
-`./tracedl get --type tipset --compress gz --height 3897964`
+`./tracedl get --type tipset --compress gz --height 3897964 --outPath ../../data/heights`
+
+---
+You can use the `script.sh` to automate the download of traces, native logs, eth logs, and tipsets for specified heights.
+
+1. Open `script.sh` and modify the heights array with the desired heights.
+2. Run the script:
+
+`./script.sh`
diff --git a/cmd/tracedl/config.yaml b/cmd/tracedl/config.yaml
@@ -1,4 +1,4 @@
-  network_name: "mainnet"
+  network_name: "calibration"
   symbol: "fil"
-  node_url: "wss://node-fil-mainnet-next.zondax.ch/rpc/v1"
+  node_url: "wss://node-fil-calibration-next.zondax.ch/rpc/v1"
   node_token: ""
diff --git a/cmd/tracedl/script.sh b/cmd/tracedl/script.sh
@@ -0,0 +1,18 @@
+#!/bin/bash
+
+# Heights to download traces, native logs, eth logs, and tipsets
+heights=(1698055 1576593 1572087 1552242 1352134 1334035 1289201 1258459 1256171)
+
+# Function to download files
+download_files() {
+    local height=$1
+    ./tracedl get --type traces --compress gz --height "$height" --outPath ../../data/heights
+    ./tracedl get --type nativelog --compress gz --height "$height" --outPath ../../data/heights
+    ./tracedl get --type ethlog --compress gz --height "$height" --outPath ../../data/heights
+    ./tracedl get --type tipset --compress gz --height "$height" --outPath ../../data/heights
+}
+
+# Download files for each height
+for height in "${heights[@]}"; do
+    download_files "$height"
+done
diff --git a/data/heights/ethlog_1162295.json.gz b/data/heights/ethlog_1162295.json.gz
diff --git a/data/heights/ethlog_1256171.json.gz b/data/heights/ethlog_1256171.json.gz
diff --git a/data/heights/ethlog_1258459.json.gz b/data/heights/ethlog_1258459.json.gz
diff --git a/data/heights/ethlog_1289201.json.gz b/data/heights/ethlog_1289201.json.gz
diff --git a/data/heights/ethlog_1334035.json.gz b/data/heights/ethlog_1334035.json.gz
diff --git a/data/heights/ethlog_1352134.json.gz b/data/heights/ethlog_1352134.json.gz
diff --git a/data/heights/ethlog_14107.json.gz b/data/heights/ethlog_14107.json.gz
diff --git a/data/heights/ethlog_1467665.json.gz b/data/heights/ethlog_1467665.json.gz
diff --git a/data/heights/ethlog_1552242.json.gz b/data/heights/ethlog_1552242.json.gz
diff --git a/data/heights/ethlog_1572087.json.gz b/data/heights/ethlog_1572087.json.gz
diff --git a/data/heights/ethlog_1576593.json.gz b/data/heights/ethlog_1576593.json.gz
diff --git a/data/heights/ethlog_1698055.json.gz b/data/heights/ethlog_1698055.json.gz
diff --git a/data/heights/ethlog_197673.json.gz b/data/heights/ethlog_197673.json.gz
diff --git a/data/heights/ethlog_38895.json.gz b/data/heights/ethlog_38895.json.gz
diff --git a/data/heights/ethlog_38940.json.gz b/data/heights/ethlog_38940.json.gz
diff --git a/data/heights/ethlog_39035.json.gz b/data/heights/ethlog_39035.json.gz
diff --git a/data/heights/ethlog_47635.json.gz b/data/heights/ethlog_47635.json.gz
diff --git a/data/heights/ethlog_47645.json.gz b/data/heights/ethlog_47645.json.gz
diff --git a/data/heights/ethlog_78689.json.gz b/data/heights/ethlog_78689.json.gz
diff --git a/data/heights/nativelog_1162295.json.gz b/data/heights/nativelog_1162295.json.gz
diff --git a/data/heights/nativelog_1256171.json.gz b/data/heights/nativelog_1256171.json.gz
diff --git a/data/heights/nativelog_1258459.json.gz b/data/heights/nativelog_1258459.json.gz
diff --git a/data/heights/nativelog_1289201.json.gz b/data/heights/nativelog_1289201.json.gz
diff --git a/data/heights/nativelog_1334035.json.gz b/data/heights/nativelog_1334035.json.gz
diff --git a/data/heights/nativelog_1352134.json.gz b/data/heights/nativelog_1352134.json.gz
diff --git a/data/heights/nativelog_14107.json.gz b/data/heights/nativelog_14107.json.gz
diff --git a/data/heights/nativelog_1467665.json.gz b/data/heights/nativelog_1467665.json.gz
diff --git a/data/heights/nativelog_1552242.json.gz b/data/heights/nativelog_1552242.json.gz
diff --git a/data/heights/nativelog_1572087.json.gz b/data/heights/nativelog_1572087.json.gz
diff --git a/data/heights/nativelog_1576593.json.gz b/data/heights/nativelog_1576593.json.gz
diff --git a/data/heights/nativelog_1698055.json.gz b/data/heights/nativelog_1698055.json.gz
diff --git a/data/heights/nativelog_197673.json.gz b/data/heights/nativelog_197673.json.gz
diff --git a/data/heights/nativelog_38895.json.gz b/data/heights/nativelog_38895.json.gz
diff --git a/data/heights/nativelog_38940.json.gz b/data/heights/nativelog_38940.json.gz
diff --git a/data/heights/nativelog_39035.json.gz b/data/heights/nativelog_39035.json.gz
diff --git a/data/heights/nativelog_47635.json.gz b/data/heights/nativelog_47635.json.gz
diff --git a/data/heights/nativelog_47645.json.gz b/data/heights/nativelog_47645.json.gz
diff --git a/data/heights/nativelog_78689.json.gz b/data/heights/nativelog_78689.json.gz
diff --git a/data/heights/tipset_1162295.json.gz b/data/heights/tipset_1162295.json.gz
diff --git a/data/heights/tipset_1256171.json.gz b/data/heights/tipset_1256171.json.gz
diff --git a/data/heights/tipset_1258459.json.gz b/data/heights/tipset_1258459.json.gz
diff --git a/data/heights/tipset_1289201.json.gz b/data/heights/tipset_1289201.json.gz
diff --git a/data/heights/tipset_1334035.json.gz b/data/heights/tipset_1334035.json.gz
diff --git a/data/heights/tipset_1352134.json.gz b/data/heights/tipset_1352134.json.gz
diff --git a/data/heights/tipset_14107.json.gz b/data/heights/tipset_14107.json.gz
diff --git a/data/heights/tipset_1467665.json.gz b/data/heights/tipset_1467665.json.gz
diff --git a/data/heights/tipset_1552242.json.gz b/data/heights/tipset_1552242.json.gz
diff --git a/data/heights/tipset_1572087.json.gz b/data/heights/tipset_1572087.json.gz
diff --git a/data/heights/tipset_1576593.json.gz b/data/heights/tipset_1576593.json.gz
diff --git a/data/heights/tipset_1698055.json.gz b/data/heights/tipset_1698055.json.gz
diff --git a/data/heights/tipset_197673.json.gz b/data/heights/tipset_197673.json.gz
diff --git a/data/heights/tipset_38895.json.gz b/data/heights/tipset_38895.json.gz
diff --git a/data/heights/tipset_38940.json.gz b/data/heights/tipset_38940.json.gz
diff --git a/data/heights/tipset_39035.json.gz b/data/heights/tipset_39035.json.gz
diff --git a/data/heights/tipset_47635.json.gz b/data/heights/tipset_47635.json.gz
diff --git a/data/heights/tipset_47645.json.gz b/data/heights/tipset_47645.json.gz
diff --git a/data/heights/tipset_78689.json.gz b/data/heights/tipset_78689.json.gz
diff --git a/data/heights/traces_1162295.json.gz b/data/heights/traces_1162295.json.gz
diff --git a/data/heights/traces_1256171.json.gz b/data/heights/traces_1256171.json.gz
diff --git a/data/heights/traces_1258459.json.gz b/data/heights/traces_1258459.json.gz
diff --git a/data/heights/traces_1289201.json.gz b/data/heights/traces_1289201.json.gz
diff --git a/data/heights/traces_1334035.json.gz b/data/heights/traces_1334035.json.gz
diff --git a/data/heights/traces_1352134.json.gz b/data/heights/traces_1352134.json.gz
diff --git a/data/heights/traces_14107.json.gz b/data/heights/traces_14107.json.gz
diff --git a/data/heights/traces_1467665.json.gz b/data/heights/traces_1467665.json.gz
diff --git a/data/heights/traces_1552242.json.gz b/data/heights/traces_1552242.json.gz
diff --git a/data/heights/traces_1572087.json.gz b/data/heights/traces_1572087.json.gz
diff --git a/data/heights/traces_1576593.json.gz b/data/heights/traces_1576593.json.gz
diff --git a/data/heights/traces_1698055.json.gz b/data/heights/traces_1698055.json.gz
diff --git a/data/heights/traces_197673.json.gz b/data/heights/traces_197673.json.gz
diff --git a/data/heights/traces_38895.json.gz b/data/heights/traces_38895.json.gz
diff --git a/data/heights/traces_38940.json.gz b/data/heights/traces_38940.json.gz
diff --git a/data/heights/traces_39035.json.gz b/data/heights/traces_39035.json.gz
diff --git a/data/heights/traces_47635.json.gz b/data/heights/traces_47635.json.gz
diff --git a/data/heights/traces_47645.json.gz b/data/heights/traces_47645.json.gz
diff --git a/data/heights/traces_78689.json.gz b/data/heights/traces_78689.json.gz
diff --git a/factory.go b/factory.go
@@ -8,6 +8,7 @@ import (
 
 	"github.com/filecoin-project/go-address"
 	"github.com/filecoin-project/go-state-types/big"
+	"github.com/filecoin-project/go-state-types/manifest"
 	types2 "github.com/filecoin-project/lotus/chain/types"
 	"github.com/google/uuid"
 	"github.com/zondax/fil-parser/actors/cache"
@@ -40,6 +41,7 @@ type Parser interface {
 	NodeVersionsSupported() []string
 	ParseTransactions(ctx context.Context, txsData types.TxsData) (*types.TxsParsedResult, error)
 	ParseNativeEvents(ctx context.Context, eventsData types.EventsData) (*types.EventsParsedResult, error)
+	ParseMultisigEvents(ctx context.Context, multisigTxs []*types.Transaction, tipsetCid string, tipsetKey types2.TipSetKey) (*types.MultisigEvents, error)
 	ParseEthLogs(ctx context.Context, eventsData types.EventsData) (*types.EventsParsedResult, error)
 	GetBaseFee(traces []byte, tipset *types.ExtendedTipSet) (uint64, error)
 	IsNodeVersionSupported(ver string) bool
@@ -141,6 +143,14 @@ func (p *FilecoinParser) ParseEthLogs(ctx context.Context, eventsData types.Even
 	return parsedResult, nil
 }
 
+func (p *FilecoinParser) ParseMultisigEvents(ctx context.Context, txs []*types.Transaction, tipsetCid string, tipsetKey types2.TipSetKey) (*types.MultisigEvents, error) {
+	multisigTxs, err := p.Helper.FilterTxsByActorType(ctx, txs, manifest.MultisigKey, tipsetKey)
+	if err != nil {
+		return nil, err
+	}
+	return p.parserV2.ParseMultisigEvents(ctx, multisigTxs, tipsetCid, tipsetKey)
+}
+
 func (p *FilecoinParser) translateParserVersionFromMetadata(metadata types.BlockMetadata) (string, error) {
 	switch {
 	// The empty string is for backwards compatibility with older traces versions

diff --git a/go.mod b/go.mod
@@ -18,7 +18,7 @@ require (
 	github.com/orcaman/concurrent-map v1.0.0
 	github.com/spf13/cobra v1.8.0
 	github.com/stretchr/testify v1.9.0
-	github.com/whyrusleeping/cbor-gen v0.1.1
+	github.com/whyrusleeping/cbor-gen v0.1.2
 	github.com/zondax/golem v0.14.1
 	github.com/zondax/rosetta-filecoin-lib v1.2603.0
 	github.com/zondax/znats v0.1.1
@@ -60,7 +60,7 @@ require (
 	github.com/filecoin-project/go-hamt-ipld v0.1.5 // indirect
 	github.com/filecoin-project/go-hamt-ipld/v2 v2.0.0 // indirect
 	github.com/filecoin-project/go-hamt-ipld/v3 v3.1.0 // indirect
-	github.com/filecoin-project/go-jsonrpc v0.4.0
+	github.com/filecoin-project/go-jsonrpc v0.5.0
 	github.com/filecoin-project/go-padreader v0.0.1 // indirect
 	github.com/filecoin-project/go-statemachine v1.0.3 // indirect
 	github.com/filecoin-project/go-statestore v0.2.0 // indirect
@@ -121,7 +121,7 @@ require (
 	github.com/jinzhu/inflection v1.0.0 // indirect
 	github.com/jinzhu/now v1.1.5 // indirect
 	github.com/jpillora/backoff v1.0.0 // indirect
-	github.com/klauspost/compress v1.17.8
+	github.com/klauspost/compress v1.17.9
 	github.com/klauspost/cpuid/v2 v2.2.7 // indirect
 	github.com/libp2p/go-buffer-pool v0.1.0 // indirect
 	github.com/libp2p/go-cidranger v1.1.0 // indirect
@@ -149,7 +149,7 @@ require (
 	github.com/multiformats/go-multiaddr v0.12.3 // indirect
 	github.com/multiformats/go-multiaddr-dns v0.3.1 // indirect
 	github.com/multiformats/go-multibase v0.2.0 // indirect
-	github.com/multiformats/go-multicodec v0.9.0
+	github.com/multiformats/go-multicodec v0.9.0 // indirect
 	github.com/multiformats/go-multihash v0.2.3 // indirect
 	github.com/multiformats/go-multistream v0.5.0 // indirect
 	github.com/multiformats/go-varint v0.0.7 // indirect

diff --git a/go.sum b/go.sum
@@ -139,8 +139,8 @@ github.com/filecoin-project/go-hamt-ipld/v2 v2.0.0/go.mod h1:7aWZdaQ1b16BVoQUYR+
 github.com/filecoin-project/go-hamt-ipld/v3 v3.0.1/go.mod h1:gXpNmr3oQx8l3o7qkGyDjJjYSRX7hp/FGOStdqrWyDI=
 github.com/filecoin-project/go-hamt-ipld/v3 v3.1.0 h1:rVVNq0x6RGQIzCo1iiJlGFm9AGIZzeifggxtKMU7zmI=
 github.com/filecoin-project/go-hamt-ipld/v3 v3.1.0/go.mod h1:bxmzgT8tmeVQA1/gvBwFmYdT8SOFUwB3ovSUfG1Ux0g=
-github.com/filecoin-project/go-jsonrpc v0.4.0 h1:W6kEt8YCQGUZpmvDOvLF+vKwRhrLPBN+kaSHYLEio+c=
-github.com/filecoin-project/go-jsonrpc v0.4.0/go.mod h1:/n/niXcS4ZQua6i37LcVbY1TmlJR0UIK9mDFQq2ICek=
+github.com/filecoin-project/go-jsonrpc v0.5.0 h1:6PZghgMaM9wSjlhxkDD+YgZ+oucBUIkJOfVc7SdQBTE=
+github.com/filecoin-project/go-jsonrpc v0.5.0/go.mod h1:/n/niXcS4ZQua6i37LcVbY1TmlJR0UIK9mDFQq2ICek=
 github.com/filecoin-project/go-padreader v0.0.1 h1:8h2tVy5HpoNbr2gBRr+WD6zV6VD6XHig+ynSGJg8ZOs=
 github.com/filecoin-project/go-padreader v0.0.1/go.mod h1:VYVPJqwpsfmtoHnAmPx6MUwmrK6HIcDqZJiuZhtmfLQ=
 github.com/filecoin-project/go-state-types v0.0.0-20200903145444-247639ffa6ad/go.mod h1:IQ0MBPnonv35CJHtWSN3YY1Hz2gkPru1Q9qoaYLxx9I=
@@ -472,8 +472,8 @@ github.com/kisielk/errcheck v1.2.0/go.mod h1:/BMXB+zMLi60iA8Vv6Ksmxu/1UDYcXs4uQL
 github.com/kisielk/errcheck v1.5.0/go.mod h1:pFxgyoBC7bSaBwPgfKdkLd5X25qrDl4LWUI2bnpBCr8=
 github.com/kisielk/gotool v1.0.0/go.mod h1:XhKaO+MFFWcvkIS/tQcRk01m1F5IRFswLeQ+oQHNcck=
 github.com/kkdai/bstream v0.0.0-20161212061736-f391b8402d23/go.mod h1:J+Gs4SYgM6CZQHDETBtE9HaSEkGmuNXF86RwHhHUvq4=
-github.com/klauspost/compress v1.17.8 h1:YcnTYrq7MikUT7k0Yb5eceMmALQPYBW/Xltxn0NAMnU=
-github.com/klauspost/compress v1.17.8/go.mod h1:Di0epgTjJY877eYKx5yC51cX2A2Vl2ibi7bDH9ttBbw=
+github.com/klauspost/compress v1.17.9 h1:6KIumPrER1LHsvBVuDa0r5xaG0Es51mhhB9BQB2qeMA=
+github.com/klauspost/compress v1.17.9/go.mod h1:Di0epgTjJY877eYKx5yC51cX2A2Vl2ibi7bDH9ttBbw=
 github.com/klauspost/cpuid/v2 v2.0.4/go.mod h1:FInQzS24/EEf25PyTYn52gqo7WaD8xa0213Md/qVLRg=
 github.com/klauspost/cpuid/v2 v2.0.9/go.mod h1:FInQzS24/EEf25PyTYn52gqo7WaD8xa0213Md/qVLRg=
 github.com/klauspost/cpuid/v2 v2.2.7 h1:ZWSB3igEs+d0qvnxR/ZBzXVmxkgt8DdzP6m9pfuVLDM=
@@ -834,8 +834,8 @@ github.com/whyrusleeping/cbor-gen v0.0.0-20200806213330-63aa96ca5488/go.mod h1:f
 github.com/whyrusleeping/cbor-gen v0.0.0-20200810223238-211df3b9e24c/go.mod h1:fgkXqYy7bV2cFeIEOkVTZS/WjXARfBqSH6Q2qHL33hQ=
 github.com/whyrusleeping/cbor-gen v0.0.0-20200812213548-958ddffe352c/go.mod h1:fgkXqYy7bV2cFeIEOkVTZS/WjXARfBqSH6Q2qHL33hQ=
 github.com/whyrusleeping/cbor-gen v0.0.0-20210118024343-169e9d70c0c2/go.mod h1:fgkXqYy7bV2cFeIEOkVTZS/WjXARfBqSH6Q2qHL33hQ=
-github.com/whyrusleeping/cbor-gen v0.1.1 h1:eKfcJIoxivjMtwfCfmJAqSF56MHcWqyIScXwaC1VBgw=
-github.com/whyrusleeping/cbor-gen v0.1.1/go.mod h1:pM99HXyEbSQHcosHc0iW7YFmwnscr+t9Te4ibko05so=
+github.com/whyrusleeping/cbor-gen v0.1.2 h1:WQFlrPhpcQl+M2/3dP5cvlTLWPVsL6LGBb9jJt6l/cA=
+github.com/whyrusleeping/cbor-gen v0.1.2/go.mod h1:pM99HXyEbSQHcosHc0iW7YFmwnscr+t9Te4ibko05so=
 github.com/whyrusleeping/chunker v0.0.0-20181014151217-fe64bd25879f h1:jQa4QT2UP9WYv2nzyawpKMOCl+Z/jW7djv2/J50lj9E=
 github.com/whyrusleeping/chunker v0.0.0-20181014151217-fe64bd25879f/go.mod h1:p9UJB6dDgdPgMJZs7UjUOdulKyRr9fqkS+6JKAInPy8=
 github.com/whyrusleeping/go-keyspace v0.0.0-20160322163242-5b898ac5add1 h1:EKhdznlJHPMoKr0XTrX+IlJs1LH3lyx2nfr1dOlZ79k=

diff --git a/parser/constants.go b/parser/constants.go
@@ -177,6 +177,8 @@ const (
 	MethodBurnFromExported                    = "BurnFromExported"                    // MethodsDatacap
 	MethodAllowanceExported                   = "AllowanceExported"                   // MethodsDatacap
 	MethodGranularityExported                 = "GranularityExported"                 // MethodsDatacap
+
+	MethodUnknown = "Unknown" // Common
 )
 
 // SupportedOperations operations that will be parsed

diff --git a/parser/helper/helpers.go b/parser/helper/helpers.go
@@ -3,6 +3,7 @@ package helper
 import (
 	"context"
 	"errors"
+	"strings"
 
 	"github.com/filecoin-project/go-address"
 	"github.com/filecoin-project/go-state-types/abi"
@@ -172,3 +173,45 @@ func (h *Helper) GetMethodName(msg *parser.LotusMessage, height int64, key filTy
 func (h *Helper) GetEVMSelectorSig(ctx context.Context, selectorID string) (string, error) {
 	return h.actorCache.GetEVMSelectorSig(ctx, selectorID)
 }
+
+func (h *Helper) FilterTxsByActorType(ctx context.Context, txs []*types.Transaction, actorType string, tipsetKey filTypes.TipSetKey) ([]*types.Transaction, error) {
+	var result []*types.Transaction
+	for _, tx := range txs {
+		addrTo, err := address.NewFromString(tx.TxTo)
+		if err != nil {
+			h.logger.Sugar().Errorf("could not parse address. Err: %s", err)
+			continue
+		}
+		addrFrom, err := address.NewFromString(tx.TxFrom)
+		if err != nil {
+			h.logger.Sugar().Errorf("could not parse address. Err: %s", err)
+			continue
+		}
+
+		isType, err := h.isAnyAddressOfType(ctx, []address.Address{addrTo, addrFrom}, int64(tx.Height), tipsetKey, actorType)
+		if err != nil {
+			h.logger.Sugar().Errorf("could not get actor type from address. Err: %s", err)
+			continue
+		}
+		if !isType {
+			continue
+		}
+
+		result = append(result, tx)
+	}
+
+	return result, nil
+}
+
+func (h *Helper) isAnyAddressOfType(_ context.Context, addresses []address.Address, height int64, key filTypes.TipSetKey, actorType string) (bool, error) {
+	for _, addr := range addresses {
+		actorName, err := h.GetActorNameFromAddress(addr, height, key)
+		if err != nil {
+			return false, err
+		}
+		if strings.EqualFold(actorName, actorType) {
+			return true, nil
+		}
+	}
+	return false, nil
+}
diff --git a/parser/v1/parser.go b/parser/v1/parser.go
@@ -17,6 +17,7 @@ import (
 	"github.com/zondax/fil-parser/parser/helper"
 	typesV1 "github.com/zondax/fil-parser/parser/v1/types"
 	"github.com/zondax/fil-parser/tools"
+	multisigTools "github.com/zondax/fil-parser/tools/multisig"
 	"github.com/zondax/fil-parser/types"
 	"go.uber.org/zap"
 )
@@ -26,19 +27,21 @@ const Version = "v1"
 var NodeVersionsSupported = []string{"v1.21", "v1.22"}
 
 type Parser struct {
-	actorParser      *actors.ActorParser
-	addresses        *types.AddressInfoMap
-	txCidEquivalents []types.TxCidTranslation
-	helper           *helper.Helper
-	logger           *zap.Logger
+	actorParser            *actors.ActorParser
+	addresses              *types.AddressInfoMap
+	txCidEquivalents       []types.TxCidTranslation
+	helper                 *helper.Helper
+	logger                 *zap.Logger
+	multisigEventGenerator multisigTools.EventGenerator
 }
 
 func NewParser(helper *helper.Helper, logger *zap.Logger) *Parser {
 	return &Parser{
-		actorParser: actors.NewActorParser(helper, logger),
-		addresses:   types.NewAddressInfoMap(),
-		helper:      helper,
-		logger:      logger2.GetSafeLogger(logger),
+		actorParser:            actors.NewActorParser(helper, logger),
+		addresses:              types.NewAddressInfoMap(),
+		helper:                 helper,
+		logger:                 logger2.GetSafeLogger(logger),
+		multisigEventGenerator: multisigTools.NewEventGenerator(helper, logger2.GetSafeLogger(logger)),
 	}
 }
 
@@ -165,6 +168,10 @@ func (p *Parser) ParseTransactions(ctx context.Context, txsData types.TxsData) (
 	}, nil
 }
 
+func (p *Parser) ParseMultisigEvents(ctx context.Context, multisigTxs []*types.Transaction, tipsetCid string, tipsetKey filTypes.TipSetKey) (*types.MultisigEvents, error) {
+	return nil, errors.New("unimplimented")
+}
+
 func (p *Parser) ParseNativeEvents(_ context.Context, _ types.EventsData) (*types.EventsParsedResult, error) {
 	return nil, errors.New("unimplimented")
 }

diff --git a/parser/v2/parser.go b/parser/v2/parser.go
@@ -16,6 +16,7 @@ import (
 	typesV2 "github.com/zondax/fil-parser/parser/v2/types"
 	"github.com/zondax/fil-parser/tools"
 	eventTools "github.com/zondax/fil-parser/tools/events"
+	multisigTools "github.com/zondax/fil-parser/tools/multisig"
 	"github.com/zondax/fil-parser/types"
 
 	"github.com/bytedance/sonic"
@@ -30,19 +31,21 @@ const Version = "v2"
 var NodeVersionsSupported = []string{"v1.23", "v1.24", "v1.25", "v1.26"}
 
 type Parser struct {
-	actorParser      *actors.ActorParser
-	addresses        *types.AddressInfoMap
-	txCidEquivalents []types.TxCidTranslation
-	helper           *helper.Helper
-	logger           *zap.Logger
+	actorParser            *actors.ActorParser
+	addresses              *types.AddressInfoMap
+	txCidEquivalents       []types.TxCidTranslation
+	helper                 *helper.Helper
+	logger                 *zap.Logger
+	multisigEventGenerator multisigTools.EventGenerator
 }
 
 func NewParser(helper *helper.Helper, logger *zap.Logger) *Parser {
 	return &Parser{
-		actorParser: actors.NewActorParser(helper, logger),
-		addresses:   types.NewAddressInfoMap(),
-		helper:      helper,
-		logger:      logger2.GetSafeLogger(logger),
+		actorParser:            actors.NewActorParser(helper, logger),
+		addresses:              types.NewAddressInfoMap(),
+		helper:                 helper,
+		logger:                 logger2.GetSafeLogger(logger),
+		multisigEventGenerator: multisigTools.NewEventGenerator(helper, logger2.GetSafeLogger(logger)),
 	}
 }
 
@@ -179,6 +182,10 @@ func (p *Parser) ParseEthLogs(_ context.Context, eventsData types.EventsData) (*
 	return &types.EventsParsedResult{EVMEvents: len(parsed), ParsedEvents: parsed}, nil
 }
 
+func (p *Parser) ParseMultisigEvents(ctx context.Context, multisigTxs []*types.Transaction, tipsetCid string, tipsetKey filTypes.TipSetKey) (*types.MultisigEvents, error) {
+	return p.multisigEventGenerator.GenerateMultisigEvents(ctx, multisigTxs, tipsetCid, tipsetKey)
+}
+
 func (p *Parser) GetBaseFee(traces []byte, tipset *types.ExtendedTipSet) (uint64, error) {
 	// Unmarshal into vComputeState
 	computeState := &typesV2.ComputeStateOutputV2{}