Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More →
Socket
Socket
Sign inDemoInstall

@es-git/packfile

Package Overview
Dependencies
Maintainers
1
Versions
13
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@es-git/packfile - npm Package Compare versions

Comparing version 0.8.3 to 0.9.0

es/apply-delta.d.ts.map
es/compose-packfile.d.ts.map
es/DigestableAsyncBuffer.d.ts.map
es/DigestableAsyncBuffer.test.d.ts.map
es/index.d.ts.map
es/index.test.d.ts.map
es/normalize-entries.d.ts.map
es/pack.d.ts.map
es/parse-packfile.d.ts.map
es/pipe.d.ts.map
es/pipe.test.d.ts.map
es/types.d.ts.map
es/unpack.d.ts.map
es/unpack.test.d.ts.map

1

es/apply-delta.d.ts
export default function applyDelta(delta: Uint8Array, base: Uint8Array): Uint8Array;
//# sourceMappingURL=apply-delta.d.ts.map

1

es/compose-packfile.d.ts
import { Entry } from './types';
export default function composePackfile(items: AsyncIterableIterator<Entry>, count: number): AsyncIterableIterator<Uint8Array>;
//# sourceMappingURL=compose-packfile.d.ts.map

20

es/compose-packfile.js

@@ -0,7 +1,9 @@

var __await = (this && this.__await) || function (v) { return this instanceof __await ? (this.v = v, this) : new __await(v); }
var __asyncValues = (this && this.__asyncValues) || function (o) {
if (!Symbol.asyncIterator) throw new TypeError("Symbol.asyncIterator is not defined.");
var m = o[Symbol.asyncIterator];
return m ? m.call(o) : typeof __values === "function" ? __values(o) : o[Symbol.iterator]();
var m = o[Symbol.asyncIterator], i;
return m ? m.call(o) : (o = typeof __values === "function" ? __values(o) : o[Symbol.iterator](), i = {}, verb("next"), verb("throw"), verb("return"), i[Symbol.asyncIterator] = function () { return this; }, i);
function verb(n) { i[n] = o[n] && function (v) { return new Promise(function (resolve, reject) { v = o[n](v), settle(resolve, reject, v.done, v.value); }); }; }
function settle(resolve, reject, d, v) { Promise.resolve(v).then(function(v) { resolve({ value: v, done: d }); }, reject); }
};
var __await = (this && this.__await) || function (v) { return this instanceof __await ? (this.v = v, this) : new __await(v); }
var __asyncGenerator = (this && this.__asyncGenerator) || function (thisArg, _arguments, generator) {

@@ -13,3 +15,3 @@ if (!Symbol.asyncIterator) throw new TypeError("Symbol.asyncIterator is not defined.");

function resume(n, v) { try { step(g[n](v)); } catch (e) { settle(q[0][3], e); } }
function step(r) { r.value instanceof __await ? Promise.resolve(r.value.v).then(fulfill, reject) : settle(q[0][2], r); }
function step(r) { r.value instanceof __await ? Promise.resolve(r.value.v).then(fulfill, reject) : settle(q[0][2], r); }
function fulfill(value) { resume("next", value); }

@@ -24,9 +26,10 @@ function reject(value) { resume("throw", value); }

return __asyncGenerator(this, arguments, function* composePackfile_1() {
var e_1, _a;
const hash = sha1();
yield hash.update(packHeader(count));
yield yield __await(hash.update(packHeader(count)));
try {
for (var items_1 = __asyncValues(items), items_1_1; items_1_1 = yield __await(items_1.next()), !items_1_1.done;) {
const item = yield __await(items_1_1.value);
const item = yield yield __await(__await(items_1_1.value));
for (const chunk of packFrame(item)) {
yield hash.update(chunk);
yield yield __await(hash.update(chunk));
}

@@ -42,4 +45,3 @@ }

}
yield packHash(hash.digest());
var e_1, _a;
yield yield __await(packHash(hash.digest()));
});

@@ -46,0 +48,0 @@ }

1

es/DigestableAsyncBuffer.d.ts

@@ -14,1 +14,2 @@ import { AsyncBuffer } from '@es-git/core';

}
//# sourceMappingURL=DigestableAsyncBuffer.d.ts.map

1

es/DigestableAsyncBuffer.test.d.ts
export {};
//# sourceMappingURL=DigestableAsyncBuffer.test.d.ts.map

1

es/index.d.ts
export { RawObject, Progress } from './types';
export { default as unpack } from './unpack';
export { default as pack, HashBlob } from './pack';
//# sourceMappingURL=index.d.ts.map

1

es/index.test.d.ts
export {};
//# sourceMappingURL=index.test.d.ts.map

1

es/normalize-entries.d.ts
import { Entry, RawObject, Progress } from './types';
export default function normalizeEntries(entries: AsyncIterableIterator<Entry>, progress?: Progress): AsyncIterableIterator<RawObject>;
export declare function encodeRaw(type: string, bytes: Uint8Array): Uint8Array;
//# sourceMappingURL=normalize-entries.d.ts.map

16

