Created
May 11, 2019 07:18
-
-
Save carsonfarmer/1dcba6f5b43bbb9649a45424f5ee9398 to your computer and use it in GitHub Desktop.
Typescript verison
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
| #!/usr/bin/env node | |
| import { cac } from 'cac' | |
| import textile, { Block, FeedItem } from '@textile/js-http-client' | |
| import readline from 'readline' | |
| import chalk from 'chalk' | |
| import { emojify } from 'node-emoji' | |
| const cli = cac('txtl') | |
| const { log } = console | |
| // Create 'default' chat command | |
| cli.command('', 'Starts an interactive chat session in a thread.') | |
| .action((opts) => { | |
| // Specify our readline interface | |
| const rl = readline.createInterface({ | |
| input: process.stdin, | |
| output: process.stdout, | |
| terminal: false | |
| }) | |
| // Run callback for each input on stdin | |
| rl.on('line', (line) => { | |
| if (line !== '') { | |
| textile.messages.add(opts.thread, emojify(line)) | |
| .then(() => { rl.prompt() }) | |
| .catch((err) => { | |
| log(err.toString()) | |
| process.exit(-1) | |
| }) | |
| } | |
| }) | |
| // Get our 'local' profile info... | |
| textile.profile.get() | |
| .then((peer) => { | |
| // ... and then create a custom prompt | |
| rl.setPrompt(chalk.green(peer.name || peer.address.slice(7)) + '\t') | |
| rl.prompt() // Display prompt to get started | |
| // Only subscribe to text events on the specified thread | |
| textile.subscribe.stream([Block.BlockType.TEXT], opts.thread) | |
| .then((stream) => { | |
| // All js-http-client stream endpoints return a ReadableSream | |
| const reader = stream.getReader() | |
| const read = (result: ReadableStreamReadResult<FeedItem>) => { | |
| if (result.done) { | |
| return | |
| } | |
| // Extract the text update and display it nicely... | |
| try { | |
| const item = result.value.payload | |
| const name = item.user.name || item.user.address.slice(7) | |
| if (item.user.address !== peer.address) { | |
| readline.clearLine(process.stdout, 0) | |
| readline.cursorTo(process.stdout, 0) | |
| log(chalk.cyan(name) + '\t' + chalk.grey(item.body)) | |
| rl.prompt() | |
| } | |
| } catch (err) { | |
| reader.cancel(undefined) | |
| return | |
| } | |
| // Keep reading from the stream | |
| reader.read().then(read) | |
| } | |
| // Start reading from the stream | |
| reader.read().then(read) | |
| }) | |
| .catch((err) => { | |
| log(err.toString()) | |
| process.exit(-1) | |
| }) | |
| }) | |
| .catch((err) => { | |
| log(err.toString()) | |
| process.exit(-1) | |
| }) | |
| }) | |
| .option('--thread [thread]', 'Thread ID. Omit to use the \'default\' thread.', { | |
| default: 'default', | |
| type: [String] | |
| }) | |
| // Display help message when `-h` or `--help` appears | |
| cli.help() | |
| // Display version number when `-v` or `--version` appears | |
| cli.version('0.0.1') | |
| // Parse stdin | |
| cli.parse() |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment