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

前言

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

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

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

正文

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

跨鏈流動性聚合器Router Protocol已集成Scroll測試網:6月27日消息，跨鏈流動性聚合器Router Protocol已集成Layer2解決方案Scroll測試網，支持開發人員構建IDApp，以擴展到Scroll，同時Scroll內的項目也可以通過Router Protocol訪問多個區塊鏈網絡。[2023/6/27 22:01:55]

因為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))

Web3唱片公司Hume完成1170萬美元A輪融資:9月23日消息，Web3唱片公司Hume宣布完成1170萬美元A輪融資，TCG Crypto領投，參投方包括Collab+Currency、Gemini Frontier Fund、Winklevoss Capital、gmoney.eth、Flamingo DAO、Noise DAO、The LAO、Distributed Global、Coopahtroopa等。Hume的首個metastar是angelbaby，Hume表示，在過去8個多月的時間里，angelbaby曾在Art Basel、Fluf Haus LA和SXSW完成演出。

Hume還在7月份發布Hume Genesis系列，總量1035個，分為3個稀有等級，該NFT系列持有者是能夠幫助metastar做出其藝術生涯和個人生活中重要決定的關鍵。（Forbes）[2022/9/23 7:16:16]

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

Meta旗下VR平臺副總裁將離職，主要負責元宇宙相關研發:金色財經報道，Meta旗下虛擬現實社交平臺Horizon的副總裁Vivek Sharma將離職，其團隊將直接向Meta元宇宙副總裁Vishal Shah匯報。

Sharma加入Meta已超過5年，在市場和游戲領域任高級職位，最近還在元宇宙相關業務部門擔任要職。據報道，Sharma主要負責研發“持久的沉浸式虛擬環境體驗”，以及包括Oculus headsets在內的VR設備。（界面）[2022/8/28 12:53:52]

NewClient函數內容如下：

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

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

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

外媒：BitOasis裁員5%，OKX等繼續招聘:6月20日消息，據路透社報道，BitOasis已裁員5%，首席執行官兼聯合創始人Ola Doudin表示，本周早些時候，迪拜、阿布扎比和安曼辦事處有9名員工被裁員。而OKX表示將繼續招聘。

據悉，除BitOasis之外，已經開始裁員的公司還有Coinbase、BlockFi和Crypto.com。除OKX之外，繼續招聘的公司還有Binance、Kraken和FTX。（Beincrypto）[2022/6/20 4:40:56]

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

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

????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：ENTLIENTATSTAlitentry幣未來價值aliendollarStatter NetworkMustangToken

比特幣價格