2699

pending completion

Build # 2699

Build Type

Pull #899

travis-ci-com

Committed by

web-flow

Commit Message

Merge b9af0668f into 77295b47e

Pull Request Pull Request #899: Wip/type fix

Run Details

10114 of 21218 branches covered (47.67%)

Branch coverage included in aggregate %.

0 of 3 new or added lines in 1 file covered. (0.0%)

953 existing lines in 40 files now uncovered.

23792 of 41657 relevant lines covered (57.11%)

297907.76 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

65.22

/lib/engine/db/sqlite/local_table.ts

// -*- mode: typescript; indent-tabs-mode: nil; js-basic-offset: 4 -*-
//
// This file is part of Genie
//
// Copyright 2020-2021 The Board of Trustees of the Leland Stanford Junior University
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//    http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
//
// Author: Giovanni Campagna <gcampagn@cs.stanford.edu>

import * as sql from '.';
import type { SearchParams } from '..';

type Fields<RowType> = ReadonlyArray<Exclude<keyof RowType & string, "uniqueId">>;

export default class LocalTable<RowType> {
    name : string;
    private _db : sql.SQLiteDatabase;
    private _fields : Fields<RowType>;

    constructor(db : sql.SQLiteDatabase, name : string, fields : Fields<RowType>) {
        this.name = name;
        this._db = db;
        this._fields = fields;
    }

    getAll() : Promise<RowType[]> {
        return this._db.withClient((client) => {
            return sql.selectAll(client, `select * from ${this.name}`, []);
        });
    }

    getOne(uniqueId : string) : Promise<RowType> {
        return this._db.withClient((client) => {
            return sql.selectOne(client, `select * from ${this.name} where uniqueId = ?`, [uniqueId]);
        });
    }

    getBy(field : keyof RowType, value : string) : Promise<RowType[]> {
        return this._db.withClient((client) => {
            return sql.selectAll(client, `select * from ${this.name} where ${field} = ?`, [value]);
        });
    }

    search(search : SearchParams<RowType>) {
        return this._db.withClient((client) => {
            const values = search.filter.map((f) => f.v);
            const filter = search.filter.map((f) => `${f.k} ${f.o} ?`).join(' and ');
            return sql.selectAll(client, `select * from ${this.name} where ${filter || 'true'} order by ${search.sort[0]} ${search.sort[1]} limit ${search.limit}`, values);
        });
    }

    insertOne(uniqueId : string, row : Omit<RowType, "uniqueId">) : Promise<void> {
        return this._db.withTransaction(async (client) => {
            const insertSql = `insert or replace into ${this.name}(uniqueId, ${this._fields}) values(?,${this._fields.map(() => '?')})`;
            const param = ([uniqueId] as unknown[]).concat(this._fields.map((f) => row[f]));
            await sql.insertOne(client, insertSql, param);
        });
    }

    deleteOne(uniqueId : string) : Promise<void> {
        return this._db.withTransaction(async (client) => {
            await sql.query(client, `delete from ${this.name} where uniqueId = ?`, [uniqueId]);
        });
    }
}

1	// -- mode: typescript; indent-tabs-mode: nil; js-basic-offset: 4 --
2	//
3	// This file is part of Genie
4	//
5	// Copyright 2020-2021 The Board of Trustees of the Leland Stanford Junior University
6	//
7	// Licensed under the Apache License, Version 2.0 (the "License");
8	// you may not use this file except in compliance with the License.
9	// You may obtain a copy of the License at
10	//
11	// http://www.apache.org/licenses/LICENSE-2.0
12	//
13	// Unless required by applicable law or agreed to in writing, software
14	// distributed under the License is distributed on an "AS IS" BASIS,
15	// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16	// See the License for the specific language governing permissions and
17	// limitations under the License.
18	//
19	// Author: Giovanni Campagna <gcampagn@cs.stanford.edu>
20
21	import * as sql from '.';	69✔
22	import type { SearchParams } from '..';
23
24	type Fields<RowType> = ReadonlyArray<Exclude<keyof RowType & string, "uniqueId">>;
25
26	export default class LocalTable<RowType> {	69✔
27	name : string;
28	private _db : sql.SQLiteDatabase;
29	private _fields : Fields<RowType>;
30
31	constructor(db : sql.SQLiteDatabase, name : string, fields : Fields<RowType>) {
32	this.name = name;	19✔
33	this._db = db;	19✔
34	this._fields = fields;	19✔
35	}
36
37	getAll() : Promise<RowType[]> {
38	return this._db.withClient((client) => {	2✔
39	return sql.selectAll(client, `select * from ${this.name}`, []);	2✔
40	});
41	}
42
43	getOne(uniqueId : string) : Promise<RowType> {
44	return this._db.withClient((client) => {	15✔
45	return sql.selectOne(client, `select * from ${this.name} where uniqueId = ?`, [uniqueId]);	15✔
46	});
47	}
48
49	getBy(field : keyof RowType, value : string) : Promise<RowType[]> {
50	return this._db.withClient((client) => {	×
51	return sql.selectAll(client, `select * from ${this.name} where ${field} = ?`, [value]);	×
52	});
53	}
54
55	search(search : SearchParams<RowType>) {
UNCOV 56	return this._db.withClient((client) => {	×
UNCOV 57	const values = search.filter.map((f) => f.v);	×
UNCOV 58	const filter = search.filter.map((f) => `${f.k} ${f.o} ?`).join(' and ');	×
UNCOV 59	return sql.selectAll(client, `select * from ${this.name} where ${filter \|\| 'true'} order by ${search.sort[0]} ${search.sort[1]} limit ${search.limit}`, values);	×
60	});
61	}
62
63	insertOne(uniqueId : string, row : Omit<RowType, "uniqueId">) : Promise<void> {
64	return this._db.withTransaction(async (client) => {	59✔
65	const insertSql = `insert or replace into ${this.name}(uniqueId, ${this._fields}) values(?,${this._fields.map(() => '?')})`;	104✔
66	const param = ([uniqueId] as unknown[]).concat(this._fields.map((f) => row[f]));	104✔
67	await sql.insertOne(client, insertSql, param);	59✔
68	});
69	}
70
71	deleteOne(uniqueId : string) : Promise<void> {
72	return this._db.withTransaction(async (client) => {	13✔
73	await sql.query(client, `delete from ${this.name} where uniqueId = ?`, [uniqueId]);	13✔
74	});
75	}
76	}

stanford-oval / genie-toolkit / 2699

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous