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

@furystack/repository

Package Overview
Dependencies
Maintainers
1
Versions
199
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@furystack/repository - npm Package Compare versions

Comparing version 5.0.34 to 6.0.0

dist/helpers.js

175

dist/dataset.spec.js

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

const repository_1 = require("./repository");
require("./injector-extension");
const helpers_1 = require("./helpers");
class TestClass {

@@ -19,7 +19,8 @@ constructor() {

(0, utils_1.using)(new inject_1.Injector(), (i) => {
i.setupStores((stores) => stores.addStore(new core_1.InMemoryStore({
(0, core_1.addStore)(i, new core_1.InMemoryStore({
model: TestClass,
primaryKey: 'id',
}))).setupRepository((r) => r.createDataSet(TestClass, 'id'));
const dataSet = i.getDataSetFor(TestClass, 'id');
}));
(0, helpers_1.getRepository)(i).createDataSet(TestClass, 'id');
const dataSet = (0, helpers_1.getDataSetFor)(i, TestClass, 'id');
expect(dataSet.settings.physicalStore.model).toBe(TestClass);

@@ -30,7 +31,8 @@ });

(0, utils_1.using)(new inject_1.Injector(), (i) => {
i.setupStores((stores) => stores.addStore(new core_1.InMemoryStore({
(0, core_1.addStore)(i, new core_1.InMemoryStore({
model: TestClass,
primaryKey: 'id',
}))).setupRepository((r) => r.createDataSet(TestClass, 'id'));
const dataSet = i.getDataSetFor(TestClass, 'id');
}));
(0, helpers_1.getRepository)(i).createDataSet(TestClass, 'id');
const dataSet = (0, helpers_1.getDataSetFor)(i, TestClass, 'id');
expect(dataSet.settings.physicalStore.model).toBe(TestClass);

@@ -41,3 +43,3 @@ });

(0, utils_1.using)(new inject_1.Injector(), (i) => {
expect(() => i.getDataSetFor(TestClass, 'id')).toThrowError('');
expect(() => (0, helpers_1.getDataSetFor)(i, TestClass, 'id')).toThrowError('');
});

@@ -55,4 +57,5 @@ });

await (0, utils_1.usingAsync)(new inject_1.Injector(), async (i) => {
i.setupStores((stores) => stores.addStore(new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }))).setupRepository((repo) => repo.createDataSet(TestClass, 'id'));
const dataSet = i.getDataSetFor(TestClass, 'id');
(0, core_1.addStore)(i, new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }));
(0, helpers_1.getRepository)(i).createDataSet(TestClass, 'id');
const dataSet = (0, helpers_1.getDataSetFor)(i, TestClass, 'id');
await dataSet.add(i, { id: 1, value: 'asd' });

@@ -66,4 +69,5 @@ const result = await dataSet.get(i, 1);

const authorizeAdd = jest.fn(async () => ({ isAllowed: true }));
i.setupStores((stores) => stores.addStore(new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }))).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authorizeAdd }));
const dataSet = i.getDataSetFor(TestClass, 'id');
(0, core_1.addStore)(i, new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }));
(0, helpers_1.getRepository)(i).createDataSet(TestClass, 'id', { authorizeAdd });
const dataSet = (0, helpers_1.getDataSetFor)(i, TestClass, 'id');
await dataSet.add(i, { id: 1, value: 'asd' });

@@ -78,4 +82,5 @@ expect(authorizeAdd).toBeCalled();

const authorizeAdd = jest.fn(async () => ({ isAllowed: false, message: '...' }));
i.setupStores((stores) => stores.addStore(new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }))).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authorizeAdd }));
const dataSet = await i.getDataSetFor(TestClass, 'id');
(0, core_1.addStore)(i, new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }));
(0, helpers_1.getRepository)(i).createDataSet(TestClass, 'id', { authorizeAdd });
const dataSet = await (0, helpers_1.getDataSetFor)(i, TestClass, 'id');
try {

@@ -99,4 +104,5 @@ await dataSet.add(i, { id: 1, value: 'asd' });

}));
i.setupStores((stores) => stores.addStore(new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }))).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { modifyOnAdd }));
const dataSet = i.getDataSetFor(TestClass, 'id');
(0, core_1.addStore)(i, new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }));
(0, helpers_1.getRepository)(i).createDataSet(TestClass, 'id', { modifyOnAdd });
const dataSet = (0, helpers_1.getDataSetFor)(i, TestClass, 'id');
await dataSet.add(i, { id: 1, value: 'asd' });

@@ -111,7 +117,10 @@ const result = await dataSet.get(i, 1);

expect.assertions(1);
i.setupStores((stores) => stores.addStore(new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }))).setupRepository((repo) => repo.createDataSet(TestClass, 'id', {}));
i.getDataSetFor(TestClass, 'id').onEntityAdded.subscribe(({ entity }) => {
(0, core_1.addStore)(i, new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }));
(0, helpers_1.getRepository)(i).createDataSet(TestClass, 'id', {});
(0, helpers_1.getRepository)(i)
.getDataSetFor(TestClass, 'id')
.onEntityAdded.subscribe(({ entity }) => {
expect(entity.value).toBe('asd');
});
const dataSet = i.getDataSetFor(TestClass, 'id');
const dataSet = (0, helpers_1.getDataSetFor)(i, TestClass, 'id');
await dataSet.add(i, { id: 1, value: 'asd' });

@@ -124,4 +133,5 @@ });

await (0, utils_1.usingAsync)(new inject_1.Injector(), async (i) => {
i.setupStores((stores) => stores.addStore(new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }))).setupRepository((repo) => repo.createDataSet(TestClass, 'id'));
const dataSet = i.getDataSetFor(TestClass, 'id');
(0, core_1.addStore)(i, new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }));
(0, helpers_1.getRepository)(i).createDataSet(TestClass, 'id');
const dataSet = (0, helpers_1.getDataSetFor)(i, TestClass, 'id');
await dataSet.add(i, { id: 1, value: 'asd' });

