Skip to content

Commit

Permalink
Format and bump version
Browse files Browse the repository at this point in the history
  • Loading branch information
insyri committed Nov 11, 2022
1 parent b4b06da commit ac0ee89
Show file tree
Hide file tree
Showing 9 changed files with 188 additions and 188 deletions.
4 changes: 2 additions & 2 deletions node/package-lock.json

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

2 changes: 1 addition & 1 deletion node/package.json
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "tpy",
"version": "v1.0.0-pre-release-9",
"version": "v1.0.0-pre-release-10",
"description": "🔑 A strongly typed Pylon API client.",
"author": "insyri",
"license": "MIT",
Expand Down
4 changes: 2 additions & 2 deletions src/context.ts
Original file line number Diff line number Diff line change
Expand Up @@ -91,11 +91,11 @@ export class Context {
/**
* A null context number.
*/
static nullNumber = "-1";
static nullNumber = '-1';
/**
* A null context string.
*/
static nullString = "<null string>";
static nullString = '<null string>';

/**
* Whether the given context matches a nullish context value.
Expand Down
72 changes: 36 additions & 36 deletions src/kv.ts
Original file line number Diff line number Diff line change
Expand Up @@ -7,10 +7,10 @@
* @module
*/

import { Tpy } from "./tpy.ts";
import type { Json, KV } from "./types/pylon.d.ts";
import { parametersPrompt, TpyError } from "./error.ts";
import { Context } from "./context.ts";
import { Tpy } from './tpy.ts';
import type { Json, KV } from './types/pylon.d.ts';
import { parametersPrompt, TpyError } from './error.ts';
import { Context } from './context.ts';

/**
* A KVNamespace interface that (almost) matches the Pylon KVNamespace SDK class.
Expand All @@ -31,21 +31,21 @@ export class TpyKV {
constructor(tpyInstance: Tpy, deploymentID: string, kvnamespace: string) {
if (!tpyInstance || !(tpyInstance instanceof Tpy)) {
throw new TpyError(
"Missing or Invalid Required Parameter",
'Missing or Invalid Required Parameter',
parametersPrompt(
!tpyInstance ? "missing" : "incompatible",
"tpyInstance"
!tpyInstance ? 'missing' : 'incompatible',
'tpyInstance',
),
"tpyInstance",
tpyInstance
'tpyInstance',
tpyInstance,
);
}
if (!deploymentID) {
throw new TpyError(
"Missing or Invalid Required Parameter",
parametersPrompt("missing", "deploymentID"),
"deploymentID",
deploymentID
'Missing or Invalid Required Parameter',
parametersPrompt('missing', 'deploymentID'),
'deploymentID',
deploymentID,
);
}
this.tpyc = tpyInstance;
Expand All @@ -66,13 +66,13 @@ export class TpyKV {
await this.tpyc.httpRaw(
new Context({ deploymentID }),
`/deployments/${deploymentID}/kv/namespaces/${kvnamespace}/items/${key}`,
"PUT",
'PUT',
{
body: JSON.stringify({
string: typeof value === "string" ? `"${value}"` : value,
string: typeof value === 'string' ? `"${value}"` : value,
}),
},
false
false,
);
}

Expand All @@ -85,17 +85,17 @@ export class TpyKV {
async putArrayBuffer(
key: string,
value: ArrayBuffer,
options?: KV.OperationOptions.Put
options?: KV.OperationOptions.Put,
) {
if (options?.ifNotExists && (await this.get(key))) return;

const { deploymentID, kvnamespace } = this;
await this.tpyc.httpRaw(
new Context({ deploymentID, kvnamespace }),
`/deployments/${deploymentID}/kv/namespaces/${kvnamespace}/items/${key}`,
"PUT",
'PUT',
{ body: JSON.stringify({ bytes: value }) },
false
false,
);
}

Expand All @@ -109,21 +109,21 @@ export class TpyKV {
const { deploymentID, kvnamespace } = this;
const response = await this.tpyc.httpRaw<KV.GET.Items<T>>(
new Context({ deploymentID, kvnamespace }),
`/deployments/${deploymentID}/kv/namespaces/${kvnamespace}/items`
`/deployments/${deploymentID}/kv/namespaces/${kvnamespace}/items`,
);
let item: T | undefined;
for (let i = 0; i < response.length; i++) {
const p = response[i];
if (p.key !== key) continue;
if (!p.value.string) {
throw new TpyError(
"Missing or Unexpected Value in Response",
'Missing or Unexpected Value in Response',
`response[${i}].value.string is undefined`,
`response[${i}].value.string`,
response
response,
);
}
item = ["'", '"', "`"].includes(p.value.string[0])
item = ['\'', '"', '`'].includes(p.value.string[0])
? JSON.parse(p.value.string)
: p.value.string;
break;
Expand All @@ -140,7 +140,7 @@ export class TpyKV {
const { deploymentID, kvnamespace } = this;
const response = await this.tpyc.httpRaw<KV.GET.Items>(
new Context({ deploymentID, kvnamespace }),
`/deployments/${deploymentID}/kv/namespaces/${kvnamespace}/items`
`/deployments/${deploymentID}/kv/namespaces/${kvnamespace}/items`,
);
let item: ArrayBuffer | undefined;
for (const p of response) {
Expand All @@ -161,15 +161,15 @@ export class TpyKV {
const { deploymentID, kvnamespace } = this;
let response = await this.tpyc.httpRaw<KV.GET.Items>(
new Context({ deploymentID, kvnamespace }),
`/deployments/${deploymentID}/kv/namespaces/${kvnamespace}/items`
`/deployments/${deploymentID}/kv/namespaces/${kvnamespace}/items`,
);

if (options?.limit) response = response.slice(0, options.limit);

if (options?.from) {
response = response.slice(
response.findIndex((i) => i.key === options.from) + 1,
response.length
response.length,
);
}

Expand All @@ -185,18 +185,18 @@ export class TpyKV {
* @template T The type of the key's value.
*/
async items<T>(
options?: KV.OperationOptions.Items
options?: KV.OperationOptions.Items,
): Promise<KV.GET.ItemsFlattened<T>> {
const { deploymentID, kvnamespace } = this;
let response = await this.tpyc.httpRaw<KV.GET.Items>(
new Context({ deploymentID, kvnamespace }),
`/deployments/${deploymentID}/kv/namespaces/${kvnamespace}/items`
`/deployments/${deploymentID}/kv/namespaces/${kvnamespace}/items`,
);

if (options?.from) {
response = response.slice(
response.findIndex((i) => i.key === options.from) + 1,
response.length
response.length,
);
}

Expand All @@ -210,12 +210,12 @@ export class TpyKV {
: i.value.bytes;
if (!j) {
throw new TpyError(
"Missing or Unexpected Value in Response",
'Missing or Unexpected Value in Response',
`response[${i}].value.string and/or response[${i}].value.bytes are undefined`,
[`response[${i}].value.string`, `response[${i}].value.bytes`].join(
", "
', ',
),
response
response,
);
}
return {
Expand All @@ -235,7 +235,7 @@ export class TpyKV {
(
await this.tpyc.httpRaw<KV.GET.Namespace>(
new Context({ deploymentID, kvnamespace }),
`/deployments/${deploymentID}/kv/namespaces`
`/deployments/${deploymentID}/kv/namespaces`,
)
).find((n) => n.namespace == kvnamespace)?.count || 0
);
Expand All @@ -255,7 +255,7 @@ export class TpyKV {
await this.tpyc.httpRaw<KV.DELETE.Namespace>(
new Context({ deploymentID, kvnamespace }),
`/deployments/${deploymentID}/kv/namespaces/${kvnamespace}`,
"DELETE"
'DELETE',
)
).keys_deleted;
}
Expand All @@ -274,9 +274,9 @@ export class TpyKV {
await this.tpyc.httpRaw(
new Context({ deploymentID, kvnamespace }),
`/deployments/${deploymentID}/kv/namespaces/${kvnamespace}/items/${key}`,
"DELETE",
'DELETE',
{},
false
false,
);

if (!options?.prevValue) await del();
Expand Down
Loading

0 comments on commit ac0ee89

Please sign in to comment.