2021-10-22 15:24:32 +00:00
|
|
|
import { Kind, print, } from "graphql";
|
2021-10-26 19:13:50 +00:00
|
|
|
import "svelte/store";
|
2021-10-22 15:24:32 +00:00
|
|
|
import { formatDocument as addTypenameToDocument } from "./utils/format";
|
2021-10-06 21:41:44 +00:00
|
|
|
// This function accepts a graphql document and returns a string to be used
|
|
|
|
|
// in fetch calls
|
|
|
|
|
export function gqlToString(tag) {
|
|
|
|
|
return tag.loc.source.body;
|
|
|
|
|
}
|
2021-10-22 15:24:32 +00:00
|
|
|
/**
|
|
|
|
|
* Finds the Name value from the OperationDefinition of a Document
|
|
|
|
|
*/
|
|
|
|
|
export const getOperationName = (query) => {
|
|
|
|
|
for (let i = 0, l = query.definitions.length; i < l; i++) {
|
|
|
|
|
const node = query.definitions[i];
|
|
|
|
|
if (node.kind === Kind.OPERATION_DEFINITION && node.name) {
|
|
|
|
|
return node.name.value;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
};
|
|
|
|
|
export const stringifyDocument = (node) => {
|
|
|
|
|
let str = (typeof node !== "string" ? print(node) : node)
|
|
|
|
|
.replace(/([\s,]|#[^\n\r]+)+/g, " ")
|
|
|
|
|
.trim();
|
|
|
|
|
return str;
|
|
|
|
|
};
|
2021-10-06 21:41:44 +00:00
|
|
|
export class GFetch extends Object {
|
|
|
|
|
constructor(options) {
|
|
|
|
|
super();
|
|
|
|
|
const { path } = options;
|
|
|
|
|
this.path = path;
|
|
|
|
|
this.fetch = this.fetch.bind(this);
|
|
|
|
|
}
|
|
|
|
|
// * gFetch
|
|
|
|
|
// This is a fetcher that returns a promise that resolves to a graphql response
|
2021-10-26 19:13:50 +00:00
|
|
|
async fetch({ queries, fetch, } = {}) {
|
2021-10-22 15:24:32 +00:00
|
|
|
let document = addTypenameToDocument(queries[0].query);
|
|
|
|
|
let documentString = stringifyDocument(document);
|
2021-10-06 21:41:44 +00:00
|
|
|
const newQueries = {
|
|
|
|
|
...queries[0],
|
2021-10-22 15:24:32 +00:00
|
|
|
query: documentString,
|
2021-10-06 21:41:44 +00:00
|
|
|
};
|
|
|
|
|
// This is generic fetch, that is polyfilled via svelte kit
|
|
|
|
|
// graph ql fetches must be POST
|
|
|
|
|
// credentials include for user ssr data
|
|
|
|
|
const res = await fetch(this.path, {
|
|
|
|
|
method: "POST",
|
|
|
|
|
credentials: "include",
|
|
|
|
|
headers: { "Content-Type": "application/json" },
|
|
|
|
|
body: JSON.stringify(newQueries),
|
|
|
|
|
});
|
|
|
|
|
// Gets the data back from the server
|
|
|
|
|
const data = await res.json();
|
|
|
|
|
return {
|
|
|
|
|
...data.data,
|
|
|
|
|
};
|
|
|
|
|
}
|
|
|
|
|
}
|
2021-10-26 19:13:50 +00:00
|
|
|
// * ogFetch
|
|
|
|
|
// This function is a fetcher that returns a svelte readable subscription
|
|
|
|
|
// This is to be used for client side fetching of data
|
|
|
|
|
// public oFetch<F>({
|
|
|
|
|
// queries,
|
|
|
|
|
// }: {
|
|
|
|
|
// queries: GFetchQueries[];
|
|
|
|
|
// }): Readable<GFetchReturnWithErrors<F>> {
|
|
|
|
|
// // 1. Build the store and initialize it as empty and error free
|
|
|
|
|
// const initial = new Map();
|
|
|
|
|
// // Creates a store that will be used to subscribe to the data
|
|
|
|
|
// const store = readable(initial, this.makeSubscribe(initial, queries));
|
|
|
|
|
// return store as unknown as Readable<GFetchReturnWithErrors<F>>;
|
|
|
|
|
// }
|
|
|
|
|
// // A dummy function that is used to make subscribe happy.
|
|
|
|
|
// private unsubscribe() {
|
|
|
|
|
// // Nothing to do in this case
|
|
|
|
|
// }
|
|
|
|
|
// // Part of ogFetch
|
|
|
|
|
// // Designed this way to work will with Svelte's readable store
|
|
|
|
|
// private makeSubscribe(data, queries) {
|
|
|
|
|
// // Create a closure with access to the
|
|
|
|
|
// // initial data and initialization arguments
|
|
|
|
|
// return (set) => {
|
|
|
|
|
// // 3. This won't get executed until the store has
|
|
|
|
|
// // its first subscriber. Kick off retrieval.
|
|
|
|
|
// this.fetchDataForSubscription(data, set, queries);
|
|
|
|
|
// // We're not waiting for the response.
|
|
|
|
|
// // Return the unsubscribe function which doesn't do
|
|
|
|
|
// // do anything here (but is part of the stores protocol).
|
|
|
|
|
// return this.unsubscribe;
|
|
|
|
|
// };
|
|
|
|
|
// }
|
|
|
|
|
// // Part of ogFetch
|
|
|
|
|
// // Runs gFetch and updates subscription
|
|
|
|
|
// private async fetchDataForSubscription(data, set, queries: GFetchQueries[]) {
|
|
|
|
|
// try {
|
|
|
|
|
// // Dispatch the request for the users
|
|
|
|
|
// // This code is ONLY run client side, so fetch comes globally from the browser
|
|
|
|
|
// const response = await this.fetch({ queries, fetch });
|
|
|
|
|
// set(response);
|
|
|
|
|
// } catch (error) {
|
|
|
|
|
// // 6b. if there is a fetch error - deal with it
|
|
|
|
|
// // and let observers know
|
|
|
|
|
// data.error = error;
|
|
|
|
|
// set(data);
|
|
|
|
|
// }
|
|
|
|
|
// }
|
|
|
|
|
// }
|
|
|
|
|
// export const data = writable();
|
2021-10-06 21:41:44 +00:00
|
|
|
// ! IDEAS
|
|
|
|
|
// Mutations should take care of updating a generated writeable.
|
|
|
|
|
// $tutorial is auto updated site wide
|
|
|
|
|
//# sourceMappingURL=gFetch.js.map
|