@@ -136,4 +146,5 @@ await dataSet.update(i, 1, { id: 1, value: 'asd2' });

const authorizeUpdate = jest.fn(async () => ({ isAllowed: true }));
i.setupStores((stores) => stores.addStore(new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }))).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authorizeUpdate }));
const dataSet = i.getDataSetFor(TestClass, 'id');
(0, core_1.addStore)(i, new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }));
(0, helpers_1.getRepository)(i).createDataSet(TestClass, 'id', { authorizeUpdate });
const dataSet = (0, helpers_1.getDataSetFor)(i, TestClass, 'id');
await dataSet.add(i, { id: 1, value: 'asd' });

@@ -149,4 +160,5 @@ await dataSet.update(i, 1, { id: 1, value: 'asd2' });

const authorizeUpdateEntity = jest.fn(async () => ({ isAllowed: false, message: '...' }));
i.setupStores((stores) => stores.addStore(new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }))).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authorizeUpdateEntity }));
const dataSet = await i.getDataSetFor(TestClass, 'id');
(0, core_1.addStore)(i, new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }));
(0, helpers_1.getRepository)(i).createDataSet(TestClass, 'id', { authorizeUpdateEntity });
const dataSet = await (0, helpers_1.getDataSetFor)(i, TestClass, 'id');
try {

@@ -168,4 +180,5 @@ await dataSet.add(i, { id: 1, value: 'asd' });

const authorizeUpdateEntity = jest.fn(async () => ({ isAllowed: true }));
i.setupStores((stores) => stores.addStore(new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }))).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authorizeUpdateEntity }));
const dataSet = i.getDataSetFor(TestClass, 'id');
(0, core_1.addStore)(i, new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }));
(0, helpers_1.getRepository)(i).createDataSet(TestClass, 'id', { authorizeUpdateEntity });
const dataSet = (0, helpers_1.getDataSetFor)(i, TestClass, 'id');
await dataSet.add(i, { id: 1, value: 'asd' });

@@ -181,4 +194,5 @@ await dataSet.update(i, 1, { id: 1, value: 'asd2' });

const authorizeUpdate = jest.fn(async () => ({ isAllowed: false, message: '...' }));
i.setupStores((stores) => stores.addStore(new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }))).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authorizeUpdate }));
const dataSet = await i.getDataSetFor(TestClass, 'id');
(0, core_1.addStore)(i, new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }));
(0, helpers_1.getRepository)(i).createDataSet(TestClass, 'id', { authorizeUpdate });
const dataSet = await (0, helpers_1.getDataSetFor)(i, TestClass, 'id');
try {

@@ -206,4 +220,5 @@ await dataSet.add(i, { id: 1, value: 'asd' });

});
i.setupStores((stores) => stores.addStore(new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }))).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { modifyOnUpdate }));
const dataSet = i.getDataSetFor(TestClass, 'id');
(0, core_1.addStore)(i, new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }));
(0, helpers_1.getRepository)(i).createDataSet(TestClass, 'id', { modifyOnUpdate });
const dataSet = (0, helpers_1.getDataSetFor)(i, TestClass, 'id');
await dataSet.add(i, { id: 1, value: 'asd' });

@@ -219,7 +234,10 @@ await dataSet.update(i, 1, { id: 1, value: 'asd2' });

expect.assertions(1);
i.setupStores((stores) => stores.addStore(new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }))).setupRepository((repo) => repo.createDataSet(TestClass, 'id'));
i.getDataSetFor(TestClass, 'id').onEntityUpdated.subscribe(({ change }) => {
(0, core_1.addStore)(i, new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }));
(0, helpers_1.getRepository)(i).createDataSet(TestClass, 'id');
(0, helpers_1.getRepository)(i)
.getDataSetFor(TestClass, 'id')
.onEntityUpdated.subscribe(({ change }) => {
expect(change).toEqual({ id: 1, value: 'asd2' });
});
const dataSet = i.getDataSetFor(TestClass, 'id');
const dataSet = (0, helpers_1.getDataSetFor)(i, TestClass, 'id');
await dataSet.add(i, { id: 1, value: 'asd' });

@@ -233,4 +251,5 @@ await dataSet.update(i, 1, { id: 1, value: 'asd2' });

await (0, utils_1.usingAsync)(new inject_1.Injector(), async (i) => {
i.setupStores((stores) => stores.addStore(new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }))).setupRepository((repo) => repo.createDataSet(TestClass, 'id'));
const dataSet = i.getDataSetFor(TestClass, 'id');
(0, core_1.addStore)(i, new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }));
(0, helpers_1.getRepository)(i).createDataSet(TestClass, 'id');
const dataSet = (0, helpers_1.getDataSetFor)(i, TestClass, 'id');
await dataSet.add(i, { id: 1, value: 'asd' });

@@ -244,4 +263,5 @@ const result = await dataSet.count(i);

const authorizeGet = jest.fn(async () => ({ isAllowed: true, message: '' }));
i.setupStores((stores) => stores.addStore(new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }))).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authorizeGet }));
const dataSet = i.getDataSetFor(TestClass, 'id');
(0, core_1.addStore)(i, new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }));
(0, helpers_1.getRepository)(i).createDataSet(TestClass, 'id', { authorizeGet });
const dataSet = (0, helpers_1.getDataSetFor)(i, TestClass, 'id');
await dataSet.add(i, { id: 1, value: 'asd' });

@@ -255,4 +275,5 @@ const result = await dataSet.count(i);

const authorizeGet = jest.fn(async () => ({ isAllowed: false, message: ':(' }));
i.setupStores((stores) => stores.addStore(new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }))).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authorizeGet }));
const dataSet = i.getDataSetFor(TestClass, 'id');
(0, core_1.addStore)(i, new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }));
(0, helpers_1.getRepository)(i).createDataSet(TestClass, 'id', { authorizeGet });
const dataSet = (0, helpers_1.getDataSetFor)(i, TestClass, 'id');
await dataSet.add(i, { id: 1, value: 'asd' });

