[Rel v0.2] Migrate Javascript SDK files (#110)

Author: gkastrinis

README.md

@@ -88,7 +88,7 @@ $ npm run example -- ./examples/listEngines.ts
 ```
 
 ```console
-$ npm run example -- ./examples/runQuery.ts -d dbName -e engineName -c "def output = 1 + 2"
+$ npm run example -- ./examples/runQuery.ts -d dbName -e engineName -c "def output {1 + 2}"
 ```
 
 ## Data Types

examples/hello.rel

@@ -1 +1 @@
-def R = "hello", "world"
+def R {("hello", "world")}

src/api/model/modelApi.test.ts

@@ -45,7 +45,7 @@ describe('ModelApi', () => {
 
     it('should installModel', async () => {
       const testModels: Model[] = [
-        { name: 'test_model_1', value: 'def foo = :bar' },
+        { name: 'test_model_1', value: 'def foo {:bar}' },
       ];
       const resp = await client.installModels(
         databaseName,
@@ -68,7 +68,7 @@ describe('ModelApi', () => {
 
     it('should deleteModel', async () => {
       const testModels: Model[] = [
-        { name: 'test_model_2', value: 'def foo = :bar' },
+        { name: 'test_model_2', value: 'def foo {:bar}' },
       ];
       let resp = await client.installModels(
         databaseName,

src/api/model/modelApi.ts

@@ -27,8 +27,8 @@ export class ModelApi extends ExecAsyncApi {
     models.map((model, index) => {
       const inputName = `input_${randInt}_${index}`;
       queryInputs.push({ name: inputName, value: model.value });
-      queries.push(`def delete:rel:catalog:model["${model.name}"] = rel:catalog:model["${model.name}"]
-        def insert:rel:catalog:model["${model.name}"] = ${inputName}`);
+      queries.push(`def delete[:rel, :catalog, :model, "${model.name}"]: rel[:catalog, :model, "${model.name}"]
+        def insert[:rel, :catalog, :model, "${model.name}"]: ${inputName}`);
     });
 
     return await this.exec(
@@ -48,8 +48,8 @@ export class ModelApi extends ExecAsyncApi {
     models.map((model, index) => {
       const inputName = `input_${randInt}_${index}`;
       queryInputs.push({ name: inputName, value: model.value });
-      queries.push(`def delete:rel:catalog:model["${model.name}"] = rel:catalog:model["${model.name}"]
-        def insert:rel:catalog:model["${model.name}"] = ${inputName}`);
+      queries.push(`def delete[:rel, :catalog, :model, "${model.name}"]: rel[:catalog, :model, "${model.name}"]
+        def insert[:rel, :catalog, :model, "${model.name}"]: ${inputName}`);
     });
 
     return await this.execAsync(
@@ -67,7 +67,7 @@ export class ModelApi extends ExecAsyncApi {
     const rsp = await this.exec(
       database,
       engine,
-      `def output:${outName}[name] = rel:catalog:model(name, _)`,
+      `def output(:${outName}, name): rel(:catalog, :model, name, _)`,
     );
 
     const result = rsp.results.find(
@@ -86,7 +86,7 @@ export class ModelApi extends ExecAsyncApi {
     const rsp = await this.exec(
       database,
       engine,
-      `def output:${outName} = rel:catalog:model["${name}"]`,
+      `def output[:${outName}]: rel[:catalog, :model, "${name}"]`,
     );
 
     const result = rsp.results.find(
@@ -106,15 +106,15 @@ export class ModelApi extends ExecAsyncApi {
   async deleteModels(database: string, engine: string, names: string[]) {
     const queries = names.map(
       name =>
-        `def delete:rel:catalog:model["${name}"] = rel:catalog:model["${name}"]`,
+        `def delete[:rel, :catalog, :model, "${name}"]: rel[:catalog, :model, "${name}"]`,
     );
     return await this.exec(database, engine, queries.join('\n'), [], false);
   }
 
   async deleteModelsAsync(database: string, engine: string, names: string[]) {
     const queries = names.map(
       name =>
-        `def delete:rel:catalog:model["${name}"] = rel:catalog:model["${name}"]`,
+        `def delete[:rel, :catalog, :model, "${name}"]: rel[:catalog, :model, "${name}"]`,
     );
 
     return await this.execAsync(

src/api/query/execAsyncApi.ts

@@ -117,8 +117,8 @@ export class ExecAsyncApi extends TransactionAsyncApi {
     json: any,
   ) {
     const qs = [
-      `def config:data = data`,
-      `def insert:${relation} = load_json[config]`,
+      `def config[:data]: data`,
+      `def insert[:${relation}]: load_json[config]`,
     ];
     const inputs: QueryInput[] = [
       {
@@ -138,7 +138,7 @@ export class ExecAsyncApi extends TransactionAsyncApi {
     syntax?: CsvConfigSyntax,
     schema?: CsvConfigSchema,
   ) {
-    const qs = [`def config:data = data`];
+    const qs = [`def config[:data]: data`];
     const inputs: QueryInput[] = [
       {
         name: 'data',
@@ -154,7 +154,7 @@ export class ExecAsyncApi extends TransactionAsyncApi {
       qs.push(...schemaToRel(schema));
     }
 
-    qs.push(`def insert:${relation} = load_csv[config]`);
+    qs.push(`def insert[:${relation}]: load_csv[config]`);
 
     return this.exec(database, engine, qs.join('\n'), inputs, false);
   }

src/api/query/loadData.test.ts

@@ -51,7 +51,7 @@ describe('Load data integration tests', () => {
       resp = await client.exec(
         databaseName,
         engineName,
-        'def output = test_relation',
+        'def output {test_relation}',
       );
 
       expect(resp.transaction.state).toEqual('COMPLETED');
@@ -74,7 +74,7 @@ describe('Load data integration tests', () => {
       resp = await client.exec(
         databaseName,
         engineName,
-        'def output = test_relation',
+        'def output {test_relation}',
       );
 
       expect(resp.transaction.state).toEqual('COMPLETED');
@@ -109,7 +109,7 @@ describe('Load data integration tests', () => {
       resp = await client.exec(
         databaseName,
         engineName,
-        'def output = test_relation_1',
+        'def output {test_relation_1}',
       );
 
       expect(resp.transaction.state).toEqual('COMPLETED');
@@ -142,7 +142,7 @@ describe('Load data integration tests', () => {
       resp = await client.exec(
         databaseName,
         engineName,
-        'def output = test_relation_2',
+        'def output {test_relation_2}',
       );
 
       expect(resp.transaction.state).toEqual('COMPLETED');

src/api/query/queryApi.test.ts

@@ -64,7 +64,7 @@ describe('QueryApi', () => {
           persist: [],
           inputs: [],
           source: {
-            value: 'def output = 123',
+            value: 'def output {123}',
             name: 'query',
             type: 'Source',
             path: '',
@@ -92,7 +92,7 @@ describe('QueryApi', () => {
       })
       .reply(200, response);
 
-    const result = await api.query(database, engine, 'def output = 123');
+    const result = await api.query(database, engine, 'def output {123}');
 
     scope.done();
 
@@ -119,7 +119,7 @@ describe('QueryApi', () => {
             },
           ],
           source: {
-            value: 'def output = 123',
+            value: 'def output {123}',
             name: 'query',
             type: 'Source',
             path: '',
@@ -146,7 +146,7 @@ describe('QueryApi', () => {
         compute_name: engine,
       })
       .reply(200, response);
-    const result = await api.query(database, engine, 'def output = 123', [
+    const result = await api.query(database, engine, 'def output {123}', [
       { name: 'input1', value: 'value1' },
     ]);
 

src/api/query/utils.ts

@@ -86,9 +86,9 @@ export function syntaxToRel(syntax: CsvConfigSyntax) {
           return `(${key}, :${toRelLiteral(syntax.header![key])})`;
         })
         .join('; ');
-      qs.push(`def config:syntax:header = ${headerStr}`);
+      qs.push(`def config[:syntax, :header]: { ${headerStr} }`);
     } else {
-      qs.push(`def config:syntax:${prop} = ${toRelLiteral(syntax[prop])}`);
+      qs.push(`def config[:syntax, :${prop}]: ${toRelLiteral(syntax[prop])}`);
     }
   });
 
@@ -99,7 +99,9 @@ export function schemaToRel(schema: CsvConfigSchema) {
   const qs: string[] = [];
 
   Object.keys(schema).forEach(colName => {
-    qs.push(`def config:schema${colName} = ${toRelLiteral(schema[colName])}`);
+    qs.push(
+      `def config[:schema, ${colName}]: ${toRelLiteral(schema[colName])}`,
+    );
   });
 
   return qs;

src/api/transaction/transactionAsyncApi.test.ts

@@ -28,9 +28,9 @@ const protobufMock = readFileSync(__dirname + '/mocks/metadata.pb');
 const multipartContentType =
   'multipart/form-data; boundary=28deee55b43d20e109a8fe119e47c5393620ea568b7059405c4cf23bad7b';
 
-// def output = :foo
-// def output = :"foo;bar", 1
-// def output = 1
+// def output {:foo}
+// def output {(:"foo;bar", 1)}
+// def output {1}
 const expectedArrow = [
   {
     filename: '0.arrow',

src/results/resultTable.ts

@@ -89,7 +89,7 @@ export class ResultTable implements IteratorOf<RelTypedValue['value'][]> {
    * Instantiate a new ResultTable instance.
    *
    * @example
-   *   cosnt result = await client.exec('database', 'engine', 'def output = 123, "test"')
+   *   cosnt result = await client.exec('database', 'engine', 'def output {123}, "test"')
    *   cosnt table = new ResultTable(result.results[0]);
    *
    *   console.log(table.values()); // Prints [[123n, "test"]];