import {
  LocalWorkspace,
  ConcurrentUpdateError,
  StackAlreadyExistsError,
  StackNotFoundError, InlineProgramArgs, ProjectSettings
} from '@pulumi/pulumi/automation'
import express from "express";
import { DB } from '../client-platform/database'
const projectName = 'summa-development'

const workDir = './'; // Path to your server directory


const createPulumiProgram = (content: string) => async () => {
  const DatabaseParameters = {
    name: 'summa-test-primary',
    region: 'us-east1',
    environment: 'production',
    diskSize: 25,
    tier: 'db-f1-micro',
    replica: true,
    secondaryRegion: 'us-central1',
    secondaryName: 'summa-test-secondary',
  }
  const db = new DB(DatabaseParameters)
  return db;
}

const createHandler: express.RequestHandler = async (req, res) => {
  const stackName = 'automation-api'
  const content = req.body.content as string
  const db = createPulumiProgram(content)
  const args: InlineProgramArgs = {
    stackName: stackName,
    projectName: projectName,
    program: db,
  };

  const projectSettings: ProjectSettings = {
    name: projectName,
    runtime: "nodejs",
    backend: {
      url: '<gs://client-platform-pulumi-state>',
    },
  };
  try {

    const stack = await LocalWorkspace.createOrSelectStack(args, {
      projectSettings,
      secretsProvider,
      stackSettings: {
        [stackName]: {
          secretsProvider,
        },
      },
    })

    const upRes = await stack.up({ onOutput: console.info })
    res.json({ id: stackName })
  } catch (e) {
    if (e instanceof StackAlreadyExistsError) {
      res.status(409).send(`stack "${stackName}" already exists`)
    } else {
      res.status(500).send(e)
    }
  }
}

// deletes a site
const deleteHandler: express.RequestHandler = async (req, res) => {
  const stackName = req.params.id
  try {
    // select the existing stack
    const stack = await LocalWorkspace.selectStack({
      stackName,
      projectName,
      // don't need a program for destroy
      program: async () => { },
    })
    // deploy the stack, tailing the logs to console
    await stack.destroy({ onOutput: console.info })
    await stack.workspace.removeStack(stackName)
    res.status(200).end()
  } catch (e) {
    if (e instanceof StackNotFoundError) {
      res.status(404).send(`stack "${stackName}" does not exist`)
    } else if (e instanceof ConcurrentUpdateError) {
      res
        .status(409)
        .send(`stack "${stackName}" already has update in progress`)
    } else {
      res.status(500).send(e)
    }
  }
}
const ensurePlugins = async () => {
  const ws = await LocalWorkspace.create({
    workDir: workDir,
  })
  await ws.installPlugin('gcp', '6.0.0')
}

// install necessary plugins once upon boot
// ensurePlugins()

const app = express()
app.use(express.json())

app.post('/', createHandler)
app.delete('/:id', deleteHandler)

app.listen(1337, () => console.info('server running on :1337'))

Updating (automation-api):
    pulumi:pulumi:Stack summa-development-automation-api running

    pulumi:pulumi:Stack summa-development-automation-api
Resources:
    + 1 created

Duration: 3s