@@ -273,4 +294,5 @@ try {

await (0, utils_1.usingAsync)(new inject_1.Injector(), async (i) => {
i.setupStores((stores) => stores.addStore(new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }))).setupRepository((repo) => repo.createDataSet(TestClass, 'id'));
const dataSet = i.getDataSetFor(TestClass, 'id');
(0, core_1.addStore)(i, new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }));
(0, helpers_1.getRepository)(i).createDataSet(TestClass, 'id');
const dataSet = (0, helpers_1.getDataSetFor)(i, TestClass, 'id');
await dataSet.add(i, { id: 1, value: 'asd' });

@@ -284,4 +306,5 @@ const result = await dataSet.find(i, {});

const authorizeGet = jest.fn(async () => ({ isAllowed: true, message: '' }));
i.setupStores((stores) => stores.addStore(new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }))).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authorizeGet }));
const dataSet = i.getDataSetFor(TestClass, 'id');
(0, core_1.addStore)(i, new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }));
(0, helpers_1.getRepository)(i).createDataSet(TestClass, 'id', { authorizeGet });
const dataSet = (0, helpers_1.getDataSetFor)(i, TestClass, 'id');
await dataSet.add(i, { id: 1, value: 'asd' });

@@ -295,4 +318,5 @@ const result = await dataSet.find(i, {});

const authorizeGet = jest.fn(async () => ({ isAllowed: false, message: ':(' }));
i.setupStores((stores) => stores.addStore(new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }))).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authorizeGet }));
const dataSet = i.getDataSetFor(TestClass, 'id');
(0, core_1.addStore)(i, new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }));
(0, helpers_1.getRepository)(i).createDataSet(TestClass, 'id', { authorizeGet });
const dataSet = (0, helpers_1.getDataSetFor)(i, TestClass, 'id');
await dataSet.add(i, { id: 1, value: 'asd' });

@@ -312,4 +336,5 @@ try {

await (0, utils_1.usingAsync)(new inject_1.Injector(), async (i) => {
i.setupStores((stores) => stores.addStore(new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }))).setupRepository((repo) => repo.createDataSet(TestClass, 'id'));
const dataSet = i.getDataSetFor(TestClass, 'id');
(0, core_1.addStore)(i, new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }));
(0, helpers_1.getRepository)(i).createDataSet(TestClass, 'id');
const dataSet = (0, helpers_1.getDataSetFor)(i, TestClass, 'id');
await dataSet.add(i, { id: 1, value: 'asd' });

@@ -323,4 +348,5 @@ const result = await dataSet.get(i, 1);

const authorizeGet = jest.fn(async () => ({ isAllowed: true, message: '' }));
i.setupStores((stores) => stores.addStore(new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }))).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authorizeGet }));
const dataSet = i.getDataSetFor(TestClass, 'id');
(0, core_1.addStore)(i, new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }));
(0, helpers_1.getRepository)(i).createDataSet(TestClass, 'id', { authorizeGet });
const dataSet = (0, helpers_1.getDataSetFor)(i, TestClass, 'id');
await dataSet.add(i, { id: 1, value: 'asd' });

@@ -334,4 +360,5 @@ const result = await dataSet.get(i, 1);

const authorizeGet = jest.fn(async () => ({ isAllowed: false, message: ':(' }));
i.setupStores((stores) => stores.addStore(new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }))).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authorizeGet }));
const dataSet = i.getDataSetFor(TestClass, 'id');
(0, core_1.addStore)(i, new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }));
(0, helpers_1.getRepository)(i).createDataSet(TestClass, 'id', { authorizeGet });
const dataSet = (0, helpers_1.getDataSetFor)(i, TestClass, 'id');
await dataSet.add(i, { id: 1, value: 'asd' });

@@ -350,4 +377,5 @@ try {

const authorizeGetEntity = jest.fn(async () => ({ isAllowed: true, message: '' }));
i.setupStores((stores) => stores.addStore(new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }))).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authorizeGetEntity }));
const dataSet = i.getDataSetFor(TestClass, 'id');
(0, core_1.addStore)(i, new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }));
(0, helpers_1.getRepository)(i).createDataSet(TestClass, 'id', { authorizeGetEntity });
const dataSet = (0, helpers_1.getDataSetFor)(i, TestClass, 'id');
await dataSet.add(i, { id: 1, value: 'asd' });

@@ -361,4 +389,5 @@ const result = await dataSet.get(i, 1);

const authorizeGetEntity = jest.fn(async () => ({ isAllowed: false, message: ':(' }));
i.setupStores((stores) => stores.addStore(new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }))).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authorizeGetEntity }));
const dataSet = i.getDataSetFor(TestClass, 'id');
(0, core_1.addStore)(i, new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }));
(0, helpers_1.getRepository)(i).createDataSet(TestClass, 'id', { authorizeGetEntity });
const dataSet = (0, helpers_1.getDataSetFor)(i, TestClass, 'id');
await dataSet.add(i, { id: 1, value: 'asd' });

@@ -378,4 +407,5 @@ try {

await (0, utils_1.usingAsync)(new inject_1.Injector(), async (i) => {
i.setupStores((stores) => stores.addStore(new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }))).setupRepository((repo) => repo.createDataSet(TestClass, 'id'));
const dataSet = i.getDataSetFor(TestClass, 'id');
(0, core_1.addStore)(i, new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }));
(0, helpers_1.getRepository)(i).createDataSet(TestClass, 'id');
const dataSet = (0, helpers_1.getDataSetFor)(i, TestClass, 'id');
await dataSet.add(i, { id: 1, value: 'asd' });