es/normalize-entries.js
var __asyncValues = (this && this.__asyncValues) || function (o) {
if (!Symbol.asyncIterator) throw new TypeError("Symbol.asyncIterator is not defined.");
var m = o[Symbol.asyncIterator];
return m ? m.call(o) : typeof __values === "function" ? __values(o) : o[Symbol.iterator]();
var m = o[Symbol.asyncIterator], i;
return m ? m.call(o) : (o = typeof __values === "function" ? __values(o) : o[Symbol.iterator](), i = {}, verb("next"), verb("throw"), verb("return"), i[Symbol.asyncIterator] = function () { return this; }, i);
function verb(n) { i[n] = o[n] && function (v) { return new Promise(function (resolve, reject) { v = o[n](v), settle(resolve, reject, v.done, v.value); }); }; }
function settle(resolve, reject, d, v) { Promise.resolve(v).then(function(v) { resolve({ value: v, done: d }); }, reject); }
};

@@ -13,3 +15,3 @@ var __await = (this && this.__await) || function (v) { return this instanceof __await ? (this.v = v, this) : new __await(v); }

function resume(n, v) { try { step(g[n](v)); } catch (e) { settle(q[0][3], e); } }
function step(r) { r.value instanceof __await ? Promise.resolve(r.value.v).then(fulfill, reject) : settle(q[0][2], r); }
function step(r) { r.value instanceof __await ? Promise.resolve(r.value.v).then(fulfill, reject) : settle(q[0][2], r); }
function fulfill(value) { resume("next", value); }

@@ -24,2 +26,3 @@ function reject(value) { resume("throw", value); }

return __asyncGenerator(this, arguments, function* normalizeEntries_1() {
var e_1, _a;
const references = new Map();

@@ -30,3 +33,3 @@ const offsets = new Map();

for (var entries_1 = __asyncValues(entries), entries_1_1; entries_1_1 = yield __await(entries_1.next()), !entries_1_1.done;) {
let entry = yield __await(entries_1_1.value);
let entry = yield yield __await(__await(entries_1_1.value));
if (entry.type === Type.ofsDelta

@@ -48,7 +51,7 @@ || entry.type === Type.refDelta) {

offsets.set(entry.offset, entry);
yield {
yield yield __await({
type,
body,
hash
};
});
}

@@ -80,3 +83,2 @@ }

}
var e_1, _a;
});

@@ -83,0 +85,0 @@ }

1

es/pack.d.ts
export declare type HashBlob = [string, Uint8Array];
export default function pack(objects: AsyncIterableIterator<HashBlob>, count: number): AsyncIterableIterator<Uint8Array>;
//# sourceMappingURL=pack.d.ts.map

33

es/pack.js
var __asyncValues = (this && this.__asyncValues) || function (o) {
if (!Symbol.asyncIterator) throw new TypeError("Symbol.asyncIterator is not defined.");
var m = o[Symbol.asyncIterator];
return m ? m.call(o) : typeof __values === "function" ? __values(o) : o[Symbol.iterator]();
var m = o[Symbol.asyncIterator], i;
return m ? m.call(o) : (o = typeof __values === "function" ? __values(o) : o[Symbol.iterator](), i = {}, verb("next"), verb("throw"), verb("return"), i[Symbol.asyncIterator] = function () { return this; }, i);
function verb(n) { i[n] = o[n] && function (v) { return new Promise(function (resolve, reject) { v = o[n](v), settle(resolve, reject, v.done, v.value); }); }; }
function settle(resolve, reject, d, v) { Promise.resolve(v).then(function(v) { resolve({ value: v, done: d }); }, reject); }
};

@@ -10,3 +12,3 @@ var __await = (this && this.__await) || function (v) { return this instanceof __await ? (this.v = v, this) : new __await(v); }

return i = {}, verb("next"), verb("throw", function (e) { throw e; }), verb("return"), i[Symbol.iterator] = function () { return this; }, i;
function verb(n, f) { if (o[n]) i[n] = function (v) { return (p = !p) ? { value: __await(o[n](v)), done: n === "return" } : f ? f(v) : v; }; }
function verb(n, f) { i[n] = o[n] ? function (v) { return (p = !p) ? { value: __await(o[n](v)), done: n === "return" } : f ? f(v) : v; } : f; }
};

@@ -19,3 +21,3 @@ var __asyncGenerator = (this && this.__asyncGenerator) || function (thisArg, _arguments, generator) {

function resume(n, v) { try { step(g[n](v)); } catch (e) { settle(q[0][3], e); } }
function step(r) { r.value instanceof __await ? Promise.resolve(r.value.v).then(fulfill, reject) : settle(q[0][2], r); }
function step(r) { r.value instanceof __await ? Promise.resolve(r.value.v).then(fulfill, reject) : settle(q[0][2], r); }
function fulfill(value) { resume("next", value); }

@@ -40,12 +42,13 @@ function reject(value) { resume("throw", value); }

return __asyncGenerator(this, arguments, function* toRawObject_1() {
var e_1, _a;
try {
for (var objects_1 = __asyncValues(objects), objects_1_1; objects_1_1 = yield __await(objects_1.next()), !objects_1_1.done;) {
const [hash, body] = yield __await(objects_1_1.value);
const [hash, body] = yield yield __await(__await(objects_1_1.value));
const space = body.indexOf(0x20);
const nil = body.indexOf(0x00, space);
yield {
yield yield __await({
body: body.subarray(nil + 1),
type: decode(body, 0, space),
hash: hash
};
});
}

@@ -60,3 +63,2 @@ }

}
var e_1, _a;
});

@@ -66,6 +68,7 @@ }

