first working proto

Author: pechorin

.gitignore

@@ -0,0 +1,2 @@
+node_modules/
+tags

Dockerfile

@@ -0,0 +1,13 @@
+FROM node:current-alpine
+
+ARG FOLDER
+# ARG NOTION_TOKEN
+# ARG NOTION_ROOT_ID
+
+ENV FOLDER $FOLDER
+
+# Copies your code file from your action repository to the filesystem path `/` of the container
+# COPY entrypoint.sh /entrypoint.sh
+
+RUN npm install
+ENTRYPOINT ["npm run sync"]

action.yml

@@ -1,5 +1,5 @@
-name: 'Hello World'
-description: 'Greet someone and record the time'
+name: 'Sync repo docs to notion'
+description: 'Sync all you repository md files to notion wiki'
 inputs:
   who-to-greet:  # id of input
     description: 'Who to greet'
@@ -9,5 +9,7 @@ outputs:
   time: # id of output
     description: 'The time we greeted you'
 runs:
-  using: 'node16'
-  main: 'index.js'
+  using: 'docker'
+  image: 'Dockerfile'
+  args:
+    - ${{ inputs.who-to-greet }}

index.js

@@ -1,15 +1,101 @@
-const core = require('@actions/core');
-const github = require('@actions/github');
-
-try {
-  // `who-to-greet` input defined in action metadata file
-  const nameToGreet = core.getInput('who-to-greet');
-  console.log(`Hello ${nameToGreet}!`);
-  const time = (new Date()).toTimeString();
-  core.setOutput("time", time);
-  // Get the JSON webhook payload for the event that triggered the workflow
-  const payload = JSON.stringify(github.context.payload, undefined, 2)
-  console.log(`The event payload: ${payload}`);
-} catch (error) {
-  core.setFailed(error.message);
+const fs = require("fs");
+const { globSync } = require("glob");
+const { markdownToBlocks } = require('@tryfabric/martian');
+const { Client } = require("@notionhq/client");
+const { nextTick } = require("process");
+const { root } = require("@tryfabric/martian/build/src/markdown");
+
+// TODO: add sleep interval for all requests
+// TODO: fix tables width
+// TODO: NEXT: add content-only update (no pages re-creation)
+
+['FOLDER', 'NOTION_TOKEN', 'NOTION_ROOT_ID'].forEach((varName) => {
+  if (!process.env[varName]) {
+    console.log(`${varName} not provided`)
+    process.exit(1)
+  }
+})
+
+const notionUrlMatch = process.env.NOTION_ROOT_ID.match(/[^-]*$/)
+if (notionUrlMatch == null) {
+  throw new SyntaxError('Provided page was not in a valid format, url must end with "-<page-id>"');
 }
+const notionPageId = notionUrlMatch[0]
+
+const notion = new Client({
+  auth: process.env.NOTION_TOKEN 
+})
+
+notion.pages.retrieve({ page_id: notionPageId }).then((rootPage) => {
+  // console.log("Root page-> ", rootPage)
+
+  var files = globSync(`${process.env.FOLDER}/**/*.md`, { ignore: 'node_modules/**' })
+  // console.log("Files to sync ->", files)
+
+  notion.blocks.children.list({block_id: notionPageId}).then((blocksResponse) => {
+    const blockIdsToRemove = blocksResponse.results.map((e) => e.id)
+
+    // sequencially delete all page blocks
+    var doDelete = function(idToDelete) {
+      if (!idToDelete) return;
+
+      notion.blocks.delete({
+        block_id: idToDelete
+      }).then(function() {
+        console.log("Block deleted:", idToDelete)
+        if (idToDelete != blockIdsToRemove[blockIdsToRemove.length - 1]) {
+          nextDeleteId = blockIdsToRemove[blockIdsToRemove.indexOf(idToDelete) + 1]
+          doDelete(nextDeleteId)
+        }
+      })
+    }
+
+    doDelete(blockIdsToRemove[0])
+    console.log('Block deletion complete')
+
+    var doCreate = (filePath) => {
+      const mdContent = fs.readFileSync(filePath, 'utf8')
+      const newBlocks = markdownToBlocks(mdContent)
+
+      var title
+
+      try {
+        title = newBlocks[0][newBlocks[0].type].rich_text[0].text.content
+      } catch (error) {
+        console.log("Cannot extract page title from", newBlocks[0])
+        process.exit(1)
+      }
+
+      notion.pages.create({
+        parent: {
+          type: "page_id",
+          page_id: rootPage.id
+        },
+        properties: {
+          "title": {
+            "title": [{ "text": { "content": title} }], type: "title"
+          }
+        },
+      }).then((pageResponse) => {
+        console.log('Page created', pageResponse)
+
+        notion.blocks.children.append({ block_id: pageResponse.id, children: newBlocks }).then(() => {
+          // process next page
+          if (filePath != files[files.length - 1]) {
+            doCreate(files[files.indexOf(filePath) + 1])
+          }
+        })
+
+      }).catch((error) => {
+        console.log("Page creation failed", error)
+        process.exit(1)
+      })
+    }
+
+    doCreate(files[0])
+  })
+
+}).catch((error) => {
+  console.log("Root page not found", error.body)
+  process.exit(1)
+})