バケットからファイルを公開する#

// forepaas/s3-sample/factory.js
const express = require('express')
const router = express.Router()
const AWS = require('aws-sdk')
const util = require('util')


// Modify those values for your environment
let accessKey = 'YOUR_ACCESS_KEY'
let secretKey = 'YOUR_SECRET_KEY'
let endpoint = 'https://YOUR_PROJECT_SUBDOMAIN.eu.dataplatform.ovh.net'
let bucket = 'project-YOUR_PROJECTID-YOUR_BUCKET'
let region = 'forepaas'


// If no authentication is bind, it will use that default function
let defaultDependencies = {
  authentication: {
    checkSession:(req,cb) => cb()
  }
}
  
let dependencies = {}
let factory = new AbstractFactory(dependencies)

let createSuper = factory.create
factory.create = function(moduleName) {
  createSuper.call(moduleName)
  this.moduleName = 's3-sample'
  factory.setDependencies(defaultDependencies)
  let dependencies = this.getDependencies()

  // Use authentication if binded in forepaas.json
  router.use(async (req,res,next)=>{
    try {
      req.session = await util.promisify(dependencies.authentication.checkSession)(req)
      next()
    } catch (err) {
      next(err)
    }
  })

  // Set our custom endpoint
  // Will be available on GET /s3-sample/custom-endpoint
  router.get('/custom-endpoint',async (req,res,next)=>{
    try {
      // Use s3 connector, to get a file in datstore
      const dataStoreClient = new AWS.S3({
        accessKeyId: accessKey,
        secretAccessKey: secretKey,
        endpoint: `${endpoint}/datastore`,
        region: region,
        signatureVersion: 'v4',
        s3ForcePathStyle: true
      })

      dataStoreClient.getObject({
        Bucket: bucket,
        Key: 'my-file.csv'
      })
      .createReadStream()
      .on('error', (err) => {
        next(err)
      })
      .pipe(res)
    } catch (err) {
      next(err)
    }
  })

  // Initialise the router for enable endpoint
  this.initRouter(router)
  return this
}

module.exports = factory