initial commit

Author: goodmind

.babelrc

@@ -0,0 +1,8 @@
+{
+  "presets": [
+    "es2015"
+  ],
+  "plugins": [
+    "transform-function-bind"
+  ]
+}

.eslintrc

@@ -0,0 +1,9 @@
+{
+  "extends": "standard",
+  "plugins": [
+    "standard"
+  ],
+  "rules": {
+    "max-len": ["error", 80]
+  }
+}

.gitignore

@@ -0,0 +1,4 @@
+dist/
+node_modules/
+.idea/
+npm-debug.log

index.js

@@ -0,0 +1 @@
+module.exports = require('./dist/tryhaskell.js')

package.json

@@ -0,0 +1,32 @@
+{
+  "name": "tryhaskell-bot",
+  "private": true,
+  "version": "1.0.0",
+  "description": "Try Haskell in Telegram via tryhaskell.org",
+  "main": "index.js",
+  "scripts": {
+    "build": "babel -d dist/ src/",
+    "build:watch": "babel -d dist/ src/ --watch",
+    "eslint": "eslint src/",
+    "start": "node index.js",
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "author": "goodmind <andwebar@gmail.com>",
+  "license": "MIT",
+  "devDependencies": {
+    "babel-cli": "^6.9.0",
+    "babel-plugin-transform-function-bind": "^6.8.0",
+    "eslint": "^2.11.1",
+    "eslint-config-standard": "^5.3.1",
+    "eslint-plugin-promise": "^1.3.1",
+    "eslint-plugin-standard": "^1.3.2"
+  },
+  "dependencies": {
+    "@cycle/core": "^6.0.3",
+    "@cycle/http": "^8.2.2",
+    "common-tags": "^1.2.0",
+    "cycle-telegram": "^1.3.0",
+    "ramda": "^0.21.0",
+    "rx": "^4.1.0"
+  }
+}

src/plugins/index.js

@@ -0,0 +1,11 @@
+import { Update } from 'cycle-telegram'
+
+import TryHaskell from './tryhaskell'
+
+export let plugins = [
+  {
+    type: Update,
+    name: 'tryhaskell',
+    path: /(?:[\s\S]*)/,
+    component: TryHaskell}
+]

src/plugins/tryhaskell.js

@@ -0,0 +1,59 @@
+import { Observable as $ } from 'rx'
+import { compose, prop, curryN } from 'ramda'
+import { stripIndents } from 'common-tags'
+
+import { reply, answerInlineQuery } from 'cycle-telegram'
+
+let prettify = (query, result) => `
+Prelude> ${query}
+${result}
+`
+
+let answer = curryN(2, (u, text) => $.just(
+  u.inline_query ? answerInlineQuery({
+    results: [
+      {
+        type: 'article',
+        title: text,
+        input_message_content: {
+          message_text: prettify(u.inline_query.query, text)
+        }
+      }
+    ],
+    cache_time: 0
+  }, u) : reply({ text: prettify(u.message.text, text) }, u)))
+
+function TryHaskell ({HTTP, props}, u) {
+  let text = props[0]
+  let res = HTTP
+    .filter(res$ => res$.request.send.exp === text)
+    .mergeAll()
+    .map(compose(JSON.parse, prop('text')))
+    .flatMapLatest(({
+      error,
+      success
+    }) => error ? $.throw(error) : $.just(success))
+
+  return {
+    bot: res
+      .map(res => stripIndents`
+${res.stdout.join('')}
+${res.value} :: ${res.type}
+      `)
+      .flatMapLatest(answer(u))
+      .catch(answer(u)),
+
+    HTTP: $.just({
+      method: 'POST',
+      url: 'http://tryhaskell.org/eval',
+      category: 'tryhaskell',
+      send: {
+        exp: text
+      },
+      type: 'application/x-www-form-urlencoded',
+      accept: 'application/json'
+    })
+  }
+}
+
+export default TryHaskell

src/tryhaskell.js

@@ -0,0 +1,47 @@
+import { Observable as $ } from 'rx'
+import { values } from 'ramda'
+
+import { run } from '@cycle/core'
+import { makeHTTPDriver } from '@cycle/http'
+import { makeTelegramDriver } from 'cycle-telegram'
+import { matchPlugin } from 'cycle-telegram/plugins'
+
+import { plugins } from './plugins'
+
+let intent = (sources) => ({
+  messages: sources.bot
+    .events('message')
+    ::matchPlugin(plugins, sources)
+    .share(),
+
+  inlineQuery: sources.bot
+    .events('inline_query')
+    ::matchPlugin(plugins, sources)
+    .share()
+})
+
+let model = ({messages, inlineQuery, commands}, sources) => $.from([
+  messages.pluck('bot').mergeAll(),
+  inlineQuery.pluck('bot').mergeAll()
+])
+
+let main = (sources) => {
+  let actions = intent(sources)
+
+  return {
+    HTTP: $.merge(actions.inlineQuery, actions.messages)
+      .pluck('HTTP')
+      .mergeAll(),
+
+    bot: model(actions, sources),
+
+    log: $.from(values(actions))
+      .mergeAll()
+  }
+}
+
+run(main, {
+  HTTP: makeHTTPDriver(),
+  bot: makeTelegramDriver(process.env.ACCESS_TOKEN),
+  log: (m) => m.forEach(::console.log)
+})