const { parse } = require("path")
const get = require("lodash.get")

const { addedFileContents, modifiedFileContents } = event

// Pull existing file-article mappings from workflow state:
// https://docs.pipedream.com/workflows/steps/code/state/
const fileArticleMappings = get($checkpoint, 'fileArticleMappings', {})

// ADDED FILES - Create new article
for (const file of addedFileContents) {
  // Parse markdown to see if front-matter exists. If it doesn't,
  // use the filename as the title.
  const { contents, path } = file

  // Generate a title from the filename, as a fallback.
  // DEV prefers the title present in the YAML front matter,
  // so the filename-based title will be ignored if front matter is present.

  const { name } = parse(path)
  // my-first-post.md -> my first post
  // My_First_Post.md -> My First Post
  // My First Post.md -> My First Post
  title = name.replace(/[-_]/g, " ")

  // Create article in dev.to
  const { id } = await createArticle(contents, title)
  console.log(`Created new article tied to file ${path}`)

  // Once the article has been successfully created, store its article ID
  // in $checkpoint so we know what file is matched to what dev.to article.
  fileArticleMappings[path] = id
}

// MODIFIED FILES - Update article
for (const file of modifiedFileContents) {
  const { path, contents } = file

  // See above for title-generation logic
  const { name } = parse(path)
  title = name.replace(/[-_]/g, " ")

  // If this workflow was added to an existing git repo, there may be files
  // previously added to git that weren't yet added to DEV.
  // In that case, we create a new article and store its file -> article mapping
  if (!(path in fileArticleMappings)) {
    console.log(`Updated file ${path} not tracked in dev.to. Creating new article!`)
    const { id } = await createArticle(contents, title)
    fileArticleMappings[path] = id
    continue
  }

  // Otherwise, we already have an article associated with this file 
  // in DEV, so we update
  console.log(`Updating article tied to file ${path}`)
  await updateArticle(fileArticleMappings[path], contents, title)
}

// Save file -> article mappings back to $checkpoint
$checkpoint = {
  ...$checkpoint,
  fileArticleMappings,
}

// HELPER FUNCTIONS
async function createArticle(body_markdown, title) {
  return await require("@pipedreamhq/platform").axios(this, {
    method: "POST",
    url: `https://dev.to/api/articles`,
    headers: {
      "api-key": `${auths.dev_to.api_key}`,
      "Content-Type": "application/json"
    },
    data: {
      article: {
        body_markdown,
        title,
      }
    }
  })
}

async function updateArticle(id, body_markdown, title) {
  return await require("@pipedreamhq/platform").axios(this, {
    method: "PUT",
    url: `https://dev.to/api/articles/${id}`,
    headers: {
      "api-key": `${auths.dev_to.api_key}`,
      "Content-Type": "application/json"
    },
    data: {
      article: {
        body_markdown,
        title,
      }
    }
  })
}