@@ -390,4 +420,5 @@ await dataSet.remove(i, 1);

const authorizeRemove = jest.fn(async () => ({ isAllowed: true, message: '' }));
i.setupStores((stores) => stores.addStore(new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }))).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authorizeRemove }));
const dataSet = i.getDataSetFor(TestClass, 'id');
(0, core_1.addStore)(i, new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }));
(0, helpers_1.getRepository)(i).createDataSet(TestClass, 'id', { authorizeRemove });
const dataSet = (0, helpers_1.getDataSetFor)(i, TestClass, 'id');
await dataSet.add(i, { id: 1, value: 'asd' });

@@ -402,4 +433,5 @@ await dataSet.remove(i, 1);

const authorizeRemove = jest.fn(async () => ({ isAllowed: false, message: ':(' }));
i.setupStores((stores) => stores.addStore(new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }))).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authorizeRemove }));
const dataSet = i.getDataSetFor(TestClass, 'id');
(0, core_1.addStore)(i, new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }));
(0, helpers_1.getRepository)(i).createDataSet(TestClass, 'id', { authorizeRemove });
const dataSet = (0, helpers_1.getDataSetFor)(i, TestClass, 'id');
await dataSet.add(i, { id: 1, value: 'asd' });

@@ -420,4 +452,5 @@ try {

const authroizeRemoveEntity = jest.fn(async () => ({ isAllowed: true, message: '' }));
i.setupStores((stores) => stores.addStore(new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }))).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authroizeRemoveEntity }));
const dataSet = i.getDataSetFor(TestClass, 'id');
(0, core_1.addStore)(i, new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }));
(0, helpers_1.getRepository)(i).createDataSet(TestClass, 'id', { authroizeRemoveEntity });
const dataSet = (0, helpers_1.getDataSetFor)(i, TestClass, 'id');
await dataSet.add(i, { id: 1, value: 'asd' });

@@ -432,4 +465,5 @@ await dataSet.remove(i, 1);

const authroizeRemoveEntity = jest.fn(async () => ({ isAllowed: false, message: ':(' }));
i.setupStores((stores) => stores.addStore(new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }))).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authroizeRemoveEntity }));
const dataSet = i.getDataSetFor(TestClass, 'id');
(0, core_1.addStore)(i, new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }));
(0, helpers_1.getRepository)(i).createDataSet(TestClass, 'id', { authroizeRemoveEntity });
const dataSet = (0, helpers_1.getDataSetFor)(i, TestClass, 'id');
await dataSet.add(i, { id: 1, value: 'asd' });

@@ -450,7 +484,10 @@ try {

expect.assertions(1);
i.setupStores((stores) => stores.addStore(new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }))).setupRepository((repo) => repo.createDataSet(TestClass, 'id'));
i.getDataSetFor(TestClass, 'id').onEntityRemoved.subscribe(({ key }) => {
(0, core_1.addStore)(i, new core_1.InMemoryStore({ model: TestClass, primaryKey: 'id' }));
(0, helpers_1.getRepository)(i).createDataSet(TestClass, 'id');
(0, helpers_1.getRepository)(i)
.getDataSetFor(TestClass, 'id')
.onEntityRemoved.subscribe(({ key }) => {
expect(key).toEqual(1);
});
const dataSet = i.getDataSetFor(TestClass, 'id');
const dataSet = (0, helpers_1.getDataSetFor)(i, TestClass, 'id');
await dataSet.add(i, { id: 1, value: 'asd' });

@@ -457,0 +494,0 @@ await dataSet.remove(i, 1);

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

tslib_1.__exportStar(require("./data-set-setting"), exports);
require("./injector-extension");
tslib_1.__exportStar(require("./helpers"), exports);
//# sourceMappingURL=index.js.map

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

const utils_1 = require("@furystack/utils");
require("./injector-extension");
const helpers_1 = require("./helpers");
const core_1 = require("@furystack/core");

@@ -14,4 +14,5 @@ const data_set_1 = require("./data-set");

}
i.setupStores((sm) => sm.addStore(new core_1.InMemoryStore({ model: ExampleClass, primaryKey: 'id' }))).setupRepository((r) => r.createDataSet(ExampleClass, 'id', {}));
const dataSet = i.getDataSetFor(ExampleClass, 'id');
(0, core_1.addStore)(i, new core_1.InMemoryStore({ model: ExampleClass, primaryKey: 'id' }));
(0, helpers_1.getRepository)(i).createDataSet(ExampleClass, 'id', {});
const dataSet = (0, helpers_1.getDataSetFor)(i, ExampleClass, 'id');
expect(dataSet).toBeInstanceOf(data_set_1.DataSet);

@@ -18,0 +19,0 @@ });

{
"name": "@furystack/repository",
"version": "5.0.34",
"version": "6.0.0",
"description": "Repository implementation for FuryStack",

@@ -8,2 +8,3 @@ "main": "dist/index.js",

"dist",
"types",
"src"

@@ -32,7 +33,7 @@ ],

"dependencies": {
"@furystack/core": "^10.4.10",
"@furystack/inject": "^5.0.7",
"@furystack/logging": "^2.0.91",
"@furystack/utils": "^2.1.0",
"tslib": "^2.3.1"
"@furystack/core": "^11.0.0",
"@furystack/inject": "^6.0.0",
"@furystack/logging": "^3.0.0",
"@furystack/utils": "^3.0.0",
"tslib": "^2.4.0"
},

@@ -42,4 +43,4 @@ "devDependencies": {

},
"typings": "./dist/index.d.ts",
"typings": "./types/index.d.ts",
"gitHead": "1045d854bfd8c475b7035471d130d401417a2321"
}
import { Injector } from '@furystack/inject'
import { using, usingAsync } from '@furystack/utils'
import { InMemoryStore, WithOptionalId } from '@furystack/core'
import { InMemoryStore, WithOptionalId, addStore } from '@furystack/core'
import { Repository } from './repository'
import { AuthorizationResult, DataSetSettings } from './data-set-setting'
import './injector-extension'
import { getDataSetFor, getRepository } from './helpers'

