Skip to content

Commit

Permalink
Showing 18 changed files with 59 additions and 360 deletions.
8 changes: 1 addition & 7 deletions demo/test-insert.js
Original file line number Diff line number Diff line change
@@ -9,7 +9,6 @@ async function demo() {

const database = new Cama({
path: './.cama',
pageLength: 10000,
persistenceAdapter: 'fs',
logLevel: 'debug'
});
@@ -18,10 +17,7 @@ async function demo() {
columns: [],
indexes: [],
});
const collection2 = await database.initCollection('test2', {
columns: [],
indexes: [],
});

console.log('generating dummy data');
console.time('dummy data generated');
const dummyData = [];
@@ -58,9 +54,7 @@ Sed pellentesque ante quis nunc accumsan sodales. Nam vitae dui a quam bibendum
});
console.log('insert col1');
await collection.insertMany(dummyData);
console.log('insert col2');

await collection2.insertMany(dummyData);
const findResult = await collection.findMany({
_id: {
$gte: 50000,
2 changes: 1 addition & 1 deletion package.json
Original file line number Diff line number Diff line change
@@ -11,7 +11,7 @@
"lint:fix": "eslint src --fix --ext .js,.ts",
"test": "jest --config jest.config.js",
"publish": "npm publish",
"demo": "node ./demo/test-insert.js",
"demo": "yarn build && node ./demo/test-insert.js",
"generate-docs": "typedoc --out docs ./src"
},
"repository": {
3 changes: 1 addition & 2 deletions src/interfaces/cama-config.interface.ts
Original file line number Diff line number Diff line change
@@ -3,7 +3,6 @@ import { LogLevel } from './logger-level.enum';

export interface ICamaConfig {
persistenceAdapter: PersistenceAdapterEnum;
path: string;
pageLength: number;
path?: string;
logLevel?: LogLevel
}
4 changes: 0 additions & 4 deletions src/interfaces/db-page.interface.ts

This file was deleted.

8 changes: 3 additions & 5 deletions src/interfaces/fs.interface.ts
Original file line number Diff line number Diff line change
@@ -1,17 +1,15 @@
import { IPagingAllocation } from './paging-allocation.interface';

export interface IFS {
writeJSON<T>(path: string, fileName: string, data: T): Promise<void>;
exists(filePath: string): Promise<boolean>;
loadJSON<T>(filePath: string): Promise<T>;
writePages<T>(camaFolder:string, collectionName: string, allocations: Array<IPagingAllocation<T>>): Promise<Array<string>>;
commitPages(filePaths: Array<string>): Promise<void>;
commit(filePath: string, collection:string ): Promise<void>;


mkdir(path: string):Promise<void>;
readDir(path:string): Promise<any>;

loadPage(file: string):Promise<any>;

writePage(page:string, camaFolder:string, camaCollection:string, data: any):Promise<void>;
writeData(camaFolder:string, camaCollection:string, data: any):Promise<void>;
readData<T>(path:string): Promise<T>;
}
1 change: 0 additions & 1 deletion src/interfaces/meta-structure.interface.ts
Original file line number Diff line number Diff line change
@@ -1,4 +1,3 @@
import { IDbPage } from './db-page.interface';
import { ICollectionConfig } from './collection-config.interface';

export interface IMetaStructure extends ICollectionConfig {
4 changes: 0 additions & 4 deletions src/interfaces/page.interface.ts

This file was deleted.

5 changes: 0 additions & 5 deletions src/interfaces/paging-allocation.interface.ts

This file was deleted.

6 changes: 0 additions & 6 deletions src/interfaces/paging-map.interface.ts

This file was deleted.

13 changes: 0 additions & 13 deletions src/interfaces/paging.interface.ts

This file was deleted.

1 change: 0 additions & 1 deletion src/interfaces/query-service.interface.ts
Original file line number Diff line number Diff line change
@@ -4,5 +4,4 @@ import { IFilterResult } from './filter-result.interface';
export interface IQueryService<T> {
filter(query:any, options: IQueryOptions):Promise<IFilterResult<T>>;

retrieveIndexes(query: any): Promise<void>;
}
3 changes: 0 additions & 3 deletions src/modules/collection/index.ts
Original file line number Diff line number Diff line change
@@ -34,9 +34,6 @@ export class Collection implements ICollection {
collectionConfig: ICollectionConfig,
camaConfig: ICamaConfig
) {
if(!camaConfig.pageLength){
camaConfig.pageLength = 10000;
}
this.container = new Container();
const persistenceModule = selectPersistenceAdapterClass(camaConfig.persistenceAdapter);
this.container.load(persistenceModule);
4 changes: 3 additions & 1 deletion src/modules/persistence/fs/collection-meta.ts
Original file line number Diff line number Diff line change
@@ -54,8 +54,10 @@ export class CollectionMeta implements ICollectionMeta {
...config,
collectionName,
};
console.log(this);
this.logger.log(LogLevel.Info, 'Writing meta file');

await this.fs.writeData(this.camaPath, this.collectionName, []);
await this.fs.commit(this.camaPath, this.collectionName);
return this.fs.writeJSON<IMetaStructure>(this.dbPath, this.fileName, this.meta);
}

120 changes: 0 additions & 120 deletions src/modules/persistence/fs/fs-paging.ts

This file was deleted.

Loading

0 comments on commit c428d9f

Please sign in to comment.