return __asyncGenerator(this, arguments, function* toEntry_1() {
var e_2, _a;
try {
for (var objects_2 = __asyncValues(objects), objects_2_1; objects_2_1 = yield __await(objects_2.next()), !objects_2_1.done;) {
const object = yield __await(objects_2_1.value);
yield {
const object = yield yield __await(__await(objects_2_1.value));
yield yield __await({
body: object.body,

@@ -76,3 +79,3 @@ type: object.type === 'commit' ? Type.commit

offset: 0
};
});
}

@@ -87,3 +90,2 @@ }

}
var e_2, _a;
});

@@ -93,2 +95,3 @@ }

return __asyncGenerator(this, arguments, function* sortByType_1() {
var e_3, _a;
const commits = [];

@@ -100,3 +103,3 @@ const trees = [];

for (var entries_1 = __asyncValues(entries), entries_1_1; entries_1_1 = yield __await(entries_1.next()), !entries_1_1.done;) {
const entry = yield __await(entries_1_1.value);
const entry = yield yield __await(__await(entries_1_1.value));
switch (entry.type) {

@@ -129,8 +132,4 @@ case Type.commit:

yield __await(yield* __asyncDelegator(__asyncValues(others)));
var e_3, _a;
});
}
function byType(a, b) {
return a.type - b.type;
}
//# sourceMappingURL=pack.js.map

1

es/parse-packfile.d.ts
import { Entry, Progress } from './types';
export default function parsePackfile(chunks: AsyncIterableIterator<Uint8Array>, progress?: Progress): AsyncIterableIterator<Entry>;
//# sourceMappingURL=parse-packfile.d.ts.map

4

es/parse-packfile.js

@@ -8,3 +8,3 @@ var __await = (this && this.__await) || function (v) { return this instanceof __await ? (this.v = v, this) : new __await(v); }

function resume(n, v) { try { step(g[n](v)); } catch (e) { settle(q[0][3], e); } }
function step(r) { r.value instanceof __await ? Promise.resolve(r.value.v).then(fulfill, reject) : settle(q[0][2], r); }
function step(r) { r.value instanceof __await ? Promise.resolve(r.value.v).then(fulfill, reject) : settle(q[0][2], r); }
function fulfill(value) { resume("next", value); }

@@ -27,3 +27,3 @@ function reject(value) { resume("throw", value); }

if (state.state === 'entry') {
yield state.entry;
yield yield __await(state.entry);
}

@@ -30,0 +30,0 @@ } while (state.state !== 'done');

1

es/pipe.d.ts

@@ -11,1 +11,2 @@ export default function pipe<TIn>(input: AsyncIterableIterator<TIn> | PipableAsyncIterableIterator<TIn>): PipableAsyncIterableIterator<TIn>;

}
//# sourceMappingURL=pipe.d.ts.map

1

es/pipe.test.d.ts
export {};
//# sourceMappingURL=pipe.test.d.ts.map

3

es/types.d.ts

@@ -7,3 +7,3 @@ export declare enum Type {

ofsDelta = 6,
refDelta = 7,
refDelta = 7
}

@@ -32,1 +32,2 @@ export interface AbstractEntry {

export declare type Progress = (message: string) => void;
//# sourceMappingURL=types.d.ts.map

1

es/unpack.d.ts
import { RawObject, Progress } from './types';
export { RawObject };
export default function unpack(chunks: AsyncIterableIterator<Uint8Array>, progress?: Progress): AsyncIterableIterator<RawObject>;
//# sourceMappingURL=unpack.d.ts.map

10

es/unpack.js
var __asyncValues = (this && this.__asyncValues) || function (o) {
if (!Symbol.asyncIterator) throw new TypeError("Symbol.asyncIterator is not defined.");
var m = o[Symbol.asyncIterator];
return m ? m.call(o) : typeof __values === "function" ? __values(o) : o[Symbol.iterator]();
var m = o[Symbol.asyncIterator], i;
return m ? m.call(o) : (o = typeof __values === "function" ? __values(o) : o[Symbol.iterator](), i = {}, verb("next"), verb("throw"), verb("return"), i[Symbol.asyncIterator] = function () { return this; }, i);
function verb(n) { i[n] = o[n] && function (v) { return new Promise(function (resolve, reject) { v = o[n](v), settle(resolve, reject, v.done, v.value); }); }; }
function settle(resolve, reject, d, v) { Promise.resolve(v).then(function(v) { resolve({ value: v, done: d }); }, reject); }
};

@@ -10,3 +12,3 @@ var __await = (this && this.__await) || function (v) { return this instanceof __await ? (this.v = v, this) : new __await(v); }

return i = {}, verb("next"), verb("throw", function (e) { throw e; }), verb("return"), i[Symbol.iterator] = function () { return this; }, i;
function verb(n, f) { if (o[n]) i[n] = function (v) { return (p = !p) ? { value: __await(o[n](v)), done: n === "return" } : f ? f(v) : v; }; }
function verb(n, f) { i[n] = o[n] ? function (v) { return (p = !p) ? { value: __await(o[n](v)), done: n === "return" } : f ? f(v) : v; } : f; }
};

@@ -19,3 +21,3 @@ var __asyncGenerator = (this && this.__asyncGenerator) || function (thisArg, _arguments, generator) {

function resume(n, v) { try { step(g[n](v)); } catch (e) { settle(q[0][3], e); } }
function step(r) { r.value instanceof __await ? Promise.resolve(r.value.v).then(fulfill, reject) : settle(q[0][2], r); }
function step(r) { r.value instanceof __await ? Promise.resolve(r.value.v).then(fulfill, reject) : settle(q[0][2], r); }
function fulfill(value) { resume("next", value); }

@@ -22,0 +24,0 @@ function reject(value) { resume("throw", value); }

1

es/unpack.test.d.ts
export {};
//# sourceMappingURL=unpack.test.d.ts.map

153

js/compose-packfile.js

@@ -39,10 +39,25 @@ "use strict";

var __await = undefined && undefined.__await || function (v) {
return this instanceof __await ? (this.v = v, this) : new __await(v);
};
var __asyncValues = undefined && undefined.__asyncValues || function (o) {
if (!_symbol2.default.asyncIterator) throw new TypeError("Symbol.asyncIterator is not defined.");
var m = o[_symbol2.default.asyncIterator];
return m ? m.call(o) : typeof __values === "function" ? __values(o) : (0, _getIterator3.default)(o);
var m = o[_symbol2.default.asyncIterator],
i;
return m ? m.call(o) : (o = typeof __values === "function" ? __values(o) : (0, _getIterator3.default)(o), i = {}, verb("next"), verb("throw"), verb("return"), i[_symbol2.default.asyncIterator] = function () {
return this;
}, i);
function verb(n) {
i[n] = o[n] && function (v) {
return new _promise2.default(function (resolve, reject) {
v = o[n](v), settle(resolve, reject, v.done, v.value);
});
};
}
function settle(resolve, reject, d, v) {
_promise2.default.resolve(v).then(function (v) {
resolve({ value: v, done: d });
}, reject);
}
};
var __await = undefined && undefined.__await || function (v) {
return this instanceof __await ? (this.v = v, this) : new __await(v);
};
var __asyncGenerator = undefined && undefined.__asyncGenerator || function (thisArg, _arguments, generator) {

@@ -85,3 +100,3 @@ if (!_symbol2.default.asyncIterator) throw new TypeError("Symbol.asyncIterator is not defined.");

return __asyncGenerator(this, arguments, /*#__PURE__*/_regenerator2.default.mark(function composePackfile_1() {
var hash, items_1, items_1_1, item, _iteratorNormalCompletion, _didIteratorError, _iteratorError, _iterator, _step, chunk, e_1, _a;
var e_1, _a, hash, items_1, items_1_1, item, _iteratorNormalCompletion, _didIteratorError, _iteratorError, _iterator, _step, chunk;

@@ -94,24 +109,32 @@ return _regenerator2.default.wrap(function composePackfile_1$(_context) {

_context.next = 3;
return hash.update(packHeader(count));
return __await(hash.update(packHeader(count)));
case 3:
_context.prev = 3;
_context.next = 5;
return _context.sent;
case 5:
_context.prev = 5;
items_1 = __asyncValues(items);
case 5:
_context.next = 7;
case 7:
_context.next = 9;
return __await(items_1.next());
case 7:
case 9:
items_1_1 = _context.sent;
if (items_1_1.done) {
_context.next = 40;
_context.next = 46;
break;
}
_context.next = 11;
return __await(items_1_1.value);
_context.next = 13;
return __await(__await(items_1_1.value));
case 11:
case 13:
_context.next = 15;
return _context.sent;
case 15:
item = _context.sent;

@@ -121,8 +144,8 @@ _iteratorNormalCompletion = true;

_iteratorError = undefined;
_context.prev = 15;
_context.prev = 19;
_iterator = (0, _getIterator3.default)(packFrame(item));
case 17:
case 21:
if (_iteratorNormalCompletion = (_step = _iterator.next()).done) {
_context.next = 24;
_context.next = 30;
break;

@@ -132,23 +155,27 @@ }

chunk = _step.value;
_context.next = 21;
return hash.update(chunk);
_context.next = 25;
return __await(hash.update(chunk));
case 21:
case 25:
_context.next = 27;
return _context.sent;
case 27:
_iteratorNormalCompletion = true;
_context.next = 17;
_context.next = 21;
break;
case 24:
_context.next = 30;
case 30:
_context.next = 36;
break;
case 26:
_context.prev = 26;
_context.t0 = _context["catch"](15);
case 32:
_context.prev = 32;
_context.t0 = _context["catch"](19);
_didIteratorError = true;
_iteratorError = _context.t0;
case 30:
_context.prev = 30;
_context.prev = 31;
case 36:
_context.prev = 36;
_context.prev = 37;

@@ -159,7 +186,7 @@ if (!_iteratorNormalCompletion && _iterator.return) {

case 33:
_context.prev = 33;
case 39:
_context.prev = 39;
if (!_didIteratorError) {
_context.next = 36;
_context.next = 42;
break;

@@ -170,38 +197,38 @@ }

case 36:
return _context.finish(33);
case 42:
return _context.finish(39);
case 37:
return _context.finish(30);
case 43:
return _context.finish(36);
case 38:
_context.next = 5;
case 44:
_context.next = 7;
break;
case 40:
_context.next = 45;
case 46:
_context.next = 51;
break;
case 42:
_context.prev = 42;
_context.t1 = _context["catch"](3);
case 48:
_context.prev = 48;
_context.t1 = _context["catch"](5);
e_1 = { error: _context.t1 };
case 45:
_context.prev = 45;
_context.prev = 46;
case 51:
_context.prev = 51;
_context.prev = 52;
if (!(items_1_1 && !items_1_1.done && (_a = items_1.return))) {
_context.next = 50;
_context.next = 56;
break;
}
_context.next = 50;
_context.next = 56;
return __await(_a.call(items_1));
case 50:
_context.prev = 50;
case 56:
_context.prev = 56;
if (!e_1) {
_context.next = 53;
_context.next = 59;
break;

@@ -212,13 +239,17 @@ }

case 53:
return _context.finish(50);
case 59:
return _context.finish(56);
case 54:
return _context.finish(45);
case 60:
return _context.finish(51);
case 55:
_context.next = 57;
return (0, _core.packHash)(hash.digest());
case 61:
_context.next = 63;
return __await((0, _core.packHash)(hash.digest()));
case 57:
case 63:
_context.next = 65;
return _context.sent;
case 65:
case "end":

@@ -228,3 +259,3 @@ return _context.stop();

}
}, composePackfile_1, this, [[3, 42, 45, 55], [15, 26, 30, 38], [31,, 33, 37], [46,, 50, 54]]);
}, composePackfile_1, this, [[5, 48, 51, 61], [19, 32, 36, 44], [37,, 39, 43], [52,, 56, 60]]);
}));

@@ -231,0 +262,0 @@ }

79

js/normalize-entries.js

@@ -42,4 +42,19 @@ "use strict";

if (!_symbol2.default.asyncIterator) throw new TypeError("Symbol.asyncIterator is not defined.");
var m = o[_symbol2.default.asyncIterator];
return m ? m.call(o) : typeof __values === "function" ? __values(o) : (0, _getIterator3.default)(o);
var m = o[_symbol2.default.asyncIterator],
i;
return m ? m.call(o) : (o = typeof __values === "function" ? __values(o) : (0, _getIterator3.default)(o), i = {}, verb("next"), verb("throw"), verb("return"), i[_symbol2.default.asyncIterator] = function () {
return this;
}, i);
function verb(n) {
i[n] = o[n] && function (v) {
return new _promise2.default(function (resolve, reject) {
v = o[n](v), settle(resolve, reject, v.done, v.value);
});
};
}
function settle(resolve, reject, d, v) {
_promise2.default.resolve(v).then(function (v) {
resolve({ value: v, done: d });
}, reject);
}
};

@@ -86,3 +101,3 @@ var __await = undefined && undefined.__await || function (v) {

return __asyncGenerator(this, arguments, /*#__PURE__*/_regenerator2.default.mark(function normalizeEntries_1() {
var references, offsets, deltas, entries_1, entries_1_1, entry, base, _body, type, body, hash, getBase, e_1, _a;
var e_1, _a, references, offsets, deltas, entries_1, entries_1_1, entry, base, _body, type, body, hash, getBase;

@@ -120,3 +135,3 @@ return _regenerator2.default.wrap(function normalizeEntries_1$(_context) {

if (entries_1_1.done) {
_context.next = 23;
_context.next = 27;
break;

@@ -126,5 +141,9 @@ }

_context.next = 12;
return __await(entries_1_1.value);
return __await(__await(entries_1_1.value));
case 12:
_context.next = 14;
return _context.sent;
case 14:
entry = _context.sent;

@@ -149,39 +168,43 @@

offsets.set(entry.offset, entry);
_context.next = 21;
return {
_context.next = 23;
return __await({
type: type,
body: body,
hash: hash
};
});
case 21:
case 23:
_context.next = 25;
return _context.sent;
case 25:
_context.next = 6;
break;
case 23:
_context.next = 28;
case 27:
_context.next = 32;
break;
case 25:
_context.prev = 25;
case 29:
_context.prev = 29;
_context.t0 = _context["catch"](4);
e_1 = { error: _context.t0 };
case 28:
_context.prev = 28;
_context.prev = 29;
case 32:
_context.prev = 32;
_context.prev = 33;
if (!(entries_1_1 && !entries_1_1.done && (_a = entries_1.return))) {
_context.next = 33;
_context.next = 37;
break;
}
_context.next = 33;
_context.next = 37;
return __await(_a.call(entries_1));
case 33:
_context.prev = 33;
case 37:
_context.prev = 37;
if (!e_1) {
_context.next = 36;
_context.next = 40;
break;

@@ -192,12 +215,12 @@ }

case 36:
return _context.finish(33);
case 40:
return _context.finish(37);
case 37:
return _context.finish(28);
case 41:
return _context.finish(32);
case 38:
case 42:
if (progress) progress("Resolving deltas: 100% (" + deltas + "/" + deltas + "), done.\n");
case 39:
case 43:
case "end":

@@ -207,3 +230,3 @@ return _context.stop();

}
}, normalizeEntries_1, this, [[4, 25, 28, 38], [29,, 33, 37]]);
}, normalizeEntries_1, this, [[4, 29, 32, 42], [33,, 37, 41]]);
}));

@@ -210,0 +233,0 @@ }

248

js/pack.js

@@ -19,2 +19,6 @@ "use strict";

var _iterator = require("babel-runtime/core-js/symbol/iterator");
var _iterator2 = _interopRequireDefault(_iterator);
var _promise = require("babel-runtime/core-js/promise");

@@ -24,6 +28,2 @@

var _iterator = require("babel-runtime/core-js/symbol/iterator");
var _iterator2 = _interopRequireDefault(_iterator);
var _getIterator2 = require("babel-runtime/core-js/get-iterator");

@@ -55,4 +55,19 @@

if (!_symbol2.default.asyncIterator) throw new TypeError("Symbol.asyncIterator is not defined.");
var m = o[_symbol2.default.asyncIterator];
return m ? m.call(o) : typeof __values === "function" ? __values(o) : (0, _getIterator3.default)(o);
var m = o[_symbol2.default.asyncIterator],
i;
return m ? m.call(o) : (o = typeof __values === "function" ? __values(o) : (0, _getIterator3.default)(o), i = {}, verb("next"), verb("throw"), verb("return"), i[_symbol2.default.asyncIterator] = function () {
return this;
}, i);
function verb(n) {
i[n] = o[n] && function (v) {
return new _promise2.default(function (resolve, reject) {
v = o[n](v), settle(resolve, reject, v.done, v.value);
});
};
}
function settle(resolve, reject, d, v) {
_promise2.default.resolve(v).then(function (v) {
resolve({ value: v, done: d });
}, reject);
}
};

@@ -70,5 +85,5 @@ var __await = undefined && undefined.__await || function (v) {

function verb(n, f) {
if (o[n]) i[n] = function (v) {
i[n] = o[n] ? function (v) {
return (p = !p) ? { value: __await(o[n](v)), done: n === "return" } : f ? f(v) : v;
};
} : f;
}

@@ -140,3 +155,3 @@ };

return __asyncGenerator(this, arguments, /*#__PURE__*/_regenerator2.default.mark(function toRawObject_1() {
var objects_1, objects_1_1, _ref, _ref2, hash, body, space, nil, e_1, _a;
var e_1, _a, objects_1, objects_1_1, _ref, _ref2, hash, body, space, nil;

@@ -158,3 +173,3 @@ return _regenerator2.default.wrap(function toRawObject_1$(_context2) {

if (objects_1_1.done) {
_context2.next = 18;
_context2.next = 22;
break;

@@ -164,5 +179,9 @@ }

_context2.next = 8;
return __await(objects_1_1.value);
return __await(__await(objects_1_1.value));
case 8:
_context2.next = 10;
return _context2.sent;
case 10:
_ref = _context2.sent;

@@ -174,39 +193,43 @@ _ref2 = (0, _slicedToArray3.default)(_ref, 2);

nil = body.indexOf(0x00, space);
_context2.next = 16;
return {
_context2.next = 18;
return __await({
body: body.subarray(nil + 1),
type: (0, _core.decode)(body, 0, space),
hash: hash
};
});
case 16:
case 18:
_context2.next = 20;
return _context2.sent;
case 20:
_context2.next = 2;
break;
case 18:
_context2.next = 23;
case 22:
_context2.next = 27;
break;
case 20:
_context2.prev = 20;
case 24:
_context2.prev = 24;
_context2.t0 = _context2["catch"](0);
e_1 = { error: _context2.t0 };
case 23:
_context2.prev = 23;
_context2.prev = 24;
case 27:
_context2.prev = 27;
_context2.prev = 28;
if (!(objects_1_1 && !objects_1_1.done && (_a = objects_1.return))) {
_context2.next = 28;
_context2.next = 32;
break;
}
_context2.next = 28;
_context2.next = 32;
return __await(_a.call(objects_1));
case 28:
_context2.prev = 28;
case 32:
_context2.prev = 32;
if (!e_1) {
_context2.next = 31;
_context2.next = 35;
break;

@@ -217,9 +240,9 @@ }

case 31:
return _context2.finish(28);
case 35:
return _context2.finish(32);
case 32:
return _context2.finish(23);
case 36:
return _context2.finish(27);
case 33:
case 37:
case "end":

@@ -229,3 +252,3 @@ return _context2.stop();

}
}, toRawObject_1, this, [[0, 20, 23, 33], [24,, 28, 32]]);
}, toRawObject_1, this, [[0, 24, 27, 37], [28,, 32, 36]]);
}));

@@ -235,3 +258,3 @@ }

return __asyncGenerator(this, arguments, /*#__PURE__*/_regenerator2.default.mark(function toEntry_1() {
var objects_2, objects_2_1, object, e_2, _a;
var e_2, _a, objects_2, objects_2_1, object;

@@ -253,3 +276,3 @@ return _regenerator2.default.wrap(function toEntry_1$(_context3) {

if (objects_2_1.done) {
_context3.next = 13;
_context3.next = 17;
break;

@@ -259,43 +282,51 @@ }

_context3.next = 8;
return __await(objects_2_1.value);
return __await(__await(objects_2_1.value));
case 8:
_context3.next = 10;
return _context3.sent;
case 10:
object = _context3.sent;
_context3.next = 11;
return {
_context3.next = 13;
return __await({
body: object.body,
type: object.type === 'commit' ? _types.Type.commit : object.type === 'tree' ? _types.Type.tree : _types.Type.blob,
offset: 0
};
});
case 11:
case 13:
_context3.next = 15;
return _context3.sent;
case 15:
_context3.next = 2;
break;
case 13:
_context3.next = 18;
case 17:
_context3.next = 22;
break;
case 15:
_context3.prev = 15;
case 19:
_context3.prev = 19;
_context3.t0 = _context3["catch"](0);
e_2 = { error: _context3.t0 };
case 18:
_context3.prev = 18;
_context3.prev = 19;
case 22:
_context3.prev = 22;
_context3.prev = 23;
if (!(objects_2_1 && !objects_2_1.done && (_a = objects_2.return))) {
_context3.next = 23;
_context3.next = 27;
break;
}
_context3.next = 23;
_context3.next = 27;
return __await(_a.call(objects_2));
case 23:
_context3.prev = 23;
case 27:
_context3.prev = 27;
if (!e_2) {
_context3.next = 26;
_context3.next = 30;
break;

@@ -306,9 +337,9 @@ }

case 26:
return _context3.finish(23);
case 30:
return _context3.finish(27);
case 27:
return _context3.finish(18);
case 31:
return _context3.finish(22);
case 28:
case 32:
case "end":

@@ -318,3 +349,3 @@ return _context3.stop();

}
}, toEntry_1, this, [[0, 15, 18, 28], [19,, 23, 27]]);
}, toEntry_1, this, [[0, 19, 22, 32], [23,, 27, 31]]);
}));

@@ -324,3 +355,3 @@ }

return __asyncGenerator(this, arguments, /*#__PURE__*/_regenerator2.default.mark(function sortByType_1() {
var commits, trees, blobs, others, entries_1, entries_1_1, entry, e_3, _a;
var e_3, _a, commits, trees, blobs, others, entries_1, entries_1_1, entry;

@@ -346,3 +377,3 @@ return _regenerator2.default.wrap(function sortByType_1$(_context4) {

if (entries_1_1.done) {
_context4.next = 26;
_context4.next = 28;
break;

@@ -352,56 +383,60 @@ }

_context4.next = 12;
return __await(entries_1_1.value);
return __await(__await(entries_1_1.value));
case 12:
_context4.next = 14;
return _context4.sent;
case 14:
entry = _context4.sent;
_context4.t0 = entry.type;
_context4.next = _context4.t0 === _types.Type.commit ? 16 : _context4.t0 === _types.Type.tree ? 18 : _context4.t0 === _types.Type.blob ? 20 : 22;
_context4.next = _context4.t0 === _types.Type.commit ? 18 : _context4.t0 === _types.Type.tree ? 20 : _context4.t0 === _types.Type.blob ? 22 : 24;
break;
case 16:
case 18:
commits.push(entry);
return _context4.abrupt("break", 24);
return _context4.abrupt("break", 26);
case 18:
case 20:
trees.push(entry);
return _context4.abrupt("break", 24);
return _context4.abrupt("break", 26);
case 20:
case 22:
blobs.push(entry);
return _context4.abrupt("break", 24);
return _context4.abrupt("break", 26);
case 22:
case 24:
others.push(entry);
return _context4.abrupt("break", 24);
return _context4.abrupt("break", 26);
case 24:
case 26:
_context4.next = 6;
break;
case 26:
_context4.next = 31;
case 28:
_context4.next = 33;
break;
case 28:
_context4.prev = 28;
case 30:
_context4.prev = 30;
_context4.t1 = _context4["catch"](4);
e_3 = { error: _context4.t1 };
case 31:
_context4.prev = 31;
_context4.prev = 32;
case 33:
_context4.prev = 33;
_context4.prev = 34;
if (!(entries_1_1 && !entries_1_1.done && (_a = entries_1.return))) {
_context4.next = 36;
_context4.next = 38;
break;
}
_context4.next = 36;
_context4.next = 38;
return __await(_a.call(entries_1));
case 36:
_context4.prev = 36;
case 38:
_context4.prev = 38;
if (!e_3) {
_context4.next = 39;
_context4.next = 41;
break;

@@ -412,45 +447,45 @@ }

case 39:
return _context4.finish(36);
case 41:
return _context4.finish(38);
case 40:
return _context4.finish(31);
case 42:
return _context4.finish(33);
case 41:
case 43:
_context4.t2 = __await;
return _context4.delegateYield(__asyncDelegator(__asyncValues(commits)), "t3", 43);
return _context4.delegateYield(__asyncDelegator(__asyncValues(commits)), "t3", 45);
case 43:
case 45:
_context4.t4 = _context4.t3;
_context4.next = 46;
_context4.next = 48;
return (0, _context4.t2)(_context4.t4);
case 46:
case 48:
_context4.t5 = __await;
return _context4.delegateYield(__asyncDelegator(__asyncValues(trees)), "t6", 48);
return _context4.delegateYield(__asyncDelegator(__asyncValues(trees)), "t6", 50);
case 48:
case 50:
_context4.t7 = _context4.t6;
_context4.next = 51;
_context4.next = 53;
return (0, _context4.t5)(_context4.t7);
case 51:
case 53:
_context4.t8 = __await;
return _context4.delegateYield(__asyncDelegator(__asyncValues(blobs)), "t9", 53);
return _context4.delegateYield(__asyncDelegator(__asyncValues(blobs)), "t9", 55);
case 53:
case 55:
_context4.t10 = _context4.t9;
_context4.next = 56;
_context4.next = 58;
return (0, _context4.t8)(_context4.t10);
case 56:
case 58:
_context4.t11 = __await;
return _context4.delegateYield(__asyncDelegator(__asyncValues(others)), "t12", 58);
return _context4.delegateYield(__asyncDelegator(__asyncValues(others)), "t12", 60);
case 58:
case 60:
_context4.t13 = _context4.t12;
_context4.next = 61;
_context4.next = 63;
return (0, _context4.t11)(_context4.t13);
case 61:
case 63:
case "end":

@@ -460,9 +495,6 @@ return _context4.stop();

}
}, sortByType_1, this, [[4, 28, 31, 41], [32,, 36, 40]]);
}, sortByType_1, this, [[4, 30, 33, 43], [34,, 38, 42]]);
}));
}
function byType(a, b) {
return a.type - b.type;
}
//# sourceMappingURL=pack.js.map
//# sourceMappingURL=pack.js.map

