first commit

Author: micalevisk

.env.example

@@ -0,0 +1,3 @@
+TELEGRAM_BOT_TOKEN=123456789:ABCz12WQ13E13Vod-13113kXEASgEGSFYGM
+TELEGRAM_TARGET_CHAT_ID=@plpicompufam2018 # telegram channel
+GPROJECT_NAME=plpicompufam2018periodo2

.gitignore

@@ -0,0 +1,99 @@
+
+# Created by https://www.gitignore.io/api/vim,node
+
+### Node ###
+# Logs
+logs
+*.log
+npm-debug.log*
+yarn-debug.log*
+yarn-error.log*
+
+# Runtime data
+pids
+*.pid
+*.seed
+*.pid.lock
+
+# Directory for instrumented libs generated by jscoverage/JSCover
+lib-cov
+
+# Coverage directory used by tools like istanbul
+coverage
+
+# nyc test coverage
+.nyc_output
+
+# Grunt intermediate storage (http://gruntjs.com/creating-plugins#storing-task-files)
+.grunt
+
+# Bower dependency directory (https://bower.io/)
+bower_components
+
+# node-waf configuration
+.lock-wscript
+
+# Compiled binary addons (https://nodejs.org/api/addons.html)
+build/Release
+
+# Dependency directories
+node_modules/
+jspm_packages/
+
+# TypeScript v1 declaration files
+typings/
+
+# Optional npm cache directory
+.npm
+
+# Optional eslint cache
+.eslintcache
+
+# Optional REPL history
+.node_repl_history
+
+# Output of 'npm pack'
+*.tgz
+
+# Yarn Integrity file
+.yarn-integrity
+
+# dotenv environment variables file
+.env
+
+# parcel-bundler cache (https://parceljs.org/)
+.cache
+
+# next.js build output
+.next
+
+# nuxt.js build output
+.nuxt
+
+# vuepress build output
+.vuepress/dist
+
+# Serverless directories
+.serverless
+
+### Vim ###
+# Swap
+[._]*.s[a-v][a-z]
+[._]*.sw[a-p]
+[._]s[a-rt-v][a-z]
+[._]ss[a-gi-z]
+[._]sw[a-p]
+
+# Session
+Session.vim
+
+# Temporary
+.netrwhist
+*~
+# Auto-generated tag files
+tags
+# Persistent undo
+[._]*.un~
+
+
+# End of https://www.gitignore.io/api/vim,node

fetch-last-announcement.js

@@ -0,0 +1,93 @@
+const fetch = require('node-fetch')
+const cheerio= require('cheerio')
+const _ = require('./utils')
+
+//#region configs
+const SITES_GOOGLE_BASE_URL = 'https://sites.google.com'
+const SITES_GOOGLE_CLASSROOM_NEWS = 'classroom-news'
+const getURLToProjectName = projectName => `${SITES_GOOGLE_BASE_URL}/site/${projectName}`
+//#endregion
+
+//#region handlers
+const titleHandler = {
+  isPattern(e) {
+    return _.isType(e, 'tag')
+        && _.isName(e, 'h4')
+  },
+
+  isChildren(e) {
+    return _.isType(e, 'tag')
+        && _.isName(e, 'a')
+        && e.hasOwnProperty('attribs')
+        && _.hasAttribs(e, { dir: 'ltr' })
+  }
+}
+
+const dateHandler = {
+  isPattern(className) {
+    return e => _.isType(e, 'tag')
+             && e.hasOwnProperty('attribs')
+             && _.hasAttribs(e, { class: className })
+  },
+
+  isChildren(e) {
+    return _.isType(e, 'tag')
+        && e.hasOwnProperty('attribs')
+        && _.hasAttribs(e, { dir: 'ltr' })
+  }
+}
+//#endregion
+
+function formatDate(strDate) {
+  const {day, month, year} = _.strDateToObj(strDate)
+  return `${day}/${month}/${year}`
+}
+
+function scrapeLastAnnouncement(baseURL, body) {
+  const $ = cheerio.load(body)
+
+  const ultimaPublicacao = $('div.announcement')[0]
+  if (!ultimaPublicacao) {
+    return Promise.reject(new Error('Publicação não encontrada'))
+  }
+
+  const titleElement = ultimaPublicacao.children.find(titleHandler.isPattern)
+  const publiLinkElement = titleElement.children.find(titleHandler.isChildren)
+  const title = publiLinkElement.children.find(_.hasData).data
+  const pageLinkPath = _.getAttribs(publiLinkElement)['href'] //.split('/').pop()
+
+  const timeElement = ultimaPublicacao.children.find(dateHandler.isPattern('timestamp'))
+  const dateElement = timeElement.children.find(dateHandler.isChildren)
+  const publish_date = dateElement.children.find(_.hasData).data
+
+  const response = {
+    title: title,
+    link: baseURL + pageLinkPath,
+    publish_date: formatDate(publish_date)
+  }
+
+  const updatedTimeElement = timeElement.children.find(dateHandler.isPattern('updatedTime'))
+  if (updatedTimeElement) {
+    const updatedDateElement = updatedTimeElement.children.find(dateHandler.isChildren)
+    const updated_date = updatedDateElement.children.find(_.hasData).data
+
+    Object.assign(response, { updated_date: formatDate(updated_date) })
+  }
+
+  return Promise.resolve(response)
+}
+
+
+/**
+ *
+ * @param {string} projectName
+ * @returns {Promise<{title:string, link:string, publish_date:string, updated_date?:string}>}
+ */
+function fetchLastAnnouncement(projectName) {
+  return fetch( getURLToProjectName(projectName) + '/' + SITES_GOOGLE_CLASSROOM_NEWS )
+    .then(res => res.text())
+    .then(body => scrapeLastAnnouncement(SITES_GOOGLE_BASE_URL, body))
+    .catch(err => err.message)
+}
+
+module.exports = fetchLastAnnouncement

