-
Notifications
You must be signed in to change notification settings - Fork 3
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
1 parent
659c095
commit 7eddce3
Showing
5 changed files
with
294 additions
and
230 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
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,70 +1,10 @@ | ||
| import KYVE, { Item } from '@kyve/core'; | ||
| import { Signature } from './types'; | ||
| import { fetchBlock, fetchHeight, isBlockNotFound } from './utils'; | ||
| import { name, version } from '../package.json'; | ||
| import { Node, Arweave, Gzip, JsonFileCache } from '@kyve/core'; | ||
|
|
||
| process.env.KYVE_RUNTIME = name; | ||
| process.env.KYVE_VERSION = version; | ||
| import Near from './runtime'; | ||
|
|
||
| KYVE.metrics.register.setDefaultLabels({ | ||
| app: process.env.KYVE_RUNTIME, | ||
| }); | ||
|
|
||
| class KyveNear extends KYVE { | ||
| public async getDataItem(key: string): Promise<Item> { | ||
| let block; | ||
|
|
||
| const height = await fetchHeight( | ||
| this.pool.config.rpc, | ||
| await this.getSignature() | ||
| ); | ||
| if (+key > height) throw new Error(); | ||
|
|
||
| try { | ||
| block = await fetchBlock( | ||
| this.pool.config.rpc, | ||
| +key, | ||
| await this.getSignature() | ||
| ); | ||
| } catch (err) { | ||
| if (isBlockNotFound(err)) return { key, value: null }; | ||
|
|
||
| this.logger.warn(`Failed to fetch block ${key}. Retrying ...`); | ||
|
|
||
| throw err; | ||
| } | ||
|
|
||
| return { key, value: block }; | ||
| } | ||
|
|
||
| public async getNextKey(key: string): Promise<string> { | ||
| if (key) { | ||
| return (parseInt(key) + 1).toString(); | ||
| } | ||
|
|
||
| return '0'; | ||
| } | ||
|
|
||
| public async formatValue(value: any): Promise<string> { | ||
| return value.header?.hash ?? 'error'; | ||
| } | ||
|
|
||
| private async getSignature(): Promise<Signature> { | ||
| const address = await this.sdk.wallet.getAddress(); | ||
| const timestamp = new Date().valueOf().toString(); | ||
|
|
||
| const message = `${address}//${this.poolId}//${timestamp}`; | ||
|
|
||
| const { signature, pub_key } = await this.sdk.signString(message); | ||
|
|
||
| return { | ||
| signature, | ||
| pubKey: pub_key.value, | ||
| poolId: this.poolId.toString(), | ||
| timestamp, | ||
| }; | ||
| } | ||
| } | ||
|
|
||
| // noinspection JSIgnoredPromiseFromCall | ||
| new KyveNear().start(); | ||
| new Node() | ||
| .addRuntime(new Near()) | ||
| .addStorageProvider(new Arweave()) | ||
| .addCompression(new Gzip()) | ||
| .addCache(new JsonFileCache()) | ||
| .start(); |
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,54 @@ | ||
| import { DataItem, IRuntime, Node } from '@kyve/core'; | ||
| import { fetchBlock, fetchHeight, isBlockNotFound } from './utils'; | ||
| import { name, version } from '../package.json'; | ||
|
|
||
| export default class Near implements IRuntime { | ||
| public name = name; | ||
| public version = version; | ||
|
|
||
| public async getDataItem(core: Node, key: string): Promise<DataItem> { | ||
| let block; | ||
|
|
||
| const headers = await this.generateCoinbaseCloudHeaders(core); | ||
|
|
||
| const height = await fetchHeight(core.poolConfig.rpc, headers); | ||
| if (+key > height) throw new Error(); | ||
|
|
||
| try { | ||
| block = await fetchBlock(core.poolConfig.rpc, +key, headers); | ||
| } catch (err) { | ||
| if (isBlockNotFound(err)) return { key, value: null }; | ||
|
|
||
| throw err; | ||
| } | ||
|
|
||
| return { key, value: block }; | ||
| } | ||
|
|
||
| public async getNextKey(key: string): Promise<string> { | ||
| return (parseInt(key) + 1).toString(); | ||
| } | ||
|
|
||
| public async formatValue(value: any): Promise<string> { | ||
| return value.hash; | ||
| } | ||
|
|
||
| private async generateCoinbaseCloudHeaders(core: Node): Promise<any> { | ||
| // requestSignature for coinbase cloud | ||
| const address = core.client.account.address; | ||
| const timestamp = new Date().valueOf().toString(); | ||
| const poolId = core.pool.id; | ||
|
|
||
| const { signature, pub_key } = await core.client.signString( | ||
| `${address}//${poolId}//${timestamp}` | ||
| ); | ||
|
|
||
| return { | ||
| 'Content-Type': 'application/json', | ||
| Signature: signature, | ||
| 'Public-Key': pub_key.value, | ||
| 'Pool-ID': poolId, | ||
| Timestamp: timestamp, | ||
| }; | ||
| } | ||
| } |
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.