FileHandle.js 2.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172
  1. "use strict";
  2. Object.defineProperty(exports, "__esModule", { value: true });
  3. exports.FileHandle = void 0;
  4. const util_1 = require("./util");
  5. class FileHandle {
  6. constructor(fs, fd) {
  7. this.fs = fs;
  8. this.fd = fd;
  9. }
  10. appendFile(data, options) {
  11. return (0, util_1.promisify)(this.fs, 'appendFile')(this.fd, data, options);
  12. }
  13. chmod(mode) {
  14. return (0, util_1.promisify)(this.fs, 'fchmod')(this.fd, mode);
  15. }
  16. chown(uid, gid) {
  17. return (0, util_1.promisify)(this.fs, 'fchown')(this.fd, uid, gid);
  18. }
  19. close() {
  20. return (0, util_1.promisify)(this.fs, 'close')(this.fd);
  21. }
  22. datasync() {
  23. return (0, util_1.promisify)(this.fs, 'fdatasync')(this.fd);
  24. }
  25. createReadStream(options) {
  26. return this.fs.createReadStream('', Object.assign(Object.assign({}, options), { fd: this }));
  27. }
  28. createWriteStream(options) {
  29. return this.fs.createWriteStream('', Object.assign(Object.assign({}, options), { fd: this }));
  30. }
  31. readableWebStream(options) {
  32. return new ReadableStream({
  33. pull: async (controller) => {
  34. const data = await this.readFile();
  35. controller.enqueue(data);
  36. controller.close();
  37. },
  38. });
  39. }
  40. read(buffer, offset, length, position) {
  41. return (0, util_1.promisify)(this.fs, 'read', bytesRead => ({ bytesRead, buffer }))(this.fd, buffer, offset, length, position);
  42. }
  43. readv(buffers, position) {
  44. return (0, util_1.promisify)(this.fs, 'readv', bytesRead => ({ bytesRead, buffers }))(this.fd, buffers, position);
  45. }
  46. readFile(options) {
  47. return (0, util_1.promisify)(this.fs, 'readFile')(this.fd, options);
  48. }
  49. stat(options) {
  50. return (0, util_1.promisify)(this.fs, 'fstat')(this.fd, options);
  51. }
  52. sync() {
  53. return (0, util_1.promisify)(this.fs, 'fsync')(this.fd);
  54. }
  55. truncate(len) {
  56. return (0, util_1.promisify)(this.fs, 'ftruncate')(this.fd, len);
  57. }
  58. utimes(atime, mtime) {
  59. return (0, util_1.promisify)(this.fs, 'futimes')(this.fd, atime, mtime);
  60. }
  61. write(buffer, offset, length, position) {
  62. return (0, util_1.promisify)(this.fs, 'write', bytesWritten => ({ bytesWritten, buffer }))(this.fd, buffer, offset, length, position);
  63. }
  64. writev(buffers, position) {
  65. return (0, util_1.promisify)(this.fs, 'writev', bytesWritten => ({ bytesWritten, buffers }))(this.fd, buffers, position);
  66. }
  67. writeFile(data, options) {
  68. return (0, util_1.promisify)(this.fs, 'writeFile')(this.fd, data, options);
  69. }
  70. }
  71. exports.FileHandle = FileHandle;
  72. //# sourceMappingURL=FileHandle.js.map