@@ -17,11 +17,11 @@ class TestClass {

using(new Injector(), (i) => {
i.setupStores((stores) =>
stores.addStore(
new InMemoryStore({
model: TestClass,
primaryKey: 'id',
}),
),
).setupRepository((r) => r.createDataSet(TestClass, 'id'))
const dataSet = i.getDataSetFor(TestClass, 'id')
addStore(
i,
new InMemoryStore({
model: TestClass,
primaryKey: 'id',
}),
)
getRepository(i).createDataSet(TestClass, 'id')
const dataSet = getDataSetFor(i, TestClass, 'id')
expect(dataSet.settings.physicalStore.model).toBe(TestClass)

@@ -33,11 +33,11 @@ })

using(new Injector(), (i) => {
i.setupStores((stores) =>
stores.addStore(
new InMemoryStore({
model: TestClass,
primaryKey: 'id',
}),
),
).setupRepository((r) => r.createDataSet(TestClass, 'id'))
const dataSet = i.getDataSetFor(TestClass, 'id')
addStore(
i,
new InMemoryStore({
model: TestClass,
primaryKey: 'id',
}),
)
getRepository(i).createDataSet(TestClass, 'id')
const dataSet = getDataSetFor(i, TestClass, 'id')
expect(dataSet.settings.physicalStore.model).toBe(TestClass)

@@ -49,3 +49,3 @@ })

using(new Injector(), (i) => {
expect(() => i.getDataSetFor(TestClass, 'id')).toThrowError('')
expect(() => getDataSetFor(i, TestClass, 'id')).toThrowError('')
})

@@ -65,7 +65,7 @@ })

await usingAsync(new Injector(), async (i) => {
i.setupStores((stores) =>
stores.addStore(new InMemoryStore({ model: TestClass, primaryKey: 'id' })),
).setupRepository((repo) => repo.createDataSet(TestClass, 'id'))
addStore(i, new InMemoryStore({ model: TestClass, primaryKey: 'id' }))
const dataSet = i.getDataSetFor(TestClass, 'id')
getRepository(i).createDataSet(TestClass, 'id')
const dataSet = getDataSetFor(i, TestClass, 'id')
await dataSet.add(i, { id: 1, value: 'asd' })

@@ -80,6 +80,6 @@ const result = await dataSet.get(i, 1)

const authorizeAdd = jest.fn(async () => ({ isAllowed: true } as AuthorizationResult))
i.setupStores((stores) =>
stores.addStore(new InMemoryStore({ model: TestClass, primaryKey: 'id' })),
).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authorizeAdd }))
const dataSet = i.getDataSetFor(TestClass, 'id')
addStore(i, new InMemoryStore({ model: TestClass, primaryKey: 'id' }))
getRepository(i).createDataSet(TestClass, 'id', { authorizeAdd })
const dataSet = getDataSetFor(i, TestClass, 'id')
await dataSet.add(i, { id: 1, value: 'asd' })

@@ -95,8 +95,8 @@ expect(authorizeAdd).toBeCalled()

const authorizeAdd = jest.fn(async () => ({ isAllowed: false, message: '...' } as AuthorizationResult))
i.setupStores((stores) =>
stores.addStore(new InMemoryStore({ model: TestClass, primaryKey: 'id' })),
).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authorizeAdd }))
addStore(i, new InMemoryStore({ model: TestClass, primaryKey: 'id' }))
const dataSet = await i.getDataSetFor(TestClass, 'id')
getRepository(i).createDataSet(TestClass, 'id', { authorizeAdd })
const dataSet = await getDataSetFor(i, TestClass, 'id')
try {

@@ -123,7 +123,6 @@ await dataSet.add(i, { id: 1, value: 'asd' })

i.setupStores((stores) =>
stores.addStore(new InMemoryStore({ model: TestClass, primaryKey: 'id' })),
).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { modifyOnAdd }))
addStore(i, new InMemoryStore({ model: TestClass, primaryKey: 'id' }))
getRepository(i).createDataSet(TestClass, 'id', { modifyOnAdd })
const dataSet = i.getDataSetFor(TestClass, 'id')
const dataSet = getDataSetFor(i, TestClass, 'id')
await dataSet.add(i, { id: 1, value: 'asd' })

@@ -139,11 +138,13 @@ const result = await dataSet.get(i, 1)

expect.assertions(1)
i.setupStores((stores) =>
stores.addStore(new InMemoryStore({ model: TestClass, primaryKey: 'id' })),
).setupRepository((repo) => repo.createDataSet(TestClass, 'id', {}))
addStore(i, new InMemoryStore({ model: TestClass, primaryKey: 'id' }))
i.getDataSetFor(TestClass, 'id').onEntityAdded.subscribe(({ entity }) => {
expect(entity.value).toBe('asd')
})
getRepository(i).createDataSet(TestClass, 'id', {})
const dataSet = i.getDataSetFor(TestClass, 'id')
getRepository(i)
.getDataSetFor(TestClass, 'id')
.onEntityAdded.subscribe(({ entity }) => {
expect(entity.value).toBe('asd')
})
const dataSet = getDataSetFor(i, TestClass, 'id')
await dataSet.add(i, { id: 1, value: 'asd' })

@@ -157,7 +158,6 @@ })

