-
Notifications
You must be signed in to change notification settings - Fork 38
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
12 changed files
with
220 additions
and
47 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,86 @@ | ||
| package main | ||
|
|
||
| import ( | ||
| "context" | ||
| "github.com/ipfs/go-cid" | ||
| "github.com/myxtype/filecoin-client" | ||
| "github.com/myxtype/filecoin-client/types" | ||
| ) | ||
|
|
||
| // 简单的充值逻辑 | ||
| func main() { | ||
| client := filecoin.New("https://1lB5G4SmGdSTikOo7l6vYlsktdd:b58884915362a99b4fc18c2bf8af8358@filecoin.infura.io") | ||
|
|
||
| job := &RechargeFilJob{} | ||
|
|
||
| // 处理区块652243 | ||
| job.mapHeight(client, 652243) | ||
|
|
||
| // todo | ||
| } | ||
|
|
||
| // 充值处理任务 | ||
| type RechargeFilJob struct { | ||
| } | ||
|
|
||
| func (job *RechargeFilJob) mapHeight(c *filecoin.Client, height int64) error { | ||
| ts, err := c.ChainGetTipSetByHeight(context.Background(), height, nil) | ||
| if err != nil { | ||
| return err | ||
| } | ||
| for _, n := range ts.Cids { | ||
| bm, err := c.ChainGetBlockMessages(context.Background(), n) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| // BlsMessages | ||
| for _, msg := range bm.BlsMessages { | ||
| err := job.handleMessage(msg.Cid(), msg) | ||
| if err != nil { | ||
| return err | ||
| } | ||
| } | ||
|
|
||
| // SecpkMessages | ||
| for _, msg := range bm.SecpkMessages { | ||
| err := job.handleSecpkMessage(msg) | ||
| if err != nil { | ||
| return err | ||
| } | ||
| } | ||
| } | ||
| return nil | ||
| } | ||
|
|
||
| func (job *RechargeFilJob) handleSecpkMessage(msg *types.SignedMessage) error { | ||
| return job.handleMessage(msg.Cid(), msg.Message) | ||
| } | ||
|
|
||
| func (job *RechargeFilJob) handleMessage(msgCid cid.Cid, msg *types.Message) error { | ||
| // 发送交易并且值大于0 | ||
| if msg.Method != 0 || msg.Value.IsZero() { | ||
| return nil | ||
| } | ||
|
|
||
| value := filecoin.ToFil(msg.Value) | ||
|
|
||
| println(msgCid.String(), value.String()) | ||
|
|
||
| // todo | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
| // 结果如下： | ||
| /* | ||
| bafy2bzacedv5q3nam6icb4qwuftxw3nazn33iu3vd6zvwkcr6ljgfbkjmow62 5.002 | ||
| bafy2bzacecb52i5423svvxgyfz7dvfvl4wssi4vraiyilkckomytplvbtxbgo 1.676583814823873898 | ||
| bafy2bzaceabqawv4iwnjn4xusseqgxenprq36w6xxyveryflr3e7dpfmroprw 9.999853889870997446 | ||
| bafy2bzacedvdkwm7js4qjgzyiqdzcoy3kgf7fdooowzbchj4rnzlw6wuk4bp6 3.978744820695744384 | ||
| bafy2bzaced7tmalo62e74xsveb2ahmb6metcb6kwo5jq35neic3xlzwphm7am 3100 | ||
| bafy2bzacecdykvlsswqlrkgohqsvr4cwv7rph4hzabbfg2p4iqixcm3iv62ly 220 | ||
| bafy2bzaceakfahxbzfvson5ylx7nsa2velqfy37xmdz5bycyxds4rsyefittu 220 | ||
| bafy2bzacec3rlx3yoezxzpnzyzehu5kenyjoso2gogkkpiw5wwbjv7hcjmy5y 9.99 | ||
| bafy2bzacebrnc5tactfdeddxmpiyy5wppfc4gyc45zscwymn4r2pm4uwmasx4 17.90844787 | ||
| */ |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,78 @@ | ||
| package types | ||
|
|
||
| import ( | ||
| "bytes" | ||
| "github.com/filecoin-project/go-state-types/abi" | ||
| "github.com/filecoin-project/go-state-types/crypto" | ||
| block "github.com/ipfs/go-block-format" | ||
| "github.com/ipfs/go-cid" | ||
| cbg "github.com/whyrusleeping/cbor-gen" | ||
| "io" | ||
| ) | ||
|
|
||
| type SignedMessage struct { | ||
| Message *Message `json:"Message"` | ||
| Signature *crypto.Signature `json:"Signature"` | ||
| } | ||
|
|
||
| func (sm *SignedMessage) Cid() cid.Cid { | ||
| if sm.Signature.Type == crypto.SigTypeBLS { | ||
| return sm.Message.Cid() | ||
| } | ||
|
|
||
| sb, err := sm.ToStorageBlock() | ||
| if err != nil { | ||
| panic(err) | ||
| } | ||
|
|
||
| return sb.Cid() | ||
| } | ||
|
|
||
| func (sm *SignedMessage) ToStorageBlock() (block.Block, error) { | ||
| if sm.Signature.Type == crypto.SigTypeBLS { | ||
| return sm.Message.ToStorageBlock() | ||
| } | ||
|
|
||
| data, err := sm.Serialize() | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
|
|
||
| c, err := abi.CidBuilder.Sum(data) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
|
|
||
| return block.NewBlockWithCid(data, c) | ||
| } | ||
|
|
||
| func (sm *SignedMessage) Serialize() ([]byte, error) { | ||
| buf := new(bytes.Buffer) | ||
| if err := sm.MarshalCBOR(buf); err != nil { | ||
| return nil, err | ||
| } | ||
| return buf.Bytes(), nil | ||
| } | ||
|
|
||
| var lengthBufSignedMessage = []byte{130} | ||
|
|
||
| func (t *SignedMessage) MarshalCBOR(w io.Writer) error { | ||
| if t == nil { | ||
| _, err := w.Write(cbg.CborNull) | ||
| return err | ||
| } | ||
| if _, err := w.Write(lengthBufSignedMessage); err != nil { | ||
| return err | ||
| } | ||
|
|
||
| // t.Message (types.Message) (struct) | ||
| if err := t.Message.MarshalCBOR(w); err != nil { | ||
| return err | ||
| } | ||
|
|
||
| // t.Signature (crypto.Signature) (struct) | ||
| if err := t.Signature.MarshalCBOR(w); err != nil { | ||
| return err | ||
| } | ||
| return nil | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.