Merge branch 'main' into utils/timestamp

Author: hazelnutcloud

README.md

@@ -1,21 +1,33 @@
-# [Arkiver](https://docs.arkiver.net)
+![Arkiver Logo](./img/arkiver_logo.png)
+
+# Arkiver 
+Seamlessly Develop, Deploy & Manage Data Pipelines for Web3 Applications
 
 Fast and Fully Type-Safe Blockchain Indexer
 
+# Links
+ - [Arkiver App](https://arkiver.net)
+ - [Docs](https://www.arkiver.net/docs/intro) 
+ - [Quickstart](https://www.arkiver.net/docs/examples/index-erc20-events) 
+
 # Features
 
-- **Fast** - Maximize indexing speed by minimizing I/O and caching data in
-  memory
+- **Fast** - Maximize indexing speed by minimizing I/O and caching data in memory
 - **Type-Safe** - End-to-end type-safety with TypeScript
 - **Flexible** - Write custom handlers to process data however you want
 - **Ergonomic** - Minimal configuration and easy to test locally
 - **Multi-Chain** - Index multiple chains in a single Arkive
 - **GraphQL** - Serve your data via a GraphQL API
 - **Open-Source** - Arkiver is open-source and free to use
 - **Self-Hosted** - Run Arkiver on your own infrastructure
-- **Cloud-Hosted** - Deploy your Arkive to the Arkiver cloud
+- **Cloud-Hosted** - Deploy your Arkive to the Arkiver Hosted Service
+
+### Pick your use-case
+
+Deploy Next.js, Svelte, Remix, Astro, Solid, or any static site to AWS.
 
-... and a lot more!
+- [**ERC20 Events**](https://www.arkiver.net/docs/examples/index-erc20-events)
+- [**Vault Share Price**](https://www.arkiver.net/docs/examples/block-handler-vault-snapshot)
 
 # Overview
 
@@ -38,10 +50,10 @@ manifest
 export default manifest.build()
 ```
 
-# Documentation
-
-[(WIP)](https://docs.arkiver.net)
-
 # License
 
 [MIT](LICENSE) License
+
+---
+
+**Join our community** [Discord](https://discord.gg/robovault-865495351175282708) | [Twitter](https://twitter.com/robolabs_biz)

cli.ts

@@ -51,7 +51,7 @@ command.command('logout', 'Logout from RoboArkiver').action(logout.action)
 // deploy
 command
   .command('deploy', 'Deploy arkive')
-  .option('--public', 'Make arkive public')
+  .option('--private', 'Make arkive private')
   .option('--major', 'Deploy as major version')
   .option('--env <env:string>', 'Environment to deploy to')
   .arguments('<dir:string>')

cli/deploy/mod.ts

@@ -7,7 +7,7 @@ import { pkg } from './pkg.ts'
 import { upload } from './upload.ts'
 
 export const action = async (
-  options: { public?: true; major?: true; env?: string },
+  options: { private?: true; major?: true; env?: string },
   directory: string,
 ) => {
   const dev = options.env?.toLowerCase() === 'dev'
@@ -80,7 +80,7 @@ export const action = async (
 }
 
 const deployDev = async (
-  options: { public?: true; major?: true },
+  options: { private?: true; major?: true },
   directory: string,
 ) => {
   const manifestPath = join(Deno.cwd(), directory, 'manifest.ts')

cli/deploy/upload.ts

@@ -7,7 +7,7 @@ export const upload = async (
   pkgName: string,
   tempPath: string,
   manifest: ArkiveManifest,
-  options: { public?: true; major?: true; env?: string },
+  options: { private?: true; major?: true; env?: string },
 ) => {
   spinner().text = 'Uploading...'
   const { session } = await getSupabaseClientAndLogin()
@@ -23,7 +23,7 @@ export const upload = async (
     'pkg',
     new File([await Deno.readFile(filePath)], pkgName),
   )
-  if (options.public) {
+  if (options.private === undefined) {
     formData.append('isPublic', 'on')
   }
   if (options.major) {

cli/start/mod.ts

@@ -10,6 +10,8 @@ import { ArkiverMetadata } from '../../src/arkiver/arkive-metadata.ts'
 import { createManifestHandlers } from './logger.ts'
 import { colors, mongoose, SchemaComposer } from '../../src/deps.ts'
 import { logger } from '../../src/logger.ts'
+import { collectRpcUrls } from '../utils.ts'
+
 
 export const action = async (
   options: {
@@ -114,11 +116,17 @@ export const action = async (
     },
   })
 
+  // An RPC for our Arkive is going to be assigned at some point.
+  // The order of assignment is as follows:
+  // 1. CLI command line option -r, --rpc-url
+  // 2. Env variables such as {CHAIN}_RPC_URL
+  // 3. RPC url defined in manifest
+  // 4. Default RPC of Viem
   const rpcUrls = options.rpcUrl?.reduce((acc, rpc) => {
     const [name, url] = rpc.split('=')
     acc[name] = url
     return acc
-  }, {} as Record<string, string>) ?? {}
+  }, {} as Record<string, string>) ?? collectRpcUrls() ?? {}
 
   logger('arkiver').debug(`Connecting to database...`)
   const connectionString = options.mongoConnection ??

cli/utils.ts

@@ -2,6 +2,7 @@ import { SUPABASE_ANON_PUBLIC_KEY, SUPABASE_URL } from './constants.ts'
 import { createClient, Input, Secret, z } from './deps.ts'
 import { login } from './login/mod.ts'
 import { spinner } from './spinner.ts'
+import { supportedChains } from '../src/chains.ts'
 
 export const getEmail = async () => {
   const email = await Input.prompt('✉️  Email:')
@@ -127,3 +128,23 @@ export const craftEndpoint = (
     majorVersion ? majorVersion + '/' : ''
   }graphql`
 }
+
+export const getEnv = (key: string, defaultValue?: string): string => {
+  const value = Deno.env.get(key)
+  if (!value && !defaultValue) {
+    throw new Error(`Missing environment variable: ${key}`)
+  }
+  return value || defaultValue || ''
+}
+
+export const collectRpcUrls = () => {
+  const rpcUrls: Record<string, string> = {}
+  for (const chain of Object.keys(supportedChains)) {
+    try {
+      rpcUrls[chain] = getEnv(`${chain.toUpperCase()}_RPC_URL`)
+    } catch (_e) {
+      // ignore
+    }
+  }
+  return rpcUrls
+}