add it working

Author: sw-yx

src/commands/functions/create.js

@@ -5,24 +5,29 @@ const { flags } = require('@oclif/command')
 const Command = require('@netlify/cli-utils')
 const inquirer = require('inquirer')
 const readRepoURL = require('../../utils/readRepoURL')
+const { createSiteAddon } = require('../../utils/addons')
 const http = require('http')
 const fetch = require('node-fetch')
 const cp = require('child_process')
+const { createAddon } = require('netlify/src/addons')
 
 const templatesDir = path.resolve(__dirname, '../../functions-templates')
 
+/**
+ * Be very clear what is the SOURCE (templates dir) vs the DEST (functions dir)
+ */
 class FunctionsCreateCommand extends Command {
   async run() {
     const { flags, args } = this.parse(FunctionsCreateCommand)
-    const { config } = this.netlify
-
+    const { config, api, site } = this.netlify
+    const accessToken = await this.authenticate()
     const functionsDir = ensureFunctionDirExists(flags, config, this.log)
 
     /* either download from URL or scaffold from template */
     if (flags.url) {
       await downloadFromURL(flags, args, functionsDir)
     } else {
-      await scaffoldFromTemplate(flags, args, functionsDir, this.log)
+      await scaffoldFromTemplate(flags, args, functionsDir, api, site, accessToken, this.log)
     }
   }
 }
@@ -83,23 +88,31 @@ async function getNameFromArgs(args, flags, defaultName) {
 
 // pick template from our existing templates
 async function pickTemplate() {
-  // let templates = fs.readdirSync(templatesDir).filter(x => x.split('.').length === 1) // only folders
-  const registry = require(path.join(templatesDir, 'template-registry.js'))
-  let templates = registry.sort((a, b) => (a.priority || 999) - (b.priority || 999)) // doesnt scale but will be ok for now
+  // doesnt scale but will be ok for now
+  const registries = ['js', 'ts', 'go'].flatMap(formatRegistryArrayForInquirer)
   const { chosentemplate } = await inquirer.prompt([
     {
       name: 'chosentemplate',
       message: 'pick a template',
       type: 'list',
-      choices: templates.map(t => ({
-        // confusing but this is the format inquirer wants
-        name: t.description,
-        value: t.name,
-        short: t.name
-      }))
+      choices: registries
     }
   ])
-  return registry.find(x => x.name === chosentemplate)
+  return chosentemplate
+  function formatRegistryArrayForInquirer(lang) {
+    const registry = require(path.join(templatesDir, lang, 'template-registry.js'))
+      .sort((a, b) => (a.priority || 999) - (b.priority || 999))
+      .map(t => {
+        t.lang = lang
+        return {
+          // confusing but this is the format inquirer wants
+          name: `[${lang}] ` + t.description,
+          value: t,
+          short: lang + '-' + t.name
+        }
+      })
+    return [new inquirer.Separator(`----[${lang.toUpperCase()}]----`), ...registry]
+  }
 }
 
 /* get functions dir (and make it if necessary) */
@@ -150,10 +163,10 @@ async function downloadFromURL(flags, args, functionsDir) {
 }
 
 // no --url flag specified, pick from a provided template
-async function scaffoldFromTemplate(flags, args, functionsDir, log) {
-  const { onComplete, name: templateName } = await pickTemplate() // pull the rest of the metadata from the template
+async function scaffoldFromTemplate(flags, args, functionsDir, api, site, accessToken, log) {
+  const { onComplete, name: templateName, lang, addons = [] } = await pickTemplate() // pull the rest of the metadata from the template
 
-  const pathToTemplate = path.join(templatesDir, templateName)
+  const pathToTemplate = path.join(templatesDir, lang, templateName)
   if (!fs.existsSync(pathToTemplate)) {
     throw new Error(`there isnt a corresponding folder to the selected name, ${templateName} template is misconfigured`)
   }
@@ -184,6 +197,20 @@ async function scaffoldFromTemplate(flags, args, functionsDir, log) {
       })
     }
 
+    if (addons.length) {
+      const siteId = site.id
+      if (!siteId) {
+        this.log('No site id found, please run inside a site folder or `netlify link`')
+        return false
+      }
+      api.getSite({ siteId }).then(async siteData => {
+        const arr = addons.map(addonName => {
+          log('installing addon: ' + addonName)
+          return createSiteAddon(accessToken, addonName, siteId, siteData, log)
+        })
+        return Promise.all(arr)
+      })
+    }
     if (onComplete) onComplete() // do whatever the template wants to do after it is scaffolded
   })
 }

src/functions-templates/README.md

@@ -6,17 +6,4 @@ place new templates here and our CLI will pick it up. each template must be in i
 
 we dont colocate this inside `src/commands/functions` because oclif will think it's a new command.
 
-<!--
-## providing metadata (and other functionality)
-
-we split the file based on the `// --- Netlify Template Below -- //` string. everything below it is cloned as the template. everything above it can be required and run as a module for configuring the template. for now we simply export a `metadata` object that fits [`inquirer's choices spec`](https://www.npmjs.com/package/inquirer#question).
-
-once the templating is done we can also call an `onComplete` hook to print a reminder or execute other logic - see `node-fetch.js` for an example.
-
-you can optionally set a `priority` to pin display order.
-
-in future we can think about other options we may want to offer.
-
-## future dev thoughts
-
-we will want a way to scale this to TS and Go as well. -->
+every function should be registered with their respective `template-registry.js`.

src/functions-templates/go/hello-world/hello-world.go

@@ -0,0 +1,18 @@
+package main
+
+import (
+	"github.com/aws/aws-lambda-go/events"
+	"github.com/aws/aws-lambda-go/lambda"
+)
+
+func handler(request events.APIGatewayProxyRequest) (*events.APIGatewayProxyResponse, error) {
+	return &events.APIGatewayProxyResponse{
+		StatusCode: 200,
+		Body:       "Hello, World",
+	}, nil
+}
+
+func main() {
+	// Make the handler available for Remote Procedure Call by AWS Lambda
+	lambda.Start(handler)
+}

src/functions-templates/go/template-registry.js

@@ -0,0 +1,12 @@
+// every object should have:
+// //  a 'name' field that corresponds to a folder
+// // "description" is just what shows in the CLI but we use the name as the identifier
+// onComplete is optional.
+// priority is optional - for controlling what shows first in CLI
+module.exports = [
+  {
+    name: 'hello-world',
+    priority: 1,
+    description: 'Basic Hello World function in Golang'
+  }
+]

src/functions-templates/auth-fetch/auth-fetch.js renamed to src/functions-templates/js/auth-fetch/auth-fetch.js

@@ -0,0 +1,36 @@
+const faunadb = require('faunadb')
+
+/* configure faunaDB Client with our secret */
+const q = faunadb.query
+const client = new faunadb.Client({
+  secret: process.env.FAUNADB_SERVER_SECRET
+})
+
+/* export our lambda function as named "handler" export */
+exports.handler = (event, context, callback) => {
+  /* parse the string body into a useable JS object */
+  const data = JSON.parse(event.body)
+  console.log('Function `todo-create` invoked', data)
+  const todoItem = {
+    data: data
+  }
+  /* construct the fauna query */
+  return client
+    .query(q.Create(q.Ref('classes/todos'), todoItem))
+    .then(response => {
+      console.log('success', response)
+      /* Success! return the response with statusCode 200 */
+      return callback(null, {
+        statusCode: 200,
+        body: JSON.stringify(response)
+      })
+    })
+    .catch(error => {
+      console.log('error', error)
+      /* Error! return the error with statusCode 400 */
+      return callback(null, {
+        statusCode: 400,
+        body: JSON.stringify(error)
+      })
+    })
+}

src/functions-templates/auth-fetch/package-lock.json renamed to src/functions-templates/js/auth-fetch/package-lock.json

@@ -0,0 +1,32 @@
+/* Import faunaDB sdk */
+const faunadb = require('faunadb')
+
+function getId(urlPath) {
+  return urlPath.match(/([^\/]*)\/*$/)[0]
+}
+
+const q = faunadb.query
+const client = new faunadb.Client({
+  secret: process.env.FAUNADB_SERVER_SECRET
+})
+
+exports.handler = (event, context, callback) => {
+  const id = getId(event.path)
+  console.log(`Function 'todo-delete' invoked. delete id: ${id}`)
+  return client
+    .query(q.Delete(q.Ref(`classes/todos/${id}`)))
+    .then(response => {
+      console.log('success', response)
+      return callback(null, {
+        statusCode: 200,
+        body: JSON.stringify(response)
+      })
+    })
+    .catch(error => {
+      console.log('error', error)
+      return callback(null, {
+        statusCode: 400,
+        body: JSON.stringify(error)
+      })
+    })
+}

src/functions-templates/auth-fetch/package.json renamed to src/functions-templates/js/auth-fetch/package.json

@@ -0,0 +1,14 @@
+exports.handler = async (event, context, callback) => {
+  const { action } = event.queryStringParameters
+  switch (action) {
+    case 'create':
+      return require('./create').handler(event, context, callback)
+    case 'read':
+      return require('./read').handler(event, context, callback)
+    case 'update':
+      return require('./update').handler(event, context, callback)
+    case 'delete':
+      return require('./delete').handler(event, context, callback)
+  }
+  return { statusCode: 500, body: 'unrecognized action ' + action }
+}