Merge pull request #4 from hasura/daniel/by-pk-query

Query by primary key support

package.json

@@ -12,7 +12,8 @@
   },
   "dependencies": {
     "@aws-sdk/client-dynamodb": "^3.427.0",
-    "@hasura/ndc-sdk-typescript": "^1.1.0"
+    "@hasura/ndc-sdk-typescript": "^1.1.0",
+    "@smithy/util-base64": "^2.0.0"
   },
   "devDependencies": {
     "@tsconfig/node18": "^18.2.2",

src/configuration-schema.generated.json

@@ -9,7 +9,7 @@
           "type": "string"
         },
         "dynamoType": {
-          "$ref": "#/definitions/DynamoAttributeType"
+          "$ref": "#/definitions/DynamoType"
         },
         "name": {
           "type": "string"
@@ -73,7 +73,7 @@
       ],
       "type": "object"
     },
-    "DynamoAttributeType": {
+    "DynamoType": {
       "enum": [
         "S",
         "N",
@@ -161,18 +161,7 @@
       "additionalProperties": false,
       "properties": {
         "indexName": {
-          "additionalProperties": {
-            "type": "string"
-          },
-          "properties": {
-            "length": {
-              "type": "number"
-            }
-          },
-          "required": [
-            "length"
-          ],
-          "type": "object"
+          "type": "string"
         },
         "keySchema": {
           "$ref": "#/definitions/KeySchema"

src/connector.ts

@@ -5,6 +5,7 @@ import { DynamoDBClient } from "@aws-sdk/client-dynamodb";
 import { Configuration, configurationSchema, makeEmptyConfiguration, updateConfiguration } from "./configuration";
 import { ConnectorSchema, createSchema } from "./schema-ndc";
 import { Err, Ok } from "./result";
+import { performQuery } from "./query";
 
 
 type State = {
@@ -56,8 +57,8 @@ export const connector: Connector<Configuration, State> = {
       throw new BadRequest("Schema's busted, yo", result.error)
     }
   },
-  query: function (configuration: Configuration, state: State, request: QueryRequest): Promise<QueryResponse> {
-    throw new Error("Function not implemented.");
+  query: async function (configuration: Configuration, state: State, request: QueryRequest): Promise<QueryResponse> {
+    return await performQuery(request, state.schema, state.dynamodbClient);
   },
   explain: function (configuration: Configuration, state: State, request: QueryRequest): Promise<ExplainResponse> {
     throw new Error("Function not implemented.");