import { EventEmitter } from 'events'
// You also need node-fetch for this to work
import fetch, { Response } from 'node-fetch'
import { AsyncPipe } from 'or-pipets'

const emitter = new EventEmitter()

const getJson = async (response: Response) => response.json()

const boredPipe = AsyncPipe.of(() => 'https://www.boredapi.com/api/activity')
	.pipeTapP(() => console.log('Searching for activities... 🤔'))
	.pipeP(fetch)
	.pipeP(getJson)
	.pipeP((json: { activity: string }) => json.activity)
	.pipeTapP(() => console.log('Found one 🎉'))
	.pipeP((activity) => `  💡 ${activity}`)
	.pipeP(console.log)

emitter.on('bored', boredPipe.processP)

setTimeout(() => emitter.emit('bored'), 300)

import { Pipe } from 'or-pipets'

// Start with removing the first two strings in the argv
Pipe.of((argv: string[]) => argv.slice(2))
	// .pipeTap executes provided function but the return value is
	// ignored - the argument is passed to the next function instead
	// Log the context to console
	.pipeTap((x) => console.log('>>>', x))
	// Get the first item in the array and parse a number, 0 if NaN
	.pipe(([numberString]) => Number.parseInt(numberString, 10) || 0)
	// Log the context to console
	.pipeTap((x) => console.log('>>>', x))
	// Add 10
	.pipe((number) => number + 10)
	// Log the result to console
	.pipe((result) => console.log(`🧮 ${result}`))
	// Pass argv to the context of the Pipe
	.process(process.argv)

import * as express from 'express'
import { Pipe } from 'or-pipets'

const app = express()

interface ICtx {
	request: express.Request
	response: express.Response
}

// Here we start with Pipe.empty() because our first function returns
// void. If we pass it to Pipe.of, it will pass nothing to the first
// pipeExtend and the code will fail. This is because pipeExtend
// manages saving previous context, not the Pipe itself.
const getSlashPipeline = Pipe.empty<ICtx>()
	.pipeExtend(({ response }) => response.setHeader('X-Powered-By', 'Express with Pipe'))
	// Puts the value of the Host header to the context
	.pipeExtend(({ request }) => ({ host: request.header('host') ?? '🤔' }))
	// Creates the response string with the host
	.pipeExtend(({ host }) => ({ responseBody: `Welcome to ${host}!` }))
	// Wraps the response string into h1
	.pipeExtend(({ responseBody }) => ({ responseBody: `<h1>${responseBody}</h1>` }))
	// Sends the response
	.pipe(({ response, responseBody }) => response.send(responseBody))

app.get('/', (request, response) => getSlashPipeline.process({ request, response }))

app.listen(3000, () => {
	console.log(`Example app listening on port 3000`)
})