Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
Typescript verison
#!/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
You can’t perform that action at this time.