-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #68 from quorumcontrol/feature/re-publish
republish blocks
- Loading branch information
Showing
5 changed files
with
198 additions
and
0 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
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,116 @@ | ||
| package main | ||
|
|
||
| import ( | ||
| "context" | ||
| "encoding/json" | ||
| "os" | ||
| "path/filepath" | ||
|
|
||
| "github.com/quorumcontrol/jasons-game/network" | ||
|
|
||
| "github.com/pkg/errors" | ||
| logging "github.com/ipfs/go-log" | ||
|
|
||
| "github.com/ethereum/go-ethereum/common/hexutil" | ||
| "github.com/ethereum/go-ethereum/crypto" | ||
| "github.com/gobuffalo/packr/v2" | ||
| "github.com/quorumcontrol/tupelo-go-sdk/bls" | ||
| "github.com/quorumcontrol/tupelo-go-sdk/gossip3/types" | ||
| "github.com/shibukawa/configdir" | ||
| ) | ||
|
|
||
| const sessionStorageDir = "session-storage" | ||
|
|
||
| func doIt(ctx context.Context) error { | ||
| err := logging.SetLogLevel("gamenetwork", "info") | ||
| if err != nil { | ||
| return errors.Wrap(err, "error setting log level") | ||
| } | ||
|
|
||
| group, err := setupNotaryGroup(ctx, false) | ||
| if err != nil { | ||
| panic(errors.Wrap(err, "setting up notary group")) | ||
| } | ||
|
|
||
| configDirs := configdir.New("tupelo", "jasons-game") | ||
| folders := configDirs.QueryFolders(configdir.Global) | ||
| folder := configDirs.QueryFolderContainsFile(sessionStorageDir) | ||
| if folder == nil { | ||
| if err := folders[0].CreateParentDir(sessionStorageDir); err != nil { | ||
| panic(err) | ||
| } | ||
| } | ||
|
|
||
| sessionPath := filepath.Join(folders[0].Path, sessionStorageDir) | ||
|
|
||
| statePath := filepath.Join(sessionPath, filepath.Base("12345")) | ||
| if err := os.MkdirAll(statePath, 0750); err != nil { | ||
| panic(errors.Wrap(err, "error creating session storage")) | ||
| } | ||
| net, err := network.NewRemoteNetwork(ctx, group, statePath) | ||
| if err != nil { | ||
| panic(errors.Wrap(err, "setting up network")) | ||
| } | ||
|
|
||
| return net.(*network.RemoteNetwork).RepublishAll() | ||
| } | ||
|
|
||
| func main() { | ||
| ctx, cancel := context.WithCancel(context.Background()) | ||
| defer cancel() | ||
| err := doIt(ctx) | ||
| if err != nil { | ||
| panic(err) | ||
| } | ||
| } | ||
|
|
||
| type publicKeySet struct { | ||
| BlsHexPublicKey string `json:"blsHexPublicKey,omitempty"` | ||
| EcdsaHexPublicKey string `json:"ecdsaHexPublicKey,omitempty"` | ||
| PeerIDBase58Key string `json:"peerIDBase58Key,omitempty"` | ||
| } | ||
|
|
||
| func loadSignerKeys(connectToLocalnet bool) ([]*publicKeySet, error) { | ||
| localBox := packr.New("localKeys", "../devdocker/localkeys") | ||
| testnetBox := packr.New("testnetKeys", "../devdocker/testnetkeys") | ||
|
|
||
| var jsonBytes []byte | ||
| var err error | ||
|
|
||
| // TODO: Referencing devdocker dir here seems gross; should maybe rethink this | ||
| if connectToLocalnet { | ||
| jsonBytes, err = localBox.Find("public-keys.json") | ||
| } else { | ||
| jsonBytes, err = testnetBox.Find("public-keys.json") | ||
| } | ||
|
|
||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| var keySet []*publicKeySet | ||
| if err := json.Unmarshal(jsonBytes, &keySet); err != nil { | ||
| return nil, err | ||
| } | ||
|
|
||
| return keySet, nil | ||
| } | ||
|
|
||
| func setupNotaryGroup(ctx context.Context, connectToLocalnet bool) (*types.NotaryGroup, error) { | ||
| keys, err := loadSignerKeys(connectToLocalnet) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| group := types.NewNotaryGroup("tupelo-in-local-docker") | ||
| for _, keySet := range keys { | ||
| ecdsaBytes := hexutil.MustDecode(keySet.EcdsaHexPublicKey) | ||
| verKeyBytes := hexutil.MustDecode(keySet.BlsHexPublicKey) | ||
| ecdsaPubKey, err := crypto.UnmarshalPubkey(ecdsaBytes) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| signer := types.NewRemoteSigner(ecdsaPubKey, bls.BytesToVerKey(verKeyBytes)) | ||
| group.AddSigner(signer) | ||
| } | ||
|
|
||
| return group, nil | ||
| } |