Filecoin をマスターする: Lotus Real データ処理プロバイダーの初期化

StorageProviderオブジェクトは Storage Miner API オブジェクトに依存しているため、ストレージマイナーの起動プロセス中に、DI コンテナーはStorageProvider関数 (node/modules/storageminer.go) を呼び出してそれを作成します。 StorageProvider関数のフローは次のとおりです。

NewFromLibp2pHost関数を呼び出して、 StorageMarketNetworkオブジェクトを生成します。
```
ネット:= smnet.NewFromLibp2pHost(h)
```
NewLocalFileStore関数を呼び出して、 FileStoreストレージオブジェクトを生成します。
```
ストア、エラー:= piecefilestore.NewLocalFileStore(piecefilestore.OsPath(r.Path()))
```
NewLocalFileStore関数 (go-fil-markets ライブラリ filestore/filestore.go) のプロセスは次のとおりです。
```
ベース:=ファイルパス.Clean(文字列(ベースディレクトリ))
情報、エラー:= os.Stat(文字列(ベース))
```

if !info.IsDir() { return nil, fmt.Errorf("%s はディレクトリではありません", base) }

return &fileStore{string(base)}, nil NewLocalFileStore関数で使用されるパスは、ウェアハウスディレクトリです。つまり、フラグメントの一時ディレクトリはウェアハウスディレクトリです。

CustomDealDecisionLogic関数を呼び出し、関数オブジェクトを返します。関数オブジェクトで提供されるコールバック関数を呼び出して、カスタムトランザクションロジックの判断を実行します。
```
 opt := storageimpl.CustomDealDecisionLogic(func(ctx context.Context, deal storagemarket.MinerDeal) (bool, string, error) {})
```

StorageProviderオブジェクトを生成して返します。

 p, err := storageimpl.NewProvider(net, namespace.Wrap(ds, datastore.NewKey("/deals/provider")), ibs, store, pieceStore, dataTransfer, spn, address.Address(minerAddress), ffiConfig.SealProofType, storedAsk, opt) 戻り値 p, nil

NewProvider関数はこれを次のように処理します。

環境オブジェクトはproviderDealEnvironmentです。
状態オブジェクトはMinerDealです。
状態フィールドはStateです。
イベントコレクションはProviderEventsです。storagemarket/impl/providerstates/provider_fsm.go ファイルを参照してください。
状態処理関数コレクションはProviderStateEntryFuncsであり、ステートマシンの状態プロセッサは対応する状態に応じて指定された関数を取得して処理します。
最終状態コレクションはProviderFinalityStatesです。
通知オブジェクトは、 Providerオブジェクトのdispatchメソッドです。

PieceIOWithStoreオブジェクトを生成します。

 carIO := cario.NewCarIO()
pio := pieceio.NewPieceIOWithStore(carIO, fs, bs)

Providerオブジェクトを生成します。

 h := &プロバイダー{
    ネット：ネット、
    証明タイプ: rt,
    spp: spp,
    フェス: フェス、
    ピオ: ピオ、
    ピースストア: ピースストア,
    接続: connmanager.NewConnManager(),
    保存された質問: 保存された質問、
    俳優: minerAddress、
    データ転送: データ転送、
    取引承認バッファ: デフォルト取引承認バッファ、
    pubSub: pubsub.New(providerDispatcher)、
}

fsm 状態グループオブジェクトを生成します。

取引、エラー:= NewProviderStateMachine(
    ds、
    &providerDealEnvironment{h},
    h.ディスパッチ、
)h.deals = 取引

fsm 状態グループオブジェクトで使用される構成パラメータは次のとおりです。

 fsm.New(ds, fsm.Parameters{ を返します。
    環境: env,
    状態タイプ: storagemarket.MinerDeal{},
    StateKeyField: "州"、
    イベント: providerstates.ProviderEvents、
    状態エントリ関数: providerstates.ProviderStateEntryFuncs、
    ファイナリティ状態: providerstates.ProviderFinalityStates、
    通知者: 通知者、
})

構成オプションを使用してProviderオブジェクトを構成します。
```
 h.Configure(オプション...)
```
データ転送監視対象を設定します。
```
 dataTransfer.SubscribeToEvents(dtutils.ProviderDataTransferSubscriber(取引))
```
データ転送が開始、終了、または失敗すると、 ProviderEventDataTransferInitiated 、 ProviderEventDataTransferCompleted 、 ProviderEventDataTransferFailedなどのイベントが fsm ステータスグループに送信されます。
Providerオブジェクトを返します。

HandleDeals関数 (node/modules/storageminer.go) は、ストレージマイナーの起動プロセス中に自動的に呼び出されます。この関数では、 StorageProviderオブジェクトのStartメソッドを呼び出してオブジェクトを起動します。

Startメソッドの実行プロセスは次のとおりです。

StorageMarketNetworkネットワークオブジェクトのSetDelegate呼び出して、プロキシ/デリゲートをそれ自体に設定します。
```
エラー:= p.net.SetDelegate(p)
```
ネットワークオブジェクトは、 libp2pStorageMarketNetwork構造体 (storagemarket/network/libp2p_impl.go) として実装されます。 SetDelegateメソッドの内容は次のとおりです。
```
実装レシーバー = r
impl.host.SetStreamHandler(storagemarket.DealProtocolID、impl.handleNewDealStream) を実装します。
impl.host.SetStreamHandler(storagemarket.AskProtocolID、impl.handleNewAskStream) を実装します。
nilを返す
```
ネットワークオブジェクトのhandleNewDealStreamメソッドは、ストレージを意味するDealProtocolIDプロトコルを処理するために上記で設定されています。 handleNewAskStreamメソッドはAskProtocolIDプロトコル (ask を意味する) を処理するように設定されています。
handleNewDealStreamメソッドの内容は次のとおりです。
```
 // クライアントピアID
remotePID := s.Conn().RemotePeer() buffered := bufio.NewReaderSize(s, 16) // ストリームをラップします ds := &dealStream{remotePID, impl.host, s, buffered} // StorageProvider オブジェクトの HandleDealStream メソッドを呼び出して、クライアントのストレージ要求を処理します impl.receiver.HandleDealStream(ds)
```
トランザクションを再処理するには、コルーチンでStorageProviderオブジェクトのrestartDealsメソッドを呼び出します。 restartDealsメソッドのプロセスは次のとおりです。

現在のトランザクションオブジェクトが終了した場合は、次のプロセスに進みます。
現在のトランザクションオブジェクトの接続が閉じられている場合は、次のプロセスに進みます。
初期トランザクションイベントを fsm ステータスグループに送信します。
```
エラー = c.deals.Send(deal.ProposalCid、storagemarket.ProviderEventRestart)
```
トランザクション提案の Cid は、ステートマシンの名前/番号を表します。