ceramic.ts

import program from 'commander'

import { CeramicCliUtils, DEFAULT_PINNING_STORE_PATH } from "../ceramic-cli-utils"

program
    .command('daemon')
    .option('--ipfs-api <url>', 'The ipfs http api to use')
    .option('--ethereum-rpc <url>', 'The Ethereum RPC URL used for communicating with Ethereum blockchain')
    .option('--anchor-service-api <url>', 'The anchor service URL to use')
    .option('--validate-docs', 'Validate documents according to their schemas. It is enabled by default')
    .option('--pinning <url...>', 'Pinning endpoints')
    .option('--pinning-store-path <url>', `The directory path used for pinning service. Defaults to WORKING_DIR/${DEFAULT_PINNING_STORE_PATH}`)
    .option('--gateway', 'Makes read only endpoints available. It is disabled by default')
    .option('--port <int>', 'Port daemon is availabe. Default is 7007')
    .option('--debug', 'Enable debug logging level. Default is false')
    .option('--log-to-files', 'If debug is true, write logs to files. Default is false')
    .option('--log-path <dir>', 'Store logs in this directory. Defaults to "/usr/local/var/log/ceramic"')
    .description('Start the daemon')
    .action(async ({ ipfsApi, ethereumRpc, anchorServiceApi, validateDocs, pinning, pinningStorePath, gateway, port, debug, logToFiles, logPath }) => {
        await CeramicCliUtils.createDaemon(ipfsApi, ethereumRpc, anchorServiceApi, validateDocs, pinning, pinningStorePath, gateway, port, debug, logToFiles, logPath)
    })

program
    .command('create <doctype>')
    .option('--content <content>', 'New document content')
    .option('--only-genesis', 'Only create the genesis object. No anchor will be created')
    .option('--controllers <controllers>', 'Specify a comma-separated list of the controllers of the document. Controllers are the users that are allowed to publish updates to this document. Defaults to current user')
    .option('--unique', 'Ensure document is unique regardless of content')
    .option('--schema <schema>', 'Schema document ID')
    .description('Create a new document')
    .action(async (doctype, { content, onlyGenesis, controllers, unique, schema }) => {
        await CeramicCliUtils.createDoc(doctype, content, controllers, onlyGenesis, unique, schema)
    })

program
    .command('change <docId>')
    .option('--content <content>', 'Change document content')
    .option('--controllers <controllers>', 'Change controllers of this document (only 3ID)')
    .option('--schema <schema>', 'Change the schema document ID')
    .description('Update the content of a document')
    .action(async (docId, { content, controllers, schema }) => {
        await CeramicCliUtils.change(docId, content, controllers, schema)
    })

program
    .command('show <docId> [<anchor>]')
    .description('Show the content of a document')
    .action(async (docId) => {
        await CeramicCliUtils.show(docId)
    })

program
    .command('state <docId> [<anchor>]')
    .description('Show the state of a document')
    .action(async (docId) => {
        await CeramicCliUtils.state(docId)
    })

program
    .command('watch <docId>')
    .description('Watch for updates in a document')
    .action(async (docId) => {
        await CeramicCliUtils.watch(docId)
    })

program
    .command('versions <docId>')
    .description('List document versions')
    .action(async (docId) => {
        await CeramicCliUtils.versions(docId)
    })

const schemas = program.command('schema')
schemas.description('Ceramic schemas')

schemas
    .command('create <new-content>')
    .option('--only-genesis', 'Only create the genesis object. No anchor will be created')
    .option('--controllers <controllers>', 'Specify a comma-separated list of the controllers of the schema document. Defaults to' + ' current user')
    .option('--unique', 'Ensure schema document is unique regardless of content')
    .description('Create a new schema')
    .action(async (content, { onlyGenesis, controllers, unique }) => {
        await CeramicCliUtils.schemaCreateDoc(content, controllers, onlyGenesis, unique)
    })

schemas
    .command('change <docId> <new-content>')
    .option('--controllers <controllers>', 'Change controllers of this document (only 3ID)')
    .description('Update the content of a schema')
    .action(async (docId, content, { controllers }) => {
        await CeramicCliUtils.schemaChangeDoc(docId, content, controllers)
    })

const pin = program.command('pin')
pin.description('Ceramic local pinning API')

pin
    .command('add <docId>')
    .description('Pin document')
    .action(async (docId) => {
        await CeramicCliUtils.pinAdd(docId)
    });

pin
    .command('rm <docId>')
    .description('Unpin document')
    .action(async (docId) => {
        await CeramicCliUtils.pinRm(docId)
    });

pin
    .command('ls [<docId>]')
    .description('List pinned documents')
    .action(async (docId) => {
        await CeramicCliUtils.pinLs(docId)
    })

const config = program.command('config')
config.description('CLI Ceramic configuration. Configurable parameters: seed, ceramicHost ')

config
    .command('show')
    .description('Show CLI Ceramic configuration')
    .action(async () => {
        await CeramicCliUtils.showConfig()
    });

config
    .command('set <variable> <value>')
    .description('Set variable value')
    .action(async (variable, value) => {
        await CeramicCliUtils.setConfig(variable, value)
    })

config
    .command('unset <variable>')
    .description('Unset configuration variable')
    .action(async (variable) => {
        await CeramicCliUtils.unsetConfig(variable)
    })


program.parse(process.argv)