diff options
Diffstat (limited to 'trygvis/eda/cli')
| -rw-r--r-- | trygvis/eda/cli/__init__.py | 53 | ||||
| -rw-r--r-- | trygvis/eda/cli/add_to_db.py | 4 | ||||
| -rwxr-xr-x | trygvis/eda/cli/db_stats.py | 4 | ||||
| -rwxr-xr-x | trygvis/eda/cli/digikey_download_for_schematic.py | 9 | ||||
| -rw-r--r-- | trygvis/eda/cli/eda_rdf.py | 157 | ||||
| -rwxr-xr-x | trygvis/eda/cli/init.py | 29 | ||||
| -rwxr-xr-x | trygvis/eda/cli/make_bom.py | 4 |
7 files changed, 194 insertions, 66 deletions
diff --git a/trygvis/eda/cli/__init__.py b/trygvis/eda/cli/__init__.py index 8a4ce6f..f300f86 100644 --- a/trygvis/eda/cli/__init__.py +++ b/trygvis/eda/cli/__init__.py @@ -1,8 +1,9 @@ import sys import logging - from rdflib import store, ConjunctiveGraph, Graph, RDF, RDFS from rdflib.plugins.sparql import prepareQuery +import rdflib.plugins.stores.sparqlstore as sparqlstore +import configparser from ..digikey import rdf as digikey_rdf from ..kicad import rdf as kicad_rdf @@ -12,7 +13,7 @@ class CliException(Exception): pass -def init(): +def initialize(): logging.basicConfig(level=logging.DEBUG) pass @@ -27,16 +28,27 @@ def do_exit(msg=None): sys.exit(msg) -def with_database(path, tx): - g = ConjunctiveGraph('Sleepycat') - rt = g.open(path, create=False) - if rt == store.NO_STORE: - info("Creating store in %s" % path) - g.open(path, create=True) - elif rt != store.VALID_STORE: - raise CliException("The database is corrupt: %s" % path) +def with_database(tx): + config = read_config() + + db_type = config['db']['type'] + if db_type is None or db_type == 'local': + path = ".eda-rdf/db" + g = ConjunctiveGraph('Sleepycat') + rt = g.open(path, create=False) + if rt == store.NO_STORE: + info("Creating store in %s" % path) + g.open(path, create=True) + elif rt != store.VALID_STORE: + raise CliException("The database is corrupt: %s" % path) + elif db_type == 'sparql': + g = sparqlstore.SPARQLStore() + g.open(config["db"]["url"]) + else: + raise CliException("Unknown db.type: %s" % db_type) try: + print("g=%s" % g) tx(g) finally: g.close() @@ -70,7 +82,22 @@ _initNs = { "kicad-type": kicad_rdf.KICAD_TYPE} -def sparql(g, query, init_bindings=None): - q = prepareQuery(query, initNs=_initNs) +def sparql(g: Graph, query: str, init_bindings=None): + + if isinstance(g, sparqlstore.SPARQLStore): + return g.query(query, initNs=_initNs, initBindings=init_bindings) + else: + q = prepareQuery(query, initNs=_initNs) + return g.query(q, initBindings=init_bindings) + + +def write_config(config: configparser.ConfigParser): + with open('.eda-rdf/config.ini', 'w') as configfile: + config.write(configfile) + - return g.query(q, initBindings=init_bindings) +def read_config(): + with open('.eda-rdf/config.ini', 'r') as f: + config = configparser.ConfigParser() + config.read_file(f) + return config diff --git a/trygvis/eda/cli/add_to_db.py b/trygvis/eda/cli/add_to_db.py index e3b07c1..84f8d74 100644 --- a/trygvis/eda/cli/add_to_db.py +++ b/trygvis/eda/cli/add_to_db.py @@ -1,7 +1,7 @@ import trygvis.eda.cli as cli -def run(files, path, args): +def run(files, args): def load(g): s = 0 for f in files: @@ -15,4 +15,4 @@ def run(files, path, args): cli.info("Done. Loaded %d tuples" % s) - cli.with_database(path, load) + cli.with_database(load) diff --git a/trygvis/eda/cli/db_stats.py b/trygvis/eda/cli/db_stats.py index 5ee99ac..5261ed1 100755 --- a/trygvis/eda/cli/db_stats.py +++ b/trygvis/eda/cli/db_stats.py @@ -1,7 +1,7 @@ from trygvis.eda import cli -def run(db_path): +def run(): def db_stats(g): res = cli.sparql(g, """ SELECT ?schematic ?label @@ -37,4 +37,4 @@ ORDER BY ?dk_part_number for row in res: cli.info(" %-30s: %s" % (row.dk_part_number, row.label)) - cli.with_database(db_path, db_stats) + cli.with_database(db_stats) diff --git a/trygvis/eda/cli/digikey_download_for_schematic.py b/trygvis/eda/cli/digikey_download_for_schematic.py index ecfbc9e..0c21b3a 100755 --- a/trygvis/eda/cli/digikey_download_for_schematic.py +++ b/trygvis/eda/cli/digikey_download_for_schematic.py @@ -1,4 +1,5 @@ from rdflib.plugins.sparql import prepareQuery +import rdflib import rdflib.term from trygvis.eda import cli, write_graph @@ -7,8 +8,8 @@ from trygvis.eda.digikey import rdf as digikey_rdf from trygvis.eda.kicad import rdf as kicad_rdf initNs = { - "rdf": RDF, - "rdfs": RDFS, + "rdf": rdflib.RDF, + "rdfs": rdflib.RDFS, "dk": digikey_rdf.DIGIKEY, "dk-attr-type": digikey_rdf.DIGIKEY_ATTRIBUTE_TYPE, "dk-attr-value": digikey_rdf.DIGIKEY_ATTRIBUTE_VALUE, @@ -128,6 +129,6 @@ ORDER BY ?digikey_pn # writeGraph(tmpG, 'ttl/' + filename) -def run(schematic_url, db_path, args): +def run(schematic_url, args): cli.info("Schematic: %s" % schematic_url) - cli.with_database(db_path, lambda g: work(schematic_url, g)) + cli.with_database(lambda g: work(schematic_url, g)) diff --git a/trygvis/eda/cli/eda_rdf.py b/trygvis/eda/cli/eda_rdf.py index 7bf0934..33018ec 100644 --- a/trygvis/eda/cli/eda_rdf.py +++ b/trygvis/eda/cli/eda_rdf.py @@ -3,44 +3,47 @@ import sys import trygvis.eda.cli as cli -def main(): - parser = argparse.ArgumentParser() +class CliCommand(object): + def __init__(self, key, description): + self.key = key + self.description = description + + +class AddToDb(CliCommand): + def __init__(self): + super().__init__("add-to-db", "Import RDF triplet file to the database") - subparsers = parser.add_subparsers(dest="cmd") + def run(self, argv): + p = argparse.ArgumentParser(prog=self.key, description=self.description) + p.add_argument("files", nargs='*') + args = p.parse_args(argv) - # kicad-* - p = subparsers.add_parser("kicad-bom-to-ttl") - p.add_argument("-o", "--output", required=False) - p.add_argument("-i", "--input", required=False) + from trygvis.eda.cli import add_to_db + add_to_db.run(args.files, args) - # db-* - p = subparsers.add_parser("add-to-db") - p.add_argument("-d", "--db", required=True) - p.add_argument("files", nargs='*') - p = subparsers.add_parser("db-stats") - p.add_argument("-d", "--db", required=True) +class DbStats(CliCommand): + def __init__(self): + super().__init__("db-stats", "Show some statistics about the data in the database") - # digikey-* - p = subparsers.add_parser("digikey-download-for-schematic") - p.add_argument("-d", "--db", required=True) - p.add_argument("--schematic", required=True) + def run(self, argv): + p = argparse.ArgumentParser(prog=self.key, description=self.description) + args = p.parse_args(argv) - p = subparsers.add_parser("digikey-download-attribute-types-for-category") - p.add_argument("-c", "--category", required=True) - p.add_argument("-s", "--sub-category", required=True) - p.add_argument("-o", "--output", required=False) + from trygvis.eda.cli import db_stats + db_stats.run() - # Other - p = subparsers.add_parser("make-bom") - p.add_argument("-d", "--db", required=True) - p.add_argument("--schematic", required=True) - args = parser.parse_args() +class KicadBomToTtl(CliCommand): + def __init__(self): + super().__init__("kicad-bom-to-ttl", "Create RDF triples from a KiCAD BOM.xml file") - cli.init() + def run(self, argv): + p = argparse.ArgumentParser(prog=self.key, description=self.description) + p.add_argument("-o", "--output", required=False) + p.add_argument("-i", "--input", required=False) + args = p.parse_args(argv) - if args.cmd == "kicad-bom-to-ttl": from trygvis.eda.cli import kicad_bom_to_ttl if args.input is not None: @@ -56,24 +59,92 @@ def main(): with src, dst: kicad_bom_to_ttl.run(src, dst, args) - elif args.cmd == "add-to-db": - from trygvis.eda.cli import add_to_db - - add_to_db.run(args.files, args.db, args) - elif args.cmd == "db-stats": - from trygvis.eda.cli import db_stats - db_stats.run(args.db) +class DigikeyDownloadForSchematic(CliCommand): + def __init__(self): + super().__init__("digikey-download-for-schematic", "Download missing data from digikey.com") - elif args.cmd == "make-bom": - from trygvis.eda.cli import make_bom - make_bom.run(args.schematic, args.db) + def run(self, argv): + p = argparse.ArgumentParser(prog=self.key, description=self.description) + p.add_argument("--schematic", required=True) + args = p.parse_args(argv) - elif args.cmd == "digikey-download-for-schematic": from trygvis.eda.cli import digikey_download_for_schematic - digikey_download_for_schematic.run(args.schematic, args.db, args) - elif args.cmd == "digikey-download-attribute-types-for-category": + digikey_download_for_schematic.run(args.schematic, args) + + +class DigikeyDownloadAttributeTypesForCategory(CliCommand): + def __init__(self): + super().__init__("digikey-download-attribute-types-for-category", "Download the attribute types for a category from digikey.com") + + def run(self, argv): + p = argparse.ArgumentParser(prog=self.key, description=self.description) + p.add_argument("-c", "--category", required=True) + p.add_argument("-s", "--sub-category", required=True) + p.add_argument("-o", "--output", required=False) + args = p.parse_args(argv) + from trygvis.eda.cli import digikey_download_attribute_types_for_category digikey_download_attribute_types_for_category.run(args.category, args.sub_category, args.output, args) - else: - sys.exit("Unknown command: %s" % args.cmd) + +class MakeBom(CliCommand): + def __init__(self): + super().__init__("make-bom", "Create a BOM for a project with all info for each part.") + + def run(self, argv): + p = argparse.ArgumentParser(prog=self.key, description=self.description) + p.add_argument("--schematic", required=True) + args = p.parse_args(argv) + + from trygvis.eda.cli import make_bom + make_bom.run(args.schematic) + + +class Init(CliCommand): + def __init__(self): + super().__init__("init", "Initialize a EDA-RFD database") + + def run(self, argv): + p = argparse.ArgumentParser(prog=self.key, description=self.description) + p.add_argument("--database-url", dest="database_url") + args = p.parse_args(argv) + + from trygvis.eda.cli import init + init.run(args) + + +def main(): + cli.initialize() + + commands = [ + AddToDb(), + Init(), + DbStats(), + MakeBom(), + KicadBomToTtl(), + DigikeyDownloadForSchematic(), + DigikeyDownloadAttributeTypesForCategory(), + ] + + parser = argparse.ArgumentParser( + description='EDA RFD tools', + usage="""eda-rdf <command> [<args>] + +Available commands + +""" + "\n".join([" %-50s %s" % (cmd.key, cmd.description) for cmd in commands])) + parser.add_argument('command', help='Subcommand to run', nargs='?') + args = parser.parse_args(sys.argv[1:2]) + cmd_args = sys.argv[2:] + + if args.command is None: + print(parser.usage) + print() + sys.exit(1) + + for cmd in commands: + if cmd.key == args.command: + cmd.run(cmd_args) + return + + print("Unknown command: %s" % args.command) diff --git a/trygvis/eda/cli/init.py b/trygvis/eda/cli/init.py new file mode 100755 index 0000000..1ea9079 --- /dev/null +++ b/trygvis/eda/cli/init.py @@ -0,0 +1,29 @@ +from os.path import isfile, exists, isdir + +from trygvis.eda import cli +import configparser + +import os +import sys + + +def run(args): + try: + os.mkdir('.eda-rdf') + except FileExistsError: + if isdir('.eda-rdf'): + cli.info('Already initialized') + else: + cli.info('.eda-rdf exists, but is not a directory') + sys.exit(1) + + config = configparser.ConfigParser() + config['db'] = { + "type": "local" + } + + if args.database_url is not None: + config["db"]["type"] = "sparql" + config["db"]["url"] = args.database_url + + cli.write_config(config) diff --git a/trygvis/eda/cli/make_bom.py b/trygvis/eda/cli/make_bom.py index eae7043..fcdbe99 100755 --- a/trygvis/eda/cli/make_bom.py +++ b/trygvis/eda/cli/make_bom.py @@ -21,8 +21,8 @@ class Component(object): self.fields[field_name] = field_value -def run(schematic_url, db_path): - cli.with_database(db_path, lambda g: work(schematic_url, g)) +def run(schematic_url): + cli.with_database(lambda g: work(schematic_url, g)) def work(schematic_url, g): |