await usingAsync(new Injector(), async (i) => {
i.setupStores((stores) =>
stores.addStore(new InMemoryStore({ model: TestClass, primaryKey: 'id' })),
).setupRepository((repo) => repo.createDataSet(TestClass, 'id'))
addStore(i, new InMemoryStore({ model: TestClass, primaryKey: 'id' }))
getRepository(i).createDataSet(TestClass, 'id')
const dataSet = i.getDataSetFor(TestClass, 'id')
const dataSet = getDataSetFor(i, TestClass, 'id')
await dataSet.add(i, { id: 1, value: 'asd' })

@@ -173,6 +173,5 @@ await dataSet.update(i, 1, { id: 1, value: 'asd2' })

const authorizeUpdate = jest.fn(async () => ({ isAllowed: true } as AuthorizationResult))
i.setupStores((stores) =>
stores.addStore(new InMemoryStore({ model: TestClass, primaryKey: 'id' })),
).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authorizeUpdate }))
const dataSet = i.getDataSetFor(TestClass, 'id')
addStore(i, new InMemoryStore({ model: TestClass, primaryKey: 'id' }))
getRepository(i).createDataSet(TestClass, 'id', { authorizeUpdate })
const dataSet = getDataSetFor(i, TestClass, 'id')
await dataSet.add(i, { id: 1, value: 'asd' })

@@ -191,7 +190,6 @@ await dataSet.update(i, 1, { id: 1, value: 'asd2' })

)
i.setupStores((stores) =>
stores.addStore(new InMemoryStore({ model: TestClass, primaryKey: 'id' })),
).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authorizeUpdateEntity }))
addStore(i, new InMemoryStore({ model: TestClass, primaryKey: 'id' }))
getRepository(i).createDataSet(TestClass, 'id', { authorizeUpdateEntity })
const dataSet = await i.getDataSetFor(TestClass, 'id')
const dataSet = await getDataSetFor(i, TestClass, 'id')

@@ -213,6 +211,5 @@ try {

const authorizeUpdateEntity = jest.fn(async () => ({ isAllowed: true } as AuthorizationResult))
i.setupStores((stores) =>
stores.addStore(new InMemoryStore({ model: TestClass, primaryKey: 'id' })),
).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authorizeUpdateEntity }))
const dataSet = i.getDataSetFor(TestClass, 'id')
addStore(i, new InMemoryStore({ model: TestClass, primaryKey: 'id' }))
getRepository(i).createDataSet(TestClass, 'id', { authorizeUpdateEntity })
const dataSet = getDataSetFor(i, TestClass, 'id')
await dataSet.add(i, { id: 1, value: 'asd' })

@@ -229,7 +226,6 @@ await dataSet.update(i, 1, { id: 1, value: 'asd2' })

const authorizeUpdate = jest.fn(async () => ({ isAllowed: false, message: '...' } as AuthorizationResult))
i.setupStores((stores) =>
stores.addStore(new InMemoryStore({ model: TestClass, primaryKey: 'id' })),
).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authorizeUpdate }))
addStore(i, new InMemoryStore({ model: TestClass, primaryKey: 'id' }))
getRepository(i).createDataSet(TestClass, 'id', { authorizeUpdate })
const dataSet = await i.getDataSetFor(TestClass, 'id')
const dataSet = await getDataSetFor(i, TestClass, 'id')

@@ -256,7 +252,6 @@ try {

i.setupStores((stores) =>
stores.addStore(new InMemoryStore({ model: TestClass, primaryKey: 'id' })),
).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { modifyOnUpdate }))
addStore(i, new InMemoryStore({ model: TestClass, primaryKey: 'id' }))
getRepository(i).createDataSet(TestClass, 'id', { modifyOnUpdate })
const dataSet = i.getDataSetFor(TestClass, 'id')
const dataSet = getDataSetFor(i, TestClass, 'id')
await dataSet.add(i, { id: 1, value: 'asd' })

@@ -273,11 +268,12 @@ await dataSet.update(i, 1, { id: 1, value: 'asd2' })

expect.assertions(1)
i.setupStores((stores) =>
stores.addStore(new InMemoryStore({ model: TestClass, primaryKey: 'id' })),
).setupRepository((repo) => repo.createDataSet(TestClass, 'id'))
addStore(i, new InMemoryStore({ model: TestClass, primaryKey: 'id' }))
getRepository(i).createDataSet(TestClass, 'id')
i.getDataSetFor(TestClass, 'id').onEntityUpdated.subscribe(({ change }) => {
expect(change).toEqual({ id: 1, value: 'asd2' })
})
getRepository(i)
.getDataSetFor(TestClass, 'id')
.onEntityUpdated.subscribe(({ change }) => {
expect(change).toEqual({ id: 1, value: 'asd2' })
})
const dataSet = i.getDataSetFor(TestClass, 'id')
const dataSet = getDataSetFor(i, TestClass, 'id')
await dataSet.add(i, { id: 1, value: 'asd' })

@@ -292,7 +288,6 @@ await dataSet.update(i, 1, { id: 1, value: 'asd2' })

await usingAsync(new Injector(), async (i) => {
i.setupStores((stores) =>
stores.addStore(new InMemoryStore({ model: TestClass, primaryKey: 'id' })),
).setupRepository((repo) => repo.createDataSet(TestClass, 'id'))
addStore(i, new InMemoryStore({ model: TestClass, primaryKey: 'id' }))
getRepository(i).createDataSet(TestClass, 'id')
const dataSet = i.getDataSetFor(TestClass, 'id')
const dataSet = getDataSetFor(i, TestClass, 'id')
await dataSet.add(i, { id: 1, value: 'asd' })

@@ -307,7 +302,6 @@ const result = await dataSet.count(i)

const authorizeGet = jest.fn(async () => ({ isAllowed: true, message: '' }))
i.setupStores((stores) =>
stores.addStore(new InMemoryStore({ model: TestClass, primaryKey: 'id' })),
).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authorizeGet }))
addStore(i, new InMemoryStore({ model: TestClass, primaryKey: 'id' }))
getRepository(i).createDataSet(TestClass, 'id', { authorizeGet })
const dataSet = i.getDataSetFor(TestClass, 'id')
const dataSet = getDataSetFor(i, TestClass, 'id')
await dataSet.add(i, { id: 1, value: 'asd' })

@@ -322,7 +316,6 @@ const result = await dataSet.count(i)

const authorizeGet = jest.fn(async () => ({ isAllowed: false, message: ':(' }))
i.setupStores((stores) =>
stores.addStore(new InMemoryStore({ model: TestClass, primaryKey: 'id' })),
).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authorizeGet }))
addStore(i, new InMemoryStore({ model: TestClass, primaryKey: 'id' }))
getRepository(i).createDataSet(TestClass, 'id', { authorizeGet })
const dataSet = i.getDataSetFor(TestClass, 'id')
const dataSet = getDataSetFor(i, TestClass, 'id')
await dataSet.add(i, { id: 1, value: 'asd' })

@@ -343,7 +336,6 @@ try {

await usingAsync(new Injector(), async (i) => {
i.setupStores((stores) =>
stores.addStore(new InMemoryStore({ model: TestClass, primaryKey: 'id' })),
).setupRepository((repo) => repo.createDataSet(TestClass, 'id'))
addStore(i, new InMemoryStore({ model: TestClass, primaryKey: 'id' }))
getRepository(i).createDataSet(TestClass, 'id')
const dataSet = i.getDataSetFor(TestClass, 'id')
const dataSet = getDataSetFor(i, TestClass, 'id')
await dataSet.add(i, { id: 1, value: 'asd' })

@@ -358,7 +350,6 @@ const result = await dataSet.find(i, {})

const authorizeGet = jest.fn(async () => ({ isAllowed: true, message: '' }))
i.setupStores((stores) =>
stores.addStore(new InMemoryStore({ model: TestClass, primaryKey: 'id' })),
).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authorizeGet }))
addStore(i, new InMemoryStore({ model: TestClass, primaryKey: 'id' }))
getRepository(i).createDataSet(TestClass, 'id', { authorizeGet })
const dataSet = i.getDataSetFor(TestClass, 'id')
const dataSet = getDataSetFor(i, TestClass, 'id')
await dataSet.add(i, { id: 1, value: 'asd' })

@@ -373,7 +364,6 @@ const result = await dataSet.find(i, {})

const authorizeGet = jest.fn(async () => ({ isAllowed: false, message: ':(' }))
i.setupStores((stores) =>
stores.addStore(new InMemoryStore({ model: TestClass, primaryKey: 'id' })),
).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authorizeGet }))
addStore(i, new InMemoryStore({ model: TestClass, primaryKey: 'id' }))
getRepository(i).createDataSet(TestClass, 'id', { authorizeGet })
const dataSet = i.getDataSetFor(TestClass, 'id')
const dataSet = getDataSetFor(i, TestClass, 'id')
await dataSet.add(i, { id: 1, value: 'asd' })

@@ -393,7 +383,6 @@ try {

await usingAsync(new Injector(), async (i) => {
i.setupStores((stores) =>
stores.addStore(new InMemoryStore({ model: TestClass, primaryKey: 'id' })),
).setupRepository((repo) => repo.createDataSet(TestClass, 'id'))
addStore(i, new InMemoryStore({ model: TestClass, primaryKey: 'id' }))
getRepository(i).createDataSet(TestClass, 'id')
const dataSet = i.getDataSetFor(TestClass, 'id')
const dataSet = getDataSetFor(i, TestClass, 'id')
await dataSet.add(i, { id: 1, value: 'asd' })

@@ -408,7 +397,6 @@ const result = await dataSet.get(i, 1)

const authorizeGet = jest.fn(async () => ({ isAllowed: true, message: '' }))
i.setupStores((stores) =>
stores.addStore(new InMemoryStore({ model: TestClass, primaryKey: 'id' })),
).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authorizeGet }))
addStore(i, new InMemoryStore({ model: TestClass, primaryKey: 'id' }))
getRepository(i).createDataSet(TestClass, 'id', { authorizeGet })
const dataSet = i.getDataSetFor(TestClass, 'id')
const dataSet = getDataSetFor(i, TestClass, 'id')
await dataSet.add(i, { id: 1, value: 'asd' })

@@ -423,7 +411,6 @@ const result = await dataSet.get(i, 1)

const authorizeGet = jest.fn(async () => ({ isAllowed: false, message: ':(' }))
i.setupStores((stores) =>
stores.addStore(new InMemoryStore({ model: TestClass, primaryKey: 'id' })),
).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authorizeGet }))
addStore(i, new InMemoryStore({ model: TestClass, primaryKey: 'id' }))
getRepository(i).createDataSet(TestClass, 'id', { authorizeGet })
const dataSet = i.getDataSetFor(TestClass, 'id')
const dataSet = getDataSetFor(i, TestClass, 'id')
await dataSet.add(i, { id: 1, value: 'asd' })

@@ -442,7 +429,6 @@ try {

const authorizeGetEntity = jest.fn(async () => ({ isAllowed: true, message: '' }))
i.setupStores((stores) =>
stores.addStore(new InMemoryStore({ model: TestClass, primaryKey: 'id' })),
).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authorizeGetEntity }))
addStore(i, new InMemoryStore({ model: TestClass, primaryKey: 'id' }))
getRepository(i).createDataSet(TestClass, 'id', { authorizeGetEntity })
const dataSet = i.getDataSetFor(TestClass, 'id')
const dataSet = getDataSetFor(i, TestClass, 'id')
await dataSet.add(i, { id: 1, value: 'asd' })

@@ -457,7 +443,6 @@ const result = await dataSet.get(i, 1)

const authorizeGetEntity = jest.fn(async () => ({ isAllowed: false, message: ':(' }))
i.setupStores((stores) =>
stores.addStore(new InMemoryStore({ model: TestClass, primaryKey: 'id' })),
).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authorizeGetEntity }))
addStore(i, new InMemoryStore({ model: TestClass, primaryKey: 'id' }))
getRepository(i).createDataSet(TestClass, 'id', { authorizeGetEntity })
const dataSet = i.getDataSetFor(TestClass, 'id')
const dataSet = getDataSetFor(i, TestClass, 'id')
await dataSet.add(i, { id: 1, value: 'asd' })

@@ -476,7 +461,6 @@ try {

await usingAsync(new Injector(), async (i) => {
i.setupStores((stores) =>
stores.addStore(new InMemoryStore({ model: TestClass, primaryKey: 'id' })),
).setupRepository((repo) => repo.createDataSet(TestClass, 'id'))
addStore(i, new InMemoryStore({ model: TestClass, primaryKey: 'id' }))
getRepository(i).createDataSet(TestClass, 'id')
const dataSet = i.getDataSetFor(TestClass, 'id')
const dataSet = getDataSetFor(i, TestClass, 'id')
await dataSet.add(i, { id: 1, value: 'asd' })

@@ -492,7 +476,6 @@ await dataSet.remove(i, 1)

const authorizeRemove = jest.fn(async () => ({ isAllowed: true, message: '' }))
i.setupStores((stores) =>
stores.addStore(new InMemoryStore({ model: TestClass, primaryKey: 'id' })),
).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authorizeRemove }))
addStore(i, new InMemoryStore({ model: TestClass, primaryKey: 'id' }))
getRepository(i).createDataSet(TestClass, 'id', { authorizeRemove })
const dataSet = i.getDataSetFor(TestClass, 'id')
const dataSet = getDataSetFor(i, TestClass, 'id')
await dataSet.add(i, { id: 1, value: 'asd' })

@@ -508,7 +491,6 @@ await dataSet.remove(i, 1)

const authorizeRemove = jest.fn(async () => ({ isAllowed: false, message: ':(' }))
i.setupStores((stores) =>
stores.addStore(new InMemoryStore({ model: TestClass, primaryKey: 'id' })),
).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authorizeRemove }))
addStore(i, new InMemoryStore({ model: TestClass, primaryKey: 'id' }))
getRepository(i).createDataSet(TestClass, 'id', { authorizeRemove })
const dataSet = i.getDataSetFor(TestClass, 'id')
const dataSet = getDataSetFor(i, TestClass, 'id')
await dataSet.add(i, { id: 1, value: 'asd' })

@@ -529,7 +511,6 @@ try {

const authroizeRemoveEntity = jest.fn(async () => ({ isAllowed: true, message: '' }))
i.setupStores((stores) =>
stores.addStore(new InMemoryStore({ model: TestClass, primaryKey: 'id' })),
).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authroizeRemoveEntity }))
addStore(i, new InMemoryStore({ model: TestClass, primaryKey: 'id' }))
getRepository(i).createDataSet(TestClass, 'id', { authroizeRemoveEntity })
const dataSet = i.getDataSetFor(TestClass, 'id')
const dataSet = getDataSetFor(i, TestClass, 'id')
await dataSet.add(i, { id: 1, value: 'asd' })

@@ -545,7 +526,6 @@ await dataSet.remove(i, 1)

const authroizeRemoveEntity = jest.fn(async () => ({ isAllowed: false, message: ':(' }))
i.setupStores((stores) =>
stores.addStore(new InMemoryStore({ model: TestClass, primaryKey: 'id' })),
).setupRepository((repo) => repo.createDataSet(TestClass, 'id', { authroizeRemoveEntity }))
addStore(i, new InMemoryStore({ model: TestClass, primaryKey: 'id' }))
getRepository(i).createDataSet(TestClass, 'id', { authroizeRemoveEntity })
const dataSet = i.getDataSetFor(TestClass, 'id')
const dataSet = getDataSetFor(i, TestClass, 'id')
await dataSet.add(i, { id: 1, value: 'asd' })

@@ -565,11 +545,12 @@ try {

expect.assertions(1)
i.setupStores((stores) =>
stores.addStore(new InMemoryStore({ model: TestClass, primaryKey: 'id' })),
).setupRepository((repo) => repo.createDataSet(TestClass, 'id'))
addStore(i, new InMemoryStore({ model: TestClass, primaryKey: 'id' }))
getRepository(i).createDataSet(TestClass, 'id')
i.getDataSetFor(TestClass, 'id').onEntityRemoved.subscribe(({ key }) => {
expect(key).toEqual(1)
})
getRepository(i)
.getDataSetFor(TestClass, 'id')
.onEntityRemoved.subscribe(({ key }) => {
expect(key).toEqual(1)
})
const dataSet = i.getDataSetFor(TestClass, 'id')
const dataSet = getDataSetFor(i, TestClass, 'id')
await dataSet.add(i, { id: 1, value: 'asd' })

@@ -576,0 +557,0 @@ await dataSet.remove(i, 1)

export * from './repository'
export * from './data-set'
export * from './data-set-setting'
import './injector-extension'
export * from './helpers'
import { Injector } from '@furystack/inject'
import { using } from '@furystack/utils'
import './injector-extension'
import { InMemoryStore } from '@furystack/core'
import { getDataSetFor, getRepository } from './helpers'
import { addStore, InMemoryStore } from '@furystack/core'
import { DataSet } from './data-set'

@@ -13,7 +13,6 @@

}
i.setupStores((sm) => sm.addStore(new InMemoryStore({ model: ExampleClass, primaryKey: 'id' }))).setupRepository(
(r) => r.createDataSet(ExampleClass, 'id', {}),
)
addStore(i, new InMemoryStore({ model: ExampleClass, primaryKey: 'id' }))
getRepository(i).createDataSet(ExampleClass, 'id', {})
const dataSet = i.getDataSetFor(ExampleClass, 'id')
const dataSet = getDataSetFor(i, ExampleClass, 'id')
expect(dataSet).toBeInstanceOf(DataSet)

@@ -20,0 +19,0 @@ })

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

SocketSocket SOC 2 Logo

Product

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

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc