94 lines
2.6 KiB
TypeScript
94 lines
2.6 KiB
TypeScript
|
import Redis from "ioredis";
|
||
|
|
|
||
|
|
import {
|
||
|
|
APL,
|
||
|
|
AplConfiguredResult,
|
||
|
|
AplReadyResult,
|
||
|
|
AuthData,
|
||
|
|
} from "@saleor/app-sdk/APL";
|
||
|
|
|
||
|
|
export type RedisAPLClientArgs = {
|
||
|
|
client: Redis;
|
||
|
|
appApiBaseUrl: string;
|
||
|
|
};
|
||
|
|
export type RedisAPLUrlArgs = {
|
||
|
|
redisUrl: string;
|
||
|
|
appApiBaseUrl: string;
|
||
|
|
};
|
||
|
|
/**
|
||
|
|
* Redis APL
|
||
|
|
* @param redisUrl - in format redis[s]://[[username][:password]@][host][:port][/db-number],
|
||
|
|
* so for example redis://alice:foobared@awesome.redis.server:6380
|
||
|
|
* For saleor-platform, thats: `redis://redis:6379/2`
|
||
|
|
*/
|
||
|
|
export class RedisAPL implements APL {
|
||
|
|
private client;
|
||
|
|
|
||
|
|
private appApiBaseUrl;
|
||
|
|
|
||
|
|
constructor(args: RedisAPLClientArgs | RedisAPLUrlArgs) {
|
||
|
|
if (!args.appApiBaseUrl)
|
||
|
|
throw new Error(
|
||
|
|
"The RedisAPL requires to know the app api url beforehand",
|
||
|
|
);
|
||
|
|
this.appApiBaseUrl = args.appApiBaseUrl;
|
||
|
|
|
||
|
|
if ("client" in args && args.client) {
|
||
|
|
this.client = args.client;
|
||
|
|
} else if ("redisUrl" in args && args.redisUrl) {
|
||
|
|
this.client = new Redis(args.redisUrl, { lazyConnect: true });
|
||
|
|
} else {
|
||
|
|
throw new Error("RedisAPL: No redis url or client defined");
|
||
|
|
}
|
||
|
|
this.isConfigured().then((v) => console.log("REDIS: CONFIGURED TEST: ", v));
|
||
|
|
}
|
||
|
|
|
||
|
|
private prepareKey(saleorApiUrl: string) {
|
||
|
|
return `${this.appApiBaseUrl}:${saleorApiUrl}`;
|
||
|
|
}
|
||
|
|
|
||
|
|
async get(saleorApiUrl: string): Promise<AuthData | undefined> {
|
||
|
|
const res = await this.client.get(this.prepareKey(saleorApiUrl));
|
||
|
|
console.log(
|
||
|
|
`REDIS: GET FOR ${this.prepareKey(saleorApiUrl)} (is ${res ? "truthy" : "falsy"}):`,
|
||
|
|
);
|
||
|
|
if (res) {
|
||
|
|
const data = JSON.parse(res) as AuthData;
|
||
|
|
console.dir(data, { depth: null });
|
||
|
|
return data;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
async set(authData: AuthData): Promise<void> {
|
||
|
|
const res = await this.client.set(
|
||
|
|
this.prepareKey(authData.saleorApiUrl),
|
||
|
|
JSON.stringify(authData),
|
||
|
|
);
|
||
|
|
console.log(
|
||
|
|
`REDIS: SET FOR ${this.prepareKey(authData.saleorApiUrl)}: `,
|
||
|
|
res,
|
||
|
|
);
|
||
|
|
}
|
||
|
|
|
||
|
|
async delete(saleorApiUrl: string): Promise<void> {
|
||
|
|
const val = await this.client.getdel(this.prepareKey(saleorApiUrl));
|
||
|
|
console.log("REDIS: DEL: ", val);
|
||
|
|
}
|
||
|
|
|
||
|
|
async getAll(): Promise<AuthData[]> {
|
||
|
|
throw new Error("redisAPL does not support getAll method");
|
||
|
|
}
|
||
|
|
|
||
|
|
async isReady(): Promise<AplReadyResult> {
|
||
|
|
const ready = !!(await this.client.info());
|
||
|
|
console.log("REDIS: ISREADY: ", ready);
|
||
|
|
return { ready: ready } as AplReadyResult;
|
||
|
|
}
|
||
|
|
|
||
|
|
async isConfigured(): Promise<AplConfiguredResult> {
|
||
|
|
const ready = !!(await this.client.info());
|
||
|
|
console.log("REDIS: ISCONF: ", ready);
|
||
|
|
return { configured: ready } as AplConfiguredResult;
|
||
|
|
}
|
||
|
|
}
|