精通 Filecoin：Lotus 真實數據處理之 Client 初始化_ENT:StakedZEN

前言

隨著Filecoin/Lotus公鏈越來越接近啟動，真實數據的處理也越來越重要了。根據官方的設計，真實數據的有效算力是自填自挖算力的10倍，鑒于真實數據的比重是如此之在，從今天起，我們就來了聊下真實的相關處理情況，今天為本部分的第一篇。

當前情況下官方的機器人會給存儲礦工發送經過驗證的真實數據，未來隨著基礎設施的完善，也會有其他方式來發送真實數據，比如客戶端自己指定某個礦工來發送數據。接下來我們從客戶端開始來研究下Lotus是怎么處理真實數據。

當客戶端要存儲真實數據時，他會調用lotusclientdealdataCidminerIdpriceduration命令發送數據到指定的礦工。

正文

當Lotusdaemon接收到這個請求之后就開始了交易處理。Lotusdaemon會調用go-file-markets類庫的StorageClient對象對交易進行處理。

美國共和黨提議將債務上限提高1.5萬億美元:金色財經報道，據Punchbowl：美國共和黨提議將債務上限提高1.5萬億美元，或延長至明年3月31日。[2023/4/20 14:14:37]

因為StorageClient對象被LotusAPI對象所依賴，所以在啟動Lotus的過程中，DI容器會調用StorageClient函數來創建它。

StorageClient函數流程如下：

調用NewFromLibp2pHost函數，生成StorageMarketNetwork對象。net?:=?smnet.NewFromLibp2pHost(h)

調用NewClient函數，生成Client對象。c,?err?:=?storageimpl.NewClient(net,?ibs,?dataTransfer,?discovery,?deals,?scn,?storageimpl.DealPollingInterval(time.Second))

BitMEX將于明日推出ETHPoW期貨合約:8月8日消息，BitMEX發布公告，將于明日推出ETHPoW期貨合約 ETHPOWZ22，以 USDT (ERC-20) 為保證金，最大杠桿為 2 倍。據悉，ETHPOWZ22 期貨合約已在測試網上線[2022/8/8 12:09:48]

scn即node對象，也是環境對象返回的節點對象，這個對象是ClientNodeAdapter對象由DI容器調用NewClientNodeAdapter函數而創建。

NewClient函數內容如下：

生成兩個IO對象。carIO?:=?cario.NewCarIO()

pio?:=?pieceio.NewPieceIO(carIO,?bs)

生成Client對象。c?:=?&Client{

????net:?????????????net,

BlockFi 即將推出新的費率，并于7月1日生效:金色財經報道，BlockFi聯合創始人Zac Prince在社交媒體上表示，BlockFi的風險管理和系統使我們能夠根據我們的合同采取果斷的行動來降低風險。這些行動可能包括在適當的時候追加保證金和資產清算。BlockFi可以確認，最近我們對一個未能履行其超額抵押保證金貸款義務的大客戶行使了我們的最佳商業判斷。我們完全結清了貸款，并清算或對沖了所有相關抵押品。沒有客戶的資金受到影響。我們相信我們是最早對這個對手方采取行動的人之一。BlockFi審慎和積極的風險管理是為了我們更廣泛的客戶群的利益，并使我們在市場壓力時期仍能保持業務。我們繼續積極放貸，并在我們的全球產品和服務中正常運作。

此外，我們將在未來幾周內公布我們的新費率，該費率將于 7 月 1 日生效。[2022/6/17 4:33:57]

????dataTransfer:????dataTransfer,

馬斯克要揭露推特虛假賬號數，但專家稱其方法“愚蠢”:5月15日消息，特斯拉馬斯克稱，為了弄清楚推特上的虛假/垃圾賬號是否像該公司長期宣稱的那樣低于5%，他將隨機抽取100名粉絲作為研究樣本。然而，社交媒體、虛假信息和統計分析方面的專家表示，馬斯克的分析方法存在嚴重缺陷。

?“為了找到答案，我的團隊將隨機抽取100名推特粉絲。我會邀請其他人重復同樣的過程，看看他們會發現什么，”馬斯克在推特中闡明了自己的方法，并補充說，“選擇任何有大量粉絲的賬戶，忽略前1000個粉絲，然后每10個選擇一個。我愿意接受更好的想法。?（鳳凰網科技）[2022/5/15 3:16:59]

????bs:??????????????bs,

????pio:?????????????pio,

????discovery:???????discovery,

????node:????????????scn,

????pubSub:??????????pubsub.New(clientDispatcher),

????pollingInterval:?DefaultPollingInterval,

}

生成fsm狀態組對象。statemachines,?err?:=?newClientStateMachine(

????ds,

????&clientDealEnvironment{c},

????c.dispatch,

)

c.statemachines?=?statemachines

fsm狀態組對象使用的配置參數如下：return?fsm.New(ds,?fsm.Parameters{

????Environment:?????env,

????StateType:???????storagemarket.ClientDeal{},

????StateKeyField:???"State",

????Events:??????????clientstates.ClientEvents,

????StateEntryFuncs:?clientstates.ClientStateEntryFuncs,

????FinalityStates:??clientstates.ClientFinalityStates,

????Notifier:????????notifier,

})

環境對象為clientDealEnvironment。

狀態對象為ClientDeal。

狀態字段為State。

事件集合為ClientEvents，參考storagemarket/impl/clientstates/client_fsm.go文件。

狀態處理函數集合為ClientStateEntryFuncs，狀態機的狀態處理器根據對應的狀態獲取到指定的函數進行處理。

終止狀態集合為ClientFinalityStates。

通知對象為Client對象的dispatch方法。

使用配置選項，配置Client對象。c.Configure(options...)

設置數據傳輸監聽對象。dataTransfer.SubscribeToEvents(dtutils.ClientDataTransferSubscriber(statemachines))

當傳輸結束、傳輸錯誤時會發送ClientEventDataTransferComplete、ClientEventDataTransferFailed等事件到fsm狀態組。

返回Client對象。

在DI容器的OnStart鉤子函數中調用Client對象的Start方法。Start方法調用自身的restartDeals方法開始進行重新交易。

返回Client對象。

Tags：ENTLIENTATSTAAcentaliendollarSTATE價格StakedZEN

歐易交易所