get-daily-plp.js

@@ -0,0 +1,77 @@
+const fetch = require('node-fetch');
+const fetchLastAnnouncement = require('./fetch-last-announcement');
+
+function sendMessageToTelegram(token, chatId, text, parseMode = 'HTML') {
+  const url = `https://api.telegram.org/bot${token}/sendMessage?parse_mode=${parseMode}&chat_id=${chatId}&text=${text}`;
+  return fetch(url);
+}
+
+//#region Webtask.io API
+
+function saveToStorage(ctx, data, cb) {
+  ctx.storage.set(data, { force: 1 }, function (error) {
+    if (typeof cb !== 'function') return;
+
+    if (error) return cb(error);
+    return cb(null, error);
+  });
+}
+
+function retriveFromStorage(ctx, cb) {
+  ctx.storage.get((error, data) => {
+    if (error) return cb(error);
+    cb(null, data);
+  });
+}
+
+
+function saveLastAnnouncement(ctx, lastAnnouncementFetched) {
+  return new Promise((resolve, reject) => {
+
+    const onRetrived = (error, lastAnnouncementSaved) => {
+      if (error) return;
+      if (!lastAnnouncementSaved || lastAnnouncementSaved !== lastAnnouncementFetched) {
+        saveToStorage(ctx, lastAnnouncementFetched);
+        resolve();
+      } else {
+        reject();
+      }
+    };
+
+    retriveFromStorage(ctx, onRetrived);
+
+  });
+}
+
+
+/**
+ *
+ * @param {WebtaskContext} ctx https://webtask.io/docs/context
+ * @param {Function} cb Callback
+ */
+function getLastAnnouncement(ctx, cb) {
+  const { TELEGRAM_BOT_TOKEN, TELEGRAM_TARGET_CHAT_ID, GPROJECT_NAME } = ctx.secrets;
+
+  fetchLastAnnouncement(GPROJECT_NAME)
+    .then((dadosUltimoAnuncio) => {
+      const {title, link, publish_date, updated_date} = dadosUltimoAnuncio;
+      const msgFormatada = (updated_date)
+        ? `<b>${publish_date}</b> ~ <code>${updated_date}</code>\n<a href="${link}">${title}</a>`
+        : `<b>${publish_date}</b>\n<a href="${link}">${title}</a>`;
+
+      saveLastAnnouncement(ctx, msgFormatada)
+        .then(() => {
+          sendMessageToTelegram(TELEGRAM_BOT_TOKEN, TELEGRAM_TARGET_CHAT_ID, msgFormatada)
+            .then(response => cb(null, response))
+            .catch(() => cb('something wrong'));
+        })
+        .catch(() => {
+          cb(null, `[nada de novo] > "${title}"`);
+        })
+    })
+    .catch(errMessage => cb(errMessage));
+}
+
+//#endregion
+
+module.exports = getLastAnnouncement;