12

js/parse-packfile.js

@@ -597,3 +597,3 @@ "use strict";

if (!(state.state === 'entry')) {
_context.next = 7;
_context.next = 9;
break;

@@ -603,5 +603,9 @@ }

_context.next = 7;
return state.entry;
return __await(state.entry);
case 7:
_context.next = 9;
return _context.sent;
case 9:
if (state.state !== 'done') {

@@ -612,6 +616,6 @@ _context.next = 1;

case 8:
case 10:
state.buffer.complete();
case 9:
case 11:
case "end":

@@ -618,0 +622,0 @@ return _context.stop();

31

js/unpack.js

@@ -15,2 +15,6 @@ "use strict";

var _iterator = require("babel-runtime/core-js/symbol/iterator");
var _iterator2 = _interopRequireDefault(_iterator);
var _promise = require("babel-runtime/core-js/promise");

@@ -20,6 +24,2 @@

var _iterator = require("babel-runtime/core-js/symbol/iterator");
var _iterator2 = _interopRequireDefault(_iterator);
var _getIterator2 = require("babel-runtime/core-js/get-iterator");

@@ -51,4 +51,19 @@

if (!_symbol2.default.asyncIterator) throw new TypeError("Symbol.asyncIterator is not defined.");
var m = o[_symbol2.default.asyncIterator];
return m ? m.call(o) : typeof __values === "function" ? __values(o) : (0, _getIterator3.default)(o);
var m = o[_symbol2.default.asyncIterator],
i;
return m ? m.call(o) : (o = typeof __values === "function" ? __values(o) : (0, _getIterator3.default)(o), i = {}, verb("next"), verb("throw"), verb("return"), i[_symbol2.default.asyncIterator] = function () {
return this;
}, i);
function verb(n) {
i[n] = o[n] && function (v) {
return new _promise2.default(function (resolve, reject) {
v = o[n](v), settle(resolve, reject, v.done, v.value);
});
};
}
function settle(resolve, reject, d, v) {
_promise2.default.resolve(v).then(function (v) {
resolve({ value: v, done: d });
}, reject);
}
};

@@ -66,5 +81,5 @@ var __await = undefined && undefined.__await || function (v) {

function verb(n, f) {
if (o[n]) i[n] = function (v) {
i[n] = o[n] ? function (v) {
return (p = !p) ? { value: __await(o[n](v)), done: n === "return" } : f ? f(v) : v;
};
} : f;
}

@@ -71,0 +86,0 @@ };

4

package.json
{
"name": "@es-git/packfile",
"version": "0.8.3",
"version": "0.9.0",
"description": "",

@@ -42,5 +42,5 @@ "main": "js/index.js",

"dependencies": {
"@es-git/core": "^0.8.3",
"@es-git/core": "^0.9.0",
"pako": "^1.0.5"
}
}

5

ts/compose-packfile.ts
import {
packHash,
concat,
sha1,
Sha1
sha1
} from '@es-git/core';
import * as pako from 'pako';

@@ -8,0 +7,0 @@

1

ts/normalize-entries.ts
import {
concat,
encode,
Hash,
sha1

@@ -6,0 +5,0 @@ } from '@es-git/core'

5

ts/pack.ts
import {
concat,
decode

@@ -9,3 +8,2 @@ } from '@es-git/core';

Type,
Entry,
NormalEntry,

@@ -77,4 +75,1 @@ RawObject

function byType(a : NormalEntry, b : NormalEntry) {
return a.type - b.type;
}
es/compose-packfile.js.map

Sorry, the diff of this file is not supported yet

es/DigestableAsyncBuffer.test.js.map

Sorry, the diff of this file is not supported yet

es/index.test.js.map

Sorry, the diff of this file is not supported yet

es/normalize-entries.js.map

Sorry, the diff of this file is not supported yet

es/pack.js.map

Sorry, the diff of this file is not supported yet

es/parse-packfile.js.map

Sorry, the diff of this file is not supported yet

es/unpack.js.map

Sorry, the diff of this file is not supported yet

es/unpack.test.js.map

Sorry, the diff of this file is not supported yet

js/compose-packfile.js.map

Sorry, the diff of this file is not supported yet

js/DigestableAsyncBuffer.test.js.map

Sorry, the diff of this file is not supported yet

js/index.test.js.map

Sorry, the diff of this file is not supported yet

js/normalize-entries.js.map

Sorry, the diff of this file is not supported yet

js/pack.js.map

Sorry, the diff of this file is not supported yet

js/parse-packfile.js.map

Sorry, the diff of this file is not supported yet

js/unpack.js.map

Sorry, the diff of this file is not supported yet

js/unpack.test.js.map

Sorry, the diff of this file is not supported yet

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

About

Packages

npm

Go

Maven

PyPI

Rubygems

Stay in touch

Get open source security insights delivered straight into your inbox.

  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc