ZipCache.js

   1 /*
   2  * Copyright (C) 2018 Nick Downing <nick@ndcode.org>
   3  * SPDX-License-Identifier: MIT
   4  *
   5  * Permission is hereby granted, free of charge, to any person obtaining a copy
   6  * of this software and associated documentation files (the "Software"), to
   7  * deal in the Software without restriction, including without limitation the
   8  * rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
   9  * sell copies of the Software, and to permit persons to whom the Software is
  10  * furnished to do so, subject to the following conditions:
  11  *
  12  * The above copyright notice and this permission notice shall be included in
  13  * all copies or substantial portions of the Software.
  14  *
  15  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
  16  * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
  17  * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
  18  * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
  19  * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
  20  * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
  21  * IN THE SOFTWARE.
  22  */
  23
  24 let BuildCache = require('@ndcode/build_cache')
  25 let stream_buffers = require('stream-buffers')
  26 let util = require('util')
  27 let yauzl = require('yauzl')
  28
  29 let yauzl_open = util.promisify(yauzl.open)
  30
  31 let ZipCache = function(diag1, diag) {
  32   if (!this instanceof ZipCache)
  33     throw new Error('ZipCache is a constructor')
  34   BuildCache.call(this, diag)
  35   this.diag1 = diag1
  36 }
  37
  38 ZipCache.prototype = Object.create(BuildCache.prototype)
  39
  40 ZipCache.prototype.build = async function(key, result) {
  41   let zipfile = await yauzl_open(key, {autoClose: false})
  42   if (this.diag1)
  43     console.log(`loading zip file ${key}`)
  44
  45   let entries = []
  46   await new Promise(
  47     (resolve, reject) => {
  48       zipfile.
  49       on('entry', entry => {entries.push(entry)}).
  50       on('end', () => resolve())
  51     }
  52   )
  53
  54   result.value = {}
  55   for (let i = 0; i < entries.length; ++i) {
  56     let read_stream = await new Promise(
  57       (resolve, reject) => {
  58         zipfile.openReadStream(
  59           entries[i],
  60           (err, stream) => {
  61             if (err)
  62               reject(err)
  63             resolve(stream)
  64           }
  65         )
  66       }
  67     )
  68
  69     let write_stream = new stream_buffers.WritableStreamBuffer()
  70     let data = new Promise(
  71       (resolve, reject) => {
  72         write_stream.
  73         on('finish', () => {resolve(write_stream.getContents())}).
  74         on('error', err => {reject(err)})
  75       }
  76     )
  77     read_stream.pipe(write_stream)
  78     data = await data
  79
  80     let entry_pathname = '/' + entries[i].fileName
  81     if (this.diag1)
  82       console.log(`entry pathname ${entry_pathname} size ${data.length}`)
  83     result.value[entry_pathname] = data
  84   }
  85   await zipfile.close()
  86 }
  87
  88 module.exports = ZipCache